Feature/users stats

api/src/database/service/User.ts

@@ -6,6 +6,7 @@ import {
   IBusinessDwollaId,
   ICustomerDwollaId,
   INewUserInput,
+  IDBUser,
 } from "src/types";
 import { User, User as UserSchema } from "../schema";
 import { removeMongoMeta } from "../utils/index";
@@ -37,14 +38,16 @@ export async function get<T>(filter: any): Promise<T> {
   return removeMongoMeta(response?.toObject());
 }
 
+export async function getAll(): Promise<IDBUser[]> {
+  const response = await User.find();
+  return response?.length > 0
+    ? response.map((doc) => removeMongoMeta(doc.toObject()))
+    : [];
+}
+
 export async function getBusinesses(): Promise<Business[]> {
   const response = await User.find({ verifiedBusiness: true });
-  if (response?.length > 0) {
-    const result: Business[] = [];
-    response.forEach((element) => {
-      const business = removeMongoMeta(element.toObject()).business;
-      result.push(business);
-    });
-    return result;
-  } else return [];
+  return response?.length > 0
+    ? response.map((doc) => removeMongoMeta(doc.toObject()).business)
+    : [];
 }

api/src/router/stats/controller.ts

@@ -1,4 +1,5 @@
 import { Request, Response } from "express";
+import * as PublicServices from "src/service/PublicService";
 import {
   getFundingStatus,
   getDeposits,
@@ -7,11 +8,15 @@ import {
 } from "src/service/PublicService";
 import { httpUtils } from "src/utils";
 import {
+  IDBUser,
+  StatsUser,
   IDeposit,
   IWithdrawal,
   IOperatorTotal,
   ITransferEvent,
+  IWallet,
 } from "src/types";
+import { UserService as UserDatabaseService } from "src/database/service";
 
 const codes = httpUtils.codes;
 
@@ -62,3 +67,62 @@ export async function getAllTransfers(
     httpUtils.serverError(err, res);
   }
 }
+
+export async function getUsersStats(
+  req: Request,
+  res: Response
+): Promise<StatsUser[]> {
+  try {
+    const users: IDBUser[] = await UserDatabaseService.getAll();
+    if (!users?.length) return [];
+    const businesses: StatsUser[] = [];
+    const customers: StatsUser[] = [];
+
+    await Promise.all(
+      users.map(async (u: IDBUser): Promise<StatsUser[]> => {
+        if (u.verifiedBusiness) {
+          const business = u.business;
+          const walletData: IWallet = await PublicServices.getWallet(
+            business.dwollaId
+          );
+          const user: StatsUser = {
+            firstName: business.owner.firstName,
+            lastName: business.owner.lastName,
+            email: u.email,
+            dwollaId: business.dwollaId,
+            balance: walletData.availableBalance,
+            lastLogin: 0,
+            walletAddress: business.walletAddress,
+            address: `${business.address1} ${business.address2}`,
+            type: "business",
+          };
+          businesses.push(user);
+        }
+        if (u.verifiedCustomer) {
+          const customer = u.customer;
+          const walletData: IWallet = await PublicServices.getWallet(
+            customer.dwollaId
+          );
+          const user: StatsUser = {
+            firstName: customer.firstName,
+            lastName: customer.lastName,
+            email: u.email,
+            dwollaId: customer.dwollaId,
+            balance: walletData.availableBalance,
+            lastLogin: 0,
+            walletAddress: customer.walletAddress,
+            address: `${customer.address1} ${customer.address2}`,
+            type: "customer",
+          };
+          customers.push(user);
+        }
+        return;
+      })
+    );
+
+    const all = customers.concat(businesses);
+    httpUtils.createHttpResponse(all, codes.OK, res);
+  } catch (err) {
+    httpUtils.serverError(err, res);
+  }
+}

api/src/router/stats/index.ts

@@ -7,5 +7,6 @@ stats.get("/stats/deposit", controller.getAllDeposits);
 stats.get("/stats/withdrawal", controller.getAllWithdrawals);
 stats.get("/stats/operator", controller.getOperatorStatistics);
 stats.get("/stats/transfer", controller.getAllTransfers);
+stats.get("/stats/users", controller.getUsersStats);
 
 export default stats;

api/src/test/Operator.server.test.ts

@@ -1327,6 +1327,20 @@ describe("Operator endpoints test", () => {
           done(err);
         });
     });
+
+    it("GET /stats/users: it should retrieve all users, HTTP 200", (done) => {
+      chai
+        .request(server)
+        .get("/stats/users")
+        .then((res) => {
+          expect(res).to.have.status(codes.OK);
+          log(JSON.parse(res.text));
+          done();
+        })
+        .catch((err) => {
+          done(err);
+        });
+    });
   });
 
   describe("GET /users/:id/notifications", () => {

api/src/types/index.ts

@@ -217,10 +217,23 @@ export type GenericDatabaseResponse<T, E = string> = {
   error?: E;
 };
 
+export interface StatsUser {
+  firstName: string;
+  lastName: string;
+  email: string;
+  dwollaId: string;
+  balance: number;
+  lastLogin: number;
+  walletAddress: string;
+  address: string;
+  type: "customer" | "business";
+}
+
 export interface HomeScreenContentLink {
   url: string;
   text: string;
 }
+
 export interface HomeScreenContent {
   contentType:
     | "Pictures"