@@ -312,10 +312,11 @@ export function sendRequest(queryObject) {
312
312
} ) ;
313
313
}
314
314
} ;
315
-
315
+ console . log ( "cachePolicy" , cachePolicy )
316
316
switch ( cachePolicy ) {
317
317
case 1 :
318
318
return new Promise ( function ( resolve , reject ) {
319
+ console . log ( "self.prvider>>>>>" , self . provider )
319
320
if ( self . provider !== null ) {
320
321
self . provider . get ( hashQuery , function ( err , _data ) {
321
322
try {
@@ -345,91 +346,107 @@ export function sendRequest(queryObject) {
345
346
} ;
346
347
347
348
if ( cachePolicy === 3 ) {
348
- /////// New Implementaion
349
- // return new Promise(function(resolve, reject) {
350
- // // if (self.provider !== null) {
351
- // self.provider.get(hashQuery, function(err, _data) {
352
- // try {
353
- // if (err) {
354
- // reject(err);
355
- // } else {
356
- // if (!tojson) _data = resultWrapper(_data);
357
- // resolve(spreadResult(_data));
358
- // }
359
- // } catch (e) {
360
- // reject(e);
361
- // }
362
- // });
363
- // // }else {
364
- // // callback(true, resolve, reject);
365
- // // // reject({ error_code: 141, error_message: 'The requested entry doesn\'t exist.' });
366
- // // }
367
- // });
368
349
369
- // Old Implementation
370
- return {
371
- cache : ( function ( ) {
372
- return new Promise ( function ( resolve , reject ) {
373
- self . provider . get ( hashQuery , function ( err , _data ) {
374
- try {
375
- if ( err ) {
376
- reject ( err ) ;
377
- } else {
378
- if ( ! tojson ) _data = resultWrapper ( _data ) ;
379
- resolve ( spreadResult ( _data ) ) ;
380
- }
381
- } catch ( e ) {
382
- reject ( e ) ;
383
- }
384
- } ) ;
385
- } ) ;
386
- } ( ) ) ,
387
- network : ( function ( ) {
388
- return new Promise ( function ( resolve , reject ) {
389
- callback ( true , resolve , reject ) ;
390
- } ) ;
391
- } ( ) ) ,
392
- both : function ( _callback_ ) {
350
+ var promise = new Promise ( function ( resolve , reject ) {
393
351
if ( self . provider !== null ) {
394
- self . provider . get ( hashQuery , function ( err , entries ) {
395
- if ( ! tojson ) entries = resultWrapper ( entries ) ;
396
- _callback_ ( err , spreadResult ( entries ) )
397
- } ) ;
398
- }
399
- Request ( queryObject . requestParams )
400
- . then ( function ( data ) {
352
+ console . log ( "inside the catche" )
353
+ self . provider . get ( hashQuery , function ( err , _data ) {
401
354
try {
402
- self . entry_uid = self . tojson = self . queryCachePolicy = undefined ;
403
- let entries = { } ,
404
- error = null ;
405
- if ( queryObject . singleEntry ) {
406
- queryObject . singleEntry = false ;
407
- if ( data . schema ) entries . schema = data . schema ;
408
- if ( data . content_type ) {
409
- entries . content_type = data . content_type ;
410
- delete entries . schema
411
- }
412
- if ( data . entries && data . entries . length ) {
413
- entries . entry = data . entries [ 0 ] ;
414
- } else if ( data . assets && data . assets . length ) {
415
- entries . assets = data . assets [ 0 ] ;
416
- } else {
417
- error = { error_code : 141 , error_message : 'The requested entry doesn\'t exist.' } ;
418
- }
355
+ if ( err || ! _data ) {
356
+ return reject ( err ) ;
357
+ //reject(Error("It broke"));
419
358
} else {
420
- entries = data ;
359
+ console . log ( "inside else part" )
360
+ if ( ! tojson ) _data = resultWrapper ( _data ) ;
361
+ return resolve ( spreadResult ( _data ) ) ;
421
362
}
422
- if ( ! tojson ) entries = resultWrapper ( entries ) ;
423
- _callback_ ( error , spreadResult ( entries ) ) ;
424
363
} catch ( e ) {
425
- _callback_ ( e ) ;
364
+ return reject ( e ) ;
426
365
}
427
- } . bind ( self ) )
428
- . catch ( function ( error ) {
429
- _callback_ ( error ) ;
430
366
} ) ;
431
- }
367
+ }
368
+ } ) ;
432
369
433
- } ;
370
+ return promise . then ( function ( ) {
371
+ return new Promise ( function ( resolve , reject ) {
372
+ callback ( true , resolve , reject ) ;
373
+ } ) ;
374
+ } ) . catch ( ( error ) => {
375
+ return new Promise ( function ( resolve , reject ) {
376
+ callback ( true , resolve , reject ) ;
377
+ } ) ;
378
+ console . error ( error )
379
+ } )
380
+
381
+ // return {
382
+ // cache: (function() {
383
+ // console.log("inside cache")
384
+ // return new Promise(function(resolve, reject) {
385
+ // self.provider.get(hashQuery, function(err, _data) {
386
+ // console.log("datatatat", _data)
387
+ // try {
388
+ // if (err) {
389
+ // reject(err);
390
+ // } else {
391
+ // console.log("else part")
392
+ // if (!tojson) _data = resultWrapper(_data);
393
+ // console.log("spreddatat", _data)
394
+ // resolve(spreadResult(_data));
395
+ // }
396
+ // } catch (e) {
397
+ // reject(e);
398
+ // }
399
+ // });
400
+ // });
401
+ // }()),
402
+ // network: (function() {
403
+ // console.log("inside netwrk")
404
+ // return new Promise(function(resolve, reject) {
405
+ // callback(true, resolve, reject);
406
+ // });
407
+ // }()),
408
+ // both: function(_callback_) {
409
+ // console.log("inside both")
410
+ // if (self.provider !== null) {
411
+ // self.provider.get(hashQuery, function(err, entries) {
412
+ // if (!tojson) entries = resultWrapper(entries);
413
+ // _callback_(err, spreadResult(entries))
414
+ // });
415
+ // }
416
+ // Request(queryObject.requestParams)
417
+ // .then(function(data) {
418
+ // console.log("datattatat>>>>>>>", data)
419
+ // try {
420
+ // self.entry_uid = self.tojson = self.queryCachePolicy = undefined;
421
+ // let entries = {},
422
+ // error = null;
423
+ // if (queryObject.singleEntry) {
424
+ // queryObject.singleEntry = false;
425
+ // if (data.schema) entries.schema = data.schema;
426
+ // if (data.content_type) {
427
+ // entries.content_type = data.content_type;
428
+ // delete entries.schema
429
+ // }
430
+ // if (data.entries && data.entries.length) {
431
+ // entries.entry = data.entries[0];
432
+ // } else if (data.assets && data.assets.length) {
433
+ // entries.assets = data.assets[0];
434
+ // } else {
435
+ // error = { error_code: 141, error_message: 'The requested entry doesn\'t exist.' };
436
+ // }
437
+ // } else {
438
+ // entries = data;
439
+ // }
440
+ // if (!tojson) entries = resultWrapper(entries);
441
+ // _callback_(error, spreadResult(entries));
442
+ // } catch (e) {
443
+ // _callback_(e);
444
+ // }
445
+ // }.bind(self))
446
+ // .catch(function(error) {
447
+ // _callback_(error);
448
+ // });
449
+ // }
450
+ // };
434
451
}
435
452
} ;
0 commit comments