js-data-projection/dist/cjs/index.cjs

"use strict";
var __defProp = Object.defineProperty;
var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
var __getOwnPropNames = Object.getOwnPropertyNames;
var __hasOwnProp = Object.prototype.hasOwnProperty;
var __name = (target, value) => __defProp(target, "name", { value, configurable: true });
var __export = (target, all) => {
  for (var name in all)
    __defProp(target, name, { get: all[name], enumerable: true });
};
var __copyProps = (to, from, except, desc) => {
  if (from && typeof from === "object" || typeof from === "function") {
    for (let key of __getOwnPropNames(from))
      if (!__hasOwnProp.call(to, key) && key !== except)
        __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
  }
  return to;
};
var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);

// src/index.js
var index_exports = {};
__export(index_exports, {
  DataProjector: () => DataProjector,
  ProjectionSchemaRegistry: () => ProjectionSchemaRegistry,
  ProjectionScope: () => ProjectionScope,
  projectData: () => projectData,
  validateProjectionSchema: () => validateProjectionSchema
});
module.exports = __toCommonJS(index_exports);

// src/project-data.js
var import_js_format2 = require("@e22m4u/js-format");

// src/validate-projection-schema.js
var import_js_format = require("@e22m4u/js-format");
function validateProjectionSchema(schema, shallowMode = false) {
  if (!schema || typeof schema !== "object" || Array.isArray(schema)) {
    throw new import_js_format.InvalidArgumentError(
      "Projection schema must be an Object, but %v was given.",
      schema
    );
  }
  if (typeof shallowMode !== "boolean") {
    throw new import_js_format.InvalidArgumentError(
      'Parameter "shallowMode" must be a Boolean, but %v was given.',
      shallowMode
    );
  }
  Object.keys(schema).forEach((propName) => {
    const options = schema[propName];
    if (options === void 0) {
      return;
    }
    if (options === null || typeof options !== "boolean" && typeof options !== "object" || Array.isArray(options)) {
      throw new import_js_format.InvalidArgumentError(
        "Property options must be a Boolean or an Object, but %v was given.",
        options
      );
    }
    if (typeof options === "boolean") {
      return;
    }
    if (options.select !== void 0 && typeof options.select !== "boolean") {
      throw new import_js_format.InvalidArgumentError(
        'Property option "select" must be a Boolean, but %v was given.',
        options.select
      );
    }
    if (options.schema !== void 0) {
      if (!options.schema || typeof options.schema !== "string" && typeof options.schema !== "object" || Array.isArray(options.schema)) {
        throw new import_js_format.InvalidArgumentError(
          "Embedded schema must be an Object or a non-empty String that represents a schema name, but %v was given.",
          options.schema
        );
      }
      if (!shallowMode && typeof options.schema === "object") {
        validateProjectionSchema(options.schema, shallowMode);
      }
    }
    if (options.scopes !== void 0) {
      if (!options.scopes || typeof options.scopes !== "object" || Array.isArray(options.scopes)) {
        throw new import_js_format.InvalidArgumentError(
          'Property option "scopes" must be an Object, but %v was given.',
          options.scopes
        );
      }
      Object.keys(options.scopes).forEach((scopeName) => {
        const scopeOptions = options.scopes[scopeName];
        if (scopeOptions === void 0) {
          return;
        }
        if (scopeOptions === null || typeof scopeOptions !== "boolean" && typeof scopeOptions !== "object" || Array.isArray(scopeOptions)) {
          throw new import_js_format.InvalidArgumentError(
            "Scope options must be a Boolean or an Object, but %v was given.",
            scopeOptions
          );
        }
        if (typeof scopeOptions === "boolean") {
          return;
        }
        if (scopeOptions.select !== void 0) {
          if (typeof scopeOptions.select !== "boolean") {
            throw new import_js_format.InvalidArgumentError(
              'Scope option "select" must be a Boolean, but %v was given.',
              scopeOptions.select
            );
          }
        }
      });
    }
  });
}
__name(validateProjectionSchema, "validateProjectionSchema");

