feat(registry): Replace custom implementation by wasm_pkg_client

Author: celarye

Cargo.lock

@@ -14,6 +14,7 @@ clap = { version = "4.6.4", features = ["derive"] }
 cron = "0.17.0"
 dotenvy = "0.15.7"
 fjall = "3.1.8"
+futures-util = "0.3.33"
 hashbrown = "0.17.1"
 hotpath = "0.22.0"
 reqwest = { version = "0.13.4", features = ["hickory-dns"] }
@@ -37,6 +38,7 @@ twilight-http = { git = "https://github.com/wpbs-rs/twilight/", features = [
 twilight-model = { git = "https://github.com/wpbs-rs/twilight/" }
 url = "2.5.8"
 uuid = "1.24.0"
+wasm-pkg-client = "0.16.0"
 wasmtime = "47.0.2"
 wasmtime-wasi = "47.0.2"
 wasmtime-wasi-http = "47.0.2"

Cargo.toml

@@ -36,14 +36,8 @@ pub struct Cli {
     #[arg(default_value = "./plugins", short, long, value_name = "DIRECTORY PATH", help = "The path to the program its plugin directory", long_help = None)]
     pub plugin_directory: PathBuf,
 
-    #[arg(action=ArgAction::Set, default_value_t = true, short = 'C', long, value_name = "BOOL", help = "Enable the usage of cached plugins", long_help = None, hide_possible_values = true)]
-    pub cache: bool,
-
     #[arg(default_value = "./database", short, long, value_name = "DIRECTORY PATH", help = "The path to the program its database", long_help = None)]
     pub database_directory: PathBuf,
-
-    #[arg(default_value_t = 15, short = 't', long, value_name = "SECONDS", help = "The amount of seconds after which the HTTP client should timeout", long_help = None)]
-    pub http_client_timeout_seconds: u64,
 }
 
 #[derive(Args)]

src/cli.rs

@@ -13,7 +13,6 @@ pub mod permissions;
 #[derive(Deserialize)]
 pub struct ConfigPlugin {
     pub plugin: String,
-    pub cache: Option<bool>,
     #[serde(default)]
     pub permissions: PluginPermissions,
     #[serde(default)]

src/config/plugins.rs

@@ -26,7 +26,6 @@ use tracing::{debug, error, info, warn};
 mod cli;
 mod config;
 mod database;
-mod http;
 mod registry;
 mod runtime;
 mod services;
@@ -113,9 +112,7 @@ async fn main() -> Result<ExitCode> {
     );
 
     let setup_result = setup(
-        cli.http_client_timeout_seconds,
         cli.plugin_directory,
-        cli.cache,
         channels.services,
         channels.runtime,
         config,
@@ -181,21 +178,14 @@ fn message_handler(
 }
 
 async fn setup(
-    http_client_timeout_seconds: u64,
     plugin_directory_path: PathBuf,
-    cache: bool,
     service_channels: ChannelsServices,
     runtime_channels: ChannelsRuntime,
     config: Config,
     secrets: Secrets,
 ) -> Result<()> {
-    let available_plugins = registry::registry_get_plugins(
-        http_client_timeout_seconds,
-        config.plugins,
-        plugin_directory_path.clone(),
-        cache,
-    )
-    .await?;
+    let available_plugins =
+        registry::registry_get_plugins(config.plugins, &plugin_directory_path).await?;
 
     services::setup(config.services, secrets.services, service_channels).await?;