Commit ceaee5ff authored by Tobinsk's avatar Tobinsk

Merge branch 'debug' into 'master'

Debug

See merge request !6
parents 71963db8 67553902
......@@ -32,6 +32,7 @@ class DodisNormalizerTransformer extends Transform {
url: chunk.url,
name: data.data.name,
alternative_name: data.data.comment,
typology: [],
country: data.data.countryCode,
location: DodisNormalizerTransformer.buildLocation(data.data),
modification_date: DodisNormalizerTransformer.getDate()
......
......@@ -4,6 +4,7 @@ import ProducerStream = require('node-rdkafka/lib/producer-stream');
import DodisNormalizerTransformer from "./dodis-normalizer-transformer";
import SitemapReader from './sitemap-reader';
import MagpieTransformer from 'magpie/dist/magpie-transformer';
import Debug from 'geolinker-common/dist/stream/debug';
/**
* Init core
......@@ -39,6 +40,7 @@ kafka.init().then(async () => {
requestOptions: {headers}
}))
.pipe(new DodisNormalizerTransformer({objectMode: true, logger: core.getLogger()}))
.pipe(new Debug({objectMode: true}, 'Debug'))
.pipe(new StreamProducerPreparer({
objectMode: true,
topic: core.getNconf().get('producer:geolinker:topics'),
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment