the-guard-bot/handlers/middlewares/removeLinks.js

'use strict';

// Utils
const { loadJSON } = require('../../utils/json');
const { link } = require('../../utils/tg');
const { logError } = require('../../utils/log');

// Config
const {
	excludedChannels,
	excludedGroups,
	numberOfWarnsToBan
} = loadJSON('config.json');

// Bot
const bot = require('../../bot');
const { replyOptions } = require('../../bot/options');

// DB
const { warn } = require('../../stores/warn');
const { ban } = require('../../stores/ban');
const { isAdmin } = require('../../stores/admin');
const { listGroups } = require('../../stores/group');

const removeLinks = async ({ message, chat, reply }, next) => {
	const groups = await listGroups();
	const groupLinks = [
		...groups.map(group => group.link
			? group.link.split('/joinchat/')[1]
			: ''),
		...excludedGroups
	];
	if (
		message.forward_from_chat &&
		message.forward_from_chat.type !== 'private' &&
		!excludedChannels.includes(message.forward_from_chat.username) ||
		message.text &&
		(message.text.includes('t.me') ||
			message.text.includes('telegram.me')) &&
		!(excludedChannels.includes(message.text) ||
			groupLinks.includes(message.text.split('/joinchat/')[1]))
	) {
		const userToWarn = message.from;
		if (await isAdmin(userToWarn)) {
			return next();
		}
		const reason = 'Channel forward/link';
		const warnCount = await warn(userToWarn, reason);
		const promises = [
			bot.telegram.deleteMessage(chat.id, message.message_id)
		];
		if (warnCount < numberOfWarnsToBan) {
			promises.push(reply(
				`⚠️ ${link(userToWarn)} <b>got warned!</b> (${warnCount}/3)` +
				`\n\nReason: ${reason}`,
				replyOptions));
		} else {
			promises.push(bot.telegram.kickChatMember(chat.id, userToWarn.id));
			promises.push(ban(userToWarn,
				'Reached max number of warnings'));
			promises.push(reply(
				`🚫 ${link(userToWarn)} <b>got banned</b>! (${warnCount}/3)` +
				'\n\nReason: Reached max number of warnings',
				replyOptions));
		}
		try {
			await Promise.all(promises).catch(logError(process.env.DEBUG));
		} catch (err) {
			logError(process.env.DEBUG)(err);
		}
		return next();
	}
	return next();
};

module.exports = removeLinks;