Merge pull request #31 from xeptagondev/iverfiy-rdc-be

Iverfiy rdc be

Author: palindaa

apps/triage/src/app/app.service.ts

@@ -8,6 +8,13 @@ import { PerspectiveClientService } from '@iverify/perspective-client/src/lib/pe
 import { MlServiceType } from '@iverify/iverify-common';
 import { TranslateService } from './TranslateService/TranslateService';
 
+const RadioFilterConvert = {
+  "Désinfo - Politique": "POLITIQUE",
+  "Désinfo - Sécurité": "SÉCURITÉ",
+  "Désinfo - Genre et Société":"GENRE ET SOCIÉTÉ",
+  "Désinfo - Environment et Santé":"ENVIRONNEMENT ET SANTÉ",
+}
+
 @Injectable()
 export class AppService {
   private readonly logger = new Logger('TriageAppService');
@@ -23,7 +30,7 @@ export class AppService {
     private translate: TranslateService
     ){}
 
-  async pullRadioMessages(): Promise<number> {
+  async pullRadioMessages(): Promise<any> {
     if (this.config.enableRadioMessages != 'true') {
       this.logger.log('Radio messages feature disabled')
       return
@@ -51,23 +58,47 @@ export class AppService {
    const pageIndex = pageCount - 1;
    let createdItems = [];
    let createdPosts = [];
-   for(let page = pageIndex ; page >=0 ; page --) {
-       const list = await this.unitedwaveClient.getPosts(page,startTime).toPromise();
-       for (let i = list.length - 1; i >= 0; i--) {
-        const post = list[i];
-        const title = ['radio', post?.keywords, post?.date_reported]
-        .filter(Boolean)
-        .join(' - ');
+   for (let page = pageIndex; page >= 0; page--) {
+     const list = await this.unitedwaveClient
+       .getPosts(page, startTime)
+       .toPromise();
+     for (let i = list.length - 1; i >= 0; i--) {
+       const post = list[i];
+       const title = ['radio', post?.keywords, post?.date_reported]
+         .filter(Boolean)
+         .join(' - ');
+       const arr = post.filters.split(',');
+
+       const realValue = arr.find((item) => RadioFilterConvert[item]) || '';
+       const category:string = RadioFilterConvert[realValue] || '';
+
+       console.log('posts-category', category, title);
        // check  duplication
-        const isDuplicate = this.isDuplicatePost(post, createdPosts);
-        if (!isDuplicate) {
-          const item = await this.checkClient.createItemFromRadio(post?.clip_url, title, post?.source_text, post?.date_reported).toPromise();
-          if(!item.error) {
+       const isDuplicate = this.isDuplicatePost(post, createdPosts);
+       if (!isDuplicate) {
+        try {
+          const item = await this.checkClient.createItemFromRadio(
+            post?.clip_url,
+            title,
+            post?.source_text,
+            post?.date_reported
+          ).toPromise();
+
+          if (item && !item.error) {
             createdItems = [...createdItems, item];
             createdPosts = [...createdPosts, post];
+
+            if (category) {
+              const annotationList = item.data.createProjectMedia.project_media.tasks.edges;
+
+              await this.checkClient.UpdateRadioCategory(category, annotationList).toPromise();
+            }
           }
+        } catch (error) {
+          console.error('Error while creating item:', error);
         }
       }
+     }
    }
     this.logger.log(`Created ${createdItems.length} items.`)
     return createdItems.length;

libs/common/src/lib/tasks-labels.ts

@@ -41,7 +41,8 @@ export const TasksLabels = {
         upload_file: 'Upload Files',
         audio_url:'audio_url',
         message:'message',
-        original_reported_date: 'original_reported_date'
+        original_reported_date: 'original_reported_date',
+        meedan_category:'category'
     },
     es: {
         claim: 'Declaración',
@@ -85,7 +86,8 @@ export const TasksLabels = {
         upload_file: 'Upload Files',
         audio_url:'audio_url',
         message:'message',
-        original_reported_date: 'original_reported_date'
+        original_reported_date: 'original_reported_date',
+        meedan_category:'categoria'
     },
     fr: {
         claim: 'Affirmation',
@@ -129,7 +131,8 @@ export const TasksLabels = {
         upload_file: 'Téléchargements de fichiers',
         audio_url:'url_audio',
         message:'message',
-        original_reported_date: 'date_de_rapport_originale'
+        original_reported_date: 'date_de_rapport_originale',
+        meedan_category:'Catégorie'
     },
     mkd: {
       claim: 'Тврдење',
@@ -173,6 +176,7 @@ export const TasksLabels = {
       upload_file: 'Upload Files',
       audio_url:'audio_url',
       message:'message',
-      original_reported_date: 'original_reported_date'
+      original_reported_date: 'original_reported_date',
+      meedan_category:'category'
   },
 }

libs/meedan-check-client/src/lib/helper.service.ts

@@ -101,6 +101,15 @@ export class CheckClientHelperService {
             project_media {
               dbid
               id
+              tasks {
+              edges {
+                node {
+                  id
+                  fieldset
+                  label
+                }
+              }
+            }
             }
           }
         }

libs/meedan-check-client/src/lib/meedan-check-client.service.ts

@@ -189,7 +189,7 @@ export class MeedanCheckClientService {
   }
 
   private getAnnotationId(annotationList: any[], label: string): string {
-    console.log('getAnnotationId', annotationList)
+ //   console.log('getAnnotationId', annotationList)
     return annotationList
       .filter((edge) => edge.node.label === label)
       .map((edge) => edge.node.id)
@@ -246,6 +246,26 @@ export class MeedanCheckClientService {
     return this.postData(combinedQuery, headers);
   }
 
+   UpdateRadioCategory(
+    category: string,
+    annotationList?: any[],
+  ): Observable<any> {
+    const headers = this.config.headers;
+    const categoryId = this.getAnnotationId(
+      annotationList,
+      TasksLabels[this.lang].meedan_category
+    );
+    console.log('UpdateRadioCategory',categoryId,category)
+    const combinedQuery = this.helper.buildAnnotationItemsCombinedFromWpMutation(
+      categoryId,
+      'task_response_single_choice',
+      'response_single_choice',
+      category
+    );
+
+    return this.postData(combinedQuery, headers);
+  }
+
   private async handleFiles(
     files: string[],
     headers: any,