main.js

'use strict';

/*
 * Created with @iobroker/create-adapter v1.17.0
 */

// The adapter-core module gives you access to the core ioBroker functions
// you need to create an adapter
const utils = require('@iobroker/adapter-core');
const request = require('request');

/**
 * The adapter instance
 * @type {ioBroker.Adapter}
 */
let adapter;


function sendMessageToWhatsApp(message, phoneNumber) {
    return new Promise((resolve, reject) =>  {
        phoneNumber = phoneNumber || adapter.config.defaultPhone;

        if (message) {
            message = encodeURIComponent(message);
            // Detect Emojies after encoding, and reverse encoding for them again
            // Details https://www.callmebot.com/uncategorized/list-of-urlencoded-unicode-emoticons-emojis/
            const emojies = message.match(/%25F0%259F%25[0-9A-Fa-f]{2}%25[0-9A-Fa-f]{2}/g);
            if (emojies && emojies.length) {
                emojies.forEach(em => message = message.replace(em, decodeURIComponent(em)));
            }
            const url = `https://api.callmebot.com/whatsapp.php?phone=${phoneNumber}&text=${message}&apikey=${adapter.config.apikey}&source=iobroker`;
            adapter.log.debug('Call ' + url);
            request(url, (err, resp, body) => {
                adapter.log.debug(body);
                // 201 - wrong parameters
                // 202 - your number is banned
                // 203 - APikey is incorrect
                // 209 - phone number is permanent banned
                // 204 - Too many messages sent (API overflow for the phone number)
                // 205 - Unknown error.
                // 207 - Service is down
                // 208 - Your number is in Pause.
                // 209 - Quota exceeded
                // 210 - Messaged queued to be sent later
                !err && resp && resp.statusCode == 200 && (!body || !body.includes('ERROR')) ? resolve() : reject(err || body || (resp && resp.statusCode));
            })
                .on('error', err => reject(err));
        } else {
            resolve();
        }
    });
}
/**
 * Starts the adapter instance
 * @param {Partial<utils.AdapterOptions>} [options]
 */
function startAdapter(options) {
    // Create the adapter and define its methods
    return adapter = utils.adapter(Object.assign({}, options, {
        name: 'whatsapp-cmb',
        ready: main, // Main method defined below for readability
        stateChange: (id, state) => {
            if (state && !state.ack && state.val && adapter.config.apikey) {
                if (adapter.config.defaultPhone) {
                    // The state was changed
                    adapter.log.debug(`Sending message "${state.val}" to default number "${adapter.config.defaultPhone}"`);
                    sendMessageToWhatsApp(state.val)
                        .then(() => adapter.log.debug(`Successfully sent`))
                        .catch(err => adapter.log.error('Cannot send message: ' + err));
                } else {
                    adapter.log.error('Please set the default phone number.');
                }
            }
        },
        message: (obj) => {
            if (typeof obj === 'object' && obj.message && adapter.config.apikey) {
                if (obj.command === 'send' ) {
                    if (typeof obj.message !== 'object') {
                        obj.message = {
                            text: obj.message
                        };
                    }
                    obj.message.phone = obj.message.phone || adapter.config.defaultPhone;
                    if (!obj.message.phone) {
                        adapter.log.warn('Default phone number is not provided!');
                        return obj.callback && adapter.sendTo(obj.from, obj.command, {result: 'Message sent'}, obj.callback);
                    }

                    // e.g. send email or pushover or whatever
                    adapter.log.info(`Send ${obj.message.text} to ${obj.message.phone}`);

                    sendMessageToWhatsApp(obj.message.text, obj.message.phone)
                        .then(() => {
                            // Send response in callback if required
                            obj.callback && adapter.sendTo(obj.from, obj.command, {result: 'Message sent'}, obj.callback);
                        })
                        .catch(err => {
                            adapter.log.error('Cannot send message: ' + err);
                            obj.callback && adapter.sendTo(obj.from, obj.command, {error: err}, obj.callback);
                        });
                }
            }
        },
    }));
}

function main() {
    if (!adapter.config.apikey) {
        adapter.log.warn('APIKEY is not provided. No messages will be sent');
        return;
    }

    // in this template all states changes inside the adapters namespace are subscribed
    adapter.subscribeStates('sendMessage');
}

// @ts-ignore parent is a valid property on module
if (module.parent) {
    // Export startAdapter in compact mode
    module.exports = startAdapter;
} else {
    // otherwise start the instance directly
    startAdapter();
}