in eventmanager/eventmanager.go [51:95]
func (em *EventManager) configureEvents() {
em.eventServer().OnConnect("/files", func(conn *websocket.Conn) *common.Response {
em.logEvent("/files", "CONNECT", logrus.Fields{})
em.filemanager.Start()
return successResponse()
})
em.eventServer().OnDisconnect("/files", func(conn *websocket.Conn) *common.Response {
em.logEvent("/files", "DISCONNECT", logrus.Fields{})
em.filemanager.Stop()
return successResponse()
})
em.eventServer().OnEvent("/files", "PATCH", func(conn *websocket.Conn, payload json.RawMessage) *common.Response {
var request *common.PatchRequest
if err := json.Unmarshal(payload, &request); err != nil {
return jsonErrorResponse(err)
}
em.logEvent("/files", "PATCH", logrus.Fields{})
err := em.execPatch(request.Diff, request.DeleteFiles)
if err != nil {
em.logError("/files", "PATCH", err)
return errorResponse(err)
}
return successResponse()
})
fn := func(conn *websocket.Conn) *common.Response {
em.logEvent("/repository", "DELETE", logrus.Fields{})
err := em.execResetRepository()
if err != nil {
}
return successResponse()
}
em.eventServer().OnEvent(
"/repository",
"DELETE",
websocketserver.NoPayload(fn),
)
}