summaryrefslogtreecommitdiff
path: root/src/api/endpoints/i/appdata/set.ts
blob: 354935cb4c9213e20c420c3e90d28fd881d2603e (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
/**
 * Module dependencies
 */
import Appdata from '../../../models/appdata';
import User from '../../../models/user';
import serialize from '../../../serializers/user';
import event from '../../../event';

/**
 * Set app data
 *
 * @param {any} params
 * @param {any} user
 * @param {any} app
 * @param {Boolean} isSecure
 * @return {Promise<any>}
 */
module.exports = (params, user, app, isSecure) => new Promise(async (res, rej) => {
	const data = params.data;
	if (data == null) {
		return rej('data is required');
	}

	if (isSecure) {
		const _user = await User.findOneAndUpdate(user._id, {
			$set: {
				data: Object.assign(user.data || {}, JSON.parse(data))
			}
		});
		res(204);

		// Publish i updated event
		event(user._id, 'i_updated', await serialize(_user, user, {
			detail: true,
			includeSecrets: true
		}));
	} else {
		const appdata = await Appdata.findOne({
			app_id: app._id,
			user_id: user._id
		});
		await Appdata.update({
			app_id: app._id,
			user_id: user._id
		}, Object.assign({
			app_id: app._id,
			user_id: user._id
		}, {
			$set: {
				data: Object.assign((appdata || {}).data || {}, JSON.parse(data))
			}
		}), {
			upsert: true
		});
		res(204);
	}
});