coder · kylecarbs · Mar 22, 2022 · Mar 22, 2022 · Mar 22, 2022 · Mar 22, 2022
diff --git a/.github/workflows/coder.yaml b/.github/workflows/coder.yaml
@@ -135,19 +135,31 @@ jobs:
         with:
           go-version: "^1.17"
 
-      - uses: actions/cache@v3
+      - name: Echo Go Cache Paths
+        id: go-cache-paths
+        run: |
+          echo "::set-output name=go-build::$(go env GOCACHE)"
+          echo "::set-output name=go-mod::$(go env GOMODCACHE)"
+
+      - name: Go Build Cache
+        uses: actions/cache@v3
         with:
-          # Go mod cache, Linux build cache, Mac build cache, Windows build cache
-          path: |
-            ~/go/pkg/mod
-            ~/.cache/go-build
-            ~/Library/Caches/go-build
-            %LocalAppData%\go-build
-          key: ${{ matrix.os }}-go-${{ hashFiles('**/go.sum') }}
-          restore-keys: |
-            ${{ matrix.os }}-go-
+          path: ${{ steps.go-cache-paths.outputs.go-build }}
+          key: ${{ runner.os }}-go-build-${{ hashFiles('**/go.sum') }}
 
-      - run: go install gotest.tools/gotestsum@latest
+      - name: Go Mod Cache
+        uses: actions/cache@v3
+        with:
+          path: ${{ steps.go-cache-paths.outputs.go-mod }}
+          key: ${{ runner.os }}-go-mod-${{ hashFiles('**/go.sum') }}
+
+      - name: Install goreleaser
+        uses: jaxxstorm/action-install-gh-release@v1.4.0
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+        with:
+          repo: gotestyourself/gotestsum
+          tag: v1.7.0
 
       - uses: hashicorp/setup-terraform@v1
         with:
@@ -162,7 +174,7 @@ jobs:
         run: gotestsum --junitfile="gotests.xml" --packages="./..." --
           -covermode=atomic -coverprofile="gotests.coverage"
           -coverpkg=./...,github.com/coder/coder/codersdk
-          -timeout=3m -count=$GOCOUNT -race -short -failfast
+          -timeout=3m -count=$GOCOUNT -short -failfast
 
       - name: Upload DataDog Trace
         if: (success() || failure()) && github.actor != 'dependabot[bot]'
@@ -173,29 +185,91 @@ jobs:
           GIT_COMMIT_MESSAGE: ${{ github.event.head_commit.message }}
         run: go run scripts/datadog-cireport/main.go gotests.xml
 
+      - uses: codecov/codecov-action@v2
+        if: github.actor != 'dependabot[bot]'
+        with:
+          token: ${{ secrets.CODECOV_TOKEN }}
+          files: ./gotests.coverage
+          flags: unittest-go-${{ matrix.os }}
+          fail_ci_if_error: true
+
+  test-go-postgres:
+    name: "test/go/postgres"
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v3
+
+      - uses: actions/setup-go@v2
+        with:
+          go-version: "^1.17"
+
+      - name: Echo Go Cache Paths
+        id: go-cache-paths
+        run: |
+          echo "::set-output name=go-build::$(go env GOCACHE)"
+          echo "::set-output name=go-mod::$(go env GOMODCACHE)"
+
+      - name: Go Build Cache
+        uses: actions/cache@v3
+        with:
+          path: ${{ steps.go-cache-paths.outputs.go-build }}
+          key: ${{ runner.os }}-go-build-${{ hashFiles('**/go.sum') }}
+
+      - name: Go Mod Cache
+        uses: actions/cache@v3
+        with:
+          path: ${{ steps.go-cache-paths.outputs.go-mod }}
+          key: ${{ runner.os }}-go-mod-${{ hashFiles('**/go.sum') }}
+
+      - name: Install goreleaser
+        uses: jaxxstorm/action-install-gh-release@v1.4.0
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
+        with:
+          repo: gotestyourself/gotestsum
+          tag: v1.7.0
+
+      - uses: hashicorp/setup-terraform@v1
+        with:
+          terraform_version: 1.1.2
+          terraform_wrapper: false
+
+      - name: Start PostgreSQL Database
+        env:
+          POSTGRES_PASSWORD: postgres
+          POSTGRES_USER: postgres
+          POSTGRES_DB: postgres
+          PGDATA: /tmp
+        run: |
+          docker run \
+            -e POSTGRES_PASSWORD=postgres \
+            -e POSTGRES_USER=postgres \
+            -e POSTGRES_DB=postgres \
+            -e PGDATA=/tmp \
+            -p 5432:5432 \
+            -d postgres:11 \
+            -c shared_buffers=1GB \
+            -c max_connections=1000
+          while ! pg_isready -h 127.0.0.1
+          do
+              echo "$(date) - waiting for database to start"
+              sleep 0.5
+          done
+
       - name: Test with PostgreSQL Database
