feature: workshops. Almost completed currently debugging

Author: csilva1-eng

apps/api/internal/api/api.go

@@ -24,6 +24,7 @@ import (
 	"github.com/swamphacks/core/apps/api/internal/domains/redeemables"
 	"github.com/swamphacks/core/apps/api/internal/domains/teams"
 	"github.com/swamphacks/core/apps/api/internal/domains/users"
+	"github.com/swamphacks/core/apps/api/internal/domains/workshops"
 	"github.com/swamphacks/core/apps/api/internal/emailutils"
 	"github.com/swamphacks/core/apps/api/internal/logger"
 	"github.com/swamphacks/core/apps/api/internal/storage"
@@ -116,6 +117,7 @@ func Run() {
 	redeemablesRepo := repository.NewRedeemablesRepository(db)
 	batRunsRepo := repository.NewBatRunsRepository(db)
 	eventInterestsRepo := repository.NewEventInterestsRepository(db)
+	workshopRepo := repository.NewWorkshopsRepository(db)
 
 	mw := mw.NewMiddleware(userRepo, db, logger, config)
 
@@ -149,6 +151,10 @@ func Run() {
 	redeemablesHandler := redeemables.NewHandler(redeemablesService, config, logger)
 	redeemables.RegisterRoutes(redeemablesHandler, huma.NewGroup(api, "/redeemables"), mw)
 
+	workshopService := workshops.NewService(workshopRepo, logger)
+	workshopHandler := workshops.NewHandler(workshopService, logger)
+	workshops.RegisterRoutes(workshopHandler, huma.NewGroup(api, "/workshops"), mw)
+
 	huma.Register(api, huma.Operation{
 		OperationID: "ping",
 		Method:      http.MethodGet,

apps/api/internal/database/migrations/20260409205342_workshops_init.sql

@@ -0,0 +1,45 @@
+-- +goose Up
+-- +goose StatementBegin
+
+-- TABLES
+create table workshops
+(
+	id uuid default gen_random_uuid() not null primary key,
+	title text not null,
+	description text,
+	start_time timestamptz not null,
+	end_time timestamptz not null,
+	curr_attendees integer default 0 not null,
+	location text,
+	presenter text,
+	created_at timestamptz default now() not null,
+	updated_at timestamptz default now() not null
+);
+
+create table workshop_registrations
+(
+    user_id uuid not null,
+    workshop_id uuid not null,
+    created_at timestamptz default now() not null,
+
+    primary key (user_id, workshop_id),
+
+    foreign key (workshop_id)
+        references workshops(id)
+        on delete cascade
+);
+
+-- TRIGGERS
+create trigger set_updated_at_workshops
+	before update
+	on workshops
+	for each row
+	execute procedure update_modified_column();
+
+-- +goose StatementEnd
+-- +goose Down
+drop trigger if exists set_updated_at_workshops on workshops;
+
+drop table if exists workshop_registrations;
+
+drop table if exists workshops;

apps/api/internal/database/queries/workshops.sql

@@ -0,0 +1,47 @@
+-- name: GetWorkshop :one
+SELECT w.* FROM workshops w
+WHERE w.id = @workshop_id;
+
+-- name: GetAllWorkshops :many
+SELECT w.* FROM workshops w
+WHERE w.start_time > CURRENT_TIMESTAMP
+ORDER BY w.start_time ASC;
+
+-- name: DeleteWorkshop :exec
+DELETE FROM workshops
+WHERE id = @workshop_id;
+
+-- name: CreateWorkshop :one
+INSERT INTO workshops (title, description, start_time, end_time, location, presenter)
+VALUES (@title, @description, @start_time, @end_time, @location, @presenter)
+RETURNING *;
+
+-- name: RegisterUserForWorkshop :exec
+INSERT INTO workshop_registrations (user_id, workshop_id)
+VALUES (@user_id, @workshop_id);
+
+-- name: UnregisterUserForWorkshop :exec
+DELETE FROM workshop_registrations
+WHERE user_id = @user_id AND workshop_id = @workshop_id;
+
+-- name: IsUserRegistered :one
+SELECT EXISTS (
+    SELECT 1
+    FROM workshop_registrations
+    WHERE user_id = @user_id AND workshop_id = @workshop_id
+);
+
+-- name: GetWorkshopRegistrations :many
+SELECT *
+FROM workshop_registrations
+WHERE workshop_id = @workshop_id;
+
+-- name: IncrementWorkshopAttendees :exec
+UPDATE workshops
+SET curr_attendees = curr_attendees + 1
+WHERE id = $1;
+
+-- name: DecrementWorkshopAttendees :exec
+UPDATE workshops
+SET curr_attendees = GREATEST(curr_attendees - 1, 0)
+WHERE id = $1;

apps/api/internal/database/repository/workshops.go

@@ -0,0 +1,95 @@
+package repository
+
+import (
+	"context"
+
+
+	"github.com/google/uuid"
+	"github.com/swamphacks/core/apps/api/internal/database"
+	"github.com/swamphacks/core/apps/api/internal/database/sqlc"
+)
+
+type WorkshopsRepository struct {
+	db *database.DB
+}
+
+func NewWorkshopsRepository(db *database.DB) *WorkshopsRepository{
+	return &WorkshopsRepository{
+		db: db,
+	}
+}
+
+func (r *WorkshopsRepository) GetWorkshop(ctx context.Context, workshopID uuid.UUID) (*sqlc.Workshop, error) {
+	workshop, err := r.db.Query.GetWorkshop(ctx, workshopID)
+	if err != nil {
+		return nil, err
+	}
+	
+	return &workshop, nil
+}
+
+func (r *WorkshopsRepository) GetAllWorkshops(ctx context.Context) ([]sqlc.Workshop, error){
+	workshop, err := r.db.Query.GetAllWorkshops(ctx)
+	if err != nil {
+		return nil, err
+	}
+
+	return workshop, nil
+}
+
+func (r *WorkshopsRepository) DeleteWorkshop(ctx context.Context, workshopID uuid.UUID) error {
+	err := r.db.Query.DeleteWorkshop(ctx, workshopID)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (r *WorkshopsRepository) UnregisterUserForWorkshop(ctx context.Context, params sqlc.UnregisterUserForWorkshopParams) error {
+
+	err := r.db.Query.UnregisterUserForWorkshop(ctx, params)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (r *WorkshopsRepository) RegisterUserForWorkshop(ctx context.Context, params sqlc.RegisterUserForWorkshopParams) error {
+
+	err := r.db.Query.RegisterUserForWorkshop(ctx, params)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (r *WorkshopsRepository) DecrementWorkshopAttendees(ctx context.Context, workshopID uuid.UUID) error {
+
+	err := r.db.Query.DecrementWorkshopAttendees(ctx, workshopID)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (r *WorkshopsRepository) CreateWorkshop(ctx context.Context, params sqlc.CreateWorkshopParams) (*sqlc.Workshop, error){
+	workshop, err := r.db.Query.CreateWorkshop(ctx, params)
+	if err != nil {
+		return nil, err
+	}
+
+	return &workshop, nil
+}
+
+func (r *WorkshopsRepository) IncrementWorkshopAttendees(ctx context.Context, workshopID uuid.UUID) error {
+	err := r.db.Query.IncrementWorkshopAttendees(ctx, workshopID)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}