// src/project-data.js
function projectData(schemaOrName, data, options = void 0) {
  if (!schemaOrName || typeof schemaOrName !== "string" && typeof schemaOrName !== "object" || Array.isArray(schemaOrName)) {
    throw new import_js_format2.InvalidArgumentError(
      "Projection schema must be an Object or a non-empty String that represents a schema name, but %v was given.",
      schemaOrName
    );
  }
  if (options !== void 0) {
    if (!options || typeof options !== "object" || Array.isArray(options)) {
      throw new import_js_format2.InvalidArgumentError(
        'Parameter "options" must be an Object, but %v was given.',
        options
      );
    }
    if (options.strict !== void 0 && typeof options.strict !== "boolean") {
      throw new import_js_format2.InvalidArgumentError(
        'Option "strict" must be a Boolean, but %v was given.',
        options.strict
      );
    }
    if (options.scope !== void 0 && (!options.scope || typeof options.scope !== "string")) {
      throw new import_js_format2.InvalidArgumentError(
        'Option "scope" must be a non-empty String, but %v was given.',
        options.scope
      );
    }
    if (options.resolver !== void 0 && (!options.resolver || typeof options.resolver !== "function")) {
      throw new import_js_format2.InvalidArgumentError(
        'Option "resolver" must be a Function, but %v was given.',
        options.resolver
      );
    }
  }
  const strict = Boolean(options && options.strict);
  const scope = options && options.scope || void 0;
  const resolver = options && options.resolver || void 0;
  let schema = schemaOrName;
  if (typeof schemaOrName === "string") {
    if (!resolver) {
      throw new import_js_format2.InvalidArgumentError(
        "Unable to resolve the named schema %v without a specified projection schema resolver.",
        schemaOrName
      );
    }
    schema = resolver(schemaOrName);
    if (!schema || typeof schema !== "object" || Array.isArray(schema)) {
      throw new import_js_format2.InvalidArgumentError(
        "Projection schema resolver must return an Object, but %v was given.",
        schema
      );
    }
  }
  validateProjectionSchema(schema, true);
  if (data === null || typeof data !== "object") {
    return data;
  }
  if (Array.isArray(data)) {
    return data.map(
      (item) => projectData(schema, item, { strict, scope, resolver })
    );
  }
  const result = {};
  const keys = Object.keys(strict ? schema : data);
  for (const key of keys) {
    if (!(key in data)) continue;
    const propOptionsOrBoolean = schema[key];
    if (_shouldSelect(propOptionsOrBoolean, strict, scope)) {
      const value = data[key];
      if (propOptionsOrBoolean && typeof propOptionsOrBoolean === "object" && propOptionsOrBoolean.schema) {
        result[key] = projectData(propOptionsOrBoolean.schema, value, {
          strict,
          scope,
          resolver
        });
      } else {
        result[key] = value;
      }
    }
  }
  return result;
}
__name(projectData, "projectData");
function _shouldSelect(propOptionsOrBoolean, strict, scope) {
  if (typeof propOptionsOrBoolean === "boolean") {
    return propOptionsOrBoolean;
  }
  if (typeof propOptionsOrBoolean === "object") {
    const propOptions = propOptionsOrBoolean;
    if (scope && propOptions.scopes && typeof propOptions.scopes === "object" && propOptions.scopes[scope] != null) {
      const scopeOptionsOrBoolean = propOptions.scopes[scope];
      if (typeof scopeOptionsOrBoolean === "boolean") {
        return scopeOptionsOrBoolean;
      }
      if (scopeOptionsOrBoolean && typeof scopeOptionsOrBoolean === "object" && typeof scopeOptionsOrBoolean.select === "boolean") {
        return scopeOptionsOrBoolean.select;
      }
    }
    if (typeof propOptionsOrBoolean.select === "boolean") {
      return propOptionsOrBoolean.select;
    }
  }
  return !strict;
}
__name(_shouldSelect, "_shouldSelect");

// src/data-projector.js
var import_js_service2 = require("@e22m4u/js-service");

// src/projection-scope.js
var ProjectionScope = {
  INPUT: "input",
  OUTPUT: "output"
};

// src/data-projector.js
var import_js_format4 = require("@e22m4u/js-format");

