✨ Add CRUD helpers for orgs/members

Author: AnandChowdhary

package.json

@@ -20,6 +20,7 @@
     "@types/jest": "^24.0.11",
     "@types/jsonwebtoken": "^8.3.2",
     "@types/marked": "^0.6.5",
+    "@types/mustache": "^0.8.32",
     "@types/mysql": "^2.15.5",
     "@types/node": "^11.13.6",
     "concurrently": "^4.1.0",
@@ -34,7 +35,6 @@
     "typescript": "^3.4.4"
   },
   "dependencies": {
-    "@types/mustache": "^0.8.32",
     "bcrypt": "^3.0.6",
     "express-async-handler": "^1.1.4",
     "fs-extra": "^7.0.1",

src/crud/email.ts

@@ -2,6 +2,8 @@ import { query, tableValues, setValues } from "../helpers/mysql";
 import { Email } from "../interfaces/tables/emails";
 import { dateToDateTime } from "../helpers/utils";
 import { KeyValue } from "../interfaces/general";
+import { User } from "../interfaces/tables/user";
+import { getUser } from "./user";
 
 export const createEmail = async (email: Email, sendVerification = true) => {
   // Clean up values
@@ -24,6 +26,40 @@ export const updateEmail = async (id: number, email: KeyValue) => {
   ]);
 };
 
+export const deleteEmail = async (id: number) => {
+  return await query("DELETE FROM emails WHERE id = ?", [id]);
+};
+
 export const getEmail = async (id: number) => {
-  return (<Email[]>await query("SELECT * FROM emails WHERE id = ?", [id]))[0];
+  return (<Email[]>(
+    await query("SELECT * FROM emails WHERE id = ? LIMIT 1", [id])
+  ))[0];
+};
+
+export const getUserPrimaryEmailObject = async (user: User | number) => {
+  let userObject: User;
+  if (typeof user === "number") {
+    userObject = await getUser(user);
+  } else {
+    userObject = user;
+  }
+  const primaryEmailId = userObject.primaryEmail;
+  if (!primaryEmailId) throw new Error("no-primary-email");
+  return await getEmail(primaryEmailId);
+};
+
+export const getUserPrimaryEmail = async (user: User | number) => {
+  return (await getUserPrimaryEmailObject(user)).email;
+};
+
+export const getUserEmails = async (userId: number) => {
+  return <Email>await query("SELECT * FROM emails WHERE userId = ?", [userId]);
+};
+
+export const getUserVerifiedEmails = async (userId: number) => {
+  return <Email>(
+    await query("SELECT * FROM emails WHERE userId = ? AND isVerified = 1", [
+      userId
+    ])
+  );
 };

src/crud/membership.ts

@@ -0,0 +1,55 @@
+import { query, tableValues, setValues } from "../helpers/mysql";
+import { Membership } from "../interfaces/tables/memberships";
+import { dateToDateTime } from "../helpers/utils";
+import { KeyValue } from "../interfaces/general";
+import { User } from "../interfaces/tables/user";
+import { getOrganization } from "./organization";
+
+export const createMembership = async (membership: Membership) => {
+  membership.createdAt = new Date();
+  membership.updatedAt = membership.createdAt;
+  return await query(
+    `INSERT INTO memberships ${tableValues(membership)}`,
+    Object.values(membership)
+  );
+};
+
+export const updateMembership = async (id: number, membership: KeyValue) => {
+  membership.updatedAt = dateToDateTime(new Date());
+  return await query(
+    `UPDATE memberships SET ${setValues(membership)} WHERE id = ?`,
+    [...Object.values(membership), id]
+  );
+};
+
+export const deleteMembership = async (id: number) => {
+  return await query("DELETE FROM memberships WHERE id = ?", [id]);
+};
+
+export const getMembership = async (id: number) => {
+  return (<Membership[]>(
+    await query("SELECT * FROM memberships WHERE id = ? LIMIT 1", [id])
+  ))[0];
+};
+
+export const getUserMembershipObject = async (user: User | number) => {
+  let userId: number = 0;
+  if (typeof user === "number") {
+    userId = user;
+  } else if (user.id) {
+    userId = user.id;
+  }
+  if (!userId) throw new Error("user id not found");
+  return <Membership>(
+    await query(`SELECT * FROM memberships WHERE userId = ? LIMIT 1`, [userId])
+  );
+};
+
+export const getUserOrganizationId = async (user: User | number) => {
+  return (await getUserMembershipObject(user)).organizationId;
+};
+
+export const getUserOrganization = async (user: User | number) => {
+  const organizationId = await getUserOrganizationId(user);
+  return await getOrganization(organizationId);
+};

src/crud/organization.ts

@@ -0,0 +1,41 @@
+import { query, tableValues, setValues } from "../helpers/mysql";
+import { Organization } from "../interfaces/tables/organization";
+import { capitalizeFirstAndLastLetter, dateToDateTime } from "../helpers/utils";
+import { KeyValue } from "../interfaces/general";
+
+export const listAllOrganizations = async () => {
+  return <Organization[]>await query("SELECT * from organizations");
+};
+
+export const createOrganization = async (organization: Organization) => {
+  if (organization.name)
+    organization.name = capitalizeFirstAndLastLetter(organization.name);
+  organization.createdAt = new Date();
+  organization.updatedAt = organization.createdAt;
+  // Create organization
+  return await query(
+    `INSERT INTO organizations ${tableValues(organization)}`,
+    Object.values(organization)
+  );
+};
+
+export const getOrganization = async (id: number) => {
+  return (<Organization[]>(
+    await query(`SELECT * FROM organizations WHERE id = ? LIMIT 1`, [id])
+  ))[0];
+};
+
+export const updateOrganization = async (
+  id: number,
+  organization: KeyValue
+) => {
+  organization.updatedAt = dateToDateTime(new Date());
+  return await query(
+    `UPDATE organizations SET ${setValues(organization)} WHERE id = ?`,
+    [...Object.values(organization), id]
+  );
+};
+
+export const deleteOrganization = async (id: number) => {
+  return await query("DELETE FROM organizations WHERE id = ?", [id]);
+};