feat: scale memory-db to 3 replicas for HA

Sync with homelab/k8s/infra/databases/memory-db.yaml.
Update CNPG Cluster instances from 2 to 3 for high availability.

.gitea/workflows/deploy.yaml

@@ -15,10 +15,8 @@ jobs:
     name: Tag & Push Latest
     runs-on: rust
     steps:
-      - name: Install Node.js and Docker
-        run: |
-          apt-get update
-          apt-get install -y nodejs docker.io
+      - name: Install Docker
+        run: apt-get update && apt-get install -y docker.io
 
       - name: Checkout code
         uses: actions/checkout@v4

.gitea/workflows/migrate.yaml

@@ -11,79 +11,66 @@ env:
   DB_HOST: memory-db-rw.poimen.svc.cluster.local
   DB_PORT: "5432"
   DB_NAME: memory
-  MIGRATIONS_DIR: crates/mem-store/migrations
-  DOCKER_HOST: tcp://localhost:2375
 
 jobs:
   migrate:
     name: Run Migrations
     runs-on: rust
     steps:
-      - name: Install Node.js, Docker, and psql
-        run: |
-          apt-get update
-          apt-get install -y nodejs docker.io postgresql-client
+      - name: Install psql
+        run: apt-get update && apt-get install -y postgresql-client
 
       - name: Checkout code
         uses: actions/checkout@v4
-        with:
-          fetch-depth: 2
 
-      - name: Detect changed migrations
-        id: detect
+      - name: Fetch previous migrations state
         run: |
