grid-sdk 0.3.5

// Copyright 2018-2021 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.

pub mod models;
mod operations;
pub(in crate) mod schema;

use diesel::connection::AnsiTransactionManager;
use diesel::r2d2::{ConnectionManager, Pool};

use super::{
    ListPOFilters, ListVersionFilters, PurchaseOrder, PurchaseOrderAlternateId,
    PurchaseOrderAlternateIdList, PurchaseOrderList, PurchaseOrderStore, PurchaseOrderStoreError,
    PurchaseOrderVersion, PurchaseOrderVersionList, PurchaseOrderVersionRevision,
    PurchaseOrderVersionRevisionList,
};

use models::{
    make_purchase_order_version_revisions, make_purchase_order_versions,
    NewPurchaseOrderAlternateIdModel,
};

use crate::error::ResourceTemporarilyUnavailableError;

use operations::add_purchase_order::PurchaseOrderStoreAddPurchaseOrderOperation as _;
use operations::get_latest_revision_id::PurchaseOrderStoreGetLatestRevisionIdOperation as _;
use operations::get_purchase_order::PurchaseOrderStoreGetPurchaseOrderOperation as _;
use operations::get_purchase_order_version::PurchaseOrderStoreGetPurchaseOrderVersionOperation as _;
use operations::get_purchase_order_version_revision::PurchaseOrderStoreGetPurchaseOrderRevisionOperation as _;
use operations::list_alternate_ids_for_purchase_order::PurchaseOrderStoreListAlternateIdsForPurchaseOrderOperation as _;
use operations::list_purchase_order_version_revisions::PurchaseOrderStoreListPurchaseOrderRevisionsOperation as _;
use operations::list_purchase_order_versions::PurchaseOrderStoreListPurchaseOrderVersionsOperation as _;
use operations::list_purchase_orders::PurchaseOrderStoreListPurchaseOrdersOperation as _;
use operations::PurchaseOrderStoreOperations;

/// Manages creating agents in the database
#[derive(Clone)]
pub struct DieselPurchaseOrderStore<C: diesel::Connection + 'static> {
    connection_pool: Pool<ConnectionManager<C>>,
}

impl<C: diesel::Connection> DieselPurchaseOrderStore<C> {
    /// Creates a new DieselPurchaseOrderStore
    ///
    /// # Arguments
    ///
    ///  * `connection_pool`: connection pool to the database
    pub fn new(connection_pool: Pool<ConnectionManager<C>>) -> Self {
        DieselPurchaseOrderStore { connection_pool }
    }
}

#[cfg(feature = "postgres")]
impl PurchaseOrderStore for DieselPurchaseOrderStore<diesel::pg::PgConnection> {
    fn add_purchase_order(&self, order: PurchaseOrder) -> Result<(), PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .add_purchase_order(
            order.clone().into(),
            make_purchase_order_versions(&order),
            make_purchase_order_version_revisions(&order),
            order
                .alternate_ids
                .iter()
                .map(NewPurchaseOrderAlternateIdModel::from)
                .collect(),
        )
    }

    fn list_purchase_orders(
        &self,
        filters: ListPOFilters,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .list_purchase_orders(filters, service_id, offset, limit)
    }

    fn list_purchase_order_versions(
        &self,
        po_uid: &str,
        filters: ListVersionFilters,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderVersionList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .list_purchase_order_versions(po_uid, filters, service_id, offset, limit)
    }

    fn get_purchase_order(
        &self,
        purchase_order_uid: &str,
        version_id: Option<&str>,
        revision_number: Option<i64>,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrder>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .get_purchase_order(purchase_order_uid, version_id, revision_number, service_id)
    }

    fn get_purchase_order_version(
        &self,
        po_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrderVersion>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .get_purchase_order_version(po_uid, version_id, service_id)
    }

    fn get_purchase_order_revision(
        &self,
        po_uid: &str,
        version_id: &str,
        revision_id: &i64,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrderVersionRevision>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .get_purchase_order_revision(po_uid, version_id, revision_id, service_id)
    }

    fn list_purchase_order_revisions(
        &self,
        po_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderVersionRevisionList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .list_purchase_order_revisions(po_uid, version_id, service_id, offset, limit)
    }

    fn list_alternate_ids_for_purchase_order(
        &self,
        purchase_order_uid: &str,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderAlternateIdList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .list_alternate_ids_for_purchase_order(
            purchase_order_uid,
            service_id,
            offset,
            limit,
        )
    }

    fn get_latest_revision_id(
        &self,
        purchase_order_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
    ) -> Result<Option<i64>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .get_latest_revision_id(purchase_order_uid, version_id, service_id)
    }
}

