add dips graphql

Author: mangas

service/src/routes/dips.rs

@@ -0,0 +1,65 @@
+use async_graphql::{Context, FieldResult, Object, SimpleObject};
+
+#[derive(SimpleObject, Debug)]
+struct Agreement {
+    signature: String,
+    data: String,
+    protocol_network: String,
+}
+
+#[derive(SimpleObject, Debug)]
+struct Price {
+    price_per_block: String,
+    chain_id: String,
+    protocol_network: String,
+}
+
+#[derive(Debug)]
+pub struct AgreementQuery {}
+
+#[Object]
+impl AgreementQuery {
+    pub async fn get_agreement<'a>(
+        &self,
+        ctx: &'a Context<'_>,
+        signature: String,
+    ) -> FieldResult<Agreement> {
+        todo!()
+    }
+
+    pub async fn get_price<'a>(
+        &self,
+        ctx: &'a Context<'_>,
+        protocol_network: String,
+        chain_id: String,
+    ) -> FieldResult<Price> {
+        todo!()
+    }
+
+    pub async fn get_all_prices<'a>(&self, ctx: &'a Context<'_>) -> FieldResult<Vec<Price>> {
+        todo!()
+    }
+}
+
+#[derive(Debug)]
+pub struct AgreementMutation {}
+
+#[Object]
+impl AgreementMutation {
+    pub async fn create_agreement<'a>(
+        &self,
+        ctx: &'a Context<'_>,
+        signature: String,
+        data: String,
+    ) -> FieldResult<Agreement> {
+        todo!()
+    }
+
+    pub async fn cancel_agreement<'a>(
+        &self,
+        ctx: &'a Context<'_>,
+        signature: String,
+    ) -> FieldResult<Agreement> {
+        todo!()
+    }
+}

service/src/routes/mod.rs

@@ -2,6 +2,7 @@
 // SPDX-License-Identifier: Apache-2.0
 
 pub mod cost;
+pub mod dips;
 mod status;
 
 pub use status::status;

service/src/service.rs

@@ -6,7 +6,13 @@ use std::time::Duration;
 
 use super::{config::Config, error::SubgraphServiceError, routes};
 use anyhow::anyhow;
-use axum::{async_trait, routing::post, Json, Router};
+use async_graphql::{EmptySubscription, Schema};
+use async_graphql_axum::GraphQL;
+use axum::{
+    async_trait,
+    routing::{post, post_service},
+    Json, Router,
+};
 use indexer_common::indexer_service::http::{
     AttestationOutput, IndexerServiceImpl, IndexerServiceResponse,
 };
@@ -173,6 +179,13 @@ pub async fn run() -> anyhow::Result<()> {
             .clone(),
     });
 
+    let schema = Schema::build(
+        routes::dips::AgreementQuery {},
+        routes::dips::AgreementMutation {},
+        EmptySubscription,
+    )
+    .finish();
+
     IndexerService::run(IndexerServiceOptions {
         release,
         config: config.0.clone(),
@@ -182,6 +195,7 @@ pub async fn run() -> anyhow::Result<()> {
         extra_routes: Router::new()
             .route("/cost", post(routes::cost::cost))
             .route("/status", post(routes::status))
+            .route("/dips", post_service(GraphQL::new(schema)))
             .with_state(state),
     })
     .await