Skip to content

Commit a4787a5

Browse files
aditihariniaditiharini
committed
feat: add support for backfilling lend storage messages
1 parent f1f2b4c commit a4787a5

File tree

10 files changed

+402
-2
lines changed

10 files changed

+402
-2
lines changed

‎generate-protos.sh‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
PROTO_REPO=https://github.com/farcasterxyz/snapchain
22
PROTO_PATH=src/proto
3-
PROTO_REV=32fa4b1fa7e5ed32e271777d6854ee637678f4a9 # Update this if you want to generate off updated snapchain protos
3+
PROTO_REV=e634aa8789fa8196446ce1d68b459864b93a8780 # Update this if you want to generate off updated snapchain protos
44

55
TMPDIR=tmp-protogen
66
git clone $PROTO_REPO $TMPDIR

‎packages/core/src/protobufs/generated/admin_rpc.ts‎

Lines changed: 64 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,10 @@ export interface UploadSnapshotRequest {
2424
shardIndexes: number[];
2525
}
2626

27+
export interface RunOnchainEventsMigrationRequest {
28+
shardId: number;
29+
}
30+
2731
function createBaseEmpty(): Empty {
2832
return {};
2933
}
@@ -355,6 +359,66 @@ export const UploadSnapshotRequest = {
355359
},
356360
};
357361

362+
function createBaseRunOnchainEventsMigrationRequest(): RunOnchainEventsMigrationRequest {
363+
return { shardId: 0 };
364+
}
365+
366+
export const RunOnchainEventsMigrationRequest = {
367+
encode(message: RunOnchainEventsMigrationRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
368+
if (message.shardId !== 0) {
369+
writer.uint32(8).uint64(message.shardId);
370+
}
371+
return writer;
372+
},
373+
374+
decode(input: _m0.Reader | Uint8Array, length?: number): RunOnchainEventsMigrationRequest {
375+
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
376+
let end = length === undefined ? reader.len : reader.pos + length;
377+
const message = createBaseRunOnchainEventsMigrationRequest();
378+
while (reader.pos < end) {
379+
const tag = reader.uint32();
380+
switch (tag >>> 3) {
381+
case 1:
382+
if (tag != 8) {
383+
break;
384+
}
385+
386+
message.shardId = longToNumber(reader.uint64() as Long);
387+
continue;
388+
}
389+
if ((tag & 7) == 4 || tag == 0) {
390+
break;
391+
}
392+
reader.skipType(tag & 7);
393+
}
394+
return message;
395+
},
396+
397+
fromJSON(object: any): RunOnchainEventsMigrationRequest {
398+
return { shardId: isSet(object.shardId) ? Number(object.shardId) : 0 };
399+
},
400+
401+
toJSON(message: RunOnchainEventsMigrationRequest): unknown {
402+
const obj: any = {};
403+
message.shardId !== undefined && (obj.shardId = Math.round(message.shardId));
404+
return obj;
405+
},
406+
407+
create<I extends Exact<DeepPartial<RunOnchainEventsMigrationRequest>, I>>(
408+
base?: I,
409+
): RunOnchainEventsMigrationRequest {
410+
return RunOnchainEventsMigrationRequest.fromPartial(base ?? {});
411+
},
412+
413+
fromPartial<I extends Exact<DeepPartial<RunOnchainEventsMigrationRequest>, I>>(
414+
object: I,
415+
): RunOnchainEventsMigrationRequest {
416+
const message = createBaseRunOnchainEventsMigrationRequest();
417+
message.shardId = object.shardId ?? 0;
418+
return message;
419+
},
420+
};
421+
358422
declare var self: any | undefined;
359423
declare var window: any | undefined;
360424
declare var global: any | undefined;

‎packages/core/src/protobufs/generated/request_response.ts‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,7 @@ export interface ShardInfo {
134134
approxSize: number;
135135
blockDelay: number;
136136
mempoolSize: number;
137+
numOnchainEvents: number;
137138
}
138139

139140
export interface GetInfoRequest {
@@ -806,6 +807,7 @@ function createBaseShardInfo(): ShardInfo {
806807
approxSize: 0,
807808
blockDelay: 0,
808809
mempoolSize: 0,
810+
numOnchainEvents: 0,
809811
};
810812
}
811813

@@ -832,6 +834,9 @@ export const ShardInfo = {
832834
if (message.mempoolSize !== 0) {
833835
writer.uint32(56).uint64(message.mempoolSize);
834836
}
837+
if (message.numOnchainEvents !== 0) {
838+
writer.uint32(64).uint64(message.numOnchainEvents);
839+
}
835840
return writer;
836841
},
837842

