Skip to content

Commit 71bc5be

Browse files
author
Meiko-S22
committed
feat: add Meiko lesson 10
1 parent b01aa8a commit 71bc5be

File tree

2 files changed

+51
-1
lines changed

2 files changed

+51
-1
lines changed

lesson_10/libraries/src/loaders/loaders.module.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,11 @@
11
import { Module } from '@nestjs/common';
22

33
import { AnthonyMaysLoader } from './anthony_mays_loader.js';
4+
import { MeikoStephensLoader } from './meiko_stephens_loader.js';
45

56
export const Loaders = Symbol.for('Loaders');
67

7-
const LOADER_PROVIDERS = [AnthonyMaysLoader];
8+
const LOADER_PROVIDERS = [AnthonyMaysLoader,MeikoStephensLoader];
89

910
@Module({
1011
providers: [
Lines changed: 49 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
import csv from 'csv-parser';
2+
import fs from 'fs';
3+
import { Credit, MediaItem } from '../models/index.js';
4+
import { Loader } from './loader.js';
5+
6+
export class MeikoStephensLoader implements Loader {
7+
getLoaderName(): string {
8+
return 'meikostephens';
9+
}
10+
11+
async loadData(): Promise<MediaItem[]> {
12+
const credits = await this.loadCredits();
13+
const mediaItems = await this.loadMediaItems();
14+
const mediaMap = new Map<string, MediaItem>();
15+
mediaItems.forEach((mediaItem) => {
16+
mediaMap.set(mediaItem.getId(), mediaItem);
17+
});
18+
19+
20+
console.log(`Loaded ${credits.length} credits and ${mediaItems.length} media items`, );
21+
22+
return [...mediaItems.values( )];
23+
}
24+
25+
async loadMediaItems(): Promise<MediaItem[]> {
26+
const mediaItems = [];
27+
const readable = fs
28+
.createReadStream('data/media_items.csv', 'utf-8')
29+
.pipe(csv());
30+
for await (const row of readable) {
31+
const { id, title, type, year} = row;
32+
mediaItems.push(new MediaItem(id, title, type, year,[]));
33+
}
34+
return mediaItems;
35+
}
36+
37+
38+
async loadCredits(): Promise<Credit[]> {
39+
const credits = [];
40+
const readable = fs
41+
.createReadStream('data/credits.csv', 'utf-8')
42+
.pipe(csv());
43+
for await (const row of readable) {
44+
const { media_item_id, role, name } = row;
45+
credits.push(new Credit(media_item_id, name, role));
46+
}
47+
return credits;
48+
}
49+
}

0 commit comments

Comments
 (0)