✅ Add tests and fix right schema headers

Author: fabsrc

src/__tests__/diff.test.ts

@@ -21,6 +21,90 @@ describe('getDiff', () => {
       expect(result).toBeUndefined();
     });
 
+    it('fetches remote schemas with headers', async () => {
+      nock(testRemoteSchemaLocation)
+        .matchHeader('test', 'test')
+        .post('', JSON.stringify({ query: introspectionQuery }))
+        .twice()
+        .reply(200, introspectionResponse);
+
+      const result = await getDiff(
+        testRemoteSchemaLocation,
+        testRemoteSchemaLocation,
+        {
+          headers: {
+            Test: 'test'
+          }
+        }
+      );
+      expect(result).toBeUndefined();
+    });
+
+    it('fetches remote schemas with left and right schema headers', async () => {
+      const testRemoteRightSchemaLocation = 'http://testRight/graphql';
+      nock(testRemoteSchemaLocation)
+        .matchHeader('test', 'left')
+        .post('', JSON.stringify({ query: introspectionQuery }))
+        .reply(200, introspectionResponse);
+      nock(testRemoteRightSchemaLocation)
+        .matchHeader('test', 'right')
+        .post('', JSON.stringify({ query: introspectionQuery }))
+        .reply(200, introspectionResponse);
+
+      const result = await getDiff(
+        testRemoteSchemaLocation,
+        testRemoteRightSchemaLocation,
+        {
+          leftSchema: {
+            headers: {
+              Test: 'left'
+            }
+          },
+          rightSchema: {
+            headers: {
+              Test: 'right'
+            }
+          }
+        }
+      );
+      expect(result).toBeUndefined();
+    });
+
+    it('fetches remote schemas with merged schema headers', async () => {
+      const testRemoteRightSchemaLocation = 'http://testRight/graphql';
+      nock(testRemoteSchemaLocation)
+        .matchHeader('global', 'merged')
+        .matchHeader('test', 'left')
+        .post('', JSON.stringify({ query: introspectionQuery }))
+        .reply(200, introspectionResponse);
+      nock(testRemoteRightSchemaLocation)
+        .matchHeader('global', 'merged')
+        .matchHeader('test', 'right')
+        .post('', JSON.stringify({ query: introspectionQuery }))
+        .reply(200, introspectionResponse);
+
+      const result = await getDiff(
+        testRemoteSchemaLocation,
+        testRemoteRightSchemaLocation,
+        {
+          headers: {
+            Global: 'merged',
+          },
+          leftSchema: {
+            headers: {
+              Test: 'left'
+            }
+          },
+          rightSchema: {
+            headers: {
+              Test: 'right'
+            }
+          }
+        }
+      );
+      expect(result).toBeUndefined();
+    });
+
     it('throws error on status codes other than 200', () => {
       nock(testRemoteSchemaLocation)
         .post('', JSON.stringify({ query: introspectionQuery }))

src/diff.ts

@@ -99,7 +99,7 @@ export async function getDiff(
   const rightSchemaOptions = {
     headers: {
       ...options.headers,
-      ...(options.leftSchema && options.leftSchema.headers)
+      ...(options.rightSchema && options.rightSchema.headers)
     }
   };
   const [leftSchema, rightSchema] = await Promise.all([