Hotfix/eagle eye events (#6)

Author: Joan Reyero

backend/src/api/eagleEyeContent/eagleEyeContentList.ts

@@ -10,7 +10,9 @@ export default async (req, res) => {
     const payload = await new EagleEyeContentService(req).findAndCountAll(req.query)
 
     if (req.query.filter && Object.keys(req.query.filter).length > 0) {
-      track('Eagle Eye Content Filtered', { filter: req.query.filter }, { ...req })
+      const platforms = req.query.filter.platforms ? req.query.filter.platforms.split(',') : []
+      const nDays = req.query.filter.nDays
+      track('Eagle Eye Filter', { filter: req.query.filter, platforms, nDays }, { ...req })
     }
 
     await ApiResponseHandler.success(req, res, payload)

backend/src/api/eagleEyeContent/eagleEyeContentSearch.ts

@@ -12,7 +12,7 @@ export default async (req, res) => {
 
     const payload = await new EagleEyeContentService(req).search(req.body.data)
 
-    track('EagleEyeContent Manually Created', { ...req.body.data }, { ...req })
+    track('EagleEyeSearch', { ...req.body.data }, { ...req })
 
     await ApiResponseHandler.success(req, res, payload)
   } catch (error) {

backend/src/database/repositories/__tests__/eagleEyeContentRepository.test.ts

@@ -329,6 +329,22 @@ describe('eagleEyeContentRepository tests', () => {
       expect(found.count).toBe(3)
     })
 
+    it('Filter by nDays', async () => {
+      const mockIRepositoryOptions = await SequelizeTestUtils.getTestIRepositoryOptions(db)
+
+      await addAll(mockIRepositoryOptions)
+
+      const found = await EagleEyeContentRepository.findAndCountAll(
+        {
+          filter: {
+            nDays: 1,
+          },
+        },
+        mockIRepositoryOptions,
+      )
+      expect(found.count).toBe(3)
+    })
+
     it('Filter by status NULL', async () => {
       const mockIRepositoryOptions = await SequelizeTestUtils.getTestIRepositoryOptions(db)
 

backend/src/database/repositories/eagleEyeContentRepository.ts

@@ -184,6 +184,14 @@ export default class EagleEyeContentRepository {
         })
       }
 
+      if (filter.nDays) {
+        whereAnd.push({
+          timestamp: {
+            [Op.gte]: moment().subtract(filter.nDays, 'days').toDate(),
+          },
+        })
+      }
+
       if (filter.title) {
         whereAnd.push(SequelizeFilterUtils.ilikeIncludes('eagleEyeContent', 'title', filter.title))
       }

backend/src/services/eagleEyeContentService.ts

@@ -5,6 +5,7 @@ import { IServiceOptions } from './IServiceOptions'
 import EagleEyeContentRepository from '../database/repositories/eagleEyeContentRepository'
 import { getConfig } from '../config'
 import Error400 from '../errors/Error403'
+import track from '../segment/track'
 
 interface EagleEyeSearchPoint {
   vectorId: string
@@ -118,11 +119,43 @@ export default class EagleEyeContentService {
     const transaction = await SequelizeRepository.createTransaction(this.options.database)
 
     try {
+      const recordBeforeUpdate = await EagleEyeContentRepository.findById(id, { ...this.options })
       const record = await EagleEyeContentRepository.update(id, data, {
         ...this.options,
         transaction,
       })
 
+      // If we are updating status we want to track it
+      if (data.status !== recordBeforeUpdate.status) {
+        // If we are going from null to status, we are either accepting or rejecting
+        if (data.status && data.status !== null && data.status !== undefined) {
+          track(
+            `EagleEye ${data.status}`,
+            {
+              ...data,
+              platform: record.platform,
+              keywords: record.keywords,
+              title: record.title,
+              url: record.url,
+            },
+            { ...this.options },
+          )
+          // Here we are bringing back a rejected post to the Inbox
+        } else if (recordBeforeUpdate.status === 'rejected' && data.status === null) {
+          track(
+            `EagleEye post from rejected to Inbox`,
+            {
+              ...data,
+              platform: record.platform,
+              keywords: record.keywords,
+              title: record.title,
+              url: record.url,
+            },
+            { ...this.options },
+          )
+        }
+      }
+
       await SequelizeRepository.commitTransaction(transaction)
 
       return record