Skip to content

Commit

Permalink
Remove old network event names
Browse files Browse the repository at this point in the history
Reviewed By: kassens

Differential Revision: D25039688

fbshipit-source-id: d1273ef262d7c0ff6e17bddf41d65ca21251b02c
  • Loading branch information
tyao1 authored and facebook-github-bot committed Dec 9, 2020
1 parent 28aa394 commit 5075851
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 117 deletions.
36 changes: 3 additions & 33 deletions packages/relay-experimental/__tests__/useLazyLoadQueryNode-test.js
Original file line number Diff line number Diff line change
Expand Up @@ -607,13 +607,9 @@ describe('useLazyLoadQueryNode', () => {
});

expect(logs).toMatchObject([
{
name: 'execute.start',
transactionID: 100000,
},
{
name: 'network.start',
transactionID: 100001,
transactionID: 100000,
},
{
name: 'queryresource.fetch',
Expand All @@ -622,18 +618,10 @@ describe('useLazyLoadQueryNode', () => {
},
{
name: 'network.next',
transactionID: 100001,
},
{
name: 'execute.next',
transactionID: 100000,
},
{
name: 'network.complete',
transactionID: 100001,
},
{
name: 'execute.complete',
transactionID: 100000,
},
{
Expand Down Expand Up @@ -717,13 +705,8 @@ describe('useLazyLoadQueryNode', () => {
},
{
// request for variables one starts
name: 'execute.start',
transactionID: 100000,
variables: variablesOne,
},
{
name: 'network.start',
transactionID: 100001,
transactionID: 100000,
variables: variablesOne,
},
{
Expand All @@ -740,13 +723,8 @@ describe('useLazyLoadQueryNode', () => {
},
{
// request for variables two starts
name: 'execute.start',
transactionID: 100002,
variables: variablesTwo,
},
{
name: 'network.start',
transactionID: 100003,
transactionID: 100001,
variables: variablesTwo,
},
{
Expand All @@ -765,18 +743,10 @@ describe('useLazyLoadQueryNode', () => {
// since it's already cached and reused
{
name: 'network.next',
transactionID: 100001,
},
{
name: 'execute.next',
transactionID: 100000,
},
{
name: 'network.complete',
transactionID: 100001,
},
{
name: 'execute.complete',
transactionID: 100000,
},
// retain event for variables one
Expand Down
63 changes: 3 additions & 60 deletions packages/relay-runtime/store/RelayModernEnvironment.js
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@ import type {HandlerProvider} from '../handlers/RelayDefaultHandlerProvider';
import type {
GraphQLResponse,
INetwork,
LogRequestInfoFunction,
PayloadData,
UploadableMap,
} from '../network/RelayNetworkTypes';
Expand Down Expand Up @@ -367,10 +366,6 @@ class RelayModernEnvironment implements IEnvironment {
operation: OperationDescriptor,
updater?: ?SelectorStoreUpdater,
|}): RelayObservable<GraphQLResponse> {
const logObserver = this.__createExecuteLogObserver(
operation.request.node.params,
operation.request.variables,
);
return RelayObservable.create(sink => {
const source = this._network.execute(
operation.request.node.params,
Expand All @@ -395,7 +390,7 @@ class RelayModernEnvironment implements IEnvironment {
treatMissingFieldsAsNull: this._treatMissingFieldsAsNull,
});
return () => executor.cancel();
}).do(logObserver);
});
}

/**
Expand All @@ -421,10 +416,6 @@ class RelayModernEnvironment implements IEnvironment {
updater?: ?SelectorStoreUpdater,
uploadables?: ?UploadableMap,
|}): RelayObservable<GraphQLResponse> {
const logObserver = this.__createExecuteLogObserver(
operation.request.node.params,
operation.request.variables,
);
return RelayObservable.create(sink => {
let optimisticConfig;
if (optimisticResponse || optimisticUpdater) {
Expand Down Expand Up @@ -460,7 +451,7 @@ class RelayModernEnvironment implements IEnvironment {
treatMissingFieldsAsNull: this._treatMissingFieldsAsNull,
});
return () => executor.cancel();
}).do(logObserver);
});
}

/**
Expand All @@ -479,10 +470,6 @@ class RelayModernEnvironment implements IEnvironment {
operation: OperationDescriptor,
source: RelayObservable<GraphQLResponse>,
|}): RelayObservable<GraphQLResponse> {
const logObserver = this.__createExecuteLogObserver(
operation.request.node.params,
operation.request.variables,
);
return RelayObservable.create(sink => {
const executor = RelayModernQueryExecutor.execute({
operation,
Expand All @@ -500,57 +487,13 @@ class RelayModernEnvironment implements IEnvironment {
treatMissingFieldsAsNull: this._treatMissingFieldsAsNull,
});
return () => executor.cancel();
}).do(logObserver);
});
}

toJSON(): mixed {
return `RelayModernEnvironment(${this.configName ?? ''})`;
}
__createExecuteLogObserver(
params: RequestParameters,
variables: Variables,
): Observer<GraphQLResponse> {
const transactionID = generateID();
const log = this.__log;
return {
start: subscription => {
log({
name: 'execute.start',
transactionID,
params,
variables,
});
},
next: response => {
log({
name: 'execute.next',
transactionID,
response,
});
},
error: error => {
log({
name: 'execute.error',
transactionID,
error,
});
},
complete: () => {
log({
name: 'execute.complete',
transactionID,
});
},
unsubscribe: () => {
log({
name: 'execute.unsubscribe',
transactionID,
});
},
};
}

/**
* Wraps the network with logging to ensure that network requests are
* always logged. Relying on each network callsite to be wrapped is
Expand Down
24 changes: 0 additions & 24 deletions packages/relay-runtime/store/RelayStoreTypes.js
Original file line number Diff line number Diff line change
Expand Up @@ -464,30 +464,6 @@ export type LogEvent =
// value from ProfilerContext
+profilerContext: mixed,
|}
| {|
+name: 'execute.start',
+transactionID: number,
+params: RequestParameters,
+variables: Variables,
|}
| {|
+name: 'execute.next',
+transactionID: number,
+response: GraphQLResponse,
|}
| {|
+name: 'execute.error',
+transactionID: number,
+error: Error,
|}
| {|
+name: 'execute.complete',
+transactionID: number,
|}
| {|
+name: 'execute.unsubscribe',
+transactionID: number,
|}
| {|
+name: 'network.info',
+transactionID: number,
Expand Down

0 comments on commit 5075851

Please sign in to comment.