stream day 6

This commit is contained in:
Zoe
2023-01-11 22:29:41 -06:00
parent a30bcfa0a8
commit 21a9b11547
21 changed files with 644 additions and 145 deletions

View File

@@ -1,4 +1,4 @@
import { IChannel, IServer, IUser } from '../../../../types'
import { IChannel, IServer, SafeUser } from '../../../../types'
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
@@ -20,11 +20,47 @@ export default defineEventHandler(async (event) => {
where: {
id: event.context.params.id
},
include: {
messages: true,
dmParticipants: true
select: {
id: true,
name: true,
server: {
select: {
id: true
}
},
messages: {
select: {
id: true,
body: true,
creator: {
select: {
id: true,
username: true
}
},
invites: {
select: {
id: true,
server: {
select: {
id: true,
name: true
}
}
}
}
}
},
DM: true,
dmParticipants: {
select: {
id: true,
username: true
}
},
serverId: true,
}
}) as IChannel
}) as IChannel | null;
if (!channel) {
event.node.res.statusCode = 404;
@@ -39,11 +75,12 @@ export default defineEventHandler(async (event) => {
id: channel.serverId
},
include: {
participants: true
participants: true,
roles: true
}
}) as IServer
}) as IServer | null;
const userInServer: Array<IUser> = server.participants.filter((e: IUser) => e.id === event.context.user.id)
const userInServer: Array<SafeUser> | undefined = server?.participants.filter((e: SafeUser) => e.id === event.context.user.id)
if (!userInServer) {
event.node.res.statusCode = 401;

View File

@@ -42,13 +42,25 @@ export default defineEventHandler(async (event) => {
name: 'general',
},
]
},
roles: {
create: [
{
name: 'owner',
owner: true,
users: {
connect: [{ id: event.context.user.id }]
}
},
]
}
},
include: {
channels: true,
participants: true
participants: true,
roles: true
}
}) as IServer
}) as IServer;
return server
})

View File

