implement goal summary in backend

Author: VishakhaSainani-Josh

backend/internal/app/bigquery/domain.go

@@ -25,7 +25,8 @@ WHERE
     'PullRequestEvent', 
     'PullRequestReviewEvent', 
     'IssueCommentEvent', 
-    'PullRequestReviewCommentEvent'
+    'PullRequestReviewCommentEvent',
+    'PushEvent'
   )
   AND (
     actor.id IN (%s) 

backend/internal/app/contribution/service.go

@@ -3,6 +3,7 @@ package contribution
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"log/slog"
 	"net/http"
 
@@ -76,6 +77,7 @@ type Service interface {
 	ListMonthlyContributionSummary(ctx context.Context, year int, monthParam int, userId int) ([]MonthlyContributionSummary, error)
 	ListAllContributionTypes(ctx context.Context) ([]ContributionScore, error)
 	ConfigureContributionTypeScore(ctx context.Context, configureContributionTypeScore []ConfigureContributionTypeScore) ([]ContributionScore, error)
+	HandleGoalSynchronization(ctx context.Context, userId int) error
 }
 
 func NewService(bigqueryService bigquery.Service, contributionRepository repository.ContributionRepository, repositoryService repoService.Service, userService user.Service, transactionService transaction.Service, goalService goal.Service, httpClient *http.Client) Service {
@@ -153,6 +155,12 @@ func (s *service) ProcessEachContribution(ctx context.Context, contribution Cont
 		return err
 	}
 
+	err = s.HandleGoalSynchronization(ctx, obtainedContribution.UserId)
+	if err != nil {
+		slog.Error("error handling goal synchronization", "error", err)
+		return err
+	}
+
 	return nil
 }
 
@@ -274,24 +282,6 @@ func (s *service) HandleContributionCreation(ctx context.Context, repositoryID i
 		return Contribution{}, err
 	}
 
-	err = s.goalService.SyncUserGoalProgressWithContributions(ctx, user.Id)
-	if err != nil {
-		slog.Error("error syncing goal progress with contibutions", "error", err)
-		return obtainedContribution, err
-	}
-
-	err = s.goalService.AllocateBadge(ctx, user.Id)
-	if err != nil {
-		slog.Error("error allocating badge", "error", err)
-		return obtainedContribution, err
-	}
-
-	_, err = s.goalService.CreateUserGoalSummary(ctx, user.Id)
-	if err != nil {
-		slog.Error("error creating goal summary for user", "error", err)
-		return obtainedContribution, err
-	}
-
 	return obtainedContribution, nil
 }
 
@@ -387,3 +377,26 @@ func (s *service) ConfigureContributionTypeScore(ctx context.Context, configureC
 
 	return serviceContributionTypeScores, nil
 }
+
+func (s *service) HandleGoalSynchronization(ctx context.Context, userId int) error {
+	err := s.goalService.SyncUserGoalProgressWithContributions(ctx, userId)
+	if err != nil {
+		slog.Error("error syncing goal progress with contibutions", "error", err)
+		return err
+	}
+
+	err = s.goalService.AllocateBadge(ctx, userId)
+	if err != nil {
+		slog.Error("error allocating badge", "error", err)
+		return err
+	}
+
+	fmt.Println("before create user")
+	_, err = s.goalService.CreateUserGoalSummary(ctx, userId)
+	if err != nil {
+		slog.Error("error creating goal summary for user", "error", err)
+		return err
+	}
+
+	return nil
+}

backend/internal/app/goal/service.go

