diff --git a/lib/reducers/message-reducer.js b/lib/reducers/message-reducer.js
--- a/lib/reducers/message-reducer.js
+++ b/lib/reducers/message-reducer.js
@@ -67,6 +67,7 @@
   createReplaceMessageStoreThreadsOperations,
 } from '../ops/message-store-ops.js';
 import { pendingToRealizedThreadIDsSelector } from '../selectors/thread-selectors.js';
+import { processFarcasterOpsActionType } from '../shared/farcaster/farcaster-actions.js';
 import {
   localIDPrefix,
   messageID,
@@ -1940,6 +1941,26 @@
         localOperation,
       ]),
     };
+  } else if (action.type === processFarcasterOpsActionType) {
+    const { rawMessageInfos, updateInfos } = action.payload;
+
+    const messagesResult = mergeUpdatesWithMessageInfos(
+      rawMessageInfos,
+      updateInfos,
+    );
+
+    const { messageStoreOperations, messageStore: newMessageStore } =
+      mergeNewMessages(
+        messageStore,
+        messagesResult.rawMessageInfos,
+        messagesResult.truncationStatuses,
+        newThreadInfos,
+      );
+
+    return {
+      messageStoreOperations,
+      messageStore: newMessageStore,
+    };
   }
   return { messageStoreOperations: [], messageStore };
 }
diff --git a/lib/reducers/thread-reducer.js b/lib/reducers/thread-reducer.js
--- a/lib/reducers/thread-reducer.js
+++ b/lib/reducers/thread-reducer.js
@@ -40,6 +40,7 @@
   threadStoreOpsHandlers,
 } from '../ops/thread-store-ops.js';
 import { getThreadUpdatesForNewMessages } from '../shared/dm-ops/dm-op-utils.js';
+import { processFarcasterOpsActionType } from '../shared/farcaster/farcaster-actions.js';
 import { stateSyncSpecs } from '../shared/state-sync/state-sync-specs.js';
 import { updateSpecs } from '../shared/updates/update-specs.js';
 import { processDMOpsActionType } from '../types/dm-ops.js';
@@ -586,6 +587,23 @@
         ...threadStoreOperationsWithNewMessagesUpdates,
       ],
     };
