92 lines
1.9 KiB
Go
92 lines
1.9 KiB
Go
package handlers
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/a-h/templ"
|
|
"github.com/go-playground/validator/v10"
|
|
"github.com/labstack/echo/v4"
|
|
|
|
"git.grosinger.net/tgrosinger/saasitone/pkg/form"
|
|
"git.grosinger.net/tgrosinger/saasitone/pkg/msg"
|
|
"git.grosinger.net/tgrosinger/saasitone/pkg/page"
|
|
"git.grosinger.net/tgrosinger/saasitone/pkg/services"
|
|
"git.grosinger.net/tgrosinger/saasitone/pkg/tasks"
|
|
"git.grosinger.net/tgrosinger/saasitone/templ/layouts"
|
|
"git.grosinger.net/tgrosinger/saasitone/templ/pages"
|
|
"git.grosinger.net/tgrosinger/saasitone/templates"
|
|
)
|
|
|
|
const (
|
|
routeNameTask = "task"
|
|
routeNameTaskSubmit = "task.submit"
|
|
)
|
|
|
|
type (
|
|
Task struct {
|
|
tasks *services.TaskClient
|
|
*services.TemplateRenderer
|
|
}
|
|
)
|
|
|
|
func init() {
|
|
Register(new(Task))
|
|
}
|
|
|
|
func (h *Task) Init(c *services.Container) error {
|
|
h.TemplateRenderer = c.TemplateRenderer
|
|
h.tasks = c.Tasks
|
|
return nil
|
|
}
|
|
|
|
func (h *Task) Routes(g *echo.Group) {
|
|
g.GET("/task", h.Page).Name = routeNameTask
|
|
g.POST("/task", h.Submit).Name = routeNameTaskSubmit
|
|
}
|
|
|
|
func (h *Task) Page(ctx echo.Context) error {
|
|
p := page.New(ctx)
|
|
p.Name = templates.PageTask
|
|
p.Title = "Create a task"
|
|
|
|
f := form.Get[pages.TaskForm](ctx)
|
|
component := pages.Task(p, f)
|
|
|
|
// TODO: This can be reused
|
|
p.LayoutComponent = func(content templ.Component) templ.Component {
|
|
return layouts.Main(p, content)
|
|
}
|
|
|
|
return h.RenderPageTempl(ctx, p, component)
|
|
}
|
|
|
|
func (h *Task) Submit(ctx echo.Context) error {
|
|
var input pages.TaskForm
|
|
|
|
err := form.Submit(ctx, &input)
|
|
|
|
switch err.(type) {
|
|
case nil:
|
|
case validator.ValidationErrors:
|
|
return h.Page(ctx)
|
|
default:
|
|
return err
|
|
}
|
|
|
|
// Insert the task
|
|
err = h.tasks.New(tasks.ExampleTask{
|
|
Message: input.Message,
|
|
}).
|
|
Wait(time.Duration(input.Delay) * time.Second).
|
|
Save()
|
|
if err != nil {
|
|
return fail(err, "unable to create a task")
|
|
}
|
|
|
|
msg.Success(ctx, fmt.Sprintf("The task has been created. Check the logs in %d seconds.", input.Delay))
|
|
form.Clear(ctx)
|
|
|
|
return h.Page(ctx)
|
|
}
|