@@ -312,10 +312,11 @@ export function sendRequest(queryObject) {
312312 } ) ;
313313 }
314314 } ;
315-
315+ console . log ( "cachePolicy" , cachePolicy )
316316 switch ( cachePolicy ) {
317317 case 1 :
318318 return new Promise ( function ( resolve , reject ) {
319+ console . log ( "self.prvider>>>>>" , self . provider )
319320 if ( self . provider !== null ) {
320321 self . provider . get ( hashQuery , function ( err , _data ) {
321322 try {
@@ -345,91 +346,107 @@ export function sendRequest(queryObject) {
345346 } ;
346347
347348 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- // });
368349
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 ) {
393351 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 ) {
401354 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"));
419358 } else {
420- entries = data ;
359+ console . log ( "inside else part" )
360+ if ( ! tojson ) _data = resultWrapper ( _data ) ;
361+ return resolve ( spreadResult ( _data ) ) ;
421362 }
422- if ( ! tojson ) entries = resultWrapper ( entries ) ;
423- _callback_ ( error , spreadResult ( entries ) ) ;
424363 } catch ( e ) {
425- _callback_ ( e ) ;
364+ return reject ( e ) ;
426365 }
427- } . bind ( self ) )
428- . catch ( function ( error ) {
429- _callback_ ( error ) ;
430366 } ) ;
431- }
367+ }
368+ } ) ;
432369
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+ // };
434451 }
435452} ;
0 commit comments