53 lines
2.7 KiB
TypeScript
53 lines
2.7 KiB
TypeScript
/**
|
|
* MetaMesh Plugin: anime-detector
|
|
*
|
|
* ============================================================================
|
|
* PLUGIN MOUNT ARCHITECTURE - DO NOT MODIFY WITHOUT AUTHORIZATION
|
|
* ============================================================================
|
|
*
|
|
* Each plugin container has exactly 3 mounts (2 for plugins without output):
|
|
*
|
|
* 1. /files (READ-ONLY) - Shared media files, read access only
|
|
* 2. /cache (READ-WRITE) - Plugin-specific cache folder
|
|
* 3. /files/plugin/<id> (READ-WRITE) - Plugin output folder (if needed)
|
|
*
|
|
* This plugin (anime-detector) only requires mount 2:
|
|
* - /cache (RW) - to cache detection results
|
|
* - Note: This plugin analyzes metadata, doesn't read files directly
|
|
*
|
|
* SECURITY: Plugins must NEVER write to /files directly.
|
|
* All write operations go to /cache or /files/plugin/<id> only.
|
|
*
|
|
* ============================================================================
|
|
*/
|
|
|
|
import Fastify from 'fastify';
|
|
import type { HealthResponse, ProcessRequest, ProcessResponse, CallbackPayload, ConfigureRequest, ConfigureResponse } from './types.js';
|
|
import { manifest, process as processFile } from './plugin.js';
|
|
import { startBeacon, stopBeacon } from './beacon-advertise.js';
|
|
|
|
const app = Fastify({ logger: true });
|
|
let ready = false;
|
|
|
|
app.get('/health', async (): Promise<HealthResponse> => ({ status: 'healthy', ready, version: manifest.version }));
|
|
app.get('/manifest', async () => manifest);
|
|
app.post<{ Body: ConfigureRequest }>('/configure', async (request): Promise<ConfigureResponse> => {
|
|
console.log(`[${manifest.id}] Configuration updated`);
|
|
return { status: 'ok' };
|
|
});
|
|
app.post<{ Body: ProcessRequest }>('/process', async (request, reply) => {
|
|
const { taskId, cid, filePath, callbackUrl, metaCoreUrl } = request.body;
|
|
if (!taskId || !cid || !filePath || !callbackUrl || !metaCoreUrl) {
|
|
return reply.send({ status: 'rejected', error: 'Missing required fields' } as ProcessResponse);
|
|
}
|
|
processFile(request.body, async (payload: CallbackPayload) => {
|
|
try { await fetch(callbackUrl, { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify(payload) }); }
|
|
catch (error) { console.error(`[${manifest.id}] Callback error:`, error); }
|
|
}).catch(console.error);
|
|
return reply.send({ status: 'accepted' } as ProcessResponse);
|
|
});
|
|
|
|
const port = parseInt(process.env.PORT || '8080', 10);
|
|
app.listen({ port, host: '0.0.0.0' }).then(() => { startBeacon(manifest.id, manifest.version, port); ready = true; console.log(`[${manifest.id}] Listening on port ${port}`); });
|
|
process.on('SIGTERM', async () => { await stopBeacon(); ready = false; await app.close(); process.exit(0); });
|