Compare commits
21 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 174a56ac53 | |||
| 0bc7cb11f0 | |||
| 6859b36ae0 | |||
| 0ce2a552d8 | |||
| eb64f6c2e7 | |||
| 7429c4a1ee | |||
| ee705c6d43 | |||
| 58bc3f6b9d | |||
| 288e584cbd | |||
| 8ab786b934 | |||
| 72a4b0e101 | |||
| 59c610bdd8 | |||
| 1908413bd2 | |||
| 3c790f51c7 | |||
| 44e19154ab | |||
| fd0c40d444 | |||
| d3e90f7d5d | |||
| 98887eecce | |||
| 95e6bd178e | |||
| ac7c8d04ed | |||
| fd44712e37 |
@@ -4,7 +4,9 @@ WEB_RESET_ADDRESS=localhost/reset
|
|||||||
WEB_PORT=3200
|
WEB_PORT=3200
|
||||||
WEB_ORIGIN=http://localhost:3001
|
WEB_ORIGIN=http://localhost:3001
|
||||||
|
|
||||||
DB_HOSTNAME=database
|
DB_HOSTNAME=localhost
|
||||||
|
DB_PORTNAME=3306
|
||||||
|
|
||||||
DB_DATABASE=auth
|
DB_DATABASE=auth
|
||||||
DB_USERNAME=auth
|
DB_USERNAME=auth
|
||||||
DB_PASSWORD=charizard
|
DB_PASSWORD=charizard
|
||||||
@@ -20,6 +22,9 @@ ADMIN_DEFAULT_USERNAME=admin
|
|||||||
# Give this a value to generate the default admin account (must be at least 8 characters)
|
# Give this a value to generate the default admin account (must be at least 8 characters)
|
||||||
ADMIN_DEFAULT_PASSWORD=password
|
ADMIN_DEFAULT_PASSWORD=password
|
||||||
|
|
||||||
|
# Give this a value to generate teh default admin account (must be a valid domain name, to pass the initial email check)
|
||||||
|
ADMIN_DEFAULT_HOSTNAME=example.com
|
||||||
|
|
||||||
# Select a "TZ database name" that suits your needs: https://en.wikipedia.org/wiki/List_of_tz_database_time_zones
|
# Select a "TZ database name" that suits your needs: https://en.wikipedia.org/wiki/List_of_tz_database_time_zones
|
||||||
DB_TIMEZONE=Australia/Sydney
|
DB_TIMEZONE=Australia/Sydney
|
||||||
|
|
||||||
|
|||||||
+2
-2
@@ -1,7 +1,7 @@
|
|||||||
|
|
||||||
FROM node:18-bullseye-slim
|
FROM node:22-bookworm-slim
|
||||||
WORKDIR "/app"
|
WORKDIR "/app"
|
||||||
COPY package*.json ./
|
COPY package*.json /app
|
||||||
RUN npm install --production
|
RUN npm install --production
|
||||||
COPY . /app
|
COPY . /app
|
||||||
EXPOSE 3200
|
EXPOSE 3200
|
||||||
|
|||||||
@@ -6,7 +6,7 @@ This server is available via docker hub at krgamestudios/auth-server.
|
|||||||
|
|
||||||
# Setup
|
# Setup
|
||||||
|
|
||||||
There are multiple ways to run this app - it can run on it's own via `npm start` (for production) or `npm run dev` (for development). it can also run inside docker using `docker-compose up --build` - run `node configure-script.js` to generate docker-compose.yml and startup.sql.
|
There are multiple ways to run this app - it can run on it's own via `npm start` (for production) or `npm run dev` (for development). it can also run inside docker using `docker compose up --build` - run `node configure-script.js` to generate docker-compose.yml and startup.sql.
|
||||||
|
|
||||||
# API
|
# API
|
||||||
|
|
||||||
@@ -79,7 +79,7 @@ Cookie: refreshToken
|
|||||||
###
|
###
|
||||||
|
|
||||||
|
|
||||||
//DOCS: Retreives the private account data, results vary
|
//DOCS: Retrieves the private account data, results vary
|
||||||
GET /auth/account
|
GET /auth/account
|
||||||
Authorization: Bearer accessToken
|
Authorization: Bearer accessToken
|
||||||
|
|
||||||
|
|||||||
+57
-26
@@ -36,6 +36,25 @@ const question = (prompt, def = null) => {
|
|||||||
const resetAddress = await question('Reset Addr', `example.com/reset`);
|
const resetAddress = await question('Reset Addr', `example.com/reset`);
|
||||||
const appPort = await question('App Port', '3200');
|
const appPort = await question('App Port', '3200');
|
||||||
|
|
||||||
|
//configure the database address
|
||||||
|
let dbLocation = '';
|
||||||
|
while (typeof dbLocation != 'string' || /^[le]/i.test(dbLocation[0]) == false) {
|
||||||
|
dbLocation = await question('[l]ocal or [e]xternal database?');
|
||||||
|
}
|
||||||
|
|
||||||
|
let appDBHost = '';
|
||||||
|
let appDBPort = '';
|
||||||
|
|
||||||
|
if (/^[l]/i.test(dbLocation[0])) {
|
||||||
|
appDBHost = 'database';
|
||||||
|
appDBPort = '3306';
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
appDBHost = await question('DB Host');
|
||||||
|
appDBPort = await question('DB Port', '3306');
|
||||||
|
}
|
||||||
|
|
||||||
|
//configure the database account
|
||||||
const appDBUser = await question('DB User', appName);
|
const appDBUser = await question('DB User', appName);
|
||||||
const appDBPass = await question('DB Pass', 'charizard');
|
const appDBPass = await question('DB Pass', 'charizard');
|
||||||
const dbRootPass = await question('DB Root Pass');
|
const dbRootPass = await question('DB Root Pass');
|
||||||
@@ -46,6 +65,7 @@ const question = (prompt, def = null) => {
|
|||||||
const appMailPhysical = await question('Mail Physical');
|
const appMailPhysical = await question('Mail Physical');
|
||||||
|
|
||||||
const appDefaultUser = await question('App Default User', '');
|
const appDefaultUser = await question('App Default User', '');
|
||||||
|
const appDefaultHost = await question('App Default Host', '');
|
||||||
const appDefaultPass = await question('App Default Pass', '');
|
const appDefaultPass = await question('App Default Pass', '');
|
||||||
|
|
||||||
const appSecretAccess = await question('Access Token Secret', uuid(32));
|
const appSecretAccess = await question('Access Token Secret', uuid(32));
|
||||||
@@ -55,21 +75,19 @@ const question = (prompt, def = null) => {
|
|||||||
|
|
||||||
//generate the files
|
//generate the files
|
||||||
const ymlfile = `
|
const ymlfile = `
|
||||||
version: '3'
|
|
||||||
|
|
||||||
services:
|
services:
|
||||||
${appName}:
|
${appName}:
|
||||||
build:
|
build:
|
||||||
context: .
|
context: .
|
||||||
ports:
|
ports:
|
||||||
- "${appPort}"
|
- ${appPort}
|
||||||
labels:
|
labels:
|
||||||
- "traefik.enable=true"
|
- traefik.enable=true
|
||||||
- "traefik.http.routers.${appName}router.rule=Host(\`${appWebAddress}\`)"
|
- traefik.http.routers.${appName}router.rule=Host(\`${appWebAddress}\`)
|
||||||
- "traefik.http.routers.${appName}router.entrypoints=websecure"
|
- traefik.http.routers.${appName}router.entrypoints=websecure
|
||||||
- "traefik.http.routers.${appName}router.tls.certresolver=myresolver"
|
- traefik.http.routers.${appName}router.tls.certresolver=myresolver
|
||||||
- "traefik.http.routers.${appName}router.service=${appName}service@docker"
|
- traefik.http.routers.${appName}router.service=${appName}service@docker
|
||||||
- "traefik.http.services.${appName}service.loadbalancer.server.port=${appPort}"
|
- traefik.http.services.${appName}service.loadbalancer.server.port=${appPort}
|
||||||
environment:
|
environment:
|
||||||
- WEB_PROTOCOL=${appWebProtocol}
|
- WEB_PROTOCOL=${appWebProtocol}
|
||||||
- WEB_ORIGIN=${appWebOrigin}
|
- WEB_ORIGIN=${appWebOrigin}
|
||||||
@@ -77,7 +95,8 @@ services:
|
|||||||
- HOOK_POST_VALIDATION_ARRAY=${postValidationHookArray}
|
- HOOK_POST_VALIDATION_ARRAY=${postValidationHookArray}
|
||||||
- WEB_RESET_ADDRESS=${resetAddress}
|
- WEB_RESET_ADDRESS=${resetAddress}
|
||||||
- WEB_PORT=${appPort}
|
- WEB_PORT=${appPort}
|
||||||
- DB_HOSTNAME=database
|
- DB_HOSTNAME=${appDBHost}
|
||||||
|
- DB_PORTNAME=${appDBPort}
|
||||||
- DB_DATABASE=${appName}
|
- DB_DATABASE=${appName}
|
||||||
- DB_USERNAME=${appDBUser}
|
- DB_USERNAME=${appDBUser}
|
||||||
- DB_PASSWORD=${appDBPass}
|
- DB_PASSWORD=${appDBPass}
|
||||||
@@ -87,17 +106,23 @@ services:
|
|||||||
- MAIL_PASSWORD=${appMailPass}
|
- MAIL_PASSWORD=${appMailPass}
|
||||||
- MAIL_PHYSICAL=${appMailPhysical}
|
- MAIL_PHYSICAL=${appMailPhysical}
|
||||||
- ADMIN_DEFAULT_USERNAME=${appDefaultUser}
|
- ADMIN_DEFAULT_USERNAME=${appDefaultUser}
|
||||||
|
- ADMIN_DEFAULT_HOSTNAME=${appDefaultHost}
|
||||||
- ADMIN_DEFAULT_PASSWORD=${appDefaultPass}
|
- ADMIN_DEFAULT_PASSWORD=${appDefaultPass}
|
||||||
- SECRET_ACCESS=${appSecretAccess}
|
- SECRET_ACCESS=${appSecretAccess}
|
||||||
- SECRET_REFRESH=${appSecretRefresh}
|
- SECRET_REFRESH=${appSecretRefresh}
|
||||||
|
volumes:
|
||||||
|
- /etc/timezone:/etc/timezone:ro
|
||||||
|
- /etc/localtime:/etc/localtime:ro
|
||||||
networks:
|
networks:
|
||||||
- app-network
|
- app-network${ appDBHost != 'database' ? '' : `
|
||||||
depends_on:
|
depends_on:
|
||||||
- database
|
- database
|
||||||
|
|
||||||
database:
|
database:
|
||||||
image: mariadb:latest
|
image: mariadb:latest
|
||||||
environment:
|
environment:
|
||||||
MYSQL_DATABASE: ${appName}
|
MYSQL_DATABASE: ${appName}
|
||||||
|
MYSQL_TCP_PORT: ${appDBPort}
|
||||||
MYSQL_USER: ${appDBUser}
|
MYSQL_USER: ${appDBUser}
|
||||||
MYSQL_PASSWORD: ${appDBPass}
|
MYSQL_PASSWORD: ${appDBPass}
|
||||||
MYSQL_ROOT_PASSWORD: ${dbRootPass}
|
MYSQL_ROOT_PASSWORD: ${dbRootPass}
|
||||||
@@ -106,34 +131,40 @@ services:
|
|||||||
volumes:
|
volumes:
|
||||||
- ./mysql:/var/lib/mysql
|
- ./mysql:/var/lib/mysql
|
||||||
- ./startup.sql:/docker-entrypoint-initdb.d/startup.sql:ro
|
- ./startup.sql:/docker-entrypoint-initdb.d/startup.sql:ro
|
||||||
|
- /etc/timezone:/etc/timezone:ro
|
||||||
|
- /etc/localtime:/etc/localtime:ro`}
|
||||||
|
|
||||||
traefik_${appName}:
|
traefik_${appName}:
|
||||||
container_name: ${appName}_traefik
|
container_name: ${appName}_traefik
|
||||||
image: "traefik:v2.4"
|
image: traefik:latest
|
||||||
container_name: "traefik"
|
container_name: traefik
|
||||||
command:
|
command:
|
||||||
- "--log.level=ERROR"
|
- --log.level=ERROR
|
||||||
- "--api.insecure=false"
|
- --api.insecure=false
|
||||||
- "--providers.docker=true"
|
- --providers.docker=true
|
||||||
- "--providers.docker.exposedbydefault=false"
|
- --providers.docker.exposedbydefault=false
|
||||||
- "--entrypoints.websecure.address=:443"
|
- --entrypoints.websecure.address=:443
|
||||||
- "--certificatesresolvers.myresolver.acme.tlschallenge=true"
|
- --certificatesresolvers.myresolver.acme.tlschallenge=true
|
||||||
- "--certificatesresolvers.myresolver.acme.email=${supportEmail}"
|
- --certificatesresolvers.myresolver.acme.email=${supportEmail}
|
||||||
- "--certificatesresolvers.myresolver.acme.storage=/letsencrypt/acme.json"
|
- --certificatesresolvers.myresolver.acme.storage=/letsencrypt/acme.json
|
||||||
ports:
|
ports:
|
||||||
- "80:80"
|
- 80:80
|
||||||
- "443:443"
|
- 443:443
|
||||||
volumes:
|
volumes:
|
||||||
- "./letsencrypt:/letsencrypt"
|
- ./letsencrypt:/letsencrypt
|
||||||
- "/var/run/docker.sock:/var/run/docker.sock:ro"
|
- /var/run/docker.sock:/var/run/docker.sock:ro
|
||||||
|
- /etc/timezone:/etc/timezone:ro
|
||||||
|
- /etc/localtime:/etc/localtime:ro
|
||||||
networks:
|
networks:
|
||||||
- app-network
|
- app-network
|
||||||
|
|
||||||
networks:
|
networks:
|
||||||
app-network:
|
app-network:
|
||||||
driver: bridge
|
driver: bridge
|
||||||
`;
|
`;
|
||||||
|
|
||||||
const dockerfile = `
|
const dockerfile = `
|
||||||
FROM node:18-bullseye-slim
|
FROM node:22-bookworm-slim
|
||||||
WORKDIR "/app"
|
WORKDIR "/app"
|
||||||
COPY package*.json ./
|
COPY package*.json ./
|
||||||
RUN npm install --production
|
RUN npm install --production
|
||||||
|
|||||||
Generated
+849
-560
File diff suppressed because it is too large
Load Diff
+13
-13
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "auth-server",
|
"name": "auth-server",
|
||||||
"version": "1.7.6",
|
"version": "1.8.7",
|
||||||
"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": {
|
||||||
@@ -13,25 +13,25 @@
|
|||||||
"url": "git+https://github.com/krgamestudios/auth-server.git"
|
"url": "git+https://github.com/krgamestudios/auth-server.git"
|
||||||
},
|
},
|
||||||
"author": "Kayne Ruse",
|
"author": "Kayne Ruse",
|
||||||
"license": "ISC",
|
"license": "Zlib",
|
||||||
"bugs": {
|
"bugs": {
|
||||||
"url": "https://github.com/krgamestudios/auth-server/issues"
|
"url": "https://github.com/krgamestudios/auth-server/issues"
|
||||||
},
|
},
|
||||||
"homepage": "https://github.com/krgamestudios/auth-server#readme",
|
"homepage": "https://github.com/krgamestudios/auth-server#readme",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"bcryptjs": "^2.4.3",
|
"bcryptjs": "^3.0.2",
|
||||||
"cookie-parser": "^1.4.6",
|
"cookie-parser": "^1.4.7",
|
||||||
"cors": "^2.8.5",
|
"cors": "^2.8.5",
|
||||||
"dotenv": "^16.0.3",
|
"dotenv": "^17.2.1",
|
||||||
"express": "^4.18.2",
|
"express": "^5.1.0",
|
||||||
"jsonwebtoken": "^9.0.0",
|
"jsonwebtoken": "^9.0.2",
|
||||||
"mariadb": "^3.1.1",
|
"mariadb": "^3.4.5",
|
||||||
"node-cron": "^3.0.2",
|
"node-cron": "^4.2.1",
|
||||||
"node-fetch": "^2.6.9",
|
"node-fetch": "^3.3.2",
|
||||||
"nodemailer": "^6.9.1",
|
"nodemailer": "^7.0.5",
|
||||||
"sequelize": "^6.31.1"
|
"sequelize": "^6.37.7"
|
||||||
},
|
},
|
||||||
"devDependencies": {
|
"devDependencies": {
|
||||||
"nodemon": "^2.0.22"
|
"nodemon": "^3.1.10"
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,7 +7,7 @@ module.exports = async () => {
|
|||||||
await sequelize.sync(); //this whole file is just one big BUGFIX
|
await sequelize.sync(); //this whole file is just one big BUGFIX
|
||||||
|
|
||||||
//validate env variables
|
//validate env variables
|
||||||
if (!process.env.ADMIN_DEFAULT_USERNAME || !process.env.ADMIN_DEFAULT_PASSWORD) {
|
if (!process.env.ADMIN_DEFAULT_USERNAME || !process.env.ADMIN_DEFAULT_HOSTNAME || !process.env.ADMIN_DEFAULT_PASSWORD) {
|
||||||
//skip this if arguments are missing
|
//skip this if arguments are missing
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@@ -25,9 +25,8 @@ module.exports = async () => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
if (adminRecord == null) {
|
if (adminRecord == null) {
|
||||||
const webAddress = process.env.WEB_ADDRESS == 'localhost:3000' ? 'example.com' : process.env.WEB_ADDRESS; //can't log in as "localhost"
|
|
||||||
await accounts.create({
|
await accounts.create({
|
||||||
email: `${process.env.ADMIN_DEFAULT_USERNAME}@${webAddress}`,
|
email: `${process.env.ADMIN_DEFAULT_USERNAME}@${process.env.ADMIN_DEFAULT_HOSTNAME}`,
|
||||||
username: `${process.env.ADMIN_DEFAULT_USERNAME}`,
|
username: `${process.env.ADMIN_DEFAULT_USERNAME}`,
|
||||||
hash: await bcrypt.hash(`${process.env.ADMIN_DEFAULT_PASSWORD}`, await bcrypt.genSalt(11)),
|
hash: await bcrypt.hash(`${process.env.ADMIN_DEFAULT_PASSWORD}`, await bcrypt.genSalt(11)),
|
||||||
type: 'normal',
|
type: 'normal',
|
||||||
@@ -35,6 +34,6 @@ module.exports = async () => {
|
|||||||
mod: true
|
mod: true
|
||||||
});
|
});
|
||||||
|
|
||||||
console.warn(`Created default admin account (email: ${process.env.ADMIN_DEFAULT_USERNAME}@${webAddress}; password: ${process.env.ADMIN_DEFAULT_PASSWORD})`);
|
console.warn(`Created default admin account (email: ${process.env.ADMIN_DEFAULT_USERNAME}@${process.env.ADMIN_DEFAULT_HOSTNAME}; password: ${process.env.ADMIN_DEFAULT_PASSWORD})`);
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|||||||
+11
-6
@@ -5,15 +5,13 @@ const { accounts } = require('../database/models');
|
|||||||
|
|
||||||
//middleware
|
//middleware
|
||||||
const tokenAuth = require('../utilities/token-auth');
|
const tokenAuth = require('../utilities/token-auth');
|
||||||
|
const tokenDecode = require('../utilities/token-decode');
|
||||||
|
|
||||||
//signup -> validate -> login all without a token
|
//signup -> validate -> login all without a token
|
||||||
router.post('/signup', require('./signup'));
|
router.post('/signup', require('./signup'));
|
||||||
router.get('/validation', require('./validation'));
|
router.get('/validation', require('./validation'));
|
||||||
router.post('/login', require('./login'));
|
router.post('/login', require('./login'));
|
||||||
|
|
||||||
//refresh token
|
|
||||||
router.post('/token', require('./token'));
|
|
||||||
|
|
||||||
//password recover and reset
|
//password recover and reset
|
||||||
router.post('/recover', require('./password-recover'));
|
router.post('/recover', require('./password-recover'));
|
||||||
router.get('/reset', require('./password-redirect'));
|
router.get('/reset', require('./password-redirect'));
|
||||||
@@ -22,13 +20,14 @@ router.patch('/reset', require('./password-reset'));
|
|||||||
//logouts allowed when banned, and when the token itself is invalid
|
//logouts allowed when banned, and when the token itself is invalid
|
||||||
router.delete('/logout', require('./logout'));
|
router.delete('/logout', require('./logout'));
|
||||||
|
|
||||||
//middleware
|
//authenticate token
|
||||||
router.use(tokenAuth);
|
router.use(tokenDecode);
|
||||||
|
|
||||||
|
//middleware
|
||||||
router.use(async (req, res, next) => {
|
router.use(async (req, res, next) => {
|
||||||
const record = await accounts.findOne({
|
const record = await accounts.findOne({
|
||||||
where: {
|
where: {
|
||||||
email: req.user.email || ''
|
email: req.user?.email || ''
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -43,6 +42,12 @@ router.use(async (req, res, next) => {
|
|||||||
next();
|
next();
|
||||||
});
|
});
|
||||||
|
|
||||||
|
//refresh token
|
||||||
|
router.post('/token', require('./token'));
|
||||||
|
|
||||||
|
//authenticate token
|
||||||
|
router.use(tokenAuth);
|
||||||
|
|
||||||
//basic account management (needs a token)
|
//basic account management (needs a token)
|
||||||
router.get('/account', require('./account-query'));
|
router.get('/account', require('./account-query'));
|
||||||
router.patch('/account', require('./account-update'));
|
router.patch('/account', require('./account-update'));
|
||||||
|
|||||||
@@ -49,7 +49,7 @@ const route = async (req, res) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//generate the JWTs
|
//generate the JWTs
|
||||||
const { accessToken, refreshToken } = tokenGenerateRefresh(account.index, account.email, account.username, account.type, account.admin, account.mod);
|
const { accessToken, refreshToken } = await tokenGenerateRefresh(account.index, account.email, account.username, account.type, account.admin, account.mod);
|
||||||
|
|
||||||
//set the cookie
|
//set the cookie
|
||||||
res.cookie('refreshToken', refreshToken, { path: '/', httpOnly: true, secure: true, sameSite: 'none', maxAge: 60 * 60 * 24 * 30 * 1000 }); //30 days
|
res.cookie('refreshToken', refreshToken, { path: '/', httpOnly: true, secure: true, sameSite: 'none', maxAge: 60 * 60 * 24 * 30 * 1000 }); //30 days
|
||||||
|
|||||||
+16
-2
@@ -22,7 +22,7 @@ const route = async (req, res) => {
|
|||||||
//script throttle
|
//script throttle
|
||||||
const throttle = await checkThrottle(req.body.email);
|
const throttle = await checkThrottle(req.body.email);
|
||||||
if (throttle) {
|
if (throttle) {
|
||||||
console.warn(`Spam attack detected: ${req.body.email} (${req.body.username})`);
|
console.warn(`Spam Throttled\t${req.body.email} (${req.body.username})`);
|
||||||
return res.status(401).send(throttle);
|
return res.status(401).send(throttle);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -121,7 +121,21 @@ const checkThrottle = async (email) => {
|
|||||||
}
|
}
|
||||||
|
|
||||||
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,
|
||||||
|
|||||||
@@ -1,10 +1,8 @@
|
|||||||
const jwt = require('jsonwebtoken');
|
|
||||||
|
|
||||||
const tokenRefresh = require('../utilities/token-refresh');
|
const tokenRefresh = require('../utilities/token-refresh');
|
||||||
|
|
||||||
//auth/token
|
//auth/token
|
||||||
module.exports = async (req, res) => {
|
module.exports = async (req, res) => {
|
||||||
return tokenRefresh(req.cookies.refreshToken || '', (err, accessToken, refreshToken) => {
|
return await tokenRefresh(req.cookies.refreshToken || '', (err, accessToken, refreshToken) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
return res.status(err).end();
|
return res.status(err).end();
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
const { pendingSignups, accounts } = require('../database/models');
|
const { pendingSignups, accounts } = require('../database/models');
|
||||||
const fetch = require('node-fetch');
|
const fetch = (...args) => import('node-fetch').then(({default: fetch}) => fetch(...args));
|
||||||
const jwt = require('jsonwebtoken');
|
const jwt = require('jsonwebtoken');
|
||||||
|
|
||||||
//auth/validation
|
//auth/validation
|
||||||
@@ -44,7 +44,7 @@ const route = async (req, res) => {
|
|||||||
hooks = JSON.parse(process.env.HOOK_POST_VALIDATION_ARRAY);
|
hooks = JSON.parse(process.env.HOOK_POST_VALIDATION_ARRAY);
|
||||||
|
|
||||||
if (!Array.isArray(hooks)) {
|
if (!Array.isArray(hooks)) {
|
||||||
throw 'isArray() check failed';
|
throw 'post validation hook isArray() check failed';
|
||||||
}
|
}
|
||||||
|
|
||||||
//authenticate the hooks
|
//authenticate the hooks
|
||||||
|
|||||||
@@ -2,11 +2,10 @@ const Sequelize = require('sequelize');
|
|||||||
|
|
||||||
const sequelize = new Sequelize(process.env.DB_DATABASE, process.env.DB_USERNAME, process.env.DB_PASSWORD, {
|
const sequelize = new Sequelize(process.env.DB_DATABASE, process.env.DB_USERNAME, process.env.DB_PASSWORD, {
|
||||||
host: process.env.DB_HOSTNAME,
|
host: process.env.DB_HOSTNAME,
|
||||||
|
port: process.env.DB_PORTNAME,
|
||||||
dialect: 'mariadb',
|
dialect: 'mariadb',
|
||||||
timezone: process.env.DB_TIMEZONE,
|
timezone: process.env.DB_TIMEZONE,
|
||||||
logging: process.env.DB_LOGGING ? console.log : false
|
logging: process.env.DB_LOGGING ? console.log : false
|
||||||
});
|
});
|
||||||
|
|
||||||
sequelize.sync();
|
|
||||||
|
|
||||||
module.exports = sequelize;
|
module.exports = sequelize;
|
||||||
@@ -1,6 +1,8 @@
|
|||||||
const Sequelize = require('sequelize');
|
const Sequelize = require('sequelize');
|
||||||
const sequelize = require('..');
|
const sequelize = require('..');
|
||||||
|
|
||||||
|
//DOCS: this isn't set by anything - it's a stub for now
|
||||||
|
|
||||||
module.exports = sequelize.define('bannedIPAddresses', {
|
module.exports = sequelize.define('bannedIPAddresses', {
|
||||||
content: {
|
content: {
|
||||||
type: 'varchar(320)',
|
type: 'varchar(320)',
|
||||||
|
|||||||
+3
-2
@@ -24,7 +24,7 @@ app.use(cookieParser());
|
|||||||
const database = require('./database');
|
const database = require('./database');
|
||||||
|
|
||||||
//ip-based management
|
//ip-based management
|
||||||
app.use(require('./utilities/banned-up-addresses-middleware'));
|
app.use(require('./utilities/banned-ip-addresses-middleware'));
|
||||||
|
|
||||||
//access the admin
|
//access the admin
|
||||||
app.use('/admin', require('./admin'));
|
app.use('/admin', require('./admin'));
|
||||||
@@ -33,7 +33,7 @@ app.use('/admin', require('./admin'));
|
|||||||
app.use('/auth', require('./auth'));
|
app.use('/auth', require('./auth'));
|
||||||
|
|
||||||
//error on access
|
//error on access
|
||||||
app.get('*', (req, res) => {
|
app.get('/{*any}', (req, res) => {
|
||||||
res.redirect('https://github.com/krgamestudios/auth-server');
|
res.redirect('https://github.com/krgamestudios/auth-server');
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -41,4 +41,5 @@ app.get('*', (req, res) => {
|
|||||||
server.listen(process.env.WEB_PORT || 3200, async (err) => {
|
server.listen(process.env.WEB_PORT || 3200, async (err) => {
|
||||||
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}`);
|
||||||
|
console.log(`database located at ${process.env.DB_HOSTNAME || '<default>'}:${process.env.DB_PORTNAME || '<default>'}`);
|
||||||
});
|
});
|
||||||
|
|||||||
+10
-2
@@ -10,16 +10,24 @@ module.exports = async (req, res, next) => {
|
|||||||
content: address,
|
content: address,
|
||||||
|
|
||||||
expiry: {
|
expiry: {
|
||||||
[Op.gt]: Date.now()
|
[Op.or]: {
|
||||||
|
//future or forever
|
||||||
|
[Op.gt]: Date.now(),
|
||||||
|
[Op.eq]: null,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
//log the access timestamp
|
||||||
|
const date = new Date();
|
||||||
|
|
||||||
if (!!record) {
|
if (!!record) {
|
||||||
|
console.log(`IP blocked\t${address}\t\t\t${date.toTimeString()}`);
|
||||||
return res.status(403).send("IP address banned");
|
return res.status(403).send("IP address banned");
|
||||||
}
|
}
|
||||||
|
|
||||||
console.log(`IP ${address}`);
|
// console.log(`IP allowed\t${address}\t\t\t${date.toTimeString()}`);
|
||||||
|
|
||||||
return next();
|
return next();
|
||||||
};
|
};
|
||||||
@@ -6,7 +6,7 @@ module.exports = (req, res, next) => {
|
|||||||
const accessToken = authHeader?.split(' ')[1]; //'Bearer token'
|
const accessToken = authHeader?.split(' ')[1]; //'Bearer token'
|
||||||
|
|
||||||
if (!accessToken) {
|
if (!accessToken) {
|
||||||
return res.status(401).send('No access token found');
|
return res.status(401).send('No access token provided');
|
||||||
}
|
}
|
||||||
|
|
||||||
return jwt.verify(accessToken, process.env.SECRET_ACCESS, (err, user) => {
|
return jwt.verify(accessToken, process.env.SECRET_ACCESS, (err, user) => {
|
||||||
|
|||||||
@@ -0,0 +1,17 @@
|
|||||||
|
const jwt = require('jsonwebtoken');
|
||||||
|
|
||||||
|
//middleware to decode the JWT token
|
||||||
|
module.exports = (req, res, next) => {
|
||||||
|
const authHeader = req.headers['authorization'];
|
||||||
|
const accessToken = authHeader?.split(' ')[1]; //'Bearer token'
|
||||||
|
|
||||||
|
if (!accessToken) {
|
||||||
|
return res.status(401).send('No access token provided');
|
||||||
|
}
|
||||||
|
|
||||||
|
const decoded = jwt.decode(accessToken);
|
||||||
|
|
||||||
|
req.user = decoded;
|
||||||
|
|
||||||
|
return next();
|
||||||
|
};
|
||||||
@@ -1,7 +1,7 @@
|
|||||||
const { tokens } = require('../database/models');
|
const { tokens } = require('../database/models');
|
||||||
|
|
||||||
module.exports = (refreshToken) => {
|
module.exports = async (refreshToken) => {
|
||||||
tokens.destroy({
|
await tokens.destroy({
|
||||||
where: {
|
where: {
|
||||||
token: refreshToken || ''
|
token: refreshToken || ''
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,7 +2,7 @@ const jwt = require('jsonwebtoken');
|
|||||||
const { tokens } = require('../database/models');
|
const { tokens } = require('../database/models');
|
||||||
|
|
||||||
//generates a JWT token based on the given arguments
|
//generates a JWT token based on the given arguments
|
||||||
module.exports = (index, email, username, type, admin, mod) => {
|
module.exports = async (index, email, username, type, admin, mod) => {
|
||||||
const content = {
|
const content = {
|
||||||
index,
|
index,
|
||||||
email,
|
email,
|
||||||
@@ -16,7 +16,7 @@ module.exports = (index, email, username, type, admin, mod) => {
|
|||||||
const accessToken = jwt.sign(content, process.env.SECRET_ACCESS, { expiresIn: '10m', issuer: 'auth' });
|
const accessToken = jwt.sign(content, process.env.SECRET_ACCESS, { expiresIn: '10m', issuer: 'auth' });
|
||||||
const refreshToken = jwt.sign(content, process.env.SECRET_REFRESH, { expiresIn: '30d', issuer: 'auth' });
|
const refreshToken = jwt.sign(content, process.env.SECRET_REFRESH, { expiresIn: '30d', issuer: 'auth' });
|
||||||
|
|
||||||
tokens.create({ token: refreshToken, email: email });
|
await tokens.create({ token: refreshToken, email: email });
|
||||||
|
|
||||||
return { accessToken, refreshToken };
|
return { accessToken, refreshToken };
|
||||||
};
|
};
|
||||||
@@ -19,15 +19,15 @@ module.exports = async (oldRefreshToken, callback) => {
|
|||||||
return callback(403);
|
return callback(403);
|
||||||
}
|
}
|
||||||
|
|
||||||
jwt.verify(oldRefreshToken, process.env.SECRET_REFRESH, (err, user) => {
|
jwt.verify(oldRefreshToken, process.env.SECRET_REFRESH, async (err, user) => {
|
||||||
if (err) {
|
if (err) {
|
||||||
return callback(403);
|
return callback(403);
|
||||||
}
|
}
|
||||||
|
|
||||||
const { accessToken, refreshToken } = generate(user.index, user.email, user.username, user.type, user.admin, user.mod);
|
await destroy(oldRefreshToken);
|
||||||
|
|
||||||
destroy(oldRefreshToken);
|
const { accessToken, refreshToken } = await generate(user.index, user.email, user.username, user.type, user.admin, user.mod);
|
||||||
|
|
||||||
return callback(null, accessToken, refreshToken);
|
return await callback(null, accessToken, refreshToken);
|
||||||
});
|
});
|
||||||
};
|
};
|
||||||
@@ -1,4 +1,4 @@
|
|||||||
#use this while debugging
|
#use this while debugging
|
||||||
CREATE DATABASE IF NOT EXISTS auth;
|
CREATE DATABASE auth;
|
||||||
CREATE USER IF NOT EXISTS 'auth'@'%' IDENTIFIED BY 'charizard';
|
CREATE USER 'auth'@'%' IDENTIFIED BY 'charizard';
|
||||||
GRANT ALL PRIVILEGES ON auth.* TO 'auth'@'%';
|
GRANT ALL PRIVILEGES ON auth.* TO 'auth'@'%';
|
||||||
|
|||||||
@@ -1 +0,0 @@
|
|||||||
ALTER TABLE `accounts` CHANGE `id` `index` INT( 11 ) NOT NULL AUTO_INCREMENT;
|
|
||||||
@@ -1 +0,0 @@
|
|||||||
DROP TABLE tokens;
|
|
||||||
@@ -1,5 +1,5 @@
|
|||||||
import React, { useState, useEffect, createContext } from 'react';
|
import React, { useState, useEffect, createContext } from 'react';
|
||||||
import decode from 'jwt-decode';
|
import { jwtDecode } from 'jwt-decode';
|
||||||
|
|
||||||
export const TokenContext = createContext();
|
export const TokenContext = createContext();
|
||||||
|
|
||||||
@@ -25,18 +25,13 @@ const TokenProvider = props => {
|
|||||||
localStorage.setItem("accessToken", accessToken);
|
localStorage.setItem("accessToken", accessToken);
|
||||||
}, [accessToken]);
|
}, [accessToken]);
|
||||||
|
|
||||||
//force a logout if refresh token is too old
|
|
||||||
if (accessToken && (new Date(Date.now() - 60 * 60 * 24 * 30 * 1000).getTime() > decode(accessToken).exp * 1000)) {
|
|
||||||
forceLogout();
|
|
||||||
}
|
|
||||||
|
|
||||||
//wrap the default fetch function
|
//wrap the default fetch function
|
||||||
const tokenFetch = async (url, options) => {
|
const tokenFetch = async (url, options) => {
|
||||||
//use this?
|
//use this?
|
||||||
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(jwtDecode(accessToken).exp) < Date.now() / 1000;
|
||||||
|
|
||||||
if (expired) {
|
if (expired) {
|
||||||
//BUGFIX: if logging out, just skip over the refresh token
|
//BUGFIX: if logging out, just skip over the refresh token
|
||||||
@@ -53,6 +48,9 @@ const TokenProvider = props => {
|
|||||||
//ping the auth server for a new access token
|
//ping the auth server for a new access token
|
||||||
const response = await fetch(`${process.env.AUTH_URI}/auth/token`, {
|
const response = await fetch(`${process.env.AUTH_URI}/auth/token`, {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
|
headers: {
|
||||||
|
'Authorization': `Bearer ${bearer}`
|
||||||
|
},
|
||||||
credentials: 'include'
|
credentials: 'include'
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -84,13 +82,19 @@ const TokenProvider = props => {
|
|||||||
|
|
||||||
//access the refreshed token via callback
|
//access the refreshed token via callback
|
||||||
const tokenCallback = async (cb) => {
|
const tokenCallback = async (cb) => {
|
||||||
|
//use this?
|
||||||
|
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(jwtDecode(accessToken).exp) < Date.now() / 1000;
|
||||||
|
|
||||||
if (expired) {
|
if (expired) {
|
||||||
//ping the auth server for a new token
|
//ping the auth server for a new token
|
||||||
const response = await fetch(`${process.env.AUTH_URI}/auth/token`, {
|
const response = await fetch(`${process.env.AUTH_URI}/auth/token`, {
|
||||||
method: 'POST',
|
method: 'POST',
|
||||||
|
headers: {
|
||||||
|
'Authorization': `Bearer ${bearer}`
|
||||||
|
},
|
||||||
credentials: 'include'
|
credentials: 'include'
|
||||||
});
|
});
|
||||||
|
|
||||||
@@ -115,7 +119,7 @@ const TokenProvider = props => {
|
|||||||
};
|
};
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<TokenContext.Provider value={{ accessToken, setAccessToken, tokenFetch, tokenCallback, getPayload: () => decode(accessToken) }}>
|
<TokenContext.Provider value={{ accessToken, setAccessToken, tokenFetch, tokenCallback, getPayload: () => jwtDecode(accessToken) }}>
|
||||||
{props.children}
|
{props.children}
|
||||||
</TokenContext.Provider>
|
</TokenContext.Provider>
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user