Mirrors
/
prologic-msgbus
mirror of https://git.mills.io/prologic/msgbus.git
6
0
Fork 0
Code Issues Projects Releases Wiki Activity

Set application/json content-types for most responses

This commit is contained in:
James Mills 2018-03-25 16:27:39 -07:00
parent fc8df01b2c
commit baf9ecbf55
No known key found for this signature in database
GPG Key ID: AC4C014F1440EBD6
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
msgbus.go
View File

@ -2,7 +2,6 @@ package msgbus
import (
"encoding/json"
"fmt"
"io/ioutil"
"log"
"net/http"
@ -234,10 +233,14 @@ func (mb *MessageBus) Unsubscribe(id, topic string) {
func (mb *MessageBus) ServeHTTP(w http.ResponseWriter, r *http.Request) {
if r.Method == "GET" && (r.URL.Path == "/" || r.URL.Path == "") {
for topic := range mb.topics {
w.Write([]byte(fmt.Sprintf("%s\n", topic)))
out, err := json.Marshal(mb.topics)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
return
}
w.WriteHeader(http.StatusOK)
w.Header().Set("Content-Type", "application/json")
w.Write(out)
return
}
@ -277,6 +280,7 @@ func (mb *MessageBus) ServeHTTP(w http.ResponseWriter, r *http.Request) {
return
}
w.Header().Set("Content-Type", "application/json")
w.Write(out)
case "DELETE":
http.Error(w, "Not Implemented", http.StatusNotImplemented)