Compare commits

..

16 Commits

Author SHA1 Message Date
81c1ce886b Disable dynamic bot status 2026-01-26 09:23:22 +01:00
2cc35f659e Remote legacy cleanup jobs 2026-01-26 09:03:33 +01:00
52f12ffac7 Fix budget set function typo 2026-01-19 15:04:53 +01:00
53ac0f4b79 Make budget view non ephemeral 2026-01-19 14:58:51 +01:00
de9767f0bf Add budget view command 2026-01-19 14:58:01 +01:00
745e709bef Add basic receipt logging 2026-01-19 13:59:06 +01:00
e5933aacc2 WIP: receipt feature implementation 2026-01-19 08:47:21 +01:00
333f3d94bf CleanupMessages: Handle missing permissions for local testing 2026-01-17 18:15:06 +01:00
00210a03cf DB: Switch to better-sqlite3 2026-01-17 18:14:22 +01:00
2e4147abec Receipt Timer: Changed date format 2026-01-17 14:01:46 +01:00
fbdcef7bca Add receipt day announcements 2026-01-17 13:47:15 +01:00
f29abd9df4 Return sticker url with size 1024 2024-11-26 11:58:38 +00:00
f55bd3d98a Send linkTrack errors to interaction channel 2024-04-08 23:01:34 +02:00
e957444000 Add data folder to gitignore 2024-04-08 22:58:17 +02:00
a1c22295f6 Track Link formatting changes 2024-04-06 01:02:21 +02:00
4e1ec14272 Add jellyfin handling 2024-04-06 01:01:46 +02:00
15 changed files with 682 additions and 1232 deletions

1
.gitignore vendored
View File

@@ -2,3 +2,4 @@ node_modules/
config.json config.json
old/ old/
bot.log bot.log
data/

View File

@@ -0,0 +1,108 @@
const { SlashCommandBuilder, EmbedBuilder } = require('discord.js');
module.exports = {
category: 'utility',
global: true,
data: new SlashCommandBuilder()
.setName('budget')
.setDescription('The thing')
.addSubcommand(subcommand =>
subcommand
.setName('set')
.setDescription('Set weekly budget')
.addIntegerOption(option =>
option.setName('amount')
.setRequired(true)
.setDescription('Amount as int'))
.addBooleanOption(option =>
option.setName('override')
.setRequired(false)
.setDescription('Override budget of current period'))
)
.addSubcommand(subcommand =>
subcommand
.setName('view')
.setDescription('View your grocery spendings for the current or previous week')
.addBooleanOption(option =>
option
.setName('lastweek')
.setDescription('Show spendings from the previous budget cycle instead of the current one')
.setRequired(false)
)
),
async execute(interaction) {
console.log('budget command entrypoint');
let db = await interaction.client.localDB;
let discordId = interaction.member.id;
console.log(db, discordId);
let allowed = ['372115788498468864', '222457277708369928'].includes(discordId);
console.log(allowed);
if (!allowed) {
console.log('budget command denied');
await interaction.reply('This command may only be invoked by Miffy!');
return;
}
console.log(`Switcching on sub ${interaction.options.getSubcommand()}`);
switch (interaction.options.getSubcommand()) {
case 'set':
console.log('budget command set');
let override = interaction.options.getBoolean('override') ?? false;
let budget = interaction.options.get('amount').value;
db.prepare(`INSERT OR REPLACE INTO bot_config (id, weekly_budget) VALUES (1, ?)`).run(budget);
if (override) {
db.prepare(`
UPDATE weekly_budgets
SET budget_amount = ?
WHERE id = (
SELECT id FROM weekly_budgets
WHERE date('now', 'localtime') BETWEEN start_date AND end_date
ORDER BY id DESC
LIMIT 1
)`).run(budget);
}
await interaction.reply(`Budget set to ${budget}.`);
break;
case 'view':
const currentBudget = db.prepare(`
SELECT id, budget_amount, exchange_rate, start_date, end_date
FROM weekly_budgets
WHERE date('now', 'localtime') BETWEEN start_date AND end_date
LIMIT 1
`).get();
const userSpendings = db.prepare(`
SELECT amount, message_raw
FROM grocery_spendings
WHERE budget_id = ? AND discord_id = ?
`).all(currentBudget.id, interaction.member.id);
const totalSpentEur = userSpendings.reduce((acc, s) => {
return acc + s.amount;
}, 0);
const remainingEur = currentBudget.budget_amount - totalSpentEur;
const remainingSek = remainingEur * currentBudget.exchange_rate;
const todayTimestamp = Math.floor(Date.now() / 1000);
const endTimestamp = Math.floor(new Date(`${currentBudget.end_date}T23:59:59`).getTime() / 1000);
const budgetEmbed = new EmbedBuilder()
.setColor(remainingEur > 0 ? 0x00ff00 : 0xff0000)
.setTitle(`${interaction.member.displayName} Budget as of <t:${todayTimestamp}:F>`)
.setDescription(`Period: \`${currentBudget.start_date}\` to \`${currentBudget.end_date}\`\nReset <t:${endTimestamp}:R>`)
.addFields(
{ name: 'Spent', value: `${totalSpentEur.toFixed(2)}\n${(totalSpentEur * currentBudget.exchange_rate).toFixed(2)} kr`, inline: true },
{ name: 'Remaining', value: `${remainingEur.toFixed(2)}\n${remainingSek.toFixed(2)} kr`, inline: true },
)
.setFooter({ text: `Exchange rate this week: 1 € = ${currentBudget.exchange_rate} kr` })
.setTimestamp();
await interaction.reply({ embeds: [budgetEmbed] });
break
default:
await interaction.reply(`Sub mismatch. Switching on ${interaction.options.getSubcommand()}`);
break;
}
},
};

