Implement get_orders_by_token endpoint and refactor orders module

Cargo.toml

@@ -14,6 +14,7 @@ utoipa-swagger-ui = { version = "9", features = ["rocket"] }
 tokio = { version = "1", features = ["full"] }
 alloy = { version = "=1.0.12", default-features = false, features = ["std", "serde"] }
 async-trait = "0.1"
+futures = "0.3"
 tracing = "0.1"
 tracing-subscriber = { version = "0.3", features = ["env-filter", "json"] }
 tracing-appender = "0.2"

src/main.rs

@@ -61,6 +61,7 @@ enum StartupError {
         routes::order::post_order_cancel,
         routes::orders::get_orders_by_tx,
         routes::orders::get_orders_by_address,
+        routes::orders::get_orders_by_token,
         routes::trades::get_trades_by_tx,
         routes::trades::get_trades_by_address,
         routes::registry::get_registry,

src/routes/order/mod.rs

@@ -34,13 +34,15 @@ impl<'a> OrderDataSource for RaindexOrderDataSource<'a> {
             order_hash: Some(hash),
             ..Default::default()
         };
-        self.client
-            .get_orders(None, Some(filters), None)
+        let result = self
+            .client
+            .get_orders(None, Some(filters), None, None)
             .await
             .map_err(|e| {
                 tracing::error!(error = %e, "failed to query orders");
                 ApiError::Internal("failed to query orders".into())
-            })
+            })?;
+        Ok(result.orders().to_vec())
     }
 
     async fn get_order_quotes(

src/routes/orders/get_by_owner.rs

@@ -0,0 +1,46 @@
+use crate::auth::AuthenticatedKey;
+use crate::error::{ApiError, ApiErrorResponse};
+use crate::fairings::{GlobalRateLimit, TracingSpan};
+use crate::types::common::ValidatedAddress;
+use crate::types::orders::{OrdersListResponse, OrdersPaginationParams};
+use rocket::serde::json::Json;
+use rocket::State;
+use tracing::Instrument;
+
+#[utoipa::path(
+    get,
+    path = "/v1/orders/owner/{address}",
+    tag = "Orders",
+    security(("basicAuth" = [])),
+    params(
+        ("address" = String, Path, description = "Owner address"),
+        OrdersPaginationParams,
+    ),
+    responses(
+        (status = 200, description = "Paginated list of orders", body = OrdersListResponse),
+        (status = 400, description = "Bad request", body = ApiErrorResponse),
+        (status = 401, description = "Unauthorized", body = ApiErrorResponse),
+        (status = 429, description = "Rate limited", body = ApiErrorResponse),
+        (status = 500, description = "Internal server error", body = ApiErrorResponse),
+    )
+)]
+#[get("/owner/<address>?<params..>")]
+pub async fn get_orders_by_address(
+    _global: GlobalRateLimit,
+    _key: AuthenticatedKey,
+    shared_raindex: &State<crate::raindex::SharedRaindexProvider>,
+    span: TracingSpan,
+    address: ValidatedAddress,
+    params: OrdersPaginationParams,
+) -> Result<Json<OrdersListResponse>, ApiError> {
+    async move {
+        tracing::info!(address = ?address, params = ?params, "request received");
+        let raindex = shared_raindex.read().await;
+        raindex
+            .run_with_client(move |_client| async move { todo!() })
+            .await
+            .map_err(ApiError::from)?
+    }
+    .instrument(span.0)
+    .await
+}