sniffing protocol for port forwarding

config/config.go

@@ -261,6 +261,7 @@ type ForwardNodeConfig struct {
 	Name     string   `yaml:",omitempty" json:"name,omitempty"`
 	Addr     string   `yaml:",omitempty" json:"addr,omitempty"`
 	Host     string   `yaml:",omitempty" json:"host,omitempty"`
+	Protocol string   `yaml:",omitempty" json:"protocol,omitempty"`
 	Bypass   string   `yaml:",omitempty" json:"bypass,omitempty"`
 	Bypasses []string `yaml:",omitempty" json:"bypasses,omitempty"`
 }
@@ -335,6 +336,7 @@ type NodeConfig struct {
 	Name      string           `json:"name"`
 	Addr      string           `yaml:",omitempty" json:"addr,omitempty"`
 	Host      string           `yaml:",omitempty" json:"host,omitempty"`
+	Protocol  string           `yaml:",omitempty" json:"protocol,omitempty"`
 	Interface string           `yaml:",omitempty" json:"interface,omitempty"`
 	SockOpts  *SockOptsConfig  `yaml:"sockopts,omitempty" json:"sockopts,omitempty"`
 	Bypass    string           `yaml:",omitempty" json:"bypass,omitempty"`

config/parsing/chain.go

@@ -216,6 +216,7 @@ func ParseHop(cfg *config.HopConfig) (chain.Hop, error) {
 			chain.HostMapperNodeOption(registry.HostsRegistry().Get(v.Hosts)),
 			chain.MetadataNodeOption(nm),
 			chain.HostNodeOption(host),
+			chain.ProtocolNodeOption(v.Protocol),
 		)
 		nodes = append(nodes, node)
 	}

config/parsing/service.go

@@ -250,6 +250,7 @@ func parseForwarder(cfg *config.ForwarderConfig) (chain.Hop, error) {
 						Name:     node.Name,
 						Addr:     node.Addr,
 						Host:     node.Host,
+						Protocol: node.Protocol,
 						Bypass:   node.Bypass,
 						Bypasses: node.Bypasses,
 					},