// 开发文档: https://uniapp.dcloud.net.cn/uniCloud/cloud-obj
function uniPush(appId) {
	return uniCloud.getPushManager({appId})
}
const uniID = require('uni-id-common')
module.exports = {
	_before: async function() {
		const clientInfo = this.getClientInfo()
		this.uniID = uniID.createInstance({
			clientInfo
		})
		const token = this.getUniIdToken()
		let payload = await this.uniID.checkToken(token)
		let role = payload.role||[]
		//检查是不是管理员，或者自己的云函数调用此云函数
		if(clientInfo.source != 'server' && !role.includes('admin')){
			return {
				errCode: 'uni-push-co-permission-denied',
				errMsg: '你没有访问此接口权限'
			}
		}
	},
	async sendMessage(data) {
		const appId = data.appId
		data.must_report = true //默认为false，消息接受者为单设备时，不统计推送结果。开启此项将都会统计。但整体推送速度会慢100-500毫秒
		// delete data.appId
		let res = await uniPush(appId).sendMessage(data)
		if (res.errCode == 0 && res.before_id) {
			const UniPushCo = uniCloud.importObject("uni-push-co")
			data.before_id = res.before_id //查询的初始id，用于高性能分页查询
			data.taskid = res.data.taskid || Object.keys(res.data)[0]
			
			UniPushCo.sendMessage(data).catch(e=>{
				// console.log(e.message);
			}) 
			// 等待500毫秒给下一个请求发出去的时间
			return new Promise((resolve, reject) => {
				setTimeout(() => {
					resolve(res)
				}, 500)
			})
		}
		return res
	},
	async getReport({
		appId,
		taskid
	}) {
		let res = await uniPush(appId).getReport({
			taskid
		})
		//获取推送结果
		console.log(JSON.stringify(res));
		return res
	},
	async getAdminUrl(appId) {
		let res = await uniPush(appId).getAdminUrl() //获取推送结果
		console.log(JSON.stringify(res));
		return res
	}
}