Resume
/
sub-manager-backend
2
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Compare commits

merge into: Resume:master
Branches Tags
Resume:master
Resume:auth
Resume:DO-jwt-tut
Resume:jwt
...
pull from: Resume:auth
Branches Tags
Resume:auth
Resume:DO-jwt-tut
Resume:jwt
Resume:master

1 Commits
master ... auth

Author SHA1 Message Date
andrzej f40dbb2d72 import auth related files 2024-06-10 11:50:46 +02:00
10 changed files with 1212 additions and 105 deletions
Show Stats Expand all files Collapse all files

80
auth/auth.mjs Normal file
View File

@ -0,0 +1,80 @@
import passport from "passport";
import { Strategy as localStrategy } from "passport-local";
import { encryptPwd, pwdIsValid } from "../model/model.mjs";
import { Strategy as JWTstrategy, ExtractJwt } from "passport-jwt";
import { userDb } from "../db.mjs";
passport.use(
"signup",
new localStrategy(
{
usernameField: "username",
passwordField: "password",
},
async (username, password, done) => {
console.log("signup auth strategy has begun");
try {
const encryptedPwd = await encryptPwd(password);
const user = await userDb("users")
.insert({ username: username, password: encryptedPwd })
.returning(["username", "password"]);
console.log(`user: ${user}`);
return done(null, user);
} catch (err) {
console.error(err);
done(err);
}
},
),
);
passport.use(
"login",
new localStrategy(
{
usernameField: "username",
passwordField: "password",
session: false,
},
async (email, password, done) => {
console.log("local strategy called");
try {
let returnedUser = await userDb("users")
.select("username", "password")
.where({ username: email });
const user = returnedUser[0];
console.log(`user: ${user}`);
if (!user || returnedUser.length === 0) {
return done(null, false, { message: "user not found" });
}
const validate = await pwdIsValid(password, user);
console.log(`isValidPassword? ${validate}`);
if (!validate) {
return done(null, false, { message: "wrong password" });
}
return done(null, user, { message: "logged in successfully" });
} catch (error) {
return done(error);
}
},
),
);
passport.use(
new JWTstrategy(
{
secretOrKey: "TOP_SECRET",
jwtFromRequest: ExtractJwt.fromAuthHeaderWithScheme("secret_token"),
},
async (token, done) => {
try {
return done(null, token.user);
} catch (error) {
done(error);
}
},
),
);

10
curl-res Normal file
View File

@ -0,0 +1,10 @@
<!DOCTYPE html>
<html lang="en">
<head>
<meta charset="utf-8">
<title>Error</title>
</head>
<body>
<pre>SyntaxError: Unexpected token &#39;e&#39;, &quot;email:demo@demo.test&quot; is not valid JSON<br> &nbsp; &nbsp;at JSON.parse (&lt;anonymous&gt;)<br> &nbsp; &nbsp;at createStrictSyntaxError (/home/andrzej/dev/sub-manager-backend/node_modules/body-parser/lib/types/json.js:169:10)<br> &nbsp; &nbsp;at parse (/home/andrzej/dev/sub-manager-backend/node_modules/body-parser/lib/types/json.js:86:15)<br> &nbsp; &nbsp;at /home/andrzej/dev/sub-manager-backend/node_modules/body-parser/lib/read.js:128:18<br> &nbsp; &nbsp;at AsyncResource.runInAsyncScope (node:async_hooks:206:9)<br> &nbsp; &nbsp;at invokeCallback (/home/andrzej/dev/sub-manager-backend/node_modules/raw-body/index.js:238:16)<br> &nbsp; &nbsp;at done (/home/andrzej/dev/sub-manager-backend/node_modules/raw-body/index.js:227:7)<br> &nbsp; &nbsp;at IncomingMessage.onEnd (/home/andrzej/dev/sub-manager-backend/node_modules/raw-body/index.js:287:7)<br> &nbsp; &nbsp;at IncomingMessage.emit (node:events:511:28)<br> &nbsp; &nbsp;at endReadableNT (node:internal/streams/readable:1367:12)</pre>
</body>
</html>

28
db.mjs
View File

@ -1,20 +1,24 @@
import knex from "knex";
export const db = knex({
client: 'sqlite3',
client: "sqlite3",
connection: {
filename: "./submissions"
filename: "./submissions.db",
},
useNullAsDefault: true
})
export const testDb = knex({
client: 'sqlite3',
useNullAsDefault: true,
});
export const userDb = knex({
client: "sqlite3",
connection: {
filename: "./test.db"
filename: "./users.db",
},
useNullAsDefault: true
})
useNullAsDefault: true,
});
export const testDb = knex({
client: "sqlite3",
connection: {
filename: "./test.db",
},
useNullAsDefault: true,
});

9
model/model.mjs Normal file
View File

@ -0,0 +1,9 @@
import bcrypt from "bcrypt";
export async function encryptPwd(pwd) {
return Promise.resolve(bcrypt.hash(pwd, 10));
}
export async function pwdIsValid(pwd, user) {
return Promise.resolve(bcrypt.compare(pwd, user.password));
}

1125
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

7
package.json
View File

@ -9,16 +9,21 @@
"author": "Andrzej Stepien",
"license": "GPL-3.0-or-later",
"dependencies": {
"bcrypt": "^5.1.1",
"body-parser": "^1.20.2",
"chai": "^4.3.8",
"chai-as-promised": "^7.1.1",
"chai-http": "^4.4.0",
"cors": "^2.8.5",
"express": "^4.18.2",
"express": "^4.19.2",
"jsonwebtoken": "^9.0.2",
"knex": "^2.5.1",
"lodash": "^4.17.21",
"luxon": "^3.4.3",
"mocha": "^10.2.0",
"passport": "^0.7.0",
"passport-jwt": "^4.0.1",
"passport-local": "^1.0.0",
"pino": "^8.15.0",
"pino-http": "^8.5.0",
"sqlite3": "^5.1.6"

46
server.mjs
View File

@ -1,36 +1,34 @@
import express from "express"
import pinoHTTP from 'pino-http'
import express from "express";
import pinoHTTP from "pino-http";
import logger from "./logger.mjs";
import bodyParser from "body-parser";
import passport from "passport";
import "./auth/auth.mjs";
import { Data } from "./objects/Data.mjs";
import { db } from "./db.mjs";
import { getEndpoints, postEndpoints } from "./objects/Endpoints.mjs";
import cors from 'cors'
import cors from "cors";
const app = express()
const port = 4000
const corsOptions={
origin: ['http://localhost:5173']
}
app.use(cors())
app.use(pinoHTTP({logger}))
app.use(bodyParser.json())
const data = new Data(db)
await data.init()
app.use('/api',getEndpoints(data))
app.use('/api',postEndpoints(db,data) )
const app = express();
app.use(passport.initialize());
const port = 4000;
app.use(cors());
app.use(pinoHTTP({ logger }));
app.use(bodyParser.json());
const data = new Data(db);
await data.init();
app.use("/api", getEndpoints(data));
app.use(
"/api",
passport.authenticate("jwt", { session: false }),
postEndpoints(db, data),
);
app.listen(port, (err) => {
if (err) logger.error(err);
logger.info("Server listening on PORT " + port)
})
logger.info("Server listening on PORT " + port);
});
export default app
export default app;

BIN
submissions
View File

Binary file not shown.

BIN
submissions.db Normal file
View File

Binary file not shown.

BIN
users.db Normal file
View File

Binary file not shown.