インターセプターの種類

var Monitor = Interceptor("Monitor", func() {
    Description("データを変更せずにメトリクスを収集します")
    
    // ペイロードからリクエストサイズを読み取る
    ReadPayload(func() {
        Attribute("size")        // 型と説明はペイロード型から継承
    })
    
    // リザルトからレスポンスステータスを読み取る
    ReadResult(func() {
        Attribute("status")      // 型と説明はリザルト型から継承
    })
})

var Enricher = Interceptor("Enricher", func() {
    Description("リクエストとレスポンスにコンテキスト情報を追加します")
    
    // ペイロードにリクエストIDを追加
    WritePayload(func() {
        Attribute("requestID")   // ペイロード型で定義されている必要がある
    })
    
    // リザルトにタイミングを追加
    WriteResult(func() {
        Attribute("processedAt") // リザルト型で定義されている必要がある
    })
})

var DataProcessor = Interceptor("DataProcessor", func() {
    Description("リクエストとレスポンスの両方を処理します")
    
    // リクエストデータを変換
    ReadPayload(func() {
        Attribute("rawData")     // ペイロードからの入力データ
        Attribute("format")      // 現在のフォーマット
    })
    WritePayload(func() {
        Attribute("processed")   // 変換されたデータ
        Attribute("newFormat")   // 新しいフォーマット
    })
    
    // レスポンスデータを変換
    ReadResult(func() {
        Attribute("status")      // レスポンスステータス
        Attribute("data")        // レスポンスデータ
    })
    WriteResult(func() {
        Attribute("enriched")    // 強化されたレスポンス
        Attribute("metadata")    // 追加されたメタデータ
    })
})

var Cache = Interceptor("Cache", func() {
    Description("GETリクエストのレスポンスキャッシュを実装します")
    
    // キャッシュキーとして使用するレコードIDを読み取る必要がある
    ReadPayload(func() {
        Attribute("recordID")    // ペイロード型からのUUID
    })
    
    // レスポンスにキャッシュメタデータを追加する
    WriteResult(func() {
        Attribute("cachedAt")    // リザルト型からのString
        Attribute("ttl")         // リザルト型からのInt
    })
})

var _ = Service("catalog", func() {
    // サービス内のすべてのメソッドにキャッシュを適用
    ServerInterceptor(Cache)
    
    Method("get", func() {
        Payload(func() {
            // Cacheインターセプターが使用する属性を定義
            Attribute("recordID", UUID, "キャッシュキーのためのレコード識別子")
        })
        Result(func() {
            // Cacheインターセプターが使用する属性を定義
            Attribute("cachedAt", String, "レスポンスがキャッシュされた時刻")
            Attribute("ttl", Int, "生存時間（秒）")
            // その他のリザルトフィールド...
        })
        HTTP(func() {
            GET("/{recordID}")
            Response(StatusOK)
        })
    })
})

var ClientContext = Interceptor("ClientContext", func() {
    Description("リクエストにクライアントコンテキストを追加しレート制限を追跡します")
    
    // 送信リクエストにクライアントコンテキストを追加
    WritePayload(func() {
        Attribute("clientVersion")  // ペイロード型からのString
        Attribute("clientID")       // ペイロード型からのUUID
        Attribute("region")         // ペイロード型からのString
    })
    
    // レスポンスからレート制限情報を追跡
    ReadResult(func() {
        Attribute("rateLimit")           // リザルト型から
        Attribute("rateLimitRemaining")  // リザルト型から
        Attribute("rateLimitReset")      // リザルト型から
    })
})

var _ = Service("inventory", func() {
    // すべてのクライアント呼び出しにコンテキスト情報を含める
    ClientInterceptor(ClientContext)
    
    Method("list", func() {
        Payload(func() {
            // ビジネスロジックの属性
            Attribute("page", Int, "ページ番号")
            Attribute("perPage", Int, "1ページあたりのアイテム数")
            
            // ClientContextインターセプターが必要とする属性
            Attribute("clientVersion", String, "クライアントライブラリのバージョン")
            Attribute("clientID", UUID, "このクライアントインスタンスの一意の識別子")
            Attribute("region", String, "クライアントの地理的リージョン")
        })
        Result(func() {
            // ビジネスロジックの属性
            Attribute("items", ArrayOf(Item))
            
            // ClientContextインターセプターが必要とする属性
            Attribute("rateLimit", Int, "現在のレート制限")
            Attribute("rateLimitRemaining", Int, "現在のウィンドウで残っているリクエスト数")
            Attribute("rateLimitReset", Int, "レート制限ウィンドウがリセットされる時刻")
        })
    })
})