apunkt/rowboat
1
0
Fork 0
mirror of https://github.com/rowboatlabs/rowboat.git synced 2026-04-30 19:06:23 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

use project checks before loading workflow

Browse source
This commit is contained in:
Ramnique Singh 2025-08-18 21:40:42 +05:30
parent cc4d5cdff5
commit 45e1c13946
2 changed files with 28 additions and 12 deletions
Download patch file Download diff file Expand all files Collapse all files

11
apps/rowboat/app/projects/[projectId]/workflow/error.tsx Normal file
View file

@ -0,0 +1,11 @@
"use client";
import { Alert } from "@heroui/react";
export default function Error(props: { error: Error }) {
return <Alert
color="danger"
title="Error loading workflow"
>
There was an error loading the workflow: {props.error.message}
</Alert>;
}

29
apps/rowboat/app/projects/[projectId]/workflow/page.tsx
View file

@ -4,14 +4,15 @@ import { USE_RAG, USE_RAG_UPLOADS, USE_RAG_S3_UPLOADS, USE_RAG_SCRAPING, USE_BIL
import { notFound } from "next/navigation";
import { requireActiveBillingSubscription } from '@/app/lib/billing';
import { container } from "@/di/container";
import { IProjectsRepository } from "@/src/application/repositories/projects.repository.interface";
import { IDataSourcesRepository } from "@/src/application/repositories/data-sources.repository.interface";
import { getEligibleModels } from "@/app/lib/billing";
import { ModelsResponse } from "@/app/lib/types/billing_types";
import { requireAuth } from "@/app/lib/auth";
import { IFetchProjectController } from "@/src/interface-adapters/controllers/projects/fetch-project.controller";
import { IListDataSourcesController } from "@/src/interface-adapters/controllers/data-sources/list-data-sources.controller";
import { z } from "zod";
const projectsRepository = container.resolve<IProjectsRepository>('projectsRepository');
const dataSourceRepository = container.resolve<IDataSourcesRepository>('dataSourcesRepository');
const fetchProjectController = container.resolve<IFetchProjectController>('fetchProjectController');
const listDataSourcesController = container.resolve<IListDataSourcesController>('listDataSourcesController');
const DEFAULT_MODEL = process.env.PROVIDER_DEFAULT_MODEL || "gpt-4.1";
@ -25,20 +26,24 @@ export default async function Page(
}
) {
const params = await props.params;
const user = await requireAuth();
const customer = await requireActiveBillingSubscription();
console.log('->>> workflow page being rendered');
const project = await projectsRepository.fetch(params.projectId);
const project = await fetchProjectController.execute({
caller: "user",
userId: user._id,
projectId: params.projectId,
});
if (!project) {
notFound();
}
const sources = [];
let cursor = undefined;
do {
const result = await dataSourceRepository.list(project.id, undefined, cursor);
sources.push(...result.items);
cursor = result.nextCursor;
} while (cursor);
const sources = await listDataSourcesController.execute({
caller: "user",
userId: user._id,
projectId: params.projectId,
});
let eligibleModels: z.infer<typeof ModelsResponse> | "*" = '*';
if (USE_BILLING) {