added Dockerfile

Author: vgenev

Dockerfile

@@ -0,0 +1,25 @@
+FROM node:10.15.3-alpine
+USER root
+
+WORKDIR /opt/event-stream-processor
+
+RUN apk --no-cache add git
+RUN apk add --no-cache -t build-dependencies make gcc g++ python libtool autoconf automake \
+    && cd $(npm root -g)/npm \
+    && npm config set unsafe-perm true \
+    && npm install -g node-gyp
+
+COPY package.json package-lock.json* /opt/event-stream-processor/
+
+RUN npm install --production && \
+  npm uninstall -g npm
+
+COPY src /opt/event-stream-processor/src
+COPY config /opt/event-stream-processor/config
+COPY app.js /opt/event-stream-processor/
+# COPY docs /opt/central-event-processor/docs
+
+RUN apk del build-dependencies
+
+EXPOSE 3082
+CMD node app.js

config/default.json

@@ -5,7 +5,7 @@
     "timeout": 3.0,
     "reconnectInterval": 600
   },
-  "PORT": 3081,
+  "PORT": 3082,
   "KAFKA": {
     "TOPIC_TEMPLATES": {
       "GENERAL_TOPIC_TEMPLATE": {

src/observables/apmTracerObservable.js

@@ -7,19 +7,19 @@ const apmTracerObservable = ({ message }) => {
   return Rx.Observable.create(observable => {
     const flags = Buffer.alloc(1).fill(1)
     const version = Buffer.alloc(1).fill(0)
-    const { service, traceId, parentSpanId, spanId, timestamp, endTimestamp } = message.value.metadata.trace
+    const { service, traceId, parentSpanId, spanId, startTimestamp, finishTimestamp } = message.value.metadata.trace
     const traceIdBuff = Buffer.from(traceId, 'hex')
     const spanIdBuff = Buffer.from(spanId, 'hex')
     const parentSpanIdBuff = parentSpanId && Buffer.from(parentSpanId, 'hex')
     Logger.info(`version: ${version.toString('hex')} traceId: ${traceId} spanId: ${spanId} parentSpanId: ${parentSpanId} flags: ${flags.toString('hex')}`)
     const context = parentSpanIdBuff
       ? new TraceParent(Buffer.concat([version, traceIdBuff, spanIdBuff, flags, parentSpanIdBuff]))
       : new TraceParent(Buffer.concat([version, traceIdBuff, spanIdBuff, flags]))
-    let span = tracer.startSpan(`${service}`, { startTime: Date.parse(timestamp) }, context)
+    let span = tracer.startSpan(`${service}`, { startTime: Date.parse(startTimestamp) }, context)
     tracer.startSpan()
     span.setTag('payload', message.value.content.payload)
     span.setTag('messageId', message.value.id)
-    span.finish(Date.parse(endTimestamp))
+    span.finish(Date.parse(finishTimestamp))
     observable.next({ span })
   })
 }