@@ -891,6 +896,13 @@ export const ShardInfo = {
891896

892897
message.mempoolSize = longToNumber(reader.uint64() as Long);
893898
continue;
899+
case 8:
900+
if (tag != 64) {
901+
break;
902+
}
903+
904+
message.numOnchainEvents = longToNumber(reader.uint64() as Long);
905+
continue;
894906
}
895907
if ((tag & 7) == 4 || tag == 0) {
896908
break;
@@ -909,6 +921,7 @@ export const ShardInfo = {
909921
approxSize: isSet(object.approxSize) ? Number(object.approxSize) : 0,
910922
blockDelay: isSet(object.blockDelay) ? Number(object.blockDelay) : 0,
911923
mempoolSize: isSet(object.mempoolSize) ? Number(object.mempoolSize) : 0,
924+
numOnchainEvents: isSet(object.numOnchainEvents) ? Number(object.numOnchainEvents) : 0,
912925
};
913926
},
914927

@@ -921,6 +934,7 @@ export const ShardInfo = {
921934
message.approxSize !== undefined && (obj.approxSize = Math.round(message.approxSize));
922935
message.blockDelay !== undefined && (obj.blockDelay = Math.round(message.blockDelay));
923936
message.mempoolSize !== undefined && (obj.mempoolSize = Math.round(message.mempoolSize));
937+
message.numOnchainEvents !== undefined && (obj.numOnchainEvents = Math.round(message.numOnchainEvents));
924938
return obj;
925939
},
926940

@@ -937,6 +951,7 @@ export const ShardInfo = {
937951
message.approxSize = object.approxSize ?? 0;
938952
message.blockDelay = object.blockDelay ?? 0;
939953
message.mempoolSize = object.mempoolSize ?? 0;
954+
message.numOnchainEvents = object.numOnchainEvents ?? 0;
940955
return message;
941956
},
942957
};

‎packages/hub-nodejs/src/generated/admin_rpc.ts‎

Lines changed: 90 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,10 @@ export interface UploadSnapshotRequest {
3838
shardIndexes: number[];
3939
}
4040

41+
export interface RunOnchainEventsMigrationRequest {
42+
shardId: number;
43+
}
44+
4145
function createBaseEmpty(): Empty {
4246
return {};
4347
}
@@ -369,6 +373,66 @@ export const UploadSnapshotRequest = {
369373
},
370374
};
371375

