Add AsyncAPI doc and generation script

Daniel Jimenez · Daniel Jimenez · commit fc86a580ca6e · 2022-11-29T15:46:28.000+01:00
diff --git a/README.md b/README.md
@@ -13,6 +13,12 @@ cd db && source flyway-migrate.sh && cd -
 vulnerability-db-consumer -c _resources/config/local.toml
 ```
 
+## How to generate AsyncAPI documentation
+Generated [AsyncAPI documentation](https://www.asyncapi.com/) can be found in `./docs` directory.
+```
+cd pkg/asyncapi/_gen && ./gen.sh && cd -
+```
+
 ## How to run the Vulnerability DB in development mode
 
 You can test the Vulnerability DB Consumer locally in your machine.
diff --git a/docs/asyncapi.yaml b/docs/asyncapi.yaml
@@ -0,0 +1,141 @@
+asyncapi: 2.4.0
+info:
+  title: Vulnerability DB
+  version: v0.0.1
+servers:
+  production:
+    url: broker.example.com
+    description: Dummy server
+    protocol: kafka
+channels:
+  findings:
+    subscribe:
+      message:
+        $ref: '#/components/messages/FindingPayload'
+components:
+  schemas:
+    FindingPayload:
+      properties:
+        affected_resource:
+          type: string
+        current_exposure:
+          type: integer
+        details:
+          type: string
+        id:
+          type: string
+        impact_details:
+          type: string
+        issue:
+          $ref: '#/components/schemas/StoreIssueLabels'
+        resources:
+          $ref: '#/components/schemas/StoreResources'
+        score:
+          type: number
+        source:
+          $ref: '#/components/schemas/StoreSource'
+        status:
+          type: string
+        target:
+          $ref: '#/components/schemas/StoreTargetTeams'
+        total_exposure:
+          type: integer
+      type: object
+    PqStringArray:
+      items:
+        type: string
+      type:
+      - array
+      - "null"
+    StoreIssueLabels:
+      properties:
+        cwe_id:
+          minimum: 0
+          type: integer
+        description:
+          type: string
+        id:
+          type: string
+        labels:
+          items:
+            type: string
+          type:
+          - array
+          - "null"
+        recommendations:
+          $ref: '#/components/schemas/PqStringArray'
+        reference_links:
+          $ref: '#/components/schemas/PqStringArray'
+        summary:
+          type: string
+      type: object
+    StoreResourceGroup:
+      properties:
+        attributes:
+          items:
+            type: string
+          type:
+          - array
+          - "null"
+        name:
+          type: string
+        resources:
+          items:
+            additionalProperties:
+              type: string
+            type: object
+          type:
+          - array
+          - "null"
+      type: object
+    StoreResources:
+      items:
+        $ref: '#/components/schemas/StoreResourceGroup'
+      type:
+      - array
+      - "null"
+    StoreSource:
+      properties:
+        component:
+          type: string
+        id:
+          type: string
+        instance:
+          type: string
+        name:
+          type: string
+        options:
+          type: string
+        time:
+          format: date-time
+          type: string
+      type: object
+    StoreTargetTeams:
+      properties:
+        id:
+          type: string
+        identifier:
+          type: string
+        teams:
+          items:
+            type: string
+          type:
+          - array
+          - "null"
+      type: object
+  messages:
+    FindingPayload:
+      contentType: application/json
+      headers:
+        properties:
+          version:
+            description: schema version header
+            type: string
+        required:
+        - version
+        type: object
+      payload:
+        $ref: '#/components/schemas/FindingPayload'
+      summary: Events generated from Vulnerability DB findings state changes
+      name: Finding
+      title: Findings state
diff --git a/go.mod b/go.mod
@@ -15,6 +15,7 @@ require (
 
 require (
 	github.com/jmespath/go-jmespath v0.4.0 // indirect
+	github.com/stretchr/testify v1.8.0 // indirect
 	golang.org/x/sys v0.0.0-20220913175220-63ea55921009 // indirect
 	gopkg.in/yaml.v2 v2.4.0 // indirect
 )
diff --git a/go.sum b/go.sum
@@ -128,13 +128,15 @@ github.com/santhosh-tekuri/jsonschema/v5 v5.0.0/go.mod h1:FKdcjfQW6rpZSnxxUvEA5H
 github.com/sirupsen/logrus v1.8.1 h1:dJKuHgqk1NNQlqoA6BTlM1Wf9DOH3NBjQyu0h9+AZZE=
 github.com/sirupsen/logrus v1.8.1/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
 github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.3.1-0.20190311161405-34c6fa2dc709/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
 github.com/stretchr/testify v1.5.1/go.mod h1:5W2xD1RspED5o8YsWQXVCued0rvSQ+mT+I5cxcmMvtA=
 github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
-github.com/stretchr/testify v1.7.1 h1:5TQK59W5E3v0r2duFAb7P95B6hEeOyEnHRa8MjYSMTY=
 github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
+github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
+github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
 github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
 go.opentelemetry.io/proto/otlp v0.7.0/go.mod h1:PqfVotwruBrMGOCsRd/89rSnXhoiJIqeYNgFYFoEGnI=
 golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
@@ -244,7 +246,8 @@ gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
 gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
-gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b h1:h8qDotaEPuJATrMmW04NCwg7v22aHH28wwpauUhK9Oo=
 gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
+gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 honnef.co/go/tools v0.0.0-20190102054323-c2f93a96b099/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
 honnef.co/go/tools v0.0.0-20190523083050-ea95bdfd59fc/go.mod h1:rf3lG4BRIbNafJWhAfAdb/ePZxsR/4RtNHQocxwk9r4=
diff --git a/pkg/asyncapi/_gen/gen.go b/pkg/asyncapi/_gen/gen.go
@@ -0,0 +1,53 @@
+package main
+
+import (
+	"os"
+
+	"github.com/adevinta/vulnerability-db/pkg/notify"
+
+	"github.com/swaggest/go-asyncapi/reflector/asyncapi-2.4.0"
+	"github.com/swaggest/go-asyncapi/spec-2.4.0"
+)
+
+type FindingPayload struct {
+	notify.FindingNotification
+	Version string `header:"version" description:"schema version header" required:"true"`
+}
+
+func main() {
+	asyncAPI := spec.AsyncAPI{}
+	asyncAPI.Info.Version = notify.Version
+	asyncAPI.Info.Title = "Vulnerability DB"
+
+	asyncAPI.AddServer("production", spec.Server{
+		URL:         "broker.example.com",
+		Description: "Dummy server",
+		Protocol:    "kafka",
+	})
+
+	reflector := asyncapi.Reflector{}
+	reflector.Schema = &asyncAPI
+
+	mustNotFail(reflector.AddChannel(asyncapi.ChannelInfo{
+		Name: "findings",
+		Subscribe: &asyncapi.MessageSample{
+			MessageEntity: spec.MessageEntity{
+				Name:        "Finding",
+				Title:       "Findings state",
+				Summary:     "Events generated from Vulnerability DB findings state changes",
+				ContentType: "application/json",
+			},
+			MessageSample: new(FindingPayload),
+		},
+	}))
+
+	yaml, err := reflector.Schema.MarshalYAML()
+	mustNotFail(err)
+	mustNotFail(os.WriteFile("../../../docs/asyncapi.yaml", yaml, 0o600))
+}
+
+func mustNotFail(err error) {
+	if err != nil {
+		panic(err)
+	}
+}
diff --git a/pkg/asyncapi/_gen/gen.sh b/pkg/asyncapi/_gen/gen.sh
@@ -0,0 +1,7 @@
+#!/bin/bash
+
+# Copyright 2022 Adevinta
+
+set -eu
+
+go run gen.go
diff --git a/pkg/asyncapi/_gen/go.mod b/pkg/asyncapi/_gen/go.mod
@@ -0,0 +1,22 @@
+module github.com/adevinta/vulnerability-db/pkg/asyncapi/_gen
+
+go 1.19
+
+require (
+	github.com/adevinta/vulnerability-db v1.1.5
+	github.com/swaggest/go-asyncapi v0.8.0
+)
+
+require (
+	github.com/aws/aws-sdk-go v1.44.98 // indirect
+	github.com/jmespath/go-jmespath v0.4.0 // indirect
+	github.com/jmoiron/sqlx v1.3.4 // indirect
+	github.com/lib/pq v1.10.3 // indirect
+	github.com/sirupsen/logrus v1.8.1 // indirect
+	github.com/swaggest/jsonschema-go v0.3.39 // indirect
+	github.com/swaggest/refl v1.1.0 // indirect
+	golang.org/x/sys v0.0.0-20220913175220-63ea55921009 // indirect
+	gopkg.in/yaml.v2 v2.4.0 // indirect
+)
+
+replace github.com/adevinta/vulnerability-db => ../../../
diff --git a/pkg/asyncapi/_gen/go.sum b/pkg/asyncapi/_gen/go.sum
@@ -0,0 +1,55 @@
+github.com/aws/aws-sdk-go v1.44.98 h1:fX+NxebSdO/9T6DTNOLhpC+Vv6RNkKRfsMg0a7o/yBo=
+github.com/aws/aws-sdk-go v1.44.98/go.mod h1:y4AeaBuwd2Lk+GepC1E9v0qOiTws0MIWAX4oIKwKHZo=
+github.com/bool64/dev v0.2.20 h1:9eIRGdcg2kQW2NGza++QbOKidNNaK+KfWuUXcZFDejE=
+github.com/bool64/shared v0.1.5 h1:fp3eUhBsrSjNCQPcSdQqZxxh9bBwrYiZ+zOKFkM0/2E=
+github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
+github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
+github.com/go-sql-driver/mysql v1.5.0 h1:ozyZYNQW3x3HtqT1jira07DN2PArx2v7/mN66gGcHOs=
+github.com/go-sql-driver/mysql v1.5.0/go.mod h1:DCzpHaOWr8IXmIStZouvnhqoel9Qv2LBy8hT2VhHyBg=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/iancoleman/orderedmap v0.2.0 h1:sq1N/TFpYH++aViPcaKjys3bDClUEU7s5B+z6jq8pNA=
+github.com/jmespath/go-jmespath v0.4.0 h1:BEgLn5cpjn8UN1mAw4NjwDrS35OdebyEtFe+9YPoQUg=
+github.com/jmespath/go-jmespath v0.4.0/go.mod h1:T8mJZnbsbmF+m6zOOFylbeCJqk5+pHWvzYPziyZiYoo=
+github.com/jmespath/go-jmespath/internal/testify v1.5.1 h1:shLQSRRSCCPj3f2gpwzGwWFoC7ycTf1rcQZHOlsJ6N8=
+github.com/jmespath/go-jmespath/internal/testify v1.5.1/go.mod h1:L3OGu8Wl2/fWfCI6z80xFu9LTZmf1ZRjMHUOPmWr69U=
+github.com/jmoiron/sqlx v1.3.4 h1:wv+0IJZfL5z0uZoUjlpKgHkgaFSYD+r9CfrXjEXsO7w=
+github.com/jmoiron/sqlx v1.3.4/go.mod h1:2BljVx/86SuTyjE+aPYlHCTNvZrnJXghYGpNiXLBMCQ=
+github.com/lib/pq v1.2.0/go.mod h1:5WUZQaWbwv1U+lTReE5YruASi9Al49XbQIvNi/34Woo=
+github.com/lib/pq v1.10.3 h1:v9QZf2Sn6AmjXtQeFpdoq/eaNtYP6IN+7lcrygsIAtg=
+github.com/lib/pq v1.10.3/go.mod h1:AlVN5x4E4T544tWzH6hKfbfQvm3HdbOxrmggDNAPY9o=
+github.com/mattn/go-sqlite3 v1.14.6 h1:dNPt6NO46WmLVt2DLNpwczCmdV5boIZ6g/tlDrlRUbg=
+github.com/mattn/go-sqlite3 v1.14.6/go.mod h1:NyWgC/yNuGj7Q9rpYnZvas74GogHl5/Z4A/KQRfk6bU=
+github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
+github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
+github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
+github.com/sergi/go-diff v1.2.0 h1:XU+rvMAioB0UC3q1MFrIQy4Vo5/4VsRDQQXHsEya6xQ=
+github.com/sirupsen/logrus v1.8.1 h1:dJKuHgqk1NNQlqoA6BTlM1Wf9DOH3NBjQyu0h9+AZZE=
+github.com/sirupsen/logrus v1.8.1/go.mod h1:yWOB1SBYBC5VeMP7gHvWumXLIWorT60ONWic61uBYv0=
+github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
+github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=
+github.com/stretchr/testify v1.8.0 h1:pSgiaMZlXftHpm5L7V1+rVB+AZJydKsMxsQBIJw4PKk=
+github.com/swaggest/assertjson v1.7.0 h1:SKw5Rn0LQs6UvmGrIdaKQbMR1R3ncXm5KNon+QJ7jtw=
+github.com/swaggest/go-asyncapi v0.8.0 h1:aze7YL3o/4fkxx9ZL8ubKdyYCqFJy+9+JHpwLyF10H4=
+github.com/swaggest/go-asyncapi v0.8.0/go.mod h1:s1urrZuYPcNPJrRUU/kF1eOnIBU02O4JfXCDS09wONI=
+github.com/swaggest/jsonschema-go v0.3.39 h1:qX+a/LiK44xppnwUTZqJWNFcICxdWKeT27aFh4RvkEk=
+github.com/swaggest/jsonschema-go v0.3.39/go.mod h1:ipIOmoFP64QyRUgyPyU/P9tayq2m2TlvUhyZHrhe3S4=
+github.com/swaggest/refl v1.1.0 h1:a+9a75Kv6ciMozPjVbOfcVTEQe81t2R3emvaD9oGQGc=
+github.com/swaggest/refl v1.1.0/go.mod h1:g3Qa6ki0A/L2yxiuUpT+cuBURuRaltF5SDQpg1kMZSY=
+github.com/yudai/gojsondiff v1.0.0 h1:27cbfqXLVEJ1o8I6v3y9lg8Ydm53EKqHXAOMxEGlCOA=
+github.com/yudai/golcs v0.0.0-20170316035057-ecda9a501e82 h1:BHyfKlQyqbsFN5p3IfnEUduWvb9is428/nNb5L3U01M=
+golang.org/x/net v0.0.0-20220127200216-cd36cc0744dd/go.mod h1:CfG3xpIq0wQ8r1q4Su4UZFWDARRcnwPjda9FqA0JpMk=
+golang.org/x/sys v0.0.0-20191026070338-33540a1f6037/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20211216021012-1d35b9e2eb4e/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/sys v0.0.0-20220913175220-63ea55921009 h1:PuvuRMeLWqsf/ZdT1UUZz0syhioyv1mzuFZsXs4fvhw=
+golang.org/x/sys v0.0.0-20220913175220-63ea55921009/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
+golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
+gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
+gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=
+gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=
+gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
diff --git a/pkg/notify/kafka.go b/pkg/notify/kafka.go
@@ -11,7 +11,7 @@ import (
 )
 
 const (
-	version = "v0.0.1" // Defines the notification schema version
+	Version = "v0.0.1" // Defines the notification schema version
 )
 
 // EventStreamClient represent a client of an event stream system, like Kafka
@@ -48,7 +48,7 @@ func (k *KafkaNotifier) PushFinding(f FindingNotification) error {
 		return err
 	}
 	meta := map[string][]byte{
-		"version": []byte(version),
+		"version": []byte(Version),
 	}
 	return k.c.Push(f.ID, payload, meta)
 }
diff --git a/pkg/notify/kafka_test.go b/pkg/notify/kafka_test.go
@@ -210,7 +210,7 @@ func TestKafka_PushFinding(t *testing.T) {
 				}
 				`)),
 				metadata: map[string][]byte{
-					"version": []byte(version),
+					"version": []byte(Version),
 				},
 			},
 		},

