diff --git a/keyserver/src/responders/message-responders.js b/keyserver/src/responders/message-responders.js
index e26658b92..70ac2543a 100644
--- a/keyserver/src/responders/message-responders.js
+++ b/keyserver/src/responders/message-responders.js
@@ -1,255 +1,267 @@
 // @flow
 
 import invariant from 'invariant';
 import t from 'tcomb';
 
 import { createMediaMessageData, trimMessage } from 'lib/shared/message-utils';
 import { relationshipBlockedInEitherDirection } from 'lib/shared/relationship-utils';
 import type { Media } from 'lib/types/media-types.js';
 import {
   messageTypes,
   type SendTextMessageRequest,
   type SendMultimediaMessageRequest,
   type SendReactionMessageRequest,
   type FetchMessageInfosResponse,
   type FetchMessageInfosRequest,
   defaultNumberPerThread,
   type SendMessageResponse,
   type ReactionMessageData,
 } from 'lib/types/message-types';
 import type { TextMessageData } from 'lib/types/messages/text';
 import { threadPermissions } from 'lib/types/thread-types';
 import { ServerError } from 'lib/utils/errors';
 import {
   tString,
   tShape,
   tMediaMessageMedia,
 } from 'lib/utils/validation-utils';
 
 import createMessages from '../creators/message-creator';
+import { SQL } from '../database/database';
 import {
   fetchMessageInfos,
   fetchMessageInfoForLocalID,
   fetchMessageInfoByID,
 } from '../fetchers/message-fetchers';
