-
Notifications
You must be signed in to change notification settings - Fork 12
/
deployment_create.go
84 lines (69 loc) · 2.19 KB
/
deployment_create.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
package handlers
import (
"net/http"
log "github.com/sirupsen/logrus"
"github.com/Azure/azure-sdk-for-go/sdk/azcore"
"github.com/Azure/azure-sdk-for-go/sdk/azcore/to"
"github.com/labstack/echo/v4"
"github.com/microsoft/commercial-marketplace-offer-deploy/internal/config"
"github.com/microsoft/commercial-marketplace-offer-deploy/internal/data"
"github.com/microsoft/commercial-marketplace-offer-deploy/internal/mapper"
"github.com/microsoft/commercial-marketplace-offer-deploy/internal/model"
"github.com/microsoft/commercial-marketplace-offer-deploy/sdk"
"gorm.io/gorm"
)
type createDeploymentHandler struct {
db *gorm.DB
mapper *mapper.CreateDeploymentMapper
}
// HTTP handler for creating deployments
func (h *createDeploymentHandler) Handle(c echo.Context) error {
var command *sdk.CreateDeployment
err := c.Bind(&command)
if err != nil {
return err
}
deployment, err := h.mapper.Map(command)
if err != nil {
return err
}
tx := h.db.Create(&deployment)
log.Debugf("Deployment [%d] created.", deployment.ID)
if tx.Error != nil {
return err
}
if err != nil {
return err
}
result := createResult(deployment)
return c.JSON(http.StatusOK, result)
}
func createResult(deployment *model.Deployment) *sdk.Deployment {
result := &sdk.Deployment{
ID: to.Ptr(int32(deployment.ID)),
Name: &deployment.Name,
Location: to.Ptr(deployment.Location),
ResourceGroup: to.Ptr(deployment.ResourceGroup),
SubscriptionID: to.Ptr(deployment.SubscriptionId),
}
for _, stage := range deployment.Stages {
result.Stages = append(result.Stages, &sdk.DeploymentStage{
Name: to.Ptr(stage.Name),
ID: to.Ptr(stage.ID.String()),
DeploymentName: &stage.AzureDeploymentName,
Retries: to.Ptr(int32(stage.Retries)),
Attributes: stage.Attributes,
})
}
return result
}
func NewCreateDeploymentHandler(appConfig *config.AppConfig, credential azcore.TokenCredential) echo.HandlerFunc {
return func(c echo.Context) error {
db := data.NewDatabase(appConfig.GetDatabaseOptions()).Instance()
handler := createDeploymentHandler{
db: db,
mapper: mapper.NewCreateDeploymentMapper(),
}
return handler.Handle(c)
}
}