2021-02-21 13:23:31 +01:00
|
|
|
import TransformDescriptor from 'src/TransformDescriptor';
|
2021-02-05 18:28:04 +01:00
|
|
|
import Item from 'src/Item';
|
2021-02-13 11:09:34 +01:00
|
|
|
import ItemResult from 'src/ItemResult';
|
2021-02-05 18:28:04 +01:00
|
|
|
import ItemTransformer from 'src/transformer/ItemTransformer';
|
|
|
|
import TransformContext from 'src/transformer/TransformContext';
|
2024-03-25 23:36:58 +01:00
|
|
|
import { verifyRequiredColumns } from 'src/convert';
|
2021-02-05 18:28:04 +01:00
|
|
|
|
|
|
|
class TestSchemaTransformer extends ItemTransformer {
|
2021-02-21 13:23:31 +01:00
|
|
|
constructor(name: string, descriptor: Partial<TransformDescriptor>, outputSchema: string[] | undefined = undefined) {
|
2021-02-13 11:09:34 +01:00
|
|
|
if (outputSchema) {
|
2024-03-25 23:36:58 +01:00
|
|
|
super(name, `Description for ${name}`, descriptor, () => outputSchema);
|
2021-02-13 11:09:34 +01:00
|
|
|
} else {
|
|
|
|
super(name, `Description for ${name}`, descriptor);
|
|
|
|
}
|
2021-02-05 18:28:04 +01:00
|
|
|
}
|
2021-02-13 11:09:34 +01:00
|
|
|
transform(_: TransformContext, items: Item[]): ItemResult {
|
|
|
|
return { items, messages: [] };
|
2021-02-05 18:28:04 +01:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
test('verify valid transform', async () => {
|
|
|
|
const inputSchema = ['A', 'B', 'C'];
|
|
|
|
|
|
|
|
const transformers = [
|
2021-02-13 11:09:34 +01:00
|
|
|
new TestSchemaTransformer('Replace B & C with D', { requireColumns: ['B', 'C'] }, ['A', 'D']),
|
|
|
|
new TestSchemaTransformer('Create E', {}, ['A', 'D', 'E']),
|
|
|
|
new TestSchemaTransformer('Uses A, D & E', { requireColumns: ['A', 'D', 'E'] }, ['A', 'D', 'E']),
|
2021-02-05 18:28:04 +01:00
|
|
|
];
|
2024-03-25 23:36:58 +01:00
|
|
|
verifyRequiredColumns(inputSchema, transformers);
|
2021-02-05 18:28:04 +01:00
|
|
|
});
|
|
|
|
|
|
|
|
test('verify invalid consume', async () => {
|
|
|
|
const inputSchema = ['A', 'B', 'C'];
|
2021-02-13 11:09:34 +01:00
|
|
|
const transformers = [new TestSchemaTransformer('Consumes X', { requireColumns: ['X'] })];
|
2024-03-25 23:36:58 +01:00
|
|
|
expect(() => verifyRequiredColumns(inputSchema, transformers)).toThrowError(
|
2021-02-14 11:43:26 +01:00
|
|
|
"Input schema [A, B, C] for transformer 'Consumes X' does not contain the required column 'X'",
|
2021-02-05 18:28:04 +01:00
|
|
|
);
|
|
|
|
});
|