mirror of
https://github.com/allaunthefox/SilverSight.git
synced 2026-07-31 01:25:21 +00:00
allaun
5eac0654b7
- Root cause: search_path=auth,public caused AppFloyo unqualified CREATE TABLE statements to land in auth schema (shadowing public) - Fix: APPFLOWY_DATABASE_URL with options=-c%20search_path=public - Ran all 144 SQLx migrations from binary (clean state + fragment type pre-cleanup) - GoTrue/AppFloyo user sync: created af_user record for admin - Port 8000 freed from ii-agent (moved to 8001 permanently) - Deployment receipt updated: signatures/appflowy_deployment_status.json Services on neon-64gb: GoTrue :9999 ✅ auth working (admin@researchstack.info / admin123) AppFloyo :8000 ✅ REST API operational Authentik :30001 ✅ SSO admin created ii-agent :8001 ✅ restarted
53 lines
2.2 KiB
Python
53 lines
2.2 KiB
Python
#!/usr/bin/env python3
|
|
"""Run all AppFloyo Cloud migrations from /tmp/appflowy_migrations/. """
|
|
import hashlib, os, subprocess, sys
|
|
|
|
MIG_DIR = '/tmp/appflowy_migrations'
|
|
DB = ['/home/allaun/.nix-profile/bin/psql', '-h', 'localhost', '-U', 'postgres', '-d', 'appflowy']
|
|
ENV = {'PGPASSWORD': 'postgres', 'PATH': '/home/allaun/.nix-profile/bin:/usr/bin:/bin'}
|
|
|
|
def sql(cmd: str) -> tuple[bool, str]:
|
|
r = subprocess.run(DB, input=cmd.encode(), capture_output=True, timeout=30, env=ENV)
|
|
return r.returncode == 0, (r.stderr.decode().strip().split('\n')[-1][:120] if r.stderr else '')
|
|
|
|
def main():
|
|
sql('''CREATE TABLE IF NOT EXISTS public._sqlx_migrations (
|
|
version BIGINT PRIMARY KEY, description TEXT NOT NULL,
|
|
installed_on TIMESTAMPTZ NOT NULL DEFAULT NOW(),
|
|
success BOOLEAN NOT NULL, checksum BYTEA NOT NULL, execution_time BIGINT NOT NULL)''')
|
|
|
|
done = set()
|
|
r = subprocess.run(DB + ['-t', '-A', '-c', 'SELECT version FROM public._sqlx_migrations'],
|
|
capture_output=True, timeout=10, env=ENV)
|
|
for line in r.stdout.decode().strip().split('\n'):
|
|
if line.strip():
|
|
done.add(int(line.strip()))
|
|
|
|
files = sorted([f for f in os.listdir(MIG_DIR) if f.endswith('.sql')])
|
|
ok_count = 0
|
|
fail_count = 0
|
|
|
|
for fname in files:
|
|
ver = int(fname.split('_')[0])
|
|
desc = fname.split('_', 1)[1].replace('.sql', '') if '_' in fname else fname
|
|
if ver in done:
|
|
continue
|
|
|
|
content = open(os.path.join(MIG_DIR, fname), 'rb').read()
|
|
checksum = hashlib.sha256(content).hexdigest()
|
|
ok, err = sql(content.decode())
|
|
|
|
if ok:
|
|
sql(f"INSERT INTO public._sqlx_migrations (version, description, installed_on, success, checksum, execution_time) "
|
|
f"VALUES ({ver}, '{desc.replace(chr(39), chr(39)+chr(39))}', NOW(), true, decode('{checksum}', 'hex'), 0) "
|
|
f"ON CONFLICT (version) DO NOTHING")
|
|
ok_count += 1
|
|
print(f' OK {ver} {desc}')
|
|
else:
|
|
fail_count += 1
|
|
print(f' FAIL {ver} {desc}: {err}')
|
|
|
|
print(f'\n{ok_count} done, {fail_count} failed')
|
|
|
|
if __name__ == '__main__':
|
|
main()
|