+import { fetchServerThreadInfos } from '../fetchers/thread-fetchers';
 import { checkThreadPermission } from '../fetchers/thread-permission-fetchers';
 import {
   fetchMedia,
   fetchMediaFromMediaMessageContent,
 } from '../fetchers/upload-fetchers';
 import { fetchKnownUserInfos } from '../fetchers/user-fetchers';
 import type { Viewer } from '../session/viewer';
 import {
   assignMedia,
   assignMessageContainerToMedia,
 } from '../updaters/upload-updaters';
 import { validateInput } from '../utils/validation-utils';
 
 const sendTextMessageRequestInputValidator = tShape({
   threadID: t.String,
   localID: t.maybe(t.String),
   text: t.String,
 });
 async function textMessageCreationResponder(
   viewer: Viewer,
   input: any,
 ): Promise<SendMessageResponse> {
   const request: SendTextMessageRequest = input;
   await validateInput(viewer, sendTextMessageRequestInputValidator, request);
 
   const { threadID, localID, text: rawText } = request;
   const text = trimMessage(rawText);
   if (!text) {
     throw new ServerError('invalid_parameters');
   }
 
   const hasPermission = await checkThreadPermission(
     viewer,
     threadID,
     threadPermissions.VOICED,
   );
   if (!hasPermission) {
     throw new ServerError('invalid_parameters');
   }
 
   const messageData: TextMessageData = {
     type: messageTypes.TEXT,
     threadID,
     creatorID: viewer.id,
     time: Date.now(),
     text,
   };
   if (localID) {
     messageData.localID = localID;
   }
   const rawMessageInfos = await createMessages(viewer, [messageData]);
 
   return { newMessageInfo: rawMessageInfos[0] };
 }
 
 const fetchMessageInfosRequestInputValidator = tShape({
   cursors: t.dict(t.String, t.maybe(t.String)),
   numberPerThread: t.maybe(t.Number),
 });
 async function messageFetchResponder(
   viewer: Viewer,
   input: any,
 ): Promise<FetchMessageInfosResponse> {
   const request: FetchMessageInfosRequest = input;
   await validateInput(viewer, fetchMessageInfosRequestInputValidator, request);
   const response = await fetchMessageInfos(
     viewer,
     { threadCursors: request.cursors },
     request.numberPerThread ? request.numberPerThread : defaultNumberPerThread,
   );
   return { ...response, userInfos: {} };
 }
 
 const sendMultimediaMessageRequestInputValidator = t.union([
   tShape({
     threadID: t.String,
     localID: t.String,
     mediaIDs: t.list(t.String),
   }),
   tShape({
     threadID: t.String,
     localID: t.String,
     mediaMessageContents: t.list(tMediaMessageMedia),
   }),
 ]);
 async function multimediaMessageCreationResponder(
   viewer: Viewer,
   input: any,
 ): Promise<SendMessageResponse> {
   const request: SendMultimediaMessageRequest = input;
   await validateInput(
     viewer,
     sendMultimediaMessageRequestInputValidator,
     request,
   );
 
   if (
     (request.mediaIDs && request.mediaIDs.length === 0) ||
     (request.mediaMessageContents && request.mediaMessageContents.length === 0)
   ) {
     throw new ServerError('invalid_parameters');
   }
 
   const { threadID, localID } = request;
   const hasPermission = await checkThreadPermission(
     viewer,
     threadID,
     threadPermissions.VOICED,
   );
   if (!hasPermission) {
     throw new ServerError('invalid_parameters');
   }
 
   const existingMessageInfoPromise = fetchMessageInfoForLocalID(
     viewer,
     localID,
   );
   const mediaPromise: Promise<$ReadOnlyArray<Media>> = request.mediaIDs
     ? fetchMedia(viewer, request.mediaIDs)
     : fetchMediaFromMediaMessageContent(viewer, request.mediaMessageContents);
 
   const [existingMessageInfo, media] = await Promise.all([
     existingMessageInfoPromise,
     mediaPromise,
   ]);
 
   if (media.length === 0 && !existingMessageInfo) {
     throw new ServerError('invalid_parameters');
   }
 
   const messageData = createMediaMessageData({
     localID,
     threadID,
     creatorID: viewer.id,
     media,
   });
   const [newMessageInfo] = await createMessages(viewer, [messageData]);
   const { id } = newMessageInfo;
   invariant(
     id !== null && id !== undefined,
     'serverID should be set in createMessages result',
   );
 
   if (request.mediaIDs) {
     await assignMedia(viewer, request.mediaIDs, id);
   } else {
     await assignMessageContainerToMedia(
       viewer,
       request.mediaMessageContents,
       id,
     );
   }
 
   return { newMessageInfo };
 }
 
 const sendReactionMessageRequestInputValidator = tShape({
   threadID: t.String,
   targetMessageID: t.String,
   reaction: tString('👍'),
   action: t.enums.of(['add_reaction', 'remove_reaction']),
 });
 async function reactionMessageCreationResponder(
   viewer: Viewer,
   input: any,
 ): Promise<SendMessageResponse> {
   const request: SendReactionMessageRequest = input;
   await validateInput(viewer, sendReactionMessageRequestInputValidator, input);
 
   const { threadID, targetMessageID, reaction, action } = request;
 
   if (!targetMessageID || !reaction) {
     throw new ServerError('invalid_parameters');
   }
 
   const targetMessageInfo = await fetchMessageInfoByID(viewer, targetMessageID);
 
   if (!targetMessageInfo || !targetMessageInfo.id) {
     throw new ServerError('invalid_parameters');
   }
 
-  const [hasPermission, targetMessageUserInfos] = await Promise.all([
+  const [
+    serverThreadInfos,
+    hasPermission,
+    targetMessageUserInfos,
+  ] = await Promise.all([
+    fetchServerThreadInfos(SQL`t.id = ${threadID}`),
     checkThreadPermission(viewer, threadID, threadPermissions.VOICED),
     fetchKnownUserInfos(viewer, [targetMessageInfo.creatorID]),
   ]);
 
+  const targetMessageThreadInfo = serverThreadInfos.threadInfos[threadID];
+  if (targetMessageThreadInfo.sourceMessageID === targetMessageID) {
+    throw new ServerError('invalid_parameters');
+  }
+
   const targetMessageCreator =
     targetMessageUserInfos[targetMessageInfo.creatorID];
 
   const targetMessageCreatorRelationship =
     targetMessageCreator?.relationshipStatus;
 
   const creatorRelationshipHasBlock =
     targetMessageCreatorRelationship &&
     relationshipBlockedInEitherDirection(targetMessageCreatorRelationship);
 
   if (!hasPermission || creatorRelationshipHasBlock) {
     throw new ServerError('invalid_parameters');
   }
 
   const messageData: ReactionMessageData = {
     type: messageTypes.REACTION,
     threadID,
     creatorID: viewer.id,
     time: Date.now(),
     targetMessageID,
     reaction,
     action,
   };
 
   const rawMessageInfos = await createMessages(viewer, [messageData]);
 
   return { newMessageInfo: rawMessageInfos[0] };
 }
 
 export {
   textMessageCreationResponder,
   messageFetchResponder,
   multimediaMessageCreationResponder,
   reactionMessageCreationResponder,
 };
diff --git a/native/chat/reaction-message-utils.js b/native/chat/reaction-message-utils.js
index 72667369e..39e765d04 100644
--- a/native/chat/reaction-message-utils.js
+++ b/native/chat/reaction-message-utils.js
@@ -1,121 +1,124 @@
 // @flow
 
 import invariant from 'invariant';
 import Alert from 'react-native/Libraries/Alert/Alert';
 
 import {
   sendReactionMessage,
   sendReactionMessageActionTypes,
 } from 'lib/actions/message-actions';
 import { relationshipBlockedInEitherDirection } from 'lib/shared/relationship-utils';
 import { threadHasPermission } from 'lib/shared/thread-utils';
 import type {
   RobotextMessageInfo,
   ComposableMessageInfo,
 } from 'lib/types/message-types';
 import { threadPermissions, type ThreadInfo } from 'lib/types/thread-types';
 import type { BindServerCall, DispatchFunctions } from 'lib/utils/action-utils';
 import { useSelector } from 'lib/utils/redux-utils';
 
 import type { TooltipRoute } from '../navigation/tooltip.react';
 
 function onPressReact(
   route:
     | TooltipRoute<'TextMessageTooltipModal'>
     | TooltipRoute<'MultimediaMessageTooltipModal'>
     | TooltipRoute<'RobotextMessageTooltipModal'>,
   dispatchFunctions: DispatchFunctions,
   bindServerCall: BindServerCall,
 ) {
   const messageID = route.params.item.messageInfo.id;
   invariant(messageID, 'messageID should be set');
 
   const threadID = route.params.item.threadInfo.id;
   invariant(threadID, 'threadID should be set');
 
   const reactionInput = '👍';
   const viewerReacted = route.params.item.reactions.get(reactionInput)
     ?.viewerReacted;
 
   const action = viewerReacted ? 'remove_reaction' : 'add_reaction';
 
   sendReaction(
     messageID,
     threadID,
     reactionInput,
     action,
     dispatchFunctions,
     bindServerCall,
   );
 }
 
 function sendReaction(
   messageID: string,
   threadID: string,
   reaction: string,
   action: 'add_reaction' | 'remove_reaction',
   dispatchFunctions: DispatchFunctions,
   bindServerCall: BindServerCall,
 ) {
   const callSendReactionMessage = bindServerCall(sendReactionMessage);
 
   const reactionMessagePromise = (async () => {
     try {
       const result = await callSendReactionMessage({
         threadID,
         targetMessageID: messageID,
         reaction,
         action,
       });
       return {
         serverID: result.id,
         threadID,
         time: result.newMessageInfo.time,
         newMessageInfos: [result.newMessageInfo],
       };
     } catch (e) {
       Alert.alert(
         'Couldn’t send the reaction',
         'Please try again later',
         [{ text: 'OK' }],
         {
           cancelable: true,
         },
       );
       throw e;
     }
   })();
 
   dispatchFunctions.dispatchActionPromise(
     sendReactionMessageActionTypes,
     reactionMessagePromise,
   );
 }
 
 function useCanCreateReactionFromMessage(
   threadInfo: ThreadInfo,
   targetMessageInfo: ComposableMessageInfo | RobotextMessageInfo,
 ): boolean {
   const targetMessageCreatorRelationship = useSelector(
     state =>
       state.userStore.userInfos[targetMessageInfo.creator.id]
         ?.relationshipStatus,
   );
 
-  if (!targetMessageInfo.id) {
+  if (
+    !targetMessageInfo.id ||
+    threadInfo.sourceMessageID === targetMessageInfo.id
+  ) {
     return false;
   }
 
   const creatorRelationshipHasBlock =
     targetMessageCreatorRelationship &&
     relationshipBlockedInEitherDirection(targetMessageCreatorRelationship);
 
   const hasPermission = threadHasPermission(
     threadInfo,
     threadPermissions.VOICED,
   );
 
   return hasPermission && !creatorRelationshipHasBlock;
 }
 
 export { onPressReact, useCanCreateReactionFromMessage };