Sync & Changes

import requests
import time
from datetime import datetime, timezone

API_BASE = "https://your-tenant.rallycrm.io/api/v1"
API_KEY = "rk_live_your_api_key_here"
HEADERS = {"X-Api-Key": API_KEY}
POLL_INTERVAL = 60  # seconds

def get_changes(since: str, entities: str = None, limit: int = 1000):
    """Fetch changes since the given ISO 8601 timestamp."""
    params = {"since": since, "limit": limit}
    if entities:
        params["entities"] = entities

    response = requests.get(
        f"{API_BASE}/sync/changes",
        headers=HEADERS,
        params=params,
    )
    response.raise_for_status()
    return response.json()

def fetch_entity(entity_type: str, entity_id: str):
    """Fetch the full record for an entity."""
    # Map singular type to plural endpoint
    endpoint_map = {
        "contact": "contacts",
        "company": "companies",
        "deal": "deals",
        "activity": "activities",
    }
    endpoint = endpoint_map[entity_type]

    response = requests.get(
        f"{API_BASE}/{endpoint}/{entity_id}",
        headers=HEADERS,
    )
    response.raise_for_status()
    return response.json()

def process_changes(changes):
    """Process each change entry."""
    for change in changes:
        action = change["action"]
        entity_type = change["entityType"]
        entity_id = change["entityId"]

        if action in ("inserted", "updated"):
            record = fetch_entity(entity_type, entity_id)
            print(f"{action.upper()} {entity_type} {entity_id}")
            # Upsert into your local database...

        elif action == "deleted":
            print(f"DELETED {entity_type} {entity_id}")
            # Remove from your local database...

def run_sync_loop():
    """Main sync loop."""
    # Start from 24 hours ago (or load from persistent storage)
    last_sync = datetime.now(timezone.utc).isoformat()
    print(f"Starting sync from: {last_sync}")

    while True:
        changes = get_changes(since=last_sync)

        if changes:
            print(f"Processing {len(changes)} changes...")
            process_changes(changes)

            # Update high-water mark
            last_sync = changes[-1]["changedAt"]
            print(f"Sync cursor updated to: {last_sync}")
        else:
            print("No new changes")

        time.sleep(POLL_INTERVAL)

if __name__ == "__main__":
    run_sync_loop()