HTTPサーバー
HTTP server
あなたは、ユーザーがプレーヤーが勝ったゲームの数を追跡できるWebサーバーを作成するように求められました。
GET /players/{name}は、勝利の合計数を示す数値を返す必要がありますPOST /players/{name}は、その名前の勝利を記録し、後続のPOSTごとに増分する必要があります
TDDアプローチに従い、できる限り迅速にソフトウェアを動作させ、解決策が見つかるまで小さな反復的な改善を行います。このアプローチを取ることによって
- 問題のあるスペースを常に小さく保つ
- なかなか抜け出すことができない状況に陥ってはいけません
- 行き詰まったり失われたりした場合でも、元に戻しても負荷は減りません。
レッド、グリーン、リファクタリング（Red, green, refactor）
この本全体を通して、テストを作成して失敗するのを監視するTDDプロセスを強調し、（red）、それを機能させるための minimal 量のコードを記述し、（green）してリファクタリングします。
最小限のコードを書くというこの規律は、TDDが与える安全性の観点から重要です。できるだけ早く「赤（red）」から抜け出すように努力する必要があります。
ケント・ベックは次のように説明しています。
テストを迅速に実行し、プロセスで必要なあらゆる罪を犯します。
テストの安全性に後押しされてリファクタリングされるため、これらの罪を犯すことができます。
これを行わないとどうなりますか？
赤で表示されている変更が多いほど、テストではカバーされない問題を追加する可能性が高くなります。
アイデアは、ウサギの穴に何時間も陥らないように、テストによって駆動される小さなステップで有用なコードを繰り返し書くことです。
鶏肉と卵
これを段階的に構築するにはどうすればよいですか？何かを保存せずにプレーヤーを
GETすることはできず、GETエンドポイントがすでに存在しない状態でPOSTが機能したかどうかを知るのは難しいようです。これが mocking の輝きです。
- プレーヤーのスコアを取得するには、
GETにPlayerStorething が必要です。これはインターフェースである必要があるので、テストするときに、実際のストレージコードを実装する必要なく、コードをテストするための簡単なスタブを作成できます。 POSTの場合、PlayerStoreへの呼び出しを spy して、プレーヤーが正しく保存されていることを確認できます。保存の実装は検索と連動しません。- 機能するソフトウェアをすばやく用意するために、非常にシンプルなインメモリ実装を作成し、その後、任意のストレージメカニズムに基づく実装を作成できます。
最初にテストを書く
テストを作成し、ハードコードされた値を返すことでテストを成功させることができます。ケントベックはこれを「偽造（
Faking it）」と呼んでいます。動作するテストができたら、その定数を削除するのに役立つテストをさらに記述できます。この非常に小さなステップを実行することで、アプリケーションロジックをあまり気にすることなく、プロジェクト全体の構造を正しく機能させる重要な出発点を作ることができます。
1
func ListenAndServe(addr string, handler Handler) error
Copied!
1
type Handler interface {
2
ServeHTTP(ResponseWriter, *Request)
3
}
Copied!
タイプは、2つの引数を期待する
ServeHTTPメソッドを実装することにより、ハンドラーインターフェースを実装します。1つ目は、レスポンスを書き込む場所で、2つ目はサーバーに送信されたHTTPリクエストです。これらの2つの引数を受け取る関数
PlayerServerのテストを書いてみましょう。送信されるリクエストは、プレーヤーのスコアを取得することです。これは"20"であると予想されます。1
func TestGETPlayers(t *testing.T) {
2
t.Run("returns Pepper's score", func(t *testing.T) {
3
request, _ := http.NewRequest(http.MethodGet, "/players/Pepper", nil)
4
response := httptest.NewRecorder()
5
6
PlayerServer(response, request)
7
8
got := response.Body.String()
9
want := "20"
10
11
if got != want {
12
t.Errorf("got %q, want %q", got, want)
13
}
14
})
15
}
Copied!
サーバーをテストするには、送信する
Requestが必要であり、ハンドラーがResponseWriterに書き込む内容を spy する必要があります。http.NewRequestを使用してリクエストを作成します。最初の引数はリクエストのメソッドで、2番目はリクエストのパスです。nil引数はリクエストの本文を参照します。この場合、設定する必要はありません。net/http/httptestには、ResponseRecorderというスパイが既に作成されているので、それを使用できます。応答として書き込まれた内容を検査するための多くの便利な方法があります。
テストを実行してみます
./server_test.go:13:2: undefined: PlayerServerテストを実行するための最小限のコードを記述し、失敗したテスト出力を確認します
コンパイラーは正常に動いています。耳を傾けてください。
PlayerServerを定義します1
func PlayerServer() {}
Copied!
再試行
1
./server_test.go:13:14: too many arguments in call to PlayerServer
2
have (*httptest.ResponseRecorder, *http.Request)
3
want ()
Copied!
関数に引数を追加します
1
import "net/http"
2
3
func PlayerServer(w http.ResponseWriter, r *http.Request) {
4
5
}
Copied!
コードがコンパイルされ、テストが失敗します
1
=== RUN TestGETPlayers/returns_Pepper's_score
2
--- FAIL: TestGETPlayers/returns_Pepper's_score (0.00s)
3
server_test.go:20: got '', want '20'
Copied!
成功させるのに十分なコードを書く
DIの章から、
Greet関数を使用してHTTPサーバーに触れました。 net/httpのResponseWriterもioWriterを実装しているため、fmt.Fprintを使用して文字列をHTTP応答として送信できることがわかりました。1
func PlayerServer(w http.ResponseWriter, r *http.Request) {
2
fmt.Fprint(w, "20")
3
}
Copied!
これでテストに成功するはずです。
足場を完成させましょう
これをアプリケーションに結び付けたいと思います。これは重要です
- 実際に動作するソフトウェアを用意します。そのためのテストを記述したくありません。コードの動作を確認することをお勧めします。
- コードをリファクタリングすると、プログラムの構造が変更される可能性があります。これは、インクリメンタルアプローチの一部として、アプリケーションにも反映されるようにしたいと考えています。
アプリケーション用の新しいファイルを作成し、このコードを配置します。
1
package main
2
3
import (
4
"log"
5
"net/http"
6
)
7
8
func main() {
9
handler := http.HandlerFunc(PlayerServer)
10
if err := http.ListenAndServe(":5000", handler); err != nil {
11
log.Fatalf("could not listen on port 5000 %v", err)
12
}
13
}
Copied!
これまでのところ、すべてのアプリケーションコードが1つのファイルに含まれていますが、これは、物事を異なるファイルに分離する必要がある大規模なプロジェクトでは、ベストプラクティスではありません。
これを実行するには、ディレクトリ内のすべての
.goファイルを取得してプログラムをビルドするgo buildを実行します。その後、./myprogramで実行できます。http.HandlerFunc
http.HandlerFunc以前に
Handlerインターフェースがサーバーを作るために実装する必要があるものであることを探りました。 通常は、structを作成してそれを行い、独自のServeHTTPメソッドを実装してインターフェースを実装します。ただし、構造体のユースケースはデータを保持するためのものですが、currently には状態がないため、データを作成するのは適切ではありません。HandlerFuncタイプは、通常の関数をHTTPハンドラーとして使用できるようにするアダプターです。fが適切なシグネチャを持つ関数である場合、HandlerFunc(f) はfを呼び出すハンドラーです。
1
type HandlerFunc func(ResponseWriter, *Request)
Copied!
ドキュメントから、タイプ
HandlerFuncがすでにServeHTTPメソッドを実装していることがわかります。PlayerServer関数をタイプキャストすることで、必要なHandlerを実装しました。http.ListenAndServe(":5000"...)
http.ListenAndServe(":5000"...)ListenAndServeは、ポートを使用してHandlerをリッスンします。ポートがすでにリッスンされている場合は「エラーerror」が返されるため、ifステートメントを使用してそのシナリオをキャプチャし、問題をユーザーに記録します。これから行うのは、ハードコーディングされた値から離れるようにポジティブな変更を強制する another テストを作成することです。
最初にテストを書く
別のサブテストをスイートに追加して、別のプレーヤーのスコアを取得しようとします。これにより、ハードコーディングされたアプローチが壊れます。
1
t.Run("returns Floyd's score", func(t *testing.T) {
2
request, _ := http.NewRequest(http.MethodGet, "/players/Floyd", nil)
3
response := httptest.NewRecorder()
4
5
PlayerServer(response, request)
6
7
got := response.Body.String()
8
want := "10"
9
10
if got != want {
11
t.Errorf("got %q, want %q", got, want)
12
}
13
})
Copied!
あなたは考えていたかもしれません。
確かに、どのプレイヤーがどのスコアを獲得するかを制御するために、何らかのストレージの概念が必要です。テストで値が非常に恣意的に見えるのは奇妙です。
できる限り小さなステップを実行するように心がけていることを忘れないでください。したがって、今は定数を壊そうとしているだけです。
テストを実行してみます
1
=== RUN TestGETPlayers/returns_Pepper's_score
2
--- PASS: TestGETPlayers/returns_Pepper's_score (0.00s)
3
=== RUN TestGETPlayers/returns_Floyd's_score
4
--- FAIL: TestGETPlayers/returns_Floyd's_score (0.00s)
5
server_test.go:34: got '20', want '10'
Copied!
成功させるのに十分なコードを書く
1
func PlayerServer(w http.ResponseWriter, r *http.Request) {
2
player := strings.TrimPrefix(r.URL.Path, "/players/")
3
4
if player == "Pepper" {
5
fmt.Fprint(w, "20")
6
return
7
}
8
9
if player == "Floyd" {
10
fmt.Fprint(w, "10")
11
return
12
}
13
}
Copied!
このテストにより、リクエストのURLを実際に確認して決定を迫られました。したがって、頭の中では、プレイヤーのストアとインターフェースについて心配している可能性があります。次の論理的なステップは、実際には routing のようです。
店舗コードから始めた場合、必要な変更の量はこれに比べて非常に大きくなります。 これは最終目標に向けたより小さなステップであり、テストによって推進されました。
現在、ルーティングライブラリを使用するという誘惑に抵抗しています。テストに合格するための最小のステップにすぎません。
r.URL.Pathはリクエストのパスを返すので、strings.TrimPrefixを使用して、 /players/を削除します。要求されたプレーヤーを取得します。それほど堅牢ではありませんが、とりあえずはうまくいくでしょう。リファクタリング♪
スコアの取得を関数に分離することで、
PlayerServerを簡略化できます1
func PlayerServer(w http.ResponseWriter, r *http.Request) {
2
player := strings.TrimPrefix(r.URL.Path, "/players/")
3
4
fmt.Fprint(w, GetPlayerScore(player))
5
}
6
7
func GetPlayerScore(name string) string {
8
if name == "Pepper" {
9
return "20"
10
}
11
12
if name == "Floyd" {
13
return "10"
14
}
15
16
return ""
17
}
Copied!
そして、いくつかのヘルパーを作成することで、テストのコードの一部を乾燥させることができます。
1
func TestGETPlayers(t *testing.T) {
2
t.Run("returns Pepper's score", func(t *testing.T) {
3
request := newGetScoreRequest("Pepper")
4
response := httptest.NewRecorder()
5
6
PlayerServer(response, request)
7
8
assertResponseBody(t, response.Body.String(), "20")
9
})
10
11
t.Run("returns Floyd's score", func(t *testing.T) {
12
request := newGetScoreRequest("Floyd")
13
response := httptest.NewRecorder()
14
15
PlayerServer(response, request)
16
17
assertResponseBody(t, response.Body.String(), "10")
18
})
19
}
20
21
func newGetScoreRequest(name string) *http.Request {
22
req, _ := http.NewRequest(http.MethodGet, fmt.Sprintf("/players/%s", name), nil)
23
return req
24
}
25
26
func assertResponseBody(t *testing.T, got, want string) {
27
t.Helper()
28
if got != want {
29
t.Errorf("response body is wrong, got %q want %q", got, want)
30
}
31
}
Copied!
しかし、私たちはまだ幸せであってはなりません。私たちのサーバーがスコアを知っていることは正しくありません。
私たちのリファクタリングは何をすべきかをかなり明確にしました。
スコア計算をハンドラーの本体から関数
GetPlayerScoreに移動しました。これは、インターフェースを使用して懸念事項を分離するのに適切な場所のように感じます。代わりにリファクタリングした関数をインターフェイスに移動してみましょう。
1
type PlayerStore interface {
2
GetPlayerScore(name string) int
3
}
Copied!
PlayerServerがPlayerStoreを使用できるようにするには、それを参照する必要があります。これで、アーキテクチャを変更して、PlayerServerがstructになるようにする適切なタイミングのように感じられます。1
type PlayerServer struct {
2
store PlayerStore
3
}
Copied!
最後に、新しい構造体にメソッドを追加して既存のハンドラーコードを挿入することにより、
Handlerインターフェースを実装します。1
func (p *PlayerServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
2
player := strings.TrimPrefix(r.URL.Path, "/players/")
3
fmt.Fprint(w, p.store.GetPlayerScore(player))
4
}
Copied!
他の唯一の変更は、定義したローカル関数（これで削除できます）ではなく、
store.GetPlayerScoreを呼び出してスコアを取得することです。サーバーの完全なコードリストは次のとおりです。
1
type PlayerStore interface {
2
GetPlayerScore(name string) int
3
}
4
5
type PlayerServer struct {
6
store PlayerStore
7
}
8
9
func (p *PlayerServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
10
player := strings.TrimPrefix(r.URL.Path, "/players/")
11
fmt.Fprint(w, p.store.GetPlayerScore(player))
12
}
Copied!
問題を修正する
これはかなりの数の変更であり、テストとアプリケーションがコンパイルされなくなることがわかっています。リラックスして、コンパイラーにそれを実行させてください。
./main.go:9:58: type PlayerServer is not an expressionテストを変更して、代わりに
PlayerServerの新しいインスタンスを作成し、そのメソッドServeHTTPを呼び出す必要があります。1
func TestGETPlayers(t *testing.T) {
2
server := &PlayerServer{}
3
4
t.Run("returns Pepper's score", func(t *testing.T) {
5
request := newGetScoreRequest("Pepper")
6
response := httptest.NewRecorder()
7
8
server.ServeHTTP(response, request)
9
10
assertResponseBody(t, response.Body.String(), "20")
11
})
12
13
t.Run("returns Floyd's score", func(t *testing.T) {
14
request := newGetScoreRequest("Floyd")
15
response := httptest.NewRecorder()
16
17
server.ServeHTTP(response, request)
18
19
assertResponseBody(t, response.Body.String(), "10")
20
})
21
}
Copied!
まだストアを作成することについてはまだ心配していないことに注意してください。できるだけ早くコンパイラーを渡したいだけです。
コンパイルするコードを優先し、次にテストに合格するコードを優先する習慣を身に付ける必要があります。
コードがコンパイルされていないときに（スタブストアのような）機能を追加することにより、潜在的に more コンパイルの問題に直面することになります。
同じ理由で
main.goはコンパイルされません。1
func main() {
2
server := &PlayerServer{}
3
4
if err := http.ListenAndServe(":5000", server); err != nil {
5
log.Fatalf("could not listen on port 5000 %v", err)
6
}
7
}
Copied!
最後に、すべてがコンパイルされていますが、テストは失敗しています
1
=== RUN TestGETPlayers/returns_the_Pepper's_score
2
panic: runtime error: invalid memory address or nil pointer dereference [recovered]
3
panic: runtime error: invalid memory address or nil pointer dereference
Copied!
これは、テストで
PlayerStoreを渡していないためです。スタブを1つ作成する必要があります。1
type StubPlayerStore struct {
2
scores map[string]int
3
}
4
5
func (s *StubPlayerStore) GetPlayerScore(name string) int {
6
score := s.scores[name]
7
return score
8
}
Copied!
mapは、テスト用のスタブ キー/値（key/value）ストアを作成する迅速で簡単な方法です。次に、テスト用にこれらのストアの1つを作成して、PlayerServerに送信します。1
func TestGETPlayers(t *testing.T) {
2
store := StubPlayerStore{
3
map[string]int{
4
"Pepper": 20,
5
"Floyd": 10,
6
},
7
}
8
server := &PlayerServer{&store}
9
10
t.Run("returns Pepper's score", func(t *testing.T) {
11
request := newGetScoreRequest("Pepper")
12
response := httptest.NewRecorder()
13
14
server.ServeHTTP(response, request)
15
16
assertResponseBody(t, response.Body.String(), "20")
17
})
18
19
t.Run("returns Floyd's score", func(t *testing.T) {
20
request := newGetScoreRequest("Floyd")
21
response := httptest.NewRecorder()
22
23
server.ServeHTTP(response, request)
24
25
assertResponseBody(t, response.Body.String(), "10")
26
})
27
}
Copied!
テストは成功し、見た目も良くなっています。ストアの導入により、コードの背後にある intent がより明確になりました。
PlayerStoreにこのデータがあるので、それをPlayerServerで使用すると、次の応答が得られるはずであることを読者に伝えています。アプリケーションを実行します
これで、このリファクタリングを完了するために必要な最後のことは、アプリケーションの動作を確認することです。プログラムは起動するはずですが、
http://localhost:5000/players/Pepperでサーバーにアクセスしようとすると、恐ろしい応答が返されます。これは、
PlayerStoreを渡していないためです。1つの実装を作成する必要がありますが、意味のあるデータを格納していないため、当面はハードコーディングする必要があるため、現時点ではそれは困難です。
1
type InMemoryPlayerStore struct{}
2
3
func (i *InMemoryPlayerStore) GetPlayerScore(name string) int {
4
return 123
5
}
6
7
func main() {
8
server := &PlayerServer{&InMemoryPlayerStore{}}
9
10
if err := http.ListenAndServe(":5000", server); err != nil {
11
log.Fatalf("could not listen on port 5000 %v", err)
12
}
13
}
Copied!
go buildを再度実行して同じURLにアクセスすると、"123"が表示されます。すばらしいとは言えませんが、データを保存するまでは、私たちができる最高のことです。私たちは次に何をすべきかについていくつかのオプションがあります
- レイヤーが存在しないシナリオを処理します
POST /players/{name}シナリオを処理します- メインアプリケーションが起動していても実際に動作していないのは気分がよくありませんでした。問題を確認するために手動でテストする必要がありました。
POSTシナリオは「ハッピーパス」に近づきますが、すでにそのコンテキストにいるため、最初に不足しているプレーヤーシナリオに取り組む方が簡単だと思います。残りは後で行います。最初にテストを書く
不足しているプレーヤーのシナリオを既存のスイートに追加する
1
t.Run("returns 404 on missing players", func(t *testing.T) {
2
request := newGetScoreRequest("Apollo")
3
response := httptest.NewRecorder()
4
5
server.ServeHTTP(response, request)
6
7
got := response.Code
8
want := http.StatusNotFound
9
10
if got != want {
11
t.Errorf("got status %d want %d", got, want)
12
}
13
})
Copied!
テストを実行してみます
1
=== RUN TestGETPlayers/returns_404_on_missing_players
2
--- FAIL: TestGETPlayers/returns_404_on_missing_players (0.00s)
3
server_test.go:56: got status 200 want 404
Copied!
成功させるのに十分なコードを書く
1
func (p *PlayerServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
2
player := strings.TrimPrefix(r.URL.Path, "/players/")
3
4
w.WriteHeader(http.StatusNotFound)
5
6
fmt.Fprint(w, p.store.GetPlayerScore(player))
7
}
Copied!
TDDの提唱者が「コードを最小限にするだけでコードをパスできるようにする」と言ったとき、私はときどき目を凝らします。
しかし、このシナリオは例をよく示しています。私は最低限の（正しくないことを知っている）を実行しました。これはすべての応答に
StatusNotFoundを書き込むことですが、すべてのテストに成功しています！テストに合格するために最低限必要なことを行うことで、テストのギャップを強調できます。今回のケースでは、プレイヤーがストアに存在するときに
StatusOKを取得する必要があることを表明していません。他の2つのテストを更新してステータスを評価し、コードを修正します。
これが新しいテストです
1
func TestGETPlayers(t *testing.T) {
2
store := StubPlayerStore{
3
map[string]int{
4
"Pepper": 20,
5
"Floyd": 10,
6
},
7
}
8
server := &PlayerServer{&store}
9
10
t.Run("returns Pepper's score", func(t *testing.T) {
11
request := newGetScoreRequest("Pepper")
12
response := httptest.NewRecorder()
13
14
server.ServeHTTP(response, request)
15
16
assertStatus(t, response.Code, http.StatusOK)
17
assertResponseBody(t, response.Body.String(), "20")
18
})
19
20
t.Run("returns Floyd's score", func(t *testing.T) {
21
request := newGetScoreRequest("Floyd")
22
response := httptest.NewRecorder()
23
24
server.ServeHTTP(response, request)
25
26
assertStatus(t, response.Code, http.StatusOK)
27
assertResponseBody(t, response.Body.String(), "10")
28
})
29
30
t.Run("returns 404 on missing players", func(t *testing.T) {
31
request := newGetScoreRequest("Apollo")
32
response := httptest.NewRecorder()
33
34
server.ServeHTTP(response, request)
35
36
assertStatus(t, response.Code, http.StatusNotFound)
37
})
38
}
39
40
func assertStatus(t *testing.T, got, want int) {
41
t.Helper()
42
if got != want {
43
t.Errorf("did not get correct status, got %d, want %d", got, want)
44
}
45
}
46
47
func newGetScoreRequest(name string) *http.Request {
48
req, _ := http.NewRequest(http.MethodGet, fmt.Sprintf("/players/%s", name), nil)
49
return req
50
}
51
52
func assertResponseBody(t *testing.T, got, want string) {
53
t.Helper()
54
if got != want {
55
t.Errorf("response body is wrong, got %q want %q", got, want)
56
}
57
}
Copied!
現在、すべてのテストでステータスをチェックしているので、これを容易にするヘルパー
assertStatusを作成しました。これで、最初の2つのテストは200ではなく404が原因で失敗します。そのため、スコアが0の場合にのみ見つからないことを返すように
PlayerServerを修正できます。1
func (p *PlayerServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
2
player := strings.TrimPrefix(r.URL.Path, "/players/")
3
4
score := p.store.GetPlayerScore(player)
5
6
if score == 0 {
7
w.WriteHeader(http.StatusNotFound)
8
}
9
10
fmt.Fprint(w, score)
11
}
Copied!
スコアを保存する
ストアからスコアを取得できるようになったので、新しいスコアを格納できるようになりました。
最初にテストを書く
1
func TestStoreWins(t *testing.T) {
2
store := StubPlayerStore{
3
map[string]int{},
4
}
5
server := &PlayerServer{&store}
6
7
t.Run("it returns accepted on POST", func(t *testing.T) {
8
request, _ := http.NewRequest(http.MethodPost, "/players/Pepper", nil)
9
response := httptest.NewRecorder()
10
11
server.ServeHTTP(response, request)
12
13
assertStatus(t, response.Code, http.StatusAccepted)
14
})
15
}
Copied!
まず、POSTで特定のルートに到達した場合に正しいステータスコードを取得することを確認します。これにより、異なる種類のリクエストを受け入れ、それを
GET /players/{name}とは異なる方法で処理する機能を実行できます。これがうまくいったら、ハンドラーとストアの相互作用を評価し始めることができます。テストを実行してみます
1
=== RUN TestStoreWins/it_returns_accepted_on_POST
2
--- FAIL: TestStoreWins/it_returns_accepted_on_POST (0.00s)
3
server_test.go:70: did not get correct status, got 404, want 202
Copied!
成功させるのに十分なコードを書く
意図的に罪を犯しているので、リクエストのメソッドに基づく
ifステートメントでうまくいくことを覚えておいてください。1
func (p *PlayerServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
2
3
if r.Method == http.MethodPost {
4
w.WriteHeader(http.StatusAccepted)
5
return
6
}
7
8
player := strings.TrimPrefix(r.URL.Path, "/players/")
9
10
score := p.store.GetPlayerScore(player)
11
12
if score == 0 {
13
w.WriteHeader(http.StatusNotFound)
14
}
15
16
fmt.Fprint(w, score)
17
}
Copied!
リファクタリング♪
ハンドラーは少し混乱しています。コードを分割して、さまざまな機能を簡単に追跡して分離し、新しい機能に分離しましょう。
1
func (p *PlayerServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
2
3
switch r.Method {
4
case http.MethodPost:
5
p.processWin(w)
6
case http.MethodGet:
7
p.showScore(w, r)
8
}
9
10
}
11
12
func (p *PlayerServer) showScore(w http.ResponseWriter, r *http.Request) {
13
player := strings.TrimPrefix(r.URL.Path, "/players/")
14
15
score := p.store.GetPlayerScore(player)
16
17
if score == 0 {
18
w.WriteHeader(http.StatusNotFound)
19
}
20
21
fmt.Fprint(w, score)
22
}
23
24
func (p *PlayerServer) processWin(w http.ResponseWriter) {
25
w.WriteHeader(http.StatusAccepted)
26
}
Copied!
これにより、
ServeHTTPのルーティングの側面が少し明確になり、格納に関する次の反復がprocessWinの内部に収まるようになります次に、
POST /players/{name}を実行するときに、PlayerStoreが勝利を記録するように指示されていることを確認します。最初にテストを書く
これは、
StubPlayerStoreを新しいRecordWinメソッドで拡張し、その呼び出しをスパイすることで実現できます。1
type StubPlayerStore struct {
2
scores map[string]int
3
winCalls []string
4
}
5
6
func (s *StubPlayerStore) GetPlayerScore(name string) int {
7
score := s.scores[name]
8
return score
9
}
10
11
func (s *StubPlayerStore) RecordWin(name string) {
12
s.winCalls = append(s.winCalls, name)
13
}
Copied!
テストを拡張して、開始の呼び出しの数を確認します。
1
func TestStoreWins(t *testing.T) {
2
store := StubPlayerStore{
3
map[string]int{},
4
}
5
server := &PlayerServer{&store}
6
7
t.Run("it records wins when POST", func(t *testing.T) {
8
request := newPostWinRequest("Pepper")
9
response := httptest.NewRecorder()
10
11
server.ServeHTTP(response, request)
12
13
assertStatus(t, response.Code, http.StatusAccepted)
14
15
if len(store.winCalls) != 1 {
16
t.Errorf("got %d calls to RecordWin want %d", len(store.winCalls), 1)
17
}
18
})
19
}
20
21
func newPostWinRequest(name string) *http.Request {
22
req, _ := http.NewRequest(http.MethodPost, fmt.Sprintf("/players/%s", name), nil)
23
return req
24
}
Copied!
テストを実行してみます
1
./server_test.go:26:20: too few values in struct initializer
2
./server_test.go:65:20: too few values in struct initializer
Copied!
テストを実行するための最小限のコードを記述し、失敗したテスト出力を確認します
新しいフィールドを追加したので、
StubPlayerStoreを作成するコードを更新する必要があります1
store := StubPlayerStore{
2
map[string]int{},
3
nil,
4
}
Copied!
1
--- FAIL: TestStoreWins (0.00s)
2
--- FAIL: TestStoreWins/it_records_wins_when_POST (0.00s)
3
server_test.go:80: got 0 calls to RecordWin want 1
Copied!
成功させるのに十分なコードを書く
特定の値ではなく呼び出しの数のみを評価しているため、最初の反復が少し小さくなります。
RecordWinを呼び出せるようにするには、インターフェイスを変更して、PlayerStoreが何であるかについてのPlayerServerの考えを更新する必要があります。1
type PlayerStore interface {
2
GetPlayerScore(name string) int
3
RecordWin(name string)
4
}
Copied!
これを行うことにより、
mainはコンパイルされなくなります1
./main.go:17:46: cannot use InMemoryPlayerStore literal (type *InMemoryPlayerStore) as type PlayerStore in field value:
2
*InMemoryPlayerStore does not implement PlayerStore (missing RecordWin method)
Copied!
コンパイラは何が悪いのかを教えてくれます。そのメソッドを持つように
InMemoryPlayerStoreを更新しましょう。1
type InMemoryPlayerStore struct{}
2
3
func (i *InMemoryPlayerStore) RecordWin(name string) {}
Copied!
テストを試して実行すると、コードのコンパイルに戻るはずですが、テストはまだ失敗しています。
PlayerStoreにRecordWinがあるので、PlayerServer内で呼び出すことができます。1
func (p *PlayerServer) processWin(w http.ResponseWriter) {
2
p.store.RecordWin("Bob")
3
w.WriteHeader(http.StatusAccepted)
4
}
Copied!
テストを実行すれば合格です。明らかに、
"Bob"は、RecordWinに送信したいものではないので、テストをさらに改良してみましょう。最初にテストを書く
1
t.Run("it records wins on POST", func(t *testing.T) {
2
player := "Pepper"
3
4
request := newPostWinRequest(player)
5
response := httptest.NewRecorder()
6
7
server.ServeHTTP(response, request)
8
9
assertStatus(t, response.Code, http.StatusAccepted)
10
11
if len(store.winCalls) != 1 {
12
t.Fatalf("got %d calls to RecordWin want %d", len(store.winCalls), 1)
13
}
14
15
if store.winCalls[0] != player {
16
t.Errorf("did not store correct winner got %q want %q", store.winCalls[0], player)
17
}
18
})
Copied!
winCallsスライスに1つの要素があることがわかったので、最初の要素を安全に参照して、それがplayerと等しいことを確認できます。テストを実行してみます
1
=== RUN TestStoreWins/it_records_wins_on_POST
2
--- FAIL: TestStoreWins/it_records_wins_on_POST (0.00s)
3
server_test.go:86: did not store correct winner got 'Bob' want 'Pepper'
Copied!
成功させるのに十分なコードを書く
1
func (p *PlayerServer) processWin(w http.ResponseWriter, r *http.Request) {
2
player := strings.TrimPrefix(r.URL.Path, "/players/")
3
p.store.RecordWin(player)
4
w.WriteHeader(http.StatusAccepted)
5
}
Copied!
processWinをhttp.Requestに変更して、URLを見てプレーヤーの名前を抽出できるようにしました。それができたら、正しい値でstoreを呼び出してテストに合格することができます。リファクタリング♪
2つの場所で同じ方法でプレイヤー名を抽出しているので、このコードを少しDRYにすることができます。
1
func (p *PlayerServer) ServeHTTP(w http.ResponseWriter, r *http.Request) {
2
player := strings.TrimPrefix(r.URL.Path, "/players/")
3
4
switch r.Method {
5
case http.MethodPost:
6
p.processWin(w, player)
7
case http.MethodGet:
8
p.showScore(w, player)
9
}
10
}
11
12
func (p *PlayerServer) showScore(w http.ResponseWriter, player string) {
13
score := p.store.GetPlayerScore(player)
14
15
if score == 0 {
16
w.WriteHeader(http.StatusNotFound)
17
}
18
19
fmt.Fprint(w, score)
20
}
21
22
func (p *PlayerServer) processWin(w http.ResponseWriter, player string) {
23
p.store.RecordWin(player)
24
w.WriteHeader(http.StatusAccepted)
25
}
Copied!
テストは成功していますが、実際に機能するソフトウェアはありません。
mainを実行して、意図したとおりにソフトウェアを使用すると、PlayerStoreを正しく実装するためのラウンドがないため、機能しません。これは問題ありません。ハンドラーに焦点を当てることで、事前に設計するのではなく、必要なインターフェースを特定しました。InMemoryPlayerStoreの周りにいくつかのテストを書き始めることができましたが、これは、プレーヤーのスコアを永続化するためのより堅牢な方法を実装するまで一時的にのみです（つまり、データベース）。ここでは、
PlayerServerとInMemoryPlayerStoreの間に 統合テスト を記述して、機能を完成させます。これにより、InMemoryPlayerStoreを直接テストする必要なく、アプリケーションが機能していると確信できるという目標を達成できます。それだけでなく、データベースでのPlayerStoreの実装に取り掛かると、同じ統合テストでその実装をテストできます。統合テスト
統合テストは、システムのより広い領域が機能することをテストするのに役立ちますが、次の点に注意する必要があります。
- 書くのが難しい
- 失敗すると、なぜ（通常、統合テストのコンポーネント内のバグであるか）を理解するのが難しくなるため、修正が困難になる可能性があります。
- 実行に時間がかかる場合があります（データベースなどの「実際の」コンポーネントで使用されることが多いため）。
そのためにも、テストピラミッド（The Test Pyramid） をリサーチしておくことをお勧めします。
最初にテストを書く
簡潔にするために、最後のリファクタリングされた統合テストを紹介します。
1
func TestRecordingWinsAndRetrievingThem(t *testing.T) {
2
store := InMemoryPlayerStore{}
3
server := PlayerServer{&store}
4
player := "Pepper"
5
6
server.ServeHTTP(httptest.NewRecorder(), newPostWinRequest(player))
7
server.ServeHTTP(httptest.NewRecorder(), newPostWinRequest(player))
8
server.ServeHTTP(httptest.NewRecorder(), newPostWinRequest(player))
9
10
response := httptest.NewRecorder()
11
server.ServeHTTP(response, newGetScoreRequest(player))
12
assertStatus(t, response.Code, http.StatusOK)
13
14
assertResponseBody(t, response.Body.String(), "3")
15
}
Copied!
- 統合しようとしている2つのコンポーネント、
InMemoryPlayerStoreとPlayerServerを作成しています。 - 次に、
playerの3つの勝利を記録するために3つのリクエストを発行します。このテストのステータスコードは、それらがうまく統合されているかどうかには関係がないので、あまり心配していません。 - 次に注意するのは変数
responseを格納することなので、playerのスコアを取得しようとするためです。
テストを実行してみます
1
--- FAIL: TestRecordingWinsAndRetrievingThem (0.00s)
2
server_integration_test.go:24: response body is wrong, got '123' want '3'
Copied!
成功させるのに十分なコードを書く
私はここでいくつかの自由を取り、テストを書かずに慣れるよりも多くのコードを書きます。
これは許可されています！正常に機能していることを確認するテストはまだありますが、
InMemoryPlayerStoreで使用している特定のユニットの周りではありません。このシナリオで行き詰まった場合は、変更を失敗したテストに戻し、
InMemoryPlayerStoreに関連するより具体的な単体テストを記述して、ソリューションを実行できるようにします。1
func NewInMemoryPlayerStore() *InMemoryPlayerStore {
2
return &InMemoryPlayerStore{map[string]int{}}
3
}
4
5
type InMemoryPlayerStore struct {
6
store map[string]int
7
}
8
9
func (i *InMemoryPlayerStore) RecordWin(name string) {
10
i.store[name]++
11
}
12
13
func (i *InMemoryPlayerStore) GetPlayerScore(name string) int {
14
return i.store[name]
15
}
Copied!
- データを保存する必要があるので、
map[string]intをInMemoryPlayerStore構造体に追加しました - 便宜上、ストアを初期化するために
NewInMemoryPlayerStoreを作成し、それを使用するように統合テストを更新しました（store := NewInMemoryPlayerStore()） - 残りのコードは、
mapをラップするだけです
統合テストに合格したので、
mainを変更してNewInMemoryPlayerStore()を使用するだけです。1
package main
2
3
import (
4
"log"
5
"net/http"
6
)
7
8
func main() {
9
server := &PlayerServer{NewInMemoryPlayerStore()}
10
11
if err := http.ListenAndServe(":5000", server); err != nil {
12
log.Fatalf("could not listen on port 5000 %v", err)
13
}
14
}
Copied!
ビルドして実行し、
curlを使用してテストします。- これを数回実行し、
curl -X POST http://localhost:5000/players/Pepperのようにプレーヤー名を変更します curl http://localhost:5000/players/Pepperでスコアを確認してください
すごい！ REST風のサービスを作成しました。これを進めるには、データストアを選択して、プログラムの実行時間よりも長いスコアを保持する必要があります。
- ストアを選択してください （Bolt? Mongo? Postgres? File system?）
PostgresPlayerStoreにPlayerStoreを実装させる- TDDの機能により、確実に機能します
- 統合テストに接続し、問題がないことを確認します
- 最後に
mainに接続します
リファクタリング♪
私たちは、ほぼ、そこにいる！このような同時実行エラーを防ぐために少し努力しましょう
1
fatal error: concurrent map read and map write
Copied!
ミューテックスを追加することで、特に
RecordWin関数のカウンターに同時実行の安全性を適用します。 mutexの詳細については、同期の章をご覧ください。まとめ
http.Handler
http.Handler- このインターフェースを実装してWebサーバーを作成する
- 通常の関数を
http.Handlerに変換するには、http.HandlerFuncを使用します httptest.NewRecorderを使用してResponseWriterとして渡し、ハンドラーが送信する応答をスパイできるようにしますhttp.NewRequestを使用して、システムに入ると予想されるリクエストを作成します
インターフェース、モッキング、DI
- 小さなチャンクでシステムを繰り返し構築できます
- 実際のストレージを必要とせずにストレージを必要とするハンドラーを開発できます
- TDDは必要なインターフェースを駆動します
罪を犯して、リファクタリング（そして、ソースコントロールにコミットして）
- コンパイルに失敗したり、テストに失敗したりすることは、できるだけ早く脱出しなければならない赤信号として扱う必要があります。
- そのために必要なコードだけを書いてください。その後、リファクタリングをしてコードを良くしてください。