make a button to send a protobuf to a local socket
Signed-off-by: Jeff Carr <jcarr@wit.com>
This commit is contained in:
parent
b49aed2de0
commit
2330e0a2b6
40
channel.go
40
channel.go
|
@ -6,6 +6,7 @@ import "net"
|
||||||
import "os"
|
import "os"
|
||||||
import "io"
|
import "io"
|
||||||
import "bytes"
|
import "bytes"
|
||||||
|
import "strconv"
|
||||||
|
|
||||||
import "github.com/golang/protobuf/proto"
|
import "github.com/golang/protobuf/proto"
|
||||||
import pb "git.wit.com/wit/witProtobuf"
|
import pb "git.wit.com/wit/witProtobuf"
|
||||||
|
@ -55,18 +56,18 @@ func addEvent() {
|
||||||
msg := pb.CreateSampleEvent()
|
msg := pb.CreateSampleEvent()
|
||||||
msg.Name = "generated in addEvent()"
|
msg.Name = "generated in addEvent()"
|
||||||
|
|
||||||
// var mybuf bytes.Buffer
|
|
||||||
|
|
||||||
data, err := proto.Marshal(msg)
|
data, err := proto.Marshal(msg)
|
||||||
if (err != nil) {
|
if (err != nil) {
|
||||||
log.Printf("something fucked up happened")
|
log.Printf("addEvent() something fucked up happened in Marshal")
|
||||||
}
|
}
|
||||||
|
|
||||||
pdata := new(pb.Event)
|
pdata := new(pb.Event)
|
||||||
// err = proto.Unmarshal(data.Bytes(), pdata)
|
|
||||||
err = proto.Unmarshal(data, pdata)
|
err = proto.Unmarshal(data, pdata)
|
||||||
|
if (err != nil) {
|
||||||
|
log.Printf("addEvent() something fucked up happened in Unmarshal")
|
||||||
|
}
|
||||||
|
|
||||||
mychannel <- pdata
|
mychannel <- pdata
|
||||||
// sendDataToDest(data)
|
|
||||||
// writeBytesToSocket(data)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func sendEventToWIT() {
|
func sendEventToWIT() {
|
||||||
|
@ -79,3 +80,30 @@ func sendEventToWIT() {
|
||||||
}
|
}
|
||||||
writeBytesToSocket(mybuf)
|
writeBytesToSocket(mybuf)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
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()
|
||||||
|
}
|
||||||
|
|
|
@ -53,6 +53,7 @@ func makeCloudInfoBox() ui.Control {
|
||||||
})
|
})
|
||||||
vbox.Append(add2button, false)
|
vbox.Append(add2button, false)
|
||||||
// ATTEMPT TO ADD THE TABLE HERE END
|
// ATTEMPT TO ADD THE TABLE HERE END
|
||||||
|
|
||||||
hbox.Append(ui.NewVerticalSeparator(), false)
|
hbox.Append(ui.NewVerticalSeparator(), false)
|
||||||
|
|
||||||
// Send a test protobuf Event to localhost
|
// Send a test protobuf Event to localhost
|
||||||
|
@ -71,6 +72,14 @@ func makeCloudInfoBox() ui.Control {
|
||||||
})
|
})
|
||||||
vbox.Append(add4button, false)
|
vbox.Append(add4button, false)
|
||||||
|
|
||||||
|
// Send a protobuf Event over the WIT socket
|
||||||
|
add5button := ui.NewButton("Send protobuf to localhost")
|
||||||
|
add5button.OnClicked(func(*ui.Button) {
|
||||||
|
log.Println("sent a Marshal'd protobuf to a localhost socket")
|
||||||
|
sendDataToDest()
|
||||||
|
})
|
||||||
|
vbox.Append(add5button, false)
|
||||||
|
|
||||||
hbox.Append(ui.NewVerticalSeparator(), false)
|
hbox.Append(ui.NewVerticalSeparator(), false)
|
||||||
|
|
||||||
vbox = ui.NewVerticalBox()
|
vbox = ui.NewVerticalBox()
|
||||||
|
|
Loading…
Reference in New Issue