Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

WIP: snapchain migration #2443

Draft
wants to merge 11 commits into
base: main
Choose a base branch
from
+1,130 −156
Draft

WIP: snapchain migration #2443

Changes from 1 commit
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
d9a485d
migration
aditiharini Dec 11, 2024
e478d68
improve logging
aditiharini Dec 16, 2024
90db126
better logging and support customizations to messages submitted
aditiharini Dec 19, 2024
12fc912
enable onchain events ingestion with stop block option
aditiharini Dec 23, 2024
3542a4e
Initialize the sync engine so merkle trie is also initialized
sanjayprabhu Dec 23, 2024
5ef759c
support stopping fname transfer at specified id
aditiharini Jan 2, 2025
8bce95f
update logger to not crash
aditiharini Jan 9, 2025
a942230
reduce onchain event consumption
aditiharini Jan 13, 2025
a431a7d
make prune messages more frequent
aditiharini Jan 13, 2025
24b4068
remove rpc server rate limits
aditiharini Jan 15, 2025
5a603de
remove fname retry
aditiharini Jan 17, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
remove fname retry
@aditiharini
aditiharini committed Jan 22, 2025
commit 5a603de958c5d33876f3101f651c2ba34a47f5a8
22 changes: 11 additions & 11 deletions apps/hubble/src/storage/engine/index.ts
View file
Original file line number Diff line number Diff line change
@@ -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;
}