lore/wasm-nats-producer-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: lore:cdc80d0b5397b5911b6a2d26d0b0440c1d2beeb5
Branches Tags
lore:main
..
compare: lore:8ba95bfe0c42bcbd8c31a0d6833fc3ee987ff044
Branches Tags
lore:main

No commits in common. "cdc80d0b5397b5911b6a2d26d0b0440c1d2beeb5" and "8ba95bfe0c42bcbd8c31a0d6833fc3ee987ff044" have entirely different histories.
cdc80d0b53 ... 8ba95bfe0c

4 changed files with 29 additions and 39 deletions
Show Stats Expand all files Collapse all files

2
Dockerfile
View File

@ -49,4 +49,4 @@ WORKDIR /app
# Install go dependencies, build the wasm module, push it to the registry # Install go dependencies, build the wasm module, push it to the registry
#CMD ["sh", "-c", "go mod download && go mod verify && go mod tidy && wash build && wash push $REGISTRY build/*_s.wasm"] #CMD ["sh", "-c", "go mod download && go mod verify && go mod tidy && wash build && wash push $REGISTRY build/*_s.wasm"]
CMD ["sh", "-c", "go env -w GOFLAGS=-buildvcs=false && go mod download && go mod verify && wash build && wash push $REGISTRY build/*.wasm"] CMD ["sh", "-c", "go env -w GOFLAGS=-buildvcs=false && go mod download && go mod verify && wash build && wash push $REGISTRY build/*_s.wasm"]

1
main.go
View File

@ -2,6 +2,7 @@
package main package main
import ( import (
"gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasmcloud/messaging/handler"
) )
func init() { func init() {

15
messaging.go
View File

@ -6,7 +6,6 @@ import (
"gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasmcloud/messaging/types" "gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasmcloud/messaging/types"
logger "gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasi/logging/logging" logger "gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasi/logging/logging"
//config "gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasi/config/runtime" //config "gitea.rebus.ninja/lore/wasm-nats-producer-client/gen/wasi/config/runtime"
"time"
) )
type messagingConsumerAdapter struct { type messagingConsumerAdapter struct {
@ -23,13 +22,12 @@ func loop() cm.Result[string, struct{}, string] {
// TODO implement the logic to get the destination topic from the config // TODO implement the logic to get the destination topic from the config
// dest_topic := config.GetAll() // dest_topic := config.GetAll()
dest_topic := "test.reply" dest_topic := "test.reply"
counter := 0
// TASK // TASK
for { for true {
// generate random message // generate random message
data := []byte("Hello, World! " + string(counter)) data := []byte("Hello, World!")
// Send reply // Send reply
reply := types.BrokerMessage{ reply := types.BrokerMessage{
@ -43,15 +41,6 @@ func loop() cm.Result[string, struct{}, string] {
return res return res
} }
counter++
if counter == 1000 {
break
}
// sleep for 1 second
time.Sleep(1 * time.Second)
} }
return cm.OK[cm.Result[string, struct{}, string]](struct{}{}) return cm.OK[cm.Result[string, struct{}, string]](struct{}{})