iceshrimp/src/api/common/watch-post.ts

import * as mongodb from 'mongodb';
import Watching from '../models/post-watching';

export default async (me: mongodb.ObjectID, post: mongodb.ObjectID) => {
	// if watching now
	const exist = await Watching.findOne({
		post_id: post,
		user_id: me,
		deleted_at: { $exists: false }
	});

	if (exist !== null) {
		return;
	}

	await Watching.insert({
		created_at: new Date(),
		post_id: post,
		user_id: me
	});
};