10 Commits

13 changed files with 477 additions and 26 deletions

View File

@@ -2,7 +2,7 @@
build/packages: build/packages:
mkdir -p $@ mkdir -p $@
node tools/stage-for-pnpn.mjs package-manifest.yaml source $@ node tools/stage-for-pnpm.mjs package-manifest.yaml source $@
publish: publish:
cd build/packages && ./publish-all.sh cd build/packages && ./publish-all.sh

View File

@@ -0,0 +1,9 @@
# @efforting.tech/data
Data processing modules.
**TODO:** *Explain in more detail what this vague description actually refers to.*
## field-configuration-factories.mjs
Currently there are a few factories defined but we might add more as specific needs arises throughout the library.

50
experiments/config1.mjs Normal file
View File

@@ -0,0 +1,50 @@
import { Schema, Field_Configuration } from '@efforting.tech/data/field-configuration';
function mandatory_anything(value) {
return value !== undefined;
}
function string_coercion_function(value) {
if (value === undefined) {
throw new Error('Undefined not allowed');
}
return String(value);
}
const fc = new Field_Configuration(null, string_coercion_function, null, 'Anything that could be a string');
const fd = new Field_Configuration(null, string_coercion_function, () => 'baz', 'A string. Defaults to \'baz\'');
console.log(fc.check_validation(undefined));
console.log(fc.check_validation(true));
console.log([ fc.coerce(123) ]);
console.log([ fc.coerce(true) ]);
// console.log([ fc.load(undefined, 'Some configuration') ]);
// console.log([ fc.load(true) ]);
//fc.validate(undefined);
//console.log(fc.load(undefined, 'New thingamabob object'));
const s = new Schema({
foo: fc,
bar: fd,
});
const s2 = new Schema({
thing: fc,
stuff: s,
});
console.log(s2.load({
stuff: { foo: 'Hello World' },
thing: 123,
}));
// { thing: '123', stuff: { foo: 'Hello World', bar: 'baz' } }

10
experiments/config2.mjs Normal file
View File

@@ -0,0 +1,10 @@
import * as F from '@efforting.tech/data/field-configuration-factories';
const s = new F.Schema({
foo: F.value(123, 'The value'),
bar: F.factory((t) => `Field ${t.name} was not set`, 'The factory'),
rq: F.required('Anything. Just not nothing.'),
}, 'Some schema');
console.log(s.load()) // { foo: 123, bar: 'Field bar was not set' }

View File

@@ -1,8 +0,0 @@
{
"name": "experiments",
"type": "module",
"dependencies": {
"@efforting.tech/errors": "link:../build/packages/errors",
"@efforting.tech/rule-processing": "link:../build/packages/rule-processing"
}
}

157
experiments/text-nodes.mjs Normal file
View File

