63 lines
1.1 KiB
Go
63 lines
1.1 KiB
Go
package ipv4
|
|
|
|
import (
|
|
"crypto/tls"
|
|
"fmt"
|
|
"net"
|
|
"time"
|
|
|
|
omm "git.loafle.net/overflow/model/meta"
|
|
)
|
|
|
|
type serviceConnector interface {
|
|
MetaCryptoType() *omm.MetaCryptoType
|
|
Dial(ip string, port int) (net.Conn, error)
|
|
}
|
|
|
|
type normalServiceConn struct {
|
|
metaCryptoType *omm.MetaCryptoType
|
|
}
|
|
|
|
func (nsc *normalServiceConn) MetaCryptoType() *omm.MetaCryptoType {
|
|
return nsc.metaCryptoType
|
|
}
|
|
|
|
func (nsc *normalServiceConn) Dial(ip string, port int) (net.Conn, error) {
|
|
addr := fmt.Sprintf("%s:%d", ip, port)
|
|
conn, err := net.DialTimeout("tcp", addr, time.Duration(3)*time.Second)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return conn, err
|
|
}
|
|
|
|
type tlsServiceConn struct {
|
|
metaCryptoType *omm.MetaCryptoType
|
|
}
|
|
|
|
func (tsc *tlsServiceConn) MetaCryptoType() *omm.MetaCryptoType {
|
|
return tsc.metaCryptoType
|
|
}
|
|
|
|
func (tsc *tlsServiceConn) Dial(ip string, port int) (net.Conn, error) {
|
|
addr := fmt.Sprintf("%s:%d", ip, port)
|
|
dialer := &net.Dialer{
|
|
Timeout: 3 * time.Second,
|
|
}
|
|
conn, err := tls.DialWithDialer(
|
|
dialer,
|
|
"tcp",
|
|
addr,
|
|
&tls.Config{
|
|
InsecureSkipVerify: true,
|
|
ServerName: ip,
|
|
},
|
|
)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return conn, err
|
|
}
|