feat(ask): feature ask implemnetation

apps/web-api/prisma/migrations/20250124072138_ask/migration.sql

@@ -0,0 +1,23 @@
+-- CreateTable
+CREATE TABLE "Ask" (
+    "id" SERIAL NOT NULL,
+    "uid" TEXT NOT NULL,
+    "title" TEXT NOT NULL,
+    "description" TEXT NOT NULL,
+    "tags" TEXT[],
+    "teamUid" TEXT,
+    "projectUid" TEXT,
+    "createdAt" TIMESTAMP(3) NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    "updatedAt" TIMESTAMP(3) NOT NULL,
+
+    CONSTRAINT "Ask_pkey" PRIMARY KEY ("id")
+);
+
+-- CreateIndex
+CREATE UNIQUE INDEX "Ask_uid_key" ON "Ask"("uid");
+
+-- AddForeignKey
+ALTER TABLE "Ask" ADD CONSTRAINT "Ask_teamUid_fkey" FOREIGN KEY ("teamUid") REFERENCES "Team"("uid") ON DELETE SET NULL ON UPDATE CASCADE;
+
+-- AddForeignKey
+ALTER TABLE "Ask" ADD CONSTRAINT "Ask_projectUid_fkey" FOREIGN KEY ("projectUid") REFERENCES "Project"("uid") ON DELETE SET NULL ON UPDATE CASCADE;

apps/web-api/prisma/schema.prisma

@@ -49,7 +49,22 @@ model Team {
   teamFocusAreas               TeamFocusArea[]
   teamFocusAreasVersionHistory TeamFocusAreaVersionHistory[]
   relatedQuestions             DiscoveryQuestion[]           @relation("TeamRelatedDiscoveryQuestions")
+  asks                         Ask[]
 }
+model Ask {
+  id                           Int                           @id @default(autoincrement())
+  uid                          String                        @unique @default(cuid())
+  title                        String
+  description                  String
+  tags                         String[]
+  team                         Team?                          @relation(fields: [teamUid], references: [uid])
+  teamUid                      String?
+  project                      Project?                        @relation(fields: [projectUid], references: [uid])
+  projectUid                   String?
+  createdAt                    DateTime @default(now())
+  updatedAt                    DateTime @updatedAt
+}
+
 
 model Member {
   id                           Int                           @id @default(autoincrement())
@@ -354,6 +369,7 @@ model Project {
   projectFocusAreas  ProjectFocusArea[]
   contributions      ProjectContribution[]
   relatedQuestions   DiscoveryQuestion[]   @relation("ProjectRelatedDiscoveryQuestions")
+  asks               Ask[]
 }
 
 model PLEventLocation {

apps/web-api/src/projects/projects.controller.ts

@@ -23,8 +23,26 @@ export class ProjectsController {
 
   @Api(server.route.getProjectFilters)
   @NoCache()
-  async getProjectFilters() {
-    return await this.projectsService.getProjectFilters();
+  async getProjectFilters(@Req() req) {
+    // return await this.projectsService.getProjectFilters();
+    const queryableFields = prismaQueryableFieldsFromZod(
+      ResponseProjectWithRelationsSchema
+    );
+    const builder = new PrismaQueryBuilder(queryableFields);
+    const builtQuery = builder.build(req.query);
+    const { focusAreas }: any = req.query;
+    builtQuery.where = {
+      AND: [
+        {
+          isDeleted: false,
+        },
+        builtQuery.where ? builtQuery.where : {},
+        this.projectsService.buildFocusAreaFilters(focusAreas),
+        this.projectsService.buildRecentProjectsFilter(req.query),
+        this.projectsService.buildAskTagFilter(req.query)
+      ]
+    }
+    return await this.projectsService.getProjectFilters(builtQuery);
   }
 
   @Api(server.route.createProject)
@@ -60,7 +78,8 @@ export class ProjectsController {
       AND: [
         builtQuery.where ? builtQuery.where : {},
         this.projectsService.buildFocusAreaFilters(focusAreas),
-        this.projectsService.buildRecentProjectsFilter(req.query)
+        this.projectsService.buildRecentProjectsFilter(req.query),
+        this.projectsService.buildAskTagFilter(req.query)
       ]
     }
     return this.projectsService.getProjects(builtQuery);
@@ -89,4 +108,10 @@ export class ProjectsController {
     return this.projectsService.removeProjectByUid(uid, request.userEmail);
   }
 
+  @Api(server.route.patchAskProject)
+  @UseGuards(UserTokenValidation)
+  async addEditAsk(@Param('uid') projectUid, @Body() body, @Req() req) {
+    return await this.projectsService.addEditProjectAsk(projectUid,req.userEmail,body);
+  }
+
 }

apps/web-api/src/projects/projects.service.ts

@@ -1,3 +1,4 @@
+/* eslint-disable prettier/prettier */
 import { BadRequestException, ConflictException, ForbiddenException, Injectable, NotFoundException } from '@nestjs/common';
 import { LogService } from '../shared/log.service';
 import { PrismaService } from '../shared/prisma.service';
@@ -147,6 +148,15 @@ export class ProjectsService {
                 }
               }
             }
+          },
+          asks: {
+            select: {
+              uid: true,
+              title: true,
+              description: true,
+              tags: true,
+              projectUid: true
+            }
           }
         }
       });
@@ -387,12 +397,24 @@ export class ProjectsService {
     return {};
   }
 
