diff --git a/lib/hooks/input-state-container-hooks.js b/lib/hooks/input-state-container-hooks.js
new file mode 100644
index 000000000..4012fee93
--- /dev/null
+++ b/lib/hooks/input-state-container-hooks.js
@@ -0,0 +1,100 @@
+// @flow
+
+import invariant from 'invariant';
+import * as React from 'react';
+import uuid from 'uuid';
+
+import { useSendTextMessage } from '../actions/message-actions.js';
+import { dmOperationSpecificationTypes } from '../shared/dm-ops/dm-op-utils.js';
+import { useSendComposableDMOperation } from '../shared/dm-ops/process-dm-ops.js';
+import type { SendMessagePayload } from '../types/message-types.js';
+import type { RawTextMessageInfo } from '../types/messages/text.js';
+import type { ThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js';
+import {
+  thickThreadTypes,
+  threadTypeIsThick,
+} from '../types/thread-types-enum.js';
+
+function useInputStateContainerSendTextMessage(): (
+  messageInfo: RawTextMessageInfo,
+  threadInfo: ThreadInfo,
+  parentThreadInfo: ?ThreadInfo,
+  sidebarCreation: boolean,
+) => Promise<SendMessagePayload> {
+  const sendTextMessage = useSendTextMessage();
+  const sendComposableDMOperation = useSendComposableDMOperation();
+
+  return React.useCallback(
+    async (
+      messageInfo: RawTextMessageInfo,
+      threadInfo: ThreadInfo,
+      parentThreadInfo: ?ThreadInfo,
+      sidebarCreation: boolean,
+    ) => {
+      const { localID } = messageInfo;
+      invariant(
+        localID !== null && localID !== undefined,
+        'localID should be set',
+      );
+      if (!threadTypeIsThick(threadInfo.type)) {
+        const result = await sendTextMessage({
+          threadID: messageInfo.threadID,
+          localID,
+          text: messageInfo.text,
+          sidebarCreation,
+        });
+        return {
+          localID,
+          serverID: result.id,
+          threadID: messageInfo.threadID,
+          time: result.time,
+        };
+      }
+
+      const messageID = uuid.v4();
+      const time = Date.now();
+
+      const recipients =
+        threadInfo.type === thickThreadTypes.THICK_SIDEBAR && parentThreadInfo
+          ? parentThreadInfo.members
+          : threadInfo.members;
+      const recipientsIDs = recipients.map(recipient => recipient.id);
+
+      const messageIDs = await sendComposableDMOperation({
+        type: dmOperationSpecificationTypes.OUTBOUND,
+        op: {
+          type: 'send_text_message',
+          threadID: threadInfo.id,
+          creatorID: messageInfo.creatorID,
+          time,
+          messageID,
+          text: messageInfo.text,
+        },
+        // We need to use a different mechanism than `all_thread_members`
+        // because when creating a thread, the thread might not yet
+        // be in the store.
+        recipients: {
+          type: 'some_users',
+          userIDs: recipientsIDs,
+        },
+        sendOnly: true,
+        composableMessageID: localID,
+      });
+
+      if (messageIDs.length > 0) {
+        const e: any = new Error('Failed to send message to all peers');
+        e.failedOutboundP2PMessageIDs = messageIDs;
+        throw e;
+      }
+      return {
+        localID,
+        serverID: messageID,
+        threadID: messageInfo.threadID,
+        time,
+      };
+    },
+    [sendComposableDMOperation, sendTextMessage],
+  );
+}
+
+export { useInputStateContainerSendTextMessage };