fix: support maps that may be removed or replaced in map server plugin (

#906)

package.json

@@ -191,7 +191,7 @@
     "sodium-universal": "^4.0.0",
     "start-stop-state-machine": "^1.2.0",
     "streamx": "^2.19.0",
-    "styled-map-package": "^1.1.0",
+    "styled-map-package": "^2.0.0",
     "sub-encoder": "^2.1.1",
     "throttle-debounce": "^5.0.0",
     "tiny-typed-emitter": "^2.1.0",

src/fastify-plugins/maps.js

@@ -1,7 +1,7 @@
 import fs from 'node:fs/promises'
 import path from 'node:path'
 import { fetch } from 'undici'
-import { Server as SMPServerPlugin } from 'styled-map-package'
+import { ReaderWatch, Server as SMPServerPlugin } from 'styled-map-package'
 
 import { noop } from '../utils.js'
 import { NotFoundError, ENOENTError } from './utils.js'
@@ -25,6 +25,10 @@ export async function plugin(fastify, opts) {
   if (opts.customMapPath) {
     const { customMapPath } = opts
 
+    const customMapReader = new ReaderWatch(customMapPath)
+
+    fastify.addHook('onClose', () => customMapReader.close().catch(noop))
+
     fastify.get(`/${CUSTOM_MAP_PREFIX}/info`, async () => {
       const baseUrl = new URL(fastify.prefix, fastify.listeningOrigin)
 
@@ -78,13 +82,17 @@ export async function plugin(fastify, opts) {
 
     fastify.register(SMPServerPlugin, {
       prefix: CUSTOM_MAP_PREFIX,
-      filepath: customMapPath,
+      reader: customMapReader,
     })
   }
 
+  const fallbackMapReader = new ReaderWatch(opts.fallbackMapPath)
+
+  fastify.addHook('onClose', () => fallbackMapReader.close().catch(noop))
+
   fastify.register(SMPServerPlugin, {
     prefix: FALLBACK_MAP_PREFIX,
-    filepath: opts.fallbackMapPath,
+    reader: fallbackMapReader,
   })
 
   fastify.get('/style.json', async (_request, reply) => {