app.js

'use strict';

if (process.env.DEBUG === '1')
{
	// eslint-disable-next-line node/no-unsupported-features/node-builtins, global-require
	require('inspector').open(9223, '0.0.0.0', true);
}

const Homey = require('homey');
const YoLinkAPI = require('./yoLinkAPI');
const nodemailer = require('./nodemailer');

module.exports = class YoLink extends Homey.App
{

	/**
	 * onInit is called when the app is initialized.
	 */
	async onInit()
	{
		this.yoLinkAPI = new YoLinkAPI(this);
		this.homeyID = await this.homey.cloud.getHomeyId();
		this.diagLog = this.diagLog || '';

		if (process.env.DEBUG === '1')
		{
			this.homey.settings.set('debugMode', true);
		}
		else
		{
			this.homey.settings.set('debugMode', false);
		}

		this._triggerButtonPressed = this.homey.flow.getDeviceTriggerCard('button_pressed');
		this._triggerButtonLongPressed = this.homey.flow.getDeviceTriggerCard('button_long_pressed');
		this.measure_water_depth_changedTrigger = this.homey.flow.getDeviceTriggerCard('measure_water_depth_changed');
		this.measure_flushes_changedTrigger = this.homey.flow.getDeviceTriggerCard('measure_flushes_changed');
		this.updateLog('YoLink app has been initialized');
	}

	getSymData()
	{
		if (process.env.DEBUG === '1')
		{
			return this.homey.settings.get('simData');
		}
		return null;
	}

	// Convert a variable of any type (almost) to a string
	varToString(source)
	{
		try
		{
			if (source === null)
			{
				return 'null';
			}
			if (source === undefined)
			{
				return 'undefined';
			}
			if (source instanceof Error)
			{
				const stack = typeof source.stack === 'string' ? source.stack.replace(/\\n/g, '\n') : '';
				return `${source.message}\n${stack}`;
			}
			if (typeof (source) === 'object')
			{
				const getCircularReplacer = () =>
				{
					const seen = new WeakSet();
					return (key, value) =>
					{
						if (typeof value === 'object' && value !== null)
						{
							if (seen.has(value))
							{
								return '';
							}
							seen.add(value);
						}
						return value;
					};
				};

				return JSON.stringify(source, getCircularReplacer(), 2);
			}
			if (typeof (source) === 'string')
			{
				return source;
			}
		}
		catch (err)
		{
			this.updateLog(`VarToString Error: ${err.message}`);
		}

		return String(source);
	}

	// Add a message to the debug log if not running in the cloud
	updateLog(newMessage, errorLevel = 1)
	{
		if ((errorLevel === 0) || this.homey.settings.get('logEnabled'))
		{
			if (errorLevel === 0)
			{
				this.error(newMessage);
			}
			else
			{
				this.log(newMessage);
			}

			try
			{
				const nowTime = new Date(Date.now());
				if (typeof this.diagLog !== 'string')
				{
					this.diagLog = '';
				}

				this.diagLog += '\r\n* ';
				this.diagLog += nowTime.toJSON();
				this.diagLog += '\r\n';

				this.diagLog += newMessage;
				this.diagLog += '\r\n';
				if (this.diagLog.length > 60000)
				{
					this.diagLog = this.diagLog.substr(this.diagLog.length - 60000);
				}

				if (!this.cloudOnly)
				{
					this.homey.api.realtime('com.yolink.logupdated', { log: this.diagLog });
				}
			}
			catch (err)
			{
				this.log(err);
			}
		}
	}

	getLog()
	{
		return this.diagLog;
	}

	clearLog()
	{
		this.diagLog = '';
		this.homey.api.realtime('com.yolink.logupdated', { log: this.diagLog });
	}

	// Send the log to the developer (not applicable to Homey cloud)
	async sendLog({ email = '', description = '', log = '' })
	{
		let tries = 5;
		let error = null;
		while (tries-- > 0)
		{
			try
			{
				// create reusable transporter object using the default SMTP transport
				const transporter = nodemailer.createTransport(
					{
						host: Homey.env.MAIL_HOST, // Homey.env.MAIL_HOST,
						port: 465,
						ignoreTLS: false,
						secure: true, // true for 465, false for other ports
						auth:
						{
							user: Homey.env.MAIL_USER, // generated ethereal user
							pass: Homey.env.MAIL_SECRET, // generated ethereal password
						},
						tls:
						{
							// do not fail on invalid certs
							rejectUnauthorized: false,
						},
					},
				);

				// send mail with defined transport object
				const info = await transporter.sendMail(
					{
						from: `"Homey User" <${Homey.env.MAIL_USER}>`, // sender address
						to: Homey.env.MAIL_RECIPIENT, // list of receivers
						cc: email,
						subject: `YoLink log (${Homey.manifest.version})`, // Subject line
						text: `${email}\n${description}\n\n${log}`, // plain text body
					},
				);

				this.updateLog(`Message sent: ${info.messageId}`);
				// Message sent: <b658f8ca-6296-ccf4-8306-87d57a0b4321@example.com>

				// Preview only available when sending through an Ethereal account
				this.log('Preview URL: ', nodemailer.getTestMessageUrl(info));
				return this.homey.__('settings.logSent');
			}
			catch (err)
			{
				this.updateLog(`Send log error: ${err.message}`, 0);
				error = err;
			}
		}

		throw new Error(this.homey.__('settings.logSendFailed') + error.message);
	}

	async getDeviceList()
	{
		let deviceList = [];
		const uaidList = await this.yoLinkAPI.getUAIDList();
		if (uaidList && uaidList.length > 0)
		{
			// get the device list for all UAIDs
			for (const uaid of uaidList)
			{
				// Append the devices to the list
				const newusDevices = await this.yoLinkAPI.getDeviceList(uaid, null, 'us') || [];
				deviceList = deviceList.concat(newusDevices);

				// Get the list for the EU/UK zone as well but don't add duplicates
				const neweuDevices = await this.yoLinkAPI.getDeviceList(uaid, null, 'eu_uk') || [];

				// Filter out duplicates
				for (const neweuDevice of neweuDevices)
				{
					if (!deviceList.find((device) => device.UID === neweuDevice.UID))
					{
						deviceList.push(neweuDevice);
					}
				}
			}
		}
		return this.varToString(deviceList);
	}

	async isYoLinkLoggedIn()
	{
		const uaidList = await this.yoLinkAPI.getUAIDList();
		return Array.isArray(uaidList) && uaidList.length > 0;
	}

	async loginYoLink({ UAID = '', secretKey = '', serviceZone = null } = {})
	{
		const normalizedUAID = typeof UAID === 'string' ? UAID.trim() : '';
		const normalizedSecretKey = typeof secretKey === 'string' ? secretKey.trim() : '';
		const normalizedServiceZone = typeof serviceZone === 'string' && serviceZone.trim() ? serviceZone.trim() : null;

		if (!normalizedUAID || !normalizedSecretKey)
		{
			throw new Error('UAID and Secret Key are required');
		}

		const accessToken = await this.yoLinkAPI.getAccessTokenForUAID(
			normalizedUAID,
			normalizedSecretKey,
			normalizedServiceZone || undefined,
		);
		if (!accessToken)
		{
			throw new Error('Login failed. Please check your UAID and Secret Key.');
		}

		this.homey.settings.set('UAID', normalizedUAID);
		this.homey.settings.set('secretKey', normalizedSecretKey);

		return { loggedIn: true };
	}

};