#[cfg(feature = "sqlite")]
impl PurchaseOrderStore for DieselPurchaseOrderStore<diesel::sqlite::SqliteConnection> {
    fn add_purchase_order(&self, order: PurchaseOrder) -> Result<(), PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .add_purchase_order(
            order.clone().into(),
            make_purchase_order_versions(&order),
            make_purchase_order_version_revisions(&order),
            order
                .alternate_ids
                .iter()
                .map(NewPurchaseOrderAlternateIdModel::from)
                .collect(),
        )
    }

    fn list_purchase_orders(
        &self,
        filters: ListPOFilters,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .list_purchase_orders(filters, service_id, offset, limit)
    }

    fn list_purchase_order_versions(
        &self,
        po_uid: &str,
        filters: ListVersionFilters,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderVersionList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .list_purchase_order_versions(po_uid, filters, service_id, offset, limit)
    }

    fn get_purchase_order(
        &self,
        purchase_order_uid: &str,
        version_id: Option<&str>,
        revision_number: Option<i64>,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrder>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .get_purchase_order(purchase_order_uid, version_id, revision_number, service_id)
    }

    fn get_purchase_order_version(
        &self,
        po_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrderVersion>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .get_purchase_order_version(po_uid, version_id, service_id)
    }

    fn get_purchase_order_revision(
        &self,
        po_uid: &str,
        version_id: &str,
        revision_id: &i64,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrderVersionRevision>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .get_purchase_order_revision(po_uid, version_id, revision_id, service_id)
    }

    fn list_purchase_order_revisions(
        &self,
        po_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderVersionRevisionList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .list_purchase_order_revisions(po_uid, version_id, service_id, offset, limit)
    }

    fn list_alternate_ids_for_purchase_order(
        &self,
        purchase_order_uid: &str,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderAlternateIdList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .list_alternate_ids_for_purchase_order(
            purchase_order_uid,
            service_id,
            offset,
            limit,
        )
    }

    fn get_latest_revision_id(
        &self,
        purchase_order_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
    ) -> Result<Option<i64>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(&*self.connection_pool.get().map_err(|err| {
            PurchaseOrderStoreError::ResourceTemporarilyUnavailableError(
                ResourceTemporarilyUnavailableError::from_source(Box::new(err)),
            )
        })?)
        .get_latest_revision_id(purchase_order_uid, version_id, service_id)
    }
}

pub struct DieselConnectionPurchaseOrderStore<'a, C>
where
    C: diesel::Connection<TransactionManager = AnsiTransactionManager> + 'static,
    C::Backend: diesel::backend::UsesAnsiSavepointSyntax,
{
    connection: &'a C,
}

impl<'a, C> DieselConnectionPurchaseOrderStore<'a, C>
where
    C: diesel::Connection<TransactionManager = AnsiTransactionManager> + 'static,
    C::Backend: diesel::backend::UsesAnsiSavepointSyntax,
{
    pub fn new(connection: &'a C) -> Self {
        DieselConnectionPurchaseOrderStore { connection }
    }
}

