apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-05-25 18:55:19 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix lint errs

Browse source
This commit is contained in:
Ramnique Singh 2026-01-07 12:35:30 +05:30
parent 13f2b7c2a5
commit c7a6b060f1
1 changed files with 0 additions and 22 deletions
Download patch file Download diff file Expand all files Collapse all files

22
apps/x/packages/core/src/knowledge/build_graph.ts
View file

@ -3,8 +3,6 @@ import path from 'path';
import { WorkDir } from '../config/config.js'; import { WorkDir } from '../config/config.js';
import { createRun, createMessage } from '../runs/runs.js'; import { createRun, createMessage } from '../runs/runs.js';
import { bus } from '../runs/bus.js'; import { bus } from '../runs/bus.js';
import container from '../di/container.js';
import { IRunsRepo } from '../runs/repo.js';
/** /**
* Build obsidian-style knowledge graph by running topic extraction * Build obsidian-style knowledge graph by running topic extraction
@ -13,7 +11,6 @@ import { IRunsRepo } from '../runs/repo.js';
const KNOWLEDGE_SOURCE_DIR = path.join(WorkDir, 'gmail_sync'); const KNOWLEDGE_SOURCE_DIR = path.join(WorkDir, 'gmail_sync');
const NOTES_OUTPUT_DIR = path.join(WorkDir, 'notes'); const NOTES_OUTPUT_DIR = path.join(WorkDir, 'notes');
const TOPIC_EXTRACTION_AGENT = 'topic_extraction';
const NOTE_CREATION_AGENT = 'note_creation'; const NOTE_CREATION_AGENT = 'note_creation';
/** /**
@ -55,25 +52,6 @@ async function waitForRunCompletion(runId: string): Promise<void> {
}); });
} }
/**
* Run topic extraction agent on content
*/
async function extractTopics(content: string, sourceFile: string): Promise<string> {
// Create a run for the topic extraction agent
const run = await createRun({
agentId: TOPIC_EXTRACTION_AGENT,
});
// Send the content as a message to the agent
// The agent will extract topics and write them to ~/.rowboat/topics file
await createMessage(run.id, content);
// Wait for the run to complete
await waitForRunCompletion(run.id);
return run.id;
}
/** /**
* Run note creation agent on content to extract entities and create/update notes * Run note creation agent on content to extract entities and create/update notes
*/ */