Skip to content

Commit d5bc1a4

Browse files
authored
feat: adds Nile_Jackson_loader.ts and Modifies loader.ts -lesson10Hw (#344)
1 parent 6a45e46 commit d5bc1a4

File tree

2 files changed

+50
-2
lines changed

2 files changed

+50
-2
lines changed

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,15 @@
11
import { Module } from '@nestjs/common';
22
import { AnthonyMaysLoader } from './anthony_mays_loader.js';
3+
import { NileJacksonLoader } from './nile_jackson_loader.js';
34
import { XavierCruzLoader } from './xavier_cruz_loader.js';
4-
55
export const Loaders = Symbol.for('Loaders');
66

77
// Add your quiz provider here.
8-
const LOADER_PROVIDERS = [AnthonyMaysLoader, XavierCruzLoader];
8+
const LOADER_PROVIDERS = [
9+
AnthonyMaysLoader,
10+
XavierCruzLoader,
11+
NileJacksonLoader,
12+
];
913

1014
@Module({
1115
providers: [
Lines changed: 44 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,44 @@
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 NileJacksonLoader implements Loader {
7+
getLoaderName(): string {
8+
return 'nilejackson';
9+
}
10+
11+
async loadData(): Promise<MediaItem[]> {
12+
const credits = await this.loadCredits();
13+
const mediaItems = await this.loadMediaItems();
14+
15+
console.log(
16+
`Loaded ${credits.length} credits and ${mediaItems.length} media items`,
17+
);
18+
19+
return [...mediaItems.values()];
20+
}
21+
async loadMediaItems(): Promise<MediaItem[]> {
22+
const mediaItems = [];
23+
const readable = fs
24+
.createReadStream('data/media_items.csv', 'utf-8')
25+
.pipe(csv());
26+
for await (const row of readable) {
27+
const { id, title, type, year } = row;
28+
mediaItems.push(new MediaItem(id, title, type, year, []));
29+
}
30+
return mediaItems;
31+
}
32+
33+
async loadCredits(): Promise<Credit[]> {
34+
const credits = [];
35+
const readable = fs
36+
.createReadStream('data/credits.csv', 'utf-8')
37+
.pipe(csv());
38+
for await (const row of readable) {
39+
const { media_item_id, role, name } = row;
40+
credits.push(new Credit(media_item_id, name, role));
41+
}
42+
return credits;
43+
}
44+
}

0 commit comments

Comments
 (0)