Skip to content

Commit fefe89e

Browse files
Meiko-S22Meiko-S22anthonydmays
authored
feat: add Meiko's media items loader (#366)
* feat: add Meiko lesson 10 * fix: updated lesson 10 --------- Co-authored-by: Meiko-S22 <mdstephens251@gmail,.com> Co-authored-by: Anthony D. Mays <[email protected]>
1 parent 9e63e47 commit fefe89e

File tree

2 files changed

+59
-0
lines changed

2 files changed

+59
-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 { ChanelHuttLoader } from './chanel_hutt_loader.js';
55
import { DavidAdenaikeLoader } from './david_adenaike_loader.js';
66
import { DavisDLoader } from './davis_d_loader.js';
77
import { DylanLaffertysLoader } from './dylan_lafferty_loaders.js';
8+
import { MeikoStephensLoader } from './meiko_stephens_loader.js';
89
import { NiaPackLoader } from './nia_pack_loader.js';
910
import { JBeyLoader } from './JBey_loader.js';
1011
import { KarenAlabiLoader } from './karen_alabi_loader.js';
@@ -29,6 +30,7 @@ const LOADER_PROVIDERS = [
2930
KarenAlabiLoader,
3031
RasheedMillerLoader,
3132
DavidAdenaikeLoader,
33+
MeikoStephensLoader,
3234
MontezBLoader,
3335
OliviaJamesLoader
3436
];
Lines changed: 57 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,57 @@
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+
16+
for (const mediaItem of mediaItems) {
17+
mediaMap.set(mediaItem.getId(), mediaItem);
18+
}
19+
for (const credit of credits) {
20+
const mediaItem = mediaMap.get(credit.getMediaItemId());
21+
22+
if (mediaItem) {
23+
mediaItem.addCredit(credit);
24+
}
25+
}
26+
27+
console.log(
28+
`Loaded ${credits.length} credits and ${mediaItems.length} media items`,
29+
);
30+
31+
return Array.from(mediaMap.values());
32+
}
33+
34+
async loadMediaItems(): Promise<MediaItem[]> {
35+
const mediaItems = [];
36+
const readable = fs
37+
.createReadStream('data/media_items.csv', 'utf-8')
38+
.pipe(csv());
39+
for await (const row of readable) {
40+
const { id, title, type, year } = row;
41+
mediaItems.push(new MediaItem(id, title, type, year, []));
42+
}
43+
return mediaItems;
44+
}
45+
46+
async loadCredits(): Promise<Credit[]> {
47+
const credits = [];
48+
const readable = fs
49+
.createReadStream('data/credits.csv', 'utf-8')
50+
.pipe(csv());
51+
for await (const row of readable) {
52+
const { media_item_id, role, name } = row;
53+
credits.push(new Credit(media_item_id, name, role));
54+
}
55+
return credits;
56+
}
57+
}

0 commit comments

Comments
 (0)