fix(pencil): Fix bug config updates are disabled

Author: alexivsn

src/agent-manager.ts

@@ -107,12 +107,12 @@ export default class AgentManager {
             //start hgeart beats
             this.heartBeatManager = new HeartBeatManager(this.options.heartBeatInterval, this.apiManager.heartBeat.bind(this));
             this.heartBeatManager.startHeartBeatLoop();
-            this.configurationUpdate.call(this);
-
             this.eventManager.setSessionId(data.sessionId);
             this.eventManager.startEventsPersist();
             this.isAgentStarted = true;
-
+            
+            //schedual config update
+            this.configurationUpdate.call(this);
             Logger.debug('Agent successfuly started!');
             return resolve(true);
           } else {

src/events/sdk-event.ts

@@ -34,6 +34,9 @@ export default class SDKEvent implements IEvent {
     Logger.debug('Building SDK event');
     // extract info from session
     const { req } = SessionManager.getLastSession();
+    if (!req) {
+      Logger.debug('request is empty', req);
+    }
     const reqCtx = mergeRequestContexts(event.context || {}, contextFromRequest(req));
 
     const decryptedToken = decrypt(reqCtx?.clientToken, options.apiKey);
@@ -42,7 +45,6 @@ export default class SDKEvent implements IEvent {
     Logger.debug('Parsed client token:', parsedToken);
 
     const user: any = event.userTraits || {};
-
     this.rid = v4();
     this.eventType = event.event;
     this.userId = event.userId || '';

src/interceptors/http-server-interceptor.ts

@@ -74,7 +74,7 @@ export default class HttpServerInterceptor extends Interceptor implements IInter
             if (this && this.sn_finished) {
               return;
             }
-            if (arguments.length > 0 && arguments[0] !== undefined) {
+            if (arguments && arguments.length > 0 && arguments[0] !== undefined) {
               intercept(this.req && this.req.sn_uid, 'write');
             }
             return original.apply(this, arguments);
@@ -105,7 +105,7 @@ export default class HttpServerInterceptor extends Interceptor implements IInter
             intercept(this.req && this.req.sn_uid, 'end');
             const { req, res } = SessionManager.getSession(this.req?.sn_uid);
             if (req && res) {
-              risk({ eventType: EventType.RISK, context: { req: contextFromRequest(req), res: contextFromResponse(res) } });
+              risk({ event: EventType.RISK, context: { req: contextFromRequest(req), res: contextFromResponse(res) } });
             }
 
             SessionManager.cleanSession(this.req && this.req.sn_uid);

src/session-manager.ts

@@ -1,5 +1,5 @@
 import { IncomingMessage, ServerResponse } from 'http';
-
+import { Logger } from './logger';
 export interface Session {
   req: IncomingMessage | any;
   res: ServerResponse | any;
@@ -10,14 +10,17 @@ export default class SessionManager {
   private static session: Map<string, Session> = new Map<string, Session>();
 
   static getLastSession(): Session {
-    return SessionManager.session.get(SessionManager.lastSessionId) || { req: null, res: null };
+    const session = SessionManager.session.get(SessionManager.lastSessionId) || { req: null, res: null };
+    Logger.debug(`[SessionManager] Getting last session by: ${SessionManager.lastSessionId}, is: ${session.req?.sn_uid}`);
+    return session;
   }
 
   static getSession(id: string): Session {
     return SessionManager.session.get(id) || { req: null, res: null };
   }
 
   static setSession(id: string, session: Session) {
+    Logger.debug(`[SessionManager] Setting session: ${id}`);
     session.req.sn_uid = id;
     session.res.sn_uid = id;
     SessionManager.session.set(id, session);
@@ -27,6 +30,7 @@ export default class SessionManager {
   }
 
   static cleanSession(id: string) {
+    Logger.debug(`[SessionManager] Cleaning session: ${id}`);
     SessionManager.session.delete(id);
   }
 }