mirror of
https://github.com/gosticks/DefinitelyTyped.git
synced 2025-10-16 12:05:41 +00:00
* add RelayNetworkLogger types * add export for RelayNetworkLoggerTransaction Fix changes suggested by TravisCI too * add export to createRelayNetworkLogger and change type of arg * move Network loggers to separate files * add tests to RelayNetworkLogger
160 lines
3.6 KiB
TypeScript
160 lines
3.6 KiB
TypeScript
import {
|
|
ConcreteRequest,
|
|
Environment,
|
|
Network,
|
|
RecordSource,
|
|
Store,
|
|
ConnectionHandler,
|
|
ViewerHandler,
|
|
commitLocalUpdate,
|
|
QueryResponseCache,
|
|
ROOT_ID,
|
|
RelayNetworkLoggerTransaction,
|
|
createRelayNetworkLogger,
|
|
} from 'relay-runtime';
|
|
|
|
const source = new RecordSource();
|
|
const store = new Store(source);
|
|
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
// Network Layer
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
// Define a function that fetches the results of an operation (query/mutation/etc)
|
|
// and returns its results as a Promise:
|
|
function fetchQuery(operation: any, variables: { [key: string]: string }, cacheConfig: {}) {
|
|
return fetch('/graphql', {
|
|
method: 'POST',
|
|
body: JSON.stringify({
|
|
query: operation.text, // GraphQL text from input
|
|
variables,
|
|
}),
|
|
}).then((response: any) => {
|
|
return response.json();
|
|
});
|
|
}
|
|
|
|
const RelayNetworkLogger = createRelayNetworkLogger(RelayNetworkLoggerTransaction);
|
|
|
|
// Create a network layer from the fetch function
|
|
const network = Network.create(RelayNetworkLogger.wrapFetch(fetchQuery));
|
|
|
|
// Create a cache for storing query responses
|
|
const cache = new QueryResponseCache({ size: 250, ttl: 60000 });
|
|
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
// Environment
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
const environment = new Environment({
|
|
handlerProvider, // Can omit.
|
|
network,
|
|
store,
|
|
});
|
|
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
// Handler Provider
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
|
|
function handlerProvider(handle: any) {
|
|
switch (handle) {
|
|
// Augment (or remove from) this list:
|
|
case 'connection':
|
|
return ConnectionHandler;
|
|
// case 'viewer':
|
|
// // ViewerHandler is special-cased and does not have an `update` method
|
|
// return ViewerHandler;
|
|
}
|
|
throw new Error(`handlerProvider: No handler provided for ${handle}`);
|
|
}
|
|
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
// Source
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
|
|
store.publish(source);
|
|
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
// commitLocalUpdate
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
|
|
commitLocalUpdate(environment, store => {
|
|
const root = store.get(ROOT_ID)!;
|
|
root.setValue('foo', 'localKey');
|
|
});
|
|
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
// ConcreteRequest
|
|
// ~~~~~~~~~~~~~~~~~~~~~
|
|
|
|
/*
|
|
# client schema
|
|
extend type Query {
|
|
foo: Boolean!
|
|
}
|
|
*/
|
|
|
|
/*
|
|
// component
|
|
graphql`
|
|
query FooQuery {
|
|
__typename
|
|
foo
|
|
}
|
|
`;
|
|
*/
|
|
|
|
/*
|
|
query FooQuery {
|
|
__typename
|
|
}
|
|
*/
|
|
|
|
/* tslint:disable:only-arrow-functions no-var-keyword prefer-const */
|
|
const node: ConcreteRequest = (function() {
|
|
var v0 = [
|
|
{
|
|
kind: 'ScalarField',
|
|
alias: null,
|
|
name: '__typename',
|
|
args: null,
|
|
storageKey: null,
|
|
},
|
|
{
|
|
kind: 'ClientExtension',
|
|
selections: [
|
|
{
|
|
kind: 'ScalarField',
|
|
alias: null,
|
|
name: 'foo',
|
|
args: null,
|
|
storageKey: null,
|
|
},
|
|
],
|
|
},
|
|
];
|
|
return {
|
|
kind: 'Request',
|
|
fragment: {
|
|
kind: 'Fragment',
|
|
name: 'FooQuery',
|
|
type: 'Query',
|
|
metadata: null,
|
|
argumentDefinitions: [],
|
|
selections: v0 /*: any*/,
|
|
},
|
|
operation: {
|
|
kind: 'Operation',
|
|
name: 'FooQuery',
|
|
argumentDefinitions: [],
|
|
selections: v0 /*: any*/,
|
|
},
|
|
params: {
|
|
operationKind: 'query',
|
|
name: 'FooQuery',
|
|
id: null,
|
|
text: 'query FooQuery {\n __typename\n}\n',
|
|
metadata: {},
|
|
},
|
|
};
|
|
})();
|
|
/* tslint:enable:only-arrow-functions no-var-keyword prefer-const */
|