feat: Data persistence using Atlas and SQLBoiler (#86)

Author: kevinmichaelchen

.github/workflows/golangci-lint.yml

@@ -19,7 +19,7 @@ jobs:
       - uses: actions/checkout@v3
       - uses: actions/setup-go@v4
         with:
-          go-version: '1.21.3'
+          go-version: '1.21.5'
           cache: false
       - name: golangci-lint
         uses: golangci/golangci-lint-action@v3

Makefile

@@ -24,5 +24,7 @@ check_pkgx:
 all: check_pkgx
 	pkgx --sync
 	pkgx killport@latest 7233
+	sleep 1
 	pkgx temporal@latest server start-dev &
+	sleep 2
 	pkgx task@latest run:all

README.md

@@ -39,7 +39,10 @@ make
 ```
 
 > [!NOTE]
-> Under the hood, we use [pkgx][pkgx] to run Temporal's [dev server][temporal-cli], and Docker to run [Jaeger][jaeger] (a telemetry backend).
+> 
+> Under the hood, we use [pkgx][pkgx] to run Temporal's [dev
+> server][temporal-cli], and Docker to run [Jaeger][jaeger] (a telemetry
+> backend).
 
 [temporal-cli]: https://github.com/temporalio/cli
 [pkgx]: https://pkgx.sh/

Taskfile.yml

@@ -9,6 +9,8 @@ includes:
     taskfile: ./taskfiles/golang.yml
   run:
     taskfile: ./taskfiles/run.yml
+  sqlboiler:
+    taskfile: ./taskfiles/sqlboiler.yml
 
 tasks:
   generate:

cmd/saga/start/service/service.go

@@ -9,6 +9,7 @@ import (
 	temporalPB "buf.build/gen/go/kevinmichaelchen/temporalapis/protocolbuffers/go/temporal/v1beta1"
 	"connectrpc.com/connect"
 	"github.com/bufbuild/protovalidate-go"
+	"github.com/google/uuid"
 	"github.com/sirupsen/logrus"
 	"go.temporal.io/sdk/client"
 
@@ -53,10 +54,26 @@ func (s *Service) CreateOnboardingWorkflow(
 		TaskQueue: saga.CreateLicenseTaskQueue,
 	}
 
+	orgID := uuid.New().String()
+	profileID := uuid.New().String()
+	licenseID := uuid.New().String()
+
 	args := saga.CreateLicenseInputArgs{
-		OrgName:     req.Msg.GetOrg().GetName(),
-		ProfileName: req.Msg.GetProfile().GetName(),
-		LicenseName: "New License",
+		Org: saga.Org{
+			ID:   orgID,
+			Name: req.Msg.GetOrg().GetName(),
+		},
+		Profile: saga.Profile{
+			ID:       profileID,
+			FullName: req.Msg.GetProfile().GetFullName(),
+			OrgID:    orgID,
+		},
+		License: saga.License{
+			ID:     licenseID,
+			Start:  req.Msg.GetLicense().GetStart().AsTime(),
+			End:    req.Msg.GetLicense().GetEnd().AsTime(),
+			UserID: profileID,
+		},
 	}
 
 	workflow, err := temporalClient.ExecuteWorkflow(
@@ -73,6 +90,9 @@ func (s *Service) CreateOnboardingWorkflow(
 
 	res := &temporalPB.CreateOnboardingWorkflowResponse{
 		WorkflowId: workflow.GetID(),
+		OrgId:      orgID,
+		ProfileId:  profileID,
+		LicenseId:  licenseID,
 	}
 
 	out := connect.NewResponse(res)
@@ -83,9 +103,8 @@ func (s *Service) CreateOnboardingWorkflow(
 
 func printResults(args saga.CreateLicenseInputArgs, workflowID, runID string) {
 	logrus.WithFields(logrus.Fields{
-		"org_name":             args.OrgName,
-		"profile_name":         args.ProfileName,
-		"license_name":         args.LicenseName,
+		"org_name":             args.Org.Name,
+		"profile_name":         args.Profile.FullName,
 		"temporal.workflow_id": workflowID,
 		"temporal.run_id":      runID,
 	}).Info("Successfully completed Workflow")

cmd/saga/start/service/validate_test.go

@@ -29,7 +29,7 @@ func TestValidate(t *testing.T) {
 				Name: "Name",
 			},
 			Profile: &temporalPB.Profile{
-				Name: "Name",
+				FullName: "Name",
 			},
 		}
 	}

cmd/svc/license/app/app.go

@@ -12,6 +12,7 @@ import (
 	modConnect "github.com/kevinmichaelchen/temporal-saga-grpc/pkg/fxmod/connect"
 	"github.com/kevinmichaelchen/temporal-saga-grpc/pkg/fxmod/logging"
 	"github.com/kevinmichaelchen/temporal-saga-grpc/pkg/fxmod/otel"
+	"github.com/kevinmichaelchen/temporal-saga-grpc/pkg/fxmod/sql"
 )
 
 // Module - An FX module for the application.
@@ -38,4 +39,5 @@ var Module = fx.Options(
 	otel.CreateModule(otel.ModuleOptions{
 		ServiceName: "license-svc",
 	}),
+	sql.Module,
 )

cmd/svc/license/app/service/service.go

@@ -2,6 +2,8 @@
 package service
 
 import (
+	"database/sql"
+
 	"go.uber.org/fx"
 
 	"github.com/kevinmichaelchen/temporal-saga-grpc/cmd/svc/license/service"
@@ -15,6 +17,6 @@ var Module = fx.Module("service",
 )
 
 // NewService - Returns a new Service.
-func NewService() *service.Service {
-	return service.NewService()
+func NewService(db *sql.DB) *service.Service {
+	return service.NewService(db)
 }