Skip to content

Commit 713b355

Browse files
feat: started work on Xavier's lesson_10 parse CSV files/finished extra credit 1
1 parent fc54da1 commit 713b355

File tree

2 files changed

+57
-2
lines changed

2 files changed

+57
-2
lines changed

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

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

66
// Add your quiz provider here.
7-
const LOADER_PROVIDERS = [AnthonyMaysLoader];
7+
const LOADER_PROVIDERS = [AnthonyMaysLoader, XavierCruzLoader];
88

99
@Module({
1010
providers: [
Lines changed: 55 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,55 @@
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 XavierCruzLoader implements Loader {
7+
getLoaderName(): string {
8+
return 'xaviercruz';
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+
for (let i = 0; i < mediaItems.length; i++) {
20+
if (i < 100) {
21+
mediaItems[i].addCredit(credits[i] as Credit); //tests pass however people in credits dont match up to the movies??
22+
}
23+
}
24+
25+
return [...mediaItems.values()];
26+
}
27+
28+
async loadMediaItems(): Promise<MediaItem[]> {
29+
// TODO: Implement this method.
30+
const mediaItems = [];
31+
const readable = fs
32+
.createReadStream('data/media_items.csv', 'utf-8')
33+
.pipe(csv());
34+
35+
for await (const row of readable) {
36+
const { id, type, title, year } = row;
37+
mediaItems.push(new MediaItem(id, title, type, year, []));
38+
}
39+
40+
return mediaItems;
41+
}
42+
43+
//PARSE CSV MANUALLY - Extra Credit
44+
async loadCredits(): Promise<Credit[]> {
45+
const credits = [];
46+
const readable = fs
47+
.createReadStream('data/credits.csv', 'utf-8')
48+
.pipe(csv());
49+
for await (const row of readable) {
50+
const { media_item_id: mediaItemId, role, name } = row;
51+
credits.push({ mediaItemId, name, role });
52+
}
53+
return credits;
54+
}
55+
}

0 commit comments

Comments
 (0)