export const tracingStore = new PostgresStore({
    connectionString: process.env.DATABASE_URL!,
    ssl:
        process.env.NODE_ENV === "production"
            ? { rejectUnauthorized: false }
            : false,
    max: 5,
    idleTimeoutMillis: 30000,
})

/**
 * Memory storage instance
 * Shared across all agents to avoid duplicate database connections
 */
const memoryStore = new PostgresStore({
    connectionString: process.env.DATABASE_URL!,
    ssl:
        process.env.NODE_ENV === "production"
            ? { rejectUnauthorized: false }
            : false,
    max: 5,
    idleTimeoutMillis: 30000,
})

/**
 * Vector storage instance
 * Shared across all agents for semantic recall
 */
const vectorStore = new PgVector({
    connectionString: process.env.DATABASE_URL!,
    ssl:
        process.env.NODE_ENV === "production"
            ? { rejectUnauthorized: false }
            : false,
    max: 5,
    idleTimeoutMillis: 30000,
})

/**
 * Singleton Memory instance
 * Reused across all agents to avoid duplicate database connections
 */
let memoryInstance: Memory | null = null

/**
 * Get or create the shared Memory instance
 * This ensures only one Memory instance is created per application lifecycle
 */
export function createMemory(): Memory {
    if (!memoryInstance) {
        memoryInstance = new Memory({
            storage: memoryStore,
            vector: vectorStore,
            embedder: openai.embedding("text-embedding-3-small"),

            options: {
                lastMessages: 10,

                semanticRecall: {
                    topK: 3,
                    messageRange: 2,
                    scope: "resource", // Search across all threads for this user
                },

                workingMemory: {
                    enabled: true,
                    scope: "resource", // Resource = user-specific working memory
                    template: workingMemoryTemplate,
                },
...