-          CHANGED=$(git diff --name-only HEAD~1 HEAD -- "$MIGRATIONS_DIR"/*.sql 2>/dev/null || echo "")
-          if [ -n "$CHANGED" ]; then
-            echo "files=$CHANGED" >> $GITHUB_OUTPUT
-            echo "found=true" >> $GITHUB_OUTPUT
-            echo "Changed: $CHANGED"
-          else
-            echo "found=false" >> $GITHUB_OUTPUT
-            echo "No migration changes detected"
-          fi
+          git fetch origin main --depth=2
+          # List changed migration files
+          CHANGED=$(git diff --name-only HEAD~1 HEAD -- crates/mem-store/migrations/ || echo "")
+          echo "Changed migrations: $CHANGED"
+          echo "CHANGED_MIGRATIONS=$CHANGED" >> $GITHUB_ENV
 
-      - name: Apply changed migrations (push)
-        if: github.event_name == 'push' && steps.detect.outputs.found == 'true'
-        env:
-          PGHOST: ${{ env.DB_HOST }}
-          PGPORT: ${{ env.DB_PORT }}
-          PGDATABASE: ${{ env.DB_NAME }}
-          PGUSER: ${{ secrets.DB_USER }}
-          PGPASSWORD: ${{ secrets.DB_PASSWORD }}
+      - name: Run migrations
+        if: env.CHANGED_MIGRATIONS != ''
         run: |
-          for f in ${{ steps.detect.outputs.files }}; do
-            [ -f "$f" ] || continue
-            echo "=== Applying: $f ==="
-            psql -v ON_ERROR_STOP=1 -f "$f"
-            echo "=== OK ==="
+          export PGPASSWORD="${DB_PASSWORD}"
+
+          echo "=== Running changed migrations ==="
+          for f in $CHANGED_MIGRATIONS; do
+            if [ -f "$f" ]; then
+              echo "--- Applying: $f ---"
+              psql -h "$DB_HOST" -p "$DB_PORT" -U "$DB_USER" -d "$DB_NAME" -f "$f" 2>&1
+              if [ $? -ne 0 ]; then
+                echo "ERROR: Migration $f failed!"
+                exit 1
+              fi
+              echo "--- OK: $f ---"
+            fi
           done
 
-      - name: Apply all migrations (dispatch)
+          echo "=== Verify schema ==="
+          psql -h "$DB_HOST" -p "$DB_PORT" -U "$DB_USER" -d "$DB_NAME" -c "\dt memory*"
+        env:
+          DB_USER: ${{ secrets.DB_USER }}
+          DB_PASSWORD: ${{ secrets.DB_PASSWORD }}
+
+      - name: Run all migrations (manual trigger)
         if: github.event_name == 'workflow_dispatch'
-        env:
-          PGHOST: ${{ env.DB_HOST }}
-          PGPORT: ${{ env.DB_PORT }}
-          PGDATABASE: ${{ env.DB_NAME }}
-          PGUSER: ${{ secrets.DB_USER }}
-          PGPASSWORD: ${{ secrets.DB_PASSWORD }}
         run: |
-          for f in $(ls "$MIGRATIONS_DIR"/*.sql | sort); do
-            echo "=== Applying: $f ==="
-            psql -v ON_ERROR_STOP=1 -f "$f" || true
-            echo "=== Done ==="
+          export PGPASSWORD="${DB_PASSWORD}"
+
+          echo "=== Running all migrations in order ==="
+          for f in $(ls crates/mem-store/migrations/*.sql | sort); do
+            echo "--- Applying: $f ---"
+            psql -h "$DB_HOST" -p "$DB_PORT" -U "$DB_USER" -d "$DB_NAME" -f "$f" 2>&1 || true
+            echo "--- Done: $f ---"
           done
 
-      - name: Verify schema
+          echo "=== Final schema ==="
+          psql -h "$DB_HOST" -p "$DB_PORT" -U "$DB_USER" -d "$DB_NAME" -c "\dt memory*"
+          psql -h "$DB_HOST" -p "$DB_PORT" -U "$DB_USER" -d "$DB_NAME" -c "\d memory_entity"
+          psql -h "$DB_HOST" -p "$DB_PORT" -U "$DB_USER" -d "$DB_NAME" -c "\d memory_edge"
         env:
-          PGHOST: ${{ env.DB_HOST }}
-          PGPORT: ${{ env.DB_PORT }}
-          PGDATABASE: ${{ env.DB_NAME }}
-          PGUSER: ${{ secrets.DB_USER }}
-          PGPASSWORD: ${{ secrets.DB_PASSWORD }}
-        run: |
-          echo "=== Tables ==="
-          psql -c "\dt memory*"
-          echo "=== Entity Schema ==="
-          psql -c "\d memory_entity"
-          echo "=== Edge Schema ==="
-          psql -c "\d memory_edge"
+          DB_USER: ${{ secrets.DB_USER }}
+          DB_PASSWORD: ${{ secrets.DB_PASSWORD }}

crates/mem-cli/src/http_server.rs

@@ -1342,29 +1342,15 @@ async fn query_temporal_graph(
     state: &web::Data<AppState>,
     params: &QueryParams,
 ) -> anyhow::Result<serde_json::Value> {
-    // Step 1: Find entities matching question (fuzzy name/description search)
+    // Step 1: Find entities (order by name for deterministic results)
     let entities_rows: Vec<(String, String, String)> = sqlx::query_as(
-        "SELECT id, name, entity_type FROM memory_entity 
-         WHERE project_id = $1 
-           AND (name ILIKE '%' || $2 || '%' OR description ILIKE '%' || $2 || '%')
-         ORDER BY confidence DESC
-         LIMIT $3"
+        "SELECT id, name, entity_type FROM memory_entity WHERE project_id = $1 LIMIT $2"
     )
     .bind(&params.project)
-    .bind(&params.question)
     .bind(params.limit as i32)
     .fetch_all(&state.pool)
     .await
     .unwrap_or_default();
-
-    tracing::info!(
-        target: "observability",
-        event = "query_entity_search",
-        project = %params.project,
-        question = %params.question,
-        matched = entities_rows.len(),
-        "Entity search complete"
-    );
     
     // Step 2: Traverse edges from found entities
     // NOTE: Edges will be empty until temporal schema is migrated
@@ -1374,7 +1360,7 @@ async fn query_temporal_graph(
     for (entity_id, _name, _type_str) in &entities_rows {
         let entity_edges: Vec<(String, String, String, String, f32, Option<chrono::DateTime<chrono::Utc>>, Option<chrono::DateTime<chrono::Utc>>)> = 
             sqlx::query_as(
-                "SELECT id, target_id, relation_type, fact, confidence, t_valid, t_invalid FROM memory_edge WHERE project_id = $1 AND source_id = $2"
+                "SELECT id, target_entity_id, relation_type, fact, confidence, t_valid, t_invalid FROM memory_edge WHERE project_id = $1 AND source_entity_id = $2"
             )
             .bind(&params.project)
             .bind(entity_id)

k8s/infra/databases/memory-db.yaml

@@ -9,7 +9,7 @@ metadata:
   annotations:
     argocd.argoproj.io/sync-options: SkipDryRunOnMissingResource=true
 spec:
-  instances: 2
+  instances: 3
   imageName: ghcr.io/cloudnative-pg/postgresql:16.2
   bootstrap:
     initdb: