|
@@ -70,7 +70,6 @@ func New(opt Opt, q *Queries, lo *log.Logger) (*Manager, error) {
|
|
switch opt.MailboxType {
|
|
switch opt.MailboxType {
|
|
case "pop":
|
|
case "pop":
|
|
m.mailbox = mailbox.NewPOP(opt.Mailbox)
|
|
m.mailbox = mailbox.NewPOP(opt.Mailbox)
|
|
- case "imap":
|
|
|
|
default:
|
|
default:
|
|
return nil, errors.New("unknown bounce mailbox type")
|
|
return nil, errors.New("unknown bounce mailbox type")
|
|
}
|
|
}
|
|
@@ -107,13 +106,18 @@ func (m *Manager) Run() {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+ date := b.CreatedAt
|
|
|
|
+ if date.IsZero() {
|
|
|
|
+ date = time.Now()
|
|
|
|
+ }
|
|
|
|
+
|
|
_, err := m.queries.RecordQuery.Exec(b.SubscriberUUID,
|
|
_, err := m.queries.RecordQuery.Exec(b.SubscriberUUID,
|
|
b.Email,
|
|
b.Email,
|
|
b.CampaignUUID,
|
|
b.CampaignUUID,
|
|
b.Type,
|
|
b.Type,
|
|
b.Source,
|
|
b.Source,
|
|
b.Meta,
|
|
b.Meta,
|
|
- b.CreatedAt,
|
|
|
|
|
|
+ date,
|
|
m.opt.BounceCount,
|
|
m.opt.BounceCount,
|
|
m.opt.BounceAction)
|
|
m.opt.BounceAction)
|
|
if err != nil {
|
|
if err != nil {
|