Skip to content

Commit 2eb8001

Browse files
feat: adds Pable's loaders and .ts file (#354)
Co-authored-by: Anthony D. Mays <[email protected]>
1 parent 741db73 commit 2eb8001

File tree

2 files changed

+47
-0
lines changed

2 files changed

+47
-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
@@ -5,6 +5,7 @@ import { DavidSmithLoader } from './david_smith_loader.js';
55
import { DwightBlueLoader } from './dwight_blue_loader.js';
66
import { JamesCapparellLoader } from './james_capparell_loader.js';
77
import { NileJacksonLoader } from './nile_jackson_loader.js';
8+
import { PabloLimonParedesLoader } from './pablo_limon_paredes_loader.js';
89
import { XavierCruzLoader } from './xavier_cruz_loader.js';
910
import { ZionBuchananLoader } from './zion_buchanan_loader.js';
1011

@@ -18,6 +19,7 @@ const LOADER_PROVIDERS = [
1819
DwightBlueLoader,
1920
JamesCapparellLoader,
2021
NileJacksonLoader,
22+
PabloLimonParedesLoader,
2123
XavierCruzLoader,
2224
ZionBuchananLoader,
2325
];
Lines changed: 45 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,45 @@
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 PabloLimonParedesLoader implements Loader {
7+
getLoaderName(): string {
8+
return 'pablolimonparedes';
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+
22+
async loadMediaItems(): Promise<MediaItem[]> {
23+
const mediaitem = [];
24+
const readable = fs
25+
.createReadStream('data/media_items.csv', 'utf-8')
26+
.pipe(csv());
27+
for await (const row of readable) {
28+
const { id, title, type, year } = row;
29+
mediaitem.push(new MediaItem(id, title, type, year, []));
30+
}
31+
return mediaitem;
32+
}
33+
34+
async loadCredits(): Promise<Credit[]> {
35+
const credits = [];
36+
const readable = fs
37+
.createReadStream('data/credits.csv', 'utf-8')
38+
.pipe(csv());
39+
for await (const row of readable) {
40+
const { media_item_id, role, name } = row;
41+
credits.push(new Credit(media_item_id, name, role));
42+
}
43+
return credits;
44+
}
45+
}

0 commit comments

Comments
 (0)