Original file line number	Diff line number	Diff line change
`@@ -15,6 +15,7 @@ require (`
`15`	`15`
`16`	`16`	`require (`
`17`	`17`	`github.com/jmespath/go-jmespath v0.4.0 // indirect`
	`18`	`+ github.com/stretchr/testify v1.8.0 // indirect`
`18`	`19`	`golang.org/x/sys v0.0.0-20220913175220-63ea55921009 // indirect`
`19`	`20`	`gopkg.in/yaml.v2 v2.4.0 // indirect`
`20`	`21`	`)`
-Original file line number
+Diff line change
 +module github.com/adevinta/vulnerability-db/pkg/asyncapi/_gen
++
 +go 1.19
++
 +require (
 +	github.com/adevinta/vulnerability-db v1.1.5
 +	github.com/swaggest/go-asyncapi v0.8.0
 +)
++
 +require (
 +	github.com/aws/aws-sdk-go v1.44.98 // indirect
 +	github.com/jmespath/go-jmespath v0.4.0 // indirect
 +	github.com/jmoiron/sqlx v1.3.4 // indirect
 +	github.com/lib/pq v1.10.3 // indirect
 +	github.com/sirupsen/logrus v1.8.1 // indirect
 +	github.com/swaggest/jsonschema-go v0.3.39 // indirect
 +	github.com/swaggest/refl v1.1.0 // indirect
 +	golang.org/x/sys v0.0.0-20220913175220-63ea55921009 // indirect
 +	gopkg.in/yaml.v2 v2.4.0 // indirect
 +)
