feat: projects view

package.json

@@ -11,7 +11,7 @@
     "build": "npm run build:server",
     "build:server": "tsc -p .",
     "format": "prettier --write \"**/*.{js,jsx,json,md,ts,tsx}\"",
-    "start": "concurrently -c blue,green -n SERVER,FRONT 'npm run serve' 'npm run develop'",
+    "start": "concurrently -c blue -n SERVER 'npm run serve'",
     "serve": "DOTENV_CONFIG_PATH=.env.development nodemon --watch src/entities --watch src/back --watch src/clients --watch src/services --watch src/server.ts --watch static/api.yaml -e ts,json --exec 'ts-node -r dotenv/config' src/server",
     "version": "tsc -p .",
     "migrate": "DOTENV_CONFIG_PATH=.env.development ts-node -r dotenv/config.js ./node_modules/node-pg-migrate/bin/node-pg-migrate -j ts -m src/migrations -d CONNECTION_STRING",

src/back/jobs/ProjectsMigration.ts

@@ -0,0 +1,10 @@
+import { ProjectService } from '../../services/ProjectService'
+
+export async function migrateProjects() {
+  const result = await ProjectService.migrateProjects()
+  if (result.error || result.migrationErrors.length > 0) {
+    throw JSON.stringify(result)
+  }
+
+  return result
+}

src/back/models/Personnel.ts

@@ -0,0 +1,18 @@
+import { Model } from 'decentraland-gatsby/dist/entities/Database/model'
+
+import { TeamMember } from '../../entities/Grant/types'
+
+export type PersonnelAttributes = TeamMember & {
+  id: string
+  project_id: string
+  deleted: boolean
+  updated_by?: string
+  updated_at?: Date
+  created_at: Date
+}
+
+export default class PersonnelModel extends Model<PersonnelAttributes> {
+  static tableName = 'personnel'
+  static withTimestamps = false
+  static primaryKey = 'id'
+}

src/back/models/Project.ts

