提交 32a84553 编写于 作者: fxy060608's avatar fxy060608

fix(push): add enabled event

上级 bb602168
{"version":3,"sources":["/Users/fxy/Documents/projects/GitHub/uni-app/uni-app-next/packages/playground/uts/nativeplugins/test-uniplugin/android/src/io/dcloud/uniplugin/TestModule.uts"],"names":["TestModule","UniModule","TAG","UniJSMethod","uiThread","testAsyncFunc","options","callback","log","data","JSONObject","invoke","testSyncFunc","onActivityResult","requestCode","resultCode","REQUEST_CODE","hasExtra","getStringExtra"],"mappings":"AAAA;AAAA,OAAmB,sBAAwB,CAAC;AAC5C,OAAuB,+BAAiC,CAAC;AACzD,OAAsB,yCAA2C,CAAC;AAClE,OAAwB,+CAAiD,CAAC;AAC1E,OAA0B,6CAA+C,CAAC;AAC1E,OAAgB,2BAAO,CAAC;AACT,WAAMA,UAAU,GAASC,SAAS,EAAE;IACjDC,SAAAA,GAAG,GAAG,YAAY,CAAC;IAGnB,CAACC,WAAW,CAAC,CAAEC,QAAQ,GAAE,IAAI,CAAE,CAAC;IAAA,SAChCC,aAAa,CAACC,OAAmB,EAAV,UAAU,EAAEC,QAAwB,EAAb,aAAa,CAAA,EAAE;QAC3DC,GAAG,CAAC,IAAI,CAACN,GAAG,EAAE,yBAAyB,CAAC,CAAC;QACzC,IAAIK,QAAQ,IAAI,IAAI,EAAE;YACpB,IAAME,IAAI,GAAG,AAAIC,UAAU,EAAE,AAAC;YAC9BD,IAAI,CAAC,MAAM,CAAC,GAAG,cAAc,CAAC;YAC9BF,QAAQ,CAACI,MAAM,CAACF,IAAI,CAAC,CAAC;;;IAI1B,CAACN,WAAW,CAAC,CAAEC,QAAQ,GAAE,KAAK,CAAE,CAAC;IAAA,SACjCQ,YAAY,CAACN,OAAmB,EAAV,UAAU,GAAG,UAAU,CAAC;QAC5C,IAAMG,IAAI,GAAG,AAAIC,UAAU,EAAE,AAAC;QAC9BD,IAAI,CAAC,MAAM,CAAC,GAAG,YAAY,CAAC;QAC5B,OAAOA,IAAI,CAAC;;IAEd,aAASI,gBAAgB,CAACC,WAAgB,EAAH,GAAG,EAAEC,UAAe,EAAH,GAAG,EAAEN,IAAY,EAAN,MAAM,EAAE;QACzE,IAAIK,WAAW,IAAId,UAAU,CAACgB,YAAY,IAAIP,IAAI,CAACQ,QAAQ,CAAC,SAAS,CAAC,EAAE;YACtET,GAAG,CAAC,IAAI,CAACN,GAAG,EAAE,wBAAY,GAAGO,IAAI,CAACS,cAAc,CAAC,SAAS,CAAC,CAAC,CAAC;;QAC9D,MAAM;YACL,KAAK,CAACL,gBAAgB,CAACC,WAAW,EAAEC,UAAU,EAAEN,IAAI,CAAC,CAAC;;;;QAtB1D,IAAOO,YAAY,GAAG,IAAI,CAAC;;CAyB5B"}
\ No newline at end of file
{"version":3,"sources":["/Users/fxy/Documents/projects/GitHub/uni-app/uni-app-next/packages/playground/uts/nativeplugins/test-uniplugin/android/src/io/dcloud/uniplugin/log.uts"],"names":["log","tag","msg","Log","e"],"mappings":"AAAA;AAAA,OAAgB,gBAAkB,CAAC;AACpB,IAASA,GAAG,CAACC,GAAW,EAAN,MAAM,EAAEC,GAAW,EAAN,MAAM,EAAE;IACpDC,GAAG,GAAEC,CAAC,CAACH,GAAG,EAAEC,GAAG,CAAC,CAAC"}
\ No newline at end of file
{"version":3,"sources":["/Users/fxy/Documents/projects/GitHub/uni-app/uni-app-next/packages/playground/uts/nativeplugins/test-uniplugin/android/src/test.uts"],"names":["log","tag","msg","Log","e"],"mappings":"AAAA;AAAA,OAAgB,gBAAkB,CAAC;AACpB,IAASA,GAAG,CAACC,GAAW,EAAN,MAAM,EAAEC,GAAW,EAAN,MAAM,EAAE;IACpDC,GAAG,CAACC,CAAC,CAACH,GAAG,EAAEC,GAAG,CAAC,CAAC"}
\ No newline at end of file
import { defineAsyncApi } from '../../helpers/api'
interface OnPushCidCallback {
interface OnPushEnabledCallback {
type: 'enabled'
}
interface OnPushClientIdCallback {
type: 'clientId'
cid: string
errMsg?: string
......@@ -23,6 +27,8 @@ interface OnPushClickCallback {
let cid: string | undefined
let cidErrMsg: string | undefined
let enabled: boolean | undefined
function normalizePushMessage(message: unknown) {
try {
return JSON.parse(message as string) as Record<string, any>
......@@ -35,12 +41,15 @@ function normalizePushMessage(message: unknown) {
*/
export function invokePushCallback(
args:
| OnPushCidCallback
| OnPushEnabledCallback
| OnPushClientIdCallback
| OnPushLineStateCallback
| OnPushMsgCallback
| OnPushClickCallback
) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true
} else if (args.type === 'clientId') {
cid = args.cid
cidErrMsg = args.errMsg
invokeGetPushCidCallbacks(cid, args.errMsg)
......@@ -74,16 +83,23 @@ const API_GET_PUSH_CLIENT_ID = 'getPushClientId'
export const getPushClientId = defineAsyncApi(
API_GET_PUSH_CLIENT_ID,
(_, { resolve, reject }) => {
getPushCidCallbacks.push((cid?: string, errMsg?: string) => {
if (cid) {
resolve({ cid })
} else {
reject(errMsg)
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false
cid = ''
cidErrMsg = 'unipush is not enabled'
}
getPushCidCallbacks.push((cid?: string, errMsg?: string) => {
if (cid) {
resolve({ cid })
} else {
reject(errMsg)
}
})
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg)
}
})
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg))
}
}
)
......
......@@ -11074,6 +11074,7 @@ const getLaunchOptionsSync = defineSyncApi(API_GET_LAUNCH_OPTIONS_SYNC, () => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -11086,7 +11087,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -11117,17 +11121,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......@@ -16428,7 +16439,7 @@ const providers = {
services.forEach(({ id }) => {
provider.push(id);
});
callback(null, provider);
callback(null, provider, services);
}, (err) => {
err = err;
callback(err);
......@@ -16441,7 +16452,7 @@ const providers = {
services.forEach(({ id }) => {
provider.push(id);
});
callback(null, provider);
callback(null, provider, services);
}, (err) => {
callback(err);
});
......@@ -16452,14 +16463,15 @@ const providers = {
services.forEach(({ id }) => {
provider.push(id);
});
callback(null, provider);
callback(null, provider, services);
}, (err) => {
callback(err);
});
},
push(callback) {
if (typeof weex !== 'undefined' || typeof plus !== 'undefined') {
callback(null, [plus.push.getClientInfo().id]);
const clientInfo = plus.push.getClientInfo();
callback(null, [clientInfo.id], [clientInfo]);
}
else {
callback(null, []);
......@@ -16468,14 +16480,29 @@ const providers = {
};
const getProvider = defineAsyncApi(API_GET_PROVIDER, ({ service }, { resolve, reject }) => {
if (providers[service]) {
providers[service]((err, provider) => {
providers[service]((err, provider = [], providers = []) => {
if (err) {
reject(err.message);
}
else {
resolve({
service,
// 5+ PlusShareShareService['id'] 类型错误
provider: provider,
providers: providers.map((provider) => {
const returnProvider = {};
if (isPlainObject(provider)) {
for (const key in provider) {
if (Object.hasOwnProperty.call(provider, key)) {
const item = provider[key];
if (!isFunction(item) && typeof item !== 'undefined') {
returnProvider[key] = item;
}
}
}
}
return returnProvider;
}),
});
}
});
......
......@@ -4584,6 +4584,7 @@ const getLaunchOptionsSync = /* @__PURE__ */ defineSyncApi(API_GET_LAUNCH_OPTION
});
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -4592,7 +4593,9 @@ function normalizePushMessage(message) {
return message;
}
function invokePushCallback(args) {
if (args.type === "clientId") {
if (args.type === "enabled") {
enabled = true;
} else if (args.type === "clientId") {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -4621,16 +4624,23 @@ function invokeGetPushCidCallbacks(cid2, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = "getPushClientId";
const getPushClientId = /* @__PURE__ */ defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid2, errMsg) => {
if (cid2) {
resolve({ cid: cid2 });
} else {
reject(errMsg);
Promise.resolve().then(() => {
if (typeof enabled === "undefined") {
enabled = false;
cid = "";
cidErrMsg = "unipush is not enabled";
}
getPushCidCallbacks.push((cid2, errMsg) => {
if (cid2) {
resolve({ cid: cid2 });
} else {
reject(errMsg);
}
});
if (typeof cid !== "undefined") {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== "undefined") {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
const onPushMessage = (fn) => {
......
......@@ -649,6 +649,7 @@ const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -661,7 +662,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -692,17 +696,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
else {
reject(errMsg);
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......
......@@ -649,6 +649,7 @@ const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -661,7 +662,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -692,17 +696,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
else {
reject(errMsg);
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......
......@@ -649,6 +649,7 @@ const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -661,7 +662,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -692,17 +696,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
else {
reject(errMsg);
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......
......@@ -649,6 +649,7 @@ const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -661,7 +662,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -692,17 +696,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
else {
reject(errMsg);
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......
......@@ -649,6 +649,7 @@ const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -661,7 +662,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -692,17 +696,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
else {
reject(errMsg);
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......
......@@ -649,6 +649,7 @@ const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -661,7 +662,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -692,17 +696,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
else {
reject(errMsg);
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......
......@@ -613,6 +613,7 @@ const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -625,7 +626,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -656,17 +660,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
else {
reject(errMsg);
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......
......@@ -103,6 +103,10 @@ var GtPush = /*@__PURE__*/getDefaultExportFromCjs(gtpushMin);
// if (process.env.UNI_PUSH_DEBUG) {
// GtPush.setDebugMode(true)
// }
// @ts-expect-error
uni.invokePushCallback({
type: 'enabled',
});
const appid = process.env.UNI_APP_ID;
if (!appid) {
Promise.resolve().then(() => {
......
// @ts-expect-error
uni.invokePushCallback({
type: 'enabled',
});
Promise.resolve().then(() => {
plus.push.setAutoNotification && plus.push.setAutoNotification(false);
const info = plus.push.getClientInfo();
......
......@@ -45,7 +45,7 @@ var index = () => [
}
if (isEnable) {
return {
code: code + `;import '@dcloudio/uni-push';`,
code: `import '@dcloudio/uni-push';` + code,
map: null,
};
}
......
......@@ -4,6 +4,11 @@ import GtPush from '../lib/gtpush-min'
// GtPush.setDebugMode(true)
// }
// @ts-expect-error
uni.invokePushCallback({
type: 'enabled',
})
const appid = process.env.UNI_APP_ID!
if (!appid) {
Promise.resolve().then(() => {
......
......@@ -50,7 +50,7 @@ export default () => [
}
if (isEnable) {
return {
code: code + `;import '@dcloudio/uni-push';`,
code: `import '@dcloudio/uni-push';` + code,
map: null,
}
}
......
// @ts-expect-error
uni.invokePushCallback({
type: 'enabled',
})
Promise.resolve().then(() => {
plus.push.setAutoNotification && plus.push.setAutoNotification(false)
const info = plus.push.getClientInfo()
......
......@@ -649,6 +649,7 @@ const $emit = defineSyncApi(API_EMIT, (name, ...args) => {
let cid;
let cidErrMsg;
let enabled;
function normalizePushMessage(message) {
try {
return JSON.parse(message);
......@@ -661,7 +662,10 @@ function normalizePushMessage(message) {
* @param args
*/
function invokePushCallback(args) {
if (args.type === 'clientId') {
if (args.type === 'enabled') {
enabled = true;
}
else if (args.type === 'clientId') {
cid = args.cid;
cidErrMsg = args.errMsg;
invokeGetPushCidCallbacks(cid, args.errMsg);
......@@ -692,17 +696,24 @@ function invokeGetPushCidCallbacks(cid, errMsg) {
}
const API_GET_PUSH_CLIENT_ID = 'getPushClientId';
const getPushClientId = defineAsyncApi(API_GET_PUSH_CLIENT_ID, (_, { resolve, reject }) => {
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
Promise.resolve().then(() => {
if (typeof enabled === 'undefined') {
enabled = false;
cid = '';
cidErrMsg = 'unipush is not enabled';
}
else {
reject(errMsg);
getPushCidCallbacks.push((cid, errMsg) => {
if (cid) {
resolve({ cid });
}
else {
reject(errMsg);
}
});
if (typeof cid !== 'undefined') {
invokeGetPushCidCallbacks(cid, cidErrMsg);
}
});
if (typeof cid !== 'undefined') {
Promise.resolve().then(() => invokeGetPushCidCallbacks(cid, cidErrMsg));
}
});
const onPushMessageCallbacks = [];
// 不使用 defineOnApi 实现,是因为 defineOnApi 依赖 UniServiceJSBridge ,该对象目前在小程序上未提供,故简单实现
......
......@@ -10,7 +10,7 @@ runBuild(UtsTarget.KOTLIN, {
},
output: {
dir: path.resolve(projectDir, 'unpackage/nativeplugins/test-uniplugin'),
sourceMap: true,
sourceMap: false,
inlineSourcesContent: false,
},
})
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册