jtBaseApp/dist/assets/QueryEngine.05824aeb.js

import{eX as ee,dC as W,eY as te,ca as se,eZ as G,e_ as P,t as g,e$ as ie,dD as re,dF as ae,ci as C,bC as I,dP as M,c1 as Z,g as F,a as w,f0 as N,aY as H,bB as D,f1 as ne,f2 as ue,bH as ce,aO as oe,bn as L,au as he,aG as le,aq as fe,cX as de}from"./index.6c049565.js";import{A as d,q as ye,l as me,c as A,o as pe,a as ge,f as xe}from"./QueryEngineResult.fe74257f.js";import{g as T,f as q,M as _e}from"./projectionSupport.2b4a8796.js";import{t as we}from"./QueryEngineCapabilities.78217f95.js";import{t as Se,v,n as Fe,I as U,P as V}from"./timeSupport.4d8d3d9b.js";import{E as j,F as E,z as J,v as Re}from"./utils.9592ea84.js";function Qe(z){return z.every(e=>e.statisticType!=="exceedslimit")}const R="feature-store:unsupported-query",Ie=new ee(2e6);let Ee=0;class qe{constructor(e){this.capabilities={query:we},this.geometryType=e.geometryType,this.hasM=e.hasM,this.hasZ=e.hasZ,this.objectIdField=e.objectIdField,this.spatialReference=e.spatialReference,this.definitionExpression=e.definitionExpression,this.featureStore=e.featureStore,this.aggregateAdapter=e.aggregateAdapter,this._changeHandle=this.featureStore.events.on("changed",()=>this.clearCache()),this.timeInfo=e.timeInfo,e.cacheSpatialQueries&&(this._geometryQueryCache=new te(Ee+++"$$",Ie)),this.fieldsIndex=new se(e.fields),e.scheduler&&e.priority&&(this._frameTask=e.scheduler.registerTask(e.priority))}destroy(){this._frameTask=G(this._frameTask),this.clearCache(),P(this._geometryQueryCache),this._changeHandle=G(this._changeHandle),P(this.fieldsIndex)}get featureAdapter(){return this.featureStore.featureAdapter}get fullExtent(){const e=this.featureStore.fullBounds;return g(e)?null:{xmin:e[0],ymin:e[1],xmax:e[2],ymax:e[3],spatialReference:j(this.spatialReference)}}get timeExtent(){return this.timeInfo?(this._timeExtent||(this._timeExtent=Se(this.timeInfo,this.featureStore)),this._timeExtent):null}clearCache(){var e;(e=this._geometryQueryCache)==null||e.clear(),this._allItems=null,this._timeExtent=null}async executeQuery(e,t){try{return(await this._executeQuery(e,{},t)).createQueryResponse()}catch(s){if(s!==E)throw s;return new d([],e,this).createQueryResponse()}}async executeQueryForCount(e={},t){try{return(await this._executeQuery(e,{returnGeometry:!1,returnCentroid:!1,outSR:null},t)).createQueryResponseForCount()}catch(s){if(s!==E)throw s;return 0}}async executeQueryForExtent(e,t){const s=e.outSR;try{const i=await this._executeQuery(e,{returnGeometry:!0,returnCentroid:!1,outSR:null},t),r=i.size;if(!r)return{count:0,extent:null};ie(x,re),this.featureStore.forEachBounds(i.items,u=>ae(x,u),be);const n={xmin:x[0],ymin:x[1],xmax:x[3],ymax:x[4],spatialReference:j(this.spatialReference)};this.hasZ&&isFinite(x[2])&&isFinite(x[5])&&(n.zmin=x[2],n.zmax=x[5]);const a=T(n,i.spatialReference,s);if(a.spatialReference=j(s||this.spatialReference),a.xmax-a.xmin==0){const u=C(a.spatialReference);a.xmin-=u,a.xmax+=u}if(a.ymax-a.ymin==0){const u=C(a.spatialReference);a.ymin-=u,a.ymax+=u}if(this.hasZ&&a.zmin!=null&&a.zmax!=null&&a.zmax-a.zmin==0){const u=C(a.spatialReference);a.zmin-=u,a.zmax+=u}return{count:r,extent:a}}catch(i){if(i===E)return{count:0,extent:null};throw i}}async executeQueryForIds(e,t){return this.executeQueryForIdSet(e,t).then(s=>Array.from(s))}async executeQueryForIdSet(e,t){try{const s=await this._executeQuery(e,{returnGeometry:!0,returnCentroid:!1,outSR:null},t),i=s.items,r=new Set;return await this._reschedule(()=>{for(const n of i)r.add(s.featureAdapter.getObjectId(n))},t),r}catch(s){if(s===E)return new Set;throw s}}async executeQueryForSnapping(e,t){const{point:s,distance:i,types:r}=e;if(r===ye.NONE)return{candidates:[]};const n=await this._reschedule(()=>this._checkQuerySupport(e.query),t),a=!I(s.spatialReference,this.spatialReference);a&&await q(s.spatialReference,this.spatialReference);const u=typeof i=="number"?i:i.x,h=typeof i=="number"?i:i.y,o={xmin:s.x-u,xmax:s.x+u,ymin:s.y-h,ymax:s.y+h,spatialReference:s.spatialReference},c=a?T(o,this.spatialReference):o;if(!c)return{candidates:[]};const y=(await M(Z(s),null,{signal:t}))[0],m=(await M(Z(c),null,{signal:t}))[0];if(g(y)||g(m))return{candidates:[]};const _=new d(this._searchFeatures(this._getQueryBBoxes(m.toJSON())),n,this);await this._reschedule(()=>this._executeObjectIdsQuery(_),t),await this._reschedule(()=>this._executeTimeQuery(_),t),await this._reschedule(()=>this._executeAttributesQuery(_),t);const l=y.toJSON(),S=a?T(l,this.spatialReference):l,p=a?Math.max(c.xmax-c.xmin,c.ymax-c.ymin)/2:i;return _.createSnappingResponse({...e,point:S,distance:p},s.spatialReference)}async executeQueryForLatestObservations(e,t){if(!this.timeInfo||!this.timeInfo.trackIdField)throw new F(R,"Missing timeInfo or timeInfo.trackIdField",{query:e,timeInfo:this.timeInfo});try{const s=await this._executeQuery(e,{},t);return await this._reschedule(()=>this._filterLatest(s),t),s.createQueryResponse()}catch(s){if(s!==E)throw s;return new d([],e,this).createQueryResponse()}}async executeQueryForSummaryStatistics(e={},t,s){const{field:i,normalizationField:r,valueExpression:n}=t;return(await this._getQueryEngineResultForStats(e,{field:i,normalizationField:r,valueExpression:n},s)).createSummaryStatisticsResponse(t)}async executeQueryForUniqueValues(e={},t,s){const{field:i,field2:r,field3:n,valueExpression:a}=t;return(await this._getQueryEngineResultForStats(e,{field:i,field2:r,field3:n,valueExpression:a},s)).createUniqueValuesResponse(t)}async executeQueryForClassBreaks(e={},t,s){const{field:i,normalizationField:r,valueExpression:n}=t;return(await this._getQueryEngineResultForStats(e,{field:i,normalizationField:r,valueExpression:n},s)).createClassBreaksResponse(t)}async executeQueryForHistogram(e={},t,s){const{field:i,normalizationField:r,valueExpression:n}=t;return(await this._getQueryEngineResultForStats(e,{field:i,normalizationField:r,valueExpression:n},s)).createHistogramResponse(t)}async _schedule(e,t){return w(this._frameTask)?this._frameTask.schedule(e,t):e(N)}async _reschedule(e,t){return w(this._frameTask)?this._frameTask.reschedule(e,t):e(N)}_getAll(e){return g(this._allItems)&&(this._allItems=this.featureStore.toArray()),new d(this._allItems,e,this)}async _executeQuery(e,t,s){e=H(e),e=await this._schedule(()=>J(e,this.definitionExpression,this.spatialReference),s),e=await this._reschedule(()=>this._checkQuerySupport(e),s),e={...e,...t};const i=await this._reschedule(()=>this._executeSceneFilterQuery(e,s),s),r=await this._reschedule(()=>this._executeGeometryQuery(e,i,s),s);return await this._reschedule(()=>this._executeAggregateIdsQuery(r),s),await this._reschedule(()=>this._executeObjectIdsQuery(r),s),await this._reschedule(()=>this._executeTimeQuery(r),s),await this._reschedule(()=>this._executeAttributesQuery(r),s),r}async _executeSceneFilterQuery(e,t){if(g(e.sceneFilter))return null;const{outSR:s,returnGeometry:i,returnCentroid:r}=e,n=this.featureStore.featureSpatialReference,a=e.sceneFilter.geometry,u=g(n)||I(n,a.spatialReference)?a:T(a,n);if(!u)return null;const h=i||r,o=D(s)&&!I(this.spatialReference,s)&&h?async l=>this._project(l,s):l=>l,c=this.featureAdapter,y=this._searchFeatures(this._getQueryBBoxes(u));if(e.sceneFilter.spatialRelationship==="disjoint"){if(!y.length)return null;const l=new Set;for(const b of y)l.add(c.getObjectId(b));const S=await this._reschedule(()=>this.featureStore.toArray(),t),p=await this._reschedule(async()=>{const b=await v("esriSpatialRelDisjoint",u,this.geometryType,this.hasZ,this.hasM),$=Q=>!l.has(c.getObjectId(Q))||b(c.getGeometry(Q)),f=await this._runSpatialFilter(S,$,t);return new d(f,e,this)},t);return o(p)}if(!y.length)return new d([],e,this);if(this._canExecuteSinglePass(u,e))return o(new d(y,e,this));const m=await v("esriSpatialRelContains",u,this.geometryType,this.hasZ,this.hasM),_=await this._runSpatialFilter(y,l=>m(c.getGeometry(l)),t);return o(new d(_,e,this))}async _executeGeometryQuery(e,t,s){if(w(t)&&t.items.length===0)return t;e=w(t)?t.query:e;const{geometry:i,outSR:r,spatialRel:n,returnGeometry:a,returnCentroid:u}=e,h=this.featureStore.featureSpatialReference,o=!i||g(h)||I(h,i.spatialReference)?i:T(i,h),c=a||u,y=D(r)&&!I(this.spatialReference,r),m=this._geometryQueryCache&&g(t)?y&&c?JSON.stringify({originalFilterGeometry:i,spatialRelationship:n,outSpatialReference:r}):JSON.stringify({originalFilterGeometry:i,spatialRelationship:n}):null,_=m?this._geometryQueryCache.get(m):null;if(w(_))return new d(_,e,this);const l=async f=>(y&&c&&await this._project(f,r),m&&this._geometryQueryCache.put(m,f.items,f.items.length+1),f);if(!o)return l(w(t)?t:this._getAll(e));const S=this.featureAdapter;let p=this._searchFeatures(this._getQueryBBoxes(i));if(n==="esriSpatialRelDisjoint"){if(!p.length)return l(w(t)?t:this._getAll(e));const f=new Set;for(const k of p)f.add(S.getObjectId(k));const Q=w(t)?t.items:await this._reschedule(()=>this.featureStore.toArray(),s),X=await this._reschedule(async()=>{const k=await v(n,o,this.geometryType,this.hasZ,this.hasM),Y=O=>!f.has(S.getObjectId(O))||k(S.getGeometry(O)),K=await this._runSpatialFilter(Q,Y,s);return new d(K,e,this)},s);return l(X)}if(w(t)){const f=new ne;p=p.filter(Q=>ue(t.items,Q,t.items.length,f)>=0)}if(!p.length){const f=new d([],e,this);return m&&this._geometryQueryCache.put(m,f.items,1),f}if(this._canExecuteSinglePass(o,e))return l(new d(p,e,this));const b=await v(n,o,this.geometryType,this.hasZ,this.hasM),$=await this._runSpatialFilter(p,f=>b(S.getGeometry(f)),s);return l(new d($,e,this))}_executeAggregateIdsQuery(e){if(e.items.length===0||!e.query.aggregateIds||!e.query.aggregateIds.length||g(this.aggregateAdapter))return;const t=new Set;for(const i of e.query.aggregateIds)this.aggregateAdapter.getFeatureObjectIds(i).forEach(r=>t.add(r));const s=this.featureAdapter.getObjectId;e.items=e.items.filter(i=>t.has(s(i)))}_executeObjectIdsQuery(e){if(e.items.length===0||!e.query.objectIds||!e.query.objectIds.length)return;const t=new Set(e.query.objectIds),s=this.featureAdapter.getObjectId;e.items=e.items.filter(i=>t.has(s(i)))}_executeTimeQuery(e){if(e.items.length===0)return;const t=Fe(this.timeInfo,e.query.timeExtent,this.featureAdapter);g(t)||(e.items=e.items.filter(t))}_executeAttributesQuery(e){if(e.items.length===0)return;const t=me(e.query.where,this.fieldsIndex);if(t){if(!t.isStandardized)throw new TypeError("Where clause is not standardized");e.items=e.items.filter(s=>t.testFeature(s,this.featureAdapter))}}async _runSpatialFilter(e,t,s){if(!t)return e;if(g(this._frameTask))return e.filter(a=>t(a));let i=0;const r=new Array,n=async a=>{for(;i<e.length;){const u=e[i++];t(u)&&(r.push(u),a.madeProgress()),a.done&&await this._reschedule(h=>n(h),s)}};return this._reschedule(a=>n(a),s).then(()=>r)}_filterLatest(e){const{trackIdField:t,startTimeField:s,endTimeField:i}=this.timeInfo,r=i||s,n=new Map,a=this.featureAdapter.getAttribute;for(const u of e.items){const h=a(u,t),o=a(u,r),c=n.get(h);(!c||o>a(c,r))&&n.set(h,u)}e.items=Array.from(n.values())}_canExecuteSinglePass(e,t){const{spatialRel:s}=t;return U(e)&&(s==="esriSpatialRelEnvelopeIntersects"||this.geometryType==="esriGeometryPoint"&&(s==="esriSpatialRelIntersects"||s==="esriSpatialRelContains"||s==="esriSpatialRelWithin"))}async _project(e,t){if(!t||I(this.spatialReference,t))return e;const s=this.featureAdapter,i=await _e(e.items.map(r=>Re(this.geometryType,this.hasZ,this.hasM,s.getGeometry(r))),this.spatialReference,t);return e.items=i.map((r,n)=>s.cloneWithGeometry(e.items[n],ce(r,this.hasZ,this.hasM))),e}_getQueryBBoxes(e){if(U(e)){if(oe(e))return[L(e.xmin,e.ymin,e.xmax,e.ymax)];if(he(e))return e.rings.map(t=>L(Math.min(t[0][0],t[2][0]),Math.min(t[0][1],t[2][1]),Math.max(t[0][0],t[2][0]),Math.max(t[0][1],t[2][1])))}return[le(fe(),e)]}_searchFeatures(e){for(const s of e)this.featureStore.forEachInBounds(s,i=>B.add(i));const t=Array.from(B.values());return B.clear(),t}async _checkStatisticsSupport(e,t){if(e.distance<0||e.geometryPrecision!=null||e.multipatchOption||e.pixelSize||e.relationParam||e.text||e.outStatistics||e.groupByFieldsForStatistics||e.having||e.orderByFields)throw new F(R,"Unsupported query options",{query:e});return this._checkAttributesQuerySupport(e),Promise.all([this._checkStatisticsParamsSupport(t),V(e,this.geometryType,this.spatialReference),q(this.spatialReference,e.outSR)]).then(()=>e)}async _checkStatisticsParamsSupport(e){let t=[];if(e.valueExpression){const{arcadeUtils:s}=await de();t=s.extractFieldNames(e.valueExpression)}if(e.field&&t.push(e.field),e.field2&&t.push(e.field2),e.field3&&t.push(e.field3),e.normalizationField&&t.push(e.normalizationField),!t.length)throw new F(R,"params should have at least a field or valueExpression",{params:e});A(this.fieldsIndex,t,"params contains missing fields")}async _checkQuerySupport(e){if(e.distance<0||e.geometryPrecision!=null||e.multipatchOption||e.pixelSize||e.relationParam||e.text)throw new F(R,"Unsupported query options",{query:e});return this._checkAttributesQuerySupport(e),this._checkStatisticsQuerySupport(e),Promise.all([V(e,this.geometryType,this.spatialReference),q(this.spatialReference,e.outSR)]).then(()=>e)}_checkAttributesQuerySupport(e){const{outFields:t,orderByFields:s,returnDistinctValues:i,outStatistics:r}=e,n=r?r.map(a=>a.outStatisticFieldName&&a.outStatisticFieldName.toLowerCase()).filter(Boolean):[];if(s&&s.length>0){const a=" asc",u=" desc",h=s.map(o=>{const c=o.toLowerCase();return c.includes(a)?c.split(a)[0]:c.includes(u)?c.split(u)[0]:o}).filter(o=>!n.includes(o));A(this.fieldsIndex,h,"orderByFields contains missing fields")}if(t&&t.length>0)A(this.fieldsIndex,t,"outFields contains missing fields");else if(i)throw new F(R,"outFields should be specified for returnDistinctValues",{query:e});pe(this.fieldsIndex,e.where)}_checkStatisticsQuerySupport(e){const{outStatistics:t,groupByFieldsForStatistics:s,having:i}=e,r=s&&s.length,n=t&&t.length;if(i){if(!r||!n)throw new F(R,"outStatistics and groupByFieldsForStatistics should be specified with having",{query:e});ge(this.fieldsIndex,i,t)}if(n){if(!Qe(t))return;const a=t.map(u=>u.onStatisticField).filter(Boolean);A(this.fieldsIndex,a,"onStatisticFields contains missing fields"),r&&A(this.fieldsIndex,s,"groupByFieldsForStatistics contains missing fields");for(const u of t){const{onStatisticField:h,statisticType:o}=u;if((o==="percentile_disc"||o==="percentile_cont")&&"statisticParameters"in u){const{statisticParameters:c}=u;if(!c)throw new F(R,"statisticParamters should be set for percentile type",{definition:u,query:e})}else if(o!=="count"&&h&&xe(h,this.fieldsIndex))throw new F(R,"outStatistics contains non-numeric fields",{definition:u,query:e})}}}async _getQueryEngineResultForStats(e,t,s){e=H(e);try{e=await this._schedule(()=>J(e,this.definitionExpression,this.spatialReference),s),e=await this._reschedule(()=>this._checkStatisticsSupport(e,t),s);const i=await this._reschedule(()=>this._executeSceneFilterQuery(e,s),s),r=await this._reschedule(()=>this._executeGeometryQuery(e,i,s),s);return await this._reschedule(()=>this._executeAggregateIdsQuery(r),s),await this._reschedule(()=>this._executeObjectIdsQuery(r),s),await this._reschedule(()=>this._executeTimeQuery(r),s),await this._reschedule(()=>this._executeAttributesQuery(r),s),r}catch(i){if(i!==E)throw i;return new d([],e,this)}}}const be=W(),x=W(),B=new Set;export{qe as Y};