uni.api.esm.js 33.4 KB
Newer Older
fxy060608's avatar
fxy060608 已提交
1
import { isArray, hasOwn, isString, isPlainObject, isObject, capitalize, toRawType, makeMap, isFunction, isPromise, remove, extend } from '@vue/shared';
fxy060608's avatar
fxy060608 已提交
2

fxy060608's avatar
fxy060608 已提交
3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
let vueApp;
const createVueAppHooks = [];
/**
 * 提供 createApp 的回调事件,方便三方插件接收 App 对象,处理挂靠全局 mixin 之类的逻辑
 */
function onCreateVueApp(hook) {
    // TODO 每个 nvue 页面都会触发
    if (vueApp) {
        return hook(vueApp);
    }
    createVueAppHooks.push(hook);
}
function invokeCreateVueAppHook(app) {
    vueApp = app;
    createVueAppHooks.forEach((hook) => hook(app));
}

fxy060608's avatar
fxy060608 已提交
20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55
const eventChannels = {};
const eventChannelStack = [];
let id = 0;
function initEventChannel(events, cache = true) {
    id++;
    const eventChannel = new swan.EventChannel(id, events);
    if (cache) {
        eventChannels[id] = eventChannel;
        eventChannelStack.push(eventChannel);
    }
    return eventChannel;
}
function getEventChannel(id) {
    if (id) {
        const eventChannel = eventChannels[id];
        delete eventChannels[id];
        return eventChannel;
    }
    return eventChannelStack.shift();
}
const navigateTo = {
    args(fromArgs) {
        const id = initEventChannel(fromArgs.events).id;
        if (fromArgs.url) {
            fromArgs.url =
                fromArgs.url +
                    (fromArgs.url.indexOf('?') === -1 ? '?' : '&') +
                    '__id__=' +
                    id;
        }
    },
    returnValue(fromRes) {
        fromRes.eventChannel = getEventChannel();
    },
};

fxy060608's avatar
fxy060608 已提交
56 57
function getBaseSystemInfo() {
  return swan.getSystemInfoSync()
fxy060608's avatar
fxy060608 已提交
58 59
}

fxy060608's avatar
fxy060608 已提交
60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110
const E = function () {
    // Keep this empty so it's easier to inherit from
    // (via https://github.com/lipsmack from https://github.com/scottcorgan/tiny-emitter/issues/3)
};
E.prototype = {
    on: function (name, callback, ctx) {
        var e = this.e || (this.e = {});
        (e[name] || (e[name] = [])).push({
            fn: callback,
            ctx: ctx,
        });
        return this;
    },
    once: function (name, callback, ctx) {
        var self = this;
        function listener() {
            self.off(name, listener);
            callback.apply(ctx, arguments);
        }
        listener._ = callback;
        return this.on(name, listener, ctx);
    },
    emit: function (name) {
        var data = [].slice.call(arguments, 1);
        var evtArr = ((this.e || (this.e = {}))[name] || []).slice();
        var i = 0;
        var len = evtArr.length;
        for (i; i < len; i++) {
            evtArr[i].fn.apply(evtArr[i].ctx, data);
        }
        return this;
    },
    off: function (name, callback) {
        var e = this.e || (this.e = {});
        var evts = e[name];
        var liveEvents = [];
        if (evts && callback) {
            for (var i = 0, len = evts.length; i < len; i++) {
                if (evts[i].fn !== callback && evts[i].fn._ !== callback)
                    liveEvents.push(evts[i]);
            }
        }
        // Remove event from queue to prevent memory leak
        // Suggested by https://github.com/lazd
        // Ref: https://github.com/scottcorgan/tiny-emitter/commit/c6ebfaa9bc973b33d110a84a307742b7cf94c953#commitcomment-5024910
        liveEvents.length ? (e[name] = liveEvents) : delete e[name];
        return this;
    },
};
var E$1 = E;

