#!/usr/bin/env python3
"""
HopSaaS Notion Database to Coda Table Synchronizer
Reads Notion block databases and maps relational properties into Coda C-columns.
"""
import os
import requests

NOTION_KEY = os.getenv("NOTION_API_KEY", "secret_...")
CODA_KEY = os.getenv("CODA_API_KEY", "coda_...")
NOTION_DB_ID = os.getenv("NOTION_DATABASE_ID", "...")
CODA_DOC_ID = os.getenv("CODA_DOC_ID", "...")
CODA_TABLE_ID = os.getenv("CODA_TABLE_ID", "...")

def sync_records():
    res = requests.post(
        f"https://api.notion.com/v1/databases/{NOTION_DB_ID}/query",
        headers={
            "Authorization": f"Bearer {NOTION_KEY}",
            "Notion-Version": "2022-06-28"
        }
    )
    pages = res.json().get("results", [])
    print(f"[*] Pulled {len(pages)} Notion database items. Transforming to Coda rows...")

    rows = []
    for page in pages:
        props = page.get("properties", {})
        title_list = props.get("Name", {}).get("title", [])
        title = title_list[0]["plain_text"] if title_list else "Untitled"
        rows.append({"cells": [{"column": "c-title", "value": title}]})

    coda_url = f"https://coda.io/apis/v1/docs/{CODA_DOC_ID}/tables/{CODA_TABLE_ID}/rows"
    coda_res = requests.post(
        coda_url,
        headers={"Authorization": f"Bearer {CODA_KEY}", "Content-Type": "application/json"},
        json={"rows": rows}
    )
    if coda_res.status_code == 202:
        print("[✓] Upserted rows successfully into Coda doc.")

if __name__ == "__main__":
    sync_records()