diff options
Diffstat (limited to 'jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain')
9 files changed, 285 insertions, 0 deletions
diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/GameEntity.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/GameEntity.java new file mode 100644 index 0000000..e248cb5 --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/GameEntity.java @@ -0,0 +1,4 @@ +package fr.epita.assistants.item_producer.domain.entity; + +public class GameEntity { +} diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/ItemEntity.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/ItemEntity.java new file mode 100644 index 0000000..a8b666d --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/ItemEntity.java @@ -0,0 +1,13 @@ +package fr.epita.assistants.item_producer.domain.entity; + +import fr.epita.assistants.common.aggregate.ItemAggregate; +import lombok.AllArgsConstructor; +import lombok.Getter; + +@Getter +@AllArgsConstructor +public class ItemEntity { + long id; + float quantity; + ItemAggregate.ResourceType type; +} diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/ItemsEntity.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/ItemsEntity.java new file mode 100644 index 0000000..b03b373 --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/ItemsEntity.java @@ -0,0 +1,13 @@ +package fr.epita.assistants.item_producer.domain.entity; + +import fr.epita.assistants.common.api.response.ItemResponse; +import lombok.AllArgsConstructor; +import lombok.Getter; + +import java.util.List; + +@Getter +@AllArgsConstructor +public class ItemsEntity { + List<ItemEntity> items; +} diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/MoveEntity.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/MoveEntity.java new file mode 100644 index 0000000..72ea511 --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/MoveEntity.java @@ -0,0 +1,11 @@ +package fr.epita.assistants.item_producer.domain.entity; + +import lombok.AllArgsConstructor; +import lombok.Getter; + +@Getter +@AllArgsConstructor +public class MoveEntity { + int posX; + int posY; +} diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/PlayerEntity.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/PlayerEntity.java new file mode 100644 index 0000000..0913c3f --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/PlayerEntity.java @@ -0,0 +1,18 @@ +package fr.epita.assistants.item_producer.domain.entity; + +import lombok.AllArgsConstructor; +import lombok.Getter; + +import java.time.LocalDateTime; + +@AllArgsConstructor +@Getter +public class PlayerEntity { + int posX; + int posY; + LocalDateTime lastMove; + LocalDateTime lastCollect; + float moveSpeedMultiplier; + float staminaMultiplier; + float collectRateMultiplier; +} diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/StartEntity.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/StartEntity.java new file mode 100644 index 0000000..44a4961 --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/StartEntity.java @@ -0,0 +1,11 @@ +package fr.epita.assistants.item_producer.domain.entity; + +import lombok.AllArgsConstructor; +import lombok.Getter; + +@Getter +@AllArgsConstructor +public class StartEntity { + String mapPath; + String rle; +} diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/UpgradeCostEntity.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/UpgradeCostEntity.java new file mode 100644 index 0000000..fac79e0 --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/entity/UpgradeCostEntity.java @@ -0,0 +1,12 @@ +package fr.epita.assistants.item_producer.domain.entity; + +import lombok.AllArgsConstructor; +import lombok.Getter; + +@Getter +@AllArgsConstructor +public class UpgradeCostEntity { + float upgradeCollectCost; + float upgradeMoveCost; + float upgradeStaminaCost; +} diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/service/ErwenService.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/service/ErwenService.java new file mode 100644 index 0000000..fb3a507 --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/service/ErwenService.java @@ -0,0 +1,4 @@ +package fr.epita.assistants.item_producer.domain.service; + +public class ErwenService { +} diff --git a/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/service/ItemProducerService.java b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/service/ItemProducerService.java new file mode 100644 index 0000000..2a224c7 --- /dev/null +++ b/jws/epibazaar/item-producer/src/main/java/fr/epita/assistants/item_producer/domain/service/ItemProducerService.java @@ -0,0 +1,199 @@ +package fr.epita.assistants.item_producer.domain.service; + +import fr.epita.assistants.common.aggregate.ItemAggregate; +import fr.epita.assistants.common.aggregate.ResetInventoryAggregate; +import fr.epita.assistants.common.api.response.*; +import fr.epita.assistants.common.command.*; +import fr.epita.assistants.common.utils.Direction; +import fr.epita.assistants.item_producer.converter.ItemProducerConverter; +import fr.epita.assistants.item_producer.data.model.ItemModel; +import fr.epita.assistants.item_producer.data.model.PlayerModel; +import fr.epita.assistants.item_producer.data.repository.GameRepository; +import fr.epita.assistants.item_producer.data.repository.ItemRepository; +import fr.epita.assistants.item_producer.data.repository.PlayerRepository; +import fr.epita.assistants.item_producer.domain.entity.*; +import io.smallrye.reactive.messaging.annotations.Broadcast; +import jakarta.enterprise.context.ApplicationScoped; +import org.eclipse.microprofile.config.inject.ConfigProperty; +import org.eclipse.microprofile.reactive.messaging.Channel; +import org.eclipse.microprofile.reactive.messaging.Emitter; + +import jakarta.inject.Inject; + +import java.io.File; +import java.io.IOException; +import java.nio.file.Files; +import java.nio.file.Paths; +import java.time.LocalDateTime; +import java.time.temporal.ChronoUnit; +import java.util.List; +import java.util.Optional; +import java.util.stream.Collectors; +import java.util.stream.Stream; + +@ApplicationScoped +public class ItemProducerService { + @ConfigProperty(name = "JWS_TICK_DURATION") + String tps; + @ConfigProperty(name = "JWS_DELAY_MOVEMENT") + String movementDelay; + @ConfigProperty(name = "JWS_DELAY_COLLECT") + String collectDelay; + @ConfigProperty(name = "JWS_UPGRADE_COLLECT_COST") + String upgradeCollectCost; + @ConfigProperty(name = "JWS_UPGRADE_MOVE_COST") + String upgradeMoveCost; + @ConfigProperty(name = "JWS_UPGRADE_STAMINA_COST") + String upgradeStaminaCost; + @ConfigProperty(name = "JWS_UPGRADE_MULTIPLIER") + String upgradeMultiplier; + @Inject + PlayerRepository playerRepository; + @Inject + GameRepository gameRepository; + @Inject + ItemRepository itemRepository; + + @Inject + @Channel("reset-inventory-command") + @Broadcast + Emitter<ResetInventoryCommand> resetInventoryCommandEmitter; + @Inject + @Channel("collect-item-command") + @Broadcast + Emitter<CollectItemCommand> collectItemCommandEmitter; + @Inject + @Channel("upgrade-movement-speed-command") + @Broadcast + Emitter<UpgradeMovementSpeedCommand> upgradeMovementSpeedCommandEmitter; + @Inject + @Channel("upgrade-stamina-command") + @Broadcast + Emitter<UpgradeStaminaCommand> upgradeStaminaCommandEmitter; + @Inject + @Channel("upgrade-collect-rate-command") + @Broadcast + Emitter<UpgradeCollectRateCommand> upgradeCollectRateCommandEmitter; + + public StartEntity startGame(StartEntity startEntity) { + if (startEntity == null) + return null; + gameRepository.clearDB(); + playerRepository.clearDB(); + try (Stream<String> stream = Files.lines(Paths.get(startEntity.getMapPath()))) { + if (new File(startEntity.getMapPath()).isDirectory()) + return null; + String rle = stream.collect(Collectors.joining(";")); + gameRepository.addEntry(rle); + playerRepository.addEntry(); + resetInventoryCommandEmitter.send(new ResetInventoryCommand()); + return new StartEntity(null, rle); + } catch (IOException e) { + return null; + } + } + + public void clearItems(ResetInventoryAggregate items) { + itemRepository.deleteItems(ItemProducerConverter.DeleteItems(items)); + } + + public ItemsEntity getAllItems() { + return new ItemsEntity(itemRepository.getItems().stream().map(m -> new ItemEntity(m.getId(), + m.getQuantity(), m.getType())).toList()); + } + + public boolean isGameRunning() { + return !gameRepository.isEmpty(); + } + + public boolean canMove() { + long tickRate = Long.parseLong(tps); + long moveDelay = Long.parseLong(movementDelay); + PlayerEntity player = getCurrentPlayer(); + return player.getLastMove() == null || player.getLastMove().plus((long) (moveDelay * tickRate * player.getMoveSpeedMultiplier()), + ChronoUnit.MILLIS).isBefore(LocalDateTime.now()); + } + + public boolean canCollect() { + long tickRate = Long.parseLong(tps); + long collectDelayLong = Long.parseLong(collectDelay); + PlayerEntity player = getCurrentPlayer(); + return player.getLastCollect() == null || player.getLastCollect().plus((long) (collectDelayLong * tickRate * player.getMoveSpeedMultiplier()), + ChronoUnit.MILLIS).isBefore(LocalDateTime.now()); + } + + public PlayerEntity getCurrentPlayer() { + PlayerModel p = playerRepository.getFirstPlayer(); + return new PlayerEntity(p.getPosX(), p.getPosY(), p.getLastMove(), p.getLastCollect(), + p.getMoveSpeedMultiplier(), p.getStaminaMultiplier(), p.getCollectRateMultiplier()); + } + + public UpgradeCostEntity getUpgradeCosts() { + return new UpgradeCostEntity(Float.parseFloat(upgradeCollectCost), + Float.parseFloat(upgradeMoveCost), Float.parseFloat(upgradeStaminaCost)); + } + + public MoveEntity move(Direction direction) { + if (direction == null) + return null; + if (!playerRepository.isValidMove(direction, gameRepository.getMap())) + return null; + playerRepository.movePlayer(direction); + return ItemProducerConverter.Move(playerRepository.getFirstPlayer()); + } + + public StartEntity collect() { + PlayerEntity player = getCurrentPlayer(); + if (!gameRepository.isValidCollect(player.getPosX(), player.getPosY())) + return null; + String item = gameRepository.collectResource(player.getPosX(), player.getPosY()); + gameRepository.setToGround(player.getPosX(), player.getPosY()); + collectItemCommandEmitter.send(new CollectItemCommand(ItemAggregate.ResourceType.valueOf(item), + player.getCollectRateMultiplier())); + return ItemProducerConverter.Collect(item); + } + + public void collectItem(ItemAggregate agr) { + Optional<ItemModel> item = itemRepository.exists(agr.getType()); + if (item.isPresent()) { + itemRepository.fillInventory(agr.getType(), agr.getQuantity()); + } else { + itemRepository.addItem(agr.getType(), agr.getQuantity()); + } + } + + public Double getMoney() { + List<ItemModel> entries = itemRepository.getMoney(); + if (entries.isEmpty()) + return null; + return entries.stream().mapToDouble(m -> m.getQuantity().doubleValue()).sum(); + } + + public void upgradeMove() { + upgradeMovementSpeedCommandEmitter.send(new UpgradeMovementSpeedCommand(Float.parseFloat(upgradeMoveCost))); + } + + public void updateMove() { + playerRepository.updateMoveSpeed(getCurrentPlayer().getMoveSpeedMultiplier() - Float.parseFloat(upgradeMultiplier)); + } + + public void upgradeCollect() { + upgradeCollectRateCommandEmitter.send(new UpgradeCollectRateCommand(Float.parseFloat(upgradeMoveCost))); + } + + public void updateCollect() { + playerRepository.updateCollectRate(getCurrentPlayer().getCollectRateMultiplier() - Float.parseFloat(upgradeMultiplier)); + } + + public void upgradeStamina() { + upgradeStaminaCommandEmitter.send(new UpgradeStaminaCommand(Float.parseFloat(upgradeMoveCost))); + } + + public void updateStamina() { + playerRepository.updateStamina(getCurrentPlayer().getStaminaMultiplier() - Float.parseFloat(upgradeMultiplier)); + } + + public void pay(Float newMoney) { + itemRepository.fillInventory(ItemAggregate.ResourceType.MONEY, newMoney); + } +} |