import { parse as parseYAML, stringify as stringifyYAML } from "https://deno.land/std/yaml/mod.ts"; // import * as jsonMod from "https://deno.land/std@0.224.0/json/mod.ts"; // import * as csv from "npm:csvtojson"; // import { readCSV, readCSVRows, writeCSV } from "jsr:@vslinko/csv"; // import { parse as parseCSV, stringify as stringifyCSV } from "https://deno.land/std/csv/mod.ts"; import csv from "npm:csvtojson"; // import { CSVtoJSON } from "https://deno.land/x/data_format_converter@v1.2.0/mod.ts"; import { parse as parseTOML, stringify as stringifyTOML } from "https://deno.land/std/toml/mod.ts"; type DataFormat = 'object' | 'json' | 'yaml' | 'csv' | 'toml'; type SelectorType = 'property' | 'index' | 'search' | 'dynamic' | 'append' | 'function'; interface Selector { type: SelectorType; value: string | number; conditions?: Condition[]; args?: string[]; } interface Condition { property: string; operator: string; value: any; } class SelectorParser { parse(selectorString: string): Selector[] { const selectors: Selector[] = []; const parts = this.splitSelector(selectorString); for (const part of parts) { if (part.startsWith('.')) { selectors.push(this.parseProperty(part)); } else if (part.startsWith('[') && part.endsWith(']')) { selectors.push(this.parseIndex(part)); } else if (part.startsWith('(') && part.endsWith(')')) { selectors.push(this.parseDynamic(part)); } else if (part === '[]') { selectors.push(this.parseAppend()); } else if (part.includes('(')) { selectors.push(this.parseFunction(part)); } else { // Handle top-level properties without a leading dot selectors.push(this.parseProperty(`.${part}`)); } } return selectors; } private splitSelector(selector: string): string[] { const parts: string[] = []; let current = ''; let depth = 0; let inQuotes = false; for (const char of selector) { if (char === '"' && depth === 0) { inQuotes = !inQuotes; } if (!inQuotes) { if (char === '(' || char === '[') depth++; if (char === ')' || char === ']') depth--; } if (char === '.' && depth === 0 && !inQuotes && current) { parts.push(current); current = ''; } else { current += char; } } if (current) parts.push(current); // If the selector doesn't start with '.', add the first part as is if (selector[0] !== '.') { return parts; } // Otherwise, add the dot to each part return parts.map(part => part.startsWith('.') ? part : `.${part}`); } private parseProperty(part: string): Selector { return { type: 'property', value: part.slice(1) }; } private parseIndex(part: string): Selector { const inner = part.slice(1, -1); if (inner === '*') { return { type: 'index', value: 'all' }; } const index = parseInt(inner, 10); if (isNaN(index)) { throw new Error(`Invalid index: ${inner}`); } return { type: 'index', value: index }; } private parseDynamic(part: string): Selector { const inner = part.slice(1, -1); const [property, operator, value] = inner.split(/\s*(=|!=|>|<|>=|<=)\s*/); return { type: 'dynamic', value: property, conditions: [{ property, operator, value: this.parseValue(value) }] }; } private parseAppend(): Selector { return { type: 'append', value: 'append' }; } private parseFunction(part: string): Selector { const [funcName, argsString] = part.split('('); const args = argsString.slice(0, -1).split(',').map(arg => arg.trim()); return { type: 'function', value: funcName, args }; } private parseValue(value: string): any { if (value === 'true') return true; if (value === 'false') return false; if (value === 'null') return null; if (!isNaN(Number(value))) return Number(value); return value.replace(/^["']|["']$/g, ''); // Remove quotes if present } } type FunctionHandler = (data: any, args: string[]) => any; const functions: Record = { length: (data) => Array.isArray(data) ? data.length : Object.keys(data).length, keys: (data) => Object.keys(data), values: (data) => Object.values(data), sum: (data) => data.reduce((a: number, b: number) => a + b, 0), avg: (data) => data.reduce((a: number, b: number) => a + b, 0) / data.length, min: (data) => Math.min(...data), max: (data) => Math.max(...data), join: (data, args) => data.join(args[0] || ','), split: (data, args) => data.split(args[0] || ','), toUpper: (data) => typeof data === 'string' ? data.toUpperCase() : data, toLower: (data) => typeof data === 'string' ? data.toLowerCase() : data, }; function applyFunction(funcName: string, data: any, args: string[] = []): any { const func = functions[funcName]; if (!func) { throw new Error(`Unknown function: ${funcName}`); } if (Array.isArray(data)) { return data.map(item => func(item, args)); } return func(data, args); } class Diesel { private data: any; private format: DataFormat; private selectorParser: SelectorParser; private dataReady: Promise; constructor(data: string | object, format: DataFormat) { this.format = format; this.selectorParser = new SelectorParser(); if (typeof data === 'object' || format === 'object') { this.data = data; this.dataReady = Promise.resolve(); } else { this.dataReady = this.parseData(data, format).then(parsedData => { this.data = parsedData; }).catch(err => { console.error("Error parsing data:", err); }); } } private async parseData(data: string, format: DataFormat): Promise { if (data === undefined) { throw new Error("No data to convert"); } switch (format) { case 'json': return JSON.parse(data); case 'yaml': return parseYAML(data); case 'csv': return await csv().fromString(data) case 'toml': return parseTOML(data); default: throw new Error(`Unsupported format: ${format}`); } } private async stringifyData(data: any, format: DataFormat): Promise { // Function to remove undefined values const removeUndefined = (obj: any): any => { if (Array.isArray(obj)) { return obj.map(removeUndefined).filter(v => v !== undefined); } else if (typeof obj === 'object' && obj !== null) { return Object.fromEntries( Object.entries(obj) .map(([k, v]) => [k, removeUndefined(v)]) .filter(([_, v]) => v !== undefined) ); } return obj; }; // Remove undefined values from the data const cleanData = removeUndefined(data); switch (format) { case 'json': return JSON.stringify(cleanData); case 'yaml': return stringifyYAML(cleanData); case 'csv': const writer = new StringWriter(); await writeCSV(writer, cleanData); return writer.toString(); case 'toml': return stringifyTOML(cleanData); default: throw new Error(`Unsupported format: ${format}`); } } async select(selectorString: string): Promise { await this.dataReady; // Ensure data is ready if (!selectorString || selectorString === '') { return this.data; } const selectors = this.selectorParser.parse(selectorString); return this.traverseSelectors(this.data, selectors); } put(selectorString: string, value: any): void { const selectors = this.selectorParser.parse(selectorString); this.data = this.traverseSelectorsForPut(this.data, selectors, value); } delete(selectorString: string): void { const selectors = this.selectorParser.parse(selectorString); this.data = this.traverseSelectorsForDelete(this.data, selectors); } private traverseSelectors(data: any, selectors: Selector[]): any { let current = data; for (const selector of selectors) { if (current === undefined || current === null) return undefined; switch (selector.type) { case 'property': current = current[selector.value as string]; break; case 'index': if (Array.isArray(current)) { if (selector.value === 'all') { return current.map(item => this.traverseSelectors(item, selectors.slice(1))); } current = current[selector.value as number]; } break; case 'function': // If the function is 'length' and current is an array, apply it directly if (selector.value === 'length' && Array.isArray(current)) { return current.length; } // Otherwise, apply the function normally current = applyFunction(selector.value as string, current, selector.args || []); break; case 'dynamic': current = this.applyDynamicSelector(current, selector); break; case 'append': // Append doesn't make sense in a read context return undefined; } } return current; } private traverseSelectorsForPut(data: any, selectors: Selector[], value: any): any { if (selectors.length === 0) return value; const [currentSelector, ...remainingSelectors] = selectors; let result: any; switch (currentSelector.type) { case 'property': result = data && typeof data === 'object' ? { ...data } : {}; result[currentSelector.value as string] = this.traverseSelectorsForPut( result[currentSelector.value as string], remainingSelectors, value ); break; case 'index': result = Array.isArray(data) ? [...data] : []; if (currentSelector.value === 'all') { return result.map(item => this.traverseSelectorsForPut(item, remainingSelectors, value)); } result[currentSelector.value as number] = this.traverseSelectorsForPut( result[currentSelector.value as number], remainingSelectors, value ); break; case 'dynamic': result = Array.isArray(data) ? [...data] : []; for (let i = 0; i < result.length; i++) { if (this.matchesDynamicConditions(result[i], currentSelector)) { result[i] = this.traverseSelectorsForPut(result[i], remainingSelectors, value); } } break; case 'append': result = Array.isArray(data) ? [...data] : []; result.push(this.traverseSelectorsForPut({}, remainingSelectors, value)); break; case 'function': throw new Error('Cannot put to a function selector'); } return result; } private traverseSelectorsForDelete(data: any, selectors: Selector[]): any { if (selectors.length === 0 || data === undefined || data === null) return undefined; const [currentSelector, ...remainingSelectors] = selectors; let result: any; switch (currentSelector.type) { case 'property': if (typeof data !== 'object' || data === null) return data; result = { ...data }; if (remainingSelectors.length === 0) { delete result[currentSelector.value as string]; } else { result[currentSelector.value as string] = this.traverseSelectorsForDelete( data[currentSelector.value as string], remainingSelectors ); } break; case 'index': if (!Array.isArray(data)) return data; result = [...data]; if (currentSelector.value === 'all') { return result.map(item => this.traverseSelectorsForDelete(item, remainingSelectors)); } if (remainingSelectors.length === 0) { result.splice(currentSelector.value as number, 1); } else { result[currentSelector.value as number] = this.traverseSelectorsForDelete( data[currentSelector.value as number], remainingSelectors ); } break; case 'dynamic': if (!Array.isArray(data)) return data; result = data.filter((item: any) => !this.matchesDynamicConditions(item, currentSelector)); break; case 'append': return data; case 'function': throw new Error('Cannot delete from a function selector'); } return result; } private applyDynamicSelector(data: any, selector: Selector): any { if (!Array.isArray(data)) { return undefined; } return data.filter(item => this.matchesDynamicConditions(item, selector)); } private matchesDynamicConditions(item: any, selector: Selector): boolean { return selector.conditions?.every(condition => { const itemValue = item[condition.property]; switch (condition.operator) { case '=': return itemValue === condition.value; case '!=': return itemValue !== condition.value; case '>': return itemValue > condition.value; case '<': return itemValue < condition.value; case '>=': return itemValue >= condition.value; case '<=': return itemValue <= condition.value; default: throw new Error(`Unknown operator: ${condition.operator}`); } }) ?? false; } async convert(targetFormat: DataFormat): Promise { if (this.data === undefined) { return "undefined"; } return this.stringifyData(this.data, targetFormat); } async toString(): Promise { return this.stringifyData(this.data, this.format); } } // Helper classes for CSV parsing/stringifying class StringReader implements Deno.Reader { private data: string; private position: number = 0; constructor(data: string) { this.data = data; } read(p: Uint8Array): Promise { if (this.position >= this.data.length) { return Promise.resolve(null); } const n = Math.min(p.length, this.data.length - this.position); for (let i = 0; i < n; i++) { p[i] = this.data.charCodeAt(this.position + i); } this.position += n; return Promise.resolve(n); } } class StringWriter implements Deno.Writer { private data: string = ''; write(p: Uint8Array): Promise { this.data += new TextDecoder().decode(p); return Promise.resolve(p.length); } toString(): string { return this.data; } } export default Diesel;

diesel