feat: move to sqlite

Author: GalvinPython

.env.example

@@ -9,13 +9,6 @@ DISCORD_DEV_TOKEN='YOUR_DISCORD_DEV_TOKEN'
 # YouTube API Key
 YOUTUBE_API_KEY='YOUR_YOUTUBE_API_KEY'
 
-# MySQL Database
-MYSQL_ADDRESS='YOUR_MYSQL_SERVER_ADDRESS'
-MYSQL_PORT='YOUR_MYSQL_SERVER_PORT'
-MYSQL_USER='YOUR_MYSQL_USER'
-MYSQL_PASSWORD='YOUR_MYSQL_PASSWORD'
-MYSQL_DATABASE='YOUR_DATABASE_NAME'
-
 # Twitch
 TWITCH_CLIENT_ID='YOUR_TWITCH_CLIENT_ID'
 TWITCH_CLIENT_SECRET='YOUR_TWITCH_CLIENT_SECRET'

.eslintrc.json

@@ -20,7 +20,7 @@
         "sourceType": "module"
     },
     "rules": {
-        "no-console": "warn",
+        // "no-console": "warn",
         "prettier/prettier": [
             "warn",
             {

.gitignore

@@ -1,5 +1,6 @@
 node_modules/
 .env
 
-# backups of database
-*.sql
+*.db
+*.sqlite
+*.sqlite3

README.md

@@ -52,7 +52,8 @@ Feedr requires Bun in order to work
 
 ## 1.3.0
 
-- WIP
+- Moved database to SQLite
+- Added Bluesky
 
 ## 1.2.0
 

bun.lockb

@@ -2,27 +2,29 @@
   "name": "videonotifier",
   "module": "src/index.ts",
   "type": "module",
-  "version": "1.3.0-wip",
+  "version": "1.3.0",
   "devDependencies": {
     "@types/bun": "1.1.10",
+    "@typescript-eslint/eslint-plugin": "8.11.0",
+    "@typescript-eslint/parser": "8.11.0",
     "eslint": "^8.57.0",
     "eslint-config-prettier": "9.1.0",
     "eslint-plugin-import": "^2.26.0",
     "eslint-plugin-node": "^11.1.0",
     "eslint-plugin-prettier": "5.2.1",
-    "eslint-plugin-unused-imports": "4.1.4",
-    "@typescript-eslint/eslint-plugin": "8.11.0",
-    "@typescript-eslint/parser": "8.11.0"
+    "eslint-plugin-unused-imports": "4.1.4"
   },
   "peerDependencies": {
     "typescript": "^5.0.0"
   },
   "scripts": {
+    "dev": "bun --watch . --dev",
+    "test:jetstream": "bun --watch src/utils/bluesky/jetstream.ts",
     "lint": "eslint . --ext .ts -c .eslintrc.json",
     "lint:fix": "eslint . --ext .ts -c .eslintrc.json --fix"
   },
   "dependencies": {
-    "discord.js": "^14.16.3",
-    "mysql2": "^3.11.3"
+    "cron": "^3.2.1",
+    "discord.js": "^14.16.3"
   }
 }

package.json

@@ -1,17 +1,18 @@
 // FILL IN THIS INFORMATION IN .ENV
 export const config: { [key: string]: string | number } = {
-    updateIntervalYouTube: process.env?.CONFIG_UPDATE_INTERVAL_YOUTUBE ? parseInt(process.env?.CONFIG_UPDATE_INTERVAL_YOUTUBE) * 1000 : 60_000,
-    updateIntervalTwitch: process.env?.CONFIG_UPDATE_INTERVAL_TWITCH ? parseInt(process.env?.CONFIG_UPDATE_INTERVAL_TWITCH) * 1000 : 60_000,
-}
+    updateIntervalYouTube: process.env?.CONFIG_UPDATE_INTERVAL_YOUTUBE
+        ? parseInt(process.env?.CONFIG_UPDATE_INTERVAL_YOUTUBE) * 1000
+        : 60_000,
+    updateIntervalTwitch: process.env?.CONFIG_UPDATE_INTERVAL_TWITCH
+        ? parseInt(process.env?.CONFIG_UPDATE_INTERVAL_TWITCH) * 1000
+        : 60_000,
+};
 
 export const env: { [key: string]: string | undefined } = {
-    discordToken: process.argv.includes('--dev') ? process.env?.DISCORD_DEV_TOKEN : process.env?.DISCORD_TOKEN,
+    discordToken: process.argv.includes("--dev")
+        ? process.env?.DISCORD_DEV_TOKEN
+        : process.env?.DISCORD_TOKEN,
     youtubeApiKey: process.env?.YOUTUBE_API_KEY,
-    mysqlAddress: process.env?.MYSQL_ADDRESS,
-    mysqlPort: process.env?.MYSQL_PORT,
-    mysqlUser: process.env?.MYSQL_USER,
-    mysqlPassword: process.env?.MYSQL_PASSWORD,
-    mysqlDatabase: process.env?.MYSQL_DATABASE,
     twitchClientId: process.env?.TWITCH_CLIENT_ID,
     twitchClientSecret: process.env?.TWITCH_CLIENT_SECRET,
-};
+};

