feat: world manifest

src/entities/CheckScenes/task/taskRunnerSqs.ts

@@ -1,5 +1,10 @@
 import { randomUUID } from "crypto"
 
+import AWS from "aws-sdk"
+import env from "decentraland-gatsby/dist/utils/env"
+import fetch from "node-fetch"
+import { retry } from "radash"
+
 import CategoryModel from "../../Category/model"
 import { DecentralandCategories } from "../../Category/types"
 import PlaceModel from "../../Place/model"
@@ -14,7 +19,7 @@ import {
 } from "../../Slack/utils"
 import CheckScenesModel from "../model"
 import { CheckSceneLogsTypes } from "../types"
-import { getWorldAbout } from "../utils"
+import { calculateWorldManifestPositions, getWorldAbout } from "../utils"
 import { DeploymentToSqs } from "./consumer"
 import {
   ProcessEntitySceneResult,
@@ -43,6 +48,50 @@ const placesAttributes: Array<keyof PlaceAttributes> = [
   "textsearch",
 ]
 
+const ACCESS_KEY = env("AWS_ACCESS_KEY")
+const ACCESS_SECRET = env("AWS_ACCESS_SECRET")
+const BUCKET_HOSTNAME = env("BUCKET_HOSTNAME")
+const BUCKET_NAME = env("AWS_BUCKET_NAME", "")
+
+async function updateWorldManifest() {
+  const s3 = new AWS.S3({
+    accessKeyId: ACCESS_KEY,
+    secretAccessKey: ACCESS_SECRET,
+  })
+
+  const signedUrl = await retry({ times: 10, delay: 100 }, async () => {
+    const responseUrl = s3.getSignedUrl("putObject", {
+      Bucket: BUCKET_NAME,
+      Key: `WorldManifest.json`,
+      Expires: 60 * 1000,
+      ContentType: "application/json",
+      ACL: "public-read",
+      CacheControl: "no-store, no-cache, must-revalidate, proxy-revalidate",
+    })
+
+    const url = new URL(responseUrl)
+    if (url.searchParams.size === 0) {
+      throw new Error("Invalid AWS response")
+    }
+
+    if (BUCKET_HOSTNAME) {
+      url.hostname = BUCKET_HOSTNAME
+    }
+
+    return url.toString()
+  })
+
+  const worldManifestPositions = await calculateWorldManifestPositions()
+
+  return await fetch(signedUrl, {
+    method: "PUT",
+    headers: {
+      "Content-Type": "application/json",
+    },
+    body: JSON.stringify(worldManifestPositions),
+  })
+}
+
 export async function taskRunnerSqs(job: DeploymentToSqs) {
   const contentEntityScene = await processEntityId(job)
 
@@ -228,6 +277,9 @@ export async function taskRunnerSqs(job: DeploymentToSqs) {
 
     await CheckScenesModel.createMany(placesToDisable)
   }
+
+  // do not await so it is done on background
+  updateWorldManifest()
 }
 
 async function getValidCategories(creatorTags: string[]) {

src/entities/CheckScenes/utils.ts

@@ -10,6 +10,8 @@ import ContentServer from "decentraland-gatsby/dist/utils/api/ContentServer"
 
 import areSamePositions from "../../utils/array/areSamePositions"
 import { PlaceAttributes } from "../Place/types"
+import PlacePositionModel from "../PlacePosition/model"
+import roadCoordinates from "./RoadCoordinates.json"
 import { DeploymentTrackAttributes, WorldAbout } from "./types"
 
 /** @deprecated */
@@ -88,3 +90,24 @@ export async function getWorldAbout(
   const worldContentServer = await ContentServer.getInstanceFrom(url)
   return worldContentServer.fetch(`/world/${worldName}/about`)
 }
+
+export async function calculateWorldManifestPositions() {
+  const occupiedPositions = await PlacePositionModel.find({})
+  const emptyPositions = []
+
+  for (let x = -150; x <= 150; x++) {
+    for (let y = -150; y <= 150; y++) {
+      const position = [x.toString(), y.toString()]
+      if (
+        !occupiedPositions.some((place) =>
+          areSamePositions(place.positions, position)
+        ) &&
+        !areSamePositions(roadCoordinates, position)
+      ) {
+        emptyPositions.push(position)
+      }
+    }
+  }
+
+  return { occupiedPositions, emptyPositions, roadPositions: roadCoordinates }
+}