grid-sdk 0.1.3

Hyperledger Grid is a platform for building supply chain solutions that include distributed ledger components. It provides a growing set of tools that accelerate development for supply chain smart contractsand client interfaces.
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
102
103

// Copyright 2018-2020 Cargill Incorporated
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

use crate::commits::store::diesel::schema::{chain_record::dsl::*, commits::dsl::*};
#[cfg(feature = "location")]
use crate::locations::store::diesel::schema::{location::dsl::*, location_attribute::dsl::*};
#[cfg(feature = "product")]
use crate::products::store::diesel::schema::{product::dsl::*, product_property_value::dsl::*};
#[cfg(feature = "schema")]
use crate::schemas::store::diesel::schema::{
    grid_property_definition::dsl::grid_property_definition, grid_schema::dsl::*,
};
#[cfg(feature = "track-and-trace")]
use crate::track_and_trace::store::diesel::schema::{
    associated_agent::dsl::*, property::dsl::*, proposal::dsl::*, record::dsl::*,
    reported_value::dsl::*, reporter::dsl::*,
};
#[cfg(feature = "pike")]
use crate::{
    agents::store::diesel::schema::{agent::dsl::*, role::dsl::role},
    organizations::store::diesel::schema::organization::dsl::*,
};

use diesel::RunQueryDsl;
#[cfg(feature = "sqlite")]
use diesel::{sqlite::SqliteConnection, Connection};

use crate::error::ResourceTemporarilyUnavailableError;
use crate::migrations::error::MigrationsError;

embed_migrations!("./src/migrations/diesel/sqlite/migrations");

/// Run database migrations to create Grid tables
///
/// # Arguments
///
/// * `conn` - Connection to database
///
#[cfg(all(feature = "sqlite", feature = "diesel"))]
pub fn run_migrations(conn: &SqliteConnection) -> Result<(), MigrationsError> {
    embedded_migrations::run(conn).map_err(|err| {
        MigrationsError::ResourceTemporarilyUnavailableError(
            ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
        )
    })?;

    info!("Successfully applied Grid migrations");

    Ok(())
}

#[cfg(all(feature = "sqlite", feature = "diesel"))]
pub fn clear_database(conn: &SqliteConnection) -> Result<(), MigrationsError> {
    conn.transaction::<_, MigrationsError, _>(|| {
        #[cfg(feature = "pike")]
        {
            diesel::delete(agent).execute(conn)?;
            diesel::delete(organization).execute(conn)?;
            diesel::delete(role).execute(conn)?;
        }
        #[cfg(feature = "location")]
        {
            diesel::delete(location_attribute).execute(conn)?;
            diesel::delete(location).execute(conn)?;
        }
        #[cfg(feature = "product")]
        {
            diesel::delete(product).execute(conn)?;
            diesel::delete(product_property_value).execute(conn)?;
        }
        #[cfg(feature = "schema")]
        {
            diesel::delete(grid_property_definition).execute(conn)?;
            diesel::delete(grid_schema).execute(conn)?;
        }
        #[cfg(feature = "track-and-trace")]
        {
            diesel::delete(associated_agent).execute(conn)?;
            diesel::delete(property).execute(conn)?;
            diesel::delete(proposal).execute(conn)?;
            diesel::delete(record).execute(conn)?;
            diesel::delete(reported_value).execute(conn)?;
            diesel::delete(reporter).execute(conn)?;
        }
        diesel::delete(chain_record).execute(conn)?;
        diesel::delete(commits).execute(conn)?;

        Ok(())
    })?;

    Ok(())
}