also override ResolverTypeWrapper

README.md

@@ -5,6 +5,8 @@
 
 `npm install graphql-codegen-typescript-reactive-resolvers --save-dev`
 
+⚠️ It overrides the `resolverTypeWrapperSignature` config
+
 ## Usage
 
 Run `gql-gen` as usual with this config:

package.json

@@ -1,12 +1,14 @@
 {
-  "name": "graphql-codegen-typescript-reactive-resolvers",
-  "version": "1.0.0",
+  "name": "@getstation/graphql-codegen-typescript-reactive-resolvers",
+  "version": "1.17.10",
   "description": "graphql-codegen-cli template for TypeScript typings of reactive resolvers",
   "repository": "[email protected]:getstation/graphql-codegen-typescript-reactive-resolvers.git",
   "license": "MIT",
   "scripts": {
     "build": "tsc -m esnext --outDir dist/esnext && tsc -m commonjs --outDir dist/commonjs",
-    "test": "jest --config ./jest.config.js"
+    "test": "jest --config ./jest.config.js",
+    "prepublishOnly": "npm run build",
+    "prepack": "npm run build"
   },
   "dependencies": {
     "@graphql-codegen/visitor-plugin-common": "^1.17.14",

src/index.ts

@@ -134,7 +134,20 @@ export type ResolverFn<TResult, TParent, TContext, TArgs> = (
 
   const header = `${indexSignature}
 
-${visitor.getResolverTypeWrapperSignature()}
+export type DeepObservable<T> = [T] extends [Function]
+  ? T : [T] extends [Array<infer U>]
+    ? _DeepObservableArray<U>
+    : [T] extends [object]
+      ? _DeepObservableObject<T>
+      : T | Observable<T> | Promise<T>;
+
+export interface _DeepObservableArray<T> extends ReadonlyArray<DeepObservable<T>> {}
+
+export type _DeepObservableObject<T> = {
+  [P in keyof T]: DeepObservable<T[P]>;
+};
+
+export type ResolverTypeWrapper<T> = DeepObservable<T> | Promise<T> | T;
 
 ${defsToInclude.join('\n')}
 
@@ -174,7 +187,7 @@ export type TypeResolveFn<TTypes, TParent = {}, TContext = {}> = (
   parent: TParent,
   context: TContext,
   info${optionalSignForInfoArg}: GraphQLResolveInfo
-) => ${namespacedImportPrefix}Maybe<TTypes> | Promise<${namespacedImportPrefix}Maybe<TTypes>>;
+) => ${namespacedImportPrefix}Maybe<TTypes> | Promise<${namespacedImportPrefix}Maybe<TTypes>> | Observable<${namespacedImportPrefix}Maybe<TTypes>>;
 
 export type IsTypeOfResolverFn<T = {}> = (obj: T, info${optionalSignForInfoArg}: GraphQLResolveInfo) => boolean | Promise<boolean>;
 

tests/__snapshots__/ts-resolvers.spec.ts.snap

@@ -59,7 +59,20 @@ export type MyUnion = MyType | MyOtherType;
 export type WithIndex<TObject> = TObject & Record<string, any>;
 export type ResolversObject<TObject> = WithIndex<TObject>;
 
-export type ResolverTypeWrapper<T> = Promise<T> | T;
+export type DeepObservable<T> = [T] extends [Function]
+  ? T : [T] extends [Array<infer U>]
+    ? _DeepObservableArray<U>
+    : [T] extends [object]
+      ? _DeepObservableObject<T>
+      : T | Observable<T> | Promise<T>;
+
+export interface _DeepObservableArray<T> extends ReadonlyArray<DeepObservable<T>> {}
+
+export type _DeepObservableObject<T> = {
+  [P in keyof T]: DeepObservable<T[P]>;
+};
+
+export type ResolverTypeWrapper<T> = DeepObservable<T> | Promise<T> | T;
 
 export type Resolver<TResult, TParent = {}, TContext = {}, TArgs = {}> = ResolverFn<TResult, TParent, TContext, TArgs>;
 
@@ -106,7 +119,7 @@ export type TypeResolveFn<TTypes, TParent = {}, TContext = {}> = (
   parent: TParent,
   context: TContext,
   info: GraphQLResolveInfo
-) => Maybe<TTypes> | Promise<Maybe<TTypes>>;
+) => Maybe<TTypes> | Promise<Maybe<TTypes>> | Observable<Maybe<TTypes>>;
 
 export type IsTypeOfResolverFn<T = {}> = (obj: T, info: GraphQLResolveInfo) => boolean | Promise<boolean>;
 
@@ -240,7 +253,20 @@ export type RequireFields<T, K extends keyof T> = { [X in Exclude<keyof T, K>]?:
 export type WithIndex<TObject> = TObject & Record<string, any>;
 export type ResolversObject<TObject> = WithIndex<TObject>;
 
-export type ResolverTypeWrapper<T> = Promise<T> | T;
+export type DeepObservable<T> = [T] extends [Function]
+  ? T : [T] extends [Array<infer U>]
+    ? _DeepObservableArray<U>
+    : [T] extends [object]
+      ? _DeepObservableObject<T>
+      : T | Observable<T> | Promise<T>;
+
+export interface _DeepObservableArray<T> extends ReadonlyArray<DeepObservable<T>> {}
+
+export type _DeepObservableObject<T> = {
+  [P in keyof T]: DeepObservable<T[P]>;
+};
+
+export type ResolverTypeWrapper<T> = DeepObservable<T> | Promise<T> | T;
 
 export type Resolver<TResult, TParent = {}, TContext = {}, TArgs = {}> = ResolverFn<TResult, TParent, TContext, TArgs>;
 
@@ -287,7 +313,7 @@ export type TypeResolveFn<TTypes, TParent = {}, TContext = {}> = (
   parent: TParent,
   context: TContext,
   info: GraphQLResolveInfo
-) => Types.Maybe<TTypes> | Promise<Types.Maybe<TTypes>>;
+) => Types.Maybe<TTypes> | Promise<Types.Maybe<TTypes>> | Observable<Types.Maybe<TTypes>>;
 
 export type IsTypeOfResolverFn<T = {}> = (obj: T, info: GraphQLResolveInfo) => boolean | Promise<boolean>;
 
@@ -465,7 +491,20 @@ export type MyUnion = MyType | MyOtherType;
 export type WithIndex<TObject> = TObject & Record<string, any>;
 export type ResolversObject<TObject> = WithIndex<TObject>;
 
-export type ResolverTypeWrapper<T> = Promise<T> | T;
+export type DeepObservable<T> = [T] extends [Function]
+  ? T : [T] extends [Array<infer U>]
+    ? _DeepObservableArray<U>
+    : [T] extends [object]
+      ? _DeepObservableObject<T>
+      : T | Observable<T> | Promise<T>;
+
+export interface _DeepObservableArray<T> extends ReadonlyArray<DeepObservable<T>> {}
+
+export type _DeepObservableObject<T> = {
+  [P in keyof T]: DeepObservable<T[P]>;
+};
+
+export type ResolverTypeWrapper<T> = DeepObservable<T> | Promise<T> | T;
 
 export type Resolver<TResult, TParent = {}, TContext = {}, TArgs = {}> = ResolverFn<TResult, TParent, TContext, TArgs>;
 
@@ -512,7 +551,7 @@ export type TypeResolveFn<TTypes, TParent = {}, TContext = {}> = (
   parent: TParent,
   context: TContext,
   info?: GraphQLResolveInfo
-) => Maybe<TTypes> | Promise<Maybe<TTypes>>;
+) => Maybe<TTypes> | Promise<Maybe<TTypes>> | Observable<Maybe<TTypes>>;
 
 export type IsTypeOfResolverFn<T = {}> = (obj: T, info?: GraphQLResolveInfo) => boolean | Promise<boolean>;
 

tests/ts-resolvers.spec.ts

@@ -445,20 +445,6 @@ describe('TypeScript Resolvers Plugin', () => {
     await validate(result);
   });
 
-  it('Should allow to override ResolverTypeWrapper signature', async () => {
-    const result = (await plugin(
-      schema,
-      [],
-      {
-        noSchemaStitching: true,
-        resolverTypeWrapperSignature: 'Promise<DeepPartial<T>> | DeepPartial<T>',
-      },
-      { outputFile: '' }
-    )) as Types.ComplexPluginOutput;
-
-    expect(result.content).toContain(`export type ResolverTypeWrapper<T> = Promise<DeepPartial<T>> | DeepPartial<T>;`);
-  });
-
   it('Should have default value for ResolverTypeWrapper signature', async () => {
     const result = (await plugin(
       schema,
@@ -469,7 +455,7 @@ describe('TypeScript Resolvers Plugin', () => {
       { outputFile: '' }
     )) as Types.ComplexPluginOutput;
 
-    expect(result.content).toContain(`export type ResolverTypeWrapper<T> = Promise<T> | T;`);
+    expect(result.content).toContain(`export type ResolverTypeWrapper<T> = DeepObservable<T> | Promise<T> | T`);
   });
 
   it('Should not warn when noSchemaStitching is not defined', async () => {
@@ -1737,7 +1723,7 @@ export type ResolverFn<TResult, TParent, TContext, TArgs> = (
     )) as Types.ComplexPluginOutput;
 
     expect(content.content).toBeSimilarStringTo(`
-      export type ResolverTypeWrapper<T> = Promise<T> | T;
+      export type ResolverTypeWrapper<T> = DeepObservable<T> | Promise<T> | T;
     `);
   });