feat(outbox): add events outbox relayer internals

gothunder · Dec 12, 2023 · b4889e7 · b4889e7
1 parent 3b2aa5d
commit b4889e7
Show file tree

Hide file tree

Showing 41 changed files with 2,056 additions and 57 deletions.
diff --git a/Makefile b/Makefile
@@ -2,4 +2,5 @@ test-example:
 	@go run github.com/onsi/ginkgo/v2/ginkgo -v ./example/testing
 
 test:
+	@go test -v ./internal/... ./pkg/...
 	@go run github.com/onsi/ginkgo/v2/ginkgo -v -p --race ./tests
diff --git a/go.mod b/go.mod
@@ -1,14 +1,16 @@
 module github.com/gothunder/thunder
 
-go 1.19
+go 1.21
+
+toolchain go1.21.5
 
 require (
 	entgo.io/ent v0.12.4
 	github.com/99designs/gqlgen v0.17.24
 	github.com/TheRafaBonin/roxy v0.6.1
 	github.com/cenkalti/backoff/v4 v4.2.0
 	github.com/go-chi/chi/v5 v5.0.8
-	github.com/google/uuid v1.3.0
+	github.com/google/uuid v1.3.1
 	github.com/mattn/go-sqlite3 v1.14.16
 	github.com/onsi/ginkgo/v2 v2.8.0
 	github.com/onsi/gomega v1.25.0
@@ -33,13 +35,16 @@ require (
 	github.com/go-openapi/inflect v0.19.0 // indirect
 	github.com/golang/protobuf v1.5.3 // indirect
 	github.com/hashicorp/hcl/v2 v2.13.0 // indirect
+	github.com/lithammer/shortuuid/v3 v3.0.7 // indirect
 	github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7 // indirect
+	github.com/oklog/ulid v1.3.1 // indirect
 	github.com/zclconf/go-cty v1.8.0 // indirect
 	google.golang.org/genproto v0.0.0-20230306155012-7f2fa6fef1f4 // indirect
 	google.golang.org/protobuf v1.30.0 // indirect
 )
 
 require (
+	github.com/ThreeDotsLabs/watermill v1.3.5
 	github.com/agnivade/levenshtein v1.1.1 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/fsnotify/fsnotify v1.5.4 // indirect

diff --git a/go.sum b/go.sum
@@ -48,6 +48,8 @@ github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym
 github.com/DATA-DOG/go-sqlmock v1.5.0 h1:Shsta01QNfFxHCfpW6YH2STWB0MudeXXEWMr20OEh60=
 github.com/TheRafaBonin/roxy v0.6.1 h1:uW7ttgqtww4ipH82smosk6SZDz3GjJM5mC/GRWsi+2Q=
 github.com/TheRafaBonin/roxy v0.6.1/go.mod h1:wLE6Upm7KEkwpYA6LzPBMHlyXSXiMe/fWwHi/+5Fk1w=
+github.com/ThreeDotsLabs/watermill v1.3.5 h1:50JEPEhMGZQMh08ct0tfO1PsgMOAOhV3zxK2WofkbXg=
+github.com/ThreeDotsLabs/watermill v1.3.5/go.mod h1:O/u/Ptyrk5MPTxSeWM5vzTtZcZfxXfO9PK9eXTYiFZY=
 github.com/agext/levenshtein v1.2.1 h1:QmvMAjj2aEICytGiWzmxoE0x2KZvE0fvmqMOfy2tjT8=
 github.com/agext/levenshtein v1.2.1/go.mod h1:JEDfjyjHDjOF/1e4FlBE/PkbqA9OfWu2ki2W0IB5558=
 github.com/agnivade/levenshtein v1.0.1/go.mod h1:CURSv5d9Uaml+FovSIICkLbAUZ9S4RqaHDIsdSBg7lM=
@@ -164,8 +166,11 @@ github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38 h1:yAJXTCF9TqKcTiHJAE
 github.com/google/pprof v0.0.0-20210407192527-94a9f03dee38/go.mod h1:kpwsk12EmLew5upagYY7GY0pfYCcupk39gWOCRROcvE=
 github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=
 github.com/google/uuid v1.1.2/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/google/uuid v1.2.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/google/uuid v1.3.0 h1:t6JiXgmwXMjEs8VusXIJk2BXHsn+wx8BZdTaoZ5fu7I=
 github.com/google/uuid v1.3.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
+github.com/google/uuid v1.3.1 h1:KjJaJ9iWZ3jOFZIf1Lqf4laDRCasjl0BCmnEGxkdLb4=
+github.com/google/uuid v1.3.1/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
 github.com/googleapis/gax-go/v2 v2.0.4/go.mod h1:0Wqv26UfaUD9n4G6kQubkQ+KchISgw+vpHVxEJEs9eg=
 github.com/googleapis/gax-go/v2 v2.0.5/go.mod h1:DWXyrwAJ9X0FpwwEdw+IPEYBICEFu5mhpdKc/us6bOk=
 github.com/googleapis/google-cloud-go-testing v0.0.0-20200911160855-bcd43fbb19e8/go.mod h1:dvDLG8qkwmyD9a/MJJN3XJcT3xFxOKAvTZGvuZmac9g=
@@ -194,6 +199,8 @@ github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
 github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kylelemons/godebug v0.0.0-20170820004349-d65d576e9348 h1:MtvEpTB6LX3vkb4ax0b5D2DHbNAUsen0Gx5wZoq3lV4=
+github.com/lithammer/shortuuid/v3 v3.0.7 h1:trX0KTHy4Pbwo/6ia8fscyHoGA+mf1jWbPJVuvyJQQ8=
+github.com/lithammer/shortuuid/v3 v3.0.7/go.mod h1:vMk8ke37EmiewwolSO1NLW8vP4ZaKlRuDIi8tWWmAts=
 github.com/logrusorgru/aurora/v3 v3.0.0/go.mod h1:vsR12bk5grlLvLXAYrBsb5Oc/N+LxAlxggSjiwMnCUc=
 github.com/magiconair/properties v1.8.6 h1:5ibWZ6iY0NctNGWo87LalDlEZ6R41TqbbDamhfG/Qzo=
 github.com/magiconair/properties v1.8.6/go.mod h1:y3VJvCyxH9uVvJTWEGAELF3aiYNyPKd5NZ3oSwXrF60=
@@ -204,6 +211,8 @@ github.com/mattn/go-colorable v0.1.13/go.mod h1:7S9/ev0klgBDR4GtXTXX8a3vIGJpMovk
 github.com/mattn/go-isatty v0.0.14/go.mod h1:7GGIvUiUoEMVVmxf/4nioHXj79iQHKdU27kJ6hsGG94=
 github.com/mattn/go-isatty v0.0.16 h1:bq3VjFmv/sOjHtdEhmkEV4x1AJtvUvOJ2PFAZ5+peKQ=
 github.com/mattn/go-isatty v0.0.16/go.mod h1:kYGgaQfpe5nmfYZH+SKPsOc2e4SrIfOl2e/yFXSvRLM=
+github.com/mattn/go-runewidth v0.0.9 h1:Lm995f3rfxdpd6TSmuVCHVb/QhupuXlYr8sCI/QdE+0=
+github.com/mattn/go-runewidth v0.0.9/go.mod h1:H031xJmbD/WCDINGzjvQ9THkh0rPKHF+m2gUSrubnMI=
 github.com/mattn/go-sqlite3 v1.14.16 h1:yOQRA0RpS5PFz/oikGwBEqvAWhWg5ufRz4ETLjwpU1Y=
 github.com/mattn/go-sqlite3 v1.14.16/go.mod h1:2eHXhiwb8IkHr+BDWZGa96P6+rkvnG63S2DGjv9HUNg=
 github.com/mitchellh/go-homedir v1.1.0 h1:lukF9ziXFxDFPkA1vsr5zpc1XuPDn/wFntq5mG+4E0Y=
@@ -212,6 +221,10 @@ github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7 h1:DpOJ2HYzC
 github.com/mitchellh/go-wordwrap v0.0.0-20150314170334-ad45545899c7/go.mod h1:ZXFpozHsX6DPmq2I0TCekCxypsnAUbP2oI0UX1GXzOo=
 github.com/mitchellh/mapstructure v1.5.0 h1:jeMsZIYE/09sWLaz43PL7Gy6RuMjD2eJVyuac5Z2hdY=
 github.com/mitchellh/mapstructure v1.5.0/go.mod h1:bFUtVrKA4DC2yAKiSyO/QUcy7e+RRV2QTWOzhPopBRo=
+github.com/oklog/ulid v1.3.1 h1:EGfNDEx6MqHz8B3uNV6QAib1UR2Lm97sHi3ocA6ESJ4=
+github.com/oklog/ulid v1.3.1/go.mod h1:CirwcVhetQ6Lv90oh/F+FBtV6XMibvdAFo93nm5qn4U=
+github.com/olekukonko/tablewriter v0.0.5 h1:P2Ga83D34wi1o9J6Wh1mRuqd4mF/x/lgBS7N7AbDhec=
+github.com/olekukonko/tablewriter v0.0.5/go.mod h1:hPp6KlRPjbx+hW8ykQs1w3UBbZlj6HuIJcUGPhkA7kY=
 github.com/onsi/ginkgo/v2 v2.8.0 h1:pAM+oBNPrpXRs+E/8spkeGx9QgekbRVyr74EUvRVOUI=
 github.com/onsi/ginkgo/v2 v2.8.0/go.mod h1:6JsQiECmxCa3V5st74AL/AmsV482EDdVrGaVW6z3oYU=
 github.com/onsi/gomega v1.25.0 h1:Vw7br2PCDYijJHSfBOWhov+8cAnUf8MfMaIOV323l6Y=

diff --git a/tests/entInit/client.go → internal/events/outbox/ent/entInit/client.go b/tests/entInit/client.go → internal/events/outbox/ent/entInit/client.go
diff --git a/tests/entInit/ent.go → internal/events/outbox/ent/entInit/ent.go b/tests/entInit/ent.go → internal/events/outbox/ent/entInit/ent.go
diff --git a/tests/entInit/enttest/enttest.go → ...nts/outbox/ent/entInit/enttest/enttest.go b/tests/entInit/enttest/enttest.go → ...nts/outbox/ent/entInit/enttest/enttest.go
diff --git a/internal/events/outbox/ent/entInit/generate.go b/internal/events/outbox/ent/entInit/generate.go
@@ -0,0 +1,3 @@
+package entInit
+
+//go:generate go run -mod=mod entgo.io/ent/cmd/ent generate --feature intercept ./schema
diff --git a/tests/entInit/hook/hook.go → ...al/events/outbox/ent/entInit/hook/hook.go b/tests/entInit/hook/hook.go → ...al/events/outbox/ent/entInit/hook/hook.go
diff --git a/internal/events/outbox/ent/entInit/intercept/intercept.go b/internal/events/outbox/ent/entInit/intercept/intercept.go
diff --git a/tests/entInit/migrate/migrate.go → ...nts/outbox/ent/entInit/migrate/migrate.go b/tests/entInit/migrate/migrate.go → ...nts/outbox/ent/entInit/migrate/migrate.go
diff --git a/tests/entInit/migrate/schema.go → ...ents/outbox/ent/entInit/migrate/schema.go b/tests/entInit/migrate/schema.go → ...ents/outbox/ent/entInit/migrate/schema.go
diff --git a/tests/entInit/mutation.go → ...nal/events/outbox/ent/entInit/mutation.go b/tests/entInit/mutation.go → ...nal/events/outbox/ent/entInit/mutation.go
diff --git a/tests/entInit/outboxmessage.go → ...vents/outbox/ent/entInit/outboxmessage.go b/tests/entInit/outboxmessage.go → ...vents/outbox/ent/entInit/outboxmessage.go
diff --git a/tests/entInit/outboxmessage/outboxmessage.go → ...nt/entInit/outboxmessage/outboxmessage.go b/tests/entInit/outboxmessage/outboxmessage.go → ...nt/entInit/outboxmessage/outboxmessage.go
diff --git a/tests/entInit/outboxmessage/where.go → ...outbox/ent/entInit/outboxmessage/where.go b/tests/entInit/outboxmessage/where.go → ...outbox/ent/entInit/outboxmessage/where.go
diff --git a/tests/entInit/outboxmessage_create.go → ...utbox/ent/entInit/outboxmessage_create.go b/tests/entInit/outboxmessage_create.go → ...utbox/ent/entInit/outboxmessage_create.go
diff --git a/tests/entInit/outboxmessage_delete.go → ...utbox/ent/entInit/outboxmessage_delete.go b/tests/entInit/outboxmessage_delete.go → ...utbox/ent/entInit/outboxmessage_delete.go
diff --git a/tests/entInit/outboxmessage_query.go → ...outbox/ent/entInit/outboxmessage_query.go b/tests/entInit/outboxmessage_query.go → ...outbox/ent/entInit/outboxmessage_query.go
diff --git a/tests/entInit/outboxmessage_update.go → ...utbox/ent/entInit/outboxmessage_update.go b/tests/entInit/outboxmessage_update.go → ...utbox/ent/entInit/outboxmessage_update.go
diff --git a/tests/entInit/predicate/predicate.go → ...outbox/ent/entInit/predicate/predicate.go b/tests/entInit/predicate/predicate.go → ...outbox/ent/entInit/predicate/predicate.go
diff --git a/tests/entInit/runtime.go → ...rnal/events/outbox/ent/entInit/runtime.go b/tests/entInit/runtime.go → ...rnal/events/outbox/ent/entInit/runtime.go
diff --git a/tests/entInit/runtime/runtime.go → ...nts/outbox/ent/entInit/runtime/runtime.go b/tests/entInit/runtime/runtime.go → ...nts/outbox/ent/entInit/runtime/runtime.go
diff --git a/tests/entInit/schema/OutboxMessage.go → ...utbox/ent/entInit/schema/OutboxMessage.go b/tests/entInit/schema/OutboxMessage.go → ...utbox/ent/entInit/schema/OutboxMessage.go
diff --git a/tests/entInit/tx.go → internal/events/outbox/ent/entInit/tx.go b/tests/entInit/tx.go → internal/events/outbox/ent/entInit/tx.go
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		package entInit

		//go:generate go run -mod=mod entgo.io/ent/cmd/ent generate --feature intercept ./schema