Method create

backend/src/workflows/workflows.service.ts:270–310

(dto: WorkflowGraphDto, auth?: AuthContext | null)

  }

  async create(dto: WorkflowGraphDto, auth?: AuthContext | null): Promise<ServiceWorkflowResponse> {
    const input = this.parse(dto);

    // Validate workflow graph before saving (including port connections)
    try {
      compileWorkflowGraph(input);
    } catch (error) {
      if (error instanceof Error) {
        throw new BadRequestException(`Workflow validation failed: ${error.message}`);
      }
      throw error;
    }

    this.ensureOrganizationAdmin(auth);
    const organizationId = this.requireOrganizationId(auth);
    const record = await this.repository.create(input, { organizationId });
    let version: WorkflowVersionRecord;
    try {
      version = await this.versionRepository.create({
        workflowId: record.id,
        graph: input,
        organizationId,
      });
      if (auth?.userId) {
        await this.roleRepository.upsert({
          workflowId: record.id,
          userId: auth.userId,
          role: 'ADMIN',
          organizationId,
        });
      }
    } catch (error) {
      await this.repository.delete(record.id, { organizationId });
      throw error;
    }
    const response = this.buildWorkflowResponse(record, version);
    this.logger.log(
      `Created workflow ${response.id} version ${version.version} (nodes=${input.nodes.length}, edges=${input.edges.length})`,
    );
    return response;
  }

  async update(
    id: string,