dipe (data-pipe)

Let your data flow.

data-pipe is a small lib that lets you write data processors functions for data reading and manipulation. It helps you lift up all the boilerplate needed for processing static or server data from domains specific contexts to pre-configured (or custom) processors callbacks.

Why would I need this?

data-pipe allows you to define data flows processors in a structured and (hopefully) readable way.

• It provides you a way to configure data sources and how this data goes through (whenever it comes from local or remote sources) and gets manipulated (using f.i. normalization, aggregation, filtering, sorting or whaterver process) before it reaches the output destination.

• Writing one massive logic doesn't organize well. Asynchronous data fetching frameworks for example like react-query and apollo already allow you to write data queries and mutations closer to the component contexts. Why can't static/server data fetcher be written in a similar way?!.

Here are some use case where I found myself using the package:

• Next.js static/server data fetching and manipulation
• NodeJS Twitter bot (this libs is used for setting up the whols data flow, from article sources to multichannel posting) every step of the pipeline is configured in a config.js file (whch can then use .env variables to access sensible data such as API tokens)

Installation 🔧

npm install -S dipe
or 

yarn add dipe

Usage 💡

You can immagine something like this to be a valid configuration object

// example.config.js
const { createProcessor } = require('dipe');
const { LocalDataParser, LocalDataPostProcessor } = require('dipe-processors');
const LocalDataProcessor = () => {};

const config = {
  articles: {
    processors: [
      LocalDataProcessor, // use a simple function
    ]
  },
  posts: { 
    processors: [
      createProcessor(LocalDataProcessor, { options: {
        source: './extra-posts-overrite',
      }}), // use the same function but with some additional options
      LocalFilesPostProcessor
    ],
    // Shared config options between processors
    source: './posts',
    extraExampleData: {},
  },
};

export default config;

And then the actul implementation will look similar to:

const { articles, posts } = require('./example.config.js');
let { data, errors } = readData(articles, {});

// or simply
let { data, errors } = readData({
  processors: [],
}, {});

See the example in this repo for some ideas on how to organize your data using preconfigured processors.

Read data (readData)

let { data, errors } = readData(articles):

Async read data (readAsyncData) WIP

let { data, errors } = await readAsyncData(articles):
// or
readAsyncData(articles).then({ data }).catch(errors => console.log(errors));

Lazy read data (lazyReadData)

let [{ data, errors }, getArticles] = lazyReadData(articles):
// execute
getArticles({});

Read data as stream (readStreamData) WIP

Write data (writeData) WIP

How to alter Processors or create a custom one?

Processors are just functions. You can add your custom processor or either alter a specific one by creating a function which wraps up the old implementation or create it from scratch. Let's use a simple FilterProcessor as an example:

const FilterProcessor = (data: any, config: ConfigData, options?: any) => {
  const filteredData = Object.fromEntries(Object.entries(data).filter(options.filterBy));
  return Object.values(filteredData);
}

If you wanna provide additional options specific to the processor you can use the createProcessor as follows.

const SimpleProcessor = (data, config, options) => {
  console.log('value: ' . options.customOption);
  // console.log(config); outputs { configExampleData: {} }
}

const config = {
  data_one: {
    processors: [
      createProcessor(SimpleProcessor, { options: { customOption: 'custom' }})
    ]
    configExampleData: {},
  },
  data_two: {
    processors: [
      SimpleProcessor,
    ]
  },
}

const {data , errors} = readData(config.data_one, { customOption: 'inner' }); //outputs value: inner`
const {data , errors} = readData(config.data_one); // outputs `value: custom`
const {data , errors} = readData(config.data_two); // outputs `value: undefined`
const {data , errors} = readData(config.data_two, { customOption: 'inner' }); //outputs value: inner`

Built in processors

This lib comes together with some built-in Processors, available as sub-module dipe-processors (data-pipe-processors), however you can just ignore them and use your own implementations.

LocalDataParser

Parse local files hosted in the config.source defined directory and uses gray-matter to parse their content.

const config = {
  processors: [LocalDataParser],
  source: './posts',
}

const { data: posts, errors } = readData(config);

LocalDataPostProcessor (WIP)

Filters and sorts out data.

const config = {
  processors: [LocalDataParser, LocalDataPostProcessor],
  source: './posts',
}

const { data: posts, errors } = readData(config);

LocalDataStream (WIP)

RemoteDataStream (WIP)