package logic

import (
	"context"
	"linkpay/internal/service"
	"log"

	"git.linkiio.cn/linkpay/protobuf"
)

/*
*
  - 双向通信流示例查询订单
  - @param  void
  - @author  dc.To
  - @version 20250429
  - ApiOrders(ctx, &protobuf.Orders{
    Org: "org",
    })
*/
func ApiOrders(ctx context.Context, req *protobuf.Orders) {

	client := service.BssClient()

	stream, _ := client.Order(context.Background())

	//查询协程
	go func() {
		stream.Send(req)
		stream.CloseSend()
	}()

	//监听返回
	for {
		res, err := stream.Recv()
		if err != nil {
			break
		}
		log.Printf("Got order response: %v", res)
	}
}