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

remove fname retry

Browse Source
This commit is contained in:
Aditi Srinivasan
2025-01-17 11:11:35 -05:00
parent 24b4068c40
commit 5a603de958
1 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
apps/hubble/src/storage/engine/index.ts
View File

@@ -1038,17 +1038,17 @@ class Engine extends TypedEmitter<EngineEvents> {
const result = await ResultAsync.fromPromise(this._userDataStore.getUserNameProof(name), (e) => e as HubError);
if (result.isErr() && result.error.errCode === "not_found" && retries > 0 && this._fNameRegistryEventsProvider) {
const rateLimitResult = await ResultAsync.fromPromise(
this._fNameRetryRateLimiter.consume(0),
() => new HubError("unavailable", "Too many requests to fName server"),
);
if (rateLimitResult.isErr()) {
return err(rateLimitResult.error);
}
await this._fNameRegistryEventsProvider.retryTransferByName(name);
return this.getUserNameProof(name, retries - 1);
}
// if (result.isErr() && result.error.errCode === "not_found" && retries > 0 && this._fNameRegistryEventsProvider) {
// const rateLimitResult = await ResultAsync.fromPromise(
// this._fNameRetryRateLimiter.consume(0),
// () => new HubError("unavailable", "Too many requests to fName server"),
// );
// if (rateLimitResult.isErr()) {
// return err(rateLimitResult.error);
// }
// await this._fNameRegistryEventsProvider.retryTransferByName(name);
// return this.getUserNameProof(name, retries - 1);
// }
return result;
}