Merge pull request #333 from smartcontractkit/BCF-2701-mv-starknet-cmd

relayer/pkg/chainlink/cmd/chainlink-starknet/main.go

@@ -0,0 +1,81 @@
+package main
+
+import (
+	"context"
+	"fmt"
+	"strings"
+
+	"github.com/hashicorp/go-plugin"
+	"github.com/pelletier/go-toml/v2"
+
+	"github.com/smartcontractkit/chainlink-relay/pkg/loop"
+	pkgstarknet "github.com/smartcontractkit/chainlink-starknet/relayer/pkg/chainlink"
+	starkchain "github.com/smartcontractkit/chainlink-starknet/relayer/pkg/chainlink/chain"
+	stkcfg "github.com/smartcontractkit/chainlink-starknet/relayer/pkg/chainlink/config"
+)
+
+const (
+	loggerName = "PluginStarknet"
+)
+
+func main() {
+	s := loop.MustNewStartedServer(loggerName)
+	defer s.Stop()
+
+	p := &pluginRelayer{Plugin: loop.Plugin{Logger: s.Logger}}
+	defer s.Logger.ErrorIfFn(p.Close, "Failed to close")
+
+	s.MustRegister(p)
+
+	stopCh := make(chan struct{})
+	defer close(stopCh)
+
+	plugin.Serve(&plugin.ServeConfig{
+		HandshakeConfig: loop.PluginRelayerHandshakeConfig(),
+		Plugins: map[string]plugin.Plugin{
+			loop.PluginRelayerName: &loop.GRPCPluginRelayer{
+				PluginServer: p,
+				BrokerConfig: loop.BrokerConfig{
+					StopCh:   stopCh,
+					Logger:   s.Logger,
+					GRPCOpts: s.GRPCOpts,
+				},
+			},
+		},
+		GRPCServer: s.GRPCOpts.NewServer,
+	})
+}
+
+type pluginRelayer struct {
+	loop.Plugin
+}
+
+// NewRelayer implements the Loopp factory method used by the Loopp server to instantiate a starknet relayer
+// [github.com/smartcontractkit/chainlink-relay/pkg/loop.PluginRelayer]
+// loopKs must be an implementation that can construct a starknet keystore adapter
+// [github.com/smartcontractkit/chainlink-starknet/relayer/pkg/chainlink/txm.NewKeystoreAdapter]
+func (c *pluginRelayer) NewRelayer(ctx context.Context, config string, loopKs loop.Keystore) (loop.Relayer, error) {
+	d := toml.NewDecoder(strings.NewReader(config))
+	d.DisallowUnknownFields()
+	var cfg struct {
+		Starknet stkcfg.TOMLConfig
+	}
+	if err := d.Decode(&cfg); err != nil {
+		return nil, fmt.Errorf("failed to decode config toml: %w:\n\t%s", err, config)
+	}
+
+	opts := starkchain.ChainOpts{
+		Logger:   c.Logger,
+		KeyStore: loopKs,
+	}
+
+	chain, err := starkchain.NewChain(&cfg.Starknet, opts)
+	if err != nil {
+		return nil, fmt.Errorf("failed to create chain: %w", err)
+	}
+	ra := &loop.RelayerAdapter{Relayer: pkgstarknet.NewRelayer(c.Logger, chain), RelayerExt: chain}
+
+	c.SubService(ra)
+
+	return ra, nil
+}