One Hat Cyber Team

Edit File: influxdbPlugin.140a7777089f9559c11c.js

"use strict";(self.webpackChunkgrafana=self.webpackChunkgrafana||[]).push([[9404],{23912:(or,Ce,p)=>{p.r(Ce),p.d(Ce,{plugin:()=>sr});var _e=p(40187),f=p(2543),s=p(96540),x=p(22391),se=p(84167),B=p(88575),U=p(88323),ie=p(42418),et=p(91409),q=p(14186),A=p(10354),ee=p(2913);const be="Direct browser access in the InfluxDB datasource is no longer available. Switch to server access mode.",W="default";var E=(a=>(a.InfluxQL="InfluxQL",a.Flux="Flux",a.SQL="SQL",a))(E||{}),te=p(39268),le=p(9226);const D=20,tt=a=>{const{options:{jsonData:e,secureJsonData:t,secureJsonFields:r}}=a,n=(0,f.uniqueId)("influxdb-flux-config");return s.createElement(s.Fragment,null,s.createElement(te.C,null,s.createElement(q.I,{labelWidth:D,label:"Organization",htmlFor:`${n}-org`},s.createElement(A.p,{id:`${n}-org`,className:"width-20",value:e.organization||"",onChange:(0,x.PG)(a,"organization")}))),s.createElement(te.C,null,s.createElement(q.I,{labelWidth:D,label:"Token"},s.createElement(le.L4,{isConfigured:!!(r&&r.token),value:t?.token||"",label:"Token","aria-label":"Token",className:"width-20",onReset:()=>(0,x.QP)(a,"token"),onChange:(0,x.mn)(a,"token")}))),s.createElement(te.C,null,s.createElement(q.I,{labelWidth:D,label:"Default Bucket"},s.createElement(A.p,{className:"width-20",placeholder:"default bucket",value:e.defaultBucket||"",onChange:(0,x.PG)(a,"defaultBucket")}))),s.createElement(te.C,null,s.createElement(q.I,{labelWidth:D,label:"Min time interval",tooltip:`A lower limit for the auto group by time interval. Recommended to be set to write frequency,
				for example 1m if your data is written every minute.`},s.createElement(A.p,{className:"width-20",placeholder:"10s",value:e.timeInterval||"",onChange:(0,x.PG)(a,"timeInterval")}))))};var I=p(32196),Y=p(40845),O=p(76892);const Ae=[{label:"GET",value:"GET"},{label:"POST",value:"POST"}],Ne=a=>{const{options:e,onOptionsChange:t}=a,{database:r,jsonData:n,secureJsonData:i,secureJsonFields:l}=e,o=(0,Y.of)(at),u=(0,f.uniqueId)("influxdb-influxql-config");return s.createElement(s.Fragment,null,s.createElement(ie.F,{severity:"info",title:"Database Access"},s.createElement("p",null,"Setting the database for this datasource does not deny access to other databases. The InfluxDB query syntax allows switching the database in the query. For example:",s.createElement("code",null,"SHOW MEASUREMENTS ON _internal")," or",s.createElement("code",null,'SELECT * FROM "_internal".."database" LIMIT 10'),s.createElement("br",null),s.createElement("br",null),"To support data isolation and security, make sure appropriate permissions are configured in InfluxDB.")),s.createElement(B.D,{horizontal:!0,label:s.createElement(O.c,{width:D},"Database"),className:o.horizontalField,htmlFor:`${u}-db`},s.createElement(A.p,{id:`${u}-db`,className:"width-20",value:n.dbName??r,onChange:c=>{t({...e,database:"",jsonData:{...n,dbName:c.currentTarget.value}})}})),s.createElement(B.D,{horizontal:!0,label:s.createElement(O.c,{width:D},"User"),className:o.horizontalField,htmlFor:`${u}-user`},s.createElement(A.p,{id:`${u}-user`,className:"width-20",value:e.user||"",onChange:(0,x.zX)(a,"user")})),s.createElement(B.D,{horizontal:!0,label:s.createElement(O.c,{width:D},"Password"),className:o.horizontalField},s.createElement(le.L4,{isConfigured:!!(l&&l.password),value:i?.password||"",label:"Password","aria-label":"Password",className:"width-20",onReset:()=>(0,x.QP)(a,"password"),onChange:(0,x.mn)(a,"password")})),s.createElement(B.D,{horizontal:!0,label:s.createElement(O.c,{width:D,tooltip:`You can use either GET or POST HTTP method to query your InfluxDB database. The POST
          method allows you to perform heavy requests (with a lots of WHERE clause) while the GET method
          will restrict you and return an error if the query is too large.`},"HTTP Method"),htmlFor:`${u}-http-method`,className:o.horizontalField},s.createElement(U.l6,{inputId:`${u}-http-method`,className:"width-20",value:Ae.find(c=>c.value===e.jsonData.httpMode),options:Ae,defaultValue:e.jsonData.httpMode,onChange:(0,x.BD)(a,"httpMode")})),s.createElement(B.D,{horizontal:!0,label:s.createElement(O.c,{width:D,tooltip:"A lower limit for the auto group by time interval. Recommended to be set to write frequency, for example 1m if your data is written every minute."},"Min time interval"),className:o.horizontalField},s.createElement(A.p,{className:"width-20",placeholder:"10s",value:e.jsonData.timeInterval||"",onChange:(0,x.PG)(a,"timeInterval")})))},at=a=>({horizontalField:(0,I.css)({justifyContent:"initial",margin:`0 ${a.spacing(.5)} ${a.spacing(.5)} 0`})}),rt=a=>{const{options:e,onOptionsChange:t}=a,{jsonData:r,secureJsonData:n,secureJsonFields:i}=e,l=(0,Y.of)(nt),o=(0,f.uniqueId)("influxdb-sql-config");return s.createElement("div",null,s.createElement(B.D,{horizontal:!0,label:s.createElement(O.c,{width:D},"Database"),className:l.horizontalField,htmlFor:`${o}-dbName`},s.createElement(A.p,{id:`${o}-dbName`,className:"width-20","aria-label":"Database or bucket name",value:r.dbName,onChange:u=>{t({...e,jsonData:{...r,dbName:u.currentTarget.value}})}})),s.createElement(B.D,{horizontal:!0,label:s.createElement(O.c,{width:D},"Token"),className:l.horizontalField},s.createElement(le.L4,{label:"Token","aria-label":"Token",className:"width-20",value:n?.token||"",onReset:()=>(0,x.QP)(a,"token"),onChange:(0,x.mn)(a,"token"),isConfigured:!!(i&&i.token)})))},nt=a=>({horizontalField:(0,I.css)({justifyContent:"initial",margin:`0 ${a.spacing(.5)} ${a.spacing(.5)} 0`})}),V={[E.InfluxQL]:{label:"InfluxQL",value:E.InfluxQL,description:"The InfluxDB SQL-like query language."},[E.SQL]:{label:"SQL",value:E.SQL,description:"Native SQL language. Supported in InfluxDB 3.0"},[E.Flux]:{label:"Flux",value:E.Flux,description:"Supported in InfluxDB 2.x and 1.8+"}},st=[V[E.InfluxQL],V[E.Flux]],it=[V[E.InfluxQL],V[E.SQL],V[E.Flux]];class lt extends s.PureComponent{constructor(e){super(e),this.state={maxSeries:""},this.versionNotice={Flux:"Support for Flux in Grafana is currently in beta",SQL:"Support for SQL in Grafana is currently in alpha"},this.onVersionChanged=t=>{const{options:r,onOptionsChange:n}=this.props,i={...r,jsonData:{...r.jsonData,version:t.value}};if(t.value===E.Flux){i.access="proxy",i.basicAuth=!0,i.jsonData.httpMode="POST";const{user:l,database:o,...u}=i;n(u)}else n(i)},this.state.maxSeries=e.options.jsonData.maxSeries?.toString()||"",this.htmlPrefix=(0,f.uniqueId)("influxdb-config")}renderJsonDataOptions(){switch(this.props.options.jsonData.version){case E.InfluxQL:return s.createElement(Ne,{...this.props});case E.Flux:return s.createElement(tt,{...this.props});case E.SQL:return s.createElement(rt,{...this.props});default:return s.createElement(Ne,{...this.props})}}render(){const{options:e,onOptionsChange:t}=this.props,r=e.access==="direct";return s.createElement(s.Fragment,null,s.createElement(se.n,null,s.createElement("h3",{className:"page-heading"},"Query language"),s.createElement(B.D,null,s.createElement(U.l6,{"aria-label":"Query language",className:"width-30",value:V[e.jsonData.version??E.InfluxQL],options:ee.$W.featureToggles.influxdbSqlSupport?it:st,defaultValue:V[E.InfluxQL],onChange:this.onVersionChanged}))),e.jsonData.version!==E.InfluxQL&&s.createElement(ie.F,{severity:"info",title:this.versionNotice[e.jsonData.version]},s.createElement("p",null,"Please report any issues to: ",s.createElement("br",null),s.createElement("a",{href:"https://github.com/grafana/grafana/issues/new/choose"},"https://github.com/grafana/grafana/issues"))),r&&s.createElement(ie.F,{title:"Error",severity:"error"},be),s.createElement(et.t,{showAccessOptions:r,dataSourceConfig:e,defaultUrl:"http://localhost:8086",onChange:t,secureSocksDSProxyEnabled:ee.$W.secureSocksDSProxyEnabled}),s.createElement(se.n,null,s.createElement("h3",{className:"page-heading"},"InfluxDB Details"),this.renderJsonDataOptions(),s.createElement(q.I,{labelWidth:20,label:"Max series",tooltip:"Limit the number of series/tables that Grafana will process. Lower this number to prevent abuse, and increase it if you have lots of small time series and not all are shown. Defaults to 1000."},s.createElement(A.p,{placeholder:"1000",type:"number",className:"width-20",value:this.state.maxSeries,onChange:n=>{this.setState({maxSeries:n.currentTarget.value});const i=parseInt(n.currentTarget.value,10);(0,x.lO)(this.props,"maxSeries",Number.isFinite(i)?i:void 0)}}))))}}const ot=lt;var G=p(54479),v=p(1062);const oe=[],S={Aggregations:[],Selectors:[],Transformations:[],Predictors:[],Math:[],Aliasing:[],Fields:[]};function Re(a){const e=oe[a.type];if(!e)throw{message:"Could not find query part "+a.type};return new v.kW(a,e)}function T(a){oe[a.type]=new v.tI(a),a.category.push(oe[a.type])}const ue=[];function ut(a,e){return e+' AS "'+a.params[0]+'"'}function xe(a){const e=a.params[0];if(e==="*")return"*";let t=`"${e}"`;return e.endsWith("::tag")&&(t=`"${e.slice(0,-5)}"::tag`),e.endsWith("::field")&&(t=`"${e.slice(0,-7)}"::field`),t}function N(a,e){for(let t=0;t<a.length;t++){const r=a[t];if(r.def.category===S.Aggregations){if(r.def.type===e.def.type)return;if(r.def.type==="count"&&e.def.type==="distinct")break;if(r.def.type==="distinct"){const n=a.length>=t+2;if(e.def.type!=="count"&&n)a[t+1].def.category===S.Aggregations&&a.splice(t+1,1);else if(e.def.type==="count"){(!n||a[t+1].def.type!=="count")&&a.splice(t+1,0,e);return}}a[t]=e;return}if(r.def.category===S.Selectors){a[t]=e;return}}a.splice(1,0,e)}function P(a,e){let t;for(t=0;t<a.length;t++){const r=a[t];if(r.def.category===S.Math||r.def.category===S.Aliasing)break}a.splice(t,0,e)}function ct(a,e){const t=a.length;if(t>0){if(a[t-1].def.type==="math"){a[t-1]=e;return}if(t>1&&a[t-2].def.type==="math"){a[t-2]=e;return}else if(a[t-1].def.type==="alias"){a.splice(t-1,0,e);return}}a.push(e)}function mt(a,e){const t=a.length;if(t>0&&a[t-1].def.type==="alias"){a[t-1]=e;return}a.push(e)}function dt(a,e,t){const r=(0,f.map)(a,n=>Re({type:n.def.type,params:(0,f.clone)(n.params)}));t.selectModels.push(r)}T({type:"field",addStrategy:dt,category:S.Fields,params:[{type:"field",dynamicLookup:!0}],defaultParams:["value"],renderer:xe}),T({type:"count",addStrategy:N,category:S.Aggregations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"distinct",addStrategy:N,category:S.Aggregations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"integral",addStrategy:N,category:S.Aggregations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"mean",addStrategy:N,category:S.Aggregations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"median",addStrategy:N,category:S.Aggregations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"mode",addStrategy:N,category:S.Aggregations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"sum",addStrategy:N,category:S.Aggregations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"derivative",addStrategy:P,category:S.Transformations,params:[{name:"duration",type:"interval",options:["1s","10s","1m","5m","10m","15m","1h"]}],defaultParams:["10s"],renderer:v.Wn}),T({type:"spread",addStrategy:P,category:S.Transformations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"non_negative_derivative",addStrategy:P,category:S.Transformations,params:[{name:"duration",type:"interval",options:["1s","10s","1m","5m","10m","15m","1h"]}],defaultParams:["10s"],renderer:v.Wn}),T({type:"difference",addStrategy:P,category:S.Transformations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"non_negative_difference",addStrategy:P,category:S.Transformations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"moving_average",addStrategy:P,category:S.Transformations,params:[{name:"window",type:"int",options:[5,10,20,30,40]}],defaultParams:[10],renderer:v.Wn}),T({type:"cumulative_sum",addStrategy:P,category:S.Transformations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"stddev",addStrategy:P,category:S.Transformations,params:[],defaultParams:[],renderer:v.Wn}),T({type:"time",category:ue,params:[{name:"interval",type:"time",options:["$__interval","1s","10s","1m","5m","10m","15m","1h"]}],defaultParams:["$__interval"],renderer:v.Wn}),T({type:"fill",category:ue,params:[{name:"fill",type:"string",options:["none","null","0","previous","linear"]}],defaultParams:["null"],renderer:v.Wn}),T({type:"elapsed",addStrategy:P,category:S.Transformations,params:[{name:"duration",type:"interval",options:["1s","10s","1m","5m","10m","15m","1h"]}],defaultParams:["10s"],renderer:v.Wn}),T({type:"holt_winters",addStrategy:P,category:S.Predictors,params:[{name:"number",type:"int",options:[5,10,20,30,40]},{name:"season",type:"int",options:[0,1,2,5,10]}],defaultParams:[10,2],renderer:v.Wn}),T({type:"holt_winters_with_fit",addStrategy:P,category:S.Predictors,params:[{name:"number",type:"int",options:[5,10,20,30,40]},{name:"season",type:"int",options:[0,1,2,5,10]}],defaultParams:[10,2],renderer:v.Wn}),T({type:"bottom",addStrategy:N,category:S.Selectors,params:[{name:"count",type:"int"}],defaultParams:[3],renderer:v.Wn}),T({type:"first",addStrategy:N,category:S.Selectors,params:[],defaultParams:[],renderer:v.Wn}),T({type:"last",addStrategy:N,category:S.Selectors,params:[],defaultParams:[],renderer:v.Wn}),T({type:"max",addStrategy:N,category:S.Selectors,params:[],defaultParams:[],renderer:v.Wn}),T({type:"min",addStrategy:N,category:S.Selectors,params:[],defaultParams:[],renderer:v.Wn}),T({type:"percentile",addStrategy:N,category:S.Selectors,params:[{name:"nth",type:"int"}],defaultParams:[95],renderer:v.Wn}),T({type:"top",addStrategy:N,category:S.Selectors,params:[{name:"count",type:"int"}],defaultParams:[3],renderer:v.Wn}),T({type:"tag",category:ue,params:[{name:"tag",type:"string",dynamicLookup:!0}],defaultParams:["tag"],renderer:xe}),T({type:"math",addStrategy:ct,category:S.Math,params:[{name:"expr",type:"string"}],defaultParams:[" / 100"],renderer:v.Dw}),T({type:"alias",addStrategy:mt,category:S.Aliasing,params:[{name:"name",type:"string",quote:"double"}],defaultParams:["alias"],renderMode:"suffix",renderer:ut});const k={create:Re,getCategories:()=>S,replaceAggregationAdd:N};class M{constructor(e,t,r){this.selectModels=[],this.target=e,this.templateSrv=t,this.scopedVars=r,e.policy=e.policy||W,e.resultFormat=e.resultFormat||"time_series",e.orderByTime=e.orderByTime||"ASC",e.tags=e.tags||[],e.groupBy=e.groupBy||[{type:"time",params:["$__interval"]},{type:"fill",params:["null"]}],e.select=e.select||[[{type:"field",params:["value"]},{type:"mean",params:[]}]],this.updateProjection()}updateProjection(){this.selectModels=(0,f.map)(this.target.select,e=>(0,f.map)(e,k.create)),this.groupByParts=(0,f.map)(this.target.groupBy,k.create)}updatePersistedParts(){this.target.select=(0,f.map)(this.selectModels,e=>(0,f.map)(e,t=>({type:t.def.type,params:t.params})))}hasGroupByTime(){return(0,f.find)(this.target.groupBy,e=>e.type==="time")}hasFill(){return(0,f.find)(this.target.groupBy,e=>e.type==="fill")}addGroupBy(e){let t=e.match(/^(\w+)$(.*)$$/);if(!t||!this.target.groupBy)return;const r=t[1],n=t[2],i=k.create({type:r,params:[n]}),l=this.target.groupBy.length;l===0?this.target.groupBy.push(i.part):r==="time"?this.target.groupBy.splice(0,0,i.part):r==="tag"?this.target.groupBy[l-1].type==="fill"?this.target.groupBy.splice(l-1,0,i.part):this.target.groupBy.push(i.part):this.target.groupBy.push(i.part),this.updateProjection()}removeGroupByPart(e,t){const r=k.getCategories();e.def.type==="time"&&(this.target.groupBy=(0,f.filter)(this.target.groupBy,n=>n.type!=="fill"),this.target.select=(0,f.map)(this.target.select,n=>(0,f.filter)(n,i=>{const l=k.create(i);return!(l.def.category===r.Aggregations||l.def.category===r.Selectors)}))),this.target.groupBy.splice(t,1),this.updateProjection()}removeSelect(e){this.target.select.splice(e,1),this.updateProjection()}removeSelectPart(e,t){if(t.def.type==="field"){if(this.selectModels.length>1){const r=(0,f.indexOf)(this.selectModels,e);this.selectModels.splice(r,1)}}else{const r=(0,f.indexOf)(e,t);e.splice(r,1)}this.updatePersistedParts()}addSelectPart(e,t){const r=k.create({type:t});r.def.addStrategy(e,r,this),this.updatePersistedParts()}isOperatorTypeHandler(e,t,r){let n;if(e==="Is Not"?e="!=":e="=",r.endsWith("::tag"))return n="'"+t.replace(/\\/g,"\\\\").replace(/\'/g,"\\'")+"'",{operator:e,value:n};let i=t.toLowerCase();return isNaN(parseFloat(t))?["true","false"].includes(i)?n=i:n="'"+t.replace(/\\/g,"\\\\").replace(/\'/g,"\\'")+"'":n=t,{operator:e,value:n}}renderTagCondition(e,t,r){let n="",i=e.operator,l=e.value;if(t>0&&(n=(e.condition||"AND")+" "),i||(/^\/.*\/$/.test(l)?i="=~":i="="),i!=="=~"&&i!=="!~")if(r&&(l=this.templateSrv.replace(l,this.scopedVars)),i.startsWith("Is")){let u=this.isOperatorTypeHandler(i,l,e.key);i=u.operator,l=u.value}else(!i.startsWith(">")&&!i.startsWith("<")||i==="<>")&&(l="'"+l.replace(/\\/g,"\\\\").replace(/\'/g,"\\'")+"'");else r&&(l=this.templateSrv.replace(l,this.scopedVars,"regex"));let o=`"${e.key}"`;return e.key.endsWith("::tag")&&(o=`"${e.key.slice(0,-5)}"::tag`),e.key.endsWith("::field")&&(o=`"${e.key.slice(0,-7)}"::field`),n+o+" "+i+" "+l}getMeasurementAndPolicy(e){let t=this.target.policy,r=this.target.measurement||"measurement";return r.match("^/.*/$")?e&&(r=this.templateSrv.replace(r,this.scopedVars,"regex")):r='"'+r+'"',t!==W?t='"'+this.target.policy+'".':t="",t+r}interpolateQueryStr(e,t,r){return!t.multi&&!t.includeAll?e:typeof e=="string"?(0,G.$f)(e):"("+(0,f.map)(e,G.$f).join("|")+")"}render(e){const t=this.target;if(t.rawQuery)return e?this.templateSrv.replace(t.query,this.scopedVars,this.interpolateQueryStr):t.query;let r="SELECT ",n,i;for(n=0;n<this.selectModels.length;n++){const u=this.selectModels[n];let c="";for(i=0;i<u.length;i++)c=u[i].render(c);n>0&&(r+=", "),r+=c}r+=" FROM "+this.getMeasurementAndPolicy(e)+" WHERE ";const l=(0,f.map)(t.tags,(u,c)=>this.renderTagCondition(u,c,e));l.length>0&&(r+="("+l.join(" ")+") AND "),r+="$timeFilter";let o="";for(n=0;n<this.groupByParts.length;n++){const u=this.groupByParts[n];n>0&&(o+=u.def.type==="fill"?" ":", "),o+=u.render("")}return o.length&&(r+=" GROUP BY "+o),t.fill&&(r+=" fill("+t.fill+")"),t.orderByTime==="DESC"&&(r+=" ORDER BY time DESC"),t.limit&&(r+=" LIMIT "+t.limit),t.slimit&&(r+=" SLIMIT "+t.slimit),t.tz&&(r+=" tz('"+t.tz+"')"),r}renderAdhocFilters(e){return(0,f.map)(e,(r,n)=>this.renderTagCondition(r,n,!0)).join(" ")}}function Oe(a){const e=(0,f.cloneDeep)(a);return new M(e).render(!1)}function ft(a){if(a.policy!==void 0&&a.resultFormat!==void 0&&a.orderByTime!==void 0&&a.tags!==void 0&&a.groupBy!==void 0&&a.select!==void 0)return a;const e=(0,f.cloneDeep)(a);return new M(e).target}function pt(a,e,t){const r=(0,f.cloneDeep)(a),n=new M(r);return n.addSelectPart(n.selectModels[t],e),n.target}function gt(a,e,t){const r=(0,f.cloneDeep)(a),n=new M(r),i=n.selectModels[t];return n.removeSelectPart(i,i[e]),n.target}function ht(a,e,t,r){const n=[...a.select??[]];return n[e]=[...n[e]],n[e][t]={...n[e][t],params:r},{...a,select:n}}function yt(a,e){const t=(0,f.cloneDeep)(a),r=new M(t);return r.addGroupBy(e),r.target}function Et(a,e){const t=(0,f.cloneDeep)(a),r=new M(t);return r.removeGroupByPart(r.groupByParts[e],e),r.target}function St(a,e,t){const r=[...a.groupBy??[]];return r[e]={...r[e],params:t},{...a,groupBy:r}}var ce=p(72574),z=p(19716),Tt=p(32372),ae=p(55852),vt=p(38401),F=p(38894);const It=[{label:"Show buckets",description:"List the available buckets (table)",value:"buckets()"},{label:"Simple query",description:"filter by measurement and field",value:`from(bucket: "db/rp")
  |> range(start: v.timeRangeStart, stop:v.timeRangeStop)
  |> filter(fn: (r) =>
    r._measurement == "example-measurement" and
    r._field == "example-field"
  )`},{label:"Grouped Query",description:"Group by (min/max/sum/median)",value:`// v.windowPeriod is a variable referring to the current optimized window period (currently: $interval)
from(bucket: v.bucket)
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "measurement1" or r["_measurement"] =~ /^.*?regex.*$/)
  |> filter(fn: (r) => r["_field"] == "field2" or r["_field"] =~ /^.*?regex.*$/)
  |> aggregateWindow(every: v.windowPeriod, fn: mean|median|max|count|derivative|sum)
  |> yield(name: "some-name")`},{label:"Filter by value",description:"Results between a min/max",value:`// v.bucket, v.timeRangeStart, and v.timeRange stop are all variables supported by the flux plugin and influxdb
from(bucket: v.bucket)
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_value"] >= 10 and r["_value"] <= 20)`},{label:"Schema Exploration: (measurements)",description:"Get a list of measurement using flux",value:`import "influxdata/influxdb/v1"
v1.measurements(bucket: v.bucket)`},{label:"Schema Exploration: (fields)",description:"Return every possible key in a single table",value:`from(bucket: v.bucket)
  |> range(start: v.timeRangeStart, stop:v.timeRangeStop)
  |> keys()
  |> keep(columns: ["_value"])
  |> group()
  |> distinct()`},{label:"Schema Exploration: (tag keys)",description:"Get a list of tag keys using flux",value:`import "influxdata/influxdb/v1"
v1.tagKeys(bucket: v.bucket)`},{label:"Schema Exploration: (tag values)",description:"Get a list of tag values using flux",value:`import "influxdata/influxdb/v1"
v1.tagValues(
    bucket: v.bucket,
    tag: "host",
    predicate: (r) => true,
    start: -1d
)`}];class Ct extends s.PureComponent{constructor(){super(...arguments),this.onFluxQueryChange=e=>{this.props.onChange({...this.props.query,query:e}),this.props.onRunQuery()},this.onSampleChange=e=>{this.props.onChange({...this.props.query,query:e.value}),this.forceUpdate(),this.props.onRunQuery()},this.getSuggestions=()=>{const e=[{label:"v.timeRangeStart",kind:z.q.Property,detail:"The start time"},{label:"v.timeRangeStop",kind:z.q.Property,detail:"The stop time"},{label:"v.windowPeriod",kind:z.q.Property,detail:"based on max data points"},{label:"v.defaultBucket",kind:z.q.Property,detail:"bucket configured in the datsource"},{label:"v.organization",kind:z.q.Property,detail:"org configured for the datsource"}],t=(0,ce.w)();return t.getVariables().forEach(r=>{const n="${"+r.name+"}";let i=t.replace(n);i===n&&(i=""),e.push({label:n,kind:z.q.Text,detail:`(Template Variable) ${i}`})}),e},this.editorDidMountCallbackHack=e=>{setTimeout(()=>e.layout(),100)}}render(){const{query:e,theme:t}=this.props,r=bt(t),n=s.createElement("div",null,"Type: ",s.createElement("i",null,"ctrl+space")," to show template variable suggestions ",s.createElement("br",null),"Many queries can be copied from Chronograf");return s.createElement(s.Fragment,null,s.createElement(Tt.B,{height:"100%",containerStyles:r.editorContainerStyles,language:"sql",value:e.query||"",onBlur:this.onFluxQueryChange,onSave:this.onFluxQueryChange,showMiniMap:!1,showLineNumbers:!0,getSuggestions:this.getSuggestions,onEditorDidMount:this.editorDidMountCallbackHack}),s.createElement("div",{className:(0,I.cx)("gf-form-inline",r.editorActions)},s.createElement(ae.z9,{icon:"external-link-alt",variant:"secondary",target:"blank",href:"https://docs.influxdata.com/influxdb/latest/query-data/get-started/"},"Flux language syntax"),s.createElement(vt.Y,{options:It,value:"Sample query",onChange:this.onSampleChange,className:(0,I.css)`
              margin-top: -${t.spacing(.5)};
              margin-left: ${t.spacing(.5)};
            `}),s.createElement("div",{className:"gf-form gf-form--grow"},s.createElement("div",{className:"gf-form-label gf-form-label--grow"})),s.createElement(F.I,{width:5,tooltip:n},"Help")))}}const bt=a=>({editorContainerStyles:(0,I.css)`
    height: 200px;
    max-width: 100%;
    resize: vertical;
    overflow: auto;
    background-color: ${a.isDark?a.colors.background.canvas:a.colors.background.primary};
    padding-bottom: ${a.spacing(1)};
  `,editorActions:(0,I.css)`
    margin-top: 6px;
  `}),me=(0,Y.cV)(Ct);var H=p(71928),C=p(98765);function At(a){const e=[];for(const t of a){let r="text";switch(t.type?.toUpperCase()){case"BOOLEAN":case"BOOL":{r="boolean";break}case"BYTES":case"VARCHAR":{r="text";break}case"FLOAT":case"FLOAT64":case"INT":case"INTEGER":case"INT64":case"NUMERIC":case"BIGNUMERIC":{r="number";break}case"DATE":{r="date";break}case"TIMESTAMP(NANOSECOND, NONE)":case"DATETIME":{r="datetime";break}case"TIME":{r="time";break}case"TIMESTAMP":{r="datetime";break}case"GEOGRAPHY":{r="text";break}default:break}e.push({...t,raqbFieldType:r,icon:Nt(t.type.toUpperCase())})}return e}function Nt(a){switch(a){case"TIME":case"DATETIME":case"TIMESTAMP":return"clock-nine";case"BOOLEAN":return"toggle-off";case"INTEGER":case"FLOAT":case"FLOAT64":case"INT":case"SMALLINT":case"BIGINT":case"TINYINT":case"BYTEINT":case"INT64":case"NUMERIC":case"DECIMAL":return"calculator-alt";case"CHAR":case"VARCHAR":case"STRING":case"BYTES":case"TEXT":case"TINYTEXT":case"MEDIUMTEXT":case"LONGTEXT":return"text";case"GEOGRAPHY":return"map";default:return}}function Rt(a){return a[0]==='"'&&a[a.length-1]==='"'?a.substring(1,a.length-1).replace(/""/g,'"'):a[0]==="`"&&a[a.length-1]==="`"?a.substring(1,a.length-1):a}function Le(a){return"'"+a.replace(/'/g,"''")+"'"}function we({sql:a,table:e}){let t="";if(!a||!(0,H.YW)(a.columns))return t;const r=a.columns.map(n=>({...n,parameters:n.parameters?.map(i=>({...i,name:`"${i.name}"`}))}));if(t+=(0,H.oF)(r),e&&(t+=`FROM "${e}" `),t+='WHERE "time" >= $__timeFrom AND "time" <= $__timeTo ',a.whereString){const n=new RegExp("(\\s?)([^\\(]\\S+)(\\s?=)","g"),i='$1"$2"$3',l=a.whereString.replace(n,i);t+=`AND ${l} `}if(a.groupBy?.[0]?.property.name){const n=a.groupBy.map(i=>`"${i.property.name}"`).filter(i=>!(0,f.isEmpty)(i));t+=`GROUP BY ${n.join(", ")} `}return a.orderBy?.property.name&&(t+=`ORDER BY "${a.orderBy.property.name}" `),a.orderBy?.property.name&&a.orderByDirection&&(t+=`${a.orderByDirection} `),xt(a.limit)&&(t+=`LIMIT ${a.limit}`),t}const xt=a=>a!==void 0&&a>=0;function de(a){return Ot(a)?a:`"${a}"`}function Ot(a){const e=/^[a-zA-Z_][a-zA-Z0-9_$]*$/g.test(a);return!Lt.includes(a.toUpperCase())&&e}const Lt=["ACCESSIBLE","ADD","ALL","ALTER","ANALYZE","AND","AS","ASC","ASENSITIVE","BEFORE","BETWEEN","BIGINT","BINARY","BLOB","BOTH","BY","CALL","CASCADE","CASE","CHANGE","CHAR","CHARACTER","CHECK","COLLATE","COLUMN","CONDITION","CONSTRAINT","CONTINUE","CONVERT","CREATE","CROSS","CUBE","CUME_DIST","CURRENT_DATE","CURRENT_TIME","CURRENT_TIMESTAMP","CURRENT_USER","CURSOR","DATABASE","DATABASES","DAY_HOUR","DAY_MICROSECOND","DAY_MINUTE","DAY_SECOND","DEC","DECIMAL","DECLARE","DEFAULT","DELAYED","DELETE","DENSE_RANK","DESC","DESCRIBE","DETERMINISTIC","DISTINCT","DISTINCTROW","DIV","DOUBLE","DROP","DUAL","EACH","ELSE","ELSEIF","EMPTY","ENCLOSED","ESCAPED","EXCEPT","EXISTS","EXIT","EXPLAIN","FALSE","FETCH","FIRST_VALUE","FLOAT","FLOAT4","FLOAT8","FOR","FORCE","FOREIGN","FROM","FULLTEXT","FUNCTION","GENERATED","GET","GRANT","GROUP","GROUPING","GROUPS","HAVING","HIGH_PRIORITY","HOUR_MICROSECOND","HOUR_MINUTE","HOUR_SECOND","IF","IGNORE","IN","INDEX","INFILE","INNER","INOUT","INSENSITIVE","INSERT","INT","INT1","INT2","INT3","INT4","INT8","INTEGER","INTERSECT","INTERVAL","INTO","IO_AFTER_GTIDS","IO_BEFORE_GTIDS","IS","ITERATE","JOIN","JSON_TABLE","KEY","KEYS","KILL","LAG","LAST_VALUE","LATERAL","LEAD","LEADING","LEAVE","LEFT","LIKE","LIMIT","LINEAR","LINES","LOAD","LOCALTIME","LOCALTIMESTAMP","LOCK","LONG","LONGBLOB","LONGTEXT","LOOP","LOW_PRIORITY","MASTER_BIND","MASTER_SSL_VERIFY_SERVER_CERT","MATCH","MAXVALUE","MEDIUMBLOB","MEDIUMINT","MEDIUMTEXT","MIDDLEINT","MINUTE_MICROSECOND","MINUTE_SECOND","MOD","MODIFIES","NATURAL","NOT","NO_WRITE_TO_BINLOG","NTH_VALUE","NTILE","NULL","NUMERIC","OF","ON","OPTIMIZE","OPTIMIZER_COSTS","OPTION","OPTIONALLY","OR","ORDER","OUT","OUTER","OUTFILE","OVER","PARTITION","PERCENT_RANK","PRECISION","PRIMARY","PROCEDURE","PURGE","RANGE","RANK","READ","READS","READ_WRITE","REAL","RECURSIVE","REFERENCES","REGEXP","RELEASE","RENAME","REPEAT","REPLACE","REQUIRE","RESIGNAL","RESTRICT","RETURN","REVOKE","RIGHT","RLIKE","ROW","ROWS","ROW_NUMBER","SCHEMA","SCHEMAS","SECOND_MICROSECOND","SELECT","SENSITIVE","SEPARATOR","SET","SHOW","SIGNAL","SMALLINT","SPATIAL","SPECIFIC","SQL","SQLEXCEPTION","SQLSTATE","SQLWARNING","SQL_BIG_RESULT","SQL_CALC_FOUND_ROWS","SQL_SMALL_RESULT","SSL","STARTING","STORED","STRAIGHT_JOIN","SYSTEM","TABLE","TERMINATED","THEN","TINYBLOB","TINYINT","TINYTEXT","TO","TRAILING","TRIGGER","TRUE","UNDO","UNION","UNIQUE","UNLOCK","UNSIGNED","UPDATE","USAGE","USE","USING","UTC_DATE","UTC_TIME","UTC_TIMESTAMP","VALUES","VARBINARY","VARCHAR","VARCHARACTER","VARYING","VIRTUAL","WHEN","WHERE","WHILE","WINDOW","WITH","WRITE","XOR","YEAR_MONTH","ZEROFILL"];function wt(a){return`SELECT table_name FROM information_schema.tables WHERE table_schema = ${a!==void 0?j(a):"database()"} ORDER BY table_name`}function ur(){return"SELECT DISTINCT TABLE_SCHEMA from information_schema.TABLES where TABLE_TYPE != 'SYSTEM VIEW' ORDER BY TABLE_SCHEMA"}function Dt(a,e){let t="SELECT column_name, data_type FROM information_schema.columns WHERE ";return t+=Pt(a,e),t+=" ORDER BY column_name",t}function Pt(a,e){let t="";if(a.includes(".")){const r=a.split(".");return t="table_schema = "+j(r[0]),t+=" AND table_name = "+j(r[1]),t}else return t=`table_schema = ${e!==void 0?j(e):"database()"} AND table_name = `+j(a),t}function j(a){return Le(Rt(a))}var Ft=p(33125);const Mt=({getMeta:a})=>(e,t)=>({...t&&(0,Ft.N)(e,t),customStatementPlacement:Qt,customSuggestionKinds:kt(a)}),De={afterDatabase:"afterDatabase"},Bt={tablesWithinDatabase:"tablesWithinDatabase"},fe="FROM",Qt=()=>[{id:De.afterDatabase,resolve:(a,e,t)=>!!(a?.is(C.ks.Delimiter,".")&&e?.value===fe&&(t?.is(C.ks.IdentifierQuote)||t?.isIdentifier())&&a?.getPreviousUntil(C.ks.Keyword,[C.ks.IdentifierQuote],fe)?.filter(r=>r.isIdentifier()).length===1)}],kt=a=>()=>[{id:C.ng.Tables,overrideDefault:!0,suggestionsResolver:async e=>{const t=ge(e.currentToken);return(await a({schema:t})).map(pe(e))}},{id:C.ng.Columns,overrideDefault:!0,suggestionsResolver:async e=>{const t=Wt(e.currentToken),r=ge(t),n=$t(t);return!r||!n?[]:(await a({schema:r,table:n})).map(pe(e))}},{id:Bt.tablesWithinDatabase,applyTo:[De.afterDatabase],suggestionsResolver:async e=>{const t=ge(e.currentToken);return(await a({schema:t})).map(pe(e))}}];function pe(a){return function(e){return{label:e.name,insertText:e.completion??e.name,command:{id:"editor.action.triggerSuggest",title:""},kind:C.Io.Field,sortText:C.mY.High,range:{...a.range,startColumn:a.range.endColumn,endColumn:a.range.endColumn}}}}function ge(a){if(a?.isIdentifier()&&a.value[a.value.length-1]!==".")return a.value;if(a?.is(C.ks.Delimiter,"."))return a.getPreviousOfType(C.ks.Identifier)?.value;if(a?.is(C.ks.IdentifierQuote))return a.getPreviousOfType(C.ks.Identifier)?.value||a.getNextOfType(C.ks.Identifier)?.value}function $t(a){return a?.getNextOfType(C.ks.Identifier)?.value}const Ut=a=>(a?.getPreviousOfType(C.ks.Keyword,"SELECT")??null)?.getNextOfType(C.ks.Keyword,fe),Wt=a=>{const t=Ut(a)?.getNextOfType(C.ks.Identifier);return t?.isKeyword()&&t.next?.is(C.ks.Parenthesis,"(")?null:t};class Vt extends H.oK{constructor(e,t=(0,ce.w)()){super(e),this.instanceSettings=e,this.templateSrv=t}getQueryModel(){return{quoteLiteral:Le}}getSqlLanguageDefinition(){if(this.sqlLanguageDefinition!==void 0)return this.sqlLanguageDefinition;const e={getMeta:t=>this.fetchMeta(t)};return this.sqlLanguageDefinition={id:"flightsql",completionProvider:Mt(e),formatter:H.se},this.sqlLanguageDefinition}async fetchDatasets(){return Promise.resolve(["iox"])}async fetchTables(e){const t=wt(e),n=(await this.runSql(t,{refId:"tables"})).map(i=>de(i[0]));return n.unshift(...this.getTemplateVariables()),n}async fetchFields(e){if(!e.dataset||!e.table)return[];const t=this.templateSrv.replace(e.table),r=Dt(t,e.dataset),i=(await this.runSql(r,{refId:"fields"})).map(l=>({name:l[0],text:l[0],value:de(l[0]),type:l[1],label:l[0]}));return i.unshift(...this.getTemplateVariables().map(l=>({name:l,text:l,value:de(l),type:"",label:l}))),At(i)}getTemplateVariables(){return this.templateSrv.getVariables().map(e=>`$${e.name}`)}async fetchMeta(e){const t=this.instanceSettings.jsonData.database;return!e?.schema&&t?(await this.fetchTables(t)).map(n=>({name:n,completion:`${t}.${n}`,kind:C.Io.Class})):!e?.schema&&!t?(await this.fetchDatasets()).map(n=>({name:n,completion:`${n}.`,kind:C.Io.Module})):!e?.table&&(!t||e?.schema)?(await this.fetchTables(e?.schema)).map(n=>({name:n,completion:n,kind:C.Io.Class})):e?.table&&e.schema?(await this.fetchFields({dataset:e.schema,table:e.table})).map(n=>({name:n.name,completion:n.value,kind:C.Io.Field})):[]}getDB(){return this.db!==void 0?this.db:{datasets:()=>this.fetchDatasets(),tables:e=>this.fetchTables(e),fields:e=>this.fetchFields(e),validateQuery:(e,t)=>Promise.resolve({query:e,error:"",isError:!1,isValid:!0}),dsID:()=>this.id,toRawSql:we,functions:()=>["VARIANCE","STDDEV"],getEditorLanguageDefinition:()=>this.getSqlLanguageDefinition()}}}class Gt extends s.PureComponent{constructor(e){super(e);const{datasource:t}=e;this.datasource=new Vt({url:t.urls[0],access:t.access,id:t.id,jsonData:{allowCleartextPasswords:!1,tlsAuth:!1,tlsAuthWithCACert:!1,tlsSkipVerify:!1,maxIdleConns:1,maxOpenConns:1,maxIdleConnsAuto:!0,connMaxLifetime:1,timezone:"",user:"",database:"",url:t.urls[0],timeInterval:""},meta:t.meta,name:t.name,readOnly:!1,type:t.type,uid:t.uid},t.templateSrv)}transformQuery(e){const t=(0,H.To)(e);return{...t,dataset:"iox",sql:{...t.sql,limit:void 0}}}render(){const{query:e,theme:t,onRunQuery:r,onChange:n}=this.props,i=Ht(t),l=()=>r(),o=c=>{n({...c})},u=s.createElement("div",null,"Type: ",s.createElement("i",null,"ctrl+space")," to show template variable suggestions ",s.createElement("br",null),"Many queries can be copied from Chronograf");return s.createElement(s.Fragment,null,s.createElement(H.e_,{datasource:this.datasource,query:this.transformQuery(e),onRunQuery:l,onChange:o,queryHeaderProps:{dialect:"influx"}}),s.createElement("div",{className:(0,I.cx)("gf-form-inline",i.editorActions)},s.createElement(ae.z9,{icon:"external-link-alt",variant:"secondary",target:"blank",href:"https://docs.influxdata.com/influxdb/cloud-serverless/query-data/sql/"},"SQL language syntax"),s.createElement("div",{className:"gf-form gf-form--grow"},s.createElement("div",{className:"gf-form-label gf-form-label--grow"})),s.createElement(F.I,{width:5,tooltip:u},"Help")))}}const Ht=a=>({editorContainerStyles:(0,I.css)`
    height: 200px;
    max-width: 100%;
    resize: vertical;
    overflow: auto;
    background-color: ${a.isDark?a.colors.background.canvas:a.colors.background.primary};
    padding-bottom: ${a.spacing(1)};
  `,editorActions:(0,I.css)`
    margin-top: 6px;
  `}),Yt=(0,Y.cV)(Gt);var zt=p(96374);const Kt=({isRaw:a,onChange:e})=>{const[t,r]=(0,s.useState)(!1);return(0,s.useEffect)(()=>{r(!1)},[a]),a?s.createElement(s.Fragment,null,s.createElement(ae.$n,{"aria-label":"Switch to visual editor",icon:"pen",variant:"secondary",type:"button",onClick:()=>{r(!0)}}),s.createElement(zt.u,{isOpen:t,title:"Switch to visual editor mode",body:"Are you sure to switch to visual editor mode? You will lose the changes done in raw query mode.",confirmText:"Yes, switch to editor mode",dismissText:"No, stay in raw query mode",onConfirm:()=>{e(!1)},onDismiss:()=>{r(!1)}})):s.createElement(ae.$n,{"aria-label":"Switch to text editor",icon:"pen",variant:"secondary",type:"button",onClick:()=>{e(!0)}})};var he=p(21744),qt=p(66864);const Pe=[{label:"Time series",value:"time_series"},{label:"Table",value:"table"},{label:"Logs",value:"logs"}],Fe="time_series";var jt=p(84596);function re(a){const[e,t]=(0,s.useState)(a),r=(0,jt.A)(a);return(0,s.useEffect)(()=>{r!==a&&e!==a&&t(a)},[a,e,r]),[e,t]}const Xt=({query:a,onChange:e,onRunQuery:t})=>{const[r,n]=re(a.query),[i,l]=re(a.alias),o=(0,s.useId)(),u=(0,s.useId)(),c=a.resultFormat??Fe,d=()=>{e({...a,query:r,alias:i,resultFormat:c}),t()};return s.createElement("div",null,s.createElement(he.f,{"aria-label":"query",rows:3,spellCheck:!1,placeholder:"InfluxDB Query",onBlur:d,onChange:m=>{n(m.currentTarget.value)},value:r??""}),s.createElement(qt.Gy,null,s.createElement(F.I,{htmlFor:u},"Format as"),s.createElement(U.l6,{inputId:u,onChange:m=>{e({...a,resultFormat:m.value}),t()},value:c,options:Pe}),s.createElement(F.I,{htmlFor:o},"Alias by"),s.createElement(A.p,{id:o,type:"text",spellCheck:!1,placeholder:"Naming pattern",onBlur:d,onChange:m=>{l(m.currentTarget.value)},value:i??""})))};var K=p(64765);const ye=a=>{let e="",{type:t,templateService:r,scopedVars:n,database:i,measurement:l,retentionPolicy:o,tags:u,withKey:c,withMeasurementFilter:d}=a;switch(t){case"RETENTION_POLICIES":return'SHOW RETENTION POLICIES on "'+i+'"';case"FIELDS":return!l||l===""?"SHOW FIELD KEYS":(l&&!l.match(/^\/.*\/|^$/)&&(l='"'+l+'"',o&&o!==W&&(o='"'+o+'"',l=o+"."+l)),"SHOW FIELD KEYS FROM "+l);case"TAG_KEYS":e="SHOW TAG KEYS";break;case"TAG_VALUES":e="SHOW TAG VALUES";break;case"MEASUREMENTS":e="SHOW MEASUREMENTS",d&&(e+=" WITH MEASUREMENT =~ /(?i)"+(0,G.$f)(d)+"/");break;default:return e}if(l&&(!l.match("^/.*/")&&!l.match(/^merge$.*$/)&&(l='"'+l+'"'),o&&o!==W&&(o='"'+o+'"',l=o+"."+l),l!==""&&(e+=" FROM "+l)),c){let m=c;m.endsWith("::tag")&&(m=m.slice(0,-5)),e+=' WITH KEY = "'+m+'"'}if(u&&u.length>0){const m=(0,f.reduce)(u,(g,h)=>(h.key&&h.key===c||h.operator===">"||h.operator==="<"||g.push(Jt(h,g.length,r,n,!0)),g),[]);m.length>0&&(e+=" WHERE "+m.join(" "))}return t==="MEASUREMENTS"&&(e+=" LIMIT 100"),e};function Jt(a,e,t,r,n){let i="",l=a.operator,o=a.value;e>0&&(i=(a.condition||"AND")+" "),l||(/^\/.*\/$/.test(a.value)?l="=~":l="="),(o===""||l!=="=~"&&l!=="!~")&&(o="'"+o.replace(/\\/g,"\\\\").replace(/\'/g,"\\'")+"'"),l!=="=~"&&l!=="!~"?n?o=t.replace(o,r):l!==">"&&l!=="<"&&(o="'"+o.replace(/\\/g,"\\\\").replace(/\'/g,"\\'")+"'"):n&&(o=t.replace(o,r,"regex"));let u=`"${a.key}"`;return a.key.endsWith("::tag")&&(u=`"${a.key.slice(0,-5)}"::tag`),a.key.endsWith("::field")&&(u=`"${a.key.slice(0,-7)}"::field`),i+u+" "+l+" "+o}const X=async a=>{const{type:e,datasource:t,scopedVars:r,measurement:n,retentionPolicy:i,tags:l,withKey:o,withMeasurementFilter:u}=a,c=ye({type:e,scopedVars:r,measurement:n,retentionPolicy:i,tags:l,withKey:o,withMeasurementFilter:u,templateService:t.templateSrv,database:t.database}),d=i?t.templateSrv.replace(i,{},"regex"):"",m={query:c,policy:d,rawQuery:!0,refId:"metadataQuery"};if(ee.Ay.featureToggles.influxdbBackendMigration)return t.runMetadataQuery(m);{const g={policy:m.policy};return t.metricFindQuery(c,g)}};async function Zt(a){return(await X({type:"RETENTION_POLICIES",datasource:a})).map(t=>t.text)}async function _t(a,e,t){return(await X({type:"MEASUREMENTS",datasource:a,tags:e,withMeasurementFilter:t})).map(n=>n.text)}async function ea(a,e,t){return(await X({type:"TAG_KEYS",datasource:a,measurement:e,retentionPolicy:t})).map(n=>n.text)}async function ta(a,e,t,r,n){return t.endsWith("::field")?[]:(await X({type:"TAG_VALUES",tags:e,withKey:t,datasource:a,measurement:r,retentionPolicy:n})).map(l=>l.text)}async function Me(a,e,t){return(await X({type:"FIELDS",datasource:a,measurement:e,retentionPolicy:t})).map(n=>n.text)}function Be(a,e){return a.filter(t=>t.key.endsWith("::tag")||e.has(t.key+"::tag"))}function L(a){return{label:a,value:a}}function J(a){if(a==null)throw new Error("value must not be nullish");return a}function aa(){const a=k.getCategories(),e=[];return Object.keys(a).forEach(r=>{const n=a[r].map(i=>L(i.type));e.push({label:r,options:n})}),e}async function ra(a,e){const t=await e(),r={...a},n=new M(r),i=[];return n.hasFill()||i.push(L("fill(null)")),n.hasGroupByTime()||i.push(L("time($interval)")),t.forEach(l=>{i.push(L(`tag(${l})`))}),i}function na(a,e){const t=k.create(a).def,r=(a.params??[]).map(n=>n.toString());if(r.length!==t.params.length)throw new Error("Invalid query-segment");return r.map((n,i)=>{const l=t.params[i];return l.dynamicLookup?{value:n,options:J(e.get(`${t.type}_${i}`))}:l.options!=null?{value:n,options:()=>Promise.resolve(l.options)}:{value:n,options:null}})}function Qe(a,e){return a.map(t=>({name:t.type,params:na(t,e)}))}function sa(a){return(0,ce.w)().getVariables().map(a)}function Ee(a,e,t){let r=sa(e);return t&&(r=r.filter(n=>n.indexOf(t)>-1)),a.then(n=>[...r,...n])}function ke(a){return`/^$${a.name}$/`}function ia(a){return`$${a.name}`}const Se=(0,I.css)({paddingRight:"4px"}),la=(0,I.cx)("width-8",Se),oa=({format:a,inputId:e,onChange:t})=>s.createElement(U.l6,{inputId:e,className:la,onChange:r=>{t(J(r.value))},value:a,options:Pe});var Te=p(3721),ua=p(76459),ca=p.n(ua),ma=p(41053);const $e=(0,I.css)({minWidth:"160px"}),Ue=a=>a,da=({loadOptions:a,allowCustomValue:e,onChange:t,onClose:r})=>{const n=ca()(a,1e3,{leading:!0});return s.createElement("div",{className:$e},s.createElement(U.DW,{formatCreateLabel:Ue,defaultOptions:!0,autoFocus:!0,isOpen:!0,onCloseMenu:r,allowCustomValue:e,loadOptions:n,onChange:t,createOptionPosition:"first"}))},fa=({loadOptions:a,allowCustomValue:e,onChange:t,onClose:r})=>{const[n,i]=(0,ma.A)(a,[a]);return(0,s.useEffect)(()=>{i("")},[i,a]),s.createElement("div",{className:$e},s.createElement(U.l6,{isLoading:n.loading,formatCreateLabel:Ue,autoFocus:!0,isOpen:!n.loading,onCloseMenu:r,allowCustomValue:e,options:n.value??[],onChange:t,createOptionPosition:"first"}))},pa=({loadOptions:a,filterByLoadOptions:e,allowCustomValue:t,onChange:r,onClose:n})=>e?s.createElement(da,{loadOptions:a,allowCustomValue:t,onChange:r,onClose:n}):s.createElement(fa,{loadOptions:a,allowCustomValue:t,onChange:r,onClose:n}),ga=({initialValue:a,onChange:e,onClose:t})=>{const[r,n]=re(a);return s.createElement(A.p,{autoFocus:!0,type:"text",spellCheck:!1,onBlur:t,onKeyDown:i=>{i.key==="Enter"&&e(r)},onChange:i=>{n(i.currentTarget.value)},value:r})},ha=(0,I.css)({width:"auto",cursor:"pointer"}),$=({value:a,buttonClassName:e,loadOptions:t,filterByLoadOptions:r,allowCustomValue:n,onChange:i})=>{const[l,o]=(0,s.useState)(!1);if(l)return t!==void 0?s.createElement(pa,{loadOptions:t,filterByLoadOptions:r??!1,allowCustomValue:n,onChange:u=>{o(!1),i(u)},onClose:()=>{o(!1)}}):s.createElement(ga,{initialValue:a,onClose:()=>{o(!1)},onChange:u=>{o(!1),i({value:u,label:u})}});{const u=(0,I.cx)(ha,e);return s.createElement(O.c,{as:"button",className:u,onClick:()=>{o(!0)}},a)}},ya=({policy:a,measurement:e,onChange:t,getPolicyOptions:r,getMeasurementOptions:n})=>{const i=async()=>{const o=await r();return(o.some(c=>c===W)?o:[W,...o]).map(L)},l=async o=>(await n(o)).map(L);return s.createElement(s.Fragment,null,s.createElement($,{allowCustomValue:!0,value:a??"using default policy",loadOptions:i,onChange:o=>{t(o.value,e)}}),s.createElement($,{allowCustomValue:!0,value:e??"select measurement",loadOptions:l,filterByLoadOptions:!0,onChange:o=>{t(a,o.value)}}),e&&s.createElement(Te.Z,{style:{marginRight:"4px"},"aria-label":"remove",icon:"times",variant:"secondary",onClick:()=>{t(a,void 0)}}))},ne=({value:a,onChange:e,isWide:t,placeholder:r})=>{const[n,i]=re(a),l=()=>{e(n===""?void 0:n)};return s.createElement(s.Fragment,null,s.createElement(A.p,{placeholder:r,className:(0,I.cx)(t??!1?"width-14":"width-8",Se),type:"text",spellCheck:!1,onBlur:l,onChange:o=>{i(o.currentTarget.value)},value:n??""}))},Ea=[{label:"ascending",value:"ASC"},{label:"descending",value:"DESC"}],Sa=(0,I.cx)("width-9",Se),Ta=({value:a,onChange:e,inputId:t})=>s.createElement(s.Fragment,null,s.createElement(U.l6,{inputId:t,className:Sa,onChange:r=>{e(J(r.value))},value:a,options:Ea})),We=({loadOptions:a,allowCustomValue:e,onAdd:t})=>s.createElement($,{value:"+",loadOptions:a,allowCustomValue:e,onChange:r=>{t(J(r.value))}}),va=(0,I.css)({paddingRight:"0",marginRight:"0"}),Ia=(0,I.css)({paddingLeft:"0",paddingRight:"0",marginLeft:"0",marginRight:"0"}),Ca=a=>(0,I.cx)("gf-form-label",(0,I.css)({paddingLeft:"0",lineHeight:a.typography.body.lineHeight,fontSize:a.typography.body.fontSize})),ba=({name:a,params:e,onChange:t})=>{const r=(0,Y.$j)(),n=(0,s.useMemo)(()=>Ca(r),[r]),i=(l,o)=>{const u=e.map(c=>c.value);u[o]=l,t(u)};return s.createElement("div",{className:n},s.createElement("button",{className:(0,I.cx)("gf-form-label",va)},a),"(",e.map((l,o)=>{const{value:u,options:c}=l,d=o===e.length-1,m=c!==null?()=>c().then(g=>g.map(L)):void 0;return s.createElement(s.Fragment,{key:o},s.createElement($,{allowCustomValue:!0,value:u,buttonClassName:Ia,loadOptions:m,onChange:g=>{i(J(g.value),o)}}),!d&&",")}),")")},Ve=({parts:a,getNewPartOptions:e,onAddNewPart:t,onRemovePart:r,onChange:n})=>s.createElement(s.Fragment,null,a.map((i,l)=>s.createElement(s.Fragment,{key:l},s.createElement(ba,{name:i.name,params:i.params,onRemove:()=>{r(l)},onChange:o=>{n(l,o)}}),s.createElement(Te.Z,{style:{marginRight:"4px"},"aria-label":"remove",icon:"times",variant:"secondary",onClick:()=>{r(l)}}))),s.createElement(We,{loadOptions:e,onAdd:t}));function Ge(a){return/^\/.*\/$/.test(a)}function He(a){return a.operator??(Ge(a.value)?"=~":"=")}function Ye(a,e){return e?void 0:a.condition??"AND"}function Aa(a,e){const t=a==="=~"||a==="!~";return Ge(e)?t?a:"=~":t?"=":a}const Na=["=","!=","<>","<",">",">=","<=","=~","!~","Is","Is Not"],Ra=["AND","OR"],xa=Na.map(L),Oa=Ra.map(L),La=()=>Promise.resolve(Oa),wa=()=>Promise.resolve(xa),Da=({tag:a,isFirst:e,onRemove:t,onChange:r,getTagKeyOptions:n,getTagValueOptions:i})=>{const l=He(a),o=Ye(a,e),u=()=>n().catch(d=>(console.error(d),[])).then(d=>d.map(L)),c=()=>i(a.key).then(d=>d.map(L));return s.createElement("div",{className:"gf-form"},o!=null&&s.createElement($,{value:o,loadOptions:La,onChange:d=>{r({...a,condition:d.value})}}),s.createElement($,{allowCustomValue:!0,value:a.key,loadOptions:u,onChange:d=>{const{value:m}=d;m===void 0?t():r({...a,key:m??""})}}),s.createElement($,{value:l,loadOptions:wa,onChange:d=>{r({...a,operator:d.value})}}),s.createElement($,{allowCustomValue:!0,value:a.value,loadOptions:c,onChange:d=>{const m=d.value??"";r({...a,value:m,operator:Aa(l,m)})}}),s.createElement(Te.Z,{style:{marginRight:"4px"},"aria-label":"remove",icon:"times",variant:"secondary",onClick:()=>{t()}}))},Pa=({tags:a,onChange:e,getTagKeyOptions:t,getTagValueOptions:r})=>{const n=(u,c)=>{const d=a.map((m,g)=>c===g?u:m);e(d)},i=u=>{const c=a.filter((d,m)=>m!==u);e(c)},l=()=>t().then(u=>u.map(L)),o=(u,c)=>{const d={key:u,value:"select tag value"},m={key:d.key,value:d.value,operator:He(d),condition:Ye(d,c)};e([...a,m])};return s.createElement(s.Fragment,null,a.map((u,c)=>s.createElement(Da,{tag:u,isFirst:c===0,key:c,onChange:d=>{n(d,c)},onRemove:()=>{i(c)},getTagKeyOptions:t,getTagValueOptions:r})),s.createElement(We,{allowCustomValue:!0,loadOptions:l,onAdd:u=>{o(u,a.length===0)}}))},Fa=a=>{const e=(0,s.useId)(),t=`influxdb-qe-format-as-${e}`,r=`influxdb-qe-order-by${e}`,n=(0,Y.of)(Ma),i=ft(a.query),{datasource:l}=a,{measurement:o,policy:u}=i,c=(0,s.useMemo)(async()=>{const y=(await ea(l,o,u)).map(R=>`${R}::tag`),b=(await Me(l,o||"",u)).map(R=>`${R}::field`);return new Set([...y,...b])},[o,u,l]),d=(0,s.useMemo)(()=>{const y=new Map([["field_0",()=>o!==void 0?Me(l,o,u):Promise.resolve([])]]);return(i.select??[]).map(b=>Qe(b,y))},[o,u,i.select,l]),m=(0,s.useMemo)(()=>async()=>[...await c],[c]),g=(0,s.useMemo)(()=>{const y=new Map([["tag_0",m]]);return Qe(i.groupBy??[],y)},[m,i.groupBy]),h=y=>{a.onChange(y),a.onRunQuery()},w=(y,b)=>{h({...i,policy:y,measurement:b})},_=y=>{h({...i,tags:y.length===0?void 0:y})};return s.createElement("div",null,s.createElement(K.L,{label:"FROM",fill:!0},s.createElement(ya,{policy:u,measurement:o,getPolicyOptions:()=>Ee(Zt(l),ia),getMeasurementOptions:y=>Ee(c.then(b=>_t(l,Be(i.tags??[],b),y===""?void 0:y)),ke,y),onChange:w}),s.createElement(O.c,{width:"auto",className:n.inlineLabel},"WHERE"),s.createElement(Pa,{tags:i.tags??[],onChange:_,getTagKeyOptions:m,getTagValueOptions:y=>Ee(c.then(b=>ta(l,Be(i.tags??[],b),y)),ke)})),d.map((y,b)=>s.createElement(K.L,{key:b,label:b===0?"SELECT":"",fill:!0},s.createElement(Ve,{parts:y,getNewPartOptions:()=>Promise.resolve(aa()),onChange:(R,ir)=>{const lr=ht(i,b,R,ir);h(lr)},onAddNewPart:R=>{h(pt(i,R,b))},onRemovePart:R=>{h(gt(i,R,b))}}))),s.createElement(K.L,{label:"GROUP BY",fill:!0},s.createElement(Ve,{parts:g,getNewPartOptions:()=>ra(i,m),onChange:(y,b)=>{const R=St(i,y,b);h(R)},onAddNewPart:y=>{h(yt(i,y))},onRemovePart:y=>{h(Et(i,y))}})),s.createElement(K.L,{label:"TIMEZONE",fill:!0},s.createElement(ne,{placeholder:"(optional)",value:i.tz,onChange:y=>{h({...i,tz:y})}}),s.createElement(O.c,{htmlFor:r,width:"auto",className:n.inlineLabel},"ORDER BY TIME"),s.createElement(Ta,{inputId:r,value:i.orderByTime==="DESC"?"DESC":"ASC",onChange:y=>{h({...i,orderByTime:y})}})),s.createElement(K.L,{label:"LIMIT",fill:!0},s.createElement(ne,{placeholder:"(optional)",value:i.limit?.toString(),onChange:y=>{h({...i,limit:y})}}),s.createElement(O.c,{width:"auto",className:n.inlineLabel},"SLIMIT"),s.createElement(ne,{placeholder:"(optional)",value:i.slimit?.toString(),onChange:y=>{h({...i,slimit:y})}})),s.createElement(K.L,{htmlFor:t,label:"FORMAT AS",fill:!0},s.createElement(oa,{inputId:t,format:i.resultFormat??Fe,onChange:y=>{h({...i,resultFormat:y})}}),i.resultFormat!=="table"&&s.createElement(s.Fragment,null,s.createElement(O.c,{width:"auto",className:n.inlineLabel},"ALIAS"),s.createElement(ne,{isWide:!0,placeholder:"Naming pattern",value:i.alias,onChange:y=>{h({...i,alias:y})}}))))};function Ma(a){return{inlineLabel:(0,I.css)`
      color: ${a.colors.primary.text};
    `}}const Ba=({query:a,onChange:e,onRunQuery:t,datasource:r})=>{switch(r.version){case E.Flux:return s.createElement("div",{className:"gf-form-query-content"},s.createElement(me,{query:a,onChange:e,onRunQuery:t,datasource:r}));case E.SQL:return s.createElement(Yt,{datasource:r,query:a,onChange:e,onRunQuery:t});case E.InfluxQL:default:return s.createElement("div",{className:(0,I.css)({display:"flex"})},s.createElement("div",{className:(0,I.css)({flexGrow:1})},a.rawQuery?s.createElement(Xt,{query:a,onChange:e,onRunQuery:t}):s.createElement(Fa,{query:a,onChange:e,onRunQuery:t,datasource:r})),s.createElement(Kt,{isRaw:a.rawQuery??!1,onChange:n=>{e({...a,query:Oe(a),rawQuery:n}),t()}}))}},Qa=[{title:"Getting started",label:"Start by selecting a measurement and field from the dropdown above. You can then use the tag selector to further narrow your search."}],ka=()=>s.createElement("div",null,s.createElement("h2",null,"InfluxDB Cheat Sheet"),Qa.map(a=>s.createElement("div",{className:"cheat-sheet-item",key:a.title},s.createElement("div",{className:"cheat-sheet-item__title"},a.title),s.createElement("div",{className:"cheat-sheet-item__label"},a.label))));function $a(){return s.createElement(ka,null)}class Ua extends s.PureComponent{constructor(){super(...arguments),this.onRefresh=()=>{}}render(){let{query:e,datasource:t,onChange:r}=this.props;switch(t.version){case E.Flux:return s.createElement(me,{datasource:t,query:{refId:"A",query:e},onRunQuery:this.onRefresh,onChange:n=>r(n.query)});case E.SQL:return s.createElement(se.n,null,s.createElement(B.D,{htmlFor:"influx-sql-variable-query"},s.createElement(he.f,{id:"influx-sql-variable-query",defaultValue:e||"",placeholder:"metric name or tags query",rows:1,onBlur:n=>r(n.currentTarget.value)})));case E.InfluxQL:default:return s.createElement("div",{className:"gf-form-inline"},s.createElement(F.I,{width:10},"Query"),s.createElement("div",{className:"gf-form-inline gf-form--grow"},s.createElement(he.f,{defaultValue:e||"",placeholder:"metric name or tags query",rows:1,className:"gf-form-input",onBlur:n=>r(n.currentTarget.value)})))}}}var ze=p(13288),Wa=p(88483),Va=p(44240),Z=p(75505),ve=p(62467),Ie=p(81160),Ga=p(66847),Ha=p(14236),Ya=p(85858),Q=p(11261),za=p(26657),Ke=p(47773),qe=p(17172),Ka=p(87986);const qa=a=>{const{query:e,onChange:t}=a,[r,n]=(0,s.useState)(e.query??""),[i,l]=(0,s.useState)(e.textColumn??""),[o,u]=(0,s.useState)(e.tagsColumn??""),[c,d]=(0,s.useState)(e?.timeEndColumn??""),[m]=(0,s.useState)(e?.titleColumn??""),g=(h,w)=>{t({...e,[h]:w,rawQuery:!0,fromAnnotations:!0,textEditor:!0})};return s.createElement("div",{className:"gf-form-group"},s.createElement("div",{className:"gf-form"},s.createElement(F.I,{width:12},"InfluxQL Query"),s.createElement(A.p,{value:r,onChange:h=>n(h.currentTarget.value??""),onBlur:()=>g("query",r),placeholder:"select text from events where $timeFilter limit 1000"})),s.createElement(F.I,{width:12,tooltip:s.createElement("div",null,"If your influxdb query returns more than one field you need to specify the column names below. An annotation event is composed of a title, tags, and an additional text field. Optionally you can map the timeEnd column for region annotation usage.")},"Field mappings"),s.createElement("div",{className:"gf-form-group"},s.createElement("div",{className:"gf-form-inline"},s.createElement("div",{className:"gf-form"},s.createElement(F.I,{width:12},"Text"),s.createElement(A.p,{value:i,onChange:h=>l(h.currentTarget.value??""),onBlur:()=>g("textColumn",i)})),s.createElement("div",{className:"gf-form"},s.createElement(F.I,{width:12},"Tags"),s.createElement(A.p,{value:o,onChange:h=>u(h.currentTarget.value??""),onBlur:()=>g("tagsColumn",o)})),s.createElement("div",{className:"gf-form"},s.createElement(F.I,{width:12},"TimeEnd"),s.createElement(A.p,{value:c,onChange:h=>d(h.currentTarget.value??""),onBlur:()=>g("timeEndColumn",c)})),s.createElement("div",{className:"gf-form ng-hide"},s.createElement(F.I,{width:12},"Title"),s.createElement(A.p,{defaultValue:m})))))};var je=p(91950);class Xe{constructor(e){this.series=e.series,this.alias=e.alias,this.annotation=e.annotation,this.meta=e.meta,this.refId=e.refId}getTimeSeries(){const e=[];let t,r;return this.series.length===0||(0,f.each)(this.series,n=>{const i=n.columns.length,l=(0,f.map)(n.tags,(o,u)=>u+": "+o);for(r=1;r<i;r++){let o=n.name;const u=n.columns[r];u!=="value"&&(o=o+"."+u),this.alias?o=this._getSeriesName(n,r):n.tags&&(o=o+" {"+l.join(", ")+"}");const c=[];if(n.values)for(t=0;t<n.values.length;t++)c[t]=[n.values[t][r],n.values[t][0]];e.push({title:o,target:o,datapoints:c,tags:n.tags,meta:this.meta,refId:this.refId})}}),e}_getSeriesName(e,t){const r=/\$(\w+)|\[\[([\s\S]+?)\]\]/g,n=e.name.split(".");return this.alias.replace(r,(i,l,o)=>{const u=l||o,c=parseInt(u,10);if(u==="m"||u==="measurement")return e.name;if(u==="col")return e.columns[t];if(!isNaN(c))return n[c]??i;if(u.indexOf("tag_")!==0)return i;const d=u.replace("tag_","");return e.tags?e.tags[d]:i})}getAnnotations(){const e=[];return(0,f.each)(this.series,t=>{let r=null,n=null,i=null;const l=[];let o=null;(0,f.each)(t.columns,(u,c)=>{if(u==="time"){n=c;return}if(u!=="sequence_number"){if(u===this.annotation.titleColumn){r=c;return}if((0,f.includes)((this.annotation.tagsColumn||"").replace(" ","").split(","),u)){l.push(c);return}if(u===this.annotation.textColumn){o=c;return}if(u===this.annotation.timeEndColumn){i=c;return}!r&&o!==c&&(r=c)}}),(0,f.each)(t.values,u=>{const c={annotation:this.annotation,time:+new Date(u[n]),title:u[r],timeEnd:u[i],tags:(0,f.flatten)(l.filter(d=>u[d]).map(d=>u[d].split(","))),text:u[o]};e.push(c)})}),e}getTable(){const e=new je.A;let t,r;return e.refId=this.refId,e.meta=this.meta,this.series.length===0||(0,f.each)(this.series,(n,i)=>{if(i===0){const l=n.columns[0],o=l==="time"?{text:"Time",type:Q.PU.time}:{text:l};for(e.columns.push(o),(0,f.each)((0,f.keys)(n.tags),u=>{e.columns.push({text:u})}),r=1;r<n.columns.length;r++)e.columns.push({text:n.columns[r]})}if(n.values)for(t=0;t<n.values.length;t++){const l=n.values[t],o=[l[0]];if(n.tags)for(const u in n.tags)n.tags.hasOwnProperty(u)&&o.push(n.tags[u]);for(r=1;r<l.length;r++)o.push(l[r]);e.rows.push(o)}}),e}}const ja=a=>{const e={refId:"",query:a.query??"",queryType:"tags",fromAnnotations:!0,tagsColumn:a.tagsColumn??"",textColumn:a.textColumn??"",timeEndColumn:a.timeEndColumn??"",titleColumn:a.titleColumn??"",name:a.name??""};return a.target&&a.target.limit&&(e.limit=a.target.limit),a.target&&a.target.matchAny&&(e.matchAny=a.target.matchAny),a.target&&a.target.tags&&(e.tags=a.target.tags),a.target&&a.target.type&&(e.type=a.target.type),e},Xa=a=>(a.target=a.target&&!a.target?.query?ja(a):a.target,a);class Ja{parse(e,t){if(!t?.results||t.results.length===0)return[];const r=t.results[0];if(!r.series)return[];const n=e.toLowerCase(),i=n.indexOf("show retention policies")>=0,l=n.indexOf("show field keys")>=0||i,o=new Set;return(0,f.each)(r.series,u=>{(0,f.each)(u.values,c=>{(0,f.isArray)(c)?l?o.add(c[0].toString()):c[1]!==void 0?o.add(c[1].toString()):o.add(c[0].toString()):o.add(c.toString())})}),Array.from(o).map(u=>({text:u}))}getTable(e,t,r){let n=new je.A;if(e.length>0)if(n.meta={...r,executedQueryString:e[0].meta?.executedQueryString},n.refId=t.refId,n=_a(e,n,t),e[0].fields[1]&&e[0].fields[1].labels){let i=(0,f.groupBy)(e,u=>u.fields[1].labels?Object.values(u.fields[1].labels):null);const l=Object.keys(i),o=Object.values(i);for(let u=0;u<o.length;u++)n=Je(o[u],n,[...l[u].split(",")])}else n=Je(e,n,[]);return n}async transformAnnotationResponse(e,t,r){const n=(0,Ke.bE)(t,[r]);if(!n)return[];const i=this.getTable(n.data,r,{}),l=[];let o=0,u=0,c=0,d=0;const m=[];return(0,f.each)(i.columns,(g,h)=>{if(g.text.toLowerCase()==="time"){u=h;return}if(g.text===e.titleColumn){o=h;return}if(Za(g.text,e.tagsColumn)){m.push(h);return}if(e.textColumn&&g.text.includes(e.textColumn)){d=h;return}if(g.text===e.timeEndColumn){c=h;return}!o&&d!==h&&(o=h)}),(0,f.each)(i.rows,g=>{const h={annotation:e,time:+new Date(g[u]),title:g[o],timeEnd:g[c],tags:(0,f.flatten)(m.filter(w=>g[w]).map(w=>g[w].split(","))),text:g[d]};l.push(h)}),l}}function Za(a,e){const t=(e||"").replace(" ","").split(",");for(const r of t)if(r!==""&&a.includes(r))return!0;return!1}function _a(a,e,t){const r=er(t);a[0].fields.forEach(n=>{n.name.toLowerCase()==="time"?e.columns.push({text:"Time",type:Q.PU.time}):n.name.toLowerCase()==="value"&&n.labels&&Object.keys(n.labels).forEach(i=>{e.columns.push({text:i})})}),a[0].refId==="metricFindQuery"&&a.forEach(n=>{n.name&&e.columns.push({text:n.name})});for(let n=0;n<r.length;n++)e.columns.push({text:r[n]});return t.rawQuery&&r.length===0&&tr(t.query,a)&&a[0].refId!=="metricFindQuery"&&a.map(n=>{n.name&&e.columns.push({text:n.name})}),e}function Je(a,e,t){const r=a[0].fields[0].values;for(let n=0;n<r.length;n++){const i=r[n],l=a.map(o=>o.fields[1]?o.fields[1].values[n]:null);l.indexOf(null)<0&&e.rows.push([i,...t,...l])}return e}function er(a){let e=[];a.select?.forEach(r=>{const n=r.filter(i=>i.type!=="field");if(n.length>0){const i=n.find(l=>l.type==="alias");i?e.push(i.params?.[0].toString()??""):e.push(n[0].type)}else r[0]&&r[0].params&&r[0].params[0]&&e.push(r[0].params[0].toString())});let t=[];return e.forEach(r=>{t.push(Ze(r,r,t,0))}),t}function Ze(a,e,t,r){return t.indexOf(e)>-1?(r++,Ze(a,a+"_"+r,t,r)):e}function tr(a,e){const r=e.map(l=>l.name).every(l=>l&&a?l.split(".").every(u=>a.toLowerCase().includes(u.toLowerCase())):!1),i=["*","SHOW"].some(l=>a?a.toLowerCase().includes(l.toLowerCase()):!1);return r||i}class ar extends za.iy{constructor(e,t=(0,Ka.w)()){super(e),this.templateSrv=t,this.type="influxdb",this.urls=(e.url??"").split(",").map(n=>n.trim()),this.username=e.username??"",this.password=e.password??"",this.name=e.name,this.basicAuth=e.basicAuth,this.withCredentials=e.withCredentials,this.access=e.access;const r=e.jsonData??{};this.database=r.dbName??e.database,this.interval=r.timeInterval,this.httpMode=r.httpMode||"GET",this.responseParser=new Ja,this.version=r.version??E.InfluxQL,this.isProxyAccess=e.access==="proxy",this.version===E.Flux?this.annotations={QueryEditor:me}:this.annotations={QueryEditor:qa,prepareAnnotation:Xa}}query(e){if(!this.isProxyAccess){const t=new Error(be);return(0,ze.$)(()=>t)}return this._query(e)}_query(e){const t={...e,targets:e.targets.filter(r=>r.hide!==!0)};if(t.targets.some(r=>r.fromAnnotations)){const r=[];for(const n of t.targets)n.query&&r.push(new Wa.c(i=>{this.annotationEvents(t,n).then(l=>i.next({data:[(0,Ha.Vc)(l)]})).catch(l=>i.error(new Error(l))).finally(()=>i.complete())}));return(0,Va.h)(...r)}return this.version===E.InfluxQL&&!this.isMigrationToggleOnAndIsAccessProxy()?this.classicQuery(e):super.query(t)}getQueryDisplayText(e){switch(this.version){case E.Flux:return e.query;case E.SQL:return we(e);case E.InfluxQL:return new M(e).render(!1);default:return""}}filterQuery(e){return this.version===E.Flux?!!e.query:!0}applyTemplateVariables(e,t){const{__interval:r,__interval_ms:n,...i}=t||{};if(this.version===E.Flux)return{...e,query:this.templateSrv.replace(e.query??"",i)};if((this.version===E.SQL||this.isMigrationToggleOnAndIsAccessProxy())&&(e=this.applyVariables(e,i),e.adhocFilters?.length)){const l=(e.adhocFilters??[]).map(o=>{const{condition:u,...c}=o;return c});e.tags=[...e.tags??[],...l]}return e}targetContainsTemplate(e){const t=this.version===E.Flux?e.query:Oe(e);return this.templateSrv.containsTemplate(t)}interpolateVariablesInQueries(e,t){return!e||e.length===0?[]:e.map(r=>this.version===E.Flux?{...r,datasource:this.getRef(),query:this.templateSrv.replace(r.query??"",t,(n=[],i)=>this.interpolateQueryExpr(n,i,r.query))}:{...r,datasource:this.getRef(),...this.applyVariables(r,t)})}applyVariables(e,t){const r={...e};return e.groupBy&&(r.groupBy=e.groupBy.map(n=>({...n,params:n.params?.map(i=>this.templateSrv.replace(i.toString(),void 0))}))),e.select&&(r.select=e.select.map(n=>n.map(i=>({...i,params:i.params?.map(l=>this.templateSrv.replace(l.toString(),void 0))})))),e.tags&&(r.tags=e.tags.map(n=>({...n,key:this.templateSrv.replace(n.key,t),value:this.templateSrv.replace(n.value??"",t,(i=[],l)=>this.interpolateQueryExpr(i,l,n.value))}))),{...r,adhocFilters:this.templateSrv.getAdhocFilters(this.name)??[],query:this.templateSrv.replace(e.query??"",t,(n=[],i)=>this.interpolateQueryExpr(n,i,e.query)),rawSql:this.templateSrv.replace(e.rawSql??"",t,(n=[],i)=>this.interpolateQueryExpr(n,i,e.rawSql)),alias:this.templateSrv.replace(e.alias??"",t),limit:this.templateSrv.replace(e.limit?.toString()??"",t),measurement:this.templateSrv.replace(e.measurement??"",t),policy:this.templateSrv.replace(e.policy??"",t),slimit:this.templateSrv.replace(e.slimit?.toString()??"",t),tz:this.templateSrv.replace(e.tz??"",t)}}interpolateQueryExpr(e=[],t,r){return r?t.multi?typeof e=="string"?isNaN(parseFloat(e))?(0,G.$f)(e):e:`(${e.map(i=>(0,G.$f)(i)).join("|")})`:new RegExp(`\\/(?:\\^)?(.*)(\\$${t.name})(.*)(?:\\$)?\\/`,"gm").test(r)?typeof e=="string"?(0,G.$f)(e):`(${e.map(i=>(0,G.$f)(i)).join("|")})`:e:e}async runMetadataQuery(e){return(0,Z.s)(super.query({targets:[e]})).then(this.toMetricFindValue)}async metricFindQuery(e,t){if(this.version===E.Flux||this.version===E.SQL||this.isMigrationToggleOnAndIsAccessProxy()){const n={refId:"metricFindQuery",query:e,rawQuery:!0,...this.version===E.SQL?{rawSql:e,format:H.gv.Table}:{}};return(0,Z.s)(super.query({...t??{},targets:[n]})).then(this.toMetricFindValue)}const r=this.templateSrv.replace(e,t?.scopedVars,(n=[],i)=>this.interpolateQueryExpr(n,i,e));return(0,Z.s)(this._seriesQuery(r,t)).then(n=>this.responseParser.parse(e,n))}toMetricFindValue(e){return(e.data??[]).map(n=>(0,Ke.$h)(n)).flat().filter((n,i,l)=>i===l.findIndex(o=>o.text===n.text))}getTagKeys(e){const t=ye({type:"TAG_KEYS",templateService:this.templateSrv,database:this.database});return this.metricFindQuery(t)}getTagValues(e){const t=ye({type:"TAG_VALUES",templateService:this.templateSrv,database:this.database,withKey:e.key});return this.metricFindQuery(t)}_seriesQuery(e,t){if(!e)return(0,ve.of)({results:[]});if(t&&t.range){const r=this.getTimeFilter({rangeRaw:t.range,timezone:t.timezone});e=e.replace("$timeFilter",r)}return this._influxRequest(this.httpMode,"/query",{q:e,epoch:"ms"},t)}serializeParams(e){return e?(0,f.reduce)(e,(t,r,n)=>(r==null||t.push(encodeURIComponent(n)+"="+encodeURIComponent(r)),t),[]).join("&"):""}_influxRequest(e,t,r,n){const i=this.urls.shift();this.urls.push(i);const l={};this.username&&(l.u=this.username,l.p=this.password),n&&n.database?l.db=n.database:this.database&&(l.db=this.database),n?.policy&&n.policy!==W&&(l.rp=n.policy);const{q:o}=r;e==="POST"&&(0,f.has)(r,"q")?((0,f.extend)(l,(0,f.omit)(r,["q"])),r=this.serializeParams((0,f.pick)(r,["q"]))):(e==="GET"||e==="POST")&&((0,f.extend)(l,r),r=null);const u={method:e,url:i+t,params:l,data:r,precision:"ms",inspect:{type:"influxdb"},paramSerializer:this.serializeParams};return u.headers=u.headers||{},(this.basicAuth||this.withCredentials)&&(u.withCredentials=!0),this.basicAuth&&(u.headers.Authorization=this.basicAuth),e==="POST"&&(u.headers["Content-type"]="application/x-www-form-urlencoded"),(0,qe.AI)().fetch(u).pipe((0,Ie.T)(c=>{const{data:d}=c;if(d&&(d.executedQueryString=o,d.results)){const m=c.data.results.filter(g=>g.error);if(m.length>0)throw{message:"InfluxDB Error: "+m[0].error,data:d}}return d}),(0,Ga.W)(c=>c.cancelled?(0,ve.of)(c):(0,ze.$)(this.handleErrors(c))))}handleErrors(e){const t={message:e&&e.status||e&&e.message||"Unknown error during query transaction. Please check JS console logs."};return(Number.isInteger(e.status)&&e.status!==0||e.status>=300)&&(e.data&&e.data.error?(t.message="InfluxDB Error: "+e.data.error,t.data=e.data,t.config=e.config):(t.message="Network Error: "+e.statusText+"("+e.status+")",t.data=e.data,t.config=e.config)),t}getTimeFilter(e){const t=this.getInfluxTime(e.rangeRaw.from,!1,e.timezone),r=this.getInfluxTime(e.rangeRaw.to,!0,e.timezone);return"time >= "+t+" and time <= "+r}getInfluxTime(e,t,r){let n;if((0,f.isString)(e)){if(e==="now")return"now()";const i=/^now-(\d+)([dhms])$/.exec(e);if(i){const l=parseInt(i[1],10),o=i[2];return"now() - "+l+o}if(n=Ya.parse(e,t,r),!n)throw new Error("unable to parse date");e=n}return e.valueOf()+"ms"}isMigrationToggleOnAndIsAccessProxy(){return ee.Ay.featureToggles.influxdbBackendMigration&&this.access==="proxy"}classicQuery(e){let t=this.getTimeFilter(e);const r=e.scopedVars,n=(0,f.cloneDeep)(e.targets),i=[];let l,o,u=(0,f.map)(n,m=>m.hide?"":(i.push(m),r.interval=r.__interval,new M(m,this.templateSrv,r).render(!0))).reduce((m,g)=>(g!==""&&(m+=";"+g),m));if(u==="")return(0,ve.of)({data:[]});const c=this.templateSrv.getAdhocFilters(this.name),d=e.targets.flatMap(m=>m.adhocFilters??[]);if(c?.length||d?.length){const m=c?.length?c:d,g=new M({refId:"A"},this.templateSrv,r);t+=" AND "+g.renderAdhocFilters(m)}return r.timeFilter={value:t},u=this.templateSrv.replace(u,r),this._seriesQuery(u,e).pipe((0,Ie.T)(m=>{if(!m||!m.results)return{data:[]};const g=[];for(l=0;l<m.results.length;l++){const h=m.results[l];if(!h||!h.series)continue;const w=i[l];let _=w.alias;_&&(_=this.templateSrv.replace(w.alias,e.scopedVars));const y={executedQueryString:m.executedQueryString},b=new Xe({refId:w.refId,series:m.results[l].series,alias:_,meta:y});switch(w.resultFormat){case"logs":y.preferredVisualisationType="logs";case"table":{g.push(b.getTable());break}default:{const R=b.getTimeSeries();for(o=0;o<R.length;o++)g.push(nr(R[o]));break}}}return{data:g}}))}async annotationEvents(e,t){if(this.version===E.Flux)return Promise.reject({message:"Flux requires the standard annotation query"});if(!t.query)return Promise.reject({message:"Query missing in annotation definition"});if(this.isMigrationToggleOnAndIsAccessProxy()){const i={refId:"metricFindQuery",datasource:this.getRef(),query:this.templateSrv.replace(t.query,void 0,(l=[],o)=>this.interpolateQueryExpr(l,o,t.query)),rawQuery:!0};return(0,Z.s)((0,qe.AI)().fetch({url:"/api/ds/query",method:"POST",headers:this.getRequestHeaders(),data:{from:e.range.from.valueOf().toString(),to:e.range.to.valueOf().toString(),queries:[i]},requestId:t.name}).pipe((0,Ie.T)(async l=>await this.responseParser.transformAnnotationResponse(t,l,i))))}const r=this.getTimeFilter({rangeRaw:e.range.raw,timezone:e.timezone});let n=t.query.replace("$timeFilter",r);return n=this.templateSrv.replace(n,void 0,(i=[],l)=>this.interpolateQueryExpr(i,l,n)),(0,Z.s)(this._seriesQuery(n,e)).then(i=>{if(!i||!i.results||!i.results[0])throw{message:"No results in response from InfluxDB"};return new Xe({series:i.results[0].series,annotation:t}).getAnnotations()})}}function rr(a){const e=a.find(r=>r!==null);if(e===void 0)return Q.PU.number;const t=typeof e;switch(t){case"string":return Q.PU.string;case"boolean":return Q.PU.boolean;case"number":return Q.PU.number;default:throw new Error(`InfluxQL: invalid value type ${t}`)}}function nr(a){const e=[],t=[],r=a.datapoints;for(const o of r)t.push(o[0]),e.push(o[1]);const n={name:Q.LE,type:Q.PU.time,config:{},values:e},i={name:Q.Bc,type:rr(t),config:{displayNameFromDS:a.title},values:t,labels:a.tags},l=[n,i];return{name:a.target,refId:a.refId,meta:a.meta,fields:l,length:t.length}}const sr=new _e.tD(ar).setConfigEditor(ot).setQueryEditor(Ba).setVariableQueryEditor(Ua).setQueryEditorHelp($a)}}]);

//# sourceMappingURL=influxdbPlugin.140a7777089f9559c11c.js.map