Verified Commit f225f444 authored by meskio's avatar meskio 🏔️
Browse files

email: Fix spelling errors

parent 473d4592

pkg/presentation/distributors/common/email.go

+2 −2
Original line number Diff line number Diff line
@@ -223,7 +223,7 @@ func (e *emailClient) fetchMessages(mboxStatus *imap.MailboxStatus) { 


	messages := make(chan *imap.Message, mboxStatus.Messages)

	flagUpdates := make(chan *flagUpdate, mboxStatus.Messages)

	go e.processIncommingMessages(messages, flagUpdates)

	go e.processIncomingMessages(messages, flagUpdates)



	log.Println("fetch", len(seqs), "messages from the imap server")

	err = e.imap.Fetch(seqset, items, messages)
@@ -248,7 +248,7 @@ func (e *emailClient) fetchMessages(mboxStatus *imap.MailboxStatus) { 
	}

}



func (e *emailClient) processIncommingMessages(messages chan *imap.Message, flagUpdates chan *flagUpdate) {

func (e *emailClient) processIncomingMessages(messages chan *imap.Message, flagUpdates chan *flagUpdate) {

	for msg := range messages {

		for _, literal := range msg.Body {

			email, err := mail.ReadMessage(literal)

pkg/presentation/distributors/common/email_test.go

+1 −1
Original line number Diff line number Diff line
@@ -85,7 +85,7 @@ func TestImapExistingInbox(t *testing.T) { 
func timeoutDistributor(t *testing.T, duration time.Duration) {

	time.Sleep(duration)

	syscall.Kill(syscall.Getpid(), syscall.SIGINT)

	t.Error("Timeout, no email recieved")

	t.Error("Timeout, no email received")

}



func checkInboxEmptyAndExit(t *testing.T, s *server.Server, mbox backend.Mailbox) {