feat: remove stream and defer directives (#1138)

Author: jasonkuhrt

examples/55_generated/generated_alias.ts

@@ -12,13 +12,16 @@ const year = day * 365.25
 const yearsAgo100 = new Date(Date.now() - year * 100).getTime()
 const yearsAgo1 = new Date(Date.now() - year).getTime()
 
+// dprint-ignore
 const pokemons = await pokemon.query.$batch({
   pokemons: [
     [`elderPokemons`, {
+//   ^^^^^^^^^^^^^^^      
       $: { filter: { birthday: { lte: yearsAgo100 } } },
       name: true,
     }],
     [`babyPokemons`, {
+//   ^^^^^^^^^^^^^^
       $: { filter: { birthday: { gte: yearsAgo1 } } },
       name: true,
     }],

examples/55_generated/generated_directive.ts

@@ -7,32 +7,26 @@ import { Pokemon } from '../$/generated-clients/pokemon/__.js'
 import { showJson } from '../$/helpers.js'
 
 const pokemon = Pokemon.create()
-// .anyware(({ pack }) => {
-//   console.log(print(parse(pack.input.query)))
-//   return pack()
-// })
 
+// dprint-ignore
 const pokemons = await pokemon.query.$batch({
   ___: {
-    // $skip: true,
-    // $defer: true,
+    $skip: true,
+//  ^^^^^^^^^^^^
     pokemons: {
       name: true,
     },
   },
   trainers: {
-    // $stream: {
-    //   if: true,
-    //   initialCount: 0,
-    //   label: `trainers`,
-    // },
     name: true,
     id: {
       $skip: true,
+//    ^^^^^^^^^^^^
     },
     pokemon: {
       id: {
         $include: false,
+//      ^^^^^^^^^^^^^^^^
       },
       name: true,
     },

examples/55_generated/generated_document.ts

@@ -8,6 +8,7 @@ import { showJson } from '../$/helpers.js'
 const pokemon = Pokemon.create()
 
 const pokemons = await pokemon.document({
+  //                           ^^^^^^^^
   query: { //                     An operation type.
     pokemonsAndTrainers: { //     A name chosen by you for this operation.
       trainers: { //              A selection on a Query type field (aka. root field, entrypoint).
@@ -39,6 +40,6 @@ const pokemons = await pokemon.document({
     },
   },
 })
-  .run(`pokemonsAndTrainers`)
+  .run(`pokemonsAndTrainers`) //  Set operation name to be executed and send request.
 
 showJson(pokemons)

examples/55_generated/generated_root-field.ts

@@ -8,5 +8,6 @@ import { showJson } from '../$/helpers.js'
 const pokemon = Pokemon.create()
 
 const pokemons = await pokemon.query.pokemons({ name: true })
+//                             ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
 
 showJson(pokemons)

examples/__outputs__/10_transport-http/transport-http_extension_headers__dynamicHeaders.output.txt

@@ -4,7 +4,7 @@
   headers: Headers {
     accept: 'application/graphql-response+json; charset=utf-8, application/json; charset=utf-8',
     'content-type': 'application/json',
-    'x-sent-at-time': '1727398656266'
+    'x-sent-at-time': '1727402243716'
   },
   signal: undefined,
   method: 'post',

examples/__outputs__/20_output/output_envelope.output.txt

@@ -16,7 +16,7 @@
     headers: Headers {
       'content-type': 'application/graphql-response+json; charset=utf-8',
       'content-length': '104',
-      date: 'Fri, 27 Sep 2024 00:57:36 GMT',
+      date: 'Fri, 27 Sep 2024 01:57:23 GMT',
       connection: 'keep-alive',
       'keep-alive': 'timeout=5'
     },

examples/__outputs__/55_generated/generated_directive.output.txt

@@ -20,19 +20,5 @@
         }
       ]
     }
-  ],
-  "pokemons": [
-    {
-      "name": "Pikachu"
-    },
-    {
-      "name": "Charizard"
-    },
-    {
-      "name": "Squirtle"
-    },
-    {
-      "name": "Bulbasaur"
-    }
   ]
 }

examples/__outputs__/60_extension/extension_opentelemetry__opentelemetry.output.txt

@@ -9,14 +9,14 @@
     }
   },
   instrumentationScope: { name: 'graffle', version: undefined, schemaUrl: undefined },
-  traceId: '244b6da7575c00d270d6b60798e72b7e',
-  parentId: 'edb4fc3f1a36cb35',
+  traceId: '00f7caa8f793fd361b4dd9d8bfac44a6',
+  parentId: '389e0f006c1b18ee',
   traceState: undefined,
   name: 'encode',
-  id: '41893153e418647a',
+  id: 'bd3e0c33c7f0618a',
   kind: 0,
-  timestamp: 1727398656738000,
-  duration: 559.083,
+  timestamp: 1727402244351000,
+  duration: 815.833,
   attributes: {},
   status: { code: 0 },
   events: [],
@@ -33,14 +33,14 @@
     }
   },
   instrumentationScope: { name: 'graffle', version: undefined, schemaUrl: undefined },
-  traceId: '244b6da7575c00d270d6b60798e72b7e',
-  parentId: 'edb4fc3f1a36cb35',
+  traceId: '00f7caa8f793fd361b4dd9d8bfac44a6',
+  parentId: '389e0f006c1b18ee',
   traceState: undefined,
   name: 'pack',
-  id: '7f4237b522a4a573',
+  id: '55ba8c5ec3d2f8a3',
   kind: 0,
-  timestamp: 1727398656741000,
-  duration: 11605.459,
+  timestamp: 1727402244355000,
+  duration: 16379.75,
   attributes: {},
   status: { code: 0 },
   events: [],
@@ -57,14 +57,14 @@
     }
   },
   instrumentationScope: { name: 'graffle', version: undefined, schemaUrl: undefined },
