リクエスト/レスポンスのエンコーディングのカスタマイズ

func main() {
    // ... サービスの初期化 ...

    // デフォルトのエンコーダーとデコーダー
    mux := goahttp.NewMuxer()
    handler := genhttp.New(
        endpoints,
        mux,
        goahttp.RequestDecoder,  // デフォルトのリクエストデコーダー
        goahttp.ResponseEncoder, // デフォルトのレスポンスエンコーダー
        nil,
        nil,
    )
}

package main

import (
    "context"
    "net/http"
    
    "github.com/vmihailenco/msgpack/v5"
    goahttp "goa.design/goa/v3/http"
    "strings"
)

type (
    // MessagePackエンコーダーの実装
    msgpackEnc struct {
        w http.ResponseWriter
    }

    // MessagePackデコーダーの実装
    msgpackDec struct {
        r *http.Request
    }
)

// カスタムエンコーダーコンストラクタ - MessagePackエンコーダーを作成
func msgpackEncoder(ctx context.Context, w http.ResponseWriter) goahttp.Encoder {
    return &msgpackEnc{w: w}
}

func (e *msgpackEnc) Encode(v any) error {
    w.Header().Set("Content-Type", "application/msgpack")
    return msgpack.NewEncoder(e.w).Encode(v)
}

// カスタムデコーダーコンストラクタ - 受信するMessagePackデータを処理
func msgpackDecoder(r *http.Request) goahttp.Decoder {
    return &msgpackDec{r: r}
}

func (d *msgpackDec) Decode(v any) error {
    return msgpack.NewDecoder(d.r.Body).Decode(v)
}

func main() {
    // ... サービスの初期化 ...

    // クライアントの要望（Acceptヘッダー）に基づくスマートなエンコーダー選択
    encodeFunc := func(ctx context.Context, w http.ResponseWriter) goahttp.Encoder {
        accept := ctx.Value(goahttp.AcceptTypeKey).(string)
        
        // q値を含む複数のタイプを含むAcceptヘッダーを解析
        // 例：「application/json;q=0.9,application/msgpack」
        types := strings.Split(accept, ",")
        for _, t := range types {
            mt := strings.TrimSpace(strings.Split(t, ";")[0])
            switch mt {
            case "application/msgpack":
                return msgpackEncoder(ctx, w)
            case "application/json", "*/*":
                return goahttp.ResponseEncoder(ctx, w)
            }
        }
        
        // 迷ったときは、JSONが味方です！
        return goahttp.ResponseEncoder(ctx, w)
    }

    // クライアントが送信するもの（Content-Type）に基づくスマートなデコーダー選択
    decodeFunc := func(r *http.Request) goahttp.Decoder {
        if r.Header.Get("Content-Type") == "application/msgpack" {
            return msgpackDecoder(r)
        }
        return goahttp.RequestDecoder(r)
    }

    // カスタムエンコーダー/デコーダーを接続
    handler := genhttp.New(
        endpoints,
        mux,
        decodeFunc,
        encodeFunc,
        nil,
        nil,
    )
}

# お馴染みのJSONを使用してコンサートを作成
curl -X POST http://localhost:8080/concerts \
    -H "Content-Type: application/json" \
    -d '{"artist":"The Beatles","venue":"O2 Arena"}'

# MessagePack形式でコンサートを取得 - 高性能クライアントに最適！
curl http://localhost:8080/concerts/123 \
    -H "Accept: application/msgpack" \
    --output concert.msgpack

# MessagePackデータを使用してコンサートを作成
curl -X POST http://localhost:8080/concerts \
    -H "Content-Type: application/msgpack" \
    --data-binary @concert.msgpack