feat: improved log experience on the UI. (#1368)

This PR:
I have the logging experience now, where users can see large amount of
logs. It behaves like terminal where if at bottom it automatically
tracks the new logs, otherwise stays in place until user goes to bottom.

I have included copy and download functionality as well, where users can
do that for service logs and logs generated during enclave creation.

enclave-manager/server/server.go

@@ -227,26 +227,22 @@ func (c *WebServer) RunStarlarkPackage(ctx context.Context, req *connect.Request
 		Msg: req.Msg.RunStarlarkPackageArgs,
 	}
 
-	apicStream, err := (*apiContainerServiceClient).RunStarlarkPackage(ctx, serviceRequest)
-	ctxWithCancel, cancel := context.WithCancel(ctx)
-	logs := getRuntimeLogsWhenCreatingEnclave(cancel, apicStream)
-	for {
-		select {
-		case <-ctxWithCancel.Done():
-			err := apicStream.Close()
-			close(logs)
-			if err != nil {
-				return stacktrace.Propagate(err, "Error occurred after closing the stream")
-			}
-			return nil
-		case resp := <-logs:
-			errWhileSending := str.Send(resp)
-			if errWhileSending != nil {
-				logrus.Errorf("error occurred: %+v", errWhileSending)
-				return stacktrace.Propagate(errWhileSending, "Error occurred while sending streams")
-			}
+	apiClient, err := (*apiContainerServiceClient).RunStarlarkPackage(ctx, serviceRequest)
+
+	for apiClient.Receive() {
+		resp := apiClient.Msg()
+		errWhileSending := str.Send(resp)
+		if errWhileSending != nil {
+			logrus.Errorf("Error occurred while sending stream frome enclave manager to the UI: %+v", errWhileSending)
+			return stacktrace.Propagate(errWhileSending, "Error occurred while sending streams")
 		}
 	}
+
+	if errWhileReceive := apiClient.Err(); errWhileReceive != nil {
+		logrus.Errorf("Error occurred while enclave manger is receiving streams from engine: %+v", errWhileReceive)
+		return stacktrace.Propagate(errWhileReceive, "Error occurred while receiving data from engine")
+	}
+	return nil
 }
 
 func (c *WebServer) DestroyEnclave(ctx context.Context, req *connect.Request[kurtosis_engine_rpc_api_bindings.DestroyEnclaveArgs]) (*connect.Response[emptypb.Empty], error) {
@@ -437,15 +433,3 @@ func RunEnclaveManagerApiServer(enforceAuth bool) error {
 	}
 	return nil
 }
-
-func getRuntimeLogsWhenCreatingEnclave(cancel context.CancelFunc, client *connect.ServerStreamForClient[kurtosis_core_rpc_api_bindings.StarlarkRunResponseLine]) chan *kurtosis_core_rpc_api_bindings.StarlarkRunResponseLine {
-	result := make(chan *kurtosis_core_rpc_api_bindings.StarlarkRunResponseLine)
-	go func() {
-		for client.Receive() {
-			res := client.Msg()
-			result <- res
-		}
-		cancel()
-	}()
-	return result
-}