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

Added more tests

This commit is contained in:
James Mills 2018-05-14 03:12:07 -07:00
parent c640130f11
commit 400702b2b4
No known key found for this signature in database
GPG Key ID: AC4C014F1440EBD6
1 changed files with 27 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
msgbus_test.go
View File

@ -64,6 +64,33 @@ func TestServeHTTPGETEmpty(t *testing.T) {
assert.Equal(w.Body.String(), "{}")
}
func TestServeHTTPGETTopics(t *testing.T) {
assert := assert.New(t)
mb := New(nil)
mb.Put(Message{Topic: mb.NewTopic("foo"), Payload: []byte("foo")})
mb.Put(Message{Topic: mb.NewTopic("hello"), Payload: []byte("hello world")})
w := httptest.NewRecorder()
r, _ := http.NewRequest("GET", "/", nil)
mb.ServeHTTP(w, r)
assert.Equal(w.Code, http.StatusOK)
assert.Regexp(`{"foo":{"name":"foo","seq":0,"created":"\d+-\d+-\d+T\d+:\d+:\d+.\d+-\d+:\d+"},"hello":{"name":"hello","seq":0,"created":"\d+-\d+-\d+T\d+:\d+:\d+.\d+-\d+:\d+"}}`, w.Body.String())
}
func TestServeHTTPGETEmptyQueue(t *testing.T) {
assert := assert.New(t)
mb := New(nil)
w := httptest.NewRecorder()
r, _ := http.NewRequest("GET", "/hello", nil)
mb.ServeHTTP(w, r)
assert.Equal(w.Code, http.StatusNotFound)
}
func TestServeHTTPPOST(t *testing.T) {
assert := assert.New(t)