Differential D7713 Diff 26453 keyserver/src/responders/activity-responders.js

Changeset View

Standalone View

keyserver/src/responders/activity-responders.js

	// @flow			// @flow

	import t from 'tcomb';			import t from 'tcomb';
	import type { TList } from 'tcomb';			import type { TList } from 'tcomb';

	import {			import {
	type UpdateActivityResult,			type UpdateActivityResult,
	type UpdateActivityRequest,			type UpdateActivityRequest,
	type SetThreadUnreadStatusRequest,			type SetThreadUnreadStatusRequest,
	type SetThreadUnreadStatusResult,			type SetThreadUnreadStatusResult,
	type ActivityUpdate,			type ActivityUpdate,
	setThreadUnreadStatusResult,			setThreadUnreadStatusResult,
	updateActivityResultValidator,			updateActivityResultValidator,
	} from 'lib/types/activity-types.js';			} from 'lib/types/activity-types.js';
	import { tShape } from 'lib/utils/validation-utils.js';			import { tShape, tID } from 'lib/utils/validation-utils.js';

	import type { Viewer } from '../session/viewer.js';			import type { Viewer } from '../session/viewer.js';
	import {			import {
	activityUpdater,			activityUpdater,
	setThreadUnreadStatus,			setThreadUnreadStatus,
	} from '../updaters/activity-updaters.js';			} from '../updaters/activity-updaters.js';
	import { validateInput, validateOutput } from '../utils/validation-utils.js';			import { validateInput, validateOutput } from '../utils/validation-utils.js';

	const activityUpdatesInputValidator: TList<Array<ActivityUpdate>> = t.list(			const activityUpdatesInputValidator: TList<Array<ActivityUpdate>> = t.list(
	tShape({			tShape({
	focus: t.Bool,			focus: t.Bool,
	threadID: t.String,			threadID: tID,
	latestMessage: t.maybe(t.String),			latestMessage: t.maybe(tID),
	}),			}),
	);			);

	const inputValidator = tShape({			const inputValidator = tShape({
	updates: activityUpdatesInputValidator,			updates: activityUpdatesInputValidator,
	});			});

	async function updateActivityResponder(			async function updateActivityResponder(
	viewer: Viewer,			viewer: Viewer,
	input: any,			input: any,
	): Promise<UpdateActivityResult> {			): Promise<UpdateActivityResult> {
	const request: UpdateActivityRequest = input;			const request: UpdateActivityRequest = input;
	await validateInput(viewer, inputValidator, request);			await validateInput(viewer, inputValidator, request);
	const result = await activityUpdater(viewer, request);			const result = await activityUpdater(viewer, request);
	return validateOutput(viewer, updateActivityResultValidator, result);			return validateOutput(viewer, updateActivityResultValidator, result);
	}			}

	const setThreadUnreadStatusValidator = tShape({			const setThreadUnreadStatusValidator = tShape<SetThreadUnreadStatusRequest>({
	threadID: t.String,			threadID: tID,
	unread: t.Bool,			unread: t.Bool,
	latestMessage: t.maybe(t.String),			latestMessage: t.maybe(tID),
	});			});
	async function threadSetUnreadStatusResponder(			async function threadSetUnreadStatusResponder(
	viewer: Viewer,			viewer: Viewer,
	input: any,			input: any,
	): Promise<SetThreadUnreadStatusResult> {			): Promise<SetThreadUnreadStatusResult> {
	const request: SetThreadUnreadStatusRequest = input;			const request: SetThreadUnreadStatusRequest = input;
	await validateInput(viewer, setThreadUnreadStatusValidator, request);			await validateInput(viewer, setThreadUnreadStatusValidator, request);

	Show All 9 Lines