mali

const Mali = require('mali'); const path = require('path'); const fs = require('fs'); // A minimalistic gRPC service definition const PROTO_CONTENT = ` syntax = "proto3"; package helloworld; service Greeter { rpc SayHello (HelloRequest) returns (HelloReply) {} } message HelloRequest { string name = 1; } message HelloReply { string message = 1; } `; // Write the proto content to a temporary file for Mali to load const PROTO_PATH = path.resolve(__dirname, 'helloworld.proto'); fs.writeFileSync(PROTO_PATH, PROTO_CONTENT); function sayHello (ctx) { ctx.res = { message: `Hello ${ctx.req.name || 'World'}` }; console.log(`Handled SayHello for ${ctx.req.name || 'World'}`); } async function main () { const app = new Mali(PROTO_PATH); app.use({ sayHello }); const port = '0.0.0.0:50051'; app.start(port); console.log(`gRPC server running on ${port}`); // Basic client to test the server (optional, for demonstration) const grpc = require('@grpc/grpc-js'); const protoLoader = require('@grpc/proto-loader'); const packageDefinition = protoLoader.loadSync(PROTO_PATH, { keepCase: true, longs: String, enums: String, defaults: true, oneofs: true }); const hello_proto = grpc.loadPackageDefinition(packageDefinition).helloworld; const client = new hello_proto.Greeter(port, grpc.credentials.createInsecure()); client.sayHello({ name: 'Mali User' }, (err, response) => { if (err) { console.error('Client error:', err); } else { console.log('Client received:', response.message); } // Clean up temporary proto file and stop the server for a real test fs.unlinkSync(PROTO_PATH); app.shutdown(); }); } main().catch(console.error);