Update environment configuration and fix test case naming

Dockerfile

@@ -10,4 +10,4 @@ COPY . /app
 EXPOSE 6969
 
 # Set the default command to run the Deno task
-CMD ["deno", "task", "admin"]
+CMD ["deno", "task", "all"]

deno.lock

@@ -1,15 +1,29 @@
 {
-  "version": "4",
+  "version": "5",
   "specifiers": {
+    "jsr:@melvdouc/xml-parser@*": "0.1.1",
+    "jsr:@melvdouc/xml-parser@~0.1.1": "0.1.1",
+    "jsr:@std/assert@1": "1.0.15",
+    "jsr:@std/dotenv@*": "0.225.3",
     "jsr:@std/dotenv@0.225.3": "0.225.3",
     "jsr:@std/fmt@^1.0.5": "1.0.6",
     "jsr:@std/fs@^1.0.11": "1.0.15",
+    "jsr:@std/internal@^1.0.12": "1.0.12",
     "jsr:@std/io@~0.225.2": "0.225.2",
     "jsr:@std/log@*": "0.224.14",
     "npm:@types/node@^22.14.1": "22.14.1",
     "npm:discord.js@14.18.0": "14.18.0"
   },
   "jsr": {
+    "@melvdouc/xml-parser@0.1.1": {
+      "integrity": "5c79d37c6471cb74efb344988317270b57b4f181decb873e441453db42eb6e5f"
+    },
+    "@std/assert@1.0.15": {
+      "integrity": "d64018e951dbdfab9777335ecdb000c0b4e3df036984083be219ce5941e4703b",
+      "dependencies": [
+        "jsr:@std/internal"
+      ]
+    },
     "@std/dotenv@0.225.3": {
       "integrity": "a95e5b812c27b0854c52acbae215856d9cce9d4bbf774d938c51d212711e8d4a"
     },
@@ -19,6 +33,9 @@
     "@std/fs@1.0.15": {
       "integrity": "c083fb479889d6440d768e498195c3fc499d426fbf9a6592f98f53884d1d3f41"
     },
+    "@std/internal@1.0.12": {
+      "integrity": "972a634fd5bc34b242024402972cd5143eac68d8dffaca5eaa4dba30ce17b027"
+    },
     "@std/io@0.225.2": {
       "integrity": "3c740cd4ee4c082e6cfc86458f47e2ab7cb353dc6234d5e9b1f91a2de5f4d6c7"
     },
@@ -169,7 +186,11 @@
       "integrity": "sha512-q/1rj5D0/zayJB2FraXdaWxbhWiNKDvu8naDT2dl1yTlvJp4BLtOcp2a5BvgGNQpYYJzau7tf1WgKv3b+7mqpQ=="
     },
     "ws@8.18.1": {
-      "integrity": "sha512-RKW2aJZMXeMxVpnZ6bck+RswznaxmzdULiBr6KY7XkTnW8uvt0iT9H5DkHUChXrc+uurzwa0rVI16n/Xzjdz1w=="
+      "integrity": "sha512-RKW2aJZMXeMxVpnZ6bck+RswznaxmzdULiBr6KY7XkTnW8uvt0iT9H5DkHUChXrc+uurzwa0rVI16n/Xzjdz1w==",
+      "optionalPeers": [
+        "bufferutil@^4.0.1",
+        "utf-8-validate@>=5.0.2"
+      ]
     }
   },
   "workspace": {

src/bot.ts

@@ -5,19 +5,12 @@ import {
 	REST,
 	Routes,
 } from "@discordjs";
-import * as stdDotenv from "jsr:@std/dotenv@0.225.3";
 import { commandRouter } from "@root/commands.ts";
-
+import { EnvConst, loadConfig } from "@root/core/configLoader.ts";
-const env = await stdDotenv.load();
-
-const token = env.TOKEN;
-if (token === undefined) throw Error("no bot token");
-// import { EnvConst, loadConfig } from "@root/core/configLoader.ts";
-// import { messagehandler } from "@root/messages.ts";
-
-// const env: EnvConst = loadConfig();
 const { promise, resolve, reject } = Promise.withResolvers<void>();
 
+const env: EnvConst = loadConfig();
+
 const client = new Client({
 	intents: [
 		GatewayIntentBits.Guilds,
@@ -33,7 +26,6 @@ client.on(Events.ClientReady, (readyClient) => {
 const commands = commandRouter();
 
 client.on(Events.InteractionCreate, async (interaction) => {
-	// messagehandler(interaction.command)
 	if (!interaction.isChatInputCommand()) return;
 
 	const command = commands.find((c) => c.data.name === interaction.commandName);
@@ -46,9 +38,9 @@ client.on(Events.Error, (e) => {
 	reject(e);
 });
 
-const rest = new REST({ version: "10" }).setToken(token);
+const rest = new REST({ version: "10" }).setToken(env.BOT_TOKEN);
 
-client.login(token);
+client.login(env.BOT_TOKEN);
 
 await promise;
 

src/core/configLoader.ts

@@ -1,13 +1,26 @@
+import { load } from "jsr:@std/dotenv";
+
+const _env = await load({
+  // optional: choose a specific path (defaults to ".env")
+  envPath: ".env",
+  // optional: also export to the process environment (so Deno.env can read it)
+  export: true,
+});
+
 export type EnvConst = {
     ADMIN: string,
     BOT_TOKEN: string,
+    RULE34_API_KEY: string,
+    RULE34_API_USER: string,
     // DB_LOCATION: string
 }
 
 export function loadConfig() {
     return {
         ADMIN: loadEnv("ADMIN"),
-        BOT_TOKEN: loadEnv("BOT_TOKEN"), 
+        BOT_TOKEN: loadEnv("BOT_TOKEN"),
+        RULE34_API_KEY: loadEnv("RULE34_API_KEY"),
+        RULE34_API_USER: loadEnv("RULE34_API_USER"),
         // DB_LOCATION: loadEnv("DB_LOCATION")
     }
 }

src/logging.ts

@@ -1,9 +1,9 @@
-import * as stdlogger from "jsr:@std/log";
+// import * as stdlogger from "jsr:@std/log";
-import { Message } from "@discordjs";
+// import { Message } from "@discordjs";
 
-export function logMessage(message: Message) {
+// export function logMessage(message: Message) {
-    return stdlogger.info(
+//     return stdlogger.info(
-        `Message from ${message.author} in ${message.guildId?? "Private"} ${message.channelId} Command:[${message.content}]`
+//         `Message from ${message.author} in ${message.guildId?? "Private"} ${message.channelId} Command:[${message.content}]`
-    );
+//     );
 
-}
+// }

src/plugins/rule34/api.ts

@@ -1,6 +1,6 @@
 //TODO Add optional extensions like limit at Posts with tags etc.
 import * as xml_parser from "jsr:@melvdouc/xml-parser";
-import { requestRaw, requestJSON } from "@root/structures/apiRequest.ts";
+import { requestRaw } from "@root/structures/apiRequest.ts";
 
 export type ImageResponse = {
 	preview_url: string;

src/plugins/rule34/commands.ts

@@ -1,32 +1,5 @@
 import { ChatInputCommandInteraction, SlashCommandBuilder } from "@discordjs";
-// import { drop, help, requestWorker } from "./plugin.ts";
+import { requestWorker } from "@root/plugins/rule34/plugin.ts";
-import { logMessage } from "@root/logging.ts";
-import { defaultString } from "@root/defaultString.ts";
-
-// export async function rule34MessageHandler(message: Message) {
-// 	const command = message.content.trim().split(" ").slice(1).join(" ");
-// 	if (command === "drop") {
-// 		bot.helpers.sendMessage(message.channelId, {
-// 			embeds: [await drop()]
-// 		})
-// 	} else if (command.startsWith("drop [") && command.endsWith("]")) {
-// 		logMessage(message);
-// 		const generatedEmbeds: Embed[] = await requestWorker(command);
-// 		for (const embed of generatedEmbeds) {
-// 			bot.helpers.sendMessage(message.channelId, {
-// 				embeds: [embed],
-// 			});
-// 		}
-// 	} else if (command === "help") {
-// 		logMessage(message);
-
-// 		bot.helpers.sendMessage(message.channelId, {
-// 			content: defaultString(help()),
-// 		});
-// 	} else {
-// 		drop();
-// 	}
-// }
 
 export const commands = [
 	{
@@ -38,9 +11,41 @@ export const commands = [
 				subcommand
 					.setName("drop")
 					.setDescription("Drops one or multiple images using the rule34 API.")
+					.addStringOption((option) =>
+						option
+							.setName("limit")
+							.setDescription("Post limitation")
+					)
+					.addStringOption((option) =>
+						option
+							.setName("tags")
+							.setDescription("Tags to add to query")
+					)
+					.addStringOption((option) =>
+						option
+							.setName("page")
+							.setDescription("Which page to query")
+					)
+					.addStringOption((option) =>
+						option
+							.setName("pid")
+							.setDescription("Which page to query")
+					)
 			),
 		async execute(interaction: ChatInputCommandInteraction) {
-			await interaction.reply(`VIOLENCE!`);
+			const limit = interaction.options.getString("limit");
+			const tags = interaction.options.getString("tags");
+			const page = interaction.options.getString("page");
+			const pid = interaction.options.getString("pid");
+
+			await interaction.reply({
+				embeds: await requestWorker({
+					limit: limit ?? "1",
+					tags: tags,
+					page: page,
+					pid: pid,
+				}),
+			});
 		},
 	},
 ];

src/plugins/rule34/plugin.ts

@@ -1,102 +1,52 @@
-import { assert } from "@std/assert/assert";
 import { requestJSON } from "@root/structures/apiRequest.ts";
 import { ImageResponse, postUrl } from "./api.ts";
+import { EmbedBuilder } from "@discordjs";
 
-const keys = ["limit", "id", "pid", "tags"] as const;
-type PostKeys = typeof keys[number];
 
-function isKey(key: string): key is PostKeys {
+export type PostRequestParameters = {
-	return keys.includes(key as any);
+	limit?: string| null| undefined,
+	id?: string| null| undefined,
+	pid?: string| null| undefined,
+	tags?: string| null| undefined,
+	page?: string| null| undefined,
 }
 
-// export async function drop() {
+export async function requestWorker(postRequestParams: PostRequestParameters) {
-// 	try {
+	const embeds = [];
-// 		const response = await requestJSON<ImageResponse[]>(`${postUrl}&limit=1`);
+	try {
-// 		const img = response[0];
+		const response = await requestJSON<ImageResponse[]>(
-// 		if (img === undefined) throw Error("An undefined Array was given!");
+			generateRequestURL(postRequestParams),
-// 		return new Embed(
+		);
-// 			`ID: ${img.id}`,
+		for (const post of response) {
-// 			img.sample_url,
+			embeds.push(
-// 			new EmbedAuthor(img.owner),
+				new EmbedBuilder()
-// 			// [new EmbedField("Tags", img.tags, true)],
+					.setTitle(post.id.toString())
-// 			new EmbedImage(img.file_url, img.height, img.width),
+					.setURL(post.file_url)
-// 		);
+					.setAuthor(
-// 	} catch (e) {
+						{
-// 		console.error((e as Error).message);
+							name: post.owner,
-// 		return new Embed(
+						},
-// 			"Error Message",
+					)
-// 			"https://gifdb.com/images/thumbnail/nuh-uh-demon-slayer-girl-hm7q3hqa4lnqyl6d.gif",
+					.setImage(post.preview_url),
-// 			new EmbedAuthor("fzzinChemical"),
+			);
-// 			new EmbedImage(
+		}
-// 				"https://gifdb.com/images/thumbnail/nuh-uh-demon-slayer-girl-hm7q3hqa4lnqyl6d.gif",
+	} catch (e) {
-// 				250,
+		console.error((e as Error).message);
-// 				250,
+		return [];
-// 			),
-// 		);
-// 	}
-// }
-
-// export async function requestWorker(requestString: string) {
-// 	try {
-// 		const response = await requestJSON<ImageResponse[]>(
-// 			generateRequestURL(requestString),
-// 		);
-// 		const stack: Embed[] = [];
-// 		for (const img of response) {
-// 			stack.push(
-// 				new Embed(
-// 					`ID: ${img.id}`,
-// 					img.sample_url,
-// 					new EmbedAuthor(img.owner),
-// 					// [new EmbedField("Tags", img.tags, true)],
-// 					new EmbedImage(img.file_url, img.height, img.width),
-// 				),
-// 			);
-// 		}
-// 		return stack;
-// 	} catch (e) {
-// 		console.error((e as Error).message);
-// 		return [];
-// 	}
-// }
-
-//TODO: get help in form of a nice beautiful format
-export function help() {
-	return "WIP";
-}
-
-export function requestParser(requestString: string) {
-	const res = requestString.match(/\[([\s*w+:\s*[\d+|\w+,]+)\]/g);
-	const map = new Map<PostKeys, string>();
-	if (res !== null) {
-		res[0]
-			.split(",")
-			.forEach((param) => {
-				const match = param.match(/\s*(\w+)\s*:\s*([\w+,+]+)/);
-				console.debug({ match });
-				if (match !== null) {
-					if (match[1] === undefined || match[2] === undefined) {
-						throw Error("Unreachable");
-					}
-					if (!isKey(match[1])) throw Error(`Key: ${match[1]} is not a Key!`);
-					map.set(match[1], match[2]);
-				} else {
-					throw Error(`match returned null in param = ${Deno.inspect(param)}`);
-				}
-			});
-	} else {
-		throw Error("Request String had some major issues chief");
 	}
-	return map;
+	return embeds;
 }
 
-// + is replaced with a space... this is pain
+export function generateRequestURL(postRequestParams: PostRequestParameters) {
-// see percent code + === 2B
+	const postCpy = new URL(postUrl);
-export function generateRequestURL(requestString: string) {
+	const parameterStrings: string[] = []
-	const postCpy = new URL(postUrl.toString());
 
-	for (const [k, v] of requestParser(requestString)) {
+	Object.entries(postRequestParams).forEach(([k, v]) => {
-		postCpy.searchParams.append(k, v);
+		if (v !== null) {
-	}
+			parameterStrings.push(`&${k}=${v}`)
-	return postCpy.href.toString().replaceAll("%2B", "+");
+		}
+	});
+	
+	parameterStrings.push('&api_key=' + (Deno.env.get("RULE34_API_KEY")) + '&user_id=' + (Deno.env.get("RULE34_API_USER")));
+	return postCpy.href + parameterStrings.join('');
 }

src/plugins/rule34/test.ts

@@ -1,25 +1,20 @@
-import { assert } from "jsr:@std/assert";
+import {generateRequestURL, requestWorker } from "@root/plugins/rule34/plugin.ts";
-import { drop, generateRequestURL, requestParser, requestWorker } from "@root/plugins/rule34/plugin.ts";
-
-Deno.test("Test Request Parser", () => {
-	assert(
-		requestParser("[limit: 12,tags:bro+likes+bread]"),
-		'{ "limit" => "12", "tags" => "bro+likes+bread" }',
-	);
-});
 
 Deno.test("Test URL Search Parameters", () => {
-	console.debug(generateRequestURL("[limit:3]"));
+	console.debug(generateRequestURL(
+		{limit: "3"}
+	));
 });
 
-Deno.test("Test Drop", async () => {
+Deno.test("Test Request Worker", async () => {
-	console.debug(await drop());
+	console.debug(await requestWorker({	
+		limit: "12",
+		tags: "sfw",
+	}));
 });
 
-Deno.test("Test Request Workder", async () => {
-	console.debug(await requestWorker("[limit: 12,tags:sfw]"));
-});
 
-Deno.test("Test Request Workder 2", async () => {
+
-	console.debug(await requestWorker("[limit: 5,tags: AI+catgirl]"));
+Deno.test("Test Request Worker 2", async () => {
+	console.debug(await requestWorker({limit: "5",tags: "AI+catgirl"}));
 });

src/plugins/yandere/api/api.ts

@@ -1,4 +1,4 @@
-import { handlePostRequest } from "@root/plugins/yandere/api/post.ts";
+import { handlePostRequest, postKeys } from "@root/plugins/yandere/api/post.ts";
 const baseURL = "https://yande.re";
 
 const apikeys = [
@@ -17,40 +17,20 @@ function prepareURLObjectForRequest(type: APIKeys) {
 	const tmp = new URL(baseURL);
 	tmp.searchParams.append("api_version", "3");
 	switch (type) {
-		case "post":
+		case "post": tmp.pathname = "post.json"; break;
-			tmp.pathname = "post.json";
+		case "tags": tmp.pathname = "tag.json"; break;
-			break;
+		case "artist": tmp.pathname = "artist.json"; break;
-		case "tags":
+		case "comments": tmp.pathname = "comment"; break;
-			tmp.pathname = "tag.json";
+		case "wiki": tmp.pathname = "wiki.json"; break;
-			break;
+		case "notes": tmp.pathname = "note.json"; break;
-		case "artist":
+		case "users": tmp.pathname = "user.json"; break;
-			tmp.pathname = "artist.json";
+		case "forum": tmp.pathname = "forum.json"; break;
-			break;
+		case "pools": tmp.pathname = "pool.json"; break; 
-		case "comments":
+		default: throw Error("unknown ");
-			tmp.pathname = "comment";
-			break;
-		case "wiki":
-			tmp.pathname = "wiki.json";
-			break;
-		case "notes":
-			tmp.pathname = "note.json";
-			break;
-		case "users":
-			tmp.pathname = "user.json";
-			break;
-		case "forum":
-			tmp.pathname = "forum.json";
-			break;
-		case "pools":
-			tmp.pathname = "pool.json";
-			break;
-		default:
-			throw Error("unknown ");
 	}
 	return tmp;
 }
 
-export function getPosts(search? : string){
+export async function getPosts(args? : postKeys){
-  const url = prepareURLObjectForRequest("post")
+  return await handlePostRequest(prepareURLObjectForRequest("post"), args)
-  return handlePostRequest(url, search)
 }

src/plugins/yandere/api/post.ts

@@ -46,29 +46,20 @@ type PostResponse = {
 	last_commented_at: string;
 }[];
 
-const postSearchkeys = ["limit", "page", "tags"];
+export type postKeys = {
+	limit?: string | null | undefined;
+	page?: string | null | undefined;
+	tags?: string | null | undefined;
+};
 
-function parsePostListArgs(url: URL, args: string) {
+function parsePostListArgs(url: URL, args: postKeys | undefined) {
-	// const urlCopy: URL = copyObject<URL>(url);
+	if (args === undefined) args = { limit: "1" }; //TODO that could be better
-	const argarr = args.replaceAll(/(\[|\ |\])/g, "").split(",");
+	Object.entries(args).forEach(([key, value]) => {
-	for (const arg of argarr) {
+		if (value !== null) {
-		const [k, v] = arg.split(":");
+			console.debug(`appending k:${key}, v:${value}`);
-		if (url === undefined) throw Error("undefined Object: url!")
+			url.searchParams.append(key, value);
-		if (k === undefined || v === undefined) {
-			throw Error(
-				`undefined key or value in ${parsePostListArgs.name}, got k:${k}, v:${v}`,
-			);
 		}
-		if (postSearchkeys.includes(k)) {
+	});
-			console.debug(k, v)
-			console.debug(JSON.stringify(url))
-			url.searchParams.append(k, v);
-		} else {
-			throw Error(
-				`unknown parameter was given in ${parsePostListArgs.name}, got k:${k}, v:${v}`,
-			);
-		}
-	}
 	return url;
 }
 
@@ -87,29 +78,20 @@ async function returnDiscordEmbeds(
 				.setAuthor(
 					{
 						name: post.author,
-					}
+					},
 				)
-				.setImage(post.file_url)
+				.setImage(post.preview_url),
-		)
+		);
 	}
 	return embeds;
 }
 
-// function copyObject<T>(obj: T) {
-// 	const newObject: T = Object.
-
-
 /**
  * Post-Request Handler Function, that returns DiscordEmbeds.
  * @param url URL Object
- * @param search Search string formatted like the following: [tags: something, page: 1, limit: 666], some parameters can miss.
+ * @param args Search string formatted like the following: [tags: something, page: 1, limit: 666], some parameters can miss.
  */
-export async function handlePostRequest(url: URL, search?: string) {
+export async function handlePostRequest(url: URL, args?: postKeys) {
-	// const urlCopy = copyObject<URL>(url);
 	//parse
-	if (search) {
+	return await returnDiscordEmbeds(parsePostListArgs(url, args));
-		return await returnDiscordEmbeds(parsePostListArgs(url, search));
+}
-	} else {
-		return await returnDiscordEmbeds(url);
-	}
-}

src/plugins/yandere/commands.ts

@@ -1,30 +1,6 @@
-import {
+import { ChatInputCommandInteraction, SlashCommandBuilder } from "@discordjs";
-	ChatInputCommandInteraction,
-	SlashCommandBuilder,
-} from "@discordjs";
 import { getPosts } from "@root/plugins/yandere/api/api.ts";
 
-// export async function yandereMessageHandler(message: Message) {
-//   const command = message.content.split(" ").slice(1).join(" ");
-//   const args = command.match(/(\[.+\])/g)
-//   if (command === "drop") {
-//     const embed: DiscordEmbed | undefined = (await getPosts("[limit: 1]"))[0]
-//     if (embed === undefined) throw Error("undefined embed")
-//     bot.helpers.sendMessage(message.channelId, {
-//       embeds: [embed]
-//     })
-//   } else if (command.startsWith("drop [") && command.endsWith("]")) {
-//     logMessage(message);
-//     if (args === null) throw Error("args is null")
-//     const generatedEmbeds = await getPosts(args[0]);
-//     for (const embed of generatedEmbeds) {
-//       bot.helpers.sendMessage(message.channelId, {
-//         embeds: [embed],
-//       });
-//     }
-//   }
-// }
-
 export const commands = [
 	{
 		data: new SlashCommandBuilder()
@@ -34,25 +10,36 @@ export const commands = [
 			.addSubcommand((subcommand) =>
 				subcommand
 					.setName("drop")
-					.setDescription("Drops one or multiple images using the yande.re API.")
+					.setDescription(
-					.addStringOption(option => 
+						"Drops one or multiple images using the yande.re API.",
+					)
+					.addStringOption((option) =>
 						option
 							.setName("limit")
-							.setDescription("Post limitation")	
+							.setDescription("Post limitation")
 					)
-					.addStringOption(option => 
+					.addStringOption((option) =>
 						option
 							.setName("tags")
-							.setDescription("Tags to add to query")	
+							.setDescription("Tags to add to query")
 					)
-					.addStringOption(option => 
+					.addStringOption((option) =>
 						option
 							.setName("page")
-							.setDescription("Which page to query")	
+							.setDescription("Which page to query")
 					)
 			),
 		async execute(interaction: ChatInputCommandInteraction) {
-			await interaction.reply({embeds: await getPosts("[limit: 5]")});
+			const limit = interaction.options.getString("limit");
+			const tags = interaction.options.getString("tags");
+			const page = interaction.options.getString("page");
+			await interaction.reply({
+				embeds: await getPosts({
+					limit: limit ?? "1",
+					tags: tags,
+					page: page,
+				}),
+			});
 		},
 	},
 ];

src/plugins/yandere/tests/api.ts

@@ -5,13 +5,19 @@ Deno.test("Empty Post Request", async() => {
 })
 
 Deno.test("Post Request with tag", async() => {
-	console.debug(await getPosts("[tags:love_live!_(series)]"))
+	console.debug(await getPosts(
+		{tags: "love_live!_(series)"}
+	))
 })
 
 Deno.test("Post Request with limit", async() => {
-	console.debug(await getPosts("[limit: 1)]"))
+	console.debug(await getPosts({
+		limit: "1"
+	}))
 })
 
 Deno.test("Post Request with page", async() => {
-	console.debug(await getPosts("[page: 30)]"))
+	console.debug(await getPosts(
+		{page: "30"}
+	))
 })