Channel utility methods in entity
This commit is contained in:
parent
1c897af1be
commit
9400fc8fb8
@ -4,7 +4,6 @@ import { HTTPError } from "lambert-server";
|
|||||||
import { ChannelModifySchema } from "../../../schema/Channel";
|
import { ChannelModifySchema } from "../../../schema/Channel";
|
||||||
|
|
||||||
import { check } from "../../../util/instanceOf";
|
import { check } from "../../../util/instanceOf";
|
||||||
import { createChannel } from "../../../util/Channel";
|
|
||||||
const router = Router();
|
const router = Router();
|
||||||
|
|
||||||
router.get("/", async (req: Request, res: Response) => {
|
router.get("/", async (req: Request, res: Response) => {
|
||||||
@ -22,7 +21,7 @@ router.post("/", check(ChannelModifySchema), async (req: Request, res: Response)
|
|||||||
const { guild_id } = req.params;
|
const { guild_id } = req.params;
|
||||||
const body = req.body as ChannelModifySchema;
|
const body = req.body as ChannelModifySchema;
|
||||||
|
|
||||||
const channel = await createChannel({ ...body, guild_id }, req.user_id);
|
const channel = await Channel.createChannel({ ...body, guild_id }, req.user_id);
|
||||||
|
|
||||||
res.status(201).json(channel);
|
res.status(201).json(channel);
|
||||||
});
|
});
|
||||||
|
@ -1,52 +0,0 @@
|
|||||||
import { ChannelCreateEvent, Channel, ChannelType, emitEvent, getPermission, Snowflake } from "@fosscord/util";
|
|
||||||
import { HTTPError } from "lambert-server";
|
|
||||||
|
|
||||||
// TODO: DM channel
|
|
||||||
export async function createChannel(
|
|
||||||
channel: Partial<Channel>,
|
|
||||||
user_id: string = "0",
|
|
||||||
opts?: {
|
|
||||||
keepId?: boolean;
|
|
||||||
skipExistsCheck?: boolean;
|
|
||||||
}
|
|
||||||
) {
|
|
||||||
// Always check if user has permission first
|
|
||||||
const permissions = await getPermission(user_id, channel.guild_id);
|
|
||||||
permissions.hasThrow("MANAGE_CHANNELS");
|
|
||||||
|
|
||||||
switch (channel.type) {
|
|
||||||
case ChannelType.GUILD_TEXT:
|
|
||||||
case ChannelType.GUILD_VOICE:
|
|
||||||
if (channel.parent_id && !opts?.skipExistsCheck) {
|
|
||||||
const exists = await Channel.findOneOrFail({ id: channel.parent_id });
|
|
||||||
if (!exists) throw new HTTPError("Parent id channel doesn't exist", 400);
|
|
||||||
if (exists.guild_id !== channel.guild_id) throw new HTTPError("The category channel needs to be in the guild");
|
|
||||||
}
|
|
||||||
break;
|
|
||||||
case ChannelType.GUILD_CATEGORY:
|
|
||||||
break;
|
|
||||||
case ChannelType.DM:
|
|
||||||
case ChannelType.GROUP_DM:
|
|
||||||
throw new HTTPError("You can't create a dm channel in a guild");
|
|
||||||
// TODO: check if guild is community server
|
|
||||||
case ChannelType.GUILD_STORE:
|
|
||||||
case ChannelType.GUILD_NEWS:
|
|
||||||
default:
|
|
||||||
throw new HTTPError("Not yet supported");
|
|
||||||
}
|
|
||||||
|
|
||||||
if (!channel.permission_overwrites) channel.permission_overwrites = [];
|
|
||||||
// TODO: auto generate position
|
|
||||||
|
|
||||||
channel = await new Channel({
|
|
||||||
...channel,
|
|
||||||
...(!opts?.keepId && { id: Snowflake.generate() }),
|
|
||||||
created_at: new Date(),
|
|
||||||
// @ts-ignore
|
|
||||||
recipient_ids: null
|
|
||||||
}).save();
|
|
||||||
|
|
||||||
await emitEvent({ event: "CHANNEL_CREATE", data: channel, guild_id: channel.guild_id } as ChannelCreateEvent);
|
|
||||||
|
|
||||||
return channel;
|
|
||||||
}
|
|
Loading…
x
Reference in New Issue
Block a user