surrealdb-core 3.2.3

A scalable, distributed, collaborative, document-graph database, for the realtime web
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
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
98
99
100
101

//! Session functions for the streaming executor.
//!
//! These functions access session information from the EvalContext.

use anyhow::Result;

use crate::exec::function::FunctionRegistry;
use crate::exec::physical_expr::EvalContext;
use crate::val::Value;
use crate::{define_context_function, register_functions};

// =========================================================================
// Implementation functions
// =========================================================================

fn session_ac_impl(ctx: &EvalContext<'_>) -> Result<Value> {
	Ok(ctx
		.session()
		.and_then(|s| s.ac.as_ref())
		.map(|ac| Value::String(ac.clone()))
		.unwrap_or(Value::None))
}

fn session_db_impl(ctx: &EvalContext<'_>) -> Result<Value> {
	Ok(ctx
		.session()
		.and_then(|s| s.db.as_ref())
		.map(|db| Value::String(db.clone()))
		.unwrap_or(Value::None))
}

fn session_id_impl(ctx: &EvalContext<'_>) -> Result<Value> {
	Ok(ctx
		.session()
		.and_then(|s| s.id.as_ref())
		.map(|id| Value::Uuid((*id).into()))
		.unwrap_or(Value::None))
}

fn session_ip_impl(ctx: &EvalContext<'_>) -> Result<Value> {
	Ok(ctx
		.session()
		.and_then(|s| s.ip.as_ref())
		.map(|ip| Value::String(ip.clone()))
		.unwrap_or(Value::None))
}

fn session_ns_impl(ctx: &EvalContext<'_>) -> Result<Value> {
	Ok(ctx
		.session()
		.and_then(|s| s.ns.as_ref())
		.map(|ns| Value::String(ns.clone()))
		.unwrap_or(Value::None))
}

fn session_origin_impl(ctx: &EvalContext<'_>) -> Result<Value> {
	Ok(ctx
		.session()
		.and_then(|s| s.origin.as_ref())
		.map(|origin| Value::String(origin.clone()))
		.unwrap_or(Value::None))
}

fn session_rd_impl(ctx: &EvalContext<'_>) -> Result<Value> {
	Ok(ctx.session().and_then(|s| s.rd.clone()).unwrap_or(Value::None))
}

fn session_token_impl(ctx: &EvalContext<'_>) -> Result<Value> {
	Ok(ctx.session().and_then(|s| s.token.clone()).unwrap_or(Value::None))
}

// =========================================================================
// Function definitions using the macro
// =========================================================================

define_context_function!(SessionAc, "session::ac", () -> Any, session_ac_impl);
define_context_function!(SessionDb, "session::db", () -> Any, session_db_impl);
define_context_function!(SessionId, "session::id", () -> Any, session_id_impl);
define_context_function!(SessionIp, "session::ip", () -> Any, session_ip_impl);
define_context_function!(SessionNs, "session::ns", () -> Any, session_ns_impl);
define_context_function!(SessionOrigin, "session::origin", () -> Any, session_origin_impl);
define_context_function!(SessionRd, "session::rd", () -> Any, session_rd_impl);
define_context_function!(SessionToken, "session::token", () -> Any, session_token_impl);

// =========================================================================
// Registration
// =========================================================================

pub fn register(registry: &mut FunctionRegistry) {
	register_functions!(
		registry,
		SessionAc,
		SessionDb,
		SessionId,
		SessionIp,
		SessionNs,
		SessionOrigin,
		SessionRd,
		SessionToken,
	);
}