Simplify feed logic to be their own rpc functions. Remove js side grpc calls and have everything go through wasm

Author: markharding

apps/polycentric/src/common/lib/polycentric-hooks/PolycentricProvider.tsx

@@ -3,11 +3,9 @@ import useFollows from '@/src/features/follow/hooks/useFollows';
 import {
   PolycentricClient,
   createPolycentricClient,
-  setGrpcWebFetch,
   types,
   type IdentityState,
 } from '@polycentric/react-native';
-import { fetch as expoFetch } from 'expo/fetch';
 import {
   createContext,
   useCallback,
@@ -147,7 +145,6 @@ export function PolycentricProvider({
 
     (async () => {
       try {
-        setGrpcWebFetch(expoFetch);
         // PolycentricClient.initialize() guarantees a keypair exists on
         // every device. Identity (the published Identity doc) is a separate
         // concept — the onboarding gate handles creating or pairing one.

apps/polycentric/src/features/feed/hooks/useExploreFeed.ts

@@ -21,11 +21,16 @@ export function useExploreFeed(options?: {
     setIsLoading(true);
     setError(null);
     try {
-      const bundles = await client.listEvents();
+      const responses = await client.getExploreFeed({
+        identity: client.activeIdentityKey,
+        limit: options?.perServerLimit ?? null,
+      });
       const posts: PostData[] = [];
-      for (const bundle of bundles) {
-        const decoded = decodeV2PostBundle(bundle);
-        if (decoded) posts.push(decoded);
+      for (const response of responses) {
+        for (const bundle of response.eventBundles) {
+          const decoded = decodeV2PostBundle(bundle);
+          if (decoded) posts.push(decoded);
+        }
       }
       setItems(posts);
     } catch (e) {
@@ -34,7 +39,7 @@ export function useExploreFeed(options?: {
     } finally {
       setIsLoading(false);
     }
-  }, [client]);
+  }, [client, options?.perServerLimit]);
 
   useEffect(() => {
     if (enabled) fetchFeed();

apps/polycentric/src/features/feed/hooks/useFollowingFeed.ts

@@ -1,5 +1,4 @@
 import { useCallback, useEffect, useState } from 'react';
-import { v2 } from '@polycentric/react-native';
 import {
   decodeV2PostBundle,
   useLocalPostInjection,
@@ -28,14 +27,15 @@ export function useFollowingFeed(options?: {
     setIsLoading(true);
     setError(null);
     try {
-      const bundles = await client.getFeed({
-        algorithm: v2.FeedAlgorithm.FOLLOWING,
+      const responses = await client.getFollowingFeed({
         limit: options?.limit ?? null,
       });
       const posts: PostData[] = [];
-      for (const bundle of bundles) {
-        const decoded = decodeV2PostBundle(bundle);
-        if (decoded) posts.push(decoded);
+      for (const response of responses) {
+        for (const bundle of response.eventBundles) {
+          const decoded = decodeV2PostBundle(bundle);
+          if (decoded) posts.push(decoded);
+        }
       }
       setItems(posts);
     } catch (e) {

packages/js-core/src/client-internal/pairing-session-manager.ts

@@ -1,8 +1,3 @@
-import {
-  createPairingSession,
-  getPairingSession,
-  joinPairingSession,
-} from '../grpc/transport';
 import type { PolycentricClient } from '../polycentric-client';
 import * as Proto from '../proto/v2';
 import { bytesToHex } from '../utils/hex';
@@ -69,8 +64,13 @@ export class PairingSessionManager {
     );
     const signedMessage = await this.signMessage(pairingSessionBytes);
 
-    // send the gRPC request
-    const session = await createPairingSession(server, signedMessage);
+    const sessionBytes = await this.client.core.createPairingSession(
+      server,
+      Proto.SignedMessage.toBinary(signedMessage).buffer as ArrayBuffer,
+    );
+    const session = Proto.PairingSession.fromBinary(
+      new Uint8Array(sessionBytes),
+    );
     const initialSession = session.initialSession!;
 
     return {
@@ -91,10 +91,13 @@ export class PairingSessionManager {
     const targetServer = server ?? this.client.servers[0];
     if (!targetServer) throw new Error('No servers configured');
 
-    const session = await getPairingSession(
+    const sessionBytes = await this.client.core.getPairingSession(
       targetServer,
       pairingSessionSignature,
     );
+    const session = Proto.PairingSession.fromBinary(
+      new Uint8Array(sessionBytes),
+    );
     const initialSession = session.initialSession!;
     return {
       session,
@@ -120,7 +123,13 @@ export class PairingSessionManager {
     );
     const signedMessage = await this.signMessage(bodyBytes);
 
-    const session = await joinPairingSession(server, signedMessage);
+    const sessionBytes = await this.client.core.joinPairingSession(
+      server,
+      Proto.SignedMessage.toBinary(signedMessage).buffer as ArrayBuffer,
+    );
+    const session = Proto.PairingSession.fromBinary(
+      new Uint8Array(sessionBytes),
+    );
     const initialSession = session.initialSession!;
     return {
       session,

packages/js-core/src/grpc/index.ts

@@ -41,7 +41,6 @@ export type {
 export * from './errors';
 export * as Errors from './errors';
 export * from './utils';
-export * from './grpc';
 
 export { KEY_TYPE, COLLECTION, HydrationStrategy } from './constants';