Add test to check Jira SourceJSON schema required fields for each stream

sources/jira-source/test/index.test.ts

@@ -6,6 +6,7 @@ import {
 } from 'faros-airbyte-cdk';
 import {FarosClient} from 'faros-js-client';
 import fs from 'fs-extra';
+import {Dictionary} from 'ts-essentials';
 import VError from 'verror';
 
 import {FarosIssuePullRequests} from '../lib/streams/faros_issue_pull_requests';
@@ -187,6 +188,46 @@ describe('index', () => {
       .mockResolvedValue(readTestResourceFile('sprint_report.json')),
   });
 
+  test('streams - json schema fields', async () => {
+    const source = new sut.JiraSource(logger);
+    const streams = source.streams(config);
+
+    const validateFieldInSchema = (
+      field: string | string[],
+      schema: Dictionary<any>
+    ) => {
+      if (Array.isArray(field)) {
+        let nestedField = schema;
+        for (const subField of field) {
+          expect(nestedField).toHaveProperty(subField);
+          nestedField = nestedField[subField].properties;
+        }
+      } else {
+        expect(schema).toHaveProperty(field);
+      }
+    };
+
+    for (const stream of streams) {
+      const jsonSchema = stream.getJsonSchema().properties;
+      const primaryKey = stream.primaryKey;
+      const cursorField = stream.cursorField;
+
+      // Validate primaryKey is in jsonSchema
+      if (primaryKey) {
+        if (Array.isArray(primaryKey)) {
+          for (const key of primaryKey) {
+            validateFieldInSchema(key, jsonSchema);
+          }
+        } else {
+          validateFieldInSchema(primaryKey, jsonSchema);
+        }
+      }
+
+      // Validate cursorField is in jsonSchema
+      validateFieldInSchema(cursorField, jsonSchema);
+    }
+  });
+
   test('streams - issue_pull_requests', async () => {
     await testStream(
       0,