Add smaller GeoPDF test

Author: ingalls

tasks/events/src/worker.ts

@@ -271,15 +271,15 @@ export default class Worker extends EventEmitter {
                 body: JSON.stringify({
                     name: json.name,
                     url: json.url,
-                    minzoom: basemap.minZoom,
-                    maxzoom: basemap.maxZoom,
-                    format: basemap.tileType,
+                    minzoom: json.minZoom,
+                    maxzoom: json.maxZoom,
+                    format: json.tileType,
                 })
             });
 
-            if (!icon_req.ok) console.error(await icon_req.text());
+            if (!basemap_req.ok) console.error(await basemap_req.text());
         } catch (err) {
-            console.log(`Import: ${this.msg.job.id} - ${file} is not a Basemap:`, err.message);
+            console.log(`Import: ${this.msg.job.id} - ${file} is not a Basemap:`, err instanceof Error ? err.message : String(err));
         }
     }
 }

tasks/events/test/fixtures/transform-raster/US-Capital-image.pdf

@@ -0,0 +1,111 @@
+import test from 'tape';
+import path from 'node:path';
+import Worker from '../src/worker.js';
+import fs from 'node:fs';
+import fsp from 'node:fs/promises';
+import Sinon from 'sinon';
+import {
+    S3Client,
+    GetObjectCommand,
+    PutObjectCommand,
+} from '@aws-sdk/client-s3';
+import { MockAgent, setGlobalDispatcher, getGlobalDispatcher } from 'undici';
+
+for (const fixturename of await fsp.readdir(new URL('./fixtures/transform-raster/', import.meta.url))) {
+    const { ext } = path.parse(fixturename);
+
+    test(`Worker Data Transform Raster: ${fixturename}`, async (t) => {
+        let id: string;
+
+        const mockAgent = new MockAgent();
+        const originalDispatcher = getGlobalDispatcher();
+        mockAgent.disableNetConnect();
+        setGlobalDispatcher(mockAgent);
+        const mockPool = mockAgent.get('http://localhost:5001');
+
+        mockPool.intercept({
+            path: /profile\/asset/,
+            method: 'POST'
+        }).reply((req) => {
+            const body = JSON.parse(req.body) as {
+                id: string
+            };
+
+            id = body.id;
+
+            return {
+                statusCode: 200,
+                data: JSON.stringify({
+                    id: body.id
+                })
+            };
+        });
+
+        const ExternalOperations = [
+                (command) => {
+                    t.ok(command instanceof GetObjectCommand);
+                    t.deepEquals(command.input, {
+                        Bucket: 'test-bucket',
+                        Key: `import/ba58a298-a3fe-46b4-a29a-9dd33fbb2139${ext}`
+                    });
+
+                    return Promise.resolve({
+                        Body: fs.createReadStream(new URL(`./fixtures/transform-raster/${fixturename}`, import.meta.url))
+                    })
+                },
+                (command) => {
+                    t.ok(command instanceof PutObjectCommand);
+
+                    t.equals(command.input.Bucket, 'test-bucket')
+                    t.ok(command.input.Key.startsWith(`profile/admin@example.com/`))
+                    t.ok(command.input.Key.endsWith(ext))
+
+                    return Promise.resolve({});
+                },
+                (command) => {
+                    t.ok(command instanceof PutObjectCommand);
+
+                    t.equals(command.input.Bucket, 'test-bucket')
+                    t.equals(command.input.Key, `profile/admin@example.com/${id}.pmtiles`);
+
+                    return Promise.resolve({});
+                },
+        ].reverse();
+
+        Sinon.stub(S3Client.prototype, 'send').callsFake((command) => {
+            return ExternalOperations.pop()(command);
+        });
+
+        const worker = new Worker({
+            api: 'http://localhost:5001',
+            secret: 'coe-wildland-fire',
+            bucket: 'test-bucket',
+            job: {
+                id: 'ba58a298-a3fe-46b4-a29a-9dd33fbb2139',
+                created: '2025-08-25T18:08:21.563Z',
+                updated: '2025-08-25T18:08:21.563Z',
+                status: 'Running',
+                error: null,
+                result: {},
+                name: `import${ext}`,
+                username: 'admin@example.com',
+                source: 'Upload',
+                config: {},
+                source_id: null,
+            }
+        });
+
+        worker.on('error', (err) => {
+            t.error(err);
+        });
+
+        worker.on('success', () => {
+            Sinon.restore();
+            setGlobalDispatcher(originalDispatcher);
+            mockAgent.close();
+            t.end()
+        });
+
+        await worker.process()
+    });
+}

tasks/events/test/fixtures/transform-raster/bogata.tif

@@ -11,10 +11,10 @@ import {
 } from '@aws-sdk/client-s3';
 import { MockAgent, setGlobalDispatcher, getGlobalDispatcher } from 'undici';
 
-for (const fixturename of await fsp.readdir(new URL('./fixtures/transform/', import.meta.url))) {
+for (const fixturename of await fsp.readdir(new URL('./fixtures/transform-vector/', import.meta.url))) {
     const { ext } = path.parse(fixturename);
 
-    test(`Worker Data Transform: ${fixturename}`, async (t) => {
+    test(`Worker Data Transform Vector: ${fixturename}`, async (t) => {
         let id: string;
 
         const mockAgent = new MockAgent();
@@ -50,7 +50,7 @@ for (const fixturename of await fsp.readdir(new URL('./fixtures/transform/', imp
                     });
 
                     return Promise.resolve({
-                        Body: fs.createReadStream(new URL(`./fixtures/transform/${fixturename}`, import.meta.url))
+                        Body: fs.createReadStream(new URL(`./fixtures/transform-vector/${fixturename}`, import.meta.url))
                     })
                 },
                 (command) => {