186 lines
7.9 KiB
TypeScript
186 lines
7.9 KiB
TypeScript
import { Composer } from "grammy";
|
|
import type { Context } from "#root/bot/context.js";
|
|
import { logHandle } from "#root/bot/helpers/logging.js";
|
|
import metaLinkCheck from "#root/lib/metaLinkCheck.js";
|
|
import twitterLinkCheck from "#root/lib/twitterLinkCheck.js";
|
|
import urql from "#root/lib/urql.js";
|
|
import increment from "#root/lib/graphql/mutations/incrimentMutation.js";
|
|
import addGroup from "#root/lib/graphql/mutations/addGroupMutation.js";
|
|
import incrementGroup from "#root/lib/graphql/mutations/incrementGroupMutation.js";
|
|
|
|
const composer = new Composer<Context>();
|
|
|
|
const feature = composer.chatType(["group", "supergroup"]);
|
|
|
|
/**
|
|
* What triggers this feature and adds to the log when it has been triggered.
|
|
* The trigger is anytime an embedded url is detected.
|
|
*/
|
|
feature.on("message::url", logHandle("embed-check"), async (ctx: Context) => {
|
|
await urql.mutation(increment, { trigger: true });
|
|
|
|
if (ctx.chat && ctx.msg) {
|
|
const groupName = ctx.chat?.title;
|
|
const groupID = ctx.chat?.id;
|
|
const groupUsername = ctx.chat?.username;
|
|
let deletedLinks = 0;
|
|
|
|
const username = ctx.msg.from?.username;
|
|
|
|
// Filters every message/caption entity that is a url into a new array.
|
|
const embeds = ctx.msg.entities
|
|
? ctx.msg.entities.filter(e => e.type === "text_link")
|
|
: null;
|
|
const captionEmbeds = ctx.msg.caption_entities
|
|
? ctx.msg.caption_entities.filter(e => e.type === "text_link")
|
|
: null;
|
|
|
|
// If the caption embeds array isn't empty filter through them to check if any is a Twitter/X or Meta url.
|
|
if (captionEmbeds !== null && captionEmbeds.length) {
|
|
const metaLinks = captionEmbeds.filter(({ url }) => metaLinkCheck(url));
|
|
const twitterLinks = captionEmbeds.filter(({ url }) =>
|
|
twitterLinkCheck(url)
|
|
);
|
|
|
|
// Handle action and response if both meta and Twitter/X links are detected.
|
|
if (metaLinks.length && twitterLinks.length) {
|
|
// Deletes the offending message.
|
|
ctx.msg.delete();
|
|
deletedLinks++;
|
|
|
|
await urql
|
|
.mutation(increment, { link: true })
|
|
.toPromise()
|
|
.then(async () => {
|
|
if (ctx.msg) {
|
|
// Replies to the user informing them of the action.
|
|
await ctx.reply(
|
|
`@${username} Twitter and X links along with reformatting services for Twitter posts are not allowed here\\. Also Facebook and meta links along with with links to meta\\-owned services are not allowed here\\. Please consider sharing the media directly or from other social media sources or websites\\. No administration action was taken against you other than the message being deleted\\.\n\nIf this was forwarded from a channel consider forwarding without the caption so the media isn't deleted\\.`,
|
|
{ parse_mode: "MarkdownV2" }
|
|
);
|
|
}
|
|
});
|
|
}
|
|
|
|
// Handle action and response if only meta links are detected.
|
|
if (metaLinks.length) {
|
|
// Deletes the offending message.
|
|
ctx.msg.delete();
|
|
deletedLinks++;
|
|
|
|
await urql
|
|
.mutation(increment, { link: true })
|
|
.toPromise()
|
|
.then(async () => {
|
|
if (ctx.msg) {
|
|
// Replies to the user informing them of the action.
|
|
await ctx.reply(
|
|
`@${username} Facebook and meta links along with with links to meta\\-owned services are not allowed here\\. Please consider sharing the media directly or from other social media sources or websites\\. No administration action was taken against you other than the message being deleted\\\n\nIf this was forwarded from a channel consider forwarding without the caption so the media isn't deleted\\.`,
|
|
{ parse_mode: "MarkdownV2" }
|
|
);
|
|
}
|
|
});
|
|
}
|
|
|
|
// Handle action and response if only Twitter/X links are detected.
|
|
if (twitterLinks.length) {
|
|
// Deletes the offending message.
|
|
ctx.msg.delete();
|
|
deletedLinks++;
|
|
|
|
await urql
|
|
.mutation(increment, { link: true })
|
|
.toPromise()
|
|
.then(async () => {
|
|
if (ctx.msg) {
|
|
// Replies to the user informing them of the action.
|
|
await ctx.reply(
|
|
`@${username} Twitter and X links along with reformatting services for Twitter posts are not allowed here\\. Please consider sharing the media directly or from other social media sources or websites\\. No administration action was taken against you other than the message being deleted\\.\n\nIf this was forwarded from a channel consider forwarding without the caption so the media isn't deleted\\.`,
|
|
{ parse_mode: "MarkdownV2" }
|
|
);
|
|
}
|
|
});
|
|
}
|
|
}
|
|
// If the embeds array isn't empty filter through them to check if any is a Twitter/X or Meta url.
|
|
if (embeds !== null && embeds.length) {
|
|
const metaLinks = embeds.filter(({ url }) => metaLinkCheck(url));
|
|
const twitterLinks = embeds.filter(({ url }) => twitterLinkCheck(url));
|
|
|
|
// Handle action and response if both meta and Twitter/X links are detected.
|
|
if (metaLinks.length && twitterLinks.length) {
|
|
// Deletes the offending message.
|
|
ctx.msg.delete();
|
|
deletedLinks++;
|
|
|
|
await urql
|
|
.mutation(increment, { link: true })
|
|
.toPromise()
|
|
.then(async () => {
|
|
if (ctx.msg) {
|
|
// Replies to the user informing them of the action.
|
|
await ctx.reply(
|
|
`@${username} Twitter and X links along with reformatting services for Twitter posts are not allowed here\\. Also Facebook and meta links along with with links to meta\\-owned services are not allowed here\\. Please consider sharing the media directly or from other social media sources or websites\\. No administration action was taken against you other than the message being deleted\\.`,
|
|
{ parse_mode: "MarkdownV2" }
|
|
);
|
|
}
|
|
});
|
|
}
|
|
|
|
// Handle action and response if only meta links are detected.
|
|
if (metaLinks.length) {
|
|
// Deletes the offending message.
|
|
ctx.msg.delete();
|
|
deletedLinks++;
|
|
|
|
await urql
|
|
.mutation(increment, { link: true })
|
|
.toPromise()
|
|
.then(async () => {
|
|
if (ctx.msg) {
|
|
// Replies to the user informing them of the action.
|
|
await ctx.reply(
|
|
`@${username} Facebook and meta links along with with links to meta\\-owned services are not allowed here\\. Please consider sharing the media directly or from other social media sources or websites\\. No administration action was taken against you other than the message being deleted\\.`,
|
|
{ parse_mode: "MarkdownV2" }
|
|
);
|
|
}
|
|
});
|
|
}
|
|
|
|
// Handle action and response if only Twitter/X links are detected.
|
|
if (twitterLinks.length) {
|
|
// Deletes the offending message.
|
|
ctx.msg.delete();
|
|
deletedLinks++;
|
|
|
|
await urql
|
|
.mutation(increment, { link: true })
|
|
.toPromise()
|
|
.then(async () => {
|
|
if (ctx.msg) {
|
|
// Replies to the user informing them of the action.
|
|
await ctx.reply(
|
|
`@${username} Twitter and X links along with reformatting services for Twitter posts are not allowed here\\. Please consider sharing the media directly or from other social media sources or websites\\. No administration action was taken against you other than the message being deleted\\.`,
|
|
{ parse_mode: "MarkdownV2" }
|
|
);
|
|
}
|
|
});
|
|
}
|
|
|
|
if (deletedLinks) {
|
|
return await urql
|
|
.mutation(addGroup, { groupID, groupName, groupUsername })
|
|
.toPromise()
|
|
.then(() =>
|
|
urql.mutation(incrementGroup, {
|
|
groupID,
|
|
linksDeleted: deletedLinks
|
|
})
|
|
);
|
|
}
|
|
}
|
|
}
|
|
});
|
|
|
|
export { composer as embedCheck };
|