-
Notifications
You must be signed in to change notification settings - Fork 0
/
mux.go
87 lines (74 loc) · 3.23 KB
/
mux.go
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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
package main
import (
"context"
"net/http"
"github.com/go-chi/chi/v5"
"github.com/go-playground/validator/v10"
"github.com/yukiHaga/go_todo_app/auth"
"github.com/yukiHaga/go_todo_app/clock"
"github.com/yukiHaga/go_todo_app/config"
"github.com/yukiHaga/go_todo_app/handler"
"github.com/yukiHaga/go_todo_app/service"
"github.com/yukiHaga/go_todo_app/store"
)
// 戻り値を*http.ServeMux型の値ではなくて、
// http.HandlerはServeHTTPを実装していればOK
// *http.ServeMuxは、ServeHTTPを実装しているから、戻り値でhttp.Handlerでも整合性がある
// 戻り値を*http.ServeMux型ではなくてhttp.Handlerにしておくことで、内部実装に依存しない関数シグネチャになる
// NewMux関数が返すルーティングでは、HTTPサーバーが稼働中かを確認するための/healthエンドポイントを一つ宣言しておく
// コンテナ実行環境の多くでは、コンテナをいつ再起動するかの判断条件として指定されたエンドポイントをポーリングするルールがある
// NewMuxを定義することで、muxライブラリの実装を内部に隠蔽できる。他のファイルのコードはNewMuxと依存することになるので、
// muxと直接依存することがなくなる。その結果、muxライブラリの変更がしやすくなる。muxライブラリが直接他のファイルのコードと依存していたら、
// muxライブラリを変更するのがとてもめんどくさい。今回の場合は変更が一箇所に集中できてる
func NewMux(ctx context.Context, cfg *config.Config) (http.Handler, func(), error) {
mux := chi.NewRouter()
mux.HandleFunc("/health", func(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json; charset=utf-8")
w.Write([]byte(`{"status": "ok"}`))
})
v := validator.New()
// このNewを使うことで、クライアント側でmysqlを指定するってことは一応なくなるのか
db, cleanup, err := store.New(ctx, cfg)
if err != nil {
return nil, cleanup, err
}
clocker := clock.RealClocker{}
// ここで依存性を注入している
// 注入することで、依存性関係を作り出している
r := &store.Repository{Clocker: clocker}
addTaskHandler := &handler.AddTask{
Service: &service.AddTask{DB: db, Repo: r},
Validator: v,
}
// ハンドラーのハンドラーファンクションを登録する
mux.Post("/tasks", addTaskHandler.ServeHTTP)
listTasksHandler := &handler.ListTasks{
Service: &service.ListTasks{DB: db, Repo: r},
}
mux.Get("/tasks", listTasksHandler.ServeHTTP)
// ここは依存性を注入している
registerUserHandler := &handler.RegisterUser{
Service: &service.RegisterUser{DB: db, Repo: r},
Validator: v,
}
mux.Post("/register", registerUserHandler.ServeHTTP)
rcli, err := store.NewKVS(ctx, cfg)
if err != nil {
return nil, cleanup, err
}
// TokenGeneratorってJWTerのことか
jwter, err := auth.NewJWTer(rcli, clocker)
if err != nil {
return nil, cleanup, err
}
l := &handler.Login{
Service: &service.Login{
DB: db,
Repo: r,
TokenGenerator: jwter,
},
Validator: v,
}
mux.Post("/login", l.ServeHTTP)
return mux, cleanup, nil
}