@@ -33,7 +33,7 @@ const logger = debug("redash:services:query");
33
33
function collectParams ( parts ) {
34
34
let parameters = [ ] ;
35
35
36
- parts . forEach ( part => {
36
+ parts . forEach ( ( part ) => {
37
37
if ( part [ 0 ] === "name" || part [ 0 ] === "&" ) {
38
38
parameters . push ( part [ 1 ] . split ( "." ) [ 0 ] ) ;
39
39
} else if ( part [ 0 ] === "#" ) {
@@ -68,12 +68,7 @@ export class Query {
68
68
69
69
scheduleInLocalTime ( ) {
70
70
const parts = this . schedule . split ( ":" ) ;
71
- return moment
72
- . utc ( )
73
- . hour ( parts [ 0 ] )
74
- . minute ( parts [ 1 ] )
75
- . local ( )
76
- . format ( "HH:mm" ) ;
71
+ return moment . utc ( ) . hour ( parts [ 0 ] ) . minute ( parts [ 1 ] ) . local ( ) . format ( "HH:mm" ) ;
77
72
}
78
73
79
74
hasResult ( ) {
@@ -158,11 +153,11 @@ export class Query {
158
153
159
154
let params = { } ;
160
155
if ( this . getParameters ( ) . isRequired ( ) ) {
161
- this . getParametersDefs ( ) . forEach ( param => {
156
+ this . getParametersDefs ( ) . forEach ( ( param ) => {
162
157
extend ( params , param . toUrlParams ( ) ) ;
163
158
} ) ;
164
159
}
165
- Object . keys ( params ) . forEach ( key => params [ key ] == null && delete params [ key ] ) ;
160
+ Object . keys ( params ) . forEach ( ( key ) => params [ key ] == null && delete params [ key ] ) ;
166
161
params = map ( params , ( value , name ) => `${ encodeURIComponent ( name ) } =${ encodeURIComponent ( value ) } ` ) . join ( "&" ) ;
167
162
168
163
if ( params !== "" ) {
@@ -220,7 +215,7 @@ class Parameters {
220
215
}
221
216
222
217
parseQuery ( ) {
223
- const fallback = ( ) => map ( this . query . options . parameters , i => i . name ) ;
218
+ const fallback = ( ) => map ( this . query . options . parameters , ( i ) => i . name ) ;
224
219
225
220
let parameters = [ ] ;
226
221
if ( this . query . query !== undefined ) {
@@ -242,26 +237,26 @@ class Parameters {
242
237
updateParameters ( update ) {
243
238
if ( this . query . query === this . cachedQueryText ) {
244
239
const parameters = this . query . options . parameters ;
245
- const hasUnprocessedParameters = find ( parameters , p => ! ( p instanceof Parameter ) ) ;
240
+ const hasUnprocessedParameters = find ( parameters , ( p ) => ! ( p instanceof Parameter ) ) ;
246
241
if ( hasUnprocessedParameters ) {
247
- this . query . options . parameters = map ( parameters , p =>
242
+ this . query . options . parameters = map ( parameters , ( p ) =>
248
243
p instanceof Parameter ? p : createParameter ( p , this . query . id )
249
244
) ;
250
245
}
251
246
return ;
252
247
}
253
248
254
249
this . cachedQueryText = this . query . query ;
255
- const parameterNames = update ? this . parseQuery ( ) : map ( this . query . options . parameters , p => p . name ) ;
250
+ const parameterNames = update ? this . parseQuery ( ) : map ( this . query . options . parameters , ( p ) => p . name ) ;
256
251
257
252
this . query . options . parameters = this . query . options . parameters || [ ] ;
258
253
259
254
const parametersMap = { } ;
260
- this . query . options . parameters . forEach ( param => {
255
+ this . query . options . parameters . forEach ( ( param ) => {
261
256
parametersMap [ param . name ] = param ;
262
257
} ) ;
263
258
264
- parameterNames . forEach ( param => {
259
+ parameterNames . forEach ( ( param ) => {
265
260
if ( ! has ( parametersMap , param ) ) {
266
261
this . query . options . parameters . push (
267
262
createParameter ( {
@@ -275,15 +270,15 @@ class Parameters {
275
270
}
276
271
} ) ;
277
272
278
- const parameterExists = p => includes ( parameterNames , p . name ) ;
273
+ const parameterExists = ( p ) => includes ( parameterNames , p . name ) ;
279
274
const parameters = this . query . options . parameters ;
280
275
this . query . options . parameters = parameters
281
276
. filter ( parameterExists )
282
- . map ( p => ( p instanceof Parameter ? p : createParameter ( p , this . query . id ) ) ) ;
277
+ . map ( ( p ) => ( p instanceof Parameter ? p : createParameter ( p , this . query . id ) ) ) ;
283
278
}
284
279
285
280
initFromQueryString ( query ) {
286
- this . get ( ) . forEach ( param => {
281
+ this . get ( ) . forEach ( ( param ) => {
287
282
param . fromUrlParams ( query ) ;
288
283
} ) ;
289
284
}
@@ -294,16 +289,16 @@ class Parameters {
294
289
}
295
290
296
291
add ( parameterDef ) {
297
- this . query . options . parameters = this . query . options . parameters . filter ( p => p . name !== parameterDef . name ) ;
292
+ this . query . options . parameters = this . query . options . parameters . filter ( ( p ) => p . name !== parameterDef . name ) ;
298
293
const param = createParameter ( parameterDef ) ;
299
294
this . query . options . parameters . push ( param ) ;
300
295
return param ;
301
296
}
302
297
303
298
getMissing ( ) {
304
299
return map (
305
- filter ( this . get ( ) , p => p . isEmpty ) ,
306
- i => i . title
300
+ filter ( this . get ( ) , ( p ) => p . isEmpty ) ,
301
+ ( i ) => i . title
307
302
) ;
308
303
}
309
304
@@ -314,28 +309,28 @@ class Parameters {
314
309
getExecutionValues ( extra = { } ) {
315
310
const params = this . get ( ) ;
316
311
return zipObject (
317
- map ( params , i => i . name ) ,
318
- map ( params , i => i . getExecutionValue ( extra ) )
312
+ map ( params , ( i ) => i . name ) ,
313
+ map ( params , ( i ) => i . getExecutionValue ( extra ) )
319
314
) ;
320
315
}
321
316
322
317
hasPendingValues ( ) {
323
- return some ( this . get ( ) , p => p . hasPendingValue ) ;
318
+ return some ( this . get ( ) , ( p ) => p . hasPendingValue ) ;
324
319
}
325
320
326
321
applyPendingValues ( ) {
327
- each ( this . get ( ) , p => p . applyPendingValue ( ) ) ;
322
+ each ( this . get ( ) , ( p ) => p . applyPendingValue ( ) ) ;
328
323
}
329
324
330
325
toUrlParams ( ) {
331
326
if ( this . get ( ) . length === 0 ) {
332
327
return "" ;
333
328
}
334
329
335
- const params = Object . assign ( ...this . get ( ) . map ( p => p . toUrlParams ( ) ) ) ;
336
- Object . keys ( params ) . forEach ( key => params [ key ] == null && delete params [ key ] ) ;
330
+ const params = Object . assign ( ...this . get ( ) . map ( ( p ) => p . toUrlParams ( ) ) ) ;
331
+ Object . keys ( params ) . forEach ( ( key ) => params [ key ] == null && delete params [ key ] ) ;
337
332
return Object . keys ( params )
338
- . map ( k => `${ encodeURIComponent ( k ) } =${ encodeURIComponent ( params [ k ] ) } ` )
333
+ . map ( ( k ) => `${ encodeURIComponent ( k ) } =${ encodeURIComponent ( params [ k ] ) } ` )
339
334
. join ( "&" ) ;
340
335
}
341
336
}
@@ -374,27 +369,27 @@ export class QueryResultError {
374
369
}
375
370
}
376
371
377
- const getQuery = query => new Query ( query ) ;
378
- const saveOrCreateUrl = data => ( data . id ? `api/queries/${ data . id } ` : "api/queries" ) ;
379
- const mapResults = data => ( { ...data , results : map ( data . results , getQuery ) } ) ;
372
+ const getQuery = ( query ) => new Query ( query ) ;
373
+ const saveOrCreateUrl = ( data ) => ( data . id ? `api/queries/${ data . id } ` : "api/queries" ) ;
374
+ const mapResults = ( data ) => ( { ...data , results : map ( data . results , getQuery ) } ) ;
380
375
381
376
const QueryService = {
382
- query : params => axios . get ( "api/queries" , { params } ) . then ( mapResults ) ,
383
- get : data => axios . get ( `api/queries/${ data . id } ` , data ) . then ( getQuery ) ,
384
- save : data => axios . post ( saveOrCreateUrl ( data ) , data ) . then ( getQuery ) ,
385
- delete : data => axios . delete ( `api/queries/${ data . id } ` ) ,
386
- recent : params => axios . get ( `api/queries/recent` , { params } ) . then ( data => map ( data , getQuery ) ) ,
387
- unassigned : params => axios . get ( `api/queries/unassigned` , { params } ) . then ( mapResults ) ,
388
- archive : params => axios . get ( `api/queries/archive` , { params } ) . then ( mapResults ) ,
389
- myQueries : params => axios . get ( "api/queries/my" , { params } ) . then ( mapResults ) ,
377
+ query : ( params ) => axios . get ( "api/queries" , { params } ) . then ( mapResults ) ,
378
+ get : ( data ) => axios . get ( `api/queries/${ data . id } ` , data ) . then ( getQuery ) ,
379
+ save : ( data ) => axios . post ( saveOrCreateUrl ( data ) , data ) . then ( getQuery ) ,
380
+ delete : ( data ) => axios . delete ( `api/queries/${ data . id } ` ) ,
381
+ recent : ( params ) => axios . get ( `api/queries/recent` , { params } ) . then ( ( data ) => map ( data , getQuery ) ) ,
382
+ unassigned : ( params ) => axios . get ( `api/queries/unassigned` , { params } ) . then ( mapResults ) ,
383
+ archive : ( params ) => axios . get ( `api/queries/archive` , { params } ) . then ( mapResults ) ,
384
+ myQueries : ( params ) => axios . get ( "api/queries/my" , { params } ) . then ( mapResults ) ,
390
385
fork : ( { id } ) => axios . post ( `api/queries/${ id } /fork` , { id } ) . then ( getQuery ) ,
391
- resultById : data => axios . get ( `api/queries/${ data . id } /results.json` ) ,
392
- asDropdown : data => axios . get ( `api/queries/${ data . id } /dropdown` ) ,
386
+ resultById : ( data ) => axios . get ( `api/queries/${ data . id } /results.json` ) ,
387
+ asDropdown : ( data ) => axios . get ( `api/queries/${ data . id } /dropdown` ) ,
393
388
associatedDropdown : ( { queryId, dropdownQueryId } ) =>
394
389
axios . get ( `api/queries/${ queryId } /dropdowns/${ dropdownQueryId } ` ) ,
395
- favorites : params => axios . get ( "api/queries/favorites" , { params } ) . then ( mapResults ) ,
396
- favorite : data => axios . post ( `api/queries/${ data . id } /favorite` ) ,
397
- unfavorite : data => axios . delete ( `api/queries/${ data . id } /favorite` ) ,
390
+ favorites : ( params ) => axios . get ( "api/queries/favorites" , { params } ) . then ( mapResults ) ,
391
+ favorite : ( data ) => axios . post ( `api/queries/${ data . id } /favorite` ) ,
392
+ unfavorite : ( data ) => axios . delete ( `api/queries/${ data . id } /favorite` ) ,
398
393
} ;
399
394
400
395
QueryService . newQuery = function newQuery ( ) {
0 commit comments