Compare commits
2
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8da5ded0a4
|
||
|
|
a6e3c8fc4e
|
+3
-12
@@ -14,7 +14,6 @@ import (
|
|||||||
"git.kundeng.us/phoenix/swoosh/swoop/types"
|
"git.kundeng.us/phoenix/swoosh/swoop/types"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
||||||
type MessageSender struct {
|
type MessageSender struct {
|
||||||
Config *config.TwiloConfig
|
Config *config.TwiloConfig
|
||||||
}
|
}
|
||||||
@@ -34,9 +33,11 @@ func (m *MessageSender) Send(msg message.Message, number contact.Contact, sendTi
|
|||||||
params.SetFrom(m.Config.Number)
|
params.SetFrom(m.Config.Number)
|
||||||
params.SetMessagingServiceSid(m.Config.ServiceSID)
|
params.SetMessagingServiceSid(m.Config.ServiceSID)
|
||||||
params.SetBody(msg.Content)
|
params.SetBody(msg.Content)
|
||||||
if sendTime != nil && isSchedulable(now, sendTime) {
|
if sendTime != nil {
|
||||||
|
if sendTime.After(now) {
|
||||||
params.SetSendAt(*sendTime)
|
params.SetSendAt(*sendTime)
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if resp, err := client.Api.CreateMessage(params); err != nil {
|
if resp, err := client.Api.CreateMessage(params); err != nil {
|
||||||
return nil, fmt.Errorf("Error sending message: %v", err)
|
return nil, fmt.Errorf("Error sending message: %v", err)
|
||||||
@@ -48,13 +49,3 @@ func (m *MessageSender) Send(msg message.Message, number contact.Contact, sendTi
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func isSchedulable(now *time.Time, scheduled *time.Time) (bool) {
|
|
||||||
early := now.Add(300 * time.Second)
|
|
||||||
|
|
||||||
if scheduled.Before(early) && scheduled.After(now) {
|
|
||||||
return true
|
|
||||||
} else {
|
|
||||||
return false
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
Reference in New Issue
Block a user