@@ -0,0 +1,115 @@
+import crypto from 'crypto'
+import { Model } from 'decentraland-gatsby/dist/entities/Database/model'
+import { SQL, join, table } from 'decentraland-gatsby/dist/entities/Database/utils'
+import isEthereumAddress from 'validator/lib/isEthereumAddress'
+import isUUID from 'validator/lib/isUUID'
+
+import CoauthorModel from '../../entities/Coauthor/model'
+import { CoauthorStatus } from '../../entities/Coauthor/types'
+import { ProjectStatus } from '../../entities/Grant/types'
+import ProposalModel from '../../entities/Proposal/model'
+import { ProjectFunding, ProposalProject } from '../../entities/Proposal/types'
+
+import PersonnelModel, { PersonnelAttributes } from './Personnel'
+import ProjectLinkModel, { ProjectLink } from './ProjectLink'
+import ProjectMilestoneModel, { ProjectMilestone } from './ProjectMilestone'
+
+export type ProjectAttributes = {
+  id: string
+  proposal_id: string
+  title: string
+  status: ProjectStatus
+  about?: string
+  about_updated_by?: string
+  about_updated_at?: Date
+  updated_at?: Date
+  created_at: Date
+}
+
+export type Project = ProjectAttributes & {
+  personnel: PersonnelAttributes[]
+  links: ProjectLink[]
+  milestones: ProjectMilestone[]
+  author: string
+  coauthors: string[] | null
+  vesting_addresses: string[]
+  funding?: ProjectFunding
+}
+
+export default class ProjectModel extends Model<ProjectAttributes> {
+  static tableName = 'projects'
+  static withTimestamps = false
+  static primaryKey = 'id'
+
+  static async getProject(id: string) {
+    if (!isUUID(id || '')) {
+      throw new Error(`Invalid project id: "${id}"`)
+    }
+
+    const query = SQL`
+        SELECT
+            pr.*,
+            p.user as author,
+            p.vesting_addresses as vesting_addresses,
+            COALESCE(json_agg(DISTINCT to_jsonb(pe.*)) FILTER (WHERE pe.id IS NOT NULL), '[]')  as personnel,
+            COALESCE(json_agg(DISTINCT to_jsonb(mi.*)) FILTER (WHERE mi.id IS NOT NULL), '[]')  as milestones,
+            COALESCE(json_agg(DISTINCT to_jsonb(li.*)) FILTER (WHERE li.id IS NOT NULL), '[]')  as links,
+            COALESCE(array_agg(co.address) FILTER (WHERE co.address IS NOT NULL), '{}') AS coauthors
+        FROM ${table(ProjectModel)} pr
+                 JOIN ${table(ProposalModel)} p ON pr.proposal_id = p.id
+                 LEFT JOIN ${table(PersonnelModel)} pe ON pr.id = pe.project_id AND pe.deleted = false
+                 LEFT JOIN ${table(ProjectMilestoneModel)} mi ON pr.id = mi.project_id
+                 LEFT JOIN ${table(ProjectLinkModel)} li ON pr.id = li.project_id
+                 LEFT JOIN ${table(CoauthorModel)} co ON pr.proposal_id = co.proposal_id 
+                        AND co.status = ${CoauthorStatus.APPROVED}
+        WHERE pr.id = ${id}
+        GROUP BY pr.id, p.user, p.vesting_addresses;
+    `
+
+    const result = await this.namedQuery<Project>(`get_project`, query)
+    if (!result || result.length === 0) {
+      throw new Error(`Project not found: "${id}"`)
+    }
+
+    return result[0]
+  }
+
+  static async migrate(proposals: ProposalProject[]) {
+    const values = proposals.map(
+      ({ id, title, about, status, updated_at }) =>
+        SQL`(${crypto.randomUUID()}, ${id}, ${title}, ${about}, ${status}, ${new Date(updated_at)})`
+    )
+
+    const query = SQL`
+      INSERT INTO ${table(ProjectModel)} (id, proposal_id, title, about, status, created_at)
+      VALUES ${join(values, SQL`, `)}
+      RETURNING *;
+    `
+
+    return this.namedQuery<ProjectAttributes>(`create_multiple_projects`, query)
+  }
+
+  static async isAuthorOrCoauthor(user: string, projectId: string): Promise<boolean> {
+    if (!isUUID(projectId || '')) {
+      throw new Error(`Invalid project id: "${projectId}"`)
+    }
+    if (!isEthereumAddress(user)) {
+      throw new Error(`Invalid user: "${user}"`)
+    }
+
+    const query = SQL`
+      SELECT EXISTS (
+        SELECT 1
+        FROM ${table(ProjectModel)} pr
+        JOIN ${table(ProposalModel)} p ON pr.proposal_id = p.id
+        LEFT JOIN ${table(CoauthorModel)} co ON pr.proposal_id = co.proposal_id 
+              AND co.status = ${CoauthorStatus.APPROVED}
+        WHERE pr.id = ${projectId}
+          AND (p.user = ${user} OR co.address = ${user})
+      ) AS "exists"
+    `
+
+    const result = await this.namedQuery<{ exists: boolean }>(`is_author_or_coauthor`, query)
+    return result[0]?.exists || false
+  }
+}

src/back/models/ProjectLink.ts

@@ -0,0 +1,18 @@
+import { Model } from 'decentraland-gatsby/dist/entities/Database/model'
+
+export type ProjectLink = {
+  id: string
+  project_id: string
+  label: string
+  url: string
+  updated_by?: string
+  updated_at?: Date
+  created_by: string
+  created_at: Date
+}
+
+export default class ProjectLinkModel extends Model<ProjectLink> {
+  static tableName = 'project_links'
+  static withTimestamps = false
+  static primaryKey = 'id'
+}

