vane 0.9.0

A flow-based reverse proxy with multi-layer routing and programmable pipelines.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

/* src/plugins/core/handler.rs */

use crate::api::response;
use crate::engine::interfaces::ExternalPluginConfig;
use crate::plugins::core::{loader, registry};
use axum::{Json, extract::Path, http::StatusCode, response::IntoResponse};
use serde_json::json;

/// GET /plugins
pub async fn list_plugins_handler() -> impl IntoResponse {
	let plugins = registry::list_external_plugins();
	let names: Vec<String> = plugins.iter().map(|p| p.name().to_owned()).collect();
	response::success(json!({ "plugins": names })).into_response()
}

/// POST /plugins/:name
pub async fn create_plugin_handler(
	Path(name): Path<String>,
	Json(config): Json<ExternalPluginConfig>,
) -> impl IntoResponse {
	if config.name != name {
		return response::error(
			StatusCode::BAD_REQUEST,
			"Path name and body name mismatch.".to_owned(),
		)
		.into_response();
	}

	// Check collision
	if registry::get_plugin(&name).is_some() {
		return response::error(
			StatusCode::CONFLICT,
			format!("Plugin '{name}' already exists."),
		)
		.into_response();
	}

	match loader::register_plugin(config).await {
		Ok(_) => response::success(json!({ "status": "created", "name": name })).into_response(),
		Err(e) => response::error(
			StatusCode::BAD_REQUEST,
			format!("Failed to register plugin: {e}"),
		)
		.into_response(),
	}
}

/// PUT /plugins/:name
pub async fn update_plugin_handler(
	Path(name): Path<String>,
	Json(config): Json<ExternalPluginConfig>,
) -> impl IntoResponse {
	if config.name != name {
		return response::error(
			StatusCode::BAD_REQUEST,
			"Path name and body name mismatch.".to_owned(),
		)
		.into_response();
	}

	if registry::get_external_plugin(&name).is_none() {
		return response::error(
			StatusCode::NOT_FOUND,
			format!("External plugin '{name}' not found."),
		)
		.into_response();
	}

	match loader::register_plugin(config).await {
		Ok(_) => response::success(json!({ "status": "updated", "name": name })).into_response(),
		Err(e) => response::error(
			StatusCode::BAD_REQUEST,
			format!("Failed to update plugin: {e}"),
		)
		.into_response(),
	}
}

/// DELETE /plugins/:name
pub async fn delete_plugin_handler(Path(name): Path<String>) -> impl IntoResponse {
	if registry::get_external_plugin(&name).is_none() {
		return response::error(
			StatusCode::NOT_FOUND,
			format!("External plugin '{name}' not found."),
		)
		.into_response();
	}

	match loader::delete_plugin(&name).await {
		Ok(_) => response::success(json!({ "status": "deleted", "name": name })).into_response(),
		Err(e) => response::error(
			StatusCode::INTERNAL_SERVER_ERROR,
			format!("Failed to delete plugin: {e}"),
		)
		.into_response(),
	}
}