From 998d45a22dedad535ee95ac18f92ad1925429e8d Mon Sep 17 00:00:00 2001
From: Jordan Krage <jmank88@gmail.com>
Date: Mon, 23 Oct 2023 20:26:05 -0500
Subject: [PATCH] relayer/pkg/chainlink: move cmd/chainlink-starknet from
 chainlink repo

---
 .../chainlink/cmd/chainlink-starknet/main.go  | 81 +++++++++++++++++++
 1 file changed, 81 insertions(+)
 create mode 100644 relayer/pkg/chainlink/cmd/chainlink-starknet/main.go

diff --git a/relayer/pkg/chainlink/cmd/chainlink-starknet/main.go b/relayer/pkg/chainlink/cmd/chainlink-starknet/main.go
new file mode 100644
index 000000000..ea7385850
--- /dev/null
+++ b/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
+}