import axios from 'axios';
import config from 'config';
import debug from 'debug';
var log = debug('hms');

const { client_id, client_secret } = config.has('service.hms') ? config.get('service.hms') : {};

const refreshToken = async () => {
    if (client_id) {
        const params = new URLSearchParams();
        params.append('grant_type', 'client_credentials');
        params.append('client_id', client_id);
        params.append('client_secret', client_secret);
        const res = await axios.post('https://oauth-login.cloud.huawei.com/oauth2/v3/token', params).catch(console.log);
        try {
            log(`HMS response: ${JSON.stringify(res.data)}`);
            const access = res.data;
            log(`HMS access token: ${access.access_token}`);
            return access.access_token;
        } catch (error) {
            log(error);
            return '';
        }
    }
    return '';
};

export const send = async (msg, tokenList = []) => {
    const adminToken = await refreshToken();
    if (adminToken) {
        const response = await axios.post(`https://push-api.cloud.huawei.com/v1/${client_id}/messages:send`, {
            headers: {
                'Authorization': adminToken,
                'Content-Type': 'application/json'
            },
            body: {
                'validate_only': false,
                'message': {
                    'android': {
                        'fast_app_target': 2
                    },
                    'data': {
                        'pushtype': 1,
                        'pushbody': {
                            'custom': {
                                'message': msg
                            }
                        }
                    },
                    'priority': 'high',
                    'delayWhileIdle': false,
                    'token': tokenList
                }
            }
        }).catch(log);
        log(`hcm: ${response.status}`);
    }
};