diff --git a/bridge/api/api.go b/bridge/api/api.go index 28c57106..0ccd85b6 100644 --- a/bridge/api/api.go +++ b/bridge/api/api.go @@ -102,6 +102,14 @@ func (b *Api) handleMessages(c echo.Context) error { func (b *Api) handleStream(c echo.Context) error { c.Response().Header().Set(echo.HeaderContentType, echo.MIMEApplicationJSON) c.Response().WriteHeader(http.StatusOK) + greet := config.Message{ + Event:config.EVENT_API_CONNECTED, + Timestamp:time.Now(), + } + if err := json.NewEncoder(c.Response()).Encode(greet); err != nil { + return err + } + c.Response().Flush() closeNotifier := c.Response().CloseNotify() for { select { diff --git a/bridge/config/config.go b/bridge/config/config.go index 7f8fc3ee..eff93094 100644 --- a/bridge/config/config.go +++ b/bridge/config/config.go @@ -22,6 +22,7 @@ const ( EVENT_REJOIN_CHANNELS = "rejoin_channels" EVENT_USER_ACTION = "user_action" EVENT_MSG_DELETE = "msg_delete" + EVENT_API_CONNECTED = "api_connected" ) type Message struct {