[chore]: enable bool-compare rule from testifylint

.golangci.yml

@@ -132,6 +132,23 @@ linters-settings:
   predeclared:
     ignore: copy
 
+  testifylint:
+    disable:
+      - compares
+      - empty
+      - error-is-as
+      - error-nil
+      - expected-actual
+      - float-compare
+      - go-require
+      - len
+      - negative-positive
+      - nil-compare
+      - require-error
+      - suite-dont-use-pkg
+      - useless-assert
+    enable-all: true
+
 linters:
   enable:
     - decorder
@@ -152,6 +169,7 @@ linters:
     - revive
     - staticcheck
     - tenv
+    - testifylint
     - unconvert
     - unparam
     - unused

connector/routingconnector/logs_test.go

@@ -463,5 +463,5 @@ func TestLogsConnectorCapabilities(t *testing.T) {
 	)
 
 	require.NoError(t, err)
-	assert.Equal(t, false, conn.Capabilities().MutatesData)
+	assert.False(t, conn.Capabilities().MutatesData)
 }

connector/routingconnector/metrics_test.go

@@ -493,5 +493,5 @@ func TestMetricsConnectorCapabilities(t *testing.T) {
 	)
 
 	require.NoError(t, err)
-	assert.Equal(t, false, conn.Capabilities().MutatesData)
+	assert.False(t, conn.Capabilities().MutatesData)
 }

connector/routingconnector/traces_test.go

@@ -417,5 +417,5 @@ func TestTraceConnectorCapabilities(t *testing.T) {
 	)
 
 	require.NoError(t, err)
-	assert.Equal(t, false, conn.Capabilities().MutatesData)
+	assert.False(t, conn.Capabilities().MutatesData)
 }

connector/servicegraphconnector/internal/store/store_test.go

@@ -30,7 +30,7 @@ func TestStoreUpsertEdge(t *testing.T) {
 		e.ClientService = clientService
 	})
 	require.NoError(t, err)
-	require.Equal(t, true, isNew)
+	require.True(t, isNew)
 	assert.Equal(t, 1, s.Len())
 
 	// Nothing should be evicted as TTL is set to 1h
@@ -44,7 +44,7 @@ func TestStoreUpsertEdge(t *testing.T) {
 		e.ServerService = "server"
 	})
 	require.NoError(t, err)
-	require.Equal(t, false, isNew)
+	require.False(t, isNew)
 	// Edge is complete and should have been removed
 	assert.Equal(t, 0, s.Len())
 
@@ -57,7 +57,7 @@ func TestStoreUpsertEdge(t *testing.T) {
 		e.expiration = time.UnixMicro(0)
 	})
 	require.NoError(t, err)
-	require.Equal(t, true, isNew)
+	require.True(t, isNew)
 	assert.Equal(t, 1, s.Len())
 	assert.Equal(t, 1, onCompletedCount)
 	assert.Equal(t, 0, onExpireCount)
@@ -80,7 +80,7 @@ func TestStoreUpsertEdge_errTooManyItems(t *testing.T) {
 		e.ClientService = clientService
 	})
 	require.NoError(t, err)