-        if: runner.os == 'Linux'
-        run: DB=true gotestsum --junitfile="gotests.xml" --packages="./..." --
+        run: DB=ci gotestsum --junitfile="gotests.xml" --packages="./..." --
           -covermode=atomic -coverprofile="gotests.coverage" -timeout=3m
           -coverpkg=./...,github.com/coder/coder/codersdk
-          -count=1 -parallel=2 -failfast
+          -count=1 -parallel=2 -race -failfast
 
       - name: Upload DataDog Trace
-        if: (success() || failure()) && github.actor != 'dependabot[bot]' && runner.os == 'Linux'
+        if: (success() || failure()) && github.actor != 'dependabot[bot]'
         env:
           DATADOG_API_KEY: ${{ secrets.DATADOG_API_KEY }}
           DD_DATABASE: postgresql
           GIT_COMMIT_MESSAGE: ${{ github.event.head_commit.message }}
         run: go run scripts/datadog-cireport/main.go gotests.xml
 
-      - uses: codecov/codecov-action@v2
-        if: github.actor != 'dependabot[bot]'
-        with:
-          token: ${{ secrets.CODECOV_TOKEN }}
-          files: ./gotests.coverage
-          flags: unittest-go-${{ matrix.os }}
-          fail_ci_if_error: true
-
   deploy:
     name: "deploy"
     runs-on: ubuntu-latest
@@ -339,17 +413,23 @@ jobs:
         with:
           install-only: true
 
-      - uses: actions/cache@v3
+      - name: Echo Go Cache Paths
+        id: go-cache-paths
+        run: |
+          echo "::set-output name=go-build::$(go env GOCACHE)"
+          echo "::set-output name=go-mod::$(go env GOMODCACHE)"
+
+      - name: Go Build Cache
+        uses: actions/cache@v3
         with:
-          # Go mod cache, Linux build cache, Mac build cache, Windows build cache
-          path: |
-            ~/go/pkg/mod
-            ~/.cache/go-build
-            ~/Library/Caches/go-build
-            %LocalAppData%\go-build
-          key: ${{ matrix.os }}-go-${{ hashFiles('**/go.sum') }}
-          restore-keys: |
-            ${{ matrix.os }}-go-
+          path: ${{ steps.go-cache-paths.outputs.go-build }}
+          key: ${{ runner.os }}-go-build-${{ hashFiles('**/go.sum') }}
+
+      - name: Go Mod Cache
+        uses: actions/cache@v3
+        with:
+          path: ${{ steps.go-cache-paths.outputs.go-mod }}
+          key: ${{ runner.os }}-go-mod-${{ hashFiles('**/go.sum') }}
 
       - run: make build
 

diff --git a/cli/start_test.go b/cli/start_test.go
@@ -31,14 +31,14 @@ func TestStart(t *testing.T) {
 			err := root.ExecuteContext(ctx)
 			require.ErrorIs(t, err, context.Canceled)
 		}()
-		var accessURL string
+		var token string
 		require.Eventually(t, func() bool {
 			var err error
-			accessURL, err = cfg.URL().Read()
+			token, err = cfg.Session().Read()
 			return err == nil
 		}, 15*time.Second, 25*time.Millisecond)
 		// Verify that authentication was properly set in dev-mode.
-		token, err := cfg.Session().Read()
+		accessURL, err := cfg.URL().Read()
 		require.NoError(t, err)
 		parsed, err := url.Parse(accessURL)
 		require.NoError(t, err)

