1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617 |
- var SubscriptionsTransportWs =
- /******/ (function(modules) { // webpackBootstrap
- /******/ // The module cache
- /******/ var installedModules = {};
- /******/
- /******/ // The require function
- /******/ function __webpack_require__(moduleId) {
- /******/
- /******/ // Check if module is in cache
- /******/ if(installedModules[moduleId]) {
- /******/ return installedModules[moduleId].exports;
- /******/ }
- /******/ // Create a new module (and put it into the cache)
- /******/ var module = installedModules[moduleId] = {
- /******/ i: moduleId,
- /******/ l: false,
- /******/ exports: {}
- /******/ };
- /******/
- /******/ // Execute the module function
- /******/ modules[moduleId].call(module.exports, module, module.exports, __webpack_require__);
- /******/
- /******/ // Flag the module as loaded
- /******/ module.l = true;
- /******/
- /******/ // Return the exports of the module
- /******/ return module.exports;
- /******/ }
- /******/
- /******/
- /******/ // expose the modules object (__webpack_modules__)
- /******/ __webpack_require__.m = modules;
- /******/
- /******/ // expose the module cache
- /******/ __webpack_require__.c = installedModules;
- /******/
- /******/ // define getter function for harmony exports
- /******/ __webpack_require__.d = function(exports, name, getter) {
- /******/ if(!__webpack_require__.o(exports, name)) {
- /******/ Object.defineProperty(exports, name, {
- /******/ configurable: false,
- /******/ enumerable: true,
- /******/ get: getter
- /******/ });
- /******/ }
- /******/ };
- /******/
- /******/ // getDefaultExport function for compatibility with non-harmony modules
- /******/ __webpack_require__.n = function(module) {
- /******/ var getter = module && module.__esModule ?
- /******/ function getDefault() { return module['default']; } :
- /******/ function getModuleExports() { return module; };
- /******/ __webpack_require__.d(getter, 'a', getter);
- /******/ return getter;
- /******/ };
- /******/
- /******/ // Object.prototype.hasOwnProperty.call
- /******/ __webpack_require__.o = function(object, property) { return Object.prototype.hasOwnProperty.call(object, property); };
- /******/
- /******/ // __webpack_public_path__
- /******/ __webpack_require__.p = "";
- /******/
- /******/ // Load entry module and return exports
- /******/ return __webpack_require__(__webpack_require__.s = 2);
- /******/ })
- /************************************************************************/
- /******/ ([
- /* 0 */
- /***/ (function(module, exports) {
- var g;
- // This works in non-strict mode
- g = (function() {
- return this;
- })();
- try {
- // This works if eval is allowed (see CSP)
- g = g || Function("return this")() || (1,eval)("this");
- } catch(e) {
- // This works if the window reference is available
- if(typeof window === "object")
- g = window;
- }
- // g can still be undefined, but nothing to do about it...
- // We return undefined, instead of nothing here, so it's
- // easier to handle this case. if(!global) { ...}
- module.exports = g;
- /***/ }),
- /* 1 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.default = void 0;
- // istanbul ignore next (See: 'https://github.com/graphql/graphql-js/issues/2317')
- var nodejsCustomInspectSymbol = typeof Symbol === 'function' && typeof Symbol.for === 'function' ? Symbol.for('nodejs.util.inspect.custom') : undefined;
- var _default = nodejsCustomInspectSymbol;
- exports.default = _default;
- /***/ }),
- /* 2 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- /* WEBPACK VAR INJECTION */(function(global) {
- var __assign = (this && this.__assign) || function () {
- __assign = Object.assign || function(t) {
- for (var s, i = 1, n = arguments.length; i < n; i++) {
- s = arguments[i];
- for (var p in s) if (Object.prototype.hasOwnProperty.call(s, p))
- t[p] = s[p];
- }
- return t;
- };
- return __assign.apply(this, arguments);
- };
- var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
- function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
- return new (P || (P = Promise))(function (resolve, reject) {
- function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
- function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
- function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
- step((generator = generator.apply(thisArg, _arguments || [])).next());
- });
- };
- var __generator = (this && this.__generator) || function (thisArg, body) {
- var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
- return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
- function verb(n) { return function (v) { return step([n, v]); }; }
- function step(op) {
- if (f) throw new TypeError("Generator is already executing.");
- while (_) try {
- if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
- if (y = 0, t) op = [op[0] & 2, t.value];
- switch (op[0]) {
- case 0: case 1: t = op; break;
- case 4: _.label++; return { value: op[1], done: false };
- case 5: _.label++; y = op[1]; op = [0]; continue;
- case 7: op = _.ops.pop(); _.trys.pop(); continue;
- default:
- if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
- if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
- if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
- if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
- if (t[2]) _.ops.pop();
- _.trys.pop(); continue;
- }
- op = body.call(thisArg, _);
- } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
- if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
- }
- };
- var __spreadArrays = (this && this.__spreadArrays) || function () {
- for (var s = 0, i = 0, il = arguments.length; i < il; i++) s += arguments[i].length;
- for (var r = Array(s), k = 0, i = 0; i < il; i++)
- for (var a = arguments[i], j = 0, jl = a.length; j < jl; j++, k++)
- r[k] = a[j];
- return r;
- };
- Object.defineProperty(exports, "__esModule", { value: true });
- exports.SubscriptionClient = void 0;
- var _global = typeof global !== 'undefined' ? global : (typeof window !== 'undefined' ? window : {});
- var NativeWebSocket = _global.WebSocket || _global.MozWebSocket;
- var Backoff = __webpack_require__(3);
- var eventemitter3_1 = __webpack_require__(4);
- var is_string_1 = __webpack_require__(5);
- var is_object_1 = __webpack_require__(6);
- var printer_1 = __webpack_require__(7);
- var getOperationAST_1 = __webpack_require__(14);
- var symbol_observable_1 = __webpack_require__(16);
- var protocol_1 = __webpack_require__(19);
- var defaults_1 = __webpack_require__(20);
- var message_types_1 = __webpack_require__(21);
- var SubscriptionClient = (function () {
- function SubscriptionClient(url, options, webSocketImpl, webSocketProtocols) {
- var _a = (options || {}), _b = _a.connectionCallback, connectionCallback = _b === void 0 ? undefined : _b, _c = _a.connectionParams, connectionParams = _c === void 0 ? {} : _c, _d = _a.minTimeout, minTimeout = _d === void 0 ? defaults_1.MIN_WS_TIMEOUT : _d, _e = _a.timeout, timeout = _e === void 0 ? defaults_1.WS_TIMEOUT : _e, _f = _a.reconnect, reconnect = _f === void 0 ? false : _f, _g = _a.reconnectionAttempts, reconnectionAttempts = _g === void 0 ? Infinity : _g, _h = _a.lazy, lazy = _h === void 0 ? false : _h, _j = _a.inactivityTimeout, inactivityTimeout = _j === void 0 ? 0 : _j, _k = _a.wsOptionArguments, wsOptionArguments = _k === void 0 ? [] : _k;
- this.wsImpl = webSocketImpl || NativeWebSocket;
- if (!this.wsImpl) {
- throw new Error('Unable to find native implementation, or alternative implementation for WebSocket!');
- }
- this.wsProtocols = webSocketProtocols || protocol_1.GRAPHQL_WS;
- this.connectionCallback = connectionCallback;
- this.url = url;
- this.operations = {};
- this.nextOperationId = 0;
- this.minWsTimeout = minTimeout;
- this.wsTimeout = timeout;
- this.unsentMessagesQueue = [];
- this.reconnect = reconnect;
- this.reconnecting = false;
- this.reconnectionAttempts = reconnectionAttempts;
- this.lazy = !!lazy;
- this.inactivityTimeout = inactivityTimeout;
- this.closedByUser = false;
- this.backoff = new Backoff({ jitter: 0.5 });
- this.eventEmitter = new eventemitter3_1.EventEmitter();
- this.middlewares = [];
- this.client = null;
- this.maxConnectTimeGenerator = this.createMaxConnectTimeGenerator();
- this.connectionParams = this.getConnectionParams(connectionParams);
- this.wsOptionArguments = wsOptionArguments;
- if (!this.lazy) {
- this.connect();
- }
- }
- Object.defineProperty(SubscriptionClient.prototype, "status", {
- get: function () {
- if (this.client === null) {
- return this.wsImpl.CLOSED;
- }
- return this.client.readyState;
- },
- enumerable: false,
- configurable: true
- });
- SubscriptionClient.prototype.close = function (isForced, closedByUser) {
- if (isForced === void 0) { isForced = true; }
- if (closedByUser === void 0) { closedByUser = true; }
- this.clearInactivityTimeout();
- if (this.client !== null) {
- this.closedByUser = closedByUser;
- if (isForced) {
- this.clearCheckConnectionInterval();
- this.clearMaxConnectTimeout();
- this.clearTryReconnectTimeout();
- this.unsubscribeAll();
- this.sendMessage(undefined, message_types_1.default.GQL_CONNECTION_TERMINATE, null);
- }
- this.client.close();
- this.client.onopen = null;
- this.client.onclose = null;
- this.client.onerror = null;
- this.client.onmessage = null;
- this.client = null;
- this.eventEmitter.emit('disconnected');
- if (!isForced) {
- this.tryReconnect();
- }
- }
- };
- SubscriptionClient.prototype.request = function (request) {
- var _a;
- var getObserver = this.getObserver.bind(this);
- var executeOperation = this.executeOperation.bind(this);
- var unsubscribe = this.unsubscribe.bind(this);
- var opId;
- this.clearInactivityTimeout();
- return _a = {},
- _a[symbol_observable_1.default] = function () {
- return this;
- },
- _a.subscribe = function (observerOrNext, onError, onComplete) {
- var observer = getObserver(observerOrNext, onError, onComplete);
- opId = executeOperation(request, function (error, result) {
- if (error === null && result === null) {
- if (observer.complete) {
- observer.complete();
- }
- }
- else if (error) {
- if (observer.error) {
- observer.error(error[0]);
- }
- }
- else {
- if (observer.next) {
- observer.next(result);
- }
- }
- });
- return {
- unsubscribe: function () {
- if (opId) {
- unsubscribe(opId);
- opId = null;
- }
- },
- };
- },
- _a;
- };
- SubscriptionClient.prototype.on = function (eventName, callback, context) {
- var handler = this.eventEmitter.on(eventName, callback, context);
- return function () {
- handler.off(eventName, callback, context);
- };
- };
- SubscriptionClient.prototype.onConnected = function (callback, context) {
- return this.on('connected', callback, context);
- };
- SubscriptionClient.prototype.onConnecting = function (callback, context) {
- return this.on('connecting', callback, context);
- };
- SubscriptionClient.prototype.onDisconnected = function (callback, context) {
- return this.on('disconnected', callback, context);
- };
- SubscriptionClient.prototype.onReconnected = function (callback, context) {
- return this.on('reconnected', callback, context);
- };
- SubscriptionClient.prototype.onReconnecting = function (callback, context) {
- return this.on('reconnecting', callback, context);
- };
- SubscriptionClient.prototype.onError = function (callback, context) {
- return this.on('error', callback, context);
- };
- SubscriptionClient.prototype.unsubscribeAll = function () {
- var _this = this;
- Object.keys(this.operations).forEach(function (subId) {
- _this.unsubscribe(subId);
- });
- };
- SubscriptionClient.prototype.applyMiddlewares = function (options) {
- var _this = this;
- return new Promise(function (resolve, reject) {
- var queue = function (funcs, scope) {
- var next = function (error) {
- if (error) {
- reject(error);
- }
- else {
- if (funcs.length > 0) {
- var f = funcs.shift();
- if (f) {
- f.applyMiddleware.apply(scope, [options, next]);
- }
- }
- else {
- resolve(options);
- }
- }
- };
- next();
- };
- queue(__spreadArrays(_this.middlewares), _this);
- });
- };
- SubscriptionClient.prototype.use = function (middlewares) {
- var _this = this;
- middlewares.map(function (middleware) {
- if (typeof middleware.applyMiddleware === 'function') {
- _this.middlewares.push(middleware);
- }
- else {
- throw new Error('Middleware must implement the applyMiddleware function.');
- }
- });
- return this;
- };
- SubscriptionClient.prototype.getConnectionParams = function (connectionParams) {
- return function () { return new Promise(function (resolve, reject) {
- if (typeof connectionParams === 'function') {
- try {
- return resolve(connectionParams.call(null));
- }
- catch (error) {
- return reject(error);
- }
- }
- resolve(connectionParams);
- }); };
- };
- SubscriptionClient.prototype.executeOperation = function (options, handler) {
- var _this = this;
- if (this.client === null) {
- this.connect();
- }
- var opId = this.generateOperationId();
- this.operations[opId] = { options: options, handler: handler };
- this.applyMiddlewares(options)
- .then(function (processedOptions) {
- _this.checkOperationOptions(processedOptions, handler);
- if (_this.operations[opId]) {
- _this.operations[opId] = { options: processedOptions, handler: handler };
- _this.sendMessage(opId, message_types_1.default.GQL_START, processedOptions);
- }
- })
- .catch(function (error) {
- _this.unsubscribe(opId);
- handler(_this.formatErrors(error));
- });
- return opId;
- };
- SubscriptionClient.prototype.getObserver = function (observerOrNext, error, complete) {
- if (typeof observerOrNext === 'function') {
- return {
- next: function (v) { return observerOrNext(v); },
- error: function (e) { return error && error(e); },
- complete: function () { return complete && complete(); },
- };
- }
- return observerOrNext;
- };
- SubscriptionClient.prototype.createMaxConnectTimeGenerator = function () {
- var minValue = this.minWsTimeout;
- var maxValue = this.wsTimeout;
- return new Backoff({
- min: minValue,
- max: maxValue,
- factor: 1.2,
- });
- };
- SubscriptionClient.prototype.clearCheckConnectionInterval = function () {
- if (this.checkConnectionIntervalId) {
- clearInterval(this.checkConnectionIntervalId);
- this.checkConnectionIntervalId = null;
- }
- };
- SubscriptionClient.prototype.clearMaxConnectTimeout = function () {
- if (this.maxConnectTimeoutId) {
- clearTimeout(this.maxConnectTimeoutId);
- this.maxConnectTimeoutId = null;
- }
- };
- SubscriptionClient.prototype.clearTryReconnectTimeout = function () {
- if (this.tryReconnectTimeoutId) {
- clearTimeout(this.tryReconnectTimeoutId);
- this.tryReconnectTimeoutId = null;
- }
- };
- SubscriptionClient.prototype.clearInactivityTimeout = function () {
- if (this.inactivityTimeoutId) {
- clearTimeout(this.inactivityTimeoutId);
- this.inactivityTimeoutId = null;
- }
- };
- SubscriptionClient.prototype.setInactivityTimeout = function () {
- var _this = this;
- if (this.inactivityTimeout > 0 && Object.keys(this.operations).length === 0) {
- this.inactivityTimeoutId = setTimeout(function () {
- if (Object.keys(_this.operations).length === 0) {
- _this.close();
- }
- }, this.inactivityTimeout);
- }
- };
- SubscriptionClient.prototype.checkOperationOptions = function (options, handler) {
- var query = options.query, variables = options.variables, operationName = options.operationName;
- if (!query) {
- throw new Error('Must provide a query.');
- }
- if (!handler) {
- throw new Error('Must provide an handler.');
- }
- if ((!is_string_1.default(query) && !getOperationAST_1.getOperationAST(query, operationName)) ||
- (operationName && !is_string_1.default(operationName)) ||
- (variables && !is_object_1.default(variables))) {
- throw new Error('Incorrect option types. query must be a string or a document,' +
- '`operationName` must be a string, and `variables` must be an object.');
- }
- };
- SubscriptionClient.prototype.buildMessage = function (id, type, payload) {
- var payloadToReturn = payload && payload.query ? __assign(__assign({}, payload), { query: typeof payload.query === 'string' ? payload.query : printer_1.print(payload.query) }) :
- payload;
- return {
- id: id,
- type: type,
- payload: payloadToReturn,
- };
- };
- SubscriptionClient.prototype.formatErrors = function (errors) {
- if (Array.isArray(errors)) {
- return errors;
- }
- if (errors && errors.errors) {
- return this.formatErrors(errors.errors);
- }
- if (errors && errors.message) {
- return [errors];
- }
- return [{
- name: 'FormatedError',
- message: 'Unknown error',
- originalError: errors,
- }];
- };
- SubscriptionClient.prototype.sendMessage = function (id, type, payload) {
- this.sendMessageRaw(this.buildMessage(id, type, payload));
- };
- SubscriptionClient.prototype.sendMessageRaw = function (message) {
- switch (this.status) {
- case this.wsImpl.OPEN:
- var serializedMessage = JSON.stringify(message);
- try {
- JSON.parse(serializedMessage);
- }
- catch (e) {
- this.eventEmitter.emit('error', new Error("Message must be JSON-serializable. Got: " + message));
- }
- this.client.send(serializedMessage);
- break;
- case this.wsImpl.CONNECTING:
- this.unsentMessagesQueue.push(message);
- break;
- default:
- if (!this.reconnecting) {
- this.eventEmitter.emit('error', new Error('A message was not sent because socket is not connected, is closing or ' +
- 'is already closed. Message was: ' + JSON.stringify(message)));
- }
- }
- };
- SubscriptionClient.prototype.generateOperationId = function () {
- return String(++this.nextOperationId);
- };
- SubscriptionClient.prototype.tryReconnect = function () {
- var _this = this;
- if (!this.reconnect || this.backoff.attempts >= this.reconnectionAttempts) {
- return;
- }
- if (!this.reconnecting) {
- Object.keys(this.operations).forEach(function (key) {
- _this.unsentMessagesQueue.push(_this.buildMessage(key, message_types_1.default.GQL_START, _this.operations[key].options));
- });
- this.reconnecting = true;
- }
- this.clearTryReconnectTimeout();
- var delay = this.backoff.duration();
- this.tryReconnectTimeoutId = setTimeout(function () {
- _this.connect();
- }, delay);
- };
- SubscriptionClient.prototype.flushUnsentMessagesQueue = function () {
- var _this = this;
- this.unsentMessagesQueue.forEach(function (message) {
- _this.sendMessageRaw(message);
- });
- this.unsentMessagesQueue = [];
- };
- SubscriptionClient.prototype.checkConnection = function () {
- if (this.wasKeepAliveReceived) {
- this.wasKeepAliveReceived = false;
- return;
- }
- if (!this.reconnecting) {
- this.close(false, true);
- }
- };
- SubscriptionClient.prototype.checkMaxConnectTimeout = function () {
- var _this = this;
- this.clearMaxConnectTimeout();
- this.maxConnectTimeoutId = setTimeout(function () {
- if (_this.status !== _this.wsImpl.OPEN) {
- _this.reconnecting = true;
- _this.close(false, true);
- }
- }, this.maxConnectTimeGenerator.duration());
- };
- SubscriptionClient.prototype.connect = function () {
- var _a;
- var _this = this;
- this.client = new ((_a = this.wsImpl).bind.apply(_a, __spreadArrays([void 0, this.url, this.wsProtocols], this.wsOptionArguments)))();
- this.checkMaxConnectTimeout();
- this.client.onopen = function () { return __awaiter(_this, void 0, void 0, function () {
- var connectionParams, error_1;
- return __generator(this, function (_a) {
- switch (_a.label) {
- case 0:
- if (!(this.status === this.wsImpl.OPEN)) return [3, 4];
- this.clearMaxConnectTimeout();
- this.closedByUser = false;
- this.eventEmitter.emit(this.reconnecting ? 'reconnecting' : 'connecting');
- _a.label = 1;
- case 1:
- _a.trys.push([1, 3, , 4]);
- return [4, this.connectionParams()];
- case 2:
- connectionParams = _a.sent();
- this.sendMessage(undefined, message_types_1.default.GQL_CONNECTION_INIT, connectionParams);
- this.flushUnsentMessagesQueue();
- return [3, 4];
- case 3:
- error_1 = _a.sent();
- this.sendMessage(undefined, message_types_1.default.GQL_CONNECTION_ERROR, error_1);
- this.flushUnsentMessagesQueue();
- return [3, 4];
- case 4: return [2];
- }
- });
- }); };
- this.client.onclose = function () {
- if (!_this.closedByUser) {
- _this.close(false, false);
- }
- };
- this.client.onerror = function (err) {
- _this.eventEmitter.emit('error', err);
- };
- this.client.onmessage = function (_a) {
- var data = _a.data;
- _this.processReceivedData(data);
- };
- };
- SubscriptionClient.prototype.processReceivedData = function (receivedData) {
- var parsedMessage;
- var opId;
- try {
- parsedMessage = JSON.parse(receivedData);
- opId = parsedMessage.id;
- }
- catch (e) {
- throw new Error("Message must be JSON-parseable. Got: " + receivedData);
- }
- if ([message_types_1.default.GQL_DATA,
- message_types_1.default.GQL_COMPLETE,
- message_types_1.default.GQL_ERROR,
- ].indexOf(parsedMessage.type) !== -1 && !this.operations[opId]) {
- this.unsubscribe(opId);
- return;
- }
- switch (parsedMessage.type) {
- case message_types_1.default.GQL_CONNECTION_ERROR:
- if (this.connectionCallback) {
- this.connectionCallback(parsedMessage.payload);
- }
- break;
- case message_types_1.default.GQL_CONNECTION_ACK:
- this.eventEmitter.emit(this.reconnecting ? 'reconnected' : 'connected', parsedMessage.payload);
- this.reconnecting = false;
- this.backoff.reset();
- this.maxConnectTimeGenerator.reset();
- if (this.connectionCallback) {
- this.connectionCallback();
- }
- break;
- case message_types_1.default.GQL_COMPLETE:
- var handler = this.operations[opId].handler;
- delete this.operations[opId];
- handler.call(this, null, null);
- break;
- case message_types_1.default.GQL_ERROR:
- this.operations[opId].handler(this.formatErrors(parsedMessage.payload), null);
- delete this.operations[opId];
- break;
- case message_types_1.default.GQL_DATA:
- var parsedPayload = !parsedMessage.payload.errors ?
- parsedMessage.payload : __assign(__assign({}, parsedMessage.payload), { errors: this.formatErrors(parsedMessage.payload.errors) });
- this.operations[opId].handler(null, parsedPayload);
- break;
- case message_types_1.default.GQL_CONNECTION_KEEP_ALIVE:
- var firstKA = typeof this.wasKeepAliveReceived === 'undefined';
- this.wasKeepAliveReceived = true;
- if (firstKA) {
- this.checkConnection();
- }
- if (this.checkConnectionIntervalId) {
- clearInterval(this.checkConnectionIntervalId);
- this.checkConnection();
- }
- this.checkConnectionIntervalId = setInterval(this.checkConnection.bind(this), this.wsTimeout);
- break;
- default:
- throw new Error('Invalid message type!');
- }
- };
- SubscriptionClient.prototype.unsubscribe = function (opId) {
- if (this.operations[opId]) {
- delete this.operations[opId];
- this.setInactivityTimeout();
- this.sendMessage(opId, message_types_1.default.GQL_STOP, undefined);
- }
- };
- return SubscriptionClient;
- }());
- exports.SubscriptionClient = SubscriptionClient;
- //# sourceMappingURL=client.js.map
- /* WEBPACK VAR INJECTION */}.call(exports, __webpack_require__(0)))
- /***/ }),
- /* 3 */
- /***/ (function(module, exports) {
- /**
- * Expose `Backoff`.
- */
- module.exports = Backoff;
- /**
- * Initialize backoff timer with `opts`.
- *
- * - `min` initial timeout in milliseconds [100]
- * - `max` max timeout [10000]
- * - `jitter` [0]
- * - `factor` [2]
- *
- * @param {Object} opts
- * @api public
- */
- function Backoff(opts) {
- opts = opts || {};
- this.ms = opts.min || 100;
- this.max = opts.max || 10000;
- this.factor = opts.factor || 2;
- this.jitter = opts.jitter > 0 && opts.jitter <= 1 ? opts.jitter : 0;
- this.attempts = 0;
- }
- /**
- * Return the backoff duration.
- *
- * @return {Number}
- * @api public
- */
- Backoff.prototype.duration = function(){
- var ms = this.ms * Math.pow(this.factor, this.attempts++);
- if (this.jitter) {
- var rand = Math.random();
- var deviation = Math.floor(rand * this.jitter * ms);
- ms = (Math.floor(rand * 10) & 1) == 0 ? ms - deviation : ms + deviation;
- }
- return Math.min(ms, this.max) | 0;
- };
- /**
- * Reset the number of attempts.
- *
- * @api public
- */
- Backoff.prototype.reset = function(){
- this.attempts = 0;
- };
- /**
- * Set the minimum duration
- *
- * @api public
- */
- Backoff.prototype.setMin = function(min){
- this.ms = min;
- };
- /**
- * Set the maximum duration
- *
- * @api public
- */
- Backoff.prototype.setMax = function(max){
- this.max = max;
- };
- /**
- * Set the jitter
- *
- * @api public
- */
- Backoff.prototype.setJitter = function(jitter){
- this.jitter = jitter;
- };
- /***/ }),
- /* 4 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- var has = Object.prototype.hasOwnProperty
- , prefix = '~';
- /**
- * Constructor to create a storage for our `EE` objects.
- * An `Events` instance is a plain object whose properties are event names.
- *
- * @constructor
- * @private
- */
- function Events() {}
- //
- // We try to not inherit from `Object.prototype`. In some engines creating an
- // instance in this way is faster than calling `Object.create(null)` directly.
- // If `Object.create(null)` is not supported we prefix the event names with a
- // character to make sure that the built-in object properties are not
- // overridden or used as an attack vector.
- //
- if (Object.create) {
- Events.prototype = Object.create(null);
- //
- // This hack is needed because the `__proto__` property is still inherited in
- // some old browsers like Android 4, iPhone 5.1, Opera 11 and Safari 5.
- //
- if (!new Events().__proto__) prefix = false;
- }
- /**
- * Representation of a single event listener.
- *
- * @param {Function} fn The listener function.
- * @param {*} context The context to invoke the listener with.
- * @param {Boolean} [once=false] Specify if the listener is a one-time listener.
- * @constructor
- * @private
- */
- function EE(fn, context, once) {
- this.fn = fn;
- this.context = context;
- this.once = once || false;
- }
- /**
- * Add a listener for a given event.
- *
- * @param {EventEmitter} emitter Reference to the `EventEmitter` instance.
- * @param {(String|Symbol)} event The event name.
- * @param {Function} fn The listener function.
- * @param {*} context The context to invoke the listener with.
- * @param {Boolean} once Specify if the listener is a one-time listener.
- * @returns {EventEmitter}
- * @private
- */
- function addListener(emitter, event, fn, context, once) {
- if (typeof fn !== 'function') {
- throw new TypeError('The listener must be a function');
- }
- var listener = new EE(fn, context || emitter, once)
- , evt = prefix ? prefix + event : event;
- if (!emitter._events[evt]) emitter._events[evt] = listener, emitter._eventsCount++;
- else if (!emitter._events[evt].fn) emitter._events[evt].push(listener);
- else emitter._events[evt] = [emitter._events[evt], listener];
- return emitter;
- }
- /**
- * Clear event by name.
- *
- * @param {EventEmitter} emitter Reference to the `EventEmitter` instance.
- * @param {(String|Symbol)} evt The Event name.
- * @private
- */
- function clearEvent(emitter, evt) {
- if (--emitter._eventsCount === 0) emitter._events = new Events();
- else delete emitter._events[evt];
- }
- /**
- * Minimal `EventEmitter` interface that is molded against the Node.js
- * `EventEmitter` interface.
- *
- * @constructor
- * @public
- */
- function EventEmitter() {
- this._events = new Events();
- this._eventsCount = 0;
- }
- /**
- * Return an array listing the events for which the emitter has registered
- * listeners.
- *
- * @returns {Array}
- * @public
- */
- EventEmitter.prototype.eventNames = function eventNames() {
- var names = []
- , events
- , name;
- if (this._eventsCount === 0) return names;
- for (name in (events = this._events)) {
- if (has.call(events, name)) names.push(prefix ? name.slice(1) : name);
- }
- if (Object.getOwnPropertySymbols) {
- return names.concat(Object.getOwnPropertySymbols(events));
- }
- return names;
- };
- /**
- * Return the listeners registered for a given event.
- *
- * @param {(String|Symbol)} event The event name.
- * @returns {Array} The registered listeners.
- * @public
- */
- EventEmitter.prototype.listeners = function listeners(event) {
- var evt = prefix ? prefix + event : event
- , handlers = this._events[evt];
- if (!handlers) return [];
- if (handlers.fn) return [handlers.fn];
- for (var i = 0, l = handlers.length, ee = new Array(l); i < l; i++) {
- ee[i] = handlers[i].fn;
- }
- return ee;
- };
- /**
- * Return the number of listeners listening to a given event.
- *
- * @param {(String|Symbol)} event The event name.
- * @returns {Number} The number of listeners.
- * @public
- */
- EventEmitter.prototype.listenerCount = function listenerCount(event) {
- var evt = prefix ? prefix + event : event
- , listeners = this._events[evt];
- if (!listeners) return 0;
- if (listeners.fn) return 1;
- return listeners.length;
- };
- /**
- * Calls each of the listeners registered for a given event.
- *
- * @param {(String|Symbol)} event The event name.
- * @returns {Boolean} `true` if the event had listeners, else `false`.
- * @public
- */
- EventEmitter.prototype.emit = function emit(event, a1, a2, a3, a4, a5) {
- var evt = prefix ? prefix + event : event;
- if (!this._events[evt]) return false;
- var listeners = this._events[evt]
- , len = arguments.length
- , args
- , i;
- if (listeners.fn) {
- if (listeners.once) this.removeListener(event, listeners.fn, undefined, true);
- switch (len) {
- case 1: return listeners.fn.call(listeners.context), true;
- case 2: return listeners.fn.call(listeners.context, a1), true;
- case 3: return listeners.fn.call(listeners.context, a1, a2), true;
- case 4: return listeners.fn.call(listeners.context, a1, a2, a3), true;
- case 5: return listeners.fn.call(listeners.context, a1, a2, a3, a4), true;
- case 6: return listeners.fn.call(listeners.context, a1, a2, a3, a4, a5), true;
- }
- for (i = 1, args = new Array(len -1); i < len; i++) {
- args[i - 1] = arguments[i];
- }
- listeners.fn.apply(listeners.context, args);
- } else {
- var length = listeners.length
- , j;
- for (i = 0; i < length; i++) {
- if (listeners[i].once) this.removeListener(event, listeners[i].fn, undefined, true);
- switch (len) {
- case 1: listeners[i].fn.call(listeners[i].context); break;
- case 2: listeners[i].fn.call(listeners[i].context, a1); break;
- case 3: listeners[i].fn.call(listeners[i].context, a1, a2); break;
- case 4: listeners[i].fn.call(listeners[i].context, a1, a2, a3); break;
- default:
- if (!args) for (j = 1, args = new Array(len -1); j < len; j++) {
- args[j - 1] = arguments[j];
- }
- listeners[i].fn.apply(listeners[i].context, args);
- }
- }
- }
- return true;
- };
- /**
- * Add a listener for a given event.
- *
- * @param {(String|Symbol)} event The event name.
- * @param {Function} fn The listener function.
- * @param {*} [context=this] The context to invoke the listener with.
- * @returns {EventEmitter} `this`.
- * @public
- */
- EventEmitter.prototype.on = function on(event, fn, context) {
- return addListener(this, event, fn, context, false);
- };
- /**
- * Add a one-time listener for a given event.
- *
- * @param {(String|Symbol)} event The event name.
- * @param {Function} fn The listener function.
- * @param {*} [context=this] The context to invoke the listener with.
- * @returns {EventEmitter} `this`.
- * @public
- */
- EventEmitter.prototype.once = function once(event, fn, context) {
- return addListener(this, event, fn, context, true);
- };
- /**
- * Remove the listeners of a given event.
- *
- * @param {(String|Symbol)} event The event name.
- * @param {Function} fn Only remove the listeners that match this function.
- * @param {*} context Only remove the listeners that have this context.
- * @param {Boolean} once Only remove one-time listeners.
- * @returns {EventEmitter} `this`.
- * @public
- */
- EventEmitter.prototype.removeListener = function removeListener(event, fn, context, once) {
- var evt = prefix ? prefix + event : event;
- if (!this._events[evt]) return this;
- if (!fn) {
- clearEvent(this, evt);
- return this;
- }
- var listeners = this._events[evt];
- if (listeners.fn) {
- if (
- listeners.fn === fn &&
- (!once || listeners.once) &&
- (!context || listeners.context === context)
- ) {
- clearEvent(this, evt);
- }
- } else {
- for (var i = 0, events = [], length = listeners.length; i < length; i++) {
- if (
- listeners[i].fn !== fn ||
- (once && !listeners[i].once) ||
- (context && listeners[i].context !== context)
- ) {
- events.push(listeners[i]);
- }
- }
- //
- // Reset the array, or remove it completely if we have no more listeners.
- //
- if (events.length) this._events[evt] = events.length === 1 ? events[0] : events;
- else clearEvent(this, evt);
- }
- return this;
- };
- /**
- * Remove all listeners, or those of the specified event.
- *
- * @param {(String|Symbol)} [event] The event name.
- * @returns {EventEmitter} `this`.
- * @public
- */
- EventEmitter.prototype.removeAllListeners = function removeAllListeners(event) {
- var evt;
- if (event) {
- evt = prefix ? prefix + event : event;
- if (this._events[evt]) clearEvent(this, evt);
- } else {
- this._events = new Events();
- this._eventsCount = 0;
- }
- return this;
- };
- //
- // Alias methods names because people roll like that.
- //
- EventEmitter.prototype.off = EventEmitter.prototype.removeListener;
- EventEmitter.prototype.addListener = EventEmitter.prototype.on;
- //
- // Expose the prefix.
- //
- EventEmitter.prefixed = prefix;
- //
- // Allow `EventEmitter` to be imported as module namespace.
- //
- EventEmitter.EventEmitter = EventEmitter;
- //
- // Expose the module.
- //
- if (true) {
- module.exports = EventEmitter;
- }
- /***/ }),
- /* 5 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", { value: true });
- function isString(value) {
- return typeof value === 'string';
- }
- exports.default = isString;
- //# sourceMappingURL=is-string.js.map
- /***/ }),
- /* 6 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", { value: true });
- function isObject(value) {
- return ((value !== null) && (typeof value === 'object'));
- }
- exports.default = isObject;
- //# sourceMappingURL=is-object.js.map
- /***/ }),
- /* 7 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.print = print;
- var _visitor = __webpack_require__(8);
- var _blockString = __webpack_require__(13);
- /**
- * Converts an AST into a string, using one set of reasonable
- * formatting rules.
- */
- function print(ast) {
- return (0, _visitor.visit)(ast, {
- leave: printDocASTReducer
- });
- }
- var MAX_LINE_LENGTH = 80; // TODO: provide better type coverage in future
- var printDocASTReducer = {
- Name: function Name(node) {
- return node.value;
- },
- Variable: function Variable(node) {
- return '$' + node.name;
- },
- // Document
- Document: function Document(node) {
- return join(node.definitions, '\n\n') + '\n';
- },
- OperationDefinition: function OperationDefinition(node) {
- var op = node.operation;
- var name = node.name;
- var varDefs = wrap('(', join(node.variableDefinitions, ', '), ')');
- var directives = join(node.directives, ' ');
- var selectionSet = node.selectionSet; // Anonymous queries with no directives or variable definitions can use
- // the query short form.
- return !name && !directives && !varDefs && op === 'query' ? selectionSet : join([op, join([name, varDefs]), directives, selectionSet], ' ');
- },
- VariableDefinition: function VariableDefinition(_ref) {
- var variable = _ref.variable,
- type = _ref.type,
- defaultValue = _ref.defaultValue,
- directives = _ref.directives;
- return variable + ': ' + type + wrap(' = ', defaultValue) + wrap(' ', join(directives, ' '));
- },
- SelectionSet: function SelectionSet(_ref2) {
- var selections = _ref2.selections;
- return block(selections);
- },
- Field: function Field(_ref3) {
- var alias = _ref3.alias,
- name = _ref3.name,
- args = _ref3.arguments,
- directives = _ref3.directives,
- selectionSet = _ref3.selectionSet;
- var prefix = wrap('', alias, ': ') + name;
- var argsLine = prefix + wrap('(', join(args, ', '), ')');
- if (argsLine.length > MAX_LINE_LENGTH) {
- argsLine = prefix + wrap('(\n', indent(join(args, '\n')), '\n)');
- }
- return join([argsLine, join(directives, ' '), selectionSet], ' ');
- },
- Argument: function Argument(_ref4) {
- var name = _ref4.name,
- value = _ref4.value;
- return name + ': ' + value;
- },
- // Fragments
- FragmentSpread: function FragmentSpread(_ref5) {
- var name = _ref5.name,
- directives = _ref5.directives;
- return '...' + name + wrap(' ', join(directives, ' '));
- },
- InlineFragment: function InlineFragment(_ref6) {
- var typeCondition = _ref6.typeCondition,
- directives = _ref6.directives,
- selectionSet = _ref6.selectionSet;
- return join(['...', wrap('on ', typeCondition), join(directives, ' '), selectionSet], ' ');
- },
- FragmentDefinition: function FragmentDefinition(_ref7) {
- var name = _ref7.name,
- typeCondition = _ref7.typeCondition,
- variableDefinitions = _ref7.variableDefinitions,
- directives = _ref7.directives,
- selectionSet = _ref7.selectionSet;
- return (// Note: fragment variable definitions are experimental and may be changed
- // or removed in the future.
- "fragment ".concat(name).concat(wrap('(', join(variableDefinitions, ', '), ')'), " ") + "on ".concat(typeCondition, " ").concat(wrap('', join(directives, ' '), ' ')) + selectionSet
- );
- },
- // Value
- IntValue: function IntValue(_ref8) {
- var value = _ref8.value;
- return value;
- },
- FloatValue: function FloatValue(_ref9) {
- var value = _ref9.value;
- return value;
- },
- StringValue: function StringValue(_ref10, key) {
- var value = _ref10.value,
- isBlockString = _ref10.block;
- return isBlockString ? (0, _blockString.printBlockString)(value, key === 'description' ? '' : ' ') : JSON.stringify(value);
- },
- BooleanValue: function BooleanValue(_ref11) {
- var value = _ref11.value;
- return value ? 'true' : 'false';
- },
- NullValue: function NullValue() {
- return 'null';
- },
- EnumValue: function EnumValue(_ref12) {
- var value = _ref12.value;
- return value;
- },
- ListValue: function ListValue(_ref13) {
- var values = _ref13.values;
- return '[' + join(values, ', ') + ']';
- },
- ObjectValue: function ObjectValue(_ref14) {
- var fields = _ref14.fields;
- return '{' + join(fields, ', ') + '}';
- },
- ObjectField: function ObjectField(_ref15) {
- var name = _ref15.name,
- value = _ref15.value;
- return name + ': ' + value;
- },
- // Directive
- Directive: function Directive(_ref16) {
- var name = _ref16.name,
- args = _ref16.arguments;
- return '@' + name + wrap('(', join(args, ', '), ')');
- },
- // Type
- NamedType: function NamedType(_ref17) {
- var name = _ref17.name;
- return name;
- },
- ListType: function ListType(_ref18) {
- var type = _ref18.type;
- return '[' + type + ']';
- },
- NonNullType: function NonNullType(_ref19) {
- var type = _ref19.type;
- return type + '!';
- },
- // Type System Definitions
- SchemaDefinition: addDescription(function (_ref20) {
- var directives = _ref20.directives,
- operationTypes = _ref20.operationTypes;
- return join(['schema', join(directives, ' '), block(operationTypes)], ' ');
- }),
- OperationTypeDefinition: function OperationTypeDefinition(_ref21) {
- var operation = _ref21.operation,
- type = _ref21.type;
- return operation + ': ' + type;
- },
- ScalarTypeDefinition: addDescription(function (_ref22) {
- var name = _ref22.name,
- directives = _ref22.directives;
- return join(['scalar', name, join(directives, ' ')], ' ');
- }),
- ObjectTypeDefinition: addDescription(function (_ref23) {
- var name = _ref23.name,
- interfaces = _ref23.interfaces,
- directives = _ref23.directives,
- fields = _ref23.fields;
- return join(['type', name, wrap('implements ', join(interfaces, ' & ')), join(directives, ' '), block(fields)], ' ');
- }),
- FieldDefinition: addDescription(function (_ref24) {
- var name = _ref24.name,
- args = _ref24.arguments,
- type = _ref24.type,
- directives = _ref24.directives;
- return name + (hasMultilineItems(args) ? wrap('(\n', indent(join(args, '\n')), '\n)') : wrap('(', join(args, ', '), ')')) + ': ' + type + wrap(' ', join(directives, ' '));
- }),
- InputValueDefinition: addDescription(function (_ref25) {
- var name = _ref25.name,
- type = _ref25.type,
- defaultValue = _ref25.defaultValue,
- directives = _ref25.directives;
- return join([name + ': ' + type, wrap('= ', defaultValue), join(directives, ' ')], ' ');
- }),
- InterfaceTypeDefinition: addDescription(function (_ref26) {
- var name = _ref26.name,
- interfaces = _ref26.interfaces,
- directives = _ref26.directives,
- fields = _ref26.fields;
- return join(['interface', name, wrap('implements ', join(interfaces, ' & ')), join(directives, ' '), block(fields)], ' ');
- }),
- UnionTypeDefinition: addDescription(function (_ref27) {
- var name = _ref27.name,
- directives = _ref27.directives,
- types = _ref27.types;
- return join(['union', name, join(directives, ' '), types && types.length !== 0 ? '= ' + join(types, ' | ') : ''], ' ');
- }),
- EnumTypeDefinition: addDescription(function (_ref28) {
- var name = _ref28.name,
- directives = _ref28.directives,
- values = _ref28.values;
- return join(['enum', name, join(directives, ' '), block(values)], ' ');
- }),
- EnumValueDefinition: addDescription(function (_ref29) {
- var name = _ref29.name,
- directives = _ref29.directives;
- return join([name, join(directives, ' ')], ' ');
- }),
- InputObjectTypeDefinition: addDescription(function (_ref30) {
- var name = _ref30.name,
- directives = _ref30.directives,
- fields = _ref30.fields;
- return join(['input', name, join(directives, ' '), block(fields)], ' ');
- }),
- DirectiveDefinition: addDescription(function (_ref31) {
- var name = _ref31.name,
- args = _ref31.arguments,
- repeatable = _ref31.repeatable,
- locations = _ref31.locations;
- return 'directive @' + name + (hasMultilineItems(args) ? wrap('(\n', indent(join(args, '\n')), '\n)') : wrap('(', join(args, ', '), ')')) + (repeatable ? ' repeatable' : '') + ' on ' + join(locations, ' | ');
- }),
- SchemaExtension: function SchemaExtension(_ref32) {
- var directives = _ref32.directives,
- operationTypes = _ref32.operationTypes;
- return join(['extend schema', join(directives, ' '), block(operationTypes)], ' ');
- },
- ScalarTypeExtension: function ScalarTypeExtension(_ref33) {
- var name = _ref33.name,
- directives = _ref33.directives;
- return join(['extend scalar', name, join(directives, ' ')], ' ');
- },
- ObjectTypeExtension: function ObjectTypeExtension(_ref34) {
- var name = _ref34.name,
- interfaces = _ref34.interfaces,
- directives = _ref34.directives,
- fields = _ref34.fields;
- return join(['extend type', name, wrap('implements ', join(interfaces, ' & ')), join(directives, ' '), block(fields)], ' ');
- },
- InterfaceTypeExtension: function InterfaceTypeExtension(_ref35) {
- var name = _ref35.name,
- interfaces = _ref35.interfaces,
- directives = _ref35.directives,
- fields = _ref35.fields;
- return join(['extend interface', name, wrap('implements ', join(interfaces, ' & ')), join(directives, ' '), block(fields)], ' ');
- },
- UnionTypeExtension: function UnionTypeExtension(_ref36) {
- var name = _ref36.name,
- directives = _ref36.directives,
- types = _ref36.types;
- return join(['extend union', name, join(directives, ' '), types && types.length !== 0 ? '= ' + join(types, ' | ') : ''], ' ');
- },
- EnumTypeExtension: function EnumTypeExtension(_ref37) {
- var name = _ref37.name,
- directives = _ref37.directives,
- values = _ref37.values;
- return join(['extend enum', name, join(directives, ' '), block(values)], ' ');
- },
- InputObjectTypeExtension: function InputObjectTypeExtension(_ref38) {
- var name = _ref38.name,
- directives = _ref38.directives,
- fields = _ref38.fields;
- return join(['extend input', name, join(directives, ' '), block(fields)], ' ');
- }
- };
- function addDescription(cb) {
- return function (node) {
- return join([node.description, cb(node)], '\n');
- };
- }
- /**
- * Given maybeArray, print an empty string if it is null or empty, otherwise
- * print all items together separated by separator if provided
- */
- function join(maybeArray) {
- var _maybeArray$filter$jo;
- var separator = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : '';
- return (_maybeArray$filter$jo = maybeArray === null || maybeArray === void 0 ? void 0 : maybeArray.filter(function (x) {
- return x;
- }).join(separator)) !== null && _maybeArray$filter$jo !== void 0 ? _maybeArray$filter$jo : '';
- }
- /**
- * Given array, print each item on its own line, wrapped in an
- * indented "{ }" block.
- */
- function block(array) {
- return wrap('{\n', indent(join(array, '\n')), '\n}');
- }
- /**
- * If maybeString is not null or empty, then wrap with start and end, otherwise print an empty string.
- */
- function wrap(start, maybeString) {
- var end = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : '';
- return maybeString != null && maybeString !== '' ? start + maybeString + end : '';
- }
- function indent(str) {
- return wrap(' ', str.replace(/\n/g, '\n '));
- }
- function isMultiline(str) {
- return str.indexOf('\n') !== -1;
- }
- function hasMultilineItems(maybeArray) {
- return maybeArray != null && maybeArray.some(isMultiline);
- }
- /***/ }),
- /* 8 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.visit = visit;
- exports.visitInParallel = visitInParallel;
- exports.getVisitFn = getVisitFn;
- exports.BREAK = exports.QueryDocumentKeys = void 0;
- var _inspect = _interopRequireDefault(__webpack_require__(9));
- var _ast = __webpack_require__(10);
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
- var QueryDocumentKeys = {
- Name: [],
- Document: ['definitions'],
- OperationDefinition: ['name', 'variableDefinitions', 'directives', 'selectionSet'],
- VariableDefinition: ['variable', 'type', 'defaultValue', 'directives'],
- Variable: ['name'],
- SelectionSet: ['selections'],
- Field: ['alias', 'name', 'arguments', 'directives', 'selectionSet'],
- Argument: ['name', 'value'],
- FragmentSpread: ['name', 'directives'],
- InlineFragment: ['typeCondition', 'directives', 'selectionSet'],
- FragmentDefinition: ['name', // Note: fragment variable definitions are experimental and may be changed
- // or removed in the future.
- 'variableDefinitions', 'typeCondition', 'directives', 'selectionSet'],
- IntValue: [],
- FloatValue: [],
- StringValue: [],
- BooleanValue: [],
- NullValue: [],
- EnumValue: [],
- ListValue: ['values'],
- ObjectValue: ['fields'],
- ObjectField: ['name', 'value'],
- Directive: ['name', 'arguments'],
- NamedType: ['name'],
- ListType: ['type'],
- NonNullType: ['type'],
- SchemaDefinition: ['description', 'directives', 'operationTypes'],
- OperationTypeDefinition: ['type'],
- ScalarTypeDefinition: ['description', 'name', 'directives'],
- ObjectTypeDefinition: ['description', 'name', 'interfaces', 'directives', 'fields'],
- FieldDefinition: ['description', 'name', 'arguments', 'type', 'directives'],
- InputValueDefinition: ['description', 'name', 'type', 'defaultValue', 'directives'],
- InterfaceTypeDefinition: ['description', 'name', 'interfaces', 'directives', 'fields'],
- UnionTypeDefinition: ['description', 'name', 'directives', 'types'],
- EnumTypeDefinition: ['description', 'name', 'directives', 'values'],
- EnumValueDefinition: ['description', 'name', 'directives'],
- InputObjectTypeDefinition: ['description', 'name', 'directives', 'fields'],
- DirectiveDefinition: ['description', 'name', 'arguments', 'locations'],
- SchemaExtension: ['directives', 'operationTypes'],
- ScalarTypeExtension: ['name', 'directives'],
- ObjectTypeExtension: ['name', 'interfaces', 'directives', 'fields'],
- InterfaceTypeExtension: ['name', 'interfaces', 'directives', 'fields'],
- UnionTypeExtension: ['name', 'directives', 'types'],
- EnumTypeExtension: ['name', 'directives', 'values'],
- InputObjectTypeExtension: ['name', 'directives', 'fields']
- };
- exports.QueryDocumentKeys = QueryDocumentKeys;
- var BREAK = Object.freeze({});
- /**
- * visit() will walk through an AST using a depth-first traversal, calling
- * the visitor's enter function at each node in the traversal, and calling the
- * leave function after visiting that node and all of its child nodes.
- *
- * By returning different values from the enter and leave functions, the
- * behavior of the visitor can be altered, including skipping over a sub-tree of
- * the AST (by returning false), editing the AST by returning a value or null
- * to remove the value, or to stop the whole traversal by returning BREAK.
- *
- * When using visit() to edit an AST, the original AST will not be modified, and
- * a new version of the AST with the changes applied will be returned from the
- * visit function.
- *
- * const editedAST = visit(ast, {
- * enter(node, key, parent, path, ancestors) {
- * // @return
- * // undefined: no action
- * // false: skip visiting this node
- * // visitor.BREAK: stop visiting altogether
- * // null: delete this node
- * // any value: replace this node with the returned value
- * },
- * leave(node, key, parent, path, ancestors) {
- * // @return
- * // undefined: no action
- * // false: no action
- * // visitor.BREAK: stop visiting altogether
- * // null: delete this node
- * // any value: replace this node with the returned value
- * }
- * });
- *
- * Alternatively to providing enter() and leave() functions, a visitor can
- * instead provide functions named the same as the kinds of AST nodes, or
- * enter/leave visitors at a named key, leading to four permutations of the
- * visitor API:
- *
- * 1) Named visitors triggered when entering a node of a specific kind.
- *
- * visit(ast, {
- * Kind(node) {
- * // enter the "Kind" node
- * }
- * })
- *
- * 2) Named visitors that trigger upon entering and leaving a node of
- * a specific kind.
- *
- * visit(ast, {
- * Kind: {
- * enter(node) {
- * // enter the "Kind" node
- * }
- * leave(node) {
- * // leave the "Kind" node
- * }
- * }
- * })
- *
- * 3) Generic visitors that trigger upon entering and leaving any node.
- *
- * visit(ast, {
- * enter(node) {
- * // enter any node
- * },
- * leave(node) {
- * // leave any node
- * }
- * })
- *
- * 4) Parallel visitors for entering and leaving nodes of a specific kind.
- *
- * visit(ast, {
- * enter: {
- * Kind(node) {
- * // enter the "Kind" node
- * }
- * },
- * leave: {
- * Kind(node) {
- * // leave the "Kind" node
- * }
- * }
- * })
- */
- exports.BREAK = BREAK;
- function visit(root, visitor) {
- var visitorKeys = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : QueryDocumentKeys;
- /* eslint-disable no-undef-init */
- var stack = undefined;
- var inArray = Array.isArray(root);
- var keys = [root];
- var index = -1;
- var edits = [];
- var node = undefined;
- var key = undefined;
- var parent = undefined;
- var path = [];
- var ancestors = [];
- var newRoot = root;
- /* eslint-enable no-undef-init */
- do {
- index++;
- var isLeaving = index === keys.length;
- var isEdited = isLeaving && edits.length !== 0;
- if (isLeaving) {
- key = ancestors.length === 0 ? undefined : path[path.length - 1];
- node = parent;
- parent = ancestors.pop();
- if (isEdited) {
- if (inArray) {
- node = node.slice();
- } else {
- var clone = {};
- for (var _i2 = 0, _Object$keys2 = Object.keys(node); _i2 < _Object$keys2.length; _i2++) {
- var k = _Object$keys2[_i2];
- clone[k] = node[k];
- }
- node = clone;
- }
- var editOffset = 0;
- for (var ii = 0; ii < edits.length; ii++) {
- var editKey = edits[ii][0];
- var editValue = edits[ii][1];
- if (inArray) {
- editKey -= editOffset;
- }
- if (inArray && editValue === null) {
- node.splice(editKey, 1);
- editOffset++;
- } else {
- node[editKey] = editValue;
- }
- }
- }
- index = stack.index;
- keys = stack.keys;
- edits = stack.edits;
- inArray = stack.inArray;
- stack = stack.prev;
- } else {
- key = parent ? inArray ? index : keys[index] : undefined;
- node = parent ? parent[key] : newRoot;
- if (node === null || node === undefined) {
- continue;
- }
- if (parent) {
- path.push(key);
- }
- }
- var result = void 0;
- if (!Array.isArray(node)) {
- if (!(0, _ast.isNode)(node)) {
- throw new Error("Invalid AST Node: ".concat((0, _inspect.default)(node), "."));
- }
- var visitFn = getVisitFn(visitor, node.kind, isLeaving);
- if (visitFn) {
- result = visitFn.call(visitor, node, key, parent, path, ancestors);
- if (result === BREAK) {
- break;
- }
- if (result === false) {
- if (!isLeaving) {
- path.pop();
- continue;
- }
- } else if (result !== undefined) {
- edits.push([key, result]);
- if (!isLeaving) {
- if ((0, _ast.isNode)(result)) {
- node = result;
- } else {
- path.pop();
- continue;
- }
- }
- }
- }
- }
- if (result === undefined && isEdited) {
- edits.push([key, node]);
- }
- if (isLeaving) {
- path.pop();
- } else {
- var _visitorKeys$node$kin;
- stack = {
- inArray: inArray,
- index: index,
- keys: keys,
- edits: edits,
- prev: stack
- };
- inArray = Array.isArray(node);
- keys = inArray ? node : (_visitorKeys$node$kin = visitorKeys[node.kind]) !== null && _visitorKeys$node$kin !== void 0 ? _visitorKeys$node$kin : [];
- index = -1;
- edits = [];
- if (parent) {
- ancestors.push(parent);
- }
- parent = node;
- }
- } while (stack !== undefined);
- if (edits.length !== 0) {
- newRoot = edits[edits.length - 1][1];
- }
- return newRoot;
- }
- /**
- * Creates a new visitor instance which delegates to many visitors to run in
- * parallel. Each visitor will be visited for each node before moving on.
- *
- * If a prior visitor edits a node, no following visitors will see that node.
- */
- function visitInParallel(visitors) {
- var skipping = new Array(visitors.length);
- return {
- enter: function enter(node) {
- for (var i = 0; i < visitors.length; i++) {
- if (skipping[i] == null) {
- var fn = getVisitFn(visitors[i], node.kind,
- /* isLeaving */
- false);
- if (fn) {
- var result = fn.apply(visitors[i], arguments);
- if (result === false) {
- skipping[i] = node;
- } else if (result === BREAK) {
- skipping[i] = BREAK;
- } else if (result !== undefined) {
- return result;
- }
- }
- }
- }
- },
- leave: function leave(node) {
- for (var i = 0; i < visitors.length; i++) {
- if (skipping[i] == null) {
- var fn = getVisitFn(visitors[i], node.kind,
- /* isLeaving */
- true);
- if (fn) {
- var result = fn.apply(visitors[i], arguments);
- if (result === BREAK) {
- skipping[i] = BREAK;
- } else if (result !== undefined && result !== false) {
- return result;
- }
- }
- } else if (skipping[i] === node) {
- skipping[i] = null;
- }
- }
- }
- };
- }
- /**
- * Given a visitor instance, if it is leaving or not, and a node kind, return
- * the function the visitor runtime should call.
- */
- function getVisitFn(visitor, kind, isLeaving) {
- var kindVisitor = visitor[kind];
- if (kindVisitor) {
- if (!isLeaving && typeof kindVisitor === 'function') {
- // { Kind() {} }
- return kindVisitor;
- }
- var kindSpecificVisitor = isLeaving ? kindVisitor.leave : kindVisitor.enter;
- if (typeof kindSpecificVisitor === 'function') {
- // { Kind: { enter() {}, leave() {} } }
- return kindSpecificVisitor;
- }
- } else {
- var specificVisitor = isLeaving ? visitor.leave : visitor.enter;
- if (specificVisitor) {
- if (typeof specificVisitor === 'function') {
- // { enter() {}, leave() {} }
- return specificVisitor;
- }
- var specificKindVisitor = specificVisitor[kind];
- if (typeof specificKindVisitor === 'function') {
- // { enter: { Kind() {} }, leave: { Kind() {} } }
- return specificKindVisitor;
- }
- }
- }
- }
- /***/ }),
- /* 9 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.default = inspect;
- var _nodejsCustomInspectSymbol = _interopRequireDefault(__webpack_require__(1));
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
- function _typeof(obj) { "@babel/helpers - typeof"; if (typeof Symbol === "function" && typeof Symbol.iterator === "symbol") { _typeof = function _typeof(obj) { return typeof obj; }; } else { _typeof = function _typeof(obj) { return obj && typeof Symbol === "function" && obj.constructor === Symbol && obj !== Symbol.prototype ? "symbol" : typeof obj; }; } return _typeof(obj); }
- var MAX_ARRAY_LENGTH = 10;
- var MAX_RECURSIVE_DEPTH = 2;
- /**
- * Used to print values in error messages.
- */
- function inspect(value) {
- return formatValue(value, []);
- }
- function formatValue(value, seenValues) {
- switch (_typeof(value)) {
- case 'string':
- return JSON.stringify(value);
- case 'function':
- return value.name ? "[function ".concat(value.name, "]") : '[function]';
- case 'object':
- if (value === null) {
- return 'null';
- }
- return formatObjectValue(value, seenValues);
- default:
- return String(value);
- }
- }
- function formatObjectValue(value, previouslySeenValues) {
- if (previouslySeenValues.indexOf(value) !== -1) {
- return '[Circular]';
- }
- var seenValues = [].concat(previouslySeenValues, [value]);
- var customInspectFn = getCustomFn(value);
- if (customInspectFn !== undefined) {
- var customValue = customInspectFn.call(value); // check for infinite recursion
- if (customValue !== value) {
- return typeof customValue === 'string' ? customValue : formatValue(customValue, seenValues);
- }
- } else if (Array.isArray(value)) {
- return formatArray(value, seenValues);
- }
- return formatObject(value, seenValues);
- }
- function formatObject(object, seenValues) {
- var keys = Object.keys(object);
- if (keys.length === 0) {
- return '{}';
- }
- if (seenValues.length > MAX_RECURSIVE_DEPTH) {
- return '[' + getObjectTag(object) + ']';
- }
- var properties = keys.map(function (key) {
- var value = formatValue(object[key], seenValues);
- return key + ': ' + value;
- });
- return '{ ' + properties.join(', ') + ' }';
- }
- function formatArray(array, seenValues) {
- if (array.length === 0) {
- return '[]';
- }
- if (seenValues.length > MAX_RECURSIVE_DEPTH) {
- return '[Array]';
- }
- var len = Math.min(MAX_ARRAY_LENGTH, array.length);
- var remaining = array.length - len;
- var items = [];
- for (var i = 0; i < len; ++i) {
- items.push(formatValue(array[i], seenValues));
- }
- if (remaining === 1) {
- items.push('... 1 more item');
- } else if (remaining > 1) {
- items.push("... ".concat(remaining, " more items"));
- }
- return '[' + items.join(', ') + ']';
- }
- function getCustomFn(object) {
- var customInspectFn = object[String(_nodejsCustomInspectSymbol.default)];
- if (typeof customInspectFn === 'function') {
- return customInspectFn;
- }
- if (typeof object.inspect === 'function') {
- return object.inspect;
- }
- }
- function getObjectTag(object) {
- var tag = Object.prototype.toString.call(object).replace(/^\[object /, '').replace(/]$/, '');
- if (tag === 'Object' && typeof object.constructor === 'function') {
- var name = object.constructor.name;
- if (typeof name === 'string' && name !== '') {
- return name;
- }
- }
- return tag;
- }
- /***/ }),
- /* 10 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.isNode = isNode;
- exports.Token = exports.Location = void 0;
- var _defineInspect = _interopRequireDefault(__webpack_require__(11));
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
- /**
- * Contains a range of UTF-8 character offsets and token references that
- * identify the region of the source from which the AST derived.
- */
- var Location = /*#__PURE__*/function () {
- /**
- * The character offset at which this Node begins.
- */
- /**
- * The character offset at which this Node ends.
- */
- /**
- * The Token at which this Node begins.
- */
- /**
- * The Token at which this Node ends.
- */
- /**
- * The Source document the AST represents.
- */
- function Location(startToken, endToken, source) {
- this.start = startToken.start;
- this.end = endToken.end;
- this.startToken = startToken;
- this.endToken = endToken;
- this.source = source;
- }
- var _proto = Location.prototype;
- _proto.toJSON = function toJSON() {
- return {
- start: this.start,
- end: this.end
- };
- };
- return Location;
- }(); // Print a simplified form when appearing in `inspect` and `util.inspect`.
- exports.Location = Location;
- (0, _defineInspect.default)(Location);
- /**
- * Represents a range of characters represented by a lexical token
- * within a Source.
- */
- var Token = /*#__PURE__*/function () {
- /**
- * The kind of Token.
- */
- /**
- * The character offset at which this Node begins.
- */
- /**
- * The character offset at which this Node ends.
- */
- /**
- * The 1-indexed line number on which this Token appears.
- */
- /**
- * The 1-indexed column number at which this Token begins.
- */
- /**
- * For non-punctuation tokens, represents the interpreted value of the token.
- */
- /**
- * Tokens exist as nodes in a double-linked-list amongst all tokens
- * including ignored tokens. <SOF> is always the first node and <EOF>
- * the last.
- */
- function Token(kind, start, end, line, column, prev, value) {
- this.kind = kind;
- this.start = start;
- this.end = end;
- this.line = line;
- this.column = column;
- this.value = value;
- this.prev = prev;
- this.next = null;
- }
- var _proto2 = Token.prototype;
- _proto2.toJSON = function toJSON() {
- return {
- kind: this.kind,
- value: this.value,
- line: this.line,
- column: this.column
- };
- };
- return Token;
- }(); // Print a simplified form when appearing in `inspect` and `util.inspect`.
- exports.Token = Token;
- (0, _defineInspect.default)(Token);
- /**
- * @internal
- */
- function isNode(maybeNode) {
- return maybeNode != null && typeof maybeNode.kind === 'string';
- }
- /**
- * The list of all possible AST node types.
- */
- /***/ }),
- /* 11 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.default = defineInspect;
- var _invariant = _interopRequireDefault(__webpack_require__(12));
- var _nodejsCustomInspectSymbol = _interopRequireDefault(__webpack_require__(1));
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
- /**
- * The `defineInspect()` function defines `inspect()` prototype method as alias of `toJSON`
- */
- function defineInspect(classObject) {
- var fn = classObject.prototype.toJSON;
- typeof fn === 'function' || (0, _invariant.default)(0);
- classObject.prototype.inspect = fn; // istanbul ignore else (See: 'https://github.com/graphql/graphql-js/issues/2317')
- if (_nodejsCustomInspectSymbol.default) {
- classObject.prototype[_nodejsCustomInspectSymbol.default] = fn;
- }
- }
- /***/ }),
- /* 12 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.default = invariant;
- function invariant(condition, message) {
- var booleanCondition = Boolean(condition); // istanbul ignore else (See transformation done in './resources/inlineInvariant.js')
- if (!booleanCondition) {
- throw new Error(message != null ? message : 'Unexpected invariant triggered.');
- }
- }
- /***/ }),
- /* 13 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.dedentBlockStringValue = dedentBlockStringValue;
- exports.getBlockStringIndentation = getBlockStringIndentation;
- exports.printBlockString = printBlockString;
- /**
- * Produces the value of a block string from its parsed raw value, similar to
- * CoffeeScript's block string, Python's docstring trim or Ruby's strip_heredoc.
- *
- * This implements the GraphQL spec's BlockStringValue() static algorithm.
- *
- * @internal
- */
- function dedentBlockStringValue(rawString) {
- // Expand a block string's raw value into independent lines.
- var lines = rawString.split(/\r\n|[\n\r]/g); // Remove common indentation from all lines but first.
- var commonIndent = getBlockStringIndentation(rawString);
- if (commonIndent !== 0) {
- for (var i = 1; i < lines.length; i++) {
- lines[i] = lines[i].slice(commonIndent);
- }
- } // Remove leading and trailing blank lines.
- var startLine = 0;
- while (startLine < lines.length && isBlank(lines[startLine])) {
- ++startLine;
- }
- var endLine = lines.length;
- while (endLine > startLine && isBlank(lines[endLine - 1])) {
- --endLine;
- } // Return a string of the lines joined with U+000A.
- return lines.slice(startLine, endLine).join('\n');
- }
- function isBlank(str) {
- for (var i = 0; i < str.length; ++i) {
- if (str[i] !== ' ' && str[i] !== '\t') {
- return false;
- }
- }
- return true;
- }
- /**
- * @internal
- */
- function getBlockStringIndentation(value) {
- var _commonIndent;
- var isFirstLine = true;
- var isEmptyLine = true;
- var indent = 0;
- var commonIndent = null;
- for (var i = 0; i < value.length; ++i) {
- switch (value.charCodeAt(i)) {
- case 13:
- // \r
- if (value.charCodeAt(i + 1) === 10) {
- ++i; // skip \r\n as one symbol
- }
- // falls through
- case 10:
- // \n
- isFirstLine = false;
- isEmptyLine = true;
- indent = 0;
- break;
- case 9: // \t
- case 32:
- // <space>
- ++indent;
- break;
- default:
- if (isEmptyLine && !isFirstLine && (commonIndent === null || indent < commonIndent)) {
- commonIndent = indent;
- }
- isEmptyLine = false;
- }
- }
- return (_commonIndent = commonIndent) !== null && _commonIndent !== void 0 ? _commonIndent : 0;
- }
- /**
- * Print a block string in the indented block form by adding a leading and
- * trailing blank line. However, if a block string starts with whitespace and is
- * a single-line, adding a leading blank line would strip that whitespace.
- *
- * @internal
- */
- function printBlockString(value) {
- var indentation = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : '';
- var preferMultipleLines = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : false;
- var isSingleLine = value.indexOf('\n') === -1;
- var hasLeadingSpace = value[0] === ' ' || value[0] === '\t';
- var hasTrailingQuote = value[value.length - 1] === '"';
- var hasTrailingSlash = value[value.length - 1] === '\\';
- var printAsMultipleLines = !isSingleLine || hasTrailingQuote || hasTrailingSlash || preferMultipleLines;
- var result = ''; // Format a multi-line block quote to account for leading space.
- if (printAsMultipleLines && !(isSingleLine && hasLeadingSpace)) {
- result += '\n' + indentation;
- }
- result += indentation ? value.replace(/\n/g, '\n' + indentation) : value;
- if (printAsMultipleLines) {
- result += '\n';
- }
- return '"""' + result.replace(/"""/g, '\\"""') + '"""';
- }
- /***/ }),
- /* 14 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.getOperationAST = getOperationAST;
- var _kinds = __webpack_require__(15);
- /**
- * Returns an operation AST given a document AST and optionally an operation
- * name. If a name is not provided, an operation is only returned if only one is
- * provided in the document.
- */
- function getOperationAST(documentAST, operationName) {
- var operation = null;
- for (var _i2 = 0, _documentAST$definiti2 = documentAST.definitions; _i2 < _documentAST$definiti2.length; _i2++) {
- var definition = _documentAST$definiti2[_i2];
- if (definition.kind === _kinds.Kind.OPERATION_DEFINITION) {
- var _definition$name;
- if (operationName == null) {
- // If no operation name was provided, only return an Operation if there
- // is one defined in the document. Upon encountering the second, return
- // null.
- if (operation) {
- return null;
- }
- operation = definition;
- } else if (((_definition$name = definition.name) === null || _definition$name === void 0 ? void 0 : _definition$name.value) === operationName) {
- return definition;
- }
- }
- }
- return operation;
- }
- /***/ }),
- /* 15 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.Kind = void 0;
- /**
- * The set of allowed kind values for AST nodes.
- */
- var Kind = Object.freeze({
- // Name
- NAME: 'Name',
- // Document
- DOCUMENT: 'Document',
- OPERATION_DEFINITION: 'OperationDefinition',
- VARIABLE_DEFINITION: 'VariableDefinition',
- SELECTION_SET: 'SelectionSet',
- FIELD: 'Field',
- ARGUMENT: 'Argument',
- // Fragments
- FRAGMENT_SPREAD: 'FragmentSpread',
- INLINE_FRAGMENT: 'InlineFragment',
- FRAGMENT_DEFINITION: 'FragmentDefinition',
- // Values
- VARIABLE: 'Variable',
- INT: 'IntValue',
- FLOAT: 'FloatValue',
- STRING: 'StringValue',
- BOOLEAN: 'BooleanValue',
- NULL: 'NullValue',
- ENUM: 'EnumValue',
- LIST: 'ListValue',
- OBJECT: 'ObjectValue',
- OBJECT_FIELD: 'ObjectField',
- // Directives
- DIRECTIVE: 'Directive',
- // Types
- NAMED_TYPE: 'NamedType',
- LIST_TYPE: 'ListType',
- NON_NULL_TYPE: 'NonNullType',
- // Type System Definitions
- SCHEMA_DEFINITION: 'SchemaDefinition',
- OPERATION_TYPE_DEFINITION: 'OperationTypeDefinition',
- // Type Definitions
- SCALAR_TYPE_DEFINITION: 'ScalarTypeDefinition',
- OBJECT_TYPE_DEFINITION: 'ObjectTypeDefinition',
- FIELD_DEFINITION: 'FieldDefinition',
- INPUT_VALUE_DEFINITION: 'InputValueDefinition',
- INTERFACE_TYPE_DEFINITION: 'InterfaceTypeDefinition',
- UNION_TYPE_DEFINITION: 'UnionTypeDefinition',
- ENUM_TYPE_DEFINITION: 'EnumTypeDefinition',
- ENUM_VALUE_DEFINITION: 'EnumValueDefinition',
- INPUT_OBJECT_TYPE_DEFINITION: 'InputObjectTypeDefinition',
- // Directive Definitions
- DIRECTIVE_DEFINITION: 'DirectiveDefinition',
- // Type System Extensions
- SCHEMA_EXTENSION: 'SchemaExtension',
- // Type Extensions
- SCALAR_TYPE_EXTENSION: 'ScalarTypeExtension',
- OBJECT_TYPE_EXTENSION: 'ObjectTypeExtension',
- INTERFACE_TYPE_EXTENSION: 'InterfaceTypeExtension',
- UNION_TYPE_EXTENSION: 'UnionTypeExtension',
- ENUM_TYPE_EXTENSION: 'EnumTypeExtension',
- INPUT_OBJECT_TYPE_EXTENSION: 'InputObjectTypeExtension'
- });
- /**
- * The enum type representing the possible kind values of AST nodes.
- */
- exports.Kind = Kind;
- /***/ }),
- /* 16 */
- /***/ (function(module, __webpack_exports__, __webpack_require__) {
- "use strict";
- Object.defineProperty(__webpack_exports__, "__esModule", { value: true });
- /* WEBPACK VAR INJECTION */(function(global, module) {/* harmony import */ var __WEBPACK_IMPORTED_MODULE_0__ponyfill_js__ = __webpack_require__(18);
- /* global window */
- var root;
- if (typeof self !== 'undefined') {
- root = self;
- } else if (typeof window !== 'undefined') {
- root = window;
- } else if (typeof global !== 'undefined') {
- root = global;
- } else if (true) {
- root = module;
- } else {
- root = Function('return this')();
- }
- var result = Object(__WEBPACK_IMPORTED_MODULE_0__ponyfill_js__["a" /* default */])(root);
- /* harmony default export */ __webpack_exports__["default"] = (result);
- /* WEBPACK VAR INJECTION */}.call(__webpack_exports__, __webpack_require__(0), __webpack_require__(17)(module)))
- /***/ }),
- /* 17 */
- /***/ (function(module, exports) {
- module.exports = function(originalModule) {
- if(!originalModule.webpackPolyfill) {
- var module = Object.create(originalModule);
- // module.parent = undefined by default
- if(!module.children) module.children = [];
- Object.defineProperty(module, "loaded", {
- enumerable: true,
- get: function() {
- return module.l;
- }
- });
- Object.defineProperty(module, "id", {
- enumerable: true,
- get: function() {
- return module.i;
- }
- });
- Object.defineProperty(module, "exports", {
- enumerable: true,
- });
- module.webpackPolyfill = 1;
- }
- return module;
- };
- /***/ }),
- /* 18 */
- /***/ (function(module, __webpack_exports__, __webpack_require__) {
- "use strict";
- /* harmony export (immutable) */ __webpack_exports__["a"] = symbolObservablePonyfill;
- function symbolObservablePonyfill(root) {
- var result;
- var Symbol = root.Symbol;
- if (typeof Symbol === 'function') {
- if (Symbol.observable) {
- result = Symbol.observable;
- } else {
- result = Symbol('observable');
- Symbol.observable = result;
- }
- } else {
- result = '@@observable';
- }
- return result;
- };
- /***/ }),
- /* 19 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", { value: true });
- exports.GRAPHQL_SUBSCRIPTIONS = exports.GRAPHQL_WS = void 0;
- var GRAPHQL_WS = 'graphql-ws';
- exports.GRAPHQL_WS = GRAPHQL_WS;
- var GRAPHQL_SUBSCRIPTIONS = 'graphql-subscriptions';
- exports.GRAPHQL_SUBSCRIPTIONS = GRAPHQL_SUBSCRIPTIONS;
- //# sourceMappingURL=protocol.js.map
- /***/ }),
- /* 20 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", { value: true });
- exports.WS_TIMEOUT = exports.MIN_WS_TIMEOUT = void 0;
- var MIN_WS_TIMEOUT = 1000;
- exports.MIN_WS_TIMEOUT = MIN_WS_TIMEOUT;
- var WS_TIMEOUT = 30000;
- exports.WS_TIMEOUT = WS_TIMEOUT;
- //# sourceMappingURL=defaults.js.map
- /***/ }),
- /* 21 */
- /***/ (function(module, exports, __webpack_require__) {
- "use strict";
- Object.defineProperty(exports, "__esModule", { value: true });
- var MessageTypes = (function () {
- function MessageTypes() {
- throw new Error('Static Class');
- }
- MessageTypes.GQL_CONNECTION_INIT = 'connection_init';
- MessageTypes.GQL_CONNECTION_ACK = 'connection_ack';
- MessageTypes.GQL_CONNECTION_ERROR = 'connection_error';
- MessageTypes.GQL_CONNECTION_KEEP_ALIVE = 'ka';
- MessageTypes.GQL_CONNECTION_TERMINATE = 'connection_terminate';
- MessageTypes.GQL_START = 'start';
- MessageTypes.GQL_DATA = 'data';
- MessageTypes.GQL_ERROR = 'error';
- MessageTypes.GQL_COMPLETE = 'complete';
- MessageTypes.GQL_STOP = 'stop';
- MessageTypes.SUBSCRIPTION_START = 'subscription_start';
- MessageTypes.SUBSCRIPTION_DATA = 'subscription_data';
- MessageTypes.SUBSCRIPTION_SUCCESS = 'subscription_success';
- MessageTypes.SUBSCRIPTION_FAIL = 'subscription_fail';
- MessageTypes.SUBSCRIPTION_END = 'subscription_end';
- MessageTypes.INIT = 'init';
- MessageTypes.INIT_SUCCESS = 'init_success';
- MessageTypes.INIT_FAIL = 'init_fail';
- MessageTypes.KEEP_ALIVE = 'keepalive';
- return MessageTypes;
- }());
- exports.default = MessageTypes;
- //# sourceMappingURL=message-types.js.map
- /***/ })
- /******/ ]);
|