-
Notifications
You must be signed in to change notification settings - Fork 749
/
server.js
127 lines (106 loc) · 3.75 KB
/
server.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
import express from 'express';
import bodyParser from 'body-parser';
import mongoose from 'mongoose';
import nodemailer from 'nodemailer';
import { RegisterSchema } from './assets/validation/zodschema.js';
import validate from './assets/validation/validate.schema.js';
import cors from 'cors';
import { sendEmail } from './controller/subscribe.js';
import submitRating from './controller/Rating.js';
import dotenv from 'dotenv';
import book from './routes/books.js'
dotenv.config();
const app = express();
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: true }));
app.use(cors());
app.use(express.static('public'));
app.use(book);
// Add a root route
app.get('/', (req, res) => {
res.send('Welcome to the SwapReads API! Use the endpoints for signup, login, etc.');
});
const MONGO_URI = "mongodb+srv://nishantkaushal0708:[email protected]/";
const dbConnect = async () => {
try {
await mongoose.connect(MONGO_URI, {
serverSelectionTimeoutMS: 30000,
});
console.log("DB connected");
} catch (err) {
console.log("DB failed", err);
}
};
dbConnect().then(() => {
const User = mongoose.model("User", { username: String, password: String });
app.post("/signup", validate(RegisterSchema), async (req, res) => {
const { username, password } = req.body;
const userExists = await User.findOne({ username });
if (userExists) {
res.json({ success: false, message: "Username already exists." });
} else {
const newUser = new User({ username, password });
await newUser.save();
res.json({ success: true });
}
});
app.post("/login", validate(RegisterSchema), async (req, res) => {
const { username, password } = req.body;
const user = await User.findOne({ username, password });
if (user) {
res.json({ success: true });
} else {
res.json({ success: false, message: "Invalid username or password." });
}
});
// Contact form endpoint
app.post("/contact", async (req, res) => {
const { name, email, subject, message } = req.body;
const transporter = nodemailer.createTransport({
service: "gmail",
auth: {
user: "enter_you_mail",
pass: "Enter_YOUR_APP_PASSWORD",
},
});
const mailOptions = {
from: email,
to: "enter_you_mail",
subject: `You Have New Query from ${name} Regarding ${subject}`,
html: `Hey there is query from is ${name} Email: ${email} Message:<p style="color: red;"> ${message}</p>`,
};
const acknowledgmentOptions = {
from: "enter_you_mail",
to: email,
subject: "Acknowledgment of your message",
html: `<div style="font-family: Arial, sans-serif; line-height: 1.6;">
<p>Dear <strong>${name}</strong>,</p>
<p>Thank you for reaching out to us. We have received your message and will get back to you shortly.</p>
<p style="margin-top: 20px;">Best regards,<br><strong>SwapReads.com</strong></p>
</div>`,
};
try {
await transporter.sendMail(mailOptions);
await transporter.sendMail(acknowledgmentOptions);
res.json({ success: true, message: "Message sent successfully" });
} catch (err) {
console.error("Error sending email:", err);
res.json({ success: false, message: "Error sending message" });
}
});
app.post('/subscribe', (req, res) => {
const { name, email } = req.body;
// Call the function to send the email
sendEmail(name, email, (err, info) => {
if (err) {
return res.status(500).send('Error sending email');
}
res.status(200).send('Success');
});
});
app.post('/rate', submitRating);
const PORT = process.env.PORT || 4000;
app.listen(PORT, () => {
console.log(`Server running on port ${PORT}`);
});
});