fix radio category update issue

Author: Janith Rathnayaka

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

@@ -30,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
@@ -72,24 +72,32 @@ export class AppService {
        const realValue = arr.find((item) => RadioFilterConvert[item]) || '';
        const category:string = RadioFilterConvert[realValue] || '';
 
-       console.log('posts-category', category, post.cl_id);
+       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,
-             category
-           )
-           .toPromise();
-         if (!item.error) {
-           createdItems = [...createdItems, item];
-           createdPosts = [...createdPosts, post];
-         }
-       }
+        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.`)

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

@@ -132,7 +132,7 @@ export const TasksLabels = {
         audio_url:'url_audio',
         message:'message',
         original_reported_date: 'date_de_rapport_originale',
-        meedan_category:'type_de_categorie'
+        meedan_category:'Catégorie'
     },
     mkd: {
       claim: 'Тврдење',

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

@@ -79,12 +79,11 @@ export class CheckClientHelperService {
     }
 
 
-    buildCreateItemFromRadioMessage(url: string, name, content, created_date, category:string,tag = 'Radio') {
+    buildCreateItemFromRadioMessage(url: string, name, content, created_date, tag = 'Radio') {
       const tasksResponsesObj = {
         [TasksLabels[this.lang].audio_url]: url,
         [TasksLabels[this.lang].message]: content,
         [TasksLabels[this.lang].original_reported_date]: created_date,
-        [TasksLabels[this.lang].meedan_category]: category
       };
       let setTasksResponses = JSON.stringify(tasksResponsesObj);
       setTasksResponses = setTasksResponses.replace(/\\/g, '\\\\').replace(/"/g, '\\"');
@@ -102,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,
@@ -281,8 +301,8 @@ export class MeedanCheckClientService {
   }
 
 
-  createItemFromRadio(url: string, name: string, content: string, created_date: string, category:string): Observable<any>{
-    const query: string = this.helper.buildCreateItemFromRadioMessage(url, name, content, created_date, category);
+  createItemFromRadio(url: string, name: string, content: string, created_date: string): Observable<any>{
+    const query: string = this.helper.buildCreateItemFromRadioMessage(url, name, content, created_date);
     const headers = this.config.headers;
 
     return this.http.post(this.config.checkApiUrl, {query}, {headers}).pipe(