From 85482b7d13701ffb3cb8a3702572e7fa08793be3 Mon Sep 17 00:00:00 2001
From: 0xthrpw <0xthrpw@gmail.com>
Date: Fri, 12 Jul 2024 10:06:56 -0400
Subject: [PATCH] timings for event loop

---
 .../users/followers/create_function__get_unique_followers.sql   | 1 +
 src/pubsub/publisher/contract-event-publisher.ts                | 2 +-
 src/pubsub/publisher/event-interleaver.ts                       | 2 ++
 3 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/db/queries/api/v1/users/followers/create_function__get_unique_followers.sql b/db/queries/api/v1/users/followers/create_function__get_unique_followers.sql
index 4358de4..e8cd005 100644
--- a/db/queries/api/v1/users/followers/create_function__get_unique_followers.sql
+++ b/db/queries/api/v1/users/followers/create_function__get_unique_followers.sql
@@ -114,6 +114,7 @@ BEGIN
         v.record_type,
         v.record_data,
         v.tags,
+        v.updated_at,
         following_info.is_following,
         following_info.is_blocked,
         following_info.is_muted
diff --git a/src/pubsub/publisher/contract-event-publisher.ts b/src/pubsub/publisher/contract-event-publisher.ts
index d53b248..7bab474 100644
--- a/src/pubsub/publisher/contract-event-publisher.ts
+++ b/src/pubsub/publisher/contract-event-publisher.ts
@@ -60,7 +60,7 @@ export class ContractEventPublisher implements EventPublisher {
     let i = 0
     const logs: Log[] = []
     for (const eventSignature of eventSignatures) {
-      await sleep(2_500)
+      await sleep(500)
       console.log(
         `Fetching historical logs for ${this.contractName} ${eventSignature} (${++i}/${eventSignatures.length})`
       )
diff --git a/src/pubsub/publisher/event-interleaver.ts b/src/pubsub/publisher/event-interleaver.ts
index 8caa53b..056259e 100644
--- a/src/pubsub/publisher/event-interleaver.ts
+++ b/src/pubsub/publisher/event-interleaver.ts
@@ -3,6 +3,7 @@ import { logger } from '#/logger'
 import { type Event, compareEvents } from '#/pubsub/event'
 import type { EventSubscriber } from '#/pubsub/subscriber/interface'
 import type { EventPublisher } from './interface'
+import { sleep } from '#/utilities/index'
 
 type ReceivedEvent = {
   event: Event
@@ -165,6 +166,7 @@ export class EventInterleaver implements EventPublisher, EventSubscriber {
         await this.#propagateBatch(batch)
         batch = []
       }
+      await sleep(1000)
     }
 
     // Propagate any remaining events in the last batch