feat(engine): engine database upgrade improvement

engine/Makefile

@@ -6,7 +6,8 @@ BUILDTIME := `date "+%m/%d/%y-%H:%M:%S"`
 
 TARGET_DIR = ./dist
 TARGET_ENGINE = cds-engine
-TARGET_LDFLAGS = -ldflags "-X github.com/ovh/cds/sdk.VERSION=$(VERSION) -X github.com/ovh/cds/sdk.GOOS=$$GOOS -X github.com/ovh/cds/sdk.GOARCH=$$GOARCH -X github.com/ovh/cds/sdk.GITHASH=$(GITHASH) -X github.com/ovh/cds/sdk.BUILDTIME=$(BUILDTIME) -X github.com/ovh/cds/sdk.BINARY=$(TARGET_ENGINE)"
+DBMIGRATE = $(words $(wildcard sql/*.sql))
+TARGET_LDFLAGS = -ldflags "-X github.com/ovh/cds/sdk.VERSION=$(VERSION) -X github.com/ovh/cds/sdk.GOOS=$$GOOS -X github.com/ovh/cds/sdk.GOARCH=$$GOARCH -X github.com/ovh/cds/sdk.GITHASH=$(GITHASH) -X github.com/ovh/cds/sdk.BUILDTIME=$(BUILDTIME) -X github.com/ovh/cds/sdk.BINARY=$(TARGET_ENGINE) -X github.com/ovh/cds/sdk.DBMIGRATE=$(DBMIGRATE)"
 TARGET_OS = $(if ${OS},${OS},windows darwin linux freebsd)
 TARGET_ARCH = $(if ${ARCH},${ARCH},amd64 arm 386)
 

engine/api/database/cli.go

@@ -1,16 +1,24 @@
 package database
 
 import (
+	"bytes"
 	"fmt"
+	"io"
+	"io/ioutil"
 	"os"
+	"path/filepath"
+	"strconv"
+	"strings"
 	"time"
 
+	"github.com/mholt/archiver"
 	"github.com/olekukonko/tablewriter"
 	"github.com/rubenv/sql-migrate"
 	"github.com/spf13/cobra"
 
 	"github.com/ovh/cds/engine/api/database/dbmigrate"
 	"github.com/ovh/cds/sdk"
+	"github.com/ovh/cds/sdk/cdsclient"
 )
 
 //DBCmd is the root command for database management
@@ -23,8 +31,17 @@ var DBCmd = &cobra.Command{
 var upgradeCmd = &cobra.Command{
 	Use:   "upgrade",
 	Short: "Upgrade schema",
-	Long:  "Migrates the database to the most recent version available.",
-	Run:   upgradeCmdFunc,
+	Long: `Migrates the database to the most recent version available.
+
+	Example of usage:
+
+	engine database upgrade --db-password=your-password --db-sslmode=disable --db-name=cds --migrate-dir=./sql
+
+	If the directory --migrate-dir is not up to date with the current version, this
+	directory will be automatically updated with the release from https://github.com/ovh/cds/releases
+
+	`,
+	Run: upgradeCmdFunc,
 }
 
 var downgradeCmd = &cobra.Command{
@@ -85,22 +102,111 @@ type statusRow struct {
 }
 
 func upgradeCmdFunc(cmd *cobra.Command, args []string) {
+	source := migrate.FileMigrationSource{
+		Dir: sqlMigrateDir,
+	}
+
+	migrations, err := source.FindMigrations()
+	if err != nil {
+		sdk.Exit("Error: %v\n", err)
+	}
+
+	if sdk.VERSION != "snapshot" {
+		nbMigrateOnThisVersion, err := strconv.Atoi(sdk.DBMIGRATE)
+		if err == nil { // no err -> it's a real release
+			fmt.Printf("There are %d migrate files locally. Current engine needs %d files\n", len(migrations), nbMigrateOnThisVersion)
+			if nbMigrateOnThisVersion > len(migrations) {
+				fmt.Printf("This version %s should contains %d migrate files.\n", sdk.VERSION, nbMigrateOnThisVersion)
+				downloadSQLTarGz()
+				migrations, err := source.FindMigrations()
+				if err != nil {
+					sdk.Exit("Error: %v\n", err)
+				}
+				fmt.Printf("sql.tar.gz downloaded, there are now %d migrate files locally\n", len(migrations))
+			}
+		} else {
+			sdk.Exit("Invalid compilation flag DBMIGRATE")
+		}
+	}
+
 	if err := ApplyMigrations(migrate.Up, sqlMigrateDryRun, sqlMigrateLimitUp); err != nil {
-		sdk.Exit("Error: %s\n", err)
+		sdk.Exit("Error: %v\n", err)
+	}
+}
+
+// downloadSQLTarGz downloads sql.tar.gz from github release corresponding to the current engine version
+// check status 200 on download
+// then write sql.tar.gz file in tmpdir
+// then unzip sql.tar.gz file
+// then move all sql file to sqlMigrateDir directory
+func downloadSQLTarGz() {
+	currentTag := sdk.VERSION[:strings.LastIndex(sdk.VERSION, "+")]
+	urlTarGZ := fmt.Sprintf("https://github.com/ovh/cds/releases/download/%s/sql.tar.gz", currentTag)
+	fmt.Printf("Getting sql.tar.gz from github on %s...\n", urlTarGZ)
+
+	httpClient := cdsclient.NewHTTPClient(60*time.Second, false)
+	resp, err := httpClient.Get(urlTarGZ)
+	if err != nil {
+		sdk.Exit("Error while getting sql.tar.gz from Github: %v\n", err)
+	}
+	defer resp.Body.Close()
+
+	if err := sdk.CheckContentTypeBinary(resp); err != nil {
+		sdk.Exit(err.Error())
+	}
+
+	if resp.StatusCode != 200 {
+		buf := new(bytes.Buffer)
+		if _, err := buf.ReadFrom(resp.Body); err == nil {
+			fmt.Printf("body returned from github: \n%s\n", buf.String())
+		}
+		sdk.Exit("Error http code: %d, url called: %s\n", resp.StatusCode, urlTarGZ)
+	}
+
+	tmpfile, err := ioutil.TempFile(os.TempDir(), "sql.tar.gz")
+	if err != nil {
+		sdk.Exit(err.Error())
+	}
+	defer tmpfile.Close()
+
+	if _, err = io.Copy(tmpfile, resp.Body); err != nil {
+		sdk.Exit("Error on creating file: %v", err.Error())
+	}
+
+	dest := tmpfile.Name() + "extract"
+	if err := archiver.TarGz.Open(tmpfile.Name(), dest); err != nil {
+		sdk.Exit("Unarchive sql.tar.gz failed: %v", err)
+	}
+	// the directory dest/sql/ -> contains all sql files
+	fmt.Printf("Unarchive to %s\n", dest)
+
+	dirFiles := dest + "/sql"
+	files, err := ioutil.ReadDir(dirFiles)
+	if err != nil {
+		sdk.Exit("Error on readDir %s", dirFiles)
+	}
+	for _, f := range files {
+		if strings.HasSuffix(f.Name(), ".sql") {
+			src := dirFiles + "/" + f.Name()
+			dest := sqlMigrateDir + "/" + filepath.Base(f.Name())
+			if err := os.Rename(src, dest); err != nil {
+				sdk.Exit("Error on move %s to %s err:%v", src, dest, err)
+			}
+		}
 	}
 }
 
 func downgradeCmdFunc(cmd *cobra.Command, args []string) {
 	if err := ApplyMigrations(migrate.Down, sqlMigrateDryRun, sqlMigrateLimitDown); err != nil {
-		sdk.Exit("Error: %s\n", err)
+		sdk.Exit("Error: %v\n", err)
 	}
 }
 
 func statusCmdFunc(cmd *cobra.Command, args []string) {
 	var err error
 	connFactory, err = Init(connFactory.dbUser, connFactory.dbRole, connFactory.dbPassword, connFactory.dbName, connFactory.dbHost, connFactory.dbPort, connFactory.dbSSLMode, connFactory.dbConnectTimeout, connFactory.dbTimeout, connFactory.dbMaxConn)
 	if err != nil {
-		sdk.Exit("Error: %s\n", err)
+		sdk.Exit("Error: %v\n", err)
 	}
 
 	source := migrate.FileMigrationSource{
@@ -109,12 +215,12 @@ func statusCmdFunc(cmd *cobra.Command, args []string) {
 
 	migrations, err := source.FindMigrations()
 	if err != nil {
-		sdk.Exit("Error: %s\n", err)
+		sdk.Exit("Error: %v\n", err)
 	}
 
 	records, err := migrate.GetMigrationRecords(connFactory.DB(), "postgres")
 	if err != nil {
-		sdk.Exit("Error: %s\n", err)
+		sdk.Exit("Error: %v\n", err)
 	}
 
 	table := tablewriter.NewWriter(os.Stdout)
@@ -163,12 +269,12 @@ func ApplyMigrations(dir migrate.MigrationDirection, dryrun bool, limit int) err
 	var err error
 	connFactory, err = Init(connFactory.dbUser, connFactory.dbRole, connFactory.dbPassword, connFactory.dbName, connFactory.dbHost, connFactory.dbPort, connFactory.dbSSLMode, connFactory.dbConnectTimeout, connFactory.dbTimeout, connFactory.dbMaxConn)
 	if err != nil {
-		sdk.Exit("Error: %s\n", err)
+		sdk.Exit("Error: %v\n", err)
 	}
 
 	migrations, err := dbmigrate.Do(connFactory.DB, sqlMigrateDir, dir, dryrun, limit)
 	if err != nil {
-		sdk.Exit("Error: %s\n", err)
+		sdk.Exit("Error: %v\n", err)
 	}
 
 	if dryrun {

engine/update.go

@@ -45,7 +45,7 @@ var updateCmd = &cobra.Command{
 
 		resp, err := http.Get(urlBinary)
 		if err != nil {
-			sdk.Exit("Error while getting binary from CDS API: %s\n", err)
+			sdk.Exit("Error while getting binary from: %s err:%s\n", urlBinary, err)
 		}
 		defer resp.Body.Close()
 

sdk/version.go

@@ -23,6 +23,10 @@ var (
 
 	//BINARY is set with -ldflags "-X github.com/ovh/cds/sdk.BINARY=$(BINARY)"
 	BINARY = ""
+
+	//DBMIGRATE is set with -ldflags "-X github.com/ovh/cds/sdk.DBMIGRATE=$(DBMIGRATE)"
+	// this flag contains the number of sql files to migrate for this version
+	DBMIGRATE = ""
 )
 
 func init() {
@@ -41,6 +45,7 @@ type Version struct {
 	OS           string `json:"os"`
 	GitHash      string `json:"git_hash"`
 	BuildTime    string `json:"build_time"`
+	DBMigrate    string `json:"db_migrate"`
 }
 
 // VersionCurrent returns the current version
@@ -51,10 +56,11 @@ func VersionCurrent() Version {
 		OS:           GOOS,
 		GitHash:      GITHASH,
 		BuildTime:    BUILDTIME,
+		DBMigrate:    DBMIGRATE,
 	}
 }
 
 // VersionString returns a string contains all about current version
 func VersionString() string {
-	return fmt.Sprintf("CDS %s version:%s os:%s architecture:%s git.hash:%s build.time:%s", BINARY, VERSION, GOOS, GOARCH, GITHASH, BUILDTIME)
+	return fmt.Sprintf("CDS %s version:%s os:%s architecture:%s git.hash:%s build.time:%s db.migrate:%s", BINARY, VERSION, GOOS, GOARCH, GITHASH, BUILDTIME, DBMIGRATE)
 }