fixed send on server unary decorator

examples/firecomm/client.js

@@ -7,9 +7,10 @@ const firecomm = require("../../index");
 
 let certificate = path.join(__dirname, "/server.crt");
 
-const stub = new firecomm.Stub(routeguide.RouteGuide, "localhost:3000", {
-  certificate
-});
+const stub = new firecomm.Stub(routeguide.RouteGuide, "localhost:3000");
+// {
+//   certificate
+// }
 
 // stub.openChannel('localhost:3000');
 

examples/firecomm/methodHandlers.js

@@ -3,12 +3,16 @@ const grpc = require("grpc");
 function unaryChat(ctx) {
   // ctx.setStatus({'trailer': 'value'});
   // ctx.throw(new Error('custom error message'));
-  console.log(ctx.metadata);
-  console.log(ctx.body);
+  // console.log(ctx.metadata);
+  // console.log(ctx.body);
+  console.log({ ctx });
+  ctx.on(data => console.log({ data }));
+  ctx.set({ hello: "world" });
+  ctx.send({ message: "message body" });
   // ctx.setTrailer({'hello': 'trailer'})
   // ctx.setMeta({'hello': 'world'})
   // ctx.send({message: 'what\'s up'});
-  throw new Error("uncaught error");
+  // throw new Error("uncaught error");
 }
 
 function serverStream(context) {
@@ -17,19 +21,20 @@ function serverStream(context) {
 
 function clientStream(context) {
   // console.log('serverStream context: ', context);
-  context.on('data', data => {console.log(data)});
-  context.send({message: 'world'})
-  }
-
+  context.on("data", data => {
+    console.log(data);
+  });
+  context.send({ message: "world" });
+}
 
 function bidiChat(context) {
   // console.log('context', context);
   // console.log('context keys', Object.keys(context));
   // console.log('context proto', context.__proto__)
 
-  context.on('data', data => {
+  context.on("data", data => {
     // console.log('data:', data);
-    context.write({message: data.message + ' World'});
+    context.write({ message: data.message + " World" });
   });
   context.throw(new Error("error"));
   setTimeout(() => {

examples/firecomm/server.js

@@ -42,10 +42,11 @@ server.addService(
 
 // {private_key: (__dirname + '/server.crt'), certificate: (__dirname +
 // '/server.key')}
-server.bind("0.0.0.0:3000", {
-  privateKey: __dirname + "/server.key",
-  certificate: __dirname + "/server.crt"
-});
+server.bind("0.0.0.0:3000");
+// {
+//   privateKey: __dirname + "/server.key",
+//   certificate: __dirname + "/server.crt"
+// }
 // console.log({server})
 // console.log(new grpc.Server().__proto__)
 

lib/callFactories/callDecorators/serverUnaryDecorator.js

@@ -10,11 +10,11 @@ module.exports = function serverUnaryDecorator(customCall, sendCallback) {
   customCall.metadata = undefined;
   customCall.sendCallback = sendCallback;
 
-  customCall.send = function(message) {
+  customCall.send = function(message, flags) {
     if (this.metadata) {
       this.sendMetadata(this.metadata);
     }
-    this.sendCallback(undefined);
+    this.sendCallback(null, message, null, flags);
   };
 
   customCall.set = function(object) {