Merge pull request #10 from knovator/file-upload-mapping_dal

Dal repositories for File, Upload and Mapping

libs/dal/src/index.ts

@@ -3,3 +3,6 @@ export * from './repositories/project';
 export * from './repositories/common';
 export * from './repositories/template';
 export * from './repositories/column';
+export * from './repositories/file';
+export * from './repositories/upload';
+export * from './repositories/mapping';

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

@@ -0,0 +1,11 @@
+export class FileEntity {
+  _id?: string;
+
+  name: string;
+
+  originalName: string;
+
+  mimeType: string;
+
+  path: string;
+}

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

@@ -0,0 +1,9 @@
+import { BaseRepository } from '../base-repository';
+import { FileEntity } from './file.entity';
+import { File } from './file.schema';
+
+export class FileRepository extends BaseRepository<FileEntity> {
+  constructor() {
+    super(File, FileEntity);
+  }
+}

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

@@ -0,0 +1,19 @@
+import { Schema, Document, model, models } from 'mongoose';
+import { schemaOptions } from '../schema-default.options';
+import { FileEntity } from './file.entity';
+
+const fileSchema = new Schema(
+  {
+    name: String,
+    originalName: String,
+    mimeType: String,
+    path: String,
+  },
+  { ...schemaOptions }
+);
+
+interface IFileDocument extends FileEntity, Document {
+  _id: never;
+}
+
+export const File = models.File || model<IFileDocument>('File', fileSchema);

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

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

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

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

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

@@ -0,0 +1,9 @@
+export class MappingEntity {
+  _id?: string;
+
+  _columnId: string;
+
+  _uploadId: string;
+
+  columnHeading: string;
+}

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

@@ -0,0 +1,9 @@
+import { BaseRepository } from '../base-repository';
+import { MappingEntity } from './mapping.entity';
+import { Mapping } from './mapping.schema';
+
+export class MappingRepository extends BaseRepository<MappingEntity> {
+  constructor() {
+    super(Mapping, MappingEntity);
+  }
+}

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

@@ -0,0 +1,24 @@
+import { Schema, Document, model, models } from 'mongoose';
+import { schemaOptions } from '../schema-default.options';
+import { MappingEntity } from './mapping.entity';
+
+const mappingSchema = new Schema(
+  {
+    columnHeading: String,
+    _columnId: {
+      type: Schema.Types.String,
+      ref: 'Column',
+    },
+    _uploadId: {
+      type: Schema.Types.String,
+      ref: 'Upload',
+    },
+  },
+  { ...schemaOptions }
+);
+
+interface IMappingDocument extends MappingEntity, Document {
+  _id: never;
+}
+
+export const Mapping = models.Mapping || model<IMappingDocument>('Mapping', mappingSchema);

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

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

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

@@ -0,0 +1,27 @@
+export class UploadEntity {
+  _id?: string;
+
+  _templateId: string;
+
+  _uploadedFileId: string;
+
+  _validDataFileId: string;
+
+  _invalidDataFileId: string;
+
+  headings: string[];
+
+  uploadedDate: Date;
+
+  totalRecords: number;
+
+  validRecords: number;
+
+  invalidRecords: number;
+
+  authHeaderValue: string;
+
+  status: string;
+
+  extra: string;
+}

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

@@ -0,0 +1,9 @@
+import { BaseRepository } from '../base-repository';
+import { UploadEntity } from './upload.entity';
+import { Upload } from './upload.schema';
+
+export class UploadRepository extends BaseRepository<UploadEntity> {
+  constructor() {
+    super(Upload, UploadEntity);
+  }
+}

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

@@ -0,0 +1,39 @@
+import { Schema, Document, model, models } from 'mongoose';
+import { schemaOptions } from '../schema-default.options';
+import { UploadEntity } from './upload.entity';
+
+const uploadSchema = new Schema(
+  {
+    _templateId: {
+      type: Schema.Types.String,
+      ref: 'Template',
+    },
+    _uploadedFileId: {
+      type: Schema.Types.String,
+      ref: 'File',
+    },
+    _validDataFileId: {
+      type: Schema.Types.String,
+      ref: 'File',
+    },
+    _invalidDataFileId: {
+      type: Schema.Types.String,
+      ref: 'File',
+    },
+    headings: [String],
+    uploadDate: Date,
+    totalRecords: Number,
+    validRecords: String,
+    invalidRecords: String,
+    authHeaderValue: String,
+    status: String,
+    extra: String,
+  },
+  { ...schemaOptions }
+);
+
+interface IUploadDocument extends UploadEntity, Document {
+  _id: never;
+}
+
+export const Upload = models.Upload || model<IUploadDocument>('Upload', uploadSchema);

libs/shared/src/types/index.ts

@@ -1 +1,2 @@
 export * from './column/column.types';
+export * from './upload/upload.types';

libs/shared/src/types/upload/upload.types.ts

@@ -0,0 +1,8 @@
+export enum UploadStatusEnum {
+  'MAPPING' = 'Mapping',
+  'REVIEWING' = 'Reviewing',
+  'REVIEWED' = 'Reviewed',
+  'CONFIRMED' = 'Confirmed',
+  'PROCESSING' = 'Processing',
+  'COMPLETED' = 'Completed',
+}