fxy060608's avatar
fxy060608 已提交
111
function validateProtocolFail(name, msg) {
112
    console.warn(`${name}: ${msg}`);
fxy060608's avatar
fxy060608 已提交
113
}
fxy060608's avatar
fxy060608 已提交
114 115 116 117
function validateProtocol(name, data, protocol, onFail) {
    if (!onFail) {
        onFail = validateProtocolFail;
    }
fxy060608's avatar
fxy060608 已提交
118 119
    for (const key in protocol) {
        const errMsg = validateProp(key, data[key], protocol[key], !hasOwn(data, key));
fxy060608's avatar
fxy060608 已提交
120
        if (isString(errMsg)) {
fxy060608's avatar
fxy060608 已提交
121
            onFail(name, errMsg);
fxy060608's avatar
fxy060608 已提交
122 123 124
        }
    }
}
fxy060608's avatar
fxy060608 已提交
125
function validateProtocols(name, args, protocol, onFail) {
fxy060608's avatar
fxy060608 已提交
126 127 128
    if (!protocol) {
        return;
    }
fxy060608's avatar
fxy060608 已提交
129
    if (!isArray(protocol)) {
fxy060608's avatar
fxy060608 已提交
130
        return validateProtocol(name, args[0] || Object.create(null), protocol, onFail);
fxy060608's avatar
fxy060608 已提交
131 132 133 134 135 136 137 138
    }
    const len = protocol.length;
    const argsLen = args.length;
    for (let i = 0; i < len; i++) {
        const opts = protocol[i];
        const data = Object.create(null);
        if (argsLen > i) {
            data[opts.name] = args[i];
fxy060608's avatar
fxy060608 已提交
139
        }
fxy060608's avatar
fxy060608 已提交
140
        validateProtocol(name, data, { [opts.name]: opts }, onFail);
fxy060608's avatar
fxy060608 已提交
141 142 143
    }
}
function validateProp(name, value, prop, isAbsent) {
fxy060608's avatar
fxy060608 已提交
144 145 146
    if (!isPlainObject(prop)) {
        prop = { type: prop };
    }
fxy060608's avatar
fxy060608 已提交
147 148 149 150 151 152
    const { type, required, validator } = prop;
    // required!
    if (required && isAbsent) {
        return 'Missing required args: "' + name + '"';
    }
    // missing but optional
fxy060608's avatar
fxy060608 已提交
153
    if (value == null && !required) {
fxy060608's avatar
fxy060608 已提交
154 155 156
        return;
    }
    // type check
fxy060608's avatar
fxy060608 已提交
157
    if (type != null) {
fxy060608's avatar
fxy060608 已提交
158 159 160 161 162 163 164 165 166 167 168 169 170 171
        let isValid = false;
        const types = isArray(type) ? type : [type];
        const expectedTypes = [];
        // value is valid as long as one of the specified types match
        for (let i = 0; i < types.length && !isValid; i++) {
            const { valid, expectedType } = assertType(value, types[i]);
            expectedTypes.push(expectedType || '');
            isValid = valid;
        }
        if (!isValid) {
            return getInvalidTypeMessage(name, value, expectedTypes);
        }
    }
    // custom validator
fxy060608's avatar
fxy060608 已提交
172 173
    if (validator) {
        return validator(value);
fxy060608's avatar
fxy060608 已提交
174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245
    }
}
const isSimpleType = /*#__PURE__*/ makeMap('String,Number,Boolean,Function,Symbol');
function assertType(value, type) {
    let valid;
    const expectedType = getType(type);
    if (isSimpleType(expectedType)) {
        const t = typeof value;
        valid = t === expectedType.toLowerCase();
        // for primitive wrapper objects
        if (!valid && t === 'object') {
            valid = value instanceof type;
        }
    }
    else if (expectedType === 'Object') {
        valid = isObject(value);
    }
    else if (expectedType === 'Array') {
        valid = isArray(value);
    }
    else {
        {
            valid = value instanceof type;
        }
    }
    return {
        valid,
        expectedType,
    };
}
function getInvalidTypeMessage(name, value, expectedTypes) {
    let message = `Invalid args: type check failed for args "${name}".` +
        ` Expected ${expectedTypes.map(capitalize).join(', ')}`;
    const expectedType = expectedTypes[0];
    const receivedType = toRawType(value);
    const expectedValue = styleValue(value, expectedType);
    const receivedValue = styleValue(value, receivedType);
    // check if we need to specify expected value
    if (expectedTypes.length === 1 &&
        isExplicable(expectedType) &&
        !isBoolean(expectedType, receivedType)) {
        message += ` with value ${expectedValue}`;
    }
    message += `, got ${receivedType} `;
    // check if we need to specify received value
    if (isExplicable(receivedType)) {
        message += `with value ${receivedValue}.`;
    }
    return message;
}
function getType(ctor) {
    const match = ctor && ctor.toString().match(/^\s*function (\w+)/);
    return match ? match[1] : '';
}
function styleValue(value, type) {
    if (type === 'String') {
        return `"${value}"`;
    }
    else if (type === 'Number') {
        return `${Number(value)}`;
    }
    else {
        return `${value}`;
    }
}
function isExplicable(type) {
    const explicitTypes = ['string', 'number', 'boolean'];
    return explicitTypes.some((elem) => type.toLowerCase() === elem);
}
function isBoolean(...args) {
    return args.some((elem) => elem.toLowerCase() === 'boolean');
}
fxy060608's avatar
fxy060608 已提交
246

fxy060608's avatar
fxy060608 已提交
247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270
function tryCatch(fn) {
    return function () {
        try {
            return fn.apply(fn, arguments);
        }
        catch (e) {
            // TODO
            console.error(e);
        }
    };
}

function getApiCallbacks(args) {
    const apiCallbacks = {};
    for (const name in args) {
        const fn = args[name];
        if (isFunction(fn)) {
            apiCallbacks[name] = tryCatch(fn);
            delete args[name];
        }
    }
    return apiCallbacks;
}

