Merge pull request #8 from ExpediaDotCom/update-haystack-client

updating haystack-client min version 0.1.3

Author: Kapil Rastogi

package.json

@@ -20,7 +20,7 @@
     "Haystack <haystack@expedia.com>"
   ],
   "dependencies": {
-    "haystack-client": "^0.1.0",
+    "haystack-client": "^0.1.3",
     "google-protobuf": "^3.0.0",
     "grpc": "^1.9.0",
     "base-64": "^0.1.0",

src/blob_client_impl.ts

@@ -50,8 +50,8 @@ export default class BlobClientImpl implements BlobClient {
             throw new Error(`Fail to write the blob to an already closed haystack span`);
         }
         const spanCtx = span.context();
-        const parentSpanId = spanCtx.parentSpanId() || spanCtx.traceId();
-        span.setTag(`Blob-${blobType}`, `/getBlob/${span.serviceName()}/${blobType}/${spanCtx.traceId()}/${parentSpanId}/${spanCtx.spanId()}`);
+        const parentSpanId = spanCtx.parentSpanId || spanCtx.traceId;
+        span.setTag(`Blob-${blobType}`, `/getBlob/${span.serviceName()}/${blobType}/${spanCtx.traceId}/${parentSpanId}/${spanCtx.spanId}`);
         this._dispatcher.dispatch(span, blobPayload, blobType, contentType, callback);
     }
 }

src/dispatchers/offline_agent_dispatcher.ts

@@ -65,13 +65,13 @@ export default class OfflineAgentDispatcher implements Dispatcher {
         this._ensureDirectoryExists(span, blobDir => {
             const blobFilePath = Utils.blobFilePath(span, blobDir, blobtype);
             const spanCtx = span.context();
-            const requestId = spanCtx.parentSpanId() || spanCtx.traceId();
+            const requestId = spanCtx.parentSpanId || spanCtx.traceId;
 
             const blobWithMetadata = {
                 client: span.serviceName(),
                 timestamp: Date.now(),
-                transactionid: spanCtx.traceId(),
-                eventid: spanCtx.spanId(),
+                transactionid: spanCtx.traceId,
+                eventid: spanCtx.spanId,
                 requestid: requestId,
                 blobType: blobtype,
                 contentType: contenttype.toString(),

src/dispatchers/remote.ts

@@ -66,11 +66,11 @@ export default class RemoteDispatcher implements Dispatcher {
     private _convertToProtoBlob(span: haystack.Span, blobPayload: Buffer, blobType: string, contentType: BlobContentType): any {
         const protoBlob = new messages.Blob();
         const spanCtx = span.context();
-        const requestId = spanCtx.parentSpanId() || spanCtx.traceId();
+        const requestId = spanCtx.parentSpanId || spanCtx.traceId;
 
         protoBlob.setClient(span.serviceName());
-        protoBlob.setTransactionid(spanCtx.traceId());
-        protoBlob.setEventid(spanCtx.spanId());
+        protoBlob.setTransactionid(spanCtx.traceId);
+        protoBlob.setEventid(spanCtx.spanId);
         protoBlob.setRequestid(requestId);
         protoBlob.setTimestamp(Date.now());
         protoBlob.setContent(blobPayload);

src/utils.ts

@@ -20,7 +20,7 @@ export default class Utils {
 
     static blobFilePath(span: haystack.Span, baseDir: string, blobType: string): string {
         const spanCtx = span.context();
-        const parentSpanIdMarker = spanCtx.parentSpanId() || spanCtx.traceId();
-        return `${baseDir}/${span.serviceName()}_${spanCtx.traceId()}_${parentSpanIdMarker}_${spanCtx.spanId()}_${blobType}.log`;
+        const parentSpanIdMarker = spanCtx.parentSpanId || spanCtx.traceId;
+        return `${baseDir}/${span.serviceName()}_${spanCtx.traceId}_${parentSpanIdMarker}_${spanCtx.spanId}_${blobType}.log`;
     }
 }