123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253 |
- 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 __spreadArray = (this && this.__spreadArray) || function (to, from) {
- for (var i = 0, il = from.length, j = to.length; i < il; i++, j++)
- to[j] = from[i];
- return to;
- };
- var __create = Object.create;
- var __defProp = Object.defineProperty;
- var __defProps = Object.defineProperties;
- var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
- var __getOwnPropDescs = Object.getOwnPropertyDescriptors;
- var __getOwnPropNames = Object.getOwnPropertyNames;
- var __getOwnPropSymbols = Object.getOwnPropertySymbols;
- var __getProtoOf = Object.getPrototypeOf;
- var __hasOwnProp = Object.prototype.hasOwnProperty;
- var __propIsEnum = Object.prototype.propertyIsEnumerable;
- var __defNormalProp = function (obj, key, value) { return key in obj ? __defProp(obj, key, { enumerable: true, configurable: true, writable: true, value: value }) : obj[key] = value; };
- var __spreadValues = function (a, b) {
- for (var prop in b || (b = {}))
- if (__hasOwnProp.call(b, prop))
- __defNormalProp(a, prop, b[prop]);
- if (__getOwnPropSymbols)
- for (var _j = 0, _k = __getOwnPropSymbols(b); _j < _k.length; _j++) {
- var prop = _k[_j];
- if (__propIsEnum.call(b, prop))
- __defNormalProp(a, prop, b[prop]);
- }
- return a;
- };
- var __spreadProps = function (a, b) { return __defProps(a, __getOwnPropDescs(b)); };
- var __markAsModule = function (target) { return __defProp(target, "__esModule", { value: true }); };
- var __objRest = function (source, exclude) {
- var target = {};
- for (var prop in source)
- if (__hasOwnProp.call(source, prop) && exclude.indexOf(prop) < 0)
- target[prop] = source[prop];
- if (source != null && __getOwnPropSymbols)
- for (var _j = 0, _k = __getOwnPropSymbols(source); _j < _k.length; _j++) {
- var prop = _k[_j];
- if (exclude.indexOf(prop) < 0 && __propIsEnum.call(source, prop))
- target[prop] = source[prop];
- }
- return target;
- };
- var __export = function (target, all) {
- for (var name in all)
- __defProp(target, name, { get: all[name], enumerable: true });
- };
- var __reExport = function (target, module2, desc) {
- if (module2 && typeof module2 === "object" || typeof module2 === "function") {
- var _loop_1 = function (key) {
- if (!__hasOwnProp.call(target, key) && key !== "default")
- __defProp(target, key, { get: function () { return module2[key]; }, enumerable: !(desc = __getOwnPropDesc(module2, key)) || desc.enumerable });
- };
- for (var _j = 0, _k = __getOwnPropNames(module2); _j < _k.length; _j++) {
- var key = _k[_j];
- _loop_1(key);
- }
- }
- return target;
- };
- var __toModule = function (module2) {
- return __reExport(__markAsModule(__defProp(module2 != null ? __create(__getProtoOf(module2)) : {}, "default", module2 && module2.__esModule && "default" in module2 ? { get: function () { return module2.default; }, enumerable: true } : { value: module2, enumerable: true })), module2);
- };
- var __async = function (__this, __arguments, generator) {
- return new Promise(function (resolve, reject) {
- var fulfilled = function (value) {
- try {
- step(generator.next(value));
- }
- catch (e) {
- reject(e);
- }
- };
- var rejected = function (value) {
- try {
- step(generator.throw(value));
- }
- catch (e) {
- reject(e);
- }
- };
- var step = function (x) { return x.done ? resolve(x.value) : Promise.resolve(x.value).then(fulfilled, rejected); };
- step((generator = generator.apply(__this, __arguments)).next());
- });
- };
- // src/query/index.ts
- __markAsModule(exports);
- __export(exports, {
- QueryStatus: function () { return QueryStatus; },
- buildCreateApi: function () { return buildCreateApi; },
- copyWithStructuralSharing: function () { return copyWithStructuralSharing; },
- coreModule: function () { return coreModule; },
- coreModuleName: function () { return coreModuleName; },
- createApi: function () { return createApi; },
- defaultSerializeQueryArgs: function () { return defaultSerializeQueryArgs; },
- fakeBaseQuery: function () { return fakeBaseQuery; },
- fetchBaseQuery: function () { return fetchBaseQuery; },
- retry: function () { return retry; },
- setupListeners: function () { return setupListeners; },
- skipSelector: function () { return skipSelector; },
- skipToken: function () { return skipToken; }
- });
- // src/query/core/apiState.ts
- var QueryStatus;
- (function (QueryStatus2) {
- QueryStatus2["uninitialized"] = "uninitialized";
- QueryStatus2["pending"] = "pending";
- QueryStatus2["fulfilled"] = "fulfilled";
- QueryStatus2["rejected"] = "rejected";
- })(QueryStatus || (QueryStatus = {}));
- function getRequestStatusFlags(status) {
- return {
- status: status,
- isUninitialized: status === QueryStatus.uninitialized,
- isLoading: status === QueryStatus.pending,
- isSuccess: status === QueryStatus.fulfilled,
- isError: status === QueryStatus.rejected
- };
- }
- // src/query/utils/isAbsoluteUrl.ts
- function isAbsoluteUrl(url) {
- return new RegExp("(^|:)//").test(url);
- }
- // src/query/utils/joinUrls.ts
- var withoutTrailingSlash = function (url) { return url.replace(/\/$/, ""); };
- var withoutLeadingSlash = function (url) { return url.replace(/^\//, ""); };
- function joinUrls(base, url) {
- if (!base) {
- return url;
- }
- if (!url) {
- return base;
- }
- if (isAbsoluteUrl(url)) {
- return url;
- }
- var delimiter = base.endsWith("/") || !url.startsWith("?") ? "/" : "";
- base = withoutTrailingSlash(base);
- url = withoutLeadingSlash(url);
- return "" + base + delimiter + url;
- }
- // src/query/utils/flatten.ts
- var flatten = function (arr) { return [].concat.apply([], arr); };
- // src/query/utils/isOnline.ts
- function isOnline() {
- return typeof navigator === "undefined" ? true : navigator.onLine === void 0 ? true : navigator.onLine;
- }
- // src/query/utils/isDocumentVisible.ts
- function isDocumentVisible() {
- if (typeof document === "undefined") {
- return true;
- }
- return document.visibilityState !== "hidden";
- }
- // src/query/utils/copyWithStructuralSharing.ts
- var import_toolkit = __toModule(require("@reduxjs/toolkit"));
- var isPlainObject = import_toolkit.isPlainObject;
- function copyWithStructuralSharing(oldObj, newObj) {
- if (oldObj === newObj || !(isPlainObject(oldObj) && isPlainObject(newObj) || Array.isArray(oldObj) && Array.isArray(newObj))) {
- return newObj;
- }
- var newKeys = Object.keys(newObj);
- var oldKeys = Object.keys(oldObj);
- var isSameObject = newKeys.length === oldKeys.length;
- var mergeObj = Array.isArray(newObj) ? [] : {};
- for (var _j = 0, newKeys_1 = newKeys; _j < newKeys_1.length; _j++) {
- var key = newKeys_1[_j];
- mergeObj[key] = copyWithStructuralSharing(oldObj[key], newObj[key]);
- if (isSameObject)
- isSameObject = oldObj[key] === mergeObj[key];
- }
- return isSameObject ? oldObj : mergeObj;
- }
- // src/query/fetchBaseQuery.ts
- var import_toolkit2 = __toModule(require("@reduxjs/toolkit"));
- var defaultFetchFn = function () {
- var args = [];
- for (var _j = 0; _j < arguments.length; _j++) {
- args[_j] = arguments[_j];
- }
- return fetch.apply(void 0, args);
- };
- var defaultValidateStatus = function (response) { return response.status >= 200 && response.status <= 299; };
- var defaultIsJsonContentType = function (headers) { return /ion\/(vnd\.api\+)?json/.test(headers.get("content-type") || ""); };
- function stripUndefined(obj) {
- if (!(0, import_toolkit2.isPlainObject)(obj)) {
- return obj;
- }
- var copy = __spreadValues({}, obj);
- for (var _j = 0, _k = Object.entries(copy); _j < _k.length; _j++) {
- var _l = _k[_j], k = _l[0], v = _l[1];
- if (v === void 0)
- delete copy[k];
- }
- return copy;
- }
- function fetchBaseQuery(_a) {
- var _this = this;
- if (_a === void 0) { _a = {}; }
- var _b = _a, baseUrl = _b.baseUrl, _j = _b.prepareHeaders, prepareHeaders = _j === void 0 ? function (x) { return x; } : _j, _k = _b.fetchFn, fetchFn = _k === void 0 ? defaultFetchFn : _k, paramsSerializer = _b.paramsSerializer, _l = _b.isJsonContentType, isJsonContentType = _l === void 0 ? defaultIsJsonContentType : _l, _m = _b.jsonContentType, jsonContentType = _m === void 0 ? "application/json" : _m, jsonReplacer = _b.jsonReplacer, defaultTimeout = _b.timeout, globalResponseHandler = _b.responseHandler, globalValidateStatus = _b.validateStatus, baseFetchOptions = __objRest(_b, [
- "baseUrl",
- "prepareHeaders",
- "fetchFn",
- "paramsSerializer",
- "isJsonContentType",
- "jsonContentType",
- "jsonReplacer",
- "timeout",
- "responseHandler",
- "validateStatus"
- ]);
- if (typeof fetch === "undefined" && fetchFn === defaultFetchFn) {
- console.warn("Warning: `fetch` is not available. Please supply a custom `fetchFn` property to use `fetchBaseQuery` on SSR environments.");
- }
- return function (arg, api) { return __async(_this, null, function () {
- var signal, getState, extra, endpoint, forced, type, meta, _a2, url, _j, headers, _k, params, _l, responseHandler, _m, validateStatus, _o, timeout, rest, config, _p, isJsonifiable, divider, query, request, requestClone, response, timedOut, timeoutId, e_1, responseClone, resultData, responseText, handleResponseError_1, e_2;
- return __generator(this, function (_q) {
- switch (_q.label) {
- case 0:
- signal = api.signal, getState = api.getState, extra = api.extra, endpoint = api.endpoint, forced = api.forced, type = api.type;
- _a2 = typeof arg == "string" ? { url: arg } : arg, url = _a2.url, _j = _a2.headers, headers = _j === void 0 ? new Headers(baseFetchOptions.headers) : _j, _k = _a2.params, params = _k === void 0 ? void 0 : _k, _l = _a2.responseHandler, responseHandler = _l === void 0 ? globalResponseHandler != null ? globalResponseHandler : "json" : _l, _m = _a2.validateStatus, validateStatus = _m === void 0 ? globalValidateStatus != null ? globalValidateStatus : defaultValidateStatus : _m, _o = _a2.timeout, timeout = _o === void 0 ? defaultTimeout : _o, rest = __objRest(_a2, [
- "url",
- "headers",
- "params",
- "responseHandler",
- "validateStatus",
- "timeout"
- ]);
- config = __spreadValues(__spreadProps(__spreadValues({}, baseFetchOptions), {
- signal: signal
- }), rest);
- headers = new Headers(stripUndefined(headers));
- _p = config;
- return [4 /*yield*/, prepareHeaders(headers, {
- getState: getState,
- extra: extra,
- endpoint: endpoint,
- forced: forced,
- type: type
- })];
- case 1:
- _p.headers = (_q.sent()) || headers;
- isJsonifiable = function (body) { return typeof body === "object" && ((0, import_toolkit2.isPlainObject)(body) || Array.isArray(body) || typeof body.toJSON === "function"); };
- if (!config.headers.has("content-type") && isJsonifiable(config.body)) {
- config.headers.set("content-type", jsonContentType);
- }
- if (isJsonifiable(config.body) && isJsonContentType(config.headers)) {
- config.body = JSON.stringify(config.body, jsonReplacer);
- }
- if (params) {
- divider = ~url.indexOf("?") ? "&" : "?";
- query = paramsSerializer ? paramsSerializer(params) : new URLSearchParams(stripUndefined(params));
- url += divider + query;
- }
- url = joinUrls(baseUrl, url);
- request = new Request(url, config);
- requestClone = new Request(url, config);
- meta = { request: requestClone };
- timedOut = false, timeoutId = timeout && setTimeout(function () {
- timedOut = true;
- api.abort();
- }, timeout);
- _q.label = 2;
- case 2:
- _q.trys.push([2, 4, 5, 6]);
- return [4 /*yield*/, fetchFn(request)];
- case 3:
- response = _q.sent();
- return [3 /*break*/, 6];
- case 4:
- e_1 = _q.sent();
- return [2 /*return*/, {
- error: {
- status: timedOut ? "TIMEOUT_ERROR" : "FETCH_ERROR",
- error: String(e_1)
- },
- meta: meta
- }];
- case 5:
- if (timeoutId)
- clearTimeout(timeoutId);
- return [7 /*endfinally*/];
- case 6:
- responseClone = response.clone();
- meta.response = responseClone;
- responseText = "";
- _q.label = 7;
- case 7:
- _q.trys.push([7, 9, , 10]);
- return [4 /*yield*/, Promise.all([
- handleResponse(response, responseHandler).then(function (r) { return resultData = r; }, function (e) { return handleResponseError_1 = e; }),
- responseClone.text().then(function (r) { return responseText = r; }, function () {
- })
- ])];
- case 8:
- _q.sent();
- if (handleResponseError_1)
- throw handleResponseError_1;
- return [3 /*break*/, 10];
- case 9:
- e_2 = _q.sent();
- return [2 /*return*/, {
- error: {
- status: "PARSING_ERROR",
- originalStatus: response.status,
- data: responseText,
- error: String(e_2)
- },
- meta: meta
- }];
- case 10: return [2 /*return*/, validateStatus(response, resultData) ? {
- data: resultData,
- meta: meta
- } : {
- error: {
- status: response.status,
- data: resultData
- },
- meta: meta
- }];
- }
- });
- }); };
- function handleResponse(response, responseHandler) {
- return __async(this, null, function () {
- var text;
- return __generator(this, function (_j) {
- switch (_j.label) {
- case 0:
- if (typeof responseHandler === "function") {
- return [2 /*return*/, responseHandler(response)];
- }
- if (responseHandler === "content-type") {
- responseHandler = isJsonContentType(response.headers) ? "json" : "text";
- }
- if (!(responseHandler === "json")) return [3 /*break*/, 2];
- return [4 /*yield*/, response.text()];
- case 1:
- text = _j.sent();
- return [2 /*return*/, text.length ? JSON.parse(text) : null];
- case 2: return [2 /*return*/, response.text()];
- }
- });
- });
- }
- }
- // src/query/HandledError.ts
- var HandledError = /** @class */ (function () {
- function HandledError(value, meta) {
- if (meta === void 0) { meta = void 0; }
- this.value = value;
- this.meta = meta;
- }
- return HandledError;
- }());
- // src/query/retry.ts
- function defaultBackoff(attempt, maxRetries) {
- if (attempt === void 0) { attempt = 0; }
- if (maxRetries === void 0) { maxRetries = 5; }
- return __async(this, null, function () {
- var attempts, timeout;
- return __generator(this, function (_j) {
- switch (_j.label) {
- case 0:
- attempts = Math.min(attempt, maxRetries);
- timeout = ~~((Math.random() + 0.4) * (300 << attempts));
- return [4 /*yield*/, new Promise(function (resolve) { return setTimeout(function (res) { return resolve(res); }, timeout); })];
- case 1:
- _j.sent();
- return [2 /*return*/];
- }
- });
- });
- }
- function fail(e) {
- throw Object.assign(new HandledError({ error: e }), {
- throwImmediately: true
- });
- }
- var EMPTY_OPTIONS = {};
- var retryWithBackoff = function (baseQuery, defaultOptions) { return function (args, api, extraOptions) { return __async(void 0, null, function () {
- var possibleMaxRetries, maxRetries, defaultRetryCondition, options, retry2, result, e_3;
- return __generator(this, function (_j) {
- switch (_j.label) {
- case 0:
- possibleMaxRetries = [
- 5,
- (defaultOptions || EMPTY_OPTIONS).maxRetries,
- (extraOptions || EMPTY_OPTIONS).maxRetries
- ].filter(function (x) { return x !== void 0; });
- maxRetries = possibleMaxRetries.slice(-1)[0];
- defaultRetryCondition = function (_, __, _j) {
- var attempt = _j.attempt;
- return attempt <= maxRetries;
- };
- options = __spreadValues(__spreadValues({
- maxRetries: maxRetries,
- backoff: defaultBackoff,
- retryCondition: defaultRetryCondition
- }, defaultOptions), extraOptions);
- retry2 = 0;
- _j.label = 1;
- case 1:
- if (!true) return [3 /*break*/, 7];
- _j.label = 2;
- case 2:
- _j.trys.push([2, 4, , 6]);
- return [4 /*yield*/, baseQuery(args, api, extraOptions)];
- case 3:
- result = _j.sent();
- if (result.error) {
- throw new HandledError(result);
- }
- return [2 /*return*/, result];
- case 4:
- e_3 = _j.sent();
- retry2++;
- if (e_3.throwImmediately) {
- if (e_3 instanceof HandledError) {
- return [2 /*return*/, e_3.value];
- }
- throw e_3;
- }
- if (e_3 instanceof HandledError && !options.retryCondition(e_3.value.error, args, {
- attempt: retry2,
- baseQueryApi: api,
- extraOptions: extraOptions
- })) {
- return [2 /*return*/, e_3.value];
- }
- return [4 /*yield*/, options.backoff(retry2, options.maxRetries)];
- case 5:
- _j.sent();
- return [3 /*break*/, 6];
- case 6: return [3 /*break*/, 1];
- case 7: return [2 /*return*/];
- }
- });
- }); }; };
- var retry = /* @__PURE__ */ Object.assign(retryWithBackoff, { fail: fail });
- // src/query/core/setupListeners.ts
- var import_toolkit3 = __toModule(require("@reduxjs/toolkit"));
- var onFocus = /* @__PURE__ */ (0, import_toolkit3.createAction)("__rtkq/focused");
- var onFocusLost = /* @__PURE__ */ (0, import_toolkit3.createAction)("__rtkq/unfocused");
- var onOnline = /* @__PURE__ */ (0, import_toolkit3.createAction)("__rtkq/online");
- var onOffline = /* @__PURE__ */ (0, import_toolkit3.createAction)("__rtkq/offline");
- var initialized = false;
- function setupListeners(dispatch, customHandler) {
- function defaultHandler() {
- var handleFocus = function () { return dispatch(onFocus()); };
- var handleFocusLost = function () { return dispatch(onFocusLost()); };
- var handleOnline = function () { return dispatch(onOnline()); };
- var handleOffline = function () { return dispatch(onOffline()); };
- var handleVisibilityChange = function () {
- if (window.document.visibilityState === "visible") {
- handleFocus();
- }
- else {
- handleFocusLost();
- }
- };
- if (!initialized) {
- if (typeof window !== "undefined" && window.addEventListener) {
- window.addEventListener("visibilitychange", handleVisibilityChange, false);
- window.addEventListener("focus", handleFocus, false);
- window.addEventListener("online", handleOnline, false);
- window.addEventListener("offline", handleOffline, false);
- initialized = true;
- }
- }
- var unsubscribe = function () {
- window.removeEventListener("focus", handleFocus);
- window.removeEventListener("visibilitychange", handleVisibilityChange);
- window.removeEventListener("online", handleOnline);
- window.removeEventListener("offline", handleOffline);
- initialized = false;
- };
- return unsubscribe;
- }
- return customHandler ? customHandler(dispatch, { onFocus: onFocus, onFocusLost: onFocusLost, onOffline: onOffline, onOnline: onOnline }) : defaultHandler();
- }
- // src/query/core/buildSelectors.ts
- var import_toolkit7 = __toModule(require("@reduxjs/toolkit"));
- // src/query/endpointDefinitions.ts
- var DefinitionType;
- (function (DefinitionType2) {
- DefinitionType2["query"] = "query";
- DefinitionType2["mutation"] = "mutation";
- })(DefinitionType || (DefinitionType = {}));
- function isQueryDefinition(e) {
- return e.type === DefinitionType.query;
- }
- function isMutationDefinition(e) {
- return e.type === DefinitionType.mutation;
- }
- function calculateProvidedBy(description, result, error, queryArg, meta, assertTagTypes) {
- if (isFunction(description)) {
- return description(result, error, queryArg, meta).map(expandTagDescription).map(assertTagTypes);
- }
- if (Array.isArray(description)) {
- return description.map(expandTagDescription).map(assertTagTypes);
- }
- return [];
- }
- function isFunction(t) {
- return typeof t === "function";
- }
- function expandTagDescription(description) {
- return typeof description === "string" ? { type: description } : description;
- }
- // src/query/core/buildSlice.ts
- var import_toolkit6 = __toModule(require("@reduxjs/toolkit"));
- // src/query/utils/isNotNullish.ts
- function isNotNullish(v) {
- return v != null;
- }
- // src/query/core/buildInitiate.ts
- var forceQueryFnSymbol = Symbol("forceQueryFn");
- var isUpsertQuery = function (arg) { return typeof arg[forceQueryFnSymbol] === "function"; };
- function buildInitiate(_j) {
- var serializeQueryArgs = _j.serializeQueryArgs, queryThunk = _j.queryThunk, mutationThunk = _j.mutationThunk, api = _j.api, context = _j.context;
- var runningQueries = new Map();
- var runningMutations = new Map();
- var _k = api.internalActions, unsubscribeQueryResult = _k.unsubscribeQueryResult, removeMutationResult = _k.removeMutationResult, updateSubscriptionOptions = _k.updateSubscriptionOptions;
- return {
- buildInitiateQuery: buildInitiateQuery,
- buildInitiateMutation: buildInitiateMutation,
- getRunningQueryThunk: getRunningQueryThunk,
- getRunningMutationThunk: getRunningMutationThunk,
- getRunningQueriesThunk: getRunningQueriesThunk,
- getRunningMutationsThunk: getRunningMutationsThunk,
- getRunningOperationPromises: getRunningOperationPromises,
- removalWarning: removalWarning
- };
- function removalWarning() {
- throw new Error("This method had to be removed due to a conceptual bug in RTK.\n Please see https://github.com/reduxjs/redux-toolkit/pull/2481 for details.\n See https://redux-toolkit.js.org/rtk-query/usage/server-side-rendering for new guidance on SSR.");
- }
- function getRunningOperationPromises() {
- if (typeof process !== "undefined" && true) {
- removalWarning();
- }
- else {
- var extract = function (v) { return Array.from(v.values()).flatMap(function (queriesForStore) { return queriesForStore ? Object.values(queriesForStore) : []; }); };
- return __spreadArray(__spreadArray([], extract(runningQueries)), extract(runningMutations)).filter(isNotNullish);
- }
- }
- function getRunningQueryThunk(endpointName, queryArgs) {
- return function (dispatch) {
- var _a;
- var endpointDefinition = context.endpointDefinitions[endpointName];
- var queryCacheKey = serializeQueryArgs({
- queryArgs: queryArgs,
- endpointDefinition: endpointDefinition,
- endpointName: endpointName
- });
- return (_a = runningQueries.get(dispatch)) == null ? void 0 : _a[queryCacheKey];
- };
- }
- function getRunningMutationThunk(_endpointName, fixedCacheKeyOrRequestId) {
- return function (dispatch) {
- var _a;
- return (_a = runningMutations.get(dispatch)) == null ? void 0 : _a[fixedCacheKeyOrRequestId];
- };
- }
- function getRunningQueriesThunk() {
- return function (dispatch) { return Object.values(runningQueries.get(dispatch) || {}).filter(isNotNullish); };
- }
- function getRunningMutationsThunk() {
- return function (dispatch) { return Object.values(runningMutations.get(dispatch) || {}).filter(isNotNullish); };
- }
- function middlewareWarning(dispatch) {
- if (true) {
- if (middlewareWarning.triggered)
- return;
- var registered = dispatch(api.internalActions.internal_probeSubscription({
- queryCacheKey: "DOES_NOT_EXIST",
- requestId: "DUMMY_REQUEST_ID"
- }));
- middlewareWarning.triggered = true;
- if (typeof registered !== "boolean") {
- throw new Error("Warning: Middleware for RTK-Query API at reducerPath \"" + api.reducerPath + "\" has not been added to the store.\nYou must add the middleware for RTK-Query to function correctly!");
- }
- }
- }
- function buildInitiateQuery(endpointName, endpointDefinition) {
- var queryAction = function (arg, _j) {
- var _k = _j === void 0 ? {} : _j, _l = _k.subscribe, subscribe = _l === void 0 ? true : _l, forceRefetch = _k.forceRefetch, subscriptionOptions = _k.subscriptionOptions, _m = forceQueryFnSymbol, forceQueryFn = _k[_m];
- return function (dispatch, getState) {
- var _j;
- var _a;
- var queryCacheKey = serializeQueryArgs({
- queryArgs: arg,
- endpointDefinition: endpointDefinition,
- endpointName: endpointName
- });
- var thunk = queryThunk((_j = {
- type: "query",
- subscribe: subscribe,
- forceRefetch: forceRefetch,
- subscriptionOptions: subscriptionOptions,
- endpointName: endpointName,
- originalArgs: arg,
- queryCacheKey: queryCacheKey
- },
- _j[forceQueryFnSymbol] = forceQueryFn,
- _j));
- var selector = api.endpoints[endpointName].select(arg);
- var thunkResult = dispatch(thunk);
- var stateAfter = selector(getState());
- middlewareWarning(dispatch);
- var requestId = thunkResult.requestId, abort = thunkResult.abort;
- var skippedSynchronously = stateAfter.requestId !== requestId;
- var runningQuery = (_a = runningQueries.get(dispatch)) == null ? void 0 : _a[queryCacheKey];
- var selectFromState = function () { return selector(getState()); };
- var statePromise = Object.assign(forceQueryFn ? thunkResult.then(selectFromState) : skippedSynchronously && !runningQuery ? Promise.resolve(stateAfter) : Promise.all([runningQuery, thunkResult]).then(selectFromState), {
- arg: arg,
- requestId: requestId,
- subscriptionOptions: subscriptionOptions,
- queryCacheKey: queryCacheKey,
- abort: abort,
- unwrap: function () {
- return __async(this, null, function () {
- var result;
- return __generator(this, function (_j) {
- switch (_j.label) {
- case 0: return [4 /*yield*/, statePromise];
- case 1:
- result = _j.sent();
- if (result.isError) {
- throw result.error;
- }
- return [2 /*return*/, result.data];
- }
- });
- });
- },
- refetch: function () { return dispatch(queryAction(arg, { subscribe: false, forceRefetch: true })); },
- unsubscribe: function () {
- if (subscribe)
- dispatch(unsubscribeQueryResult({
- queryCacheKey: queryCacheKey,
- requestId: requestId
- }));
- },
- updateSubscriptionOptions: function (options) {
- statePromise.subscriptionOptions = options;
- dispatch(updateSubscriptionOptions({
- endpointName: endpointName,
- requestId: requestId,
- queryCacheKey: queryCacheKey,
- options: options
- }));
- }
- });
- if (!runningQuery && !skippedSynchronously && !forceQueryFn) {
- var running_1 = runningQueries.get(dispatch) || {};
- running_1[queryCacheKey] = statePromise;
- runningQueries.set(dispatch, running_1);
- statePromise.then(function () {
- delete running_1[queryCacheKey];
- if (!Object.keys(running_1).length) {
- runningQueries.delete(dispatch);
- }
- });
- }
- return statePromise;
- };
- };
- return queryAction;
- }
- function buildInitiateMutation(endpointName) {
- return function (arg, _j) {
- var _k = _j === void 0 ? {} : _j, _l = _k.track, track = _l === void 0 ? true : _l, fixedCacheKey = _k.fixedCacheKey;
- return function (dispatch, getState) {
- var thunk = mutationThunk({
- type: "mutation",
- endpointName: endpointName,
- originalArgs: arg,
- track: track,
- fixedCacheKey: fixedCacheKey
- });
- var thunkResult = dispatch(thunk);
- middlewareWarning(dispatch);
- var requestId = thunkResult.requestId, abort = thunkResult.abort, unwrap = thunkResult.unwrap;
- var returnValuePromise = thunkResult.unwrap().then(function (data) { return ({ data: data }); }).catch(function (error) { return ({ error: error }); });
- var reset = function () {
- dispatch(removeMutationResult({ requestId: requestId, fixedCacheKey: fixedCacheKey }));
- };
- var ret = Object.assign(returnValuePromise, {
- arg: thunkResult.arg,
- requestId: requestId,
- abort: abort,
- unwrap: unwrap,
- unsubscribe: reset,
- reset: reset
- });
- var running = runningMutations.get(dispatch) || {};
- runningMutations.set(dispatch, running);
- running[requestId] = ret;
- ret.then(function () {
- delete running[requestId];
- if (!Object.keys(running).length) {
- runningMutations.delete(dispatch);
- }
- });
- if (fixedCacheKey) {
- running[fixedCacheKey] = ret;
- ret.then(function () {
- if (running[fixedCacheKey] === ret) {
- delete running[fixedCacheKey];
- if (!Object.keys(running).length) {
- runningMutations.delete(dispatch);
- }
- }
- });
- }
- return ret;
- };
- };
- }
- }
- // src/query/core/buildThunks.ts
- var import_toolkit4 = __toModule(require("@reduxjs/toolkit"));
- var import_immer = __toModule(require("immer"));
- var import_toolkit5 = __toModule(require("@reduxjs/toolkit"));
- function defaultTransformResponse(baseQueryReturnValue) {
- return baseQueryReturnValue;
- }
- function buildThunks(_j) {
- var _this = this;
- var reducerPath = _j.reducerPath, baseQuery = _j.baseQuery, endpointDefinitions = _j.context.endpointDefinitions, serializeQueryArgs = _j.serializeQueryArgs, api = _j.api, assertTagType = _j.assertTagType;
- var patchQueryData = function (endpointName, args, patches, updateProvided) { return function (dispatch, getState) {
- var endpointDefinition = endpointDefinitions[endpointName];
- var queryCacheKey = serializeQueryArgs({
- queryArgs: args,
- endpointDefinition: endpointDefinition,
- endpointName: endpointName
- });
- dispatch(api.internalActions.queryResultPatched({ queryCacheKey: queryCacheKey, patches: patches }));
- if (!updateProvided) {
- return;
- }
- var newValue = api.endpoints[endpointName].select(args)(getState());
- var providedTags = calculateProvidedBy(endpointDefinition.providesTags, newValue.data, void 0, args, {}, assertTagType);
- dispatch(api.internalActions.updateProvidedBy({ queryCacheKey: queryCacheKey, providedTags: providedTags }));
- }; };
- var updateQueryData = function (endpointName, args, updateRecipe, updateProvided) {
- if (updateProvided === void 0) { updateProvided = true; }
- return function (dispatch, getState) {
- var _j, _k;
- var endpointDefinition = api.endpoints[endpointName];
- var currentState = endpointDefinition.select(args)(getState());
- var ret = {
- patches: [],
- inversePatches: [],
- undo: function () { return dispatch(api.util.patchQueryData(endpointName, args, ret.inversePatches, updateProvided)); }
- };
- if (currentState.status === QueryStatus.uninitialized) {
- return ret;
- }
- var newValue;
- if ("data" in currentState) {
- if ((0, import_immer.isDraftable)(currentState.data)) {
- var _l = (0, import_immer.produceWithPatches)(currentState.data, updateRecipe), value = _l[0], patches = _l[1], inversePatches = _l[2];
- (_j = ret.patches).push.apply(_j, patches);
- (_k = ret.inversePatches).push.apply(_k, inversePatches);
- newValue = value;
- }
- else {
- newValue = updateRecipe(currentState.data);
- ret.patches.push({ op: "replace", path: [], value: newValue });
- ret.inversePatches.push({
- op: "replace",
- path: [],
- value: currentState.data
- });
- }
- }
- dispatch(api.util.patchQueryData(endpointName, args, ret.patches, updateProvided));
- return ret;
- };
- };
- var upsertQueryData = function (endpointName, args, value) { return function (dispatch) {
- var _j;
- return dispatch(api.endpoints[endpointName].initiate(args, (_j = {
- subscribe: false,
- forceRefetch: true
- },
- _j[forceQueryFnSymbol] = function () { return ({
- data: value
- }); },
- _j)));
- }; };
- var executeEndpoint = function (_0, _1) { return __async(_this, [_0, _1], function (arg, _j) {
- var endpointDefinition, transformResponse, result, baseQueryApi_1, forceQueryFn, what, err, _k, _l, key, _m, error_1, catchedError, transformErrorResponse, _o, e_4;
- var _p, _q;
- var signal = _j.signal, abort = _j.abort, rejectWithValue = _j.rejectWithValue, fulfillWithValue = _j.fulfillWithValue, dispatch = _j.dispatch, getState = _j.getState, extra = _j.extra;
- return __generator(this, function (_r) {
- switch (_r.label) {
- case 0:
- endpointDefinition = endpointDefinitions[arg.endpointName];
- _r.label = 1;
- case 1:
- _r.trys.push([1, 8, , 13]);
- transformResponse = defaultTransformResponse;
- result = void 0;
- baseQueryApi_1 = {
- signal: signal,
- abort: abort,
- dispatch: dispatch,
- getState: getState,
- extra: extra,
- endpoint: arg.endpointName,
- type: arg.type,
- forced: arg.type === "query" ? isForcedQuery(arg, getState()) : void 0
- };
- forceQueryFn = arg.type === "query" ? arg[forceQueryFnSymbol] : void 0;
- if (!forceQueryFn) return [3 /*break*/, 2];
- result = forceQueryFn();
- return [3 /*break*/, 6];
- case 2:
- if (!endpointDefinition.query) return [3 /*break*/, 4];
- return [4 /*yield*/, baseQuery(endpointDefinition.query(arg.originalArgs), baseQueryApi_1, endpointDefinition.extraOptions)];
- case 3:
- result = _r.sent();
- if (endpointDefinition.transformResponse) {
- transformResponse = endpointDefinition.transformResponse;
- }
- return [3 /*break*/, 6];
- case 4: return [4 /*yield*/, endpointDefinition.queryFn(arg.originalArgs, baseQueryApi_1, endpointDefinition.extraOptions, function (arg2) { return baseQuery(arg2, baseQueryApi_1, endpointDefinition.extraOptions); })];
- case 5:
- result = _r.sent();
- _r.label = 6;
- case 6:
- if (typeof process !== "undefined" && true) {
- what = endpointDefinition.query ? "`baseQuery`" : "`queryFn`";
- err = void 0;
- if (!result) {
- err = what + " did not return anything.";
- }
- else if (typeof result !== "object") {
- err = what + " did not return an object.";
- }
- else if (result.error && result.data) {
- err = what + " returned an object containing both `error` and `result`.";
- }
- else if (result.error === void 0 && result.data === void 0) {
- err = what + " returned an object containing neither a valid `error` and `result`. At least one of them should not be `undefined`";
- }
- else {
- for (_k = 0, _l = Object.keys(result); _k < _l.length; _k++) {
- key = _l[_k];
- if (key !== "error" && key !== "data" && key !== "meta") {
- err = "The object returned by " + what + " has the unknown property " + key + ".";
- break;
- }
- }
- }
- if (err) {
- console.error("Error encountered handling the endpoint " + arg.endpointName + ".\n " + err + "\n It needs to return an object with either the shape `{ data: <value> }` or `{ error: <value> }` that may contain an optional `meta` property.\n Object returned was:", result);
- }
- }
- if (result.error)
- throw new HandledError(result.error, result.meta);
- _m = fulfillWithValue;
- return [4 /*yield*/, transformResponse(result.data, result.meta, arg.originalArgs)];
- case 7: return [2 /*return*/, _m.apply(void 0, [_r.sent(), (_p = {
- fulfilledTimeStamp: Date.now(),
- baseQueryMeta: result.meta
- },
- _p[import_toolkit5.SHOULD_AUTOBATCH] = true,
- _p)])];
- case 8:
- error_1 = _r.sent();
- catchedError = error_1;
- if (!(catchedError instanceof HandledError)) return [3 /*break*/, 12];
- transformErrorResponse = defaultTransformResponse;
- if (endpointDefinition.query && endpointDefinition.transformErrorResponse) {
- transformErrorResponse = endpointDefinition.transformErrorResponse;
- }
- _r.label = 9;
- case 9:
- _r.trys.push([9, 11, , 12]);
- _o = rejectWithValue;
- return [4 /*yield*/, transformErrorResponse(catchedError.value, catchedError.meta, arg.originalArgs)];
- case 10: return [2 /*return*/, _o.apply(void 0, [_r.sent(), (_q = { baseQueryMeta: catchedError.meta }, _q[import_toolkit5.SHOULD_AUTOBATCH] = true, _q)])];
- case 11:
- e_4 = _r.sent();
- catchedError = e_4;
- return [3 /*break*/, 12];
- case 12:
- if (typeof process !== "undefined" && true) {
- console.error("An unhandled error occurred processing a request for the endpoint \"" + arg.endpointName + "\".\nIn the case of an unhandled error, no tags will be \"provided\" or \"invalidated\".", catchedError);
- }
- else {
- console.error(catchedError);
- }
- throw catchedError;
- case 13: return [2 /*return*/];
- }
- });
- }); };
- function isForcedQuery(arg, state) {
- var _a, _b, _c, _d;
- var requestState = (_b = (_a = state[reducerPath]) == null ? void 0 : _a.queries) == null ? void 0 : _b[arg.queryCacheKey];
- var baseFetchOnMountOrArgChange = (_c = state[reducerPath]) == null ? void 0 : _c.config.refetchOnMountOrArgChange;
- var fulfilledVal = requestState == null ? void 0 : requestState.fulfilledTimeStamp;
- var refetchVal = (_d = arg.forceRefetch) != null ? _d : arg.subscribe && baseFetchOnMountOrArgChange;
- if (refetchVal) {
- return refetchVal === true || (Number(new Date()) - Number(fulfilledVal)) / 1e3 >= refetchVal;
- }
- return false;
- }
- var queryThunk = (0, import_toolkit5.createAsyncThunk)(reducerPath + "/executeQuery", executeEndpoint, {
- getPendingMeta: function () {
- var _j;
- return _j = { startedTimeStamp: Date.now() }, _j[import_toolkit5.SHOULD_AUTOBATCH] = true, _j;
- },
- condition: function (queryThunkArgs, _j) {
- var getState = _j.getState;
- var _a, _b, _c;
- var state = getState();
- var requestState = (_b = (_a = state[reducerPath]) == null ? void 0 : _a.queries) == null ? void 0 : _b[queryThunkArgs.queryCacheKey];
- var fulfilledVal = requestState == null ? void 0 : requestState.fulfilledTimeStamp;
- var currentArg = queryThunkArgs.originalArgs;
- var previousArg = requestState == null ? void 0 : requestState.originalArgs;
- var endpointDefinition = endpointDefinitions[queryThunkArgs.endpointName];
- if (isUpsertQuery(queryThunkArgs)) {
- return true;
- }
- if ((requestState == null ? void 0 : requestState.status) === "pending") {
- return false;
- }
- if (isForcedQuery(queryThunkArgs, state)) {
- return true;
- }
- if (isQueryDefinition(endpointDefinition) && ((_c = endpointDefinition == null ? void 0 : endpointDefinition.forceRefetch) == null ? void 0 : _c.call(endpointDefinition, {
- currentArg: currentArg,
- previousArg: previousArg,
- endpointState: requestState,
- state: state
- }))) {
- return true;
- }
- if (fulfilledVal) {
- return false;
- }
- return true;
- },
- dispatchConditionRejection: true
- });
- var mutationThunk = (0, import_toolkit5.createAsyncThunk)(reducerPath + "/executeMutation", executeEndpoint, {
- getPendingMeta: function () {
- var _j;
- return _j = { startedTimeStamp: Date.now() }, _j[import_toolkit5.SHOULD_AUTOBATCH] = true, _j;
- }
- });
- var hasTheForce = function (options) { return "force" in options; };
- var hasMaxAge = function (options) { return "ifOlderThan" in options; };
- var prefetch = function (endpointName, arg, options) { return function (dispatch, getState) {
- var force = hasTheForce(options) && options.force;
- var maxAge = hasMaxAge(options) && options.ifOlderThan;
- var queryAction = function (force2) {
- if (force2 === void 0) { force2 = true; }
- return api.endpoints[endpointName].initiate(arg, { forceRefetch: force2 });
- };
- var latestStateValue = api.endpoints[endpointName].select(arg)(getState());
- if (force) {
- dispatch(queryAction());
- }
- else if (maxAge) {
- var lastFulfilledTs = latestStateValue == null ? void 0 : latestStateValue.fulfilledTimeStamp;
- if (!lastFulfilledTs) {
- dispatch(queryAction());
- return;
- }
- var shouldRetrigger = (Number(new Date()) - Number(new Date(lastFulfilledTs))) / 1e3 >= maxAge;
- if (shouldRetrigger) {
- dispatch(queryAction());
- }
- }
- else {
- dispatch(queryAction(false));
- }
- }; };
- function matchesEndpoint(endpointName) {
- return function (action) {
- var _a, _b;
- return ((_b = (_a = action == null ? void 0 : action.meta) == null ? void 0 : _a.arg) == null ? void 0 : _b.endpointName) === endpointName;
- };
- }
- function buildMatchThunkActions(thunk, endpointName) {
- return {
- matchPending: (0, import_toolkit4.isAllOf)((0, import_toolkit4.isPending)(thunk), matchesEndpoint(endpointName)),
- matchFulfilled: (0, import_toolkit4.isAllOf)((0, import_toolkit4.isFulfilled)(thunk), matchesEndpoint(endpointName)),
- matchRejected: (0, import_toolkit4.isAllOf)((0, import_toolkit4.isRejected)(thunk), matchesEndpoint(endpointName))
- };
- }
- return {
- queryThunk: queryThunk,
- mutationThunk: mutationThunk,
- prefetch: prefetch,
- updateQueryData: updateQueryData,
- upsertQueryData: upsertQueryData,
- patchQueryData: patchQueryData,
- buildMatchThunkActions: buildMatchThunkActions
- };
- }
- function calculateProvidedByThunk(action, type, endpointDefinitions, assertTagType) {
- return calculateProvidedBy(endpointDefinitions[action.meta.arg.endpointName][type], (0, import_toolkit4.isFulfilled)(action) ? action.payload : void 0, (0, import_toolkit4.isRejectedWithValue)(action) ? action.payload : void 0, action.meta.arg.originalArgs, "baseQueryMeta" in action.meta ? action.meta.baseQueryMeta : void 0, assertTagType);
- }
- // src/query/core/buildSlice.ts
- var import_immer2 = __toModule(require("immer"));
- var import_immer3 = __toModule(require("immer"));
- function updateQuerySubstateIfExists(state, queryCacheKey, update) {
- var substate = state[queryCacheKey];
- if (substate) {
- update(substate);
- }
- }
- function getMutationCacheKey(id) {
- var _a;
- return (_a = "arg" in id ? id.arg.fixedCacheKey : id.fixedCacheKey) != null ? _a : id.requestId;
- }
- function updateMutationSubstateIfExists(state, id, update) {
- var substate = state[getMutationCacheKey(id)];
- if (substate) {
- update(substate);
- }
- }
- var initialState = {};
- function buildSlice(_j) {
- var reducerPath = _j.reducerPath, queryThunk = _j.queryThunk, mutationThunk = _j.mutationThunk, _k = _j.context, definitions = _k.endpointDefinitions, apiUid = _k.apiUid, extractRehydrationInfo = _k.extractRehydrationInfo, hasRehydrationInfo = _k.hasRehydrationInfo, assertTagType = _j.assertTagType, config = _j.config;
- var resetApiState = (0, import_toolkit6.createAction)(reducerPath + "/resetApiState");
- var querySlice = (0, import_toolkit6.createSlice)({
- name: reducerPath + "/queries",
- initialState: initialState,
- reducers: {
- removeQueryResult: {
- reducer: function (draft, _j) {
- var queryCacheKey = _j.payload.queryCacheKey;
- delete draft[queryCacheKey];
- },
- prepare: (0, import_toolkit6.prepareAutoBatched)()
- },
- queryResultPatched: {
- reducer: function (draft, _j) {
- var _k = _j.payload, queryCacheKey = _k.queryCacheKey, patches = _k.patches;
- updateQuerySubstateIfExists(draft, queryCacheKey, function (substate) {
- substate.data = (0, import_immer3.applyPatches)(substate.data, patches.concat());
- });
- },
- prepare: (0, import_toolkit6.prepareAutoBatched)()
- }
- },
- extraReducers: function (builder) {
- builder.addCase(queryThunk.pending, function (draft, _j) {
- var meta = _j.meta, arg = _j.meta.arg;
- var _a, _b;
- var upserting = isUpsertQuery(arg);
- if (arg.subscribe || upserting) {
- (_b = draft[_a = arg.queryCacheKey]) != null ? _b : draft[_a] = {
- status: QueryStatus.uninitialized,
- endpointName: arg.endpointName
- };
- }
- updateQuerySubstateIfExists(draft, arg.queryCacheKey, function (substate) {
- substate.status = QueryStatus.pending;
- substate.requestId = upserting && substate.requestId ? substate.requestId : meta.requestId;
- if (arg.originalArgs !== void 0) {
- substate.originalArgs = arg.originalArgs;
- }
- substate.startedTimeStamp = meta.startedTimeStamp;
- });
- }).addCase(queryThunk.fulfilled, function (draft, _j) {
- var meta = _j.meta, payload = _j.payload;
- updateQuerySubstateIfExists(draft, meta.arg.queryCacheKey, function (substate) {
- var _a;
- if (substate.requestId !== meta.requestId && !isUpsertQuery(meta.arg))
- return;
- var merge = definitions[meta.arg.endpointName].merge;
- substate.status = QueryStatus.fulfilled;
- if (merge) {
- if (substate.data !== void 0) {
- var fulfilledTimeStamp_1 = meta.fulfilledTimeStamp, arg_1 = meta.arg, baseQueryMeta_1 = meta.baseQueryMeta, requestId_1 = meta.requestId;
- var newData = (0, import_toolkit6.createNextState)(substate.data, function (draftSubstateData) {
- return merge(draftSubstateData, payload, {
- arg: arg_1.originalArgs,
- baseQueryMeta: baseQueryMeta_1,
- fulfilledTimeStamp: fulfilledTimeStamp_1,
- requestId: requestId_1
- });
- });
- substate.data = newData;
- }
- else {
- substate.data = payload;
- }
- }
- else {
- substate.data = ((_a = definitions[meta.arg.endpointName].structuralSharing) != null ? _a : true) ? copyWithStructuralSharing((0, import_immer2.isDraft)(substate.data) ? (0, import_immer3.original)(substate.data) : substate.data, payload) : payload;
- }
- delete substate.error;
- substate.fulfilledTimeStamp = meta.fulfilledTimeStamp;
- });
- }).addCase(queryThunk.rejected, function (draft, _j) {
- var _k = _j.meta, condition = _k.condition, arg = _k.arg, requestId = _k.requestId, error = _j.error, payload = _j.payload;
- updateQuerySubstateIfExists(draft, arg.queryCacheKey, function (substate) {
- if (condition) {
- }
- else {
- if (substate.requestId !== requestId)
- return;
- substate.status = QueryStatus.rejected;
- substate.error = payload != null ? payload : error;
- }
- });
- }).addMatcher(hasRehydrationInfo, function (draft, action) {
- var queries = extractRehydrationInfo(action).queries;
- for (var _j = 0, _k = Object.entries(queries); _j < _k.length; _j++) {
- var _l = _k[_j], key = _l[0], entry = _l[1];
- if ((entry == null ? void 0 : entry.status) === QueryStatus.fulfilled || (entry == null ? void 0 : entry.status) === QueryStatus.rejected) {
- draft[key] = entry;
- }
- }
- });
- }
- });
- var mutationSlice = (0, import_toolkit6.createSlice)({
- name: reducerPath + "/mutations",
- initialState: initialState,
- reducers: {
- removeMutationResult: {
- reducer: function (draft, _j) {
- var payload = _j.payload;
- var cacheKey = getMutationCacheKey(payload);
- if (cacheKey in draft) {
- delete draft[cacheKey];
- }
- },
- prepare: (0, import_toolkit6.prepareAutoBatched)()
- }
- },
- extraReducers: function (builder) {
- builder.addCase(mutationThunk.pending, function (draft, _j) {
- var meta = _j.meta, _k = _j.meta, requestId = _k.requestId, arg = _k.arg, startedTimeStamp = _k.startedTimeStamp;
- if (!arg.track)
- return;
- draft[getMutationCacheKey(meta)] = {
- requestId: requestId,
- status: QueryStatus.pending,
- endpointName: arg.endpointName,
- startedTimeStamp: startedTimeStamp
- };
- }).addCase(mutationThunk.fulfilled, function (draft, _j) {
- var payload = _j.payload, meta = _j.meta;
- if (!meta.arg.track)
- return;
- updateMutationSubstateIfExists(draft, meta, function (substate) {
- if (substate.requestId !== meta.requestId)
- return;
- substate.status = QueryStatus.fulfilled;
- substate.data = payload;
- substate.fulfilledTimeStamp = meta.fulfilledTimeStamp;
- });
- }).addCase(mutationThunk.rejected, function (draft, _j) {
- var payload = _j.payload, error = _j.error, meta = _j.meta;
- if (!meta.arg.track)
- return;
- updateMutationSubstateIfExists(draft, meta, function (substate) {
- if (substate.requestId !== meta.requestId)
- return;
- substate.status = QueryStatus.rejected;
- substate.error = payload != null ? payload : error;
- });
- }).addMatcher(hasRehydrationInfo, function (draft, action) {
- var mutations = extractRehydrationInfo(action).mutations;
- for (var _j = 0, _k = Object.entries(mutations); _j < _k.length; _j++) {
- var _l = _k[_j], key = _l[0], entry = _l[1];
- if (((entry == null ? void 0 : entry.status) === QueryStatus.fulfilled || (entry == null ? void 0 : entry.status) === QueryStatus.rejected) && key !== (entry == null ? void 0 : entry.requestId)) {
- draft[key] = entry;
- }
- }
- });
- }
- });
- var invalidationSlice = (0, import_toolkit6.createSlice)({
- name: reducerPath + "/invalidation",
- initialState: initialState,
- reducers: {
- updateProvidedBy: {
- reducer: function (draft, action) {
- var _a, _b, _c, _d;
- var _j = action.payload, queryCacheKey = _j.queryCacheKey, providedTags = _j.providedTags;
- for (var _k = 0, _l = Object.values(draft); _k < _l.length; _k++) {
- var tagTypeSubscriptions = _l[_k];
- for (var _m = 0, _o = Object.values(tagTypeSubscriptions); _m < _o.length; _m++) {
- var idSubscriptions = _o[_m];
- var foundAt = idSubscriptions.indexOf(queryCacheKey);
- if (foundAt !== -1) {
- idSubscriptions.splice(foundAt, 1);
- }
- }
- }
- for (var _p = 0, providedTags_1 = providedTags; _p < providedTags_1.length; _p++) {
- var _q = providedTags_1[_p], type = _q.type, id = _q.id;
- var subscribedQueries = (_d = (_b = (_a = draft[type]) != null ? _a : draft[type] = {})[_c = id || "__internal_without_id"]) != null ? _d : _b[_c] = [];
- var alreadySubscribed = subscribedQueries.includes(queryCacheKey);
- if (!alreadySubscribed) {
- subscribedQueries.push(queryCacheKey);
- }
- }
- },
- prepare: (0, import_toolkit6.prepareAutoBatched)()
- }
- },
- extraReducers: function (builder) {
- builder.addCase(querySlice.actions.removeQueryResult, function (draft, _j) {
- var queryCacheKey = _j.payload.queryCacheKey;
- for (var _k = 0, _l = Object.values(draft); _k < _l.length; _k++) {
- var tagTypeSubscriptions = _l[_k];
- for (var _m = 0, _o = Object.values(tagTypeSubscriptions); _m < _o.length; _m++) {
- var idSubscriptions = _o[_m];
- var foundAt = idSubscriptions.indexOf(queryCacheKey);
- if (foundAt !== -1) {
- idSubscriptions.splice(foundAt, 1);
- }
- }
- }
- }).addMatcher(hasRehydrationInfo, function (draft, action) {
- var _a, _b, _c, _d;
- var provided = extractRehydrationInfo(action).provided;
- for (var _j = 0, _k = Object.entries(provided); _j < _k.length; _j++) {
- var _l = _k[_j], type = _l[0], incomingTags = _l[1];
- for (var _m = 0, _o = Object.entries(incomingTags); _m < _o.length; _m++) {
- var _p = _o[_m], id = _p[0], cacheKeys = _p[1];
- var subscribedQueries = (_d = (_b = (_a = draft[type]) != null ? _a : draft[type] = {})[_c = id || "__internal_without_id"]) != null ? _d : _b[_c] = [];
- for (var _q = 0, cacheKeys_1 = cacheKeys; _q < cacheKeys_1.length; _q++) {
- var queryCacheKey = cacheKeys_1[_q];
- var alreadySubscribed = subscribedQueries.includes(queryCacheKey);
- if (!alreadySubscribed) {
- subscribedQueries.push(queryCacheKey);
- }
- }
- }
- }
- }).addMatcher((0, import_toolkit6.isAnyOf)((0, import_toolkit6.isFulfilled)(queryThunk), (0, import_toolkit6.isRejectedWithValue)(queryThunk)), function (draft, action) {
- var providedTags = calculateProvidedByThunk(action, "providesTags", definitions, assertTagType);
- var queryCacheKey = action.meta.arg.queryCacheKey;
- invalidationSlice.caseReducers.updateProvidedBy(draft, invalidationSlice.actions.updateProvidedBy({
- queryCacheKey: queryCacheKey,
- providedTags: providedTags
- }));
- });
- }
- });
- var subscriptionSlice = (0, import_toolkit6.createSlice)({
- name: reducerPath + "/subscriptions",
- initialState: initialState,
- reducers: {
- updateSubscriptionOptions: function (d, a) {
- },
- unsubscribeQueryResult: function (d, a) {
- },
- internal_probeSubscription: function (d, a) {
- }
- }
- });
- var internalSubscriptionsSlice = (0, import_toolkit6.createSlice)({
- name: reducerPath + "/internalSubscriptions",
- initialState: initialState,
- reducers: {
- subscriptionsUpdated: {
- reducer: function (state, action) {
- return (0, import_immer3.applyPatches)(state, action.payload);
- },
- prepare: (0, import_toolkit6.prepareAutoBatched)()
- }
- }
- });
- var configSlice = (0, import_toolkit6.createSlice)({
- name: reducerPath + "/config",
- initialState: __spreadValues({
- online: isOnline(),
- focused: isDocumentVisible(),
- middlewareRegistered: false
- }, config),
- reducers: {
- middlewareRegistered: function (state, _j) {
- var payload = _j.payload;
- state.middlewareRegistered = state.middlewareRegistered === "conflict" || apiUid !== payload ? "conflict" : true;
- }
- },
- extraReducers: function (builder) {
- builder.addCase(onOnline, function (state) {
- state.online = true;
- }).addCase(onOffline, function (state) {
- state.online = false;
- }).addCase(onFocus, function (state) {
- state.focused = true;
- }).addCase(onFocusLost, function (state) {
- state.focused = false;
- }).addMatcher(hasRehydrationInfo, function (draft) { return __spreadValues({}, draft); });
- }
- });
- var combinedReducer = (0, import_toolkit6.combineReducers)({
- queries: querySlice.reducer,
- mutations: mutationSlice.reducer,
- provided: invalidationSlice.reducer,
- subscriptions: internalSubscriptionsSlice.reducer,
- config: configSlice.reducer
- });
- var reducer = function (state, action) { return combinedReducer(resetApiState.match(action) ? void 0 : state, action); };
- var actions = __spreadProps(__spreadValues(__spreadValues(__spreadValues(__spreadValues(__spreadValues(__spreadValues({}, configSlice.actions), querySlice.actions), subscriptionSlice.actions), internalSubscriptionsSlice.actions), mutationSlice.actions), invalidationSlice.actions), {
- unsubscribeMutationResult: mutationSlice.actions.removeMutationResult,
- resetApiState: resetApiState
- });
- return { reducer: reducer, actions: actions };
- }
- // src/query/core/buildSelectors.ts
- var skipToken = /* @__PURE__ */ Symbol.for("RTKQ/skipToken");
- var skipSelector = skipToken;
- var initialSubState = {
- status: QueryStatus.uninitialized
- };
- var defaultQuerySubState = /* @__PURE__ */ (0, import_toolkit7.createNextState)(initialSubState, function () {
- });
- var defaultMutationSubState = /* @__PURE__ */ (0, import_toolkit7.createNextState)(initialSubState, function () {
- });
- function buildSelectors(_j) {
- var serializeQueryArgs = _j.serializeQueryArgs, reducerPath = _j.reducerPath;
- var selectSkippedQuery = function (state) { return defaultQuerySubState; };
- var selectSkippedMutation = function (state) { return defaultMutationSubState; };
- return { buildQuerySelector: buildQuerySelector, buildMutationSelector: buildMutationSelector, selectInvalidatedBy: selectInvalidatedBy };
- function withRequestFlags(substate) {
- return __spreadValues(__spreadValues({}, substate), getRequestStatusFlags(substate.status));
- }
- function selectInternalState(rootState) {
- var state = rootState[reducerPath];
- if (true) {
- if (!state) {
- if (selectInternalState.triggered)
- return state;
- selectInternalState.triggered = true;
- console.error("Error: No data found at `state." + reducerPath + "`. Did you forget to add the reducer to the store?");
- }
- }
- return state;
- }
- function buildQuerySelector(endpointName, endpointDefinition) {
- return function (queryArgs) {
- var serializedArgs = serializeQueryArgs({
- queryArgs: queryArgs,
- endpointDefinition: endpointDefinition,
- endpointName: endpointName
- });
- var selectQuerySubstate = function (state) {
- var _a, _b, _c;
- return (_c = (_b = (_a = selectInternalState(state)) == null ? void 0 : _a.queries) == null ? void 0 : _b[serializedArgs]) != null ? _c : defaultQuerySubState;
- };
- var finalSelectQuerySubState = queryArgs === skipToken ? selectSkippedQuery : selectQuerySubstate;
- return (0, import_toolkit7.createSelector)(finalSelectQuerySubState, withRequestFlags);
- };
- }
- function buildMutationSelector() {
- return function (id) {
- var _a;
- var mutationId;
- if (typeof id === "object") {
- mutationId = (_a = getMutationCacheKey(id)) != null ? _a : skipToken;
- }
- else {
- mutationId = id;
- }
- var selectMutationSubstate = function (state) {
- var _a2, _b, _c;
- return (_c = (_b = (_a2 = selectInternalState(state)) == null ? void 0 : _a2.mutations) == null ? void 0 : _b[mutationId]) != null ? _c : defaultMutationSubState;
- };
- var finalSelectMutationSubstate = mutationId === skipToken ? selectSkippedMutation : selectMutationSubstate;
- return (0, import_toolkit7.createSelector)(finalSelectMutationSubstate, withRequestFlags);
- };
- }
- function selectInvalidatedBy(state, tags) {
- var _a;
- var apiState = state[reducerPath];
- var toInvalidate = new Set();
- for (var _j = 0, _k = tags.map(expandTagDescription); _j < _k.length; _j++) {
- var tag = _k[_j];
- var provided = apiState.provided[tag.type];
- if (!provided) {
- continue;
- }
- var invalidateSubscriptions = (_a = tag.id !== void 0 ? provided[tag.id] : flatten(Object.values(provided))) != null ? _a : [];
- for (var _l = 0, invalidateSubscriptions_1 = invalidateSubscriptions; _l < invalidateSubscriptions_1.length; _l++) {
- var invalidate = invalidateSubscriptions_1[_l];
- toInvalidate.add(invalidate);
- }
- }
- return flatten(Array.from(toInvalidate.values()).map(function (queryCacheKey) {
- var querySubState = apiState.queries[queryCacheKey];
- return querySubState ? [
- {
- queryCacheKey: queryCacheKey,
- endpointName: querySubState.endpointName,
- originalArgs: querySubState.originalArgs
- }
- ] : [];
- }));
- }
- }
- // src/query/defaultSerializeQueryArgs.ts
- var import_toolkit8 = __toModule(require("@reduxjs/toolkit"));
- var cache = WeakMap ? new WeakMap() : void 0;
- var defaultSerializeQueryArgs = function (_j) {
- var endpointName = _j.endpointName, queryArgs = _j.queryArgs;
- var serialized = "";
- var cached = cache == null ? void 0 : cache.get(queryArgs);
- if (typeof cached === "string") {
- serialized = cached;
- }
- else {
- var stringified = JSON.stringify(queryArgs, function (key, value) { return (0, import_toolkit8.isPlainObject)(value) ? Object.keys(value).sort().reduce(function (acc, key2) {
- acc[key2] = value[key2];
- return acc;
- }, {}) : value; });
- if ((0, import_toolkit8.isPlainObject)(queryArgs)) {
- cache == null ? void 0 : cache.set(queryArgs, stringified);
- }
- serialized = stringified;
- }
- return endpointName + "(" + serialized + ")";
- };
- // src/query/createApi.ts
- var import_toolkit9 = __toModule(require("@reduxjs/toolkit"));
- var import_reselect = __toModule(require("reselect"));
- function buildCreateApi() {
- var modules = [];
- for (var _j = 0; _j < arguments.length; _j++) {
- modules[_j] = arguments[_j];
- }
- return function baseCreateApi(options) {
- var extractRehydrationInfo = (0, import_reselect.defaultMemoize)(function (action) {
- var _a, _b;
- return (_b = options.extractRehydrationInfo) == null ? void 0 : _b.call(options, action, {
- reducerPath: (_a = options.reducerPath) != null ? _a : "api"
- });
- });
- var optionsWithDefaults = __spreadProps(__spreadValues({
- reducerPath: "api",
- keepUnusedDataFor: 60,
- refetchOnMountOrArgChange: false,
- refetchOnFocus: false,
- refetchOnReconnect: false
- }, options), {
- extractRehydrationInfo: extractRehydrationInfo,
- serializeQueryArgs: function (queryArgsApi) {
- var finalSerializeQueryArgs = defaultSerializeQueryArgs;
- if ("serializeQueryArgs" in queryArgsApi.endpointDefinition) {
- var endpointSQA_1 = queryArgsApi.endpointDefinition.serializeQueryArgs;
- finalSerializeQueryArgs = function (queryArgsApi2) {
- var initialResult = endpointSQA_1(queryArgsApi2);
- if (typeof initialResult === "string") {
- return initialResult;
- }
- else {
- return defaultSerializeQueryArgs(__spreadProps(__spreadValues({}, queryArgsApi2), {
- queryArgs: initialResult
- }));
- }
- };
- }
- else if (options.serializeQueryArgs) {
- finalSerializeQueryArgs = options.serializeQueryArgs;
- }
- return finalSerializeQueryArgs(queryArgsApi);
- },
- tagTypes: __spreadArray([], options.tagTypes || [])
- });
- var context = {
- endpointDefinitions: {},
- batch: function (fn) {
- fn();
- },
- apiUid: (0, import_toolkit9.nanoid)(),
- extractRehydrationInfo: extractRehydrationInfo,
- hasRehydrationInfo: (0, import_reselect.defaultMemoize)(function (action) { return extractRehydrationInfo(action) != null; })
- };
- var api = {
- injectEndpoints: injectEndpoints,
- enhanceEndpoints: function (_j) {
- var addTagTypes = _j.addTagTypes, endpoints = _j.endpoints;
- if (addTagTypes) {
- for (var _k = 0, addTagTypes_1 = addTagTypes; _k < addTagTypes_1.length; _k++) {
- var eT = addTagTypes_1[_k];
- if (!optionsWithDefaults.tagTypes.includes(eT)) {
- ;
- optionsWithDefaults.tagTypes.push(eT);
- }
- }
- }
- if (endpoints) {
- for (var _l = 0, _m = Object.entries(endpoints); _l < _m.length; _l++) {
- var _o = _m[_l], endpointName = _o[0], partialDefinition = _o[1];
- if (typeof partialDefinition === "function") {
- partialDefinition(context.endpointDefinitions[endpointName]);
- }
- else {
- Object.assign(context.endpointDefinitions[endpointName] || {}, partialDefinition);
- }
- }
- }
- return api;
- }
- };
- var initializedModules = modules.map(function (m) { return m.init(api, optionsWithDefaults, context); });
- function injectEndpoints(inject) {
- var evaluatedEndpoints = inject.endpoints({
- query: function (x) { return __spreadProps(__spreadValues({}, x), { type: DefinitionType.query }); },
- mutation: function (x) { return __spreadProps(__spreadValues({}, x), { type: DefinitionType.mutation }); }
- });
- for (var _j = 0, _k = Object.entries(evaluatedEndpoints); _j < _k.length; _j++) {
- var _l = _k[_j], endpointName = _l[0], definition = _l[1];
- if (!inject.overrideExisting && endpointName in context.endpointDefinitions) {
- if (typeof process !== "undefined" && true) {
- console.error("called `injectEndpoints` to override already-existing endpointName " + endpointName + " without specifying `overrideExisting: true`");
- }
- continue;
- }
- context.endpointDefinitions[endpointName] = definition;
- for (var _m = 0, initializedModules_1 = initializedModules; _m < initializedModules_1.length; _m++) {
- var m = initializedModules_1[_m];
- m.injectEndpoint(endpointName, definition);
- }
- }
- return api;
- }
- return api.injectEndpoints({ endpoints: options.endpoints });
- };
- }
- // src/query/fakeBaseQuery.ts
- function fakeBaseQuery() {
- return function () {
- throw new Error("When using `fakeBaseQuery`, all queries & mutations must use the `queryFn` definition syntax.");
- };
- }
- // src/query/core/buildMiddleware/index.ts
- var import_toolkit13 = __toModule(require("@reduxjs/toolkit"));
- // src/query/core/buildMiddleware/cacheCollection.ts
- function isObjectEmpty(obj) {
- for (var k in obj) {
- return false;
- }
- return true;
- }
- var THIRTY_TWO_BIT_MAX_TIMER_SECONDS = 2147483647 / 1e3 - 1;
- var buildCacheCollectionHandler = function (_j) {
- var reducerPath = _j.reducerPath, api = _j.api, context = _j.context, internalState = _j.internalState;
- var _k = api.internalActions, removeQueryResult = _k.removeQueryResult, unsubscribeQueryResult = _k.unsubscribeQueryResult;
- function anySubscriptionsRemainingForKey(queryCacheKey) {
- var subscriptions = internalState.currentSubscriptions[queryCacheKey];
- return !!subscriptions && !isObjectEmpty(subscriptions);
- }
- var currentRemovalTimeouts = {};
- var handler = function (action, mwApi, internalState2) {
- var _a;
- if (unsubscribeQueryResult.match(action)) {
- var state = mwApi.getState()[reducerPath];
- var queryCacheKey = action.payload.queryCacheKey;
- handleUnsubscribe(queryCacheKey, (_a = state.queries[queryCacheKey]) == null ? void 0 : _a.endpointName, mwApi, state.config);
- }
- if (api.util.resetApiState.match(action)) {
- for (var _j = 0, _k = Object.entries(currentRemovalTimeouts); _j < _k.length; _j++) {
- var _l = _k[_j], key = _l[0], timeout = _l[1];
- if (timeout)
- clearTimeout(timeout);
- delete currentRemovalTimeouts[key];
- }
- }
- if (context.hasRehydrationInfo(action)) {
- var state = mwApi.getState()[reducerPath];
- var queries = context.extractRehydrationInfo(action).queries;
- for (var _m = 0, _o = Object.entries(queries); _m < _o.length; _m++) {
- var _p = _o[_m], queryCacheKey = _p[0], queryState = _p[1];
- handleUnsubscribe(queryCacheKey, queryState == null ? void 0 : queryState.endpointName, mwApi, state.config);
- }
- }
- };
- function handleUnsubscribe(queryCacheKey, endpointName, api2, config) {
- var _a;
- var endpointDefinition = context.endpointDefinitions[endpointName];
- var keepUnusedDataFor = (_a = endpointDefinition == null ? void 0 : endpointDefinition.keepUnusedDataFor) != null ? _a : config.keepUnusedDataFor;
- if (keepUnusedDataFor === Infinity) {
- return;
- }
- var finalKeepUnusedDataFor = Math.max(0, Math.min(keepUnusedDataFor, THIRTY_TWO_BIT_MAX_TIMER_SECONDS));
- if (!anySubscriptionsRemainingForKey(queryCacheKey)) {
- var currentTimeout = currentRemovalTimeouts[queryCacheKey];
- if (currentTimeout) {
- clearTimeout(currentTimeout);
- }
- currentRemovalTimeouts[queryCacheKey] = setTimeout(function () {
- if (!anySubscriptionsRemainingForKey(queryCacheKey)) {
- api2.dispatch(removeQueryResult({ queryCacheKey: queryCacheKey }));
- }
- delete currentRemovalTimeouts[queryCacheKey];
- }, finalKeepUnusedDataFor * 1e3);
- }
- }
- return handler;
- };
- // src/query/core/buildMiddleware/invalidationByTags.ts
- var import_toolkit10 = __toModule(require("@reduxjs/toolkit"));
- var buildInvalidationByTagsHandler = function (_j) {
- var reducerPath = _j.reducerPath, context = _j.context, endpointDefinitions = _j.context.endpointDefinitions, mutationThunk = _j.mutationThunk, api = _j.api, assertTagType = _j.assertTagType, refetchQuery = _j.refetchQuery;
- var removeQueryResult = api.internalActions.removeQueryResult;
- var isThunkActionWithTags = (0, import_toolkit10.isAnyOf)((0, import_toolkit10.isFulfilled)(mutationThunk), (0, import_toolkit10.isRejectedWithValue)(mutationThunk));
- var handler = function (action, mwApi) {
- if (isThunkActionWithTags(action)) {
- invalidateTags(calculateProvidedByThunk(action, "invalidatesTags", endpointDefinitions, assertTagType), mwApi);
- }
- if (api.util.invalidateTags.match(action)) {
- invalidateTags(calculateProvidedBy(action.payload, void 0, void 0, void 0, void 0, assertTagType), mwApi);
- }
- };
- function invalidateTags(tags, mwApi) {
- var rootState = mwApi.getState();
- var state = rootState[reducerPath];
- var toInvalidate = api.util.selectInvalidatedBy(rootState, tags);
- context.batch(function () {
- var _a;
- var valuesArray = Array.from(toInvalidate.values());
- for (var _j = 0, valuesArray_1 = valuesArray; _j < valuesArray_1.length; _j++) {
- var queryCacheKey = valuesArray_1[_j].queryCacheKey;
- var querySubState = state.queries[queryCacheKey];
- var subscriptionSubState = (_a = state.subscriptions[queryCacheKey]) != null ? _a : {};
- if (querySubState) {
- if (Object.keys(subscriptionSubState).length === 0) {
- mwApi.dispatch(removeQueryResult({
- queryCacheKey: queryCacheKey
- }));
- }
- else if (querySubState.status !== QueryStatus.uninitialized) {
- mwApi.dispatch(refetchQuery(querySubState, queryCacheKey));
- }
- }
- }
- });
- }
- return handler;
- };
- // src/query/core/buildMiddleware/polling.ts
- var buildPollingHandler = function (_j) {
- var reducerPath = _j.reducerPath, queryThunk = _j.queryThunk, api = _j.api, refetchQuery = _j.refetchQuery, internalState = _j.internalState;
- var currentPolls = {};
- var handler = function (action, mwApi) {
- if (api.internalActions.updateSubscriptionOptions.match(action) || api.internalActions.unsubscribeQueryResult.match(action)) {
- updatePollingInterval(action.payload, mwApi);
- }
- if (queryThunk.pending.match(action) || queryThunk.rejected.match(action) && action.meta.condition) {
- updatePollingInterval(action.meta.arg, mwApi);
- }
- if (queryThunk.fulfilled.match(action) || queryThunk.rejected.match(action) && !action.meta.condition) {
- startNextPoll(action.meta.arg, mwApi);
- }
- if (api.util.resetApiState.match(action)) {
- clearPolls();
- }
- };
- function startNextPoll(_j, api2) {
- var queryCacheKey = _j.queryCacheKey;
- var state = api2.getState()[reducerPath];
- var querySubState = state.queries[queryCacheKey];
- var subscriptions = internalState.currentSubscriptions[queryCacheKey];
- if (!querySubState || querySubState.status === QueryStatus.uninitialized)
- return;
- var lowestPollingInterval = findLowestPollingInterval(subscriptions);
- if (!Number.isFinite(lowestPollingInterval))
- return;
- var currentPoll = currentPolls[queryCacheKey];
- if (currentPoll == null ? void 0 : currentPoll.timeout) {
- clearTimeout(currentPoll.timeout);
- currentPoll.timeout = void 0;
- }
- var nextPollTimestamp = Date.now() + lowestPollingInterval;
- var currentInterval = currentPolls[queryCacheKey] = {
- nextPollTimestamp: nextPollTimestamp,
- pollingInterval: lowestPollingInterval,
- timeout: setTimeout(function () {
- currentInterval.timeout = void 0;
- api2.dispatch(refetchQuery(querySubState, queryCacheKey));
- }, lowestPollingInterval)
- };
- }
- function updatePollingInterval(_j, api2) {
- var queryCacheKey = _j.queryCacheKey;
- var state = api2.getState()[reducerPath];
- var querySubState = state.queries[queryCacheKey];
- var subscriptions = internalState.currentSubscriptions[queryCacheKey];
- if (!querySubState || querySubState.status === QueryStatus.uninitialized) {
- return;
- }
- var lowestPollingInterval = findLowestPollingInterval(subscriptions);
- if (!Number.isFinite(lowestPollingInterval)) {
- cleanupPollForKey(queryCacheKey);
- return;
- }
- var currentPoll = currentPolls[queryCacheKey];
- var nextPollTimestamp = Date.now() + lowestPollingInterval;
- if (!currentPoll || nextPollTimestamp < currentPoll.nextPollTimestamp) {
- startNextPoll({ queryCacheKey: queryCacheKey }, api2);
- }
- }
- function cleanupPollForKey(key) {
- var existingPoll = currentPolls[key];
- if (existingPoll == null ? void 0 : existingPoll.timeout) {
- clearTimeout(existingPoll.timeout);
- }
- delete currentPolls[key];
- }
- function clearPolls() {
- for (var _j = 0, _k = Object.keys(currentPolls); _j < _k.length; _j++) {
- var key = _k[_j];
- cleanupPollForKey(key);
- }
- }
- function findLowestPollingInterval(subscribers) {
- if (subscribers === void 0) { subscribers = {}; }
- var lowestPollingInterval = Number.POSITIVE_INFINITY;
- for (var key in subscribers) {
- if (!!subscribers[key].pollingInterval) {
- lowestPollingInterval = Math.min(subscribers[key].pollingInterval, lowestPollingInterval);
- }
- }
- return lowestPollingInterval;
- }
- return handler;
- };
- // src/query/core/buildMiddleware/windowEventHandling.ts
- var buildWindowEventHandler = function (_j) {
- var reducerPath = _j.reducerPath, context = _j.context, api = _j.api, refetchQuery = _j.refetchQuery, internalState = _j.internalState;
- var removeQueryResult = api.internalActions.removeQueryResult;
- var handler = function (action, mwApi) {
- if (onFocus.match(action)) {
- refetchValidQueries(mwApi, "refetchOnFocus");
- }
- if (onOnline.match(action)) {
- refetchValidQueries(mwApi, "refetchOnReconnect");
- }
- };
- function refetchValidQueries(api2, type) {
- var state = api2.getState()[reducerPath];
- var queries = state.queries;
- var subscriptions = internalState.currentSubscriptions;
- context.batch(function () {
- for (var _j = 0, _k = Object.keys(subscriptions); _j < _k.length; _j++) {
- var queryCacheKey = _k[_j];
- var querySubState = queries[queryCacheKey];
- var subscriptionSubState = subscriptions[queryCacheKey];
- if (!subscriptionSubState || !querySubState)
- continue;
- var shouldRefetch = Object.values(subscriptionSubState).some(function (sub) { return sub[type] === true; }) || Object.values(subscriptionSubState).every(function (sub) { return sub[type] === void 0; }) && state.config[type];
- if (shouldRefetch) {
- if (Object.keys(subscriptionSubState).length === 0) {
- api2.dispatch(removeQueryResult({
- queryCacheKey: queryCacheKey
- }));
- }
- else if (querySubState.status !== QueryStatus.uninitialized) {
- api2.dispatch(refetchQuery(querySubState, queryCacheKey));
- }
- }
- }
- });
- }
- return handler;
- };
- // src/query/core/buildMiddleware/cacheLifecycle.ts
- var import_toolkit11 = __toModule(require("@reduxjs/toolkit"));
- var neverResolvedError = new Error("Promise never resolved before cacheEntryRemoved.");
- var buildCacheLifecycleHandler = function (_j) {
- var api = _j.api, reducerPath = _j.reducerPath, context = _j.context, queryThunk = _j.queryThunk, mutationThunk = _j.mutationThunk, internalState = _j.internalState;
- var isQueryThunk = (0, import_toolkit11.isAsyncThunkAction)(queryThunk);
- var isMutationThunk = (0, import_toolkit11.isAsyncThunkAction)(mutationThunk);
- var isFulfilledThunk = (0, import_toolkit11.isFulfilled)(queryThunk, mutationThunk);
- var lifecycleMap = {};
- var handler = function (action, mwApi, stateBefore) {
- var cacheKey = getCacheKey(action);
- if (queryThunk.pending.match(action)) {
- var oldState = stateBefore[reducerPath].queries[cacheKey];
- var state = mwApi.getState()[reducerPath].queries[cacheKey];
- if (!oldState && state) {
- handleNewKey(action.meta.arg.endpointName, action.meta.arg.originalArgs, cacheKey, mwApi, action.meta.requestId);
- }
- }
- else if (mutationThunk.pending.match(action)) {
- var state = mwApi.getState()[reducerPath].mutations[cacheKey];
- if (state) {
- handleNewKey(action.meta.arg.endpointName, action.meta.arg.originalArgs, cacheKey, mwApi, action.meta.requestId);
- }
- }
- else if (isFulfilledThunk(action)) {
- var lifecycle = lifecycleMap[cacheKey];
- if (lifecycle == null ? void 0 : lifecycle.valueResolved) {
- lifecycle.valueResolved({
- data: action.payload,
- meta: action.meta.baseQueryMeta
- });
- delete lifecycle.valueResolved;
- }
- }
- else if (api.internalActions.removeQueryResult.match(action) || api.internalActions.removeMutationResult.match(action)) {
- var lifecycle = lifecycleMap[cacheKey];
- if (lifecycle) {
- delete lifecycleMap[cacheKey];
- lifecycle.cacheEntryRemoved();
- }
- }
- else if (api.util.resetApiState.match(action)) {
- for (var _j = 0, _k = Object.entries(lifecycleMap); _j < _k.length; _j++) {
- var _l = _k[_j], cacheKey2 = _l[0], lifecycle = _l[1];
- delete lifecycleMap[cacheKey2];
- lifecycle.cacheEntryRemoved();
- }
- }
- };
- function getCacheKey(action) {
- if (isQueryThunk(action))
- return action.meta.arg.queryCacheKey;
- if (isMutationThunk(action))
- return action.meta.requestId;
- if (api.internalActions.removeQueryResult.match(action))
- return action.payload.queryCacheKey;
- if (api.internalActions.removeMutationResult.match(action))
- return getMutationCacheKey(action.payload);
- return "";
- }
- function handleNewKey(endpointName, originalArgs, queryCacheKey, mwApi, requestId) {
- var endpointDefinition = context.endpointDefinitions[endpointName];
- var onCacheEntryAdded = endpointDefinition == null ? void 0 : endpointDefinition.onCacheEntryAdded;
- if (!onCacheEntryAdded)
- return;
- var lifecycle = {};
- var cacheEntryRemoved = new Promise(function (resolve) {
- lifecycle.cacheEntryRemoved = resolve;
- });
- var cacheDataLoaded = Promise.race([
- new Promise(function (resolve) {
- lifecycle.valueResolved = resolve;
- }),
- cacheEntryRemoved.then(function () {
- throw neverResolvedError;
- })
- ]);
- cacheDataLoaded.catch(function () {
- });
- lifecycleMap[queryCacheKey] = lifecycle;
- var selector = api.endpoints[endpointName].select(endpointDefinition.type === DefinitionType.query ? originalArgs : queryCacheKey);
- var extra = mwApi.dispatch(function (_, __, extra2) { return extra2; });
- var lifecycleApi = __spreadProps(__spreadValues({}, mwApi), {
- getCacheEntry: function () { return selector(mwApi.getState()); },
- requestId: requestId,
- extra: extra,
- updateCachedData: endpointDefinition.type === DefinitionType.query ? function (updateRecipe) { return mwApi.dispatch(api.util.updateQueryData(endpointName, originalArgs, updateRecipe)); } : void 0,
- cacheDataLoaded: cacheDataLoaded,
- cacheEntryRemoved: cacheEntryRemoved
- });
- var runningHandler = onCacheEntryAdded(originalArgs, lifecycleApi);
- Promise.resolve(runningHandler).catch(function (e) {
- if (e === neverResolvedError)
- return;
- throw e;
- });
- }
- return handler;
- };
- // src/query/core/buildMiddleware/queryLifecycle.ts
- var import_toolkit12 = __toModule(require("@reduxjs/toolkit"));
- var buildQueryLifecycleHandler = function (_j) {
- var api = _j.api, context = _j.context, queryThunk = _j.queryThunk, mutationThunk = _j.mutationThunk;
- var isPendingThunk = (0, import_toolkit12.isPending)(queryThunk, mutationThunk);
- var isRejectedThunk = (0, import_toolkit12.isRejected)(queryThunk, mutationThunk);
- var isFullfilledThunk = (0, import_toolkit12.isFulfilled)(queryThunk, mutationThunk);
- var lifecycleMap = {};
- var handler = function (action, mwApi) {
- var _a, _b, _c;
- if (isPendingThunk(action)) {
- var _j = action.meta, requestId = _j.requestId, _k = _j.arg, endpointName_1 = _k.endpointName, originalArgs_1 = _k.originalArgs;
- var endpointDefinition = context.endpointDefinitions[endpointName_1];
- var onQueryStarted = endpointDefinition == null ? void 0 : endpointDefinition.onQueryStarted;
- if (onQueryStarted) {
- var lifecycle_1 = {};
- var queryFulfilled = new Promise(function (resolve, reject) {
- lifecycle_1.resolve = resolve;
- lifecycle_1.reject = reject;
- });
- queryFulfilled.catch(function () {
- });
- lifecycleMap[requestId] = lifecycle_1;
- var selector_1 = api.endpoints[endpointName_1].select(endpointDefinition.type === DefinitionType.query ? originalArgs_1 : requestId);
- var extra = mwApi.dispatch(function (_, __, extra2) { return extra2; });
- var lifecycleApi = __spreadProps(__spreadValues({}, mwApi), {
- getCacheEntry: function () { return selector_1(mwApi.getState()); },
- requestId: requestId,
- extra: extra,
- updateCachedData: endpointDefinition.type === DefinitionType.query ? function (updateRecipe) { return mwApi.dispatch(api.util.updateQueryData(endpointName_1, originalArgs_1, updateRecipe)); } : void 0,
- queryFulfilled: queryFulfilled
- });
- onQueryStarted(originalArgs_1, lifecycleApi);
- }
- }
- else if (isFullfilledThunk(action)) {
- var _l = action.meta, requestId = _l.requestId, baseQueryMeta = _l.baseQueryMeta;
- (_a = lifecycleMap[requestId]) == null ? void 0 : _a.resolve({
- data: action.payload,
- meta: baseQueryMeta
- });
- delete lifecycleMap[requestId];
- }
- else if (isRejectedThunk(action)) {
- var _m = action.meta, requestId = _m.requestId, rejectedWithValue = _m.rejectedWithValue, baseQueryMeta = _m.baseQueryMeta;
- (_c = lifecycleMap[requestId]) == null ? void 0 : _c.reject({
- error: (_b = action.payload) != null ? _b : action.error,
- isUnhandledError: !rejectedWithValue,
- meta: baseQueryMeta
- });
- delete lifecycleMap[requestId];
- }
- };
- return handler;
- };
- // src/query/core/buildMiddleware/devMiddleware.ts
- var buildDevCheckHandler = function (_j) {
- var api = _j.api, apiUid = _j.context.apiUid, reducerPath = _j.reducerPath;
- return function (action, mwApi) {
- var _a, _b;
- if (api.util.resetApiState.match(action)) {
- mwApi.dispatch(api.internalActions.middlewareRegistered(apiUid));
- }
- if (typeof process !== "undefined" && true) {
- if (api.internalActions.middlewareRegistered.match(action) && action.payload === apiUid && ((_b = (_a = mwApi.getState()[reducerPath]) == null ? void 0 : _a.config) == null ? void 0 : _b.middlewareRegistered) === "conflict") {
- console.warn("There is a mismatch between slice and middleware for the reducerPath \"" + reducerPath + "\".\nYou can only have one api per reducer path, this will lead to crashes in various situations!" + (reducerPath === "api" ? "\nIf you have multiple apis, you *have* to specify the reducerPath option when using createApi!" : ""));
- }
- }
- };
- };
- // src/query/core/buildMiddleware/batchActions.ts
- var import_immer4 = __toModule(require("immer"));
- var promise;
- var queueMicrotaskShim = typeof queueMicrotask === "function" ? queueMicrotask.bind(typeof window !== "undefined" ? window : typeof global !== "undefined" ? global : globalThis) : function (cb) { return (promise || (promise = Promise.resolve())).then(cb).catch(function (err) { return setTimeout(function () {
- throw err;
- }, 0); }); };
- var buildBatchedActionsHandler = function (_j) {
- var api = _j.api, queryThunk = _j.queryThunk, internalState = _j.internalState;
- var subscriptionsPrefix = api.reducerPath + "/subscriptions";
- var previousSubscriptions = null;
- var dispatchQueued = false;
- var _k = api.internalActions, updateSubscriptionOptions = _k.updateSubscriptionOptions, unsubscribeQueryResult = _k.unsubscribeQueryResult;
- var actuallyMutateSubscriptions = function (mutableState, action) {
- var _a, _b, _c, _d, _e, _f, _g, _h, _i;
- if (updateSubscriptionOptions.match(action)) {
- var _j = action.payload, queryCacheKey = _j.queryCacheKey, requestId = _j.requestId, options = _j.options;
- if ((_a = mutableState == null ? void 0 : mutableState[queryCacheKey]) == null ? void 0 : _a[requestId]) {
- mutableState[queryCacheKey][requestId] = options;
- }
- return true;
- }
- if (unsubscribeQueryResult.match(action)) {
- var _k = action.payload, queryCacheKey = _k.queryCacheKey, requestId = _k.requestId;
- if (mutableState[queryCacheKey]) {
- delete mutableState[queryCacheKey][requestId];
- }
- return true;
- }
- if (api.internalActions.removeQueryResult.match(action)) {
- delete mutableState[action.payload.queryCacheKey];
- return true;
- }
- if (queryThunk.pending.match(action)) {
- var _l = action.meta, arg = _l.arg, requestId = _l.requestId;
- if (arg.subscribe) {
- var substate = (_c = mutableState[_b = arg.queryCacheKey]) != null ? _c : mutableState[_b] = {};
- substate[requestId] = (_e = (_d = arg.subscriptionOptions) != null ? _d : substate[requestId]) != null ? _e : {};
- return true;
- }
- }
- if (queryThunk.rejected.match(action)) {
- var _m = action.meta, condition = _m.condition, arg = _m.arg, requestId = _m.requestId;
- if (condition && arg.subscribe) {
- var substate = (_g = mutableState[_f = arg.queryCacheKey]) != null ? _g : mutableState[_f] = {};
- substate[requestId] = (_i = (_h = arg.subscriptionOptions) != null ? _h : substate[requestId]) != null ? _i : {};
- return true;
- }
- }
- return false;
- };
- return function (action, mwApi) {
- var _a, _b;
- if (!previousSubscriptions) {
- previousSubscriptions = JSON.parse(JSON.stringify(internalState.currentSubscriptions));
- }
- if (api.util.resetApiState.match(action)) {
- previousSubscriptions = internalState.currentSubscriptions = {};
- return [true, false];
- }
- if (api.internalActions.internal_probeSubscription.match(action)) {
- var _j = action.payload, queryCacheKey = _j.queryCacheKey, requestId = _j.requestId;
- var hasSubscription = !!((_a = internalState.currentSubscriptions[queryCacheKey]) == null ? void 0 : _a[requestId]);
- return [false, hasSubscription];
- }
- var didMutate = actuallyMutateSubscriptions(internalState.currentSubscriptions, action);
- if (didMutate) {
- if (!dispatchQueued) {
- queueMicrotaskShim(function () {
- var newSubscriptions = JSON.parse(JSON.stringify(internalState.currentSubscriptions));
- var _j = (0, import_immer4.produceWithPatches)(previousSubscriptions, function () { return newSubscriptions; }), patches = _j[1];
- mwApi.next(api.internalActions.subscriptionsUpdated(patches));
- previousSubscriptions = newSubscriptions;
- dispatchQueued = false;
- });
- dispatchQueued = true;
- }
- var isSubscriptionSliceAction = !!((_b = action.type) == null ? void 0 : _b.startsWith(subscriptionsPrefix));
- var isAdditionalSubscriptionAction = queryThunk.rejected.match(action) && action.meta.condition && !!action.meta.arg.subscribe;
- var actionShouldContinue = !isSubscriptionSliceAction && !isAdditionalSubscriptionAction;
- return [actionShouldContinue, false];
- }
- return [true, false];
- };
- };
- // src/query/core/buildMiddleware/index.ts
- function buildMiddleware(input) {
- var reducerPath = input.reducerPath, queryThunk = input.queryThunk, api = input.api, context = input.context;
- var apiUid = context.apiUid;
- var actions = {
- invalidateTags: (0, import_toolkit13.createAction)(reducerPath + "/invalidateTags")
- };
- var isThisApiSliceAction = function (action) {
- return !!action && typeof action.type === "string" && action.type.startsWith(reducerPath + "/");
- };
- var handlerBuilders = [
- buildDevCheckHandler,
- buildCacheCollectionHandler,
- buildInvalidationByTagsHandler,
- buildPollingHandler,
- buildCacheLifecycleHandler,
- buildQueryLifecycleHandler
- ];
- var middleware = function (mwApi) {
- var initialized2 = false;
- var internalState = {
- currentSubscriptions: {}
- };
- var builderArgs = __spreadProps(__spreadValues({}, input), {
- internalState: internalState,
- refetchQuery: refetchQuery
- });
- var handlers = handlerBuilders.map(function (build) { return build(builderArgs); });
- var batchedActionsHandler = buildBatchedActionsHandler(builderArgs);
- var windowEventsHandler = buildWindowEventHandler(builderArgs);
- return function (next) {
- return function (action) {
- if (!initialized2) {
- initialized2 = true;
- mwApi.dispatch(api.internalActions.middlewareRegistered(apiUid));
- }
- var mwApiWithNext = __spreadProps(__spreadValues({}, mwApi), { next: next });
- var stateBefore = mwApi.getState();
- var _j = batchedActionsHandler(action, mwApiWithNext, stateBefore), actionShouldContinue = _j[0], hasSubscription = _j[1];
- var res;
- if (actionShouldContinue) {
- res = next(action);
- }
- else {
- res = hasSubscription;
- }
- if (!!mwApi.getState()[reducerPath]) {
- windowEventsHandler(action, mwApiWithNext, stateBefore);
- if (isThisApiSliceAction(action) || context.hasRehydrationInfo(action)) {
- for (var _k = 0, handlers_1 = handlers; _k < handlers_1.length; _k++) {
- var handler = handlers_1[_k];
- handler(action, mwApiWithNext, stateBefore);
- }
- }
- }
- return res;
- };
- };
- };
- return { middleware: middleware, actions: actions };
- function refetchQuery(querySubState, queryCacheKey, override) {
- if (override === void 0) { override = {}; }
- return queryThunk(__spreadValues({
- type: "query",
- endpointName: querySubState.endpointName,
- originalArgs: querySubState.originalArgs,
- subscribe: false,
- forceRefetch: true,
- queryCacheKey: queryCacheKey
- }, override));
- }
- }
- // src/query/tsHelpers.ts
- function assertCast(v) {
- }
- function safeAssign(target) {
- var args = [];
- for (var _j = 1; _j < arguments.length; _j++) {
- args[_j - 1] = arguments[_j];
- }
- Object.assign.apply(Object, __spreadArray([target], args));
- }
- // src/query/core/module.ts
- var import_immer5 = __toModule(require("immer"));
- var coreModuleName = /* @__PURE__ */ Symbol();
- var coreModule = function () { return ({
- name: coreModuleName,
- init: function (api, _j, context) {
- var baseQuery = _j.baseQuery, tagTypes = _j.tagTypes, reducerPath = _j.reducerPath, serializeQueryArgs = _j.serializeQueryArgs, keepUnusedDataFor = _j.keepUnusedDataFor, refetchOnMountOrArgChange = _j.refetchOnMountOrArgChange, refetchOnFocus = _j.refetchOnFocus, refetchOnReconnect = _j.refetchOnReconnect;
- (0, import_immer5.enablePatches)();
- assertCast(serializeQueryArgs);
- var assertTagType = function (tag) {
- if (typeof process !== "undefined" && true) {
- if (!tagTypes.includes(tag.type)) {
- console.error("Tag type '" + tag.type + "' was used, but not specified in `tagTypes`!");
- }
- }
- return tag;
- };
- Object.assign(api, {
- reducerPath: reducerPath,
- endpoints: {},
- internalActions: {
- onOnline: onOnline,
- onOffline: onOffline,
- onFocus: onFocus,
- onFocusLost: onFocusLost
- },
- util: {}
- });
- var _k = buildThunks({
- baseQuery: baseQuery,
- reducerPath: reducerPath,
- context: context,
- api: api,
- serializeQueryArgs: serializeQueryArgs,
- assertTagType: assertTagType
- }), queryThunk = _k.queryThunk, mutationThunk = _k.mutationThunk, patchQueryData = _k.patchQueryData, updateQueryData = _k.updateQueryData, upsertQueryData = _k.upsertQueryData, prefetch = _k.prefetch, buildMatchThunkActions = _k.buildMatchThunkActions;
- var _l = buildSlice({
- context: context,
- queryThunk: queryThunk,
- mutationThunk: mutationThunk,
- reducerPath: reducerPath,
- assertTagType: assertTagType,
- config: {
- refetchOnFocus: refetchOnFocus,
- refetchOnReconnect: refetchOnReconnect,
- refetchOnMountOrArgChange: refetchOnMountOrArgChange,
- keepUnusedDataFor: keepUnusedDataFor,
- reducerPath: reducerPath
- }
- }), reducer = _l.reducer, sliceActions = _l.actions;
- safeAssign(api.util, {
- patchQueryData: patchQueryData,
- updateQueryData: updateQueryData,
- upsertQueryData: upsertQueryData,
- prefetch: prefetch,
- resetApiState: sliceActions.resetApiState
- });
- safeAssign(api.internalActions, sliceActions);
- var _m = buildMiddleware({
- reducerPath: reducerPath,
- context: context,
- queryThunk: queryThunk,
- mutationThunk: mutationThunk,
- api: api,
- assertTagType: assertTagType
- }), middleware = _m.middleware, middlewareActions = _m.actions;
- safeAssign(api.util, middlewareActions);
- safeAssign(api, { reducer: reducer, middleware: middleware });
- var _o = buildSelectors({
- serializeQueryArgs: serializeQueryArgs,
- reducerPath: reducerPath
- }), buildQuerySelector = _o.buildQuerySelector, buildMutationSelector = _o.buildMutationSelector, selectInvalidatedBy = _o.selectInvalidatedBy;
- safeAssign(api.util, { selectInvalidatedBy: selectInvalidatedBy });
- var _p = buildInitiate({
- queryThunk: queryThunk,
- mutationThunk: mutationThunk,
- api: api,
- serializeQueryArgs: serializeQueryArgs,
- context: context
- }), buildInitiateQuery = _p.buildInitiateQuery, buildInitiateMutation = _p.buildInitiateMutation, getRunningMutationThunk = _p.getRunningMutationThunk, getRunningMutationsThunk = _p.getRunningMutationsThunk, getRunningQueriesThunk = _p.getRunningQueriesThunk, getRunningQueryThunk = _p.getRunningQueryThunk, getRunningOperationPromises = _p.getRunningOperationPromises, removalWarning = _p.removalWarning;
- safeAssign(api.util, {
- getRunningOperationPromises: getRunningOperationPromises,
- getRunningOperationPromise: removalWarning,
- getRunningMutationThunk: getRunningMutationThunk,
- getRunningMutationsThunk: getRunningMutationsThunk,
- getRunningQueryThunk: getRunningQueryThunk,
- getRunningQueriesThunk: getRunningQueriesThunk
- });
- return {
- name: coreModuleName,
- injectEndpoint: function (endpointName, definition) {
- var _a, _b;
- var anyApi = api;
- (_b = (_a = anyApi.endpoints)[endpointName]) != null ? _b : _a[endpointName] = {};
- if (isQueryDefinition(definition)) {
- safeAssign(anyApi.endpoints[endpointName], {
- name: endpointName,
- select: buildQuerySelector(endpointName, definition),
- initiate: buildInitiateQuery(endpointName, definition)
- }, buildMatchThunkActions(queryThunk, endpointName));
- }
- else if (isMutationDefinition(definition)) {
- safeAssign(anyApi.endpoints[endpointName], {
- name: endpointName,
- select: buildMutationSelector(),
- initiate: buildInitiateMutation(endpointName)
- }, buildMatchThunkActions(mutationThunk, endpointName));
- }
- }
- };
- }
- }); };
- // src/query/core/index.ts
- var createApi = /* @__PURE__ */ buildCreateApi(coreModule());
- //# sourceMappingURL=rtk-query.cjs.development.js.map
|