@rpldy/shared
Advanced tools
Comparing version 0.14.2 to 0.15.0
@@ -25,3 +25,4 @@ "use strict"; | ||
var _default = (f, batchId, isPending = false) => { | ||
const createBatchItem = function (f, batchId) { | ||
let isPending = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : false; | ||
iCounter += f.id && f.batchId ? 0 : 1; //keep existing id for recycled items | ||
@@ -66,2 +67,3 @@ | ||
var _default = createBatchItem; | ||
exports.default = _default; |
@@ -6,3 +6,3 @@ "use strict"; | ||
}); | ||
exports.FILE_STATES = exports.BATCH_STATES = exports.DEBUG_LOG_KEY = void 0; | ||
exports.FILE_STATES = exports.DEBUG_LOG_KEY = exports.BATCH_STATES = void 0; | ||
const DEBUG_LOG_KEY = "__rpldy-logger-debug__"; | ||
@@ -9,0 +9,0 @@ exports.DEBUG_LOG_KEY = DEBUG_LOG_KEY; |
@@ -6,56 +6,50 @@ "use strict"; | ||
}); | ||
Object.defineProperty(exports, "invariant", { | ||
Object.defineProperty(exports, "BATCH_STATES", { | ||
enumerable: true, | ||
get: function () { | ||
return _invariant.default; | ||
return _consts.BATCH_STATES; | ||
} | ||
}); | ||
Object.defineProperty(exports, "throttle", { | ||
Object.defineProperty(exports, "FILE_STATES", { | ||
enumerable: true, | ||
get: function () { | ||
return _justThrottle.default; | ||
return _consts.FILE_STATES; | ||
} | ||
}); | ||
Object.defineProperty(exports, "BATCH_STATES", { | ||
Object.defineProperty(exports, "clone", { | ||
enumerable: true, | ||
get: function () { | ||
return _consts.BATCH_STATES; | ||
return _utils.clone; | ||
} | ||
}); | ||
Object.defineProperty(exports, "FILE_STATES", { | ||
Object.defineProperty(exports, "createBatchItem", { | ||
enumerable: true, | ||
get: function () { | ||
return _consts.FILE_STATES; | ||
return _batchItem.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "triggerCancellable", { | ||
Object.defineProperty(exports, "devFreeze", { | ||
enumerable: true, | ||
get: function () { | ||
return _triggerCancellable.default; | ||
return _utils.devFreeze; | ||
} | ||
}); | ||
Object.defineProperty(exports, "triggerUpdater", { | ||
Object.defineProperty(exports, "getMerge", { | ||
enumerable: true, | ||
get: function () { | ||
return _triggerUpdater.default; | ||
return _utils.getMerge; | ||
} | ||
}); | ||
Object.defineProperty(exports, "createBatchItem", { | ||
Object.defineProperty(exports, "hasWindow", { | ||
enumerable: true, | ||
get: function () { | ||
return _batchItem.default; | ||
return _utils.hasWindow; | ||
} | ||
}); | ||
Object.defineProperty(exports, "request", { | ||
Object.defineProperty(exports, "invariant", { | ||
enumerable: true, | ||
get: function () { | ||
return _request.default; | ||
return _invariant.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "parseResponseHeaders", { | ||
enumerable: true, | ||
get: function () { | ||
return _request.parseResponseHeaders; | ||
} | ||
}); | ||
Object.defineProperty(exports, "isFunction", { | ||
@@ -73,14 +67,15 @@ enumerable: true, | ||
}); | ||
Object.defineProperty(exports, "isSamePropInArrays", { | ||
Object.defineProperty(exports, "isProduction", { | ||
enumerable: true, | ||
get: function () { | ||
return _utils.isSamePropInArrays; | ||
return _utils.isProduction; | ||
} | ||
}); | ||
Object.defineProperty(exports, "devFreeze", { | ||
Object.defineProperty(exports, "isSamePropInArrays", { | ||
enumerable: true, | ||
get: function () { | ||
return _utils.devFreeze; | ||
return _utils.isSamePropInArrays; | ||
} | ||
}); | ||
exports.logger = void 0; | ||
Object.defineProperty(exports, "merge", { | ||
@@ -92,33 +87,38 @@ enumerable: true, | ||
}); | ||
Object.defineProperty(exports, "getMerge", { | ||
Object.defineProperty(exports, "parseResponseHeaders", { | ||
enumerable: true, | ||
get: function () { | ||
return _utils.getMerge; | ||
return _request.parseResponseHeaders; | ||
} | ||
}); | ||
Object.defineProperty(exports, "clone", { | ||
Object.defineProperty(exports, "pick", { | ||
enumerable: true, | ||
get: function () { | ||
return _utils.clone; | ||
return _utils.pick; | ||
} | ||
}); | ||
Object.defineProperty(exports, "pick", { | ||
Object.defineProperty(exports, "request", { | ||
enumerable: true, | ||
get: function () { | ||
return _utils.pick; | ||
return _request.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "hasWindow", { | ||
Object.defineProperty(exports, "throttle", { | ||
enumerable: true, | ||
get: function () { | ||
return _utils.hasWindow; | ||
return _justThrottle.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "isProduction", { | ||
Object.defineProperty(exports, "triggerCancellable", { | ||
enumerable: true, | ||
get: function () { | ||
return _utils.isProduction; | ||
return _triggerCancellable.default; | ||
} | ||
}); | ||
exports.logger = void 0; | ||
Object.defineProperty(exports, "triggerUpdater", { | ||
enumerable: true, | ||
get: function () { | ||
return _triggerUpdater.default; | ||
} | ||
}); | ||
@@ -145,6 +145,6 @@ var _invariant = _interopRequireDefault(require("invariant")); | ||
function _getRequireWildcardCache() { if (typeof WeakMap !== "function") return null; var cache = new WeakMap(); _getRequireWildcardCache = function () { return cache; }; return cache; } | ||
function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function (nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); } | ||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } if (obj === null || typeof obj !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; } | ||
function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || typeof obj !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; } | ||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } |
@@ -6,3 +6,3 @@ "use strict"; | ||
}); | ||
exports.debugLog = exports.setDebug = exports.isDebugOn = void 0; | ||
exports.setDebug = exports.isDebugOn = exports.debugLog = void 0; | ||
@@ -37,6 +37,6 @@ var _consts = require("./consts"); | ||
const debugLog = (...args) => { | ||
const debugLog = function () { | ||
if (isDebugOn()) { | ||
// eslint-disable-next-line no-console | ||
console.log(...args); | ||
console.log(...arguments); | ||
} | ||
@@ -43,0 +43,0 @@ }; |
@@ -6,2 +6,3 @@ "use strict"; | ||
}); | ||
exports.default = void 0; | ||
Object.defineProperty(exports, "parseResponseHeaders", { | ||
@@ -13,3 +14,2 @@ enumerable: true, | ||
}); | ||
exports.default = void 0; | ||
@@ -16,0 +16,0 @@ var _request = _interopRequireDefault(require("./request")); |
@@ -10,3 +10,3 @@ "use strict"; | ||
var _default = xhr => { | ||
const parseResponseHeaders = xhr => { | ||
let resHeaders; | ||
@@ -27,2 +27,3 @@ | ||
var _default = parseResponseHeaders; | ||
exports.default = _default; |
@@ -18,3 +18,4 @@ "use strict"; | ||
const request = (url, data, options = {}) => { | ||
const request = function (url, data) { | ||
let options = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {}; | ||
const req = new XMLHttpRequest(); | ||
@@ -21,0 +22,0 @@ const pXhr = new Promise((resolve, reject) => { |
@@ -8,13 +8,23 @@ "use strict"; | ||
const triggerCancellable = (trigger, event, ...args) => { | ||
const doTrigger = (event, ...args) => new Promise((resolve, reject) => { | ||
const results = trigger(event, ...args); | ||
if (results && results.length) { | ||
Promise.all(results).catch(reject).then(resolvedResults => resolvedResults && resolve(!!~resolvedResults.findIndex(r => r === false))); | ||
} else { | ||
resolve(false); | ||
const triggerCancellable = function (trigger, event) { | ||
const doTrigger = function (event) { | ||
for (var _len2 = arguments.length, args = new Array(_len2 > 1 ? _len2 - 1 : 0), _key2 = 1; _key2 < _len2; _key2++) { | ||
args[_key2 - 1] = arguments[_key2]; | ||
} | ||
}); | ||
return new Promise((resolve, reject) => { | ||
const results = trigger(event, ...args); | ||
if (results && results.length) { | ||
Promise.all(results).catch(reject).then(resolvedResults => resolvedResults && resolve(!!~resolvedResults.findIndex(r => r === false))); | ||
} else { | ||
resolve(false); | ||
} | ||
}); | ||
}; | ||
for (var _len = arguments.length, args = new Array(_len > 2 ? _len - 2 : 0), _key = 2; _key < _len; _key++) { | ||
args[_key - 2] = arguments[_key]; | ||
} | ||
return event ? doTrigger(event, ...args) : doTrigger; | ||
@@ -21,0 +31,0 @@ }; |
@@ -10,26 +10,37 @@ "use strict"; | ||
var _default = (trigger, event, ...args) => { | ||
const doTrigger = (event, ...args) => new Promise((resolve, reject) => { | ||
const results = trigger(event, ...args); | ||
const triggerUpdater = function (trigger, event) { | ||
const doTrigger = function (event) { | ||
for (var _len2 = arguments.length, args = new Array(_len2 > 1 ? _len2 - 1 : 0), _key2 = 1; _key2 < _len2; _key2++) { | ||
args[_key2 - 1] = arguments[_key2]; | ||
} | ||
if (results && results.length) { | ||
Promise.all(results).catch(reject).then(resolvedResults => { | ||
let result; | ||
return new Promise((resolve, reject) => { | ||
const results = trigger(event, ...args); | ||
if (resolvedResults) { | ||
while (isEmpty(result) && resolvedResults.length) { | ||
result = resolvedResults.pop(); | ||
if (results && results.length) { | ||
Promise.all(results).catch(reject).then(resolvedResults => { | ||
let result; | ||
if (resolvedResults) { | ||
while (isEmpty(result) && resolvedResults.length) { | ||
result = resolvedResults.pop(); | ||
} | ||
} | ||
} | ||
resolve(isEmpty(result) ? undefined : result); | ||
}); | ||
} else { | ||
resolve(); | ||
} | ||
}); | ||
resolve(isEmpty(result) ? undefined : result); | ||
}); | ||
} else { | ||
resolve(); | ||
} | ||
}); | ||
}; | ||
for (var _len = arguments.length, args = new Array(_len > 2 ? _len - 2 : 0), _key = 2; _key < _len; _key++) { | ||
args[_key - 2] = arguments[_key]; | ||
} | ||
return event ? doTrigger(event, ...args) : doTrigger; | ||
}; | ||
var _default = triggerUpdater; | ||
exports.default = _default; |
@@ -10,5 +10,5 @@ "use strict"; | ||
function _getRequireWildcardCache() { if (typeof WeakMap !== "function") return null; var cache = new WeakMap(); _getRequireWildcardCache = function () { return cache; }; return cache; } | ||
function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function (nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); } | ||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } if (obj === null || typeof obj !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; } | ||
function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || typeof obj !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; } | ||
@@ -21,4 +21,8 @@ /** | ||
*/ | ||
var _default = (obj, mergeFn = _merge.default) => (0, _merge.isMergeObj)(obj) ? mergeFn(Array.isArray(obj) ? [] : {}, obj) : obj; | ||
const clone = function (obj) { | ||
let mergeFn = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : _merge.default; | ||
return (0, _merge.isMergeObj)(obj) ? mergeFn(Array.isArray(obj) ? [] : {}, obj) : obj; | ||
}; | ||
var _default = clone; | ||
exports.default = _default; |
@@ -6,60 +6,60 @@ "use strict"; | ||
}); | ||
Object.defineProperty(exports, "isFunction", { | ||
Object.defineProperty(exports, "clone", { | ||
enumerable: true, | ||
get: function () { | ||
return _isFunction.default; | ||
return _clone.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "isSamePropInArrays", { | ||
Object.defineProperty(exports, "devFreeze", { | ||
enumerable: true, | ||
get: function () { | ||
return _isSamePropInArrays.default; | ||
return _devFreeze.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "devFreeze", { | ||
Object.defineProperty(exports, "getMerge", { | ||
enumerable: true, | ||
get: function () { | ||
return _devFreeze.default; | ||
return _merge.getMerge; | ||
} | ||
}); | ||
Object.defineProperty(exports, "merge", { | ||
Object.defineProperty(exports, "hasWindow", { | ||
enumerable: true, | ||
get: function () { | ||
return _merge.default; | ||
return _hasWindow.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "getMerge", { | ||
Object.defineProperty(exports, "isFunction", { | ||
enumerable: true, | ||
get: function () { | ||
return _merge.getMerge; | ||
return _isFunction.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "clone", { | ||
Object.defineProperty(exports, "isPlainObject", { | ||
enumerable: true, | ||
get: function () { | ||
return _clone.default; | ||
return _isPlainObject.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "pick", { | ||
Object.defineProperty(exports, "isProduction", { | ||
enumerable: true, | ||
get: function () { | ||
return _pick.default; | ||
return _isProduction.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "isPlainObject", { | ||
Object.defineProperty(exports, "isSamePropInArrays", { | ||
enumerable: true, | ||
get: function () { | ||
return _isPlainObject.default; | ||
return _isSamePropInArrays.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "hasWindow", { | ||
Object.defineProperty(exports, "merge", { | ||
enumerable: true, | ||
get: function () { | ||
return _hasWindow.default; | ||
return _merge.default; | ||
} | ||
}); | ||
Object.defineProperty(exports, "isProduction", { | ||
Object.defineProperty(exports, "pick", { | ||
enumerable: true, | ||
get: function () { | ||
return _isProduction.default; | ||
return _pick.default; | ||
} | ||
@@ -86,6 +86,6 @@ }); | ||
function _getRequireWildcardCache() { if (typeof WeakMap !== "function") return null; var cache = new WeakMap(); _getRequireWildcardCache = function () { return cache; }; return cache; } | ||
function _getRequireWildcardCache(nodeInterop) { if (typeof WeakMap !== "function") return null; var cacheBabelInterop = new WeakMap(); var cacheNodeInterop = new WeakMap(); return (_getRequireWildcardCache = function (nodeInterop) { return nodeInterop ? cacheNodeInterop : cacheBabelInterop; })(nodeInterop); } | ||
function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } if (obj === null || typeof obj !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; } | ||
function _interopRequireWildcard(obj, nodeInterop) { if (!nodeInterop && obj && obj.__esModule) { return obj; } if (obj === null || typeof obj !== "object" && typeof obj !== "function") { return { default: obj }; } var cache = _getRequireWildcardCache(nodeInterop); if (cache && cache.has(obj)) { return cache.get(obj); } var newObj = {}; var hasPropertyDescriptor = Object.defineProperty && Object.getOwnPropertyDescriptor; for (var key in obj) { if (key !== "default" && Object.prototype.hasOwnProperty.call(obj, key)) { var desc = hasPropertyDescriptor ? Object.getOwnPropertyDescriptor(obj, key) : null; if (desc && (desc.get || desc.set)) { Object.defineProperty(newObj, key, desc); } else { newObj[key] = obj[key]; } } } newObj.default = obj; if (cache) { cache.set(obj, newObj); } return newObj; } | ||
function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; } |
@@ -8,3 +8,3 @@ "use strict"; | ||
var _default = obj => { | ||
const isPlainObject = obj => { | ||
var _Object$getPrototypeO; | ||
@@ -15,2 +15,3 @@ | ||
var _default = isPlainObject; | ||
exports.default = _default; |
@@ -6,3 +6,3 @@ "use strict"; | ||
}); | ||
exports.getMerge = exports.default = exports.isMergeObj = void 0; | ||
exports.isMergeObj = exports.getMerge = exports.default = void 0; | ||
@@ -22,4 +22,10 @@ var _isPlainObject = _interopRequireDefault(require("./isPlainObject")); | ||
const getMerge = (options = {}) => { | ||
const merge = (target, ...sources) => { | ||
const getMerge = function () { | ||
let options = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {}; | ||
const merge = function (target) { | ||
for (var _len = arguments.length, sources = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) { | ||
sources[_key - 1] = arguments[_key]; | ||
} | ||
if (target && sources.length) { | ||
@@ -26,0 +32,0 @@ sources.forEach(source => { |
@@ -8,3 +8,3 @@ "use strict"; | ||
var _default = (obj, props) => obj && Object.keys(obj).reduce((res, key) => { | ||
const pick = (obj, props) => obj && Object.keys(obj).reduce((res, key) => { | ||
if (~props.indexOf(key)) { | ||
@@ -17,2 +17,3 @@ res[key] = obj[key]; | ||
var _default = pick; | ||
exports.default = _default; |
@@ -17,3 +17,4 @@ import { FILE_STATES } from "./consts"; | ||
export default ((f, batchId, isPending = false) => { | ||
const createBatchItem = function (f, batchId) { | ||
let isPending = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : false; | ||
iCounter += f.id && f.batchId ? 0 : 1; //keep existing id for recycled items | ||
@@ -56,2 +57,4 @@ | ||
return batchItem; | ||
}); | ||
}; | ||
export default createBatchItem; |
@@ -9,6 +9,6 @@ import invariant from "invariant"; | ||
import request, { parseResponseHeaders } from "./request"; | ||
export { BATCH_STATES, FILE_STATES //one source for invariant to all other packages | ||
, invariant //one source for throttle to all other packages | ||
, throttle, logger, triggerCancellable, triggerUpdater, createBatchItem, request, parseResponseHeaders }; | ||
export { BATCH_STATES, FILE_STATES, //one source for invariant to all other packages | ||
invariant, //one source for throttle to all other packages | ||
throttle, logger, triggerCancellable, triggerUpdater, createBatchItem, request, parseResponseHeaders }; | ||
export { //cant use * because of flow | ||
isFunction, isPlainObject, isSamePropInArrays, devFreeze, merge, getMerge, clone, pick, hasWindow, isProduction } from "./utils"; |
@@ -21,6 +21,6 @@ import { DEBUG_LOG_KEY } from "./consts"; | ||
const debugLog = (...args) => { | ||
const debugLog = function () { | ||
if (isDebugOn()) { | ||
// eslint-disable-next-line no-console | ||
console.log(...args); | ||
console.log(...arguments); | ||
} | ||
@@ -27,0 +27,0 @@ }; |
import { debugLog } from "../logger"; | ||
export default (xhr => { | ||
const parseResponseHeaders = xhr => { | ||
let resHeaders; | ||
@@ -16,2 +17,4 @@ | ||
return resHeaders; | ||
}); | ||
}; | ||
export default parseResponseHeaders; |
@@ -11,3 +11,4 @@ const setHeaders = (req, headers) => { | ||
const request = (url, data, options = {}) => { | ||
const request = function (url, data) { | ||
let options = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : {}; | ||
const req = new XMLHttpRequest(); | ||
@@ -14,0 +15,0 @@ const pXhr = new Promise((resolve, reject) => { |
@@ -1,12 +0,22 @@ | ||
const triggerCancellable = (trigger, event, ...args) => { | ||
const doTrigger = (event, ...args) => new Promise((resolve, reject) => { | ||
const results = trigger(event, ...args); | ||
if (results && results.length) { | ||
Promise.all(results).catch(reject).then(resolvedResults => resolvedResults && resolve(!!~resolvedResults.findIndex(r => r === false))); | ||
} else { | ||
resolve(false); | ||
const triggerCancellable = function (trigger, event) { | ||
const doTrigger = function (event) { | ||
for (var _len2 = arguments.length, args = new Array(_len2 > 1 ? _len2 - 1 : 0), _key2 = 1; _key2 < _len2; _key2++) { | ||
args[_key2 - 1] = arguments[_key2]; | ||
} | ||
}); | ||
return new Promise((resolve, reject) => { | ||
const results = trigger(event, ...args); | ||
if (results && results.length) { | ||
Promise.all(results).catch(reject).then(resolvedResults => resolvedResults && resolve(!!~resolvedResults.findIndex(r => r === false))); | ||
} else { | ||
resolve(false); | ||
} | ||
}); | ||
}; | ||
for (var _len = arguments.length, args = new Array(_len > 2 ? _len - 2 : 0), _key = 2; _key < _len; _key++) { | ||
args[_key - 2] = arguments[_key]; | ||
} | ||
return event ? doTrigger(event, ...args) : doTrigger; | ||
@@ -13,0 +23,0 @@ }; |
const isEmpty = val => val === null || val === undefined; | ||
export default ((trigger, event, ...args) => { | ||
const doTrigger = (event, ...args) => new Promise((resolve, reject) => { | ||
const results = trigger(event, ...args); | ||
const triggerUpdater = function (trigger, event) { | ||
const doTrigger = function (event) { | ||
for (var _len2 = arguments.length, args = new Array(_len2 > 1 ? _len2 - 1 : 0), _key2 = 1; _key2 < _len2; _key2++) { | ||
args[_key2 - 1] = arguments[_key2]; | ||
} | ||
if (results && results.length) { | ||
Promise.all(results).catch(reject).then(resolvedResults => { | ||
let result; | ||
return new Promise((resolve, reject) => { | ||
const results = trigger(event, ...args); | ||
if (resolvedResults) { | ||
while (isEmpty(result) && resolvedResults.length) { | ||
result = resolvedResults.pop(); | ||
if (results && results.length) { | ||
Promise.all(results).catch(reject).then(resolvedResults => { | ||
let result; | ||
if (resolvedResults) { | ||
while (isEmpty(result) && resolvedResults.length) { | ||
result = resolvedResults.pop(); | ||
} | ||
} | ||
} | ||
resolve(isEmpty(result) ? undefined : result); | ||
}); | ||
} else { | ||
resolve(); | ||
} | ||
}); | ||
resolve(isEmpty(result) ? undefined : result); | ||
}); | ||
} else { | ||
resolve(); | ||
} | ||
}); | ||
}; | ||
for (var _len = arguments.length, args = new Array(_len > 2 ? _len - 2 : 0), _key = 2; _key < _len; _key++) { | ||
args[_key - 2] = arguments[_key]; | ||
} | ||
return event ? doTrigger(event, ...args) : doTrigger; | ||
}); | ||
}; | ||
export default triggerUpdater; |
@@ -9,2 +9,7 @@ import merge, { isMergeObj } from "./merge"; | ||
*/ | ||
export default ((obj, mergeFn = merge) => isMergeObj(obj) ? mergeFn(Array.isArray(obj) ? [] : {}, obj) : obj); | ||
const clone = function (obj) { | ||
let mergeFn = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : merge; | ||
return isMergeObj(obj) ? mergeFn(Array.isArray(obj) ? [] : {}, obj) : obj; | ||
}; | ||
export default clone; |
@@ -1,5 +0,7 @@ | ||
export default (obj => { | ||
const isPlainObject = obj => { | ||
var _Object$getPrototypeO; | ||
return !!obj && typeof obj === "object" && (((_Object$getPrototypeO = Object.getPrototypeOf(obj)) === null || _Object$getPrototypeO === void 0 ? void 0 : _Object$getPrototypeO.constructor.name) === "Object" || Object.getPrototypeOf(obj) === null); | ||
}); | ||
}; | ||
export default isPlainObject; |
@@ -9,4 +9,10 @@ import isPlainObject from "./isPlainObject"; | ||
const getMerge = (options = {}) => { | ||
const merge = (target, ...sources) => { | ||
const getMerge = function () { | ||
let options = arguments.length > 0 && arguments[0] !== undefined ? arguments[0] : {}; | ||
const merge = function (target) { | ||
for (var _len = arguments.length, sources = new Array(_len > 1 ? _len - 1 : 0), _key = 1; _key < _len; _key++) { | ||
sources[_key - 1] = arguments[_key]; | ||
} | ||
if (target && sources.length) { | ||
@@ -13,0 +19,0 @@ sources.forEach(source => { |
@@ -1,2 +0,2 @@ | ||
export default ((obj, props) => obj && Object.keys(obj).reduce((res, key) => { | ||
const pick = (obj, props) => obj && Object.keys(obj).reduce((res, key) => { | ||
if (~props.indexOf(key)) { | ||
@@ -7,2 +7,4 @@ res[key] = obj[key]; | ||
return res; | ||
}, {})); | ||
}, {}); | ||
export default pick; |
{ | ||
"version": "0.14.2", | ||
"version": "0.15.0", | ||
"name": "@rpldy/shared", | ||
@@ -21,3 +21,3 @@ "description": "internal set of utils+types for react-uploady", | ||
"devDependencies": { | ||
"flow-bin": "^0.159.0" | ||
"flow-bin": "^0.164.0" | ||
}, | ||
@@ -31,3 +31,3 @@ "dependencies": { | ||
}, | ||
"gitHead": "a03a076546fd0895f2eada2687de86a2e23f7732" | ||
"gitHead": "7909b3aacc4afd229e4bc6810da8560be19706b2" | ||
} |
@@ -15,3 +15,16 @@ export type Destination = { | ||
export interface UploadOptions { | ||
export interface SendOptions { | ||
method: string; | ||
paramName: string; | ||
params?: Record<string, unknown>; | ||
headers?: Record<string, unknown>; | ||
forceJsonResponse?: boolean; | ||
withCredentials?: boolean; | ||
formatGroupParamName?: FormatParamGroupNameMethod; | ||
sendWithFormData?: boolean; | ||
formDataAllowUndefined?: boolean; | ||
formatServerResponse?: FormatServerResponseMethod; | ||
} | ||
export interface UploadOptions extends Partial<SendOptions>{ | ||
autoUpload?: boolean; | ||
@@ -23,12 +36,4 @@ clearPendingOnAdd?: boolean; | ||
fileFilter?: FileFilterMethod; | ||
//send options | ||
destination?: Destination; | ||
inputFieldName?: string; | ||
method?: string; | ||
params?: Record<string, unknown>; | ||
forceJsonResponse?: boolean; | ||
withCredentials?: boolean; | ||
sendWithFormData?: boolean; | ||
formatServerResponse?: FormatServerResponseMethod, | ||
} | ||
@@ -35,0 +40,0 @@ |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
40273
1016