Method DownloadFileContent

cli/cmd/capture/download.go:287–324

DownloadFileContent downloads a capture file from a specific node and returns the content

(ctx context.Context, nodeName, hostPath, fileName, captureName string)

// DownloadFileContent downloads a capture file from a specific node and returns the content
func (ds *DownloadService) DownloadFileContent(ctx context.Context, nodeName, hostPath, fileName, captureName string) ([]byte, error) {
	node, err := ds.kubeClient.CoreV1().Nodes().Get(ctx, nodeName, metav1.GetOptions{})
	if err != nil {
		return nil, errors.Join(ErrGetNodeInfo, err)
	}

	downloadCmd, err := getDownloadCmd(node, hostPath, fileName)
	if err != nil {
		return nil, err
	}

	fmt.Println("File to be downloaded: ", downloadCmd.SrcFilePath)
	downloadPod, err := ds.createDownloadPod(ctx, nodeName, hostPath, captureName, downloadCmd)
	if err != nil {
		return nil, err
	}

	// Ensure cleanup
	defer func() {
		cleanupErr := ds.kubeClient.CoreV1().Pods(ds.namespace).Delete(ctx, downloadPod.Name, metav1.DeleteOptions{})
		if cleanupErr != nil {
			retinacmd.Logger.Warn("Failed to clean up debug pod", zap.String("name", downloadPod.Name), zap.Error(cleanupErr))
		}
	}()

	fileExists, err := ds.verifyFileExists(ctx, downloadPod, downloadCmd)
	if err != nil || !fileExists {
		return nil, err
	}

	fmt.Println("Obtaining file...")
	fileContent, err := ds.executeFileDownload(ctx, downloadPod, downloadCmd)
	if err != nil {
		return nil, err
	}

	return fileContent, nil
}

func getCapturePods(ctx context.Context, kubeClient kubernetes.Interface, captureName, namespace string) (*corev1.PodList, error) {
	pods, err := kubeClient.CoreV1().Pods(namespace).List(ctx, metav1.ListOptions{