✨ Org events and data export

Author: AnandChowdhary

src/crud/event.ts

@@ -50,6 +50,34 @@ export const getUserRecentEvents = async (userId: number) => {
   ));
 };
 
+/*
+ * Get all security events for a user
+ */
+export const getOrganizationEvents = async (organizationId: number) => {
+  return <Event[]>(
+    await cachedQuery(
+      CacheCategories.ORGANIZATION_EVENT,
+      organizationId,
+      `SELECT * FROM events WHERE organizationId = ?`,
+      [organizationId]
+    )
+  );
+};
+
+/*
+ * Get the 10 most recent security events for a user
+ */
+export const getOrganizationRecentEvents = async (organizationId: number) => {
+  return await addLocationToEvents(<Event[]>(
+    await cachedQuery(
+      CacheCategories.ORGANIZATION_RECENT_EVENTS,
+      organizationId,
+      `SELECT * FROM events WHERE organizationId = ? ORDER BY id DESC LIMIT 10`,
+      [organizationId]
+    )
+  ));
+};
+
 /*
  * Delete all security events for a user
  */

src/interfaces/enum.ts

@@ -90,7 +90,9 @@ export enum CacheCategories {
   USER_VERIFIED_EMAILS = "user-verified-emails",
   EMAIL = "email",
   USER_EVENT = "user-event",
+  ORGANIZATION_EVENT = "organization-event",
   USER_RECENT_EVENTS = "user-recent-events",
+  ORGANIZATION_RECENT_EVENTS = "organization-recent-events",
   USER_MEMBERSHIPS = "user-memberships",
   USER_MEMBERSHIP_ORGANIZATION = "user-membership-org",
   ORGANIZATION_MEMBERSHIPS = "memberships",

src/rest/organization.ts

@@ -8,15 +8,20 @@ import {
 import { InsertResult } from "../interfaces/mysql";
 import {
   createMembership,
-  deleteAllOrganizationMemberships
+  deleteAllOrganizationMemberships,
+  getOrganizationMemberDetails
 } from "../crud/membership";
 import {
   MembershipRole,
   ErrorCode,
   EventType,
   Authorizations
 } from "../interfaces/enum";
-import { createEvent } from "../crud/event";
+import {
+  createEvent,
+  getOrganizationEvents,
+  getOrganizationRecentEvents
+} from "../crud/event";
 import { Locals } from "../interfaces/general";
 import { can } from "../helpers/authorization";
 import {
@@ -273,3 +278,52 @@ export const createOrganizationSourceForUser = async (
   }
   throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
 };
+
+export const getAllOrganizationDataForUser = async (
+  userId: number,
+  organizationId: number
+) => {
+  if (
+    await can(
+      userId,
+      Authorizations.READ_SECURE,
+      "organization",
+      organizationId
+    )
+  ) {
+    const organization = await getOrganization(organizationId);
+    const memberships = await getOrganizationMemberDetails(organizationId);
+    const events = await getOrganizationEvents(organizationId);
+    let billing = {};
+    let subscriptions = {};
+    let invoices = {};
+    let sources = {};
+    if (organization.stripeCustomerId) {
+      billing = await getStripeCustomer(organization.stripeCustomerId);
+      subscriptions = await getStripeSubscriptions(
+        organization.stripeCustomerId
+      );
+      invoices = await getStripeInvoices(organization.stripeCustomerId);
+      sources = await getStripeSources(organization.stripeCustomerId);
+    }
+    return {
+      organization,
+      memberships,
+      events,
+      billing,
+      subscriptions,
+      invoices,
+      sources
+    };
+  }
+  throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
+};
+
+export const getOrganizationRecentEventsForUser = async (
+  userId: number,
+  organizationId: number
+) => {
+  if (await can(userId, Authorizations.READ, "organization", organizationId))
+    return await getOrganizationRecentEvents(organizationId);
+  throw new Error(ErrorCode.INSUFFICIENT_PERMISSION);
+};

src/routes/index.ts

@@ -29,7 +29,9 @@ import {
   routeOrganizationSourceGet,
   routeOrganizationSourcesPut,
   routeOrganizationSourceUpdate,
-  routeOrganizationSourceDelete
+  routeOrganizationSourceDelete,
+  routeOrganizationDataGet,
+  routeOrganizationRecentEventsGet
 } from "./organizations";
 import { authHandler } from "../helpers/middleware";
 import {
@@ -196,6 +198,16 @@ const routesOrganization = (app: Application) => {
     authHandler,
     asyncHandler(routeOrganizationSourceDelete)
   );
+  app.get(
+    "/organizations/:id/data",
+    authHandler,
+    asyncHandler(routeOrganizationDataGet)
+  );
+  app.get(
+    "/organizations/:id/events",
+    authHandler,
+    asyncHandler(routeOrganizationRecentEventsGet)
+  );
 };
 
 const routesMembership = (app: Application) => {

src/routes/organizations.ts

@@ -13,7 +13,9 @@ import {
   getOrganizationSourceForUser,
   createOrganizationSourceForUser,
   updateOrganizationSourceForUser,
-  deleteOrganizationSourceForUser
+  deleteOrganizationSourceForUser,
+  getAllOrganizationDataForUser,
+  getOrganizationRecentEventsForUser
 } from "../rest/organization";
 import { ErrorCode } from "../interfaces/enum";
 
@@ -181,3 +183,18 @@ export const routeOrganizationSourcesPut = async (
     )
   );
 };
+
+export const routeOrganizationDataGet = async (req: Request, res: Response) => {
+  res.json(
+    await getAllOrganizationDataForUser(res.locals.token.id, req.params.id)
+  );
+};
+
+export const routeOrganizationRecentEventsGet = async (
+  req: Request,
+  res: Response
+) => {
+  res.json(
+    await getOrganizationRecentEventsForUser(res.locals.token.id, req.params.id)
+  );
+};