From 9e813c1e519bcd022991382cb7766591cfbe8fbf Mon Sep 17 00:00:00 2001
From: "ashutosh.nehete" <ashutosh.nehete@marcoaiot.com>
Date: Thu, 15 May 2025 19:26:55 +0530
Subject: [PATCH] Added an API to Get a list of buckets Assigned to that
 employee

---
 Marco.Pms.Model/Mapper/DirectoryMapper.cs     | 11 ++++++++++
 .../Controllers/DirectoryController.cs        |  6 +++++
 Marco.Pms.Services/Helpers/DirectoryHelper.cs | 22 +++++++++++++++++++
 3 files changed, 39 insertions(+)

diff --git a/Marco.Pms.Model/Mapper/DirectoryMapper.cs b/Marco.Pms.Model/Mapper/DirectoryMapper.cs
index 9b5c835..b5d6667 100644
--- a/Marco.Pms.Model/Mapper/DirectoryMapper.cs
+++ b/Marco.Pms.Model/Mapper/DirectoryMapper.cs
@@ -178,5 +178,16 @@ namespace Marco.Pms.Model.Mapper
                 Description = contactType.Description ?? string.Empty,
             };
         }
+
+        // Bucket
+        public static BucketVM ToBucketVMFromBucket(this Bucket bucket)
+        {
+            return new BucketVM
+            {
+                Id = bucket.Id,
+                Name = bucket.Name,
+                Description = bucket.Description
+            };
+        }
     }
 }
diff --git a/Marco.Pms.Services/Controllers/DirectoryController.cs b/Marco.Pms.Services/Controllers/DirectoryController.cs
index fe82bce..65ccd2d 100644
--- a/Marco.Pms.Services/Controllers/DirectoryController.cs
+++ b/Marco.Pms.Services/Controllers/DirectoryController.cs
@@ -83,5 +83,11 @@ namespace Marco.Pms.Services.Controllers
         }
 
 
+        [HttpGet("buckets")]
+        public async Task<IActionResult> GetBucketList()
+        {
+            var response = await _directoryHelper.GetBucketList();
+            return Ok(response);
+        }
     }
 }
diff --git a/Marco.Pms.Services/Helpers/DirectoryHelper.cs b/Marco.Pms.Services/Helpers/DirectoryHelper.cs
index fb68e67..a922c3f 100644
--- a/Marco.Pms.Services/Helpers/DirectoryHelper.cs
+++ b/Marco.Pms.Services/Helpers/DirectoryHelper.cs
@@ -1772,5 +1772,27 @@ namespace Marco.Pms.Services.Helpers
             _logger.LogWarning("Employee with ID {LoggedInEmployeeId} sended empty payload", LoggedInEmployee.Id);
             return ApiResponse<object>.ErrorResponse("User Send empty Payload", "User Send empty Payload", 400);
         }
+
+        // -------------------------------- Bucket  --------------------------------
+
+        public async Task<ApiResponse<object>> GetBucketList()
+        {
+            Guid tenantId = _userHelper.GetTenantId();
+            var LoggedInEmployee = await _userHelper.GetCurrentEmployeeAsync();
+
+            List<EmployeeBucketMapping> employeeBuckets = await _context.EmployeeBucketMappings.Where(b => b.EmployeeId == LoggedInEmployee.Id).ToListAsync();
+            var bucketIds = employeeBuckets.Select(b => b.BucketId).ToList();
+
+            List<Bucket> bucketList = await _context.Buckets.Where(b => bucketIds.Contains(b.Id)).ToListAsync();
+
+            List<BucketVM> bucketVMs = new List<BucketVM>();
+            foreach (var bucket in bucketList)
+            {
+                BucketVM bucketVM = bucket.ToBucketVMFromBucket();
+                bucketVMs.Add(bucketVM);
+            }
+            _logger.LogInfo("{count} Buckets are fetched by Employee with ID {LoggedInEmployeeId}", bucketVMs.Count, LoggedInEmployee.Id);
+            return ApiResponse<object>.SuccessResponse(bucketVMs, System.String.Format("{0} buckets fetched successfully", bucketVMs.Count), 200);
+        }
     }
 }