183 lines
3.4 KiB
TypeScript
183 lines
3.4 KiB
TypeScript
import { IChannel, IServer, SafeUser, IMessage } from '~/types'
|
|
import { Server } from 'socket.io'
|
|
import { PrismaClient } from '@prisma/client'
|
|
import { registerRuntimeHelpers } from '@vue/compiler-core'
|
|
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.'
|
|
}
|
|
}
|
|
|
|
let { 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
|
|
},
|
|
select: {
|
|
id: true,
|
|
name: true,
|
|
messages: false,
|
|
DM: true,
|
|
dmParticipants: {
|
|
select: {
|
|
id: true,
|
|
username: true
|
|
}
|
|
}
|
|
}
|
|
}) as IChannel | null;
|
|
|
|
if (!channel) {
|
|
event.node.res.statusCode = 404;
|
|
return {
|
|
message: `Channel with id "${channelId}" not found.`
|
|
}
|
|
}
|
|
|
|
if (!channel.DM) {
|
|
const server = await prisma.server.findFirst({
|
|
where: {
|
|
id: channel.serverId
|
|
},
|
|
select: {
|
|
id: true,
|
|
name: true,
|
|
channels: {
|
|
select: {
|
|
id: true,
|
|
DM: true,
|
|
name: true
|
|
}
|
|
},
|
|
participants: {
|
|
select: {
|
|
id: true,
|
|
username: true
|
|
}
|
|
},
|
|
roles: {
|
|
select: {
|
|
id: true,
|
|
name: true,
|
|
administrator: true,
|
|
owner: true,
|
|
users: {
|
|
select: {
|
|
id: true
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}) as IServer | null;
|
|
|
|
if (!server) {
|
|
throw new Error(`server with id "${channel.serverId}" is not found but channel with id "${channel.id}" is not a dm?`)
|
|
}
|
|
|
|
const userInServer: SafeUser | undefined = server.participants.find((e: SafeUser) => e.id === event.context.user.id)
|
|
|
|
if (!userInServer) {
|
|
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: SafeUser | undefined = channel.dmParticipants?.find((e) => e.id === event.context.user.id)
|
|
|
|
if (!userInDM) {
|
|
event.node.res.statusCode = 401;
|
|
return {
|
|
message: 'You must be in the DM to send a message.'
|
|
}
|
|
}
|
|
}
|
|
|
|
const inviteCodes = body.match(/<&([a-z]|[0-9]){25}>/g);
|
|
|
|
let invites: { id: string; }[] = [];
|
|
if (inviteCodes) {
|
|
inviteCodes.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,
|
|
creator: {
|
|
connect: {
|
|
id: event.context.user.id
|
|
}
|
|
},
|
|
channel: {
|
|
connect: {
|
|
id: channelId
|
|
}
|
|
},
|
|
invites: {
|
|
connect: invites
|
|
}
|
|
},
|
|
select: {
|
|
id: true,
|
|
body: true,
|
|
creator: {
|
|
select: {
|
|
id: true,
|
|
username: true,
|
|
}
|
|
},
|
|
invites: {
|
|
select: {
|
|
id: true,
|
|
expires: true,
|
|
expiryDate: true,
|
|
maxUses: true,
|
|
server: {
|
|
select: {
|
|
id: true,
|
|
name: true,
|
|
participants: true
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}) as unknown as IMessage
|
|
|
|
|
|
global.io.emit(`message-${channel.id}`, { message });
|
|
|
|
return message
|
|
}) |