+
{otherSubmitButton}
);
-}
\ No newline at end of file
+}
diff --git a/apps/web/src/lib/form/actions.ts b/apps/web/src/lib/form/actions.ts
index 72fc38d..9155c7e 100644
--- a/apps/web/src/lib/form/actions.ts
+++ b/apps/web/src/lib/form/actions.ts
@@ -2,11 +2,12 @@
import { revalidatePath } from 'next/cache';
import { validateRequest } from '@/lib/auth/validate';
-import { prisma } from '@hctv/db';
+import { prisma, getRedisConnection } from '@hctv/db';
import zodVerify from '../zodVerify';
import {
createBotSchema,
createChannelSchema,
+ changeUsernameSchema,
editBotSchema,
onboardSchema,
streamInfoEditSchema,
@@ -343,7 +344,10 @@ export async function deleteChannel(channelId: string) {
}
if (!can(user, 'delete', 'channel', { channel })) {
- return { success: false, error: 'Only channel owners can delete channels (personal channels cannot be deleted)' };
+ return {
+ success: false,
+ error: 'Only channel owners can delete channels (personal channels cannot be deleted)',
+ };
}
await prisma.channel.delete({
@@ -424,3 +428,125 @@ export async function editBot(prev: any, formData: FormData) {
return { success: true, slug: updatedBot.slug };
}
+
+const USERNAME_CHANGE_COOLDOWN_DAYS = 30;
+
+export async function changeUsername(prev: any, formData: FormData) {
+ const { user } = await validateRequest();
+ if (!user) {
+ return { success: false, error: 'Unauthorized' };
+ }
+
+ const zod = await zodVerify(changeUsernameSchema, formData);
+ if (!zod.success) {
+ return zod;
+ }
+
+ const channel = await prisma.channel.findUnique({
+ where: { id: zod.data.channelId },
+ include: {
+ owner: true,
+ managers: true,
+ personalFor: true,
+ streamInfo: true,
+ streamKey: true,
+ },
+ });
+
+ if (!channel) {
+ return { success: false, error: 'Channel not found' };
+ }
+
+ if (!channel.personalFor || channel.personalFor.id !== user.id) {
+ return { success: false, error: 'You can only change the username of your personal channel' };
+ }
+
+ if (channel.ownerId !== user.id) {
+ return { success: false, error: 'Unauthorized' };
+ }
+
+ if (channel.nameLastChanged) {
+ const daysSinceLastChange = Math.floor(
+ (Date.now() - new Date(channel.nameLastChanged).getTime()) / (1000 * 60 * 60 * 24)
+ );
+ if (daysSinceLastChange < USERNAME_CHANGE_COOLDOWN_DAYS) {
+ const daysRemaining = USERNAME_CHANGE_COOLDOWN_DAYS - daysSinceLastChange;
+ return {
+ success: false,
+ error: `Please wait ${daysRemaining} more day${daysRemaining === 1 ? '' : 's'}.`,
+ };
+ }
+ }
+
+ const oldName = channel.name;
+ const newName = zod.data.newUsername;
+
+ if (oldName === newName) {
+ return { success: false, error: 'New username must be different from the current one' };
+ }
+
+ const existingChannel = await prisma.channel.findUnique({
+ where: { name: newName },
+ });
+ if (existingChannel) {
+ return { success: false, error: 'This username is already taken' };
+ }
+
+ const redis = getRedisConnection();
+
+ try {
+ await prisma.channel.update({
+ where: { id: channel.id },
+ data: {
+ name: newName,
+ nameLastChanged: process.env.NODE_ENV === 'production' ? new Date() : null,
+ },
+ });
+
+ if (channel.streamInfo.length > 0) {
+ await prisma.streamInfo.updateMany({
+ where: { channelId: channel.id },
+ data: { username: newName },
+ });
+ }
+
+ if (channel.streamKey) {
+ const oldStreamKey = `streamKey:${oldName}`;
+ const newStreamKey = `streamKey:${newName}`;
+ if (await redis.exists(oldStreamKey)) {
+ await redis.rename(oldStreamKey, newStreamKey);
+ }
+ }
+
+ const oldHistoryKey = `chat:history:${oldName}`;
+ const newHistoryKey = `chat:history:${newName}`;
+ if (await redis.exists(oldHistoryKey)) {
+ const messagesWithScores = await redis.zrange(oldHistoryKey, 0, -1, 'WITHSCORES');
+ if (messagesWithScores.length > 0) {
+ const args: (string | number)[] = [];
+ for (let i = 0; i < messagesWithScores.length; i += 2) {
+ const msgStr = messagesWithScores[i];
+ const score = messagesWithScores[i + 1];
+ try {
+ const msg = JSON.parse(msgStr);
+ msg.user.username = newName;
+ args.push(score, JSON.stringify(msg));
+ } catch {
+ args.push(score, msgStr);
+ }
+ }
+ await redis.zadd(newHistoryKey, ...args);
+ }
+ await redis.del(oldHistoryKey);
+ }
+
+ revalidatePath(`/settings/channel/${newName}`);
+ revalidatePath(`/${oldName}`);
+ revalidatePath(`/${newName}`);
+
+ return { success: true, newUsername: newName };
+ } catch (error) {
+ console.error('Failed to change username:', error);
+ return { success: false, error: 'Failed to change username. Please try again.' };
+ }
+}
diff --git a/apps/web/src/lib/form/zod.ts b/apps/web/src/lib/form/zod.ts
index 5d314cb..492cf1a 100644
--- a/apps/web/src/lib/form/zod.ts
+++ b/apps/web/src/lib/form/zod.ts
@@ -50,3 +50,8 @@ export const editBotSchema = createBotSchema.and(
from: z.string().min(1),
})
);
+
+export const changeUsernameSchema = z.object({
+ channelId: z.string().min(1),
+ newUsername: username,
+});
diff --git a/packages/db/prisma/migrations/20260131224649_add_name_last_changed_to_channel/migration.sql b/packages/db/prisma/migrations/20260131224649_add_name_last_changed_to_channel/migration.sql
new file mode 100644
index 0000000..5534e66
--- /dev/null
+++ b/packages/db/prisma/migrations/20260131224649_add_name_last_changed_to_channel/migration.sql
@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "Channel" ADD COLUMN "nameLastChanged" TIMESTAMP(3);
diff --git a/packages/db/prisma/schema.prisma b/packages/db/prisma/schema.prisma
index 5bec0d6..3f79289 100644
--- a/packages/db/prisma/schema.prisma
+++ b/packages/db/prisma/schema.prisma
@@ -45,8 +45,9 @@ model Channel {
description String @default("A hctv channel")
pfpUrl String
- createdAt DateTime @default(now())
- updatedAt DateTime @updatedAt
+ createdAt DateTime @default(now())
+ updatedAt DateTime @updatedAt
+ nameLastChanged DateTime?
personalFor User? @relation("PersonalChannel")