func terminalSendLines(ctx context.Context, conn net.Conn, in io.Reader) error {
encoder := json.NewEncoder(conn)
scanner := bufio.NewScanner(in)
- scanner.Buffer(make([]byte, 64*1024), requestBytes)
+ scanner.Buffer(make([]byte, 64*1024), socketRequestBytes)
for ctx.Err() == nil && scanner.Scan() {
line := scanner.Text()
- request := clientRequest{
+ request := SocketRequest{
Type: "send",
Text: line,
}
case "":
continue
case stopCommand:
- request = clientRequest{
+ request = SocketRequest{
Type: "interrupt",
}
}
// connection closes.
func terminalShowEvents(conn net.Conn, out io.Writer) error {
scanner := bufio.NewScanner(conn)
- scanner.Buffer(make([]byte, 64*1024), requestBytes)
+ scanner.Buffer(make([]byte, 64*1024), socketRequestBytes)
for scanner.Scan() {
var event Event
err := json.Unmarshal(scanner.Bytes(), &event)