Name and order the probe code

[onechat] / terminal.go

diff --git a/terminal.go b/terminal.go
index 2906204477b14baa33600fd3efb743865cc85037..c785a969aef149ffd823e970d2aa1d04334d8919 100644 (file)
--- a/terminal.go
+++ b/terminal.go
@@ -76,10 +76,10 @@ func terminalSession(ctx context.Context, conn net.Conn, in io.Reader, out io.Wr
 func terminalSendLines(ctx context.Context, conn net.Conn, in io.Reader) error {
        encoder := json.NewEncoder(conn)
        scanner := bufio.NewScanner(in)
 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()
        for ctx.Err() == nil && scanner.Scan() {
                line := scanner.Text()

-               request := clientRequest{
+               request := SocketRequest{

                        Type: "send",
                        Text: line,
                }
                        Type: "send",
                        Text: line,
                }


@@ -88,7 +88,7 @@ func terminalSendLines(ctx context.Context, conn net.Conn, in io.Reader) error {
                case "":
                        continue
                case stopCommand:
                case "":
                        continue
                case stopCommand:

-                       request = clientRequest{
+                       request = SocketRequest{

                                Type: "interrupt",
                        }
                }
                                Type: "interrupt",
                        }
                }


@@ -106,7 +106,7 @@ func terminalSendLines(ctx context.Context, conn net.Conn, in io.Reader) error {
 // connection closes.
 func terminalShowEvents(conn net.Conn, out io.Writer) error {
        scanner := bufio.NewScanner(conn)
 // 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)
        for scanner.Scan() {
                var event Event
                err := json.Unmarshal(scanner.Bytes(), &event)