fix #5

Author: prohazko2

README.md

@@ -59,7 +59,7 @@ message HelloReply {
 Service typings are not essential, but it's nice to have them
 
 ```sh
-$ deno run --allow-read https://deno.land/x/grpc_basic@0.4.2/gen/dts.ts ./greeter.proto > ./greeter.d.ts
+$ deno run --allow-read https://deno.land/x/grpc_basic@0.4.3/gen/dts.ts ./greeter.proto > ./greeter.d.ts
 ```
 
 ```ts
@@ -80,7 +80,7 @@ export interface HelloReply {
 ### `server.ts`
 
 ```ts
-import { GrpcServer } from "https://deno.land/x/grpc_basic@0.4.2/server.ts";
+import { GrpcServer } from "https://deno.land/x/grpc_basic@0.4.3/server.ts";
 import { Greeter } from "./greeter.d.ts";
 
 const port = 15070;
@@ -114,7 +114,7 @@ for await (const conn of Deno.listen({ port })) {
 ### `client.ts`
 
 ```ts
-import { getClient } from "https://deno.land/x/grpc_basic@0.4.2/client.ts";
+import { getClient } from "https://deno.land/x/grpc_basic@0.4.3/client.ts";
 import { Greeter } from "./greeter.d.ts";
 
 const protoPath = new URL("./greeter.proto", import.meta.url);

client.ts

@@ -162,6 +162,7 @@ export class GrpcClientImpl implements GrpcClient {
       return;
     }
     this.flushing = true;
+    await this.ensureConnection();
 
     while (this.frames.length) {
       const f = this.frames.shift();
@@ -236,7 +237,7 @@ export class GrpcClientImpl implements GrpcClient {
           f.headers = this.hd.decompress(f.data);
         }
 
-        this.c._receive(f, () => {});
+        this.c._write(f, '', () => {});
       }
     }
   }
@@ -293,11 +294,11 @@ export class GrpcClientImpl implements GrpcClient {
     ]);
 
     if (frame.type === "DATA") {
-      const res = this.root
-        .lookupType(method.responseType)
-        .decode(frame.data.slice(5)) as unknown as Res;
+        const res = this.root
+          .lookupType(method.responseType)
+          .decode(frame.data.slice(5)) as unknown as Res;
 
-      return res;
+        return res;
     }
 
     if (frame.type === "HEADERS" && frame.flags.END_STREAM) {

http2/util.ts

@@ -1,8 +1,28 @@
 export const logData = false;
 
-export const noop = () => {};
+import { hexdump } from "https://deno.land/x/prohazko@1.3.5/hex.ts";
+
+function consoleLog(level: string, ...args: any[]) {
+  if (!logData) {
+    return;
+  }
+  let [more, msg] = args || [];
+
+  if (more && more.frame) {
+    more = `frame ${more.frame.type} of s:${
+      more.frame.stream
+    } with flags ${JSON.stringify(more.frame.flags)}`;
+  }
+
+  if (more && more.data) {
+    more = "\n" + hexdump(more.data).trim();
+  }
+
+  console.log(`${new Date().toISOString()} ${level[0]} ${msg}`, more);
+}
+
 export const consoleLogger = () => ({
-  debug: (...args: any[]) => (logData ? console.log(...args) : noop()),
-  trace: (...args: any[]) => (logData ? console.log(...args) : noop()),
-  error: (...args: any[]) => (logData ? console.error(...args) : noop()),
+  debug: (...args: any[]) => consoleLog("debug", ...args),
+  trace: (...args: any[]) => consoleLog("trace", ...args),
+  error: (...args: any[]) => consoleLog("error", ...args),
 });