diff --git a/coderd/tunnel/tunnel_test.go b/coderd/tunnel/tunnel_test.go
@@ -5,6 +5,7 @@ import (
 	"net"
 	"net/http"
 	"net/http/httptest"
+	"os"
 	"testing"
 	"time"
 
@@ -21,7 +22,9 @@ import (
 
 func TestTunnel(t *testing.T) {
 	t.Parallel()
-	if testing.Short() {
+	if testing.Short() || os.Getenv("CI") != "" {
+		// This test has extreme inconsistency in CI.
+		// It's something with the networking in CI that causes this test to flake.
 		t.Skip()
 		return
 	}

diff --git a/database/postgres/postgres.go b/database/postgres/postgres.go
@@ -9,6 +9,7 @@ import (
 	"sync"
 	"time"
 
+	"github.com/coder/coder/cryptorand"
 	"github.com/ory/dockertest/v3"
 	"github.com/ory/dockertest/v3/docker"
 	"golang.org/x/xerrors"
@@ -20,6 +21,28 @@ var openPortMutex sync.Mutex
 
 // Open creates a new PostgreSQL server using a Docker container.
 func Open() (string, func(), error) {
+	if os.Getenv("DB") == "ci" {
+		// In CI, creating a Docker container for each test is slow.
+		// This expects a PostgreSQL instance with the hardcoded credentials
+		// available.
+		dbURL := "postgres://postgres:postgres@127.0.0.1:5432/postgres?sslmode=disable"
+		db, err := sql.Open("postgres", dbURL)
+		if err != nil {
+			return "", nil, xerrors.Errorf("connect to ci postgres: %w", err)
+		}
+		defer db.Close()
+		dbName, err := cryptorand.StringCharset(cryptorand.Lower, 10)
+		if err != nil {
+			return "", nil, xerrors.Errorf("generate db name: %w", err)
+		}
+		dbName = "ci" + dbName
+		_, err = db.Exec("CREATE DATABASE " + dbName)
+		if err != nil {
+			return "", nil, xerrors.Errorf("create db: %w", err)
+		}
+		return "postgres://postgres:postgres@127.0.0.1:5432/" + dbName + "?sslmode=disable", func() {}, nil
+	}
+
 	pool, err := dockertest.NewPool("")
 	if err != nil {
 		return "", nil, xerrors.Errorf("create pool: %w", err)

diff --git a/peer/conn.go b/peer/conn.go
@@ -354,6 +354,9 @@ func (c *Conn) AddRemoteCandidate(i webrtc.ICECandidateInit) {
 	go func() {
 		c.negotiateMutex.Lock()
 		defer c.negotiateMutex.Unlock()
+		if c.isClosed() {
+			return
+		}
 		c.opts.Logger.Debug(context.Background(), "accepting candidate", slog.F("candidate", i.Candidate))
 		err := c.rtc.AddICECandidate(i)
 		if err != nil {

diff --git a/provisionerd/provisionerd.go b/provisionerd/provisionerd.go
@@ -230,16 +230,18 @@ func (p *Server) runJob(ctx context.Context, job *proto.AcquiredJob) {
 	go func() {
 		ticker := time.NewTicker(p.opts.UpdateInterval)
 		defer ticker.Stop()
-		select {
-		case <-p.closed:
-			return
-		case <-ctx.Done():
-			return
-		case <-p.shutdown:
-			p.opts.Logger.Info(ctx, "attempting graceful cancelation")
-			shutdownCancel()
-			return
-		case <-ticker.C:
+		for {
+			select {
+			case <-p.closed:
+				return
+			case <-ctx.Done():
+				return
+			case <-p.shutdown:
+				p.opts.Logger.Info(ctx, "attempting graceful cancelation")
+				shutdownCancel()
+				return
+			case <-ticker.C:
+			}
 			resp, err := p.client.UpdateJob(ctx, &proto.UpdateJobRequest{
 				JobId: job.JobId,
 			})
@@ -248,18 +250,18 @@ func (p *Server) runJob(ctx context.Context, job *proto.AcquiredJob) {
 				return
 			}
 			if !resp.Canceled {
-				return
+				continue
 			}
 			p.opts.Logger.Info(ctx, "attempting graceful cancelation")
 			shutdownCancel()
 			// Hard-cancel the job after a minute of pending cancelation.
 			timer := time.NewTimer(p.opts.ForceCancelInterval)
-			defer timer.Stop()
 			select {
 			case <-timer.C:
 				p.failActiveJobf("cancelation timed out")
 				return
 			case <-ctx.Done():
+				timer.Stop()
 				return
 			}
 		}

diff --git a/pty/start_other.go b/pty/start_other.go
@@ -7,6 +7,7 @@ import (
 	"os"
 	"os/exec"
 	"runtime"
+	"strings"
 	"syscall"
 
 	"github.com/creack/pty"
@@ -28,6 +29,12 @@ func startPty(cmd *exec.Cmd) (PTY, *os.Process, error) {
 	err = cmd.Start()
 	if err != nil {
 		_ = ptty.Close()
+		if runtime.GOOS == "darwin" && strings.Contains(err.Error(), "bad file descriptor") {
+			// MacOS has an obscure issue where the PTY occasionally closes
+			// before it's used. It's unknown why this is, but creating a new
+			// TTY resolves it.
+			return startPty(cmd)
+		}
 		return nil, nil, xerrors.Errorf("start: %w", err)
 	}
 	go func() {