feat(rpc): updates to use latest core api

rafamel · Nov 12, 2019 · 4962855 · 4962855
1 parent 2c90093
commit 4962855
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/packages/rpc/src/reproduce.ts b/packages/rpc/src/reproduce.ts
@@ -48,20 +48,19 @@ export async function reproduce(
 
   const implementation = collections(
     toImplementation(await collection, (service, info) => {
-      const { types } = service;
       if (isServiceQuery(service)) {
         return query({
-          types,
+          ...service,
           resolve: (data: any) => client.unary(info.route.join(':'), data)
         });
       } else if (isServiceMutation(service)) {
         return mutation({
-          types,
+          ...service,
           resolve: (data: any) => client.unary(info.route.join(':'), data)
         });
       } else if (isServiceSubscription(service)) {
         return subscription({
-          types,
+          ...service,
           resolve: (data: any) => client.stream(info.route.join(':'), data)
         });
       } else {

diff --git a/packages/rpc/src/server/RPCServer.ts b/packages/rpc/src/server/RPCServer.ts
@@ -39,7 +39,9 @@ export class RPCServer {
         ':fallback': {
           declaration: {
             kind: 'query',
-            types: { request: '', response: '', errors: {} }
+            request: '',
+            response: '',
+            errors: {}
           },
           resolve: app.fallback
         },