chore: update snapshots fetcher

package.json

@@ -15,14 +15,15 @@
     "semi": false
   },
   "dependencies": {
-    "@dcl/catalyst-storage": "^2.0.3",
     "@dcl/schemas": "^6.6.0",
+    "@dcl/catalyst-storage": "^2.0.3",
     "@dcl/snapshots-fetcher": "^5.0.4",
+    "@types/destroy": "^1.0.0",
     "@well-known-components/env-config-provider": "^1.1.1",
     "@well-known-components/http-server": "^1.1.1",
     "@well-known-components/interfaces": "^1.1.1",
     "@well-known-components/logger": "^3.0.0",
     "@well-known-components/metrics": "^2.0.1",
     "aws-sdk": "^2.1138.0"
   }
-}
+}

src/adapters/deployer/index.ts

@@ -2,7 +2,7 @@ import { downloadEntityAndContentFiles } from "@dcl/snapshots-fetcher"
 import { IDeployerComponent } from "@dcl/snapshots-fetcher/dist/types"
 import { SNS } from "aws-sdk"
 import { AppComponents } from "../../types"
-import { DeploymentToSqs } from "@dcl/schemas/dist/misc/deployments-to-sqs";
+import { DeploymentToSqs } from "@dcl/schemas/dist/misc/deployments-to-sqs"
 
 export function createDeployerComponent(
   components: Pick<AppComponents, "logs" | "storage" | "downloadQueue" | "fetch" | "metrics" | "sns">
@@ -13,6 +13,7 @@ export function createDeployerComponent(
 
   return {
     async deployEntity(entity, servers) {
+      const markAsDeployed = entity.markAsDeployed ? entity.markAsDeployed : async () => { }
       if (entity.entityType == "scene" || entity.entityType == "wearable" || entity.entityType == "emote") {
         const exists = await components.storage.exist(entity.entityId)
 
@@ -51,10 +52,15 @@ export function createDeployerComponent(
                 SequenceNumber: receipt.SequenceNumber as any,
               })
             }
+            await markAsDeployed()
           })
+        } else {
+          await markAsDeployed()
         }
+      } else {
+        await markAsDeployed()
       }
     },
-    async onIdle() {},
+    async onIdle() { },
   }
 }

src/components.ts

@@ -123,5 +123,7 @@ export async function initComponents(): Promise<AppComponents> {
     synchronizer,
     deployer,
     sns,
+    processedSnapshotStorage,
+    snapshotStorage
   }
 }

src/types.ts

@@ -1,5 +1,6 @@
 import { IJobQueue } from "@dcl/snapshots-fetcher/dist/job-queue-port"
-import { IDeployerComponent, SynchronizerComponent } from "@dcl/snapshots-fetcher/dist/types"
+import { IDeployerComponent, IProcessedSnapshotStorageComponent, ISnapshotStorageComponent, SynchronizerComponent } from "@dcl/snapshots-fetcher/dist/types"
+
 import type { IFetchComponent } from "@well-known-components/http-server"
 import type {
   IConfigComponent,
@@ -26,6 +27,10 @@ export type BaseComponents = {
   fs: IFileSystemComponent
   storage: IContentStorageComponent
   synchronizer: SynchronizerComponent
+
+  processedSnapshotStorage: IProcessedSnapshotStorageComponent
+  snapshotStorage: ISnapshotStorageComponent
+
   deployer: IDeployerComponent
   sns: SnsComponent
 }
@@ -47,11 +52,11 @@ export type TestComponents = BaseComponents & {
 export type HandlerContextWithPath<
   ComponentNames extends keyof AppComponents,
   Path extends string = any
-> = IHttpServerComponent.PathAwareContext<
-  IHttpServerComponent.DefaultContext<{
-    components: Pick<AppComponents, ComponentNames>
-  }>,
-  Path
->
+  > = IHttpServerComponent.PathAwareContext<
+    IHttpServerComponent.DefaultContext<{
+      components: Pick<AppComponents, ComponentNames>
+    }>,
+    Path
+  >
 
 export type Context<Path extends string = any> = IHttpServerComponent.PathAwareContext<GlobalContext, Path>