40 lines
957 B
JavaScript
40 lines
957 B
JavaScript
'use server';
|
|
import connectDB from '@/config/database';
|
|
import Message from '@/models/Message';
|
|
import { getSessionUser } from '@/utils/getSessionUser';
|
|
import { revalidatePath } from 'next/cache';
|
|
|
|
async function addMessage(previousState, formData) {
|
|
await connectDB();
|
|
|
|
const sessionUser = await getSessionUser();
|
|
|
|
if (!sessionUser || !sessionUser.user) {
|
|
return { error: 'You must be logged in to send a message' };
|
|
}
|
|
|
|
const { user } = sessionUser;
|
|
|
|
const recipient = formData.get('recipient');
|
|
|
|
if (user.id === recipient) {
|
|
return { error: 'You can not send a message to yourself' };
|
|
}
|
|
|
|
const newMessage = new Message({
|
|
sender: user.id,
|
|
recipient,
|
|
property: formData.get('property'),
|
|
name: formData.get('name'),
|
|
email: formData.get('email'),
|
|
phone: formData.get('phone'),
|
|
body: formData.get('message'),
|
|
});
|
|
|
|
await newMessage.save();
|
|
|
|
return { submitted: true };
|
|
}
|
|
|
|
export default addMessage;
|