plan route and import fix

Author: Kerry Wilson

README.md

@@ -2,6 +2,9 @@
 
 Continuous integration service for [Terraform](https://terraform.io). 
 
+## Current State
+* Requires terraform repositories to be checked out to a directory (CHECKOUT_DIR) and to have a terraform.tfplan
+
 ## Planned Features
 * Securely stores template variables
 * Generates plans when changes committed to source
@@ -11,6 +14,15 @@ Continuous integration service for [Terraform](https://terraform.io).
 * Backend written in go
 * Frontend vue.js app
 
+### API Endpoints
+
+#### Projects
+
+* `/status` - (GET) Get service status
+* `/api/projects` - (GET, PUT) List all projects, create project
+* `/api/projects/{guid}` - (POST, DELETE) Update or delete projects
+* `/api/plan/{guid}` - (GET) Return the current plan associated with the project guid
+
 ## Testing
 * `make test`
 

config/config.go

@@ -7,17 +7,18 @@ import (
 	"strconv"
 
 	"github.com/hashicorp/logutils"
-	"github.com/webdevwilson/terraform-ui/persist"
-	"github.com/webdevwilson/terraform-ui/task"
+	"github.com/webdevwilson/terraform-ci/persist"
+	"github.com/webdevwilson/terraform-ci/task"
 )
 
 // Settings contains all the configuration values for the service
 type Settings struct {
-	LogLevel string
-	SiteRoot string
-	Port     int
-	Store    persist.Store
-	Executor *task.Executor
+	LogLevel          string
+	SiteRoot          string
+	CheckoutDirectory string
+	Port              int
+	Store             persist.Store
+	Executor          *task.Executor
 }
 
 var settings *Settings
@@ -33,10 +34,17 @@ func init() {
 
 	executor := task.NewExecutor(store)
 
+	workingDir, err := os.Getwd()
+
+	if err != nil {
+		log.Fatalf("[FATAL] Failed to get current working directory: %s", workingDir)
+	}
+
 	// initialize settings
 	settings = &Settings{
 		envOr("LOG_LEVEL", "INFO"),
-		envOrFunc("SITE_ROOT", defaultSiteRoot),
+		envOr("SITE_ROOT", path.Join(workingDir, "site", "dist")),
+		envOr("CHECKOUT_DIR", path.Join(workingDir, ".state", "projects")),
 		envOrInt("PORT", 3000),
 		store,
 		executor,
@@ -66,15 +74,6 @@ func defaultStatePath() (statePath string) {
 	return
 }
 
-func defaultSiteRoot() (siteRoot string) {
-	wd, err := os.Getwd()
-	if err != nil {
-		log.Fatalf("[FATAL] Failed to get current working directory: %s", wd)
-	}
-	siteRoot = path.Join(wd, "site", "dist")
-	return
-}
-
 // env returns environment variables. fatal error if it does not exist
 func env(name string) (v string) {
 	if v = os.Getenv(name); len(v) == 0 {

main.go

@@ -2,20 +2,49 @@ package main
 
 import (
 	"log"
+	"path"
+	"path/filepath"
 
 	"fmt"
 
-	"github.com/webdevwilson/terraform-ui/config"
-	"github.com/webdevwilson/terraform-ui/routes"
-	_ "github.com/webdevwilson/terraform-ui/task"
+	"github.com/webdevwilson/terraform-ci/config"
+	"github.com/webdevwilson/terraform-ci/model"
+	"github.com/webdevwilson/terraform-ci/routes"
+	_ "github.com/webdevwilson/terraform-ci/task"
 )
 
 func main() {
-	port := config.Get().Port
+	settings := config.Get()
+	port := settings.Port
 	log.Print(fmt.Sprintf("[INFO] Listening on port %d ...", port))
 
-	routes.StartServer(port)
+	// this should be temporary, until we can get a proper CRUD frontend
+	bootstrapProjects(settings.CheckoutDirectory)
+
+	go routes.StartServer(port)
 
 	for {
 	}
 }
+
+func bootstrapProjects(dir string) {
+	dirs, err := filepath.Glob(path.Join(dir, "*"))
+	if err != nil {
+		log.Fatalf("[FATAL] Error encountered loading projects: %s", err)
+	}
+
+	for _, dir := range dirs {
+		name := path.Base(dir)
+		prj, err := model.GetProjectByName(name)
+
+		if err != nil {
+			log.Fatalf("[FATAL] Error bootstrapping projects: %s", err)
+		}
+
+		if prj == nil {
+			model.CreateProject(&model.Project{
+				Name: name,
+			})
+		}
+	}
+}

model/project.go

@@ -1,8 +1,8 @@
 package model
 
 import (
-	"github.com/webdevwilson/terraform-ui/config"
-	"github.com/webdevwilson/terraform-ui/persist"
+	"github.com/webdevwilson/terraform-ci/config"
+	"github.com/webdevwilson/terraform-ci/persist"
 )
 
 const projectNS = "projects"
@@ -32,6 +32,7 @@ func ListProjects() (projects []Project, err error) {
 	projects = make([]Project, len(guids))
 	for i, guid := range guids {
 		err = store.Get(projectNS, guid, &projects[i])
+		projects[i].GUID = guid
 		if err != nil {
 			return
 		}
@@ -53,6 +54,28 @@ func GetProject(guid string) (*Project, error) {
 	return &prj, err
 }
 
+// GetProjectByName returns the named project
+func GetProjectByName(name string) (*Project, error) {
+
+	projects, err := store.List(projectNS)
+	if err != nil {
+		return nil, err
+	}
+
+	for _, guid := range projects {
+		prj, err := GetProject(guid)
+
+		if err != nil {
+			return nil, err
+		}
+
+		if prj.Name == name {
+			return prj, nil
+		}
+	}
+	return nil, nil
+}
+
 // CreateProject
 func CreateProject(prj *Project) (err error) {
 	var guid string

routes/init.go

@@ -8,8 +8,8 @@ import (
 	"sync"
 
 	"github.com/gorilla/mux"
-	"github.com/webdevwilson/terraform-ui/config"
-	"github.com/webdevwilson/terraform-ui/persist"
+	"github.com/webdevwilson/terraform-ci/config"
+	"github.com/webdevwilson/terraform-ci/persist"
 )
 
 // Route function interface

routes/project.go

@@ -6,7 +6,7 @@ import (
 	"encoding/json"
 
 	"github.com/gorilla/mux"
-	"github.com/webdevwilson/terraform-ui/model"
+	"github.com/webdevwilson/terraform-ci/model"
 )
 
 func init() {

routes/project_test.go

@@ -14,8 +14,8 @@ import (
 	"strings"
 
 	"github.com/stretchr/testify/assert"
-	"github.com/webdevwilson/terraform-ui/config"
-	"github.com/webdevwilson/terraform-ui/model"
+	"github.com/webdevwilson/terraform-ci/config"
+	"github.com/webdevwilson/terraform-ci/model"
 )
 
 var prjs = []model.Project{

routes/site.go

@@ -1,6 +1,6 @@
 package routes
 
-import "github.com/webdevwilson/terraform-ui/config"
+import "github.com/webdevwilson/terraform-ci/config"
 
 func init() {
 	//r := Router()

task/executor.go

@@ -10,7 +10,7 @@ import (
 	"runtime/debug"
 
 	uuid "github.com/nu7hatch/gouuid"
-	"github.com/webdevwilson/terraform-ui/persist"
+	"github.com/webdevwilson/terraform-ci/persist"
 )
 
 const persistNamespace = "executions"