From 2e2807f022294d424f06206b8311bd3ad7b16f14 Mon Sep 17 00:00:00 2001 From: metamuffin Date: Fri, 14 Nov 2025 20:11:18 +0100 Subject: preparation for config reloading --- src/modules/proxy.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'src/modules/proxy.rs') diff --git a/src/modules/proxy.rs b/src/modules/proxy.rs index aecd775..252e482 100644 --- a/src/modules/proxy.rs +++ b/src/modules/proxy.rs @@ -4,7 +4,8 @@ Copyright (C) 2025 metamuffin */ use super::{Node, NodeContext, NodeKind, NodeRequest, NodeResponse}; -use crate::ServiceError; +use crate::{config::DynNode, modules::InstContext, ServiceError}; +use anyhow::Result; use futures::Future; use http::{Response, Version}; use http_body_util::BodyExt; @@ -12,7 +13,6 @@ use hyper::{body::Incoming, http::HeaderValue, upgrade::OnUpgrade, StatusCode}; use hyper_util::rt::TokioIo; use log::{debug, warn}; use serde::Deserialize; -use serde_yml::Value; use std::{ fmt::Display, net::{Ipv4Addr, SocketAddr, SocketAddrV4}, @@ -53,8 +53,8 @@ impl NodeKind for ProxyKind { fn name(&self) -> &'static str { "proxy" } - fn instanciate(&self, config: Value) -> anyhow::Result> { - Ok(Arc::new(serde_yml::from_value::(config)?)) + fn instanciate(&self, ic: InstContext) -> Result { + Ok(Arc::new(ic.config().parse::()?)) } } -- cgit v1.3