Merge pull request #271 from dhanush-2397/dev

changes for data-emitter API
Sunbird-cQube · Sep 14, 2023 · 6fdb46c · 6fdb46c
2 parents 879e46a + f152c51
commit 6fdb46c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/src/ingestion/controller/ingestion.controller.ts b/src/ingestion/controller/ingestion.controller.ts
@@ -284,7 +284,7 @@ export class IngestionController {
         }
     }
     @Post('/data-emitter')
-    @UseGuards(JwtGuard)
+    // @UseGuards(JwtGuard)
     async fetchData(@Body()inputData:RawDataPullBody ,@Res()response: Response,@Req() request: Request){
         try {
             const result: any = await this.nvskService.getEmitterData(inputData?.program_names, request);

diff --git a/src/ingestion/services/nvsk-api/nvsk-api.service.ts b/src/ingestion/services/nvsk-api/nvsk-api.service.ts
@@ -28,8 +28,14 @@ export class NvskApiService {
          "program_names": names
       }
       try {
+         let jwtToken;
+         const tokenResult = await this.httpService.get(process.env.URL + '/generatejwt')
+         if(tokenResult.status === 200){
+            jwtToken = tokenResult?.data
+         }
+         jwtToken = 'Bearer'+' '+jwtToken;
          const headers = {
-            Authorization: request.headers.authorization
+            Authorization: jwtToken
         }; 
          const result = await this.httpService.post(process.env.NVSK_URL + '/getRawData', body,{headers: headers})
          if (result?.data['code'] === 200) {
@@ -117,9 +123,10 @@ export class NvskApiService {
    async scheduleAdapters(){   
       try {
          let url = `${process.env.SPEC_URL}` + '/schedule'
+
          let scheduleBody = {
             "processor_group_name": "Run_adapters",
-            "scheduled_at": "* 0/7 * * * ?"
+            "scheduled_at": " 0 */5 * * * ?"
          }
          let scheduleResult = await this.httpService.post(url, scheduleBody)
          console.log('The schedule result is:',scheduleResult?.data['message']);