aboutsummaryrefslogtreecommitdiffstats
path: root/lib/api-config/src/schema/create.rs
diff options
context:
space:
mode:
Diffstat (limited to 'lib/api-config/src/schema/create.rs')
-rw-r--r--lib/api-config/src/schema/create.rs32
1 files changed, 0 insertions, 32 deletions
diff --git a/lib/api-config/src/schema/create.rs b/lib/api-config/src/schema/create.rs
index de2d214..5c91f64 100644
--- a/lib/api-config/src/schema/create.rs
+++ b/lib/api-config/src/schema/create.rs
@@ -1,8 +1,4 @@
-use async_trait::async_trait;
use serde::{Deserialize, Serialize};
-use warden_core::state::AppState;
-
-use crate::schema::{SchemaDriver, TransactionSchema};
#[derive(Deserialize, Serialize)]
#[cfg_attr(feature = "utoipa", derive(utoipa::ToSchema))]
@@ -17,31 +13,3 @@ pub struct CreateSchema {
#[serde(rename = "json_schema")]
pub schema: serde_json::Value,
}
-
-#[async_trait]
-impl SchemaDriver for AppState {
- async fn create_schema(
- &self,
- name: impl AsRef<str> + Send + Sync,
- version: impl AsRef<str> + Send + Sync,
- schema: &serde_json::Value,
- ) -> Result<super::TransactionSchema, crate::ConfigurationError> {
- sqlx::query_as!(
- TransactionSchema,
- "insert into transaction_schema (type, version, json_schema) values ($1, $2, $3)
- returning
- type as kind,
- version,
- json_schema as schema,
- created_at,
- updated_at
- ",
- name.as_ref(),
- version.as_ref(),
- sqlx::types::Json(&schema) as _
- )
- .fetch_one(&self.database)
- .await
- .map_err(|e| e.into())
- }
-}