diff --git a/communicate_test.go b/communicate_test.go index 4c90e13..9bb6b65 100644 --- a/communicate_test.go +++ b/communicate_test.go @@ -50,9 +50,9 @@ func TestSend(t *testing.T) { })) defer ts.Close() for i := 0; i < 10; i++ { - e := events.NewEvent(events.CENTRAL_EVENT, events.CollectorInstallEvent{Message: "Test"}) + e := events.NewEvent(events.CENTRAL_EVENT, events.CollectorInstallEvent{Version: "Test"}) Send(e) - t.Log(e.GetResult()) + // t.Log(e.GetResult()) } } diff --git a/communicator.go b/communicator.go index 676ace0..8419ded 100644 --- a/communicator.go +++ b/communicator.go @@ -5,7 +5,6 @@ import ( "encoding/json" "loafle.com/commons/communicate/events" "net/http" - "strconv" ) type communicator struct { @@ -27,8 +26,15 @@ func (c *communicator) start() { go func(event *events.Event) { m := event.Data.(events.URLMaker) data, _ := json.Marshal(event) - r, _ := http.Post(GetRootURL()+m.GetUrl(), "application/json", bytes.NewBuffer(data)) - e.Result <- events.Result{Message: strconv.Itoa(r.StatusCode)} + res, err := http.Post(GetRootURL()+m.GetUrl(), "application/json", bytes.NewBuffer(data)) + + // todo timeout,error + if err != nil { + + } + if res.StatusCode != 200 && res.StatusCode != 201 { + + } }(e) } }() diff --git a/events/event.go b/events/event.go index f74c261..b60b2f2 100644 --- a/events/event.go +++ b/events/event.go @@ -30,12 +30,12 @@ type Event struct { Time Timestamp EventType string Data interface{} - Result chan Result `json:"-"` + //Result chan Result `json:"-"` } -func (e *Event) GetResult() Result { - return <-e.Result -} +//func (e *Event) GetResult() Result { +// return <-e.Result +//} func NewEvent(dataType string, data interface{}) *Event { return &Event{ @@ -43,6 +43,5 @@ func NewEvent(dataType string, data interface{}) *Event { Time: Now(), EventType: dataType, Data: data, - Result: make(chan Result), } }