@@ -3,6 +3,7 @@ package goal
 import (
 	"context"
 	"errors"
+	"fmt"
 	"log/slog"
 	"time"
 
@@ -315,7 +316,7 @@ func (s *service) SyncUserGoalProgressWithContributions(ctx context.Context, use
 		return err
 	}
 
-	serviceUserCurrentGoalTargets := make([]UserGoalTarget, 0)
+	serviceUserCurrentGoalTargets := make([]UserGoalTarget, len(userCurrentGoalTargets))
 	for i, userCurrentGoalTarget := range userCurrentGoalTargets {
 		serviceUserCurrentGoalTargets[i] = UserGoalTarget(userCurrentGoalTarget)
 	}
@@ -390,12 +391,15 @@ func (s *service) UpdateUserGoalStatusMonthly(ctx context.Context) error {
 }
 
 func (s *service) CreateUserGoalSummary(ctx context.Context, userId int) (GoalSummary, error) {
+	fmt.Println("in create user goal summary ")
 	userIncompleteGoalCount, err := s.goalRepository.CalculateUserIncompleteGoalsUntilDay(ctx, nil, userId)
 	if err != nil {
 		slog.Error("error calculating user incomplete goalstatus until day", "error", err)
 		return GoalSummary{}, err
 	}
 
+	fmt.Println("in create user goal summary  2", userIncompleteGoalCount)
+
 	userCurrentGoalStatus, err := s.GetUserCurrentGoalStatus(ctx, userId)
 	if err != nil {
 		slog.Error("error getting user current goal status", "error", err)
@@ -417,7 +421,13 @@ func (s *service) CreateUserGoalSummary(ctx context.Context, userId int) (GoalSu
 		TargetCompleted:      totalTargetCompleted,
 	}
 
-	return userMonthlyGoalSummary, nil
+	createdUserGoalSummary, err := s.goalRepository.CreateUserGoalSummary(ctx, nil, repository.GoalSummary(userMonthlyGoalSummary))
+	if err != nil {
+		slog.Error("error creating user goal summary", "error", err)
+		return GoalSummary{}, err
+	}
+
+	return GoalSummary(createdUserGoalSummary), nil
 }
 
 func (s *service) FetchUserGoalSummary(ctx context.Context, userId int) ([]GoalSummary, error) {
@@ -427,7 +437,7 @@ func (s *service) FetchUserGoalSummary(ctx context.Context, userId int) ([]GoalS
 		return nil, err
 	}
 
-	serviceUserGoalSummary := make([]GoalSummary, 0, len(usersGoalSummary))
+	serviceUserGoalSummary := make([]GoalSummary, len(usersGoalSummary))
 	for i, userGoalSummary := range usersGoalSummary {
 		serviceUserGoalSummary[i] = GoalSummary(userGoalSummary)
 	}

backend/internal/db/migrations/1748862201_init.down.sql

@@ -1,5 +1,4 @@
 DROP TABLE IF EXISTS "goal_contribution";
-DROP TABLE IF EXISTS "goal";
 DROP TABLE IF EXISTS "summary";
 DROP TABLE IF EXISTS "badges";
 DROP TABLE IF EXISTS "leaderboard_hourly";
@@ -8,3 +7,4 @@ DROP TABLE IF EXISTS "contributions";
 DROP TABLE IF EXISTS "repositories";
 DROP TABLE IF EXISTS "contribution_score";
 DROP TABLE IF EXISTS "users";
+DROP TABLE IF EXISTS "goal";

backend/internal/repository/goal.go

@@ -30,6 +30,7 @@ type GoalRepository interface {
 	GetGoalLevelById(ctx context.Context, tx *sqlx.Tx, goalLevelId int) (GoalLevel, error)
 	FetchInProgressUserGoalsOfPreviousMonth(ctx context.Context, tx *sqlx.Tx) ([]UserGoal, error)
 	CalculateUserIncompleteGoalsUntilDay(ctx context.Context, tx *sqlx.Tx, userID int) (int, error)
+	CreateUserGoalSummary(ctx context.Context, tx *sqlx.Tx, userGoalSummary GoalSummary) (GoalSummary, error)
 	FetchUserGoalSummary(ctx context.Context, tx *sqlx.Tx, userId int) ([]GoalSummary, error)
 }