EagleEye contents with actions (#483)

Co-authored-by: Joan Reyero <joan@crowd.dev>

Author: epipav

backend/.env.dist.local

@@ -133,4 +133,8 @@ CROWD_QDRANT_PORT=6333
 
 # Enrichment settings
 CROWD_ENRICHMENT_URL=
-CROWD_ENRICHMENT_API_KEY=
+CROWD_ENRICHMENT_API_KEY=
+
+# EagleEye settings
+CROWD_EAGLE_EYE_URL=
+CROWD_EAGLE_EYE_API_KEY=

backend/config/custom-environment-variables.json

@@ -135,5 +135,9 @@
   "enrichment": {
     "url": "CROWD_ENRICHMENT_URL",
     "apiKey": "CROWD_ENRICHMENT_API_KEY"
+  },
+  "eagleEye": {
+    "url": "CROWD_EAGLE_EYE_URL",
+    "apiKey": "CROWD_EAGLE_EYE_API_KEY"
   }
 }

backend/config/default.json

@@ -34,5 +34,6 @@
     "maxRetrospectInSeconds": 3600
   },
   "github": {},
-  "enrichment": {}
+  "enrichment": {},
+  "eagleEye": {}
 }

backend/src/api/eagleEyeContent/eagleEyeActionCreate.ts

@@ -0,0 +1,11 @@
+import Permissions from '../../security/permissions'
+import EagleEyeActionService from '../../services/eagleEyeActionService'
+import PermissionChecker from '../../services/user/permissionChecker'
+
+export default async (req, res) => {
+  new PermissionChecker(req).validateHas(Permissions.values.eagleEyeActionCreate)
+
+  const payload = await new EagleEyeActionService(req).create(req.body, req.params.contentId)
+
+  await req.responseHandler.success(req, res, payload)
+}

backend/src/api/eagleEyeContent/eagleEyeActionDestroy.ts

@@ -0,0 +1,11 @@
+import Permissions from '../../security/permissions'
+import EagleEyeActionService from '../../services/eagleEyeActionService'
+import PermissionChecker from '../../services/user/permissionChecker'
+
+export default async (req, res) => {
+  new PermissionChecker(req).validateHas(Permissions.values.eagleEyeActionDestroy)
+
+  const payload = await new EagleEyeActionService(req).destroy(req.params.actionId)
+
+  await req.responseHandler.success(req, res, payload)
+}

backend/src/api/eagleEyeContent/eagleEyeContentList.ts

@@ -4,11 +4,9 @@ import EagleEyeContentService from '../../services/eagleEyeContentService'
 import PermissionChecker from '../../services/user/permissionChecker'
 
 export default async (req, res) => {
-  new PermissionChecker(req).validateHas(Permissions.values.eagleEyeContentSearch)
-
-  const payload = await new EagleEyeContentService(req).search(req.body)
-
-  track('EagleEyeSearch', { ...req.body }, { ...req })
+  new PermissionChecker(req).validateHas(Permissions.values.eagleEyeActionCreate)
 
+  const payload = await new EagleEyeContentService(req).search()
+  track('EagleEye backend search', { ...req.body }, { ...req })
   await req.responseHandler.success(req, res, payload)
 }

backend/src/api/eagleEyeContent/eagleEyeContentSearch.ts

@@ -3,9 +3,9 @@ import EagleEyeContentService from '../../services/eagleEyeContentService'
 import PermissionChecker from '../../services/user/permissionChecker'
 
 export default async (req, res) => {
-  new PermissionChecker(req).validateHas(Permissions.values.eagleEyeContentEdit)
+  new PermissionChecker(req).validateHas(Permissions.values.eagleEyeContentCreate)
 
-  const payload = await new EagleEyeContentService(req).update(req.params.id, req.body)
+  const payload = await new EagleEyeContentService(req).upsert(req.body)
 
   await req.responseHandler.success(req, res, payload)
 }

