New sentiment

backend/.env.dist.composed

@@ -27,5 +27,8 @@ CROWD_OPENSEARCH_NODE=http://open-search:9200
 # Temporal
 CROWD_TEMPORAL_SERVER_URL=temporal:7233
 
+# HuggingFace
+CROWD_HUGGINGFACE_API_KEY=
+
 # Seach sync api
-CROWD_SEARCH_SYNC_API_URL=http://search-sync-api:8083
+CROWD_SEARCH_SYNC_API_URL=http://search-sync-api:8083

backend/.env.dist.local

@@ -171,5 +171,8 @@ CROWD_ANALYTICS_API_TOKEN=
 CROWD_TEMPORAL_SERVER_URL=localhost:7233
 CROWD_TEMPORAL_NAMESPACE=default
 
+# HuggingFace
+CROWD_HUGGINGFACE_API_KEY=
+
 # Seach sync api
-CROWD_SEARCH_SYNC_API_URL=http://search-sync-api:8083
+CROWD_SEARCH_SYNC_API_URL=http://search-sync-api:8083

backend/src/bin/scripts/unleash-init.ts

@@ -244,6 +244,9 @@ const constaintConfiguration = {
     ],
   ],
 
+  // New sentiment
+  [FeatureFlag.NEW_SENTIMENT]: [],
+
   [FeatureFlag.SYNCHRONOUS_OPENSEARCH_UPDATES]: [
     [
       {

frontend/src/modules/activity/components/activity-sentiment.vue

@@ -2,7 +2,7 @@
   <el-tooltip
     v-if="sentiment && sentiment > 0"
     effect="dark"
-    :content="`Sentiment score: ${sentiment}`"
+    :content="`${label} sentiment`"
     placement="top"
   >
     <i

services/apps/data_sink_worker/config/custom-environment-variables.json

@@ -16,7 +16,8 @@
   "sentiment": {
     "region": "CROWD_COMPREHEND_AWS_REGION",
     "accessKeyId": "CROWD_COMPREHEND_AWS_ACCESS_KEY_ID",
-    "secretAccessKey": "CROWD_COMPREHEND_AWS_SECRET_ACCESS_KEY"
+    "secretAccessKey": "CROWD_COMPREHEND_AWS_SECRET_ACCESS_KEY",
+    "huggingfaceApiKey": "CROWD_HUGGINGFACE_API_KEY"
   },
   "slackAlerting": {
     "url": "CROWD_SLACK_ALERTING_URL"

services/apps/data_sink_worker/src/service/activity.service.ts

@@ -46,8 +46,24 @@ export default class ActivityService extends LoggerBase {
   ): Promise<string> {
     try {
       this.log.debug('Creating an activity.')
-
-      const sentiment = await getSentiment(`${activity.body || ''} ${activity.title || ''}`.trim())
+      // TODO: isNewSentimentEnabled FF
+      const isNewSentimentEnabled = await isFeatureEnabled(
+        FeatureFlag.NEW_SENTIMENT,
+        async () => {
+          return {
+            tenantId,
+          }
+        },
+        this.unleash,
+        this.redisClient,
+        60,
+        tenantId,
+      )
+
+      const sentiment = await getSentiment(
+        `${activity.body || ''} ${activity.title || ''}`.trim(),
+        isNewSentimentEnabled,
+      )
 
       const id = await this.store.transactionally(async (txStore) => {
         const txRepo = new ActivityRepository(txStore, this.log)
@@ -160,7 +176,7 @@ export default class ActivityService extends LoggerBase {
         const txRepo = new ActivityRepository(txStore, this.log)
         const txSettingsRepo = new SettingsRepository(txStore, this.log)
 
-        const toUpdate = await this.mergeActivityData(activity, original)
+        const toUpdate = await this.mergeActivityData(activity, original, tenantId)
 
         if (toUpdate.type) {
           await txSettingsRepo.createActivityType(
@@ -222,9 +238,24 @@ export default class ActivityService extends LoggerBase {
   private async mergeActivityData(
     data: IActivityUpdateData,
     original: IDbActivity,
+    tenantId: string,
   ): Promise<IDbActivityUpdateData> {
     let calcSentiment = false
 
+    // TODO: isNewSentimentEnabled FF
+    const isNewSentimentEnabled = await isFeatureEnabled(
+      FeatureFlag.NEW_SENTIMENT,
+      async () => {
+        return {
+          tenantId,
+        }
+      },
+      this.unleash,
+      this.redisClient,
+      60,
+      tenantId,
+    )
+
     let body: string | undefined
     if (!arePrimitivesDbEqual(original.body, data.body)) {
       body = data.body
@@ -239,7 +270,7 @@ export default class ActivityService extends LoggerBase {
 
     let sentiment: Promise<ISentimentAnalysisResult | undefined>
     if (calcSentiment) {
-      sentiment = getSentiment(`${body || ''} ${title || ''}`.trim())
+      sentiment = getSentiment(`${body || ''} ${title || ''}`.trim(), isNewSentimentEnabled)
     } else {
       sentiment = Promise.resolve(undefined)
     }

services/libs/sentiment/package.json

@@ -21,6 +21,7 @@
   "dependencies": {
     "@aws-sdk/client-comprehend": "^3.335.0",
     "@crowd/common": "file:../common",
-    "@crowd/logging": "file:../logging"
+    "@crowd/logging": "file:../logging",
+    "axios": "^1.6.1"
   }
 }