mirror of
https://github.com/jhillyerd/inbucket.git
synced 2025-12-18 10:07:02 +00:00
chore: fix many unit test style warnings (#488)
Signed-off-by: James Hillyerd <james@hillyerd.com>
This commit is contained in:
@@ -47,7 +47,7 @@ func TestPoolGrowsWithPuts(t *testing.T) {
|
|||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
b, err := pool.getState()
|
b, err := pool.getState()
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
assert.Equal(t, 0, len(pool.states), "Wanted pool to be empty")
|
assert.Empty(t, pool.states, "Wanted pool to be empty")
|
||||||
|
|
||||||
pool.putState(a)
|
pool.putState(a)
|
||||||
pool.putState(b)
|
pool.putState(b)
|
||||||
@@ -64,11 +64,11 @@ func TestPoolPutDiscardsClosed(t *testing.T) {
|
|||||||
|
|
||||||
a, err := pool.getState()
|
a, err := pool.getState()
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
assert.Equal(t, 0, len(pool.states), "Wanted pool to be empty")
|
assert.Empty(t, pool.states, "Wanted pool to be empty")
|
||||||
|
|
||||||
a.Close()
|
a.Close()
|
||||||
pool.putState(a)
|
pool.putState(a)
|
||||||
assert.Equal(t, 0, len(pool.states), "Wanted pool to remain empty")
|
assert.Empty(t, pool.states, "Wanted pool to remain empty")
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestPoolPutClearsStack(t *testing.T) {
|
func TestPoolPutClearsStack(t *testing.T) {
|
||||||
@@ -76,7 +76,7 @@ func TestPoolPutClearsStack(t *testing.T) {
|
|||||||
|
|
||||||
ls, err := pool.getState()
|
ls, err := pool.getState()
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
assert.Equal(t, 0, len(pool.states), "Wanted pool to be empty")
|
assert.Empty(t, pool.states, "Wanted pool to be empty")
|
||||||
|
|
||||||
// Setup stack.
|
// Setup stack.
|
||||||
ls.Push(lua.LNumber(4))
|
ls.Push(lua.LNumber(4))
|
||||||
@@ -85,7 +85,7 @@ func TestPoolPutClearsStack(t *testing.T) {
|
|||||||
|
|
||||||
// Return and verify stack cleared.
|
// Return and verify stack cleared.
|
||||||
pool.putState(ls)
|
pool.putState(ls)
|
||||||
assert.Equal(t, 1, len(pool.states), "Wanted pool to have one item")
|
assert.Len(t, pool.states, 1, "Wanted pool to have one item")
|
||||||
require.Equal(t, 0, ls.GetTop(), "Want stack to be empty")
|
require.Equal(t, 0, ls.GetTop(), "Want stack to be empty")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -392,7 +392,7 @@ func TestMarkSeen(t *testing.T) {
|
|||||||
assert.False(t, msg.Seen, "msg should be unseen")
|
assert.False(t, msg.Seen, "msg should be unseen")
|
||||||
|
|
||||||
err = sm.MarkSeen("box1", id)
|
err = sm.MarkSeen("box1", id)
|
||||||
assert.NoError(t, err, "MarkSeen should succeed")
|
require.NoError(t, err, "MarkSeen should succeed")
|
||||||
|
|
||||||
// Verify test message seen.
|
// Verify test message seen.
|
||||||
msg, err = sm.GetMessage("box1", id)
|
msg, err = sm.GetMessage("box1", id)
|
||||||
@@ -414,7 +414,7 @@ func TestRemoveMessage(t *testing.T) {
|
|||||||
|
|
||||||
// Delete message 2 and verify.
|
// Delete message 2 and verify.
|
||||||
err = sm.RemoveMessage("box1", id2)
|
err = sm.RemoveMessage("box1", id2)
|
||||||
assert.NoError(t, err)
|
require.NoError(t, err)
|
||||||
got, err = sm.GetMetadata("box1")
|
got, err = sm.GetMetadata("box1")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
require.Len(t, got, 2, "Should be 2 messages remaining")
|
require.Len(t, got, 2, "Should be 2 messages remaining")
|
||||||
@@ -440,10 +440,10 @@ func TestPurgeMessages(t *testing.T) {
|
|||||||
|
|
||||||
// Purge and verify.
|
// Purge and verify.
|
||||||
err = sm.PurgeMessages("box1")
|
err = sm.PurgeMessages("box1")
|
||||||
assert.NoError(t, err)
|
require.NoError(t, err)
|
||||||
got, err = sm.GetMetadata("box1")
|
got, err = sm.GetMetadata("box1")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
require.Len(t, got, 0, "Purge should remove all mailbox messages")
|
assert.Empty(t, got, "Purge should remove all mailbox messages")
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestSourceReader(t *testing.T) {
|
func TestSourceReader(t *testing.T) {
|
||||||
@@ -543,7 +543,7 @@ func assertMessageCount(t *testing.T, sm *message.StoreManager, mailbox string,
|
|||||||
t.Helper()
|
t.Helper()
|
||||||
|
|
||||||
metas, err := sm.GetMetadata(mailbox)
|
metas, err := sm.GetMetadata(mailbox)
|
||||||
assert.NoError(t, err, "StoreManager GetMetadata failed")
|
require.NoError(t, err, "StoreManager GetMetadata failed")
|
||||||
|
|
||||||
got := len(metas)
|
got := len(metas)
|
||||||
if got != count {
|
if got != count {
|
||||||
|
|||||||
@@ -435,11 +435,12 @@ Hi!
|
|||||||
|
|
||||||
// playSession creates a new session, reads the greeting and then plays the script
|
// playSession creates a new session, reads the greeting and then plays the script
|
||||||
func playSession(t *testing.T, server *Server, script []scriptStep) error {
|
func playSession(t *testing.T, server *Server, script []scriptStep) error {
|
||||||
|
t.Helper()
|
||||||
pipe := setupSMTPSession(t, server)
|
pipe := setupSMTPSession(t, server)
|
||||||
c := textproto.NewConn(pipe)
|
c := textproto.NewConn(pipe)
|
||||||
|
|
||||||
if code, _, err := c.ReadCodeLine(220); err != nil {
|
if code, _, err := c.ReadCodeLine(220); err != nil {
|
||||||
return fmt.Errorf("Expected a 220 greeting, got %v", code)
|
return fmt.Errorf("expected a 220 greeting, got %v", code)
|
||||||
}
|
}
|
||||||
|
|
||||||
err := playScriptAgainst(t, c, script)
|
err := playScriptAgainst(t, c, script)
|
||||||
@@ -596,6 +597,7 @@ func setupSMTPServer(ds storage.Store, extHost *extension.Host) *Server {
|
|||||||
var sessionNum int
|
var sessionNum int
|
||||||
|
|
||||||
func setupSMTPSession(t *testing.T, server *Server) net.Conn {
|
func setupSMTPSession(t *testing.T, server *Server) net.Conn {
|
||||||
|
t.Helper()
|
||||||
logger := zerolog.New(zerolog.NewTestWriter(t))
|
logger := zerolog.New(zerolog.NewTestWriter(t))
|
||||||
serverConn, clientConn := net.Pipe()
|
serverConn, clientConn := net.Pipe()
|
||||||
|
|
||||||
|
|||||||
@@ -38,7 +38,7 @@ func TestSuite(t *testing.T) {
|
|||||||
func TestFSNew(t *testing.T) {
|
func TestFSNew(t *testing.T) {
|
||||||
// Should fail if no path specified.
|
// Should fail if no path specified.
|
||||||
ds, err := New(config.Storage{}, extension.NewHost())
|
ds, err := New(config.Storage{}, extension.NewHost())
|
||||||
assert.ErrorContains(t, err, "parameter not specified")
|
require.ErrorContains(t, err, "parameter not specified")
|
||||||
assert.Nil(t, ds)
|
assert.Nil(t, ds)
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -100,7 +100,7 @@ func TestFSDirStructure(t *testing.T) {
|
|||||||
|
|
||||||
// Delete message
|
// Delete message
|
||||||
err := ds.RemoveMessage(mbName, id1)
|
err := ds.RemoveMessage(mbName, id1)
|
||||||
assert.Nil(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
// Message should be removed
|
// Message should be removed
|
||||||
expect = filepath.Join(mbPath, id1+".raw")
|
expect = filepath.Join(mbPath, id1+".raw")
|
||||||
@@ -110,7 +110,7 @@ func TestFSDirStructure(t *testing.T) {
|
|||||||
|
|
||||||
// Delete message
|
// Delete message
|
||||||
err = ds.RemoveMessage(mbName, id2)
|
err = ds.RemoveMessage(mbName, id2)
|
||||||
assert.Nil(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
// Message should be removed
|
// Message should be removed
|
||||||
expect = filepath.Join(mbPath, id2+".raw")
|
expect = filepath.Join(mbPath, id2+".raw")
|
||||||
@@ -147,15 +147,15 @@ func TestFSMissing(t *testing.T) {
|
|||||||
|
|
||||||
// Delete a message file without removing it from index
|
// Delete a message file without removing it from index
|
||||||
msg, err := ds.GetMessage(mbName, sentIds[1])
|
msg, err := ds.GetMessage(mbName, sentIds[1])
|
||||||
assert.Nil(t, err)
|
require.NoError(t, err)
|
||||||
fmsg := msg.(*Message)
|
fmsg := msg.(*Message)
|
||||||
_ = os.Remove(fmsg.rawPath())
|
_ = os.Remove(fmsg.rawPath())
|
||||||
msg, err = ds.GetMessage(mbName, sentIds[1])
|
msg, err = ds.GetMessage(mbName, sentIds[1])
|
||||||
assert.Nil(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
// Try to read parts of message
|
// Try to read parts of message
|
||||||
_, err = msg.Source()
|
_, err = msg.Source()
|
||||||
assert.Error(t, err)
|
require.Error(t, err)
|
||||||
|
|
||||||
if t.Failed() {
|
if t.Failed() {
|
||||||
// Wait for handler to finish logging
|
// Wait for handler to finish logging
|
||||||
@@ -176,7 +176,7 @@ func TestGetLatestMessage(t *testing.T) {
|
|||||||
// Test empty mailbox
|
// Test empty mailbox
|
||||||
msg, err := ds.GetMessage(mbName, "latest")
|
msg, err := ds.GetMessage(mbName, "latest")
|
||||||
assert.Nil(t, msg)
|
assert.Nil(t, msg)
|
||||||
assert.Error(t, err)
|
require.Error(t, err)
|
||||||
|
|
||||||
// Deliver test message
|
// Deliver test message
|
||||||
deliverMessage(ds, mbName, "test", time.Now())
|
deliverMessage(ds, mbName, "test", time.Now())
|
||||||
@@ -187,18 +187,18 @@ func TestGetLatestMessage(t *testing.T) {
|
|||||||
// Test get the latest message
|
// Test get the latest message
|
||||||
msg, err = ds.GetMessage(mbName, "latest")
|
msg, err = ds.GetMessage(mbName, "latest")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
assert.True(t, msg.ID() == id2, "Expected %q to be equal to %q", msg.ID(), id2)
|
assert.Equal(t, id2, msg.ID(), "Expected %q to be equal to %q", msg.ID(), id2)
|
||||||
|
|
||||||
// Deliver test message 3
|
// Deliver test message 3
|
||||||
id3, _ := deliverMessage(ds, mbName, "test 3", time.Now())
|
id3, _ := deliverMessage(ds, mbName, "test 3", time.Now())
|
||||||
|
|
||||||
msg, err = ds.GetMessage(mbName, "latest")
|
msg, err = ds.GetMessage(mbName, "latest")
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
assert.True(t, msg.ID() == id3, "Expected %q to be equal to %q", msg.ID(), id3)
|
assert.Equal(t, id3, msg.ID(), "Expected %q to be equal to %q", msg.ID(), id3)
|
||||||
|
|
||||||
// Test wrong id
|
// Test wrong id
|
||||||
_, err = ds.GetMessage(mbName, "wrongid")
|
_, err = ds.GetMessage(mbName, "wrongid")
|
||||||
assert.Error(t, err)
|
require.Error(t, err)
|
||||||
|
|
||||||
if t.Failed() {
|
if t.Failed() {
|
||||||
// Wait for handler to finish logging
|
// Wait for handler to finish logging
|
||||||
|
|||||||
@@ -157,7 +157,7 @@ func testContent(t *testing.T, store storage.Store, extHost *extension.Host) {
|
|||||||
got, err := io.ReadAll(r)
|
got, err := io.ReadAll(r)
|
||||||
require.NoError(t, err, "failed to read source")
|
require.NoError(t, err, "failed to read source")
|
||||||
err = r.Close()
|
err = r.Close()
|
||||||
assert.NoError(t, err, "failed to close source reader")
|
require.NoError(t, err, "failed to close source reader")
|
||||||
|
|
||||||
// Verify source.
|
// Verify source.
|
||||||
if len(got) != len(content) {
|
if len(got) != len(content) {
|
||||||
@@ -425,10 +425,10 @@ func testVisitMailboxes(t *testing.T, ds storage.Store, extHost *extension.Host)
|
|||||||
name = messages[0].Mailbox()
|
name = messages[0].Mailbox()
|
||||||
}
|
}
|
||||||
|
|
||||||
assert.Equal(t, 2, len(messages), "incorrect message count in mailbox %s", name)
|
assert.Len(t, messages, 2, "incorrect message count in mailbox %s", name)
|
||||||
return true
|
return true
|
||||||
})
|
})
|
||||||
assert.NoError(t, err, "VisitMailboxes() failed")
|
require.NoError(t, err, "VisitMailboxes() failed")
|
||||||
assert.Equal(t, 5, nboxes, "visited %v mailboxes, want: 5", nboxes)
|
assert.Equal(t, 5, nboxes, "visited %v mailboxes, want: 5", nboxes)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -84,7 +84,7 @@ func TestStoreStubMailboxAddGetVisit(t *testing.T) {
|
|||||||
|
|
||||||
want, ok := expectCounts[mailbox]
|
want, ok := expectCounts[mailbox]
|
||||||
assert.True(t, ok, "Mailbox %q was unexpected", mailbox)
|
assert.True(t, ok, "Mailbox %q was unexpected", mailbox)
|
||||||
assert.Equal(t, want, len(m), "Unexpected message count for mailbox %q", mailbox)
|
assert.Len(t, m, want, "Unexpected message count for mailbox %q", mailbox)
|
||||||
|
|
||||||
delete(expectCounts, mailbox)
|
delete(expectCounts, mailbox)
|
||||||
|
|
||||||
@@ -114,7 +114,7 @@ func TestStoreStubMarkSeen(t *testing.T) {
|
|||||||
// Mark second message as seen.
|
// Mark second message as seen.
|
||||||
seen := inputMsgs[1]
|
seen := inputMsgs[1]
|
||||||
err := ss.MarkSeen("box1", seen.ID())
|
err := ss.MarkSeen("box1", seen.ID())
|
||||||
assert.NoError(t, err, "MarkSeen must not fail")
|
require.NoError(t, err, "MarkSeen must not fail")
|
||||||
|
|
||||||
// Verify message has seen flag.
|
// Verify message has seen flag.
|
||||||
got, err := ss.GetMessage("box1", seen.ID())
|
got, err := ss.GetMessage("box1", seen.ID())
|
||||||
@@ -150,16 +150,16 @@ func TestStoreStubRemoveMessage(t *testing.T) {
|
|||||||
// Delete second message.
|
// Delete second message.
|
||||||
deleted := inputMsgs[1]
|
deleted := inputMsgs[1]
|
||||||
err := ss.RemoveMessage("box1", deleted.ID())
|
err := ss.RemoveMessage("box1", deleted.ID())
|
||||||
assert.NoError(t, err, "DeleteMessage must not fail")
|
require.NoError(t, err, "DeleteMessage must not fail")
|
||||||
|
|
||||||
// Verify message is not in mailbox.
|
// Verify message is not in mailbox.
|
||||||
messages, err := ss.GetMessages("box1")
|
messages, err := ss.GetMessages("box1")
|
||||||
assert.NoError(t, err)
|
require.NoError(t, err)
|
||||||
assert.NotContains(t, messages, deleted, "Mailbox should not contain msg %q", deleted.ID())
|
assert.NotContains(t, messages, deleted, "Mailbox should not contain msg %q", deleted.ID())
|
||||||
|
|
||||||
// Verify message is no longer retrievable.
|
// Verify message is no longer retrievable.
|
||||||
got, err := ss.GetMessage("box1", deleted.ID())
|
got, err := ss.GetMessage("box1", deleted.ID())
|
||||||
assert.Error(t, err)
|
require.Error(t, err)
|
||||||
assert.Nil(t, got, "Message should have been nil")
|
assert.Nil(t, got, "Message should have been nil")
|
||||||
|
|
||||||
// Verify message is in deleted list.
|
// Verify message is in deleted list.
|
||||||
@@ -181,12 +181,12 @@ func TestStoreStubPurgeMessages(t *testing.T) {
|
|||||||
|
|
||||||
// Purge messages.
|
// Purge messages.
|
||||||
err := ss.PurgeMessages("box1")
|
err := ss.PurgeMessages("box1")
|
||||||
assert.NoError(t, err, "PurgeMessages must not fail")
|
require.NoError(t, err, "PurgeMessages must not fail")
|
||||||
|
|
||||||
// Verify message is not in mailbox.
|
// Verify message is not in mailbox.
|
||||||
messages, err := ss.GetMessages("box1")
|
messages, err := ss.GetMessages("box1")
|
||||||
assert.NoError(t, err)
|
require.NoError(t, err)
|
||||||
assert.Len(t, messages, 0, "Mailbox should be empty")
|
assert.Empty(t, messages, "Mailbox should be empty")
|
||||||
|
|
||||||
// Verify messages are in deleted list.
|
// Verify messages are in deleted list.
|
||||||
for _, want := range inputMsgs {
|
for _, want := range inputMsgs {
|
||||||
@@ -208,15 +208,15 @@ func TestStoreStubForcedErrors(t *testing.T) {
|
|||||||
|
|
||||||
// Verify methods return error.
|
// Verify methods return error.
|
||||||
_, err = ss.GetMessage("messageerr", id1)
|
_, err = ss.GetMessage("messageerr", id1)
|
||||||
assert.Error(t, err, "GetMessage()")
|
require.Error(t, err, "GetMessage()")
|
||||||
assert.NotEqual(t, storage.ErrNotExist, err)
|
assert.NotEqual(t, storage.ErrNotExist, err)
|
||||||
|
|
||||||
_, err = ss.GetMessages("messageserr")
|
_, err = ss.GetMessages("messageserr")
|
||||||
assert.Error(t, err, "GetMessages()")
|
require.Error(t, err, "GetMessages()")
|
||||||
assert.NotEqual(t, storage.ErrNotExist, err)
|
assert.NotEqual(t, storage.ErrNotExist, err)
|
||||||
|
|
||||||
err = ss.MarkSeen("messageerr", id1)
|
err = ss.MarkSeen("messageerr", id1)
|
||||||
assert.Error(t, err, "MarkSeen()")
|
require.Error(t, err, "MarkSeen()")
|
||||||
assert.NotEqual(t, storage.ErrNotExist, err)
|
assert.NotEqual(t, storage.ErrNotExist, err)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user