Function updateManyChannels

packages/core/src/channel.ts:269–286

(
	data: z.infer<typeof zChannelUpdateMany>[],
)

}

export async function updateManyChannels(
	data: z.infer<typeof zChannelUpdateMany>[],
) {
	const dataReturned: Channel[] = [];
	for await (const channel of data) {
		await db
			.update(dbChannels)
			.set(channelInsertSchema.parse(channel))
			.where(eq(dbChannels.id, channel.id));

		const updated = await db.query.dbChannels.findFirst({
			where: eq(dbChannels.id, channel.id),
		});
		if (!updated) throw new Error('Error updating channel');
		dataReturned.push(updated);
	}
	return dataReturned;
}

export async function deleteChannel(id: string) {
	await deleteManyMessagesByChannelId(id);