Merge pull request #908 from sparrowapp-dev/release/2.35.0

Release/2.35.0 to Dev [Test flow test data Implementation]

Author: itsmdasifraza

package.json

@@ -1,6 +1,6 @@
 {
   "name": "project-sparrow-api",
-  "version": "2.34.0",
+  "version": "2.35.0",
   "description": "Backend APIs for Project Sparrow.",
   "author": "techdome",
   "license": "",

src/modules/common/enum/testflow.enum.ts

@@ -37,12 +37,21 @@ export interface EmailData {
   scheduleRunPassedCount: number;
   scheduleRunFailedCount: number;
   scheduleRunTotalRequest: number;
-  scheduleRunPassPercentage: string; 
+  scheduleRunPassPercentage: string;
   scheduleTotalTime: string | number;
   scheduleRunEnvName: string;
   isSuccess: boolean;
   isFailed: boolean;
   isPartial: boolean;
+  testflowDataSummary?: DatasetSummaryItem[];
+}
+
+export interface DatasetSummaryItem {
+  datasetName: string;
+  requestCount: number;
+  passedCount: number;
+  failedCount: number;
+  duration: string;
 }
 
 export interface OnceConfig {

src/modules/common/models/testflow.model.ts

@@ -21,23 +21,26 @@ import {
 import { Auth, KeyValue } from "./collection.rxdb.model";
 import { AuthModeEnum, BodyModeEnum } from "./collection.model";
 import { HTTPMethods } from "fastify";
-import { DayOfWeek, NotificationReceiveType, RequestDataTypeEnum, RunCycleEnum,  } from "../enum/testflow.enum";
+import {
+  DayOfWeek,
+  NotificationReceiveType,
+  RequestDataTypeEnum,
+  RunCycleEnum,
+} from "../enum/testflow.enum";
 
 export class SparrowRequestBody {
   raw?: string;
   urlencoded?: KeyValue[];
   formdata?: FormData;
 }
 
-
 export class FormDataKeyValue {
   key: string;
   value: string | unknown;
   checked: boolean;
   type: "text" | "file";
 }
 
-
 interface FormData {
   text: FormDataKeyValue[];
 }
@@ -227,6 +230,78 @@ export class TestflowNodes {
   data?: NodeData;
 }
 
+// Main TestflowDataSet class
+export class TestflowDataSet {
+  @IsArray()
+  @IsNotEmpty()
+  dataSet: Record<string, string | number | boolean | null>[];
+}
+
+export enum FormatType {
+  JSON = "JSON",
+  CSV = "CSV",
+}
+
+export class TestflowDataSetItem {
+  @IsString()
+  @ApiProperty({ required: true, example: "uuid" })
+  id: string;
+
+  @IsString()
+  @ApiProperty({ required: true, example: "testflow-dataset-name" })
+  @IsNotEmpty()
+  name: string;
+
+  @ValidateNested()
+  @Type(() => TestflowDataSet)
+  item: TestflowDataSet;
+
+  @IsString()
+  @IsNotEmpty()
+  formatType: FormatType;
+
+  @IsString()
+  @IsNotEmpty()
+  fileSize: string;
+
+  @IsDate()
+  @IsOptional()
+  createdAt?: Date;
+
+  @IsDate()
+  @IsOptional()
+  updatedAt?: Date;
+
+  @IsString()
+  @IsOptional()
+  createdBy?: string;
+
+  @IsString()
+  @IsOptional()
+  updatedBy?: string;
+}
+
+export class TestflowDataSetItemDto {
+  @IsArray()
+  @IsNotEmpty()
+  dataSet: Record<string, string | number | boolean | null>[];
+}
+
+export class TestflowDataSetDto {
+  @ValidateNested()
+  @Type(() => TestflowDataSetItemDto)
+  item: TestflowDataSetItemDto;
+
+  @IsString()
+  @IsNotEmpty()
+  formatType: FormatType;
+
+  @IsString()
+  @IsOptional()
+  @ApiProperty({ required: true, example: "testflow-dataset-name" })
+  name: string;
+}
+
 /**
  * Represents a Testflow, containing nodes and edges.
  */
@@ -257,6 +332,12 @@ export class Testflow {
   @IsOptional()
   schedules?: TestflowSchedular[];
 
+  @IsArray()
+  @Type(() => TestflowDataSetItem)
+  @ValidateNested({ each: true })
+  @IsOptional()
+  datasets?: TestflowDataSetItem[];
+
   @IsDate()
   @IsOptional()
   createdAt?: Date;
@@ -363,7 +444,7 @@ export class TestFlowSchedularRunHistory {
 
   @IsArray()
   @IsOptional()
-  responses?:TestflowSchedularHistoryResponse[];
+  responses?: TestflowSchedularHistoryResponse[];
 
   @IsArray()
   @Type(() => TestflowEdges)
@@ -406,6 +487,79 @@ export class TestFlowSchedularRunHistory {
   updatedBy?: string;
 }
 
+export class TestflowSchedularDataSetHistory {
+  @IsString()
+  @ApiProperty({ required: true, example: "uuid" })
+  id: string;
+
+  @IsArray()
+  @Type(() => TestflowDataSetRunHistoryRequest)
+  @ValidateNested({ each: true })
+  @IsOptional()
+  schedularDataRunHistory?: TestflowDataSetRunHistoryRequest[];
+
+  @IsArray()
+  @Type(() => TestflowEdges)
+  @ValidateNested({ each: true })
+  @IsOptional()
+  edges?: TestflowEdges[];
+
+  @IsArray()
+  @Type(() => TestflowNodes)
+  @ValidateNested({ each: true })
+  @IsOptional()
+  nodes?: TestflowNodes[];
+
+  @IsBoolean()
+  isScheduled: boolean;
+
+  @IsString()
+  @IsNotEmpty()
+  status: string;
+
+  @IsDate()
+  @IsOptional()
+  createdAt?: Date;
+
+  @IsDate()
+  @IsOptional()
+  updatedAt?: Date;
+
+  @IsString()
+  @IsOptional()
+  createdBy?: string;
+
+  @IsString()
+  @IsOptional()
+  updatedBy?: string;
+}
+
+export class TestflowDataSetRunHistoryRequest {
+  @IsString()
+  @IsNotEmpty()
+  failedRequests: number;
+
+  @IsArray()
+  @IsOptional()
+  requests?: TestflowSchedularHistoryRequest[];
+
+  @IsArray()
+  @IsOptional()
+  responses?: TestflowSchedularHistoryResponse[];
+
+  @IsString()
+  @IsNotEmpty()
+  status: string;
+
+  @IsNumber()
+  @IsNotEmpty()
+  successRequests: number;
+
+  @IsString()
+  @IsNotEmpty()
+  totalTime: string;
+}
+
 export class NotificationDto {
   @ApiProperty({
     required: false,
@@ -429,7 +583,7 @@ export class RunConfigurationDto {
     required: true,
     enum: RunCycleEnum,
     example: RunCycleEnum.DAILY,
-    description: "Type of run cycle"
+    description: "Type of run cycle",
   })
   @IsEnum(RunCycleEnum)
   runCycle: RunCycleEnum;
@@ -438,7 +592,8 @@ export class RunConfigurationDto {
   @ApiProperty({
     required: false,
     example: "2025-12-25T15:30:00.000Z",
-    description: "ISO date string for one-time execution (required for ONCE type)"
+    description:
+      "ISO date string for one-time execution (required for ONCE type)",
   })
   @IsISO8601()
   @IsOptional()
@@ -450,7 +605,7 @@ export class RunConfigurationDto {
     example: 2,
     minimum: 1,
     maximum: 24,
-    description: "Interval in hours (required for HOURLY type)"
+    description: "Interval in hours (required for HOURLY type)",
   })
   @IsInt()
   @Min(1)
@@ -462,8 +617,9 @@ export class RunConfigurationDto {
   @ApiProperty({
     required: false,
     example: [1, 3, 5], // Monday, Wednesday, Friday
-    description: "Array of days (0=Sunday, 1=Monday, ..., 6=Saturday) - required for WEEKLY type",
-    type: [Number]
+    description:
+      "Array of days (0=Sunday, 1=Monday, ..., 6=Saturday) - required for WEEKLY type",
+    type: [Number],
   })
   @IsArray()
   @IsInt({ each: true })
@@ -477,12 +633,13 @@ export class RunConfigurationDto {
   @ApiProperty({
     required: false,
     example: "14:30",
-    description: "Time in HH:mm format - REQUIRED for DAILY (runs daily at this time), REQUIRED for WEEKLY (runs on selected days at this time), OPTIONAL for HOURLY (start time)"
+    description:
+      "Time in HH:mm format - REQUIRED for DAILY (runs daily at this time), REQUIRED for WEEKLY (runs on selected days at this time), OPTIONAL for HOURLY (start time)",
   })
   @IsString()
   @IsOptional()
   @Transform(({ value }) => {
-    if (typeof value === 'string' && /^\d{2}:\d{2}$/.test(value)) {
+    if (typeof value === "string" && /^\d{2}:\d{2}$/.test(value)) {
       return value;
     }
     return value;
@@ -529,7 +686,15 @@ export class TestflowSchedular {
   @IsBoolean()
   @ApiProperty({ required: true, example: true })
   @IsOptional()
-  isActive:boolean;
+  isActive: boolean;
+
+  @IsString()
+  @IsOptional()
+  testflowDataSetId?: string;
+
+  @IsString()
+  @IsOptional()
+  testflowDataSetName?: string;
 
   @ApiProperty({
     required: false,
@@ -560,14 +725,20 @@ export class TestflowSchedular {
   @IsString()
   @ApiProperty({ required: true, example: "test" })
   @IsOptional()
-  schedularName?:string;
+  schedularName?: string;
 
   @IsArray()
   @Type(() => TestFlowSchedularRunHistory)
   @ValidateNested({ each: true })
   @IsOptional()
   schedularRunHistory?: TestFlowSchedularRunHistory[];
 
+  @IsArray()
+  @Type(() => TestflowSchedularDataSetHistory)
+  @ValidateNested({ each: true })
+  @IsOptional()
+  schedularDataSetHistory?: TestflowSchedularDataSetHistory[];
+
   @IsDate()
   @IsOptional()
   createdAt?: Date;
@@ -584,3 +755,10 @@ export class TestflowSchedular {
   @IsOptional()
   updatedBy?: string;
 }
+
+export class RunScheduleTestDataSetDto {
+  @IsString()
+  @ApiProperty({ required: true, example: "uuid" })
+  @IsOptional()
+  testflowDataSetId?: string;
+}