Create publisher_ai.py

publisher/publisher_ai.py

@@ -0,0 +1,68 @@
+# publisher/publisher_ai.py
+
+import asyncio
+
+from publisher.scheduler_engine import (
+    next_jobs,
+    mark_done
+)
+
+from publisher.account_manager import (
+    connected_accounts,
+    choose_platforms
+)
+
+from publisher.metadata_engine import generate_metadata
+from publisher.thumbnail_engine import generate_thumbnail
+from publisher.platform_dispatcher import dispatch
+
+
+async def process_job(job):
+
+    job_id, user_id, video = job
+
+    print("Processing:", video)
+
+    accounts = connected_accounts(user_id)
+
+    if not accounts:
+        print("No connected accounts")
+        return
+
+    metadata = await generate_metadata(video)
+
+    thumb = generate_thumbnail(
+        metadata["title"],
+        f"thumbnails/{job_id}.jpg"
+    )
+
+    targets = choose_platforms(
+        "short_video",
+        accounts
+    )
+
+    for acc in targets:
+
+        await dispatch(
+            acc["platform"],
+            acc["token"],
+            video,
+            metadata,
+            thumb
+        )
+
+    mark_done(job_id)
+
+
+async def autonomous_loop():
+
+    print("Publisher AI Started")
+
+    while True:
+
+        jobs = next_jobs()
+
+        for job in jobs:
+            await process_job(job)
+
+        await asyncio.sleep(30)