chore: fix

Author: ovr

packages/cubejs-backend-shared/src/track.ts

@@ -5,7 +5,8 @@ import { internalExceptions } from './errors';
 
 export type BaseEvent = {
   event: string,
-  timestamp: string,
+  // it's possible to fill timestamp at place of logging, otherwise it will fill it automatically
+  timestamp?: string,
   [key: string]: any,
 };
 

packages/cubejs-server-core/src/core/agentCollect.ts

@@ -8,7 +8,7 @@ import crypto from 'crypto';
 import WebSocket from 'ws';
 import zlib from 'zlib';
 import { promisify } from 'util';
-import { LoggerFn } from './types';
+import { LoggerFnParams, LoggerFn } from './types';
 
 const deflate = promisify(zlib.deflate);
 interface AgentTransport {
@@ -176,7 +176,7 @@ const clearTransport = () => {
   agentInterval = null;
 };
 
-export default async (event: Record<string, any>, endpointUrl: string, logger: LoggerFn) => {
+export const agentCollect = async (event: LoggerFnParams, endpointUrl: string, logger: LoggerFn) => {
   trackEvents.push({
     timestamp: new Date().toJSON(),
     ...event,
@@ -228,3 +228,5 @@ export default async (event: Record<string, any>, endpointUrl: string, logger: L
     }, getEnv('agentFlushInterval'));
   }
 };
+
+export default agentCollect;

packages/cubejs-server-core/src/core/server.ts

@@ -30,7 +30,7 @@ import { RefreshScheduler, ScheduledRefreshOptions } from './RefreshScheduler';
 import { OrchestratorApi, OrchestratorApiOptions } from './OrchestratorApi';
 import { CompilerApi } from './CompilerApi';
 import { DevServer } from './DevServer';
-import agentCollect from './agentCollect';
+import { agentCollect } from './agentCollect';
 import { OrchestratorStorage } from './OrchestratorStorage';
 import { prodLogger, devLogger } from './logger';
 import { OptsHandler } from './OptsHandler';
@@ -58,7 +58,8 @@ import type {
   LoggerFn,
   DriverConfig,
   ScheduledRefreshTimeZonesFn,
-  ContextToCubeStoreRouterIdFn, LoggerEventParams,
+  ContextToCubeStoreRouterIdFn,
+  LoggerFnParams,
 } from './types';
 import {
   ContextToOrchestratorIdFn,
@@ -230,7 +231,7 @@ export class CubejsServerCore {
 
     this.startScheduledRefreshTimer();
 
-    this.event = async (event, props: LoggerEventParams) => {
+    this.event = async (event, props: LoggerFnParams) => {
       if (!this.options.telemetry) {
         return;
       }

packages/cubejs-server-core/src/core/types.ts

@@ -167,11 +167,12 @@ export type ExternalDbTypeFn = (context: RequestContext) => DatabaseType;
 export type ExternalDriverFactoryFn = (context: RequestContext) => Promise<BaseDriver> | BaseDriver;
 export type ExternalDialectFactoryFn = (context: RequestContext) => BaseQuery;
 
-export type LoggerEventParams = {
+export type LoggerFnParams = {
+  // it's possible to fill timestamp at place of logging, otherwise it will fill it automatically
   timestamp?: string,
   [key: string]: any,
 };
-export type LoggerFn = (msg: string, params: LoggerEventParams) => void;
+export type LoggerFn = (msg: string, params: LoggerFnParams) => void;
 
 export type BiToolSyncConfig = {
   type: string;