hookified

import { Hookified, Hook, WaterfallHook } from 'hookified'; class MyService extends Hookified { constructor() { super(); this.data = { count: 0, items: [] }; } async processData(input: string) { await this.hook('beforeProcess', input); this.data.count++; this.data.items.push(input.toUpperCase()); await this.hook('afterProcess', this.data); return this.data; } async saveData(initialData: any) { const processedData = await this.hook('saveData', initialData); console.log('Final data saved:', processedData); this.emit('dataSaved', processedData); } } const service = new MyService(); // Register a standard hook handler for 'beforeProcess' service.onHook({ event: 'beforeProcess', handler: async (input: string) => { console.log(`[Hook: beforeProcess] Input received: ${input}`); } }); // Register another hook for 'afterProcess' service.onHook('afterProcess', (data: { count: number }) => { console.log(`[Hook: afterProcess] Current count: ${data.count}`); }); // Register a WaterfallHook for 'saveData' to transform data sequentially const transformHook = new WaterfallHook('saveData', ({ args, results }) => { const currentResult = results.length > 0 ? results[results.length - 1].result : args[0]; const transformed = { ...currentResult, timestamp: Date.now(), processedBy: 'transformHook' }; console.log('[WaterfallHook: saveData] Data transformed.'); return transformed; }); service.onHook(transformHook); // Register an event listener service.on('dataSaved', (data) => { console.log(`[Event: dataSaved] Event emitted with data: ${JSON.stringify(data)}`); }); // Run the service (async () => { console.log('--- Starting processData ---'); await service.processData('hello world'); await service.processData('hookified'); console.log('--- Finished processData ---\n'); console.log('--- Starting saveData ---'); await service.saveData({ id: 1, value: 'initial' }); console.log('--- Finished saveData ---'); // Example of using a hook programmatically (equivalent to onHook but for single use) await service.onceHook(new Hook('afterProcess', (data) => { console.log(`[Hook: onceHook] Special one-time afterProcess hook triggered with count: ${data.count}`); })); await service.processData('one-time-hook-test'); })();