feat: support storage lending (#2650)

## Why is this change needed?

All the changes required to submit storage lending messages to the
protocol.

## Merge Checklist

_Choose all relevant options below by adding an `x` now or at any time
before submitting for review_

- [x] PR title adheres to the [conventional
commits](https://www.conventionalcommits.org/en/v1.0.0/) standard
- [x] PR has a
[changeset](https://github.com/farcasterxyz/hub-monorepo/blob/main/CONTRIBUTING.md#35-adding-changesets)
- [x] PR has been tagged with a change label(s) (i.e. documentation,
feature, bugfix, or chore)
- [ ] PR includes
[documentation](https://github.com/farcasterxyz/hub-monorepo/blob/main/CONTRIBUTING.md#32-writing-docs)
if necessary.

<!-- start pr-codex -->

---

## PR-Codex overview
This PR introduces support for storage lending in the system, including
new message types and validation for lending operations.

### Detailed summary
- Added support for `LendStorage` message type in
`packages/shuttle/src/utils.ts`.
- Introduced `LendStorageData` and `LendStorageMessage` types in
`packages/core/src/protobufs/types.ts`.
- Updated `StoreType` to include `STORAGE_LENDS`.
- Implemented validation for lending storage in
`packages/core/src/validations.ts`.
- Enhanced `ContactInfoBody` to include `announceRpcAddress` in multiple
files.
- Updated related protobufs and message handling for `MergeMessage`
events.

> The following files were skipped due to too many changes:
`packages/core/src/protobufs/generated/request_response.ts`,
`packages/hub-web/src/generated/message.ts`,
`packages/hub-nodejs/src/generated/message.ts`,
`packages/core/src/protobufs/generated/message.ts`

> ✨ Ask PR-Codex anything about this PR by commenting with `/codex {your
question}`

<!-- end pr-codex -->

Author: aditiharini

.changeset/slimy-turtles-camp.md

@@ -0,0 +1,8 @@
+---
+"@farcaster/hub-nodejs": patch
+"@farcaster/hub-web": patch
+"@farcaster/shuttle": patch
+"@farcaster/core": patch
+---
+
+feat: support storage lending

generate-protos.sh

@@ -1,6 +1,6 @@
 PROTO_REPO=https://github.com/farcasterxyz/snapchain
 PROTO_PATH=src/proto
-PROTO_REV=82903473a69e3cb898c4cba85cbe1a71a469355f # Update this if you want to generate off updated snapchain protos
+PROTO_REV=32fa4b1fa7e5ed32e271777d6854ee637678f4a9 # Update this if you want to generate off updated snapchain protos
 
 TMPDIR=tmp-protogen
 git clone $PROTO_REPO $TMPDIR
@@ -11,7 +11,7 @@ cd ..
 
 # Determine which files you care about
 if [[ "$LIBRARY" == "core" ]]; then
-    RELEVANT_PROTOS=$(ls $TMPDIR/$PROTO_PATH/*.proto | xargs -n 1 basename | xargs -I{} echo '/defs/{}' | tr '\n' ' ')
+    RELEVANT_PROTOS="/defs/request_response.proto /defs/rpc.proto /defs/admin_rpc.proto /defs/message.proto /defs/hub_event.proto /defs/onchain_event.proto /defs/username_proof.proto"
     OUT_PATH=src/protobufs/generated
     CUSTOM_TS_PROTO_OPTS="outputServices=false"
 elif [[ "$LIBRARY" == "hub-nodejs" ]]; then

packages/core/src/builders.ts

@@ -27,6 +27,7 @@ type MessageBodyOptions = Pick<
   | "linkCompactStateBody"
   | "usernameProofBody"
   | "frameActionBody"
+  | "lendStorageBody"
 >;
 
 /** Generic Methods */
@@ -357,3 +358,22 @@ export const makeFrameActionData = (
 ): HubAsyncResult<protobufs.FrameActionData> => {
   return makeMessageData({ frameActionBody: body }, protobufs.MessageType.FRAME_ACTION, dataOptions);
 };
+
+export const makeLendStorageData = async (
+  body: protobufs.LendStorageBody,
+  dataOptions: MessageDataOptions,
+): HubAsyncResult<protobufs.LendStorageData> => {
+  return makeMessageData({ lendStorageBody: body }, protobufs.MessageType.LEND_STORAGE, dataOptions);
+};
+
+export const makeLendStorage = async (
+  body: protobufs.LendStorageBody,
+  dataOptions: MessageDataOptions,
+  signer: Signer,
+): HubAsyncResult<protobufs.LendStorageMessage> => {
+  const data = await makeLendStorageData(body, dataOptions);
+  if (data.isErr()) {
+    return err(data.error);
+  }
+  return makeMessage(data.value, signer);
+};

packages/core/src/limits.ts

@@ -35,6 +35,11 @@ const STORAGE_UNIT_DEFAULTS = {
     [StorageUnitType.UNIT_TYPE_2024]: 25,
     [StorageUnitType.UNIT_TYPE_2025]: 5,
   },
+  [StoreType.STORAGE_LENDS]: {
+    [StorageUnitType.UNIT_TYPE_LEGACY]: 1,
+    [StorageUnitType.UNIT_TYPE_2024]: 1,
+    [StorageUnitType.UNIT_TYPE_2025]: 1,
+  },
   [StoreType.NONE]: {
     [StorageUnitType.UNIT_TYPE_LEGACY]: 0,
     [StorageUnitType.UNIT_TYPE_2024]: 0,

packages/core/src/protobufs/generated/blocks.ts

@@ -37,13 +37,17 @@ export function voteTypeToJSON(object: VoteType): string {
 
 export enum BlockEventType {
   HEARTBEAT = 0,
+  MERGE_MESSAGE = 1,
 }
 
 export function blockEventTypeFromJSON(object: any): BlockEventType {
   switch (object) {
     case 0:
     case "BLOCK_EVENT_TYPE_HEARTBEAT":
       return BlockEventType.HEARTBEAT;
+    case 1:
+    case "BLOCK_EVENT_TYPE_MERGE_MESSAGE":
+      return BlockEventType.MERGE_MESSAGE;
     default:
       throw new tsProtoGlobalThis.Error("Unrecognized enum value " + object + " for enum BlockEventType");
   }
@@ -53,6 +57,8 @@ export function blockEventTypeToJSON(object: BlockEventType): string {
   switch (object) {
     case BlockEventType.HEARTBEAT:
       return "BLOCK_EVENT_TYPE_HEARTBEAT";
+    case BlockEventType.MERGE_MESSAGE:
+      return "BLOCK_EVENT_TYPE_MERGE_MESSAGE";
     default:
       throw new tsProtoGlobalThis.Error("Unrecognized enum value " + object + " for enum BlockEventType");
   }
@@ -140,13 +146,18 @@ export interface ConsensusMessage {
 export interface HeartbeatEventBody {
 }
 
+export interface MergeMessageEventBody {
+  message: Message | undefined;
+}
+
 export interface BlockEventData {
   seqnum: number;
   type: BlockEventType;
   blockNumber: number;
   eventIndex: number;
   blockTimestamp: number;
   heartbeatEventBody?: HeartbeatEventBody | undefined;
+  mergeMessageEventBody?: MergeMessageEventBody | undefined;
 }
 
 export interface BlockEvent {
@@ -1369,8 +1380,74 @@ export const HeartbeatEventBody = {
   },
 };
 
+function createBaseMergeMessageEventBody(): MergeMessageEventBody {
+  return { message: undefined };
+}
+
+export const MergeMessageEventBody = {
+  encode(message: MergeMessageEventBody, writer: _m0.Writer = _m0.Writer.create()): _m0.Writer {
+    if (message.message !== undefined) {
+      Message.encode(message.message, writer.uint32(10).fork()).ldelim();
+    }
+    return writer;
+  },
+
+  decode(input: _m0.Reader | Uint8Array, length?: number): MergeMessageEventBody {
+    const reader = input instanceof _m0.Reader ? input : _m0.Reader.create(input);
+    let end = length === undefined ? reader.len : reader.pos + length;
+    const message = createBaseMergeMessageEventBody();
+    while (reader.pos < end) {
+      const tag = reader.uint32();
+      switch (tag >>> 3) {
+        case 1:
+          if (tag != 10) {
+            break;
+          }
+
+          message.message = Message.decode(reader, reader.uint32());
+          continue;
+      }
+      if ((tag & 7) == 4 || tag == 0) {
+        break;
+      }
+      reader.skipType(tag & 7);
+    }
+    return message;
+  },
+
+  fromJSON(object: any): MergeMessageEventBody {
+    return { message: isSet(object.message) ? Message.fromJSON(object.message) : undefined };
+  },
+
+  toJSON(message: MergeMessageEventBody): unknown {
+    const obj: any = {};
+    message.message !== undefined && (obj.message = message.message ? Message.toJSON(message.message) : undefined);
+    return obj;
+  },
+
+  create<I extends Exact<DeepPartial<MergeMessageEventBody>, I>>(base?: I): MergeMessageEventBody {
+    return MergeMessageEventBody.fromPartial(base ?? {});
+  },
+
+  fromPartial<I extends Exact<DeepPartial<MergeMessageEventBody>, I>>(object: I): MergeMessageEventBody {
+    const message = createBaseMergeMessageEventBody();
+    message.message = (object.message !== undefined && object.message !== null)
+      ? Message.fromPartial(object.message)
+      : undefined;
+    return message;
+  },
+};
+
 function createBaseBlockEventData(): BlockEventData {
-  return { seqnum: 0, type: 0, blockNumber: 0, eventIndex: 0, blockTimestamp: 0, heartbeatEventBody: undefined };
+  return {
+    seqnum: 0,
+    type: 0,
+    blockNumber: 0,
+    eventIndex: 0,
+    blockTimestamp: 0,
+    heartbeatEventBody: undefined,
+    mergeMessageEventBody: undefined,
+  };
 }
 
 export const BlockEventData = {
@@ -1393,6 +1470,9 @@ export const BlockEventData = {
     if (message.heartbeatEventBody !== undefined) {
       HeartbeatEventBody.encode(message.heartbeatEventBody, writer.uint32(50).fork()).ldelim();
     }
+    if (message.mergeMessageEventBody !== undefined) {
+      MergeMessageEventBody.encode(message.mergeMessageEventBody, writer.uint32(58).fork()).ldelim();
+    }
     return writer;
   },
 
@@ -1445,6 +1525,13 @@ export const BlockEventData = {
 
           message.heartbeatEventBody = HeartbeatEventBody.decode(reader, reader.uint32());
           continue;
+        case 7:
+          if (tag != 58) {
+            break;
+          }
+
+          message.mergeMessageEventBody = MergeMessageEventBody.decode(reader, reader.uint32());
+          continue;
       }
       if ((tag & 7) == 4 || tag == 0) {
         break;
@@ -1464,6 +1551,9 @@ export const BlockEventData = {
       heartbeatEventBody: isSet(object.heartbeatEventBody)
         ? HeartbeatEventBody.fromJSON(object.heartbeatEventBody)
         : undefined,
+      mergeMessageEventBody: isSet(object.mergeMessageEventBody)
+        ? MergeMessageEventBody.fromJSON(object.mergeMessageEventBody)
+        : undefined,
     };
   },
 
@@ -1477,6 +1567,9 @@ export const BlockEventData = {
     message.heartbeatEventBody !== undefined && (obj.heartbeatEventBody = message.heartbeatEventBody
       ? HeartbeatEventBody.toJSON(message.heartbeatEventBody)
       : undefined);
+    message.mergeMessageEventBody !== undefined && (obj.mergeMessageEventBody = message.mergeMessageEventBody
+      ? MergeMessageEventBody.toJSON(message.mergeMessageEventBody)
+      : undefined);
     return obj;
   },
 
@@ -1494,6 +1587,10 @@ export const BlockEventData = {
     message.heartbeatEventBody = (object.heartbeatEventBody !== undefined && object.heartbeatEventBody !== null)
       ? HeartbeatEventBody.fromPartial(object.heartbeatEventBody)
       : undefined;
+    message.mergeMessageEventBody =
+      (object.mergeMessageEventBody !== undefined && object.mergeMessageEventBody !== null)
+        ? MergeMessageEventBody.fromPartial(object.mergeMessageEventBody)
+        : undefined;
     return message;
   },
 };