Implement activity tracking for k8s

Signed-off-by: Vladyslav Zhukovskyi <[email protected]>

extensions/eclipse-che-theia-remote-api/src/common/http-service.ts

@@ -14,4 +14,6 @@ export const HttpService = Symbol('HttpService');
 
 export interface HttpService {
   get(url: string): Promise<string | undefined>;
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  post(url: string, data?: any): Promise<string | undefined>;
 }

extensions/eclipse-che-theia-remote-impl-che-server/src/node/che-server-http-service-impl.ts

@@ -40,6 +40,11 @@ export class CheServerHttpServiceImpl implements HttpService {
     }
   }
 
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  async post(uri: string, data?: any): Promise<string | undefined> {
+    throw new Error('httpsService.post() not supported');
+  }
+
   /**
    * Use proxy and/or certificates.
    */

extensions/eclipse-che-theia-remote-impl-k8s/src/node/k8s-http-service-impl.ts

@@ -40,6 +40,24 @@ export class K8SHttpServiceImpl implements HttpService {
     }
   }
 
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  async post(uri: string, data?: any): Promise<string | undefined> {
+    const axiosInstance = await this.getAxiosInstance(uri);
+    try {
+      const response = await axiosInstance.post(uri, data, {
+        transformResponse: [responseData => responseData],
+        responseType: 'text',
+      });
+      return response.data;
+    } catch (error) {
+      // not found then we return undefined
+      if (error.response && error.response.status === 404) {
+        return undefined;
+      }
+      throw error;
+    }
+  }
+
   /**
    * Use proxy and/or certificates.
    */

extensions/eclipse-che-theia-remote-impl-k8s/src/node/k8s-workspace-service-impl.ts

@@ -17,6 +17,8 @@ import {
 import { inject, injectable } from 'inversify';
 
 import { DevfileService } from '@eclipse-che/theia-remote-api/lib/common/devfile-service';
+import { EndpointService } from '@eclipse-che/theia-remote-api/lib/common/endpoint-service';
+import { HttpService } from '@eclipse-che/theia-remote-api/lib/common/http-service';
 import { K8sDevWorkspaceEnvVariables } from './k8s-devworkspace-env-variables';
 
 @injectable()
@@ -27,6 +29,12 @@ export class K8sWorkspaceServiceImpl implements WorkspaceService {
   @inject(K8sDevWorkspaceEnvVariables)
   private env: K8sDevWorkspaceEnvVariables;
 
+  @inject(EndpointService)
+  private endpointService: EndpointService;
+
+  @inject(HttpService)
+  private httpService: HttpService;
+
   public async getCurrentNamespace(): Promise<string> {
     return this.env.getWorkspaceNamespace();
   }
@@ -62,7 +70,15 @@ export class K8sWorkspaceServiceImpl implements WorkspaceService {
   }
 
   public async updateWorkspaceActivity(): Promise<void> {
-    throw new Error('workspaceService.updateWorkspaceActivity() not supported');
+    const endpoints = await this.endpointService.getEndpointsByType('collocated-terminal');
+    const machineExecEndpoint = endpoints.find(endpoint => endpoint.name === 'terminal');
+
+    if (machineExecEndpoint === undefined || machineExecEndpoint.targetPort === undefined) {
+      throw new Error('Endpoint for machine-exec did not found.');
+    }
+
+    const requestUrl = `http://127.0.0.1:${machineExecEndpoint.targetPort}/activity/tick`;
+    await this.httpService.post(requestUrl);
   }
 
   public async stop(): Promise<void> {