++
 +replace github.com/adevinta/vulnerability-db => ../../../
Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@ import (`
`11`	`11`	`)`
`12`	`12`
`13`	`13`	`const (`
`14`		`- version = "v0.0.1" // Defines the notification schema version`
	`14`	`+ Version = "v0.0.1" // Defines the notification schema version`
`15`	`15`	`)`
`16`	`16`
`17`	`17`	`// EventStreamClient represent a client of an event stream system, like Kafka`
`@@ -48,7 +48,7 @@ func (k *KafkaNotifier) PushFinding(f FindingNotification) error {`
`48`	`48`	`return err`
`49`	`49`	`}`
`50`	`50`	`meta := map[string][]byte{`
`51`		`- "version": []byte(version),`
	`51`	`+ "version": []byte(Version),`
`52`	`52`	`}`
`53`	`53`	`return k.c.Push(f.ID, payload, meta)`
`54`	`54`	`}`
Original file line number	Diff line number	Diff line change
`@@ -210,7 +210,7 @@ func TestKafka_PushFinding(t *testing.T) {`
`210`	`210`	`}`
`211`	`211`	`)),
`212`	`212`	`metadata: map[string][]byte{`
`213`		`- "version": []byte(version),`
	`213`	`+ "version": []byte(Version),`
`214`	`214`	`},`
`215`	`215`	`},`
`216`	`216`	`},`