Function TestPost

protocol/http/http_server_test.go:184–237

(t *testing.T)

}

func TestPost(t *testing.T) {
	handler, _ := newHttpHandler()
	defer handler.Clean()
	// 创建一个测试用的 HTTP 服务器
	server := httptest.NewServer(http.HandlerFunc(handler.PostHandler))
	defer server.Close()

	// 构造请求
	reqBody := map[string]string{
		"key":   "test_post",
		"value": "test_post_value",
	}
	reqBytes, _ := json.Marshal(reqBody)

	req, _ := http.NewRequest(http.MethodPost, server.URL, bytes.NewBuffer(reqBytes))
	req.Header.Set("Content-Type", "application/json")

	// 发送请求
	resp, err := http.DefaultClient.Do(req)
	if err != nil {
		t.Fatalf("could not send request: %v", err)
	}
	defer func(Body io.ReadCloser) {
		err := Body.Close()
		if err != nil {
			// 处理关闭响应主体失败的错误
		}
	}(resp.Body)

	// 检查响应
	if resp.StatusCode != http.StatusOK {
		t.Errorf("unexpected status code: %d", resp.StatusCode)
	}

	body, err := io.ReadAll(resp.Body)
	if err != nil {
		t.Errorf("ReadAll error: %v", err)
	}
	if string(body) != "ok" {
		t.Errorf("Post error: expected ok, got %s", string(body))
	}

	// 验证是否成功创建新资源
	valueByte, err := handler.Get([]byte("test_post"))
	if err != nil {
		t.Errorf("Get error: %v", err)
	}
	value := string(valueByte)
	if value != "test_post_value" {
		t.Errorf("Post error: expected %s, got %s", "test_value", value)
	} else {
		t.Logf("Post: test_value and Get: %s", value)
	}
}

func TestGetListKeysHandler(t *testing.T) {
	handler, _ := newHttpHandler()