index.js

const url = require('url');
const http = require('http');
const dotenv = require('dotenv');
const fetch = require('cross-fetch');
const { parse } = require('querystring');
const { Client, Intents, Permissions } = require('discord.js');
const discord = new Client({ intents: [Intents.FLAGS.GUILDS, Intents.FLAGS.GUILD_MESSAGES] });
dotenv.config();

discord.on('ready', async () => {
	console.log(`Logged in as ${discord.user.tag}!`);
	if (!process.env.DISCORD_USER_ID) process.env.DISCORD_USER_ID = discord.guilds.cache.find(ch => ch.id === process.env.DISCORD_SERVER_ID).ownerId;
});
discord.on('messageCreate', async (message) => {
	if (process.env.DISCORD_USER_ID && message.author.id !== process.env.DISCORD_USER_ID) return;

	if (!message.system && message.type == "DEFAULT" && message.channel.type === "GUILD_PUBLIC_THREAD") {
		let media = Array.from(message.attachments.values());
		if (media.length) media = media.map((m) => m.url);
		let from = normalizePhone(message.channel.parent.topic);
		let to = normalizePhone(message.channel.name);
		sendSms(/signalwire/i.test(message.channel.parent.topic) ? 'signalwire' : 'voipms', from, to, message.content, media);
	}
});

const server = http.createServer(async (req, res) => {
	if (req.method === 'POST' && req.url === '/signalwire') {
		collectRequestData(req, result => {
			console.log(`Message received, ID: ${result.MessageSid}`);
			result.Service = 'SignalWire';
			sendDiscordMsg(result);
			res.end('<?xml version="1.0" encoding="UTF-8"?><Response></Response>');
		});
	} else if (req.method === 'GET' && /^\/voipms/.test(req.url)) {
		let query = url.parse(req.url, true).query;
		console.log(query);
		let msg = {'To': query.to, 'From': query.from};
		let media = [];

		msg.Body = query.message ?? '';
		try {
			const response = await fetch(`https://voip.ms/api/v1/rest.php?api_username=${process.env.VOIPMS_USERNAME}&api_password=${process.env.VOIPMS_API_PASS}&method=getMediaMMS&media_as_array=1&id=${query.id}`);
			const data = await response.json();
			if (data.status === 'success' && data.media) media = data.media;
		} catch (err) {
			sendErrorMsg(`Error fetching MMS for message ID ${query.id}: ${err.message}`);
		}
		for (let i = 0; i < media.length; i++) msg['MediaUrl'+i] = media[i];
		msg.NumMedia = media.length;
		msg.Service = 'VoIP.ms';
		sendDiscordMsg(msg);
	} else {
		console.log(req.url);
		res.end();
	}
});

async function sendErrorMsg(msg) {
	console.error(msg);
	await (await discord.users.fetch(process.env.DISCORD_USER_ID)).send(msg);
}

async function sendDiscordMsg(msg) {
	let server = discord.guilds.cache.find(ch => ch.id === process.env.DISCORD_SERVER_ID);
	if (!server) await sendErrorMsg(`Server ID not found.`);
	let ch_to = server.channels.cache.find(
		ch => ch.type === "GUILD_TEXT" && ch.topic && ch.topic.replace(/\D/g,'') && (new RegExp( ch.topic.replace(/\D/g,'') )).test(normalizePhone(msg.To))
	);
	if (!ch_to) {
		ch_to = await server.channels.create(normalizePhone(msg.To), {
			topic: `${msg.Service} \n ${normalizePhone(msg.To)}`,
			permissionOverwrites: [ // private channel
				{
					id: process.env.DISCORD_USER_ID, // server owner
					allow: [Permissions.FLAGS.VIEW_CHANNEL],
				},
				{
					id: discord.user.id, // bot
					allow: [Permissions.FLAGS.VIEW_CHANNEL],
				},
				{
					id: server.roles.everyone,
					deny: [Permissions.FLAGS.VIEW_CHANNEL],
				}
			 ]
		});
	}
	await ch_to.threads.fetchArchived();

	let ch_from = ch_to.threads.cache.find(
		ch => ch.type === "GUILD_PUBLIC_THREAD" && ch.parentId == ch_to.id && ch.name.replace(/\D/g,'') && (new RegExp( ch.name.replace(/\D/g,'') )).test(normalizePhone(msg.From))
	);
	if (ch_from && ch_from.archived) await ch_from.setArchived(false);

	let media = [];
	if (parseInt(msg.NumMedia) > 0) for (let i = 0; i < parseInt(msg.NumMedia); i++) {
		if (msg['MediaContentType'+i] === 'text/plain') {
			let response = await fetch(msg['MediaUrl'+i]);
			msg.Body = await response.text();
			continue;
		}
		media.push({ attachment: msg['MediaUrl'+i], name: new Date().toISOString().replace(/T/, '_').replace(/:/g, '-').replace(/\..+/, '') + '_' + i +'.jpg' });
	}

	let msg_opts = {};
	if (msg.Body) msg_opts.content = msg.Body;
	if (media.length) msg_opts.files = media;

	if (ch_from) {
		ch_from.send(msg_opts);
	} else {
		console.log(`Creating new thread for ${msg.From}`);
		let thread = await ch_to.threads.create({
			name: msg.From,
			autoArchiveDuration: 1440
		});
		thread.send(`<@${process.env.DISCORD_USER_ID}>`);
		thread.send(msg_opts);
		console.log(`Created thread: ${thread.name}`);
	}
}

