Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 3 additions & 0 deletions .github/workflows/golang-tests-with-db.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -12,6 +12,9 @@ on:
jobs:
workspace-engine-tests:
runs-on: ubuntu-latest
permissions:
contents: read
pull-requests: write

# Add PostgreSQL service for integration tests
services:
Expand Down
3 changes: 3 additions & 0 deletions .github/workflows/golang-tests.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,9 @@ on:
jobs:
workspace-engine-tests:
runs-on: ubuntu-latest
permissions:
contents: read
pull-requests: write
defaults:
run:
working-directory: apps/workspace-engine
Expand Down
7 changes: 7 additions & 0 deletions apps/workspace-engine/pkg/db/changeset.go
Original file line number Diff line number Diff line change
Expand Up @@ -136,6 +136,13 @@ func applyChange(ctx context.Context, conn pgx.Tx, change changeset.Change[any],
return writeJob(ctx, e, conn)
}

if e, ok := change.Entity.(*oapi.ReleaseTarget); ok && e != nil {
if change.Type == changeset.ChangeTypeDelete {
return deleteReleaseTarget(ctx, e, conn)
}
return writeReleaseTarget(ctx, e, conn)
}

return fmt.Errorf("unknown entity type: %s", change.Entity)
}

Expand Down
30 changes: 30 additions & 0 deletions apps/workspace-engine/pkg/db/release_targets.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,30 @@
package db

import (
"context"
"workspace-engine/pkg/oapi"

"github.com/jackc/pgx/v5"
)

const WRITE_RELEASE_TARGET_QUERY = `
INSERT INTO release_target (resource_id, environment_id, deployment_id)
VALUES ($1, $2, $3)
ON CONFLICT (resource_id, environment_id, deployment_id)
DO NOTHING
`

func writeReleaseTarget(ctx context.Context, releaseTarget *oapi.ReleaseTarget, tx pgx.Tx) error {
_, err := tx.Exec(ctx, WRITE_RELEASE_TARGET_QUERY, releaseTarget.ResourceId, releaseTarget.EnvironmentId, releaseTarget.DeploymentId)
return err
}

const DELETE_RELEASE_TARGET_QUERY = `
DELETE FROM release_target
WHERE resource_id = $1 AND environment_id = $2 AND deployment_id = $3
`

func deleteReleaseTarget(ctx context.Context, releaseTarget *oapi.ReleaseTarget, tx pgx.Tx) error {
_, err := tx.Exec(ctx, DELETE_RELEASE_TARGET_QUERY, releaseTarget.ResourceId, releaseTarget.EnvironmentId, releaseTarget.DeploymentId)
return err
}
Loading
Loading