/g, '\n\n');
- const searchableTextContent = JSDOM.fragment(searchableContent).textContent;
+ // Check filters
+ if (req.cachedFilters && !unpackedPayload.filtered) {
+ const status = unpackedPayload;
+ const searchContent = ([status.spoiler_text || '', status.content].concat((status.poll && status.poll.options) ? status.poll.options.map(option => option.title) : [])).concat(status.media_attachments.map(att => att.description)).join('\n\n').replace(/ /g, '\n\n');
+ const searchIndex = JSDOM.fragment(searchContent).textContent;
const now = new Date();
- const filter_results = Object.values(req.cachedFilters).reduce((results, cachedFilter) => {
- // Check the filter hasn't expired before applying:
- if (cachedFilter.expires_at !== null && cachedFilter.expires_at < now) {
- return results;
- }
-
- // Just in-case JSDOM fails to find textContent in searchableContent
- if (!searchableTextContent) {
- return results;
- }
-
- const keyword_matches = searchableTextContent.match(cachedFilter.regexp);
- if (keyword_matches) {
- // results is an Array of FilterResult; status_matches is always
- // null as we only are only applying the keyword-based custom
- // filters, not the status-based custom filters.
- // https://docs.joinmastodon.org/entities/FilterResult/
- results.push({
- filter: cachedFilter.filter,
- keyword_matches,
- status_matches: null
- });
+ payload.filtered = [];
+ Object.values(req.cachedFilters).forEach((cachedFilter) => {
+ if ((cachedFilter.expires_at === null || cachedFilter.expires_at > now)) {
+ const keyword_matches = searchIndex.match(cachedFilter.regexp);
+ if (keyword_matches) {
+ payload.filtered.push({
+ filter: cachedFilter.repr,
+ keyword_matches,
+ });
+ }
}
-
- return results;
- }, []);
-
- // Send the payload + the FilterResults as the `filtered` property
- // to the streaming connection. To reach this code, the `event` must
- // have been either `update` or `status.update`, meaning the
- // `payload` is a Status entity, which has a `filtered` property:
- //
- // filtered: https://docs.joinmastodon.org/entities/Status/#filtered
- transmit(event, {
- ...payload,
- filtered: filter_results
});
- } else {
- transmit(event, payload);
}
+
+ transmit();
}).catch(err => {
- releasePgConnection();
log.error(err);
+ done();
});
});
};
@@ -850,7 +781,7 @@ const startWorker = async (workerId) => {
subscribe(`${redisPrefix}${id}`, listener);
});
- if (typeof attachCloseHandler === 'function') {
+ if (attachCloseHandler) {
attachCloseHandler(ids.map(id => `${redisPrefix}${id}`), listener);
}
@@ -887,13 +818,12 @@ const startWorker = async (workerId) => {
/**
* @param {any} req
* @param {function(): void} [closeHandler]
- * @returns {function(string[], SubscriptionListener): void}
+ * @return {function(string[]): void}
*/
-
- const streamHttpEnd = (req, closeHandler = undefined) => (ids, listener) => {
+ const streamHttpEnd = (req, closeHandler = undefined) => (ids) => {
req.on('close', () => {
ids.forEach(id => {
- unsubscribe(id, listener);
+ unsubscribe(id);
});
if (closeHandler) {
@@ -1153,7 +1083,7 @@ const startWorker = async (workerId) => {
* @typedef WebSocketSession
* @property {any} socket
* @property {any} request
- * @property {Object.