Added initial support for event timelines

refs https://github.com/TryGhost/Ghost/issues/12602

This adds initial support for sitewide event timelines

ghost/members-api/index.js

@@ -83,6 +83,7 @@ module.exports = function MembersApi({
         MemberPaidSubscriptionEvent,
         MemberPaymentEvent,
         MemberStatusEvent,
+        MemberLoginEvent,
         MemberEmailChangeEvent
     });
 

ghost/members-api/lib/repositories/event/index.js

@@ -3,6 +3,7 @@ module.exports = class EventRepository {
         MemberSubscribeEvent,
         MemberPaymentEvent,
         MemberStatusEvent,
+        MemberLoginEvent,
         MemberPaidSubscriptionEvent,
         logger
     }) {
@@ -10,6 +11,7 @@ module.exports = class EventRepository {
         this._MemberPaidSubscriptionEvent = MemberPaidSubscriptionEvent;
         this._MemberPaymentEvent = MemberPaymentEvent;
         this._MemberStatusEvent = MemberStatusEvent;
+        this._MemberLoginEvent = MemberLoginEvent;
         this._logging = logger;
     }
 
@@ -20,6 +22,92 @@ module.exports = class EventRepository {
         });
     }
 
+    async getNewsletterSubscriptionEvents(options = {}) {
+        options.withRelated = ['member'];
+        const {data: models, meta} = await this._MemberSubscribeEvent.findPage(options);
+
+        const data = models.map((data) => {
+            return {
+                type: 'newsletter_event',
+                data: data.toJSON(options)
+            };
+        });
+
+        return {
+            data,
+            meta
+        };
+    }
+
+    async getSubscriptionEvents(options = {}) {
+        options.withRelated = ['member'];
+        const {data: models, meta} = await this._MemberPaidSubscriptionEvent.findPage(options);
+
+        const data = models.map((data) => {
+            return {
+                type: 'subscription_event',
+                data: data.toJSON(options)
+            };
+        });
+
+        return {
+            data,
+            meta
+        };
+    }
+
+    async getPaymentEvents(options = {}) {
+        options.withRelated = ['member'];
+        const {data: models, meta} = await this._MemberPaymentEvent.findPage(options);
+
+        const data = models.map((data) => {
+            return {
+                type: 'payment_event',
+                data: data.toJSON(options)
+            };
+        });
+
+        return {
+            data,
+            meta
+        };
+    }
+
+    async getLoginEvents(options = {}) {
+        options.withRelated = ['member'];
+        const {data: models, meta} = await this._MemberLoginEvent.findPage(options);
+
+        const data = models.map((data) => {
+            return {
+                type: 'login_event',
+                data: data.toJSON(options)
+            };
+        });
+
+        return {
+            data,
+            meta
+        };
+    }
+
+    async getEventTimeline(options = {}) {
+        if (!options.limit) {
+            options.limit = 10;
+        }
+
+        const allEventPages = await Promise.all([
+            this.getNewsletterSubscriptionEvents(options),
+            this.getSubscriptionEvents(options),
+            this.getLoginEvents(options)
+        ]);
+
+        const allEvents = allEventPages.reduce((allEvents, page) => allEvents.concat(page.data), []);
+
+        return allEvents.sort((a, b) => {
+            return new Date(b.data.created_at) - new Date(a.data.created_at);
+        }).slice(0, options.limit);
+    }
+
     async getSubscriptions() {
         const results = await this._MemberSubscribeEvent.findAll({
             aggregateSubscriptionDeltas: true