// src/projection-schema-registry.js
var import_js_service = require("@e22m4u/js-service");
var import_js_format3 = require("@e22m4u/js-format");
var _ProjectionSchemaRegistry = class _ProjectionSchemaRegistry extends import_js_service.Service {
  /**
   * Schema map.
   */
  _schemas = /* @__PURE__ */ new Map();
  /**
   * Define schema.
   *
   * @param {string} name
   * @param {object} schema
   * @returns {this}
   */
  defineSchema(name, schema) {
    if (!name || typeof name !== "string") {
      throw new import_js_format3.InvalidArgumentError(
        "Schema name must be a non-empty String, but %v was given.",
        name
      );
    }
    if (!schema || typeof schema !== "object" || Array.isArray(schema)) {
      throw new import_js_format3.InvalidArgumentError(
        "Projection schema must be an Object, but %v was given.",
        schema
      );
    }
    if (this._schemas.has(name)) {
      throw new import_js_format3.InvalidArgumentError(
        "Projection schema %v is already registered.",
        name
      );
    }
    validateProjectionSchema(schema);
    this._schemas.set(name, schema);
    return this;
  }
  /**
   * Get schema.
   *
   * @param {string} name
   * @returns {object}
   */
  getSchema(name) {
    if (!name || typeof name !== "string") {
      throw new import_js_format3.InvalidArgumentError(
        "Schema name must be a non-empty String, but %v was given.",
        name
      );
    }
    const schema = this._schemas.get(name);
    if (!schema) {
      throw new import_js_format3.InvalidArgumentError(
        "Projection schema %v is not found.",
        name
      );
    }
    return schema;
  }
};
__name(_ProjectionSchemaRegistry, "ProjectionSchemaRegistry");
var ProjectionSchemaRegistry = _ProjectionSchemaRegistry;

// src/data-projector.js
var _DataProjector = class _DataProjector extends import_js_service2.Service {
  /**
   * Define schema.
   *
   * @param {string} name
   * @param {object} schema
   * @returns {this}
   */
  defineSchema(name, schema) {
    this.getService(ProjectionSchemaRegistry).defineSchema(name, schema);
    return this;
  }
  /**
   * Project.
   *
   * @param {object|string} schemaOrName
   * @param {object} data
   * @param {object|undefined} options
   * @returns {*}
   */
  project(schemaOrName, data, options = void 0) {
    if (!schemaOrName || typeof schemaOrName !== "string" && typeof schemaOrName !== "object" || Array.isArray(schemaOrName)) {
      throw new import_js_format4.InvalidArgumentError(
        "Projection schema must be an Object or a non-empty String that represents a schema name, but %v was given.",
        schemaOrName
      );
    }
    if (options !== void 0) {
      if (!options || typeof options !== "object" || Array.isArray(options)) {
        throw new import_js_format4.InvalidArgumentError(
          'Parameter "options" must be an Object, but %v was given.',
          options
        );
      }
      if (options.strict !== void 0 && typeof options.strict !== "boolean") {
        throw new import_js_format4.InvalidArgumentError(
          'Option "strict" must be a Boolean, but %v was given.',
          options.strict
        );
      }
      if (options.scope !== void 0 && (!options.scope || typeof options.scope !== "string")) {
        throw new import_js_format4.InvalidArgumentError(
          'Option "scope" must be a non-empty String, but %v was given.',
          options.scope
        );
      }
      if (options.resolver !== void 0) {
        throw new import_js_format4.InvalidArgumentError(
          'Option "resolver" is not supported for the DataProjector.'
        );
      }
    }
    const registry = this.getService(ProjectionSchemaRegistry);
    return projectData(schemaOrName, data, {
      ...options,
      resolver: /* @__PURE__ */ __name((name) => registry.getSchema(name), "resolver")
    });
  }
  /**
   * Project with "input" scope.
   *
   * @param {object|string} schemaOrName
   * @param {object} data
   * @param {object|undefined} options
   * @returns {*}
   */
  projectInput(schemaOrName, data, options = void 0) {
    options = { ...options, scope: ProjectionScope.INPUT };
    return this.project(schemaOrName, data, options);
  }
  /**
   * Project with "output" scope.
   *
   * @param {object|string} schemaOrName
   * @param {object} data
   * @param {object|undefined} options
   * @returns {*}
   */
  projectOutput(schemaOrName, data, options = void 0) {
    options = { ...options, scope: ProjectionScope.OUTPUT };
    return this.project(schemaOrName, data, options);
  }
};
__name(_DataProjector, "DataProjector");
var DataProjector = _DataProjector;
// Annotate the CommonJS export names for ESM import in node:
0 && (module.exports = {
  DataProjector,
  ProjectionSchemaRegistry,
  ProjectionScope,
  projectData,
  validateProjectionSchema
});