Skip to content

Commit cf6cf1e

Browse files
author
Ivan Franchin
committed
Refactor application packages
1 parent 19a263f commit cf6cf1e

File tree

12 files changed

+23
-38
lines changed

12 files changed

+23
-38
lines changed

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/rest/PriceController.java renamed to ‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/PriceController.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,7 @@
1-
package com.ivanfranchin.bitcoinapi.rest;
1+
package com.ivanfranchin.bitcoinapi.price;
22

3-
import com.ivanfranchin.bitcoinapi.model.Price;
4-
import com.ivanfranchin.bitcoinapi.rest.dto.PriceResponse;
5-
import com.ivanfranchin.bitcoinapi.service.PriceService;
6-
import io.swagger.v3.oas.annotations.Operation;
3+
import com.ivanfranchin.bitcoinapi.price.dto.PriceResponse;
4+
import com.ivanfranchin.bitcoinapi.price.model.Price;
75
import lombok.RequiredArgsConstructor;
86
import org.springframework.web.bind.annotation.GetMapping;
97
import org.springframework.web.bind.annotation.RequestMapping;
@@ -16,7 +14,6 @@ public class PriceController {
1614

1715
private final PriceService priceService;
1816

19-
@Operation(summary = "Get last price")
2017
@GetMapping("/last")
2118
public PriceResponse getLastPrice() {
2219
Price price = priceService.getLastPrice();

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/kafka/PriceStreamer.java renamed to ‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/PriceEmitter.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
1-
package com.ivanfranchin.bitcoinapi.kafka;
1+
package com.ivanfranchin.bitcoinapi.price;
22

3-
import com.ivanfranchin.bitcoinapi.model.Price;
3+
import com.ivanfranchin.bitcoinapi.price.message.PriceMessage;
4+
import com.ivanfranchin.bitcoinapi.price.model.Price;
45
import lombok.RequiredArgsConstructor;
56
import lombok.extern.slf4j.Slf4j;
67
import org.springframework.cloud.stream.function.StreamBridge;
@@ -9,7 +10,7 @@
910
@Slf4j
1011
@RequiredArgsConstructor
1112
@Component
12-
public class PriceStreamer {
13+
public class PriceEmitter {
1314

1415
private final StreamBridge streamBridge;
1516

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/repository/PriceRepository.java renamed to ‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/PriceRepository.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
package com.ivanfranchin.bitcoinapi.repository;
1+
package com.ivanfranchin.bitcoinapi.price;
22

3-
import com.ivanfranchin.bitcoinapi.model.Price;
3+
import com.ivanfranchin.bitcoinapi.price.model.Price;
44
import org.springframework.data.repository.CrudRepository;
55
import org.springframework.stereotype.Repository;
66

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/service/PriceServiceImpl.java renamed to ‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/PriceService.java

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,22 +1,19 @@
1-
package com.ivanfranchin.bitcoinapi.service;
1+
package com.ivanfranchin.bitcoinapi.price;
22

3-
import com.ivanfranchin.bitcoinapi.model.Price;
4-
import com.ivanfranchin.bitcoinapi.repository.PriceRepository;
3+
import com.ivanfranchin.bitcoinapi.price.model.Price;
54
import lombok.RequiredArgsConstructor;
65
import org.springframework.stereotype.Service;
76

87
@RequiredArgsConstructor
98
@Service
10-
public class PriceServiceImpl implements PriceService {
9+
public class PriceService {
1110

1211
private final PriceRepository priceRepository;
1312

14-
@Override
1513
public Price getLastPrice() {
1614
return priceRepository.findTopByOrderByTimestampDesc();
1715
}
1816

19-
@Override
2017
public Price savePrice(Price price) {
2118
return priceRepository.save(price);
2219
}

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/rest/dto/PriceResponse.java renamed to ‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/dto/PriceResponse.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.ivanfranchin.bitcoinapi.rest.dto;
1+
package com.ivanfranchin.bitcoinapi.price.dto;
22

33
import java.math.BigDecimal;
44
import java.time.LocalDateTime;

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/kafka/PriceMessage.java renamed to ‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/message/PriceMessage.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.ivanfranchin.bitcoinapi.kafka;
1+
package com.ivanfranchin.bitcoinapi.price.message;
22

33
import java.math.BigDecimal;
44
import java.time.LocalDateTime;

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/model/Price.java renamed to ‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/price/model/Price.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.ivanfranchin.bitcoinapi.model;
1+
package com.ivanfranchin.bitcoinapi.price.model;
22

33
import jakarta.persistence.Column;
44
import jakarta.persistence.Entity;

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/runner/SimulationRunner.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package com.ivanfranchin.bitcoinapi.runner;
22

3-
import com.ivanfranchin.bitcoinapi.model.Price;
4-
import com.ivanfranchin.bitcoinapi.service.PriceService;
3+
import com.ivanfranchin.bitcoinapi.price.model.Price;
4+
import com.ivanfranchin.bitcoinapi.price.PriceService;
55
import lombok.RequiredArgsConstructor;
66
import org.springframework.boot.CommandLineRunner;
77
import org.springframework.stereotype.Component;

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/scheduler/PriceScheduler.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,8 +1,8 @@
11
package com.ivanfranchin.bitcoinapi.scheduler;
22

3-
import com.ivanfranchin.bitcoinapi.kafka.PriceStreamer;
4-
import com.ivanfranchin.bitcoinapi.model.Price;
5-
import com.ivanfranchin.bitcoinapi.service.PriceService;
3+
import com.ivanfranchin.bitcoinapi.price.PriceEmitter;
4+
import com.ivanfranchin.bitcoinapi.price.model.Price;
5+
import com.ivanfranchin.bitcoinapi.price.PriceService;
66
import lombok.RequiredArgsConstructor;
77
import lombok.extern.slf4j.Slf4j;
88
import org.springframework.scheduling.annotation.Scheduled;
@@ -20,7 +20,7 @@
2020
public class PriceScheduler {
2121

2222
private final PriceService priceService;
23-
private final PriceStreamer priceStreamer;
23+
private final PriceEmitter priceStreamer;
2424

2525
@Scheduled(cron = "*/5 * * * * *") // every 5 seconds
2626
public void streamNewPrice() {

‎bitcoin-api/src/main/java/com/ivanfranchin/bitcoinapi/service/PriceService.java

Lines changed: 0 additions & 10 deletions
This file was deleted.

‎bitcoin-client/src/main/java/com/ivanfranchin/bitcoinclient/controller/PriceController.java renamed to ‎bitcoin-client/src/main/java/com/ivanfranchin/bitcoinclient/controller/UIController.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010

1111
@RequiredArgsConstructor
1212
@Controller
13-
public class PriceController {
13+
public class UIController {
1414

1515
private final SimpMessagingTemplate simpMessagingTemplate;
1616

‎bitcoin-client/src/main/java/com/ivanfranchin/bitcoinclient/kafka/PriceStream.java renamed to ‎bitcoin-client/src/main/java/com/ivanfranchin/bitcoinclient/kafka/PriceListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@
1616
@Slf4j
1717
@RequiredArgsConstructor
1818
@Component
19-
public class PriceStream {
19+
public class PriceListener {
2020

2121
private final SimpMessagingTemplate simpMessagingTemplate;
2222

0 commit comments

Comments
 (0)