View File

@@ -63,7 +63,7 @@ module.exports = {
collector.on('collect', m => { collector.on('collect', m => {
m.stickers.forEach(sticker => { m.stickers.forEach(sticker => {
stickers.push(`https://media.discordapp.net/stickers/${sticker.id}.png`); stickers.push(`https://media.discordapp.net/stickers/${sticker.id}.png?size=1024`);
collector.stop(); collector.stop();
}); });
}); });

View File

@@ -41,10 +41,6 @@ module.exports = {
option.setName('songname') option.setName('songname')
.setDescription('Override song name, otherwise uses name from Spotify') .setDescription('Override song name, otherwise uses name from Spotify')
.setRequired(false)) .setRequired(false))
.addStringOption(option =>
option.setName('footer_override')
.setDescription('Custom footer')
.setRequired(false))
.addAttachmentOption(option => .addAttachmentOption(option =>
option.setName('cover_override') option.setName('cover_override')
.setDescription('Uses this image instead of Spotofy metadata') .setDescription('Uses this image instead of Spotofy metadata')
@@ -54,6 +50,7 @@ module.exports = {
clientSecret: spotify.clientSecret, clientSecret: spotify.clientSecret,
}), }),
async execute(interaction) { async execute(interaction) {
try {
let token = await this.spotifyAPI.clientCredentialsGrant().then( let token = await this.spotifyAPI.clientCredentialsGrant().then(
function(data) { function(data) {
return data.body['access_token']; return data.body['access_token'];
@@ -97,12 +94,20 @@ module.exports = {
links.push(`[<:ytbm:1224704771248750622> Youtube ](${url})`); links.push(`[<:ytbm:1224704771248750622> Youtube ](${url})`);
continue; continue;
} }
if (url.startsWith('https://jelly.')) {
links.push(`[<:jelly:1225931843279519905> Jellyfin (${url.split('.')[1]}) ](${url})`);
continue;
}
if (url.startsWith('https://soundcloud.com/') || url.startsWith('https://m.soundcloud.com/')) {
links.push(`[<:soundcld:1225702702135119902> Soundcloud ](${url})`);
continue;
}
} }
if(spotifyID) { if(spotifyID) {
let spotifyTrack = await this.spotifyAPI.getTrack(spotifyID); let spotifyTrack = await this.spotifyAPI.getTrack(spotifyID);
trackEmbed.setImage(spotifyTrack['body'].album.images[0].url); trackEmbed.setThumbnail(spotifyTrack['body'].album.images[0].url);
songName = spotifyTrack['body'].name; songName = spotifyTrack['body'].name;
mainArtist = spotifyTrack['body'].artists[0].name; mainArtist = spotifyTrack['body'].artists[0].name;
artists = spotifyTrack['body'].artists.map(a => a.name).join(', '); artists = spotifyTrack['body'].artists.map(a => a.name).join(', ');
@@ -111,7 +116,7 @@ module.exports = {
} }
if(interaction.options.getAttachment('cover_override')) { if(interaction.options.getAttachment('cover_override')) {
trackEmbed.setImage(interaction.options.getAttachment('cover_override').url); trackEmbed.setThumbnail(interaction.options.getAttachment('cover_override').url);
} }
songName = interaction.options.getString('songname', false) ?? songName; songName = interaction.options.getString('songname', false) ?? songName;
artists = interaction.options.getString('artist', false) ?? artists; artists = interaction.options.getString('artist', false) ?? artists;
@@ -122,12 +127,11 @@ module.exports = {
trackEmbed.setTitle(`${title}`); trackEmbed.setTitle(`${title}`);
let submitterName = interaction.member.displayName; let submitterName = interaction.member.displayName;
let footer = interaction.options.getString('footer_override', false) ?? `Submitted by ${submitterName}`; let footer = `Submitted by ${submitterName} `;
trackEmbed.setFooter({text: footer });
if(interaction.options.getString('rating', false)) { if(interaction.options.getString('rating', false)) {
trackEmbed.addFields( trackEmbed.addFields(
{ name: `${submitterName} rated this`, value: `${interaction.options.getString('rating', false)} out of 10`, inline: true }, { name: `${submitterName} rated this`, value: `${interaction.options.getString('rating', false)} out of **10**`, inline: true },
) )
} }
@@ -138,7 +142,7 @@ module.exports = {
if(interaction.options.getInteger('scrobbles', false) || lfmData.data['track']?.['userplaycount'] > 0) { if(interaction.options.getInteger('scrobbles', false) || lfmData.data['track']?.['userplaycount'] > 0) {
trackEmbed.addFields( trackEmbed.addFields(
{ name: `${submitterName} scrobbled this`, value: `${interaction.options.getInteger('scrobbles', false) ?? lfmData.data['track']['userplaycount']} times so far`, inline: true }, { name: `${submitterName} scrobbled this`, value: `**${interaction.options.getInteger('scrobbles', false) ?? lfmData.data['track']['userplaycount']}** times so far`, inline: true },
) )
} }
@@ -148,28 +152,23 @@ module.exports = {
console.log(tags); console.log(tags);
let listeners = this.numToHumanReadable(lfmData.data['track']['listeners']); let listeners = this.numToHumanReadable(lfmData.data['track']['listeners']);
let globalScrobbles = this.numToHumanReadable(lfmData.data['track']['playcount']); let globalScrobbles = this.numToHumanReadable(lfmData.data['track']['playcount']);
footer += `∘ Listeners: ${listeners} • Scrobbles: ${globalScrobbles}`;
trackEmbed.addFields( let tagContent = '';
{ name: `LFM Global`, value: `Listeners: ${listeners} • Scrobbles: ${globalScrobbles}\n`, inline: false },
)
let tagHeader = 'Tags';
if(tags.length === 0) { if(tags.length === 0) {
//artist tag fallback //artist tag fallback
let lfmArtistTags = await axios.get(`https://ws.audioscrobbler.com/2.0/?method=artist.getTopTags&api_key=${lfmKey}&artist=${mainArtist}&format=json`); let lfmArtistTags = await axios.get(`https://ws.audioscrobbler.com/2.0/?method=artist.getTopTags&api_key=${lfmKey}&artist=${mainArtist}&format=json`);
console.log(lfmArtistTags); console.log(lfmArtistTags);
tags = lfmArtistTags.data['toptags']['tag'].map(a => a.name); tags = lfmArtistTags.data['toptags']['tag'].map(a => a.name);
tagHeader = `Artist ${tagHeader}`;
} }
if(tags) { if(tags.length > 1) {
tags = this.joinLineBreak(tags, ', ', 4); tags = this.joinLineBreak(tags, ', ', 3);
trackEmbed.addFields( trackEmbed.addFields(
{ name: `${tagHeader}`, value: `${tags.substr(0,60)}${tags.length > 60 ? '...' : ''}`, inline: true }, { name: `Tags`, value: `${tags.substr(0,60)}${tags.length > 60 ? '...' : ''}`, inline: true },
) )
} }
}
description = `${description}\n${this.joinLineBreak(links, ' ∘ ', 3)}` }
if(!description) { if(!description) {
await interaction.reply({content: 'Sorry, no valid link has bee supplied.', ephemeral: true }); await interaction.reply({content: 'Sorry, no valid link has bee supplied.', ephemeral: true });
@@ -177,11 +176,20 @@ module.exports = {
} }
trackEmbed.setDescription(description); trackEmbed.setDescription(description);
trackEmbed.addFields(
{ name: 'Links', value: `${this.joinLineBreak(links, ' ∘ ', 4)}` }
);
trackEmbed.setFooter({text: footer });
interaction.channel.send({ embeds: [trackEmbed] }); interaction.channel.send({ embeds: [trackEmbed] });
let response = await interaction.reply({content: 'done', ephemeral: true}); let response = await interaction.reply({content: 'done', ephemeral: true});
await response.delete(); await response.delete();
} catch (error) {
await interaction.reply(`# FUCK \n ${JSON.stringify(error)}`.substring(0,200));
}
}, },
numToHumanReadable: function(num) { numToHumanReadable: function(num) {
if (num > 1000000 ) { if (num > 1000000 ) {

View File

@@ -1,20 +1,21 @@
const fs = require("fs"); const fs = require("fs");
const sqlite3 = require("sqlite3").verbose(); const Database = require("better-sqlite3");
const path = require("path");
const { open } = require('sqlite'); const { open } = require('sqlite');
const filepath = "./data/minzbot.db"; const filepath = "./data/minzbot.db";
async function createDbConnection() { async function createDbConnection() {
if (fs.existsSync(filepath)) { const dir = path.dirname(filepath);
//new sqlite3.Database(filepath); if (!fs.existsSync(dir)) {
const db = await open({filename: filepath, driver: sqlite3.Database}); fs.mkdirSync(dir, { recursive: true });
await initDB(db);
return db;
} else {
const db = await open({filename: filepath, driver: sqlite3.Database});
await initDB(db);
console.log("[DATABASE] Connection with SQLite has been established");
return db;
} }
const db = new Database(filepath, { verbose: console.log });
initDB(db);
console.log("[DATABASE] Connection with better-sqlite3 established");
return db;
} }
async function initDB(db) { async function initDB(db) {
@@ -33,7 +34,45 @@ async function initDB(db) {
lastfm_name TEXT lastfm_name TEXT
); );
`); `);
await db.exec(`
CREATE TABLE IF NOT EXISTS bot_config (
id INTEGER PRIMARY KEY CHECK (id = 1),
weekly_budget REAL DEFAULT 0,
last_date_msg_receipts DATE NOT NULL DEFAULT CURRENT_TIMESTAMP
);
`);
await db.exec(`
CREATE TABLE IF NOT EXISTS grocery_spendings (
id INTEGER PRIMARY KEY AUTOINCREMENT,
discord_id VARCHAR(50) NOT NULL,
message_id VARCHAR(50) NOT NULL,
message_raw TEXT DEFAULT "-",
amount DECIMAL(10, 2) NOT NULL,
created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
budget_id INTEGER,
FOREIGN KEY (budget_id) REFERENCES weekly_budgets(id)
);
`);
await db.exec(`
CREATE TABLE IF NOT EXISTS weekly_budgets (
id INTEGER PRIMARY KEY AUTOINCREMENT,
start_date DATE NOT NULL,
end_date DATE NOT NULL,
budget_amount DECIMAL(10, 2) NOT NULL,
exchange_rate DECIMAL(10, 6) NOT NULL,
created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
CONSTRAINT date_check CHECK (end_date > start_date)
);
CREATE INDEX IF NOT EXISTS idx_budget_dates ON weekly_budgets (start_date, end_date);
`);
await db.exec(`
INSERT OR IGNORE INTO bot_config (id, weekly_budget)
VALUES (1, 10);
`);
console.log('[DATABASE] Created new DB table'); console.log('[DATABASE] Created new DB table');
} }
module.exports = createDbConnection(); module.exports = createDbConnection;

View File

@@ -36,14 +36,14 @@ const rest = new REST().setToken(token);
// and deploy your commands! // and deploy your commands!
(async () => { (async () => {
try { try {
console.log(`[GUILD] Started refreshing ${guildCommands.length} application (/) commands.`); console.log(`[GUILD] Started refreshing ${guildCommands.length} Guild (/) commands.`);
let data = await rest.put( let data = await rest.put(
Routes.applicationGuildCommands(clientId, guildId), Routes.applicationGuildCommands(clientId, guildId),
{ body: guildCommands }, { body: guildCommands },
); );
console.log(`[GUILD] Successfully reloaded ${data.length} application (/) commands.`); console.log(`[GUILD] Successfully reloaded ${data.length} Guild (/) commands.`);
console.log(`[GLOBAL] Started refreshing ${globalCommands.length} application (/) commands.`); console.log(`[GLOBAL] Started refreshing ${globalCommands.length} application (/) commands.`);

View File

@@ -0,0 +1,104 @@
const { Events, channelLink, discordSort } = require('discord.js');
module.exports = {
name: Events.MessageCreate,
async execute(message) {
if (message.author.bot) return;
if(message.channel.id === '1462060674766344370') {
const CURRENCY_MAP = {
"222457277708369928": "EUR", // Minz
"372115788498468864": "SEK", // Miffy
};
let reply = "";
let db = await message.client.localDB;
const receiptsChannel = message.channel;
const authorId = message.author.id;
const currentBudget = db.prepare(`
SELECT id, exchange_rate, budget_amount FROM weekly_budgets
WHERE date('now', 'localtime') BETWEEN start_date AND end_date
ORDER BY created_at DESC
LIMIT 1
`).get();
if (message.content === "fuck") {
let lastSpend = db.prepare(`
SELECT id, amount, message_raw, created_at
FROM grocery_spendings
WHERE discord_id = ? AND budget_id = ?
ORDER BY created_at DESC, id DESC
LIMIT 1
`).get(authorId, currentBudget.id);
if (lastSpend) {
db.prepare(`DELETE FROM grocery_spendings WHERE id = ?`).run(lastSpend.id);
await message.reply(`Your last spending of ${lastSpend.amount.toFixed(2)}€ has been deleted.`);
} else {
await message.reply("You don't have any entries within the current budgeting period!");
}
return;
}
let matches = [];
let lines = message.content.split("\n");
let additionalSpent = 0.0;
lines.forEach(line => {0
if (line.startsWith('-')) {
console.log(`Matching on line ${line}`);
const regex = /-(?=[0-9])([0-9]*[.,]?[0-9]*)/m;
let match = regex.exec(line)
console.log(match);
if (match) {
additionalSpent = additionalSpent + parseFloat(match[1].replace(',', '.'));
}
}
});
if (additionalSpent > 0) {
const currency = CURRENCY_MAP[authorId] || "EUR"
switch (currency) {
case "SEK":
additionalSpent = additionalSpent / currentBudget.exchange_rate;
break;
default:
break;
}
db.prepare(`
INSERT INTO grocery_spendings (
discord_id,
message_id,
message_raw,
amount,
budget_id
) VALUES (?, ?, ?, ?, ?)
`).run(
authorId,
message.id,
message.content,
additionalSpent,
currentBudget.id
);
const allSpendings = db.prepare(`
SELECT amount
FROM grocery_spendings
WHERE budget_id = ? AND discord_id = ?
`).all(currentBudget.id, authorId);
const totalSpent = allSpendings.reduce((acc, entry) => {
return acc + entry.amount;
}, 0);
reply = `${message.author.globalName} spent ${additionalSpent}€ / ${(additionalSpent * currentBudget.exchange_rate).toFixed(2)} kr of their budget.\nThey have ${currentBudget.budget_amount - totalSpent}€ / ${((currentBudget.budget_amount - totalSpent) * currentBudget.exchange_rate).toFixed(2)} kr remaining.`;
await message.reply(reply);
}
}
},
};

38
main.js
View File

@@ -2,24 +2,27 @@ const fs = require('node:fs');
const path = require('node:path'); const path = require('node:path');
const { Client, Collection, Events, GatewayIntentBits, Options, Partials } = require('discord.js'); const { Client, Collection, Events, GatewayIntentBits, Options, Partials } = require('discord.js');
const { token } = require('./config.json'); const { token } = require('./config.json');
const createDbConnection = require('./core/db.js');
const localDB = require('./core/db');
const client = new Client({ async function entrypoint() {
const localDB = await createDbConnection();
const client = new Client({
intents: [GatewayIntentBits.Guilds, GatewayIntentBits.MessageContent, GatewayIntentBits.GuildMessages, GatewayIntentBits.GuildMembers, GatewayIntentBits.GuildPresences, GatewayIntentBits.GuildMessageReactions], intents: [GatewayIntentBits.Guilds, GatewayIntentBits.MessageContent, GatewayIntentBits.GuildMessages, GatewayIntentBits.GuildMembers, GatewayIntentBits.GuildPresences, GatewayIntentBits.GuildMessageReactions],
partials: [Partials.Message, Partials.Channel, Partials.Reaction], partials: [Partials.Message, Partials.Channel, Partials.Reaction],
sweepers: { sweepers: {
...Options.DefaultSweeperSettings, ...Options.DefaultSweeperSettings,
reactions: { interval: 300, filter: () => () => { return true } } reactions: { interval: 300, filter: () => () => { return true } }
} }
}); });
client.localDB = localDB; client.localDB = localDB;
client.commands = new Collection(); client.commands = new Collection();
const foldersPath = path.join(__dirname, 'commands'); const foldersPath = path.join(__dirname, 'commands');
const commandFolders = fs.readdirSync(foldersPath); const commandFolders = fs.readdirSync(foldersPath);
for (const folder of commandFolders) { for (const folder of commandFolders) {
const commandsPath = path.join(foldersPath, folder); const commandsPath = path.join(foldersPath, folder);
const commandFiles = fs.readdirSync(commandsPath).filter(file => file.endsWith('.js')); const commandFiles = fs.readdirSync(commandsPath).filter(file => file.endsWith('.js'));
for (const file of commandFiles) { for (const file of commandFiles) {
@@ -31,12 +34,12 @@ for (const folder of commandFolders) {
console.log(`[WARNING] The command at ${filePath} is missing a required "data" or "execute" property.`); console.log(`[WARNING] The command at ${filePath} is missing a required "data" or "execute" property.`);
} }
} }
} }
const eventsPath = path.join(__dirname, 'events'); const eventsPath = path.join(__dirname, 'events');
const eventFiles = fs.readdirSync(eventsPath).filter(file => file.endsWith('.js')); const eventFiles = fs.readdirSync(eventsPath).filter(file => file.endsWith('.js'));
for (const file of eventFiles) { for (const file of eventFiles) {
const filePath = path.join(eventsPath, file); const filePath = path.join(eventsPath, file);
const event = require(filePath); const event = require(filePath);
if (event.once) { if (event.once) {
@@ -45,9 +48,9 @@ for (const file of eventFiles) {
console.log(`Registered event ${event.name} ${file}`); console.log(`Registered event ${event.name} ${file}`);
client.on(event.name, (...args) => event.execute(...args)); client.on(event.name, (...args) => event.execute(...args));
} }
} }
client.on(Events.ClientReady, () => { client.on(Events.ClientReady, () => {
//setup timers //setup timers
const timersPath = path.join(__dirname, 'timers'); const timersPath = path.join(__dirname, 'timers');
const timerFiles = fs.readdirSync(timersPath).filter(file => file.endsWith('.js')); const timerFiles = fs.readdirSync(timersPath).filter(file => file.endsWith('.js'));
@@ -61,6 +64,9 @@ client.on(Events.ClientReady, () => {
timer.instance = timerInstance; timer.instance = timerInstance;
if (timer.immediate) { timer.tick(client, timer) } if (timer.immediate) { timer.tick(client, timer) }
} }
}); });
client.login(token); client.login(token);
};
entrypoint();

0
notes Normal file
View File

1007
package-lock.json generated

File diff suppressed because it is too large Load Diff

View File

@@ -1,11 +1,11 @@
{ {
"dependencies": { "dependencies": {
"axios": "^1.6.8", "axios": "^1.6.8",
"better-sqlite3": "^12.6.2",
"discord.js": "^14.13.0", "discord.js": "^14.13.0",
"dotenv": "^16.3.1", "dotenv": "^16.3.1",
"spotify-web-api-node": "^5.0.2", "spotify-web-api-node": "^5.0.2",
"sqlite": "^5.1.1", "sqlite": "^5.1.1"
"sqlite3": "^5.1.7"
}, },
"name": "minzbot", "name": "minzbot",
"description": "Successor of the Discord.py implementation", "description": "Successor of the Discord.py implementation",

View File

@@ -9,6 +9,7 @@ module.exports = {
animeList: ["K-On!", "Spice and Wolf", "Bakemonogatari", "Your Lie in April", "Noragami", "Puella Magi Madoka Magica", "Akame ga Kill!", "Steins;Gate", "\u3086\u308b\u30ad\u30e3\u30f3\u25b3"] animeList: ["K-On!", "Spice and Wolf", "Bakemonogatari", "Your Lie in April", "Noragami", "Puella Magi Madoka Magica", "Akame ga Kill!", "Steins;Gate", "\u3086\u308b\u30ad\u30e3\u30f3\u25b3"]
}, },
async tick(client, timer) { async tick(client, timer) {
return;
client.user.setActivity(timer.data.animeList[timer.data.statusIndex], { type: ActivityType.Watching }); client.user.setActivity(timer.data.animeList[timer.data.statusIndex], { type: ActivityType.Watching });
timer.data.statusIndex = (timer.data.statusIndex + 1) % timer.data.animeList.length timer.data.statusIndex = (timer.data.statusIndex + 1) % timer.data.animeList.length
}, },

View File

@@ -8,13 +8,10 @@ module.exports = {
const keepMessageEmoteId = '1214140438265724980'; const keepMessageEmoteId = '1214140438265724980';
const channelConfigs = [ const channelConfigs = [
{ channelId: '1214134516247957504', keepTimeMinutes: 2, keepAttachment: true }, //toho-test/mnzbot-test { channelId: '1214134516247957504', keepTimeMinutes: 2, keepAttachment: true }, //toho-test/mnzbot-test
{ channelId: '1111054421091155978', keepTimeMinutes: 2880 }, //cotr/Spam
{ channelId: '1170190197384814762', keepTimeMinutes: 2880, keepAttachment: true }, //cotr/Red
{ channelId: '1101703550070947920', keepTimeMinutes: 2880, keepAttachment: true }, //cotr/Memes
]; ];
function isMessageLocked(message) { function isMessageLocked(message) {
for(const [id, reaction] of message.reactions.cache) { for (const [id, reaction] of message.reactions.cache) {
if(id === keepMessageEmoteId) { if (id === keepMessageEmoteId) {
return true; return true;
} }
} }
@@ -22,26 +19,28 @@ module.exports = {
return false; return false;
} }
for (let i = 0; i < channelConfigs.length; i++) { for (let i = 0; i < channelConfigs.length; i++) {
try {
const config = channelConfigs[i]; const config = channelConfigs[i];
const channel = await client.channels.fetch(config.channelId); const channel = await client.channels.fetch(config.channelId);
console.log(`[TIMER] Running cleanup task for ${channel.guild.name}/${channel.name}`); console.log(`[TIMER] Running cleanup task for ${channel.guild.name}/${channel.name}`);
channel.messages.fetch({ limit: 100 }).then(messages => { channel.messages.fetch({ limit: 100 }).then(messages => {
messages.forEach(message => { messages.forEach(message => {
if(isMessageLocked(message)) { if (isMessageLocked(message)) {
//skip if message has mnzboKeepMessage reaction //skip if message has mnzboKeepMessage reaction
console.log(`[LOCKED] [${message.guild.name}/${message.channel.name}] | ${message.author.globalName}: ${message.content}`); console.log(`[LOCKED] [${message.guild.name}/${message.channel.name}] | ${message.author.globalName}: ${message.content}`);
return; return;
} }
if(message.attachments.size > 0 && config.keepAttachment) { if (message.attachments.size > 0 && config.keepAttachment) {
//Skip messages with attachment //Skip messages with attachment
return; return;
} }
let ageInMinutes = Math.ceil((Date.now() - message.createdTimestamp) / 1000 / 60); let ageInMinutes = Math.ceil((Date.now() - message.createdTimestamp) / 1000 / 60);
if(ageInMinutes < config.keepTimeMinutes) { if (ageInMinutes < config.keepTimeMinutes) {
//Skip messages posted within last 48 Hours //Skip messages posted within last 48 Hours
return; return;
} }
@@ -50,6 +49,9 @@ module.exports = {
message.delete(); message.delete();
}); });
}); });
} catch (error) {
console.log(`[CLEANUP] Failed for ${channelConfigs[i].channelId}`);
}
} }
}, },
}; };

View File

@@ -1,78 +0,0 @@
const db = require("../core/db");
async function fetchAnniversary(id) {
console.log(await db);
let query = await db.prepare(`SELECT * FROM anniversaries WHERE discord_id = ?`)
return await query.get(id);
}
function insertNewMember(member) {
db.run(
`INSERT INTO anniversaries (name, guild_id, discord_id, last_anniversary_notification) VALUES (?, ?, ?, ?)`,
[member.user.username, member.guild.id, member.id, Date.now()],
function (error) {
if (error) {
console.error(error.message);
}
console.log(`Inserted a row with the ID: ${this.lastID}`);
}
);
}
function isAnniversary(date) {
const now = new Date("Thu Nov 11 2024");// new Date();
console.log(`${date.getDate()} - ${now.getDate()}`);
return date.getDate() === now.getDate() && date.getMonth() === now.getMonth();
}
function getTimeSince(date) {
const now = new Date();
const diff = now - date; // `date` is already a Date object
const seconds = Math.floor(diff / 1000);
const minutes = Math.floor(seconds / 60);
const hours = Math.floor(minutes / 60);
const days = Math.floor(hours / 24);
const weeks = Math.floor(days / 7);
const months = Math.floor(days / 30);
const years = Math.floor(days / 365);
if (years > 0) return `${years} years ago`;
if (months > 0) return `${months} months ago`;
if (weeks > 0) return `${weeks} weeks ago`;
if (days > 0) return `${days} days ago`;
if (hours > 0) return `${hours} hours ago`;
if (minutes > 0) return `${minutes} minutes ago`;
return `${seconds} seconds ago`;
}
module.exports = {
timeout: 60000,
immediate: true,
name: 'Daily member anniversary check',
async tick(client, timer) {
return;
console.log(`[TIMER] Anniversary Check`);
let debugChannel = await client.channels.fetch('1214134516247957504');
let subscribedChannels = [
{ guild: '442059309581336578', channel: '1214134516247957504' } //toho-test
]
for (let channelIndex = 0; channelIndex < subscribedChannels.length; channelIndex++) {
const guild = await client.guilds.fetch(subscribedChannels[channelIndex].guild);
const channel = await client.channels.fetch(subscribedChannels[channelIndex].channel);
let guildMembers = await guild.members.fetch();
guildMembers.forEach(member => {
if(isAnniversary(member.joinedAt)) {
//debugChannel.send(`Upcoming anniversary ${member.displayName} ${member.joinedAt} ${getTimeSince(member.joinedAt)}`);
console.log(`User anniversary ${member.displayName} ${member.joinedAt} ${getTimeSince(member.joinedAt)}`);
let dbEntry = fetchAnniversary(member.id);
console.log(dbEntry);
}
});
}
},
};

104
timers/receiptTimer.js Normal file
View File

@@ -0,0 +1,104 @@
module.exports = {
timeout: 1000,
immediate: false,
name: 'Receipt Day Announcements',
data: {
channelId: '1462060674766344370',
targetHour: 0,
targetMinute: 1
},
async tick(client, timer) {
try {
const today = new Date();
const lastMonday = new Date(today);
lastMonday.setDate(today.getDate() - ((today.getDay() === 0) ? 6 : today.getDay() - 1));
const startDate = lastMonday.toISOString().split('T')[0];
const nextSunday = new Date(lastMonday);
nextSunday.setDate(lastMonday.getDate() + 6);
const endDate = nextSunday.toISOString().split('T')[0];
// 0 1 2 3 4 5 6
// S M T W T F S
let db = await client.localDB;
const channel = await client.channels.fetch(timer.data.channelId);
const config = await (await db.prepare(`SELECT weekly_budget, last_date_msg_receipts FROM bot_config`).get());
const existingBudget = db.prepare(`SELECT id FROM weekly_budgets WHERE start_date = ?`).get(startDate);
if (!existingBudget) {
console.log(`No budget found for week starting ${startDate}.`);
const response = await fetch(`https://api.frankfurter.dev/v1/latest?amount=1&from=EUR&to=SEK`);
if (!response.ok) await channel.send(`Failed to fetch exchange rate:\n${response.statusText}`);
const data = await response.json();
//await channel.send(`Fetched new exchange rate:\n${JSON.stringify(data)}`);
await channel.send(`Reset weekly budget to ${config.weekly_budget}€ / ${config.weekly_budget*data.rates.SEK} kr`);
db.prepare(`
INSERT INTO weekly_budgets (start_date, end_date, budget_amount, exchange_rate)
VALUES (?, ?, ?, ?)
`).run(startDate, endDate, config.weekly_budget, data.rates.SEK);
} else {
console.log(`budget found for week starting ${startDate}.`);
}
const notification = db.prepare(`
SELECT EXISTS (
SELECT 1 FROM bot_config
WHERE date(last_date_msg_receipts) = date('now', 'localtime')
) as was_sent_today
`).get();
if (!notification.was_sent_today) {
const currentDate = new Date().toLocaleDateString('en-GB', {
weekday: 'long',
day: '2-digit',
month: '2-digit',
year: 'numeric'
});
await channel.send(`${currentDate}`);
console.log("No notification today, sending...");
db.prepare(`
UPDATE bot_config
SET last_date_msg_receipts = CURRENT_TIMESTAMP
WHERE id = 1
`).run();
} else {
console.log("Notification already sent");
}
} catch (error) {
console.error('[TIMER] Error:', error);
} finally {
// 2. Schedule the NEXT tick manually
await this.scheduleNext(client, timer);
}
},
async scheduleNext(client, timer) {
const now = new Date();
const next = new Date();
next.setHours(timer.data.targetHour, timer.data.targetMinute, 0, 0);
if (next <= now) {
next.setDate(next.getDate() + 1);
}
const delay = next.getTime() - now.getTime();
if (timer.instance) clearTimeout(timer.instance);
timer.instance = setTimeout(() => {
this.tick(client, timer);
}, delay);
const channel = await client.channels.fetch(timer.data.channelId);
//if (channel) await channel.send(`Next message scheduled for: ${next.toLocaleString()} with ms delta of ${delay} / ${delay/3600000}`);
console.log(`[TIMER] Next message scheduled for: ${next.toLocaleString()}`);
}
};