feat: HOLY SHIT IT WORKS LMFAO

Author: AlexanderWangY

apps/api/cmd/BAT_worker/main.go

@@ -6,6 +6,8 @@ import (
 	"github.com/hibiken/asynq"
 	"github.com/swamphacks/core/apps/api/internal/bat"
 	"github.com/swamphacks/core/apps/api/internal/config"
+	"github.com/swamphacks/core/apps/api/internal/db"
+	"github.com/swamphacks/core/apps/api/internal/db/repository"
 	"github.com/swamphacks/core/apps/api/internal/logger"
 	"github.com/swamphacks/core/apps/api/internal/services"
 	"github.com/swamphacks/core/apps/api/internal/tasks"
@@ -59,7 +61,13 @@ func main() {
 		logger.Fatal().Err(err).Msg("Bat engine failed to initialize.")
 	}
 
-	batService := services.NewBatService(batEngine, nil, logger)
+	database := db.NewDB(cfg.DatabaseURL)
+	defer database.Close()
+
+	eventRepo := repository.NewEventRespository(database)
+	applicationRepo := repository.NewApplicationRepository(database)
+
+	batService := services.NewBatService(batEngine, applicationRepo, eventRepo, nil, logger)
 
 	BATWorker := workers.NewBATWorker(batService, logger)
 

apps/api/cmd/api/main.go

@@ -97,7 +97,7 @@ func main() {
 	emailService := services.NewEmailService(taskQueueClient, sesClient, logger)
 	applicationService := services.NewApplicationService(applicationRepo, eventService, emailService, txm, r2Client, &cfg.CoreBuckets, logger)
 	teamService := services.NewTeamService(teamRepo, teamMemberRepo, teamJoinRequestRepo, eventRepo, txm, logger)
-	batService := services.NewBatService(batEngine, taskQueueClient, logger)
+	batService := services.NewBatService(batEngine, applicationRepo, eventRepo, taskQueueClient, logger)
 
 	// Injections into handlers
 	apiHandlers := handlers.NewHandlers(authService, userService, eventInterestService, eventService, emailService, applicationService, teamService, batService, cfg, logger)

apps/api/internal/db/queries/applications.sql

@@ -39,11 +39,23 @@ WHERE event_id = $1
 ORDER BY 
     user_id ASC;
 
--- name: ListApplicationsByEventAndStatus :many
-SELECT user_id, application, experience_rating, passion_rating
-FROM applications
-WHERE event_id = $1
-    AND status = $2;
+-- name: ListAdmissionCandidatesByEvent :many
+SELECT a.user_id,
+    a.passion_rating,
+    a.experience_rating,
+    a.application,
+    t.id as team_id
+FROM applications a
+LEFT JOIN team_members tm
+    ON tm.user_id = a.user_id
+LEFT JOIN teams t
+    ON t.id = tm.team_id
+    AND t.event_id = a.event_id
+WHERE a.event_id = $1
+    AND a.status = 'under_review'
+    AND a.passion_rating IS NOT NULL
+    AND a.experience_rating IS NOT NULL;
+    
 
 -- name: AssignApplicationsToReviewer :exec
 UPDATE applications

apps/api/internal/db/repository/application.go

@@ -66,18 +66,11 @@ func (r *ApplicationRepository) GetApplicationByUserAndEventID(ctx context.Conte
 	return &application, nil
 }
 
-func (r *ApplicationRepository) ListApplicationsByEventAndStatus(ctx context.Context, eventId uuid.UUID, status sqlc.ApplicationStatus) ([]sqlc.ListApplicationsByEventAndStatusRow, error) {
-	applications, err := r.db.Query.ListApplicationsByEventAndStatus(ctx, sqlc.ListApplicationsByEventAndStatusParams{
-		EventID: eventId,
-		Status: sqlc.NullApplicationStatus{
-			Valid:             true,
-			ApplicationStatus: status,
-		},
-	})
-	if err != nil {
-		return []sqlc.ListApplicationsByEventAndStatusRow{}, err
-	}
-	return applications, nil
+// List all candidates considered for admission for an eventId.
+// This queries for all applications who are 'under_review' and have their rating fields filled out.
+// It also LEFT JOINs in their team id (if they have one) for further grouping based on teams.
+func (r *ApplicationRepository) ListAdmissionCandidatesByEvent(ctx context.Context, eventId uuid.UUID) ([]sqlc.ListAdmissionCandidatesByEventRow, error) {
+	return r.db.Query.ListAdmissionCandidatesByEvent(ctx, eventId)
 }
 
 func (r *ApplicationRepository) SubmitApplication(ctx context.Context, data any, userId, eventId uuid.UUID) error {