feat Added dal entities for authentication

libs/dal/package.json

@@ -16,6 +16,7 @@
     "lint:fix": "eslint src --fix"
   },
   "dependencies": {
+    "@impler/shared": "^0.1.12",
     "class-transformer": "^0.5.1",
     "mongoose": "^6.6.1",
     "rimraf": "^3.0.2"

libs/dal/src/index.ts

@@ -7,3 +7,5 @@ export * from './repositories/file';
 export * from './repositories/upload';
 export * from './repositories/mapping';
 export * from './repositories/webhook-log';
+export * from './repositories/user';
+export * from './repositories/member';

libs/dal/src/repositories/member/index.ts

@@ -0,0 +1,3 @@
+export * from './member.entity';
+export * from './member.repository';
+export * from './member.schema';

libs/dal/src/repositories/member/member.entity.ts

@@ -0,0 +1,18 @@
+import { MemberRoleEnum, MemberStatusEnum, IMemberInvite } from '@impler/shared';
+import { UserEntity } from '../user';
+
+export class MemberEntity {
+  _id: string;
+
+  _userId: string;
+
+  user?: Pick<UserEntity, 'firstName' | '_id' | 'lastName' | 'email'>;
+
+  role: MemberRoleEnum;
+
+  memberStatus: MemberStatusEnum;
+
+  _projectId: string;
+
+  invite: IMemberInvite;
+}

libs/dal/src/repositories/member/member.repository.ts

@@ -0,0 +1,9 @@
+import { MemberEntity } from './member.entity';
+import { BaseRepository } from '../base-repository';
+import { Member } from './member.schema';
+
+export class MemberRepository extends BaseRepository<MemberEntity> {
+  constructor() {
+    super(Member, MemberEntity);
+  }
+}

libs/dal/src/repositories/member/member.schema.ts

@@ -0,0 +1,28 @@
+import { Schema, Document, models, model, Model } from 'mongoose';
+import { schemaOptions } from '../schema-default.options';
+import { MemberEntity } from './member.entity';
+
+const memberSchema = new Schema(
+  {
+    _userId: {
+      type: Schema.Types.ObjectId,
+      ref: 'User',
+      index: true,
+    },
+    role: String,
+    _projectId: {
+      type: Schema.Types.ObjectId,
+      ref: 'Project',
+      index: true,
+    },
+  },
+  schemaOptions
+);
+
+interface IMemberDocument extends MemberEntity, Document {
+  // eslint-disable-next-line @typescript-eslint/no-explicit-any
+  _id: any;
+}
+
+// eslint-disable-next-line @typescript-eslint/naming-convention
+export const Member = (models.Upload as Model<IMemberDocument>) || model<IMemberDocument>('Member', memberSchema);

libs/dal/src/repositories/user/index.ts

@@ -0,0 +1,3 @@
+export * from './user.entity';
+export * from './user.repository';
+export * from './user.schema';

libs/dal/src/repositories/user/user.entity.ts

@@ -0,0 +1,25 @@
+import { AuthProviderEnum } from '@impler/shared';
+import { Exclude } from 'class-transformer';
+
+export interface IUserToken {
+  providerId: string;
+  provider: AuthProviderEnum;
+  accessToken: string;
+}
+
+export class UserEntity {
+  _id: string;
+
+  firstName?: string | null;
+
+  lastName?: string | null;
+
+  email?: string | null;
+
+  profilePicture?: string | null;
+
+  @Exclude({ toPlainOnly: true })
+  tokens: IUserToken[];
+
+  showOnBoarding?: boolean;
+}

libs/dal/src/repositories/user/user.repository.ts

@@ -0,0 +1,23 @@
+import { AuthProviderEnum } from '@impler/shared';
+import { BaseRepository } from '../base-repository';
+import { UserEntity } from './user.entity';
+import { User } from './user.schema';
+
+export class UserRepository extends BaseRepository<UserEntity> {
+  constructor() {
+    super(User, UserEntity);
+  }
+
+  async findByEmail(email: string): Promise<UserEntity | null> {
+    return this.findOne({
+      email,
+    });
+  }
+
+  async findByLoginProvider(profileId: string, provider: AuthProviderEnum): Promise<UserEntity | null> {
+    return this.findOne({
+      'tokens.providerId': profileId,
+      'tokens.provider': provider,
+    });
+  }
+}

libs/dal/src/repositories/user/user.schema.ts

@@ -0,0 +1,29 @@
+import * as mongoose from 'mongoose';
+import { Schema, Document } from 'mongoose';
+import { schemaOptions } from '../schema-default.options';
+import { UserEntity } from './user.entity';
+
+const userSchema = new Schema(
+  {
+    firstName: Schema.Types.String,
+    lastName: Schema.Types.String,
+    email: Schema.Types.String,
+    profilePicture: Schema.Types.String,
+    showOnBoarding: Schema.Types.Boolean,
+    tokens: [
+      {
+        providerId: Schema.Types.String,
+        provider: Schema.Types.String,
+        accessToken: Schema.Types.String,
+      },
+    ],
+  },
+  schemaOptions
+);
+
+export interface IUserDocument extends UserEntity, Document {
+  _id: string;
+}
+
+// eslint-disable-next-line @typescript-eslint/naming-convention
+export const User = mongoose.models.User || mongoose.model<IUserDocument>('User', userSchema);

libs/shared/src/types/auth/auth.types.ts

@@ -0,0 +1,14 @@
+export enum AuthProviderEnum {
+  GOOGLE = 'google',
+  GITHUB = 'github',
+}
+
+export interface IJwtPayload {
+  _id: string;
+  _projectId: string;
+  role: string;
+  email?: string;
+  firstName?: string;
+  lastName?: string;
+  profilePicture?: string;
+}

libs/shared/src/types/auth/index.ts

@@ -0,0 +1,2 @@
+export * from './auth.types';
+export * from './member.types';

libs/shared/src/types/auth/member.types.ts

@@ -0,0 +1,16 @@
+export enum MemberRoleEnum {
+  ADMIN = 'admin',
+  MEMBER = 'member',
+}
+
+export enum MemberStatusEnum {
+  ACTIVE = 'active',
+  INVITED = 'invited',
+}
+
+export interface IMemberInvite {
+  email: string;
+  invitationDate: Date;
+  answerDate?: Date;
+  _inviterId: string;
+}

libs/shared/src/types/index.ts

@@ -3,3 +3,4 @@ export * from './upload/upload.types';
 export * from './webhook-log/webhook-log.types';
 export * from './common/common.types';
 export * from './widget/widget.types';
+export * from './auth';