add docs!

Author: fjpacheco

app/clock.py

@@ -1,7 +1,7 @@
-import asyncio
 import os
-from datetime import datetime
+import asyncio
 import random
+from datetime import datetime
 from arq import create_pool
 from arq.connections import RedisSettings
 from apscheduler.schedulers.asyncio import AsyncIOScheduler
@@ -10,18 +10,21 @@
 
 async def tick():
     now = datetime.now()
-    id_device = random.randint(0, 99999)
-    logger.info(f"[{id_device} {now}] Tock! Enqueuing job")
-    await redis.enqueue_job('heavy_endpoint', id_device)
-    logger.info(f"[{id_device} {now}] Job enqueued")
+    random_int = random.randint(0, 99999)
+    logger.info(f"[{random_int}] [{now}] Tock! Enqueuing job")
+    await redis.enqueue_job('heavy_endpoint', random_int)
+    logger.info(f"[{random_int}] [{now}] Job enqueued")
 
 if __name__ == '__main__':
-    logger = init_logging('clock')
     INTERVAL_SCHEDULE_SECS = int(os.environ.get('INTERVAL_SCHEDULE_SECS', 5))
+
+    logger = init_logging('clock')
     logger.info('Starting scheduler. Interval %s' % INTERVAL_SCHEDULE_SECS)
+
     scheduler = AsyncIOScheduler()
     scheduler.add_job(tick, 'interval', seconds=INTERVAL_SCHEDULE_SECS)
     scheduler.start()
+
     redis_url = os.environ.get('REDIS_URL')
     redis = asyncio.get_event_loop() \
         .run_until_complete(create_pool(RedisSettings.from_dsn(redis_url)))

app/worker.py

@@ -24,20 +24,28 @@ async def shutdown(ctx: Worker) -> None:
     ctx['users_repository'].shutdown()
 
 
-async def heavy_endpoint(ctx: Worker, id_device: str):
+async def heavy_endpoint(ctx: Worker, random_value: str):
     now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-    logger.info(f"[{id_device} {now}] Calling heavy endpoint...")
-    session: AsyncClient = ctx['session']
-    user_repository: UsersRepository = ctx['users_repository']
-    user_id_one = user_repository.get_user(1)
-    logger.info(f"[{id_device} {now}] User 1: {user_id_one}")
+    logger.info(f"[{random_value}] [{now}] Calling heavy endpoint...")
+    # Busco simular llamado a un endpoint que me TARDE MUCHISIMO
+    # en responder. En este caso, 10 segs.
+    # (mismo puede ser un llamado LENTO a una base de datos, etc.)
     secs_delay = 10
+    session: AsyncClient = ctx['session']
     url = 'https://httpbin.org/delay/%s' % secs_delay
     response = await session.get(url)
     now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
-    logger.info(f'[{id_device} {now}] Succesfuly called'
+    logger.info(f'[{random_value}] [{now}] Succesfuly called'
                 f' heavy endpoint. Response: {response.json()}')
 
+    # Tambien podemos acceder a la capa de repositorio...
+    # (aquí es donde habría que consultar al CRUD de Alarmas,
+    #  buscar si en el minuto actual hay alguna alarma
+    #  de algún usuario, y si la hay, enviar una notificación)
+    user_repository: UsersRepository = ctx['users_repository']
+    user_id_one = user_repository.get_user(1)
+    logger.info(f"[{random_value}] [{now}] User 1: {user_id_one}")
+
 
 class WorkerSettings:
     functions = [heavy_endpoint]