Skip to content

Commit 86decd1

Browse files
feat: adds csv loader for Dwight (#362)
* feat: lesson 10 Extra Credit by Dwight Blue * feat: loaders module file By Dwight Blue * Update loaders.module.ts --------- Co-authored-by: Anthony D. Mays <[email protected]>
1 parent 8676acd commit 86decd1

File tree

2 files changed

+53
-0
lines changed

2 files changed

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

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
import { Module } from '@nestjs/common';
22
import { AngelicaCastilloLoader } from './angelica_castillo_loader.js';
33
import { AnthonyMaysLoader } from './anthony_mays_loader.js';
4+
import { DwightBlueLoader } from './dwight_blue_loader.js';
45
import { JamesCapparellLoader } from './james_capparell_loader.js';
56
import { NileJacksonLoader } from './nile_jackson_loader.js';
67
import { XavierCruzLoader } from './xavier_cruz_loader.js';
@@ -11,6 +12,7 @@ export const Loaders = Symbol.for('Loaders');
1112
const LOADER_PROVIDERS = [
1213
AnthonyMaysLoader,
1314
AngelicaCastilloLoader,
15+
DwightBlueLoader,
1416
JamesCapparellLoader,
1517
NileJacksonLoader,
1618
XavierCruzLoader,

0 commit comments

Comments
 (0)