checkshttp

.github/workflows/build.yaml

@@ -0,0 +1,22 @@
+name: Build
+
+on:
+  push:
+  pull_request:
+
+jobs:
+  build:
+    runs-on: ubuntu-24.04
+
+    steps:
+      - uses: actions/checkout@v4
+
+      - uses: actions/setup-go@v5
+        with:
+          go-version: '>=1.19'
+
+      - name: Install tests deps
+        run: sudo apt install nmap -y
+
+      - name: Go test
+        run: go test -v ./... -count 1

bootstrapper.go

@@ -14,6 +14,7 @@ import (
 
 	"github.com/adevinta/vulcan-check-sdk/agent"
 	"github.com/adevinta/vulcan-check-sdk/config"
+	"github.com/adevinta/vulcan-check-sdk/internal/http"
 	"github.com/adevinta/vulcan-check-sdk/internal/local"
 	"github.com/adevinta/vulcan-check-sdk/internal/logging"
 	"github.com/adevinta/vulcan-check-sdk/internal/push"
@@ -130,10 +131,19 @@ func NewCheck(name string, checker Checker) Check {
 		conf.Check.Target = runTarget
 		conf.Check.Opts = options
 		c = newLocalCheck(name, checker, logger, conf, json)
+	} else if conf.Port != nil {
+		logger.Debug("Http mode")
+		l := logging.BuildLoggerWithConfigAndFields(conf.Log, log.Fields{
+			// "checkTypeName":    "TODO",
+			// "checkTypeVersion": "TODO",
+			// "component":        "checks",
+		})
+		c = http.NewCheck(name, checker, l, conf)
 	} else {
 		logger.Debug("Push mode")
 		c = push.NewCheckWithConfig(name, checker, logger, conf)
 	}
+
 	cachedConfig = conf
 	return c
 }
@@ -149,6 +159,14 @@ func NewCheckLog(name string) *log.Entry {
 	return (l)
 }
 
