deploy: container history

daemon/inertiad/build/builder.go

@@ -280,8 +280,7 @@ func (b *Builder) dockerBuild(d Config, cli *docker.Client,
 	return func() error { return b.run(ctx, cli, d.Name, containerResp.ID, out) }, nil
 }
 
-// run starts project and tracks all active project containers and pipes an error
-// to the returned channel if any container exits or errors.
+// run starts project and tracks all active project containers
 func (b *Builder) run(ctx context.Context, client *docker.Client, name, id string, out io.Writer) error {
 	reportProjectStartup(name, out)
 	return client.ContainerStart(ctx, id, types.ContainerStartOptions{})

daemon/inertiad/daemon/up.go

@@ -97,5 +97,12 @@ func (s *Server) upHandler(w http.ResponseWriter, r *http.Request) {
 		return
 	}
 
+
+	// Update container management history
+	s.deployment.UpdateContainerHistory(s.docker)
+
+	logger.WriteSuccess("Project startup initiated!", http.StatusCreated)
+
 	stream.Success(res.Msg("Project startup initiated!", http.StatusCreated))
+
 }

daemon/inertiad/project/data.go

@@ -14,7 +14,8 @@ import (
 
 var (
 	// database buckets
-	envVariableBucket = []byte("envVariables")
+	envVariableBucket     = []byte("envVariables")
+	builtContainersBucket = []byte("builtContainers")
 )
 
 // DeploymentDataManager stores persistent deployment configuration
@@ -50,6 +51,7 @@ func NewDataManager(dbPath string, keyPath string) (*DeploymentDataManager, erro
 	}
 	if err = db.Update(func(tx *bolt.Tx) error {
 		_, err := tx.CreateBucketIfNotExists(envVariableBucket)
+		_, err = tx.CreateBucketIfNotExists(builtContainersBucket)
 		return err
 	}); err != nil {
 		return nil, fmt.Errorf("failed to instantiate database: %s", err.Error())
@@ -63,8 +65,7 @@ func NewDataManager(dbPath string, keyPath string) (*DeploymentDataManager, erro
 
 // AddEnvVariable adds a new environment variable that will be applied
 // to all project containers
-func (c *DeploymentDataManager) AddEnvVariable(name, value string,
-	encrypt bool) error {
+func (c *DeploymentDataManager) AddEnvVariable(name, value string, encrypt bool) error {
 	if len(name) == 0 || len(value) == 0 {
 		return errors.New("invalid env configuration")
 	}
@@ -138,6 +139,14 @@ func (c *DeploymentDataManager) GetEnvVariables(decrypt bool) ([]string, error)
 	return envs, err
 }
 
+// AddBuiltContainer stores and tracks metadata from successful builds
+func (c *DeploymentDataManager) AddBuiltContainer(commitHash string, containerID string) error {
+	return c.db.Update(func(tx *bolt.Tx) error {
+		containersBucket := tx.Bucket(builtContainersBucket)
+		return containersBucket.Put([]byte(commitHash), []byte(containerID))
+	})
+}
+
 func (c *DeploymentDataManager) destroy() error {
 	return c.db.Update(func(tx *bolt.Tx) error {
 		if err := tx.DeleteBucket(envVariableBucket); err != nil {

daemon/inertiad/project/data_test.go

@@ -65,6 +65,37 @@ func TestDataManager_EnvVariableOperations(t *testing.T) {
 	}
 }
 
+// func TestDataManager_builtContainerOperations(t *testing.T) {
+// 	type args struct {
+// 		commitHash string
+// 		date       string
+// 	}
+// 	tests := []struct {
+// 		name    string
+// 		args    args
+// 		wantErr bool
+// 	}{
+// 		{"valid build", args{"hash", "2:20pm"}, false},
+// 	}
+// 	for _, tt := range tests {
+// 		t.Run(tt.name, func(t *testing.T) {
+// 			dir := "./test_config"
+// 			err := os.Mkdir(dir, os.ModePerm)
+// 			assert.Nil(t, err)
+// 			defer os.RemoveAll(dir)
+
+// 			// // Instantiate
+// 			// c, err := NewDataManager(path.Join(dir, "deployment.db"), path.Join(dir, "key"))
+// 			// assert.Nil(t, err)
+
+// 			// // Add
+// 			// err = c.AddBuiltContainer(tt.args.commitHash, tt.args.date)
+// 			// assert.Equal(t, tt.wantErr, (err != nil))
+
+// 		})
+// 	}
+// }
+
 func TestDataManager_destroy(t *testing.T) {
 	dir := "./test_config"
 	err := os.Mkdir(dir, os.ModePerm)

daemon/inertiad/project/deployment.go

@@ -314,6 +314,32 @@ func (d *Deployment) CompareRemotes(remoteURL string) error {
 	return nil
 }
 
+// UpdateContainerHistory will update container bucket with recent build's
+// metadata
+func (d *Deployment) UpdateContainerHistory(cli *docker.Client) error {
+	// Retrieve container ID for recently deployed project
+	ctx := context.Background()
+	var containerID string
+	containers, err := cli.ContainerList(ctx, types.ContainerListOptions{})
+	if err != nil {
+		return err
+	}
+	for _, container := range containers {
+		if container.Names[0] == d.project {
+			containerID = container.ID
+		}
+	}
+	// Retrieve project hash
+	head, err := d.repo.Head()
+	if err != nil {
+		return err
+	}
+	// Update db with newly built container metadata
+	d.dataManager.AddBuiltContainer(head.Hash().String(), containerID)
+
+	return err
+}
+
 // GetDataManager returns the class managing deployment data
 func (d *Deployment) GetDataManager() (manager *DeploymentDataManager, found bool) {
 	if d.dataManager == nil {