2 files changed, 472 insertions, 1 deletions

diff --git a/mailgun/provider.go b/mailgun/provider.go
index 8771c48..32ec890 100644
--- a/mailgun/provider.go
+++ b/mailgun/provider.go
@@ -23,7 +23,9 @@ func Provider() terraform.ResourceProvider {
                         },
                 },
 
-                ResourcesMap: map[string]*schema.Resource{},
+                ResourcesMap: map[string]*schema.Resource{
+                        "mailgun_domain": resourceMailgunDomain(),
+                },
 
                 ConfigureFunc: providerConfigure,
         }
diff --git a/mailgun/resource_mailgun_domain.go b/mailgun/resource_mailgun_domain.go
new file mode 100644
index 0000000..028c99f
--- /dev/null
+++ b/mailgun/resource_mailgun_domain.go
@@ -0,0 +1,469 @@
+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
+}