github/hub-monorepo
1
1
Fork 0
mirror of https://github.com/farcasterxyz/hub-monorepo.git synced 2026-01-10 05:38:07 -05:00
Code Issues Packages Projects Releases Wiki Activity

remove rpc server rate limits

Browse Source
This commit is contained in:
Aditi Srinivasan
2025-01-15 11:39:14 -05:00
parent a431a7d4d9
commit 24b4068c40
1 changed files with 20 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -933,18 +933,18 @@ export default class Server {
getOnChainEvents: async (call, callback) => this.getOnChainEventsRPC(call, callback),
submitMessage: async (call, callback) => {
// Identify peer that is calling, if available. This is used for rate limiting.
const peer = Result.fromThrowable(
() => call.getPeer(),
(e) => e,
)().unwrapOr("unavailable");
// const peer = Result.fromThrowable(
// () => call.getPeer(),
// (e) => e,
// )().unwrapOr("unavailable");
statsd().increment("rpc.open_request_count", { method: "submitMessage" });
const rateLimitResult = await rateLimitByIp(peer, this.submitMessageRateLimiter);
if (rateLimitResult.isErr()) {
logger.warn({ peer }, "submitMessage rate limited");
callback(toServiceError(new HubError("unavailable", "API rate limit exceeded")));
return;
}
// const rateLimitResult = await rateLimitByIp(peer, this.submitMessageRateLimiter);
// if (rateLimitResult.isErr()) {
// logger.warn({ peer }, "submitMessage rate limited");
// callback(toServiceError(new HubError("unavailable", "API rate limit exceeded")));
// return;
// }
// Authentication
const authResult = authenticateUser(call.metadata, this.rpcUsers);
@@ -972,19 +972,19 @@ export default class Server {
},
submitBulkMessages: async (call, callback) => {
// Identify peer that is calling, if available. This is used for rate limiting.
const peer = Result.fromThrowable(
() => call.getPeer(),
(e) => e,
)().unwrapOr("unavailable");
// const peer = Result.fromThrowable(
// () => call.getPeer(),
// (e) => e,
// )().unwrapOr("unavailable");
statsd().increment("rpc.open_request_count", { method: "submitBulkMessages" });
// Check for rate limits
const rateLimitResult = await rateLimitByIp(peer, this.submitMessageRateLimiter);
if (rateLimitResult.isErr()) {
logger.warn({ peer }, "submitBulkMessages rate limited");
callback(toServiceError(new HubError("unavailable", "API rate limit exceeded")));
return;
}
// const rateLimitResult = await rateLimitByIp(peer, this.submitMessageRateLimiter);
// if (rateLimitResult.isErr()) {
// logger.warn({ peer }, "submitBulkMessages rate limited");
// callback(toServiceError(new HubError("unavailable", "API rate limit exceeded")));
// return;
// }
// Authentication
const authResult = authenticateUser(call.metadata, this.rpcUsers);