Skip to main content

​
createTransformer

Transform data in pipes. 
createTransformer<I, O>(config: TransformerConfig<I, O>): Transformer<I, O>
Parameters:
  • transform: Transform function async (data: I, ctx) => O (required)
  • query: Query callback ({queryBuilder, portal, logger}) => void (optional)
Example: 
const transformer = createTransformer({
  query: ({ queryBuilder }) => {
    queryBuilder.addInstruction({
      request: { programId: ["whirLbMiicVdio4qvUfM5KAg6Ct8VwpYzGff3uctyCc"] },
      range: { from: 200000000 },
    });
  },
  transform: async (data) => {
    return data.blocks.map((b) => b.instructions);
  },
});