2019-05-11 09:53:32 -05:00
|
|
|
package main
|
|
|
|
|
|
|
|
import "fmt"
|
|
|
|
import "log"
|
|
|
|
import "net"
|
|
|
|
import "os"
|
|
|
|
import "io"
|
|
|
|
import "bytes"
|
2019-05-11 15:20:51 -05:00
|
|
|
import "strconv"
|
2019-05-11 09:53:32 -05:00
|
|
|
|
|
|
|
import "github.com/golang/protobuf/proto"
|
2019-05-11 14:45:17 -05:00
|
|
|
import pb "git.wit.com/wit/witProtobuf"
|
2019-05-11 09:53:32 -05:00
|
|
|
|
2019-05-12 20:55:15 -05:00
|
|
|
import "github.com/andlabs/ui"
|
|
|
|
import _ "github.com/andlabs/ui/winmanifest"
|
|
|
|
|
2019-05-12 17:32:38 -05:00
|
|
|
import "git.wit.com/wit/gui"
|
|
|
|
|
2019-05-11 09:53:32 -05:00
|
|
|
var mychannel chan *pb.Event
|
|
|
|
|
|
|
|
func initChannel() {
|
|
|
|
mychannel = make(chan *pb.Event)
|
|
|
|
}
|
|
|
|
|
|
|
|
// func processEvents(mychannel chan *pb.Event) {
|
|
|
|
func processEvents() {
|
|
|
|
for {
|
|
|
|
message := <-mychannel
|
2019-05-11 14:45:17 -05:00
|
|
|
log.Println("processEvents() on channel recieved a message = ", message)
|
2019-05-12 20:36:31 -05:00
|
|
|
if (message.Type == pb.Event_DEMO) {
|
|
|
|
log.Println("processEvents() do Event DEMO")
|
2019-05-12 20:55:15 -05:00
|
|
|
go ui.Main(gui.SetupDemoUI)
|
2019-05-12 20:49:59 -05:00
|
|
|
} else {
|
|
|
|
mh := addVmsTab(30)
|
|
|
|
ReadReceivedData(message, mh)
|
2019-05-12 20:36:31 -05:00
|
|
|
}
|
2019-05-11 09:53:32 -05:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2019-05-12 17:32:38 -05:00
|
|
|
func ReadReceivedData(data *pb.Event, mh *gui.TableData) {
|
2019-05-11 09:53:32 -05:00
|
|
|
msgItems := data.GetResults()
|
2019-05-11 14:45:17 -05:00
|
|
|
log.Println("ReadReceivedData() Event msgItems=", msgItems)
|
2019-05-11 09:53:32 -05:00
|
|
|
for _, item := range msgItems {
|
2019-05-11 14:45:17 -05:00
|
|
|
log.Println(item)
|
2019-05-12 14:55:11 -05:00
|
|
|
}
|
|
|
|
|
|
|
|
nets := data.GetNetworks()
|
|
|
|
log.Println("ReadReceivedData() Event networks=", nets)
|
|
|
|
for _, item := range nets {
|
|
|
|
log.Println(item)
|
|
|
|
}
|
|
|
|
|
|
|
|
vms := data.GetVms()
|
|
|
|
log.Println("ReadReceivedData() Event vms=", vms)
|
2019-05-12 23:00:55 -05:00
|
|
|
for row, item := range vms {
|
2019-05-13 00:05:56 -05:00
|
|
|
if (row % 2) == 1 {
|
|
|
|
mh.Rows[row].Human[0].Color = ui.TableColor{0, 0, 0, .04}
|
|
|
|
} else {
|
|
|
|
mh.Rows[row].Human[0].Color = ui.TableColor{0, 0, 0, 0}
|
|
|
|
}
|
|
|
|
mh.Rows[row].Human[1].Text = ui.TableString(item.Name)
|
|
|
|
mh.Rows[row].Human[1].Color = ui.TableColor{0, 0, 0, 0}
|
|
|
|
mh.Rows[row].Human[2].Text = ui.TableString(item.Hostname)
|
|
|
|
mh.Rows[row].Human[2].Color = ui.TableColor{0, 0, 0, 0}
|
|
|
|
mh.Rows[row].Human[3].Text = ui.TableString(fmt.Sprintf("%d",item.Cpus))
|
|
|
|
mh.Rows[row].Human[3].Color = ui.TableColor{0, 0, 0, 0}
|
|
|
|
mh.Rows[row].Human[4].Text = ui.TableString(fmt.Sprintf("%d",item.Memory))
|
|
|
|
mh.Rows[row].Human[4].Color = ui.TableColor{0, 0, 0, 0}
|
|
|
|
mh.Rows[row].Human[5].Text = ui.TableString(fmt.Sprintf("%d",item.Disk))
|
|
|
|
mh.Rows[row].Human[5].Color = ui.TableColor{0, 0, 0, 0}
|
|
|
|
mh.Rows[row].Human[6].Text = ui.TableString(fmt.Sprintf("Details %s",item.Name))
|
2019-05-12 23:00:55 -05:00
|
|
|
|
2019-05-12 23:20:58 -05:00
|
|
|
log.Println("\titem=", item)
|
2019-05-12 23:00:55 -05:00
|
|
|
log.Println("\titem.Name=", item.Name)
|
|
|
|
log.Println("\tRows[row]=", mh.Rows[row])
|
|
|
|
log.Println("\tRows[row]=", row)
|
|
|
|
log.Println("\tRows[row].Name=", mh.Rows[row].Name)
|
2019-05-12 14:55:11 -05:00
|
|
|
log.Println(item)
|
2019-05-12 17:32:38 -05:00
|
|
|
row += 1
|
|
|
|
}
|
|
|
|
|
2019-05-12 23:00:55 -05:00
|
|
|
/*
|
2019-05-12 17:32:38 -05:00
|
|
|
log.Println("ReadReceivedData() mh rows")
|
|
|
|
for row := 0; row < mh.RowCount; row++ {
|
|
|
|
log.Println("\trow=", row)
|
2019-05-12 23:00:55 -05:00
|
|
|
log.Println("\tRows[row]=", mh.Rows[row])
|
2019-05-11 09:53:32 -05:00
|
|
|
}
|
2019-05-12 23:00:55 -05:00
|
|
|
*/
|
2019-05-11 09:53:32 -05:00
|
|
|
}
|
|
|
|
|
2019-05-12 20:49:59 -05:00
|
|
|
func addSampleEvent() {
|
|
|
|
msg := pb.CreateSampleEvent()
|
|
|
|
msg.Name = "generated in addSampleEvent()"
|
|
|
|
|
|
|
|
addEvent(msg)
|
2019-05-11 09:53:32 -05:00
|
|
|
}
|
|
|
|
|
2019-05-12 14:32:29 -05:00
|
|
|
// Marshal & Unmarshal just to see if it ever fails
|
|
|
|
func addEvent(msg *pb.Event) {
|
2019-05-11 09:53:32 -05:00
|
|
|
data, err := proto.Marshal(msg)
|
|
|
|
if (err != nil) {
|
2019-05-11 15:20:51 -05:00
|
|
|
log.Printf("addEvent() something fucked up happened in Marshal")
|
2019-05-11 09:53:32 -05:00
|
|
|
}
|
2019-05-11 15:20:51 -05:00
|
|
|
|
2019-05-11 09:53:32 -05:00
|
|
|
pdata := new(pb.Event)
|
|
|
|
err = proto.Unmarshal(data, pdata)
|
2019-05-11 15:20:51 -05:00
|
|
|
if (err != nil) {
|
|
|
|
log.Printf("addEvent() something fucked up happened in Unmarshal")
|
|
|
|
}
|
|
|
|
|
2019-05-11 09:53:32 -05:00
|
|
|
mychannel <- pdata
|
2019-05-11 12:55:37 -05:00
|
|
|
}
|
|
|
|
|
2019-05-11 15:20:51 -05:00
|
|
|
func sendDataToDest() {
|
|
|
|
msg := pb.CreateSampleEvent()
|
|
|
|
msg.Name = "from dnssecsockettest()"
|
|
|
|
|
|
|
|
data, err := proto.Marshal(msg)
|
|
|
|
if (err != nil) {
|
|
|
|
log.Printf("something fucked up happened")
|
|
|
|
}
|
|
|
|
|
|
|
|
conn, err := net.Dial("tcp", "localhost:8080")
|
|
|
|
if err != nil {
|
|
|
|
log.Println("Fatal error: %s", err.Error())
|
|
|
|
return
|
|
|
|
}
|
|
|
|
n, err := conn.Write(data)
|
|
|
|
if err != nil {
|
|
|
|
// fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
|
|
|
|
log.Println("Fatal error: %s", err.Error())
|
|
|
|
return
|
|
|
|
}
|
|
|
|
|
|
|
|
pb.DumpEventData(msg)
|
|
|
|
log.Println("Sent " + strconv.Itoa(n) + " bytes")
|
|
|
|
// time.Sleep(3 * 1000 * 1000 * 1000)
|
|
|
|
conn.Close()
|
|
|
|
}
|
2019-05-12 20:49:59 -05:00
|
|
|
|
|
|
|
func handleProtoClient(conn net.Conn) {
|
|
|
|
fmt.Println("Connected!")
|
|
|
|
defer conn.Close()
|
|
|
|
var buf bytes.Buffer
|
|
|
|
_, err := io.Copy(&buf, conn)
|
|
|
|
if err != nil {
|
|
|
|
fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
|
|
|
|
return
|
|
|
|
}
|
|
|
|
pdata := pb.CreateSampleEvent()
|
|
|
|
err = proto.Unmarshal(buf.Bytes(), pdata)
|
|
|
|
if err != nil {
|
|
|
|
fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
|
|
|
|
return
|
|
|
|
}
|
|
|
|
mychannel <- pdata
|
|
|
|
}
|