@@ -1,4 +1,4 @@
import { IChannel, IUser } from '~/types'
import { IChannel, SafeUser } from '~/types'
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
@@ -23,13 +23,13 @@ export default defineEventHandler(async (event) => {
where: {
id: partnerId
}
}) as IUser
}) as SafeUser | null;
const user = await prisma.user.findFirst({
where: {
id: event.context.user.id
}
}) as IUser
}) as SafeUser | null;
if (!partner) {
event.node.res.statusCode = 400;
@@ -38,6 +38,10 @@ export default defineEventHandler(async (event) => {
}
}
if (!user) {
throw new Error('user not found?')
}
const preExistingServer = await prisma.channel.findFirst({
where: {
name: `${user.id}-${partner.id}`,

View File

@@ -1,4 +1,4 @@
import { IChannel, IServer, IUser, IMessage } from '~/types'
import { IChannel, IServer, SafeUser, IMessage } from '~/types'
import { Server } from 'socket.io'
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
@@ -15,7 +15,7 @@ export default defineEventHandler(async (event) => {
}
}
const { body, channelId } = await readBody(event)
let { body, channelId } = await readBody(event)
if (!body || !channelId) {
event.node.res.statusCode = 400;
@@ -43,9 +43,9 @@ export default defineEventHandler(async (event) => {
}
}) as IServer
const userInServer: Array<IUser> = server.participants.filter((e) => e.id === event.context.user.id)
const userInServer: SafeUser | undefined = server.participants.find((e: SafeUser) => e.id === event.context.user.id)
if (userInServer.length > 0) {
if (!userInServer) {
event.node.res.statusCode = 401;
return {
message: 'You must be in the server to send a message.'
@@ -59,9 +59,9 @@ export default defineEventHandler(async (event) => {
}
}
} else {
const userInDM: Array<IUser> | undefined = channel.dmParticipants?.filter((e) => e.id === event.context.user.id)
const userInDM: SafeUser | undefined = channel.dmParticipants?.find((e) => e.id === event.context.user.id)
if (!userInDM || userInDM.length > 0) {
if (!userInDM) {
event.node.res.statusCode = 401;
return {
message: 'You must be in the DM to send a message.'
@@ -69,6 +69,21 @@ export default defineEventHandler(async (event) => {
}
}
const matches = body.match(/<&([a-z]|[0-9]){25}>/g);
let invites: { id: string; }[] = [];
if (matches) {
matches.forEach((e: string) => {
if (!e) return
const opBody = body;
body = body.split(e).join('')
if (opBody === body) return;
const id = e.split('<&')[1]?.split('>')[0];
if (!id) return;
invites.push({ id });
});
}
const message = await prisma.message.create({
data: {
body,
@@ -81,16 +96,34 @@ export default defineEventHandler(async (event) => {
connect: {
id: channelId
}
},
invites: {
connect: invites
}
},
include: {
creator: true
select: {
id: true,
body: true,
creator: {
select: {
id: true,
username: true,
}
},
invites: {
select: {
id: true,
server: true,
expires: true,
expiryDate: true,
maxUses: true
}
}
}
}) as IMessage
global.io.emit(`message-${channel.id}`, { message });
return {
message
}
return message
})

View File

@@ -1,5 +1,5 @@
import { PrismaClient } from '@prisma/client'
import { IUser } from '../../types'
import { SafeUser } from '../../types'
const prisma = new PrismaClient()
export default defineEventHandler(async (event) => {
@@ -42,13 +42,24 @@ export default defineEventHandler(async (event) => {
id: true,
username: true
}
},
roles: {
select: {
id: true,
name: true,
administrator: true,
owner: true,
users: {
select: {
id: true
}
}
}
}
},
},
}
}) as IUser
user.passwordhash = undefined;
}) as SafeUser | null;
return user
})

View File

@@ -0,0 +1,67 @@
import { IChannel, IServer, SafeUser } from '~/types'
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
export default defineEventHandler(async (event) => {
if (!event.context.user.authenticated) {
return {
message: 'You must be logged in to view a channel.'
}
}
if (!event.context.params.id) {
event.node.res.statusCode = 400;
return {
message: 'A serverId is required'
}
}
const { channelName } = await readBody(event)
const server = await prisma.server.findFirst({
where: {
id: event.context.params.id
},
include: {
participants: true,
channels: true,
roles: true
}
}) as IServer | null;
if (!server) {
event.node.res.statusCode = 404;
return {
message: `Server with id "${event.context.params.id}" not found`
}
}
const userInServer: Array<SafeUser> = server.participants.filter((e: SafeUser) => e.id === event.context.user.id)
if (!userInServer) {
event.node.res.statusCode = 401;
return {
message: `You must be in the server to access a channel in that server`
}
}
if (server.channels?.find((e) => e.name === channelName)) {
event.node.res.statusCode = 409;
return {
message: `Channel with name "${channelName}" already exists in server with id "event.context.user.id"`
}
}
const channel = await prisma.channel.create({
data: {
name: channelName,
server: {
connect: {
id: server.id
}
}
}
}) as IChannel
return channel
})

View File

@@ -0,0 +1,66 @@
import { IChannel, IInviteCode, IServer, SafeUser } from '~/types'
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
export default defineEventHandler(async (event) => {
if (!event.context.user.authenticated) {
return {
message: 'You must be logged in to view a channel.'
}
}
if (!event.context.params.id) {
event.node.res.statusCode = 400;
return {
message: 'A serverId is required'
}
}
let body = await readBody(event)
let expires = false;
// if (body.expiryDate) {
// expires = true;
// body.expiryDate = new Date(body.expiryDate).getUTCDate()
// }
const server = await prisma.server.findFirst({
where: {
id: event.context.params.id
},
include: {
participants: true,
channels: true,
roles: true
}
}) as IServer | null;
if (!server) {
event.node.res.statusCode = 404;
return {
message: `Server with id "${event.context.params.id}" not found`
}
}
const userInServerAndPermited: Array<SafeUser> = server.participants.filter((e: SafeUser) => e.id === event.context.user.id && e.roles?.some((el) => el.administer === true || el.owner === false))
if (!userInServerAndPermited) {
event.node.res.statusCode = 401;
return {
message: `You must be in the server or an admin/owner of that server to make an invite code`
}
}
const inviteCode = await prisma.inviteCode.create({
data: {
server: {
connect: {
id: server.id
}
},
maxUses: 0
}
}) as IInviteCode
return inviteCode
})

View File

@@ -20,9 +20,10 @@ export default defineEventHandler(async (event) => {
},
include: {
participants: true,
channels: true
channels: true,
roles: true
}
}) as IServer
}) as IServer | null;
if (!server) {
event.node.res.statusCode = 404;

View File

@@ -0,0 +1,65 @@
import { IServer } from '~/types'
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
export default defineEventHandler(async (event) => {
if (!event.context.user.authenticated) return {
message: 'You must be logged in to view a channel.'
}
const { inviteId } = await readBody(event);
if (!inviteId) {
event.node.res.statusCode = 400;
return {
message: 'A inviteId is required'
}
}
const invite = await prisma.inviteCode.findFirst({
where: {
id: inviteId
},
include: {
server: true
}
})
if (!invite) {
event.node.res.statusCode = 404;
return {
message: `Invite with id "${inviteId}" not found`
}
}
// TODO: check if invite is valid
const server = await prisma.server.update({
where: {
id: invite.server.id
},
data: {
participants: {
connect: [
{ id: event.context.user.id }
]
}
},
include: {
participants: true,
channels: true,
roles: true
}
}) as IServer
if (!server) {
event.node.res.statusCode = 404;
return {
message: `Channel with id "${event.context.params.id}" not found`
}
}
return {
server
}
})

View File

@@ -1,7 +1,7 @@
import bcryptjs from "bcryptjs";
import { v4 as uuidv4 } from "uuid";
import { PrismaClient } from '@prisma/client'
import { IUser } from "../../types";
import { SafeUser } from "~/types";
const prisma = new PrismaClient()
export default defineEventHandler(async (event) => {
@@ -25,7 +25,7 @@ export default defineEventHandler(async (event) => {
}
]
}
}) as IUser
}) as SafeUser
if (preExistingUser) {
event.node.res.statusCode = 409;
@@ -42,7 +42,7 @@ export default defineEventHandler(async (event) => {
passwordhash,
email: body.email
}
}) as IUser
}) as SafeUser
const token = uuidv4()

View File

@@ -1,25 +0,0 @@
import { IUser } from '~/types'
import { PrismaClient } from '@prisma/client'
const prisma = new PrismaClient()
export default defineEventHandler(async (event) => {
if (!event.context.user.authenticated) {
// event.node.res.statusCode = 401;
return {
message: "Unauthenticated"
}
}
const servers = await prisma.user.findFirst({
where: {
id: event.context.user.id
},
include: {
channels: true
}
}) as IUser
servers.passwordhash = undefined;
return servers
})