Q
qiang 已提交
271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353
const HOOK_SUCCESS = 'success';
const HOOK_FAIL = 'fail';
const HOOK_COMPLETE = 'complete';
const globalInterceptors = {};
const scopedInterceptors = {};
function wrapperHook(hook) {
    return function (data) {
        return hook(data) || data;
    };
}
function queue(hooks, data) {
    let promise = false;
    for (let i = 0; i < hooks.length; i++) {
        const hook = hooks[i];
        if (promise) {
            promise = Promise.resolve(wrapperHook(hook));
        }
        else {
            const res = hook(data);
            if (isPromise(res)) {
                promise = Promise.resolve(res);
            }
            if (res === false) {
                return {
                    then() { },
                    catch() { },
                };
            }
        }
    }
    return (promise || {
        then(callback) {
            return callback(data);
        },
        catch() { },
    });
}
function wrapperOptions(interceptors, options = {}) {
    [HOOK_SUCCESS, HOOK_FAIL, HOOK_COMPLETE].forEach((name) => {
        const hooks = interceptors[name];
        if (!isArray(hooks)) {
            return;
        }
        const oldCallback = options[name];
        options[name] = function callbackInterceptor(res) {
            queue(hooks, res).then((res) => {
                return (isFunction(oldCallback) && oldCallback(res)) || res;
            });
        };
    });
    return options;
}
function wrapperReturnValue(method, returnValue) {
    const returnValueHooks = [];
    if (isArray(globalInterceptors.returnValue)) {
        returnValueHooks.push(...globalInterceptors.returnValue);
    }
    const interceptor = scopedInterceptors[method];
    if (interceptor && isArray(interceptor.returnValue)) {
        returnValueHooks.push(...interceptor.returnValue);
    }
    returnValueHooks.forEach((hook) => {
        returnValue = hook(returnValue) || returnValue;
    });
    return returnValue;
}
function getApiInterceptorHooks(method) {
    const interceptor = Object.create(null);
    Object.keys(globalInterceptors).forEach((hook) => {
        if (hook !== 'returnValue') {
            interceptor[hook] = globalInterceptors[hook].slice();
        }
    });
    const scopedInterceptor = scopedInterceptors[method];
    if (scopedInterceptor) {
        Object.keys(scopedInterceptor).forEach((hook) => {
            if (hook !== 'returnValue') {
                interceptor[hook] = (interceptor[hook] || []).concat(scopedInterceptor[hook]);
            }
        });
    }
    return interceptor;
}
354
function invokeApi(method, api, options, params) {
Q
qiang 已提交
355 356 357 358 359 360 361 362 363 364 365 366 367 368 369
    const interceptor = getApiInterceptorHooks(method);
    if (interceptor && Object.keys(interceptor).length) {
        if (isArray(interceptor.invoke)) {
            const res = queue(interceptor.invoke, options);
            return res.then((options) => {
                return api(wrapperOptions(interceptor, options), ...params);
            });
        }
        else {
            return api(wrapperOptions(interceptor, options), ...params);
        }
    }
    return api(options, ...params);
}

fxy060608's avatar
fxy060608 已提交
370
function handlePromise(promise) {
fxy060608's avatar
fxy060608 已提交
371 372 373 374 375 376 377
    // if (__UNI_FEATURE_PROMISE__) {
    //   return promise
    //     .then((data) => {
    //       return [null, data]
    //     })
    //     .catch((err) => [err])
    // }
fxy060608's avatar
fxy060608 已提交
378 379 380
    return promise;
}

fxy060608's avatar
fxy060608 已提交
381
function formatApiArgs(args, options) {
fxy060608's avatar
fxy060608 已提交
382 383 384
    const params = args[0];
    if (!options ||
        (!isPlainObject(options.formatArgs) && isPlainObject(params))) {
fxy060608's avatar
fxy060608 已提交
385
        return;
fxy060608's avatar
fxy060608 已提交
386 387
    }
    const formatArgs = options.formatArgs;
fxy060608's avatar
fxy060608 已提交
388 389 390
    const keys = Object.keys(formatArgs);
    for (let i = 0; i < keys.length; i++) {
        const name = keys[i];
fxy060608's avatar
fxy060608 已提交
391 392
        const formatterOrDefaultValue = formatArgs[name];
        if (isFunction(formatterOrDefaultValue)) {
fxy060608's avatar
fxy060608 已提交
393 394 395 396
            const errMsg = formatterOrDefaultValue(args[0][name], params);
            if (isString(errMsg)) {
                return errMsg;
            }
fxy060608's avatar
fxy060608 已提交
397 398 399 400 401 402 403
        }
        else {
            // defaultValue
            if (!hasOwn(params, name)) {
                params[name] = formatterOrDefaultValue;
            }
        }
fxy060608's avatar
fxy060608 已提交
404
    }
405
}
fxy060608's avatar
fxy060608 已提交
406 407 408 409 410 411 412 413
function beforeInvokeApi(name, args, protocol, options) {
    if ((process.env.NODE_ENV !== 'production')) {
        validateProtocols(name, args, protocol);
    }
    if (options && options.beforeInvoke) {
        const errMsg = options.beforeInvoke(args);
        if (isString(errMsg)) {
            return errMsg;
fxy060608's avatar
fxy060608 已提交
414
        }
fxy060608's avatar
fxy060608 已提交
415 416 417 418 419 420 421 422 423 424 425
    }
    const errMsg = formatApiArgs(args, options);
    if (errMsg) {
        return errMsg;
    }
}
function wrapperSyncApi(name, fn, protocol, options) {
    return (...args) => {
        const errMsg = beforeInvokeApi(name, args, protocol, options);
        if (errMsg) {
            throw new Error(errMsg);
fxy060608's avatar
fxy060608 已提交
426
        }
fxy060608's avatar
fxy060608 已提交
427
        return fn.apply(null, args);
fxy060608's avatar
fxy060608 已提交
428
    };
429
}
fxy060608's avatar
fxy060608 已提交
430
function defineSyncApi(name, fn, protocol, options) {
fxy060608's avatar
fxy060608 已提交
431
    return wrapperSyncApi(name, fn, (process.env.NODE_ENV !== 'production') ? protocol : undefined, options);
fxy060608's avatar
fxy060608 已提交
432 433
}

fxy060608's avatar
fxy060608 已提交
434
const API_UPX2PX = 'upx2px';
fxy060608's avatar
fxy060608 已提交
435 436 437 438
const Upx2pxProtocol = [
    {
        name: 'upx',
        type: [Number, String],
439 440
        required: true,
    },
fxy060608's avatar
fxy060608 已提交
441
];
fxy060608's avatar
fxy060608 已提交
442

