2014-07-23 06:03:30 +02:00
|
|
|
package heroku
|
|
|
|
|
|
|
|
import (
|
|
|
|
"fmt"
|
|
|
|
"log"
|
|
|
|
|
2014-08-27 16:50:37 +02:00
|
|
|
"github.com/cyberdelia/heroku-go/v3"
|
2014-07-23 18:09:27 +02:00
|
|
|
"github.com/hashicorp/terraform/helper/multierror"
|
2014-08-18 18:32:40 +02:00
|
|
|
"github.com/hashicorp/terraform/helper/schema"
|
2014-07-23 06:03:30 +02:00
|
|
|
)
|
|
|
|
|
2014-07-23 18:09:27 +02:00
|
|
|
// type application is used to store all the details of a heroku app
|
|
|
|
type application struct {
|
|
|
|
Id string // Id of the resource
|
|
|
|
|
|
|
|
App *heroku.App // The heroku application
|
2014-08-27 16:50:37 +02:00
|
|
|
Client *heroku.Service // Client to interact with the heroku API
|
2014-07-23 18:09:27 +02:00
|
|
|
Vars map[string]string // The vars on the application
|
|
|
|
}
|
|
|
|
|
|
|
|
// Updates the application to have the latest from remote
|
|
|
|
func (a *application) Update() error {
|
|
|
|
var errs []error
|
|
|
|
var err error
|
|
|
|
|
|
|
|
a.App, err = a.Client.AppInfo(a.Id)
|
|
|
|
if err != nil {
|
|
|
|
errs = append(errs, err)
|
|
|
|
}
|
|
|
|
|
2014-12-15 15:26:17 +01:00
|
|
|
a.Vars, err = retrieveConfigVars(a.Id, a.Client)
|
2014-07-23 18:09:27 +02:00
|
|
|
if err != nil {
|
|
|
|
errs = append(errs, err)
|
|
|
|
}
|
|
|
|
|
|
|
|
if len(errs) > 0 {
|
|
|
|
return &multierror.Error{Errors: errs}
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
func resourceHerokuApp() *schema.Resource {
|
|
|
|
return &schema.Resource{
|
2014-10-12 18:49:57 +02:00
|
|
|
Create: switchHerokuAppCreate,
|
2014-08-18 18:32:40 +02:00
|
|
|
Read: resourceHerokuAppRead,
|
|
|
|
Update: resourceHerokuAppUpdate,
|
|
|
|
Delete: resourceHerokuAppDelete,
|
|
|
|
|
|
|
|
Schema: map[string]*schema.Schema{
|
|
|
|
"name": &schema.Schema{
|
|
|
|
Type: schema.TypeString,
|
2014-08-28 00:50:38 +02:00
|
|
|
Required: true,
|
2014-08-18 18:32:40 +02:00
|
|
|
},
|
|
|
|
|
|
|
|
"region": &schema.Schema{
|
|
|
|
Type: schema.TypeString,
|
2014-08-28 00:50:38 +02:00
|
|
|
Required: true,
|
|
|
|
ForceNew: true,
|
2014-08-18 18:32:40 +02:00
|
|
|
},
|
|
|
|
|
|
|
|
"stack": &schema.Schema{
|
|
|
|
Type: schema.TypeString,
|
|
|
|
Optional: true,
|
|
|
|
Computed: true,
|
2014-08-18 18:36:37 +02:00
|
|
|
ForceNew: true,
|
2014-08-18 18:32:40 +02:00
|
|
|
},
|
|
|
|
|
|
|
|
"config_vars": &schema.Schema{
|
|
|
|
Type: schema.TypeList,
|
|
|
|
Optional: true,
|
|
|
|
Elem: &schema.Schema{
|
2014-08-19 00:18:51 +02:00
|
|
|
Type: schema.TypeMap,
|
2014-08-18 18:32:40 +02:00
|
|
|
},
|
|
|
|
},
|
|
|
|
|
2014-08-28 01:34:43 +02:00
|
|
|
"all_config_vars": &schema.Schema{
|
|
|
|
Type: schema.TypeMap,
|
|
|
|
Computed: true,
|
|
|
|
},
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
"git_url": &schema.Schema{
|
|
|
|
Type: schema.TypeString,
|
|
|
|
Computed: true,
|
|
|
|
},
|
|
|
|
|
|
|
|
"web_url": &schema.Schema{
|
|
|
|
Type: schema.TypeString,
|
|
|
|
Computed: true,
|
|
|
|
},
|
|
|
|
|
|
|
|
"heroku_hostname": &schema.Schema{
|
|
|
|
Type: schema.TypeString,
|
|
|
|
Computed: true,
|
|
|
|
},
|
2014-10-10 18:54:33 +02:00
|
|
|
|
2014-10-12 18:49:57 +02:00
|
|
|
"organization": &schema.Schema{
|
2014-10-12 19:21:32 +02:00
|
|
|
Description: "Name of Organization to create application in. Leave blank for personal apps.",
|
2014-10-12 20:01:47 +02:00
|
|
|
Type: schema.TypeList,
|
2014-10-12 19:21:32 +02:00
|
|
|
Optional: true,
|
|
|
|
ForceNew: true,
|
2014-10-12 20:01:47 +02:00
|
|
|
Elem: &schema.Resource{
|
|
|
|
Schema: map[string]*schema.Schema{
|
|
|
|
"name": &schema.Schema{
|
|
|
|
Type: schema.TypeString,
|
|
|
|
Required: true,
|
|
|
|
},
|
|
|
|
|
|
|
|
"locked": &schema.Schema{
|
|
|
|
Type: schema.TypeBool,
|
|
|
|
Optional: true,
|
|
|
|
},
|
|
|
|
|
|
|
|
"personal": &schema.Schema{
|
|
|
|
Type: schema.TypeBool,
|
|
|
|
Optional: true,
|
|
|
|
},
|
|
|
|
},
|
|
|
|
},
|
2014-10-12 18:49:57 +02:00
|
|
|
},
|
2014-08-18 18:32:40 +02:00
|
|
|
},
|
|
|
|
}
|
|
|
|
}
|
2014-07-23 06:03:30 +02:00
|
|
|
|
2014-10-10 18:54:33 +02:00
|
|
|
func switchHerokuAppCreate(d *schema.ResourceData, meta interface{}) error {
|
2014-10-12 20:01:47 +02:00
|
|
|
orgCount := d.Get("organization.#").(int)
|
|
|
|
if orgCount > 1 {
|
2014-10-21 20:00:12 +02:00
|
|
|
return fmt.Errorf("Error Creating Heroku App: Only 1 Heroku Organization is permitted")
|
2014-10-12 20:01:47 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
if _, ok := d.GetOk("organization.0.name"); ok {
|
2014-10-12 18:49:57 +02:00
|
|
|
return resourceHerokuOrgAppCreate(d, meta)
|
|
|
|
} else {
|
|
|
|
return resourceHerokuAppCreate(d, meta)
|
|
|
|
}
|
2014-10-10 18:54:33 +02:00
|
|
|
}
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
func resourceHerokuAppCreate(d *schema.ResourceData, meta interface{}) error {
|
2014-08-27 16:50:37 +02:00
|
|
|
client := meta.(*heroku.Service)
|
2014-07-23 06:03:30 +02:00
|
|
|
|
|
|
|
// Build up our creation options
|
|
|
|
opts := heroku.AppCreateOpts{}
|
|
|
|
|
2014-10-14 21:18:18 +02:00
|
|
|
if v, ok := d.GetOk("name"); ok {
|
2014-08-18 18:32:40 +02:00
|
|
|
vs := v.(string)
|
2014-08-19 00:18:51 +02:00
|
|
|
log.Printf("[DEBUG] App name: %s", vs)
|
2014-08-18 18:32:40 +02:00
|
|
|
opts.Name = &vs
|
2014-07-23 06:03:30 +02:00
|
|
|
}
|
2014-10-14 21:18:18 +02:00
|
|
|
if v, ok := d.GetOk("region"); ok {
|
2014-08-18 18:32:40 +02:00
|
|
|
vs := v.(string)
|
2014-08-19 00:18:51 +02:00
|
|
|
log.Printf("[DEBUG] App region: %s", vs)
|
2014-08-18 18:32:40 +02:00
|
|
|
opts.Region = &vs
|
2014-07-23 06:03:30 +02:00
|
|
|
}
|
2014-10-14 21:18:18 +02:00
|
|
|
if v, ok := d.GetOk("stack"); ok {
|
2014-08-18 18:32:40 +02:00
|
|
|
vs := v.(string)
|
2014-08-19 00:18:51 +02:00
|
|
|
log.Printf("[DEBUG] App stack: %s", vs)
|
2014-08-18 18:32:40 +02:00
|
|
|
opts.Stack = &vs
|
2014-07-23 06:03:30 +02:00
|
|
|
}
|
|
|
|
|
2014-08-19 00:18:51 +02:00
|
|
|
log.Printf("[DEBUG] Creating Heroku app...")
|
2014-08-27 16:50:37 +02:00
|
|
|
a, err := client.AppCreate(opts)
|
2014-07-23 06:03:30 +02:00
|
|
|
if err != nil {
|
2014-08-18 18:32:40 +02:00
|
|
|
return err
|
2014-07-23 06:03:30 +02:00
|
|
|
}
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
d.SetId(a.Name)
|
|
|
|
log.Printf("[INFO] App ID: %s", d.Id())
|
2014-07-23 17:09:05 +02:00
|
|
|
|
2014-10-14 21:18:18 +02:00
|
|
|
if v, ok := d.GetOk("config_vars"); ok {
|
2014-12-15 15:26:17 +01:00
|
|
|
err = updateConfigVars(d.Id(), client, nil, v.([]interface{}))
|
2014-07-23 17:09:05 +02:00
|
|
|
if err != nil {
|
2014-08-18 18:32:40 +02:00
|
|
|
return err
|
2014-07-23 17:09:05 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
return resourceHerokuAppRead(d, meta)
|
|
|
|
}
|
|
|
|
|
2014-10-10 18:54:33 +02:00
|
|
|
func resourceHerokuOrgAppCreate(d *schema.ResourceData, meta interface{}) error {
|
2014-10-12 18:49:57 +02:00
|
|
|
client := meta.(*heroku.Service)
|
|
|
|
// Build up our creation options
|
|
|
|
opts := heroku.OrganizationAppCreateOpts{}
|
2014-10-12 20:01:47 +02:00
|
|
|
|
|
|
|
if v := d.Get("organization.0.name"); v != nil {
|
2014-10-12 18:49:57 +02:00
|
|
|
vs := v.(string)
|
2014-10-12 20:01:47 +02:00
|
|
|
log.Printf("[DEBUG] Organization name: %s", vs)
|
2014-10-12 18:49:57 +02:00
|
|
|
opts.Organization = &vs
|
|
|
|
}
|
2014-10-12 20:01:47 +02:00
|
|
|
|
|
|
|
if v := d.Get("organization.0.personal"); v != nil {
|
|
|
|
vs := v.(bool)
|
|
|
|
log.Printf("[DEBUG] Organization Personal: %s", vs)
|
|
|
|
opts.Personal = &vs
|
|
|
|
}
|
|
|
|
|
|
|
|
if v := d.Get("organization.0.locked"); v != nil {
|
|
|
|
vs := v.(bool)
|
|
|
|
log.Printf("[DEBUG] Organization locked: %s", vs)
|
|
|
|
opts.Locked = &vs
|
|
|
|
}
|
|
|
|
|
|
|
|
if v := d.Get("name"); v != nil {
|
2014-10-12 18:49:57 +02:00
|
|
|
vs := v.(string)
|
|
|
|
log.Printf("[DEBUG] App name: %s", vs)
|
|
|
|
opts.Name = &vs
|
|
|
|
}
|
2014-10-14 21:18:18 +02:00
|
|
|
if v, ok := d.GetOk("region"); ok {
|
2014-10-12 18:49:57 +02:00
|
|
|
vs := v.(string)
|
|
|
|
log.Printf("[DEBUG] App region: %s", vs)
|
|
|
|
opts.Region = &vs
|
|
|
|
}
|
2014-10-14 21:18:18 +02:00
|
|
|
if v, ok := d.GetOk("stack"); ok {
|
2014-10-12 18:49:57 +02:00
|
|
|
vs := v.(string)
|
|
|
|
log.Printf("[DEBUG] App stack: %s", vs)
|
|
|
|
opts.Stack = &vs
|
|
|
|
}
|
|
|
|
|
|
|
|
log.Printf("[DEBUG] Creating Heroku app...")
|
|
|
|
a, err := client.OrganizationAppCreate(opts)
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
|
|
|
|
d.SetId(a.Name)
|
|
|
|
log.Printf("[INFO] App ID: %s", d.Id())
|
|
|
|
|
2014-10-14 21:18:18 +02:00
|
|
|
if v, ok := d.GetOk("config_vars"); ok {
|
2014-12-15 15:26:17 +01:00
|
|
|
err = updateConfigVars(d.Id(), client, nil, v.([]interface{}))
|
2014-10-12 18:49:57 +02:00
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return resourceHerokuAppRead(d, meta)
|
2014-10-10 18:54:33 +02:00
|
|
|
}
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
func resourceHerokuAppRead(d *schema.ResourceData, meta interface{}) error {
|
2014-08-27 16:50:37 +02:00
|
|
|
client := meta.(*heroku.Service)
|
2014-12-15 15:26:17 +01:00
|
|
|
app, err := resourceHerokuAppRetrieve(d.Id(), client)
|
2014-07-23 17:09:05 +02:00
|
|
|
if err != nil {
|
2014-08-18 18:32:40 +02:00
|
|
|
return err
|
2014-07-23 17:09:05 +02:00
|
|
|
}
|
|
|
|
|
2014-08-28 01:34:43 +02:00
|
|
|
// Only set the config_vars that we have set in the configuration.
|
|
|
|
// The "all_config_vars" field has all of them.
|
|
|
|
configVars := make(map[string]string)
|
2014-08-28 01:26:03 +02:00
|
|
|
care := make(map[string]struct{})
|
|
|
|
for _, v := range d.Get("config_vars").([]interface{}) {
|
|
|
|
for k, _ := range v.(map[string]interface{}) {
|
|
|
|
care[k] = struct{}{}
|
|
|
|
}
|
|
|
|
}
|
2014-08-28 01:34:43 +02:00
|
|
|
for k, v := range app.Vars {
|
2014-08-28 06:07:56 +02:00
|
|
|
if _, ok := care[k]; ok {
|
2014-08-28 01:34:43 +02:00
|
|
|
configVars[k] = v
|
2014-08-28 01:26:03 +02:00
|
|
|
}
|
|
|
|
}
|
2014-08-28 06:07:56 +02:00
|
|
|
var configVarsValue []map[string]string
|
|
|
|
if len(configVars) > 0 {
|
|
|
|
configVarsValue = []map[string]string{configVars}
|
|
|
|
}
|
2014-08-28 01:26:03 +02:00
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
d.Set("name", app.App.Name)
|
|
|
|
d.Set("stack", app.App.Stack.Name)
|
|
|
|
d.Set("region", app.App.Region.Name)
|
|
|
|
d.Set("git_url", app.App.GitURL)
|
|
|
|
d.Set("web_url", app.App.WebURL)
|
2014-08-28 06:07:56 +02:00
|
|
|
d.Set("config_vars", configVarsValue)
|
2014-08-28 01:34:43 +02:00
|
|
|
d.Set("all_config_vars", app.Vars)
|
2014-07-23 06:03:30 +02:00
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
// We know that the hostname on heroku will be the name+herokuapp.com
|
|
|
|
// You need this to do things like create DNS CNAME records
|
|
|
|
d.Set("heroku_hostname", fmt.Sprintf("%s.herokuapp.com", app.App.Name))
|
2014-07-23 18:38:45 +02:00
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
return nil
|
|
|
|
}
|
2014-07-23 18:38:45 +02:00
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
func resourceHerokuAppUpdate(d *schema.ResourceData, meta interface{}) error {
|
2014-08-27 16:50:37 +02:00
|
|
|
client := meta.(*heroku.Service)
|
2014-07-23 18:38:45 +02:00
|
|
|
|
2014-08-19 00:18:51 +02:00
|
|
|
// If name changed, update it
|
|
|
|
if d.HasChange("name") {
|
|
|
|
v := d.Get("name").(string)
|
|
|
|
opts := heroku.AppUpdateOpts{
|
|
|
|
Name: &v,
|
|
|
|
}
|
2014-07-23 19:56:47 +02:00
|
|
|
|
2014-08-27 16:50:37 +02:00
|
|
|
renamedApp, err := client.AppUpdate(d.Id(), opts)
|
2014-08-19 00:18:51 +02:00
|
|
|
if err != nil {
|
|
|
|
return err
|
2014-07-23 20:46:12 +02:00
|
|
|
}
|
|
|
|
|
2014-08-19 00:18:51 +02:00
|
|
|
// Store the new ID
|
|
|
|
d.SetId(renamedApp.Name)
|
|
|
|
}
|
|
|
|
|
2014-08-19 19:13:34 +02:00
|
|
|
// If the config vars changed, then recalculate those
|
|
|
|
if d.HasChange("config_vars") {
|
|
|
|
o, n := d.GetChange("config_vars")
|
|
|
|
if o == nil {
|
|
|
|
o = []interface{}{}
|
|
|
|
}
|
|
|
|
if n == nil {
|
|
|
|
n = []interface{}{}
|
|
|
|
}
|
2014-07-23 19:56:47 +02:00
|
|
|
|
2014-12-15 15:26:17 +01:00
|
|
|
err := updateConfigVars(
|
2014-08-19 19:13:34 +02:00
|
|
|
d.Id(), client, o.([]interface{}), n.([]interface{}))
|
|
|
|
if err != nil {
|
|
|
|
return err
|
|
|
|
}
|
2014-07-23 18:38:45 +02:00
|
|
|
}
|
2014-07-23 06:03:30 +02:00
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
return resourceHerokuAppRead(d, meta)
|
2014-07-23 06:03:30 +02:00
|
|
|
}
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
func resourceHerokuAppDelete(d *schema.ResourceData, meta interface{}) error {
|
2014-08-27 16:50:37 +02:00
|
|
|
client := meta.(*heroku.Service)
|
2014-07-23 06:03:30 +02:00
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
log.Printf("[INFO] Deleting App: %s", d.Id())
|
|
|
|
err := client.AppDelete(d.Id())
|
2014-07-23 06:03:30 +02:00
|
|
|
if err != nil {
|
|
|
|
return fmt.Errorf("Error deleting App: %s", err)
|
|
|
|
}
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
d.SetId("")
|
2014-07-23 06:03:30 +02:00
|
|
|
return nil
|
|
|
|
}
|
|
|
|
|
2014-12-15 15:26:17 +01:00
|
|
|
func resourceHerokuAppRetrieve(id string, client *heroku.Service) (*application, error) {
|
2014-07-23 18:09:27 +02:00
|
|
|
app := application{Id: id, Client: client}
|
|
|
|
|
|
|
|
err := app.Update()
|
2014-07-23 06:03:30 +02:00
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
return nil, fmt.Errorf("Error retrieving app: %s", err)
|
|
|
|
}
|
|
|
|
|
2014-07-23 18:09:27 +02:00
|
|
|
return &app, nil
|
2014-07-23 06:03:30 +02:00
|
|
|
}
|
|
|
|
|
2014-12-15 15:26:17 +01:00
|
|
|
func retrieveConfigVars(id string, client *heroku.Service) (map[string]string, error) {
|
2014-07-23 18:09:27 +02:00
|
|
|
vars, err := client.ConfigVarInfo(id)
|
|
|
|
|
|
|
|
if err != nil {
|
|
|
|
return nil, err
|
|
|
|
}
|
|
|
|
|
|
|
|
return vars, nil
|
|
|
|
}
|
|
|
|
|
2014-08-18 18:32:40 +02:00
|
|
|
// Updates the config vars for from an expanded configuration.
|
2014-12-15 15:26:17 +01:00
|
|
|
func updateConfigVars(
|
2014-08-19 19:13:34 +02:00
|
|
|
id string,
|
2014-08-27 16:50:37 +02:00
|
|
|
client *heroku.Service,
|
2014-08-19 19:13:34 +02:00
|
|
|
o []interface{},
|
|
|
|
n []interface{}) error {
|
2014-07-23 17:26:31 +02:00
|
|
|
vars := make(map[string]*string)
|
|
|
|
|
2014-08-19 19:13:34 +02:00
|
|
|
for _, v := range o {
|
|
|
|
for k, _ := range v.(map[string]interface{}) {
|
|
|
|
vars[k] = nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
for _, v := range n {
|
2014-08-18 18:32:40 +02:00
|
|
|
for k, v := range v.(map[string]interface{}) {
|
|
|
|
val := v.(string)
|
|
|
|
vars[k] = &val
|
|
|
|
}
|
2014-07-23 17:26:31 +02:00
|
|
|
}
|
|
|
|
|
2014-07-23 20:46:12 +02:00
|
|
|
log.Printf("[INFO] Updating config vars: *%#v", vars)
|
2014-08-18 18:32:40 +02:00
|
|
|
if _, err := client.ConfigVarUpdate(id, vars); err != nil {
|
2014-07-23 17:26:31 +02:00
|
|
|
return fmt.Errorf("Error updating config vars: %s", err)
|
|
|
|
}
|
|
|
|
|
|
|
|
return nil
|
|
|
|
}
|