Method upsertHubMemory

packages/memos-core/src/storage/sqlite.ts:2604–2619

(memory: HubMemoryRecord)

  // ─── Hub Shared Memories (independent) ───

  upsertHubMemory(memory: HubMemoryRecord): void {
    this.db.prepare(`
      INSERT INTO hub_memories (id, source_chunk_id, source_user_id, source_agent, role, content, summary, kind, group_id, visibility, created_at, updated_at)
      VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
      ON CONFLICT(source_user_id, source_chunk_id) DO UPDATE SET
        source_agent = excluded.source_agent,
        role = excluded.role,
        content = excluded.content,
        summary = excluded.summary,
        kind = excluded.kind,
        group_id = excluded.group_id,
        visibility = excluded.visibility,
        created_at = excluded.created_at,
        updated_at = excluded.updated_at
    `).run(memory.id, memory.sourceChunkId, memory.sourceUserId, memory.sourceAgent, memory.role, memory.content, memory.summary, memory.kind, memory.groupId, memory.visibility, memory.createdAt, memory.updatedAt);
  }

  getHubMemoryBySource(sourceUserId: string, sourceChunkId: string): HubMemoryRecord | null {
    const row = this.db.prepare('SELECT * FROM hub_memories WHERE source_user_id = ? AND source_chunk_id = ?').get(sourceUserId, sourceChunkId) as HubMemoryRow | undefined;