fxy060608's avatar
fxy060608 已提交
443 444 445 446 447 448
const EPS = 1e-4;
const BASE_DEVICE_WIDTH = 750;
let isIOS = false;
let deviceWidth = 0;
let deviceDPR = 0;
function checkDeviceWidth() {
fxy060608's avatar
fxy060608 已提交
449
    const { platform, pixelRatio, windowWidth } = getBaseSystemInfo();
fxy060608's avatar
fxy060608 已提交
450 451 452 453
    deviceWidth = windowWidth;
    deviceDPR = pixelRatio;
    isIOS = platform === 'ios';
}
fxy060608's avatar
fxy060608 已提交
454
const upx2px = defineSyncApi(API_UPX2PX, (number, newDeviceWidth) => {
fxy060608's avatar
fxy060608 已提交
455 456 457 458 459 460 461
    if (deviceWidth === 0) {
        checkDeviceWidth();
    }
    number = Number(number);
    if (number === 0) {
        return 0;
    }
Q
qiang 已提交
462 463
    let width = newDeviceWidth || deviceWidth;
    let result = (number / BASE_DEVICE_WIDTH) * width;
fxy060608's avatar
fxy060608 已提交
464 465 466 467 468 469 470 471 472 473 474 475 476 477
    if (result < 0) {
        result = -result;
    }
    result = Math.floor(result + EPS);
    if (result === 0) {
        if (deviceDPR === 1 || !isIOS) {
            result = 1;
        }
        else {
            result = 0.5;
        }
    }
    return number < 0 ? -result : result;
}, Upx2pxProtocol);
fxy060608's avatar
fxy060608 已提交
478

fxy060608's avatar
fxy060608 已提交
479 480
const API_ADD_INTERCEPTOR = 'addInterceptor';
const API_REMOVE_INTERCEPTOR = 'removeInterceptor';
fxy060608's avatar
fxy060608 已提交
481 482 483 484
const AddInterceptorProtocol = [
    {
        name: 'method',
        type: [String, Object],
485 486
        required: true,
    },
fxy060608's avatar
fxy060608 已提交
487 488
];
const RemoveInterceptorProtocol = AddInterceptorProtocol;
fxy060608's avatar
fxy060608 已提交
489

fxy060608's avatar
fxy060608 已提交
490
function mergeInterceptorHook(interceptors, interceptor) {
491
    Object.keys(interceptor).forEach((hook) => {
fxy060608's avatar
fxy060608 已提交
492 493 494 495 496 497 498 499 500
        if (isFunction(interceptor[hook])) {
            interceptors[hook] = mergeHook(interceptors[hook], interceptor[hook]);
        }
    });
}
function removeInterceptorHook(interceptors, interceptor) {
    if (!interceptors || !interceptor) {
        return;
    }
fxy060608's avatar
fxy060608 已提交
501 502 503 504 505
    Object.keys(interceptor).forEach((name) => {
        const hooks = interceptors[name];
        const hook = interceptor[name];
        if (isArray(hooks) && isFunction(hook)) {
            remove(hooks, hook);
fxy060608's avatar
fxy060608 已提交
506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527
        }
    });
}
function mergeHook(parentVal, childVal) {
    const res = childVal
        ? parentVal
            ? parentVal.concat(childVal)
            : isArray(childVal)
                ? childVal
                : [childVal]
        : parentVal;
    return res ? dedupeHooks(res) : res;
}
function dedupeHooks(hooks) {
    const res = [];
    for (let i = 0; i < hooks.length; i++) {
        if (res.indexOf(hooks[i]) === -1) {
            res.push(hooks[i]);
        }
    }
    return res;
}
fxy060608's avatar
fxy060608 已提交
528
const addInterceptor = defineSyncApi(API_ADD_INTERCEPTOR, (method, interceptor) => {
fxy060608's avatar
fxy060608 已提交
529 530 531 532 533 534 535
    if (typeof method === 'string' && isPlainObject(interceptor)) {
        mergeInterceptorHook(scopedInterceptors[method] || (scopedInterceptors[method] = {}), interceptor);
    }
    else if (isPlainObject(method)) {
        mergeInterceptorHook(globalInterceptors, method);
    }
}, AddInterceptorProtocol);
fxy060608's avatar
fxy060608 已提交
536
const removeInterceptor = defineSyncApi(API_REMOVE_INTERCEPTOR, (method, interceptor) => {
fxy060608's avatar
fxy060608 已提交
537 538 539 540 541 542 543 544 545 546 547
    if (typeof method === 'string') {
        if (isPlainObject(interceptor)) {
            removeInterceptorHook(scopedInterceptors[method], interceptor);
        }
        else {
            delete scopedInterceptors[method];
        }
    }
    else if (isPlainObject(method)) {
        removeInterceptorHook(globalInterceptors, method);
    }
fxy060608's avatar
fxy060608 已提交
548 549
}, RemoveInterceptorProtocol);
const interceptors = {};
fxy060608's avatar
fxy060608 已提交
550

fxy060608's avatar
fxy060608 已提交
551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585
const API_ON = '$on';
const OnProtocol = [
    {
        name: 'event',
        type: String,
        required: true,
    },
    {
        name: 'callback',
        type: Function,
        required: true,
    },
];
const API_ONCE = '$once';
const OnceProtocol = OnProtocol;
const API_OFF = '$off';
const OffProtocol = [
    {
        name: 'event',
        type: [String, Array],
    },
    {
        name: 'callback',
        type: Function,
    },
];
const API_EMIT = '$emit';
const EmitProtocol = [
    {
        name: 'event',
        type: String,
        required: true,
    },
];

