Rpd/v2

package.json

@@ -1,6 +1,6 @@
 {
     "name": "rapida-nodejs",
-    "version": "1.0.4-alpha",
+    "version": "1.0.5",
     "description": "Enable to interact with rapida platform",
     "main": "dist/index.cjs",
     "module": "dist/index.js",

src/clients/activity.ts

@@ -0,0 +1,120 @@
+/*
+ *  Copyright (c) 2024. Rapida
+ *
+ *  Permission is hereby granted, free of charge, to any person obtaining a copy
+ *  of this software and associated documentation files (the "Software"), to deal
+ *  in the Software without restriction, including without limitation the rights
+ *  to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+ *  copies of the Software, and to permit persons to whom the Software is
+ *  furnished to do so, subject to the following conditions:
+ *
+ *  The above copyright notice and this permission notice shall be included in
+ *  all copies or substantial portions of the Software.
+ *
+ *  THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ *  IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+ *  FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+ *  AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+ *  LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+ *  OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+ *  THE SOFTWARE.
+ *
+ *  Author: Prashant <prashant@rapida.ai>
+ *
+ *  This module provides functions for accessing audit logs via gRPC. It includes
+ *  operations for retrieving lists of audit logs and fetching specific audit log entries.
+ */
+
+import { Criteria, Paginate } from "@/rapida/clients/protos/common_pb";
+import {
+  UserAuthInfo,
+  ClientAuthInfo,
+  WithAuthContext,
+} from "@/rapida/clients";
+import {
+  GetAllAuditLogRequest,
+  GetAllAuditLogResponse,
+  GetAuditLogRequest,
+  GetAuditLogResponse,
+} from "@/rapida/clients/protos/audit-logging-api_pb";
+import { ConnectionConfig } from "@/rapida/connections/connection-config";
+import grpc from "@grpc/grpc-js";
+
+/**
+ * Retrieve a paginated list of audit logs with filtering criteria.
+ *
+ * @param connectionConfig - The connection configuration.
+ * @param projectId - The ID of the project for which to retrieve audit logs.
+ * @param page - The page number for pagination.
+ * @param pageSize - The number of logs per page.
+ * @param criteria - List of criteria to filter the audit logs.
+ * @param authHeader - Authentication headers for the request.
+ * @returns Promise<GetAllAuditLogResponse> - A promise that resolves with the audit log response.
+ */
+export function GetActivities(
+  connectionConfig: ConnectionConfig,
+  projectId: string,
+  page: number,
+  pageSize: number,
+  criteria: { key: string; value: string; logic: string }[]
+): Promise<GetAllAuditLogResponse> {
+  return new Promise((resolve, reject) => {
+    const req = new GetAllAuditLogRequest();
+    req.setProjectid(projectId);
+
+    const paginate = new Paginate();
+    criteria.forEach(({ key, value, logic }) => {
+      const ctr = new Criteria();
+      ctr.setKey(key);
+      ctr.setValue(value);
+      ctr.setLogic(logic);
+      req.addCriterias(ctr);
+    });
+
+    paginate.setPage(page);
+    paginate.setPagesize(pageSize);
+    req.setPaginate(paginate);
+
+    connectionConfig.auditLoggingClient.getAllAuditLog(
+      req,
+      WithAuthContext(connectionConfig.auth),
+      (
+        err: grpc.ServiceError | null,
+        response: GetAllAuditLogResponse | null
+      ) => {
+        if (err) reject(err);
+        else resolve(response!);
+      }
+    );
+  });
+}
+
+/**
+ * Retrieve a specific audit log entry by its ID.
+ *
+ * @param connectionConfig - The connection configuration.
+ * @param projectId - The ID of the project associated with the audit log.
+ * @param auditId - The ID of the audit log entry to retrieve.
+ * @param authHeader - Authentication headers for the request.
+ * @returns Promise<GetAuditLogResponse> - A promise that resolves with the audit log response.
+ */
+export function GetActivity(
+  connectionConfig: ConnectionConfig,
+  projectId: string,
+  auditId: string
+): Promise<GetAuditLogResponse> {
+  return new Promise((resolve, reject) => {
+    const req = new GetAuditLogRequest();
+    req.setProjectid(projectId);
+    req.setId(auditId);
+
+    connectionConfig.auditLoggingClient.getAuditLog(
+      req,
+      WithAuthContext(connectionConfig.auth),
+      (err: grpc.ServiceError | null, response: GetAuditLogResponse | null) => {
+        if (err) reject(err);
+        else resolve(response!);
+      }
+    );
+  });
+}