376+
function createBaseRunOnchainEventsMigrationRequest(): RunOnchainEventsMigrationRequest {
377+
return { shardId: 0 };
378+
}
379+
380+
export const RunOnchainEventsMigrationRequest = {
381+
encode(message: RunOnchainEventsMigrationRequest, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
382+
if (message.shardId !== 0) {
383+
writer.uint32(8).uint64(message.shardId);
384+
}
385+
return writer;
386+
},
387+
388+
decode(input: _m0.Reader | Uint8Array, length?: number): RunOnchainEventsMigrationRequest {
389+
const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
390+
let end = length === undefined ? reader.len : reader.pos + length;
391+
const message = createBaseRunOnchainEventsMigrationRequest();
392+
while (reader.pos < end) {
393+
const tag = reader.uint32();
394+
switch (tag >>> 3) {
395+
case 1:
396+
if (tag != 8) {
397+
break;
398+
}
399+
400+
message.shardId = longToNumber(reader.uint64() as Long);
401+
continue;
402+
}
403+
if ((tag & 7) == 4 || tag == 0) {
404+
break;
405+
}
406+
reader.skipType(tag & 7);
407+
}
408+
return message;
409+
},
410+
411+
fromJSON(object: any): RunOnchainEventsMigrationRequest {
412+
return { shardId: isSet(object.shardId) ? Number(object.shardId) : 0 };
413+
},
414+
415+
toJSON(message: RunOnchainEventsMigrationRequest): unknown {
416+
const obj: any = {};
417+
message.shardId !== undefined && (obj.shardId = Math.round(message.shardId));
418+
return obj;
419+
},
420+
421+
create<I extends Exact<DeepPartial<RunOnchainEventsMigrationRequest>, I>>(
422+
base?: I,
423+
): RunOnchainEventsMigrationRequest {
424+
return RunOnchainEventsMigrationRequest.fromPartial(base ?? {});
425+
},
426+
427+
fromPartial<I extends Exact<DeepPartial<RunOnchainEventsMigrationRequest>, I>>(
428+
object: I,
429+
): RunOnchainEventsMigrationRequest {
430+
const message = createBaseRunOnchainEventsMigrationRequest();
431+
message.shardId = object.shardId ?? 0;
432+
return message;
433+
},
434+
};
435+
372436
export type AdminServiceService = typeof AdminServiceService;
373437
export const AdminServiceService = {
374438
submitOnChainEvent: {
@@ -417,6 +481,16 @@ export const AdminServiceService = {
417481
responseSerialize: (value: Empty) => Buffer.from(Empty.encode(value).finish()),
418482
responseDeserialize: (value: Buffer) => Empty.decode(value),
419483
},
484+
runOnchainEventsMigration: {
485+
path: "/AdminService/RunOnchainEventsMigration",
486+
requestStream: false,
487+
responseStream: false,
488+
requestSerialize: (value: RunOnchainEventsMigrationRequest) =>
489+
Buffer.from(RunOnchainEventsMigrationRequest.encode(value).finish()),
490+
requestDeserialize: (value: Buffer) => RunOnchainEventsMigrationRequest.decode(value),
491+
responseSerialize: (value: Empty) => Buffer.from(Empty.encode(value).finish()),
492+
responseDeserialize: (value: Buffer) => Empty.decode(value),
493+
},
420494
} as const;
421495

422496
export interface AdminServiceServer extends UntypedServiceImplementation {
@@ -425,6 +499,7 @@ export interface AdminServiceServer extends UntypedServiceImplementation {
425499
uploadSnapshot: handleUnaryCall<UploadSnapshotRequest, Empty>;
426500
retryOnchainEvents: handleUnaryCall<RetryOnchainEventsRequest, Empty>;
427501
retryFnameEvents: handleUnaryCall<RetryFnameRequest, Empty>;
502+
runOnchainEventsMigration: handleUnaryCall<RunOnchainEventsMigrationRequest, Empty>;
428503
}
429504

430505
export interface AdminServiceClient extends Client {
@@ -503,6 +578,21 @@ export interface AdminServiceClient extends Client {
503578
options: Partial<CallOptions>,
504579
callback: (error: ServiceError | null, response: Empty) => void,
505580
): ClientUnaryCall;
581+
runOnchainEventsMigration(
582+
request: RunOnchainEventsMigrationRequest,
583+
callback: (error: ServiceError | null, response: Empty) => void,
584+
): ClientUnaryCall;
585+
runOnchainEventsMigration(
586+
request: RunOnchainEventsMigrationRequest,
587+
metadata: Metadata,
588+
callback: (error: ServiceError | null, response: Empty) => void,
589+
): ClientUnaryCall;
590+
runOnchainEventsMigration(
591+
request: RunOnchainEventsMigrationRequest,
592+
metadata: Metadata,
593+
options: Partial<CallOptions>,
594+
callback: (error: ServiceError | null, response: Empty) => void,
595+
): ClientUnaryCall;
506596
}
507597

508598
export const AdminServiceClient = makeGenericClientConstructor(AdminServiceService, "AdminService") as unknown as {

‎packages/hub-nodejs/src/generated/request_response.ts‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -134,6 +134,7 @@ export interface ShardInfo {
134134
approxSize: number;
135135
blockDelay: number;
136136
mempoolSize: number;
137+
numOnchainEvents: number;
137138
}
138139

139140
export interface GetInfoRequest {
@@ -806,6 +807,7 @@ function createBaseShardInfo(): ShardInfo {
806807
approxSize: 0,
807808
blockDelay: 0,
808809
mempoolSize: 0,
810+
numOnchainEvents: 0,
809811
};
810812
}
811813

@@ -832,6 +834,9 @@ export const ShardInfo = {
832834
if (message.mempoolSize !== 0) {
833835
writer.uint32(56).uint64(message.mempoolSize);
834836
}
837+
if (message.numOnchainEvents !== 0) {
838+
writer.uint32(64).uint64(message.numOnchainEvents);
839+
}
835840
return writer;
836841
},
837842

@@ -891,6 +896,13 @@ export const ShardInfo = {
891896

892897
message.mempoolSize = longToNumber(reader.uint64() as Long);
893898
continue;
899+
case 8:
900+
if (tag != 64) {
901+
break;
902+
}
903+
904+
message.numOnchainEvents = longToNumber(reader.uint64() as Long);
905+
continue;
894906
}
895907
if ((tag & 7) == 4 || tag == 0) {
896908
break;
@@ -909,6 +921,7 @@ export const ShardInfo = {
909921
approxSize: isSet(object.approxSize) ? Number(object.approxSize) : 0,
910922
blockDelay: isSet(object.blockDelay) ? Number(object.blockDelay) : 0,
911923
mempoolSize: isSet(object.mempoolSize) ? Number(object.mempoolSize) : 0,
924+
numOnchainEvents: isSet(object.numOnchainEvents) ? Number(object.numOnchainEvents) : 0,
912925
};
913926
},
914927

@@ -921,6 +934,7 @@ export const ShardInfo = {
921934
message.approxSize !== undefined && (obj.approxSize = Math.round(message.approxSize));
922935
message.blockDelay !== undefined && (obj.blockDelay = Math.round(message.blockDelay));
923936
message.mempoolSize !== undefined && (obj.mempoolSize = Math.round(message.mempoolSize));
937+
message.numOnchainEvents !== undefined && (obj.numOnchainEvents = Math.round(message.numOnchainEvents));
924938
return obj;
925939
},
926940

@@ -937,6 +951,7 @@ export const ShardInfo = {
937951
message.approxSize = object.approxSize ?? 0;
938952
message.blockDelay = object.blockDelay ?? 0;
939953
message.mempoolSize = object.mempoolSize ?? 0;
954+
message.numOnchainEvents = object.numOnchainEvents ?? 0;
940955
return message;
941956
},
942957
};

‎packages/hub-nodejs/src/generated/rpc.ts‎

Lines changed: 25 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -448,6 +448,15 @@ export const HubServiceService = {
448448
responseSerialize: (value: MessagesResponse) => Buffer.from(MessagesResponse.encode(value).finish()),
449449
responseDeserialize: (value: Buffer) => MessagesResponse.decode(value),
450450
},
451+
getAllLendStorageMessagesByFid: {
452+
path: "/HubService/GetAllLendStorageMessagesByFid",
453+
requestStream: false,
454+
responseStream: false,
455+
requestSerialize: (value: FidTimestampRequest) => Buffer.from(FidTimestampRequest.encode(value).finish()),
456+
requestDeserialize: (value: Buffer) => FidTimestampRequest.decode(value),
457+
responseSerialize: (value: MessagesResponse) => Buffer.from(MessagesResponse.encode(value).finish()),
458+
responseDeserialize: (value: Buffer) => MessagesResponse.decode(value),
459+
},
451460
getTrieMetadataByPrefix: {
452461
path: "/HubService/GetTrieMetadataByPrefix",
453462
requestStream: false,
@@ -515,6 +524,7 @@ export interface HubServiceServer extends UntypedServiceImplementation {
515524
getAllVerificationMessagesByFid: handleUnaryCall<FidTimestampRequest, MessagesResponse>;
516525
getAllUserDataMessagesByFid: handleUnaryCall<FidTimestampRequest, MessagesResponse>;
517526
getAllLinkMessagesByFid: handleUnaryCall<FidTimestampRequest, MessagesResponse>;
527+
getAllLendStorageMessagesByFid: handleUnaryCall<FidTimestampRequest, MessagesResponse>;
518528
getTrieMetadataByPrefix: handleUnaryCall<TrieNodeMetadataRequest, TrieNodeMetadataResponse>;
519529
}
520530

@@ -1113,6 +1123,21 @@ export interface HubServiceClient extends Client {
11131123
options: Partial<CallOptions>,
11141124
callback: (error: ServiceError | null, response: MessagesResponse) => void,
11151125
): ClientUnaryCall;
1126+
getAllLendStorageMessagesByFid(
1127+
request: FidTimestampRequest,
1128+
callback: (error: ServiceError | null, response: MessagesResponse) => void,
1129+
): ClientUnaryCall;
1130+
getAllLendStorageMessagesByFid(
1131+
request: FidTimestampRequest,
1132+
metadata: Metadata,
1133+
callback: (error: ServiceError | null, response: MessagesResponse) => void,
1134+
): ClientUnaryCall;
1135+
getAllLendStorageMessagesByFid(
1136+
request: FidTimestampRequest,
1137+
metadata: Metadata,
1138+
options: Partial<CallOptions>,
1139+
callback: (error: ServiceError | null, response: MessagesResponse) => void,
1140+
): ClientUnaryCall;
11161141
getTrieMetadataByPrefix(
11171142
request: TrieNodeMetadataRequest,
11181143
callback: (error: ServiceError | null, response: TrieNodeMetadataResponse) => void,

0 commit comments

Comments
 (0)