fxy060608's avatar
fxy060608 已提交
586
const emitter = new E$1();
fxy060608's avatar
fxy060608 已提交
587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607
const $on = defineSyncApi(API_ON, (name, callback) => {
    emitter.on(name, callback);
    return () => emitter.off(name, callback);
}, OnProtocol);
const $once = defineSyncApi(API_ONCE, (name, callback) => {
    emitter.once(name, callback);
    return () => emitter.off(name, callback);
}, OnceProtocol);
const $off = defineSyncApi(API_OFF, (name, callback) => {
    if (!name) {
        emitter.e = {};
        return;
    }
    if (!Array.isArray(name))
        name = [name];
    name.forEach((n) => emitter.off(n, callback));
}, OffProtocol);
const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
    emitter.emit(name, ...args);
}, EmitProtocol);

fxy060608's avatar
fxy060608 已提交
608 609 610 611 612 613 614 615 616
let cid;
let cidErrMsg;
function normalizePushMessage(message) {
    try {
        return JSON.parse(message);
    }
    catch (e) { }
    return message;
}
fxy060608's avatar
fxy060608 已提交
617 618 619 620 621 622 623
/**
 * @private
 * @param args
 */
function invokePushCallback(args) {
    if (args.type === 'clientId') {
        cid = args.cid;
fxy060608's avatar
fxy060608 已提交
624
        cidErrMsg = args.errMsg;
fxy060608's avatar
fxy060608 已提交
625
        invokeGetPushCidCallbacks(cid, args.errMsg);
fxy060608's avatar
fxy060608 已提交
626 627 628
    }
    else if (args.type === 'pushMsg') {
        onPushMessageCallbacks.forEach((callback) => {
fxy060608's avatar
fxy060608 已提交
629 630 631 632 633 634
            callback({ type: 'receive', data: normalizePushMessage(args.message) });
        });
    }
    else if (args.type === 'click') {
        onPushMessageCallbacks.forEach((callback) => {
            callback({ type: 'click', data: normalizePushMessage(args.message) });
fxy060608's avatar
fxy060608 已提交
635 636 637 638
        });
    }
}
const getPushCidCallbacks = [];
fxy060608's avatar
fxy060608 已提交
639
function invokeGetPushCidCallbacks(cid, errMsg) {
fxy060608's avatar
fxy060608 已提交
640
    getPushCidCallbacks.forEach((callback) => {
fxy060608's avatar
fxy060608 已提交
641
        callback(cid, errMsg);
fxy060608's avatar
fxy060608 已提交
642 643 644 645 646 647 648 649 650 651 652
    });
    getPushCidCallbacks.length = 0;
}
function getPushCid(args) {
    if (!isPlainObject(args)) {
        args = {};
    }
    const { success, fail, complete } = getApiCallbacks(args);
    const hasSuccess = isFunction(success);
    const hasFail = isFunction(fail);
    const hasComplete = isFunction(complete);
fxy060608's avatar
fxy060608 已提交
653
    getPushCidCallbacks.push((cid, errMsg) => {
fxy060608's avatar
fxy060608 已提交
654 655 656 657 658 659
        let res;
        if (cid) {
            res = { errMsg: 'getPushCid:ok', cid };
            hasSuccess && success(res);
        }
        else {
fxy060608's avatar
fxy060608 已提交
660
            res = { errMsg: 'getPushCid:fail' + (errMsg ? ' ' + errMsg : '') };
fxy060608's avatar
fxy060608 已提交
661 662 663 664
            hasFail && fail(res);
        }
        hasComplete && complete(res);
    });
fxy060608's avatar
fxy060608 已提交
665 666
    if (typeof cid !== 'undefined') {
        Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
fxy060608's avatar
fxy060608 已提交
667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687
    }
}
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
const onPushMessage = (fn) => {
    if (onPushMessageCallbacks.indexOf(fn) === -1) {
        onPushMessageCallbacks.push(fn);
    }
};
const offPushMessage = (fn) => {
    if (!fn) {
        onPushMessageCallbacks.length = 0;
    }
    else {
        const index = onPushMessageCallbacks.indexOf(fn);
        if (index > -1) {
            onPushMessageCallbacks.splice(index, 1);
        }
    }
};

