feat(back): dashboard stats

backend/back/src/workflows/dto/workflow-summary.dto.ts

@@ -0,0 +1,20 @@
+import { ApiProperty } from "@nestjs/swagger";
+import { IsNumber } from "class-validator";
+
+export class WorkflowSummaryDto {
+	@ApiProperty()
+	@IsNumber()
+	workflowRuns!: number;
+
+	@ApiProperty()
+	@IsNumber()
+	workflowErrors!: number;
+
+	@ApiProperty()
+	@IsNumber()
+	workflows!: number;
+
+	@ApiProperty()
+	@IsNumber()
+	activeWorkflows!: number;
+}

backend/back/src/workflows/workflows.controller.ts

@@ -34,6 +34,7 @@ import {
 	PickType,
 } from "@nestjs/swagger";
 import Workflow from "./entities/workflow.entity";
+import { WorkflowSummaryDto } from "./dto/workflow-summary.dto";
 
 @ApiBearerAuth()
 @ApiTags("Workflows")
@@ -48,6 +49,15 @@ export class WorkflowsController {
 
 	constructor(private readonly workspacesService: WorkflowsService) {}
 
+	@ApiOkResponse({
+		description: "The workflows summary was successfully retrieved",
+		type: WorkflowSummaryDto,
+	})
+	@Get("summary")
+	async getWorkflowsSummary(@Req() { user: { id: ownerId } }: APIRequest) {
+		return await this.workspacesService.getWorkflowsSummary(ownerId);
+	}
+
 	@ApiOkResponse({
 		description: "The workflow was successfully created",
 		schema: {

backend/back/src/workflows/workflows.module.ts

@@ -10,10 +10,11 @@ import { JobsModule } from "../jobs/jobs.module";
 import { ConnectionsModule } from "../connections/connections.module";
 import { ServicesModule } from "../services/services.module";
 import { GrpcModule } from "../grpc/grpc.module";
+import ActivityLog from "../activity/entities/activity-log.entity";
 
 @Module({
 	imports: [
-		TypeOrmModule.forFeature([Workflow, WorkflowArea, Area, User]),
+		TypeOrmModule.forFeature([Workflow, WorkflowArea, Area, User, ActivityLog]),
 		forwardRef(() => GrpcModule),
 		forwardRef(() => JobsModule),
 		ConnectionsModule,

backend/back/src/workflows/workflows.service.ts

@@ -23,6 +23,8 @@ import { ServiceName, ServicesService } from "../services/services.service";
 import { OwnerJobParams, OwnerUniqueJobParams, UniqueJobParams } from "../types/jobParams";
 import { plainToInstance } from "class-transformer";
 import { GrpcService } from "../grpc/grpc.service";
+import ActivityLog from "../activity/entities/activity-log.entity";
+import { WorkflowSummaryDto } from "./dto/workflow-summary.dto";
 
 @Injectable()
 export class WorkflowsService {
@@ -35,6 +37,8 @@ export class WorkflowsService {
 		private readonly workflowAreaRepository: Repository<WorkflowArea>,
 		@InjectRepository(Area)
 		private readonly areaRepository: Repository<Area>,
+		@InjectRepository(ActivityLog)
+		private readonly activityRepository: Repository<ActivityLog>,
 		@Inject(forwardRef(() => JobsService))
 		private readonly jobsService: JobsService,
 		@Inject(forwardRef(() => GrpcService))
@@ -43,6 +47,26 @@ export class WorkflowsService {
 		private readonly servicesService: ServicesService,
 	) {}
 
+	async getWorkflowsSummary(ownerId: string): Promise<WorkflowSummaryDto> {
+		const workflowRuns = await this.activityRepository.count({
+			where: { type: "ran", workflow: { ownerId } },
+			relations: { workflow: true },
+		});
+		const workflowErrors = await this.activityRepository.count({
+			where: { type: "error", workflow: { ownerId } },
+			relations: { workflow: true },
+		});
+		const workflows = await this.workflowRepository.countBy({ ownerId });
+		const activeWorkflows = await this.workflowRepository.countBy({ ownerId, active: true });
+
+		return {
+			workflowRuns,
+			workflowErrors,
+			workflows,
+			activeWorkflows,
+		};
+	}
+
 	async getWorkflowByNameAndOwner(name: string, ownerId: string) {
 		return this.workflowRepository.findOneBy({
 			name,