From 615f9da2dfffc32182f59011d3f30a6b712e6922 Mon Sep 17 00:00:00 2001
From: Accusys <accusys@momentry.dev>
Date: Fri, 26 Jun 2026 02:16:46 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20identity=20status=20-=20TMDb=20and=20use?=
 =?UTF-8?q?r=5Fdefined=20identities=20start=20as=20'pending'=20(=E7=A2=BA?=
 =?UTF-8?q?=E8=AA=8D=E5=88=B6)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 scripts/tmdb_identity_integration.py |  2 +-
 scripts/update_identity_status.py    | 26 ++++++++++++++++++++++++++
 src/core/db/postgres_db.rs           |  2 +-
 3 files changed, 28 insertions(+), 2 deletions(-)
 create mode 100644 scripts/update_identity_status.py

diff --git a/scripts/tmdb_identity_integration.py b/scripts/tmdb_identity_integration.py
index 5ed13fc..0ca2d88 100755
--- a/scripts/tmdb_identity_integration.py
+++ b/scripts/tmdb_identity_integration.py
@@ -264,7 +264,7 @@ def register_identity_to_db(
                 name,
                 "people",
                 "tmdb",
-                "confirmed",
+                "pending",  # TMDb identities need manual confirmation
                 embedding_str,
                 json.dumps(reference_data),
                 tmdb_id,
diff --git a/scripts/update_identity_status.py b/scripts/update_identity_status.py
new file mode 100644
index 0000000..ac5f335
--- /dev/null
+++ b/scripts/update_identity_status.py
@@ -0,0 +1,26 @@
+#!/opt/homebrew/bin/python3.11
+"""
+Update identity status from confirmed to pending
+"""
+import os
+import psycopg2
+
+DATABASE_URL = os.getenv("DATABASE_URL", "postgres://accusys@localhost:5432/momentry")
+
+conn = psycopg2.connect(DATABASE_URL)
+cur = conn.cursor()
+
+# Update all confirmed identities to pending
+cur.execute("UPDATE identities SET status='pending' WHERE status='confirmed'")
+rows_affected = cur.rowcount
+conn.commit()
+
+print(f"Updated {rows_affected} identities from 'confirmed' to 'pending'")
+
+# Verify
+cur.execute("SELECT COUNT(*) FROM identities WHERE status='pending'")
+pending_count = cur.fetchone()[0]
+print(f"Total pending identities: {pending_count}")
+
+cur.close()
+conn.close()
\ No newline at end of file
diff --git a/src/core/db/postgres_db.rs b/src/core/db/postgres_db.rs
index 8e4bfb5..58c2652 100644
--- a/src/core/db/postgres_db.rs
+++ b/src/core/db/postgres_db.rs
@@ -3950,7 +3950,7 @@ sqlx::query(
         // Not found: create new with generated uuid
         let id: i32 = sqlx::query_scalar(&format!(
             "INSERT INTO {} (uuid, name, identity_type, source, status) \
-             VALUES (gen_random_uuid(), $1, 'people', 'user_defined', 'confirmed') \
+             VALUES (gen_random_uuid(), $1, 'people', 'user_defined', 'pending') \
              RETURNING id",
             identities_table
         ))