feat!: simplify fastify maps plugin and add support for styled map packages

package.json

@@ -152,11 +152,10 @@
     "yazl": "^2.5.1"
   },
   "dependencies": {
+    "@comapeo/fallback-smp": "^1.0.0",
     "@comapeo/schema": "1.0.0",
     "@digidem/types": "^2.3.0",
-    "@electron/asar": "^3.2.8",
     "@fastify/error": "^3.4.1",
-    "@fastify/static": "^7.0.3",
     "@fastify/type-provider-typebox": "^4.1.0",
     "@hyperswarm/secret-stream": "^6.6.3",
     "@mapeo/crypto": "1.0.0-alpha.10",
@@ -192,6 +191,7 @@
     "sodium-universal": "^4.0.0",
     "start-stop-state-machine": "^1.2.0",
     "streamx": "^2.19.0",
+    "styled-map-package": "^1.1.0",
     "sub-encoder": "^2.1.1",
     "throttle-debounce": "^5.0.0",
     "tiny-typed-emitter": "^2.1.0",

src/fastify-plugins/maps.js

@@ -0,0 +1,65 @@
+import { fetch } from 'undici'
+import { Server as SMPServerPlugin } from 'styled-map-package'
+
+import { noop } from '../utils.js'
+
+/** @import { FastifyPluginAsync } from 'fastify' */
+
+export const CUSTOM_MAP_PREFIX = 'custom'
+export const FALLBACK_MAP_PREFIX = 'fallback'
+
+/**
+ * @typedef {Object} MapsPluginOpts
+ *
+ * @property {string | URL} defaultOnlineStyleUrl
+ * @property {string} [customMapPath]
+ * @property {string} fallbackMapPath
+ */
+
+/** @type {FastifyPluginAsync<MapsPluginOpts>} */
+export async function plugin(fastify, opts) {
+  if (opts.customMapPath) {
+    fastify.register(SMPServerPlugin, {
+      prefix: CUSTOM_MAP_PREFIX,
+      filepath: opts.customMapPath,
+    })
+  }
+
+  fastify.register(SMPServerPlugin, {
+    prefix: FALLBACK_MAP_PREFIX,
+    filepath: opts.fallbackMapPath,
+  })
+
+  fastify.get('/style.json', async (_request, reply) => {
+    const baseUrl = new URL(fastify.prefix, fastify.listeningOrigin)
+
+    // Important for using as a base for creating new URL objects
+    if (!baseUrl.href.endsWith('/')) {
+      baseUrl.href += '/'
+    }
+
+    /** @type {Array<string | URL>}*/
+    const styleUrls = [
+      opts.defaultOnlineStyleUrl,
+      new URL(`${FALLBACK_MAP_PREFIX}/style.json`, baseUrl),
+    ]
+
+    if (opts.customMapPath) {
+      styleUrls.unshift(new URL(`${CUSTOM_MAP_PREFIX}/style.json`, baseUrl))
+    }
+
+    for (const url of styleUrls) {
+      const resp = await fetch(url, { method: 'HEAD' }).catch(noop)
+
+      if (resp && resp.status === 200) {
+        return reply
+          .headers({
+            'cache-control': 'no-cache',
+          })
+          .redirect(url.toString())
+      }
+    }
+
+    return reply.status(404).send()
+  })
+}