Merge branch 'main' into use-env-vars

.github/workflows/build_release.yml

@@ -0,0 +1,64 @@
+# This workflow will build a golang project
+# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-go
+
+name: Release with goreleaser
+
+on:
+  push:
+    tags:
+      - v*
+permissions: write-all # Necessary for creating containers
+
+jobs:
+
+  build:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Set up Go 1.21
+        uses: actions/setup-go@v5
+        with:
+          go-version: 1.21
+      - name: Set up QEMU
+        uses: docker/setup-qemu-action@v3
+      - name: Docker Login
+        uses: docker/login-action@v3
+        with:
+          registry: ghcr.io
+          username: ${{ github.actor }}
+          password: ${{ secrets.GITHUB_TOKEN }}
+      - name: Checkout
+        uses: actions/checkout@v4
+        with:
+          fetch-tags: 1
+          fetch-depth: 1
+      - name: Unit Tests
+        run: go test -v ./...
+      - name: Release with goreleaser
+        uses: goreleaser/goreleaser-action@v5
+        env:
+          GITHUB_TOKEN: ${{ github.token }}
+        with:
+          version: latest
+          args: release --clean
+        id: goreleaser
+      - name: Process goreleaser output
+        id: process_goreleaser_output
+        run: |
+          echo "const fs = require('fs');" > process.js
+          echo 'const artifacts = ${{ steps.goreleaser.outputs.artifacts }}' >> process.js
+          echo "const firstNonNullDigest = artifacts.find(artifact => artifact.extra && artifact.extra.Digest != null)?.extra.Digest;" >> process.js
+          echo "console.log(firstNonNullDigest);" >> process.js
+          echo "fs.writeFileSync('digest.txt', firstNonNullDigest);" >> process.js
+          node process.js
+          echo "digest=$(cat digest.txt)" >> $GITHUB_OUTPUT
+      - name: Attest Binaries
+        uses: github-early-access/generate-build-provenance@main
+        with:
+          subject-path: dist/bss
+      - name: generate build provenance
+        uses: github-early-access/generate-build-provenance@main
+        with:
+          subject-name: ghcr.io/openchami/ochami-init
+          subject-digest: ${{ steps.process_goreleaser_output.outputs.digest }}
+          push-to-registry: true

.github/workflows/unit_test.yaml

@@ -0,0 +1,21 @@
+    name: Run Unit Tests
+    on: [push, pull_request]
+
+    jobs:
+      build:
+        defaults:
+          run:
+            working-directory: ./cmd/boot-script-service
+        runs-on: ubuntu-latest
+
+        steps:
+          - uses: actions/checkout@v4
+          - name: Setup Go
+            uses: actions/setup-go@v4
+            with:
+              go-version: '1.21.x'
+          - name: Install dependencies
+            run: go get .
+          - name: Test with the Go CLI
+            run: go test
+

cmd/boot-script-service/main.go

@@ -146,6 +146,59 @@ func kvDefaultURL() string {
 	return ret
 }
 
+
+func kvDefaultRetryConfig() (retryCount uint64, retryWait uint64, err error) {
+	retryCount = kvDefaultRetryCount
+	retryWait = kvDefaultRetryWait
+
+	envRetryCount := os.Getenv("ETCD_RETRY_COUNT")
+	if envRetryCount != "" {
+		retryCount, err = strconv.ParseUint(envRetryCount, 10, 64)
+		if err != nil {
+			log.Println("ERROR enable to parse ETCD_RETRY_COUNT environment variable: ", err)
+			return kvDefaultRetryCount, kvDefaultRetryWait, err
+		}
+	}
+
+	envRetryWait := os.Getenv("ETCD_RETRY_WAIT")
+	if envRetryWait != "" {
+		retryWait, err = strconv.ParseUint(envRetryWait, 10, 64)
+		if err != nil {
+			log.Println("ERROR enable to parse ETCD_RETRY_WAIT environment variable: ", err)
+			return kvDefaultRetryCount, kvDefaultRetryWait, err
+		}
+	}
+
+	return retryCount, retryWait, nil
+}
+
+// Try to read SQL_RETRY_COUNT and SQL_RETRY_WAIT environment variables.
+// If either variable contains an invalid value, return the default values of both.
+func sqlDefaultRetryConfig() (retryCount uint64, retryWait uint64, err error) {
+	retryCount = sqlDefaultRetryCount
+	retryWait = sqlDefaultRetryWait
+
+	envRetryCount := os.Getenv("SQL_RETRY_COUNT")
+	if envRetryCount != "" {
+		retryCount, err = strconv.ParseUint(envRetryCount, 10, 64)
+		if err != nil {
+			err = fmt.Errorf("ERROR: unable to parse SQL_RETRY_COUNT environment variable: %v", err)
+			return kvDefaultRetryCount, kvDefaultRetryWait, err
+		}
+	}
+
+	envRetryWait := os.Getenv("SQL_RETRY_WAIT")
+	if envRetryWait != "" {
+		retryWait, err = strconv.ParseUint(envRetryWait, 10, 64)
+		if err != nil {
+			err = fmt.Errorf("ERROR: unable to parse SQL_RETRY_WAIT environment variable: %v", err)
+			return kvDefaultRetryWait, kvDefaultRetryWait, err
+		}
+	}
+
+	return retryCount, retryWait, nil
+}
+
 func kvOpen(url, opts string, retryCount, retryWait uint64) (err error) {
 	ix := uint64(1)
 	for ; ix <= retryCount; ix++ {