…eagleEyeContent/eagleEyeContentUpdate.ts …eagleEyeContent/eagleEyeContentUpsert.tsbackend/src/api/eagleEyeContent/eagleEyeContentUpdate.ts renamed to backend/src/api/eagleEyeContent/eagleEyeContentUpsert.ts backend/src/api/eagleEyeContent/eagleEyeContentUpdate.ts renamed to backend/src/api/eagleEyeContent/eagleEyeContentUpsert.ts

@@ -0,0 +1,11 @@
+import Permissions from '../../security/permissions'
+import EagleEyeSettingsService from '../../services/eagleEyeSettingsService'
+import PermissionChecker from '../../services/user/permissionChecker'
+
+export default async (req, res) => {
+  new PermissionChecker(req).validateHas(Permissions.values.eagleEyeActionCreate)
+
+  const payload = await new EagleEyeSettingsService(req).update(req.body)
+
+  await req.responseHandler.success(req, res, payload)
+}

backend/src/api/eagleEyeContent/eagleEyeSettingsUpdate.ts

@@ -1,21 +1,47 @@
 import { safeWrap } from '../../middlewares/errorMiddleware'
+import { featureFlagMiddleware } from '../../middlewares/featureFlagMiddleware'
+import { FeatureFlag } from '../../types/common'
 
 export default (app) => {
-  app.post(
-    `/tenant/:tenantId/eagleEyeContent`,
-    safeWrap(require('./eagleEyeContentSearch').default),
-  )
   app.post(
     `/tenant/:tenantId/eagleEyeContent/query`,
+    featureFlagMiddleware(FeatureFlag.EAGLE_EYE, 'entities.eagleEye.errors.planLimitExceeded'),
     safeWrap(require('./eagleEyeContentQuery').default),
   )
-  app.put(
-    `/tenant/:tenantId/eagleEyeContent/:id`,
-    safeWrap(require('./eagleEyeContentUpdate').default),
+
+  app.post(
+    `/tenant/:tenantId/eagleEyeContent`,
+    featureFlagMiddleware(FeatureFlag.EAGLE_EYE, 'entities.eagleEye.errors.planLimitExceeded'),
+    safeWrap(require('./eagleEyeContentUpsert').default),
+  )
+
+  app.get(
+    `/tenant/:tenantId/eagleEyeContent/search`,
+    featureFlagMiddleware(FeatureFlag.EAGLE_EYE, 'entities.eagleEye.errors.planLimitExceeded'),
+    safeWrap(require('./eagleEyeContentSearch').default),
   )
-  app.get(`/tenant/:tenantId/eagleEyeContent`, safeWrap(require('./eagleEyeContentList').default))
+
   app.get(
     `/tenant/:tenantId/eagleEyeContent/:id`,
+    featureFlagMiddleware(FeatureFlag.EAGLE_EYE, 'entities.eagleEye.errors.planLimitExceeded'),
     safeWrap(require('./eagleEyeContentFind').default),
   )
+
+  app.post(
+    `/tenant/:tenantId/eagleEyeContent/:contentId/action`,
+    featureFlagMiddleware(FeatureFlag.EAGLE_EYE, 'entities.eagleEye.errors.planLimitExceeded'),
+    safeWrap(require('./eagleEyeActionCreate').default),
+  )
+
+  app.put(
+    `/tenant/:tenantId/eagleEyeContent/settings`,
+    featureFlagMiddleware(FeatureFlag.EAGLE_EYE, 'entities.eagleEye.errors.planLimitExceeded'),
+    safeWrap(require('./eagleEyeSettingsUpdate').default),
+  )
+
+  app.delete(
+    `/tenant/:tenantId/eagleEyeContent/:contentId/action/:actionId`,
+    featureFlagMiddleware(FeatureFlag.EAGLE_EYE, 'entities.eagleEye.errors.planLimitExceeded'),
+    safeWrap(require('./eagleEyeActionDestroy').default),
+  )
 }