diff --git a/.github/workflows/golangci-lint.yml b/.github/workflows/golangci-lint.yml index 8559736..8b3f99e 100644 --- a/.github/workflows/golangci-lint.yml +++ b/.github/workflows/golangci-lint.yml @@ -17,4 +17,4 @@ jobs: - name: golangci-lint uses: golangci/golangci-lint-action@v2 with: - version: v1.43 + version: v1.42 diff --git a/handler.kafka.tmpl b/handler.kafka.tmpl index 0de6fca..752890d 100644 --- a/handler.kafka.tmpl +++ b/handler.kafka.tmpl @@ -1,7 +1,7 @@ -// Code generated by protoc-gen-go. DO NOT EDIT. +// Code generated by protoc-gen-go-kafka. DO NOT EDIT. // // versions: -// protoc-gen-go v1.27.1 +// protoc-gen-go-kafka {{.Version}} // protoc (unknown) // source: {{.PathFile}} @@ -11,7 +11,6 @@ import ( "context" "github.com/ThreeDotsLabs/watermill/message" - "github.com/google/uuid" "github.com/pkg/errors" "github.com/rs/zerolog/log" "google.golang.org/protobuf/encoding/protojson" @@ -19,15 +18,15 @@ import ( // {{.ModelName}}Event структурая, содержащая поля сообщения type {{.ModelName}}Event struct { - ID uuid.UUID + ID string Meta map[string]string Body *{{.ModelName}} } // New{{.ModelName}}Event конструктор события {{.ModelName}}Event -func New{{.ModelName}}Event(data *{{.ModelName}}) *{{.ModelName}}Event { +func New{{.ModelName}}Event(id string, data *{{.ModelName}}) *{{.ModelName}}Event { return &{{.ModelName}}Event{ - ID: uuid.New(), + ID: id, Meta: make(map[string]string), Body: data, } @@ -62,20 +61,13 @@ func Make{{.ModelName}}Handler(handler {{.ModelName}}Handler) message.NoPublishH return nil } - id, err := uuid.Parse(msg.UUID) - if err != nil { - log.Err(err).Msg("невозможно разобрать идентификатор сообщения") - - return nil - } - evt := &{{.ModelName}}Event{ - ID: id, + ID: msg.UUID, Meta: msg.Metadata, Body: r, } - if err = handler.Handle(msg.Context(), evt); err != nil { + if err := handler.Handle(msg.Context(), evt); err != nil { return errors.Wrap(err, "не удалось обработать событие") } @@ -103,7 +95,7 @@ func (r *{{.ModelNamePrivate}}Publisher) Publish(event *{{.ModelName}}Event) err return errors.Wrap(err, "невозможно сериализовать данные") } - msg := message.NewMessage(event.ID.String(), payload) + msg := message.NewMessage(event.ID, payload) if event.Meta == nil { event.Meta = map[string]string{} diff --git a/main.go b/main.go index aafbadf..ea481a5 100644 --- a/main.go +++ b/main.go @@ -19,11 +19,12 @@ type gen struct { ModelName string PackageName string PathFile string + Version string } const ( defaultSuffix = "Export" - version = "v1.1.1" + version = "v1.1.3" ) func main() { @@ -53,6 +54,7 @@ func main() { ModelName: message.GetName(), PackageName: string(file.GoPackageName), PathFile: file.Desc.Path(), + Version: version, }) if err != nil { plugin.Error(err)