Skip to content

Commit

Permalink
small fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
lenaunderwood22 committed Jan 27, 2025
1 parent e421914 commit 9386d01
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 13 deletions.
15 changes: 7 additions & 8 deletions cmd/notify-mailer/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -142,7 +142,7 @@ func (m *mailer) run(ctx context.Context) error {
totalRecipients := len(m.recipients)
m.log.Infof("Resolving addresses for (%d) recipients", totalRecipients)

addressToRecipient, _, err := m.resolveAddresses(ctx)
addressToRecipient, err := m.resolveAddresses(ctx)
if err != nil {
return err
}
Expand Down Expand Up @@ -263,17 +263,16 @@ func (m *mailer) run(ctx context.Context) error {
}

// resolveAddresses creates a mapping of email addresses to (a list of)
// `recipient`s that resolve to that email address. Return true bool if
// skip resolve address steps and return readEmailsMap instead (for testing purposes)
func (m *mailer) resolveAddresses(ctx context.Context) (addressToRecipientMap, bool, error) {
// `recipient`s that resolve to that email address.
func (m *mailer) resolveAddresses(ctx context.Context) (addressToRecipientMap, error) {
if m.saveEmailsTo == "" && m.readEmailsMap != nil {
return m.readEmailsMap, true, nil
return m.readEmailsMap, nil
}
result := make(addressToRecipientMap, len(m.recipients))
for _, recipient := range m.recipients {
addresses, err := getAddressForID(ctx, recipient.id, m.dbMap)
if err != nil {
return nil, false, err
return nil, err
}

for _, address := range addresses {
Expand All @@ -287,7 +286,7 @@ func (m *mailer) resolveAddresses(ctx context.Context) (addressToRecipientMap, b
}
}
}
return result, false, nil
return result, nil
}

// dbSelector abstracts over a subset of methods from `borp.DbMap` objects to
Expand Down Expand Up @@ -450,7 +449,7 @@ func readRecipientsList(filename string, delimiter rune) ([]recipient, string, e
}
}

// Read filename then extract and return parsed addressToRecipientMap
// Read file then extract and return unmarshaled addressToRecipientMap
func readEmailsFile(filename string) (addressToRecipientMap, error) {
data, err := os.ReadFile(filename)
if err != nil {
Expand Down
7 changes: 2 additions & 5 deletions cmd/notify-mailer/main_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -766,7 +766,7 @@ func TestResolveEmails(t *testing.T) {
clk: clock.NewFake(),
}

addressesToRecipients, _, err := m.resolveAddresses(context.Background())
addressesToRecipients, err := m.resolveAddresses(context.Background())
test.AssertNotError(t, err, "failed to resolveEmailAddresses")

expected := []string{
Expand Down Expand Up @@ -858,13 +858,10 @@ func TestReadFilesFrom(t *testing.T) {
readEmailsMap: readEmailsMap,
}

resolvedMap, isRead, err := m.resolveAddresses(context.Background())
resolvedMap, err := m.resolveAddresses(context.Background())
if err != nil {
t.Errorf("error running resolveAddresses: %s", err)
}
if !isRead {
t.Error("Addresses should have been read from file, not resolved")
}
if !reflect.DeepEqual(readEmailsMap, resolvedMap) {
t.Error("Resolved map not same as map read from file")
}
Expand Down

0 comments on commit 9386d01

Please sign in to comment.