feat: refactor protobufs and utils to remove grpc-js dependency

.changeset/honest-news-own.md

@@ -0,0 +1,10 @@
+---
+'@farcaster/protobufs': minor
+'@farcaster/hub-web': minor
+'@farcaster/utils': minor
+'@farcaster/hub-nodejs': patch
+'@farcaster/hubble': patch
+---
+
+remove grpc-js dependency from protobufs, refactor hubble to use hub-nodejs
+hub-web to use @farcaster/protobufs and utils

apps/hubble/package.json

@@ -47,8 +47,7 @@
   "dependencies": {
     "@chainsafe/libp2p-gossipsub": "6.1.0",
     "@chainsafe/libp2p-noise": "^11.0.0 ",
-    "@farcaster/protobufs": "0.1.11",
-    "@farcaster/utils": "0.4.0",
+    "@farcaster/hub-nodejs": "^0.6.0",
     "@grpc/grpc-js": "~1.8.7",
     "@libp2p/interface-connection": "^3.0.2",
     "@libp2p/interface-peer-id": "^2.0.0",

apps/hubble/src/cli.ts

@@ -1,5 +1,5 @@
 #!/usr/bin/env node
-import { FarcasterNetwork } from '@farcaster/protobufs';
+import { FarcasterNetwork } from '@farcaster/hub-nodejs';
 import { PeerId } from '@libp2p/interface-peer-id';
 import { createEd25519PeerId, createFromProtobuf, exportToProtobuf } from '@libp2p/peer-id-factory';
 import { Command } from 'commander';

apps/hubble/src/console/adminCommand.ts

@@ -1,5 +1,4 @@
-import * as protobufs from '@farcaster/protobufs';
-import { AdminRpcClient } from '@farcaster/utils';
+import { AdminRpcClient, Empty } from '@farcaster/hub-nodejs';
 import { ConsoleCommandInterface } from './console';
 
 export class AdminCommand implements ConsoleCommandInterface {
@@ -21,15 +20,15 @@ export class AdminCommand implements ConsoleCommandInterface {
   object() {
     return {
       rebuildSyncTrie: async () => {
-        const result = await this.adminClient.rebuildSyncTrie(protobufs.Empty.create());
+        const result = await this.adminClient.rebuildSyncTrie(Empty.create());
         return result.match(
           () => '',
           (e) => `Error: ${e}`
         );
       },
 
       deleteAllMessagesFromDb: async () => {
-        const result = await this.adminClient.deleteAllMessagesFromDb(protobufs.Empty.create());
+        const result = await this.adminClient.deleteAllMessagesFromDb(Empty.create());
         return result.match(
           () => '',
           (e) => `Error: ${e}`

apps/hubble/src/console/console.ts

@@ -1,5 +1,11 @@
-import { Empty, Metadata } from '@farcaster/protobufs';
-import { getAdminRpcClient, getAuthMetadata, getInsecureHubRpcClient, getSSLHubRpcClient } from '@farcaster/utils';
+import {
+  Empty,
+  Metadata,
+  getAdminRpcClient,
+  getAuthMetadata,
+  getInsecureHubRpcClient,
+  getSSLHubRpcClient,
+} from '@farcaster/hub-nodejs';
 import path from 'path';
 import * as repl from 'repl';
 import { ADMIN_SERVER_PORT } from '~/rpc/adminServer';

apps/hubble/src/console/genCommand.ts

@@ -1,5 +1,12 @@
-import * as protobufs from '@farcaster/protobufs';
-import { AdminRpcClient, Factories, getAuthMetadata, HubRpcClient } from '@farcaster/utils';
+import {
+  AdminRpcClient,
+  Factories,
+  getAuthMetadata,
+  HubRpcClient,
+  Metadata,
+  FarcasterNetwork,
+  Message,
+} from '@farcaster/hub-nodejs';
 import { ConsoleCommandInterface } from './console';
 
 // We use console.log() in this file, so we disable the eslint rule. This is the REPL console, after all!
@@ -37,12 +44,12 @@ export class GenCommand implements ConsoleCommandInterface {
     return {
       submitMessages: async (
         numMessages = 100,
-        network = protobufs.FarcasterNetwork.DEVNET,
-        username?: string | protobufs.Metadata,
+        network = FarcasterNetwork.DEVNET,
+        username?: string | Metadata,
         password?: string
       ): Promise<string | SubmitStats> => {
         // Submit messages might need a username/password
-        let metadata = new protobufs.Metadata();
+        let metadata = new Metadata();
         if (username && typeof username !== 'string') {
           metadata = username;
         } else if (username && password) {
@@ -83,7 +90,7 @@ export class GenCommand implements ConsoleCommandInterface {
           return `Failed to submit signer add message for fid ${fid}: ${signerResult.error}`;
         }
 
-        const submitBatch = async (batch: protobufs.Message[]) => {
+        const submitBatch = async (batch: Message[]) => {
           const promises = [];
           for (const castAdd of batch) {
             promises.push(this.rpcClient.submitMessage(castAdd, metadata));

apps/hubble/src/console/protobufCommand.ts

@@ -1,5 +1,5 @@
-import * as protobufs from '@farcaster/protobufs';
-import { Factories } from '@farcaster/utils';
+import * as hub_nodejs from '@farcaster/hub-nodejs';
+import { Factories } from '@farcaster/hub-nodejs';
 import { ConsoleCommandInterface } from './console';
 
 export class ProtobufCommand implements ConsoleCommandInterface {
@@ -18,7 +18,7 @@ export class ProtobufCommand implements ConsoleCommandInterface {
         `;
   }
   object() {
-    return protobufs;
+    return hub_nodejs;
   }
 }
 

apps/hubble/src/console/rpcClientCommand.ts

@@ -1,4 +1,4 @@
-import { HubRpcClient } from '@farcaster/utils';
+import { HubRpcClient } from '@farcaster/hub-nodejs';
 import { ConsoleCommandInterface } from './console';
 
 export class RpcClientCommand implements ConsoleCommandInterface {