generated from nhcarrigan/template
Compare commits
No commits in common. "c05a33e8d2e98180b579b80678fc47ea12c1c9e9" and "7db3201aefc1dc8675de4e8ca590b0b8eb7c41b4" have entirely different histories.
c05a33e8d2
...
7db3201aef
@ -1,12 +0,0 @@
|
|||||||
{
|
|
||||||
"extends": "@nhcarrigan",
|
|
||||||
"overrides": [
|
|
||||||
{
|
|
||||||
"files": ["src/modules/buttons/*.ts"],
|
|
||||||
"rules": {
|
|
||||||
"jsdoc/require-param": "off",
|
|
||||||
"jsdoc/require-returns": "off"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
]
|
|
||||||
}
|
|
||||||
5
.gitignore
vendored
5
.gitignore
vendored
@ -1,5 +0,0 @@
|
|||||||
/node_modules/
|
|
||||||
/prod/
|
|
||||||
.env
|
|
||||||
/logs/*.txt
|
|
||||||
latestAirtableRecord.txt
|
|
||||||
@ -1 +0,0 @@
|
|||||||
"@nhcarrigan/prettier-config"
|
|
||||||
18
README.md
18
README.md
@ -1,10 +1,20 @@
|
|||||||
# Art for Palestine Bot
|
# New Repository Template
|
||||||
|
|
||||||
This is a bot for the [Art for Palestine](https://art4palestine.org) charity event. It serves as a bridge between AirTable, Trello, and Discord.
|
This template contains all of our basic files for a new GitHub repository. There is also a handy workflow that will create an issue on a new repository made from this template, with a checklist for the steps we usually take in setting up a new repository.
|
||||||
|
|
||||||
|
If you're starting a Node.JS project with TypeScript, we have a [specific template](https://github.com/naomi-lgbt/nodejs-typescript-template) for that purpose.
|
||||||
|
|
||||||
|
## Readme
|
||||||
|
|
||||||
|
Delete all of the above text (including this line), and uncomment the below text to use our standard readme template.
|
||||||
|
|
||||||
|
<!-- # Project Name
|
||||||
|
|
||||||
|
Project Description
|
||||||
|
|
||||||
## Live Version
|
## Live Version
|
||||||
|
|
||||||
This page is currently deployed. [View the live website.](https://discord.gg/kHNyb6Vyf8)
|
This page is currently deployed. [View the live website.]
|
||||||
|
|
||||||
## Feedback and Bugs
|
## Feedback and Bugs
|
||||||
|
|
||||||
@ -26,4 +36,4 @@ Copyright held by Naomi Carrigan.
|
|||||||
|
|
||||||
## Contact
|
## Contact
|
||||||
|
|
||||||
We may be contacted through our [Chat Server](http://chat.nhcarrigan.com) or via email at `contact@nhcarrigan.com`.
|
We may be contacted through our [Chat Server](http://chat.nhcarrigan.com) or via email at `contact@nhcarrigan.com`. -->
|
||||||
|
|||||||
@ -1 +0,0 @@
|
|||||||
We need this for the ticket system.
|
|
||||||
58
package.json
58
package.json
@ -1,58 +0,0 @@
|
|||||||
{
|
|
||||||
"name": "nodejs-typescript-template",
|
|
||||||
"version": "2.0.0",
|
|
||||||
"description": "A template for my nodejs projects",
|
|
||||||
"main": "prod/index.js",
|
|
||||||
"scripts": {
|
|
||||||
"build": "tsc",
|
|
||||||
"lint": "eslint src test --max-warnings 0 && prettier src test --check",
|
|
||||||
"start": "node -r dotenv/config prod/index.js",
|
|
||||||
"test": "ts-mocha -u tdd test/**/*.spec.ts --recursive --exit --timeout 10000"
|
|
||||||
},
|
|
||||||
"repository": {
|
|
||||||
"type": "git",
|
|
||||||
"url": "git+ssh://git@github.com/naomi-lgbt/nodejs-typescript-template.git"
|
|
||||||
},
|
|
||||||
"engines": {
|
|
||||||
"node": "22",
|
|
||||||
"pnpm": "9"
|
|
||||||
},
|
|
||||||
"keywords": [
|
|
||||||
"template",
|
|
||||||
"typescript",
|
|
||||||
"eslint",
|
|
||||||
"nodejs",
|
|
||||||
"prettier"
|
|
||||||
],
|
|
||||||
"author": "Naomi Carrigan",
|
|
||||||
"license": "SEE LICENSE IN https://docs.nhcarrigan.com/#/license",
|
|
||||||
"bugs": {
|
|
||||||
"url": "https://github.com/naomi-lgbt/nodejs-typescript-template/issues"
|
|
||||||
},
|
|
||||||
"homepage": "https://github.com/naomi-lgbt/nodejs-typescript-template#readme",
|
|
||||||
"dependencies": {
|
|
||||||
"@prisma/client": "5.13.0",
|
|
||||||
"discord.js": "14.15.2",
|
|
||||||
"dotenv": "16.4.5",
|
|
||||||
"express": "4.19.2",
|
|
||||||
"node-schedule": "2.1.1",
|
|
||||||
"winston": "3.13.0"
|
|
||||||
},
|
|
||||||
"devDependencies": {
|
|
||||||
"@nhcarrigan/eslint-config": "1.1.3",
|
|
||||||
"@nhcarrigan/prettier-config": "1.0.1",
|
|
||||||
"@nhcarrigan/typescript-config": "1.0.1",
|
|
||||||
"@types/chai": "4.3.16",
|
|
||||||
"@types/express": "4.17.21",
|
|
||||||
"@types/mocha": "10.0.6",
|
|
||||||
"@types/node": "18.19.33",
|
|
||||||
"@types/node-schedule": "2.1.7",
|
|
||||||
"chai": "4.4.1",
|
|
||||||
"eslint": "8.57.0",
|
|
||||||
"mocha": "10.4.0",
|
|
||||||
"prettier": "2.8.8",
|
|
||||||
"prisma": "5.13.0",
|
|
||||||
"ts-mocha": "10.0.0",
|
|
||||||
"typescript": "5.4.5"
|
|
||||||
}
|
|
||||||
}
|
|
||||||
3364
pnpm-lock.yaml
generated
3364
pnpm-lock.yaml
generated
File diff suppressed because it is too large
Load Diff
18
sample.env
18
sample.env
@ -1,18 +0,0 @@
|
|||||||
# Bot
|
|
||||||
TOKEN=""
|
|
||||||
MONGO_URI=""
|
|
||||||
|
|
||||||
# Hooks
|
|
||||||
DEBUG=""
|
|
||||||
COMM=""
|
|
||||||
DIST=""
|
|
||||||
NEWS=""
|
|
||||||
|
|
||||||
#Env
|
|
||||||
NODE_ENV="development"
|
|
||||||
|
|
||||||
# Trello
|
|
||||||
TRELLO_KEY=""
|
|
||||||
TRELLO_TOKEN=""
|
|
||||||
TRELLO_SECRET=""
|
|
||||||
TRELLO_HOOK_CALLBACK=""
|
|
||||||
@ -1 +0,0 @@
|
|||||||
export const TicketSupportRole = "1173582640843063366";
|
|
||||||
@ -1,44 +0,0 @@
|
|||||||
import { Webhooks } from "./Webhooks";
|
|
||||||
|
|
||||||
export const Trello = {
|
|
||||||
boardId: "",
|
|
||||||
newCardListId: "6552f24264ac58e98f8b78cd",
|
|
||||||
readyToSendListId: "6552f248af3c5fb5a81e4788",
|
|
||||||
platformLabels: {
|
|
||||||
discord: "6552f2b18af54bcca998abfe",
|
|
||||||
twitter: "6552f2cb9f21432b29106558",
|
|
||||||
email: "6552f2cee1258dfe159d48c8",
|
|
||||||
},
|
|
||||||
actionLabels: {
|
|
||||||
donate: "6552f2d257c42c85759d0199",
|
|
||||||
call: "6552f2d6d0e69a4c17f5f8ab",
|
|
||||||
protest: "6552f2dbfa9f5ac4267b136a",
|
|
||||||
},
|
|
||||||
checklistId: "6552f66d91daf000137ed4d2",
|
|
||||||
};
|
|
||||||
|
|
||||||
export const PlatformsToLabel: Record<string, string> = {
|
|
||||||
Email: Trello.platformLabels.email,
|
|
||||||
Discord: Trello.platformLabels.discord,
|
|
||||||
Twitter: Trello.platformLabels.twitter,
|
|
||||||
};
|
|
||||||
|
|
||||||
export const ActionsToLabel: Record<string, string> = {
|
|
||||||
"Sent a donation": Trello.actionLabels.donate,
|
|
||||||
"Called my representatives": Trello.actionLabels.call,
|
|
||||||
"Attended a protest": Trello.actionLabels.protest,
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Grabs the message from Discord, formats it into a Trello comment.
|
|
||||||
*
|
|
||||||
* @param {string} userName The name of the user that triggered the comment.
|
|
||||||
* @returns {string} The formatted text to send.
|
|
||||||
*/
|
|
||||||
export const TrelloComments: {
|
|
||||||
[key in Webhooks]: (userName: string) => string;
|
|
||||||
} = {
|
|
||||||
[Webhooks.NewCommissions]: (userName) => `Artwork claimed by ${userName}.`,
|
|
||||||
[Webhooks.CompleteCommissions]: (userName) =>
|
|
||||||
`Distribution claimed by ${userName}.`,
|
|
||||||
};
|
|
||||||
@ -1,19 +0,0 @@
|
|||||||
import { User } from "discord.js";
|
|
||||||
|
|
||||||
export enum Webhooks {
|
|
||||||
NewCommissions = "1172850885571911760",
|
|
||||||
CompleteCommissions = "1173062416041525259",
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Grabs the user from Discord, formats it based on the webhook ID.
|
|
||||||
*
|
|
||||||
* @param {User} u The user payload from Discord.
|
|
||||||
* @returns {string} The formatted text to send.
|
|
||||||
*/
|
|
||||||
export const ClaimTexts: { [key in Webhooks]: (u: User) => string } = {
|
|
||||||
[Webhooks.NewCommissions]: (u) =>
|
|
||||||
`Thanks for agreeing to do this art, <@!${u.id}>~! When it's completed, upload the image here and I'll automatically close this thread!`,
|
|
||||||
[Webhooks.CompleteCommissions]: (u) =>
|
|
||||||
`Thanks for agreeing to deliver this art, <@!${u.id}>~! When it's completed, upload a confirmation image here and I'll automatically close this thread!`,
|
|
||||||
};
|
|
||||||
@ -1,45 +0,0 @@
|
|||||||
import { Interaction } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
import { ticketClaimHandler } from "../modules/buttons/ticketClaim";
|
|
||||||
import { ticketCloseHandler } from "../modules/buttons/ticketClose";
|
|
||||||
import { ticketOpenHandler } from "../modules/buttons/ticketOpen";
|
|
||||||
import { handleTicketModal } from "../modules/modals/handleTicketModal";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles the logic for the interaction create event.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {Interaction} interaction The interaction payload from Discord.
|
|
||||||
*/
|
|
||||||
export const onInteractionCreate = async (
|
|
||||||
bot: ExtendedClient,
|
|
||||||
interaction: Interaction
|
|
||||||
) => {
|
|
||||||
try {
|
|
||||||
if (interaction.isModalSubmit()) {
|
|
||||||
if (interaction.customId === "ticket-modal") {
|
|
||||||
await handleTicketModal(bot, interaction);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (interaction.isButton()) {
|
|
||||||
if (!interaction.inCachedGuild()) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (interaction.customId === "ticket") {
|
|
||||||
await ticketOpenHandler(bot, interaction);
|
|
||||||
}
|
|
||||||
if (interaction.customId === "claim") {
|
|
||||||
await ticketClaimHandler(bot, interaction);
|
|
||||||
}
|
|
||||||
if (interaction.customId === "close") {
|
|
||||||
await ticketCloseHandler(bot, interaction);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in interaction create event: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,20 +0,0 @@
|
|||||||
import { GuildMember } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles the member add event from discord. Gives the new member
|
|
||||||
* the `Members` role.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {GuildMember} member The member payload from Discord.
|
|
||||||
*/
|
|
||||||
export const onMemberAdd = async (bot: ExtendedClient, member: GuildMember) => {
|
|
||||||
try {
|
|
||||||
await member.roles.add("1173580547952484352");
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error on member add event: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,172 +0,0 @@
|
|||||||
import { ChannelType, Message, PermissionFlagsBits } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
import { logTicketMessage } from "../modules/logTicketMessage";
|
|
||||||
import { startTicketPost } from "../modules/messages/startTicketPost";
|
|
||||||
import { getMuteDurationUnit } from "../utils/getMuteDurationUnit";
|
|
||||||
import { isValidWebhook } from "../utils/isValidWebhook";
|
|
||||||
import { logHandler } from "../utils/logHandler";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles the message create event. Adds reactions to messages from approved
|
|
||||||
* webhooks.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {Message} message The message payload from Discord.
|
|
||||||
*/
|
|
||||||
export const onMessageCreate = async (
|
|
||||||
bot: ExtendedClient,
|
|
||||||
message: Message
|
|
||||||
) => {
|
|
||||||
try {
|
|
||||||
if (!message.author.bot) {
|
|
||||||
if (
|
|
||||||
message.member?.permissions.has(PermissionFlagsBits.ManageGuild) &&
|
|
||||||
message.content === "~tickets"
|
|
||||||
) {
|
|
||||||
await startTicketPost(bot, message);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (
|
|
||||||
!message.channel.isDMBased() &&
|
|
||||||
message.channel.name.startsWith("ticket-")
|
|
||||||
) {
|
|
||||||
const id = message.channel.id;
|
|
||||||
const cached = bot.ticketLogs[id];
|
|
||||||
if (!cached) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
await logTicketMessage(bot, message, cached);
|
|
||||||
}
|
|
||||||
if (
|
|
||||||
message.member?.permissions.has(PermissionFlagsBits.ModerateMembers)
|
|
||||||
) {
|
|
||||||
if (message.content.startsWith("!mute")) {
|
|
||||||
const [, id, durationString, ...reason] =
|
|
||||||
message.content.split(/\s+/);
|
|
||||||
const target = await message.guild?.members.fetch(id);
|
|
||||||
if (!target) {
|
|
||||||
await message.reply("Target not found.");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const durationNumber = parseInt(
|
|
||||||
durationString.replace(/\w$/, ""),
|
|
||||||
10
|
|
||||||
);
|
|
||||||
const durationUnit = durationString.replace(/^\d+/, "");
|
|
||||||
const conversion = getMuteDurationUnit(durationUnit);
|
|
||||||
if (!conversion) {
|
|
||||||
await message.reply(`Invalid unit ${durationUnit}.`);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const time = durationNumber * conversion;
|
|
||||||
if (time > 1000 * 60 * 60 * 24 * 28) {
|
|
||||||
await message.reply("Cannot time out user for more than 28 days.");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
await target.timeout(time, reason.join(" ") || "No reason provided.");
|
|
||||||
await message.reply({ content: "Done" });
|
|
||||||
const logChannel = message.guild?.channels.cache.find(
|
|
||||||
(c) => c.name === "bot-logs"
|
|
||||||
);
|
|
||||||
if (logChannel && "send" in logChannel) {
|
|
||||||
await logChannel?.send({
|
|
||||||
content: `<@!${message.author.id}> muted <@!${target.id}> (${
|
|
||||||
target.id
|
|
||||||
}) - ${durationString} for: ${
|
|
||||||
reason.join(" ") ?? "No reason provided."
|
|
||||||
}`,
|
|
||||||
allowedMentions: {
|
|
||||||
users: [],
|
|
||||||
},
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (message.content.startsWith("!unmute")) {
|
|
||||||
const [, id, ...reason] = message.content.split(/\s+/);
|
|
||||||
const target = await message.guild?.members.fetch(id);
|
|
||||||
if (!target) {
|
|
||||||
await message.reply("Target not found.");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
await target.timeout(null, reason.join(" ") || "No reason provided.");
|
|
||||||
const logChannel = message.guild?.channels.cache.find(
|
|
||||||
(c) => c.name === "bot-logs"
|
|
||||||
);
|
|
||||||
await message.reply({ content: "Done" });
|
|
||||||
if (logChannel && "send" in logChannel) {
|
|
||||||
await logChannel?.send({
|
|
||||||
content: `<@!${message.author.id}> unmuted <@!${target.id}> (${
|
|
||||||
target.id
|
|
||||||
}) for: ${reason.join(" ") ?? "No reason provided."}`,
|
|
||||||
allowedMentions: {
|
|
||||||
users: [],
|
|
||||||
},
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
if (
|
|
||||||
message.channel.type === ChannelType.PublicThread &&
|
|
||||||
message.author.id === message.channel.name
|
|
||||||
) {
|
|
||||||
if (message.channel.parentId === "1172568787330019340") {
|
|
||||||
const { attachments } = message;
|
|
||||||
if (!attachments.size) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
await message.reply({
|
|
||||||
content:
|
|
||||||
"Accepting this as submission and closing out art request. Thanks for your support!",
|
|
||||||
});
|
|
||||||
const starter = await message.channel.fetchStarterMessage();
|
|
||||||
if (!starter) {
|
|
||||||
await message.channel.send(
|
|
||||||
`<@!465650873650118659>, couldn't load starter message for ${message.url}. Please port manually~!`
|
|
||||||
);
|
|
||||||
await message.channel.setArchived(true);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
await message.channel.setArchived(true);
|
|
||||||
await bot.dist.send({
|
|
||||||
content: starter.content,
|
|
||||||
files: [...attachments.values()],
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
if (message.channel.parentId === "1173061747737903315") {
|
|
||||||
const { attachments } = message;
|
|
||||||
if (!attachments.size) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
await message.reply({
|
|
||||||
content:
|
|
||||||
"Accepting this as delivery confirmation and closing out distribution request. Thanks for your support!",
|
|
||||||
});
|
|
||||||
await message.channel.setArchived(true);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (message.author.bot && !isValidWebhook(message.author.id)) {
|
|
||||||
logHandler.log(
|
|
||||||
"info",
|
|
||||||
`Got bot message from ${message.author.id} but is not a valid webhook.`
|
|
||||||
);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
logHandler.log("info", "Processing webhook message.");
|
|
||||||
await message.react("âś…").catch(async (err) => {
|
|
||||||
await bot.debug.send({
|
|
||||||
content: `[Failed to add reaction:](<${message.url}>) ${err.message}`,
|
|
||||||
});
|
|
||||||
});
|
|
||||||
logHandler.log("info", "Added reaction~!");
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in message create event: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,77 +0,0 @@
|
|||||||
import {
|
|
||||||
MessageReaction,
|
|
||||||
PartialMessageReaction,
|
|
||||||
PartialUser,
|
|
||||||
TextChannel,
|
|
||||||
ThreadAutoArchiveDuration,
|
|
||||||
User,
|
|
||||||
} from "discord.js";
|
|
||||||
|
|
||||||
import { ClaimTexts } from "../config/Webhooks";
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
import { isValidWebhook } from "../utils/isValidWebhook";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles the message reaction add. If added to a valid webhook, processes logic to send
|
|
||||||
* DM to the first user who reacted, remove further reactions.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {MessageReaction | PartialMessageReaction} r The reaction payload from Discord.
|
|
||||||
* @param {User | PartialUser} user The user who reacted.
|
|
||||||
*/
|
|
||||||
export const onReactionAdd = async (
|
|
||||||
bot: ExtendedClient,
|
|
||||||
r: MessageReaction | PartialMessageReaction,
|
|
||||||
user: User | PartialUser
|
|
||||||
) => {
|
|
||||||
try {
|
|
||||||
if (user.bot) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const reaction = await r.fetch().catch(async (err) => {
|
|
||||||
await bot.debug.send({
|
|
||||||
content: `[Failed to fetch reactions:](<${r.message.url}>) ${err.message}`,
|
|
||||||
});
|
|
||||||
return null;
|
|
||||||
});
|
|
||||||
if (!reaction) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const message = await r.message.fetch().catch(async (err) => {
|
|
||||||
await bot.debug.send({
|
|
||||||
content: `[Failed to fetch message:](<${r.message.url}>) ${err.message}`,
|
|
||||||
});
|
|
||||||
return null;
|
|
||||||
});
|
|
||||||
if (!message || !isValidWebhook(message.author.id)) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (reaction.count > 2) {
|
|
||||||
await r.users.remove(user.id);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const channel = r.message.channel as TextChannel;
|
|
||||||
const claimedByUser = (await channel.threads.fetchActive()).threads.filter(
|
|
||||||
(t) => t.name === user.id
|
|
||||||
);
|
|
||||||
if (claimedByUser.size >= 2) {
|
|
||||||
await r.users.remove(user.id);
|
|
||||||
await user.send(
|
|
||||||
"You currently have 2 open art rewards. Please do not claim another until you have completed one of your outstanding art works."
|
|
||||||
);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const thread = await channel.threads.create({
|
|
||||||
autoArchiveDuration: ThreadAutoArchiveDuration.OneWeek,
|
|
||||||
name: user.id,
|
|
||||||
startMessage: message,
|
|
||||||
});
|
|
||||||
await thread.members.add(user.id);
|
|
||||||
await thread.send(ClaimTexts[message.author.id](user as User));
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in processing new reaction: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,45 +0,0 @@
|
|||||||
import { scheduleJob } from "node-schedule";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
import { checkAirtableRecords } from "../modules/checkAirtableRecords";
|
|
||||||
import { fetchMessages } from "../modules/messages/fetchMessages";
|
|
||||||
import { sendUnclaimedArt } from "../modules/reminders/sendUnclaimedArt";
|
|
||||||
import { sendUnclaimedDistros } from "../modules/reminders/sendUnclaimedDistros";
|
|
||||||
import { sendUnfinishedArt } from "../modules/reminders/sendUnfinishedArt";
|
|
||||||
import { sendUnfinishedDistros } from "../modules/reminders/sendUnfinsihedDistros";
|
|
||||||
import { getNewsFeed } from "../utils/getNewsFeed";
|
|
||||||
import { serve } from "../server/serve";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles the logic when the bot is ready to receive Discord events.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
*/
|
|
||||||
export const onReady = async (bot: ExtendedClient) => {
|
|
||||||
try {
|
|
||||||
await bot.debug.send("Bot is online and ready to help!");
|
|
||||||
// donor channel
|
|
||||||
await fetchMessages(bot, "1172568787330019340");
|
|
||||||
// delivery channel
|
|
||||||
await fetchMessages(bot, "1173061747737903315");
|
|
||||||
await bot.debug.send("Fetching initial news feed...");
|
|
||||||
await getNewsFeed(bot);
|
|
||||||
await bot.debug.send("Fetching news posts every 10 minutes.");
|
|
||||||
setInterval(async () => await getNewsFeed(bot), 1000 * 60 * 10);
|
|
||||||
await bot.debug.send("Fetching new airtable submissions every 60 minutes.");
|
|
||||||
setInterval(async () => await checkAirtableRecords(bot), 1000 * 60 * 60);
|
|
||||||
|
|
||||||
scheduleJob("0 9 * * 1,3,5", async () => {
|
|
||||||
await sendUnclaimedArt(bot);
|
|
||||||
await sendUnclaimedDistros(bot);
|
|
||||||
});
|
|
||||||
|
|
||||||
scheduleJob("0 9 * * 6", async () => {
|
|
||||||
await sendUnfinishedArt(bot);
|
|
||||||
await sendUnfinishedDistros(bot);
|
|
||||||
});
|
|
||||||
await serve(bot);
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(`Error on ready event: ${(err as Error).message}`);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
73
src/index.ts
73
src/index.ts
@ -1,73 +0,0 @@
|
|||||||
import { execSync } from "child_process";
|
|
||||||
|
|
||||||
import { Client, Events, GatewayIntentBits, WebhookClient } from "discord.js";
|
|
||||||
|
|
||||||
import { onInteractionCreate } from "./events/onInteractionCreate";
|
|
||||||
import { onMemberAdd } from "./events/onMemberAdd";
|
|
||||||
import { onMessageCreate } from "./events/onMessageCreate";
|
|
||||||
import { onReactionAdd } from "./events/onReactionAdd";
|
|
||||||
import { onReady } from "./events/onReady";
|
|
||||||
import { ExtendedClient } from "./interface/ExtendedClient";
|
|
||||||
import { logHandler } from "./utils/logHandler";
|
|
||||||
|
|
||||||
(async () => {
|
|
||||||
if (
|
|
||||||
!process.env.TOKEN ||
|
|
||||||
!process.env.DEBUG ||
|
|
||||||
!process.env.COMM ||
|
|
||||||
!process.env.DIST ||
|
|
||||||
!process.env.NEWS ||
|
|
||||||
!process.env.TICKET
|
|
||||||
) {
|
|
||||||
logHandler.log("error", "Missing environment variables.");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const bot = new Client({
|
|
||||||
intents: [
|
|
||||||
GatewayIntentBits.GuildMessages,
|
|
||||||
GatewayIntentBits.Guilds,
|
|
||||||
GatewayIntentBits.GuildMessageReactions,
|
|
||||||
GatewayIntentBits.MessageContent,
|
|
||||||
GatewayIntentBits.GuildMembers,
|
|
||||||
],
|
|
||||||
}) as ExtendedClient;
|
|
||||||
bot.debug = new WebhookClient({ url: process.env.DEBUG });
|
|
||||||
bot.comm = new WebhookClient({ url: process.env.COMM });
|
|
||||||
bot.dist = new WebhookClient({ url: process.env.DIST });
|
|
||||||
bot.news = new WebhookClient({ url: process.env.NEWS });
|
|
||||||
bot.ticket = new WebhookClient({ url: process.env.TICKET });
|
|
||||||
bot.ticketLogs = {};
|
|
||||||
|
|
||||||
const commit = execSync("git rev-parse HEAD").toString().trim();
|
|
||||||
|
|
||||||
await bot.debug.send({
|
|
||||||
content: `Bot is starting up.\nVersion: ${
|
|
||||||
process.env.npm_package_version
|
|
||||||
}\nCommit: [${commit.slice(
|
|
||||||
0,
|
|
||||||
7
|
|
||||||
)}](<https://github.com/nhcarrigan/art-for-palestine-bot/commit/${commit}>)`,
|
|
||||||
});
|
|
||||||
|
|
||||||
bot.on(Events.ClientReady, async () => {
|
|
||||||
await onReady(bot);
|
|
||||||
});
|
|
||||||
|
|
||||||
bot.on(Events.MessageCreate, async (message) => {
|
|
||||||
await onMessageCreate(bot, message);
|
|
||||||
});
|
|
||||||
|
|
||||||
bot.on(Events.MessageReactionAdd, async (r, user) => {
|
|
||||||
await onReactionAdd(bot, r, user);
|
|
||||||
});
|
|
||||||
|
|
||||||
bot.on(Events.GuildMemberAdd, async (member) => {
|
|
||||||
await onMemberAdd(bot, member);
|
|
||||||
});
|
|
||||||
|
|
||||||
bot.on(Events.InteractionCreate, async (interaction) => {
|
|
||||||
await onInteractionCreate(bot, interaction);
|
|
||||||
});
|
|
||||||
|
|
||||||
await bot.login(process.env.TOKEN);
|
|
||||||
})();
|
|
||||||
@ -1,71 +0,0 @@
|
|||||||
export interface AirtableResponse {
|
|
||||||
records: {
|
|
||||||
id: string;
|
|
||||||
createdTime: string;
|
|
||||||
fields: {
|
|
||||||
"Anything Else?"?: string;
|
|
||||||
Reference: {
|
|
||||||
id: string;
|
|
||||||
width?: number;
|
|
||||||
height?: number;
|
|
||||||
url: string;
|
|
||||||
filename: string;
|
|
||||||
size: number;
|
|
||||||
type: string;
|
|
||||||
thumbnails?: {
|
|
||||||
small: {
|
|
||||||
url: string;
|
|
||||||
width: number;
|
|
||||||
height: number;
|
|
||||||
};
|
|
||||||
large: {
|
|
||||||
url: string;
|
|
||||||
width: number;
|
|
||||||
height: number;
|
|
||||||
};
|
|
||||||
full: {
|
|
||||||
url: string;
|
|
||||||
width: number;
|
|
||||||
height: number;
|
|
||||||
};
|
|
||||||
};
|
|
||||||
}[];
|
|
||||||
"Acknowledgement "?: boolean;
|
|
||||||
"Email Address"?: string;
|
|
||||||
"What would you like us to draw?"?: string;
|
|
||||||
Action: string;
|
|
||||||
Name: string;
|
|
||||||
"Contact Method": string;
|
|
||||||
Created: string;
|
|
||||||
"Proof of Donation"?: {
|
|
||||||
id: string;
|
|
||||||
width: number;
|
|
||||||
height: number;
|
|
||||||
url: string;
|
|
||||||
filename: string;
|
|
||||||
size: number;
|
|
||||||
type: string;
|
|
||||||
thumbnails: {
|
|
||||||
small: {
|
|
||||||
url: string;
|
|
||||||
width: number;
|
|
||||||
height: number;
|
|
||||||
};
|
|
||||||
large: {
|
|
||||||
url: string;
|
|
||||||
width: number;
|
|
||||||
height: number;
|
|
||||||
};
|
|
||||||
full: {
|
|
||||||
url: string;
|
|
||||||
width: number;
|
|
||||||
height: number;
|
|
||||||
};
|
|
||||||
};
|
|
||||||
}[];
|
|
||||||
"Donation Amount"?: number;
|
|
||||||
Fund?: string;
|
|
||||||
Handle?: string;
|
|
||||||
};
|
|
||||||
}[];
|
|
||||||
}
|
|
||||||
@ -1,8 +0,0 @@
|
|||||||
import { ButtonInteraction } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "./ExtendedClient";
|
|
||||||
|
|
||||||
export type ButtonHandler = (
|
|
||||||
Bot: ExtendedClient,
|
|
||||||
interaction: ButtonInteraction<"cached">
|
|
||||||
) => Promise<void>;
|
|
||||||
@ -1,11 +0,0 @@
|
|||||||
import { Client, WebhookClient } from "discord.js";
|
|
||||||
|
|
||||||
export interface ExtendedClient extends Client {
|
|
||||||
debug: WebhookClient;
|
|
||||||
comm: WebhookClient;
|
|
||||||
dist: WebhookClient;
|
|
||||||
news: WebhookClient;
|
|
||||||
ticket: WebhookClient;
|
|
||||||
lastArticle: number;
|
|
||||||
ticketLogs: { [key: string]: string };
|
|
||||||
}
|
|
||||||
@ -1,78 +0,0 @@
|
|||||||
import {
|
|
||||||
ActionRowBuilder,
|
|
||||||
ButtonBuilder,
|
|
||||||
ButtonStyle,
|
|
||||||
Embed,
|
|
||||||
GuildMember,
|
|
||||||
Message,
|
|
||||||
} from "discord.js";
|
|
||||||
|
|
||||||
import { TicketSupportRole } from "../../config/Tickets";
|
|
||||||
import { ButtonHandler } from "../../interface/ButtonHandler";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles the process of claiming a ticket.
|
|
||||||
*/
|
|
||||||
export const ticketClaimHandler: ButtonHandler = async (bot, interaction) => {
|
|
||||||
try {
|
|
||||||
await interaction.deferReply({ ephemeral: true });
|
|
||||||
const { guild, message, member } = interaction;
|
|
||||||
const { embeds } = message;
|
|
||||||
const supportRole = await guild.roles.fetch(TicketSupportRole);
|
|
||||||
|
|
||||||
if (!supportRole) {
|
|
||||||
await interaction.editReply("Cannot find support role!");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const isSupport = (member as GuildMember).roles.cache.has(supportRole.id);
|
|
||||||
|
|
||||||
if (!isSupport) {
|
|
||||||
await interaction.editReply({
|
|
||||||
content: "Only support members can claim a ticket.",
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const ticketEmbed = embeds[0] as Embed;
|
|
||||||
const updatedEmbed = {
|
|
||||||
title: ticketEmbed.title || "Lost the Title",
|
|
||||||
description: ticketEmbed.description || "Lost the Description",
|
|
||||||
fields: [{ name: "Claimed by:", value: `<@${member.user.id}>` }],
|
|
||||||
};
|
|
||||||
|
|
||||||
const claimButton = new ButtonBuilder()
|
|
||||||
.setCustomId("claim")
|
|
||||||
.setStyle(ButtonStyle.Success)
|
|
||||||
.setLabel("Claim this ticket!")
|
|
||||||
.setEmoji("âś‹")
|
|
||||||
.setDisabled(true);
|
|
||||||
const closeButton = new ButtonBuilder()
|
|
||||||
.setCustomId("close")
|
|
||||||
.setStyle(ButtonStyle.Danger)
|
|
||||||
.setLabel("Close this ticket!")
|
|
||||||
.setEmoji("🗑️");
|
|
||||||
|
|
||||||
const row = new ActionRowBuilder<ButtonBuilder>().addComponents([
|
|
||||||
claimButton,
|
|
||||||
closeButton,
|
|
||||||
]);
|
|
||||||
|
|
||||||
await (message as Message).edit({
|
|
||||||
embeds: [updatedEmbed],
|
|
||||||
components: [row],
|
|
||||||
});
|
|
||||||
|
|
||||||
await interaction.editReply(
|
|
||||||
"I have marked you as responsible for this query."
|
|
||||||
);
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in ticket claim module: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
await interaction.editReply({
|
|
||||||
content:
|
|
||||||
"Forgive me, but I failed to complete your request. Please try again later.",
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,60 +0,0 @@
|
|||||||
import { GuildMember, EmbedBuilder, TextChannel } from "discord.js";
|
|
||||||
|
|
||||||
import { TicketSupportRole } from "../../config/Tickets";
|
|
||||||
import { ButtonHandler } from "../../interface/ButtonHandler";
|
|
||||||
import { generateLogs } from "../generateLogs";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles closing a ticket.
|
|
||||||
*/
|
|
||||||
export const ticketCloseHandler: ButtonHandler = async (bot, interaction) => {
|
|
||||||
try {
|
|
||||||
await interaction.deferReply({ ephemeral: true });
|
|
||||||
const { guild, member, channel } = interaction;
|
|
||||||
|
|
||||||
if (!guild || !member || !channel) {
|
|
||||||
await interaction.editReply({
|
|
||||||
content: "Error finding the guild!",
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const supportRole = await guild.roles.fetch(TicketSupportRole);
|
|
||||||
|
|
||||||
if (!supportRole) {
|
|
||||||
await interaction.editReply("Cannot find support role!");
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const isSupport = (member as GuildMember).roles.cache.has(supportRole.id);
|
|
||||||
|
|
||||||
if (!isSupport) {
|
|
||||||
await interaction.editReply({
|
|
||||||
content: "Only support members can close a ticket.",
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const logEmbed = new EmbedBuilder();
|
|
||||||
logEmbed.setTitle("Ticket Closed");
|
|
||||||
logEmbed.setDescription(`Ticket closed by <@!${member.user.id}>`);
|
|
||||||
logEmbed.addFields({
|
|
||||||
name: "User",
|
|
||||||
value:
|
|
||||||
(channel as TextChannel)?.name.split("-").slice(1).join("-") ||
|
|
||||||
"unknown",
|
|
||||||
});
|
|
||||||
|
|
||||||
const logFile = await generateLogs(bot, channel.id);
|
|
||||||
await bot.ticket.send({ embeds: [logEmbed], files: [logFile] });
|
|
||||||
await channel.delete();
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in close ticket module: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
await interaction.editReply({
|
|
||||||
content:
|
|
||||||
"Forgive me, but I failed to complete your request. Please try again later.",
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,41 +0,0 @@
|
|||||||
import {
|
|
||||||
ActionRowBuilder,
|
|
||||||
ModalBuilder,
|
|
||||||
ModalActionRowComponentBuilder,
|
|
||||||
TextInputBuilder,
|
|
||||||
TextInputStyle,
|
|
||||||
} from "discord.js";
|
|
||||||
|
|
||||||
import { ButtonHandler } from "../../interface/ButtonHandler";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Generates the modal for opening a new ticket.
|
|
||||||
*/
|
|
||||||
export const ticketOpenHandler: ButtonHandler = async (bot, interaction) => {
|
|
||||||
try {
|
|
||||||
const ticketModal = new ModalBuilder()
|
|
||||||
.setCustomId("ticket-modal")
|
|
||||||
.setTitle("Ticket System");
|
|
||||||
const reasonInput = new TextInputBuilder()
|
|
||||||
.setCustomId("reason")
|
|
||||||
.setLabel("Why are you opening this ticket?")
|
|
||||||
.setStyle(TextInputStyle.Paragraph)
|
|
||||||
.setRequired(true)
|
|
||||||
.setMaxLength(1000);
|
|
||||||
|
|
||||||
const actionRow =
|
|
||||||
new ActionRowBuilder<ModalActionRowComponentBuilder>().addComponents(
|
|
||||||
reasonInput
|
|
||||||
);
|
|
||||||
ticketModal.addComponents(actionRow);
|
|
||||||
await interaction.showModal(ticketModal);
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in open ticket module: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
await interaction.editReply({
|
|
||||||
content:
|
|
||||||
"Forgive me, but I failed to complete your request. Please try again later.",
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,75 +0,0 @@
|
|||||||
import { readFile, writeFile } from "fs/promises";
|
|
||||||
import { join } from "path";
|
|
||||||
|
|
||||||
import { AttachmentBuilder } from "discord.js";
|
|
||||||
|
|
||||||
import { AirtableResponse } from "../interface/AirtableResponse";
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Fetches the Airtable records and pipes new records to trello.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
*/
|
|
||||||
export const checkAirtableRecords = async (bot: ExtendedClient) => {
|
|
||||||
try {
|
|
||||||
const latestId = await readFile(
|
|
||||||
join(__dirname, "..", "..", "latestAirtableRecord.txt"),
|
|
||||||
"utf-8"
|
|
||||||
);
|
|
||||||
const records = await fetch(
|
|
||||||
`https://api.airtable.com/v0/${process.env.AIRTABLE_BASE_ID}/${process.env.AIRTABLE_TABLE_ID}?maxRecords=100&sort%5B0%5D%5Bfield%5D=Created&sort%5B0%5D%5Bdirection%5D=desc`,
|
|
||||||
{
|
|
||||||
headers: {
|
|
||||||
Authorization: `Bearer ${process.env.AIRTABLE_KEY}`,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
);
|
|
||||||
const res = (await records.json()) as AirtableResponse;
|
|
||||||
const alreadySeenIndex = res.records.findIndex((r) => r.id === latestId);
|
|
||||||
if (alreadySeenIndex === 0) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const newRecords = res.records.slice(0, alreadySeenIndex);
|
|
||||||
const newLatestId = newRecords[0]?.id as string;
|
|
||||||
|
|
||||||
await writeFile(
|
|
||||||
join(__dirname, "..", "..", "latestAirtableRecord.txt"),
|
|
||||||
newLatestId,
|
|
||||||
"utf-8"
|
|
||||||
);
|
|
||||||
|
|
||||||
for (const record of newRecords) {
|
|
||||||
const {
|
|
||||||
Name: name,
|
|
||||||
Reference: images,
|
|
||||||
"Contact Method": platform,
|
|
||||||
Handle: handle,
|
|
||||||
"What would you like us to draw?": note,
|
|
||||||
"Anything Else?": additional,
|
|
||||||
} = record.fields;
|
|
||||||
const files: AttachmentBuilder[] = [];
|
|
||||||
for (const imageUrl of images) {
|
|
||||||
const image = await fetch(imageUrl.url);
|
|
||||||
const imageBuffer = await image.arrayBuffer();
|
|
||||||
const imageFinal = Buffer.from(imageBuffer);
|
|
||||||
const file = new AttachmentBuilder(imageFinal, {
|
|
||||||
name: "reference.png",
|
|
||||||
});
|
|
||||||
files.push(file);
|
|
||||||
}
|
|
||||||
await bot.comm.send({
|
|
||||||
content: `**FOR:** ${name} - Contact via ${platform}: ${handle}\n\n${note?.slice(
|
|
||||||
0,
|
|
||||||
1000
|
|
||||||
)}\n\n${additional?.slice(0, 1000)}\n\nReferences:`,
|
|
||||||
files,
|
|
||||||
});
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in check airtable records: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,32 +0,0 @@
|
|||||||
import { writeFile } from "fs/promises";
|
|
||||||
import { join } from "path";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Creates the initial ticket log file.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {string} channelId The ticket channel ID, used as a unique identifier.
|
|
||||||
* @param {string} user The user tag of the person who opened the ticket.
|
|
||||||
* @param {string} content The initial content of the log file.
|
|
||||||
*/
|
|
||||||
export const createLogFile = async (
|
|
||||||
bot: ExtendedClient,
|
|
||||||
channelId: string,
|
|
||||||
user: string,
|
|
||||||
content: string
|
|
||||||
): Promise<void> => {
|
|
||||||
try {
|
|
||||||
bot.ticketLogs[channelId] = channelId;
|
|
||||||
|
|
||||||
await writeFile(
|
|
||||||
join(process.cwd(), "logs", `${channelId}.txt`),
|
|
||||||
`[${new Date().toLocaleString()}] - **TICKET CREATED**\n[${new Date().toLocaleString()}] - ${user}: ${content}\n`
|
|
||||||
);
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in create log file module: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,46 +0,0 @@
|
|||||||
import { readFile, unlink } from "fs/promises";
|
|
||||||
import { join } from "path";
|
|
||||||
|
|
||||||
import { AttachmentBuilder } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* To run when a ticket is closed. Finds the ticket log file,
|
|
||||||
* creates a message attachement with the logs, and deletes the file.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {string} channelId The channel ID of the ticket.
|
|
||||||
* @returns {Promise<AttachmentBuilder>} The log file as a Discord attachment.
|
|
||||||
*/
|
|
||||||
export const generateLogs = async (
|
|
||||||
bot: ExtendedClient,
|
|
||||||
channelId: string
|
|
||||||
): Promise<AttachmentBuilder> => {
|
|
||||||
try {
|
|
||||||
delete bot.ticketLogs[channelId];
|
|
||||||
|
|
||||||
const logs = await readFile(
|
|
||||||
join(process.cwd(), "logs", `${channelId}.txt`),
|
|
||||||
"utf8"
|
|
||||||
).catch(() => "no logs found...");
|
|
||||||
|
|
||||||
const attachment = new AttachmentBuilder(Buffer.from(logs, "utf-8"), {
|
|
||||||
name: "log.txt",
|
|
||||||
});
|
|
||||||
|
|
||||||
await unlink(join(process.cwd(), "logs", `${channelId}.txt`)).catch(
|
|
||||||
() => null
|
|
||||||
);
|
|
||||||
|
|
||||||
return attachment;
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in generate logs module: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
return new AttachmentBuilder(
|
|
||||||
Buffer.from("An error occurred fetching these logs.", "utf-8"),
|
|
||||||
{ name: "log.txt" }
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,39 +0,0 @@
|
|||||||
import { readFile, writeFile } from "fs/promises";
|
|
||||||
import { join } from "path";
|
|
||||||
|
|
||||||
import { Message } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Logs messages to a file to track ticket activity.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {Message} message The Discord message payload.
|
|
||||||
* @param {string} logId The logId to identify the file.
|
|
||||||
*/
|
|
||||||
export const logTicketMessage = async (
|
|
||||||
bot: ExtendedClient,
|
|
||||||
message: Message,
|
|
||||||
logId: string
|
|
||||||
): Promise<void> => {
|
|
||||||
try {
|
|
||||||
const logFile = await readFile(
|
|
||||||
join(process.cwd(), "logs", `${logId}.txt`),
|
|
||||||
"utf8"
|
|
||||||
);
|
|
||||||
|
|
||||||
const parsedString = `[${new Date(
|
|
||||||
message.createdTimestamp
|
|
||||||
).toLocaleString()}] - ${message.author.tag}: ${message.content}\n`;
|
|
||||||
|
|
||||||
await writeFile(
|
|
||||||
join(process.cwd(), "logs", `${logId}.txt`),
|
|
||||||
logFile + parsedString
|
|
||||||
);
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in log ticket message module: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,40 +0,0 @@
|
|||||||
import { ExtendedClient } from "../../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Caches the messages from a specific channel. This should be done to ensure
|
|
||||||
* all donation + delivery messages are cached and reaction payloads will be received.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {string} channelId The ID of the channel to cache.
|
|
||||||
*/
|
|
||||||
export const fetchMessages = async (bot: ExtendedClient, channelId: string) => {
|
|
||||||
try {
|
|
||||||
await bot.debug.send(`Caching messages for ${channelId}`);
|
|
||||||
const guild = await bot.guilds.fetch("1172566005311090798");
|
|
||||||
const channel = await guild.channels.fetch(channelId);
|
|
||||||
|
|
||||||
if (!channel || !("send" in channel)) {
|
|
||||||
await bot.debug.send(`Failed to load <#${channelId}>~!`);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
let before: string | undefined = undefined;
|
|
||||||
|
|
||||||
await bot.debug.send("Fetching first wave of messages.");
|
|
||||||
let messages = await channel.messages.fetch({ limit: 100 });
|
|
||||||
|
|
||||||
while (messages.size === 100) {
|
|
||||||
before = messages.last()?.id;
|
|
||||||
if (!before) {
|
|
||||||
await bot.debug.send("Failed to get oldest messages from batch.");
|
|
||||||
break;
|
|
||||||
}
|
|
||||||
await bot.debug.send(
|
|
||||||
`Found more than 100 messages. Fetching next batch from ${before}`
|
|
||||||
);
|
|
||||||
messages = await channel.messages.fetch({ limit: 100, before });
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send({ content: `` });
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,48 +0,0 @@
|
|||||||
import {
|
|
||||||
ActionRowBuilder,
|
|
||||||
ButtonBuilder,
|
|
||||||
ButtonStyle,
|
|
||||||
EmbedBuilder,
|
|
||||||
Message,
|
|
||||||
} from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles the logic to start a ticket post.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
* @param {Message} message The message payload from Discord.
|
|
||||||
*/
|
|
||||||
export const startTicketPost = async (
|
|
||||||
bot: ExtendedClient,
|
|
||||||
message: Message
|
|
||||||
) => {
|
|
||||||
try {
|
|
||||||
const embed = new EmbedBuilder();
|
|
||||||
embed.setTitle("Need Help?");
|
|
||||||
embed.setDescription(
|
|
||||||
`If you have concerns with behavior in this Discord server, click the button below to open a private ticket with the Moderation team.
|
|
||||||
|
|
||||||
If you want to contact the team for any other reason, you can message an Admin or send an email to \`contact@art4palestine.org\`.`
|
|
||||||
);
|
|
||||||
embed.setColor("#0099ff");
|
|
||||||
|
|
||||||
const button = new ButtonBuilder()
|
|
||||||
.setLabel("Open a Ticket!")
|
|
||||||
.setEmoji("âť”")
|
|
||||||
.setStyle(ButtonStyle.Primary)
|
|
||||||
.setCustomId("ticket");
|
|
||||||
|
|
||||||
const row = new ActionRowBuilder<ButtonBuilder>().addComponents(button);
|
|
||||||
await message.channel.send({ embeds: [embed], components: [row] });
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in start ticket post module: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
await message.reply({
|
|
||||||
content:
|
|
||||||
"Forgive me, but I failed to complete your request. Please try again later.",
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,82 +0,0 @@
|
|||||||
import {
|
|
||||||
ActionRowBuilder,
|
|
||||||
ButtonBuilder,
|
|
||||||
ButtonStyle,
|
|
||||||
ChannelType,
|
|
||||||
EmbedBuilder,
|
|
||||||
ModalSubmitInteraction,
|
|
||||||
TextChannel,
|
|
||||||
} from "discord.js";
|
|
||||||
|
|
||||||
import { TicketSupportRole } from "../../config/Tickets";
|
|
||||||
import { ExtendedClient } from "../../interface/ExtendedClient";
|
|
||||||
import { createLogFile } from "../createLogsFile";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Handles responding to the ticket modal.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's discord instance.
|
|
||||||
* @param {ModalSubmitInteraction} interaction The interaction payload from Discord.
|
|
||||||
*/
|
|
||||||
export const handleTicketModal = async (
|
|
||||||
bot: ExtendedClient,
|
|
||||||
interaction: ModalSubmitInteraction
|
|
||||||
) => {
|
|
||||||
try {
|
|
||||||
await interaction.deferReply({ ephemeral: true });
|
|
||||||
const { guild, user, channel } = interaction;
|
|
||||||
const reason = interaction.fields.getTextInputValue("reason");
|
|
||||||
|
|
||||||
if (!guild || !channel || !("threads" in channel)) {
|
|
||||||
await interaction.editReply(
|
|
||||||
"Forgive me, but this can only be done within a server"
|
|
||||||
);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const claimButton = new ButtonBuilder()
|
|
||||||
.setCustomId("claim")
|
|
||||||
.setStyle(ButtonStyle.Success)
|
|
||||||
.setLabel("Claim this ticket!")
|
|
||||||
.setEmoji("âś‹");
|
|
||||||
const closeButton = new ButtonBuilder()
|
|
||||||
.setCustomId("close")
|
|
||||||
.setStyle(ButtonStyle.Danger)
|
|
||||||
.setLabel("Close this ticket!")
|
|
||||||
.setEmoji("🗑️");
|
|
||||||
|
|
||||||
const row = new ActionRowBuilder<ButtonBuilder>().addComponents([
|
|
||||||
claimButton,
|
|
||||||
closeButton,
|
|
||||||
]);
|
|
||||||
|
|
||||||
const ticketEmbed = new EmbedBuilder();
|
|
||||||
ticketEmbed.setTitle("Ticket Created");
|
|
||||||
ticketEmbed.setDescription(
|
|
||||||
`<@!${user.id}> opened a ticket for:\n${reason}`
|
|
||||||
);
|
|
||||||
|
|
||||||
const ticketThread = await (channel as TextChannel).threads.create({
|
|
||||||
name: `ticket-${user.username}`,
|
|
||||||
type: ChannelType.PrivateThread,
|
|
||||||
});
|
|
||||||
await ticketThread.members.add(user.id);
|
|
||||||
await ticketThread.send({
|
|
||||||
content: `<@&${TicketSupportRole}>, a ticket has been opened!`,
|
|
||||||
embeds: [ticketEmbed],
|
|
||||||
components: [row],
|
|
||||||
});
|
|
||||||
await createLogFile(bot, ticketThread.id, user.tag, reason);
|
|
||||||
await interaction.editReply(
|
|
||||||
"Your ticket channel has been created! Please head there and describe the issue you are having."
|
|
||||||
);
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in ticket modal module: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
await interaction.editReply({
|
|
||||||
content:
|
|
||||||
"Forgive me, but I failed to complete your request. Please try again later.",
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,40 +0,0 @@
|
|||||||
import { TextChannel } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Sends a reminder to claim the unclaimed art rewards.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
*/
|
|
||||||
export const sendUnclaimedArt = async (bot: ExtendedClient) => {
|
|
||||||
try {
|
|
||||||
const guild = await bot.guilds.fetch("1172566005311090798");
|
|
||||||
const artChannel = (await guild.channels.fetch(
|
|
||||||
"1172568787330019340"
|
|
||||||
)) as TextChannel;
|
|
||||||
const messages = await artChannel.messages.fetch({
|
|
||||||
after: "1241326793294610443",
|
|
||||||
});
|
|
||||||
const filtered = messages.filter((m) => !m.hasThread);
|
|
||||||
|
|
||||||
if (!filtered.size) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const channel = await guild.channels.fetch("1172568865218252801");
|
|
||||||
|
|
||||||
if (!channel || !("send" in channel)) {
|
|
||||||
await bot.debug.send(`Failed to find <#1172568865218252801>~!`);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
await channel.send(`## Unclaimed Art!
|
|
||||||
|
|
||||||
The following art rewards have not been claimed yet. If you have the capacity to do so, please consider taking one on.
|
|
||||||
|
|
||||||
${filtered.map((r) => `- ${r.url}`).join("\n")}`);
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(`Cannot send unclaimed art reminder: ${err}`);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,40 +0,0 @@
|
|||||||
import { TextChannel } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Sends a reminder to claim the unclaimed distribution requests.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
*/
|
|
||||||
export const sendUnclaimedDistros = async (bot: ExtendedClient) => {
|
|
||||||
try {
|
|
||||||
const guild = await bot.guilds.fetch("1172566005311090798");
|
|
||||||
const artChannel = (await guild.channels.fetch(
|
|
||||||
"1173061747737903315"
|
|
||||||
)) as TextChannel;
|
|
||||||
const messages = await artChannel.messages.fetch({
|
|
||||||
after: "1241055357112025168",
|
|
||||||
});
|
|
||||||
const filtered = messages.filter((m) => !m.hasThread);
|
|
||||||
|
|
||||||
if (!filtered.size) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
const channel = await guild.channels.fetch("1173061809834565764");
|
|
||||||
|
|
||||||
if (!channel || !("send" in channel)) {
|
|
||||||
await bot.debug.send(`Failed to find <#1173061809834565764>~!`);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
await channel.send(`## Unclaimed Distribtions!
|
|
||||||
|
|
||||||
The following art rewards have not been distributed yet. If you have the capacity to do so, please consider taking one on.
|
|
||||||
|
|
||||||
${filtered.map((r) => `- ${r.url}`).join("\n")}`);
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(`Cannot send unclaimed distro reminder: ${err}`);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,25 +0,0 @@
|
|||||||
import { TextChannel } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Sends a reminder to finish claimed art rewards.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
*/
|
|
||||||
export const sendUnfinishedArt = async (bot: ExtendedClient) => {
|
|
||||||
try {
|
|
||||||
const guild = await bot.guilds.fetch("1172566005311090798");
|
|
||||||
const channel = (await guild.channels.fetch(
|
|
||||||
"1172568787330019340"
|
|
||||||
)) as TextChannel;
|
|
||||||
const threads = await channel.threads.fetchActive();
|
|
||||||
for (const thread of threads.threads.values()) {
|
|
||||||
await thread.send({
|
|
||||||
content: `<@!${thread.name}>, this art appears unfinished. When it's complete, please upload the image here and the thread will be processed.`,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(`Cannot send unfinished art reminder: ${err}`);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,25 +0,0 @@
|
|||||||
import { TextChannel } from "discord.js";
|
|
||||||
|
|
||||||
import { ExtendedClient } from "../../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Sends a reminder to finish claimed distribution requests.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
*/
|
|
||||||
export const sendUnfinishedDistros = async (bot: ExtendedClient) => {
|
|
||||||
try {
|
|
||||||
const guild = await bot.guilds.fetch("1172566005311090798");
|
|
||||||
const channel = (await guild.channels.fetch(
|
|
||||||
"1173061747737903315"
|
|
||||||
)) as TextChannel;
|
|
||||||
const threads = await channel.threads.fetchActive();
|
|
||||||
for (const thread of threads.threads.values()) {
|
|
||||||
await thread.send({
|
|
||||||
content: `<@!${thread.name}>, this distribution appears unconfirmed. When it's complete, please upload a confirmation image here and the thread will be processed.`,
|
|
||||||
});
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(`Cannot send unfinished art reminder: ${err}`);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,94 +0,0 @@
|
|||||||
import { createHmac } from "crypto";
|
|
||||||
import { readFile } from "fs/promises";
|
|
||||||
import http from "http";
|
|
||||||
import https from "https";
|
|
||||||
|
|
||||||
import express from "express";
|
|
||||||
|
|
||||||
import { Trello } from "../config/Trello";
|
|
||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Instantiates the web server for listening to webhook payloads.
|
|
||||||
*
|
|
||||||
* TODO: Delete this entirely once all trello things are done.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
*/
|
|
||||||
export const serve = async (bot: ExtendedClient) => {
|
|
||||||
const app = express();
|
|
||||||
app.use(express.json());
|
|
||||||
|
|
||||||
app.get("/", (_req, res) => {
|
|
||||||
res.header("Content-Type", "text/html");
|
|
||||||
res.status(200).send(`
|
|
||||||
<!DOCTYPE html>
|
|
||||||
<html>
|
|
||||||
<head>
|
|
||||||
<title>Art 4 Palestine Bot</title>
|
|
||||||
<meta charset="utf-8" />
|
|
||||||
<meta name="viewport" content="width=device-width, initial-scale=1" />
|
|
||||||
<meta name="description" content="A bot to facilitate our initiative to raise funds for Palestine relief charities by rewarding donors with art." />
|
|
||||||
<script src="https://cdn.nhcarrigan.com/headers/index.js" async defer></script>
|
|
||||||
</head>
|
|
||||||
<body>
|
|
||||||
<main>
|
|
||||||
<h1>Art 4 Palestine Bot</h1>
|
|
||||||
<section>
|
|
||||||
<p>A bot to facilitate our initiative to raise funds for Palestine relief charities by rewarding donors with art.</p>
|
|
||||||
</section>
|
|
||||||
<section>
|
|
||||||
<h2>Links</h2>
|
|
||||||
<p>
|
|
||||||
<a href="https://codeberg.org/nhcarrigan/a4p-bot">
|
|
||||||
<i class="fa-solid fa-code"></i> Source Code
|
|
||||||
</a>
|
|
||||||
</p>
|
|
||||||
<p>
|
|
||||||
<a href="https://docs.nhcarrigan.com">
|
|
||||||
<i class="fa-solid fa-book"></i> Documentation
|
|
||||||
</a>
|
|
||||||
</p>
|
|
||||||
<p>
|
|
||||||
<a href="https://chat.nhcarrigan.com">
|
|
||||||
<i class="fa-solid fa-circle-info"></i> Support
|
|
||||||
</a>
|
|
||||||
</p>
|
|
||||||
</section>
|
|
||||||
</main>
|
|
||||||
</html>`);
|
|
||||||
});
|
|
||||||
|
|
||||||
const httpServer = http.createServer(app);
|
|
||||||
|
|
||||||
httpServer.listen(10080, async () => {
|
|
||||||
await bot.debug.send("http server listening on port 10080");
|
|
||||||
});
|
|
||||||
|
|
||||||
if (process.env.NODE_ENV === "production") {
|
|
||||||
const privateKey = await readFile(
|
|
||||||
"/etc/letsencrypt/live/afp.nhcarrigan.com/privkey.pem",
|
|
||||||
"utf8"
|
|
||||||
);
|
|
||||||
const certificate = await readFile(
|
|
||||||
"/etc/letsencrypt/live/afp.nhcarrigan.com/cert.pem",
|
|
||||||
"utf8"
|
|
||||||
);
|
|
||||||
const ca = await readFile(
|
|
||||||
"/etc/letsencrypt/live/afp.nhcarrigan.com/chain.pem",
|
|
||||||
"utf8"
|
|
||||||
);
|
|
||||||
|
|
||||||
const credentials = {
|
|
||||||
key: privateKey,
|
|
||||||
cert: certificate,
|
|
||||||
ca: ca,
|
|
||||||
};
|
|
||||||
|
|
||||||
const httpsServer = https.createServer(credentials, app);
|
|
||||||
|
|
||||||
httpsServer.listen(10443, async () => {
|
|
||||||
await bot.debug.send("https server listening on port 10443");
|
|
||||||
});
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,24 +0,0 @@
|
|||||||
/**
|
|
||||||
* Parses a unit string into units.
|
|
||||||
*
|
|
||||||
* @param {string} unit The unit string to parse.
|
|
||||||
* @returns {number} The unit conversion rate, to convert a number to ms.
|
|
||||||
*/
|
|
||||||
export const getMuteDurationUnit = (unit: string): number | null => {
|
|
||||||
switch (unit.toLowerCase()) {
|
|
||||||
case "m":
|
|
||||||
case "minute":
|
|
||||||
case "min":
|
|
||||||
case "minutes":
|
|
||||||
return 1000 * 60;
|
|
||||||
case "h":
|
|
||||||
case "hours":
|
|
||||||
case "hour":
|
|
||||||
return 1000 * 60 * 60;
|
|
||||||
case "d":
|
|
||||||
case "day":
|
|
||||||
case "days":
|
|
||||||
return 1000 * 60 * 60 * 24;
|
|
||||||
}
|
|
||||||
return null;
|
|
||||||
};
|
|
||||||
@ -1,119 +0,0 @@
|
|||||||
import { ExtendedClient } from "../interface/ExtendedClient";
|
|
||||||
|
|
||||||
const getHeadlineArticle = async (bot: ExtendedClient) => {
|
|
||||||
try {
|
|
||||||
const req = await fetch(
|
|
||||||
"https://www.aljazeera.com/tag/israel-palestine-conflict/",
|
|
||||||
{
|
|
||||||
method: "GET",
|
|
||||||
headers: {
|
|
||||||
"Wp-site": "Naomi's Art for Palestine Bot",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
);
|
|
||||||
const res = await req.text();
|
|
||||||
const link = res.match(/<a target="" href="(.*)">Live\supdates<\/a>/);
|
|
||||||
return link?.[1];
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in fetching latest news post: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
const getArticleChildren = async (bot: ExtendedClient, slug: string) => {
|
|
||||||
try {
|
|
||||||
const req = await fetch(
|
|
||||||
`https://www.aljazeera.com/graphql?wp-site=aje&operationName=SingleLiveBlogChildrensQuery&variables=%7B%22postName%22%3A%22${slug}%22%7D&extensions=%7B%7D`,
|
|
||||||
{
|
|
||||||
method: "GET",
|
|
||||||
headers: {
|
|
||||||
"Wp-site": "Naomi's Art for Palestine Bot",
|
|
||||||
},
|
|
||||||
}
|
|
||||||
);
|
|
||||||
const res = (await req.json()) as {
|
|
||||||
data: {
|
|
||||||
article: {
|
|
||||||
children: number[];
|
|
||||||
};
|
|
||||||
};
|
|
||||||
};
|
|
||||||
return res.data.article.children;
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in fetching article children: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
const getArticleInfo = async (bot: ExtendedClient, postId: number) => {
|
|
||||||
try {
|
|
||||||
const req = await fetch(
|
|
||||||
`https://www.aljazeera.com/graphql?wp-site=aje&operationName=LiveBlogUpdateQuery&variables=%7B%22postID%22%3A${postId}%2C%22postType%22%3A%22liveblog-update%22%2C%22preview%22%3A%22%22%2C%22isAmp%22%3Afalse%7D&extensions=%7B%7D`
|
|
||||||
);
|
|
||||||
const res = (await req.json()) as {
|
|
||||||
data: {
|
|
||||||
posts: {
|
|
||||||
link: string;
|
|
||||||
title: string;
|
|
||||||
id: string;
|
|
||||||
};
|
|
||||||
};
|
|
||||||
};
|
|
||||||
return res.data.posts;
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in fetching article info: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
return null;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Fetches the GraphQL feed from Aljazeera's Palestine live feed.
|
|
||||||
*
|
|
||||||
* @param {ExtendedClient} bot The bot's Discord instance.
|
|
||||||
*/
|
|
||||||
export const getNewsFeed = async (bot: ExtendedClient) => {
|
|
||||||
try {
|
|
||||||
const headline = await getHeadlineArticle(bot);
|
|
||||||
if (!headline) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const children = await getArticleChildren(
|
|
||||||
bot,
|
|
||||||
headline.split("/").slice(-1).join()
|
|
||||||
);
|
|
||||||
if (!children) {
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (!bot.lastArticle) {
|
|
||||||
bot.lastArticle = children[0];
|
|
||||||
await bot.debug.send(
|
|
||||||
`No cache found. Caching ${children[0]} and skipping run.`
|
|
||||||
);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const laterChildren = children.slice(0, children.indexOf(bot.lastArticle));
|
|
||||||
bot.lastArticle = children[0];
|
|
||||||
for (const postId of laterChildren) {
|
|
||||||
const article = await getArticleInfo(bot, postId);
|
|
||||||
if (!article) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
await bot.news.send(
|
|
||||||
`[${article.title}](<https://www.aljazeera.com${article.link.replace(
|
|
||||||
/\/$/,
|
|
||||||
""
|
|
||||||
)}?update=${article.id}>)\n--------`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
await bot.debug.send(
|
|
||||||
`Error in fetching news feed: ${(err as Error).message}`
|
|
||||||
);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
@ -1,10 +0,0 @@
|
|||||||
import { Webhooks } from "../config/Webhooks";
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Checks if the webhook ID is present in the enum.
|
|
||||||
*
|
|
||||||
* @param {string} id The ID to check.
|
|
||||||
* @returns {boolean} If the webhook ID is valid.
|
|
||||||
*/
|
|
||||||
export const isValidWebhook = (id: string): id is Webhooks =>
|
|
||||||
(Object.values(Webhooks) as string[]).includes(id);
|
|
||||||
@ -1,24 +0,0 @@
|
|||||||
import { createLogger, format, transports, config } from "winston";
|
|
||||||
|
|
||||||
const { combine, timestamp, colorize, printf } = format;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Standard log handler, using winston to wrap and format
|
|
||||||
* messages. Call with `logHandler.log(level, message)`.
|
|
||||||
*
|
|
||||||
* @param {string} level - The log level to use.
|
|
||||||
* @param {string} message - The message to log.
|
|
||||||
*/
|
|
||||||
export const logHandler = createLogger({
|
|
||||||
levels: config.npm.levels,
|
|
||||||
level: "silly",
|
|
||||||
transports: [new transports.Console()],
|
|
||||||
format: combine(
|
|
||||||
timestamp({
|
|
||||||
format: "YYYY-MM-DD HH:mm:ss",
|
|
||||||
}),
|
|
||||||
colorize(),
|
|
||||||
printf((info) => `${info.level}: ${[info.timestamp]}: ${info.message}`)
|
|
||||||
),
|
|
||||||
exitOnError: false,
|
|
||||||
});
|
|
||||||
@ -1,7 +0,0 @@
|
|||||||
import { assert } from "chai";
|
|
||||||
|
|
||||||
suite("This is an example test", () => {
|
|
||||||
test("It uses the assert API", () => {
|
|
||||||
assert.isTrue(true);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
@ -1,8 +0,0 @@
|
|||||||
{
|
|
||||||
"extends": "@nhcarrigan/typescript-config",
|
|
||||||
"compilerOptions": {
|
|
||||||
"rootDir": "./src",
|
|
||||||
"outDir": "./prod"
|
|
||||||
},
|
|
||||||
"exclude": ["./test"]
|
|
||||||
}
|
|
||||||
Loading…
x
Reference in New Issue
Block a user