teo 0.0.52-beta.3

REDEFINED HTTP server framework.
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

use std::fmt::Debug;
use std::sync::Arc;
use async_trait::async_trait;
use crate::core::action::Action;
use crate::core::action::source::ActionSource;
use crate::core::database::r#type::DatabaseType;
use crate::core::field::r#type::FieldType;
use crate::core::graph::Graph;
use crate::core::model::Model;
use crate::core::object::Object;
use crate::core::result::Result;
use crate::prelude::Value;

#[async_trait]
pub(crate) trait SaveSession: Debug + Send + Sync { }

#[async_trait]
pub(crate) trait Connector: Send + Sync {

    // Query database types

    fn default_database_type(&self, field_type: &FieldType) -> DatabaseType;

    // Migration

    async fn migrate(&mut self, models: &Vec<Model>, reset_database: bool) -> Result<()>;

    // Raw query

    async fn query_raw(&self, query: &Value) -> Result<Value>;

    // Object manipulation

    async fn save_object(&self, object: &Object, session: Arc<dyn SaveSession>) -> Result<()>;

    async fn delete_object(&self, object: &Object, session: Arc<dyn SaveSession>) -> Result<()>;

    async fn find_unique(&self, graph: &Graph, model: &Model, finder: &Value, mutation_mode: bool, action: Action, action_source: ActionSource) -> Result<Object>;

    async fn find_many(&self, graph: &Graph, model: &Model, finder: &Value, mutation_mode: bool, action: Action, action_source: ActionSource) -> Result<Vec<Object>>;

    async fn count(&self, graph: &Graph, model: &Model, finder: &Value) -> Result<usize>;

    async fn aggregate(&self, graph: &Graph, model: &Model, finder: &Value) -> Result<Value>;

    async fn group_by(&self, graph: &Graph, model: &Model, finder: &Value) -> Result<Value>;

    // Save session

    fn new_save_session(&self) -> Arc<dyn SaveSession>;
}