1. const fs = require('fs');
  2. const path = require('path');
  4. /**
  5. * Decodes dataset input based on a configuration file.
  6. * @param {string} inputData The raw dataset input.
  7. * @param {string} configPath The path to the configuration file.
  8. * @returns {any} The decoded dataset, or null if decoding fails.
  9. */
  10. function decodeDataset(inputData, configPath) {
  11. try {
  12. // Read the configuration file.
  13. const config = require(path.resolve(configPath));
  15. // Validate configuration
  16. if (!config || typeof config.schema !== 'object' || !config.schema.type) {
  17. console.error("Invalid configuration file format.");
  18. return null;
  19. }
  21. const schemaType = config.schema.type;
  23. switch (schemaType) {
  24. case 'json':
  25. try {
  26. return JSON.parse(inputData);
  27. } catch (error) {
  28. console.error("JSON parsing error:", error);
  29. return null;
  30. }
  31. case 'csv':
  32. try {
  33. const lines = inputData.split('\n');
  34. const headers = lines[0].split(',');
  35. const data = [];
  36. for (let i = 1; i < lines.length; i++) {
  37. const values = lines[i].split(',');
  38. if (values.length !== headers.length) {
  39. console.warn(`Skipping row ${i + 1} due to mismatched column count.`);
  40. continue;
  41. }
  42. const row = {};
  43. for (let j = 0; j < headers.length; j++) {
  44. row[headers[j].trim()] = values[j].trim();
  45. }
  46. data.push(row);
  47. }
  48. return data;
  49. } catch (error) {
  50. console.error("CSV parsing error:", error);
  51. return null;
  52. }
  53. case 'yaml':
  54. try {
  55. return require('yaml').parse(inputData);
  56. } catch (error) {
  57. console.error("YAML parsing error:", error);
  58. return null;
  59. }
  60. default:
  61. console.error("Unsupported schema type:", schemaType);
  62. return null;
  63. }
  64. } catch (error) {
  65. console.error("Error during decoding:", error);
  66. return null;
  67. }
  68. }
  70. module.exports = decodeDataset;

Add your comment