FredericHeem/starhackit

const { tap, pipe, fork } = require("rubico");
const assert = require("assert");
const { defaultsDeep, identity } = require("rubico/x");
const nanoid = require("nanoid");
const { insert } = require("utils/SqlOps");

module.exports = ({ sql }) => {
  const tableName = "project";
  return {
    tableName,
    insert: (data) =>
      pipe([
        () => data,
        defaultsDeep({ project_id: `project-${nanoid.nanoid(8)}` }),
        fork({ out: identity, query: insert({ tableName, sql }) }),
      ])(),
    getAllByUser: ({ where: { user_id } }) =>
      pipe([
        tap(() => {
          assert(user_id);
        }),
        () => sql`
    SELECT 
      project.project_name,
      project_id,
      project.org_id,
      org.org_name,
      (SELECT 
         COUNT(*)
         FROM workspace 
         WHERE workspace.project_id = project.project_id)
         AS workspace_count
      FROM project
      INNER JOIN org ON org.org_id = project.org_id
      INNER JOIN (
          user_orgs
          INNER JOIN users ON users.user_id = user_orgs.user_id
      ) ON project.org_id = user_orgs.org_id
      AND users.user_id = ${user_id};`,
      ])(),
    getAllByOrg: ({ where: { org_id, user_id } }) =>
      pipe([
        tap(() => {
          assert(org_id);
          assert(user_id);
        }),
        () => sql`
      SELECT 
          project.project_name,
          project_id,
          project.org_id,
          (SELECT 
            COUNT(*)
            FROM workspace 
            WHERE workspace.project_id = project.project_id)
            AS workspace_count
        FROM project
        INNER JOIN (
            user_orgs
            INNER JOIN users ON users.user_id = user_orgs.user_id
        ) ON project.org_id = user_orgs.org_id
        AND users.user_id = ${user_id} AND user_orgs.org_id = ${org_id};`,
      ])(),
  };
};