graphman: add graphman create command to graphql api

Author: shiyasmohd

server/graphman/src/resolvers/deployment_mutation.rs

@@ -3,13 +3,15 @@ use std::sync::Arc;
 use async_graphql::Context;
 use async_graphql::Object;
 use async_graphql::Result;
+use graph::prelude::SubgraphName;
 use graph_store_postgres::graphman::GraphmanStore;
 
 use crate::entities::DeploymentSelector;
 use crate::entities::EmptyResponse;
 use crate::entities::ExecutionId;
 use crate::resolvers::context::GraphmanContext;
 
+mod create;
 mod pause;
 mod restart;
 mod resume;
@@ -65,4 +67,12 @@ impl DeploymentMutation {
 
         restart::run_in_background(ctx, store, deployment, delay_seconds).await
     }
+
+    /// Create a subgraph
+    pub async fn create(&self, ctx: &Context<'_>, name: String) -> Result<EmptyResponse> {
+        let ctx = GraphmanContext::new(ctx)?;
+
+        create::run(&ctx, &name);
+        Ok(EmptyResponse::new())
+    }
 }

server/graphman/src/resolvers/deployment_mutation/create.rs

@@ -0,0 +1,24 @@
+use anyhow::anyhow;
+use graph::prelude::SubgraphName;
+use graph_store_postgres::command_support::catalog;
+use graphman::GraphmanError;
+
+use crate::resolvers::context::GraphmanContext;
+
+pub fn run(ctx: &GraphmanContext, name: &String) -> Result<(), GraphmanError> {
+    let primary_pool = ctx.primary_pool.get().map_err(GraphmanError::from)?;
+    let mut catalog_conn = catalog::Connection::new(primary_pool);
+
+    let name = match SubgraphName::new(name) {
+        Ok(name) => name,
+        Err(_) => {
+            return Err(GraphmanError::Store(anyhow!(
+                "Subgraph name must contain only a-z, A-Z, 0-9, '-' and '_'"
+            )));
+        }
+    };
+
+    catalog_conn.create_subgraph(&name);
+
+    Ok(())
+}