puerto 0.14.0

Puerto — Rust full-stack DDD framework CLI. Scaffolds Clean Architecture projects with auto-wired DI, SQLx support, and zero manual wiring. Formerly puerto-framework.
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

import { {{ pascal }}Error } from "../../domain/{{ kebab }}/errors";
{% if enums %}import { {% for e in enums %}parse{{ e.name }}, {% endfor %}type {{ pascal }}, type {{ pascal }}Draft }{% else %}import type { {{ pascal }}, {{ pascal }}Draft }{% endif %} from "../../domain/{{ kebab }}/model";
import type { {{ pascal }}Repository } from "../../domain/{{ kebab }}/repository";
import { type ApiClient, apiErrorCode } from "../http/client";
import type { components } from "../http/schema";

type {{ pascal }}Dto = components["schemas"]["{{ pascal }}Dto"];
type {{ pascal }}Request = components["schemas"]["Create{{ pascal }}Request"];

function to{{ pascal }}(dto: {{ pascal }}Dto): {{ pascal }} {
  return {
    id: dto.id,
{%- for f in fields %}
    {{ f.camel }}: {{ f.from_wire }},
{%- endfor %}
  };
}

function toRequest(draft: {{ pascal }}Draft): {{ pascal }}Request {
  return {
{%- for f in fields %}
    {{ f.camel }}: {{ f.to_wire }},
{%- endfor %}
  };
}

/** `{{ pascal }}Repository` over the REST API (`/{{ plural }}`). */
export function {{ camel }}RepositoryHttp(api: ApiClient): {{ pascal }}Repository {
  return {
    async list(page) {
      const { data, error, response } = await api.GET("/{{ plural }}", {
        params: { query: page },
      });
      if (data === undefined) throw new {{ pascal }}Error(apiErrorCode(error, response));
      return { ...data, items: data.items.map(to{{ pascal }}) };
    },
    async get(id) {
      const { data, error, response } = await api.GET("/{{ plural }}/{id}", {
        params: { path: { id } },
      });
      if (data === undefined) throw new {{ pascal }}Error(apiErrorCode(error, response));
      return to{{ pascal }}(data);
    },
    async create(draft) {
      const { data, error, response } = await api.POST("/{{ plural }}", { body: toRequest(draft) });
      if (data === undefined) throw new {{ pascal }}Error(apiErrorCode(error, response));
      return to{{ pascal }}(data);
    },
    async update(id, draft) {
      const { data, error, response } = await api.PUT("/{{ plural }}/{id}", {
        params: { path: { id } },
        body: toRequest(draft),
      });
      if (data === undefined) throw new {{ pascal }}Error(apiErrorCode(error, response));
      return to{{ pascal }}(data);
    },
    async remove(id) {
      const { error, response } = await api.DELETE("/{{ plural }}/{id}", {
        params: { path: { id } },
      });
      if (!response.ok) throw new {{ pascal }}Error(apiErrorCode(error, response));
    },
  };
}