@effectai/effect-js/dist/services/utils.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.validateCampaignSchema = exports.validateBatchData = void 0;
const tslib_1 = require("tslib");
const ajv_1 = tslib_1.__importDefault(require("ajv"));
// export class UtilityService {
//     constructor(private readonly client: Client) {}
// }
const validateBatchData = async (batch, campaign) => {
    const ajv = new ajv_1.default();
    if (!campaign.info?.input_schema) {
        // throw new Error('Campaign input schema is not defined')
        return true;
    }
    const validate = ajv.compile(campaign.info?.input_schema);
    const valid = validate(batch.data);
    if (!valid) {
        console.error(validate?.errors);
        throw new Error(`Batch data is invalid: ${validate?.errors}`);
    }
};
exports.validateBatchData = validateBatchData;
const validateCampaignSchema = (campaign) => {
    const ajv = new ajv_1.default();
    if (!campaign.info?.input_schema) {
        // throw new Error('Campaign input schema is not defined')
        return true;
    }
    const valid = ajv.validateSchema(campaign.info?.input_schema);
    if (valid) {
        return true;
    }
    else {
        console.error(ajv.errors);
        throw new Error(`Campaign schema is invalid: ${ajv.errors}`);
    }
};
exports.validateCampaignSchema = validateCampaignSchema;
//# sourceMappingURL=utils.js.map