Function initPgvector

api/src/services/pgvector.js:84–176

()

}

export async function initPgvector() {
  const dims = getEmbeddingDimensions();
  vectorDims = dims;
  vectorMode = halfvecMode(dims);

  pool = new pg.Pool({
    connectionString: POSTGRES_URL,
    max: parseInt(process.env.PGPOOL_MAX) || 10,
    idleTimeoutMillis: 30000,
    connectionTimeoutMillis: 5000,
    statement_timeout: parseInt(process.env.PG_STATEMENT_TIMEOUT_MS) || 30000,
  });
  pool.on('error', (err) => console.error('[pgvector] Idle client error:', err.message));

  // Register the pgvector type as array-of-float so values round-trip cleanly.
  // Without this, pg returns the raw '[1,2,3]' string and upserts fail on type mismatch.
  const vectorTypeOid = await registerVectorType(pool);

  // Create extension + table (idempotent)
  await pool.query('CREATE EXTENSION IF NOT EXISTS vector');

  // Capability probe — cache the installed pgvector version once so searchPoints
  // knows whether it can enable iterative_scan (relaxed_order), which needs 0.8+.
  const verRes = await pool.query("SELECT extversion FROM pg_extension WHERE extname = 'vector'");
  const pgvectorVersion = parseVectorVersion(verRes.rows[0]?.extversion);
  iterativeScanSupported = supportsIterativeScan(pgvectorVersion);

  await pool.query(`
    CREATE TABLE IF NOT EXISTS memories (
      id TEXT PRIMARY KEY,
      vector vector(${dims}),
      type TEXT NOT NULL,
      source_agent TEXT,
      client_id TEXT DEFAULT 'global',
      content_hash TEXT,
      key TEXT,
      subject TEXT,
      active BOOLEAN DEFAULT true,
      consolidated BOOLEAN DEFAULT false,
      importance TEXT,
      confidence REAL DEFAULT 1.0,
      access_count INTEGER DEFAULT 0,
      created_at TIMESTAMPTZ NOT NULL DEFAULT NOW(),
      last_accessed_at TIMESTAMPTZ,
      payload JSONB NOT NULL,
      collection TEXT DEFAULT 'shared_memories'
    )
  `);

  // Dims guard — if the table pre-exists with a vector column of a different
  // declared dimension than the provider now reports, every write would fail
  // with an opaque dimension-mismatch. Fail fast at startup with a fix instead.
  const colRes = await pool.query(
    `SELECT atttypmod FROM pg_attribute
       WHERE attrelid = 'memories'::regclass AND attname = 'vector'`
  );
  const atttypmod = colRes.rows[0]?.atttypmod;
  if (dimsGuardShouldExit(atttypmod, dims)) {