github/hub-monorepo
1
1
Fork 0
mirror of https://github.com/farcasterxyz/hub-monorepo.git synced 2026-04-18 03:00:22 -04:00
Code Issues Packages Projects Releases Wiki Activity

chore: Remove some unnecessary log statements (#1206)

Browse Source
This commit is contained in:
adityapk00
2023-08-01 12:50:03 -07:00
committed by GitHub
parent 2e4898d458
commit 7b66e6d2d2
1 changed files with 0 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
apps/hubble/src/rpc/server.ts
View File

@@ -246,7 +246,6 @@ export default class Server {
private rpcUsers: RpcUsers;
private submitMessageRateLimiter: RateLimiterMemory;
private syncSnapshotRateLimiter: RateLimiterMemory;
private subscribeIpLimiter = new IpConnectionLimiter(SUBSCRIBE_PERIP_LIMIT, SUBSCRIBE_GLOBAL_LIMIT);
constructor(
@@ -286,12 +285,6 @@ export default class Server {
points: rateLimitPerMinute,
duration: 60,
});
// Rate limit sync status to 2 per minute
this.syncSnapshotRateLimiter = new RateLimiterMemory({
points: 2,
duration: 60,
});
}
async start(ip = "0.0.0.0", port = 0): Promise<number> {
@@ -519,13 +512,6 @@ export default class Server {
const request = call.request;
(async () => {
const rateLimitResult = await rateLimitByIp(peer, this.syncSnapshotRateLimiter);
if (rateLimitResult.isErr()) {
callback(toServiceError(rateLimitResult.error));
logger.warn({ err: rateLimitResult.error }, `RPC call: Rate limit exceeded for ${peer}`);
return;
}
const rootHash = (await this.syncEngine?.trie.rootHash()) ?? "";
const snapshot = await this.syncEngine?.getSnapshotByPrefix(request.prefix);
snapshot?.match(
@@ -537,11 +523,9 @@ export default class Server {
excludedHashes: snapshot.excludedHashes,
});
callback(null, snapshotResponse);
log.info({ snapshotResponse }, `RPC call: Sending snapshot response to ${peer}`);
},
(err: HubError) => {
callback(toServiceError(err));
log.error({ err }, `RPC call: Error sending snapshot response to ${peer}`);
},
);
})();