feat: Get All Inactive User API Added

src/apis/data/trade-user/get-in-active-trade-user.api.go

@@ -0,0 +1,21 @@
+package tradeuser
+
+import (
+	"github.com/gofiber/fiber/v2"
+	"github.com/rpsoftech/bullion-server/src/interfaces"
+	"github.com/rpsoftech/bullion-server/src/services"
+)
+
+func apiGetInActiveTradeUsers(c *fiber.Ctx) error {
+	bullionId, err := interfaces.ExtractBullionIdFromCtx(c)
+	if err != nil {
+		return err
+	}
+	entity, err := services.TradeUserService.FindAndReturnAllInActiveTradeUsers(bullionId)
+	if err != nil {
+		return err
+	} else {
+		return c.JSON(entity)
+	}
+
+}

src/apis/data/trade-user/index.go

@@ -7,6 +7,7 @@ import (
 
 func AddTradeUserAPIs(router fiber.Router) {
 	adminGroup := router.Use(middleware.AllowOnlyBigAdmins.Validate)
+	adminGroup.Get("/getInActiveTradeUsers", apiGetInActiveTradeUsers)
 	adminGroup.Get("/getTradeUser", apiGetTradeUserDetails)
 	adminGroup.Patch("/updateTradeUserDetails", apiUpdateTradeUserDetails)
 	adminGroup.Patch("/updateTradeUserStatus", apiChangeTradeUserStatus)

src/interfaces/base-entity.go

@@ -32,6 +32,11 @@ type BaseEntity struct {
 // 	return json.Marshal(base)
 // }
 
+func (b *BaseEntity) RevertTimeStamps() *BaseEntity {
+	b.CreatedAt = b.CreatedAtExported
+	b.ModifiedAt = b.ModifiedAtExported
+	return b
+}
 func (b *BaseEntity) AddTimeStamps() *BaseEntity {
 	b.CreatedAtExported = b.CreatedAt
 	b.ModifiedAtExported = b.ModifiedAt

src/mongodb/repos/bank-rate-calc.repo.go

@@ -41,6 +41,7 @@ func init() {
 }
 
 func (repo *BankRateCalcRepoStruct) cacheDataToRedis(entity *interfaces.BankRateCalcEntity) {
+	entity.AddTimeStamps()
 	if entityStringBytes, err := json.Marshal(entity); err == nil {
 		entityString := string(entityStringBytes)
 		repo.redis.SetStringDataWithExpiry(fmt.Sprintf("%s/%s", bankRateRedisCollection, entity.BullionId), entityString, time.Duration(24)*time.Hour)
@@ -73,6 +74,7 @@ func (repo *BankRateCalcRepoStruct) FindOneByBullionId(id string) (*interfaces.B
 	result := new(interfaces.BankRateCalcEntity)
 	if redisData := repo.redis.GetStringData(fmt.Sprintf("%s/%s", bankRateRedisCollection, id)); redisData != "" {
 		if err := json.Unmarshal([]byte(redisData), result); err == nil {
+			result.RevertTimeStamps()
 			return result, err
 		}
 	}

src/mongodb/repos/trade-user.repo.go

@@ -133,10 +133,25 @@ func (repo *TradeUserRepoStruct) findByFilter(filter *mongoDbFilter) (*[]interfa
 	return &result, err
 }
 
+func (repo *TradeUserRepoStruct) FindAllInActiveUser(bullionId string) (*[]interfaces.TradeUserEntity, error) {
+	return repo.findByFilter(&mongoDbFilter{
+		conditions: &bson.D{
+			{
+				Key: "$and",
+				Value: bson.A{
+					bson.D{{Key: "bullionId", Value: bullionId}},
+					bson.D{{Key: "isActive", Value: false}},
+				},
+			},
+		},
+	})
+}
+
 func (repo *TradeUserRepoStruct) FindOne(id string) (*interfaces.TradeUserEntity, error) {
 	result := new(interfaces.TradeUserEntity)
 	if redisData := repo.redis.GetStringData(fmt.Sprintf("tradeUser/%s", id)); redisData != "" {
 		if err := json.Unmarshal([]byte(redisData), result); err == nil {
+			result.RevertTimeStamps()
 			return result, err
 		}
 	}
@@ -167,6 +182,7 @@ func (repo *TradeUserRepoStruct) FindOne(id string) (*interfaces.TradeUserEntity
 }
 
 func (repo *TradeUserRepoStruct) cacheDataToRedis(entity *interfaces.TradeUserEntity) {
+	entity.AddTimeStamps()
 	if entityStringBytes, err := json.Marshal(entity); err == nil {
 		entityString := string(entityStringBytes)
 		repo.redis.SetStringDataWithExpiry(fmt.Sprintf("tradeUser/%s", entity.ID), entityString, time.Duration(24)*time.Hour)

src/services/trade-user.service.go

@@ -327,6 +327,9 @@ func (service *tradeUserServiceStruct) generateTokensForTradeUserWithPasswordMat
 	return service.generateTokensForTradeUser(tradeUser)
 }
 
+func (service *tradeUserServiceStruct) FindAndReturnAllInActiveTradeUsers(bullionId string) (*[]interfaces.TradeUserEntity, error) {
+	return service.tradeUserRepo.FindAllInActiveUser(bullionId)
+}
 func (service *tradeUserServiceStruct) FindOneUserById(id string) (*interfaces.TradeUserEntity, error) {
 	return service.tradeUserRepo.FindOne(id)
 }