--- /dev/null
+package mailgun
+
+import (
+ "context"
+ "fmt"
+ "github.com/hashicorp/terraform/helper/schema"
+ "github.com/mailgun/mailgun-go"
+ "log"
+ "time"
+)
+
+func resourceMailgunDomain() *schema.Resource {
+ return &schema.Resource{
+ Create: CreateDomain,
+ Update: UpdateDomain,
+ Delete: DeleteDomain,
+ Read: ReadDomain,
+ Importer: &schema.ResourceImporter{
+ State: schema.ImportStatePassthrough,
+ },
+
+ Schema: map[string]*schema.Schema{
+ "name": &schema.Schema{
+ Type: schema.TypeString,
+ Required: true,
+ ForceNew: true,
+ },
+
+ "spam_action": &schema.Schema{
+ Type: schema.TypeString,
+ Default: "disabled",
+ ForceNew: true,
+ Optional: true,
+ },
+
+ "smtp_password": &schema.Schema{
+ Type: schema.TypeString,
+ ForceNew: true,
+ Optional: true,
+ },
+
+ "smtp_login": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+
+ "wildcard": &schema.Schema{
+ Type: schema.TypeBool,
+ Default: false,
+ ForceNew: true,
+ Optional: true,
+ },
+
+ "created_at": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ ForceNew: true,
+ },
+
+ "state": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+
+ "force_dkim_authority": &schema.Schema{
+ Type: schema.TypeBool,
+ Default: false,
+ Optional: true,
+ },
+
+ "dkim_key_size": &schema.Schema{
+ Type: schema.TypeInt,
+ Default: 1024,
+ ForceNew: true,
+ Optional: true,
+ },
+
+ "ips": &schema.Schema{
+ Type: schema.TypeList,
+ Computed: true,
+ ForceNew: true,
+ Optional: true,
+ Elem: &schema.Schema{Type: schema.TypeString},
+ },
+
+ "credentials": &schema.Schema{
+ Type: schema.TypeList,
+ Optional: true,
+ Elem: &schema.Resource{
+ Schema: map[string]*schema.Schema{
+ "created_at": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "login": &schema.Schema{
+ Type: schema.TypeString,
+ Required: true,
+ },
+ "password": &schema.Schema{
+ Type: schema.TypeString,
+ Required: true,
+ },
+ },
+ },
+ },
+
+ "open_tracking_settings_active": &schema.Schema{
+ Type: schema.TypeBool,
+ Optional: true,
+ Computed: true,
+ },
+
+ "click_tracking_settings_active": &schema.Schema{
+ Type: schema.TypeBool,
+ Optional: true,
+ Computed: true,
+ },
+
+ "unsubscribe_tracking_settings_active": &schema.Schema{
+ Type: schema.TypeBool,
+ Optional: true,
+ Computed: true,
+ },
+ "unsubscribe_tracking_settings_html_footer": &schema.Schema{
+ Type: schema.TypeString,
+ Optional: true,
+ Computed: true,
+ },
+ "unsubscribe_tracking_settings_text_footer": &schema.Schema{
+ Type: schema.TypeString,
+ Optional: true,
+ Computed: true,
+ },
+
+ "require_tls": &schema.Schema{
+ Type: schema.TypeBool,
+ Default: false,
+ Optional: true,
+ },
+
+ "skip_verification": &schema.Schema{
+ Type: schema.TypeBool,
+ Default: false,
+ Optional: true,
+ },
+
+ "receiving_records": &schema.Schema{
+ Type: schema.TypeList,
+ Computed: true,
+ Elem: &schema.Resource{
+ Schema: map[string]*schema.Schema{
+ "name": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "priority": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "record_type": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "valid": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "value": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ },
+ },
+ },
+
+ "sending_records": &schema.Schema{
+ Type: schema.TypeList,
+ Computed: true,
+ Elem: &schema.Resource{
+ Schema: map[string]*schema.Schema{
+ "name": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "priority": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "record_type": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "valid": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ "value": &schema.Schema{
+ Type: schema.TypeString,
+ Computed: true,
+ },
+ },
+ },
+ },
+ },
+ }
+}
+
+func CreateDomain(d *schema.ResourceData, meta interface{}) error {
+ mg := meta.(*mailgun.MailgunImpl)
+ ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
+ defer cancel()
+
+ log.Printf("[DEBUG] creating mailgun domain: %s", d.Id())
+
+ creationResponse, err := mg.CreateDomain(ctx, d.Get("name").(string), &mailgun.CreateDomainOptions{
+ Password: d.Get("smtp_password").(string),
+ SpamAction: mailgun.SpamAction(d.Get("spam_action").(string)),
+ Wildcard: d.Get("wildcard").(bool),
+ ForceDKIMAuthority: d.Get("force_dkim_authority").(bool),
+ DKIMKeySize: d.Get("dkim_key_size").(int),
+ IPS: d.Get("ips").([]string),
+ })
+
+ if err != nil {
+ return fmt.Errorf("Error creating mailgun domain: %s", err.Error())
+ }
+
+ mg = mailgun.NewMailgun(creationResponse.Domain.Name, mg.APIKey())
+
+ for _, i := range d.Get("credentials").([]interface{}) {
+ credential := i.(map[string]interface{})
+ err = mg.CreateCredential(ctx, credential["login"].(string), credential["password"].(string))
+ if err != nil {
+ return fmt.Errorf("Error creating mailgun credential: %s", err.Error())
+ }
+ }
+
+ err = mg.UpdateUnsubscribeTracking(ctx, creationResponse.Domain.Name, boolToString(d.Get("unsubscribe_tracking_settings_active").(bool)), d.Get("unsubscribe_tracking_settings_html_footer").(string), d.Get("unsubscribe_tracking_settings_text_footer").(string))
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun unsubscribe tracking settings: %s", err.Error())
+ }
+
+ err = mg.UpdateOpenTracking(ctx, creationResponse.Domain.Name, boolToString(d.Get("open_tracking_settings_active").(bool)))
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun open tracking settings: %s", err.Error())
+ }
+
+ err = mg.UpdateClickTracking(ctx, creationResponse.Domain.Name, boolToString(d.Get("click_tracking_settings_active").(bool)))
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun click tracking settings: %s", err.Error())
+ }
+
+ err = mg.UpdateDomainConnection(ctx, creationResponse.Domain.Name, mailgun.DomainConnection{RequireTLS: d.Get("require_tls").(bool), SkipVerification: d.Get("skip_verification").(bool)})
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun connexion settings: %s", err.Error())
+ }
+
+ d.SetId(creationResponse.Domain.Name)
+
+ return ReadDomain(d, meta)
+}
+
+func UpdateDomain(d *schema.ResourceData, meta interface{}) error {
+ mg := meta.(*mailgun.MailgunImpl)
+ ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
+ defer cancel()
+ domainName := d.Get("name").(string)
+ mg = mailgun.NewMailgun(domainName, mg.APIKey())
+
+ log.Printf("[DEBUG] updating mailgun domain: %s", d.Id())
+
+ if d.HasChange("unsubscribe_tracking_settings_active") || d.HasChange("unsubscribe_tracking_settings_html_footer") || d.HasChange("unsubscribe_tracking_settings_text_footer") {
+ err := mg.UpdateUnsubscribeTracking(ctx, domainName, boolToString(d.Get("unsubscribe_tracking_settings_active").(bool)), d.Get("unsubscribe_tracking_settings_html_footer").(string), d.Get("unsubscribe_tracking_settings_text_footer").(string))
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun unsubscribe tracking settings: %s", err.Error())
+ }
+ }
+ if d.HasChange("open_tracking_settings_active") {
+ err := mg.UpdateOpenTracking(ctx, domainName, boolToString(d.Get("open_tracking_settings_active").(bool)))
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun open tracking settings: %s", err.Error())
+ }
+ }
+
+ if d.HasChange("click_tracking_settings_active") {
+ err := mg.UpdateClickTracking(ctx, domainName, boolToString(d.Get("click_tracking_settings_active").(bool)))
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun click tracking settings: %s", err.Error())
+ }
+ }
+
+ if d.HasChange("require_tls") || d.HasChange("skip_verification") {
+ err := mg.UpdateDomainConnection(ctx, domainName, mailgun.DomainConnection{RequireTLS: d.Get("require_tls").(bool), SkipVerification: d.Get("skip_verification").(bool)})
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun connexion settings: %s", err.Error())
+ }
+ }
+
+ if d.HasChange("credentials") {
+ old, new := d.GetChange("credentials")
+ for _, i := range old.([]interface{}) {
+ oldCredential := i.(map[string]interface{})
+ found := false
+ for _, j := range new.([]interface{}) {
+ newCredential := j.(map[string]interface{})
+ if oldCredential["login"] == newCredential["login"] {
+ found = true
+ if oldCredential["password"] != newCredential["password"] {
+ err := mg.ChangeCredentialPassword(ctx, oldCredential["login"].(string), newCredential["password"].(string))
+ if err != nil {
+ return fmt.Errorf("Error updating mailgun credential password: %s", err.Error())
+ }
+ }
+ break
+ }
+ }
+ if !found {
+ err := mg.DeleteCredential(ctx, oldCredential["login"].(string))
+ if err != nil {
+ return fmt.Errorf("Error deleting mailgun credential : %s", err.Error())
+ }
+ }
+ }
+
+ for _, i := range new.([]interface{}) {
+ newCredential := i.(map[string]interface{})
+ found := false
+ for _, j := range old.([]interface{}) {
+ oldCredential := j.(map[string]interface{})
+ if oldCredential["login"] == newCredential["login"] {
+ found = true
+ break
+ }
+ }
+ if !found {
+ err := mg.CreateCredential(ctx, newCredential["login"].(string), newCredential["password"].(string))
+ if err != nil {
+ return fmt.Errorf("Error creating mailgun credential : %s", err.Error())
+ }
+ }
+ }
+ }
+
+ return ReadDomain(d, meta)
+}
+
+func DeleteDomain(d *schema.ResourceData, meta interface{}) error {
+ mg := meta.(*mailgun.MailgunImpl)
+ ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
+ defer cancel()
+
+ log.Printf("[DEBUG] Deleting mailgun domain: %s", d.Id())
+
+ err := mg.DeleteDomain(ctx, d.Get("name").(string))
+
+ return err
+}
+
+func ReadDomain(d *schema.ResourceData, meta interface{}) error {
+ mg := meta.(*mailgun.MailgunImpl)
+ ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
+ defer cancel()
+
+ domainName := d.Get("name").(string)
+
+ domainResponse, err := mg.GetDomain(ctx, domainName)
+ if err != nil {
+ return fmt.Errorf("Error Getting mailgun domain Details for %s: Error: %s", d.Id(), err)
+ }
+
+ d.Set("created_at", domainResponse.Domain.CreatedAt)
+ d.Set("smtd_login", domainResponse.Domain.SMTPLogin)
+ d.Set("name", domainResponse.Domain.Name)
+ d.Set("smtd_password", domainResponse.Domain.SMTPPassword)
+ d.Set("wildcard", domainResponse.Domain.Wildcard)
+ d.Set("spam_action", domainResponse.Domain.SpamAction)
+ d.Set("state", domainResponse.Domain.State)
+
+ simpleReceivingRecords := make([]map[string]interface{}, len(domainResponse.ReceivingDNSRecords))
+ for i, r := range domainResponse.ReceivingDNSRecords {
+ simpleReceivingRecords[i] = make(map[string]interface{})
+ simpleReceivingRecords[i]["priority"] = r.Priority
+ simpleReceivingRecords[i]["name"] = r.Name
+ simpleReceivingRecords[i]["valid"] = r.Valid
+ simpleReceivingRecords[i]["value"] = r.Value
+ simpleReceivingRecords[i]["record_type"] = r.RecordType
+ }
+ d.Set("receiving_records", simpleReceivingRecords)
+
+ simpleSendingRecords := make([]map[string]interface{}, len(domainResponse.SendingDNSRecords))
+ for i, r := range domainResponse.SendingDNSRecords {
+ simpleSendingRecords[i] = make(map[string]interface{})
+ simpleSendingRecords[i]["name"] = r.Name
+ simpleSendingRecords[i]["priority"] = r.Priority
+ simpleSendingRecords[i]["valid"] = r.Valid
+ simpleSendingRecords[i]["value"] = r.Value
+ simpleSendingRecords[i]["record_type"] = r.RecordType
+ }
+ d.Set("sending_records", simpleSendingRecords)
+
+ domainConnection, err := mg.GetDomainConnection(ctx, domainName)
+ if err != nil {
+ return fmt.Errorf("Error Getting mailgun domain connection Details for %s: Error: %s", d.Id(), err)
+ }
+ d.Set("require_tls", domainConnection.RequireTLS)
+ d.Set("skip_verification", domainConnection.SkipVerification)
+
+ domainTracking, err := mg.GetDomainTracking(ctx, domainName)
+ if err != nil {
+ return fmt.Errorf("Error Getting mailgun domain tracking Details for %s: Error: %s", d.Id(), err)
+ }
+
+ d.Set("open_tracking_settings_active", domainTracking.Open.Active)
+
+ d.Set("click_tracking_settings_active", domainTracking.Click.Active)
+ d.Set("unsubscribe_tracking_settings_active", domainTracking.Unsubscribe.Active)
+ d.Set("unsubscribe_tracking_settings_html_footer", domainTracking.Unsubscribe.HTMLFooter)
+ d.Set("unsubscribe_tracking_settings_text_footer", domainTracking.Unsubscribe.TextFooter)
+
+ ipAddress, err := mg.ListDomainIPS(ctx)
+ if err != nil {
+ return fmt.Errorf("Error Getting mailgun domain ips for %s: Error: %s", d.Id(), err)
+ }
+ ips := make([]string, len(ipAddress))
+ for i, r := range ipAddress {
+ ips[i] = r.IP
+
+ }
+ d.Set("ips", ips)
+
+ credentialsResponse, err := ListCredentials(domainName, mg.APIKey())
+ credentials := make([]map[string]interface{}, len(credentialsResponse))
+ for i, r := range credentialsResponse {
+ credentials[i] = make(map[string]interface{})
+ credentials[i]["created_at"] = r.CreatedAt
+ credentials[i]["login"] = r.Login
+ credentials[i]["password"] = r.Password
+ }
+ d.Set("credentials", credentials)
+
+ d.SetId(domainName)
+
+ return nil
+}
+
+func boolToString(b bool) string {
+ if b {
+ return "true"
+ }
+ return "false"
+}
+
+func ListCredentials(domain, apiKey string) ([]mailgun.Credential, error) {
+ mg := mailgun.NewMailgun(domain, apiKey)
+ it := mg.ListCredentials(nil)
+
+ ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
+ defer cancel()
+
+ var page, result []mailgun.Credential
+ for it.Next(ctx, &page) {
+ result = append(result, page...)
+ }
+
+ if it.Err() != nil {
+ return nil, it.Err()
+ }
+ return result, nil
+}
projects / github / fretlink / terraform-provider-mailgun.git / commitdiff
