init

2026-04-08 04:29:35 +02:00
commit 8254a28baa
480 changed files with 13386 additions and 0 deletions
--- a/template/services/api/server/todo/todo.go
+++ b/template/services/api/server/todo/todo.go
@@ -0,0 +1,116 @@
+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
+}