reifydb-engine 0.4.12

Query execution and processing engine for ReifyDB
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

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

use reifydb_catalog::catalog::sumtype::SumTypeToCreate;
use reifydb_core::{
	interface::catalog::sumtype::{Field, SumTypeKind, Variant},
	value::column::columns::Columns,
};
use reifydb_rql::nodes::CreateEventNode;
use reifydb_transaction::transaction::admin::AdminTransaction;
use reifydb_type::value::Value;

use crate::{Result, vm::services::Services};

pub(crate) fn create_event(services: &Services, txn: &mut AdminTransaction, plan: CreateEventNode) -> Result<Columns> {
	let mut variants = Vec::with_capacity(plan.variants.len());
	for (tag, variant) in plan.variants.iter().enumerate() {
		let mut fields = Vec::with_capacity(variant.columns.len());
		for col in &variant.columns {
			fields.push(Field {
				name: col.name.to_lowercase(),
				field_type: col.column_type.clone(),
			});
		}
		variants.push(Variant {
			tag: tag as u8,
			name: variant.name.to_lowercase(),
			fields,
		});
	}

	let result = services.catalog.create_sumtype(
		txn,
		SumTypeToCreate {
			name: plan.name.clone(),
			namespace: plan.namespace.id(),
			variants,
			kind: SumTypeKind::Event,
		},
	)?;

	Ok(Columns::single_row([
		("id", Value::Uint8(result.id.0)),
		("namespace", Value::Utf8(plan.namespace.name().to_string())),
		("event", Value::Utf8(plan.name.text().to_string())),
		("created", Value::Boolean(true)),
	]))
}