enricher

gistfile1.js

const { transformFactory } = require('../utils/stream');
const { GENERATED_AT_TIME } = require('../utils/constants');

module.exports = transformFactory((stream, config, transform) => data => {
    const transformed = transform(data);
    const id = transformed[0].subject;

    const graph = transformed.reduce(
        (acc, triple) => {
            acc[triple.predicate] = { '@id': triple.object };
            return acc;
        },
        { '@id': id }
    );

    stream.push({
        '@id': id,
        '@graph': graph,
        [GENERATED_AT_TIME]: new Date()
    });
});