fix/removed runtime scrapper

Author: piotr-szewczyk

package.json

@@ -18,7 +18,7 @@
   ],
   "devDependencies": {
     "@types/jest": "^29.2.0",
-    "@types/node": "10.17.0",
+    "@types/node": "20.3.1",
     "@types/react": "^16.9.49",
     "@types/react-dom": "^16.9.8",
     "@types/rimraf": "^3.0.2",

packages/node-core/src/types/http.ts

@@ -25,7 +25,6 @@ export enum RequestStatus {
 export enum CAPTURE_ENDPOINT {
   LOG = "/api/capture/log",
   INCIDENT = "/api/capture/incident",
-  RUNTIME = "/api/capture/runtime",
   METRICS = "/api/capture/metrics",
   TRACING = "/api/capture/traces"
 }

packages/node/src/client.ts

@@ -1,7 +1,6 @@
 import { INodeClient, CoreClient, TraceoOptions, Dictionary } from "@traceo-sdk/node-core";
 import { Logger } from "./logger";
 import { MetricsRunner } from "./metrics";
-import { Scrapper } from "./scrapper";
 
 export class Client extends CoreClient implements INodeClient {
   public headers: Dictionary<any>;
@@ -20,11 +19,6 @@ export class Client extends CoreClient implements INodeClient {
   }
 
   public initSDK(): void {
-    const scrapper = new Scrapper();
-    scrapper.collect();
-
-    console.log("options: ", this.options);
-
     if (this.options.collectMetrics) {
       const metrics = new MetricsRunner();
       metrics.register();

packages/node/src/logger.ts

@@ -11,7 +11,7 @@ export class Logger {
     this.logsQueue = [];
 
     const client = getGlobalTraceo();
-        
+
     const scrapLogsInterval = client.options.exportIntervalMillis;
     if (scrapLogsInterval && scrapLogsInterval >= DEFAULT_EXPORT_INTERVAL) {
       this.INTERVAL = scrapLogsInterval;
@@ -21,7 +21,7 @@ export class Logger {
   }
 
   private register() {
-    setInterval(() => this.sendLogs(), this.INTERVAL * 1000);
+    setInterval(() => this.sendLogs(), this.INTERVAL);
   }
 
   public log(...args: any[]): void {
@@ -58,13 +58,23 @@ export class Logger {
       level,
       message,
       timestamp,
-      unix: Math.floor(Date.now() / 1000),
+      unix: this.getUnix,
       resources: this.resources
     };
 
     this.logsQueue.push(requestPayload);
   }
 
+  private get getUnix(): number {
+    const currentDate = new Date();
+
+    const unixTimestamp = Math.floor(currentDate.getTime() / 1000);
+    const milliseconds = currentDate.getMilliseconds();
+    const unixWithMilliseconds = unixTimestamp * 1000 + milliseconds;
+
+    return unixWithMilliseconds;
+  }
+
   private async sendLogs() {
     if (this.logsQueue.length > 0) {
       transport.request({
@@ -84,18 +94,16 @@ export class Logger {
   }
 
   private get timestamp(): string {
-    const localeStringOptions = {
-      year: "numeric",
-      hour: "numeric",
-      minute: "numeric",
-      second: "numeric",
-      day: "2-digit",
-      month: "2-digit"
-    };
-    return new Date(Date.now()).toLocaleString(
-      undefined,
-      localeStringOptions as Intl.DateTimeFormatOptions
-    );
+    const date = new Date();
+    const year = date.getFullYear().toString().padStart(4, '0');
+    const month = (date.getMonth() + 1).toString().padStart(2, '0');
+    const day = date.getDate().toString().padStart(2, '0');
+    const hours = date.getHours().toString().padStart(2, '0');
+    const minutes = date.getMinutes().toString().padStart(2, '0');
+    const seconds = date.getSeconds().toString().padStart(2, '0');
+    const milliseconds = date.getMilliseconds().toString().padStart(3, '0');
+
+    return `${year}-${month}-${day} ${hours}:${minutes}:${seconds}:${milliseconds}`;
   }
 
   private get resources(): { [key: string]: any } {

packages/node/src/scrapper.ts

@@ -25,6 +25,7 @@
     },
     "dependencies": {
         "@opentelemetry/api": "^1.4.1",
+        "@opentelemetry/api-logs": "^0.39.1",
         "@opentelemetry/exporter-metrics-otlp-http": "^0.38.0",
         "@opentelemetry/exporter-trace-otlp-http": "^0.39.1",
         "@traceo-sdk/node-core": "0.32.2",