Function runExecServer

cmd/ax/exec.go:259–296

(ctx context.Context, d *internal.Display, req *proto.ExecRequest)

}

func runExecServer(ctx context.Context, d *internal.Display, req *proto.ExecRequest) (*proto.ConfirmationContent, error) {
	conn, err := connect(execServerAddr)
	if err != nil {
		return nil, err
	}
	defer conn.Close()

	client := proto.NewControllerServiceClient(conn)
	stream, err := client.Exec(ctx, req)
	if err != nil {
		return nil, fmt.Errorf("error executing: %w", err)
	}

	var confirmation *proto.ConfirmationContent
	var lastSeq int32
	for {
		resp, err := stream.Recv()
		if err == io.EOF {
			break
		}
		if err != nil {
			return nil, fmt.Errorf("error receiving response: %w", err)
		}
		lastSeq = resp.Seq
		if resp.Outputs != nil {
			for _, m := range resp.Outputs {
				if conf := m.GetContent().GetConfirmation(); conf != nil {
					confirmation = conf
				}
			}
			displayContents(d, resp.Outputs)
		}
	}
	if confirmation == nil {
		d.FinishOutput(fmt.Sprintf("seq=%d", lastSeq))
	}
	return confirmation, nil
}

func displayContents(d *internal.Display, contents []*proto.Message) {
	for _, output := range contents {