PenaSide/codeword
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

remove time req body

Browse Source
This commit is contained in:
Pavel 2024-04-25 20:55:07 +03:00
parent ceb8952bd3
commit 32627fcce2
2 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
internal/repository/promocode_stats.go
View File

@ -79,7 +79,7 @@ func (r *StatsRepository) GetStatistics(ctx context.Context, promoCodeID string)
return promoCodeStats, nil
}
func (r *StatsRepository) GetAllPromoActivations(ctx context.Context, req *codeword_rpc.Time) (*codeword_rpc.PromoActivationResp, error) {
func (r *StatsRepository) GetAllPromoActivations(ctx context.Context) (*codeword_rpc.PromoActivationResp, error) {
pipeline := []bson.M{
{
"$project": bson.M{
@ -128,7 +128,10 @@ func (r *StatsRepository) GetAllPromoActivations(ctx context.Context, req *codew
}
for _, user := range data.Users {
result[data.ID].Values = append(result[data.ID].Values, user.UserID)
result[data.ID].Values = append(result[data.ID].Values, &codeword_rpc.PromoActivationResp_UserTime{
UserID: user.UserID,
Time: user.Time,
})
}
}

7
internal/services/promocode_service.go
View File

@ -12,6 +12,7 @@ import (
"fmt"
"go.mongodb.org/mongo-driver/bson/primitive"
"go.uber.org/zap"
"google.golang.org/protobuf/types/known/emptypb"
"time"
)
@ -29,7 +30,7 @@ type PromoCodeRepository interface {
type PromoStatsRepository interface {
UpdateStatistics(ctx context.Context, req *models.ActivateReq, promoCode *models.PromoCode, userID string) error
GetStatistics(ctx context.Context, promoCodeID string) (models.PromoCodeStats, error)
GetAllPromoActivations(ctx context.Context, req *codeword_rpc.Time) (*codeword_rpc.PromoActivationResp, error)
GetAllPromoActivations(ctx context.Context) (*codeword_rpc.PromoActivationResp, error)
}
type PromoDeps struct {
@ -272,8 +273,8 @@ func (s *PromoCodeService) GetStats(ctx context.Context, req models.PromoStatReq
return resp, nil
}
func (s *PromoCodeService) GetAllPromoActivations(ctx context.Context, req *codeword_rpc.Time) (*codeword_rpc.PromoActivationResp, error) {
result, err := s.statsRepo.GetAllPromoActivations(ctx, req)
func (s *PromoCodeService) GetAllPromoActivations(ctx context.Context, _ *emptypb.Empty) (*codeword_rpc.PromoActivationResp, error) {
result, err := s.statsRepo.GetAllPromoActivations(ctx)
if err != nil {
s.logger.Error("error getting all promo activations data", zap.Error(err))
return nil, err