117 lines
3.3 KiB
Go
117 lines
3.3 KiB
Go
package todo
|
|
|
|
import (
|
|
"connectrpc.com/connect"
|
|
"connectrpc.com/validate"
|
|
"context"
|
|
"<@var(context.project.goprefix)>/<@var(context.project.name)>/db"
|
|
todov1 "<@var(context.project.goprefix)>/<@var(context.project.name)>/gen/todo/v1"
|
|
"<@var(context.project.goprefix)>/<@var(context.project.name)>/gen/todo/v1/todov1connect"
|
|
. "<@var(context.project.goprefix)>/<@var(context.project.name)>/utils"
|
|
"github.com/jackc/pgx/v5/pgtype"
|
|
"net/http"
|
|
"time"
|
|
)
|
|
|
|
type TodoServer struct{}
|
|
|
|
func (srv *TodoServer) CreateTodo(ctx context.Context, req *connect.Request[todov1.CreateTodoRequest]) (*connect.Response[todov1.CreateTodoResponse], error) {
|
|
var id pgtype.UUID
|
|
err := id.Scan(*req.Msg.Todo.Id)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
todo, err := db.Q.CreateTodo(ctx, db.CreateTodoParams{
|
|
ID: id,
|
|
Task: req.Msg.Todo.Task,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &connect.Response[todov1.CreateTodoResponse]{
|
|
Msg: &todov1.CreateTodoResponse{
|
|
Todo: &todov1.Todo{
|
|
Id: StrPtr(todo.ID.String()),
|
|
Task: todo.Task,
|
|
CreatedAt: StrPtr(todo.CreatedAt.Time.Format(time.RFC3339)),
|
|
UpdatesAt: StrPtr(todo.UpdatedAt.Time.Format(time.RFC3339)),
|
|
Done: BoolPtr(todo.Done.Bool),
|
|
},
|
|
},
|
|
}, nil
|
|
}
|
|
|
|
func (srv *TodoServer) ListTodos(ctx context.Context, req *connect.Request[todov1.ListTodosRequest]) (*connect.Response[todov1.ListTodosResponse], error) {
|
|
todos, err := db.Q.ListTodos(ctx)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
reponseTodos := []*todov1.Todo{}
|
|
for _, todo := range todos {
|
|
reponseTodos = append(reponseTodos, &todov1.Todo{
|
|
Id: StrPtr(todo.ID.String()),
|
|
Task: todo.Task,
|
|
CreatedAt: StrPtr(todo.CreatedAt.Time.Format(time.RFC3339)),
|
|
UpdatesAt: StrPtr(todo.UpdatedAt.Time.Format(time.RFC3339)),
|
|
Done: BoolPtr(todo.Done.Bool),
|
|
})
|
|
}
|
|
|
|
return &connect.Response[todov1.ListTodosResponse]{
|
|
Msg: &todov1.ListTodosResponse{
|
|
Todos: reponseTodos,
|
|
},
|
|
}, nil
|
|
}
|
|
|
|
func (srv *TodoServer) UpdateTodo(ctx context.Context, req *connect.Request[todov1.UpdateTodoRequest]) (*connect.Response[todov1.UpdateTodoResponse], error) {
|
|
var id pgtype.UUID
|
|
err := id.Scan(*req.Msg.Todo.Id)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
todo, err := db.Q.UpdateTodo(ctx, db.UpdateTodoParams{
|
|
Task: req.Msg.Todo.Task,
|
|
Done: pgtype.Bool{
|
|
Bool: *req.Msg.Todo.Done,
|
|
Valid: true,
|
|
},
|
|
ID: id,
|
|
})
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &connect.Response[todov1.UpdateTodoResponse]{
|
|
Msg: &todov1.UpdateTodoResponse{
|
|
Todo: &todov1.Todo{
|
|
Id: StrPtr(todo.ID.String()),
|
|
Task: todo.Task,
|
|
CreatedAt: StrPtr(todo.CreatedAt.Time.Format(time.RFC3339)),
|
|
UpdatesAt: StrPtr(todo.UpdatedAt.Time.Format(time.RFC3339)),
|
|
Done: BoolPtr(todo.Done.Bool),
|
|
},
|
|
},
|
|
}, nil
|
|
|
|
}
|
|
|
|
func (srv *TodoServer) DeleteTodo(ctx context.Context, req *connect.Request[todov1.DeleteTodoRequest]) (*connect.Response[todov1.DeleteTodoResponse], error) {
|
|
var id pgtype.UUID
|
|
err := id.Scan(*req.Msg.Todo.Id)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
err = db.Q.DeleteTodo(ctx, id)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return &connect.Response[todov1.DeleteTodoResponse]{
|
|
Msg: &todov1.DeleteTodoResponse{},
|
|
}, nil
|
|
}
|
|
|
|
func GetPathHandler() (path string, handler http.Handler) {
|
|
path, handler = todov1connect.NewTodoServiceHandler(&TodoServer{}, connect.WithInterceptors(validate.NewInterceptor()))
|
|
return
|
|
}
|