luzifer/twitch-manager
1
0
Fork 0
mirror of https://github.com/Luzifer/twitch-manager.git synced 2024-12-21 04:11:17 +00:00
Code Issues Projects Releases Wiki Activity

Add custom event API

Browse source 
Signed-off-by: Knut Ahlers <knut@ahlers.me>
This commit is contained in:
Knut Ahlers 2021-03-13 15:57:31 +01:00
parent a2484972fe
commit 65af5de2e1
Signed by: luzifer
GPG key ID: 0066F03ED215AD7D
1 changed files with 20 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
api.go
View file

@ -20,6 +20,7 @@ import (
const ( const (
msgTypeAlert string = "alert" msgTypeAlert string = "alert"
msgTypeBits string = "bits" msgTypeBits string = "bits"
msgTypeCustom string = "custom"
msgTypeHost string = "host" msgTypeHost string = "host"
msgTypeRaid string = "raid" msgTypeRaid string = "raid"
msgTypeStore string = "store" msgTypeStore string = "store"
@ -99,6 +100,7 @@ var upgrader = websocket.Upgrader{
func registerAPI(r *mux.Router) { func registerAPI(r *mux.Router) {
r.HandleFunc("/api/custom-alert", handleCustomAlert).Methods(http.MethodPost) r.HandleFunc("/api/custom-alert", handleCustomAlert).Methods(http.MethodPost)
r.HandleFunc("/api/custom-event", handleCustomEvent).Methods(http.MethodPost)
r.HandleFunc("/api/follows/clear-last", handleSetLastFollower).Methods(http.MethodPut) r.HandleFunc("/api/follows/clear-last", handleSetLastFollower).Methods(http.MethodPut)
r.HandleFunc("/api/follows/set-last/{name}", handleSetLastFollower).Methods(http.MethodPut) r.HandleFunc("/api/follows/set-last/{name}", handleSetLastFollower).Methods(http.MethodPut)
r.HandleFunc("/api/subscribe", handleUpdateSocket).Methods(http.MethodGet) r.HandleFunc("/api/subscribe", handleUpdateSocket).Methods(http.MethodGet)
@ -131,6 +133,24 @@ func handleCustomAlert(w http.ResponseWriter, r *http.Request) {
w.WriteHeader(http.StatusCreated) w.WriteHeader(http.StatusCreated)
} }
func handleCustomEvent(w http.ResponseWriter, r *http.Request) {
var event struct {
Data string `json:"data"`
}
if err := json.NewDecoder(r.Body).Decode(&event); err != nil {
http.Error(w, errors.Wrap(err, "parse request body").Error(), http.StatusBadRequest)
return
}
if err := subscriptions.SendAllSockets(msgTypeCustom, event); err != nil {
http.Error(w, errors.Wrap(err, "send to sockets").Error(), http.StatusInternalServerError)
return
}
w.WriteHeader(http.StatusCreated)
}
func handleSetLastFollower(w http.ResponseWriter, r *http.Request) { func handleSetLastFollower(w http.ResponseWriter, r *http.Request) {
name := mux.Vars(r)["name"] name := mux.Vars(r)["name"]