ATProto: arroba: send_new_commits => send_events

snarfed/arroba@aad0d9da63

activitypub.py

@@ -971,7 +971,7 @@ def inbox(protocol=None, id=None):
 
     obj = Object(id=activity.get('id'), as2=unwrap(activity))
     try:
-        # TODO: switch to task
+        # TODO: switch to task. need to handle transient activities without ids!
         return ActivityPub.receive(obj, authed_as=authed_as)
     except ValueError as e:
         logger.warning(e, exc_info=True)

hub.py

@@ -64,7 +64,7 @@ def atproto_commit():
 
     Triggers `subscribeRepos` to check for new commits.
     """
-    xrpc_sync.send_new_commits()
+    xrpc_sync.send_events()
     return 'OK'