// // Copyright 2021-2023 Buf Technologies, Inc.
// //
// // Licensed under the Apache License, Version 2.0 (the "License");
// // you may not use this file except in compliance with the License.
// // You may obtain a copy of the License at
// //
// //      http://www.apache.org/licenses/LICENSE-2.0
// //
// // Unless required by applicable law or agreed to in writing, software
// // distributed under the License is distributed on an "AS IS" BASIS,
// // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// // See the License for the specific language governing permissions and
// // limitations under the License.
package triple_protocol

//
//import (
//	"errors"
//	"fmt"
//	"net/http"
//	"testing"
//
//	"dubbo.apache.org/dubbo-go/v3/protocol/grpc_new/connect/assert"
//	pingv1 "dubbo.apache.org/dubbo-go/v3/protocol/grpc_new/connect/proto/connect/ping/v1"
//)
//
//func TestClientStreamForClient_NoPanics(t *testing.T) {
//	t.Parallel()
//	initErr := errors.New("client init failure")
//	clientStream := &ClientStreamForClient[pingv1.PingRequest, pingv1.PingResponse]{err: initErr}
//	assert.ErrorIs(t, clientStream.Send(&pingv1.PingRequest{}), initErr)
//	verifyHeaders(t, clientStream.RequestHeader())
//	res, err := clientStream.CloseAndReceive()
//	assert.Nil(t, res)
//	assert.ErrorIs(t, err, initErr)
//	conn, err := clientStream.Conn()
//	assert.NotNil(t, err)
//	assert.Nil(t, conn)
//}
//
//func TestServerStreamForClient_NoPanics(t *testing.T) {
//	t.Parallel()
//	initErr := errors.New("client init failure")
//	serverStream := &ServerStreamForClient[pingv1.PingResponse]{constructErr: initErr}
//	assert.ErrorIs(t, serverStream.Err(), initErr)
//	assert.ErrorIs(t, serverStream.Close(), initErr)
//	assert.NotNil(t, serverStream.Msg())
//	assert.False(t, serverStream.Receive())
//	verifyHeaders(t, serverStream.ResponseHeader())
//	verifyHeaders(t, serverStream.ResponseTrailer())
//	conn, err := serverStream.Conn()
//	assert.NotNil(t, err)
//	assert.Nil(t, conn)
//}
//
//func TestServerStreamForClient(t *testing.T) {
//	t.Parallel()
//	stream := &ServerStreamForClient[pingv1.PingResponse]{conn: &nopStreamingClientConn{}}
//	// Ensure that each call to Receive allocates a new message. This helps
//	// vtprotobuf, which doesn't automatically zero messages before unmarshaling
//	// (see https://github.com/bufbuild/connect-go/issues/345), and it's also
//	// less error-prone for users.
//	assert.True(t, stream.Receive())
//	first := fmt.Sprintf("%p", stream.Msg())
//	assert.True(t, stream.Receive())
//	second := fmt.Sprintf("%p", stream.Msg())
//	assert.NotEqual(t, first, second)
//	conn, err := stream.Conn()
//	assert.Nil(t, err)
//	assert.NotNil(t, conn)
//}
//
//func TestBidiStreamForClient_NoPanics(t *testing.T) {
//	t.Parallel()
//	initErr := errors.New("client init failure")
//	bidiStream := &BidiStreamForClient[pingv1.CumSumRequest, pingv1.CumSumResponse]{err: initErr}
//	res, err := bidiStream.Receive()
//	assert.Nil(t, res)
//	assert.ErrorIs(t, err, initErr)
//	verifyHeaders(t, bidiStream.RequestHeader())
//	verifyHeaders(t, bidiStream.ResponseHeader())
//	verifyHeaders(t, bidiStream.ResponseTrailer())
//	assert.ErrorIs(t, bidiStream.Send(&pingv1.CumSumRequest{}), initErr)
//	assert.ErrorIs(t, bidiStream.CloseRequest(), initErr)
//	assert.ErrorIs(t, bidiStream.CloseResponse(), initErr)
//	conn, err := bidiStream.Conn()
//	assert.NotNil(t, err)
//	assert.Nil(t, conn)
//}
//
//func verifyHeaders(t *testing.T, headers http.Header) {
//	t.Helper()
//	assert.Equal(t, headers, http.Header{})
//
//	// Verify set/del don't panic
//	headers.Set("a", "b")
//	headers.Del("a")
//}
//
//type nopStreamingClientConn struct {
//	StreamingClientConn
//}
//
//func (c *nopStreamingClientConn) Receive(msg any) error {
//	return nil
//}