Function $readCSV

src/danfojs-base/io/node/io.csv.ts:51–153

(filePath: string, options?: CsvInputOptionsNode)

 * ```
 */
const $readCSV = async (filePath: string, options?: CsvInputOptionsNode): Promise<DataFrame> => {
  const frameConfig = options?.frameConfig || {}
  const hasStringType = frameConfig.dtypes?.includes("string")

  if (filePath.startsWith("http") || filePath.startsWith("https")) {
    return new Promise((resolve, reject) => {
      let hasError = false;
      const optionsWithDefaults = {
        header: true,
        dynamicTyping: !hasStringType,
        skipEmptyLines: 'greedy',
        delimiter: ",",
        ...options,
      }

      const dataStream = request.get(filePath);
      // reject any non-2xx status codes
      dataStream.on('response', (response: any) => {
        if (response.statusCode < 200 || response.statusCode >= 300) {
          hasError = true;
          reject(new Error(`HTTP ${response.statusCode}: ${response.statusMessage}`));
        }
      });

      const parseStream: any = Papa.parse(Papa.NODE_STREAM_INPUT, optionsWithDefaults as any);
      dataStream.pipe(parseStream);

      const data: any = [];
      parseStream.on("data", (chunk: any) => {
        if (!hasError) {
          data.push(chunk);
        }
      });

      parseStream.on("error", (error: any) => {
        hasError = true;
        reject(new Error(`Failed to parse CSV: ${error.message}`));
      });

      parseStream.on("finish", () => {
        if (hasError) return;

        if (!data || data.length === 0) {
          reject(new Error('No data found in CSV file'));
          return;
        }

        try {
          const df = new DataFrame(data, frameConfig);
          resolve(df);
        } catch (error) {
          const errorMessage = error instanceof Error ? error.message : 'Unknown error occurred';
          reject(new Error(`Failed to create DataFrame: ${errorMessage}`));
        }
      });
    });

  } else {