src/back/models/ProjectMilestone.ts

@@ -0,0 +1,26 @@
+import { Model } from 'decentraland-gatsby/dist/entities/Database/model'
+
+export type ProjectMilestone = {
+  id: string
+  project_id: string
+  title: string
+  description: string
+  delivery_date: Date
+  status: ProjectMilestoneStatus
+  updated_by?: string
+  updated_at?: Date
+  created_by: string
+  created_at: Date
+}
+
+export enum ProjectMilestoneStatus {
+  Pending = 'pending',
+  InProgress = 'in_progress',
+  Done = 'done',
+}
+
+export default class ProjectMilestoneModel extends Model<ProjectMilestone> {
+  static tableName = 'project_milestones'
+  static withTimestamps = false
+  static primaryKey = 'id'
+}

src/back/models/ProjectMilestoneUpdate.ts

@@ -0,0 +1,16 @@
+import { Model } from 'decentraland-gatsby/dist/entities/Database/model'
+
+export type ProjectMilestoneUpdate = {
+  id: string
+  update_id: string
+  milestone_id: string
+  description: string
+  tasks: string[]
+  created_at: Date
+}
+
+export default class ProjectMilestoneUpdateModel extends Model<ProjectMilestoneUpdate> {
+  static tableName = 'project_milestone_updates'
+  static withTimestamps = false
+  static primaryKey = 'id'
+}

src/back/routes/budget.ts

@@ -8,7 +8,7 @@ import { Budget, BudgetWithContestants, CategoryBudget } from '../../entities/Bu
 import { QuarterBudgetAttributes } from '../../entities/QuarterBudget/types'
 import { toNewGrantCategory } from '../../entities/QuarterCategoryBudget/utils'
 import { BudgetService } from '../../services/BudgetService'
-import { validateProposalId } from '../utils/validations'
+import { validateId } from '../utils/validations'
 
 export default routes((route) => {
   const withAuth = auth()
@@ -48,6 +48,6 @@ async function getCurrentContestedBudget(): Promise<BudgetWithContestants> {
 }
 
 async function getBudgetWithContestants(req: Request<{ proposal: string }>): Promise<BudgetWithContestants> {
-  const id = validateProposalId(req.params.proposal)
+  const id = validateId(req.params.proposal)
   return await BudgetService.getBudgetWithContestants(id)
 }

src/back/routes/debug.ts

@@ -6,12 +6,14 @@ import { DEBUG_ADDRESSES } from '../../constants'
 import CacheService from '../../services/CacheService'
 import { ErrorService } from '../../services/ErrorService'
 import { giveAndRevokeLandOwnerBadges, giveTopVoterBadges, runQueuedAirdropJobs } from '../jobs/BadgeAirdrop'
+import { migrateProjects } from '../jobs/ProjectsMigration'
 import { validateDebugAddress } from '../utils/validations'
 
 const FUNCTIONS_MAP: { [key: string]: () => Promise<unknown> } = {
   runQueuedAirdropJobs,
   giveAndRevokeLandOwnerBadges,
   giveTopVoterBadges,
+  migrateProjects,
 }
 
 export default routes((router) => {

src/back/routes/events.ts

@@ -7,7 +7,7 @@ import { EventsService } from '../services/events'
 import {
   validateDebugAddress,
   validateEventTypesFilters,
-  validateProposalId,
+  validateId,
   validateRequiredString,
 } from '../utils/validations'
 
@@ -26,7 +26,7 @@ async function getLatestEvents(req: Request) {
 async function voted(req: WithAuth) {
   const user = req.auth!
 
-  validateProposalId(req.body.proposalId)
+  validateId(req.body.proposalId)
   validateRequiredString('proposalTitle', req.body.proposalTitle)
   validateRequiredString('choice', req.body.choice)
   return await EventsService.voted(req.body.proposalId, req.body.proposalTitle, req.body.choice, user)