Schedule a job for each domain instead of running all in one

funkwhale_network/cli.py

@@ -152,22 +152,22 @@ async def launch_domain_poll(session, domain):
 
 
 @cli.command()
-@click.argument("domain", type=str, nargs=-1)
+@click.argument("domains", type=str, nargs=-1)
 @async_command
-async def poll(domain):
+async def poll(domains):
     """
     Retrieve and store data for the specified domains.
     """
-    from . import crawler, worker
+    from . import crawler
 
-    if not domain:
-        click.echo("Polling all domains…")
-        crawler = worker.Crawler()
-        return await crawler.poll_all()
+    if not domains:
+        async with DB() as db:
+            domains_db = await db.get_all_domains()
+            domains = [d["name"] for d in domains_db]
 
     kwargs = crawler.get_session_kwargs()
     async with aiohttp.ClientSession(**kwargs) as session:
-        tasks = [launch_domain_poll(session, d) for d in domain]
+        tasks = [launch_domain_poll(session, d) for d in domains]
         return await asyncio.wait(tasks)