do not write to queue if server_id is empty
This commit is contained in:
parent
ce0f6316c1
commit
efad6c4a2e
|
@ -5,6 +5,7 @@
|
||||||
package action
|
package action
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"fmt"
|
||||||
"infini.sh/console/model/alerting"
|
"infini.sh/console/model/alerting"
|
||||||
"infini.sh/framework/core/queue"
|
"infini.sh/framework/core/queue"
|
||||||
"infini.sh/framework/core/util"
|
"infini.sh/framework/core/util"
|
||||||
|
@ -20,6 +21,9 @@ const EmailQueueName = "email_messages"
|
||||||
|
|
||||||
func (act *EmailAction) Execute()([]byte, error){
|
func (act *EmailAction) Execute()([]byte, error){
|
||||||
queueCfg := queue.GetOrInitConfig(EmailQueueName)
|
queueCfg := queue.GetOrInitConfig(EmailQueueName)
|
||||||
|
if act.Data.ServerID == "" {
|
||||||
|
return nil, fmt.Errorf("parameter server_id must not be empty")
|
||||||
|
}
|
||||||
emailMsg := util.MapStr{
|
emailMsg := util.MapStr{
|
||||||
"server_id": act.Data.ServerID,
|
"server_id": act.Data.ServerID,
|
||||||
"email": act.Data.Recipients.To,
|
"email": act.Data.Recipients.To,
|
||||||
|
|
Loading…
Reference in New Issue