fix opted out issue

Joystream · Oct 23, 2024 · 9b51db5 · 9b51db5
1 parent 96b6539
commit 9b51db5
Show file tree

Hide file tree

Showing 2 changed files with 31 additions and 20 deletions.
diff --git a/config.yml b/config.yml
@@ -8,7 +8,7 @@ sync:
   enable: true
   downloadsDir: ./local/data
   intervals: # in minutes
-    youtubePolling: 1440 # 24 hours
+    youtubePolling: 2 # 24 hours
     contentProcessing: 1
   limits:
     dailyApiQuota:

diff --git a/src/services/syncProcessing/YoutubePollingService.ts b/src/services/syncProcessing/YoutubePollingService.ts
@@ -86,20 +86,25 @@ export class YoutubePollingService {
   private async performChannelsIngestion(): Promise<YtChannel[]> {
     // get all channels that need to be ingested
     const channelsWithSyncEnabled = async () =>
-      await this.dynamodbService.repo.channels.scan({}, (scan) =>
-        scan
-          .filter('yppStatus')
-          .in(['Unverified', ...verifiedVariants])
-          .where('shouldBeIngested')
-          .eq(true)
-          .and()
-          .where('allowOperatorIngestion')
-          .eq(true)
-          .and()
-          // * Unauthorized channels add by infra operator are exempted from periodic
-          // * ingestion as we don't have access to their access/refresh tokens
-          .where('performUnauthorizedSync')
-          .eq(false)
+      await this.dynamodbService.repo.channels.scan(
+        {},
+        (scan) =>
+          scan
+            .filter('yppStatus')
+            .in(['Unverified', ...verifiedVariants])
+            .where('shouldBeIngested')
+            .eq(true)
+            .and()
+            .where('allowOperatorIngestion')
+            .eq(true)
+            .and()
+            // * Unauthorized channels add by infra operator are exempted from periodic
+            // * ingestion as we don't have access to their access/refresh tokens
+            .where('performUnauthorizedSync')
+            .eq(false)
+        // .and()
+        // .where('id')
+        // .eq('UCBWgpKlykQ8yPAEmTGdsXxw')
       )
 
     // updated channel objects with uptodate info
@@ -191,12 +196,18 @@ export class YoutubePollingService {
           `Opting out '${channel.id}' from YPP program as their owner has revoked the permissions from Google settings`
         )
 
-        await this.dynamodbService.repo.channels.save({
-          ...channel,
-          yppStatus: 'OptedOut',
-          shouldBeIngested: false,
-          lastActedAt: new Date(),
+        this.logger.debug(`Google permissions error`, {
+          err,
+          channelId: channel.joystreamChannelId,
+          ytChannelId: channel.id,
         })
+
+        // await this.dynamodbService.repo.channels.save({
+        //   ...channel,
+        //   yppStatus: 'OptedOut',
+        //   shouldBeIngested: false,
+        //   lastActedAt: new Date(),
+        // })
         return
       }