@@ -257,7 +257,7 @@ export function sendRequest(queryObject) {
257
257
} else if ( data . assets && data . assets . length ) {
258
258
entries . assets = data . assets [ 0 ] ;
259
259
} else {
260
- if ( cachePolicy === 2 ) {
260
+ if ( cachePolicy === 2 && self . provider !== null ) {
261
261
self . provider . get ( hashQuery , getCacheCallback ( ) ) ;
262
262
} else {
263
263
return reject ( { error_code : 141 , error_message : 'The requested entry doesn\'t exist.' } ) ;
@@ -276,7 +276,7 @@ export function sendRequest(queryObject) {
276
276
entries = data ;
277
277
}
278
278
279
- if ( cachePolicy !== - 1 ) {
279
+ if ( cachePolicy !== - 1 && self . provider !== null ) {
280
280
self . provider . set ( hashQuery , entries , function ( err ) {
281
281
try {
282
282
if ( err ) throw err ;
@@ -304,30 +304,34 @@ export function sendRequest(queryObject) {
304
304
}
305
305
} . bind ( self ) )
306
306
. catch ( function ( error ) {
307
- if ( cachePolicy === 2 ) {
307
+ if ( cachePolicy === 2 && self . provider !== null ) {
308
308
self . provider . get ( hashQuery , getCacheCallback ( ) ) ;
309
309
} else {
310
310
return reject ( error ) ;
311
311
}
312
312
} ) ;
313
313
}
314
314
} ;
315
-
316
315
switch ( cachePolicy ) {
317
316
case 1 :
318
317
return new Promise ( function ( resolve , reject ) {
319
- self . provider . get ( hashQuery , function ( err , _data ) {
320
- try {
321
- if ( err || ! _data ) {
322
- callback ( true , resolve , reject ) ;
323
- } else {
324
- if ( ! tojson ) _data = resultWrapper ( _data ) ;
325
- return resolve ( spreadResult ( _data ) ) ;
318
+ if ( self . provider !== null ) {
319
+ self . provider . get ( hashQuery , function ( err , _data ) {
320
+ try {
321
+ if ( err || ! _data ) {
322
+ callback ( true , resolve , reject ) ;
323
+ } else {
324
+ if ( ! tojson ) _data = resultWrapper ( _data ) ;
325
+ return resolve ( spreadResult ( _data ) ) ;
326
+ }
327
+ } catch ( e ) {
328
+ return reject ( e ) ;
326
329
}
327
- } catch ( e ) {
328
- return reject ( e ) ;
329
- }
330
- } ) ;
330
+ } ) ;
331
+ } else {
332
+ callback ( true , resolve , reject ) ;
333
+ }
334
+
331
335
} ) ;
332
336
break ;
333
337
case 2 :
@@ -340,67 +344,34 @@ export function sendRequest(queryObject) {
340
344
} ;
341
345
342
346
if ( cachePolicy === 3 ) {
343
- return {
344
- cache : ( function ( ) {
345
- return new Promise ( function ( resolve , reject ) {
347
+
348
+ var promise = new Promise ( function ( resolve , reject ) {
349
+ if ( self . provider !== null ) {
346
350
self . provider . get ( hashQuery , function ( err , _data ) {
347
351
try {
348
- if ( err ) {
349
- reject ( err ) ;
352
+ if ( err || ! _data ) {
353
+ reject ( err ) ;
354
+ //reject(Error("It broke"));
350
355
} else {
351
356
if ( ! tojson ) _data = resultWrapper ( _data ) ;
352
- resolve ( spreadResult ( _data ) ) ;
357
+ resolve ( spreadResult ( _data ) ) ;
353
358
}
354
359
} catch ( e ) {
355
- reject ( e ) ;
360
+ reject ( e ) ;
356
361
}
357
362
} ) ;
358
- } ) ;
359
- } ( ) ) ,
360
- network : ( function ( ) {
361
- return new Promise ( function ( resolve , reject ) {
363
+ }
364
+ } ) ;
365
+
366
+ return promise . then ( function ( ) {
367
+ return new Promise ( function ( resolve , reject ) {
362
368
callback ( true , resolve , reject ) ;
363
369
} ) ;
364
- } ( ) ) ,
365
- both : function ( _callback_ ) {
366
- self . provider . get ( hashQuery , function ( err , entries ) {
367
- if ( ! tojson ) entries = resultWrapper ( entries ) ;
368
- _callback_ ( err , spreadResult ( entries ) )
370
+ } ) . catch ( ( error ) => {
371
+ return new Promise ( function ( resolve , reject ) {
372
+ callback ( true , resolve , reject ) ;
369
373
} ) ;
370
- Request ( queryObject . requestParams )
371
- . then ( function ( data ) {
372
- try {
373
- self . entry_uid = self . tojson = self . queryCachePolicy = undefined ;
374
- let entries = { } ,
375
- error = null ;
376
- if ( queryObject . singleEntry ) {
377
- queryObject . singleEntry = false ;
378
- if ( data . schema ) entries . schema = data . schema ;
379
- if ( data . content_type ) {
380
- entries . content_type = data . content_type ;
381
- delete entries . schema
382
- }
383
- if ( data . entries && data . entries . length ) {
384
- entries . entry = data . entries [ 0 ] ;
385
- } else if ( data . assets && data . assets . length ) {
386
- entries . assets = data . assets [ 0 ] ;
387
- } else {
388
- error = { error_code : 141 , error_message : 'The requested entry doesn\'t exist.' } ;
389
- }
390
- } else {
391
- entries = data ;
392
- }
393
- if ( ! tojson ) entries = resultWrapper ( entries ) ;
394
- _callback_ ( error , spreadResult ( entries ) ) ;
395
- } catch ( e ) {
396
- _callback_ ( e ) ;
397
- }
398
- } . bind ( self ) )
399
- . catch ( function ( error ) {
400
- _callback_ ( error ) ;
401
- } ) ;
402
- }
403
-
404
- } ;
374
+ console . error ( error )
375
+ } )
405
376
}
406
377
} ;
0 commit comments