async function sendSms(service, from, to, body, media) {
	if (!from || !/\d{10}/.test(from)) return await sendErrorMsg(`Missing 'From' number in channel topic.`);
	if (!to ||!/\d{10}/.test(to)) return await sendErrorMsg(`Missing 'To' number in thread name.`);
	
	let params = new URLSearchParams();
	if (service == 'signalwire') {
		params.append('From', from);
		params.append('To', to);
		
		if (body) params.append('Body', body);
		if (media.length) for (m of media) params.append('MediaUrl', m);

		console.log('SMS params', params);
		
		let response = await fetch(`https://${process.env.SIGNALWIRE_SPACE_URL}/api/laml/2010-04-01/Accounts/${process.env.SIGNALWIRE_PROJECT}/Messages.json`, {
			method: 'POST',
			headers: {
				'Authorization': 'Basic ' + Buffer.from(process.env.SIGNALWIRE_PROJECT + ":" + process.env.SIGNALWIRE_TOKEN).toString('base64')
			},
			body: params
		});
		if (response.ok || response.status === 422) {
			let data = await response.json();
			data.error_code || data.message ? sendErrorMsg(`Sending SMS Error: ${data.error_message || data.message}`) : console.log('Message sent, ID: ', data.sid);
		} else {
			sendErrorMsg(`Sending SMS HTTP Error: ${response.status} ${response.statusText}`);
		}
	} else if (service == 'voipms') {
		params.append('did', from.replace(/^\+1/, ''));
		params.append('dst', to.replace(/^\+1/, ''));
		params.append('message', body ? body : '');
		if (media.length) for (let i = 0; i < media.length; i++) params.append('media'+i, media[i]);
		let response = await fetch(`https://voip.ms/api/v1/rest.php?api_username=${process.env.VOIPMS_USERNAME}&api_password=${process.env.VOIPMS_API_PASS}&method=send${media.length ? 'MMS' : 'SMS'}&`+params.toString());
		if (response.ok) {
			const data = await response.json();
			data.status === 'success' ? console.log('Message sent, ID: ', media.length ? data.mms : data.sms) : sendErrorMsg(`Error sending SMS: ${data.status}`);
		} else {
			sendErrorMsg(`Sending SMS HTTP Error: ${response.status} ${response.statusText}`);
		}
	}
}

function normalizePhone(phone) {
	if (/^\+/.test(phone)) return phone;
	phone = phone.replace(/\D/g,'');
	if (!phone) return false;
	return '+' + (/^1\d{10}/.test(phone) ? phone : '1' + phone);
}

function collectRequestData(request, callback) {
	if (request.headers['content-type'] === 'application/x-www-form-urlencoded') {
		let body = '';
		request.on('data', chunk => {
			body += chunk.toString();
		});
		request.on('end', () => {
			callback(parse(body));
		});
	} else {
		callback(null);
	}
}

discord.login(process.env.DISCORD_TOKEN);
server.listen(process.env.HTTP_PORT);