trufnetwork · MicBun · Jun 13, 2025 · Jun 13, 2025
diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml
@@ -49,69 +49,28 @@ jobs:
 
       - uses: actions/checkout@v4
 
+      - name: Setup Go
+        uses: actions/setup-go@v5
+        with:
+          go-version: '1.23'
+
       - name: Install Taskfile
         uses: arduino/setup-task@v2
 
       - name: Run Taskfile
-        run: task kwil-binaries
-
-      - name: Setup Go
-        uses: actions/setup-go@v5
-        with:
-          go-version: '1.21'
+        run: task build
 
       - name: Run Go Tests
-        # skip it while we don't have any tests
-        if: false
-        run: |
-          go test ./internal/...
-
-      - name: Setup Docker
-        uses: docker/setup-buildx-action@v3
+        run: go test -short -p 1 ./...
 
-      - name: Docker Compose Up
-        # docker compose up --wait makes it exit with 1 even for a successful run
-        continue-on-error: true
-        uses: isbang/compose-action@v1.5.1
-        with:
-          compose-file: "./compose.yaml"
-          # waits every container to be ready, so we're sure there's data already
-          # when in ACT, also force build to ensure it is working locally
-          up-flags: "--wait ${{env.ACT && '--build --force-recreate --no-deps' || ''}}"
-        env:
-          CACHE_FROM: "type=gha,scope=truflation/tn"
-          CACHE_TO: "type=gha,mode=max,scope=truflation/tn"
+      - name: Start Single-Node Stack
+        run: task single:start
 
-      # we need it to be manually checked, as above action will always exit with 1 even if it's successful
-      - name: Check compose status
+      - name: Wait for node to warm up
         run: |
-          output=$(docker ps -a --format "{{.Names}},{{.Image}},{{.Status}}")
-
-          function expect_status() {
-            image_name=$1
-            expected_status=$2
-            image_row=$(echo "$output" | grep "$image_name")
-            if echo "$image_row" | grep -q "$expected_status"; then
-              echo "$image_name exited with 0"
-            else
-              echo -e "$image_name isn't with expected status $expected_status\n"
-              echo -e "docker ps output: \n$output\n\n"
-
-              # extract the container name, knowing it's the first column
-              container_name=$(echo "$image_row" | cut -d ',' -f 1)
-
-              echo -e "docker logs for $image_name: \n"
-              docker logs $container_name | tail -n 500
-
-              exit 1
-            fi
-          }
-
-          # we ensure both containers are exited with 0
-          # if you are running locally, make sure any previous postgres volume state is clean
-          # otherwise, tn-db will error for out for block state being out of sync.
-          expect_status "tn-db:local" "Up"
+          echo "⏳ giving the node 10s to initialize…"
+          sleep 10
 
-      - name: Run Tests
+      - name: Run CI Tests Script
         run: |
           scripts/ci-tests.sh
diff --git a/.github/workflows/deploy-tools.yaml b/.github/workflows/deploy-tools.yaml
@@ -10,6 +10,7 @@ on:
 
 jobs:
   deploy-benchmark:
+    if: ${{ false }}        # Disabled for now, enable when ready
     name: Deploy Benchmark Stack
     runs-on: ubuntu-latest
     environment: production

diff --git a/.golangci.yaml b/.golangci.yaml
@@ -7,4 +7,8 @@ output:
 issues:
   exclude-dirs:
     - deployments/infra/cdk.out
-    - vendor
+    - vendor
+
+linters:
+  disable:
+    - errcheck
diff --git a/compose.yaml b/compose.yaml
@@ -33,11 +33,6 @@ services:
     build:
       context: .
       dockerfile: ./deployments/Dockerfile
-      # For local development, if cache is not supported, please comment the following lines
-      cache_from:
-        - ${CACHE_FROM:-type=local,src=/tmp/buildx-cache}/tn-db
-      cache_to:
-        - ${CACHE_TO:-type=local,dest=/tmp/buildx-cache-new}/tn-db
       args:
         - CHAIN_ID=${CHAIN_ID:-trufnetwork-dev}
     environment:

diff --git a/internal/benchmark/constants.go b/internal/benchmark/constants.go
@@ -8,6 +8,5 @@ var (
 	readerAddress  = MustNewEthereumAddressFromString("0x0000000000000000010000000000000000000001")
 	deployer       = MustNewEthereumAddressFromString("0x0000000000000000000000000000000200000000")
 	fixedDate      = time.Date(2021, 1, 1, 0, 0, 0, 0, time.UTC)
-	dailyInterval  = time.Hour * 24
 	secondInterval = time.Second
 )