src/config.ts

@@ -1,14 +1,16 @@
 import { Events } from "discord.js";
-import client from "..";
 
+import client from "..";
 import commandsMap from "../commands";
 
 client.on(Events.InteractionCreate, async (interaction) => {
-	if (interaction.isChatInputCommand()) {
-		const getCommand = commandsMap.get(interaction.commandName);
-		if (!getCommand) {
-			return console.log(`Command ${interaction.commandName} not found`);
-		}
-		return getCommand.execute(interaction);
-	}
-});
+    if (interaction.isChatInputCommand()) {
+        const getCommand = commandsMap.get(interaction.commandName);
+
+        if (!getCommand) {
+            return console.log(`Command ${interaction.commandName} not found`);
+        }
+
+        return getCommand.execute(interaction);
+    }
+});

src/events/commandHandler.ts

@@ -1,58 +1,57 @@
 // Check if all the required environment variables are set
-import { env } from './config.ts';
+import { env } from "./config.ts";
 
-if (!env.discordToken || env.discordToken === 'YOUR_DISCORD_TOKEN') {
-    throw new Error('You MUST provide a discord token in .env!');
+if (!env.discordToken || env.discordToken === "YOUR_DISCORD_TOKEN") {
+    throw new Error("You MUST provide a discord token in .env!");
 }
 
-if (!env.youtubeApiKey || env.youtubeApiKey === 'YOUR_YOUTUBE_API_KEY') {
-    throw new Error('You MUST provide a YouTube API key in .env!');
+if (!env.youtubeApiKey || env.youtubeApiKey === "YOUR_YOUTUBE_API_KEY") {
+    throw new Error("You MUST provide a YouTube API key in .env!");
 }
 
-if (!env.mysqlAddress || env.mysqlAddress === 'YOUR_MYSQL_SERVER_ADDRESS') {
-    throw new Error('You MUST provide a MySQL server address in .env!');
+if (!env.twitchClientId || env.twitchClientId === "YOUR_TWITCH_CLIENT_ID") {
+    throw new Error("You MUST provide a Twitch client ID in .env!");
 }
 
-if (!env.mysqlPort || env.mysqlPort === 'YOUR_MYSQL_SERVER_PORT') {
-    throw new Error('You MUST provide a MySQL server port in .env!');
+if (
+    !env.twitchClientSecret ||
+    env.twitchClientSecret === "YOUR_TWITCH_CLIENT_SECRET"
+) {
+    throw new Error("You MUST provide a Twitch client secret in .env!");
 }
 
-if (!env.mysqlUser || env.mysqlUser === 'YOUR_MYSQL_USER') {
-    throw new Error('You MUST provide a MySQL user in .env!');
-}
+// If everything is set up correctly, continue with the bot
+import {
+    Client,
+    GatewayIntentBits,
+    REST,
+    Routes,
+    type APIApplicationCommand,
+} from "discord.js";
 
-if (!env.mysqlPassword || env.mysqlPassword === 'YOUR_MYSQL_PASSWORD') {
-    throw new Error('You MUST provide a MySQL password in .env!');
-}
+import commandsMap from "./commands.ts";
 
-if (!env.mysqlDatabase || env.mysqlDatabase === 'YOUR_DATABASE_NAME') {
-    throw new Error('You MUST provide a database name in .env!');
-}
+import fs from "fs/promises";
+import path from "path";
 
-if (!env.twitchClientId || env.twitchClientId === 'YOUR_TWITCH_CLIENT_ID') {
-    throw new Error('You MUST provide a Twitch client ID in .env!');
-}
+import { initTables } from "./utils/database.ts";
+import { getTwitchToken } from "./utils/twitch/auth.ts";
 
-if (!env.twitchClientSecret || env.twitchClientSecret === 'YOUR_TWITCH_CLIENT_SECRET') {
-    throw new Error('You MUST provide a Twitch client secret in .env!');
-}
+import { CronJob } from "cron";
 
-// Import API
-import './api.ts'
+import backup from "./utils/backup.ts";
 
-// If everything is set up correctly, continue with the bot
-import { Client, GatewayIntentBits, REST, Routes, type APIApplicationCommand } from 'discord.js';
-import commandsMap from './commands.ts';
-import fs from 'fs/promises';
-import path from 'path';
-import { initTables } from './utils/database.ts';
-import { getTwitchToken } from './utils/twitch/auth.ts';
+// Start the cron jobs
+await fs.mkdir(path.resolve(process.cwd(), "backups"), { recursive: true });
+new CronJob("0 0 * * *", async () => {
+    await backup(
+        path.resolve(process.cwd(), "db.sqlite3"),
+        `./backups/db-${new Date().toISOString().replace(/[:.]/g, "-")}.sqlite3`,
+    );
+}).start();
 
 const client = new Client({
-    intents: [
-        GatewayIntentBits.Guilds,
-        GatewayIntentBits.GuildMessages,
-    ]
+    intents: [GatewayIntentBits.Guilds, GatewayIntentBits.GuildMessages],
 });
 
 // Update the commands
@@ -61,6 +60,7 @@ const rest = new REST().setToken(env.discordToken);
 const getAppId: { id?: string | null } = (await rest.get(
     Routes.currentApplication(),
 )) || { id: null };
+
 if (!getAppId?.id)
     throw "No application ID was able to be found with this token";
 
@@ -73,22 +73,25 @@ const data = (await rest.put(Routes.applicationCommands(getAppId.id), {
 console.log(`Successfully reloaded ${data.length} application (/) commands.`);
 
 // Check if MySQL is set up properly and its working
-if (!await initTables()) {
-    throw new Error('Error initializing tables');
+if (!(await initTables())) {
+    throw new Error("Error initializing tables");
 }
 
 // Get Twitch token
-if (!await getTwitchToken()) {
-    throw new Error('Error getting Twitch token');
+if (!(await getTwitchToken())) {
+    throw new Error("Error getting Twitch token");
 }
 
 // Login to Discord
 client.login(env.discordToken);
 
-export default client
+export default client;
 
 // Import events
-const getEvents = await fs.readdir(path.resolve(__dirname, './events'));
-await Promise.all(getEvents.map(async (file) => {
-    await import('./events/' + file);
-}));
+const getEvents = await fs.readdir(path.resolve(__dirname, "./events"));
+
+await Promise.all(
+    getEvents.map(async (file) => {
+        await import("./events/" + file);
+    }),
+);

src/index.ts

@@ -1,9 +1,9 @@
 export interface dbYouTube {
-	channelId: string;
-	lastVideoId: string;
+    channelId: string;
+    lastVideoId: string;
 }
 
 export interface dbTwitch {
-	twitch_channel_id: string;
-	is_live: boolean;
-}
+    twitch_channel_id: string;
+    is_live: boolean;
+}