From 0241baf72ee321d917086638af990052aca2e7de Mon Sep 17 00:00:00 2001 From: Jairus Date: Tue, 15 Sep 2026 23:01:19 -0400 Subject: [PATCH 1/6] refactor: migrate to Wago public API --- go.mod | 2 +- go.sum | 4 ++-- workers_test.go | 12 ++++-------- 3 files changed, 7 insertions(+), 11 deletions(-) diff --git a/go.mod b/go.mod index 82d9338..e04ffc2 100644 --- a/go.mod +++ b/go.mod @@ -2,4 +2,4 @@ module github.com/wago-org/workers go 1.24.0 -require github.com/wago-org/wago v0.0.0-20260812144524-1c58c9862d25 +require github.com/wago-org/wago v0.1.0-beta.8.0.20260916025321-6f31d3371e1d diff --git a/go.sum b/go.sum index 24b3655..60aaced 100644 --- a/go.sum +++ b/go.sum @@ -1,2 +1,2 @@ -github.com/wago-org/wago v0.0.0-20260812144524-1c58c9862d25 h1:gopNHvaUaDSzmW2Hfd32r8dOwwzYUHH3ph1L/IuhJUA= -github.com/wago-org/wago v0.0.0-20260812144524-1c58c9862d25/go.mod h1:6XmxI3S5qJ+YAzObyXjC6FmxHtbLhBBxrglzix42zl8= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916025321-6f31d3371e1d h1:JjS2jdRwwGLo4g7brBkYdnQMLijuDrO+3qXOJ/mB8fI= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916025321-6f31d3371e1d/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= diff --git a/workers_test.go b/workers_test.go index c8a70d7..53f6088 100644 --- a/workers_test.go +++ b/workers_test.go @@ -11,7 +11,7 @@ import ( "github.com/wago-org/wago" wagoplugin "github.com/wago-org/wago/plugin" - "github.com/wago-org/wago/tests/wasmtest" + "github.com/wago-org/wago/tests/support/wasmtest" ) type registerFunc func(*wago.Registrar) error @@ -91,17 +91,13 @@ func integrationProvider(p *integrationPlugin) wago.PluginProvider { if err != nil { return err } - module, err := imports.Module("test") - if err != nil { - return err - } - module.Func("spawn", func(caller wago.HostModule, _, _ []uint64) { + imports.HostFunc("test", "spawn", func(caller wago.Caller, _ wago.HostCall) { _ = p.service.With(func(service Service) error { p.id, _ = service.Spawn(caller, 0, WorkerOptions{QueueCapacity: 1, MaxPayloadBytes: 16, MaxQueueBytes: 16}) return nil }) }) - module.Func("next", func(caller wago.HostModule, _, _ []uint64) { + imports.HostFunc("test", "next", func(caller wago.Caller, _ wago.HostCall) { _ = p.service.With(func(service Service) error { return service.DispatchNext(context.Background(), caller) }) }) return reg.Lifecycle(wago.PluginLifecycle{ @@ -210,7 +206,7 @@ func TestPluginContractSpawnsCopiesMessageAndStops(t *testing.T) { case <-time.After(2 * time.Second): t.Fatal("exit timeout") } - if err := rt.Close(); err != nil { + if err := rt.CloseContext(context.Background()); err != nil { t.Fatal(err) } if err := p.service.With(func(Service) error { return nil }); !errors.Is(err, wago.ErrPermissionDenied) { From 7f55bca19f1399a30078fcb3086adc0d6b4c2388 Mon Sep 17 00:00:00 2001 From: JairusSW Date: Tue, 15 Sep 2026 23:41:25 -0400 Subject: [PATCH 2/6] chore: pin final Wago API revision --- go.mod | 2 +- go.sum | 2 ++ 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/go.mod b/go.mod index e04ffc2..45e5845 100644 --- a/go.mod +++ b/go.mod @@ -2,4 +2,4 @@ module github.com/wago-org/workers go 1.24.0 -require github.com/wago-org/wago v0.1.0-beta.8.0.20260916025321-6f31d3371e1d +require github.com/wago-org/wago v0.1.0-beta.8.0.20260916033857-43d658fadbdf diff --git a/go.sum b/go.sum index 60aaced..b53c33c 100644 --- a/go.sum +++ b/go.sum @@ -1,2 +1,4 @@ github.com/wago-org/wago v0.1.0-beta.8.0.20260916025321-6f31d3371e1d h1:JjS2jdRwwGLo4g7brBkYdnQMLijuDrO+3qXOJ/mB8fI= github.com/wago-org/wago v0.1.0-beta.8.0.20260916025321-6f31d3371e1d/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916033857-43d658fadbdf h1:xRaURj1fd21y7cU1hXQCF6H/y4LoE9+xv0wQpScSzuo= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916033857-43d658fadbdf/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= From c783be82d17bc6a21a5029645456fbb138a4a365 Mon Sep 17 00:00:00 2001 From: JairusSW Date: Wed, 16 Sep 2026 00:26:01 -0400 Subject: [PATCH 3/6] chore: pin final Wago API refactor head --- go.mod | 2 +- go.sum | 6 ++---- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/go.mod b/go.mod index 45e5845..b5fbf6d 100644 --- a/go.mod +++ b/go.mod @@ -2,4 +2,4 @@ module github.com/wago-org/workers go 1.24.0 -require github.com/wago-org/wago v0.1.0-beta.8.0.20260916033857-43d658fadbdf +require github.com/wago-org/wago v0.1.0-beta.8.0.20260916041951-35866fb07970 diff --git a/go.sum b/go.sum index b53c33c..b89f4d5 100644 --- a/go.sum +++ b/go.sum @@ -1,4 +1,2 @@ -github.com/wago-org/wago v0.1.0-beta.8.0.20260916025321-6f31d3371e1d h1:JjS2jdRwwGLo4g7brBkYdnQMLijuDrO+3qXOJ/mB8fI= -github.com/wago-org/wago v0.1.0-beta.8.0.20260916025321-6f31d3371e1d/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= -github.com/wago-org/wago v0.1.0-beta.8.0.20260916033857-43d658fadbdf h1:xRaURj1fd21y7cU1hXQCF6H/y4LoE9+xv0wQpScSzuo= -github.com/wago-org/wago v0.1.0-beta.8.0.20260916033857-43d658fadbdf/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916041951-35866fb07970 h1:m0CVK79+M5tL3oTDO0uY6XHi200jTmMAhwRlTs4DAuM= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916041951-35866fb07970/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= From d9e85d3a4fac241571fea76089b938c2a191018c Mon Sep 17 00:00:00 2001 From: JairusSW Date: Wed, 16 Sep 2026 00:44:04 -0400 Subject: [PATCH 4/6] chore: repin final Wago API refactor --- go.mod | 2 +- go.sum | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index b5fbf6d..91982ef 100644 --- a/go.mod +++ b/go.mod @@ -2,4 +2,4 @@ module github.com/wago-org/workers go 1.24.0 -require github.com/wago-org/wago v0.1.0-beta.8.0.20260916041951-35866fb07970 +require github.com/wago-org/wago v0.1.0-beta.8.0.20260916044221-1ed62e8dbb48 diff --git a/go.sum b/go.sum index b89f4d5..ebcb01c 100644 --- a/go.sum +++ b/go.sum @@ -1,2 +1,2 @@ -github.com/wago-org/wago v0.1.0-beta.8.0.20260916041951-35866fb07970 h1:m0CVK79+M5tL3oTDO0uY6XHi200jTmMAhwRlTs4DAuM= -github.com/wago-org/wago v0.1.0-beta.8.0.20260916041951-35866fb07970/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916044221-1ed62e8dbb48 h1:pHMgqdBUa/co7GWzZpe1PtkpQ1NSdiul1NPpGfx+fjY= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916044221-1ed62e8dbb48/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= From 4a873a230f5c20037c13b4fb47f4608e92597384 Mon Sep 17 00:00:00 2001 From: JairusSW Date: Wed, 16 Sep 2026 00:47:13 -0400 Subject: [PATCH 5/6] chore: pin final Wago API refactor head --- go.mod | 2 +- go.sum | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index 91982ef..d96f0c0 100644 --- a/go.mod +++ b/go.mod @@ -2,4 +2,4 @@ module github.com/wago-org/workers go 1.24.0 -require github.com/wago-org/wago v0.1.0-beta.8.0.20260916044221-1ed62e8dbb48 +require github.com/wago-org/wago v0.1.0-beta.8.0.20260916044641-e99947687116 diff --git a/go.sum b/go.sum index ebcb01c..4fbf2ee 100644 --- a/go.sum +++ b/go.sum @@ -1,2 +1,2 @@ -github.com/wago-org/wago v0.1.0-beta.8.0.20260916044221-1ed62e8dbb48 h1:pHMgqdBUa/co7GWzZpe1PtkpQ1NSdiul1NPpGfx+fjY= -github.com/wago-org/wago v0.1.0-beta.8.0.20260916044221-1ed62e8dbb48/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916044641-e99947687116 h1:0AgT2N3GaxZiyX8flgVdm7VtntDa0zrtDxuuinynKVQ= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916044641-e99947687116/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= From fa9222c78f9dbec64842597763ee307a9f8fa3ee Mon Sep 17 00:00:00 2001 From: JairusSW Date: Wed, 16 Sep 2026 01:09:09 -0400 Subject: [PATCH 6/6] chore: pin final Wago API refactor head --- go.mod | 2 +- go.sum | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/go.mod b/go.mod index d96f0c0..a75b6bd 100644 --- a/go.mod +++ b/go.mod @@ -2,4 +2,4 @@ module github.com/wago-org/workers go 1.24.0 -require github.com/wago-org/wago v0.1.0-beta.8.0.20260916044641-e99947687116 +require github.com/wago-org/wago v0.1.0-beta.8.0.20260916050830-c9ed2455acd9 diff --git a/go.sum b/go.sum index 4fbf2ee..f6a11d5 100644 --- a/go.sum +++ b/go.sum @@ -1,2 +1,2 @@ -github.com/wago-org/wago v0.1.0-beta.8.0.20260916044641-e99947687116 h1:0AgT2N3GaxZiyX8flgVdm7VtntDa0zrtDxuuinynKVQ= -github.com/wago-org/wago v0.1.0-beta.8.0.20260916044641-e99947687116/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916050830-c9ed2455acd9 h1:+/8b9bvAnyUZPG+YTvGpDwpAV+jpp6+bBBWOrr+8Xco= +github.com/wago-org/wago v0.1.0-beta.8.0.20260916050830-c9ed2455acd9/go.mod h1:q0pPiPF6W6GZpTXbWwy+GT+r19KHSzB/gRcPUVHyntI=