refactor: match monitor examples to JS SDK style

- Add seen_ids deduplication
- Cleanup in signal handler directly
- Show "(no diffs data)" when changed but no diffs

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>

Author: FrancescoSaverioZuppichini

examples/monitor/monitor_basic.py

@@ -33,25 +33,29 @@
 print(f"Interval: {res.data.interval}")
 print("\nPolling for activity (Ctrl+C to stop)...\n")
 
-running = True
-
 def cleanup(_sig, _frame):
-    global running
-    running = False
+    print("\nStopping monitor...")
+    sgai.monitor.delete(monitor_id)
+    print("Monitor deleted")
+    exit(0)
 
 signal.signal(signal.SIGINT, cleanup)
 
-while running:
+seen_ids = set()
+
+while True:
     activity = sgai.monitor.activity(monitor_id)
     if activity.status == "success" and activity.data:
         for tick in activity.data.ticks:
+            if tick.id in seen_ids:
+                continue
+            seen_ids.add(tick.id)
+
             changes = "CHANGED" if tick.changed else "no change"
             print(f"[{tick.created_at}] {tick.status} - {changes} ({tick.elapsed_ms}ms)")
             diffs = tick.diffs.model_dump(exclude_none=True)
             if diffs:
                 print(f"  Diffs: {json.dumps(diffs, indent=2)}")
+            elif tick.changed:
+                print("  (no diffs data)")
     time.sleep(30)
-
-print("\nStopping monitor...")
-sgai.monitor.delete(monitor_id)
-print("Monitor deleted")

examples/monitor/monitor_basic_async.py

@@ -32,16 +32,24 @@ async def main():
         print(f"Interval: {res.data.interval}")
         print("\nPolling for activity (Ctrl+C to stop)...\n")
 
+        seen_ids = set()
+
         try:
             while True:
                 activity = await sgai.monitor.activity(monitor_id)
                 if activity.status == "success" and activity.data:
                     for tick in activity.data.ticks:
+                        if tick.id in seen_ids:
+                            continue
+                        seen_ids.add(tick.id)
+
                         changes = "CHANGED" if tick.changed else "no change"
                         print(f"[{tick.created_at}] {tick.status} - {changes} ({tick.elapsed_ms}ms)")
                         diffs = tick.diffs.model_dump(exclude_none=True)
                         if diffs:
                             print(f"  Diffs: {json.dumps(diffs, indent=2)}")
+                        elif tick.changed:
+                            print("  (no diffs data)")
                 await asyncio.sleep(30)
         except asyncio.CancelledError:
             pass

examples/monitor/monitor_with_webhook.py

@@ -35,25 +35,29 @@
 print("Webhook configured")
 print("\nPolling for activity (Ctrl+C to stop)...\n")
 
-running = True
-
 def cleanup(_sig, _frame):
-    global running
-    running = False
+    print("\nStopping monitor...")
+    sgai.monitor.delete(monitor_id)
+    print("Monitor deleted")
+    exit(0)
 
 signal.signal(signal.SIGINT, cleanup)
 
-while running:
+seen_ids = set()
+
+while True:
     activity = sgai.monitor.activity(monitor_id)
     if activity.status == "success" and activity.data:
         for tick in activity.data.ticks:
+            if tick.id in seen_ids:
+                continue
+            seen_ids.add(tick.id)
+
             changes = "CHANGED" if tick.changed else "no change"
             print(f"[{tick.created_at}] {tick.status} - {changes} ({tick.elapsed_ms}ms)")
             diffs = tick.diffs.model_dump(exclude_none=True)
             if diffs:
                 print(f"  Diffs: {json.dumps(diffs, indent=2)}")
+            elif tick.changed:
+                print("  (no diffs data)")
     time.sleep(30)
-
-print("\nStopping monitor...")
-sgai.monitor.delete(monitor_id)
-print("Monitor deleted")

examples/monitor/monitor_with_webhook_async.py

@@ -34,16 +34,24 @@ async def main():
         print("Webhook configured")
         print("\nPolling for activity (Ctrl+C to stop)...\n")
 
+        seen_ids = set()
+
         try:
             while True:
                 activity = await sgai.monitor.activity(monitor_id)
                 if activity.status == "success" and activity.data:
                     for tick in activity.data.ticks:
+                        if tick.id in seen_ids:
+                            continue
+                        seen_ids.add(tick.id)
+
                         changes = "CHANGED" if tick.changed else "no change"
                         print(f"[{tick.created_at}] {tick.status} - {changes} ({tick.elapsed_ms}ms)")
                         diffs = tick.diffs.model_dump(exclude_none=True)
                         if diffs:
                             print(f"  Diffs: {json.dumps(diffs, indent=2)}")
+                        elif tick.changed:
+                            print("  (no diffs data)")
                 await asyncio.sleep(30)
         except asyncio.CancelledError:
             pass