]> git.giacomolli.uk - onechat/blobdiff - terminal.go
Name and order the agent and config code
[onechat] / terminal.go
index 2906204477b14baa33600fd3efb743865cc85037..c785a969aef149ffd823e970d2aa1d04334d8919 100644 (file)
@@ -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)
-       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,
                }
@@ -88,7 +88,7 @@ func terminalSendLines(ctx context.Context, conn net.Conn, in io.Reader) error {
                case "":
                        continue
                case stopCommand:
-                       request = clientRequest{
+                       request = SocketRequest{
                                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)
-       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)