+  buildAskTagFilter(queryParams){
+    const { askTags } = queryParams;
+    let tagFilter={}
+    if(askTags){
+      const tags = askTags.split(',')
+      tagFilter={
+        asks: { some: { tags: { hasSome: tags }, }, },
+      };
+    }
+      return tagFilter;
+    }
+
   /**
    * Fetches team names that maintain atleast a single project.
    * 
    * @returns Set of team names.
    */
-  async getProjectFilters() {
+  async getProjectFilters(queryParams) {
     const maintainingTeams = await this.prisma.team.findMany({
       where: {
         maintainingProjects: {
@@ -409,6 +431,72 @@ export class ProjectsService {
         }
       }
     })
-    return { maintainedBy: maintainingTeams.map((team) => ({ uid: team.uid, name: team.name, logo: team.logo?.url })) };
+
+
+    const askTags = await this.prisma.ask.findMany({
+      where: {
+        project: queryParams.where,
+      },
+      select: {
+        tags: true,
+      },
+    })
+    // Flatten the tags and calculate counts
+    const tagCounts = askTags
+    .flatMap(item => item.tags) // Flatten the tags array
+    .reduce((acc, tag) => {
+        acc[tag] = (acc[tag] || 0) + 1; // Count occurrences
+        return acc;
+    }, {});
+    return {
+      askTags: Object.entries(tagCounts).map(([tag, count]) => ({ tag, count }))
+    }
+    // return { maintainedBy: maintainingTeams.map((team) => ({ uid: team.uid, name: team.name, logo: team.logo?.url })) };
+  }
+
+
+  async addEditProjectAsk(projectUid, requestorEmail, data){
+    let res;
+    try{
+      //checking if the member has edit access
+      const member: any = await this.memberService.findMemberByEmail(requestorEmail);
+      const existingData: any = await this.getProjectByUid(projectUid);
+      const contributingTeamsUid = existingData?.contributingTeams?.map(team => team.uid) || [];
+      await this.isMemberAllowedToEdit(
+        member,
+        [existingData?.maintainingTeamUid, ...contributingTeamsUid],
+        existingData
+      );
+
+      if (data.uid) {
+        if (data.isDeleted) {
+          //deleting asks
+          res = await this.prisma.ask.delete({
+            where: { uid: data.uid },
+          });
+        } else {
+          //updating asks
+          res = await this.prisma.ask.update({
+            where: { uid: data.uid },
+            data: {
+              ...data,
+            },
+          });
+        }
+      }else{
+        //creating asks
+        res = await this.prisma.ask.create({
+          data: {
+            ...data,
+            projectUid,
+          },
+        });
+      }
+      await this.cacheService.reset({ service: 'projects'});
+      return res;
+    }catch(err){
+      console.error(err);
+      throw err;
+    }
   }
 }

apps/web-api/src/teams/teams.controller.ts

@@ -1,3 +1,4 @@
+/* eslint-disable prettier/prettier */
 import { Controller, Req, UseGuards, Body, Param, UsePipes } from '@nestjs/common';
 import { ApiNotFoundResponse, ApiParam } from '@nestjs/swagger';
 import { Api, ApiDecorator, initNestServer } from '@ts-rest/nest';
@@ -27,6 +28,7 @@ export class TeamsController {
 
   @Api(server.route.teamFilters)
   @ApiQueryFromZod(TeamQueryParams)
+  @NoCache()
   async getTeamFilters(@Req() request: Request) {
     const queryableFields = prismaQueryableFieldsFromZod(
       ResponseTeamWithRelationsSchema
@@ -42,7 +44,8 @@ export class TeamsController {
         builtQuery.where ? builtQuery.where : {},
         this.teamsService.buildFocusAreaFilters(focusAreas),
         this.teamsService.buildRecentTeamsFilter(request.query),
-        this.teamsService.buildParticipationTypeFilter(request.query)
+        this.teamsService.buildParticipationTypeFilter(request.query),
+        this.teamsService.buildAskTagFilter(request.query)
       ]
     }
     return await this.teamsService.getTeamFilters(builtQuery);
@@ -66,7 +69,8 @@ export class TeamsController {
         builtQuery.where ? builtQuery.where : {},
         this.teamsService.buildFocusAreaFilters(focusAreas),
         this.teamsService.buildRecentTeamsFilter(request.query),
-        this.teamsService.buildParticipationTypeFilter(request.query)
+        this.teamsService.buildParticipationTypeFilter(request.query),
+        this.teamsService.buildAskTagFilter(request.query)
       ],
     };
     // Check for the office hours blank when OH not null is passed
@@ -109,4 +113,11 @@ export class TeamsController {
     return await this.teamsService.updateTeamFromParticipantsRequest(teamUid, body, req.userEmail);
   }
 
+  @Api(server.route.patchTeam)
+  @UseGuards(UserTokenValidation)
+  async addAsk(@Param('uid') teamUid, @Body() body, @Req() req) {
+    await this.teamsService.validateRequestor(req.userEmail, teamUid);
+    const res = await this.teamsService.addEditTeamAsk(teamUid,body.teamName,req.userEmail,body.ask);
+    return res;
+  }
 }

apps/web-api/src/teams/teams.module.ts

@@ -6,7 +6,11 @@ import { ParticipantsRequestModule } from '../participants-request/participants-
 import { MembersModule } from '../members/members.module';
 
 @Module({
-  imports: [forwardRef(() => ParticipantsRequestModule), forwardRef(() => MembersModule), SharedModule],
+  imports: [
+    forwardRef(() => ParticipantsRequestModule),
+    forwardRef(() => MembersModule),
+    SharedModule,
+  ],
   controllers: [TeamsController],
   providers: [TeamsService],
   exports: [TeamsService]