Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 4c847e6de9 |
@@ -63,8 +63,12 @@ func (a *Agent) Logs(req *mcpv1.LogsRequest, stream mcpv1.McpAgentService_LogsSe
|
|||||||
|
|
||||||
scanner := bufio.NewScanner(pr)
|
scanner := bufio.NewScanner(pr)
|
||||||
for scanner.Scan() {
|
for scanner.Scan() {
|
||||||
|
line := scanner.Bytes()
|
||||||
|
if len(line) == 0 {
|
||||||
|
continue
|
||||||
|
}
|
||||||
if err := stream.Send(&mcpv1.LogsResponse{
|
if err := stream.Send(&mcpv1.LogsResponse{
|
||||||
Data: append(scanner.Bytes(), '\n'),
|
Data: append(line, '\n'),
|
||||||
}); err != nil {
|
}); err != nil {
|
||||||
_ = cmd.Process.Kill()
|
_ = cmd.Process.Kill()
|
||||||
return err
|
return err
|
||||||
|
|||||||
Reference in New Issue
Block a user