diff --git a/internal/benchmark/load_test.go b/internal/benchmark/load_test.go
@@ -22,6 +22,9 @@ import (
 
 // Main benchmark test function
 func TestBench(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping benchmark test in short mode")
+	}
 	ctx, cancel := context.WithCancel(context.Background())
 	t.Cleanup(cancel)
 	LogPhaseEnter(t, "TestBench", "Starting main benchmark test function")

diff --git a/internal/benchmark/setup.go b/internal/benchmark/setup.go
@@ -72,14 +72,12 @@ func setupSchemas(
 
 	// Separate primitive and composed streams for different handling
 	var primitiveStreams []setup.StreamInfo
-	var primitiveNodes []trees.TreeNode
 	var composedStreams []setup.StreamInfo
 	var composedNodes []trees.TreeNode
 
 	for i, streamInfo := range allStreamInfos {
 		if input.Tree.Nodes[i].IsLeaf {
 			primitiveStreams = append(primitiveStreams, streamInfo)
-			primitiveNodes = append(primitiveNodes, input.Tree.Nodes[i])
 		} else {
 			composedStreams = append(composedStreams, streamInfo)
 			composedNodes = append(composedNodes, input.Tree.Nodes[i])
@@ -407,27 +405,6 @@ func getMockStreamIds(n int) []util.StreamId {
 	return streamIds
 }
 
-// insertRecordsForPrimitive inserts records for a primitive stream using bulk insert.
-func insertRecordsForPrimitive(ctx context.Context, platform *kwilTesting.Platform, stream setup.StreamInfo, rangeParams RangeParameters) error {
-	records := generateRecords(rangeParams)
-
-	input := setup.InsertPrimitiveDataInput{
-		Platform: platform,
-		Height:   1,
-		PrimitiveStream: setup.PrimitiveStreamWithData{
-			PrimitiveStreamDefinition: setup.PrimitiveStreamDefinition{
-				StreamLocator: stream.Locator,
-			},
-			Data: records,
-		},
-	}
-
-	if err := setup.InsertPrimitiveDataBatch(ctx, input); err != nil {
-		return errors.Wrap(err, "failed to execute bulk insert")
-	}
-	return nil
-}
-
 type RangeParameters struct {
 	DataPoints int
 	FromDate   time.Time

diff --git a/internal/benchmark/util/mem_collector.go b/internal/benchmark/util/mem_collector.go
@@ -20,7 +20,6 @@ type DockerMemoryCollector struct {
 	ctx             context.Context
 	cancel          context.CancelFunc
 	wg              sync.WaitGroup
-	mu              sync.Mutex
 	errChan         chan error
 	firstSampleChan chan struct{}
 }

diff --git a/tests/streams/aggregation/get_all_weights_for_query_test.go b/tests/streams/aggregation/get_all_weights_for_query_test.go
@@ -127,9 +127,7 @@ func GetAllWeightsForQuery(ctx context.Context, input GetAllWeightsForQueryInput
 	}, func(row *common.Row) error {
 		// Convert the row values to []any
 		values := make([]any, len(row.Values))
-		for i, v := range row.Values {
-			values[i] = v
-		}
+		copy(values, row.Values)
 		resultRows = append(resultRows, values)
 		return nil
 	})

diff --git a/tests/streams/auth/auth_test.go b/tests/streams/auth/auth_test.go
@@ -559,6 +559,10 @@ func testComposePermissionControl(t *testing.T, contractInfo setup.StreamInfo) k
 			ComposingLocator: upperStreamInfo.Locator,
 			Height:           0,
 		})
+		if err != nil {
+			return errors.Wrapf(err, "failed to check compose permissions for upper stream %s on contract %s",
+				upperStreamInfo.Locator.StreamId.String(), contractInfo.Locator.StreamId.String())
+		}
 		assert.False(t, canCompose, "Upper stream should not be allowed to compose without permission")
 
 		// Grant compose permission to the foreign stream

diff --git a/tests/streams/query/query_test.go b/tests/streams/query/query_test.go
@@ -193,39 +193,6 @@ func runTestForAllStreamTypes(t *testing.T, testName string, testFn func(ctx con
 	}
 }
 
-// Helper functions for testing
-// streamTestingHandler wraps testing.T to include stream information in error messages
-type streamTestingHandler struct {
-	*testing.T
-	StreamName string
-	StreamId   string
-}
-
-// errorCapturingT is a wrapper around testing.T that captures errors instead of failing the test
-type errorCapturingT struct {
-	*testing.T
-	StreamName    string
-	StreamId      string
-	ErrorOccurred bool
-	ErrorMessage  string
-}
-
-// Errorf captures the error message rather than failing the test immediately
-func (e *errorCapturingT) Errorf(format string, args ...interface{}) {
-	e.ErrorOccurred = true
-	e.ErrorMessage = fmt.Sprintf(format, args...)
-	// Also log the error to the main test
-	e.T.Logf("[%s (StreamId: %s)] %s", e.StreamName, e.StreamId, e.ErrorMessage)
-}
-
-// Fatalf captures the error message rather than failing the test immediately
-func (e *errorCapturingT) Fatalf(format string, args ...interface{}) {
-	e.ErrorOccurred = true
-	e.ErrorMessage = fmt.Sprintf(format, args...)
-	// Also log the error to the main test
-	e.T.Logf("[%s (StreamId: %s)] %s", e.StreamName, e.StreamId, e.ErrorMessage)
-}
-
 // [QUERY01] Authorized users (owner and whitelisted wallets) can query records over a specified date range.
 func testQUERY01_InsertAndGetRecord(t *testing.T) func(ctx context.Context, platform *kwilTesting.Platform) error {
 	return runTestForAllStreamTypes(t, "QUERY01_InsertAndGetRecord", func(ctx context.Context, platform *kwilTesting.Platform, config TestConfig) error {

diff --git a/tests/streams/utils/procedure/execute.go b/tests/streams/utils/procedure/execute.go
@@ -44,9 +44,7 @@ func GetRecord(ctx context.Context, input GetRecordInput) ([]ResultRow, error) {
 	}, func(row *common.Row) error {
 		// Convert the row values to []any
 		values := make([]any, len(row.Values))
-		for i, v := range row.Values {
-			values[i] = v
-		}
+		copy(values, row.Values)
 		resultRows = append(resultRows, values)
 		return nil
 	})
@@ -97,9 +95,7 @@ func GetIndex(ctx context.Context, input GetIndexInput) ([]ResultRow, error) {
 	}, func(row *common.Row) error {
 		// Convert the row values to []any
 		values := make([]any, len(row.Values))
-		for i, v := range row.Values {
-			values[i] = v
-		}
+		copy(values, row.Values)
 		resultRows = append(resultRows, values)
 		return nil
 	})
@@ -145,9 +141,7 @@ func GetIndexChange(ctx context.Context, input GetIndexChangeInput) ([]ResultRow
 	}, func(row *common.Row) error {
 		// Convert the row values to []any
 		values := make([]any, len(row.Values))
-		for i, v := range row.Values {
-			values[i] = v
-		}
+		copy(values, row.Values)
 		resultRows = append(resultRows, values)
 		return nil
 	})
@@ -190,9 +184,7 @@ func GetFirstRecord(ctx context.Context, input GetFirstRecordInput) ([]ResultRow
 	}, func(row *common.Row) error {
 		// Convert the row values to []any
 		values := make([]any, len(row.Values))
-		for i, v := range row.Values {
-			values[i] = v
-		}
+		copy(values, row.Values)
 		resultRows = append(resultRows, values)
 		return nil
 	})
@@ -299,9 +291,7 @@ func DescribeTaxonomies(ctx context.Context, input DescribeTaxonomiesInput) ([]R
 	}, func(row *common.Row) error {
 		// Convert the row values to []any
 		values := make([]any, len(row.Values))
-		for i, v := range row.Values {
-			values[i] = v
-		}
+		copy(values, row.Values)
 		resultRows = append(resultRows, values)
 		return nil
 	})
