Page MenuHomePhorge
Files F32201052

D7585.1765111054.diff
No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

D7585.1765111054.diff
View Options

diff --git a/keyserver/src/database/search-utils.js b/keyserver/src/database/search-utils.js
--- a/keyserver/src/database/search-utils.js
+++ b/keyserver/src/database/search-utils.js
@@ -134,9 +134,20 @@
}
}
+const whiteSpaceRegex = /[\s]+/g;
+
+function processQueryForSearch(query: string): string {
+ if (query === '') {
+ return '';
+ }
+ const stemmedQuery = segmentAndStem(query);
+ return '+' + stemmedQuery.replace(whiteSpaceRegex, ' +');
+}
+
export {
processMessagesForSearch,
processMessagesInDBForSearch,
segmentAndStem,
stopwords,
+ processQueryForSearch,
};
diff --git a/keyserver/src/fetchers/message-fetchers.js b/keyserver/src/fetchers/message-fetchers.js
--- a/keyserver/src/fetchers/message-fetchers.js
+++ b/keyserver/src/fetchers/message-fetchers.js
@@ -25,6 +25,7 @@
type FetchPinnedMessagesRequest,
type FetchPinnedMessagesResult,
} from 'lib/types/message-types.js';
+import { defaultNumberPerThread } from 'lib/types/message-types.js';
import { threadPermissions } from 'lib/types/thread-types.js';
import { ServerError } from 'lib/utils/errors.js';
@@ -38,6 +39,7 @@
mergeOrConditions,
mergeAndConditions,
} from '../database/database.js';
+import { processQueryForSearch } from '../database/search-utils.js';
import type { SQLStatementType } from '../database/types.js';
import type { PushInfo } from '../push/send.js';
import type { Viewer } from '../session/viewer.js';
@@ -916,6 +918,58 @@
return [...rawMessageInfos, ...rawRelatedMessageInfos];
}
+async function searchMessagesInSingleChat(
+ inputQuery: string,
+ viewer?: Viewer,
+ cursor?: string,
+ threadID: string,
+): Promise<$ReadOnlyArray<RawMessageInfo>> {
+ if (inputQuery === '') {
+ console.warn('received empty search query');
+ return [];
+ }
+ const pattern = processQueryForSearch(inputQuery);
+
+ const query = SQL`
+ SELECT m.id, m.thread AS threadID, m.content, m.time, m.type, m.creation,
+ m.user AS creatorID, m.target_message as targetMessageID,
+ stm.permissions AS subthread_permissions, up.id AS uploadID,
+ up.type AS uploadType, up.secret AS uploadSecret, up.extra AS uploadExtra
+ FROM message_search s
+ LEFT JOIN messages m ON m.id = s.original_message_id
+ LEFT JOIN memberships stm ON m.type = ${messageTypes.CREATE_SUB_THREAD}
+ AND stm.thread = m.content AND stm.user = m.user
+ LEFT JOIN uploads up ON up.container = m.id
+ LEFT JOIN messages m2 ON m2.target_message = m.id
+ AND m2.type = ${messageTypes.SIDEBAR_SOURCE} AND m2.thread = ${threadID}
+ WHERE MATCH(s.processed_content) AGAINST(${pattern} IN BOOLEAN MODE)
+ AND (m.thread = ${threadID} OR m2.id IS NOT NULL)
+ `;
+
+ if (cursor) {
+ query.append(SQL`AND m.id < ${cursor} `);
+ }
+ query.append(SQL`
+ ORDER BY m.time DESC, m.id DESC
+ LIMIT ${defaultNumberPerThread}
+ `);
+
+ const [results] = await dbQuery(query);
+ if (results.length === 0) {
+ return [];
+ }
+
+ const rawMessageInfos = await rawMessageInfoForRowsAndRelatedMessages(
+ results,
+ viewer,
+ );
+
+ return shimUnsupportedRawMessageInfos(
+ rawMessageInfos,
+ viewer?.platformDetails,
+ );
+}
+
export {
fetchCollapsableNotifs,
fetchMessageInfos,
@@ -929,4 +983,5 @@
fetchPinnedMessageInfos,
fetchRelatedMessages,
rawMessageInfoForRowsAndRelatedMessages,
+ searchMessagesInSingleChat,
};

File Metadata

Mime Type
text/plain
Expires
Sun, Dec 7, 12:37 PM (12 h, 45 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5844188
Default Alt Text
D7585.1765111054.diff (3 KB)

Event Timeline