88 lines
1.9 KiB
Go
88 lines
1.9 KiB
Go
package ssh
|
|
|
|
import (
|
|
ocmsc "git.loafle.net/overflow/commons-go/model/sensorconfig"
|
|
"git.loafle.net/overflow/container_network/crawler/ssh/client"
|
|
crawler "git.loafle.net/overflow/crawler-go"
|
|
)
|
|
|
|
type SSHCrawler struct {
|
|
crawler.Crawler
|
|
}
|
|
|
|
func (c *SSHCrawler) Key() string {
|
|
return "SSH"
|
|
}
|
|
|
|
func (c *SSHCrawler) String() string {
|
|
return "SSH Crawler"
|
|
}
|
|
|
|
func (c *SSHCrawler) Auth(auth map[string]interface{}) error {
|
|
return nil
|
|
}
|
|
|
|
func (c *SSHCrawler) Get(config *ocmsc.SensorConfig) (map[string]string, error) {
|
|
_, err := client.New(config.Connection)
|
|
if nil != err {
|
|
return nil, err
|
|
}
|
|
|
|
// itemCount := len(config.Items.MetaCollectionItems)
|
|
results := make(map[string]string, 0)
|
|
// boundary := uuid.NewV4().String()
|
|
// commands := ""
|
|
|
|
// for i := 0; i < itemCount; i++ {
|
|
// switch i {
|
|
// case 0:
|
|
// commands = config.Items[i].QueryInfo.Query
|
|
// default:
|
|
// commands = fmt.Sprintf("%s ; echo \"--%s\" ; %s ", commands, boundary, config.Items[i].QueryInfo.Query)
|
|
// }
|
|
// }
|
|
// commands = fmt.Sprintf("%s ; echo \"--%s--\" ", commands, boundary)
|
|
|
|
// buf, err := sshClient.RunCommand(commands)
|
|
// if nil != err {
|
|
// return nil, err
|
|
// }
|
|
// r := bytes.NewReader(buf)
|
|
// scanner := bufio.NewScanner(r)
|
|
|
|
// pScanner := parser.NewParserScanner(scanner, boundary)
|
|
|
|
// for i := 0; i < itemCount; i++ {
|
|
// item := config.Items[i]
|
|
// mode := item.QueryInfo.Extend["mode"].(string)
|
|
// p := parser.GetParser(mode)
|
|
// if nil == p {
|
|
// return nil, fmt.Errorf("Container: Parser[%s] is not exist", mode)
|
|
// }
|
|
|
|
// rm, err := p.Parse(pScanner)
|
|
// if nil != err {
|
|
// return nil, err
|
|
// }
|
|
|
|
// if nil != rm {
|
|
// mm := ocmsc.KeysToMap(item.Keys)
|
|
// for key, value := range mm {
|
|
// results[value] = rm[key]
|
|
// }
|
|
// }
|
|
|
|
// if !pScanner.Clean() {
|
|
// break
|
|
// }
|
|
// }
|
|
|
|
return results, nil
|
|
}
|
|
|
|
func NewCrawler() crawler.Crawler {
|
|
c := &SSHCrawler{}
|
|
|
|
return c
|
|
}
|