package main

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"io/ioutil"
	"net/http"

	"github.com/go-kit/kit/transport/http"
)

func main() {
	http.Handle("/your-endpoint", http.NewServer(
		yourEndpoint,
		decodeRequest,
		encodeResponse,
	))
}

// 請(qǐng)求和響應(yīng)類(lèi)型
type YourRequest struct {
	// 定義你的請(qǐng)求結(jié)構(gòu)
	// ...
}

type YourResponse struct {
	// 定義你的響應(yīng)結(jié)構(gòu)
	// ...
}

// 你的端點(diǎn)邏輯
func yourEndpoint(ctx context.Context, request interface{}) (interface{}, error) {
	// 獲取原始請(qǐng)求體
	rawBody, ok := request.(json.RawMessage)
	if !ok {
		return nil, errors.New("無(wú)法訪問(wèn)原始請(qǐng)求體")
	}

	// 根據(jù)需要處理原始請(qǐng)求體
	fmt.Println("原始請(qǐng)求體:", string(rawBody))

	// 你的實(shí)際端點(diǎn)邏輯在這里
	// ...

	// 返回響應(yīng)（示例響應(yīng)）
	return YourResponse{Message: "請(qǐng)求成功處理"}, nil
}

// 請(qǐng)求解碼器以獲取原始請(qǐng)求體
func decodeRequest(_ context.Context, r *http.Request) (interface{}, error) {
	// 讀取原始請(qǐng)求體
	body, err := ioutil.ReadAll(r.Body)
	if err != nil {
		return nil, err
	}

	// 將原始請(qǐng)求體作為json.RawMessage返回
	return json.RawMessage(body), nil
}

// 響應(yīng)編碼器
func encodeResponse(_ context.Context, w http.ResponseWriter, response interface{}) error {
	return json.NewEncoder(w).Encode(response)
}

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"net/http"

	"github.com/go-kit/kit/endpoint"
	"github.com/go-kit/kit/log"
	"github.com/go-kit/kit/transport/http"
)

// 表示請(qǐng)求負(fù)載的結(jié)構(gòu)體
type Request struct {
	Message string `json:"message"`
}

// 表示響應(yīng)負(fù)載的結(jié)構(gòu)體
type Response struct {
	Result string `json:"result"`
}

func main() {
	// 創(chuàng)建一個(gè)簡(jiǎn)單的Go Kit服務(wù)
	var svc MyService
	endpoint := makeUppercaseEndpoint(&svc)

	// 創(chuàng)建一個(gè)Go Kit HTTP傳輸
	httpHandler := http.NewServer(
		endpoint,
		decodeRequest,
		encodeResponse,
	)

	// 啟動(dòng)HTTP服務(wù)器
	http.ListenAndServe(":8080", httpHandler)
}

// MyService是一個(gè)只有一個(gè)方法的簡(jiǎn)單服務(wù)
type MyService struct{}

// Uppercase是MyService上的一個(gè)方法
func (MyService) Uppercase(ctx context.Context, message string) (string, error) {
	return fmt.Sprintf("接收到消息：%s", message), nil
}

// makeUppercaseEndpoint是創(chuàng)建Uppercase方法的Go Kit端點(diǎn)的輔助函數(shù)
func makeUppercaseEndpoint(svc MyService) endpoint.Endpoint {
	return func(ctx context.Context, request interface{}) (interface{}, error) {
		req := request.(Request)
		result, err := svc.Uppercase(ctx, req.Message)
		return Response{Result: result}, err
	}
}

// decodeRequest是解碼傳入JSON請(qǐng)求的輔助函數(shù)
func decodeRequest(_ context.Context, r *http.Request) (interface{}, error) {
	var request Request
	if err := json.NewDecoder(r.Body).Decode(&request); err != nil {
		return nil, err
	}
	return request, nil
}

// encodeResponse是編碼傳出JSON響應(yīng)的輔助函數(shù)
func encodeResponse(_ context.Context, w http.ResponseWriter, response interface{}) error {
	return json.NewEncoder(w).Encode(response)
}