Skip to content

Commit 7117a98

Browse files
author
“Tezz03”
committed
fix:upload lesson_10 and extraCredit
1 parent d5c2047 commit 7117a98

File tree

2 files changed

+62
-0
lines changed

2 files changed

+62
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,15 @@ import { Module } from '@nestjs/common';
33
import { AnthonyMaysLoader } from './anthony_mays_loader.js';
44
import { DylanLaffertysLoader } from './dylan_lafferty_loaders.js';
55
import { MercedesMathewsLoader } from './mercedes_mathews_loader.js';
6+
import { MontezBLoader } from './montez_b_loaders.js';
67

78
export const Loaders = Symbol.for('Loaders');
89

910
const LOADER_PROVIDERS = [
1011
AnthonyMaysLoader,
1112
DylanLaffertysLoader,
1213
MercedesMathewsLoader,
14+
MontezBLoader
1315
];
1416

1517
@Module({
Lines changed: 60 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,60 @@
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 MontezBLoader implements Loader {
7+
getLoaderName(): string {
8+
return 'montezb';
9+
}
10+
11+
async loadData(): Promise<MediaItem[]> {
12+
const credits = await this.loadCredits();
13+
const mediaItems = await this.loadMediaItems();
14+
15+
const mediaMap = new Map<string, MediaItem>();
16+
17+
for (const media of mediaItems) {
18+
mediaMap.set(media.getId(), media);
19+
}
20+
21+
for (const credit of credits) {
22+
const mediaItem = mediaMap.get(credit.getMediaItemId());
23+
if (mediaItem) {
24+
mediaItem.addCredit(credit);
25+
}
26+
}
27+
28+
console.log(
29+
`Loaded ${credits.length} credits and ${mediaItems.length} media items`,
30+
);
31+
32+
return Array.from(mediaMap.values());
33+
}
34+
35+
async loadMediaItems(): Promise<MediaItem[]> {
36+
// TODO: Implement this method.
37+
const mediaItems = [];
38+
const readable = fs
39+
.createReadStream('data/media_items.csv', 'utf-8')
40+
.pipe(csv());
41+
42+
for await (const row of readable) {
43+
const { id, title, type, year } = row;
44+
mediaItems.push(new MediaItem( id, title, type, year, []));
45+
}
46+
return mediaItems;
47+
}
48+
49+
async loadCredits(): Promise<Credit[]> {
50+
const credits = [];
51+
const readable = fs
52+
.createReadStream('data/credits.csv', 'utf-8')
53+
.pipe(csv());
54+
for await (const row of readable) {
55+
const { media_item_id, role, name } = row;
56+
credits.push(new Credit(media_item_id, name, role));
57+
}
58+
return credits;
59+
}
60+
}

0 commit comments

Comments
 (0)