atma-io-middleware-base

import { create } from 'atma-io-middleware-base'; import { File, type IFileMiddleware } from 'atma-io'; // Peer dependency interface MyCustomOptions { prefix?: string; } // Define the middleware configuration const myMiddleware: IFileMiddleware<MyCustomOptions> = create<MyCustomOptions>({ name: 'my-super-middleware', // Synchronous processing example process(content, filename, options) { const prefixedContent = options.prefix ? `${options.prefix}: ${content}` : content; console.log(`Processing sync file: ${filename}`); return { content: prefixedContent }; }, // Asynchronous processing example (recommended for heavy tasks) async processAsync(content, filename, options) { return new Promise((resolve) => { setTimeout(() => { const prefixedContent = options.prefix ? `${options.prefix} (async): ${content}` : content; console.log(`Processing async file: ${filename}`); resolve({ content: prefixedContent }); }, 50); }); } }); // In a real application, you would register this middleware with atma-io // For demonstration, we'll just show its structure. console.log(`Middleware created: ${myMiddleware.name}`); // Example of how atma-io might use it (conceptual) const mockFileContent = 'Hello, Atma.js!'; const mockFilename = 'test.txt'; const mockOptions = { prefix: 'DEBUG' }; // Simulate synchronous process call const syncResult = myMiddleware.process?.(mockFileContent, mockFilename, mockOptions); console.log('Sync Result:', syncResult?.content); // Simulate asynchronous processAsync call myMiddleware.processAsync?.(mockFileContent, mockFilename, mockOptions) .then(asyncResult => console.log('Async Result:', asyncResult.content));