|
|
|
@ -23,6 +23,7 @@ import (
|
|
|
|
|
"net/http/httputil" |
|
|
|
|
"strings" |
|
|
|
|
|
|
|
|
|
"github.com/fatedier/frp/pkg/transport" |
|
|
|
|
frpNet "github.com/fatedier/frp/pkg/util/net" |
|
|
|
|
) |
|
|
|
|
|
|
|
|
@ -58,12 +59,6 @@ func NewHTTPS2HTTPSPlugin(params map[string]string) (Plugin, error) {
|
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
if crtPath == "" { |
|
|
|
|
return nil, fmt.Errorf("plugin_crt_path is required") |
|
|
|
|
} |
|
|
|
|
if keyPath == "" { |
|
|
|
|
return nil, fmt.Errorf("plugin_key_path is required") |
|
|
|
|
} |
|
|
|
|
if localAddr == "" { |
|
|
|
|
return nil, fmt.Errorf("plugin_local_addr is required") |
|
|
|
|
} |
|
|
|
@ -101,7 +96,16 @@ func NewHTTPS2HTTPSPlugin(params map[string]string) (Plugin, error) {
|
|
|
|
|
Handler: rp, |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
tlsConfig, err := p.genTLSConfig() |
|
|
|
|
var ( |
|
|
|
|
tlsConfig *tls.Config |
|
|
|
|
err error |
|
|
|
|
) |
|
|
|
|
if crtPath != "" || keyPath != "" { |
|
|
|
|
tlsConfig, err = p.genTLSConfig() |
|
|
|
|
} else { |
|
|
|
|
tlsConfig, err = transport.NewServerTLSConfig("", "", "") |
|
|
|
|
tlsConfig.InsecureSkipVerify = true |
|
|
|
|
} |
|
|
|
|
if err != nil { |
|
|
|
|
return nil, fmt.Errorf("gen TLS config error: %v", err) |
|
|
|
|
} |
|
|
|
@ -127,7 +131,7 @@ func (p *HTTPS2HTTPSPlugin) Handle(conn io.ReadWriteCloser, realConn net.Conn, e
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (p *HTTPS2HTTPSPlugin) Name() string { |
|
|
|
|
return PluginHTTPS2HTTP |
|
|
|
|
return PluginHTTPS2HTTPS |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
func (p *HTTPS2HTTPSPlugin) Close() error { |
|
|
|
|