From e3f40937cae47dbd03bf87385b1bf7d0abb32766 Mon Sep 17 00:00:00 2001 From: noobj Date: Thu, 22 Sep 2022 18:54:03 +0800 Subject: [PATCH] fix: entries aggregation sum up failed --- cmd/ahorro/fetchentries/main.go | 5 +++-- internal/middleware/jwt_auth/jwt_auth_middleware.go | 1 - 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/cmd/ahorro/fetchentries/main.go b/cmd/ahorro/fetchentries/main.go index fe66ba0..34cbbf6 100644 --- a/cmd/ahorro/fetchentries/main.go +++ b/cmd/ahorro/fetchentries/main.go @@ -102,7 +102,9 @@ func Handler(ctx context.Context, request events.APIGatewayV2HTTPRequest) (event }}}, }, {Key: "sum", Value: bson.D{{ - Key: "$sum", Value: "$amount"}, + Key: "$sum", Value: bson.M{ + "$toDecimal": "$amount", + }}, }}, }, }} @@ -122,7 +124,6 @@ func Handler(ctx context.Context, request events.APIGatewayV2HTTPRequest) (event repoResults := entryRepository.Aggregate([]bson.D{matchStage, sortStage, groupStage, sortSumStage, lookupStage}) var categories []CategoryEntriesBundle total := 0 - for _, repoResult := range repoResults { doc, _ := bson.Marshal(repoResult) diff --git a/internal/middleware/jwt_auth/jwt_auth_middleware.go b/internal/middleware/jwt_auth/jwt_auth_middleware.go index 1e2fb53..48e4939 100644 --- a/internal/middleware/jwt_auth/jwt_auth_middleware.go +++ b/internal/middleware/jwt_auth/jwt_auth_middleware.go @@ -26,7 +26,6 @@ func payloadHandler(ctx context.Context, payload interface{}) (context.Context, } userRepo := UserRepository.New() - defer userRepo.Disconnect()() var user UserRepository.User err := userRepo.FindOne(context.TODO(), bson.M{"_id": userObjId}).Decode(&user)