6 "github.com/hashicorp/terraform/helper/schema"
7 "github.com/mailgun/mailgun-go/v3"
12 func resourceMailgunDomain() *schema.Resource {
13 return &schema.Resource{
18 Importer: &schema.ResourceImporter{
19 State: ImportStatePassthroughDomain,
22 Schema: map[string]*schema.Schema{
23 "name": &schema.Schema{
24 Type: schema.TypeString,
29 "spam_action": &schema.Schema{
30 Type: schema.TypeString,
36 "smtp_password": &schema.Schema{
37 Type: schema.TypeString,
42 "smtp_login": &schema.Schema{
43 Type: schema.TypeString,
47 "wildcard": &schema.Schema{
48 Type: schema.TypeBool,
54 "created_at": &schema.Schema{
55 Type: schema.TypeString,
60 "state": &schema.Schema{
61 Type: schema.TypeString,
65 "force_dkim_authority": &schema.Schema{
66 Type: schema.TypeBool,
71 "dkim_key_size": &schema.Schema{
78 "ips": &schema.Schema{
79 Type: schema.TypeList,
83 Elem: &schema.Schema{Type: schema.TypeString},
86 "credentials": &schema.Schema{
87 Type: schema.TypeList,
89 Elem: &schema.Resource{
90 Schema: map[string]*schema.Schema{
91 "created_at": &schema.Schema{
92 Type: schema.TypeString,
95 "login": &schema.Schema{
96 Type: schema.TypeString,
99 "password": &schema.Schema{
100 Type: schema.TypeString,
107 "open_tracking_settings_active": &schema.Schema{
108 Type: schema.TypeBool,
113 "click_tracking_settings_active": &schema.Schema{
114 Type: schema.TypeBool,
119 "unsubscribe_tracking_settings_active": &schema.Schema{
120 Type: schema.TypeBool,
124 "unsubscribe_tracking_settings_html_footer": &schema.Schema{
125 Type: schema.TypeString,
127 Default: "\n<br>\n<p><a href=\"%unsubscribe_url%\">unsubscribe</a></p>\n",
129 "unsubscribe_tracking_settings_text_footer": &schema.Schema{
130 Type: schema.TypeString,
132 Default: "\n\nTo unsubscribe click: <%unsubscribe_url%>\n\n",
135 "require_tls": &schema.Schema{
136 Type: schema.TypeBool,
141 "skip_verification": &schema.Schema{
142 Type: schema.TypeBool,
147 "receiving_records": &schema.Schema{
148 Type: schema.TypeList,
150 Elem: &schema.Resource{
151 Schema: map[string]*schema.Schema{
152 "name": &schema.Schema{
153 Type: schema.TypeString,
156 "priority": &schema.Schema{
157 Type: schema.TypeString,
160 "record_type": &schema.Schema{
161 Type: schema.TypeString,
164 "valid": &schema.Schema{
165 Type: schema.TypeString,
168 "value": &schema.Schema{
169 Type: schema.TypeString,
176 "sending_records": &schema.Schema{
177 Type: schema.TypeList,
179 Elem: &schema.Resource{
180 Schema: map[string]*schema.Schema{
181 "name": &schema.Schema{
182 Type: schema.TypeString,
185 "priority": &schema.Schema{
186 Type: schema.TypeString,
189 "record_type": &schema.Schema{
190 Type: schema.TypeString,
193 "valid": &schema.Schema{
194 Type: schema.TypeString,
197 "value": &schema.Schema{
198 Type: schema.TypeString,
208 func interfaceToStringTab(i interface{}) []string {
209 aInterface := i.([]interface{})
210 aString := make([]string, len(aInterface))
211 for i, v := range aInterface {
212 aString[i] = v.(string)
216 func CreateDomain(d *schema.ResourceData, meta interface{}) error {
217 mg := meta.(*mailgun.MailgunImpl)
218 ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
221 log.Printf("[DEBUG] creating mailgun domain: %s", d.Id())
223 creationResponse, err := mg.CreateDomain(ctx, d.Get("name").(string), &mailgun.CreateDomainOptions{
224 Password: d.Get("smtp_password").(string),
225 SpamAction: mailgun.SpamAction(d.Get("spam_action").(string)),
226 Wildcard: d.Get("wildcard").(bool),
227 ForceDKIMAuthority: d.Get("force_dkim_authority").(bool),
228 DKIMKeySize: d.Get("dkim_key_size").(int),
229 IPS: interfaceToStringTab(d.Get("ips")),
233 return fmt.Errorf("Error creating mailgun domain: %s", err.Error())
236 mg = mailgun.NewMailgun(creationResponse.Domain.Name, mg.APIKey())
238 for _, i := range d.Get("credentials").([]interface{}) {
239 credential := i.(map[string]interface{})
240 err = mg.CreateCredential(ctx, credential["login"].(string), credential["password"].(string))
242 return fmt.Errorf("Error creating mailgun credential: %s", err.Error())
246 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))
248 return fmt.Errorf("Error updating mailgun unsubscribe tracking settings: %s", err.Error())
251 err = mg.UpdateOpenTracking(ctx, creationResponse.Domain.Name, boolToString(d.Get("open_tracking_settings_active").(bool)))
253 return fmt.Errorf("Error updating mailgun open tracking settings: %s", err.Error())
256 err = mg.UpdateClickTracking(ctx, creationResponse.Domain.Name, boolToString(d.Get("click_tracking_settings_active").(bool)))
258 return fmt.Errorf("Error updating mailgun click tracking settings: %s", err.Error())
261 err = mg.UpdateDomainConnection(ctx, creationResponse.Domain.Name, mailgun.DomainConnection{RequireTLS: d.Get("require_tls").(bool), SkipVerification: d.Get("skip_verification").(bool)})
263 return fmt.Errorf("Error updating mailgun connexion settings: %s", err.Error())
266 d.SetId(creationResponse.Domain.Name)
268 return ReadDomain(d, meta)
271 func UpdateDomain(d *schema.ResourceData, meta interface{}) error {
272 mg := meta.(*mailgun.MailgunImpl)
273 ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
275 domainName := d.Get("name").(string)
276 mg = mailgun.NewMailgun(domainName, mg.APIKey())
278 log.Printf("[DEBUG] updating mailgun domain: %s", d.Id())
280 if d.HasChange("unsubscribe_tracking_settings_active") || d.HasChange("unsubscribe_tracking_settings_html_footer") || d.HasChange("unsubscribe_tracking_settings_text_footer") {
281 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))
283 return fmt.Errorf("Error updating mailgun unsubscribe tracking settings: %s", err.Error())
286 if d.HasChange("open_tracking_settings_active") {
287 err := mg.UpdateOpenTracking(ctx, domainName, boolToString(d.Get("open_tracking_settings_active").(bool)))
289 return fmt.Errorf("Error updating mailgun open tracking settings: %s", err.Error())
293 if d.HasChange("click_tracking_settings_active") {
294 err := mg.UpdateClickTracking(ctx, domainName, boolToString(d.Get("click_tracking_settings_active").(bool)))
296 return fmt.Errorf("Error updating mailgun click tracking settings: %s", err.Error())
300 if d.HasChange("require_tls") || d.HasChange("skip_verification") {
301 err := mg.UpdateDomainConnection(ctx, domainName, mailgun.DomainConnection{RequireTLS: d.Get("require_tls").(bool), SkipVerification: d.Get("skip_verification").(bool)})
303 return fmt.Errorf("Error updating mailgun connexion settings: %s", err.Error())
307 if d.HasChange("credentials") {
308 old, new := d.GetChange("credentials")
309 for _, i := range old.([]interface{}) {
310 oldCredential := i.(map[string]interface{})
312 for _, j := range new.([]interface{}) {
313 newCredential := j.(map[string]interface{})
314 if oldCredential["login"] == newCredential["login"] {
316 if oldCredential["password"] != newCredential["password"] {
317 err := mg.ChangeCredentialPassword(ctx, oldCredential["login"].(string), newCredential["password"].(string))
319 return fmt.Errorf("Error updating mailgun credential password: %s", err.Error())
326 err := mg.DeleteCredential(ctx, oldCredential["login"].(string))
328 return fmt.Errorf("Error deleting mailgun credential : %s", err.Error())
333 for _, i := range new.([]interface{}) {
334 newCredential := i.(map[string]interface{})
336 for _, j := range old.([]interface{}) {
337 oldCredential := j.(map[string]interface{})
338 if oldCredential["login"] == newCredential["login"] {
344 err := mg.CreateCredential(ctx, newCredential["login"].(string), newCredential["password"].(string))
346 return fmt.Errorf("Error creating mailgun credential : %s", err.Error())
352 return ReadDomain(d, meta)
355 func DeleteDomain(d *schema.ResourceData, meta interface{}) error {
356 mg := meta.(*mailgun.MailgunImpl)
357 ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
360 log.Printf("[DEBUG] Deleting mailgun domain: %s", d.Id())
362 err := mg.DeleteDomain(ctx, d.Get("name").(string))
367 func ReadDomain(d *schema.ResourceData, meta interface{}) error {
368 mg := meta.(*mailgun.MailgunImpl)
369 ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
372 mg = mailgun.NewMailgun(domainName, mg.APIKey())
374 domainResponse, err := mg.GetDomain(ctx, domainName)
376 return fmt.Errorf("Error Getting mailgun domain Details for %s: Error: %s", d.Id(), err)
379 d.Set("created_at", domainResponse.Domain.CreatedAt)
380 d.Set("smtd_login", domainResponse.Domain.SMTPLogin)
381 d.Set("name", domainResponse.Domain.Name)
382 d.Set("smtd_password", domainResponse.Domain.SMTPPassword)
383 d.Set("wildcard", domainResponse.Domain.Wildcard)
384 d.Set("spam_action", domainResponse.Domain.SpamAction)
385 d.Set("state", domainResponse.Domain.State)
387 simpleReceivingRecords := make([]map[string]interface{}, len(domainResponse.ReceivingDNSRecords))
388 for i, r := range domainResponse.ReceivingDNSRecords {
389 simpleReceivingRecords[i] = make(map[string]interface{})
390 simpleReceivingRecords[i]["priority"] = r.Priority
391 simpleReceivingRecords[i]["name"] = r.Name
392 simpleReceivingRecords[i]["valid"] = r.Valid
393 simpleReceivingRecords[i]["value"] = r.Value
394 simpleReceivingRecords[i]["record_type"] = r.RecordType
396 d.Set("receiving_records", simpleReceivingRecords)
398 simpleSendingRecords := make([]map[string]interface{}, len(domainResponse.SendingDNSRecords))
399 for i, r := range domainResponse.SendingDNSRecords {
400 simpleSendingRecords[i] = make(map[string]interface{})
401 simpleSendingRecords[i]["name"] = r.Name
402 simpleSendingRecords[i]["priority"] = r.Priority
403 simpleSendingRecords[i]["valid"] = r.Valid
404 simpleSendingRecords[i]["value"] = r.Value
405 simpleSendingRecords[i]["record_type"] = r.RecordType
407 d.Set("sending_records", simpleSendingRecords)
409 domainConnection, err := mg.GetDomainConnection(ctx, domainName)
411 return fmt.Errorf("Error Getting mailgun domain connection Details for %s: Error: %s", d.Id(), err)
413 d.Set("require_tls", domainConnection.RequireTLS)
414 d.Set("skip_verification", domainConnection.SkipVerification)
416 domainTracking, err := mg.GetDomainTracking(ctx, domainName)
418 return fmt.Errorf("Error Getting mailgun domain tracking Details for %s: Error: %s", d.Id(), err)
421 d.Set("open_tracking_settings_active", domainTracking.Open.Active)
423 d.Set("click_tracking_settings_active", domainTracking.Click.Active)
424 d.Set("unsubscribe_tracking_settings_active", domainTracking.Unsubscribe.Active)
425 d.Set("unsubscribe_tracking_settings_html_footer", domainTracking.Unsubscribe.HTMLFooter)
426 d.Set("unsubscribe_tracking_settings_text_footer", domainTracking.Unsubscribe.TextFooter)
428 time.Sleep(25 * time.Second)
430 ipAddress, err := mg.ListDomainIPS(ctx)
433 return fmt.Errorf("Error Getting mailgun domain ips1 for %s: Error: %s", d.Id(), err)
435 ips := make([]string, len(ipAddress))
436 for i, r := range ipAddress {
442 credentialsResponse, err := ListCredentials(domainName, mg.APIKey())
444 return fmt.Errorf("Error Getting mailgun credentials for %s: Error: %s", d.Id(), err)
447 credentials := make([]map[string]interface{}, len(credentialsResponse))
448 for i, r := range credentialsResponse {
449 credentials[i] = make(map[string]interface{})
450 credentials[i]["created_at"] = r.CreatedAt
451 credentials[i]["login"] = r.Login
452 credentials[i]["password"] = r.Password
454 d.Set("credentials", credentials)
461 func boolToString(b bool) string {
468 func ListCredentials(domain, apiKey string) ([]mailgun.Credential, error) {
469 mg := mailgun.NewMailgun(domain, apiKey)
470 it := mg.ListCredentials(nil)
472 ctx, cancel := context.WithTimeout(context.Background(), time.Second*30)
475 var page, result []mailgun.Credential
476 for it.Next(ctx, &page) {
477 result = append(result, page...)
486 func ImportStatePassthroughDomain(d *schema.ResourceData, meta interface{}) ([]*schema.ResourceData, error) {
487 if _, ok := d.GetOk("dkim_key_size"); !ok {
488 d.Set("dkim_key_size", 1024)
491 if _, ok := d.GetOk("force_dkim_authority"); !ok {
492 d.Set("force_dkim_authority", false)
494 return []*schema.ResourceData{d}, nil