support graphql-sse

Author: dimaMachina

packages/graphiql-toolkit/src/create-fetcher/create-sse-fetcher.ts

@@ -5,6 +5,9 @@ import type {
 } from 'graphql-sse';
 import { Fetcher, FetcherParams } from './types';
 
+/**
+ * Based on https://gist.github.com/enisdenjo/d7bc1a013433502349d2763c3d2f2b79
+ */
 export async function createSseFetcher(opts: ClientOptions): Promise<Fetcher> {
   const { createClient } =
     process.env.USE_IMPORT === 'false'

packages/graphiql/cypress/e2e/graphql-ws.cy.ts

@@ -0,0 +1,33 @@
+describe('IncrementalDelivery support via fetcher', () => {
+  function assertResponse() {
+    for (const message of ['Hi', 'Bonjour', 'Hola', 'Ciao', 'Zdravo']) {
+      cy.assertQueryResult({ data: { message } });
+    }
+  }
+
+  it('should work with ws', () => {
+    const testSubscription = /* GraphQL */ `
+      subscription TestSubscription {
+        message
+      }
+    `;
+
+    cy.visit(`/?query=${testSubscription}`);
+    cy.clickExecuteQuery();
+    assertResponse();
+  });
+
+  it('should work with sse', () => {
+    const testSubscription = /* GraphQL */ `
+      subscription Test {
+        message
+      }
+    `;
+
+    cy.visit(
+      `/?sseUrl=http://localhost:8080/graphql/stream&query=${testSubscription}`,
+    );
+    cy.clickExecuteQuery();
+    assertResponse();
+  });
+});

packages/graphiql/cypress/e2e/ws-sse.cy.ts

@@ -374,7 +374,7 @@ const TestSubscriptionType = new GraphQLObjectType({
       },
       async *subscribe(root, args) {
         for (const hi of ['Hi', 'Bonjour', 'Hola', 'Ciao', 'Zdravo']) {
-          if (args?.delay) {
+          if (args.delay) {
             await sleep(args.delay);
           }
           yield { message: hi };