1
0
mirror of https://github.com/jhillyerd/inbucket.git synced 2025-12-17 17:47:03 +00:00

fix: AfterMessageStored message.size (#550)

Signed-off-by: James Hillyerd <james@hillyerd.com>
This commit is contained in:
James Hillyerd
2024-10-20 12:32:51 -07:00
committed by GitHub
parent 15d1970dbe
commit 5902189187
2 changed files with 13 additions and 1 deletions

View File

@@ -122,6 +122,7 @@ func (s *StoreManager) Deliver(
To: inbound.To, To: inbound.To,
Date: now, Date: now,
Subject: inbound.Subject, Subject: inbound.Subject,
Size: inbound.Size,
}, },
Reader: io.MultiReader(strings.NewReader(recvd), bytes.NewReader(source)), Reader: io.MultiReader(strings.NewReader(recvd), bytes.NewReader(source)),
} }

View File

@@ -312,7 +312,7 @@ func TestDeliverEmitsAfterMessageStoredEvent(t *testing.T) {
origin, origin,
[]*policy.Recipient{recip}, []*policy.Recipient{recip},
"Received: xyz\n", "Received: xyz\n",
[]byte("From: from@example.com\n\ntest email"), []byte("From: from@example.com\nSubject: events\n\ntest email."),
); err != nil { ); err != nil {
t.Fatal(err) t.Fatal(err)
} }
@@ -321,6 +321,17 @@ func TestDeliverEmitsAfterMessageStoredEvent(t *testing.T) {
require.NoError(t, err) require.NoError(t, err)
assert.NotNil(t, got, "No event received, or it was nil") assert.NotNil(t, got, "No event received, or it was nil")
assertMessageCount(t, sm, "to@example.com", 1) assertMessageCount(t, sm, "to@example.com", 1)
// Verify event content.
assert.Equal(t, "to@example.com", got.Mailbox)
assert.Equal(t, "from@example.com", got.From.Address)
assert.WithinDuration(t, time.Now(), got.Date, 5*time.Second)
assert.Equal(t, "events", got.Subject, nil)
assert.Equal(t, int64(51), got.Size)
require.Len(t, got.To, 1)
assert.Equal(t, "to@example.com", got.To[0].Address)
} }
func TestDeliverBeforeAndAfterMessageStoredEvents(t *testing.T) { func TestDeliverBeforeAndAfterMessageStoredEvents(t *testing.T) {