wip

1 files changed, 61 insertions, 0 deletions

diff --git a/src/api/endpoints/i/appdata/set.ts b/src/api/endpoints/i/appdata/set.ts
new file mode 100644
index 0000000000..57001f4e8b
--- /dev/null
+++ b/src/api/endpoints/i/appdata/set.ts
@@ -0,0 +1,61 @@
+'use strict';
+
+/**
+ * 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);
+	}
+});