@@ -0,0 +1,157 @@
import * as CF from '@efforting.tech/data/field-configuration-factories';
import { readFileSync } from 'node:fs';
import { inspect } from 'node:util';
import { Indention_Mode, Text_Settings } from '@efforting.tech/text/basic-tree';
// TODO: Move into string helper module
function string_has_contents(str) {
return /\S/.test(str);
}
function *indented_line_iterator(settings, text) {
let line_no = settings.first_line;
let index = 0;
const { indention_tabulator_width } = settings;
switch (settings.indention_mode) {
case Indention_Mode.symbols.TABULATORS: {
for (const line of text.matchAll(/^(\t*)(.*)$/gm)) {
const [raw, tabs, remaining] = line;
yield { raw, indent: tabs.length, line: remaining, line_no: line_no++, index: index++};
}
break;
}
case Indention_Mode.symbols.SPACES: {
for (const line of text.matchAll(/^([ ]*)(.*)$/gm)) {
const [raw, spaces, remaining] = line;
if ((spaces.length % indention_tabulator_width) !== 0) {
throw new Error('Unaligned indention'); //TODO - proper error
}
yield { raw, indent: Math.floor(spaces.length / indention_tabulator_width), line: remaining, line_no: line_no++, index: index++};
}
break;
}
default:
throw new Error('Unsupported indention mode'); //TODO - proper error
}
}
const ts = Text_Settings.load({
indention_mode: 'TABULATORS',
});
const example_string =
`branch1
leaf1
leaf2
branch2
sub-branch1
leaf3
leaf4
sub-branch2
leaf5
branch3
dual-indented
`;
class Text_Node {
constructor(text_settings, line=undefined, indent=0, line_no=undefined, index=undefined, raw=undefined, parent=undefined) {
Object.assign(this, { text_settings, line, indent, line_no, index, raw, parent, children: [] });
}
}
const root = new Text_Node(ts);
// NOTE: This first Text_Node is not added to the tree, it serves as an initial cursor only.
let current = new Text_Node(root.text_settings, undefined, 0, undefined, undefined, undefined, root);
for (const line_info of indented_line_iterator(ts, example_string)) {
// TODO: Implement other variants than inherit-from-previous
const indent = string_has_contents(line_info.line) ? line_info.indent : current.indent;
const delta_indent = indent - current.indent;
if (delta_indent == 0) {
const pending = new Text_Node(current.text_settings, undefined, current.indent, undefined, undefined, undefined, current.parent); // Partial insertion - same level
if (current.parent) {
current.parent.children.push(pending);
}
current = pending;
} else if (delta_indent > 0) {
for (let i=0; i<delta_indent; i++) {
const pending = new Text_Node(current.text_settings, undefined, current.indent + 1, undefined, undefined, undefined, current); // Partial insertion
current.children.push(pending);
current = pending;
}
} else {
for (let i=0; i>delta_indent; i--) {
current = current.parent;
}
const pending = new Text_Node(current.text_settings, undefined, current.indent, undefined, undefined, undefined, current.parent); // Partial insertion - same level
if (current.parent) {
current.parent.children.push(pending);
}
current = pending;
}
// Fill in partial insertion
Object.assign(current, {
line: line_info.line,
line_no: line_info.line_no,
index: line_info.index,
raw: line_info.raw,
});
}
function debug_dump(node, level=0) {
console.log(`${" ".repeat(level)}[${node.line_no ?? '-'}] ${inspect(node.line)}`);
for (const child of node.children) {
debug_dump(child, level+1);
}
}
debug_dump(root);
/*
[-] undefined
[1] 'branch1'
[2] 'leaf1'
[3] 'leaf2'
[4] ''
[5] 'branch2'
[6] 'sub-branch1'
[7] 'leaf3'
[8] 'leaf4'
[9] ''
[10] ''
[11] 'sub-branch2'
[12] 'leaf5'
[13] ''
[14] 'branch3'
[-] undefined
[15] 'dual-indented'
[16] ''
[17] ''
*/

View File

@@ -1,6 +1,6 @@
scope: '@efforting.tech' scope: '@efforting.tech'
registry: 'https://npm.efforting.tech/' registry: 'https://npm.efforting.tech/'
version: 0.2.4 version: 0.2.8
author: author:
name: 'Mikael Lövqvist' name: 'Mikael Lövqvist'
@@ -21,6 +21,19 @@ packages:
internal-dependencies: internal-dependencies:
- errors - errors
data:
path: source/data
documentation: documentation/data
description: Data management
internal-dependencies:
- errors
text:
path: source/text
#documentation: documentation/text
description: Text management
internal-dependencies:
- data
wip-packages: wip-packages:
object-graph-storage: object-graph-storage:

View File