-  traceId: '244b6da7575c00d270d6b60798e72b7e',
-  parentId: 'edb4fc3f1a36cb35',
+  traceId: '00f7caa8f793fd361b4dd9d8bfac44a6',
+  parentId: '389e0f006c1b18ee',
   traceState: undefined,
   name: 'exchange',
-  id: '10602c9bbc43dd1d',
+  id: 'bdb99e5752ccec59',
   kind: 0,
-  timestamp: 1727398656753000,
-  duration: 21156.417,
+  timestamp: 1727402244373000,
+  duration: 23841.417,
   attributes: {},
   status: { code: 0 },
   events: [],
@@ -81,14 +81,14 @@
     }
   },
   instrumentationScope: { name: 'graffle', version: undefined, schemaUrl: undefined },
-  traceId: '244b6da7575c00d270d6b60798e72b7e',
-  parentId: 'edb4fc3f1a36cb35',
+  traceId: '00f7caa8f793fd361b4dd9d8bfac44a6',
+  parentId: '389e0f006c1b18ee',
   traceState: undefined,
   name: 'unpack',
-  id: '2306ef1e07c28f31',
+  id: 'edf0e40528ece12f',
   kind: 0,
-  timestamp: 1727398656774000,
-  duration: 1144.458,
+  timestamp: 1727402244397000,
+  duration: 1305.875,
   attributes: {},
   status: { code: 0 },
   events: [],
@@ -105,14 +105,14 @@
     }
   },
   instrumentationScope: { name: 'graffle', version: undefined, schemaUrl: undefined },
-  traceId: '244b6da7575c00d270d6b60798e72b7e',
-  parentId: 'edb4fc3f1a36cb35',
+  traceId: '00f7caa8f793fd361b4dd9d8bfac44a6',
+  parentId: '389e0f006c1b18ee',
   traceState: undefined,
   name: 'decode',
-  id: '7f538ab7279ff6be',
+  id: '6d4d4750ecff5752',
   kind: 0,
-  timestamp: 1727398656776000,
-  duration: 189.833,
+  timestamp: 1727402244398000,
+  duration: 191.75,
   attributes: {},
   status: { code: 0 },
   events: [],
@@ -129,14 +129,14 @@
     }
   },
   instrumentationScope: { name: 'graffle', version: undefined, schemaUrl: undefined },
-  traceId: '244b6da7575c00d270d6b60798e72b7e',
+  traceId: '00f7caa8f793fd361b4dd9d8bfac44a6',
   parentId: undefined,
   traceState: undefined,
   name: 'request',
-  id: 'edb4fc3f1a36cb35',
+  id: '389e0f006c1b18ee',
   kind: 0,
-  timestamp: 1727398656738000,
-  duration: 38270.125,
+  timestamp: 1727402244349000,
+  duration: 49758.625,
   attributes: {},
   status: { code: 0 },
   events: [],

package.json

@@ -126,7 +126,6 @@
   "devDependencies": {
     "@arethetypeswrong/cli": "^0.16.4",
     "@ark/attest": "^0.19.0",
-    "@graphql-yoga/plugin-defer-stream": "^3.7.0",
     "@opentelemetry/api": "^1.9.0",
     "@opentelemetry/sdk-trace-base": "^1.26.0",
     "@opentelemetry/sdk-trace-node": "^1.26.0",