fix: prevent reboot (#512)

decentraland · Dec 3, 2024 · 2520f32 · 2520f32
1 parent f1e9263
commit 2520f32
Showing 1 changed file with 31 additions and 11 deletions.
diff --git a/src/adapters/deployer/index.ts b/src/adapters/deployer/index.ts
@@ -39,15 +39,31 @@ export function createDeployerComponent(
             servers: servers.join(',')
           })
 
-          await downloadEntityAndContentFiles(
-            { ...components, fetcher: components.fetch },
-            entity.entityId,
-            servers,
-            new Map(),
-            'content',
-            10,
-            1000
-          )
+          try {
+            await downloadEntityAndContentFiles(
+              { ...components, fetcher: components.fetch },
+              entity.entityId,
+              servers,
+              new Map(),
+              'content',
+              10,
+              1000
+            )
+          } catch (error: any) {
+            logger.error('Failed to download entity', {
+              entityId: entity.entityId,
+              entityType: entity.entityType,
+              errorMessage: error.message
+            })
+
+            const match = error.message?.match(/status: 4\d{2}/)
+
+            if (match) {
+              await markAsDeployed()
+            }
+
+            return
+          }
 
           logger.info('Entity stored', { entityId: entity.entityId, entityType: entity.entityType })
 
@@ -66,7 +82,9 @@ export function createDeployerComponent(
             )
             logger.info('Notification sent', {
               messageId: receipt.MessageId as any,
-              sequenceNumber: receipt.SequenceNumber as any
+              sequenceNumber: receipt.SequenceNumber as any,
+              entityId: entity.entityId,
+              entityType: entity.entityType
             })
           }
 
@@ -90,7 +108,9 @@ export function createDeployerComponent(
             )
             logger.info('Notification sent to events SNS', {
               MessageId: receipt.MessageId as any,
-              SequenceNumber: receipt.SequenceNumber as any
+              SequenceNumber: receipt.SequenceNumber as any,
+              entityId: entity.entityId,
+              entityType: entity.entityType
             })
           }
           await markAsDeployed()