Compare commits
14 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| d3e90f7d5d | |||
| 98887eecce | |||
| 95e6bd178e | |||
| ac7c8d04ed | |||
| fd44712e37 | |||
| b3c7f7cb5e | |||
| db03373892 | |||
| 267ecaa705 | |||
| 3a8cfd39ed | |||
| b157ef18ff | |||
| 500035284f | |||
| c5360a70d6 | |||
| cf4c8a0f99 | |||
| 21527d8931 |
@@ -1,3 +1,4 @@
|
|||||||
|
|
||||||
FROM node:18-bullseye-slim
|
FROM node:18-bullseye-slim
|
||||||
WORKDIR "/app"
|
WORKDIR "/app"
|
||||||
COPY package*.json ./
|
COPY package*.json ./
|
||||||
|
|||||||
@@ -1,4 +1,4 @@
|
|||||||
Copyright (c) 2021 Kayne Ruse, KR Game Studios
|
Copyright (c) 2021-2023 Kayne Ruse, KR Game Studios
|
||||||
|
|
||||||
This software is provided 'as-is', without any express or implied warranty. In no event will the authors be held liable for any damages arising from the use of this software.
|
This software is provided 'as-is', without any express or implied warranty. In no event will the authors be held liable for any damages arising from the use of this software.
|
||||||
|
|
||||||
|
|||||||
Generated
+4339
-1424
File diff suppressed because it is too large
Load Diff
+11
-7
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "auth-server",
|
"name": "auth-server",
|
||||||
"version": "1.7.1",
|
"version": "1.7.9",
|
||||||
"description": "An API centric auth server. Uses Sequelize and mariaDB by default.",
|
"description": "An API centric auth server. Uses Sequelize and mariaDB by default.",
|
||||||
"main": "server/server.js",
|
"main": "server/server.js",
|
||||||
"scripts": {
|
"scripts": {
|
||||||
@@ -22,16 +22,20 @@
|
|||||||
"bcryptjs": "^2.4.3",
|
"bcryptjs": "^2.4.3",
|
||||||
"cookie-parser": "^1.4.6",
|
"cookie-parser": "^1.4.6",
|
||||||
"cors": "^2.8.5",
|
"cors": "^2.8.5",
|
||||||
"dotenv": "^16.0.3",
|
"dotenv": "^16.3.1",
|
||||||
"express": "^4.18.2",
|
"express": "^4.18.2",
|
||||||
"jsonwebtoken": "^9.0.0",
|
"jsonwebtoken": "^9.0.0",
|
||||||
"mariadb": "^3.0.2",
|
"mariadb": "^3.2.0",
|
||||||
"node-cron": "^3.0.2",
|
"node-cron": "^3.0.2",
|
||||||
"node-fetch": "^2.6.7",
|
"node-fetch": "^2.6.11",
|
||||||
"nodemailer": "^6.8.0",
|
"nodemailer": "^6.9.3",
|
||||||
"sequelize": "^6.25.8"
|
"npm": "^9.7.2",
|
||||||
|
"sequelize": "^6.32.1"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"nodemon": "^2.0.20"
|
"nodemon": "^2.0.22"
|
||||||
|
},
|
||||||
|
"overrides": {
|
||||||
|
"semver": "^7.5.2"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
+45
-1
@@ -19,6 +19,13 @@ const route = async (req, res) => {
|
|||||||
return res.status(401).send(validateErr);
|
return res.status(401).send(validateErr);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
//script throttle
|
||||||
|
const throttle = await checkThrottle(req.body.email);
|
||||||
|
if (throttle) {
|
||||||
|
console.warn(`Spam Throttled\t${req.body.email} (${req.body.username})`);
|
||||||
|
return res.status(401).send(throttle);
|
||||||
|
}
|
||||||
|
|
||||||
//generate the password hash
|
//generate the password hash
|
||||||
const hash = await bcrypt.hash(req.body.password, await bcrypt.genSalt(11));
|
const hash = await bcrypt.hash(req.body.password, await bcrypt.genSalt(11));
|
||||||
|
|
||||||
@@ -83,6 +90,10 @@ const validateDetails = async (body) => {
|
|||||||
return 'Missing password';
|
return 'Missing password';
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (typeof body.password != "string") {
|
||||||
|
return 'Invalid password';
|
||||||
|
}
|
||||||
|
|
||||||
if (body.password.length < 8) {
|
if (body.password.length < 8) {
|
||||||
return 'Password too short';
|
return 'Password too short';
|
||||||
}
|
}
|
||||||
@@ -90,8 +101,41 @@ const validateDetails = async (body) => {
|
|||||||
return null;
|
return null;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
const checkThrottle = async (email) => {
|
||||||
|
//check email delay
|
||||||
|
const prev = await pendingSignups.findOne({
|
||||||
|
where: {
|
||||||
|
email: email,
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
const DateOffset = ( offset ) => { //Thanks, SO!
|
||||||
|
return new Date( +new Date + offset );
|
||||||
|
}
|
||||||
|
|
||||||
|
if (!!prev && prev.updatedAt > DateOffset( -5000 )) {
|
||||||
|
return "An unknown error occurred";
|
||||||
|
}
|
||||||
|
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
const registerPendingSignup = async (body, hash, token) => {
|
const registerPendingSignup = async (body, hash, token) => {
|
||||||
const record = await pendingSignups.upsert({
|
//BUGFIX: delete existing pending signups that clash
|
||||||
|
await pendingSignups.destroy({
|
||||||
|
where: {
|
||||||
|
email: body.email
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
await pendingSignups.destroy({
|
||||||
|
where: {
|
||||||
|
username: body.username
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
//record it
|
||||||
|
const record = await pendingSignups.create({
|
||||||
email: body.email,
|
email: body.email,
|
||||||
username: body.username,
|
username: body.username,
|
||||||
hash: hash,
|
hash: hash,
|
||||||
|
|||||||
@@ -0,0 +1,17 @@
|
|||||||
|
const Sequelize = require('sequelize');
|
||||||
|
const sequelize = require('..');
|
||||||
|
|
||||||
|
//DOCS: this isn't set by anything - it's a stub for now
|
||||||
|
|
||||||
|
module.exports = sequelize.define('bannedIPAddresses', {
|
||||||
|
content: {
|
||||||
|
type: 'varchar(320)',
|
||||||
|
unique: true
|
||||||
|
},
|
||||||
|
|
||||||
|
expiry: {
|
||||||
|
type: 'DATETIME',
|
||||||
|
allowNull: true,
|
||||||
|
defaultValue: null
|
||||||
|
},
|
||||||
|
});
|
||||||
@@ -2,5 +2,6 @@ module.exports = {
|
|||||||
tokens: require('./tokens'),
|
tokens: require('./tokens'),
|
||||||
accounts: require('./accounts'),
|
accounts: require('./accounts'),
|
||||||
pendingSignups: require('./pending-signups'),
|
pendingSignups: require('./pending-signups'),
|
||||||
recovery: require('./recovery')
|
recovery: require('./recovery'),
|
||||||
|
bannedIPAddresses: require("./banned-ip-addresses"),
|
||||||
};
|
};
|
||||||
+3
-11
@@ -23,6 +23,9 @@ app.use(cookieParser());
|
|||||||
//database connection
|
//database connection
|
||||||
const database = require('./database');
|
const database = require('./database');
|
||||||
|
|
||||||
|
//ip-based management
|
||||||
|
app.use(require('./utilities/banned-ip-addresses-middleware'));
|
||||||
|
|
||||||
//access the admin
|
//access the admin
|
||||||
app.use('/admin', require('./admin'));
|
app.use('/admin', require('./admin'));
|
||||||
|
|
||||||
@@ -36,17 +39,6 @@ app.get('*', (req, res) => {
|
|||||||
|
|
||||||
//startup
|
//startup
|
||||||
server.listen(process.env.WEB_PORT || 3200, async (err) => {
|
server.listen(process.env.WEB_PORT || 3200, async (err) => {
|
||||||
//BUGFIX: clear out old refresh tokens
|
|
||||||
const { Op } = require('sequelize');
|
|
||||||
const { tokens } = require('./database/models');
|
|
||||||
tokens.destroy({
|
|
||||||
where: {
|
|
||||||
createdAt: {
|
|
||||||
[Op.lt]: new Date(new Date().setDate(new Date().getDate() - 30))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
await database.sync();
|
await database.sync();
|
||||||
console.log(`listening to localhost:${process.env.WEB_PORT || 3200}`);
|
console.log(`listening to localhost:${process.env.WEB_PORT || 3200}`);
|
||||||
});
|
});
|
||||||
|
|||||||
@@ -0,0 +1,33 @@
|
|||||||
|
const { Op } = require("sequelize");
|
||||||
|
const { bannedIPAddresses } = require('../database/models');
|
||||||
|
|
||||||
|
//middleware to manage banned IP addresses
|
||||||
|
module.exports = async (req, res, next) => {
|
||||||
|
const address = req.header('x-forwarded-for') || req.socket.remoteAddress;
|
||||||
|
|
||||||
|
const record = await bannedIPAddresses.findOne({
|
||||||
|
where: {
|
||||||
|
content: address,
|
||||||
|
|
||||||
|
expiry: {
|
||||||
|
[Op.or]: {
|
||||||
|
//future or forever
|
||||||
|
[Op.gt]: Date.now(),
|
||||||
|
[Op.eq]: null,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
//log the access timestamp
|
||||||
|
const date = new Date();
|
||||||
|
|
||||||
|
if (!!record) {
|
||||||
|
console.log(`IP blocked\t${address}\t\t\t${date.toTimeString()}`);
|
||||||
|
return res.status(403).send("IP address banned");
|
||||||
|
}
|
||||||
|
|
||||||
|
// console.log(`IP allowed\t${address}\t\t\t${date.toTimeString()}`);
|
||||||
|
|
||||||
|
return next();
|
||||||
|
};
|
||||||
@@ -31,7 +31,7 @@ const TokenProvider = props => {
|
|||||||
let bearer = accessToken;
|
let bearer = accessToken;
|
||||||
|
|
||||||
//if expired (10 minutes, normally)
|
//if expired (10 minutes, normally)
|
||||||
const expired = new Date(decode(accessToken).exp * 1000) < Date.now();
|
const expired = new Date(decode(accessToken).exp + 600) < Date.now();
|
||||||
|
|
||||||
if (expired) {
|
if (expired) {
|
||||||
//BUGFIX: if logging out, just skip over the refresh token
|
//BUGFIX: if logging out, just skip over the refresh token
|
||||||
|
|||||||
Reference in New Issue
Block a user