+ 
+ 
+ 
+
+
+
+
+ Get started
+
+ Edit src/App.tsx and save to test HMR
+
+ Edit src/App.tsx and save to test HMR
+
${message}
+ `; + + return send({ email, html, subject: 'Notification' }); +} + +export const emailService = { + sendActivationEmail, + send, + sendNotification, +}; diff --git a/src/service/jwt.service.js b/src/service/jwt.service.js new file mode 100644 index 00000000..7326ec1b --- /dev/null +++ b/src/service/jwt.service.js @@ -0,0 +1,38 @@ +import jwt from 'jsonwebtoken'; + +function sign(user) { + const token = jwt.sign(user, process.env.JWT_KEY, { + expiresIn: '10s', + }); + + return token; +} + +function verify(token) { + try { + return jwt.verify(token, process.env.JWT_KEY); + } catch { + return null; + } +} + +function signRefresh(user) { + const token = jwt.sign(user, process.env.JWT_REFRESH_SECRET); + + return token; +} + +function verifyRefresh(token) { + try { + return jwt.verify(token, process.env.JWT_REFRESH_SECRET); + } catch { + return null; + } +} + +export const jwtService = { + sign, + verify, + signRefresh, + verifyRefresh, +}; diff --git a/src/service/passwordReset.service.js b/src/service/passwordReset.service.js new file mode 100644 index 00000000..a59b2180 --- /dev/null +++ b/src/service/passwordReset.service.js @@ -0,0 +1,28 @@ +import { v4 as uuidv4 } from 'uuid'; +import { User } from '../models/user.js'; +import { emailService } from './email.service.js'; +import { ApiError } from '../exeptions/api.error.js'; + +async function reset(email) { + const resetToken = uuidv4(); + const resetTokenExpiry = Date.now() + 1000 * 60 * 15; + + const user = await User.findOne({ where: { email } }); + + if (!user) { + throw ApiError.notFound('User not found'); + } + + user.resetToken = resetToken; + user.resetTokenExpiry = resetTokenExpiry; + + await user.save(); + + await emailService.sendActivationEmail(email, resetToken, 'reset-password', { + title: 'Reset Password', + }); +} + +export const passwordResetService = { + reset, +}; diff --git a/src/service/profile.service.js b/src/service/profile.service.js new file mode 100644 index 00000000..8ee90b6d --- /dev/null +++ b/src/service/profile.service.js @@ -0,0 +1,64 @@ +import { v4 as uuidv4 } from 'uuid'; +import { findByEmail } from './user.service.js'; +import { ApiError } from '../exeptions/api.error.js'; +import { User } from '../models/user.js'; +import { emailService } from './email.service.js'; +import { Op } from 'sequelize'; + +async function updateEmail(email, newEmail) { + const emailToken = uuidv4(); + const emailExpiry = new Date(Date.now() + 1000 * 60 * 60); + + const user = await findByEmail(email); + + if (!user) { + throw ApiError.badRequest('Not found User'); + } + + await User.update( + { + pendingEmail: newEmail, + emailChangeToken: emailToken, + emailChangeTokenExpiry: emailExpiry, + }, + { + where: { email }, + }, + ); + + await emailService.sendActivationEmail( + email, + emailToken, + 'profile/email', + 'Activate change Email', + ); + + await emailService.sendNotification(email, 'Your email change was requested'); +} + +async function confirmEmailChange(emailChangeToken) { + const user = await User.findOne({ + where: { + emailChangeToken, + emailChangeTokenExpiry: { [Op.gt]: new Date() }, + }, + }); + + if (!user) { + throw ApiError.notFound('Invalid or expired token'); + } + + await user.update({ + email: user.pendingEmail, + pendingEmail: null, + emailChangeToken: null, + emailChangeTokenExpiry: null, + }); + + return user; +} + +export const profileService = { + updateEmail, + confirmEmailChange, +}; diff --git a/src/service/token.service.js b/src/service/token.service.js new file mode 100644 index 00000000..01b8aab5 --- /dev/null +++ b/src/service/token.service.js @@ -0,0 +1,29 @@ +import { Token } from '../models/token.js'; + +async function save(userId, newToken) { + const token = await Token.findOne({ where: { userId } }); + + if (!token) { + await Token.create({ userId, refreshToken: newToken }); + + return; + } + + token.refreshToken = newToken; + + await token.save(); +} + +async function getByToken(refreshToken) { + return Token.findOne({ where: { refreshToken } }); +} + +async function remove(userId) { + return Token.destroy({ where: { userId } }); +} + +export const tokenService = { + save, + getByToken, + remove, +}; diff --git a/src/service/user.service.js b/src/service/user.service.js new file mode 100644 index 00000000..154cd63b --- /dev/null +++ b/src/service/user.service.js @@ -0,0 +1,50 @@ +import { ApiError } from '../exeptions/api.error.js'; +import { User } from '../models/user.js'; +import { emailService } from '../service/email.service.js'; +import { v4 as uuidv4 } from 'uuid'; + +export function getAllActivated() { + return User.findAll({ + where: { activationToken: null }, + }); +} + +function normalizeUser({ name, id, email } = {}) { + return { name, id, email }; +} + +export function findByEmail(email) { + return User.findOne({ + where: { email }, + }); +} + +async function register(name, email, password) { + const activationToken = uuidv4(); + + const existUser = await findByEmail(email); + + if (existUser) { + throw ApiError.badRequest('User already exist', { + email: 'User already exist', + }); + } + + await User.create({ + name, + email, + password, + activationToken, + }); + + await emailService.sendActivationEmail(email, activationToken, 'activate', { + title: 'Activate account', + }); +} + +export const userService = { + getAllActivated, + normalizeUser, + findByEmail, + register, +}; diff --git a/src/setup.js b/src/setup.js new file mode 100644 index 00000000..3f51b447 --- /dev/null +++ b/src/setup.js @@ -0,0 +1,7 @@ +/* eslint-disable no-unused-vars */ +import 'dotenv/config'; +import { User } from './models/user.js'; +import { Token } from './models/token.js'; +import { client } from './utils/db.js'; + +client.sync({ force: true }); diff --git a/src/utils/cathcError.js b/src/utils/cathcError.js new file mode 100644 index 00000000..f98b3cfd --- /dev/null +++ b/src/utils/cathcError.js @@ -0,0 +1,9 @@ +export const catchError = (action) => { + return async function (req, res, next) { + try { + await action(req, res, next); + } catch (e) { + next(e); + } + }; +}; diff --git a/src/utils/db.js b/src/utils/db.js new file mode 100644 index 00000000..af11e8b9 --- /dev/null +++ b/src/utils/db.js @@ -0,0 +1,10 @@ +import { Sequelize } from 'sequelize'; + +export const client = new Sequelize({ + host: process.env.DB_HOST, + username: process.env.DB_USER, + port: process.env.DB_PORT, + password: process.env.DB_PASS, + database: process.env.DB_DATABASE, + dialect: 'postgres', +}); diff --git a/src/utils/validate.js b/src/utils/validate.js new file mode 100644 index 00000000..2355cc4e --- /dev/null +++ b/src/utils/validate.js @@ -0,0 +1,43 @@ +const name = (nameUser) => { + if (!nameUser || typeof nameUser !== 'string') { + return 'Name is required'; + } + + if (nameUser.trim().length < 2) { + return 'Name must be at least 2 characters'; + } + + return null; +}; + +const email = (emailUser) => { + const emailRegex = /^[^\s@]+@[^\s@]+\.[^\s@]+$/; + + if (!emailUser) { + return 'Email is required'; + } + + if (!emailRegex.test(emailUser)) { + return 'Invalid email format'; + } + + return null; +}; + +const password = (passwordUser) => { + if (!passwordUser) { + return 'Password is required'; + } + + if (passwordUser.length < 6) { + return 'Password must be at least 6 characters'; + } + + return null; +}; + +export const Validate = { + email, + name, + password, +};
Connect with us
+Join the Vite community
++-
+
+
+ GitHub
+
+
+ -
+
+
+ Discord
+
+
+ -
+
+
+ X.com
+
+
+ -
+
+
+ Bluesky
+
+
+
+