Q
qiang 已提交
688
const SYNC_API_RE = /^\$|getLocale|setLocale|sendNativeEvent|restoreGlobal|requireGlobal|getCurrentSubNVue|getMenuButtonBoundingClientRect|^report|interceptors|Interceptor$|getSubNVueById|requireNativePlugin|upx2px|hideKeyboard|canIUse|^create|Sync$|Manager$|base64ToArrayBuffer|arrayBufferToBase64/;
fxy060608's avatar
fxy060608 已提交
689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713
const CONTEXT_API_RE = /^create|Manager$/;
// Context例外情况
const CONTEXT_API_RE_EXC = ['createBLEConnection'];
// 同步例外情况
const ASYNC_API = ['createBLEConnection'];
const CALLBACK_API_RE = /^on|^off/;
function isContextApi(name) {
    return CONTEXT_API_RE.test(name) && CONTEXT_API_RE_EXC.indexOf(name) === -1;
}
function isSyncApi(name) {
    return SYNC_API_RE.test(name) && ASYNC_API.indexOf(name) === -1;
}
function isCallbackApi(name) {
    return CALLBACK_API_RE.test(name) && name !== 'onPush';
}
function shouldPromise(name) {
    if (isContextApi(name) || isSyncApi(name) || isCallbackApi(name)) {
        return false;
    }
    return true;
}
/* eslint-disable no-extend-native */
if (!Promise.prototype.finally) {
    Promise.prototype.finally = function (onfinally) {
        const promise = this.constructor;
714
        return this.then((value) => promise.resolve(onfinally && onfinally()).then(() => value), (reason) => promise.resolve(onfinally && onfinally()).then(() => {
fxy060608's avatar
fxy060608 已提交
715 716 717 718 719 720 721 722 723 724 725
            throw reason;
        }));
    };
}
function promisify(name, api) {
    if (!shouldPromise(name)) {
        return api;
    }
    if (!isFunction(api)) {
        return api;
    }
726
    return function promiseApi(options = {}, ...rest) {
fxy060608's avatar
fxy060608 已提交
727 728 729
        if (isFunction(options.success) ||
            isFunction(options.fail) ||
            isFunction(options.complete)) {
730
            return wrapperReturnValue(name, invokeApi(name, api, options, rest));
fxy060608's avatar
fxy060608 已提交
731 732
        }
        return wrapperReturnValue(name, handlePromise(new Promise((resolve, reject) => {
fxy060608's avatar
fxy060608 已提交
733
            invokeApi(name, api, extend({}, options, {
fxy060608's avatar
fxy060608 已提交
734
                success: resolve,
735
                fail: reject,
736
            }), rest);
fxy060608's avatar
fxy060608 已提交
737 738
        })));
    };
fxy060608's avatar
fxy060608 已提交
739 740
}

fxy060608's avatar
fxy060608 已提交
741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829
const CALLBACKS = ['success', 'fail', 'cancel', 'complete'];
function initWrapper(protocols) {
    function processCallback(methodName, method, returnValue) {
        return function (res) {
            return method(processReturnValue(methodName, res, returnValue));
        };
    }
    function processArgs(methodName, fromArgs, argsOption = {}, returnValue = {}, keepFromArgs = false) {
        if (isPlainObject(fromArgs)) {
            // 一般 api 的参数解析
            const toArgs = (keepFromArgs === true ? fromArgs : {}); // returnValue 为 false 时,说明是格式化返回值,直接在返回值对象上修改赋值
            if (isFunction(argsOption)) {
                argsOption = argsOption(fromArgs, toArgs) || {};
            }
            for (const key in fromArgs) {
                if (hasOwn(argsOption, key)) {
                    let keyOption = argsOption[key];
                    if (isFunction(keyOption)) {
                        keyOption = keyOption(fromArgs[key], fromArgs, toArgs);
                    }
                    if (!keyOption) {
                        // 不支持的参数
                        console.warn(`百度小程序 ${methodName} 暂不支持 ${key}`);
                    }
                    else if (isString(keyOption)) {
                        // 重写参数 key
                        toArgs[keyOption] = fromArgs[key];
                    }
                    else if (isPlainObject(keyOption)) {
                        // {name:newName,value:value}可重新指定参数 key:value
                        toArgs[keyOption.name ? keyOption.name : key] = keyOption.value;
                    }
                }
                else if (CALLBACKS.indexOf(key) !== -1) {
                    const callback = fromArgs[key];
                    if (isFunction(callback)) {
                        toArgs[key] = processCallback(methodName, callback, returnValue);
                    }
                }
                else {
                    if (!keepFromArgs && !hasOwn(toArgs, key)) {
                        toArgs[key] = fromArgs[key];
                    }
                }
            }
            return toArgs;
        }
        else if (isFunction(fromArgs)) {
            fromArgs = processCallback(methodName, fromArgs, returnValue);
        }
        return fromArgs;
    }
    function processReturnValue(methodName, res, returnValue, keepReturnValue = false) {
        if (isFunction(protocols.returnValue)) {
            // 处理通用 returnValue
            res = protocols.returnValue(methodName, res);
        }
        return processArgs(methodName, res, returnValue, {}, keepReturnValue);
    }
    return function wrapper(methodName, method) {
        if (!hasOwn(protocols, methodName)) {
            return method;
        }
        const protocol = protocols[methodName];
        if (!protocol) {
            // 暂不支持的 api
            return function () {
                console.error(`百度小程序 暂不支持${methodName}`);
            };
        }
        return function (arg1, arg2) {
            // 目前 api 最多两个参数
            let options = protocol;
            if (isFunction(protocol)) {
                options = protocol(arg1);
            }
            arg1 = processArgs(methodName, arg1, options.args, options.returnValue);
            const args = [arg1];
            if (typeof arg2 !== 'undefined') {
                args.push(arg2);
            }
            const returnValue = swan[options.name || methodName].apply(swan, args);
            if (isSyncApi(methodName)) {
                // 同步 api
                return processReturnValue(methodName, returnValue, options.returnValue, isContextApi(methodName));
            }
            return returnValue;
        };
    };
fxy060608's avatar
fxy060608 已提交
830 831
}

