Differential D6929 Diff 23363 keyserver/src/updaters/thread-updaters.js

Changeset View

Standalone View

keyserver/src/updaters/thread-updaters.js

Show All 17 Lines	import {
type RoleChangeRequest,		type RoleChangeRequest,
type ChangeThreadSettingsResult,		type ChangeThreadSettingsResult,
type RemoveMembersRequest,		type RemoveMembersRequest,
type LeaveThreadRequest,		type LeaveThreadRequest,
type LeaveThreadResult,		type LeaveThreadResult,
type UpdateThreadRequest,		type UpdateThreadRequest,
type ServerThreadJoinRequest,		type ServerThreadJoinRequest,
type ThreadJoinResult,		type ThreadJoinResult,
		type ToggleMessagePinRequest,
threadPermissions,		threadPermissions,
threadTypes,		threadTypes,
} from 'lib/types/thread-types.js';		} from 'lib/types/thread-types.js';
import { updateTypes } from 'lib/types/update-types.js';		import { updateTypes } from 'lib/types/update-types.js';
import { ServerError } from 'lib/utils/errors.js';		import { ServerError } from 'lib/utils/errors.js';
import { promiseAll } from 'lib/utils/promises.js';		import { promiseAll } from 'lib/utils/promises.js';
import { firstLine } from 'lib/utils/string-utils.js';		import { firstLine } from 'lib/utils/string-utils.js';

▲ Show 20 Lines • Show All 802 Lines • ▼ Show 20 Lines	updateDatas.push({
threadID: threadID,		threadID: threadID,
targetSession: viewer.session,		targetSession: viewer.session,
});		});
}		}

await createUpdates(updateDatas);		await createUpdates(updateDatas);
}		}

		async function toggleMessagePinForThread(
		viewer: Viewer,
		request: ToggleMessagePinRequest,
		): Promise<void> {
		const { messageID, threadID, isPinned } = request;

		const hasPermission = await checkThreadPermission(
		viewer,
		threadID,
		threadPermissions.MANAGE_PINS,
		);

		// Verify that the viewer has the proper credentials to manage pins
		if (!hasPermission) {
		throw new ServerError('invalid_credentials');
		}

		// Toggle the pin status: if the message is pinned, unpin it, and vice versa
		let togglePinQuery;
		if (isPinned) {
		togglePinQuery = SQL`
		INSERT INTO pinned_messages (messageID, thread, pin_time)
		VALUES (${messageID}, ${threadID}, ${Date.now()})
		`;
		} else {
		togglePinQuery = SQL`
		DELETE FROM pinned_messages
		WHERE messageID = ${messageID} AND thread = ${threadID}
		`;
		}

		await dbQuery(togglePinQuery);
		}

export {		export {
updateRole,		updateRole,
removeMembers,		removeMembers,
leaveThread,		leaveThread,
updateThread,		updateThread,
joinThread,		joinThread,
updateThreadMembers,		updateThreadMembers,
		toggleMessagePinForThread,
};		};