17 Commits

Author SHA1 Message Date
e9681fbc9a Merge branch 'main' into develop 2023-05-30 20:23:24 -04:00
4ce4b62fe5 Reduce duplicate code, move shit out to common package 2023-05-30 20:22:55 -04:00
64e1f53f4e Updates as I integrate 2023-05-30 17:44:50 -04:00
efb237885f Merge pull request 'Release 1.0.6' (#4) from develop into main
All checks were successful
continuous-integration/drone/tag Build is passing
Reviewed-on: #4
2023-05-26 21:49:25 +00:00
ec61e29fb0 Tweaks and mergefail fixes
All checks were successful
continuous-integration/drone/pr Build is passing
2023-05-26 17:46:37 -04:00
d97a7d7f95 Merge branch 'main' into develop
Some checks failed
continuous-integration/drone/pr Build is failing
# Conflicts:
#	.npmignore
#	lib/dao/deleteById.ts
#	lib/dao/readOneByRecord.ts
#	lib/dao/readOneByUsername.ts
#	package.json
#	src/dao/auth/deleteById.ts
#	src/dao/auth/readOneByRecord.ts
#	src/dao/auth/readOneByUsername.ts
#	src/dao/create.ts
#	src/dao/deleteById.ts
#	src/dao/readOneByRecord.ts
#	src/dao/readOneByUsername.ts
2023-05-26 17:44:52 -04:00
4bbe520366 Merge pull request 'Add DAO shit for Strategy model, added types for different ops, bump package version' (#3) from feature/ISS-3_-_WebAuthn_Support into develop
Some checks failed
continuous-integration/drone/pr Build is failing
Reviewed-on: #3
2023-05-26 21:40:07 +00:00
e657d09ae5 Add DAO shit for Strategy model, added types for different ops, bump package version
All checks were successful
continuous-integration/drone/pr Build is passing
2023-05-26 17:35:58 -04:00
08293e8c16 .npmignore updates 2023-05-24 13:08:49 -04:00
fdfd8b567a Last try before I force it...
All checks were successful
continuous-integration/drone/pr Build is passing
2023-05-24 12:44:01 -04:00
55c2274a4f Grrrr...
Some checks failed
continuous-integration/drone/pr Build is failing
2023-05-24 12:41:12 -04:00
7d40fdfe74 Bam!
Some checks failed
continuous-integration/drone/pr Build is failing
2023-05-24 12:39:37 -04:00
8e5092b943 Haha!
Some checks failed
continuous-integration/drone/pr Build is failing
2023-05-24 12:35:37 -04:00
35b89062e4 Prettier?
Some checks failed
continuous-integration/drone/pr Build is failing
2023-05-24 10:46:24 -04:00
65e30ba1c7 Prettier...
Some checks failed
continuous-integration/drone/pr Build is failing
2023-05-24 10:33:41 -04:00
40645f58e3 Oops... paths.
Some checks failed
continuous-integration/drone/pr Build is failing
2023-05-24 10:31:38 -04:00
7619899edc Restructuring the folders
Some checks failed
continuous-integration/drone/pr Build is failing
2023-05-24 10:24:15 -04:00
46 changed files with 280 additions and 269 deletions

View File

@@ -1,10 +1,10 @@
.build.yarnrc.yml .build.yarnrc.yml
.drone.yml .drone.yml
.eslintrc* .eslintrc*
.npmrc
.prettierrc* .prettierrc*
.yarnrc.yml .yarnrc.yml
babel.config.* babel.config.*
jest.config.* jest.config.*
src
tsconfig*.json tsconfig*.json
tslint.json tslint.json

View File

@@ -1,6 +1,6 @@
{ {
"name": "@mifi/auth-db", "name": "@mifi/auth-db",
"version": "1.0.5", "version": "1.0.11",
"author": "mifi (Mike Fitzpatrick)", "author": "mifi (Mike Fitzpatrick)",
"license": "MIT", "license": "MIT",
"scripts": { "scripts": {
@@ -39,7 +39,8 @@
"typescript": "^4.9.5" "typescript": "^4.9.5"
}, },
"dependencies": { "dependencies": {
"@mifi/services-common": "1.x.x", "@mifi/auth-common": "^1.0.5",
"@mifi/services-common": "^1.0.11",
"dotenv": "^16.0.3", "dotenv": "^16.0.3",
"jsonwebtoken": "^9.0.0", "jsonwebtoken": "^9.0.0",
"mongoose": "^6.9.2" "mongoose": "^6.9.2"

View File

@@ -1,16 +1,17 @@
import { Auth, Log } from '..'; import { Action } from '@mifi/auth-common/lib/enums/action';
import { Action } from '../constants/action'; import { generateLoginToken } from '@mifi/auth-common/lib/utils/generateLoginToken';
import { getLoginToken } from '../utils/getLoginToken';
export const authenticate = async (username: string, password: string) => { import { Auth, Log } from '..';
export const authenticate = async (username: string, password: string, includeToken = false) => {
const doc = await Auth.findByUsername(username).catch(); const doc = await Auth.findByUsername(username).catch();
if (!!doc && (await doc.authenticate(password))) { if (!!doc && (await doc.authenticate(password))) {
Log.add(doc.id, Action.AUTHENTICATE); Log.add(doc.id, Action.AUTHENTICATE);
return { ...doc, token: getLoginToken(doc) }; return { sub: doc._id, record: doc.record, token: includeToken ? generateLoginToken(doc) : undefined };
} }
if (doc) { if (doc) {
Log.add(doc.id, Action.AUTHENTICATE_FAILURE); Log.add(doc.id, Action.AUTHENTICATE_FAILURE, { ...doc });
} }
return false; return false;

View File

@@ -1,4 +1,5 @@
import { StringSchemaDefinition } from 'mongoose'; import { StringSchemaDefinition } from 'mongoose';
import { Auth, Strategy } from '..'; import { Auth, Strategy } from '..';
export const deleteStrategy = async (id: StringSchemaDefinition) => { export const deleteStrategy = async (id: StringSchemaDefinition) => {

View File

@@ -1,7 +1,8 @@
import { Action } from '@mifi/auth-common/lib/enums/action';
import { TokenType } from '@mifi/auth-common/lib/enums/tokens';
import { readOneByUsername } from '../dao/readOneByUsername'; import { readOneByUsername } from '../dao/readOneByUsername';
import { Log, Token } from '..'; import { Log, Token } from '..';
import { TokenType } from '../constants/tokens';
import { Action } from '../constants/action';
export const resetPasswordGet = async (username: string) => { export const resetPasswordGet = async (username: string) => {
const doc = await readOneByUsername(username); const doc = await readOneByUsername(username);

View File

@@ -1,11 +1,12 @@
import { Types } from 'mongoose'; import { Types } from 'mongoose';
import { Log, Strategy, Token } from '..'; import { Action } from '@mifi/auth-common/lib/enums/action';
import { STRATEGIES } from '../constants/strategies'; import { STRATEGIES } from '@mifi/auth-common/lib/enums/strategies';
import { generateLoginToken } from '@mifi/auth-common/lib/utils/generateLoginToken';
import { AuthDocument } from '../schema/auth'; import { AuthDocument } from '../schema/auth';
import { getLoginToken } from '../utils/getLoginToken';
import { StrategyDocument } from '../schema/strategy'; import { StrategyDocument } from '../schema/strategy';
import { Action } from '../constants/action'; import { Log, Strategy, Token } from '..';
export const resetPasswordPost = async (token: string, password: string) => { export const resetPasswordPost = async (token: string, password: string) => {
const parentId = await Token.validateResetToken(token); const parentId = await Token.validateResetToken(token);
@@ -34,7 +35,7 @@ export const resetPasswordPost = async (token: string, password: string) => {
} }
Log.add(parent._id, Action.RESET); Log.add(parent._id, Action.RESET);
return { record: parent.record, token: getLoginToken(parent) }; return { record: parent.record, token: generateLoginToken(parent) };
} }
return false; return false;

View File

@@ -1,9 +0,0 @@
export enum Action {
AUTHENTICATE = 'AUTHENTICATE',
AUTHENTICATE_FAILURE = 'AUTHENTICATE_FAILURE',
CREATE = 'CREATE',
DELETE = 'DELETE',
RESET = 'RESET',
RESET_REQUEST = 'RESET_REQUEST',
UPDATE = 'UPDATE',
}

View File

@@ -1,8 +0,0 @@
export enum Status {
ACTIVE,
BLOCK_HARD,
BLOCK_SOFT,
DELETED,
INACTIVE,
UNVERIFIED,
}

View File

@@ -1,20 +0,0 @@
export const PACKAGE_NAME = '@mifi/auth';
export const PORT = process.env.PORT || 9000;
export const SESSION_KEY = process.env.SESSION_KEY || 'secret-key';
export const JWT_AUDIENCE = process.env.JWT_AUDIENCE || 'mifi.dev';
export const JWT_ISSUER = process.env.JWT_ISSUER || PACKAGE_NAME;
export const JWT_SECRET = process.env.JWT_SECRET || 'secret';
export const LOGIN_VALID_TIMEOUT = process.env.LOGIN_VALID_TIMEOUT || '12h'; // ###d|h|m
export const RESET_VALID_TIMEOUT = process.env.RESET_VALID_TIMEOUT || '15m'; // ###d|h|m
export const VERIFY_VALID_TIMEOUT = process.env.VERIFY_VALID_TIMEOUT || '60d'; // ###d|h|m
export const DEFAULT_TOKEN_DAYS = process.env.DEFAULT_TOKEN_DAYS || 365;
export const ROUTE_PREFIX = process.env.ROUTE_PREFIX || '/auth';
export const LOGIN_ROUTE = process.env.LOGIN_ROUTE || '/login';
export const RESET_ROUTE = process.env.RESET_ROUTE || '/reset';
export const VERIFICATION_ROUTE = process.env.VERIFICATION_ROUTE || '/verification';
export const REQUIRE_VERIFICATION = process.env.REQUIRE_VERIFICATION || true;

View File

@@ -1,12 +0,0 @@
export enum ErrorCodes {
RESET_REQUEST_DATA = 'RESET_REQUEST_DATA',
}
export const ErrorMessages = {
[ErrorCodes.RESET_REQUEST_DATA]: 'A valid username and password must be provided',
};
export const getErrorBody = (code: ErrorCodes) => ({
code,
message: ErrorMessages[code],
});

View File

@@ -1,7 +0,0 @@
export enum STRATEGIES {
LOCAL,
APPLE,
FACEBOOK,
FIDO2,
GOOGLE,
}

View File

@@ -0,0 +1,4 @@
export const LOGIN_VALID_TIMEOUT = process.env.LOGIN_VALID_TIMEOUT || '12h'; // ###d|h|m
export const RESET_VALID_TIMEOUT = process.env.RESET_VALID_TIMEOUT || '15m'; // ###d|h|m
export const VERIFY_VALID_TIMEOUT = process.env.VERIFY_VALID_TIMEOUT || '60d'; // ###d|h|m
export const DEFAULT_TOKEN_DAYS = process.env.DEFAULT_TOKEN_DAYS || 365;

View File

@@ -1,4 +0,0 @@
export enum TokenType {
RESET = 'RESET',
VERIFICATION = 'VERIFICATION',
}

65
src/dao/auth/create.ts Normal file
View File

@@ -0,0 +1,65 @@
import { Action } from '@mifi/auth-common/lib/enums/action';
import { Status } from '@mifi/auth-common/lib/enums/status';
import { STRATEGIES } from '@mifi/auth-common/lib/enums/strategies';
import { TokenType } from '@mifi/auth-common/lib/enums/tokens';
import { REQUIRE_VERIFICATION } from '@mifi/auth-common/lib/settings';
import { DatabaseError } from '@mifi/services-common/lib/domain/errors/DatabaseError';
import { Auth as AuthProps } from '../../schema/auth';
import { Auth, Log, Strategy, Token } from '../..';
type CreateProps = Pick<AuthProps, 'username'> & {
externalId?: string;
handle?: AuthProps['handle'];
password?: string;
publicKey?: string;
record?: AuthProps['record'];
};
export const create = async ({ record, username, externalId, handle, password, publicKey }: CreateProps) => {
const status = REQUIRE_VERIFICATION ? Status.UNVERIFIED : Status.ACTIVE;
const doc = await Auth.create({
handle,
record,
status,
username,
}).catch((err) => {
throw new DatabaseError('failed to create user', { err });
});
if (doc) {
const method = externalId && publicKey ? STRATEGIES.FIDO2 : STRATEGIES.LOCAL;
const strategy = await Strategy.create({
externalId,
key: password || publicKey,
method,
parent: doc._id,
}).catch((err) => {
throw new DatabaseError(`failed to create strategy ${STRATEGIES[method]}`, { err });
});
if (strategy) {
doc.strategies.push(strategy._id);
await doc.save();
Log.add(doc._id, Action.CREATE);
return {
doc,
token:
method === STRATEGIES.LOCAL &&
REQUIRE_VERIFICATION &&
(await Token.getToken(TokenType.VERIFICATION, doc._id)),
};
}
await doc.deleteOne((err) => {
throw new DatabaseError('failed to remove invalid auth record', {
err,
doc,
});
});
}
return null;
};
export type Fido2UserProps = Pick<AuthProps, 'handle' | 'username'> & { externalId: string; publicKey: string };
export const createFido2User = (props: Fido2UserProps) => create(props);
export type LocalUserProps = Pick<AuthProps, 'record' | 'username'> & { password: string };
export const createLocalUser = (props: LocalUserProps) => create(props);

View File

@@ -0,0 +1,21 @@
import { StringSchemaDefinition } from 'mongoose';
import { Action } from '@mifi/auth-common/lib/enums/action';
import { Status } from '@mifi/auth-common/lib/enums/status';
import { Auth, Log, Strategy, Token } from '../..';
export const deleteById = async (id: StringSchemaDefinition) => {
if (
await Auth.findByIdAndUpdate(id, {
status: Status.DELETED,
strategies: [],
}).catch()
) {
await Strategy.deleteMany({ parent: id });
await Token.deleteMany({ auth: id });
Log.add(id, Action.DELETE);
return true;
}
return false;
};

10
src/dao/auth/readAll.ts Normal file
View File

@@ -0,0 +1,10 @@
import { FilterQuery } from 'mongoose';
import { Status } from '@mifi/auth-common/lib/enums/status';
import { Auth } from '../../model/auth';
import { AuthDocument } from '../../schema/auth';
export const readAll = async (query: FilterQuery<AuthDocument> = {}) => Auth.find(query);
export const readAllActive = async () => readAll({ status: { $ne: Status.DELETED } });

View File

@@ -0,0 +1,5 @@
import { Types } from 'mongoose';
import { Auth } from '../../model/auth';
export const readOneById = async (id: Types.ObjectId) => Auth.findById(id);

View File

@@ -0,0 +1,5 @@
import { Types } from 'mongoose';
import { Auth } from '../../model/auth';
export const readOneByRecord = async (record: Types.ObjectId) => Auth.findOne({ record });

View File

@@ -0,0 +1,3 @@
import { Auth } from '../../model/auth';
export const readOneByUsername = async (username: string) => Auth.findOne({ username });

View File

@@ -1,45 +1,3 @@
import { DatabaseError } from '@mifi/services-common/lib/domain/errors/DatabaseError'; import { create } from './auth/create';
import { Auth, Log, Strategy, Token } from '..'; export { create };
import { Auth as AuthProps } from '../schema/auth';
import { STRATEGIES } from '../constants/strategies';
import { REQUIRE_VERIFICATION } from '../constants/env';
import { TokenType } from '../constants/tokens';
import { Status } from '../constants/auth';
import { Action } from '../constants/action';
export const create = async ({ record, username, password }: AuthProps & { password: string }) => {
const status = REQUIRE_VERIFICATION ? Status.UNVERIFIED : Status.ACTIVE;
const doc = await Auth.create({
record,
status,
username,
}).catch((err) => {
throw new DatabaseError('failed to create user', { err });
});
if (doc) {
const strategy = await Strategy.create({
method: STRATEGIES.LOCAL,
key: password,
parent: doc._id,
}).catch((err) => {
throw new DatabaseError('failed to create strategy', { err });
});
if (strategy) {
doc.strategies.push(strategy._id);
await doc.save();
Log.add(doc._id, Action.CREATE);
return {
doc,
token: REQUIRE_VERIFICATION && (await Token.getToken(TokenType.VERIFICATION, doc._id)),
};
}
await doc.deleteOne((err) => {
throw new DatabaseError('failed to remove invalid auth record', {
err,
doc,
});
});
}
return null;
};

View File

@@ -1,20 +1,3 @@
import { StringSchemaDefinition } from 'mongoose'; import { deleteById } from './auth/deleteById';
import { Auth, Log, Strategy, Token } from '..'; export { deleteById };
import { Status } from '../constants/auth';
import { Action } from '../constants/action';
export const deleteById = async (id: StringSchemaDefinition) => {
if (
await Auth.findByIdAndUpdate(id, {
status: Status.DELETED,
strategies: [],
}).catch()
) {
await Strategy.deleteMany({ parent: id });
await Token.deleteMany({ auth: id });
Log.add(id, Action.DELETE);
return true;
}
return false;
};

View File

@@ -1,9 +1,3 @@
import { FilterQuery } from 'mongoose'; import { readAll } from './auth/readAll';
import { Auth } from '../model/auth'; export { readAll };
import { Status } from '../constants/auth';
import { AuthDocument } from '../schema/auth';
export const readAll = async (query: FilterQuery<AuthDocument> = {}) => Auth.find(query);
export const readAllActive = async () => readAll({ status: { $ne: Status.DELETED } });

View File

@@ -1,5 +1,3 @@
import { Types } from 'mongoose'; import { readOneById } from './auth/readOneById';
import { Auth } from '../model/auth'; export { readOneById };
export const readOneById = async (id: Types.ObjectId) => Auth.findById(id);

View File

@@ -1,5 +1,3 @@
import { Types } from 'mongoose'; import { readOneByRecord } from './auth/readOneByRecord';
import { Auth } from '../model/auth'; export { readOneByRecord };
export const readOneByRecord = async (record: Types.ObjectId) => Auth.findOne({ record });

View File

@@ -1,3 +1,3 @@
import { Auth } from '../model/auth'; import { readOneByUsername } from './auth/readOneByUsername';
export const readOneByUsername = async (username: string) => Auth.findOne({ username }); export { readOneByUsername };

View File

@@ -0,0 +1,24 @@
import { DatabaseError } from '@mifi/services-common/lib/domain/errors/DatabaseError';
import { Strategy } from '../../model/strategy';
import { Strategy as StrategyProps } from '../../schema/strategy';
const create = async ({ externalId, key, method, parent, profile }: StrategyProps) =>
Strategy.create({
externalId,
key,
method,
parent,
profile,
}).catch((err) => {
throw new DatabaseError(err, {
externalId: externalId || null,
key,
method,
parent,
profile: profile || null,
});
});
export const createFido2Strategy = (props: Omit<StrategyProps, 'profile'>) => create(props);
export const createLocalStrategy = (props: Omit<StrategyProps, 'externalId' | 'profile'>) => create(props);

View File

@@ -0,0 +1,8 @@
import { StringSchemaDefinition } from 'mongoose';
import { Strategy } from '../../model/strategy';
export const deleteById = async (id: StringSchemaDefinition) => {
const result = await Strategy.findByIdAndDelete(id).catch();
return !!result;
};

View File

@@ -0,0 +1,6 @@
import { FilterQuery } from 'mongoose';
import { Strategy } from '../../model/strategy';
import { StrategyDocument } from '../../schema/strategy';
export const readAll = async (query: FilterQuery<StrategyDocument> = {}) => Strategy.find(query);

View File

@@ -0,0 +1,7 @@
import { Strategy } from '../../model/strategy';
import { AuthDocument } from '../../schema/auth';
export const readOneByExternalId = async (externalId: string, populate = false) =>
populate
? Strategy.findOne({ externalId }).populate<{ parent: AuthDocument }>('parent')
: Strategy.findOne({ externalId });

View File

@@ -0,0 +1,5 @@
import { Types } from 'mongoose';
import { Strategy } from '../../model/strategy';
export const readOneById = async (id: Types.ObjectId) => Strategy.findById(id);

View File

@@ -0,0 +1,8 @@
import { Types } from 'mongoose';
import { STRATEGIES } from '@mifi/auth-common/lib/enums/strategies';
import { Strategy } from '../../model/strategy';
export const readOneByParentAndMethod = async (parent: Types.ObjectId, method: STRATEGIES) =>
Strategy.findOne({ method, parent });

View File

@@ -1,12 +1,14 @@
import { Document, InferSchemaType, Model, Schema, StringSchemaDefinition, Types } from 'mongoose'; import { Document, InferSchemaType, Model, Schema, StringSchemaDefinition, Types } from 'mongoose';
import { Status } from '../constants/auth'; import { Status } from '@mifi/auth-common/lib/enums/status';
import { STRATEGIES } from '@mifi/auth-common/lib/enums/strategies';
import { COLL_STRATEGY } from '../constants/db'; import { COLL_STRATEGY } from '../constants/db';
import { STRATEGIES } from '../constants/strategies';
import { StrategyDocument } from './strategy';
import { verify } from '../utils/password'; import { verify } from '../utils/password';
import { StrategyDocument } from './strategy';
export interface Auth { export interface Auth {
handle?: string;
is2FA?: boolean; is2FA?: boolean;
record: StringSchemaDefinition; record: StringSchemaDefinition;
username: string; username: string;
@@ -35,6 +37,7 @@ export interface AuthModel extends Model<AuthDocument> {
export const AuthSchema = new Schema<AuthDocument, AuthModel>( export const AuthSchema = new Schema<AuthDocument, AuthModel>(
{ {
handle: { type: String },
is2FA: { type: Boolean, default: false }, is2FA: { type: Boolean, default: false },
record: { type: Types.ObjectId, unique: true }, record: { type: Types.ObjectId, unique: true },
status: { status: {

View File

@@ -1,9 +1,8 @@
import { InferSchemaType, Model, Schema, StringSchemaDefinition, Types } from 'mongoose'; import { InferSchemaType, Model, Schema, StringSchemaDefinition, Types } from 'mongoose';
import { Action } from '@mifi/auth-common/lib/enums/action';
import { Payload } from '@mifi/services-common/lib/types/Payload'; import { Payload } from '@mifi/services-common/lib/types/Payload';
import { Action } from '../constants/action';
export interface Log { export interface Log {
action: Action; action: Action;
auth: StringSchemaDefinition; auth: StringSchemaDefinition;

View File

@@ -1,6 +1,7 @@
import { Document, InferSchemaType, Model, Schema, StringSchemaDefinition, Types } from 'mongoose'; import { Document, InferSchemaType, Model, Schema, StringSchemaDefinition, Types } from 'mongoose';
import { STRATEGIES } from '../constants/strategies'; import { STRATEGIES } from '@mifi/auth-common/lib/enums/strategies';
import { encrypt } from '../utils/password'; import { encrypt } from '../utils/password';
import { COLL_AUTH } from '../constants/db'; import { COLL_AUTH } from '../constants/db';
import { AuthDocument } from './auth'; import { AuthDocument } from './auth';

View File

@@ -1,8 +1,9 @@
import { InferSchemaType, Model, Schema, StringSchemaDefinition, Types } from 'mongoose'; import { InferSchemaType, Model, Schema, StringSchemaDefinition, Types } from 'mongoose';
import { TokenType } from '../constants/tokens'; import { TokenType } from '@mifi/auth-common/lib/enums/tokens';
import { getDefaultExpiresFor } from '../utils/getDefaultExpiresFor'; import { getDefaultExpiresFor } from '@mifi/auth-common/lib/helpers/getDefaultExpiresFor';
import { sign, verify } from '../utils/jwt'; import { sign, verify } from '@mifi/auth-common/lib/utils/jwt';
import { SignProps } from '@mifi/auth-common/lib/utils/jwt/sign';
export interface Token { export interface Token {
auth: StringSchemaDefinition; auth: StringSchemaDefinition;
@@ -50,7 +51,7 @@ TokenSchema.statics = {
return sign({ return sign({
sub: `${doc._id}`, sub: `${doc._id}`,
exp: doc.expires, exp: doc.expires,
}); } as SignProps);
}, },
async validateResetToken(token: string) { async validateResetToken(token: string) {

View File

@@ -1,15 +0,0 @@
import { LOGIN_VALID_TIMEOUT, RESET_VALID_TIMEOUT, VERIFY_VALID_TIMEOUT } from '../constants/env';
import { TokenType } from '../constants/tokens';
import { parseTimeoutToMs } from '../utils/parseTimeoutToMs';
export const getDefaultExpiresFor = (type: TokenType | void) => {
if (type === TokenType.RESET) {
return Date.now() + parseTimeoutToMs(RESET_VALID_TIMEOUT);
}
if (type === TokenType.VERIFICATION) {
return Date.now() + parseTimeoutToMs(VERIFY_VALID_TIMEOUT);
}
return Date.now() + parseTimeoutToMs(LOGIN_VALID_TIMEOUT);
};

View File

@@ -1,11 +0,0 @@
import { sign } from '../utils/jwt';
import { LOGIN_VALID_TIMEOUT } from '../constants/env';
import { parseTimeoutToMs } from '../utils/parseTimeoutToMs';
import { AuthDocument } from '../schema/auth';
export const getLoginToken = ({ record: sub, status }: AuthDocument) =>
sign({
sub: <string>sub,
status,
exp: Date.now() + parseTimeoutToMs(LOGIN_VALID_TIMEOUT),
});

View File

@@ -1,35 +0,0 @@
import jwt from 'jsonwebtoken';
import { JWT_AUDIENCE, JWT_ISSUER, JWT_SECRET } from '../constants/env';
export interface TokenProps {
aud?: string;
exp?: number | Date;
iss?: string;
sub: string | null;
[key: string]: any;
}
export type SignProps = string | TokenProps | void;
export const sign = (props: SignProps) => {
const today = new Date();
const { sub = null, ...rest }: TokenProps =
typeof props === 'string' || typeof props === 'undefined' ? { sub: props || null } : props;
let { exp } = rest;
if (!exp) {
exp = new Date(today);
exp.setDate(today.getDate() + parseInt(process.env.JWT_DAYS_VALID as string));
exp = exp.getTime() / 1000;
}
return jwt.sign(
{
exp,
sub,
aud: rest.aud || JWT_AUDIENCE,
iat: today.getTime(),
iss: rest.iss || JWT_ISSUER,
},
JWT_SECRET,
);
};
export const verify = (token: string) => jwt.verify(token, JWT_SECRET);

View File

@@ -1,5 +0,0 @@
import { RESET_ROUTE, ROUTE_PREFIX, VERIFICATION_ROUTE } from '../constants/env';
export const getPasswordResetPath = (token: string) => `${ROUTE_PREFIX}${RESET_ROUTE}?t=${token}`;
export const getVerificationPath = (token: string) => `${ROUTE_PREFIX}${VERIFICATION_ROUTE}?t=${token}`;

View File

@@ -1,13 +0,0 @@
export const parseTimeoutToMs = (timeout: string) => {
const match = timeout.match(/(?<number>\d+)(?<unit>d|h|m)/gi)?.groups || {};
const { number, unit } = match;
switch (unit) {
case 'd':
return 1000 * 60 * 60 * 24 * parseInt(number);
case 'h':
return 1000 * 60 * 60 * parseInt(number);
case 'm':
default:
return 1000 * 60 * parseInt(number) || 1;
}
};

View File

@@ -5,8 +5,3 @@ export const encrypt = (password: string) => {
const hash = pbkdf2Sync(password, salt, 10000, 512, 'sha512').toString('hex'); const hash = pbkdf2Sync(password, salt, 10000, 512, 'sha512').toString('hex');
return `${salt}:${hash}`; return `${salt}:${hash}`;
}; };
export const verify = (test: string, secret: string) => {
const [salt, hash] = secret.split(':');
return pbkdf2Sync(test, salt, 10000, 512, 'sha512').toString('hex') === hash;
};

View File

@@ -0,0 +1,4 @@
import { encrypt } from './encrypt';
import { verify } from './verify';
export { encrypt, verify };

View File

@@ -0,0 +1,6 @@
import { pbkdf2Sync } from 'crypto';
export const verify = (test: string, secret: string) => {
const [salt, hash] = secret.split(':');
return pbkdf2Sync(test, salt, 10000, 512, 'sha512').toString('hex') === hash;
};

View File

@@ -1,11 +0,0 @@
import { sign } from './jwt';
import { LOGIN_VALID_TIMEOUT } from '../constants/env';
import { Status } from '../constants/auth';
import { parseTimeoutToMs } from './parseTimeoutToMs';
export const generateLoginToken = (sub: string, status: Status) =>
sign({
sub,
status,
exp: Date.now() + parseTimeoutToMs(LOGIN_VALID_TIMEOUT),
});

View File

@@ -10,8 +10,8 @@
"rootDirs": ["./", "src/"], "rootDirs": ["./", "src/"],
"strict": true, "strict": true,
"esModuleInterop": true, "esModuleInterop": true,
"sourceMap": false, "sourceMap": true,
"removeComments": true "removeComments": false
}, },
"include": ["src"] "include": ["src"]
} }

View File

@@ -2648,6 +2648,17 @@ __metadata:
languageName: node languageName: node
linkType: hard linkType: hard
"@mifi/auth-common@npm:^1.0.5":
version: 1.0.5
resolution: "@mifi/auth-common@npm:1.0.5::__archiveUrl=https%3A%2F%2Fgit.mifi.dev%2Fapi%2Fpackages%2Fmifi%2Fnpm%2F%2540mifi%252Fauth-common%2F-%2F1.0.5%2Fauth-common-1.0.5.tgz"
dependencies:
"@mifi/breakerbox-db": ^1.0.3
"@mifi/services-common": ^1.0.11
jsonwebtoken: ^9.0.0
checksum: 0eef5c417ae95dc2a31b8599b4e0e747478171d518a7dfd223090667fdc142c8d2cd9e29852883573cc6c7b2dd32eb0625e5bc73ff6f5908b0032a54815e0a98
languageName: node
linkType: hard
"@mifi/auth-db@workspace:.": "@mifi/auth-db@workspace:.":
version: 0.0.0-use.local version: 0.0.0-use.local
resolution: "@mifi/auth-db@workspace:." resolution: "@mifi/auth-db@workspace:."
@@ -2655,7 +2666,8 @@ __metadata:
"@babel/core": ^7.21.8 "@babel/core": ^7.21.8
"@babel/preset-env": ^7.21.5 "@babel/preset-env": ^7.21.5
"@babel/preset-typescript": ^7.21.5 "@babel/preset-typescript": ^7.21.5
"@mifi/services-common": 1.x.x "@mifi/auth-common": ^1.0.5
"@mifi/services-common": ^1.0.11
"@tsconfig/node16": ^1.0.4 "@tsconfig/node16": ^1.0.4
"@types/jsonwebtoken": ^9.0.2 "@types/jsonwebtoken": ^9.0.2
"@types/node": ^18.14.0 "@types/node": ^18.14.0
@@ -2682,10 +2694,20 @@ __metadata:
languageName: unknown languageName: unknown
linkType: soft linkType: soft
"@mifi/services-common@npm:1.x.x": "@mifi/breakerbox-db@npm:^1.0.3":
version: 1.0.6 version: 1.0.3
resolution: "@mifi/services-common@npm:1.0.6::__archiveUrl=https%3A%2F%2Fgit.mifi.dev%2Fapi%2Fpackages%2Fmifi%2Fnpm%2F%2540mifi%252Fservices-common%2F-%2F1.0.6%2Fservices-common-1.0.6.tgz" resolution: "@mifi/breakerbox-db@npm:1.0.3::__archiveUrl=https%3A%2F%2Fgit.mifi.dev%2Fapi%2Fpackages%2Fmifi%2Fnpm%2F%2540mifi%252Fbreakerbox-db%2F-%2F1.0.3%2Fbreakerbox-db-1.0.3.tgz"
checksum: 22e9aa2714d088a286fc76ddf88c89698764f966ea5f3a208da45df893ec8a0c4e43848f4ba59746cd96b16880dbfa9f3a88610e43aa3825cbdb78afc11f59dc dependencies:
lowdb: ^6.0.1
yaml: ^2.3.1
checksum: 16f2f841d4d1f87f29ddcbec222076d4186038cbd22b9116deb941c07bd0aca1473a5aa66ae113c0cb01c3ded866ef9ec4bbeda055b054d47c3696cb16cfeb62
languageName: node
linkType: hard
"@mifi/services-common@npm:^1.0.11":
version: 1.0.11
resolution: "@mifi/services-common@npm:1.0.11::__archiveUrl=https%3A%2F%2Fgit.mifi.dev%2Fapi%2Fpackages%2Fmifi%2Fnpm%2F%2540mifi%252Fservices-common%2F-%2F1.0.11%2Fservices-common-1.0.11.tgz"
checksum: 3faeba975bbf35f532826da658545c1faa04f2a90c4f5a428474628aa3d9a3a03690b9caa216ed78be87aa4564dbe78195945b3de6a234ad6de9fac0768ac999
languageName: node languageName: node
linkType: hard linkType: hard
@@ -6294,6 +6316,15 @@ __metadata:
languageName: node languageName: node
linkType: hard linkType: hard
"lowdb@npm:^6.0.1":
version: 6.0.1
resolution: "lowdb@npm:6.0.1"
dependencies:
steno: ^3.0.0
checksum: d555a5bcc2e4a963fae89209b693a6f2b7b69bae915ff67355537b7a14a4f6e44bc273467bc3d4d7e81660c1313587ee3bfebf044d50d3213a5e95ea7f07ded4
languageName: node
linkType: hard
"lru-cache@npm:^5.1.1": "lru-cache@npm:^5.1.1":
version: 5.1.1 version: 5.1.1
resolution: "lru-cache@npm:5.1.1" resolution: "lru-cache@npm:5.1.1"
@@ -7544,6 +7575,13 @@ __metadata:
languageName: node languageName: node
linkType: hard linkType: hard
"steno@npm:^3.0.0":
version: 3.0.0
resolution: "steno@npm:3.0.0"
checksum: fb928451a4f96342b496b71147fbca0a20a5daf7bfd23a4a1cec8640d3c6c67176809169e9a5801ea44490d448b5b7ecb151b9fba434872c2d65549847f39460
languageName: node
linkType: hard
"string-length@npm:^4.0.1": "string-length@npm:^4.0.1":
version: 4.0.2 version: 4.0.2
resolution: "string-length@npm:4.0.2" resolution: "string-length@npm:4.0.2"
@@ -8255,6 +8293,13 @@ __metadata:
languageName: node languageName: node
linkType: hard linkType: hard
"yaml@npm:^2.3.1":
version: 2.3.1
resolution: "yaml@npm:2.3.1"
checksum: 2c7bc9a7cd4c9f40d3b0b0a98e370781b68b8b7c4515720869aced2b00d92f5da1762b4ffa947f9e795d6cd6b19f410bd4d15fdd38aca7bd96df59bd9486fb54
languageName: node
linkType: hard
"yargs-parser@npm:^13.1.2": "yargs-parser@npm:^13.1.2":
version: 13.1.2 version: 13.1.2
resolution: "yargs-parser@npm:13.1.2" resolution: "yargs-parser@npm:13.1.2"