96 lines
1.9 KiB
TypeScript
96 lines
1.9 KiB
TypeScript
import { IChannel, IServer, IUser, IMessage } from '~/types'
|
|
import { Server } from 'socket.io'
|
|
import { PrismaClient } from '@prisma/client'
|
|
const prisma = new PrismaClient()
|
|
|
|
declare global {
|
|
var io: Server
|
|
}
|
|
|
|
export default defineEventHandler(async (event) => {
|
|
if (!event.context.user.authenticated) {
|
|
event.node.res.statusCode = 401;
|
|
return {
|
|
message: 'You must be logged in to send a message.'
|
|
}
|
|
}
|
|
|
|
const { body, channelId } = await readBody(event)
|
|
|
|
if (!body || !channelId) {
|
|
event.node.res.statusCode = 400;
|
|
return {
|
|
message: 'A body or channelId is required to send a message.'
|
|
}
|
|
}
|
|
|
|
const channel = await prisma.channel.findFirst({
|
|
where: {
|
|
id: channelId
|
|
},
|
|
include: {
|
|
dmParticipants: true
|
|
}
|
|
}) as IChannel
|
|
|
|
if (!channel.DM) {
|
|
const server = await prisma.server.findFirst({
|
|
where: {
|
|
id: channel.serverId
|
|
},
|
|
include: {
|
|
participants: true
|
|
}
|
|
}) as IServer
|
|
|
|
const userInServer: Array<IUser> = server.participants.filter((e) => e.id === event.context.user.id)
|
|
|
|
if (userInServer.length > 0) {
|
|
event.node.res.statusCode = 401;
|
|
return {
|
|
message: 'You must be in the server to send a message.'
|
|
}
|
|
}
|
|
|
|
if (!server) {
|
|
event.node.res.statusCode = 404;
|
|
return {
|
|
message: 'Server not found'
|
|
}
|
|
}
|
|
} else {
|
|
const userInDM: Array<IUser> | undefined = channel.dmParticipants?.filter((e) => e.id === event.context.user.id)
|
|
|
|
if (!userInDM || userInDM.length > 0) {
|
|
event.node.res.statusCode = 401;
|
|
return {
|
|
message: 'You must be in the DM to send a message.'
|
|
}
|
|
}
|
|
}
|
|
|
|
const message = await prisma.message.create({
|
|
data: {
|
|
body,
|
|
creator: {
|
|
connect: {
|
|
id: event.context.user.id
|
|
}
|
|
},
|
|
channel: {
|
|
connect: {
|
|
id: channelId
|
|
}
|
|
}
|
|
},
|
|
include: {
|
|
creator: true
|
|
}
|
|
}) as IMessage
|
|
|
|
global.io.emit(`message-${channel.id}`, { message });
|
|
|
|
return {
|
|
message
|
|
}
|
|
}) |