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..8d1cd38 100644 --- a/src/pubsub/publisher/event-interleaver.ts +++ b/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