fxy060608's avatar
fxy060608 已提交
832 833 834 835 836 837
const getLocale = () => {
    // 优先使用 $locale
    const app = getApp({ allowDefault: true });
    if (app && app.$vm) {
        return app.$vm.$locale;
    }
fxy060608's avatar
fxy060608 已提交
838
    return swan.getSystemInfoSync().language || 'zh-Hans';
fxy060608's avatar
fxy060608 已提交
839 840
};
const setLocale = (locale) => {
fxy060608's avatar
fxy060608 已提交
841 842 843 844 845
    const app = getApp();
    if (!app) {
        return false;
    }
    const oldLocale = app.$vm.$locale;
fxy060608's avatar
fxy060608 已提交
846
    if (oldLocale !== locale) {
fxy060608's avatar
fxy060608 已提交
847
        app.$vm.$locale = locale;
fxy060608's avatar
fxy060608 已提交
848 849 850 851 852 853 854 855 856 857
        onLocaleChangeCallbacks.forEach((fn) => fn({ locale }));
        return true;
    }
    return false;
};
const onLocaleChangeCallbacks = [];
const onLocaleChange = (fn) => {
    if (onLocaleChangeCallbacks.indexOf(fn) === -1) {
        onLocaleChangeCallbacks.push(fn);
    }
fxy060608's avatar
fxy060608 已提交
858 859 860 861
};
if (typeof global !== 'undefined') {
    global.getLocale = getLocale;
}
fxy060608's avatar
fxy060608 已提交
862

fxy060608's avatar
fxy060608 已提交
863 864 865 866 867 868
const baseApis = {
    $on,
    $off,
    $once,
    $emit,
    upx2px,
fxy060608's avatar
fxy060608 已提交
869
    interceptors,
fxy060608's avatar
fxy060608 已提交
870 871
    addInterceptor,
    removeInterceptor,
872 873
    onCreateVueApp,
    invokeCreateVueAppHook,
fxy060608's avatar
fxy060608 已提交
874 875 876
    getLocale,
    setLocale,
    onLocaleChange,
fxy060608's avatar
fxy060608 已提交
877 878 879 880
    getPushCid,
    onPushMessage,
    offPushMessage,
    invokePushCallback,
fxy060608's avatar
fxy060608 已提交
881
};
fxy060608's avatar
fxy060608 已提交
882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897
function initUni(api, protocols) {
    const wrapper = initWrapper(protocols);
    const UniProxyHandlers = {
        get(target, key) {
            if (hasOwn(target, key)) {
                return target[key];
            }
            if (hasOwn(api, key)) {
                return promisify(key, api[key]);
            }
            if (hasOwn(baseApis, key)) {
                return promisify(key, baseApis[key]);
            }
            // event-api
            // provider-api?
            return promisify(key, wrapper(key, swan[key]));
898
        },
fxy060608's avatar
fxy060608 已提交
899 900
    };
    return new Proxy({}, UniProxyHandlers);
fxy060608's avatar
fxy060608 已提交
901 902
}

fxy060608's avatar
fxy060608 已提交
903
function initGetProvider(providers) {
904
    return function getProvider({ service, success, fail, complete, }) {
fxy060608's avatar
fxy060608 已提交
905 906 907 908 909
        let res;
        if (providers[service]) {
            res = {
                errMsg: 'getProvider:ok',
                service,
910
                provider: providers[service],
fxy060608's avatar
fxy060608 已提交
911 912 913 914 915
            };
            isFunction(success) && success(res);
        }
        else {
            res = {
916
                errMsg: 'getProvider:fail:服务[' + service + ']不存在',
fxy060608's avatar
fxy060608 已提交
917 918 919 920 921
            };
            isFunction(fail) && fail(res);
        }
        isFunction(complete) && complete(res);
    };
fxy060608's avatar
fxy060608 已提交
922 923
}

fxy060608's avatar
fxy060608 已提交
924 925 926 927 928 929 930 931 932 933 934 935
function addSafeAreaInsets(fromRes, toRes) {
    if (fromRes.safeArea) {
        const safeArea = fromRes.safeArea;
        toRes.safeAreaInsets = {
            top: safeArea.top,
            left: safeArea.left,
            right: fromRes.windowWidth - safeArea.right,
            bottom: fromRes.windowHeight - safeArea.bottom,
        };
    }
}

Q
qiang 已提交
936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951
const UUID_KEY = '__DC_STAT_UUID';
let deviceId;
function useDeviceId(global = swan) {
    return function addDeviceId(_, toRes) {
        deviceId = deviceId || global.getStorageSync(UUID_KEY);
        if (!deviceId) {
            deviceId = Date.now() + '' + Math.floor(Math.random() * 1e7);
            swan.setStorage({
                key: UUID_KEY,
                data: deviceId,
            });
        }
        toRes.deviceId = deviceId;
    };
}

fxy060608's avatar
fxy060608 已提交
952
const getSystemInfo = {
Q
qiang 已提交
953 954 955 956
    returnValue: (fromRes, toRes) => {
        addSafeAreaInsets(fromRes, toRes);
        useDeviceId()(fromRes, toRes);
    },
fxy060608's avatar
fxy060608 已提交
957 958 959 960 961 962
};

const getSystemInfoSync = getSystemInfo;

const redirectTo = {};

fxy060608's avatar
fxy060608 已提交
963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991
const previewImage = {
    args(fromArgs, toArgs) {
        let currentIndex = parseInt(fromArgs.current);
        if (isNaN(currentIndex)) {
            return;
        }
        const urls = fromArgs.urls;
        if (!isArray(urls)) {
            return;
        }
        const len = urls.length;
        if (!len) {
            return;
        }
        if (currentIndex < 0) {
            currentIndex = 0;
        }
        else if (currentIndex >= len) {
            currentIndex = len - 1;
        }
        if (currentIndex > 0) {
            toArgs.current = urls[currentIndex];
            toArgs.urls = urls.filter((item, index) => index < currentIndex ? item !== urls[currentIndex] : true);
        }
        else {
            toArgs.current = urls[0];
        }
        return {
            indicator: false,
992
            loop: false,
fxy060608's avatar
fxy060608 已提交
993
        };
994
    },
fxy060608's avatar
fxy060608 已提交
995
};
fxy060608's avatar
fxy060608 已提交
996

