663bc77afe
Bundles in-flight ECHODO work with the Coolify deployment configuration: App - New routes: ai, forms, planner, settings (templates/types), teams, doc detail, whiteboard detail - New components: app shell rework (icon-rail, top-header), forms builder/renderer/responses, types manager, objects creation dialog, card primitive, form + overview views - New tRPC routers: favorites, forms, types, workspaces; updates to health and objects routers - Markdown backlog sync (packages/database) + cursor-sync schema/migrations - Schema additions: forms, types, favorites, markdown_backlog, cursor_sync - Initial Drizzle migrations checked in Deployment - docker/docker-compose.coolify.yml: drops bundled Postgres/Redis (uses CT 102 shared services), removes host port mappings, adds Coolify SERVICE_FQDN_* magic vars for web + collab - .env.example rewritten as the full ECHODO/Coolify variable manifest - NextAuth gains an Authentik OIDC provider (gated on env presence) - Root layout injects Umami tracking script when configured; metadata title flipped to ECHODO Security - .gitignore expanded to exclude AGENT-DEPLOY.md, .env.*, secrets/, credentials.*, *.key, *.crt, *.pem, ssh keys Made-with: Cursor
59 lines
1.7 KiB
TypeScript
59 lines
1.7 KiB
TypeScript
import { TRPCError } from "@trpc/server";
|
|
import { z } from "zod";
|
|
import { and, eq } from "drizzle-orm";
|
|
import { objects, workspaceMembers, users } from "@tasks/database/schema";
|
|
import { router, protectedProcedure } from "@/server/trpc";
|
|
|
|
export const workspacesRouter = router({
|
|
getById: protectedProcedure
|
|
.input(z.object({ id: z.string().uuid() }))
|
|
.query(async ({ ctx, input }) => {
|
|
const [row] = await ctx.db
|
|
.select({
|
|
id: objects.id,
|
|
title: objects.title,
|
|
type: objects.type,
|
|
icon: objects.icon,
|
|
})
|
|
.from(objects)
|
|
.where(and(eq(objects.id, input.id), eq(objects.type, "workspace")))
|
|
.limit(1);
|
|
|
|
if (!row) {
|
|
throw new TRPCError({ code: "NOT_FOUND", message: "Workspace not found" });
|
|
}
|
|
|
|
return row;
|
|
}),
|
|
|
|
listForUser: protectedProcedure.query(async ({ ctx }) => {
|
|
const userId = ctx.session.user.id;
|
|
|
|
return ctx.db
|
|
.select({
|
|
id: objects.id,
|
|
title: objects.title,
|
|
icon: objects.icon,
|
|
role: workspaceMembers.role,
|
|
})
|
|
.from(workspaceMembers)
|
|
.innerJoin(objects, eq(workspaceMembers.workspaceId, objects.id))
|
|
.where(eq(workspaceMembers.userId, userId));
|
|
}),
|
|
|
|
listMembers: protectedProcedure
|
|
.input(z.object({ workspaceId: z.string().uuid() }))
|
|
.query(async ({ ctx, input }) => {
|
|
return ctx.db
|
|
.select({
|
|
id: users.id,
|
|
name: users.name,
|
|
email: users.email,
|
|
avatarUrl: users.avatarUrl,
|
|
role: workspaceMembers.role,
|
|
})
|
|
.from(workspaceMembers)
|
|
.innerJoin(users, eq(workspaceMembers.userId, users.id))
|
|
.where(eq(workspaceMembers.workspaceId, input.workspaceId));
|
|
}),
|
|
});
|