elias/core
1
0
Fork 0
mirror of https://github.com/eliasstepanik/core.git synced 2026-01-11 18:08:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: space assignment retrieving episodes

Browse Source
This commit is contained in:
Manoj 2025-10-10 10:50:08 +05:30
parent a0c1b7eb25
commit 0dec1c7f33
1 changed files with 12 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
apps/webapp/app/trigger/spaces/space-assignment.ts
View File

@ -9,7 +9,6 @@ import {
getSpaceEpisodeCount, getSpaceEpisodeCount,
} from "~/services/graphModels/space"; } from "~/services/graphModels/space";
import { triggerSpaceSummary } from "./space-summary"; import { triggerSpaceSummary } from "./space-summary";
import { triggerSpacePattern } from "./space-pattern";
import { import {
updateMultipleSpaceStatuses, updateMultipleSpaceStatuses,
SPACE_STATUS, SPACE_STATUS,
@ -33,7 +32,6 @@ interface EpisodeData {
originalContent: string; originalContent: string;
source: string; source: string;
createdAt: Date; createdAt: Date;
metadata: any;
} }
interface SpaceData { interface SpaceData {
@ -347,34 +345,29 @@ async function getEpisodesToAnalyze(
// For new space: analyze all recent episodes // For new space: analyze all recent episodes
query = ` query = `
MATCH (e:Episode {userId: $userId}) MATCH (e:Episode {userId: $userId})
RETURN e RETURN e.uuid as uuid, e.content as content, e.originalContent as originalContent, e.source as source, e.createdAt as createdAt
ORDER BY e.createdAt DESC ORDER BY e.createdAt ASC
LIMIT 1000
`; `;
} else { } else {
// For episode mode: analyze specific episodes // For episode mode: analyze specific episodes
query = ` query = `
UNWIND $episodeIds AS episodeId UNWIND $episodeIds AS episodeId
MATCH (e:Episode {uuid: episodeId, userId: $userId}) MATCH (e:Episode {uuid: episodeId, userId: $userId})
RETURN e RETURN e.uuid as uuid, e.content as content, e.originalContent as originalContent, e.source as source, e.createdAt as createdAt
ORDER BY e.createdAt DESC ORDER BY e.createdAt ASC
`; `;
params.episodeIds = options.episodeIds; params.episodeIds = options.episodeIds;
} }
const result = await runQuery(query, params); const result = await runQuery(query, params);
return result.map((record) => { return result.map((record) => ({
const episode = record.get("e").properties; uuid: record.get("uuid"),
return { content: record.get("content"),
uuid: episode.uuid, originalContent: record.get("originalContent"),
content: episode.content, source: record.get("source"),
originalContent: episode.originalContent, createdAt: new Date(record.get("createdAt")),
source: episode.source, }));
createdAt: new Date(episode.createdAt),
metadata: JSON.parse(episode.metadata || "{}"),
};
});
} }
async function processBatchAI( async function processBatchAI(
@ -795,7 +788,7 @@ async function createLLMPrompt(
const episodesDescription = episodes const episodesDescription = episodes
.map( .map(
(ep) => (ep) =>
`ID: ${ep.uuid}\nCONTENT: ${ep.content}\nSOURCE: ${ep.source}\nMETADATA: ${JSON.stringify(ep.metadata)}`, `ID: ${ep.uuid}\nCONTENT: ${ep.content}\nSOURCE: ${ep.source}}`,
) )
.join("\n\n"); .join("\n\n");