fxy060608's avatar
fxy060608 已提交
997 998 999 1000
const getProvider = initGetProvider({
    oauth: ['baidu'],
    share: ['baidu'],
    payment: ['baidu'],
1001
    push: ['baidu'],
fxy060608's avatar
fxy060608 已提交
1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015
});
function requestPayment(params) {
    let parseError = false;
    if (typeof params.orderInfo === 'string') {
        try {
            params.orderInfo = JSON.parse(params.orderInfo);
        }
        catch (e) {
            parseError = true;
        }
    }
    if (parseError) {
        params.fail &&
            params.fail({
1016
                errMsg: 'requestPayment:fail: 参数 orderInfo 数据结构不正确,参考:https://uniapp.dcloud.io/api/plugins/payment?id=orderinfo',
fxy060608's avatar
fxy060608 已提交
1017 1018 1019 1020 1021
            });
    }
    else {
        swan.requestPolymerPayment(params);
    }
fxy060608's avatar
fxy060608 已提交
1022 1023
}

fxy060608's avatar
fxy060608 已提交
1024
var shims = /*#__PURE__*/Object.freeze({
fxy060608's avatar
fxy060608 已提交
1025 1026 1027
  __proto__: null,
  getProvider: getProvider,
  requestPayment: requestPayment
fxy060608's avatar
fxy060608 已提交
1028
});
fxy060608's avatar
fxy060608 已提交
1029

fxy060608's avatar
fxy060608 已提交
1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044
function createTodoMethod(contextName, methodName) {
    return function unsupported() {
        console.error(`百度小程序 ${contextName}暂不支持${methodName}`);
    };
}
const request = {
    args() {
        // TODO
        // data 不支持 ArrayBuffer
        // method 不支持 TRACE, CONNECT
        return {
            method: 'method',
            dataType(type) {
                return {
                    name: 'dataType',
1045
                    value: type === 'json' ? type : 'string',
fxy060608's avatar
fxy060608 已提交
1046
                };
1047
            },
fxy060608's avatar
fxy060608 已提交
1048
        };
1049
    },
fxy060608's avatar
fxy060608 已提交
1050 1051 1052
};
const connectSocket = {
    args: {
1053 1054
        method: false,
    },
fxy060608's avatar
fxy060608 已提交
1055 1056 1057 1058
};
const getRecorderManager = {
    returnValue(fromRes, toRes) {
        toRes.onFrameRecorded = createTodoMethod('RecorderManager', 'onFrameRecorded');
1059
    },
fxy060608's avatar
fxy060608 已提交
1060 1061 1062 1063 1064
};
const getBackgroundAudioManager = {
    returnValue(fromRes, toRes) {
        toRes.onPrev = createTodoMethod('BackgroundAudioManager', 'onPrev');
        toRes.onNext = createTodoMethod('BackgroundAudioManager', 'onNext');
1065
    },
fxy060608's avatar
fxy060608 已提交
1066 1067 1068 1069
};
const scanCode = {
    args: {
        onlyFromCamera: false,
1070 1071
        scanType: false,
    },
fxy060608's avatar
fxy060608 已提交
1072 1073 1074 1075 1076
};
const navigateToMiniProgram = {
    name: 'navigateToSmartProgram',
    args: {
        appId: 'appKey',
1077 1078
        envVersion: false,
    },
fxy060608's avatar
fxy060608 已提交
1079 1080
};
const navigateBackMiniProgram = {
1081
    name: 'navigateBackSmartProgram',
fxy060608's avatar
fxy060608 已提交
1082 1083
};
const showShareMenu = {
1084
    name: 'openShare',
fxy060608's avatar
fxy060608 已提交
1085 1086 1087 1088 1089
};
const getAccountInfoSync = {
    name: 'getEnvInfoSync',
    returnValue(fromRes, toRes) {
        toRes.miniProgram = {
1090
            appId: fromRes.appKey,
fxy060608's avatar
fxy060608 已提交
1091 1092 1093
        };
        toRes.plugin = {
            appId: '',
1094
            version: fromRes.sdkVersion,
fxy060608's avatar
fxy060608 已提交
1095
        };
1096
    },
fxy060608's avatar
fxy060608 已提交
1097
};
fxy060608's avatar
fxy060608 已提交
1098

fxy060608's avatar
fxy060608 已提交
1099
var protocols = /*#__PURE__*/Object.freeze({
fxy060608's avatar
fxy060608 已提交
1100 1101 1102 1103 1104 1105 1106 1107 1108 1109 1110 1111 1112 1113 1114
  __proto__: null,
  request: request,
  connectSocket: connectSocket,
  getRecorderManager: getRecorderManager,
  getBackgroundAudioManager: getBackgroundAudioManager,
  scanCode: scanCode,
  navigateToMiniProgram: navigateToMiniProgram,
  navigateBackMiniProgram: navigateBackMiniProgram,
  showShareMenu: showShareMenu,
  getAccountInfoSync: getAccountInfoSync,
  redirectTo: redirectTo,
  navigateTo: navigateTo,
  previewImage: previewImage,
  getSystemInfo: getSystemInfo,
  getSystemInfoSync: getSystemInfoSync
fxy060608's avatar
fxy060608 已提交
1115
});
fxy060608's avatar
fxy060608 已提交
1116

fxy060608's avatar
fxy060608 已提交
1117
var index = initUni(shims, protocols);
fxy060608's avatar
fxy060608 已提交
1118

fxy060608's avatar
fxy060608 已提交
1119
export { index as default };