diff --git a/activitypub.py b/activitypub.py index 3c6c4066..531ee0e9 100644 --- a/activitypub.py +++ b/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) diff --git a/hub.py b/hub.py index 18b8d035..489222fa 100644 --- a/hub.py +++ b/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'