devoyage-subgraph 0.0.15

Subgraph is a CLI that instantly generates a GraphQL API around Mongo, SQL, and HTTP APIs.
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

use crate::{
    configuration::subgraph::data_sources::sql::DialectEnum,
    data_sources::{DataSource, DataSources},
    resolver_type::ResolverType,
};

use super::ServiceSchema;
use log::debug;

mod create_entity_type_defs;
mod create_resolver;

impl ServiceSchema {
    pub fn create_entities(mut self) -> Self {
        debug!("Creating Entities Config");
        debug!("Entities: {:?}", self.subgraph_config.service.entities);
        let entities = self.subgraph_config.service.entities.clone();

        for entity in entities.iter() {
            self = self.create_entity_type_defs(entity);

            let data_source = DataSources::get_entity_data_soruce(&self.data_sources, entity);

            match data_source {
                DataSource::SQL(ds) => match ds.config.dialect {
                    DialectEnum::POSTGRES => {
                        self = self.create_resolver(entity, ResolverType::FindOne);
                        self = self.create_resolver(entity, ResolverType::FindMany);
                        self = self.create_resolver(entity, ResolverType::CreateOne);
                        self = self.create_resolver(entity, ResolverType::UpdateMany);
                    }
                    DialectEnum::MYSQL => {
                        self = self.create_resolver(entity, ResolverType::FindOne);
                        self = self.create_resolver(entity, ResolverType::FindMany);
                        self = self.create_resolver(entity, ResolverType::CreateOne);
                        self = self.create_resolver(entity, ResolverType::UpdateMany);
                        self = self.create_resolver(entity, ResolverType::UpdateOne);
                    }
                    DialectEnum::SQLITE => {
                        self = self.create_resolver(entity, ResolverType::FindOne);
                        self = self.create_resolver(entity, ResolverType::FindMany);
                        self = self.create_resolver(entity, ResolverType::CreateOne);
                        self = self.create_resolver(entity, ResolverType::UpdateMany);
                    }
                },
                DataSource::Mongo(_) | DataSource::HTTP(_) => {
                    self = self.create_resolver(entity, ResolverType::FindOne);
                    self = self.create_resolver(entity, ResolverType::FindMany);
                    self = self.create_resolver(entity, ResolverType::CreateOne);
                    self = self.create_resolver(entity, ResolverType::UpdateOne);
                    self = self.create_resolver(entity, ResolverType::UpdateMany);
                }
            }
        }

        self
    }
}