Advanced breaking change detection for input and argument values (#6764)

Author: jdolle

.changeset/early-eyes-return.md

@@ -0,0 +1,7 @@
+---
+'@graphql-hive/core': minor
+'hive': minor
+---
+
+Track provided operation arguments/inputs and use them to determine conditional breaking changes;
+Fix null to non-null argument breaking change edge case"

integration-tests/testkit/flow.ts

@@ -38,6 +38,32 @@ export function waitFor(ms: number) {
   return new Promise(resolve => setTimeout(resolve, ms));
 }
 
+function pollInternal(
+  check: () => Promise<boolean>,
+  pollFrequency: number,
+  resolve: (value: void | PromiseLike<void>) => void,
+  reject: (reason?: any) => void,
+) {
+  setTimeout(async () => {
+    try {
+      const passes = await check();
+      if (passes) {
+        resolve();
+      } else {
+        pollInternal(check, pollFrequency, resolve, reject);
+      }
+    } catch (e) {
+      reject(e);
+    }
+  }, pollFrequency);
+}
+
+export function pollFor(check: () => Promise<boolean>, pollFrequency = 500): Promise<void> {
+  return new Promise((resolve, reject) => {
+    pollInternal(check, pollFrequency, resolve, reject);
+  });
+}
+
 export function createOrganization(input: CreateOrganizationInput, authToken: string) {
   return execute({
     document: graphql(`

integration-tests/testkit/seed.ts

@@ -1,3 +1,4 @@
+import { formatISO, subHours } from 'date-fns';
 import { humanId } from 'human-id';
 import { createPool, sql } from 'slonik';
 import type { Report } from '../../packages/libraries/core/src/client/usage.js';
@@ -39,6 +40,7 @@ import {
   getOrganizationProjects,
   inviteToOrganization,
   joinOrganization,
+  pollFor,
   publishSchema,
   readClientStats,
   readOperationBody,
@@ -666,6 +668,7 @@ export function initSeed() {
                     .conditionalBreakingChangeConfiguration;
                 },
                 async updateTargetValidationSettings({
+                  isEnabled,
                   excludedClients,
                   percentage,
                   target: ttarget = target,
@@ -684,6 +687,7 @@ export function initSeed() {
                         },
                       },
                       conditionalBreakingChangeConfiguration: {
+                        isEnabled,
                         excludedClients,
                         percentage,
                         requestCount,
@@ -725,6 +729,32 @@ export function initSeed() {
 
                   return operationBodyResult?.target?.operation?.body;
                 },
+                async waitForOperationsCollected(
+                  n: number,
+                  _from?: number,
+                  _to?: number,
+                  ttarget: TargetOverwrite = target,
+                ) {
+                  const from = formatISO(_from ?? subHours(Date.now(), 1));
+                  const to = formatISO(_to ?? Date.now());
+                  const check = async () => {
+                    const statsResult = await readOperationsStats(
+                      {
+                        organizationSlug: organization.slug,
+                        projectSlug: project.slug,
+                        targetSlug: ttarget.slug,
+                        period: {
+                          from,
+                          to,
+                        },
+                      },
+                      ownerToken,
+                    ).then(r => r.expectNoGraphQLErrors());
+                    return statsResult.operationsStats.totalOperations == n;
+                  };
+
+                  return pollFor(check);
+                },
                 async readOperationsStats(
                   from: string,
                   to: string,