summaryrefslogtreecommitdiff
path: root/src/server/api/endpoints/messaging/history.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/api/endpoints/messaging/history.ts')
-rw-r--r--src/server/api/endpoints/messaging/history.ts43
1 files changed, 43 insertions, 0 deletions
diff --git a/src/server/api/endpoints/messaging/history.ts b/src/server/api/endpoints/messaging/history.ts
new file mode 100644
index 0000000000..1683ca7a89
--- /dev/null
+++ b/src/server/api/endpoints/messaging/history.ts
@@ -0,0 +1,43 @@
+/**
+ * Module dependencies
+ */
+import $ from 'cafy';
+import History from '../../models/messaging-history';
+import Mute from '../../models/mute';
+import { pack } from '../../models/messaging-message';
+
+/**
+ * Show messaging history
+ *
+ * @param {any} params
+ * @param {any} user
+ * @return {Promise<any>}
+ */
+module.exports = (params, user) => new Promise(async (res, rej) => {
+ // Get 'limit' parameter
+ const [limit = 10, limitErr] = $(params.limit).optional.number().range(1, 100).$;
+ if (limitErr) return rej('invalid limit param');
+
+ const mute = await Mute.find({
+ muter_id: user._id,
+ deleted_at: { $exists: false }
+ });
+
+ // Get history
+ const history = await History
+ .find({
+ user_id: user._id,
+ partner: {
+ $nin: mute.map(m => m.mutee_id)
+ }
+ }, {
+ limit: limit,
+ sort: {
+ updated_at: -1
+ }
+ });
+
+ // Serialize
+ res(await Promise.all(history.map(async h =>
+ await pack(h.message, user))));
+});