+// NewCheckLogFromContext retrieves the logger from the context or creates a new one.
+func NewCheckLogFromContext(ctx context.Context, name string) *log.Entry {
+	if l, ok := ctx.Value("logger").(*log.Entry); ok {
+		return l
+	}
+	return NewCheckLog(name)
+}
+
 // NewCheckFromHandlerWithConfig creates a new check from run and abort handlers using provided config.
 func NewCheckFromHandlerWithConfig(name string, conf *config.Config, run CheckerHandleRun) Check {
 	checkerAdapter := struct {

config/config.go

@@ -30,6 +30,8 @@ const (
 	pushAgentAddr    = "VULCAN_AGENT_ADDRESS"
 	pushMsgBufferLen = "VULCAN_CHECK_MSG_BUFF_LEN"
 
+	httpPort = "VULCAN_HTTP_PORT"
+
 	// Allows scanning private / reserved IP addresses.
 	allowPrivateIPs = "VULCAN_ALLOW_PRIVATE_IPS"
 
@@ -63,6 +65,7 @@ type Config struct {
 	Log             LogConfig         `toml:"Log"`
 	CommMode        string            `toml:"CommMode"`
 	Push            rest.PusherConfig `toml:"Push"`
+	Port            *int              `toml:"Port"`
 	AllowPrivateIPs *bool             `toml:"AllowPrivateIps"`
 	RequiredVars    map[string]string `toml:"RequiredVars"`
 }
@@ -121,6 +124,14 @@ func overrideCommConfigEnvVars(c *Config) {
 		c.Push.AgentAddr = pushEndPoint
 	}
 
+	port := os.Getenv(httpPort)
+	if port != "" {
+		p, err := strconv.Atoi(port)
+		if err == nil {
+			c.Port = &p
+		}
+	}
+
 	msgBuffLen := os.Getenv(pushMsgBufferLen)
 	len, err := strconv.ParseInt(msgBuffLen, 0, 32)
 	if err != nil {

config/config_test.go

@@ -167,9 +167,6 @@ func setEnvVars(envVars map[string]string) error {
 }
 
 func TestLoadConfigFromFile(t *testing.T) {
-	type args struct {
-		filePath string
-	}
 	tests := []struct {
 		name     string
 		filepath string

go.mod

@@ -6,29 +6,31 @@ require (
 	github.com/BurntSushi/toml v1.2.1
 	github.com/adevinta/vulcan-report v1.0.0
 	github.com/adevinta/vulcan-types v1.2.11
-	github.com/aws/aws-sdk-go v1.51.0
-	github.com/go-git/go-git/v5 v5.6.1
+	github.com/aws/aws-sdk-go v1.55.5
+	github.com/go-git/go-git/v5 v5.12.0
 	github.com/google/go-cmp v0.6.0
 	github.com/kr/pretty v0.3.1
 	github.com/lair-framework/go-nmap v0.0.0-20191202052157-3507e0b03523
 	github.com/sirupsen/logrus v1.9.0
+	go.uber.org/goleak v1.3.0
 	google.golang.org/api v0.171.0
 	gopkg.in/resty.v1 v1.12.0
 )
 
 require (
 	cloud.google.com/go/compute v1.23.4 // indirect
 	cloud.google.com/go/compute/metadata v0.2.3 // indirect
-	github.com/Microsoft/go-winio v0.6.0 // indirect
-	github.com/ProtonMail/go-crypto v0.0.0-20230411080316-8b3893ee7fca // indirect
-	github.com/acomagu/bufpipe v1.0.4 // indirect
-	github.com/cloudflare/circl v1.3.3 // indirect
+	dario.cat/mergo v1.0.0 // indirect
+	github.com/Microsoft/go-winio v0.6.1 // indirect
+	github.com/ProtonMail/go-crypto v1.0.0 // indirect
+	github.com/cloudflare/circl v1.3.7 // indirect
+	github.com/cyphar/filepath-securejoin v0.2.4 // indirect
 	github.com/distribution/reference v0.5.0 // indirect
 	github.com/docker/distribution v2.8.3+incompatible // indirect
 	github.com/emirpasic/gods v1.18.1 // indirect
 	github.com/felixge/httpsnoop v1.0.4 // indirect
-	github.com/go-git/gcfg v1.5.0 // indirect
-	github.com/go-git/go-billy/v5 v5.4.1 // indirect
+	github.com/go-git/gcfg v1.5.1-0.20230307220236-3a3c6141e376 // indirect
+	github.com/go-git/go-billy/v5 v5.5.0 // indirect
 	github.com/go-logr/logr v1.4.1 // indirect
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
@@ -37,16 +39,15 @@ require (
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/googleapis/enterprise-certificate-proxy v0.3.2 // indirect
 	github.com/googleapis/gax-go/v2 v2.12.3 // indirect
-	github.com/imdario/mergo v0.3.15 // indirect
 	github.com/jbenet/go-context v0.0.0-20150711004518-d14ea06fba99 // indirect
 	github.com/kevinburke/ssh_config v1.2.0 // indirect
 	github.com/kr/text v0.2.0 // indirect
 	github.com/miekg/dns v1.1.58 // indirect
 	github.com/opencontainers/go-digest v1.0.0 // indirect
 	github.com/pjbgf/sha1cd v0.3.0 // indirect
-	github.com/rogpeppe/go-internal v1.10.0 // indirect
-	github.com/sergi/go-diff v1.3.1 // indirect
-	github.com/skeema/knownhosts v1.1.0 // indirect
+	github.com/rogpeppe/go-internal v1.11.0 // indirect
+	github.com/sergi/go-diff v1.3.2-0.20230802210424-5b0b94c5c0d3 // indirect
+	github.com/skeema/knownhosts v1.2.2 // indirect
 	github.com/xanzy/ssh-agent v0.3.3 // indirect
 	go.opencensus.io v0.24.0 // indirect
 	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.49.0 // indirect