791976a3d8
Admin home lists tenants, alerts, and connection health; header selector enables superadmin context; Meta/GA4/GSC/GTM/CRM/email slots live per tenant (manual status until OAuth). Co-authored-by: Cursor <cursoragent@cursor.com>
108 lines
4.0 KiB
Python
108 lines
4.0 KiB
Python
#!/usr/bin/env python3
|
|
"""Apply sql/agency_portfolio.sql via Dokploy supabase-db terminal."""
|
|
from __future__ import annotations
|
|
|
|
import base64
|
|
import os
|
|
import re
|
|
import sys
|
|
from pathlib import Path
|
|
|
|
from playwright.sync_api import sync_playwright
|
|
|
|
ROOT = Path("/Users/4ventures/4ventures-client-portal")
|
|
BPS = Path("/Users/4ventures/Projects/bps-facturacion")
|
|
SQL = ROOT / "sql" / "agency_portfolio.sql"
|
|
SHOT = ROOT / "scripts" / "dokploy-shots"
|
|
BASE = "https://dokploy.4ventures.es"
|
|
|
|
|
|
def env(key: str) -> str:
|
|
v = os.environ.get(key, "").strip()
|
|
if v:
|
|
return v
|
|
p = BPS / ".env"
|
|
if not p.is_file():
|
|
return ""
|
|
for line in p.read_text().splitlines():
|
|
if line.startswith(f"{key}="):
|
|
return line.split("=", 1)[1].strip().strip('"').strip("'")
|
|
return ""
|
|
|
|
|
|
def main() -> int:
|
|
email = env("DOKPLOY_EMAIL") or "marketing@4ventures.es"
|
|
password = env("DOKPLOY_PASSWORD")
|
|
if not password:
|
|
print("NO_PASSWORD", flush=True)
|
|
return 2
|
|
SHOT.mkdir(parents=True, exist_ok=True)
|
|
b64 = base64.b64encode(SQL.read_text(encoding="utf-8").encode()).decode()
|
|
chunks = [b64[i : i + 180] for i in range(0, len(b64), 180)]
|
|
|
|
with sync_playwright() as p:
|
|
browser = p.chromium.launch(headless=True)
|
|
page = browser.new_page(viewport={"width": 1500, "height": 1100})
|
|
page.goto(BASE + "/", wait_until="domcontentloaded", timeout=90000)
|
|
page.wait_for_timeout(500)
|
|
if "/dashboard" not in page.url:
|
|
page.locator('input[type="email"], input[name="email"]').first.fill(email)
|
|
page.locator('input[type="password"]').first.fill(password)
|
|
page.locator('button[type="submit"]').first.click()
|
|
page.wait_for_url(re.compile(r"/dashboard"), timeout=90000)
|
|
print("login ok", flush=True)
|
|
|
|
page.goto(f"{BASE}/dashboard/docker", wait_until="domcontentloaded", timeout=120000)
|
|
page.wait_for_timeout(800)
|
|
page.locator("input[placeholder*='ilter' i], input[placeholder*='earch' i]").first.fill(
|
|
"supabase-db"
|
|
)
|
|
page.wait_for_timeout(1200)
|
|
page.keyboard.press("Escape")
|
|
page.wait_for_timeout(200)
|
|
page.get_by_role("button", name=re.compile(r"Open menu", re.I)).first.click()
|
|
page.wait_for_timeout(400)
|
|
page.get_by_text("Terminal", exact=True).click()
|
|
page.wait_for_timeout(1200)
|
|
# db image usually has bash
|
|
if page.locator("button", has_text="Bash").count():
|
|
page.locator("button", has_text="Bash").first.click()
|
|
page.wait_for_timeout(3000)
|
|
if page.locator("textarea.xterm-helper-textarea").count():
|
|
page.locator("textarea.xterm-helper-textarea").first.click()
|
|
|
|
def run(cmd: str, wait: int = 900) -> None:
|
|
page.keyboard.type(cmd, delay=1)
|
|
page.keyboard.press("Enter")
|
|
page.wait_for_timeout(wait)
|
|
|
|
run("rm -f /tmp/agency.b64 /tmp/agency.sql; echo READY", 1500)
|
|
for i, ch in enumerate(chunks):
|
|
op = ">" if i == 0 else ">>"
|
|
run(f"printf '%s' '{ch}' {op} /tmp/agency.b64", 500)
|
|
run(
|
|
"base64 -d /tmp/agency.b64 > /tmp/agency.sql && wc -c /tmp/agency.sql && "
|
|
"psql -U postgres -d postgres -v ON_ERROR_STOP=1 -f /tmp/agency.sql; echo EXIT:$?",
|
|
10000,
|
|
)
|
|
run(
|
|
"psql -U postgres -d postgres -c \"select count(*) as integrations from public.integrations;\" ; echo DONE",
|
|
4000,
|
|
)
|
|
text = page.evaluate(
|
|
"() => (document.querySelector('.xterm-rows')||{}).innerText||''"
|
|
)
|
|
page.screenshot(path=str(SHOT / "agency_sql.png"), full_page=True)
|
|
browser.close()
|
|
|
|
ok = "EXIT:0" in text
|
|
print("EXIT0", ok, flush=True)
|
|
for ln in text.splitlines():
|
|
if re.search(r"EXIT:|ERROR|integrations|DONE|READY", ln, re.I):
|
|
print(">", ln.strip()[:200], flush=True)
|
|
return 0 if ok else 6
|
|
|
|
|
|
if __name__ == "__main__":
|
|
raise SystemExit(main())
|