reifydb-sub-server-http 0.4.12

HTTP server subsystem for ReifyDB using Axum
Documentation 
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

// SPDX-License-Identifier: Apache-2.0
// Copyright (c) 2025 ReifyDB

//! Server state wrapper combining shared AppState with per-request actor spawning.

use std::ops::Deref;

use reifydb_core::actors::server::ServerMessage;
use reifydb_runtime::actor::{mailbox::ActorRef, system::ActorHandle};
use reifydb_sub_server::state::AppState;

/// HTTP server state wrapping the shared `AppState`.
///
/// Spawns a fresh actor per request to avoid serializing all HTTP requests
/// through a single actor mailbox.
#[derive(Clone)]
pub struct HttpServerState {
	state: AppState,
}

impl HttpServerState {
	pub fn new(state: AppState) -> Self {
		Self {
			state,
		}
	}

	pub fn state(&self) -> &AppState {
		&self.state
	}

	/// Spawn a short-lived actor for one request and return its ref + handle.
	///
	/// The caller must keep the `ActorHandle` alive until the reply is received;
	/// dropping it shuts down the actor.
	pub fn spawn_actor(&self) -> (ActorRef<ServerMessage>, ActorHandle<ServerMessage>) {
		self.state.spawn_server_actor()
	}
}

impl Deref for HttpServerState {
	type Target = AppState;

	fn deref(&self) -> &Self::Target {
		&self.state
	}
}