@@ -0,0 +1,58 @@
import { Field_Configuration } from './field-configuration.mjs';
export { Schema } from './field-configuration.mjs';
//constructor(validation_function=null, coercion_function=null, factory_function=null, expected_description=undefined) {
export function value(default_value, description) {
return new Field_Configuration(null, null, () => default_value, description);
}
export function factory(factory_function, description) {
return new Field_Configuration(null, null, factory_function, description);
}
export function typed_value(coercion_function, default_value, description) {
return new Field_Configuration(null, coercion_function, () => default_value, description);
}
export function typed_factory(coercion_function, factory_function, description) {
return new Field_Configuration(null, coercion_function, factory_function, description);
}
export function required(description) {
return new Field_Configuration((value) => value !== undefined, null, null, description);
}
export function typed_required(coercion_function, description) {
return new Field_Configuration((value) => value !== undefined, coercion_function, null, description);
}
export function symbol_set(description_to_name_mapping, description=null) {
const symbols_by_name = Object.fromEntries(Object.keys(description_to_name_mapping).map(k => [k, Symbol(k)]));
const valid_symbols = new Set(Object.values(symbols_by_name));
const descriptions_by_symbol = Object.fromEntries(Object.entries(symbols_by_name).map(([n, s]) => [s, description_to_name_mapping[n]]));
const result = new Field_Configuration(
(v) => valid_symbols.has(v),
(v) => typeof v === 'string' ? symbols_by_name[v] : v, // TODO: Assert that we could look up the symbol
null,
description,
);
// HACK: We are just tacking these on here but the proper method would be to create a proper subclass for the symbol set field type which is planned.
result.symbols = symbols_by_name;
result.symbol_descriptions = descriptions_by_symbol;
return result;
}
export function cardinal_value(default_value=null, description=null) {
return new Field_Configuration((v) => Number.isInteger(v) && v >= 1, parseInt, () => default_value, description);
}
export function natural_value(default_value=null, description=null) {
return new Field_Configuration((v) => Number.isInteger(v) && v >= 0, parseInt, () => default_value, description);
}

View File

@@ -0,0 +1,82 @@
import { Data_Validation_Failed, Data_Coercion_Failed, Superfluous_Data_Field } from '@efforting.tech/errors';
export class Field_Configuration {
constructor(validation_function=null, coercion_function=null, factory_function=null, expected_description=undefined) {
Object.assign(this, { validation_function, coercion_function, factory_function, expected_description });
}
check_validation(value) {
const { validation_function } = this;
return !validation_function || validation_function(value);
}
validate(value, target=undefined) {
const { validation_function, expected_description } = this;
if (!this.check_validation(value)) {
throw new Data_Validation_Failed({
validation_function, value,
target, expected_description,
});
}
}
coerce(value, target=undefined) {
const { coercion_function, expected_description } = this;
try {
return coercion_function ? coercion_function(value) : value;
} catch (e) {
throw new Data_Coercion_Failed({
coercion_function, value,
target, expected_description,
upstream_error: e,
})
}
}
load(value=undefined, target=undefined) {
const { factory_function } = this;
if ((value === undefined) && factory_function) {
value = factory_function(target);
}
const coerced_value = this.coerce(value, target);
this.validate(coerced_value, target);
return coerced_value;
}
}
export class Schema {
constructor(field_schema, name=undefined) {
Object.assign(this, { field_schema, name });
}
load(value={}, target=undefined) {
const { field_schema, name } = this;
for (const [value_name, value_value] of Object.entries(value)) {
if (!field_schema[value_name]) {
throw new Superfluous_Data_Field({
field_value: value_value, field_name: value_name, target,
});
}
}
const result = {};
const this_schema = name ? `schema "${name}"` : 'untitled schema';
for (const [field_name, field_config] of Object.entries(field_schema)) {
const sub_target = { schema: this, name: field_name, config: field_config, parent_target: target, info: `Field "${field_name}" of ${this_schema}` };
result[field_name] = field_config.load(value[field_name], sub_target);
}
return result;
}
}

View File

