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

Finally all tests pass :D

This commit is contained in:
James Mills 2022-04-03 18:26:40 +10:00
parent d1f175699f
commit 016519dcde
No known key found for this signature in database
GPG Key ID: AC4C014F1440EBD6
2 changed files with 35 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

0
hello/00000000000000000001
View File

66
msgbus_test.go
View File

@ -26,7 +26,11 @@ func TestMessageBusLen(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
mb, err := NewMessageBus()
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
mb, err := NewMessageBus(WithLogPath(testdir))
require.NoError(err)
assert.Equal(0, mb.Len())
@ -36,7 +40,7 @@ func TestMessage(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -59,7 +63,7 @@ func TestMessageIds(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -86,7 +90,7 @@ func TestMessageGetEmpty(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -105,7 +109,7 @@ func TestMessageBusPutGet(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -125,7 +129,7 @@ func TestMessageBusSubscribe(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -146,7 +150,7 @@ func TestMessageBusSubscribeWithIndex(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -179,7 +183,7 @@ func TestMessageBusWAL(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -225,7 +229,7 @@ func TestServeHTTPGETIndexEmpty(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -244,7 +248,7 @@ func TestServeHTTPGETTopics(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -267,7 +271,7 @@ func TestServeHTTPGETEmptyQueue(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -285,7 +289,7 @@ func TestServeHTTPPOST(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -304,7 +308,7 @@ func TestServeHTTPMaxPayloadSize(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -324,7 +328,7 @@ func TestServeHTTPSimple(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -346,15 +350,15 @@ func TestServeHTTPSimple(t *testing.T) {
var msg *Message
json.Unmarshal(w.Body.Bytes(), &msg)
assert.Equal(msg.ID, 0)
assert.Equal(msg.Topic.Name, "hello")
assert.Equal(msg.Payload, []byte("hello world"))
assert.Equal(int64(1), msg.ID)
assert.Equal("hello", msg.Topic.Name, "hello")
assert.Equal([]byte("hello world"), msg.Payload)
}
func BenchmarkServeHTTPPOST(b *testing.B) {
require := require.New(b)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -375,7 +379,7 @@ func TestServeHTTPSubscriber(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -415,16 +419,16 @@ func TestServeHTTPSubscriber(t *testing.T) {
defer r.Body.Close()
msg := <-msgs
assert.Equal(msg.ID, 0)
assert.Equal(msg.Topic.Name, "hello")
assert.Equal(msg.Payload, []byte("hello world"))
assert.Equal(int64(1), msg.ID)
assert.Equal("hello", msg.Topic.Name)
assert.Equal([]byte("hello world"), msg.Payload)
}
func TestServeHTTPSubscriberReconnect(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -466,16 +470,16 @@ func TestServeHTTPSubscriberReconnect(t *testing.T) {
defer r.Body.Close()
msg := <-msgs
assert.Equal(msg.ID, 0)
assert.Equal(msg.Topic.Name, "hello")
assert.Equal(msg.Payload, []byte("hello world"))
assert.Equal(int64(1), msg.ID)
assert.Equal("hello", msg.Topic.Name)
assert.Equal([]byte("hello world"), msg.Payload)
}
func TestMsgBusMetrics(t *testing.T) {
assert := assert.New(t)
require := require.New(t)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -488,7 +492,7 @@ func TestMsgBusMetrics(t *testing.T) {
func BenchmarkMessageBusPut(b *testing.B) {
require := require.New(b)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -506,7 +510,7 @@ func BenchmarkMessageBusPut(b *testing.B) {
func BenchmarkMessageBusGet(b *testing.B) {
require := require.New(b)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -527,7 +531,7 @@ func BenchmarkMessageBusGet(b *testing.B) {
func BenchmarkMessageBusGetEmpty(b *testing.B) {
require := require.New(b)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)
@ -544,7 +548,7 @@ func BenchmarkMessageBusGetEmpty(b *testing.B) {
func BenchmarkMessageBusPutGet(b *testing.B) {
require := require.New(b)
testdir, err := ioutil.TempDir("", "msgbus-logs")
testdir, err := ioutil.TempDir("", "msgbus-logs-*")
require.NoError(err)
defer os.RemoveAll(testdir)