feat(overmind-graphql): allow raw requests

Author: christianalfoni

packages/node_modules/overmind-graphql/src/index.ts

@@ -1,10 +1,11 @@
 import * as withAbsintheSocket from '@absinthe/socket';
 import { GraphQLClient } from 'graphql-request';
-import { RequestInit } from 'graphql-request/dist/types.dom';
+import * as Dom from 'graphql-request/dist/types.dom';
 import { print } from 'graphql/language/printer';
 import { Socket as PhoenixSocket } from 'phoenix';
 
 import gqlTag from 'graphql-tag';
+import { GraphQLError } from 'graphql';
 
 
 export interface Query<Result extends any, Payload extends any = void> {
@@ -32,8 +33,8 @@ interface Subscription {
 
 type Http = {
   endpoint: string;
-  headers?: () => RequestInit['headers'];
-  options?: RequestInit;
+  headers?: () => Dom.RequestInit['headers'];
+  options?: Dom.RequestInit;
 };
 
 type Ws =
@@ -44,9 +45,15 @@ type Ws =
   | (() => PhoenixSocket | null);
 
 type Queries = {
+  rawQueries?: {
+    [key: string]: (payload: any) => any;
+  };
   queries?: {
     [key: string]: (payload: any) => any;
   };
+  rawMutations?: {
+    [key: string]: (payload: any) => any;
+  };
   mutations?: {
     [key: string]: (payload: any) => any;
   };
@@ -55,9 +62,26 @@ type Queries = {
   };
 };
 
+type RawResult<T extends any> = Promise<{
+  data?: T;
+  extensions?: any;
+  headers: Dom.Headers;
+  status: number;
+  errors?: GraphQLError[];
+}>
+
 export type Graphql<T extends Queries> = {
   initialize(http: Http, ws?: Ws): void;
 } & {
+  rawQueries: {
+    [N in keyof T['rawQueries']]: T['rawQueries'][N] extends (
+      payload: infer P
+    ) => infer R
+      ? P extends void
+        ? () => RawResult<R>
+        : (payload: P) => RawResult<R>
+      : never;
+  }
   queries: {
     [N in keyof T['queries']]: T['queries'][N] extends (
       payload: infer P
@@ -67,6 +91,15 @@ export type Graphql<T extends Queries> = {
         : (payload: P) => Promise<R>
       : never;
   };
+  rawMutations: {
+    [N in keyof T['rawMutations']]: T['rawMutations'][N] extends (
+      payload: infer P
+    ) => infer R
+      ? P extends void
+        ? () => RawResult<R>
+        : (payload: P) => RawResult<R>
+      : never;
+  }
   mutations: {
     [N in keyof T['mutations']]: T['mutations'][N] extends (
       payload: infer P
@@ -151,6 +184,21 @@ export const graphql: <T extends Queries>(
   }
 
   const evaluatedQueries = {
+    rawQueries: Object.keys(queries.rawQueries || {}).reduce((aggr, key) => {
+      aggr[key] = variables => {
+        const query = queries.rawQueries![key] as any;
+        const client = getClient();
+
+        if (client) {
+          return client.rawRequest(print(query), variables);
+        }
+
+        throw createError(
+          'You are running a query, though there is no HTTP endpoint configured'
+        );
+      };
+      return aggr;
+    }, {}),
     queries: Object.keys(queries.queries || {}).reduce((aggr, key) => {
       aggr[key] = variables => {
         const query = queries.queries![key] as any;
@@ -166,6 +214,21 @@ export const graphql: <T extends Queries>(
       };
       return aggr;
     }, {}),
+    rawMutations: Object.keys(queries.rawMutations || {}).reduce((aggr, key) => {
+      aggr[key] = variables => {
+        const query = queries.rawMutations![key] as any;
+        const client = getClient();
+
+        if (client) {
+          return client.rawRequest(print(query), variables);
+        }
+
+        throw createError(
+          'You are running a query, though there is no HTTP endpoint configured'
+        );
+      };
+      return aggr;
+    }, {}),
     mutations: Object.keys(queries.mutations || {}).reduce((aggr, key) => {
       aggr[key] = variables => {
         const query = queries.mutations![key] as any;