+  } else if (action.type === processFarcasterOpsActionType) {
+    const { updateInfos } = action.payload;
+    if (updateInfos.length === 0) {
+      return {
+        threadStore: state,
+        newThreadInconsistencies: [],
+        threadStoreOperations: [],
+      };
+    }
+    const { threadStoreOperations, updatedThreadStore } =
+      generateOpsAndProcessThreadUpdates(state, updateInfos);
+
+    return {
+      threadStore: updatedThreadStore,
+      newThreadInconsistencies: [],
+      threadStoreOperations,
+    };
   }
   return {
     threadStore: state,
diff --git a/lib/selectors/thread-selectors.js b/lib/selectors/thread-selectors.js
--- a/lib/selectors/thread-selectors.js
+++ b/lib/selectors/thread-selectors.js
@@ -270,7 +270,7 @@
   (state: BaseAppState<>) => state.threadStore.threadInfos,
   (threadInfos: RawThreadInfos): { +[keyserverID: string]: number } => {
     const thinThreadInfosList = values(threadInfos).filter(
-      threadInfo => !threadInfo.thick,
+      threadInfo => !threadInfo.thick && !threadInfo.farcaster,
     );
 
     const keyserverToThreads = _groupBy(threadInfo =>
diff --git a/lib/shared/farcaster/farcaster-actions.js b/lib/shared/farcaster/farcaster-actions.js
new file mode 100644
--- /dev/null
+++ b/lib/shared/farcaster/farcaster-actions.js
@@ -0,0 +1,11 @@
+// @flow
+
+import type { RawMessageInfo } from '../../types/message-types.js';
+import type { ClientUpdateInfo } from '../../types/update-types.js';
+
+export const processFarcasterOpsActionType = 'PROCESS_FARCASTER_OPS';
+
+export type ProcessFarcasterOpsPayload = {
+  +rawMessageInfos: $ReadOnlyArray<RawMessageInfo>,
+  +updateInfos: $ReadOnlyArray<ClientUpdateInfo>,
+};
diff --git a/lib/shared/farcaster/farcaster-hooks.js b/lib/shared/farcaster/farcaster-hooks.js
--- a/lib/shared/farcaster/farcaster-hooks.js
+++ b/lib/shared/farcaster/farcaster-hooks.js
@@ -1,7 +1,9 @@
 // @flow
 
 import * as React from 'react';
+import uuid from 'uuid';
 
+import { processFarcasterOpsActionType } from './farcaster-actions.js';
 import {
   type FetchFarcasterConversationResult,
   useFetchFarcasterConversation,
@@ -12,6 +14,10 @@
 } from './farcaster-api.js';
 import type { FarcasterConversation } from './farcaster-conversation-types.js';
 import type { FarcasterMessage } from './farcaster-messages-types.js';
+import { messageTruncationStatus } from '../../types/message-types.js';
+import { updateTypes } from '../../types/update-types-enum.js';
+import type { ClientUpdateInfo } from '../../types/update-types.js';
+import { createFarcasterRawThreadInfo } from '../../utils/farcaster-utils.js';
 import { useDispatch } from '../../utils/redux-utils.js';
 import { useSendDMOperationUtils } from '../dm-ops/dm-op-utils.js';
 
@@ -83,7 +89,10 @@
           .filter(Boolean)
           .map(conversationResult => conversationResult.result.conversation);
 
-      console.log('Farcaster conversations:', farcasterConversations);
+      console.log(
+        'Farcaster conversations:',
+        JSON.stringify(farcasterConversations, null, 2),
+      );
 
       const messagePromises: $ReadOnlyArray<
         Promise<?FetchFarcasterMessageResult>,
@@ -104,9 +113,34 @@
           .filter(Boolean)
           .flatMap(messagesResult => messagesResult.result.messages);
 
-      console.log('Farcaster messages:', farcasterMessages);
+      console.log(
+        'Farcaster messages:',
+        JSON.stringify(farcasterMessages, null, 2),
+      );
+
+      //TODO: dispatch messages
+      const updates = farcasterConversations
+        .map(conversation => createFarcasterRawThreadInfo(conversation))
+        .map(
+          thread =>
+            ({
+              type: updateTypes.JOIN_THREAD,
+              id: uuid.v4(),
+              time: thread.creationTime,
+              threadInfo: thread,
+              rawMessageInfos: [],
+              truncationStatus: messageTruncationStatus.EXHAUSTIVE,
+              rawEntryInfos: [],
+            }: ClientUpdateInfo),
+        );
+      dispatch({
+        type: processFarcasterOpsActionType,
+        payload: {
+          rawMessageInfos: [],
+          updateInfos: updates,
+        },
+      });
 
-      //TODO: dispatch threads and messages
       setConversations([]);
     })();
   }, [
diff --git a/lib/shared/threads/protocols/farcaster-thread-protocol.js b/lib/shared/threads/protocols/farcaster-thread-protocol.js
--- a/lib/shared/threads/protocols/farcaster-thread-protocol.js
+++ b/lib/shared/threads/protocols/farcaster-thread-protocol.js
@@ -94,11 +94,7 @@
     throw new Error('createPendingThread method is not yet implemented');
   },
 
-  couldBeCreatedFromPendingThread: (): boolean => {
-    throw new Error(
-      'couldBeCreatedFromPendingThread method is not yet implemented',
-    );
-  },
+  couldBeCreatedFromPendingThread: () => true,
 
   canBeFrozen: (): boolean => {
     throw new Error('canBeFrozen method is not yet implemented');
diff --git a/lib/types/redux-types.js b/lib/types/redux-types.js
--- a/lib/types/redux-types.js
+++ b/lib/types/redux-types.js
@@ -182,6 +182,7 @@
   SetLateResponsePayload,
   UpdateKeyserverReachabilityPayload,
 } from '../keyserver-conn/keyserver-conn-types.js';
+import type { ProcessFarcasterOpsPayload } from '../shared/farcaster/farcaster-actions.js';
 import type { SendMessageError } from '../utils/errors.js';
 
 // Before making changes here, make sure to consider how the added property
@@ -1713,6 +1714,10 @@
         +error: true,
         +payload: Error,
         +loadingInfo: LoadingInfo,
+      }
+    | {
+        +type: 'PROCESS_FARCASTER_OPS',
+        +payload: ProcessFarcasterOpsPayload,
       },
 }>;