Skip to content

Commit

Permalink
Simplify collectFields for @defer & @stream
Browse files Browse the repository at this point in the history
  • Loading branch information
robrichard committed Nov 7, 2023
1 parent 2e29180 commit b2102f7
Show file tree
Hide file tree
Showing 6 changed files with 329 additions and 466 deletions.
19 changes: 12 additions & 7 deletions src/execution/IncrementalPublisher.ts
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@ import type {
GraphQLFormattedError,
} from '../error/GraphQLError.js';

import type { GroupedFieldSet } from './collectFields.js';
import type { DeferUsage, GroupedFieldSet } from './collectFields.js';

interface IncrementalUpdate<TData = unknown, TExtensions = ObjMap<unknown>> {
pending: ReadonlyArray<PendingResult>;
Expand Down Expand Up @@ -611,8 +611,11 @@ export class IncrementalPublisher {
const { data, deferredFragmentRecords } = deferredGroupedFieldSetRecord;
let maxLength = deferredFragmentRecords[0].path.length;
let maxIndex = 0;
for (let i = 1; i < deferredFragmentRecords.length; i++) {
for (let i = 0; i < deferredFragmentRecords.length; i++) {
const deferredFragmentRecord = deferredFragmentRecords[i];
if (deferredFragmentRecord.id == null) {
continue;
}
const length = deferredFragmentRecord.path.length;
if (length > maxLength) {
maxLength = length;
Expand Down Expand Up @@ -763,7 +766,6 @@ export class DeferredGroupedFieldSetRecord {
path: ReadonlyArray<string | number>;
deferredFragmentRecords: ReadonlyArray<DeferredFragmentRecord>;
groupedFieldSet: GroupedFieldSet;
shouldInitiateDefer: boolean;
errors: Array<GraphQLError>;
data: ObjMap<unknown> | undefined;
sent: boolean;
Expand All @@ -772,12 +774,10 @@ export class DeferredGroupedFieldSetRecord {
path: Path | undefined;
deferredFragmentRecords: ReadonlyArray<DeferredFragmentRecord>;
groupedFieldSet: GroupedFieldSet;
shouldInitiateDefer: boolean;
}) {
this.path = pathToArray(opts.path);
this.deferredFragmentRecords = opts.deferredFragmentRecords;
this.groupedFieldSet = opts.groupedFieldSet;
this.shouldInitiateDefer = opts.shouldInitiateDefer;
this.errors = [];
this.sent = false;
}
Expand All @@ -786,6 +786,8 @@ export class DeferredGroupedFieldSetRecord {
/** @internal */
export class DeferredFragmentRecord {
path: ReadonlyArray<string | number>;
pathObj: Path | undefined;
deferUsage: DeferUsage;
label: string | undefined;
id: string | undefined;
children: Set<SubsequentResultRecord>;
Expand All @@ -795,9 +797,12 @@ export class DeferredFragmentRecord {
pendingSent?: boolean;
_pending: Set<DeferredGroupedFieldSetRecord>;

constructor(opts: { path: Path | undefined; label: string | undefined }) {
constructor(opts: { path: Path | undefined; deferUsage: DeferUsage }) {
this.pathObj = opts.path;
this.path = pathToArray(opts.path);
this.label = opts.label;
this.deferUsage = opts.deferUsage;
this.label = opts.deferUsage.label;
this.deferUsage = opts.deferUsage;
this.children = new Set();
this.filtered = false;
this.deferredGroupedFieldSetRecords = new Set();
Expand Down
Loading

0 comments on commit b2102f7

Please sign in to comment.