add myceliumrx module in zoslight

cmds/modules/myceliumrx/main.go

@@ -0,0 +1,81 @@
+package myceliumrx
+
+import (
+	"crypto/ed25519"
+	"fmt"
+
+	"github.com/pkg/errors"
+	substrate "github.com/threefoldtech/tfchain/clients/tfchain-client-go"
+	"github.com/threefoldtech/tfgrid-sdk-go/messenger"
+	"github.com/threefoldtech/zosbase/pkg/api"
+	"github.com/threefoldtech/zosbase/pkg/api/jsonrpc"
+	"github.com/threefoldtech/zosbase/pkg/environment"
+	"github.com/threefoldtech/zosbase/pkg/stubs"
+	"github.com/urfave/cli/v2"
+
+	"github.com/threefoldtech/zbus"
+)
+
+// Module is entry point for module
+var Module cli.Command = cli.Command{
+	Name:  "myceliumrx",
+	Usage: "handles mycelium messages",
+	Flags: []cli.Flag{
+		&cli.StringFlag{
+			Name:  "broker",
+			Usage: "connection string to the message `BROKER`",
+			Value: "unix:///var/run/redis.sock",
+		},
+	},
+	Action: action,
+}
+
+func action(cli *cli.Context) error {
+	var broker string = cli.String("broker")
+	client, err := zbus.NewRedisClient(broker)
+	if err != nil {
+		return errors.Wrap(err, "failed to connect to zbus broker")
+	}
+
+	a, err := api.NewAPI(client, broker, "light")
+	if err != nil {
+		return errors.Wrap(err, "failed to create api")
+	}
+
+	idStub := stubs.NewIdentityManagerStub(client)
+	sk := ed25519.PrivateKey(idStub.PrivateKey(cli.Context))
+	id, err := substrate.NewIdentityFromEd25519Key(sk)
+	if err != nil {
+		return err
+	}
+
+	man, err := environment.GetSubstrate()
+	if err != nil {
+		return fmt.Errorf("failed to get substrate manager: %w", err)
+	}
+	ctx := cli.Context
+
+	msgr, err := messenger.NewMessenger(
+		messenger.WithEnableTwinIdentity(false),
+		messenger.WithSubstrateManager(man),
+		messenger.WithIdentity(id),
+	)
+
+	if err != nil {
+		return fmt.Errorf("failed to create substrate manager: %w", err)
+	}
+	defer msgr.Close()
+
+	server := messenger.NewJSONRPCServer(msgr)
+
+	hdrs := jsonrpc.NewRpcHandler(a)
+	jsonrpc.RegisterHandlers(server, hdrs)
+
+	if err := server.Start(ctx); err != nil {
+		return fmt.Errorf("failed to start server: %w", err)
+	}
+
+	// block forever
+	<-ctx.Done()
+	return nil
+}

cmds/zos/main.go

@@ -11,6 +11,7 @@ import (
 	"github.com/threefoldtech/zos4/cmds/modules/contd"
 	"github.com/threefoldtech/zos4/cmds/modules/flistd"
 	"github.com/threefoldtech/zos4/cmds/modules/gateway"
+	"github.com/threefoldtech/zos4/cmds/modules/myceliumrx"
 	"github.com/threefoldtech/zos4/cmds/modules/netlightd"
 	"github.com/threefoldtech/zos4/cmds/modules/noded"
 	"github.com/threefoldtech/zos4/cmds/modules/powerd"
@@ -56,6 +57,7 @@ func main() {
 			&gateway.Module,
 			&powerd.Module,
 			&apigateway.Module,
+			&myceliumrx.Module,
 		},
 		Before: func(c *cli.Context) error {
 			if c.Bool("debug") {

etc/zinit/myceliumrx.yaml

@@ -0,0 +1,3 @@
+exec: myceliumrx --broker unix:///var/run/redis.sock
+after:
+  - networkd

qemu/overlay.normal/bin/myceliumrx

@@ -0,0 +1 @@
+../../../bin/zos

qemu/overlay.normal/etc/zinit/myceliumrx.yaml

@@ -0,0 +1 @@
+../../../../etc/zinit/myceliumrx.yaml