@@ -9,6 +9,7 @@ function _objectSpread(target) { for (var i = 1; i < arguments.length; i++) { va
99import error from './core/contentstackError' ;
1010import cloneDeep from 'lodash/cloneDeep' ;
1111import Query from './query/index' ;
12+ import ContentstackCollection from './contentstackCollection' ;
1213export var publish = function publish ( http , type ) {
1314 return /*#__PURE__*/ function ( ) {
1415 var _ref2 = _asyncToGenerator ( /*#__PURE__*/ _regeneratorRuntime . mark ( function _callee ( _ref ) {
@@ -197,7 +198,7 @@ export var create = function create(_ref8) {
197198 break ;
198199 }
199200
200- return _context5 . abrupt ( "return" , new this . constructor ( http , parseData ( response , this . stackHeaders ) ) ) ;
201+ return _context5 . abrupt ( "return" , new this . constructor ( http , parseData ( response , this . stackHeaders , this . content_type_uid ) ) ) ;
201202
202203 case 9 :
203204 throw error ( response ) ;
@@ -249,7 +250,7 @@ export var exportObject = function exportObject(_ref10) {
249250 break ;
250251 }
251252
252- return _context6 . abrupt ( "return" , new this . constructor ( http , parseData ( response , this . stackHeaders ) ) ) ;
253+ return _context6 . abrupt ( "return" , new this . constructor ( http , parseData ( response , this . stackHeaders , this . content_type_uid ) ) ) ;
253254
254255 case 9 :
255256 throw error ( response ) ;
@@ -283,9 +284,17 @@ export var query = function query(_ref12) {
283284 var params = arguments . length > 0 && arguments [ 0 ] !== undefined ? arguments [ 0 ] : { } ;
284285
285286 if ( this . organization_uid ) {
287+ if ( ! params . query ) {
288+ params . query = { } ;
289+ }
290+
286291 params . query [ 'org_uid' ] = this . organization_uid ;
287292 }
288293
294+ if ( this . content_type_uid ) {
295+ params . content_type_uid = this . content_type_uid ;
296+ }
297+
289298 return Query ( http , this . urlPath , params , this . stackHeaders , wrapperCollection ) ;
290299 } ;
291300} ;
@@ -455,6 +464,61 @@ export var fetch = function fetch(http, type) {
455464 } , _callee9 , this , [ [ 1 , 14 ] ] ) ;
456465 } ) ) ;
457466} ;
467+ export var fetchAll = function fetchAll ( http , wrapperCollection ) {
468+ return /*#__PURE__*/ _asyncToGenerator ( /*#__PURE__*/ _regeneratorRuntime . mark ( function _callee10 ( ) {
469+ var params ,
470+ headers ,
471+ response ,
472+ _args10 = arguments ;
473+ return _regeneratorRuntime . wrap ( function _callee10$ ( _context10 ) {
474+ while ( 1 ) {
475+ switch ( _context10 . prev = _context10 . next ) {
476+ case 0 :
477+ params = _args10 . length > 0 && _args10 [ 0 ] !== undefined ? _args10 [ 0 ] : { } ;
478+ headers = { } ;
479+
480+ if ( this . stackHeaders ) {
481+ headers . headers = this . stackHeaders ;
482+ }
483+
484+ if ( params ) {
485+ headers . params = _objectSpread ( { } , cloneDeep ( params ) ) ;
486+ }
487+
488+ _context10 . prev = 4 ;
489+ _context10 . next = 7 ;
490+ return http . get ( this . urlPath , headers ) ;
491+
492+ case 7 :
493+ response = _context10 . sent ;
494+
495+ if ( ! response . data ) {
496+ _context10 . next = 12 ;
497+ break ;
498+ }
499+
500+ return _context10 . abrupt ( "return" , new ContentstackCollection ( response , http , this . stackHeaders , wrapperCollection ) ) ;
501+
502+ case 12 :
503+ throw error ( response ) ;
504+
505+ case 13 :
506+ _context10 . next = 18 ;
507+ break ;
508+
509+ case 15 :
510+ _context10 . prev = 15 ;
511+ _context10 . t0 = _context10 [ "catch" ] ( 4 ) ;
512+ throw error ( _context10 . t0 ) ;
513+
514+ case 18 :
515+ case "end" :
516+ return _context10 . stop ( ) ;
517+ }
518+ }
519+ } , _callee10 , this , [ [ 4 , 15 ] ] ) ;
520+ } ) ) ;
521+ } ;
458522export function parseData ( response , stackHeaders , contentTypeUID ) {
459523 var data = response . data || { } ;
460524
0 commit comments