File size: 2,030 Bytes
3144483 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 | import { isRastermillError, isRastermillUnavailableError } from "rastermill";
import { serveWorkerTasks } from "../infra/worker-task-pool.js";
import { createLocalImageProcessor } from "./image-processor-config.js";
import type { ImageProcessorReply, ImageProcessorRequest } from "./image-processor.types.js";
// Native codecs stay in the caller, whose subprocess lifetime survives worker cancellation.
const defaultProcessor = createLocalImageProcessor("internal");
serveWorkerTasks<ImageProcessorReply>(
async (input) => {
// SAFETY: The owning image pool is the sole sender and builds this private request with the worker.
const request = input as ImageProcessorRequest;
try {
const processor = request.limits
? createLocalImageProcessor("internal", request.limits)
: defaultProcessor;
switch (request.kind) {
case "encode": {
const value = await processor.encode(request.input, request.options);
return { kind: request.kind, value: { ...value, data: Uint8Array.from(value.data) } };
}
case "transparency":
return { kind: request.kind, value: await processor.transparency(request.input) };
case "bmpToPng": {
const { convertBmpToPngWithPhoton } = await import("./photon.runtime.js");
return {
kind: request.kind,
value: Uint8Array.from(convertBmpToPngWithPhoton(Buffer.from(request.input))),
};
}
default:
throw new Error("Unsupported image worker operation");
}
} catch (error) {
return {
kind: "failed",
error: error instanceof Error ? error : new Error(String(error)),
...(isRastermillError(error) ? { code: error.code } : {}),
unavailable: isRastermillUnavailableError(error),
};
}
},
{
transferList: (reply) =>
reply.kind === "encode"
? [reply.value.data.buffer]
: reply.kind === "bmpToPng"
? [reply.value.buffer]
: [],
},
);
|