aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--.yarn/plugins/@yarnpkg/plugin-typescript.cjs2004
-rw-r--r--.yarnrc.yml7
-rw-r--r--package.json20
-rw-r--r--yarn.lock600
4 files changed, 560 insertions, 2071 deletions
diff --git a/.yarn/plugins/@yarnpkg/plugin-typescript.cjs b/.yarn/plugins/@yarnpkg/plugin-typescript.cjs
index df8ade0..5c1859e 100644
--- a/.yarn/plugins/@yarnpkg/plugin-typescript.cjs
+++ b/.yarn/plugins/@yarnpkg/plugin-typescript.cjs
@@ -1,2001 +1,9 @@
/* eslint-disable */
+//prettier-ignore
module.exports = {
- name: '@yarnpkg/plugin-typescript',
- factory: function (require) {
- var plugin;
- plugin = (() => {
- var e = {
- 958: (e, t, r) => {
- 'use strict';
- r.r(t), r.d(t, { default: () => u });
- const s = require('@yarnpkg/core'),
- a = require('@yarnpkg/plugin-essentials'),
- o = require('semver');
- var n = r.n(o),
- i = r(410),
- c = r.n(i);
- const d = (e) => {
- const t = {
- async send(t) {
- try {
- const r = await s.httpUtils.request(
- t.url,
- t.data || null,
- { configuration: e, headers: t.headers }
- );
- return {
- content: r.body,
- isTimedOut: !1,
- status: r.statusCode
- };
- } catch (e) {
- return {
- content: e.response.body,
- isTimedOut: !1,
- status: e.response.statusCode
- };
- }
- }
- };
- return c()('OFCNCOG2CU', 'e8e1bd300d860104bb8c58453ffa1eb4', {
- requester: t
- });
- },
- l = (e) => (e.scope ? `${e.scope}__${e.name}` : '' + e.name),
- u = {
- hooks: {
- afterWorkspaceDependencyAddition: async (e, t, r, o) => {
- if ('types' === r.scope) return;
- const { project: i } = e,
- { configuration: c } = i,
- u = c.makeResolver(),
- p = {
- project: i,
- resolver: u,
- report: new s.ThrowReport()
- };
- if (
- !(await (async (e, t) => {
- var r;
- const a = s.structUtils.stringifyIdent(e),
- o = d(t).initIndex('npm-search');
- try {
- return (
- 'definitely-typed' ===
- (null ===
- (r = (
- await o.getObject(a, {
- attributesToRetrieve: ['types']
- })
- ).types) || void 0 === r
- ? void 0
- : r.ts)
- );
- } catch (e) {
- return !1;
- }
- })(r, c))
- )
- return;
- const m = l(r);
- let h = s.structUtils.parseRange(r.range).selector;
- if (!n().validRange(h)) {
- const e = await u.getCandidates(r, new Map(), p);
- h = s.structUtils.parseRange(e[0].reference).selector;
- }
- const y = n().coerce(h);
- if (null === y) return;
- const g = `${a.suggestUtils.Modifier.CARET}${y.major}`,
- b = s.structUtils.makeDescriptor(
- s.structUtils.makeIdent('types', m),
- g
- ),
- f = s.miscUtils.mapAndFind(i.workspaces, (e) => {
- var t, a;
- const o =
- null ===
- (t = e.manifest.dependencies.get(r.identHash)) ||
- void 0 === t
- ? void 0
- : t.descriptorHash,
- n =
- null ===
- (a = e.manifest.devDependencies.get(
- r.identHash
- )) || void 0 === a
- ? void 0
- : a.descriptorHash;
- if (o !== r.descriptorHash && n !== r.descriptorHash)
- return s.miscUtils.mapAndFind.skip;
- const i = [];
- for (const t of s.Manifest.allDependencies) {
- const r = e.manifest[t].get(b.identHash);
- void 0 !== r && i.push([t, r]);
- }
- return 0 === i.length ? s.miscUtils.mapAndFind.skip : i;
- });
- if (void 0 !== f)
- for (const [t, r] of f) e.manifest[t].set(r.identHash, r);
- else {
- try {
- if (
- 0 === (await u.getCandidates(b, new Map(), p)).length
- )
- return;
- } catch (e) {
- return;
- }
- e.manifest[a.suggestUtils.Target.DEVELOPMENT].set(
- b.identHash,
- b
- );
- }
- },
- afterWorkspaceDependencyRemoval: async (e, t, r) => {
- if ('types' === r.scope) return;
- const a = l(r),
- o = s.structUtils.makeIdent('types', a);
- for (const t of s.Manifest.allDependencies) {
- void 0 !== e.manifest[t].get(o.identHash) &&
- e.manifest[t].delete(o.identHash);
- }
- },
- beforeWorkspacePacking: (e, t) => {
- t.publishConfig &&
- t.publishConfig.typings &&
- (t.typings = t.publishConfig.typings),
- t.publishConfig &&
- t.publishConfig.types &&
- (t.types = t.publishConfig.types);
- }
- }
- };
- },
- 469: (e, t, r) => {
- 'use strict';
- function s(e) {
- const t = [...e.caches],
- r = t.shift();
- return void 0 === r
- ? a()
- : {
- get: (e, a, o = { miss: () => Promise.resolve() }) =>
- r.get(e, a, o).catch(() => s({ caches: t }).get(e, a, o)),
- set: (e, a) =>
- r.set(e, a).catch(() => s({ caches: t }).set(e, a)),
- delete: (e) =>
- r.delete(e).catch(() => s({ caches: t }).delete(e)),
- clear: () => r.clear().catch(() => s({ caches: t }).clear())
- };
- }
- function a() {
- return {
- get: (e, t, r = { miss: () => Promise.resolve() }) =>
- t()
- .then((e) => Promise.all([e, r.miss(e)]))
- .then(([e]) => e),
- set: (e, t) => Promise.resolve(t),
- delete: (e) => Promise.resolve(),
- clear: () => Promise.resolve()
- };
- }
- r.r(t),
- r.d(t, {
- createFallbackableCache: () => s,
- createNullCache: () => a
- });
- },
- 712: (e, t, r) => {
- 'use strict';
- function s(e = { serializable: !0 }) {
- let t = {};
- return {
- get(r, s, a = { miss: () => Promise.resolve() }) {
- const o = JSON.stringify(r);
- if (o in t)
- return Promise.resolve(
- e.serializable ? JSON.parse(t[o]) : t[o]
- );
- const n = s(),
- i = (a && a.miss) || (() => Promise.resolve());
- return n.then((e) => i(e)).then(() => n);
- },
- set: (r, s) => (
- (t[JSON.stringify(r)] = e.serializable
- ? JSON.stringify(s)
- : s),
- Promise.resolve(s)
- ),
- delete: (e) => (delete t[JSON.stringify(e)], Promise.resolve()),
- clear: () => ((t = {}), Promise.resolve())
- };
- }
- r.r(t), r.d(t, { createInMemoryCache: () => s });
- },
- 223: (e, t, r) => {
- 'use strict';
- r.r(t),
- r.d(t, {
- addABTest: () => i,
- createAnalyticsClient: () => n,
- deleteABTest: () => c,
- getABTest: () => d,
- getABTests: () => l,
- stopABTest: () => u
- });
- var s = r(757),
- a = r(858),
- o = r(541);
- const n = (e) => {
- const t = e.region || 'us',
- r = (0, s.createAuth)(
- s.AuthMode.WithinHeaders,
- e.appId,
- e.apiKey
- ),
- o = (0, a.createTransporter)({
- hosts: [{ url: `analytics.${t}.algolia.com` }],
- ...e,
- headers: {
- ...r.headers(),
- 'content-type': 'application/json',
- ...e.headers
- },
- queryParameters: {
- ...r.queryParameters(),
- ...e.queryParameters
- }
- }),
- n = e.appId;
- return (0, s.addMethods)(
- { appId: n, transporter: o },
- e.methods
- );
- },
- i = (e) => (t, r) =>
- e.transporter.write(
- { method: o.N.Post, path: '2/abtests', data: t },
- r
- ),
- c = (e) => (t, r) =>
- e.transporter.write(
- {
- method: o.N.Delete,
- path: (0, s.encode)('2/abtests/%s', t)
- },
- r
- ),
- d = (e) => (t, r) =>
- e.transporter.read(
- { method: o.N.Get, path: (0, s.encode)('2/abtests/%s', t) },
- r
- ),
- l = (e) => (t) =>
- e.transporter.read({ method: o.N.Get, path: '2/abtests' }, t),
- u = (e) => (t, r) =>
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)('2/abtests/%s/stop', t)
- },
- r
- );
- },
- 757: (e, t, r) => {
- 'use strict';
- function s(e, t, r) {
- const s = {
- 'x-algolia-api-key': r,
- 'x-algolia-application-id': t
- };
- return {
- headers: () => (e === u.WithinHeaders ? s : {}),
- queryParameters: () => (e === u.WithinQueryParameters ? s : {})
- };
- }
- function a(e) {
- let t = 0;
- const r = () => (
- t++,
- new Promise((s) => {
- setTimeout(() => {
- s(e(r));
- }, Math.min(100 * t, 1e3));
- })
- );
- return e(r);
- }
- function o(e, t = (e, t) => Promise.resolve()) {
- return Object.assign(e, {
- wait: (r) =>
- o(e.then((e) => Promise.all([t(e, r), e])).then((e) => e[1]))
- });
- }
- function n(e) {
- let t = e.length - 1;
- for (; t > 0; t--) {
- const r = Math.floor(Math.random() * (t + 1)),
- s = e[t];
- (e[t] = e[r]), (e[r] = s);
- }
- return e;
- }
- function i(e, t) {
- return (
- Object.keys(void 0 !== t ? t : {}).forEach((r) => {
- e[r] = t[r](e);
- }),
- e
- );
- }
- function c(e, ...t) {
- let r = 0;
- return e.replace(/%s/g, () => encodeURIComponent(t[r++]));
- }
- r.r(t),
- r.d(t, {
- AuthMode: () => u,
- addMethods: () => i,
- createAuth: () => s,
- createRetryablePromise: () => a,
- createWaitablePromise: () => o,
- destroy: () => l,
- encode: () => c,
- shuffle: () => n,
- version: () => d
- });
- const d = '4.2.0',
- l = (e) => () => e.transporter.requester.destroy(),
- u = { WithinQueryParameters: 0, WithinHeaders: 1 };
- },
- 103: (e, t, r) => {
- 'use strict';
- r.r(t),
- r.d(t, {
- createRecommendationClient: () => n,
- getPersonalizationStrategy: () => i,
- setPersonalizationStrategy: () => c
- });
- var s = r(757),
- a = r(858),
- o = r(541);
- const n = (e) => {
- const t = e.region || 'us',
- r = (0, s.createAuth)(
- s.AuthMode.WithinHeaders,
- e.appId,
- e.apiKey
- ),
- o = (0, a.createTransporter)({
- hosts: [{ url: `recommendation.${t}.algolia.com` }],
- ...e,
- headers: {
- ...r.headers(),
- 'content-type': 'application/json',
- ...e.headers
- },
- queryParameters: {
- ...r.queryParameters(),
- ...e.queryParameters
- }
- });
- return (0, s.addMethods)(
- { appId: e.appId, transporter: o },
- e.methods
- );
- },
- i = (e) => (t) =>
- e.transporter.read(
- { method: o.N.Get, path: '1/strategies/personalization' },
- t
- ),
- c = (e) => (t, r) =>
- e.transporter.write(
- {
- method: o.N.Post,
- path: '1/strategies/personalization',
- data: t
- },
- r
- );
- },
- 790: (e, t, r) => {
- 'use strict';
- r.r(t),
- r.d(t, {
- ApiKeyACLEnum: () => xe,
- BatchActionEnum: () => we,
- ScopeEnum: () => Ae,
- StrategyEnum: () => qe,
- SynonymEnum: () => Re,
- addApiKey: () => p,
- assignUserID: () => m,
- assignUserIDs: () => h,
- batch: () => H,
- browseObjects: () => K,
- browseRules: () => B,
- browseSynonyms: () => z,
- chunkedBatch: () => V,
- clearObjects: () => $,
- clearRules: () => L,
- clearSynonyms: () => Q,
- copyIndex: () => y,
- copyRules: () => g,
- copySettings: () => b,
- copySynonyms: () => f,
- createBrowsablePromise: () => i,
- createMissingObjectIDError: () => d,
- createObjectNotFoundError: () => l,
- createSearchClient: () => c,
- createValidUntilNotFoundError: () => u,
- deleteApiKey: () => P,
- deleteBy: () => J,
- deleteIndex: () => _,
- deleteObject: () => X,
- deleteObjects: () => Y,
- deleteRule: () => Z,
- deleteSynonym: () => ee,
- exists: () => te,
- findObject: () => re,
- generateSecuredApiKey: () => I,
- getApiKey: () => O,
- getLogs: () => j,
- getObject: () => se,
- getObjectPosition: () => ae,
- getObjects: () => oe,
- getRule: () => ne,
- getSecuredApiKeyRemainingValidity: () => v,
- getSettings: () => ie,
- getSynonym: () => ce,
- getTask: () => de,
- getTopUserIDs: () => N,
- getUserID: () => S,
- hasPendingMappings: () => D,
- initIndex: () => x,
- listApiKeys: () => w,
- listClusters: () => A,
- listIndices: () => q,
- listUserIDs: () => R,
- moveIndex: () => T,
- multipleBatch: () => k,
- multipleGetObjects: () => U,
- multipleQueries: () => C,
- multipleSearchForFacetValues: () => E,
- partialUpdateObject: () => le,
- partialUpdateObjects: () => ue,
- removeUserID: () => M,
- replaceAllObjects: () => pe,
- replaceAllRules: () => me,
- replaceAllSynonyms: () => he,
- restoreApiKey: () => W,
- saveObject: () => ye,
- saveObjects: () => ge,
- saveRule: () => be,
- saveRules: () => fe,
- saveSynonym: () => Pe,
- saveSynonyms: () => Ie,
- search: () => Oe,
- searchForFacetValues: () => je,
- searchRules: () => ve,
- searchSynonyms: () => Ne,
- searchUserIDs: () => F,
- setSettings: () => Se,
- updateApiKey: () => G,
- waitTask: () => De
- });
- var s = r(757),
- a = r(858),
- o = r(541);
- const n = require('crypto');
- function i(e) {
- const t = (r) =>
- e.request(r).then((s) => {
- if ((void 0 !== e.batch && e.batch(s.hits), !e.shouldStop(s)))
- return s.cursor
- ? t({ cursor: s.cursor })
- : t({ page: (r.page || 0) + 1 });
- });
- return t({});
- }
- const c = (e) => {
- const t = e.appId,
- r = (0, s.createAuth)(
- void 0 !== e.authMode ? e.authMode : s.AuthMode.WithinHeaders,
- t,
- e.apiKey
- ),
- o = (0, a.createTransporter)({
- hosts: [
- { url: t + '-dsn.algolia.net', accept: a.CallEnum.Read },
- { url: t + '.algolia.net', accept: a.CallEnum.Write }
- ].concat(
- (0, s.shuffle)([
- { url: t + '-1.algolianet.com' },
- { url: t + '-2.algolianet.com' },
- { url: t + '-3.algolianet.com' }
- ])
- ),
- ...e,
- headers: {
- ...r.headers(),
- 'content-type': 'application/x-www-form-urlencoded',
- ...e.headers
- },
- queryParameters: {
- ...r.queryParameters(),
- ...e.queryParameters
- }
- }),
- n = {
- transporter: o,
- appId: t,
- addAlgoliaAgent(e, t) {
- o.userAgent.add({ segment: e, version: t });
- },
- clearCache: () =>
- Promise.all([
- o.requestsCache.clear(),
- o.responsesCache.clear()
- ]).then(() => {})
- };
- return (0, s.addMethods)(n, e.methods);
- };
- function d() {
- return {
- name: 'MissingObjectIDError',
- message:
- "All objects must have an unique objectID (like a primary key) to be valid. Algolia is also able to generate objectIDs automatically but *it's not recommended*. To do it, use the `{'autoGenerateObjectIDIfNotExist': true}` option."
- };
- }
- function l() {
- return {
- name: 'ObjectNotFoundError',
- message: 'Object not found.'
- };
- }
- function u() {
- return {
- name: 'ValidUntilNotFoundError',
- message: 'ValidUntil not found in given secured api key.'
- };
- }
- const p = (e) => (t, r) => {
- const { queryParameters: a, ...n } = r || {},
- i = {
- acl: t,
- ...(void 0 !== a ? { queryParameters: a } : {})
- };
- return (0, s.createWaitablePromise)(
- e.transporter.write(
- { method: o.N.Post, path: '1/keys', data: i },
- n
- ),
- (t, r) =>
- (0, s.createRetryablePromise)((s) =>
- O(e)(t.key, r).catch((e) => {
- if (404 !== e.status) throw e;
- return s();
- })
- )
- );
- },
- m = (e) => (t, r, s) => {
- const n = (0, a.createMappedRequestOptions)(s);
- return (
- (n.queryParameters['X-Algolia-User-ID'] = t),
- e.transporter.write(
- {
- method: o.N.Post,
- path: '1/clusters/mapping',
- data: { cluster: r }
- },
- n
- )
- );
- },
- h = (e) => (t, r, s) =>
- e.transporter.write(
- {
- method: o.N.Post,
- path: '1/clusters/mapping/batch',
- data: { users: t, cluster: r }
- },
- s
- ),
- y = (e) => (t, r, a) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)('1/indexes/%s/operation', t),
- data: { operation: 'copy', destination: r }
- },
- a
- ),
- (r, s) =>
- x(e)(t, { methods: { waitTask: De } }).waitTask(r.taskID, s)
- ),
- g = (e) => (t, r, s) => y(e)(t, r, { ...s, scope: [Ae.Rules] }),
- b = (e) => (t, r, s) =>
- y(e)(t, r, { ...s, scope: [Ae.Settings] }),
- f = (e) => (t, r, s) =>
- y(e)(t, r, { ...s, scope: [Ae.Synonyms] }),
- P = (e) => (t, r) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- { method: o.N.Delete, path: (0, s.encode)('1/keys/%s', t) },
- r
- ),
- (r, a) =>
- (0, s.createRetryablePromise)((r) =>
- O(e)(t, a)
- .then(r)
- .catch((e) => {
- if (404 !== e.status) throw e;
- })
- )
- ),
- I = () => (e, t) => {
- const r = (0, a.serializeQueryParameters)(t),
- s = (0, n.createHmac)('sha256', e).update(r).digest('hex');
- return Buffer.from(s + r).toString('base64');
- },
- O = (e) => (t, r) =>
- e.transporter.read(
- { method: o.N.Get, path: (0, s.encode)('1/keys/%s', t) },
- r
- ),
- j = (e) => (t) =>
- e.transporter.read({ method: o.N.Get, path: '1/logs' }, t),
- v = () => (e) => {
- const t = Buffer.from(e, 'base64')
- .toString('ascii')
- .match(/validUntil=(\d+)/);
- if (null === t)
- throw {
- name: 'ValidUntilNotFoundError',
- message: 'ValidUntil not found in given secured api key.'
- };
- return (
- parseInt(t[1], 10) - Math.round(new Date().getTime() / 1e3)
- );
- },
- N = (e) => (t) =>
- e.transporter.read(
- { method: o.N.Get, path: '1/clusters/mapping/top' },
- t
- ),
- S = (e) => (t, r) =>
- e.transporter.read(
- {
- method: o.N.Get,
- path: (0, s.encode)('1/clusters/mapping/%s', t)
- },
- r
- ),
- D = (e) => (t) => {
- const { retrieveMappings: r, ...s } = t || {};
- return (
- !0 === r && (s.getClusters = !0),
- e.transporter.read(
- { method: o.N.Get, path: '1/clusters/mapping/pending' },
- s
- )
- );
- },
- x =
- (e) =>
- (t, r = {}) => {
- const a = {
- transporter: e.transporter,
- appId: e.appId,
- indexName: t
- };
- return (0, s.addMethods)(a, r.methods);
- },
- w = (e) => (t) =>
- e.transporter.read({ method: o.N.Get, path: '1/keys' }, t),
- A = (e) => (t) =>
- e.transporter.read({ method: o.N.Get, path: '1/clusters' }, t),
- q = (e) => (t) =>
- e.transporter.read({ method: o.N.Get, path: '1/indexes' }, t),
- R = (e) => (t) =>
- e.transporter.read(
- { method: o.N.Get, path: '1/clusters/mapping' },
- t
- ),
- T = (e) => (t, r, a) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)('1/indexes/%s/operation', t),
- data: { operation: 'move', destination: r }
- },
- a
- ),
- (r, s) =>
- x(e)(t, { methods: { waitTask: De } }).waitTask(r.taskID, s)
- ),
- k = (e) => (t, r) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: '1/indexes/*/batch',
- data: { requests: t }
- },
- r
- ),
- (t, r) =>
- Promise.all(
- Object.keys(t.taskID).map((s) =>
- x(e)(s, { methods: { waitTask: De } }).waitTask(
- t.taskID[s],
- r
- )
- )
- )
- ),
- U = (e) => (t, r) =>
- e.transporter.read(
- {
- method: o.N.Post,
- path: '1/indexes/*/objects',
- data: { requests: t }
- },
- r
- ),
- C = (e) => (t, r) => {
- const s = t.map((e) => ({
- ...e,
- params: (0, a.serializeQueryParameters)(e.params || {})
- }));
- return e.transporter.read(
- {
- method: o.N.Post,
- path: '1/indexes/*/queries',
- data: { requests: s },
- cacheable: !0
- },
- r
- );
- },
- E = (e) => (t, r) =>
- Promise.all(
- t.map((t) => {
- const { facetName: s, facetQuery: a, ...o } = t.params;
- return x(e)(t.indexName, {
- methods: { searchForFacetValues: je }
- }).searchForFacetValues(s, a, { ...r, ...o });
- })
- ),
- M = (e) => (t, r) => {
- const s = (0, a.createMappedRequestOptions)(r);
- return (
- (s.queryParameters['X-Algolia-User-ID'] = t),
- e.transporter.write(
- { method: o.N.Delete, path: '1/clusters/mapping' },
- s
- )
- );
- },
- W = (e) => (t, r) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)('1/keys/%s/restore', t)
- },
- r
- ),
- (r, a) =>
- (0, s.createRetryablePromise)((r) =>
- O(e)(t, a).catch((e) => {
- if (404 !== e.status) throw e;
- return r();
- })
- )
- ),
- F = (e) => (t, r) =>
- e.transporter.read(
- {
- method: o.N.Post,
- path: '1/clusters/mapping/search',
- data: { query: t }
- },
- r
- ),
- G = (e) => (t, r) => {
- const a = Object.assign({}, r),
- { queryParameters: n, ...i } = r || {},
- c = n ? { queryParameters: n } : {},
- d = [
- 'acl',
- 'indexes',
- 'referers',
- 'restrictSources',
- 'queryParameters',
- 'description',
- 'maxQueriesPerIPPerHour',
- 'maxHitsPerQuery'
- ];
- return (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Put,
- path: (0, s.encode)('1/keys/%s', t),
- data: c
- },
- i
- ),
- (r, o) =>
- (0, s.createRetryablePromise)((r) =>
- O(e)(t, o).then((e) =>
- ((e) =>
- Object.keys(a)
- .filter((e) => -1 !== d.indexOf(e))
- .every((t) => e[t] === a[t]))(e)
- ? Promise.resolve()
- : r()
- )
- )
- );
- },
- H = (e) => (t, r) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)('1/indexes/%s/batch', e.indexName),
- data: { requests: t }
- },
- r
- ),
- (t, r) => De(e)(t.taskID, r)
- ),
- K = (e) => (t) =>
- i({
- ...t,
- shouldStop: (e) => void 0 === e.cursor,
- request: (r) =>
- e.transporter.read(
- {
- method: o.N.Post,
- path: (0, s.encode)('1/indexes/%s/browse', e.indexName),
- data: r
- },
- t
- )
- }),
- B = (e) => (t) => {
- const r = { hitsPerPage: 1e3, ...t };
- return i({
- ...r,
- shouldStop: (e) => e.hits.length < r.hitsPerPage,
- request: (t) =>
- ve(e)('', { ...r, ...t }).then((e) => ({
- ...e,
- hits: e.hits.map((e) => (delete e._highlightResult, e))
- }))
- });
- },
- z = (e) => (t) => {
- const r = { hitsPerPage: 1e3, ...t };
- return i({
- ...r,
- shouldStop: (e) => e.hits.length < r.hitsPerPage,
- request: (t) =>
- Ne(e)('', { ...r, ...t }).then((e) => ({
- ...e,
- hits: e.hits.map((e) => (delete e._highlightResult, e))
- }))
- });
- },
- V = (e) => (t, r, a) => {
- const { batchSize: o, ...n } = a || {},
- i = { taskIDs: [], objectIDs: [] },
- c = (s = 0) => {
- const a = [];
- let d;
- for (
- d = s;
- d < t.length && (a.push(t[d]), a.length !== (o || 1e3));
- d++
- );
- return 0 === a.length
- ? Promise.resolve(i)
- : H(e)(
- a.map((e) => ({ action: r, body: e })),
- n
- ).then(
- (e) => (
- (i.objectIDs = i.objectIDs.concat(e.objectIDs)),
- i.taskIDs.push(e.taskID),
- d++,
- c(d)
- )
- );
- };
- return (0, s.createWaitablePromise)(c(), (t, r) =>
- Promise.all(t.taskIDs.map((t) => De(e)(t, r)))
- );
- },
- $ = (e) => (t) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)('1/indexes/%s/clear', e.indexName)
- },
- t
- ),
- (t, r) => De(e)(t.taskID, r)
- ),
- L = (e) => (t) => {
- const { forwardToReplicas: r, ...n } = t || {},
- i = (0, a.createMappedRequestOptions)(n);
- return (
- r && (i.queryParameters.forwardToReplicas = 1),
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)(
- '1/indexes/%s/rules/clear',
- e.indexName
- )
- },
- i
- ),
- (t, r) => De(e)(t.taskID, r)
- )
- );
- },
- Q = (e) => (t) => {
- const { forwardToReplicas: r, ...n } = t || {},
- i = (0, a.createMappedRequestOptions)(n);
- return (
- r && (i.queryParameters.forwardToReplicas = 1),
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)(
- '1/indexes/%s/synonyms/clear',
- e.indexName
- )
- },
- i
- ),
- (t, r) => De(e)(t.taskID, r)
- )
- );
- },
- J = (e) => (t, r) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Post,
- path: (0, s.encode)(
- '1/indexes/%s/deleteByQuery',
- e.indexName
- ),
- data: t
- },
- r
- ),
- (t, r) => De(e)(t.taskID, r)
- ),
- _ = (e) => (t) =>
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Delete,
- path: (0, s.encode)('1/indexes/%s', e.indexName)
- },
- t
- ),
- (t, r) => De(e)(t.taskID, r)
- ),
- X = (e) => (t, r) =>
- (0, s.createWaitablePromise)(
- Y(e)([t], r).then((e) => ({ taskID: e.taskIDs[0] })),
- (t, r) => De(e)(t.taskID, r)
- ),
- Y = (e) => (t, r) => {
- const s = t.map((e) => ({ objectID: e }));
- return V(e)(s, we.DeleteObject, r);
- },
- Z = (e) => (t, r) => {
- const { forwardToReplicas: n, ...i } = r || {},
- c = (0, a.createMappedRequestOptions)(i);
- return (
- n && (c.queryParameters.forwardToReplicas = 1),
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Delete,
- path: (0, s.encode)(
- '1/indexes/%s/rules/%s',
- e.indexName,
- t
- )
- },
- c
- ),
- (t, r) => De(e)(t.taskID, r)
- )
- );
- },
- ee = (e) => (t, r) => {
- const { forwardToReplicas: n, ...i } = r || {},
- c = (0, a.createMappedRequestOptions)(i);
- return (
- n && (c.queryParameters.forwardToReplicas = 1),
- (0, s.createWaitablePromise)(
- e.transporter.write(
- {
- method: o.N.Delete,
- path: (0, s.encode)(
- '1/indexes/%s/synonyms/%s',
- e.indexName,
- t
- )
- },
- c
- ),
- (t, r) => De(e)(t.taskID, r)
- )
- );
- },
- te = (e) => (t) =>
- ie(e)(t)
- .then(() => !0)
- .catch((e) => {
- if (404 !== e.status) throw e;
- return !1;
- }),
- re = (e) => (t, r) => {
- const { query: s, paginate: a, ...o } = r || {};
- let n = 0;
- const i = () =>
- Oe(e)(s || '', { ...o, page: n }).then((e) => {
- for (const [r, s] of Object.entries(e.hits))
- if (t(s))
- return {
- object: s,
- position: parseInt(r, 10),
- page: n
- };
- if ((n++, !1 === a || n >= e.nbPages))
- throw {
- name: 'ObjectNotFoundError',
- message: 'Object not found.'
- };
- return i();
- });
- return i();
- },
- se = (e) => (t, r) =>
- e.transporter.read(
- {
- method: o.N.Get,
- path: (0, s.encode)('1/indexes/%s/%s', e.indexName, t)
- },
- r
- ),
- ae = () => (e, t) => {
- for (const [r, s] of Object.entries(e.hits))
- if (s.objectID === t) return parseInt(r, 10);
- return -1;
- },
- oe = (e) => (t, r) => {
- const { attributesToRetrieve: s, ...a } = r || {},
- n = t.map((t) => ({
- indexName: e.indexName,
- objectID: t,
- ...(s ? { attributesToRetrieve: s } : {})
- }));
- return e.transporter.read(
- {
- method: o.N.Post,
- path: '1/indexes/*/objects',
- data: { requests: n }
- },
- a
- );
- },
- ne = (e) => (t, r) =>
- e.transporter.read(
- {
- method: o.N.Get,
- path: (0, s.encode)('1/indexes/%s/rules/%s', e.indexName, t)
- },
- r
- ),
- ie = (e) => (t) =>
- e.transporter.read(
- {
- method: o.N.Get,
- path: (0, s.encode)('1/indexes/%s/settings', e.indexName),
- data: { getVersion: 2 }
- },
- t
- ),
- ce = (e) => (t, r) =>
- e.transporter.read(
- {