Añadir demo.go

demo.go

@@ -0,0 +1,136 @@
+package main
+
+import (
+	"bytes"
+	"context"
+	"dagger.io/dagger"
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"log"
+	"net/http"
+	"os"
+	"time"
+)
+
+func main() {
+	if err := buildstaging(context.Background()); err != nil {
+		fmt.Println(err)
+	}
+}
+
+func buildstaging(ctx context.Context) error {
+	fmt.Println("Inicializando deploy")
+	os.Chdir("./..")
+
+	fmt.Println("Levantar base de datos")
+	uniqueVolume := client.CacheVolume(fmt.Sprintf("pgdata-%d", time.Now().UnixNano()))
+	databaseDevelopment := client.Container().
+		From("postgres:16").
+		WithEnvVariable("POSTGRES_PASSWORD", "secret").
+		WithEnvVariable("POSTGRES_USER", "savne").
+		WithEnvVariable("POSTGRES_DB", "sav_net_test").
+		WithExposedPort(5432).
+		WithMountedCache("/var/lib/postgresql/data", uniqueVolume).
+		WithExec([]string{"postgres"}).
+		AsService()
+
+	client.Pipeline("Migraciones")
+	migrations, err := client.Container(dagger.ContainerOpts{Platform: "linux/amd64"}).
+		From("liquibase/liquibase").
+		WithServiceBinding("sav-net-db", databaseDevelopment).
+		WithDirectory("/project/migrations", client.Host().Directory("./dbmigrations/migrations")).
+		WithFile("/project/liquibase.properties", client.Host().File("liquibase.properties")).
+		WithWorkdir("/project").
+		WithExec([]string{"sleep", "20"}).
+		WithExec([]string{"liquibase", "--defaultsFile=/project/liquibase.properties", "update"}).
+		Stdout(ctx)
+
+	if err != nil {
+		panic(err)
+	}
+
+	log.Printf("Correr Migraciones: \n%s", migrations)
+
+	client.Pipeline("Test de cobertura")
+	hostDirectory := client.Host().Directory(".")
+	containerApp := hostDirectory.
+		DockerBuild(dagger.DirectoryDockerBuildOpts{
+			Dockerfile: "/devops/.devops/development/DockerfileTest",
+		}).
+		WithWorkdir("/var/www/app").
+		WithServiceBinding("sav-net-db", databaseDevelopment).
+		WithExec([]string{"composer", "install"}).
+
+	addr, err := containerApp.
+		WithExec([]string{"vendor/bin/phpunit", "--coverage-clover", ".qa/coverage/report.xml", "/var/www/app/src"}).
+		Directory("/var/www/app/.qa").
+		Export(ctx, "./code/.qa")
+
+	if err != nil {
+		panic(err)
+	}
+	fmt.Println("Se ejecutaron los test:", addr)
+
+	fmt.Println("Ejecutar sonarScanner")
+	sonarScanner, err := client.Container(dagger.ContainerOpts{Platform: "linux/amd64"}).
+		From("sonarsource/sonar-scanner-cli").
+		WithEnvVariable("URL", os.Getenv("HOST")).
+		WithEnvVariable(
+			"SONAR_SCANNER_OPTS",
+			"-Dsonar.projectKey=Savnet "+
+				"-Dsonar.exclusions=public/**/*,vendor/**/*,storage/**/*,tests/**/*,.qa/**/*,.devops/**/* "+
+				"-Dsonar.php.coverage.reportPaths=.qa/coverage/report.xml "+
+				"-Dsonar.php.tests.reportPath=.qa/coverage/report-tests.xml -Dsonar.projectBaseDir=/var/www/app").
+		WithEnvVariable("TOKEN", os.Getenv("SAV_DEVELOP")).
+		WithDirectory("/var/www/app/app", client.Host().Directory("./code/app")).
+		WithWorkdir("/var/www/app").
+		Stdout(ctx)
+
+	if err != nil {
+		panic(err)
+	}
+	log.Printf("sonarScanner: \n%s", sonarScanner)
+
+	time.Sleep(420 * time.Second)
+
+	dataDevelopment := PayloadDevelopment{
+		NombreApp:  "SavNet",
+		EntornoApp: "Development",
+	}
+
+	fmt.Println("Quality Gate failed")
+	url := os.Getenv("HOST") + "project_status?projectKey=Savnet"
+	req, _ := http.NewRequest("GET", url, nil)
+	req.Header.Add("Authorization", os.Getenv("SAV_DEVELOP"))
+	resp, err := http.DefaultClient.Do(req)
+	if err != nil {
+		log.Fatalf("Error executing request: %v", err)
+	}
+	defer resp.Body.Close()
+	var result struct {
+		ProjectStatus struct {
+			Status string `json:"status"`
+		} `json:"projectStatus"`
+	}
+	json.NewDecoder(resp.Body).Decode(&result)
+	if result.ProjectStatus.Status != "OK" {
+		url_ := os.Getenv("TOKEN_FAILED")
+		sendNotificationDevelopment(url_, dataDevelopment)
+		log.Fatal("Quality Gate failed!")
+		os.Exit(1)
+	}
+	fmt.Printf("Estado: %s\n", result)
+
+	fmt.Println("Enviando notificación a Rocket.Chat...")
+	url_ := os.Getenv("SAV_DEVELOPMENT")
+	chatMatriz := sendNotification(url_, dataDevelopment)
+	if err != nil {
+		fmt.Println("Error al enviar la notificación:", chatMatriz)
+	} else {
+		fmt.Println("Notificación enviada correctamente")
+	}
+
+	fmt.Println("Finalizo deploy")
+	return nil
+}