75 lines
1.9 KiB
Go
75 lines
1.9 KiB
Go
//go:generate oapi-codegen -generate types -o openapi_types.gen.go -package api flamenco-manager.yaml
|
|
//go:generate oapi-codegen -generate server -o openapi_echo.gen.go -package api flamenco-manager.yaml
|
|
//go:generate oapi-codegen -generate spec -o openapi_spec.gen.go -package api flamenco-manager.yaml
|
|
//go:generate oapi-codegen -generate client -o openapi_client.gen.go -package api flamenco-manager.yaml
|
|
|
|
package api
|
|
|
|
import (
|
|
"net/http"
|
|
|
|
"github.com/google/uuid"
|
|
"github.com/labstack/echo/v4"
|
|
"github.com/rs/zerolog/log"
|
|
)
|
|
|
|
type Flamenco struct {
|
|
}
|
|
|
|
var _ ServerInterface = (*Flamenco)(nil)
|
|
|
|
func NewFlamenco() *Flamenco {
|
|
return &Flamenco{}
|
|
}
|
|
|
|
func (f *Flamenco) RegisterWorker(e echo.Context) error {
|
|
remoteIP := e.RealIP()
|
|
|
|
logger := log.With().
|
|
Str("ip", remoteIP).
|
|
Logger()
|
|
|
|
var req RegisterWorkerJSONBody
|
|
err := e.Bind(&req)
|
|
if err != nil {
|
|
logger.Warn().Err(err).Msg("bad request received")
|
|
return sendAPIError(e, http.StatusBadRequest, "invalid format")
|
|
}
|
|
|
|
logger.Info().Str("nickname", req.Nickname).Msg("registering new worker")
|
|
|
|
return e.JSON(http.StatusOK, &RegisteredWorker{
|
|
Id: uuid.New().String(),
|
|
Nickname: req.Nickname,
|
|
Platform: req.Platform,
|
|
Address: remoteIP,
|
|
})
|
|
}
|
|
|
|
func (f *Flamenco) ScheduleTask(e echo.Context) error {
|
|
return e.JSON(http.StatusOK, &AssignedTask{
|
|
Id: uuid.New().String(),
|
|
Commands: []Command{
|
|
{"echo", echo.Map{"payload": "Simon says \"Shaders!\""}},
|
|
{"blender", echo.Map{"blender_cmd": "/shared/bin/blender"}},
|
|
},
|
|
Job: uuid.New().String(),
|
|
JobPriority: 50,
|
|
JobType: "blender-render",
|
|
Name: "A1032",
|
|
Priority: 50,
|
|
Status: "active",
|
|
TaskType: "blender-render",
|
|
})
|
|
}
|
|
|
|
// sendPetstoreError wraps sending of an error in the Error format, and
|
|
// handling the failure to marshal that.
|
|
func sendAPIError(e echo.Context, code int, message string) error {
|
|
petErr := Error{
|
|
Code: int32(code),
|
|
Message: message,
|
|
}
|
|
return e.JSON(code, petErr)
|
|
}
|