#[cfg(feature = "postgres")]
impl<'a> PurchaseOrderStore for DieselConnectionPurchaseOrderStore<'a, diesel::pg::PgConnection> {
    fn add_purchase_order(&self, order: PurchaseOrder) -> Result<(), PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).add_purchase_order(
            order.clone().into(),
            make_purchase_order_versions(&order),
            make_purchase_order_version_revisions(&order),
            order
                .alternate_ids
                .iter()
                .map(NewPurchaseOrderAlternateIdModel::from)
                .collect(),
        )
    }

    fn list_purchase_orders(
        &self,
        filters: ListPOFilters,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection)
            .list_purchase_orders(filters, service_id, offset, limit)
    }

    fn list_purchase_order_versions(
        &self,
        po_uid: &str,
        filters: ListVersionFilters,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderVersionList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection)
            .list_purchase_order_versions(po_uid, filters, service_id, offset, limit)
    }

    fn get_purchase_order(
        &self,
        purchase_order_uid: &str,
        version_id: Option<&str>,
        revision_number: Option<i64>,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrder>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).get_purchase_order(
            purchase_order_uid,
            version_id,
            revision_number,
            service_id,
        )
    }

    fn get_purchase_order_version(
        &self,
        po_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrderVersion>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection)
            .get_purchase_order_version(po_uid, version_id, service_id)
    }

    fn get_purchase_order_revision(
        &self,
        po_uid: &str,
        version_id: &str,
        revision_id: &i64,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrderVersionRevision>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).get_purchase_order_revision(
            po_uid,
            version_id,
            revision_id,
            service_id,
        )
    }

    fn list_purchase_order_revisions(
        &self,
        po_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderVersionRevisionList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection)
            .list_purchase_order_revisions(po_uid, version_id, service_id, offset, limit)
    }

    fn list_alternate_ids_for_purchase_order(
        &self,
        purchase_order_uid: &str,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderAlternateIdList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).list_alternate_ids_for_purchase_order(
            purchase_order_uid,
            service_id,
            offset,
            limit,
        )
    }

    fn get_latest_revision_id(
        &self,
        purchase_order_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
    ) -> Result<Option<i64>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).get_latest_revision_id(
            purchase_order_uid,
            version_id,
            service_id,
        )
    }
}

#[cfg(feature = "sqlite")]
impl<'a> PurchaseOrderStore
    for DieselConnectionPurchaseOrderStore<'a, diesel::sqlite::SqliteConnection>
{
    fn add_purchase_order(&self, order: PurchaseOrder) -> Result<(), PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).add_purchase_order(
            order.clone().into(),
            make_purchase_order_versions(&order),
            make_purchase_order_version_revisions(&order),
            order
                .alternate_ids
                .iter()
                .map(NewPurchaseOrderAlternateIdModel::from)
                .collect(),
        )
    }

    fn list_purchase_orders(
        &self,
        filters: ListPOFilters,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection)
            .list_purchase_orders(filters, service_id, offset, limit)
    }

    fn list_purchase_order_versions(
        &self,
        po_uid: &str,
        filters: ListVersionFilters,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderVersionList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection)
            .list_purchase_order_versions(po_uid, filters, service_id, offset, limit)
    }

    fn get_purchase_order(
        &self,
        purchase_order_uid: &str,
        version_id: Option<&str>,
        revision_number: Option<i64>,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrder>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).get_purchase_order(
            purchase_order_uid,
            version_id,
            revision_number,
            service_id,
        )
    }

    fn get_purchase_order_version(
        &self,
        po_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrderVersion>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection)
            .get_purchase_order_version(po_uid, version_id, service_id)
    }

    fn get_purchase_order_revision(
        &self,
        po_uid: &str,
        version_id: &str,
        revision_id: &i64,
        service_id: Option<&str>,
    ) -> Result<Option<PurchaseOrderVersionRevision>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).get_purchase_order_revision(
            po_uid,
            version_id,
            revision_id,
            service_id,
        )
    }

    fn list_purchase_order_revisions(
        &self,
        po_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderVersionRevisionList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection)
            .list_purchase_order_revisions(po_uid, version_id, service_id, offset, limit)
    }

    fn list_alternate_ids_for_purchase_order(
        &self,
        purchase_order_uid: &str,
        service_id: Option<&str>,
        offset: i64,
        limit: i64,
    ) -> Result<PurchaseOrderAlternateIdList, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).list_alternate_ids_for_purchase_order(
            purchase_order_uid,
            service_id,
            offset,
            limit,
        )
    }

    fn get_latest_revision_id(
        &self,
        purchase_order_uid: &str,
        version_id: &str,
        service_id: Option<&str>,
    ) -> Result<Option<i64>, PurchaseOrderStoreError> {
        PurchaseOrderStoreOperations::new(self.connection).get_latest_revision_id(
            purchase_order_uid,
            version_id,
            service_id,
        )
    }
}