moleculer

import { ServiceBroker, ServiceSchema } from 'moleculer'; // Create a ServiceBroker const broker = new ServiceBroker({ nodeID: 'node-greeter-1', logLevel: 'info', transporter: 'NATS' // Or 'Redis', 'TCP', etc. }); // Define a Greeter Service const GreeterService: ServiceSchema = { name: 'greeter', settings: { defaultName: 'World' }, actions: { hello: { rest: 'GET /hello', async handler(ctx) { return `Hello ${ctx.params.name || this.settings.defaultName}`; } }, welcome: { async handler(ctx) { this.logger.info(`Welcoming ${ctx.params.name}...`); return `Welcome, ${ctx.params.name}`; } } }, events: { 'user.created': { async handler(ctx) { this.logger.info(`User created event received for ${ctx.params.username}`); } } }, async started() { this.logger.info(`Greeter service started on node ${broker.nodeID}`); }, async stopped() { this.logger.info(`Greeter service stopped on node ${broker.nodeID}`); } }; // Create a service from the schema broker.createService(GreeterService); // Start the broker broker.start() .then(async () => { // Call an action const res = await broker.call('greeter.hello', { name: 'Moleculer' }); console.log(res); // Emit an event await broker.emit('user.created', { username: 'Alice' }); // Call an action from another node if available (assuming multiple nodes) const welcomeMsg = await broker.call('greeter.welcome', { name: 'Bob' }); console.log(welcomeMsg); // Stop the broker after a delay or on signal setTimeout(() => broker.stop(), 5000); }) .catch(err => { broker.logger.error('Error starting broker:', err); });