@@ -393,9 +383,7 @@ func GetCategoryStreams(ctx context.Context, input GetCategoryStreamsInput) ([]R
 	}, func(row *common.Row) error {
 		// Convert the row values to []any
 		values := make([]any, len(row.Values))
-		for i, v := range row.Values {
-			values[i] = v
-		}
+		copy(values, row.Values)
 		resultRows = append(resultRows, values)
 		return nil
 	})
@@ -544,9 +532,7 @@ func ListStreams(ctx context.Context, input ListStreamsInput) ([]ResultRow, erro
 		input.BlockHeight,
 	}, func(row *common.Row) error {
 		values := make([]any, len(row.Values))
-		for i, v := range row.Values {
-			values[i] = v
-		}
+		copy(values, row.Values)
 		resultRows = append(resultRows, values)
 		return nil
 	})

diff --git a/tests/streams/utils/setup/roles.go b/tests/streams/utils/setup/roles.go
@@ -31,7 +31,7 @@ func CreateTestRole(ctx context.Context, input CreateTestRoleInput) error {
 		callerAddr = deployer.Address()
 
 		// Also assert that the owner parameter matches the signer's address.
-		if strings.ToLower(callerAddr) != strings.ToLower(input.Owner) {
+		if !strings.EqualFold(callerAddr, input.Owner) {
 			return errors.Errorf("owner parameter (%s) does not match platform signer address (%s)", input.Owner, callerAddr)
 		}
 	}