2018-08-12 10:24:23 +00:00
|
|
|
package ping
|
|
|
|
|
|
|
|
import (
|
|
|
|
"crypto/tls"
|
|
|
|
"fmt"
|
|
|
|
"net"
|
|
|
|
"strings"
|
|
|
|
"time"
|
|
|
|
|
2018-08-15 07:46:52 +00:00
|
|
|
csm "git.loafle.net/overflow/service_matcher-go"
|
2018-08-12 10:24:23 +00:00
|
|
|
opm "git.loafle.net/overflow_scanner/probe/matcher"
|
|
|
|
)
|
|
|
|
|
|
|
|
type Res struct {
|
|
|
|
Matcher csm.Matcher
|
|
|
|
Error error
|
|
|
|
}
|
|
|
|
|
2018-08-15 06:18:40 +00:00
|
|
|
func Ping(ch chan *Res, ip string, port int, tls bool, portType, key string) {
|
2018-08-12 10:24:23 +00:00
|
|
|
go func() {
|
|
|
|
conn, err := getConnection(ip, port, portType, tls)
|
|
|
|
if err != nil {
|
2018-08-15 06:18:40 +00:00
|
|
|
ch <- &Res{nil, err}
|
2018-08-12 10:24:23 +00:00
|
|
|
close(ch)
|
|
|
|
}
|
|
|
|
defer conn.Close()
|
|
|
|
|
|
|
|
m := opm.GetMatcherByKey(key)
|
|
|
|
if m.IsPrePacket() {
|
|
|
|
processPrepacket(ch, conn, m)
|
|
|
|
}
|
|
|
|
processPostpacket(ch, conn, m)
|
|
|
|
}()
|
|
|
|
}
|
|
|
|
|
2018-08-15 06:18:40 +00:00
|
|
|
func processPrepacket(ch chan *Res, conn net.Conn, m csm.Matcher) {
|
2018-08-12 10:24:23 +00:00
|
|
|
for i := 0; i < m.PacketCount(); i++ {
|
|
|
|
bytes := make([]byte, 1024)
|
|
|
|
n, _ := conn.Read(bytes)
|
|
|
|
p := csm.NewPacket(bytes, n)
|
|
|
|
|
2018-09-03 07:01:35 +00:00
|
|
|
_, err := conn.Write(m.Packet(i).Bytes())
|
2018-08-12 10:24:23 +00:00
|
|
|
if err != nil {
|
2018-08-15 06:18:40 +00:00
|
|
|
ch <- &Res{nil, err}
|
2018-08-12 10:24:23 +00:00
|
|
|
close(ch)
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := m.Match(nil, i, p); err != nil {
|
2018-08-15 06:18:40 +00:00
|
|
|
ch <- &Res{nil, err}
|
2018-08-12 10:24:23 +00:00
|
|
|
close(ch)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2018-08-15 06:18:40 +00:00
|
|
|
ch <- &Res{m, nil}
|
2018-08-12 10:24:23 +00:00
|
|
|
close(ch)
|
|
|
|
}
|
|
|
|
|
2018-08-15 06:18:40 +00:00
|
|
|
func processPostpacket(ch chan *Res, conn net.Conn, m csm.Matcher) {
|
2018-08-12 10:24:23 +00:00
|
|
|
for i := 0; i < m.PacketCount(); i++ {
|
2018-09-03 07:01:35 +00:00
|
|
|
_, err := conn.Write(m.Packet(i).Bytes())
|
2018-08-12 10:24:23 +00:00
|
|
|
if err != nil {
|
2018-08-15 06:18:40 +00:00
|
|
|
ch <- &Res{nil, err}
|
2018-08-12 10:24:23 +00:00
|
|
|
close(ch)
|
|
|
|
}
|
|
|
|
|
|
|
|
bytes := make([]byte, 1024)
|
|
|
|
n, _ := conn.Read(bytes)
|
|
|
|
p := csm.NewPacket(bytes, n)
|
|
|
|
|
|
|
|
if err := m.Match(nil, i, p); err != nil {
|
2018-08-15 06:18:40 +00:00
|
|
|
ch <- &Res{nil, err}
|
2018-08-12 10:24:23 +00:00
|
|
|
close(ch)
|
|
|
|
}
|
|
|
|
}
|
2018-08-15 06:18:40 +00:00
|
|
|
ch <- &Res{m, nil}
|
2018-08-12 10:24:23 +00:00
|
|
|
close(ch)
|
|
|
|
}
|
|
|
|
|
|
|
|
func getConnection(ip string, port int, portType string, isTLS bool) (net.Conn, error) {
|
|
|
|
addr := fmt.Sprintf("%s:%d", ip, port)
|
|
|
|
portType = strings.ToLower(portType)
|
|
|
|
|
|
|
|
if isTLS {
|
|
|
|
dialer := &net.Dialer{
|
|
|
|
Timeout: 5 * time.Second,
|
|
|
|
}
|
|
|
|
|
|
|
|
return tls.DialWithDialer(
|
|
|
|
dialer,
|
|
|
|
portType,
|
|
|
|
addr,
|
|
|
|
&tls.Config{
|
|
|
|
InsecureSkipVerify: true,
|
|
|
|
ServerName: ip,
|
|
|
|
},
|
|
|
|
)
|
|
|
|
}
|
|
|
|
return net.Dial(portType, addr)
|
|
|
|
}
|