src/smd/endpoints.rs

use super::{
    Config,
    context::{SalarymanDContext, StdinBuffer},
};
use dropshot::{HttpError, HttpResponseOk, RequestContext, TypedBody, endpoint};
use std::sync::Arc;

#[endpoint {
    method = GET,
    path = "/config",
}]
pub async fn endpoint_get_config(
    rqctx: RequestContext<Arc<SalarymanDContext>>,
) -> Result<HttpResponseOk<Config>, HttpError> {
    Ok(HttpResponseOk(rqctx.context().config.clone()))
}

#[endpoint {
    method = PUT,
    path = "/services/write"
}]
pub async fn endpoint_post_stdin(
    rqctx: RequestContext<Arc<SalarymanDContext>>,
    update: TypedBody<StdinBuffer>,
) -> Result<HttpResponseOk<()>, HttpError> {
    let ctx = rqctx.context();
    let stdin_str = update.into_inner();
    for i in 0..ctx.service.len() {
        let mut lock = ctx.service[i].lock().await;
        if lock.started().await {
            lock.writeln_stdin(stdin_str.string.clone()).await.unwrap(); //TODO: PROPERLY HANDLE ERROR!
        }
        drop(lock);
    }

    Ok(HttpResponseOk(()))
}
Revision:	13
Committed:	Wed Jul 9 20:24:36 2025 UTC (3 months ago) by yuzu
File size:	1017 byte(s)
Log Message:	working network communication
#	Content
1	use super::{
2	Config,
3	context::{SalarymanDContext, StdinBuffer},
4	};
5	use dropshot::{HttpError, HttpResponseOk, RequestContext, TypedBody, endpoint};
6	use std::sync::Arc;
7
8	#[endpoint {
9	method = GET,
10	path = "/config",
11	}]
12	pub async fn endpoint_get_config(
13	rqctx: RequestContext<Arc<SalarymanDContext>>,
14	) -> Result<HttpResponseOk<Config>, HttpError> {
15	Ok(HttpResponseOk(rqctx.context().config.clone()))
16	}
17
18	#[endpoint {
19	method = PUT,
20	path = "/services/write"
21	}]
22	pub async fn endpoint_post_stdin(
23	rqctx: RequestContext<Arc<SalarymanDContext>>,
24	update: TypedBody<StdinBuffer>,
25	) -> Result<HttpResponseOk<()>, HttpError> {
26	let ctx = rqctx.context();
27	let stdin_str = update.into_inner();
28	for i in 0..ctx.service.len() {
29	let mut lock = ctx.service[i].lock().await;
30	if lock.started().await {
31	lock.writeln_stdin(stdin_str.string.clone()).await.unwrap(); //TODO: PROPERLY HANDLE ERROR!
32	}
33	drop(lock);
34	}
35
36	Ok(HttpResponseOk(()))
37	}