storme/nexusAI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

bug fixed the wiring between embedding and memory write path

Browse Source
This commit is contained in:
Storme-bit
2026-04-05 00:20:40 -07:00
parent ed18022d1f
commit ddd251cd5a
4 changed files with 275 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/memory-service/src/index.js
View File

@@ -67,12 +67,12 @@ app.delete('/sessions/:id', (req, res) => {
/********** Episodic Routes ********** */
/************************************* */
app.post('/episodes', (req, res) => {
app.post('/episodes', async (req, res) => {
const { sessionId, userMessage, aiResponse, tokenCount, metadata } = req.body;
if (!sessionId || !userMessage || !aiResponse) {
return res.status(400).json({ error: 'sessionId, userMessage and aiResponse are required' });
}
const episode = episodic.createEpisode(sessionId, userMessage, aiResponse, tokenCount, metadata);
const episode = await episodic.createEpisode(sessionId, userMessage, aiResponse, tokenCount, metadata);
res.status(201).json(episode);
});

2
packages/memory-service/src/semantic/index.js
View File

@@ -47,7 +47,7 @@ async function collectionExists(name) {
//SQLite ID stored here to be able to link back to original data
async function upsertVector(collection, id, vector, payload = {}) {
const client = getClient();
await client.upsertVector(collection, {
await client.upsert(collection, {
wait: true, // Wait for the operation to complete before returning
points: [{id, vector, payload}]
});