Merge pull request #15 from ethereumfollowprotocol/missing-events-and…

…-migrations

timings for event loop

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

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})`
       )

src/pubsub/publisher/event-interleaver.ts

@@ -2,6 +2,7 @@ import BinaryHeap from 'heap-js'
 import { logger } from '#/logger'
 import { type Event, compareEvents } from '#/pubsub/event'
 import type { EventSubscriber } from '#/pubsub/subscriber/interface'
+import { sleep } from '#/utilities/index'
 import type { EventPublisher } from './interface'
 
 type ReceivedEvent = {
@@ -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