withdraw method accept optional epoch

webserver/src/dto/pos.rs

@@ -61,4 +61,6 @@ pub struct UnbondsDto {
 pub struct WithdrawsDto {
     #[validate(range(min = 1, max = 10000))]
     pub page: Option<u64>,
+    #[validate(range(min = 1, max = 10000))]
+    pub epoch: Option<u64>,
 }

webserver/src/handler/pos.rs

@@ -128,14 +128,14 @@ pub async fn get_merged_unbonds(
 pub async fn get_withdraws(
     _headers: HeaderMap,
     query: Query<WithdrawsDto>,
-    Path((address, epoch)): Path<(String, u64)>,
+    Path(address): Path<String>,
     State(state): State<CommonState>,
 ) -> Result<Json<PaginatedResponse<Vec<Withdraw>>>, ApiError> {
     let page = query.page.unwrap_or(1);
 
     let (withdraws, total_pages, total_withdraws) = state
         .pos_service
-        .get_withdraws_by_address(address, epoch, page)
+        .get_withdraws_by_address(address, query.epoch, page)
         .await?;
 
     let response =

webserver/src/service/pos.rs

@@ -227,16 +227,22 @@ impl PosService {
     pub async fn get_withdraws_by_address(
         &self,
         address: String,
-        current_epoch: u64,
+        epoch: Option<u64>,
         page: u64,
     ) -> Result<(Vec<Withdraw>, u64, u64), PoSError> {
+        let epoch = if let Some(epoch) = epoch {
+            epoch as i32
+        } else {
+            self.chain_repo
+                .get_chain_state()
+                .await
+                .map_err(PoSError::Database)?
+                .epoch
+        };
+
         let (db_withdraws, total_pages, total_items) = self
             .pos_repo
-            .find_withdraws_by_address(
-                address,
-                current_epoch as i32,
-                page as i64,
-            )
+            .find_withdraws_by_address(address, epoch, page as i64)
             .await
             .map_err(PoSError::Database)?;