diff --git a/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.37.23 PM.png b/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.37.23 PM.png new file mode 100644 index 000000000..4ed7264bd Binary files /dev/null and b/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.37.23 PM.png differ diff --git a/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.39.01 PM.png b/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.39.01 PM.png new file mode 100644 index 000000000..d0370334b Binary files /dev/null and b/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.39.01 PM.png differ diff --git a/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.39.39 PM.png b/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.39.39 PM.png new file mode 100644 index 000000000..64b539de0 Binary files /dev/null and b/gitbooks/.gitbook/assets/Screenshot 2026-05-08 at 9.39.39 PM.png differ diff --git a/gitbooks/.gitbook/assets/image.png b/gitbooks/.gitbook/assets/image.png index 9de536ebb..eae14dd59 100644 Binary files a/gitbooks/.gitbook/assets/image.png and b/gitbooks/.gitbook/assets/image.png differ diff --git a/gitbooks/.gitbook/assets/memory-tree-pipeline (1).excalidraw b/gitbooks/.gitbook/assets/memory-tree-pipeline (1).excalidraw new file mode 100644 index 000000000..29ee1a1ce --- /dev/null +++ b/gitbooks/.gitbook/assets/memory-tree-pipeline (1).excalidraw @@ -0,0 +1,1353 @@ +{ + "type": "excalidraw", + "version": 2, + "source": "openhuman-memory-tree-async-pipeline", + "elements": [ + { + "id": "title", + "type": "text", + "x": 355, + "y": 20, + "width": 740, + "height": 40, + "text": "OpenHuman Memory Tree Async Pipeline", + "fontSize": 30, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 32, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 1, + "version": 1, + "versionNonce": 1, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "subtitle", + "type": "text", + "x": 235, + "y": 64, + "width": 980, + "height": 24, + "text": "Leaf ingestion -> jobs queue -> workers -> source/topic/global tree building", + "fontSize": 18, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 18, + "strokeColor": "#495057", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 2, + "version": 1, + "versionNonce": 2, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane1", + "type": "rectangle", + "x": 40, + "y": 120, + "width": 310, + "height": 340, + "strokeColor": "#1971c2", + "backgroundColor": "#e7f5ff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 3, + "version": 1, + "versionNonce": 3, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane2", + "type": "rectangle", + "x": 390, + "y": 120, + "width": 340, + "height": 340, + "strokeColor": "#2b8a3e", + "backgroundColor": "#ebfbee", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 4, + "version": 1, + "versionNonce": 4, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane3", + "type": "rectangle", + "x": 770, + "y": 120, + "width": 390, + "height": 340, + "strokeColor": "#e67700", + "backgroundColor": "#fff4e6", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 5, + "version": 1, + "versionNonce": 5, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane4", + "type": "rectangle", + "x": 1200, + "y": 120, + "width": 440, + "height": 340, + "strokeColor": "#9c36b5", + "backgroundColor": "#f8f0fc", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 6, + "version": 1, + "versionNonce": 6, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane5", + "type": "rectangle", + "x": 40, + "y": 500, + "width": 760, + "height": 220, + "strokeColor": "#0b7285", + "backgroundColor": "#e3fafc", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 7, + "version": 1, + "versionNonce": 7, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane6", + "type": "rectangle", + "x": 840, + "y": 500, + "width": 800, + "height": 220, + "strokeColor": "#495057", + "backgroundColor": "#f1f3f5", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 8, + "version": 1, + "versionNonce": 8, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h1", + "type": "text", + "x": 135, + "y": 135, + "width": 120, + "height": 28, + "text": "1. Ingest", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#1971c2", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 9, + "version": 1, + "versionNonce": 9, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h2", + "type": "text", + "x": 505, + "y": 135, + "width": 110, + "height": 28, + "text": "2. Queue", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#2b8a3e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 10, + "version": 1, + "versionNonce": 10, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h3", + "type": "text", + "x": 890, + "y": 135, + "width": 150, + "height": 28, + "text": "3. Workers", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#e67700", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 11, + "version": 1, + "versionNonce": 11, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h4", + "type": "text", + "x": 1320, + "y": 135, + "width": 200, + "height": 28, + "text": "4. Tree State", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#9c36b5", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 12, + "version": 1, + "versionNonce": 12, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h5", + "type": "text", + "x": 275, + "y": 515, + "width": 290, + "height": 28, + "text": "5. Scheduler / Background", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#0b7285", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 13, + "version": 1, + "versionNonce": 13, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h6", + "type": "text", + "x": 1100, + "y": 515, + "width": 280, + "height": 28, + "text": "6. Leaf Lifecycle", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#343a40", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 14, + "version": 1, + "versionNonce": 14, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b1", + "type": "rectangle", + "x": 75, + "y": 185, + "width": 240, + "height": 240, + "strokeColor": "#1971c2", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 15, + "version": 1, + "versionNonce": 15, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t1", + "type": "text", + "x": 93, + "y": 205, + "width": 204, + "height": 198, + "text": "JSON-RPC / source ingestion\n\nchat | email | document\n\ncanonicalise\n-> chunk_markdown\n-> score_chunks_fast\n-> upsert_chunks_tx\n-> lifecycle_status = pending_extraction\n-> persist fast score rows\n-> enqueue extract_chunk per chunk\n-> wake_workers()", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 194, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 16, + "version": 1, + "versionNonce": 16, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b2", + "type": "rectangle", + "x": 435, + "y": 185, + "width": 250, + "height": 240, + "strokeColor": "#2b8a3e", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 17, + "version": 1, + "versionNonce": 17, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t2", + "type": "text", + "x": 453, + "y": 205, + "width": 214, + "height": 198, + "text": "SQLite: memory_tree/chunks.db\n\nmem_tree_chunks\nmem_tree_score\nmem_tree_entity_index\nmem_tree_jobs\nmem_tree_trees\nmem_tree_buffers\nmem_tree_summaries\n\njobs fields\nkind | payload_json | dedupe_key\nstatus | attempts | available_at_ms\nlocked_until_ms | last_error", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 194, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 18, + "version": 1, + "versionNonce": 18, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b3", + "type": "rectangle", + "x": 815, + "y": 185, + "width": 300, + "height": 135, + "strokeColor": "#e67700", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 19, + "version": 1, + "versionNonce": 19, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t3", + "type": "text", + "x": 833, + "y": 205, + "width": 264, + "height": 108, + "text": "jobs::start(workspace_dir)\n\nrecover_stale_locks()\nspawn 3 worker tasks\nNotify wakeup + 5s polling fallback\nshared Semaphore(3) for LLM-bound work", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 104, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 20, + "version": 1, + "versionNonce": 20, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b4", + "type": "rectangle", + "x": 815, + "y": 335, + "width": 300, + "height": 90, + "strokeColor": "#d9480f", + "backgroundColor": "#fff8f0", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 21, + "version": 1, + "versionNonce": 21, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t4", + "type": "text", + "x": 833, + "y": 355, + "width": 264, + "height": 54, + "text": "Handlers\nextract_chunk | append_buffer | seal\ntopic_route | digest_daily | flush_stale", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 50, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 22, + "version": 1, + "versionNonce": 22, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b5", + "type": "rectangle", + "x": 1240, + "y": 185, + "width": 360, + "height": 240, + "strokeColor": "#9c36b5", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 23, + "version": 1, + "versionNonce": 23, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t5", + "type": "text", + "x": 1258, + "y": 205, + "width": 324, + "height": 198, + "text": "Tree building outputs\n\nsource tree\nL0 buffer -> seal -> L1/L2/... summaries\n\ntopic tree\ncurator hotness gate\noptional append_buffer(topic)\n\nglobal tree\ndigest_daily -> daily node\nappend_daily_and_cascade", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 194, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 24, + "version": 1, + "versionNonce": 24, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b6", + "type": "rectangle", + "x": 85, + "y": 575, + "width": 670, + "height": 105, + "strokeColor": "#0b7285", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 25, + "version": 1, + "versionNonce": 25, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t6", + "type": "text", + "x": 103, + "y": 597, + "width": 634, + "height": 72, + "text": "Scheduler loop\n\nUTC daily tick -> enqueue digest_daily(yesterday) + flush_stale(today)\nflush_stale scans stale buffers and enqueues force seal jobs\nworkers consume these through the same mem_tree_jobs pipeline", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 68, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 26, + "version": 1, + "versionNonce": 26, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s1", + "type": "rectangle", + "x": 875, + "y": 585, + "width": 130, + "height": 70, + "strokeColor": "#495057", + "backgroundColor": "#fff3bf", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 27, + "version": 1, + "versionNonce": 27, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st1", + "type": "text", + "x": 891, + "y": 607, + "width": 98, + "height": 24, + "text": "pending_extraction", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 20, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 28, + "version": 1, + "versionNonce": 28, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s2", + "type": "rectangle", + "x": 1045, + "y": 585, + "width": 110, + "height": 70, + "strokeColor": "#495057", + "backgroundColor": "#d3f9d8", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 29, + "version": 1, + "versionNonce": 29, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st2", + "type": "text", + "x": 1069, + "y": 607, + "width": 62, + "height": 24, + "text": "admitted", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 20, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 30, + "version": 1, + "versionNonce": 30, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s3", + "type": "rectangle", + "x": 1195, + "y": 585, + "width": 110, + "height": 70, + "strokeColor": "#495057", + "backgroundColor": "#d0ebff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 31, + "version": 1, + "versionNonce": 31, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st3", + "type": "text", + "x": 1223, + "y": 607, + "width": 54, + "height": 24, + "text": "buffered", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 20, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 32, + "version": 1, + "versionNonce": 32, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s4", + "type": "rectangle", + "x": 1345, + "y": 585, + "width": 110, + "height": 70, + "strokeColor": "#495057", + "backgroundColor": "#e5dbff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 33, + "version": 1, + "versionNonce": 33, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st4", + "type": "text", + "x": 1375, + "y": 607, + "width": 50, + "height": 24, + "text": "sealed", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 20, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 34, + "version": 1, + "versionNonce": 34, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s5", + "type": "rectangle", + "x": 1045, + "y": 665, + "width": 110, + "height": 36, + "strokeColor": "#c92a2a", + "backgroundColor": "#ffe3e3", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 35, + "version": 1, + "versionNonce": 35, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st5", + "type": "text", + "x": 1074, + "y": 672, + "width": 52, + "height": 20, + "text": "dropped", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 16, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 36, + "version": 1, + "versionNonce": 36, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "life-note", + "type": "text", + "x": 1185, + "y": 665, + "width": 390, + "height": 36, + "text": "extract_chunk decides admitted vs dropped. append_buffer moves admitted leaves into buffers. seal creates summaries and parent links.", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 32, + "strokeColor": "#495057", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 37, + "version": 1, + "versionNonce": 37, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "a1", + "type": "arrow", + "x": 315, + "y": 305, + "width": 115, + "height": 0, + "points": [[0, 0], [115, 0]], + "strokeColor": "#2f9e44", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 38, + "version": 1, + "versionNonce": 38, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [115, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a2", + "type": "arrow", + "x": 685, + "y": 305, + "width": 125, + "height": 0, + "points": [[0, 0], [125, 0]], + "strokeColor": "#e67700", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 39, + "version": 1, + "versionNonce": 39, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [125, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a3", + "type": "arrow", + "x": 1115, + "y": 305, + "width": 125, + "height": 0, + "points": [[0, 0], [125, 0]], + "strokeColor": "#9c36b5", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 40, + "version": 1, + "versionNonce": 40, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [125, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a4", + "type": "arrow", + "x": 430, + "y": 575, + "width": 70, + "height": 120, + "points": [[0, 0], [70, -120]], + "strokeColor": "#0b7285", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 41, + "version": 1, + "versionNonce": 41, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [70, -120], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a5", + "type": "arrow", + "x": 1005, + "y": 620, + "width": 40, + "height": 0, + "points": [[0, 0], [40, 0]], + "strokeColor": "#2b8a3e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 42, + "version": 1, + "versionNonce": 42, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [40, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a6", + "type": "arrow", + "x": 1155, + "y": 620, + "width": 40, + "height": 0, + "points": [[0, 0], [40, 0]], + "strokeColor": "#1971c2", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 43, + "version": 1, + "versionNonce": 43, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [40, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a7", + "type": "arrow", + "x": 1305, + "y": 620, + "width": 40, + "height": 0, + "points": [[0, 0], [40, 0]], + "strokeColor": "#9c36b5", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 44, + "version": 1, + "versionNonce": 44, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [40, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a8", + "type": "arrow", + "x": 1100, + "y": 655, + "width": 0, + "height": 10, + "points": [[0, 0], [0, 10]], + "strokeColor": "#c92a2a", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 45, + "version": 1, + "versionNonce": 45, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [0, 10], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "foot", + "type": "text", + "x": 40, + "y": 750, + "width": 1540, + "height": 60, + "text": "Job kinds in play: extract_chunk -> append_buffer(source) -> optional seal -> topic_route -> optional append_buffer(topic). Independent background flow: scheduler -> digest_daily / flush_stale -> seal. All paths go through mem_tree_jobs, so retries, dedupe, stale lock recovery, and worker wakeups stay centralized.", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 56, + "strokeColor": "#343a40", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 46, + "version": 1, + "versionNonce": 46, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + } + ], + "appState": { + "gridSize": null, + "viewBackgroundColor": "#ffffff" + }, + "files": {} +} diff --git a/gitbooks/.gitbook/assets/memory-tree-pipeline.excalidraw b/gitbooks/.gitbook/assets/memory-tree-pipeline.excalidraw new file mode 100644 index 000000000..29ee1a1ce --- /dev/null +++ b/gitbooks/.gitbook/assets/memory-tree-pipeline.excalidraw @@ -0,0 +1,1353 @@ +{ + "type": "excalidraw", + "version": 2, + "source": "openhuman-memory-tree-async-pipeline", + "elements": [ + { + "id": "title", + "type": "text", + "x": 355, + "y": 20, + "width": 740, + "height": 40, + "text": "OpenHuman Memory Tree Async Pipeline", + "fontSize": 30, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 32, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 1, + "version": 1, + "versionNonce": 1, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "subtitle", + "type": "text", + "x": 235, + "y": 64, + "width": 980, + "height": 24, + "text": "Leaf ingestion -> jobs queue -> workers -> source/topic/global tree building", + "fontSize": 18, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 18, + "strokeColor": "#495057", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 2, + "version": 1, + "versionNonce": 2, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane1", + "type": "rectangle", + "x": 40, + "y": 120, + "width": 310, + "height": 340, + "strokeColor": "#1971c2", + "backgroundColor": "#e7f5ff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 3, + "version": 1, + "versionNonce": 3, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane2", + "type": "rectangle", + "x": 390, + "y": 120, + "width": 340, + "height": 340, + "strokeColor": "#2b8a3e", + "backgroundColor": "#ebfbee", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 4, + "version": 1, + "versionNonce": 4, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane3", + "type": "rectangle", + "x": 770, + "y": 120, + "width": 390, + "height": 340, + "strokeColor": "#e67700", + "backgroundColor": "#fff4e6", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 5, + "version": 1, + "versionNonce": 5, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane4", + "type": "rectangle", + "x": 1200, + "y": 120, + "width": 440, + "height": 340, + "strokeColor": "#9c36b5", + "backgroundColor": "#f8f0fc", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 6, + "version": 1, + "versionNonce": 6, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane5", + "type": "rectangle", + "x": 40, + "y": 500, + "width": 760, + "height": 220, + "strokeColor": "#0b7285", + "backgroundColor": "#e3fafc", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 7, + "version": 1, + "versionNonce": 7, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "lane6", + "type": "rectangle", + "x": 840, + "y": 500, + "width": 800, + "height": 220, + "strokeColor": "#495057", + "backgroundColor": "#f1f3f5", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 8, + "version": 1, + "versionNonce": 8, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h1", + "type": "text", + "x": 135, + "y": 135, + "width": 120, + "height": 28, + "text": "1. Ingest", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#1971c2", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 9, + "version": 1, + "versionNonce": 9, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h2", + "type": "text", + "x": 505, + "y": 135, + "width": 110, + "height": 28, + "text": "2. Queue", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#2b8a3e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 10, + "version": 1, + "versionNonce": 10, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h3", + "type": "text", + "x": 890, + "y": 135, + "width": 150, + "height": 28, + "text": "3. Workers", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#e67700", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 11, + "version": 1, + "versionNonce": 11, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h4", + "type": "text", + "x": 1320, + "y": 135, + "width": 200, + "height": 28, + "text": "4. Tree State", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#9c36b5", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 12, + "version": 1, + "versionNonce": 12, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h5", + "type": "text", + "x": 275, + "y": 515, + "width": 290, + "height": 28, + "text": "5. Scheduler / Background", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#0b7285", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 13, + "version": 1, + "versionNonce": 13, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "h6", + "type": "text", + "x": 1100, + "y": 515, + "width": 280, + "height": 28, + "text": "6. Leaf Lifecycle", + "fontSize": 24, + "fontFamily": 1, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 24, + "strokeColor": "#343a40", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 14, + "version": 1, + "versionNonce": 14, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b1", + "type": "rectangle", + "x": 75, + "y": 185, + "width": 240, + "height": 240, + "strokeColor": "#1971c2", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 15, + "version": 1, + "versionNonce": 15, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t1", + "type": "text", + "x": 93, + "y": 205, + "width": 204, + "height": 198, + "text": "JSON-RPC / source ingestion\n\nchat | email | document\n\ncanonicalise\n-> chunk_markdown\n-> score_chunks_fast\n-> upsert_chunks_tx\n-> lifecycle_status = pending_extraction\n-> persist fast score rows\n-> enqueue extract_chunk per chunk\n-> wake_workers()", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 194, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 16, + "version": 1, + "versionNonce": 16, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b2", + "type": "rectangle", + "x": 435, + "y": 185, + "width": 250, + "height": 240, + "strokeColor": "#2b8a3e", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 17, + "version": 1, + "versionNonce": 17, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t2", + "type": "text", + "x": 453, + "y": 205, + "width": 214, + "height": 198, + "text": "SQLite: memory_tree/chunks.db\n\nmem_tree_chunks\nmem_tree_score\nmem_tree_entity_index\nmem_tree_jobs\nmem_tree_trees\nmem_tree_buffers\nmem_tree_summaries\n\njobs fields\nkind | payload_json | dedupe_key\nstatus | attempts | available_at_ms\nlocked_until_ms | last_error", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 194, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 18, + "version": 1, + "versionNonce": 18, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b3", + "type": "rectangle", + "x": 815, + "y": 185, + "width": 300, + "height": 135, + "strokeColor": "#e67700", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 19, + "version": 1, + "versionNonce": 19, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t3", + "type": "text", + "x": 833, + "y": 205, + "width": 264, + "height": 108, + "text": "jobs::start(workspace_dir)\n\nrecover_stale_locks()\nspawn 3 worker tasks\nNotify wakeup + 5s polling fallback\nshared Semaphore(3) for LLM-bound work", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 104, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 20, + "version": 1, + "versionNonce": 20, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b4", + "type": "rectangle", + "x": 815, + "y": 335, + "width": 300, + "height": 90, + "strokeColor": "#d9480f", + "backgroundColor": "#fff8f0", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 21, + "version": 1, + "versionNonce": 21, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t4", + "type": "text", + "x": 833, + "y": 355, + "width": 264, + "height": 54, + "text": "Handlers\nextract_chunk | append_buffer | seal\ntopic_route | digest_daily | flush_stale", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 50, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 22, + "version": 1, + "versionNonce": 22, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b5", + "type": "rectangle", + "x": 1240, + "y": 185, + "width": 360, + "height": 240, + "strokeColor": "#9c36b5", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 23, + "version": 1, + "versionNonce": 23, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t5", + "type": "text", + "x": 1258, + "y": 205, + "width": 324, + "height": 198, + "text": "Tree building outputs\n\nsource tree\nL0 buffer -> seal -> L1/L2/... summaries\n\ntopic tree\ncurator hotness gate\noptional append_buffer(topic)\n\nglobal tree\ndigest_daily -> daily node\nappend_daily_and_cascade", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 194, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 24, + "version": 1, + "versionNonce": 24, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "b6", + "type": "rectangle", + "x": 85, + "y": 575, + "width": 670, + "height": 105, + "strokeColor": "#0b7285", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 25, + "version": 1, + "versionNonce": 25, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "t6", + "type": "text", + "x": 103, + "y": 597, + "width": 634, + "height": 72, + "text": "Scheduler loop\n\nUTC daily tick -> enqueue digest_daily(yesterday) + flush_stale(today)\nflush_stale scans stale buffers and enqueues force seal jobs\nworkers consume these through the same mem_tree_jobs pipeline", + "fontSize": 18, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 68, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 26, + "version": 1, + "versionNonce": 26, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s1", + "type": "rectangle", + "x": 875, + "y": 585, + "width": 130, + "height": 70, + "strokeColor": "#495057", + "backgroundColor": "#fff3bf", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 27, + "version": 1, + "versionNonce": 27, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st1", + "type": "text", + "x": 891, + "y": 607, + "width": 98, + "height": 24, + "text": "pending_extraction", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 20, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 28, + "version": 1, + "versionNonce": 28, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s2", + "type": "rectangle", + "x": 1045, + "y": 585, + "width": 110, + "height": 70, + "strokeColor": "#495057", + "backgroundColor": "#d3f9d8", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 29, + "version": 1, + "versionNonce": 29, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st2", + "type": "text", + "x": 1069, + "y": 607, + "width": 62, + "height": 24, + "text": "admitted", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 20, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 30, + "version": 1, + "versionNonce": 30, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s3", + "type": "rectangle", + "x": 1195, + "y": 585, + "width": 110, + "height": 70, + "strokeColor": "#495057", + "backgroundColor": "#d0ebff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 31, + "version": 1, + "versionNonce": 31, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st3", + "type": "text", + "x": 1223, + "y": 607, + "width": 54, + "height": 24, + "text": "buffered", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 20, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 32, + "version": 1, + "versionNonce": 32, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s4", + "type": "rectangle", + "x": 1345, + "y": 585, + "width": 110, + "height": 70, + "strokeColor": "#495057", + "backgroundColor": "#e5dbff", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 33, + "version": 1, + "versionNonce": 33, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st4", + "type": "text", + "x": 1375, + "y": 607, + "width": 50, + "height": 24, + "text": "sealed", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 20, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 34, + "version": 1, + "versionNonce": 34, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "s5", + "type": "rectangle", + "x": 1045, + "y": 665, + "width": 110, + "height": 36, + "strokeColor": "#c92a2a", + "backgroundColor": "#ffe3e3", + "fillStyle": "solid", + "strokeWidth": 2, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "roundness": { "type": 3 }, + "seed": 35, + "version": 1, + "versionNonce": 35, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "st5", + "type": "text", + "x": 1074, + "y": 672, + "width": 52, + "height": 20, + "text": "dropped", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "center", + "verticalAlign": "top", + "baseline": 16, + "strokeColor": "#1e1e1e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 36, + "version": 1, + "versionNonce": 36, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "life-note", + "type": "text", + "x": 1185, + "y": 665, + "width": 390, + "height": 36, + "text": "extract_chunk decides admitted vs dropped. append_buffer moves admitted leaves into buffers. seal creates summaries and parent links.", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 32, + "strokeColor": "#495057", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 37, + "version": 1, + "versionNonce": 37, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + }, + { + "id": "a1", + "type": "arrow", + "x": 315, + "y": 305, + "width": 115, + "height": 0, + "points": [[0, 0], [115, 0]], + "strokeColor": "#2f9e44", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 38, + "version": 1, + "versionNonce": 38, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [115, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a2", + "type": "arrow", + "x": 685, + "y": 305, + "width": 125, + "height": 0, + "points": [[0, 0], [125, 0]], + "strokeColor": "#e67700", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 39, + "version": 1, + "versionNonce": 39, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [125, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a3", + "type": "arrow", + "x": 1115, + "y": 305, + "width": 125, + "height": 0, + "points": [[0, 0], [125, 0]], + "strokeColor": "#9c36b5", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 40, + "version": 1, + "versionNonce": 40, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [125, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a4", + "type": "arrow", + "x": 430, + "y": 575, + "width": 70, + "height": 120, + "points": [[0, 0], [70, -120]], + "strokeColor": "#0b7285", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 41, + "version": 1, + "versionNonce": 41, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [70, -120], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a5", + "type": "arrow", + "x": 1005, + "y": 620, + "width": 40, + "height": 0, + "points": [[0, 0], [40, 0]], + "strokeColor": "#2b8a3e", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 42, + "version": 1, + "versionNonce": 42, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [40, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a6", + "type": "arrow", + "x": 1155, + "y": 620, + "width": 40, + "height": 0, + "points": [[0, 0], [40, 0]], + "strokeColor": "#1971c2", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 43, + "version": 1, + "versionNonce": 43, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [40, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a7", + "type": "arrow", + "x": 1305, + "y": 620, + "width": 40, + "height": 0, + "points": [[0, 0], [40, 0]], + "strokeColor": "#9c36b5", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 44, + "version": 1, + "versionNonce": 44, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [40, 0], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "a8", + "type": "arrow", + "x": 1100, + "y": 655, + "width": 0, + "height": 10, + "points": [[0, 0], [0, 10]], + "strokeColor": "#c92a2a", + "backgroundColor": "transparent", + "fillStyle": "solid", + "strokeWidth": 3, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 45, + "version": 1, + "versionNonce": 45, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false, + "lastCommittedPoint": [0, 10], + "startBinding": null, + "endBinding": null, + "startArrowhead": null, + "endArrowhead": "arrow" + }, + { + "id": "foot", + "type": "text", + "x": 40, + "y": 750, + "width": 1540, + "height": 60, + "text": "Job kinds in play: extract_chunk -> append_buffer(source) -> optional seal -> topic_route -> optional append_buffer(topic). Independent background flow: scheduler -> digest_daily / flush_stale -> seal. All paths go through mem_tree_jobs, so retries, dedupe, stale lock recovery, and worker wakeups stay centralized.", + "fontSize": 16, + "fontFamily": 3, + "textAlign": "left", + "verticalAlign": "top", + "baseline": 56, + "strokeColor": "#343a40", + "backgroundColor": "#ffffff", + "fillStyle": "solid", + "strokeWidth": 1, + "strokeStyle": "solid", + "roughness": 0, + "opacity": 100, + "angle": 0, + "seed": 46, + "version": 1, + "versionNonce": 46, + "isDeleted": false, + "groupIds": [], + "boundElements": null, + "updated": 1, + "link": null, + "locked": false + } + ], + "appState": { + "gridSize": null, + "viewBackgroundColor": "#ffffff" + }, + "files": {} +} diff --git a/gitbooks/README.md b/gitbooks/README.md index 22d5d0000..0e8dabe79 100644 --- a/gitbooks/README.md +++ b/gitbooks/README.md @@ -1,27 +1,29 @@ --- description: >- - OpenHuman is a personal AI assistant that runs on your desktop, connects to - 118+ services, and builds a local-first memory of your life from them. + OpenHuman is a personal AI assistant that runs on your desktop, connects to + 118+ services, and builds a local-first memory of your life from them. icon: diamond --- # Welcome to OpenHuman -OpenHuman is an open-source AI assistant designed to be the **memory** and **doer** for everything you do across your tools. Built on Rust + Tauri and licensed under GNU GPL3, it closes the gap between what AI models can do and what they actually know about *you*. +
+ +OpenHuman is an open-source AI assistant designed to be the **memory** and **doer** for everything you do across your tools. Built on Rust + Tauri and licensed under GNU GPL3, it closes the gap between what AI models can do and what they actually know about _you_. Every model in the world — all 200+ of them — shares the same fundamental limitation: they are stateless. You type a prompt, get a response, and the context evaporates. Even the ones with "memory" store a few bullet points. A few bullet points is a sticky note, not intelligence. OpenHuman solves this with a stack that's calmly, deliberately different: -**A local-first [Memory Tree](features/memory-tree.md).** Every source you connect — Gmail, Slack, GitHub, Notion, your own notes — flows through a deterministic pipeline: canonical Markdown, ≤3k-token chunks, scored, folded into per-source / per-topic / per-day summary trees. Stored in SQLite on your machine. No vector-soup black box. +**A local-first** [**Memory Tree**](features/memory-tree.md)**.** Every source you connect — Gmail, Slack, GitHub, Notion, your own notes — flows through a deterministic pipeline: canonical Markdown, ≤3k-token chunks, scored, folded into per-source / per-topic / per-day summary trees. Stored in SQLite on your machine. No vector-soup black box. -**An [Obsidian-style wiki](features/obsidian-wiki.md) on top of it.** The same chunks the agent reasons over land as `.md` files in a vault you can open in [Obsidian](https://obsidian.md), browse, edit, and link by hand. Inspired by [Karpathy's obsidian-wiki workflow](https://x.com/karpathy/status/2039805659525644595). You can't trust a memory you can't read. +**An** [**Obsidian-style wiki**](features/obsidian-wiki.md) **on top of it.** The same chunks the agent reasons over land as `.md` files in a vault you can open in [Obsidian](https://obsidian.md), browse, edit, and link by hand. Inspired by [Karpathy's obsidian-wiki workflow](https://x.com/karpathy/status/2039805659525644595). You can't trust a memory you can't read. -**[118+ third-party integrations](features/integrations.md), with [auto-fetch](features/auto-fetch.md).** One-click OAuth into Gmail, GitHub, Slack, Notion, Stripe, Calendar, Drive, Linear, Jira and more. Every five minutes, OpenHuman pulls fresh data from every active connection and folds it into the Memory Tree without you asking. +[**118+ third-party integrations**](features/integrations.md)**, with** [**auto-fetch**](features/auto-fetch.md)**.** One-click OAuth into Gmail, GitHub, Slack, Notion, Stripe, Calendar, Drive, Linear, Jira and more. Every five minutes, OpenHuman pulls fresh data from every active connection and folds it into the Memory Tree without you asking. **An agent built for big data.** [Smart token compression (TokenJuice)](features/token-compression.md) compacts verbose tool output before it ever enters the model's context, so sweeping through your last six months of email costs single-digit dollars. [Automatic model routing](features/model-routing.md) sends each task to the right model — `hint:reasoning` to a frontier model, `hint:fast` to a cheap one, vision to vision — all under one subscription. Built-in [native tools](features/native-tools.md) cover web search, scraping, and a full filesystem/git/lint/test/grep coder loop. -**[Native voice (ElevenLabs)](features/voice.md).** STT in, ElevenLabs TTS out, mascot lip-sync, and a live Google Meet agent that joins meetings, transcribes them into your Memory Tree, and can speak back into the call. +[**Native voice (ElevenLabs)**](features/voice.md)**.** STT in, ElevenLabs TTS out, mascot lip-sync, and a live Google Meet agent that joins meetings, transcribes them into your Memory Tree, and can speak back into the call. Together, these turn OpenHuman into something fundamentally different from a chatbot. It is an AI agent that consumes large amounts of personal data at low cost, maintains a persistent and evolving understanding of your world, and takes proactive actions on your behalf. @@ -33,17 +35,12 @@ OpenHuman is not AGI. But it is a meaningful architectural step closer, with bet OpenHuman connects to your tools, pulls from them continuously, and turns the firehose into something structured any AI can act on. -It **fetches automatically** from every active integration every five minutes, so the agent already has tomorrow's context this morning. - -It **compresses** millions of tokens of organizational noise into a deterministic Memory Tree of chunks, scores, entities, and summaries. - -It **surfaces signals** that matter: decisions, action items, risks, sentiment shifts, and buried context you would otherwise miss. - -It **routes intelligently**, picking the right model for each task and compacting tool output through TokenJuice so cost stays minimal even at scale. - -It **speaks**, listens, and joins meetings — voice is a first-class surface, not an afterthought. - -It **preserves privacy** by design. The Memory Tree's SQLite database and your Obsidian vault stay on your machine. Integration tokens are held by the OpenHuman backend, not on disk in plaintext on your laptop. +* It **fetches automatically** from every active integration every five minutes, so the agent already has tomorrow's context this morning. +* It **compresses** millions of tokens of organizational noise into a deterministic Memory Tree of chunks, scores, entities, and summaries. +* It **surfaces signals** that matter: decisions, action items, risks, sentiment shifts, and buried context you would otherwise miss. +* It **routes intelligently**, picking the right model for each task and compacting tool output through TokenJuice so cost stays minimal even at scale. +* It **speaks**, listens, and joins meetings — voice is a first-class surface, not an afterthought. +* It **preserves privacy** by design. The Memory Tree's SQLite database and your Obsidian vault stay on your machine. Integration tokens are held by the OpenHuman backend, not on disk in plaintext on your laptop. ## Who it's for diff --git a/gitbooks/SUMMARY.md b/gitbooks/SUMMARY.md index 042a6c1ec..b580cf32b 100644 --- a/gitbooks/SUMMARY.md +++ b/gitbooks/SUMMARY.md @@ -73,7 +73,7 @@ * [Memory Context Window](developing/memory-context-window.md) * [Memory Tree Pipeline](developing/memory-tree-pipeline.md) -### Frontend (app/src/) +## Frontend (app/src/) * [Overview](developing/frontend/README.md) * [Architecture](developing/frontend/architecture.md) @@ -85,7 +85,7 @@ * [Providers](developing/frontend/providers.md) * [Hooks & Utilities](developing/frontend/hooks-utils.md) -### Tauri shell (app/src-tauri/) +## Tauri shell (app/src-tauri/) * [Overview](developing/tauri-shell/README.md) * [Architecture](developing/tauri-shell/architecture.md) diff --git a/gitbooks/developing/memory-tree-pipeline.md b/gitbooks/developing/memory-tree-pipeline.md index c68583781..ea041470f 100644 --- a/gitbooks/developing/memory-tree-pipeline.md +++ b/gitbooks/developing/memory-tree-pipeline.md @@ -5,13 +5,13 @@ description: >- icon: diagram-project --- -# Memory Tree Async Pipeline +# Memory Tree Pipeline The user-facing pitch of the [Memory Tree](../features/memory-tree.md) is simple: connect a source, the agent gets persistent memory of it. The pipeline that delivers on that pitch is **not** simple — it spans an HTTP-triggered ingest path, a job queue inside SQLite, a pool of background workers, three independent summary trees, and a daily UTC scheduler. This page walks through the whole thing. The diagram below is the source of truth. Every box maps to code under `src/openhuman/memory/tree/`. -{% file src="memory-tree-pipeline.excalidraw" %} +{% file src="../.gitbook/assets/memory-tree-pipeline (1).excalidraw" %} Memory Tree Async Pipeline — leaf ingestion → jobs queue → workers → source / topic / global tree building. {% endfile %} @@ -36,9 +36,9 @@ canonicalize Hot-path requirements: -- **Deterministic.** The `chunk_id` is a hash of `(source_kind, source_id, position, body_hash)`. Re-running ingest on identical input never produces duplicates. -- **Fast.** No LLM calls in this lane. `score_chunks_fast` uses cheap heuristics; deeper scoring runs out of the worker pool. -- **Bounded write.** Everything happens inside one SQLite transaction so a partial ingest can't leave dangling rows. +* **Deterministic.** The `chunk_id` is a hash of `(source_kind, source_id, position, body_hash)`. Re-running ingest on identical input never produces duplicates. +* **Fast.** No LLM calls in this lane. `score_chunks_fast` uses cheap heuristics; deeper scoring runs out of the worker pool. +* **Bounded write.** Everything happens inside one SQLite transaction so a partial ingest can't leave dangling rows. Code: `src/openhuman/memory/tree/ingest.rs`, `chunker.rs`, `score/fast.rs`. @@ -46,26 +46,26 @@ Code: `src/openhuman/memory/tree/ingest.rs`, `chunker.rs`, `score/fast.rs`. Storage: SQLite at `/memory_tree/chunks.db`. Tables: -| Table | What's there | -| --- | --- | -| `mem_tree_chunks` | The chunks themselves — body hash, provenance, lifecycle status. | -| `mem_tree_score` | Per-chunk score rows (fast + deep). | -| `mem_tree_entity_index` | Entity → chunk lookup for topic-tree hotness. | -| `mem_tree_jobs` | The job queue (see below). | -| `mem_tree_trees` | Per-scope tree metadata (source / topic / global). | -| `mem_tree_buffers` | L0 buffers (unsealed leaves) per tree. | -| `mem_tree_summaries` | Sealed summaries (L1/L2/...) per tree. | +| Table | What's there | +| ----------------------- | ---------------------------------------------------------------- | +| `mem_tree_chunks` | The chunks themselves — body hash, provenance, lifecycle status. | +| `mem_tree_score` | Per-chunk score rows (fast + deep). | +| `mem_tree_entity_index` | Entity → chunk lookup for topic-tree hotness. | +| `mem_tree_jobs` | The job queue (see below). | +| `mem_tree_trees` | Per-scope tree metadata (source / topic / global). | +| `mem_tree_buffers` | L0 buffers (unsealed leaves) per tree. | +| `mem_tree_summaries` | Sealed summaries (L1/L2/...) per tree. | `mem_tree_jobs` columns that matter: -| Column | Purpose | -| --- | --- | -| `kind` | One of `extract_chunk`, `append_buffer`, `seal`, `topic_route`, `digest_daily`, `flush_stale`. | -| `payload_json` | Job-specific args. | -| `dedupe_key` | Coalesces duplicate enqueues — re-running an idempotent job costs one row, not N. | -| `status` | `pending` / `running` / `done` / `failed`. | -| `attempts` / `last_error` | Retry bookkeeping. | -| `available_at_ms` / `locked_until_ms` | Scheduling and worker leasing. | +| Column | Purpose | +| ------------------------------------- | ---------------------------------------------------------------------------------------------- | +| `kind` | One of `extract_chunk`, `append_buffer`, `seal`, `topic_route`, `digest_daily`, `flush_stale`. | +| `payload_json` | Job-specific args. | +| `dedupe_key` | Coalesces duplicate enqueues — re-running an idempotent job costs one row, not N. | +| `status` | `pending` / `running` / `done` / `failed`. | +| `attempts` / `last_error` | Retry bookkeeping. | +| `available_at_ms` / `locked_until_ms` | Scheduling and worker leasing. | Code: `src/openhuman/memory/tree/store.rs`, `jobs/queue.rs`. @@ -73,21 +73,21 @@ Code: `src/openhuman/memory/tree/store.rs`, `jobs/queue.rs`. Bootstrap: `jobs::start(workspace_dir)` is called once at process startup. It: -- Calls `recover_stale_locks()` — any job whose `locked_until_ms` is in the past becomes `pending` again. Crashes don't strand work. -- Spawns **3 worker tasks** (configurable, but 3 is the default and what production runs). -- Wires a `tokio::sync::Notify` so the ingest path can wake workers immediately, with a **5-second polling fallback** so a missed notify doesn't strand work. -- Holds a shared `Semaphore(3)` for LLM-bound steps so concurrent embedding / summarization calls can't blow past the configured budget. +* Calls `recover_stale_locks()` — any job whose `locked_until_ms` is in the past becomes `pending` again. Crashes don't strand work. +* Spawns **3 worker tasks** (configurable, but 3 is the default and what production runs). +* Wires a `tokio::sync::Notify` so the ingest path can wake workers immediately, with a **5-second polling fallback** so a missed notify doesn't strand work. +* Holds a shared `Semaphore(3)` for LLM-bound steps so concurrent embedding / summarization calls can't blow past the configured budget. Each worker pulls a job, runs the right handler, and updates the row. Handlers: -| Handler | Job kind | What it does | -| --- | --- | --- | -| `extract_chunk` | `extract_chunk` | Deep score + entity extraction. Decides `admitted` vs `dropped` based on the score. | -| `append_buffer` | `append_buffer` | Adds an admitted leaf to the source (or topic) tree's L0 buffer. May trigger a seal. | -| `seal` | `seal` | Compresses L0 buffer into an L1 summary; cascades up through L2/L3/... if the parent buffer is now full. | -| `topic_route` | `topic_route` | Routes a leaf into per-entity topic trees, gated by the curator hotness check. | -| `digest_daily` | `digest_daily` | Builds the global daily digest node. | -| `flush_stale` | `flush_stale` | Force-seals buffers that have been sitting too long. | +| Handler | Job kind | What it does | +| --------------- | --------------- | -------------------------------------------------------------------------------------------------------- | +| `extract_chunk` | `extract_chunk` | Deep score + entity extraction. Decides `admitted` vs `dropped` based on the score. | +| `append_buffer` | `append_buffer` | Adds an admitted leaf to the source (or topic) tree's L0 buffer. May trigger a seal. | +| `seal` | `seal` | Compresses L0 buffer into an L1 summary; cascades up through L2/L3/... if the parent buffer is now full. | +| `topic_route` | `topic_route` | Routes a leaf into per-entity topic trees, gated by the curator hotness check. | +| `digest_daily` | `digest_daily` | Builds the global daily digest node. | +| `flush_stale` | `flush_stale` | Force-seals buffers that have been sitting too long. | Code: `src/openhuman/memory/tree/jobs/{worker.rs, handlers/}`. @@ -107,8 +107,8 @@ Code: `src/openhuman/memory/tree/{tree_source, tree_topic, tree_global}/`. A separate scheduler loop runs independently of the ingest path: -- **UTC daily tick.** At 00:00 UTC each day, enqueue `digest_daily(yesterday)` and `flush_stale(today)`. Both go through the same `mem_tree_jobs` pipeline workers consume. -- **`flush_stale`** scans every tree's buffers for ones older than the configured TTL and enqueues force-seal jobs. +* **UTC daily tick.** At 00:00 UTC each day, enqueue `digest_daily(yesterday)` and `flush_stale(today)`. Both go through the same `mem_tree_jobs` pipeline workers consume. +* **`flush_stale`** scans every tree's buffers for ones older than the configured TTL and enqueues force-seal jobs. The scheduler **does not** run summarizers itself. Everything goes through the queue, so retries, dedupe, and stale-lock recovery all stay centralized. @@ -124,10 +124,10 @@ pending_extraction ──► admitted ──► buffered ──► sealed ──► dropped ``` -- `extract_chunk` decides `admitted` vs `dropped` based on the deep score. -- `append_buffer` moves admitted leaves into a buffer — `buffered`. -- `seal` writes the buffer's contents into a summary and marks each leaf `sealed`. -- `dropped` leaves stop here. Their chunk row stays for provenance, but no buffer / summary references them. +* `extract_chunk` decides `admitted` vs `dropped` based on the deep score. +* `append_buffer` moves admitted leaves into a buffer — `buffered`. +* `seal` writes the buffer's contents into a summary and marks each leaf `sealed`. +* `dropped` leaves stop here. Their chunk row stays for provenance, but no buffer / summary references them. This is why retrieval can show provenance without re-running the pipeline: the chunk row plus its terminal lifecycle status is enough. @@ -143,13 +143,13 @@ Three reasons: A few rules to keep the pipeline coherent: -- **All paths go through `mem_tree_jobs`.** Don't add a feature that does its own background scheduling. If you need a periodic step, enqueue a job; if you need a one-shot async step, enqueue a job. -- **Idempotent handlers.** Every handler must be safe to run twice on the same `(kind, payload, dedupe_key)`. Workers retry on transient errors; you can't assume "called once". -- **No LLM calls in the ingest hot path.** Anything that needs a model goes into the queue. -- **Workspace-scoped.** Tests reset state by creating a fresh `OPENHUMAN_WORKSPACE`. Don't reach outside the workspace dir. +* **All paths go through `mem_tree_jobs`.** Don't add a feature that does its own background scheduling. If you need a periodic step, enqueue a job; if you need a one-shot async step, enqueue a job. +* **Idempotent handlers.** Every handler must be safe to run twice on the same `(kind, payload, dedupe_key)`. Workers retry on transient errors; you can't assume "called once". +* **No LLM calls in the ingest hot path.** Anything that needs a model goes into the queue. +* **Workspace-scoped.** Tests reset state by creating a fresh `OPENHUMAN_WORKSPACE`. Don't reach outside the workspace dir. ## See also -- [Memory Tree (user-facing)](../features/memory-tree.md) — the product surface this pipeline powers. -- [Memory Context Window](memory-context-window.md) — how much of the resulting state lands in each agent turn. -- [Local AI](../features/local-ai.md) — opt-in path for running embeddings + summarization on-device. +* [Memory Tree (user-facing)](../features/memory-tree.md) — the product surface this pipeline powers. +* [Memory Context Window](memory-context-window.md) — how much of the resulting state lands in each agent turn. +* [Local AI](../features/local-ai.md) — opt-in path for running embeddings + summarization on-device. diff --git a/gitbooks/features/obsidian-wiki.md b/gitbooks/features/obsidian-wiki.md index ae4fcaca5..e3aec0f3f 100644 --- a/gitbooks/features/obsidian-wiki.md +++ b/gitbooks/features/obsidian-wiki.md @@ -1,12 +1,14 @@ --- description: >- - Every memory chunk also lives as a Markdown file in an Obsidian-compatible - vault you can open and edit. Inspired by Karpathy's obsidian-wiki workflow. + Every memory chunk also lives as a Markdown file in an Obsidian-compatible + vault you can open and edit. Inspired by Karpathy's obsidian-wiki workflow. icon: book-open --- # Obsidian Wiki +

A preview of the OpenHuman memory in Obsidian. Data from various sources (GMail, Slack, Whatsapp etc..) is organized as a memory tree.

+ OpenHuman's memory is not a black box. The same chunks the agent reasons over are written as plain `.md` files into a vault inside your workspace. You can open it in [Obsidian](https://obsidian.md), browse it, edit it, and link notes by hand — and the agent will see your edits. The design is directly inspired by [Andrej Karpathy's obsidian-wiki workflow](https://x.com/karpathy/status/2039805659525644595): a personal wiki where every interesting thing in your life ends up as a linkable note. @@ -35,9 +37,9 @@ Anything you put in `wiki/notes/` is fair game for ingest. The same pipeline tha This means you can: -- Drop a meeting note in `wiki/notes/2026-05-08-board-call.md` and the agent will know the context tomorrow. -- Maintain a file per project, per person, per ticker — the topic tree treats your manual notes as just another source. -- Bulk-import an existing Obsidian vault: drop the `.md` files in and trigger ingest. +* Drop a meeting note in `wiki/notes/2026-05-08-board-call.md` and the agent will know the context tomorrow. +* Maintain a file per project, per person, per ticker — the topic tree treats your manual notes as just another source. +* Bulk-import an existing Obsidian vault: drop the `.md` files in and trigger ingest. ## Why this matters @@ -47,5 +49,5 @@ It's also the cleanest possible export: stop using OpenHuman tomorrow and you ke ## See also -- [Memory Tree](memory-tree.md) — the pipeline that produces the vault. -- [Auto-fetch from Integrations](auto-fetch.md) — how the vault grows on its own. +* [Memory Tree](memory-tree.md) — the pipeline that produces the vault. +* [Auto-fetch from Integrations](auto-fetch.md) — how the vault grows on its own.