cross-posted from: r1b.it/post/12935

As I have browsed the Fediverse through r1b.it, I’ve noticed lots of missing content from remote communities. Some of that has to do with actual federation problems (which I have been in talks with other instance owners to fix), but most of it is a result of completely intentional behavior. Regardless of that, though, I feel as if missing content detracts from the r1b.it user experience. So, I decided to flex my programming muscles a bit and devised a solution.

For the more technically inclined bunch, you can keep reading to see how it works. For everyone else, you can just be happy to hear that you should now be getting all new content from your subscribed communities! If you have any further federation issues, please let me know. You can always @ me in !croak :)

**The nerd stuff**

Lemmy relies on an event-driven feed, meaning it doesn’t always automatically pull posts from remote servers unless someone is actively browsing or querying them. So, if a r1b.it user doesn’t actively interact with a community, the content won’t get pulled. If no new content is getting pulled, no one will interact with the community. To break this cycle, I’ve set up a lightweight Python script to automatically sync every subscribed community in the background. This script is set up as a cron job that runs every 6 hours. This script first queries r1b.it’s local PostgreSQL database to gather a unique list of every remote community local users are subscribed to. For each community it finds, the script targets Lemmy’s resolve_object API endpoint using the community’s full actor URL to refresh its metadata and maintain connection health. To keep this script from turning into a DDOS as r1b.it grows, it shuffles the community list to spread instances out and has a polite randomized pause between each request. Additionally, I plan to remove this script entirely if r1b.it ever gets big enough to federate itself naturally. py #!/usr/bin/env python3 import subprocess import urllib.parse import urllib.request import time import random LOCAL_DOMAIN = “https://r1b.it/” DB_CONTAINER = “REDACTED” DB_USER = “REDACTED” DB_NAME = “REDACTED” SQL_QUERY = “”" SELECT DISTINCT c.actor_id FROM community_follower cf JOIN person p ON cf.person_id = p.id JOIN community c ON cf.community_id = c.id WHERE p.local = true AND c.local = false; “”" def get_subscriptions(): cmd = [ “docker”, “exec”, “-i”, DB_CONTAINER, “psql”, “-U”, DB_USER, “-d”, DB_NAME, “-t”, “-A”, “-c”, SQL_QUERY ] try: res = subprocess.run(cmd, capture_output=True, text=True, check=True) return [line.strip() for line in res.stdout.splitlines() if line.strip()] except Exception: return [] def resolve_community(actor_id): encoded = urllib.parse.quote(actor_id, safe=“”) api_url = f"{LOCAL_DOMAIN}/api/v3/resolve_object?q={encoded}" req = urllib.request.Request( api_url, headers={“Accept”: “application/json”, “User-Agent”: “LemmyAutoSync/1.0”} ) try: with urllib.request.urlopen(req, timeout=10) as resp: return resp.status except urllib.error.HTTPError as e: return e.code except Exception: return 500 def main(): communities = get_subscriptions() if not communities: return print(f"Found {len(communities)} unique remote subscriptions") random.shuffle(communities) for actor_id in communities: status = resolve_community(actor_id) if status == 200: print(f"{actor_id} FEDERATED") elif status == 400: print(f"{actor_id} ALREADY FEDERATED") else: print(f"{actor_id} FAILED ({status)") # Polite randomized pause time.sleep(random.uniform(1, 5)) print(“Sync complete.”) if __name__ == “__main__”: main()