default_server_connector.go

package cproxy

type DefaultServerConnector struct {
	dialer      Dialer
	initializer Initializer
}

func NewServerConnector(dialer Dialer, initializer Initializer) *DefaultServerConnector {
	return &DefaultServerConnector{dialer: dialer, initializer: initializer}
}

func (it *DefaultServerConnector) Connect(client Socket, serverAddress string) Proxy {
	server := it.dialer.Dial(serverAddress)
	if server == nil {
		return nil
	}

	if !it.initializer.Initialize(client, server) {
		server.Close()
		return nil
	}

	return NewProxy(client, server)
}