Merge pull request grpc-ecosystem#17 from remko/master

Throw error object on HTTP error

generator/template.go

@@ -107,7 +107,10 @@ export function fetchReq<I, O>(path: string, init?: InitReq): Promise<O> {
 
   const url = pathPrefix ? ` + "`${pathPrefix}${path}`" + ` : path
 
-  return fetch(url, req).then(r => r.json()) as Promise<O>
+  return fetch(url, req).then(r => r.json().then((body: O) => {
+    if (!r.ok) { throw body; }
+    return body;
+  })) as Promise<O>
 }
 
 // NotifyStreamEntityArrival is a callback that will be called on streaming entity arrival

integration_tests/integration_test.ts

@@ -19,6 +19,16 @@ describe("test grpc-gateway-ts communication", () => {
     expect(result.result).to.equal(200)
   })
 
+  it("failing unary request", async () => {
+    try {
+      await CounterService.FailingIncrement({ counter: 199 }, { pathPrefix: "http://localhost:8081" }); 
+      expect.fail("expected call to throw");
+    } catch (e) {
+      expect(e).to.have.property("message", "this increment does not work")
+      expect(e).to.have.property("code", 14);
+    }
+  })
+
   it('streaming request', async () => {
     const response = [] as number[]
     await CounterService.StreamingIncrements({ counter: 1 }, (resp) => response.push(resp.result), { pathPrefix: "http://localhost:8081" })

integration_tests/service.go

@@ -4,6 +4,8 @@ import (
 	"context"
 	"time"
 
+	"google.golang.org/grpc/codes"
+	"google.golang.org/grpc/status"
 	"google.golang.org/protobuf/types/known/emptypb"
 )
 
@@ -21,6 +23,10 @@ func (r *RealCounterService) Increment(c context.Context, req *UnaryRequest) (*U
 	}, nil
 }
 
+func (r *RealCounterService) FailingIncrement(c context.Context, req *UnaryRequest) (*UnaryResponse, error) {
+	return nil, status.Errorf(codes.Unavailable, "this increment does not work")
+}
+
 func (r *RealCounterService) StreamingIncrements(req *StreamingRequest, service CounterService_StreamingIncrementsServer) error {
 	times := 5
 	counter := req.Counter