Leahnaya/account
1
0
Fork 0
mirror of https://github.com/PretendoNetwork/account.git synced 2026-09-14 22:37:22 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Added (temporary) Cemu-specific handling

Browse Source
This commit is contained in:
Jonathan Barrow
2021-12-11 07:51:58 -05:00
parent 8e816ff44d
commit 2f69cfc5ac
5 changed files with 49 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/middleware/cemu.js Normal file
View File

@@ -0,0 +1,12 @@
const xmlbuilder = require('xmlbuilder');
const database = require('../database');
async function CemuMiddleware(request, response, next) {
const subdomain = request.subdomains.reverse().join('.');
request.isCemu = subdomain === 'c.account';
return next();
}
module.exports = CemuMiddleware;

6
src/middleware/pnid.js
View File

@@ -8,9 +8,13 @@ async function PNIDMiddleware(request, response, next) {
return next();
}
const [type, token] = headers.authorization.split(' ');
let [type, token] = headers.authorization.split(' ');
let user;
if (request.isCemu) {
token = Buffer.from(token, 'hex').toString('base64');
}
if (type === 'Basic') {
user = await database.getUserBasic(token);
} else {

5
src/services/account/index.js
View File

@@ -2,6 +2,7 @@
const express = require('express');
const subdomain = require('express-subdomain');
const cemuMiddleware = require('../../middleware/cemu');
const pnidMiddleware = require('../../middleware/pnid');
const logger = require('../../../logger');
const routes = require('./routes');
@@ -10,6 +11,7 @@ const routes = require('./routes');
const account = express.Router();
logger.info('[ACCOUNT] Importing middleware');
account.use(cemuMiddleware);
account.use(pnidMiddleware);
// Setup routes
@@ -30,4 +32,7 @@ const router = express.Router();
logger.info('[ACCOUNT] Creating \'account\' subdomain');
router.use(subdomain('account', account));
logger.info('[ACCOUNT] Creating \'c.account\' subdomain');
router.use(subdomain('c.account', account));
module.exports = router;

29
src/services/account/routes/oauth.js
View File

@@ -50,6 +50,16 @@ router.post('/access_token/generate', clientHeaderCheck, async (request, respons
const pnid = await database.getUserByUsername(user_id);
if (!pnid || !bcrypt.compareSync(password, pnid.password)) {
response.status(400);
return response.send(xmlbuilder.create({
error: {
code: '0106',
message: 'Invalid account ID or password'
}
}).end());
}
if (pnid.get('access_level') < 0) {
return response.status(400).send(xmlbuilder.create({
errors: {
@@ -61,16 +71,6 @@ router.post('/access_token/generate', clientHeaderCheck, async (request, respons
}).end());
}
if (!pnid || !bcrypt.compareSync(password, pnid.password)) {
response.status(400);
return response.send(xmlbuilder.create({
error: {
code: '0106',
message: 'Invalid account ID or password'
}
}).end());
}
const cryptoPath = `${__dirname}/../../../../certs/access`;
if (!fs.pathExistsSync(cryptoPath)) {
@@ -99,8 +99,13 @@ router.post('/access_token/generate', clientHeaderCheck, async (request, respons
expire_time: BigInt(Date.now() + (3600 * 1000))
};
const accessToken = util.generateToken(null, accessTokenOptions);
const refreshToken = util.generateToken(null, refreshTokenOptions);
let accessToken = util.generateToken(null, accessTokenOptions);
let refreshToken = util.generateToken(null, refreshTokenOptions);
if (request.isCemu) {
accessToken = Buffer.from(accessToken, 'base64').toString('hex');
refreshToken = Buffer.from(refreshToken, 'base64').toString('hex');
}
response.send(xmlbuilder.create({
OAuth20: {

12
src/services/account/routes/provider.js
View File

@@ -61,7 +61,11 @@ router.get('/service_token/@me', async (request, response) => {
expire_time: BigInt(Date.now() + (3600 * 1000))
};
const serviceToken = util.generateToken(cryptoOptions, tokenOptions);
let serviceToken = util.generateToken(cryptoOptions, tokenOptions);
if (request.isCemu) {
serviceToken = Buffer.from(serviceToken, 'base64').toString('hex');
}
response.send(xmlbuilder.create({
service_token: {
@@ -147,7 +151,11 @@ router.get('/nex_token/@me', async (request, response) => {
return response.send('<errors><error><cause/><code>0008</code><message>Not Found</message></error></errors>');
}
const nexToken = util.generateToken(cryptoOptions, tokenOptions);
let nexToken = util.generateToken(cryptoOptions, tokenOptions);
if (request.isCemu) {
nexToken = Buffer.from(nexToken, 'base64').toString('hex');
}
response.send(xmlbuilder.create({
nex_token: {