@@ -1,5 +1,49 @@
import { inspect } from 'node:util'; import { inspect } from 'node:util';
// § GROUP: Configuration field errors
export class Data_Validation_Failed extends Error {
constructor(data) {
const { value, target, expected_description, validation_function, upstream_error } = data;
const type = value === null ? 'null' : typeof value;
const target_info = target?.info ? inspect(target.info) : 'unknown target';
const field_ref = target?.name ? `field "${target.name}"` : 'unknown field';
const expected_desc = expected_description ?? `data that would pass validation using ${validation_function}`;
const upstream_error_description = upstream_error ? ` Upstream error was: ${upstream_error}` : '';
super(`Data validation failed for ${field_ref} of ${target_info}. Encountered data of type "${type}" while expecting "${expected_desc}".${upstream_error_description}`);
this.data = data;
}
}
export class Superfluous_Data_Field extends Error {
constructor(data) {
const { field_value, field_name, target, upstream_error } = data;
const type = field_value === null ? 'null' : typeof field_value;
const target_info = target?.info ? inspect(target.info) : 'unknown target';
const upstream_error_description = upstream_error ? ` Upstream error was: ${upstream_error}` : '';
super(`Data validation failed for ${target_info}. Superfluous field "${field_name}" with value of type "${type}" encountered.${upstream_error_description}`);
this.data = data;
}
}
export class Data_Coercion_Failed extends Error {
constructor(data) {
const { value, target, expected_description, coercion_function, upstream_error } = data;
const type = value === null ? 'null' : typeof value;
const target_info = target?.info ? inspect(target.info) : 'unknown target';
const field_ref = target?.name ? `field "${target.name}"` : 'unknown field';
const expected_desc = expected_description ?? `data that would be coerced using ${coercion_function}`;
const upstream_error_description = upstream_error ? ` Upstream error was: ${upstream_error}` : '';
super(`Data coercion failed for ${field_ref} of ${target_info}. Encountered data of type "${type}" while expecting "${expected_desc}".${upstream_error_description}`);
this.data = data;
}
}
// § GROUP: Resolving errors // § GROUP: Resolving errors
export class Item_Unresolvable extends Error { export class Item_Unresolvable extends Error {

View File

@@ -30,6 +30,7 @@ export class Chained_Resolver extends Abstract_Resolver {
export class Mapping_Resolver extends Abstract_Resolver { export class Mapping_Resolver extends Abstract_Resolver {
constructor(rules=new Map(), key_function=null) { constructor(rules=new Map(), key_function=null) {
super();
Object.assign(this, { rules, key_function }); Object.assign(this, { rules, key_function });
} }

View File

@@ -0,0 +1,16 @@
import * as CF from '@efforting.tech/data/field-configuration-factories';
export const Indention_Mode = new CF.symbol_set({
AUTO: 'Automatic detection of indention mode',
SPACES: 'Indention is based on spaces',
TABULATORS: 'Indention is based on tabulators',
}, 'Indention mode');
// BUG: Current implementation of CF.symbol_set doesn't support default value
export const Text_Settings = new CF.Schema({
indention_mode: Indention_Mode,
indention_tabulator_width: CF.cardinal_value(4, 'Width of a tabulator in spaces'),
first_line: CF.natural_value(1, 'First line number'),
}, 'Text settings');

View File

@@ -52,9 +52,7 @@ function link_tree(src, dest) {
} }
} }
const workspace_manifest = { const published_packages = [];
packages: [],
};
const { scope, registry, author, version } = manifest; const { scope, registry, author, version } = manifest;
@@ -62,23 +60,27 @@ const common_package_data = {
author, author,
version, version,
type: 'module', type: 'module',
publishConfig: {
registry
},
}; };
const root_package = { const root_package = {
name: path.join(scope, 'root'), name: path.join(scope, '_root'),
dependencies: {}, dependencies: {},
private: true,
...common_package_data, ...common_package_data,
}; };
const local_dev_package = {
name: path.join(scope, '_dev'),
dependencies: {},
private: true,
...common_package_data,
};
for (const [package_name, package_data] of Object.entries(manifest.packages)) { for (const [package_name, package_data] of Object.entries(manifest.packages)) {
const pkg = { name: package_name, ...package_data }; const pkg = { name: package_name, ...package_data };
const pkg_scope_path = path.join(scope, pkg.name); const pkg_scope_path = path.join(scope, pkg.name);
workspace_manifest.packages.push(pkg.name); published_packages.push(pkg.name);
const pkg_dir = path.join(output_directory, pkg.name); const pkg_dir = path.join(output_directory, pkg.name);
const linked_sources = link_tree(pkg.path, pkg_dir).map(p => path.relative(pkg_dir, p)); const linked_sources = link_tree(pkg.path, pkg_dir).map(p => path.relative(pkg_dir, p));
@@ -89,7 +91,7 @@ for (const [package_name, package_data] of Object.entries(manifest.packages)) {
const exports_map = {}; const exports_map = {};
for (const file of linked_sources) { for (const file of linked_sources) {
const name = path.basename(file, '.mjs'); const name = path.basename(file, '.mjs');
const key = name === pkg.name ? '.' : `./${name}`; const key = name === path.basename(pkg.name) ? '.' : `./${name}`;
exports_map[key] = `./${file}`; exports_map[key] = `./${file}`;
} }
@@ -116,20 +118,26 @@ for (const [package_name, package_data] of Object.entries(manifest.packages)) {
writeFileSync(path.join(pkg_dir, 'package.json'), pkg_json, 'utf-8'); writeFileSync(path.join(pkg_dir, 'package.json'), pkg_json, 'utf-8');
//console.log({linked_sources}); // ['errors.mjs'] //console.log({linked_sources}); // ['errors.mjs']
root_package.dependencies[pkg_scope_path] = version;
} }
const root_pkg_json = JSON.stringify(root_package, null, ' ');
writeFileSync(path.join(output_directory, 'package.json'), root_pkg_json, 'utf-8');
writeFileSync(path.join(output_directory, 'pnpm-workspace.yaml'), format_yaml(workspace_manifest), 'utf-8');
const publish_tool = 'pnpm publish --no-git-checks'; //const publish_tool = 'pnpm publish --no-git-checks';
const publish_script_lines = workspace_manifest.packages.map( const publish_tool = `npm publish --registry "${registry}"`;
pkg => `${publish_tool} ${pkg}` const publish_script_lines = published_packages.map(
pkg => `${publish_tool} ./${pkg}`
); );
const dev_stage_script_lines = published_packages.map(
pkg => `ln -sf "${path.resolve(output_directory, pkg)}" "${path.resolve(output_directory, 'node_modules', path.join(scope, pkg))}"`
);
const dev_stage_mkdir_lines = [...new Set(published_packages.map(
pkg => `mkdir -p "${path.dirname(path.resolve(output_directory, 'node_modules', path.join(scope, pkg)))}"`
))];
const publish_script = ( const publish_script = (
'#!/usr/bin/env bash\n' + '#!/usr/bin/env bash\n' +
@@ -137,8 +145,19 @@ const publish_script = (
`${publish_script_lines.join('\n')}\n` `${publish_script_lines.join('\n')}\n`
); );
const dev_stage_script = (
'#!/usr/bin/env bash\n' +
'set -e\n' +
`${dev_stage_mkdir_lines.join('\n')}\n` +
`${dev_stage_script_lines.join('\n')}\n`
);
const publish_script_path = path.join(output_directory, 'publish-all.sh'); const publish_script_path = path.join(output_directory, 'publish-all.sh');
const dev_stage_script_path = path.join(output_directory, 'local-install.sh');
writeFileSync(publish_script_path, publish_script, 'utf-8'); writeFileSync(publish_script_path, publish_script, 'utf-8');
writeFileSync(dev_stage_script_path, dev_stage_script, 'utf-8');
chmodSync(publish_script_path, 0o755); chmodSync(publish_script_path, 0o755);
chmodSync(dev_stage_script_path, 0o755);