Skip to content

Commit 8b61eb5

Browse files
authored
Merge branch 'main' into feature/lesson_10
2 parents 8d5df19 + 3fd39d7 commit 8b61eb5

File tree

6 files changed

+261
-1
lines changed

6 files changed

+261
-1
lines changed
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
package com.codedifferently.lesson9.dataprovider;
2+
3+
import java.util.Map;
4+
import org.springframework.stereotype.Service;
5+
6+
@Service
7+
public class NileJacksonProvider extends DataProvider {
8+
9+
@Override
10+
public String getProviderName() {
11+
12+
return "nilejack";
13+
}
14+
15+
@SuppressWarnings("rawtypes")
16+
@Override
17+
public Map<String, Class> getColumnTypeByName() {
18+
19+
return Map.of(
20+
"column1", Boolean.class,
21+
"column2", Double.class,
22+
"column3", Integer.class,
23+
"column4", Long.class,
24+
"column5", Short.class,
25+
"column6", Float.class,
26+
"column7", String.class);
27+
}
28+
}
Lines changed: 92 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,92 @@
1+
[
2+
{
3+
"column1": "true",
4+
"column2": "8.050105166356494E307",
5+
"column3": "766782637",
6+
"column4": "7298784450208038912",
7+
"column5": "6468",
8+
"column6": "2.9936206E38",
9+
"column7": "w74mkyeujg2"
10+
},
11+
{
12+
"column1": "false",
13+
"column2": "1.438279322271856E308",
14+
"column3": "972373969",
15+
"column4": "2504451348935218688",
16+
"column5": "20311",
17+
"column6": "3.3115875E38",
18+
"column7": "hyjkgt"
19+
},
20+
{
21+
"column1": "false",
22+
"column2": "4.0883457051069477E306",
23+
"column3": "1150975868",
24+
"column4": "5043210076625723392",
25+
"column5": "12219",
26+
"column6": "1.3983301E38",
27+
"column7": "jr7pb1"
28+
},
29+
{
30+
"column1": "true",
31+
"column2": "1.331772707285438E308",
32+
"column3": "1984064480",
33+
"column4": "4514867651350260736",
34+
"column5": "25270",
35+
"column6": "2.5673697E37",
36+
"column7": "c0lyem"
37+
},
38+
{
39+
"column1": "true",
40+
"column2": "8.909705599370497E307",
41+
"column3": "457881506",
42+
"column4": "7352240979843026944",
43+
"column5": "28872",
44+
"column6": "1.3840811E38",
45+
"column7": "8594zfo"
46+
},
47+
{
48+
"column1": "false",
49+
"column2": "2.718461245307317E307",
50+
"column3": "799016699",
51+
"column4": "4209853829876815872",
52+
"column5": "9617",
53+
"column6": "2.902755E38",
54+
"column7": "5wfhieq6k2b"
55+
},
56+
{
57+
"column1": "false",
58+
"column2": "3.575286117193886E307",
59+
"column3": "1796453086",
60+
"column4": "4648194333129626624",
61+
"column5": "28187",
62+
"column6": "2.2096927E38",
63+
"column7": "u7z1osx4l"
64+
},
65+
{
66+
"column1": "false",
67+
"column2": "9.598052667990505E307",
68+
"column3": "868625049",
69+
"column4": "7339097490482971648",
70+
"column5": "274",
71+
"column6": "2.4408217E38",
72+
"column7": "jtr8e73zg"
73+
},
74+
{
75+
"column1": "false",
76+
"column2": "3.660769639887024E307",
77+
"column3": "474245388",
78+
"column4": "2334604646072258048",
79+
"column5": "2051",
80+
"column6": "1.1225729E38",
81+
"column7": "jzaqxuh48d"
82+
},
83+
{
84+
"column1": "true",
85+
"column2": "4.595442288389816E307",
86+
"column3": "907572760",
87+
"column4": "4219750032852018176",
88+
"column5": "8582",
89+
"column6": "3.3740117E38",
90+
"column7": "bpiz3wtjourn"
91+
}
92+
]
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 AngelicaCastilloLoader implements Loader {
7+
getLoaderName(): string {
8+
return 'angelicacastillo';
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 media = [];
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, type, title, year } = row;
29+
media.push(new MediaItem(id, title, type, year, []));
30+
}
31+
return media;
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+
}
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 JamesCapparellLoader implements Loader {
7+
getLoaderName(): string {
8+
return 'jamescapparell';
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 medias = [];
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+
medias.push(new MediaItem(id, title, type, year, []));
30+
}
31+
return medias;
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+
}

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

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,8 @@
11
import { Module } from '@nestjs/common';
2+
import { AngelicaCastilloLoader } from './angelica_castillo_loader.js';
23
import { AnthonyMaysLoader } from './anthony_mays_loader.js';
4+
import { JamesCapparellLoader } from './james_capparell_loader.js';
5+
import { NileJacksonLoader } from './nile_jackson_loader.js';
36
import { XavierCruzLoader } from './xavier_cruz_loader.js';
47
import { AmiyahJonesLoader } from './amiyah_jones.js';
58

@@ -8,8 +11,11 @@ export const Loaders = Symbol.for('Loaders');
811
// Add your quiz provider here.
912
const LOADER_PROVIDERS = [
1013
AnthonyMaysLoader,
14+
AngelicaCastilloLoader,
15+
JamesCapparellLoader,
16+
NileJacksonLoader,
1117
XavierCruzLoader,
12-
AmiyahJonesLoader,
18+
AmiyahJonesLoader
1319
];
1420

1521
@Module({
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)