-	require.Equal(t, true, isNew)
+	require.True(t, isNew)
 	assert.Equal(t, 1, s.Len())
 
 	_, err = s.UpsertEdge(key2, func(e *Edge) {
@@ -93,7 +93,7 @@ func TestStoreUpsertEdge_errTooManyItems(t *testing.T) {
 		e.ClientService = clientService
 	})
 	require.NoError(t, err)
-	require.Equal(t, false, isNew)
+	require.False(t, isNew)
 	assert.Equal(t, 1, s.Len())
 
 	assert.Equal(t, 0, onCallbackCounter)
@@ -120,7 +120,7 @@ func TestStoreExpire(t *testing.T) {
 	for key := range keys {
 		isNew, err := s.UpsertEdge(key, noopCallback)
 		require.NoError(t, err)
-		require.Equal(t, true, isNew)
+		require.True(t, isNew)
 	}
 
 	s.Expire()

connector/spanmetricsconnector/connector_test.go

@@ -692,7 +692,7 @@ func TestConnectorCapabilities(t *testing.T) {
 
 	// Verify
 	assert.NotNil(t, c)
-	assert.Equal(t, false, caps.MutatesData)
+	assert.False(t, caps.MutatesData)
 }
 
 type errConsumer struct {

exporter/alertmanagerexporter/alertmanager_exporter_test.go

@@ -138,11 +138,11 @@ func TestAlertManagerExporterEventNameAttributes(t *testing.T) {
 	// test - count of attributes
 	assert.Equal(t, 3, got[0].spanEvent.Attributes().Len())
 	attr, b := got[0].spanEvent.Attributes().Get("attr1")
-	assert.Equal(t, true, b)
+	assert.True(t, b)
 	assert.Equal(t, "unittest-event", got[0].spanEvent.Name())
 	assert.Equal(t, "unittest-baz", attr.AsString())
 	attr, b = got[0].spanEvent.Attributes().Get("attr3")
-	assert.Equal(t, true, b)
+	assert.True(t, b)
 	assert.Equal(t, 5.14, attr.Double())
 }
 

exporter/awss3exporter/s3_writer_test.go

@@ -38,7 +38,7 @@ func TestS3Key(t *testing.T) {
 	re := regexp.MustCompile(`keyprefix/year=2022/month=06/day=05/hour=00/minute=00/fileprefixlogs_([0-9]+).json`)
 	s3Key := getS3Key(tm, "keyprefix", "minute", "fileprefix", "logs", "json", "")
 	matched := re.MatchString(s3Key)
-	assert.Equal(t, true, matched)
+	assert.True(t, matched)
 }
 
 func TestS3KeyEmptyFileFormat(t *testing.T) {
@@ -52,7 +52,7 @@ func TestS3KeyEmptyFileFormat(t *testing.T) {
 	re := regexp.MustCompile(`keyprefix/year=2022/month=06/day=05/hour=00/minute=00/fileprefixlogs_([0-9]+)`)
 	s3Key := getS3Key(tm, "keyprefix", "minute", "fileprefix", "logs", "", "")
 	matched := re.MatchString(s3Key)
-	assert.Equal(t, true, matched)
+	assert.True(t, matched)
 }
 
 func TestS3KeyOfCompressedFile(t *testing.T) {
@@ -66,7 +66,7 @@ func TestS3KeyOfCompressedFile(t *testing.T) {
 	re := regexp.MustCompile(`keyprefix/year=2022/month=06/day=05/hour=00/minute=00/fileprefixlogs_([0-9]+).json.gz`)
 	s3Key := getS3Key(tm, "keyprefix", "minute", "fileprefix", "logs", "json", "gzip")
 	matched := re.MatchString(s3Key)
-	assert.Equal(t, true, matched)
+	assert.True(t, matched)
 }
 
 func TestS3KeyOfCompressedFileEmptyFileFormat(t *testing.T) {
@@ -80,7 +80,7 @@ func TestS3KeyOfCompressedFileEmptyFileFormat(t *testing.T) {
 	re := regexp.MustCompile(`keyprefix/year=2022/month=06/day=05/hour=00/minute=00/fileprefixlogs_([0-9]+).gz`)
 	s3Key := getS3Key(tm, "keyprefix", "minute", "fileprefix", "logs", "", "gzip")
 	matched := re.MatchString(s3Key)
-	assert.Equal(t, true, matched)
+	assert.True(t, matched)
 }
 
 func TestGetSessionConfigWithEndpoint(t *testing.T) {

exporter/awsxrayexporter/internal/translator/segment_test.go

@@ -1252,7 +1252,7 @@ func validateLocalRootDependencySubsegment(t *testing.T, segment *awsxray.Segmen
 
 	assert.Equal(t, "MySDK", *segment.AWS.XRay.SDK)
 	assert.Equal(t, "1.20.0", *segment.AWS.XRay.SDKVersion)
-	assert.Equal(t, true, *segment.AWS.XRay.AutoInstrumentation)
+	assert.True(t, *segment.AWS.XRay.AutoInstrumentation)
 
 	assert.Equal(t, "UpdateItem", *segment.AWS.Operation)
 	assert.Equal(t, "AWSAccountAttribute", *segment.AWS.AccountID)
@@ -1278,7 +1278,7 @@ func validateLocalRootServiceSegment(t *testing.T, segment *awsxray.Segment, spa
 	assert.Equal(t, "service.name=myTest", segment.Metadata["default"]["otel.resource.attributes"])
 	assert.Equal(t, "MySDK", *segment.AWS.XRay.SDK)
 	assert.Equal(t, "1.20.0", *segment.AWS.XRay.SDKVersion)
-	assert.Equal(t, true, *segment.AWS.XRay.AutoInstrumentation)
+	assert.True(t, *segment.AWS.XRay.AutoInstrumentation)
 	assert.Nil(t, segment.AWS.Operation)
 	assert.Nil(t, segment.AWS.AccountID)
 	assert.Nil(t, segment.AWS.RemoteRegion)
@@ -1406,7 +1406,7 @@ func TestNonLocalRootConsumerProcess(t *testing.T) {
 	assert.Equal(t, "service.name=myTest", segments[0].Metadata["default"]["otel.resource.attributes"])
 	assert.Equal(t, "MySDK", *segments[0].AWS.XRay.SDK)
 	assert.Equal(t, "1.20.0", *segments[0].AWS.XRay.SDKVersion)
-	assert.Equal(t, true, *segments[0].AWS.XRay.AutoInstrumentation)
+	assert.True(t, *segments[0].AWS.XRay.AutoInstrumentation)
 	assert.Equal(t, "UpdateItem", *segments[0].AWS.Operation)
 	assert.Nil(t, segments[0].Namespace)
 }
@@ -1563,7 +1563,7 @@ func validateLocalRootWithoutDependency(t *testing.T, segment *awsxray.Segment,
 	assert.Equal(t, "service.name=myTest", segment.Metadata["default"]["otel.resource.attributes"])
 	assert.Equal(t, "MySDK", *segment.AWS.XRay.SDK)
 	assert.Equal(t, "1.20.0", *segment.AWS.XRay.SDKVersion)
-	assert.Equal(t, true, *segment.AWS.XRay.AutoInstrumentation)
+	assert.True(t, *segment.AWS.XRay.AutoInstrumentation)
 
 	assert.Equal(t, "UpdateItem", *segment.AWS.Operation)
 	assert.Equal(t, "AWSAccountAttribute", *segment.AWS.AccountID)

exporter/datasetexporter/config_test.go

@@ -157,7 +157,7 @@ func TestConfigUseProvidedExportResourceInfoValue(t *testing.T) {
 	})
 	err := config.Unmarshal(configMap)
 	assert.NoError(t, err)
-	assert.Equal(t, true, config.LogsSettings.ExportResourceInfo)
+	assert.True(t, config.LogsSettings.ExportResourceInfo)
 }
 
 func TestConfigUseProvidedExportScopeInfoValue(t *testing.T) {
@@ -172,5 +172,5 @@ func TestConfigUseProvidedExportScopeInfoValue(t *testing.T) {
 	})
 	err := config.Unmarshal(configMap)
 	assert.NoError(t, err)
-	assert.Equal(t, false, config.LogsSettings.ExportScopeInfo)
+	assert.False(t, config.LogsSettings.ExportScopeInfo)
 }

exporter/fileexporter/factory_test.go

@@ -124,7 +124,7 @@ func TestNewFileWriter(t *testing.T) {
 			validate: func(t *testing.T, writer *fileWriter) {
 				assert.Equal(t, 5*time.Second, writer.flushInterval)
 				_, ok := writer.file.(*bufferedWriteCloser)
-				assert.Equal(t, true, ok)
+				assert.True(t, ok)
 			},
 		},
 		{
@@ -139,7 +139,7 @@ func TestNewFileWriter(t *testing.T) {
 			},
 			validate: func(t *testing.T, writer *fileWriter) {
 				logger, ok := writer.file.(*lumberjack.Logger)
-				assert.Equal(t, true, ok)
+				assert.True(t, ok)
 				assert.Equal(t, defaultMaxBackups, logger.MaxBackups)
 			},
 		},
@@ -158,11 +158,11 @@ func TestNewFileWriter(t *testing.T) {
 			},
 			validate: func(t *testing.T, writer *fileWriter) {
 				logger, ok := writer.file.(*lumberjack.Logger)
-				assert.Equal(t, true, ok)
+				assert.True(t, ok)
 				assert.Equal(t, 3, logger.MaxBackups)
 				assert.Equal(t, 30, logger.MaxSize)
 				assert.Equal(t, 100, logger.MaxAge)
-				assert.Equal(t, true, logger.LocalTime)
+				assert.True(t, logger.LocalTime)
 			},
 		},
 	}

exporter/honeycombmarkerexporter/logs_exporter_test.go

@@ -138,7 +138,7 @@ func TestExportMarkers(t *testing.T) {
 
 				userAgent := req.Header.Get(userAgentHeaderKey)
 				assert.NotEmpty(t, userAgent)
-				assert.Equal(t, strings.Contains(userAgent, "OpenTelemetry Collector"), true)
+				assert.True(t, strings.Contains(userAgent, "OpenTelemetry Collector"))
 
 				rw.WriteHeader(http.StatusAccepted)
 			}))

exporter/logicmonitorexporter/internal/logs/sender_test.go

@@ -64,7 +64,7 @@ func TestSendLogs(t *testing.T) {
 		err = sender.SendLogs(ctx, []model.LogInput{logInput})
 		cancel()
 		assert.Error(t, err)
-		assert.Equal(t, true, consumererror.IsPermanent(err))
+		assert.True(t, consumererror.IsPermanent(err))
 	})
 
 	t.Run("should not return permanent failure error", func(t *testing.T) {
@@ -87,7 +87,7 @@ func TestSendLogs(t *testing.T) {
 		err = sender.SendLogs(ctx, []model.LogInput{logInput})
 		cancel()
 		assert.Error(t, err)
-		assert.Equal(t, false, consumererror.IsPermanent(err))
+		assert.False(t, consumererror.IsPermanent(err))
 	})
 }
 

exporter/logicmonitorexporter/internal/traces/sender_test.go

@@ -64,7 +64,7 @@ func TestSendTraces(t *testing.T) {
 		err = sender.SendTraces(ctx, testdata.GenerateTraces(1))
 		cancel()
 		assert.Error(t, err)
-		assert.Equal(t, true, consumererror.IsPermanent(err))
+		assert.True(t, consumererror.IsPermanent(err))
 	})
 
 	t.Run("should not return permanent failure error", func(t *testing.T) {
@@ -86,6 +86,6 @@ func TestSendTraces(t *testing.T) {
 		err = sender.SendTraces(ctx, testdata.GenerateTraces(1))
 		cancel()
 		assert.Error(t, err)
-		assert.Equal(t, false, consumererror.IsPermanent(err))
+		assert.False(t, consumererror.IsPermanent(err))
 	})
 }

exporter/lokiexporter/exporter_test.go

@@ -276,7 +276,7 @@ func TestLogsToLokiRequestWithGroupingByTenant(t *testing.T) {
 			assert.Equal(t, len(actualPushRequestPerTenant), len(tC.expected))
 			for tenant, request := range actualPushRequestPerTenant {
 				pr, ok := tC.expected[tenant]
-				assert.Equal(t, ok, true)
+				assert.True(t, ok)
 
 				expectedLabel := pr.label
 				expectedLine := pr.line

exporter/prometheusexporter/accumulator_test.go

@@ -373,7 +373,7 @@ func TestAccumulateDeltaToCumulative(t *testing.T) {
 			require.Equal(t, mValue, vValue)
 			require.Equal(t, dataPointValue1+dataPointValue2, vValue)
 			require.Equal(t, pmetric.AggregationTemporalityCumulative, vTemporality)
-			require.Equal(t, true, vIsMonotonic)
+			require.True(t, vIsMonotonic)
 
 			require.Equal(t, ts3.Unix(), vTS.Unix())
 		})

exporter/syslogexporter/exporter_test.go

@@ -168,7 +168,7 @@ func TestSyslogExportFail(t *testing.T) {
 	consumerErr := test.exp.pushLogsData(context.Background(), logs)
 	var consumerErrorLogs consumererror.Logs
 	ok := errors.As(consumerErr, &consumerErrorLogs)
-	assert.Equal(t, ok, true)
+	assert.True(t, ok)
 	consumerLogs := consumererror.Logs.Data(consumerErrorLogs)
 	rls := consumerLogs.ResourceLogs()
 	require.Equal(t, 1, rls.Len())