External/portabase
1
0
Fork 0
mirror of https://github.com/Portabase/portabase.git synced 2026-07-14 11:16:13 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
Théo LAGACHE
2026-06-24 16:38:09 +02:00
parent 75dff0cc2c
commit 04c2bc8922
1 changed files with 147 additions and 149 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/features/channel/components/storages/channel.action.ts
+147 -149
View File
@@ -1,191 +1,189 @@
"use server"; "use server";
import {z} from "zod"; import { z } from "zod";
import {ServerActionResult} from "@/types/action-type"; import { ServerActionResult } from "@/types/action-type";
import * as drizzleDb from "@/db"; import * as drizzleDb from "@/db";
import {userAction} from "@/lib/safe-actions/actions"; import { userAction } from "@/lib/safe-actions/actions";
import {db} from "@/db"; import { db } from "@/db";
import {and, eq} from "drizzle-orm"; import { and, eq } from "drizzle-orm";
import {withUpdatedAt} from "@/db/utils"; import { withUpdatedAt } from "@/db/utils";
import { import { StorageChannelFormSchema } from "@/features/channel/schemas/channel-form.schema";
StorageChannelFormSchema import { StorageChannel } from "@/db/schema/12_storage-channel";
} from "@/features/channel/schemas/channel-form.schema";
import {StorageChannel} from "@/db/schema/12_storage-channel";
export const addStorageChannelAction = userAction
export const addStorageChannelAction = userAction.schema( .schema(
z.object({ z.object({
organizationId: z.string().optional(), organizationId: z.string().optional(),
data: StorageChannelFormSchema data: StorageChannelFormSchema,
}) }),
).action(async ({parsedInput}): Promise<ServerActionResult<StorageChannel>> => { )
const {organizationId, data} = parsedInput; .action(
async ({ parsedInput }): Promise<ServerActionResult<StorageChannel>> => {
const { organizationId, data } = parsedInput;
try { try {
const [channel] = await db const [channel] = await db
.insert(drizzleDb.schemas.storageChannel) .insert(drizzleDb.schemas.storageChannel)
.values({ .values({
provider: data.provider, provider: data.provider,
name: data.name, name: data.name,
config: data.config, config: data.config,
enabled: data.enabled ?? true, enabled: data.enabled ?? true,
organizationId: organizationId ?? null organizationId: organizationId ?? null,
}) })
.returning(); .returning();
if (organizationId) { if (organizationId) {
await db.insert(drizzleDb.schemas.organizationStorageChannel).values({ await db.insert(drizzleDb.schemas.organizationStorageChannel).values({
organizationId, organizationId,
storageChannelId: channel.id, storageChannelId: channel.id,
}); });
} }
return { return {
success: true, success: true,
value: { value: {
...channel, ...channel,
config: channel.config as JSON config: channel.config as JSON,
}, },
actionSuccess: { actionSuccess: {
message: "Storage channel has been successfully created.", message: "Storage channel has been successfully created.",
messageParams: {id: channel.id}, messageParams: { id: channel.id },
}, },
}; };
} catch (_error) { } catch (_error) {
const error = _error; const error = _error;
return { return {
success: false, success: false,
actionError: { actionError: {
message: "Failed to create storage channel.", message: "Failed to create storage channel.",
status: 500, status: 500,
cause: error instanceof Error ? error.message : "Unknown error", cause: error instanceof Error ? error.message : "Unknown error",
messageParams: {id: ""}, messageParams: { id: "" },
}, },
}; };
} }
}); },
);
export const removeStorageChannelAction = userAction.schema( export const removeStorageChannelAction = userAction
.schema(
z.object({ z.object({
organizationId: z.string().optional(), organizationId: z.string().optional(),
id: z.string(), id: z.string(),
}) }),
).action(async ({parsedInput}): Promise<ServerActionResult<StorageChannel>> => { )
const {organizationId, id} = parsedInput; .action(
async ({ parsedInput }): Promise<ServerActionResult<StorageChannel>> => {
try { const { organizationId, id } = parsedInput;
const existing = await db.query.storageChannel.findFirst({
where: eq(drizzleDb.schemas.storageChannel.id, id),
});
if (!existing) {
return {
success: false,
actionError: { message: "Storage channel not found.", status: 404, messageParams: { id } },
};
}
if (existing.organizationId === null) {
return {
success: false,
actionError: { message: "System storage channels cannot be deleted.", status: 403, messageParams: { id } },
};
}
try {
if (organizationId) { if (organizationId) {
await db await db
.delete(drizzleDb.schemas.organizationStorageChannel) .delete(drizzleDb.schemas.organizationStorageChannel)
.where( .where(
and( and(
eq(drizzleDb.schemas.organizationStorageChannel.organizationId, organizationId), eq(
eq(drizzleDb.schemas.organizationStorageChannel.storageChannelId, id) drizzleDb.schemas.organizationStorageChannel.organizationId,
) organizationId,
); ),
eq(
drizzleDb.schemas.organizationStorageChannel.storageChannelId,
id,
),
),
);
} }
const [deletedChannel] = await db const [deletedChannel] = await db
.delete(drizzleDb.schemas.storageChannel) .delete(drizzleDb.schemas.storageChannel)
.where(eq(drizzleDb.schemas.storageChannel.id, id)) .where(eq(drizzleDb.schemas.storageChannel.id, id))
.returning(); .returning();
if (!deletedChannel) { if (!deletedChannel) {
return { return {
success: false, success: false,
actionError: { actionError: {
message: "Storage channel not found.", message: "Storage channel not found.",
status: 404, status: 404,
messageParams: {id: id}, messageParams: { id: id },
}, },
}; };
} }
return { return {
success: true, success: true,
value: { value: {
...deletedChannel, ...deletedChannel,
config: deletedChannel.config as JSON config: deletedChannel.config as JSON,
}, },
actionSuccess: { actionSuccess: {
message: "Storage channel has been successfully removed.", message: "Storage channel has been successfully removed.",
messageParams: {id: id}, messageParams: { id: id },
}, },
}; };
} catch (_error) { } catch (_error) {
const error = _error; const error = _error;
return { return {
success: false, success: false,
actionError: { actionError: {
message: "Failed to remove storage channel.", message: "Failed to remove storage channel.",
status: 500, status: 500,
cause: error instanceof Error ? error.message : "Unknown error", cause: error instanceof Error ? error.message : "Unknown error",
messageParams: {id: id}, messageParams: { id: id },
}, },
}; };
} }
}); },
);
export const updateStorageChannelAction = userAction
export const updateStorageChannelAction = userAction.schema( .schema(
z.object({ z.object({
id: z.string(), id: z.string(),
data: StorageChannelFormSchema data: StorageChannelFormSchema,
}) }),
).action(async ({parsedInput}): Promise<ServerActionResult<StorageChannel>> => { )
const {id, data} = parsedInput; .action(
async ({ parsedInput }): Promise<ServerActionResult<StorageChannel>> => {
const { id, data } = parsedInput;
try { try {
const [channel] = await db const [channel] = await db
.update(drizzleDb.schemas.storageChannel) .update(drizzleDb.schemas.storageChannel)
.set(withUpdatedAt({ .set(
provider: data.provider, withUpdatedAt({
name: data.name, provider: data.provider,
config: data.config, name: data.name,
enabled: data.enabled ?? true, config: data.config,
})) enabled: data.enabled ?? true,
.where(eq(drizzleDb.schemas.storageChannel.id, id)) }),
.returning(); )
.where(eq(drizzleDb.schemas.storageChannel.id, id))
.returning();
return { return {
success: true, success: true,
value: { value: {
...channel, ...channel,
config: channel.config as JSON config: channel.config as JSON,
}, },
actionSuccess: { actionSuccess: {
message: `Storage channel "${channel.name}" has been successfully updated.`, message: `Storage channel "${channel.name}" has been successfully updated.`,
messageParams: {id: channel.id}, messageParams: { id: channel.id },
}, },
}; };
} catch (_error) { } catch (_error) {
const error = _error; const error = _error;
return { return {
success: false, success: false,
actionError: { actionError: {
message: "Failed to update storage channel.", message: "Failed to update storage channel.",
status: 500, status: 500,
cause: error instanceof Error ? error.message : "Unknown error", cause: error instanceof Error ? error.message : "Unknown error",
messageParams: {id: ""}, messageParams: { id: "" },
}, },
}; };
} }
}); },
);