Compare commits

..

5 commits

4 changed files with 6 additions and 4 deletions

View file

@ -14,7 +14,7 @@
<groupId>eu.ztsh</groupId> <groupId>eu.ztsh</groupId>
<artifactId>large-file-reading-challenge</artifactId> <artifactId>large-file-reading-challenge</artifactId>
<name>Large File Reading Challenge</name> <name>Large File Reading Challenge</name>
<version>1.0.0-SNAPSHOT</version> <version>1.0.0</version>
<properties> <properties>
<!-- encoding --> <!-- encoding -->

View file

@ -30,7 +30,7 @@ public class TemperaturesServiceImpl implements TemperaturesService {
Thread.currentThread().interrupt(); Thread.currentThread().interrupt();
} }
} }
return averages.get().get(city); return averages.get().getOrDefault(city.toLowerCase(), List.of());
} }
@EventListener(FileProcessedEvent.class) @EventListener(FileProcessedEvent.class)

View file

@ -79,7 +79,9 @@ public class FileLoadingService {
.map(line -> { .map(line -> {
try { try {
var parts = line.split(";"); var parts = line.split(";");
return new DataRow(parts[0], Integer.parseInt(parts[1].split("-")[0]), Double.parseDouble(parts[2])); return new DataRow(parts[0].toLowerCase(),
Integer.parseInt(parts[1].split("-")[0]),
Double.parseDouble(parts[2]));
} catch (Exception e) { } catch (Exception e) {
throw new FileProcessingException("Error in line %s".formatted(line), e); throw new FileProcessingException("Error in line %s".formatted(line), e);
} }

View file

@ -29,7 +29,7 @@ class FileLoadingServiceTest {
.publishEvent(captor.capture()); .publishEvent(captor.capture());
var averages = captor.getValue().averages(); var averages = captor.getValue().averages();
assertThat(averages).hasSize(1); assertThat(averages).hasSize(1);
var list = averages.get("Warszawa"); var list = averages.get("warszawa");
assertThat(list).hasSize(1); assertThat(list).hasSize(1);
assertThat(list.getFirst()).satisfies(item -> { assertThat(list.getFirst()).satisfies(item -> {
assertThat(item.getYear()).isEqualTo("2018"); assertThat(item.getYear()).isEqualTo("2018");