/
template_build_logs.go
82 lines (57 loc) · 2.14 KB
/
template_build_logs.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
package handlers
import (
"fmt"
"net/http"
"github.com/gin-gonic/gin"
"github.com/google/uuid"
"go.opentelemetry.io/otel/attribute"
"github.com/e2b-dev/infra/packages/api/internal/api"
"github.com/e2b-dev/infra/packages/api/internal/auth"
"github.com/e2b-dev/infra/packages/shared/pkg/telemetry"
)
// GetTemplatesTemplateIDBuildsBuildIDStatus serves to get a template build status (e.g. to CLI)
func (a *APIStore) GetTemplatesTemplateIDBuildsBuildIDStatus(c *gin.Context, templateID api.TemplateID, buildID api.BuildID, params api.GetTemplatesTemplateIDBuildsBuildIDStatusParams) {
ctx := c.Request.Context()
userID := c.Value(auth.UserIDContextKey).(uuid.UUID)
team, err := a.db.GetDefaultTeamFromUserID(ctx, userID)
telemetry.SetAttributes(ctx,
attribute.String("user.id", userID.String()),
attribute.String("env.team.id", team.ID.String()),
)
if err != nil {
errMsg := fmt.Errorf("error when getting default team: %w", err)
a.sendAPIStoreError(c, http.StatusInternalServerError, "Failed to get the default team")
telemetry.ReportCriticalError(ctx, errMsg)
return
}
buildUUID, err := uuid.Parse(buildID)
if err != nil {
errMsg := fmt.Errorf("error when parsing build id: %w", err)
a.sendAPIStoreError(c, http.StatusBadRequest, "Invalid build id")
telemetry.ReportError(ctx, errMsg)
return
}
dockerBuild, err := a.buildCache.Get(templateID, buildUUID)
if err != nil {
msg := fmt.Errorf("error finding cache for env %s and build %s", templateID, buildID)
a.sendAPIStoreError(c, http.StatusNotFound, "Build not found")
telemetry.ReportError(ctx, msg)
return
}
if team.ID != dockerBuild.GetTeamID() {
msg := fmt.Errorf("user doesn't have access to env '%s'", templateID)
a.sendAPIStoreError(c, http.StatusForbidden, "You don't have access to this sandbox template")
telemetry.ReportError(ctx, msg)
return
}
status := dockerBuild.GetStatus()
logs := dockerBuild.GetLogs()
result := api.TemplateBuild{
Logs: logs[*params.LogsOffset:],
TemplateID: templateID,
BuildID: buildID,
Status: &status,
}
telemetry.ReportEvent(ctx, "got template build status")
c.JSON(http.StatusOK, result)
}