https://www.servustv.com/_next/static/chunks/51c9685e-e4fd95157594…=a88bcd87fcabaacaffdef61f3960c6a40b749c35

1"use strict";(self.webpackChunk_N_E=self.webpackChunk_N_E||[]).push([[501],{22663:(e,t,r)=>{Object.defineProperty(t,"__esModule",{value:!0}),t.CacheDataClient=void 0;let a=r(72125),n=r(42378),s=r(83145),i=r(91313),o=r(1543),c=r(52725),l=r(89966),h=r(99851),d=r(57740),u=r(9837),S=r(74017),g=r(84055);class v{constructor(e){this.logger=e.configuration.getLoggerFactory().getLogger(this),this.cacheServiceErrorMapper=new s.CacheServiceErrorMapper(e.configuration.getThrowOnErrors()),this.logger.debug(`Creating data client using endpoint: '${(0,l.getWebCacheEndpoint)(e.credentialProvider)}`),this.deadlineMillis=e.configuration.getTransportStrategy().getGrpcConfig().getDeadlineMillis(),this.defaultTtlSeconds=e.defaultTtlSeconds,this.clientMetadataProvider=new h.ClientMetadataProvider({authToken:e.credentialProvider.getAuthToken(),readConcern:e.configuration.getReadConcern(),clientType:"cache"}),this.clientWrapper=new a.cache.ScsClient((0,l.getWebCacheEndpoint)(e.credentialProvider),null,{streamInterceptors:[(0,d.middlewaresInterceptor)(e.configuration.getLoggerFactory(),e.configuration.getMiddlewares(),{})]}),this.textEncoder=new TextEncoder}close(){this.logger.debug("Closing cache control client")}collectionTtlOrDefaultMilliseconds(e){var t;return null!=(t=e.ttlMilliseconds())?t:(0,S.secondsToMilliseconds)(this.defaultTtlSeconds)}ttlOrDefaultMilliseconds(e){let t=null!=e?e:this.defaultTtlSeconds;return(0,S.secondsToMilliseconds)(t)}async get(e,t){try{(0,c.validateCacheName)(e)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheGet.Error(e))}this.logger.trace(`Issuing 'get' request; key: ${t.toString()}`);let r=await this.sendGet(e,(0,l.convertToB64String)(t));return this.logger.trace(`'get' request result: ${r.toString()}`),r}async sendGet(e,t){let r=new o._GetRequest;return r.setCacheKey(t),await new Promise((t,a)=>{this.clientWrapper.get(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{if(r)switch(r.getResult()){case o.ECacheResult.MISS:t(new n.CacheGet.Miss);break;case o.ECacheResult.HIT:t(new n.CacheGet.Hit(r.getCacheBody_asU8()));break;case o.ECacheResult.INVALID:case o.ECacheResult.OK:t(new n.CacheGet.Error(new n.UnknownError(r.getMessage())));break;default:t(new n.CacheGet.Error(new n.UnknownError("An unknown error occurred: "+r.getMessage())))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheGet.Error(e),resolveFn:t,rejectFn:a})})})}async getWithHash(e,t){try{(0,c.validateCacheName)(e)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new g.CacheGetWithHash.Error(e))}this.logger.trace(`Issuing 'getWithHash' request; key: ${t.toString()}`);let r=await this.sendGetWithHash(e,(0,l.convertToB64String)(t));return this.logger.trace(`'getWithHash' request result: ${r.toString()}`),r}async sendGetWithHash(e,t){let r=new o._GetWithHashRequest;return r.setCacheKey(t),await new Promise((t,a)=>{this.clientWrapper.getWithHash(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{(null==r?void 0:r.getMissing())&&t(new g.CacheGetWithHash.Miss);let s=null==r?void 0:r.getFound();if(s&&s.getValue()&&s.getHash()){let e=s.getValue(),r=s.getHash();t(new g.CacheGetWithHash.Hit(this.convertToUint8Array(e),this.convertToUint8Array(r)))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheItemGetTtl.Error(e),resolveFn:t,rejectFn:a})})})}async set(e,t,r,a){try{(0,c.validateCacheName)(e),(null==a?void 0:a.ttl)!==void 0&&(0,c.validateTtlSeconds)(null==a?void 0:a.ttl)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSet.Error(e))}let s=(null==a?void 0:a.ttl)||this.defaultTtlSeconds;return this.logger.trace(`Issuing 'set' request; key: ${t.toString()}, value length: ${r.length}, ttl: ${s.toString()}`),await this.sendSet(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),s)}async sendSet(e,t,r,a){let s=new o._SetRequest;return s.setCacheKey(t),s.setCacheBody(r),s.setTtlMilliseconds((0,S.secondsToMilliseconds)(a)),await new Promise((t,r)=>{this.clientWrapper.set(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheSet.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSet.Error(e),resolveFn:t,rejectFn:r})})})}async setWithHash(e,t,r,a){try{(0,c.validateCacheName)(e),(null==a?void 0:a.ttl)!==void 0&&(0,c.validateTtlSeconds)(null==a?void 0:a.ttl)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new g.CacheSetWithHash.Error(e))}let n=(null==a?void 0:a.ttl)||this.defaultTtlSeconds;return this.logger.trace(`Issuing 'setWithHash' request; key: ${t.toString()}, value length: ${r.length}, ttl: ${n.toString()}`),await this.sendSetWithHash(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),n)}async sendSetWithHash(e,t,r,a){let s=new o._SetIfHashRequest;return s.setCacheKey(t),s.setCacheBody(r),s.setTtlMilliseconds((0,S.secondsToMilliseconds)(a)),s.setUnconditional(new u.Unconditional),await new Promise((t,r)=>{this.clientWrapper.setIfHash(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfHashResponse.ResultCase.STORED:{let e=a.getStored();if(e){let r=e.getNewHash_asU8();t(new g.CacheSetWithHash.Stored(r))}break}case o._SetIfHashResponse.ResultCase.NOT_STORED:t(new g.CacheSetWithHash.NotStored);break;default:t(new g.CacheSetWithHash.Error(new n.UnknownError("SetWithHash responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new g.CacheSetWithHash.Error(e),resolveFn:t,rejectFn:r})})})}async setIfNotExists(e,t,r,a){var s;try{(0,c.validateCacheName)(e),void 0!==a&&(0,c.validateTtlSeconds)(a)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfNotExists.Error(e))}this.logger.trace(`Issuing 'setIfNotExists' request; key: ${t.toString()}, field: ${r.toString()}, ttlSeconds: ${null!=(s=null==a?void 0:a.toString())?s:"null"}`);let i=await this.sendSetIfNotExists(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),this.ttlOrDefaultMilliseconds(a));return this.logger.trace(`'setIfNotExists' request result: ${i.toString()}`),i}async sendSetIfNotExists(e,t,r,a){let s=new o._SetIfRequest;return s.setCacheKey(t),s.setCacheBody(r),s.setTtlMilliseconds(a),s.setAbsent(new u.Absent),await new Promise((t,r)=>{this.clientWrapper.setIf(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfResponse.ResultCase.STORED:t(new n.CacheSetIfNotExists.Stored);break;case o._SetIfResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfNotExists.NotStored);break;default:t(new n.CacheSetIfNotExists.Error(new n.UnknownError("SetIfNotExists responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfNotExists.Error(e),resolveFn:t,rejectFn:r})})})}async setIfAbsent(e,t,r,a){var s;let i=null==a?void 0:a.ttl;try{(0,c.validateCacheName)(e),void 0!==i&&(0,c.validateTtlSeconds)(i)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfAbsent.Error(e))}this.logger.trace(`Issuing 'setIfAbsent' request; key: ${t.toString()}, field: ${r.toString()}, ttlSeconds: ${null!=(s=null==i?void 0:i.toString())?s:"null"}`);let o=await this.sendSetIfAbsent(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),this.ttlOrDefaultMilliseconds(i));return this.logger.trace(`'setIfAbsent' request result: ${o.toString()}`),o}async sendSetIfAbsent(e,t,r,a){let s=new o._SetIfRequest;return s.setCacheKey(t),s.setCacheBody(r),s.setTtlMilliseconds(a),s.setAbsent(new u.Absent),await new Promise((t,r)=>{this.clientWrapper.setIf(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfResponse.ResultCase.STORED:t(new n.CacheSetIfAbsent.Stored);break;case o._SetIfResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfAbsent.NotStored);break;default:t(new n.CacheSetIfAbsent.Error(new n.UnknownError("SetIfAbsent responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfAbsent.Error(e),resolveFn:t,rejectFn:r})})})}async setIfPresent(e,t,r,a){var s;try{(0,c.validateCacheName)(e),void 0!==a&&(0,c.validateTtlSeconds)(a)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfPresent.Error(e))}this.logger.trace(`Issuing 'setIfPresent' request; key: ${t.toString()}, field: ${r.toString()}, ttlSeconds: ${null!=(s=null==a?void 0:a.toString())?s:"null"}`);let i=await this.sendSetIfPresent(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),this.ttlOrDefaultMilliseconds(a));return this.logger.trace(`'setIfPresent' request result: ${i.toString()}`),i}async sendSetIfPresent(e,t,r,a){let s=new o._SetIfRequest;return s.setCacheKey(t),s.setCacheBody(r),s.setTtlMilliseconds(a),s.setPresent(new u.Present),await new Promise((t,r)=>{this.clientWrapper.setIf(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfResponse.ResultCase.STORED:t(new n.CacheSetIfPresent.Stored);break;case o._SetIfResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfPresent.NotStored);break;default:t(new n.CacheSetIfPresent.Error(new n.UnknownError("SetIfPresent responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfPresent.Error(e),resolveFn:t,rejectFn:r})})})}async setIfEqual(e,t,r,a,s){var i;try{(0,c.validateCacheName)(e),void 0!==s&&(0,c.validateTtlSeconds)(s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfEqual.Error(e))}this.logger.trace(`Issuing 'setIfEqual' request; key: ${t.toString()}, field: ${r.toString()}, ttlSeconds: ${null!=(i=null==s?void 0:s.toString())?i:"null"}`);let o=await this.sendSetIfEqual(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.ttlOrDefaultMilliseconds(s));return this.logger.trace(`'setIfEqual' request result: ${o.toString()}`),o}async sendSetIfEqual(e,t,r,a,s){let i=new o._SetIfRequest;return i.setCacheKey(t),i.setCacheBody(r),i.setTtlMilliseconds(s),i.setEqual(new u.Equal().setValueToCheck(a)),await new Promise((t,r)=>{this.clientWrapper.setIf(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfResponse.ResultCase.STORED:t(new n.CacheSetIfEqual.Stored);break;case o._SetIfResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfEqual.NotStored);break;default:t(new n.CacheSetIfEqual.Error(new n.UnknownError("SetIfEqual responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfEqual.Error(e),resolveFn:t,rejectFn:r})})})}async setIfNotEqual(e,t,r,a,s){var i;try{(0,c.validateCacheName)(e),void 0!==s&&(0,c.validateTtlSeconds)(s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfNotEqual.Error(e))}this.logger.trace(`Issuing 'setIfNotEqual' request; key: ${t.toString()}, field: ${r.toString()}, ttlSeconds: ${null!=(i=null==s?void 0:s.toString())?i:"null"}`);let o=await this.sendSetIfNotEqual(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.ttlOrDefaultMilliseconds(s));return this.logger.trace(`'setIfNotEqual' request result: ${o.toString()}`),o}async sendSetIfNotEqual(e,t,r,a,s){let i=new o._SetIfRequest;return i.setCacheKey(t),i.setCacheBody(r),i.setTtlMilliseconds(s),i.setNotEqual(new u.NotEqual().setValueToCheck(a)),await new Promise((t,r)=>{this.clientWrapper.setIf(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfResponse.ResultCase.STORED:t(new n.CacheSetIfNotEqual.Stored);break;case o._SetIfResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfNotEqual.NotStored);break;default:t(new n.CacheSetIfNotEqual.Error(new n.UnknownError("SetIfNotEqual responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfNotEqual.Error(e),resolveFn:t,rejectFn:r})})})}async setIfPresentAndNotEqual(e,t,r,a,s){var i;try{(0,c.validateCacheName)(e),void 0!==s&&(0,c.validateTtlSeconds)(s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfPresentAndNotEqual.Error(e))}this.logger.trace(`Issuing 'setIfPresentAndNotEqual' request; key: ${t.toString()}, field: ${r.toString()}, ttlSeconds: ${null!=(i=null==s?void 0:s.toString())?i:"null"}`);let o=await this.sendSetIfPresentAndNotEqual(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.ttlOrDefaultMilliseconds(s));return this.logger.trace(`'setIfPresentAndNotEqual' request result: ${o.toString()}`),o}async sendSetIfPresentAndNotEqual(e,t,r,a,s){let i=new o._SetIfRequest;return i.setCacheKey(t),i.setCacheBody(r),i.setTtlMilliseconds(s),i.setPresentAndNotEqual(new u.PresentAndNotEqual().setValueToCheck(a)),await new Promise((t,r)=>{this.clientWrapper.setIf(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfResponse.ResultCase.STORED:t(new n.CacheSetIfPresentAndNotEqual.Stored);break;case o._SetIfResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfPresentAndNotEqual.NotStored);break;default:t(new n.CacheSetIfPresentAndNotEqual.Error(new n.UnknownError("SetIfPresentAndNotEqual responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfPresentAndNotEqual.Error(e),resolveFn:t,rejectFn:r})})})}async setIfAbsentOrEqual(e,t,r,a,s){var i;try{(0,c.validateCacheName)(e),void 0!==s&&(0,c.validateTtlSeconds)(s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfAbsentOrEqual.Error(e))}this.logger.trace(`Issuing 'setIfAbsentOrEqual' request; key: ${t.toString()}, field: ${r.toString()}, ttlSeconds: ${null!=(i=null==s?void 0:s.toString())?i:"null"}`);let o=await this.sendSetIfAbsentOrEqual(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.ttlOrDefaultMilliseconds(s));return this.logger.trace(`'setIfAbsentOrEqual' request result: ${o.toString()}`),o}async sendSetIfAbsentOrEqual(e,t,r,a,s){let i=new o._SetIfRequest;return i.setCacheKey(t),i.setCacheBody(r),i.setTtlMilliseconds(s),i.setAbsentOrEqual(new u.AbsentOrEqual().setValueToCheck(a)),await new Promise((t,r)=>{this.clientWrapper.setIf(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfResponse.ResultCase.STORED:t(new n.CacheSetIfAbsentOrEqual.Stored);break;case o._SetIfResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfAbsentOrEqual.NotStored);break;default:t(new n.CacheSetIfAbsentOrEqual.Error(new n.UnknownError("SetIfAbsentOrEqual responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfAbsentOrEqual.Error(e),resolveFn:t,rejectFn:r})})})}async setIfPresentAndHashEqual(e,t,r,a,s){var i;try{(0,c.validateCacheName)(e),void 0!==s&&(0,c.validateTtlSeconds)(s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfPresentAndHashEqual.Error(e))}this.logger.trace(`Issuing 'setIfPresentAndHashEqual' request; key: ${t.toString()}, value: ${r.toString()}, hashEqual: ${a.toString()}, ttlSeconds: ${null!=(i=null==s?void 0:s.toString())?i:"null"}`);let o=await this.sendSetIfPresentAndHashEqual(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.ttlOrDefaultMill

1iseconds(s));return this.logger.trace(`'setIfPresentAndHashEqual' request result: ${o.toString()}`),o}async sendSetIfPresentAndHashEqual(e,t,r,a,s){let i=new o._SetIfHashRequest;return i.setCacheKey(t),i.setCacheBody(r),i.setTtlMilliseconds(s),i.setPresentAndHashEqual(new u.PresentAndHashEqual().setHashToCheck(a)),await new Promise((t,r)=>{this.clientWrapper.setIfHash(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfHashResponse.ResultCase.STORED:{let e=a.getStored();if(e){let r=e.getNewHash_asU8();t(new n.CacheSetIfPresentAndHashEqual.Stored(r))}break}case o._SetIfHashResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfPresentAndHashEqual.NotStored);break;default:t(new n.CacheSetIfPresentAndHashEqual.Error(new n.UnknownError("SetIfPresentAndHashEqual responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfPresentAndHashEqual.Error(e),resolveFn:t,rejectFn:r})})})}async setIfPresentAndHashNotEqual(e,t,r,a,s){var i;try{(0,c.validateCacheName)(e),void 0!==s&&(0,c.validateTtlSeconds)(s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfPresentAndHashNotEqual.Error(e))}this.logger.trace(`Issuing 'setIfPresentAndHashNotEqual' request; key: ${t.toString()}, value: ${r.toString()}, hashNotEqual: ${a.toString()}, ttlSeconds: ${null!=(i=null==s?void 0:s.toString())?i:"null"}`);let o=await this.sendSetIfPresentAndHashNotEqual(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.ttlOrDefaultMilliseconds(s));return this.logger.trace(`'setIfPresentAndHashEqual' request result: ${o.toString()}`),o}async sendSetIfPresentAndHashNotEqual(e,t,r,a,s){let i=new o._SetIfHashRequest;return i.setCacheKey(t),i.setCacheBody(r),i.setTtlMilliseconds(s),i.setPresentAndNotHashEqual(new u.PresentAndNotHashEqual().setHashToCheck(a)),await new Promise((t,r)=>{this.clientWrapper.setIfHash(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfHashResponse.ResultCase.STORED:{let e=a.getStored();if(e){let r=e.getNewHash_asU8();t(new n.CacheSetIfPresentAndHashNotEqual.Stored(r))}break}case o._SetIfHashResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfPresentAndHashNotEqual.NotStored);break;default:t(new n.CacheSetIfPresentAndHashNotEqual.Error(new n.UnknownError("SetIfPresentAndHashNotEqual responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfPresentAndHashNotEqual.Error(e),resolveFn:t,rejectFn:r})})})}async setIfAbsentOrHashEqual(e,t,r,a,s){var i;try{(0,c.validateCacheName)(e),void 0!==s&&(0,c.validateTtlSeconds)(s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfAbsentOrHashEqual.Error(e))}this.logger.trace(`Issuing 'setIfAbsentOrHashEqual' request; key: ${t.toString()}, value: ${r.toString()}, hashEqual: ${a.toString()}, ttlSeconds: ${null!=(i=null==s?void 0:s.toString())?i:"null"}`);let o=await this.sendSetIfAbsentOrHashEqual(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.ttlOrDefaultMilliseconds(s));return this.logger.trace(`'setIfAbsentOrHashEqual' request result: ${o.toString()}`),o}async sendSetIfAbsentOrHashEqual(e,t,r,a,s){let i=new o._SetIfHashRequest;return i.setCacheKey(t),i.setCacheBody(r),i.setTtlMilliseconds(s),i.setAbsentOrHashEqual(new u.AbsentOrHashEqual().setHashToCheck(a)),await new Promise((t,r)=>{this.clientWrapper.setIfHash(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfHashResponse.ResultCase.STORED:{let e=a.getStored();if(e){let r=e.getNewHash_asU8();t(new n.CacheSetIfAbsentOrHashEqual.Stored(r))}break}case o._SetIfHashResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfAbsentOrHashEqual.NotStored);break;default:t(new n.CacheSetIfAbsentOrHashEqual.Error(new n.UnknownError("SetIfAbsentOrHashEqual responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfAbsentOrHashEqual.Error(e),resolveFn:t,rejectFn:r})})})}async setIfAbsentOrHashNotEqual(e,t,r,a,s){var i;try{(0,c.validateCacheName)(e),void 0!==s&&(0,c.validateTtlSeconds)(s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetIfAbsentOrHashNotEqual.Error(e))}this.logger.trace(`Issuing 'setIfAbsentOrHashNotEqual' request; key: ${t.toString()}, value: ${r.toString()}, hashNotEqual: ${a.toString()}, ttlSeconds: ${null!=(i=null==s?void 0:s.toString())?i:"null"}`);let o=await this.sendSetIfAbsentOrHashNotEqual(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.ttlOrDefaultMilliseconds(s));return this.logger.trace(`'setIfAbsentOrHashNotEqual' request result: ${o.toString()}`),o}async sendSetIfAbsentOrHashNotEqual(e,t,r,a,s){let i=new o._SetIfHashRequest;return i.setCacheKey(t),i.setCacheBody(r),i.setTtlMilliseconds(s),i.setAbsentOrNotHashEqual(new u.AbsentOrNotHashEqual().setHashToCheck(a)),await new Promise((t,r)=>{this.clientWrapper.setIfHash(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(a)switch(a.getResultCase()){case o._SetIfHashResponse.ResultCase.STORED:{let e=a.getStored();if(e){let r=e.getNewHash_asU8();t(new n.CacheSetIfAbsentOrHashNotEqual.Stored(r))}break}case o._SetIfHashResponse.ResultCase.NOT_STORED:t(new n.CacheSetIfAbsentOrHashNotEqual.NotStored);break;default:t(new n.CacheSetIfAbsentOrHashNotEqual.Error(new n.UnknownError("SetIfAbsentOrHashNotEqual responded with an unknown result")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetIfAbsentOrHashNotEqual.Error(e),resolveFn:t,rejectFn:r})})})}async getBatch(e,t){try{(0,c.validateCacheName)(e)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheGetBatch.Error(e))}this.logger.trace(`Issuing 'getBatch' request; keys: ${t.toString()}`);let r=await this.sendGetBatch(e,t);return this.logger.trace(`'getBatch' request result: ${r.toString()}`),r}async sendGetBatch(e,t){let r=[];for(let e of t){let t=new o._GetRequest;t.setCacheKey((0,l.convertToB64String)(e)),r.push(t)}let a=new o._GetBatchRequest;a.setItemsList(r);let s=this.clientWrapper.getBatch(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)});return await new Promise((e,r)=>{let a=[];s.on("data",e=>{switch(e.getResult()){case o.ECacheResult.HIT:a.push(new n.CacheGet.Hit(e.getCacheBody_asU8()));break;case o.ECacheResult.MISS:a.push(new n.CacheGet.Miss);break;default:a.push(new n.CacheGet.Error(new n.UnknownError(e.getMessage())))}}),s.on("end",()=>{e(new n.CacheGetBatch.Success(a,t.map(e=>this.convertToUint8Array(e))))}),s.on("error",t=>{this.cacheServiceErrorMapper.resolveOrRejectError({err:t,errorResponseFactoryFn:e=>new n.CacheGetBatch.Error(e),resolveFn:e,rejectFn:r})})})}async setBatch(e,t,r){try{(0,c.validateCacheName)(e),(null==r?void 0:r.ttl)!==void 0&&(0,c.validateTtlSeconds)(null==r?void 0:r.ttl)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetBatch.Error(e))}let a=(null==r?void 0:r.ttl)||this.defaultTtlSeconds,s=this.convertSetBatchElements(t,a);return this.logger.trace(`Issuing 'setBatch' request; items length: ${s.length}, ttl: ${a.toString()}`),await this.sendSetBatch(e,s)}async sendSetBatch(e,t){let r=[];for(let e of t){let[t,a,n]=e,s=new o._SetRequest;s.setCacheKey(t),s.setCacheBody(a),s.setTtlMilliseconds((0,S.secondsToMilliseconds)(n)),r.push(s)}let a=new o._SetBatchRequest;a.setItemsList(r);let s=this.clientWrapper.setBatch(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)});return await new Promise((e,t)=>

1{let r=[];s.on("data",e=>{e.getResult()===o.ECacheResult.OK?r.push(new n.CacheSet.Success):r.push(new n.CacheSet.Error(new n.UnknownError(e.getMessage())))}),s.on("end",()=>{e(new n.CacheSetBatch.Success(r))}),s.on("error",r=>{this.cacheServiceErrorMapper.resolveOrRejectError({err:r,errorResponseFactoryFn:e=>new n.CacheSetBatch.Error(e),resolveFn:e,rejectFn:t})})})}async delete(e,t){try{(0,c.validateCacheName)(e)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDelete.Error(e))}return this.logger.trace(`Issuing 'delete' request; key: ${t.toString()}`),await this.sendDelete(e,(0,l.convertToB64String)(t))}async sendDelete(e,t){let r=new o._DeleteRequest;return r.setCacheKey(t),await new Promise((t,a)=>{this.clientWrapper.delete(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{r?t(new n.CacheDelete.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDelete.Error(e),resolveFn:t,rejectFn:a})})})}async increment(e,t,r=1,a){var s;try{(0,c.validateCacheName)(e),void 0!==a&&(0,c.validateTtlSeconds)(a)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheIncrement.Error(e))}this.logger.trace(`Issuing 'increment' request; field: ${t.toString()}, amount : ${r}, ttl: ${null!=(s=null==a?void 0:a.toString())?s:"null"}`);let i=await this.sendIncrement(e,(0,l.convertToB64String)(t),r,this.ttlOrDefaultMilliseconds(a));return this.logger.trace(`'increment' request result: ${i.toString()}`),i}async sendIncrement(e,t,r=1,a){let s=new o._IncrementRequest;return s.setCacheKey(t),s.setAmount(r),s.setTtlMilliseconds(a),await new Promise((t,r)=>{this.clientWrapper.increment(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?a.getValue()?t(new n.CacheIncrement.Success(a.getValue())):t(new n.CacheIncrement.Success(0)):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheIncrement.Error(e),resolveFn:t,rejectFn:r})})})}async setFetch(e,t){try{(0,c.validateCacheName)(e),(0,c.validateSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetFetch.Error(e))}return await this.sendSetFetch(e,(0,l.convertToB64String)(t))}async sendSetFetch(e,t){let r=new o._SetFetchRequest;return r.setSetName(t),await new Promise((t,a)=>{this.clientWrapper.setFetch(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{let s=null==r?void 0:r.getFound();if(s&&s.getElementsList()){let e=s.getElementsList();t(new n.CacheSetFetch.Hit(this.convertArrayToUint8(e)))}else(null==r?void 0:r.getMissing())?t(new n.CacheSetFetch.Miss):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetFetch.Error(e),resolveFn:t,rejectFn:a})})})}async setAddElements(e,t,r,a=n.CollectionTtl.fromCacheTtl()){try{(0,c.validateCacheName)(e),(0,c.validateSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetAddElements.Error(e))}return await this.sendSetAddElements(e,(0,l.convertToB64String)(t),this.convertArrayToB64Strings(r),this.collectionTtlOrDefaultMilliseconds(a),a.refreshTtl())}async sendSetAddElements(e,t,r,a,s){let i=new o._SetUnionRequest;return i.setSetName(t),i.setElementsList(r),i.setTtlMilliseconds(a),i.setRefreshTtl(s),await new Promise((t,r)=>{this.clientWrapper.setUnion(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},e=>{e?this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetAddElements.Error(e),resolveFn:t,rejectFn:r}):t(new n.CacheSetAddElements.Success)})})}async setContainsElement(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetContainsElement.Error(e))}return await this.sendSetContainsElement(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r))}async sendSetContainsElement(e,t,r){let a=new o._SetContainsRequest;return a.setSetName(t),a.setElementsList([r]),await new Promise((t,r)=>{this.clientWrapper.setContains(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{var s;if(a)if(a.hasFound()){let e=a.getFound();((null==e?void 0:e.getContainsList())===void 0||(null==e?void 0:e.getContainsList().length)===0)&&t(new n.CacheSetContainsElement.Error(new n.UnknownError("SetContains responded with an empty list"))),t(new n.CacheSetContainsElement.Hit(null!=(s=null==e?void 0:e.getContainsList().at(0))&&s))}else t(new n.CacheSetContainsElement.Miss);else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetContainsElement.Error(e),resolveFn:t,rejectFn:r})})})}async setContainsElements(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetContainsElements.Error(e))}return await this.sendSetContainsElements(e,(0,l.convertToB64String)(t),this.convertArrayToB64Str

1ings(r),this.convertArrayToUint8(r))}async sendSetContainsElements(e,t,r,a){let s=new o._SetContainsRequest;return s.setSetName(t),s.setElementsList(r),await new Promise((t,r)=>{this.clientWrapper.setContains(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,s)=>{var i;if(s)if(s.hasFound()){let e=s.getFound();((null==e?void 0:e.getContainsList())===void 0||(null==e?void 0:e.getContainsList().length)===0)&&t(new n.CacheSetContainsElements.Error(new n.UnknownError("SetContains responded with an empty list"))),t(new n.CacheSetContainsElements.Hit(a,null!=(i=null==e?void 0:e.getContainsList())?i:[]))}else t(new n.CacheSetContainsElements.Miss);else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetContainsElements.Error(e),resolveFn:t,rejectFn:r})})})}async setRemoveElements(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetRemoveElements.Error(e))}return await this.sendSetRemoveElements(e,(0,l.convertToB64String)(t),this.convertArrayToB64Strings(r))}async sendSetRemoveElements(e,t,r){let a=new o._SetDifferenceRequest._Subtrahend,s=new o._SetDifferenceRequest._Subtrahend._Set;s.setElementsList(r),a.setSet(s);let i=new o._SetDifferenceRequest;return i.setSetName(t),i.setSubtrahend(a),await new Promise((t,r)=>{this.clientWrapper.setDifference(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},e=>{e?this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetRemoveElements.Error(e),resolveFn:t,rejectFn:r}):t(new n.CacheSetRemoveElements.Success)})})}async setSample(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateSetName)(t),(0,c.validateSetSampleLimit)(r)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSetSample.Error(e))}return await this.sendSetSample(e,(0,l.convertToB64String)(t),r)}async sendSetSample(e,t,r){let a=new o._SetSampleRequest;return a.setSetName(t),a.setLimit(r),await new Promise((t,r)=>{this.clientWrapper.setSample(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{let s=null==a?void 0:a.getFound();if(s&&s.getElementsList()){let e=s.getElementsList();t(new n.CacheSetSample.Hit(this.convertArrayToUint8(e)))}else(null==a?void 0:a.getMissing())?t(new n.CacheSetSample.Miss):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSetSample.Error(e),resolveFn:t,rejectFn:r})})})}async setPop(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateSetName)(t),(0,c.validateSetPopCount)(r)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new g.CacheSetPop.Error(e))}return await this.sendSetPop(e,(0,l.convertToB64String)(t),r)}async sendSetPop(e,t,r){let a=new o._SetPopRequest;return a.setSetName(t),a.setCount(r),await new Promise((t,r)=>{this.clientWrapper.setPop(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{let n=null==a?void 0:a.getFound();if(n&&n.getElementsList()){let e=n.getElementsList();t(new g.CacheSetPop.Hit(this.convertArrayToUint8(e)))}else(null==a?void 0:a.getMissing())?t(new g.CacheSetPop.Miss):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new g.CacheSetPop.Error(e),resolveFn:t,rejectFn:r})})})}async setLength(e,t){try{(0,c.validateCacheName)(e),(0,c.validateSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new g.CacheSetLength.Error(e))}this.logger.trace("Issuing 'setLength' request");let r=await this.sendSetLength(e,(0,l.convertToB64String)(t));return this.logger.trace("'setLength' request result: %s",(0,c.truncateString)(r.toString())),r}async sendSetLength(e,t){let r=new o._SetLengthRequest;return r.setSetName(t),await new Promise((t,a)=>{this.clientWrapper.setLength(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{var n;if(null==r?void 0:r.getMissing())t(new g.CacheSetLength.Miss);else if(null==r?void 0:r.getFound()){let e=null==(n=r.getFound())?void 0:n.getLength();

1e?t(new g.CacheSetLength.Hit(e)):t(new g.CacheSetLength.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new g.CacheSetLength.Error(e),resolveFn:t,rejectFn:a})})})}async listConcatenateBack(e,t,r,a,s=n.CollectionTtl.fromCacheTtl()){var i;try{(0,c.validateCacheName)(e),(0,c.validateListName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListConcatenateBack.Error(e))}this.logger.trace(`Issuing 'listConcatenateBack' request; listName: ${t}, values length: ${r.length}, ${s.toString()}, truncateFrontToSize: ${null!=(i=null==a?void 0:a.toString())?i:"null"}`);let o=await this.sendListConcatenateBack(e,(0,l.convertToB64String)(t),this.convertArrayToB64Strings(r),this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl(),a);return this.logger.trace(`'listConcatenateBack' request result: ${o.toString()}`),o}async sendListConcatenateBack(e,t,r,a,s,i){let c=new o._ListConcatenateBackRequest;return c.setListName(t),c.setValuesList(r),c.setTtlMilliseconds(a),c.setRefreshTtl(s),c.setTruncateFrontToSize(i||0),await new Promise((t,r)=>{this.clientWrapper.listConcatenateBack(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheListConcatenateBack.Success(a.getListLength())):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListConcatenateBack.Error(e),resolveFn:t,rejectFn:r})})})}async listConcatenateFront(e,t,r,a,s=n.CollectionTtl.fromCacheTtl()){var i;try{(0,c.validateCacheName)(e),(0,c.validateListName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListConcatenateFront.Error(e))}this.logger.trace(`Issuing 'listConcatenateFront' request; listName: ${t}, values length: ${r.length}, ${s.toString()}, truncateBackToSize: ${null!=(i=null==a?void 0:a.toString())?i:"null"}`);let o=await this.sendListConcatenateFront(e,(0,l.convertToB64String)(t),this.convertArrayToB64Strings(r),this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl(),a);return this.logger.trace(`'listConcatenateFront' request result: ${o.toString()}`),o}async sendListConcatenateFront(e,t,r,a,s,i){let c=new o._ListConcatenateFrontRequest;return c.setListName(t),c.setValuesList(r),c.setTtlMilliseconds(a),c.setRefreshTtl(s),c.setTruncateBackToSize(i||0),await new Promise((t,r)=>{this.clientWrapper.listConcatenateFront(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheListConcatenateFront.Success(a.getListLength())):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListConcatenateFront.Error(e),resolveFn:t,rejectFn:r})})})}async listFetch(e,t,r,a){try{(0,c.validateCacheName)(e),(0,c.validateListName)(t),(0,c.validateListSliceStartEnd)(r,a)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListFetch.Error(e))}this.logger.trace("Issuing 'listFetch' request; listName: %s, startIndex: %s, endIndex: %s",t,null!=r?r:"null",null!=a?a:"null");let s=await this.sendListFetch(e,(0,l.convertToB64String)(t),r,a);return this.logger.trace("'listFetch' request result: %s",s.toString()),s}async sendListFetch(e,t,r,a){let s=new o._ListFetchRequest;return s.setListName(t),r?s.setInclusiveStart(r):s.setUnboundedStart(new u._Unbounded),a?s.setExclusiveEnd(a):s.setUnboundedEnd(new u._Unbounded),await new Promise((t,r)=>{this.clientWrapper.listFetch(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(null==a?void 0:a.getMissing())t(new n.CacheListFetch.Miss);else if(null==a?void 0:a.getFound()){let e=null==a?void 0:a.getFound();if(void 0!==e){let r=e.getValuesList();t(new n.CacheListFetch.Hit(this.convertArrayToUint8(r)))}else t(new n.CacheListFetch.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListFetch.Error(e),resolveFn:t,rejectFn:r})})})}async listRetain(e,t,r,a,s=n.CollectionTtl.fromCacheTtl()){var i;try{(0,c.validateCacheName)(e),(0,c.validateListName)(t),(0,c.validateListSliceStartEnd)(r,a)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListRetain.Error(e))}this.logger.trace("Issuing 'listRetain' request; listName: %s, startIndex: %s, endIndex: %s, ttl: %s",t,null!=r?r:"null",null!=a?a:"null",null!=(i=s.ttlSeconds.toString())?i:"null");let o=await this.sendListRetain(e,(0,l.convertToB64String)(t),this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl(),r,a);return this.logger.trace("'listRetain' request result: %s",o.toString()),o}async sendListRetain(e,t,r,a,s,i){let c=new o._ListRetainRequest;return c.setListName(t),c.setTtlMilliseconds(r),c.setRefreshTtl(a),s?c.setInclusiveStart(s):c.setUnboundedStart(new u._Unbounded),i?c.setExclusiveEnd(i):c.setUnboundedEnd(new u._Unbounded),await new Promise((t,r)=>{this.clientWrapper.listRetain(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheListRetain.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListRetain.Error(e),resolveFn:t,rejectFn:r})})})}async listLength(e,t){try{(0,c.validateCacheName)(e),(0,c.validateListName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListLength.Error(e))}this.logger.trace(`Issuing 'listLength' request; listName: ${t}`);let r=await this.sendListLength(e,(0,l.convertToB64String)(t));return this.logger.trace(`'listLength' request result: ${r.toString()}`),r}async sendListLength(e,t){let r=new o._ListLengthRequest;return r.setListName(t),await new Promise((t,a)=>{this.clientWrapper.listLength(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{var s;if(null==r?void 0:r.getMissing())t(new n.CacheListLength.Miss);else if(null==r?void 0:r.getFound()){let e=null==(s=r.getFound())?void 0:s.getLength();

1e?t(new n.CacheListLength.Hit(e)):t(new n.CacheListLength.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListLength.Error(e),resolveFn:t,rejectFn:a})})})}async listPopBack(e,t){try{(0,c.validateCacheName)(e),(0,c.validateListName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListPopBack.Error(e))}this.logger.trace("Issuing 'listPopBack' request");let r=await this.sendListPopBack(e,(0,l.convertToB64String)(t));return this.logger.trace(`'listPopBack' request result: ${r.toString()}`),r}async sendListPopBack(e,t){let r=new o._ListPopBackRequest;return r.setListName(t),await new Promise((t,a)=>{this.clientWrapper.listPopBack(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{var s;if(null==r?void 0:r.getMissing())t(new n.CacheListPopBack.Miss);else if(null==r?void 0:r.getFound()){let e=null==(s=r.getFound())?void 0:s.getBack();e?t(new n.CacheListPopBack.Hit(this.convertToUint8Array(e))):t(new n.CacheListPopBack.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListPopBack.Error(e),resolveFn:t,rejectFn:a})})})}async listPopFront(e,t){try{(0,c.validateCacheName)(e),(0,c.validateListName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListPopFront.Error(e))}this.logger.trace("Issuing 'listPopFront' request");let r=await this.sendListPopFront(e,(0,l.convertToB64String)(t));return this.logger.trace(`'listPopFront' request result: ${r.toString()}`),r}async sendListPopFront(e,t){let r=new o._ListPopFrontRequest;return r.setListName(t),await new Promise((t,a)=>{this.clientWrapper.listPopFront(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{var s;if(null==r?void 0:r.getMissing())t(new n.CacheListPopFront.Miss);else if(null==r?void 0:r.getFound()){let e=null==(s=r.getFound())?void 0:s.getFront();e?t(new n.CacheListPopFront.Hit(this.convertToUint8Array(e))):t(new n.CacheListPopFront.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListPopFront.Error(e),resolveFn:t,rejectFn:a})})})}async listPushBack(e,t,r,a,s=n.CollectionTtl.fromCacheTtl()){var i;try{(0,c.validateCacheName)(e),(0,c.validateListName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListPushBack.Error(e))}this.logger.trace(`Issuing 'listPushBack' request; listName: ${t}, value length: ${r.length}, ${s.toString()}, truncateFrontToSize: ${null!=(i=null==a?void 0:a.toString())?i:"null"}`);let o=await this.sendListPushBack(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl(),a);return this.logger.trace(`'listPushBack' request result: ${o.toString()}`),o}async sendListPushBack(e,t,r,a,s,i){let c=new o._ListPushBackRequest;return c.setListName(t),c.setValue(r),c.setTtlMilliseconds(a),c.setRefreshTtl(s),c.setTruncateFrontToSize(i||0),await new Promise((t,r)=>{this.clientWrapper.listPushBack(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheListPushBack.Success(a.getListLength())):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListPushBack.Error(e),resolveFn:t,rejectFn:r})})})}async listPushFront(e,t,r,a,s=n.CollectionTtl.fromCacheTtl()){var i;try{(0,c.validateCacheName)(e),(0,c.validateListName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListPushFront.Error(e))}this.logger.trace(`Issuing 'listPushFront' request; listName: ${t}, value length: ${r.length}, ${s.toString()}, truncateBackToSize: ${null!=(i=null==a?void 0:a.toString())?i:"null"}`);let o=await this.sendListPushFront(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl(),a);return this.logger.trace(`'listPushFront' request result: ${o.toString()}`),o}async sendListPushFront(e,t,r,a,s,i){let c=new o._ListPushFrontRequest;return c.setListName(t),c.setValue(r),c.setTtlMilliseconds(a),c.setRefreshTtl(s),c.setTruncateBackToSize(i||0),await new Promise((t,r)=>{this.clientWrapper.listPushFront(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheListPushFront.Success(a.getListLength())):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>

1new n.CacheListPushFront.Error(e),resolveFn:t,rejectFn:r})})})}async listRemoveValue(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateListName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheListRemoveValue.Error(e))}this.logger.trace(`Issuing 'listRemoveValue' request; listName: ${t}, value length: ${r.length}`);let a=await this.sendListRemoveValue(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r));return this.logger.trace(`'listRemoveValue' request result: ${a.toString()}`),a}async sendListRemoveValue(e,t,r){let a=new o._ListRemoveRequest;return a.setListName(t),a.setAllElementsWithValue(r),await new Promise((t,r)=>{this.clientWrapper.listRemove(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheListRemoveValue.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheListRemoveValue.Error(e),resolveFn:t,rejectFn:r})})})}async dictionarySetField(e,t,r,a,s=n.CollectionTtl.fromCacheTtl()){var i;try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionarySetField.Error(e))}this.logger.trace(`Issuing 'dictionarySetField' request; field: ${r.toString()}, value length: ${a.length}, ttl: ${null!=(i=s.ttlSeconds.toString())?i:"null"}`);let o=await this.sendDictionarySetField(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),(0,l.convertToB64String)(a),this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl());return this.logger.trace(`'dictionarySetField' request result: ${o.toString()}`),o}async sendDictionarySetField(e,t,r,a,s,i){let c=new o._DictionarySetRequest;c.setDictionaryName(t);let h=new o._DictionaryFieldValuePair;return h.setField(r),h.setValue(a),c.setItemsList([h]),c.setTtlMilliseconds(s),c.setRefreshTtl(i),await new Promise((t,r)=>{this.clientWrapper.dictionarySet(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheDictionarySetField.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionarySetField.Error(e),resolveFn:t,rejectFn:r})})})}async dictionarySetFields(e,t,r,a=n.CollectionTtl.fromCacheTtl()){var s;try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionarySetFields.Error(e))}this.logger.trace(`Issuing 'dictionarySetFields' request; elements: ${r.toString()}, ttl: ${null!=(s=a.ttlSeconds.toString())?s:"null"}`);let i=this.convertElements(r),o=await this.sendDictionarySetFields(e,(0,l.convertToB64String)(t),i,this.collectionTtlOrDefaultMilliseconds(a),a.refreshTtl());return this.logger.trace(`'dictionarySetFields' request result: ${o.toString()}`),o}async sendDictionarySetFields(e,t,r,a,s){let i=new o._DictionarySetRequest;return i.setDictionaryName(t),i.setItemsList(r),i.setTtlMilliseconds(a),i.setRefreshTtl(s),await new Promise((t,r)=>{this.clientWrapper.dictionarySet(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheDictionarySetFields.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionarySetFields.Error(e),resolveFn:t,rejectFn:r})})})}async dictionaryGetField(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionaryGetField.Error(e,this.convertToUint8Array(r)))}this.logger.trace(`Issuing 'dictionaryGetField' request; field: ${r.toString()}`);let a=await this.sendDictionaryGetField(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r));return this.logger.trace(`'dictionaryGetField' request result: ${a.toString()}`),a}async sendDictionaryGetField(e,t,r){let a=new o._DictionaryGetRequest;return a.setDictionaryName(t),a.setFieldsList([r]),await new Promise((t,s)=>{this.clientWrapper.dictionaryGet(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{if(null==a?void 0:a.getMissing())t(new n.CacheDictionaryGetField.Miss(this.convertToUint8Array(r)));else if(null==a?void 0:a.getFound()){let e=a.getFound();e&&0===e.getItemsList().length?t(new n.CacheDictionaryGetField.Error(new n.UnknownError("_DictionaryGetResponseResponse contained no data but was found"),this.convertToUint8Array(r))):e&&e.getItemsList()[0].getResult()===o.ECacheResult.MISS?t(new n.CacheDictionaryGetField.Miss(this.convertToUint8Array(r))):e&&t(new n.CacheDictionaryGetField.Hit(e.getItemsList()[0].getCacheBody_asU8(),this.convertToUint8Array(r)))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionaryGetField.Error(e,this.convertToUint8Array(r)),resolveFn:t,rejectFn:s})})})}async dictionaryGetFields(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionaryGetFields.Error(e))}this.logger.trace(`Issuing 'dictionaryGetFields' request; fields: ${r.toString()}`);let a=await this.sendDictionaryGetFields(e,(0,l.convertToB64String)(t),r);return this.logger.trace(`'dictionaryGetFields' request result: ${a.toString()}`),a}async sendDictionaryGetFields(e,t,r){let a=new o._DictionaryGetRequest;return a.setDictionaryName(t),a.setFieldsList(this.convertArrayToB64Str

1ings(r)),await new Promise((t,s)=>{this.clientWrapper.dictionaryGet(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{let o=null==a?void 0:a.getFound();if(o){let e=o.getItemsList().map(e=>{let t=this.convertECacheResult(e.getResult());return new i._DictionaryGetResponsePart(t,e.getCacheBody_asU8())});t(new n.CacheDictionaryGetFields.Hit(e,this.convertArrayToUint8(r)))}else(null==a?void 0:a.getMissing())?t(new n.CacheDictionaryGetFields.Miss):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionaryGetFields.Error(e),resolveFn:t,rejectFn:s})})})}async dictionaryFetch(e,t){try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionaryFetch.Error(e))}this.logger.trace(`Issuing 'dictionaryFetch' request; dictionaryName: ${t}`);let r=await this.sendDictionaryFetch(e,(0,l.convertToB64String)(t));return this.logger.trace(`'dictionaryFetch' request result: ${r.toString()}`),r}async sendDictionaryFetch(e,t){let r=new o._DictionaryFetchRequest;return r.setDictionaryName(t),await new Promise((t,a)=>{this.clientWrapper.dictionaryFetch(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{let s=null==r?void 0:r.getFound();if(s&&s.getItemsList()){let e=[];s.getItemsList().forEach(t=>{let r=new i._DictionaryFieldValuePair({field:t.getField_asU8(),value:t.getValue_asU8()});e.push(r)}),t(new n.CacheDictionaryFetch.Hit(e))}else(null==r?void 0:r.getMissing())?t(new n.CacheDictionaryFetch.Miss):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionaryFetch.Error(e),resolveFn:t,rejectFn:a})})})}async dictionaryIncrement(e,t,r,a=1,s=n.CollectionTtl.fromCacheTtl()){var i;try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionaryIncrement.Error(e))}this.logger.trace(`Issuing 'dictionaryIncrement' request; field: ${r.toString()}, amount : ${a}, ttl: ${null!=(i=s.ttlSeconds.toString())?i:"null"}`);let o=await this.sendDictionaryIncrement(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),a,this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl());return this.logger.trace(`'dictionaryIncrement' request result: ${o.toString()}`),o}async sendDictionaryIncrement(e,t,r,a,s,i){let c=new o._DictionaryIncrementRequest;return c.setDictionaryName(t),c.setField(r),c.setAmount(a),c.setTtlMilliseconds(s),c.setRefreshTtl(i),await new Promise((t,r)=>{this.clientWrapper.dictionaryIncrement(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?a.getValue()?t(new n.CacheDictionaryIncrement.Success(a.getValue())):t(new n.CacheDictionaryIncrement.Success(0)):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionaryIncrement.Error(e),resolveFn:t,rejectFn:r})})})}async dictionaryRemoveField(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionaryRemoveField.Error(e))}this.logger.trace(`Issuing 'dictionaryRemoveField' request; field: ${r.toString()}`);let a=await this.sendDictionaryRemoveField(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r));return this.logger.trace(`'dictionaryRemoveField' request result: ${a.toString()}`),a}async sendDictionaryRemoveField(e,t,r){let a=new o._DictionaryDeleteRequest;return a.setDictionaryName(t),a.setSome(new o._DictionaryDeleteRequest.Some().addFields(r)),await new Promise((t,r)=>{this.clientWrapper.dictionaryDelete(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheDictionaryRemoveField.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionaryRemoveField.Error(e),resolveFn:t,rejectFn:r})})})}async dictionaryRemoveFields(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionaryRemoveFields.Error(e))}this.logger.trace(`Issuing 'dictionaryRemoveFields' request; fields: ${r.toString()}`);let a=await this.sendDictionaryRemoveFields(e,(0,l.convertToB64String)(t),this.convertArrayToB64Str

1ings(r));return this.logger.trace(`'dictionaryRemoveFields' request result: ${a.toString()}`),a}async sendDictionaryRemoveFields(e,t,r){let a=new o._DictionaryDeleteRequest;return a.setDictionaryName(t),a.setSome(new o._DictionaryDeleteRequest.Some().setFieldsList(r)),await new Promise((t,r)=>{this.clientWrapper.dictionaryDelete(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheDictionaryRemoveFields.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionaryRemoveFields.Error(e),resolveFn:t,rejectFn:r})})})}async dictionaryLength(e,t){try{(0,c.validateCacheName)(e),(0,c.validateDictionaryName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDictionaryLength.Error(e))}this.logger.trace(`Issuing 'dictionaryLength' request; dictionaryName: ${t}`);let r=await this.sendDictionaryLength(e,(0,l.convertToB64String)(t));return this.logger.trace(`'dictionaryLength' request result: ${r.toString()}`),r}async sendDictionaryLength(e,t){let r=new o._DictionaryLengthRequest;return r.setDictionaryName(t),await new Promise((t,a)=>{this.clientWrapper.dictionaryLength(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{var s;if(null==r?void 0:r.getMissing())t(new n.CacheDictionaryLength.Miss);else if(null==r?void 0:r.getFound()){let e=null==(s=r.getFound())?void 0:s.getLength();e?t(new n.CacheDictionaryLength.Hit(e)):t(new n.CacheDictionaryLength.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDictionaryLength.Error(e),resolveFn:t,rejectFn:a})})})}async sortedSetFetchByRank(e,t,r,a,s){var i,o;try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t),(0,c.validateSortedSetRanks)(a,s)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetFetch.Error(e))}this.logger.trace("Issuing 'sortedSetFetchByRank' request; startRank: %s, endRank : %s, order: %s",null!=(i=a.toString())?i:"null",null!=(o=null==s?void 0:s.toString())?o:"null",r.toString());let h=await this.sendSortedSetFetchByRank(e,(0,l.convertToB64String)(t),r,a,s);return this.logger.trace("'sortedSetFetchByRank' request result: %s",h.toString()),h}async sendSortedSetFetchByRank(e,t,r,a,s){let c=new o._SortedSetFetchRequest._ByIndex;a?c.setInclusiveStartIndex(a):c.setUnboundedStart(new u._Unbounded),s?c.setExclusiveEndIndex(s):c.setUnboundedEnd(new u._Unbounded);let h=r===n.SortedSetOrder.Descending?o._SortedSetFetchRequest.Order.DESCENDING:o._SortedSetFetchRequest.Order.ASCENDING,d=new o._SortedSetFetchRequest;return d.setSetName(t),d.setOrder(h),d.setWithScores(!0),d.setByIndex(c),await new Promise((t,r)=>{this.clientWrapper.sortedSetFetch(d,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{var s,o;if(a&&a.getFound()){let e=null==(o=null==(s=a.getFound())?void 0:s.getValuesWithScores())?void 0:o.getElementsList();if(e){let r=e.map(e=>new i._SortedSetElement(this.convertToUint8Array(e.getValue()),e.getScore()));t(new n.CacheSortedSetFetch.Hit(r))}else t(new n.CacheSortedSetFetch.Error(new n.UnknownError("Unknown sorted set fetch hit response type")))}else(null==a?void 0:a.getMissing())?t(new n.CacheSortedSetFetch.Miss):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetFetch.Error(e),resolveFn:t,rejectFn:r})})})}async sortedSetFetchByScore(e,t,r,a,s,i,o){var h,d,u,S;try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t),(0,c.validateSortedSetScores)(a,s),void 0!==i&&(0,c.validateSortedSetOffset)(i),void 0!==o&&(0,c.validateSortedSetCount)(o)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetFetch.Error(e))}this.logger.trace("Issuing 'sortedSetFetchByScore' request; minScore: %s, maxScore : %s, order: %s, offset: %s, count: %s",null!=(h=null==a?void 0:a.toString())?h:"null",null!=(d=null==s?void 0:s.toString())?d:"null",r.toString(),null!=(u=null==i?void 0:i.toString())?u:"null",null!=(S=null==o?void 0:o.toString())?S:"null");let g=await this.sendSortedSetFetchByScore(e,(0,l.convertToB64String)(t),r,a,s,i,o);return this.logger.trace("'sortedSetFetchByScore' request result: %s",g.toString()),g}async sendSortedSetFetchByScore(e,t,r,a,s,c,h){let d=new o._SortedSetFetchRequest._ByScore;void 0!==a?d.setMinScore(new o._SortedSetFetchRequest._ByScore._Score().setScore(a).setExclusive(!1)):d.setUnboundedMin(new u._Unbounded),void 0!==s?d.setMaxScore(new o._SortedSetFetchRequest._ByScore._Score().setScore(s).setExclusive(!1)):d.setUnboundedMax(new u._Unbounded),d.setOffset(null!=c?c:0),d.setCount(null!=h?h:-1);let S=r===n.SortedSetOrder.Descending?o._SortedSetFetchRequest.Order.DESCENDING:o._SortedSetFetchRequest.Order.ASCENDING,g=new o._SortedSetFetchRequest;return g.setSetName(t),g.setOrder(S),g.setWithScores(!0),g.setByScore(d),await new Promise((t,r)=>{this.clientWrapper.sortedSetFetch(g,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{var s,o,c;if(a)if(null==(s=null==a?void 0:a.getFound())?void 0:s.getValuesWithScores()){let e=null==(c=null==(o=a.getFound())?void 0:o.getValuesWithScores())?void 0:c.getElementsList();if(e){let r=e.map(e=>new i._SortedSetElement(this.convertToUint8Array(e.getValue()),e.getScore()));t(new n.CacheSortedSetFetch.Hit(r))}else t(new n.CacheSortedSetFetch.Error(new n.UnknownError("Unknown sorted set fetch hit response type")))}else(null==a?void 0:a.getMissing())?t(new n.CacheSortedSetFetch.Miss):t(new n.CacheSortedSetFetch.Error(new n.UnknownError("Unknown sorted set fetch response type")));else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetFetch.Error(e),resolveFn:t,rejectFn:r})})})}async sortedSetPutElement(e,t,r,a,s=n.CollectionTtl.fromCacheTtl()){var i;try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetPutElement.Error(e))}this.logger.trace("Issuing 'sortedSetPutElement' request; value: %s, score : %s, ttl: %s",(0,c.truncateString)(r.toString()),a,null!=(i=s.ttlSeconds.toString())?i:"null");let o=await this.sendSortedSetPutElement(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),a,this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl());return this.logger.trace("'sortedSetPutElement' request result: %s",o.toString()),o}async sendSortedSetPutElement(e,t,r,a,s,i){let c=new o._SortedSetPutRequest,h=new o._SortedSetElement;return h.setValue(r),h.setScore(a),c.setSetName(t),c.setElementsList([h]),c.setTtlMilliseconds(s),c.setRefreshTtl(i),await new Promise((t,r)=>{this.clientWrapper.sortedSetPut(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheSortedSetPutElement.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetPutElement.Error(e),resolveFn:t,rejectFn:r})})})}async sortedSetPutElements(e,t,r,a=n.CollectionTtl.fromCacheTtl()){var s;try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetPutElements.Error(e))}this.logger.trace("Issuing 'sortedSetPutElements' request; elements: %s, ttl: %s",r.toString(),null!=(s=a.ttlSeconds.toString())?s:"null");let i=this.convertSortedSetMapOrRecord(r),o=await this.sendSortedSetPutElements(e,(0,l.convertToB64String)(t),i,this.collectionTtlOrDefaultMilliseconds(a),a.refreshTtl());return this.logger.trace("'sortedSetPutElements' request result: %s",o.toString()),o}async sendSortedSetPutElements(e,t,r,a,s){let i=new o._SortedSetPutRequest;return i.setSetName(t),i.setElementsList(r),i.setTtlMilliseconds(a),i.setRefreshTtl(s),await new Promise((t,r)=>{this.clientWrapper.sortedSetPut(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new n.CacheSortedSetPutElements.Success):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetPutElements.Error(e),resolveFn:t,rejectFn:r})})})}async sortedSetGetScore(e,t,r){let a=await this.sortedSetGetScores(e,t,[r]);return a instanceof n.CacheSortedSetGetScores.Hit?a.responses()[0]:a instanceof n.CacheSortedSetGetScores.Miss?new n.CacheSortedSetGetScore.Miss(this.convertToUint8Array(r)):a instanceof n.CacheSortedSetGetScores.Error?this.cacheServiceErrorMapper.returnOrThrowError(a.innerException(),e=>new n.CacheSortedSetGetScore.Error(e,this.convertToUint8Array(r))):this.cacheServiceErrorMapper.returnOrThrowError(new n.UnknownError("Unknown response type"),e=>new n.CacheSortedSetGetScore.Error(e,this.convertToUint8Array(r)))}async sortedSetGetScores(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetGetScores.Error(e))}this.logger.trace("Issuing 'sortedSetGetScores' request; values: %s",(0,c.truncateString)(r.toString()));let a=await this.sendSortedSetGetScores(e,(0,l.convertToB64String)(t),r.map(e=>(0,l.convertToB64String)(e)));return this.logger.trace("'sortedSetGetScores' request result: %s",(0,c.truncateString)(a.toString())),a}async sendSortedSetGetScores(e,t,r){let a=new o._SortedSetGetScoreRequest;return a.setSetName(t),a.setValuesList(r),await new Promise((t,s)=>{this.clientWrapper.sortedSetGetScore(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{var o;if(null==a?void 0:a.getMissing())t(new n.CacheSortedSetGetScores.Miss);else if(null==a?void 0:a.getFound()){let e=null==(o=a.getFound())?void 0:o.getElementsList().map(e=>{let t=this.convertECacheResult(e.getResult());return new i._SortedSetGetScoreResponsePart(t,e.getScore())});

1e?t(new n.CacheSortedSetGetScores.Hit(e,this.convertArrayToUint8(r.map(e=>atob(e))))):t(new n.CacheSortedSetGetScores.Error(new n.UnknownError("Unknown sorted set fetch hit response type")))}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetGetScores.Error(e),resolveFn:t,rejectFn:s})})})}async sortedSetGetRank(e,t,r,a){try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetGetRank.Error(e))}this.logger.trace("Issuing 'sortedSetGetRank' request; value: %s",(0,c.truncateString)(r.toString()));let s=await this.sendSortedSetGetRank(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),a);return this.logger.trace("'sortedSetGetRank' request result: %s",(0,c.truncateString)(s.toString())),s}async sendSortedSetGetRank(e,t,r,a){let s=a===n.SortedSetOrder.Descending?o._SortedSetGetRankRequest.Order.DESCENDING:o._SortedSetGetRankRequest.Order.ASCENDING,i=new o._SortedSetGetRankRequest;return i.setSetName(t),i.setValue(r),i.setOrder(s),await new Promise((t,r)=>{this.clientWrapper.sortedSetGetRank(i,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{var s,i,c;if((null==a?void 0:a.getMissing())||(null==(s=null==a?void 0:a.getElementRank())?void 0:s.getResult())===o.ECacheResult.MISS)t(new n.CacheSortedSetGetRank.Miss);else if((null==(i=null==a?void 0:a.getElementRank())?void 0:i.getResult())===o.ECacheResult.HIT){let e=null==(c=null==a?void 0:a.getElementRank())?void 0:c.getRank();void 0!==e?t(new n.CacheSortedSetGetRank.Hit(e)):t(new n.CacheSortedSetGetRank.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetGetRank.Error(e),resolveFn:t,rejectFn:r})})})}async sortedSetIncrementScore(e,t,r,a=1,s=n.CollectionTtl.fromCacheTtl()){try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetIncrementScore.Error(e))}this.logger.trace("Issuing 'sortedSetIncrementScore' request; value: %s",(0,c.truncateString)(r.toString()));let i=await this.sendSortedSetIncrementScore(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r),a,this.collectionTtlOrDefaultMilliseconds(s),s.refreshTtl());return this.logger.trace("'sortedSetIncrementScore' request result: %s",(0,c.truncateString)(i.toString())),i}async sendSortedSetIncrementScore(e,t,r,a,s,i){let c=new o._SortedSetIncrementRequest;return c.setSetName(t),c.setValue(r),c.setAmount(a),c.setTtlMilliseconds(s),c.setRefreshTtl(i),await new Promise((t,r)=>{this.clientWrapper.sortedSetIncrement(c,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?a.getScore()?t(new n.CacheSortedSetIncrementScore.Success(a.getScore())):t(new n.CacheSortedSetIncrementScore.Success(0)):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetIncrementScore.Error(e),resolveFn:t,rejectFn:r})})})}async sortedSetRemoveElement(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetRemoveElement.Error(e))}this.logger.trace("Issuing 'sortedSetRemoveElement' request");let a=await this.sendSortedSetRemoveElement(e,(0,l.convertToB64String)(t),(0,l.convertToB64String)(r));return this.logger.trace("'sortedSetRemoveElement' request result: %s",(0,c.truncateString)(a.toString())),a}async sendSortedSetRemoveElement(e,t,r){let a=new o._SortedSetRemoveRequest;return a.setSetName(t),a.setSome(new o._SortedSetRemoveRequest._Some().setValuesList([r])),await new Promise((t,r)=>{this.clientWrapper.sortedSetRemove(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},e=>{e?this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetRemoveElement.Error(e),resolveFn:t,rejectFn:r}):t(new n.CacheSortedSetRemoveElement.Success)})})}async sortedSetRemoveElements(e,t,r){try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetRemoveElements.Error(e))}this.logger.trace("Issuing 'sortedSetRemoveElements' request");let a=await this.sendSortedSetRemoveElements(e,(0,l.convertToB64String)(t),this.convertArrayToB64Str

1ings(r));return this.logger.trace("'sortedSetRemoveElements' request result: %s",(0,c.truncateString)(a.toString())),a}async sendSortedSetRemoveElements(e,t,r){let a=new o._SortedSetRemoveRequest;return a.setSetName(t),a.setSome(new o._SortedSetRemoveRequest._Some().setValuesList(r)),await new Promise((t,r)=>{this.clientWrapper.sortedSetRemove(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},e=>{e?this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetRemoveElements.Error(e),resolveFn:t,rejectFn:r}):t(new n.CacheSortedSetRemoveElements.Success)})})}async sortedSetLength(e,t){try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetLength.Error(e))}this.logger.trace("Issuing 'sortedSetLength' request");let r=await this.sendSortedSetLength(e,(0,l.convertToB64String)(t));return this.logger.trace("'sortedSetLength' request result: %s",(0,c.truncateString)(r.toString())),r}async sendSortedSetLength(e,t){let r=new o._SortedSetLengthRequest;return r.setSetName(t),await new Promise((t,a)=>{this.clientWrapper.sortedSetLength(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{var s;if(null==r?void 0:r.getMissing())t(new n.CacheSortedSetLength.Miss);else if(null==r?void 0:r.getFound()){let e=null==(s=r.getFound())?void 0:s.getLength();e?t(new n.CacheSortedSetLength.Hit(e)):t(new n.CacheSortedSetLength.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetLength.Error(e),resolveFn:t,rejectFn:a})})})}async sortedSetLengthByScore(e,t,r,a){var s,i;try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t),(0,c.validateSortedSetScores)(r,a)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheSortedSetLengthByScore.Error(e))}this.logger.trace("Issuing 'sortedSetLengthByScore' request; minScore: %s, maxScore: %s",null!=(s=null==r?void 0:r.toString())?s:"null",null!=(i=null==a?void 0:a.toString())?i:"null");let o=await this.sendSortedSetLengthByScore(e,(0,l.convertToB64String)(t),r,a);return this.logger.trace("'sortedSetLengthByScore' request result: %s",(0,c.truncateString)(o.toString())),o}async sendSortedSetLengthByScore(e,t,r,a){let s=new o._SortedSetLengthByScoreRequest;return s.setSetName(t),void 0===r?s.setUnboundedMin(new u._Unbounded):s.setInclusiveMin(r),void 0===a?s.setUnboundedMax(new u._Unbounded):s.setInclusiveMax(a),await new Promise((t,r)=>{this.clientWrapper.sortedSetLengthByScore(s,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{var s;if(null==a?void 0:a.getMissing())t(new n.CacheSortedSetLengthByScore.Miss);else if(null==a?void 0:a.getFound()){let e=null==(s=a.getFound())?void 0:s.getLength();e?t(new n.CacheSortedSetLengthByScore.Hit(e)):t(new n.CacheSortedSetLengthByScore.Miss)}else this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheSortedSetLengthByScore.Error(e),resolveFn:t,rejectFn:r})})})}async sortedSetUnionStore(e,t,r,a,s=n.CollectionTtl.fromCacheTtl()){var i,o;try{(0,c.validateCacheName)(e),(0,c.validateSortedSetName)(t),(0,c.validateSortedSetSources)(r)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new g.CacheSortedSetUnionStore.Error(e))}this.logger.trace("Issuing 'sortedSetUnionStore' request; sources: %s, aggregate: %s:, ttl: %s",r.toString(),null!=(i=null==a?void 0:a.toString())?i:"null",null!=(o=null==s?void 0:s.toString())?o:"null");let h=await this.sendSortedSetUnionStore(e,(0,l.convertToB64String)(t),r,s,a);return this.logger.trace(`'sortedSetUnionStore' request result: ${h.toString()}`),h}async sendSortedSetUnionStore(e,t,r,a,s){let i=this.convertAggregateResult(s),c=[];for(let e of r)c.push(this.convertSortedSetSource(e));void 0===a&&(a=new n.CollectionTtl);let h=new o._SortedSetUnionStoreRequest;return h.setSetName(t),h.setSourcesList(c),h.setAggregate(i),h.setTtlMilliseconds(this.collectionTtlOrDefaultMilliseconds(a)),await new Promise((t,r)=>{this.clientWrapper.sortedSetUnionStore(h,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{a?t(new g.CacheSortedSetUnionStore.Success(a.getLength())):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new g.CacheSortedSetUnionStore.Error(e),resolveFn:t,rejectFn:r})})})}async itemGetType(e,t){try{(0,c.validateCacheName)(e)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheItemGetType.Error(e))}return await this.sendItemGetType(e,(0,l.convertToB64String)(t))}async sendItemGetType(e,t){let r=new o._ItemGetTypeRequest;return r.setCacheKey(t),await new Promise((t,a)=>{this.clientWrapper.itemGetType(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{let s=r.getFound();if(s){let e=s.getItemType();t(new n.CacheItemGetType.Hit(this.convertItemTypeResult(e)))}else(null==r?void 0:r.getMissing())?t(new n.CacheItemGetType.Miss):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheItemGetType.Error(e),resolveFn:t,rejectFn:a})})})}async itemGetTtl(e,t){try{(0,c.validateCacheName)(e)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheItemGetTtl.Error(e))}return await this.sendItemGetTtl(e,(0,l.convertToB64String)(t))}async sendItemGetTtl(e,t){let r=new o._ItemGetTtlRequest;return r.setCacheKey(t),await new Promise((t,a)=>{this.clientWrapper.itemGetTtl(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{let s=r.getFound();s?t(new n.CacheItemGetTtl.Hit(s.getRemainingTtlMillis())):(null==r?void 0:r.getMissing())?t(new n.CacheItemGetTtl.Miss):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheItemGetTtl.Error(e),resolveFn:t,rejectFn:a})})})}async keyExists(e,t){try{(0,c.validateCacheName)(e)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheKeyExists.Error(e))}this.logger.trace("Issuing 'keyExists' request");let r=await this.sendKeyExists(e,(0,l.convertToB64String)(t));return this.logger.trace("'keyExists' request result: %s",(0,c.truncateString)(r.toString())),r}async sendKeyExists(e,t){let r=new o._KeysExistRequest;return r.setCacheKeysList([t]),await new Promise((t,a)=>{this.clientWrapper.keysExist(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{r?t(new n.CacheKeyExists.Success(r.getExistsList())):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheKeyExists.Error(e),resolveFn:t,rejectFn:a})})})}async keysExist(e,t){try{(0,c.validateCacheName)(e)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheKeysExist.Error(e))}this.logger.trace("Issuing 'keysExist' request");let r=await this.sendKeysExist(e,t);return this.logger.trace("'keysExist' request result: %s",(0,c.truncateString)(r.toString())),r}async sendKeysExist(e,t){let r=new o._KeysExistRequest;

1return r.setCacheKeysList(this.convertArrayToB64Strings(t)),await new Promise((a,s)=>{this.clientWrapper.keysExist(r,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,r)=>{r?a(new n.CacheKeysExist.Success(this.convertArrayToUint8(t),r.getExistsList())):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheKeysExist.Error(e),resolveFn:a,rejectFn:s})})})}async updateTtl(e,t,r){var a;try{(0,c.validateCacheName)(e),(0,c.validateValidForSeconds)(r)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheUpdateTtl.Error(e))}this.logger.trace("Issuing 'updateTtl' request; ttlMilliseconds: %s",null!=(a=null==r?void 0:r.toString())?a:"null");let s=await this.sendUpdateTtl(e,(0,l.convertToB64String)(t),r);return this.logger.trace("'updateTtl' request result: %s",(0,c.truncateString)(s.toString())),s}async sendUpdateTtl(e,t,r){let a=new o._UpdateTtlRequest;return a.setCacheKey(t),a.setOverwriteToMilliseconds(r),await new Promise((t,r)=>{this.clientWrapper.updateTtl(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{(null==a?void 0:a.getMissing())?t(new n.CacheUpdateTtl.Miss):(null==a?void 0:a.getSet())?t(new n.CacheUpdateTtl.Set):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheUpdateTtl.Error(e),resolveFn:t,rejectFn:r})})})}async increaseTtl(e,t,r){var a;try{(0,c.validateCacheName)(e),(0,c.validateValidForSeconds)(r)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheIncreaseTtl.Error(e))}this.logger.trace("Issuing 'increaseTtl' request; ttlMilliseconds: %s",null!=(a=null==r?void 0:r.toString())?a:"null");let s=await this.sendIncreaseTtl(e,(0,l.convertToB64String)(t),r);return this.logger.trace("'increaseTtl' request result: %s",(0,c.truncateString)(s.toString())),s}async sendIncreaseTtl(e,t,r){let a=new o._UpdateTtlRequest;return a.setCacheKey(t),a.setIncreaseToMilliseconds(r),await new Promise((t,r)=>{this.clientWrapper.updateTtl(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{(null==a?void 0:a.getMissing())?t(new n.CacheIncreaseTtl.Miss):(null==a?void 0:a.getNotSet())?t(new n.CacheIncreaseTtl.NotSet):(null==a?void 0:a.getSet())?t(new n.CacheIncreaseTtl.Set):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheIncreaseTtl.Error(e),resolveFn:t,rejectFn:r})})})}async decreaseTtl(e,t,r){var a;try{(0,c.validateCacheName)(e),(0,c.validateValidForSeconds)(r)}catch(e){return this.cacheServiceErrorMapper.returnOrThrowError(e,e=>new n.CacheDecreaseTtl.Error(e))}this.logger.trace("Issuing 'decreaseTtl' request; ttlMilliseconds: %s",null!=(a=null==r?void 0:r.toString())?a:"null");let s=await this.sendDecreaseTtl(e,(0,l.convertToB64String)(t),r);return this.logger.trace("'decreaseTtl' request result: %s",(0,c.truncateString)(s.toString())),s}async sendDecreaseTtl(e,t,r){let a=new o._UpdateTtlRequest;return a.setCacheKey(t),a.setDecreaseToMilliseconds(r),await new Promise((t,r)=>{this.clientWrapper.updateTtl(a,{...this.clientMetadataProvider.createClientMetadata(),...(0,l.createCallMetadata)(e,this.deadlineMillis)},(e,a)=>{(null==a?void 0:a.getMissing())?t(new n.CacheDecreaseTtl.Miss):(null==a?void 0:a.getNotSet())?t(new n.CacheDecreaseTtl.NotSet):(null==a?void 0:a.getSet())?t(new n.CacheDecreaseTtl.Set):this.cacheServiceErrorMapper.resolveOrRejectError({err:e,errorResponseFactoryFn:e=>new n.CacheDecreaseTtl.Error(e),resolveFn:t,rejectFn:r})})})}convertArrayToB64Strings(e){return e.map(e=>(0,l.convertToB64String)(e))}convertToUint8Array(e){return"string"==typeof e?this.textEncoder.encode(e):e}convertArrayToUint8(e){return e.map(e=>this.convertToUint8Array(e))}convertElements(e){return e instanceof Array?this.convertElements(new Map(e)):e instanceof Map?[...e.entries()].map(e=>new o._DictionaryFieldValuePair().setField((0,l.convertToB64String)(e[0])).setValue((0,l.convertToB64String)(e[1]))):Object.entries(e).map(e=>new o._DictionaryFieldValuePair().setField((0,l.convertToB64String)(e[0])).setValue((0,l.convertToB64String)(e[1])))}convertSortedSetMapOrRecord(e){return e instanceof Array?this.convertSortedSetMapOrRecord(new Map(e)):e instanceof Map?[...e.entries()].map(e=>new o._SortedSetElement().setValue((0,l.convertToB64String)(e[0])).setScore(e[1])):Object.entries(e).map(e=>new o._SortedSetElement().setValue((0,l.convertToB64String)(e[0])).setScore(e[1]))}convertSetBatchElements(e,t){return e instanceof Array?e.map(e=>{var r;return[(0,l.convertToB64String)(e.key),(0,l.convertToB64String)(e.value),null!=(r=e.ttl)?r:t]}):e instanceof Map?[...e.entries()].map(e=>[(0,l.convertToB64String)(e[0]),(0,l.convertToB64String)(e[1]),t]):Object.entries(e).map(e=>[(0,l.convertToB64String)(e[0]),(0,l.convertToB64String)(e[1]),t])}convertECacheResult(e){switch(e){case o.ECacheResult.HIT:return i._ECacheResult.Hit;case o.ECacheResult.INVALID:return i._ECacheResult.Invalid;case o.ECacheResult.MISS:return i._ECacheResult.Miss;case o.ECacheResult.OK:return i._ECacheResult.Ok}}convertItemTypeResult(e){switch(e){case o._ItemGetTypeResponse.ItemType.SCALAR:return n.ItemType.SCALAR;case o._ItemGetTypeResponse.ItemType.LIST:return n.ItemType.LIST;case o._ItemGetTypeResponse.ItemType.DICTIONARY:return n.ItemType.DICTIONARY;case o._ItemGetTypeResponse.ItemType.SET:return n.ItemType.SET;case o._ItemGetTypeResponse.ItemType.SORTED_SET:return n.ItemType.SORTED_SET}}convertAggregateResult(e){switch(e){case S.SortedSetAggregate.MAX:return o._SortedSetUnionStoreRequest.AggregateFunction.MAX;case S.SortedSetAggregate.MIN:return o._SortedSetUnionStoreRequest.AggregateFunction.MIN;case S.SortedSetAggregate.SUM:default:return o._SortedSetUnionStoreRequest.AggregateFunction.SUM}}convertSortedSetSource(e){let t=new o._SortedSetUnionStoreRequest._Source;return t.setSetName((0,l.convertToB64String)(e.sortedSetName)),t.setWeight(e.weight),t}}t.CacheDataClient=v}}]);