Add marketplace endpoints and implements get all catalogs service method.

This commit is contained in:
Florian THIERRY
2025-09-18 17:43:15 +02:00
parent 8f90eef5d4
commit 9dce18d00f
7 changed files with 93 additions and 0 deletions

View File

@@ -4,6 +4,7 @@ import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.catalog.mo
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.catalog.port.CatalogPort;
import org.springframework.stereotype.Service;
import java.util.List;
import java.util.Optional;
import java.util.UUID;
@@ -18,4 +19,8 @@ public class CatalogService {
public Optional<Catalog> getById(UUID catalogId) {
return catalogPort.getById(catalogId);
}
public List<Catalog> getAll() {
return catalogPort.getAll();
}
}

View File

@@ -2,9 +2,11 @@ package com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.catalog.p
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.catalog.model.Catalog;
import java.util.List;
import java.util.Optional;
import java.util.UUID;
public interface CatalogPort {
Optional<Catalog> getById(UUID catalogId);
List<Catalog> getAll();
}

View File

@@ -0,0 +1,28 @@
package com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.marketplace;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.catalog.CatalogService;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.item.ItemService;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.item.model.Item;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.marketplace.model.Marketplace;
import org.springframework.stereotype.Service;
@Service
public class MarketplaceService {
private final CatalogService catalogService;
private final ItemService itemService;
public MarketplaceService(CatalogService catalogService, ItemService itemService) {
this.catalogService = catalogService;
this.itemService = itemService;
}
public Marketplace getMarketplace() {
return new Marketplace(
catalogService.getAll(),
itemService.getAllItems()
.stream()
.filter(Item::isShared)
.toList()
);
}
}

View File

@@ -0,0 +1,8 @@
package com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.marketplace.model;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.catalog.model.Catalog;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.item.model.Item;
import java.util.List;
public record Marketplace(List<Catalog> catalogs, List<Item> sharedItems) {}

View File

@@ -0,0 +1,24 @@
package com.zeenea.experiments.virtualthreads.virtualthreadsapp.exposition.marketplace;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.marketplace.MarketplaceService;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.marketplace.model.Marketplace;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.exposition.marketplace.model.MarketplaceDto;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
@RequestMapping("/api/marketplace")
public class MarketplaceController {
private final MarketplaceService marketplaceService;
public MarketplaceController(MarketplaceService marketplaceService) {
this.marketplaceService = marketplaceService;
}
@GetMapping
public MarketplaceDto getMarketplace() {
Marketplace marketplace = marketplaceService.getMarketplace();
return new MarketplaceDto(marketplace);
}
}

View File

@@ -0,0 +1,17 @@
package com.zeenea.experiments.virtualthreads.virtualthreadsapp.exposition.marketplace.model;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.domain.marketplace.model.Marketplace;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.exposition.catalog.model.CatalogDto;
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.exposition.item.model.ItemDto;
import java.util.List;
public record MarketplaceDto(List<CatalogDto> catalogs, List<ItemDto> sharedItems) {
public MarketplaceDto(Marketplace marketplace) {
this(
marketplace.catalogs().stream().map(CatalogDto::new).toList(),
marketplace.sharedItems().stream().map(ItemDto::new).toList()
);
}
}

View File

@@ -6,6 +6,7 @@ import com.zeenea.experiments.virtualthreads.virtualthreadsapp.infrastructure.ca
import com.zeenea.experiments.virtualthreads.virtualthreadsapp.infrastructure.catalog.repository.CatalogJpaRepository;
import org.springframework.stereotype.Component;
import java.util.List;
import java.util.Optional;
import java.util.UUID;
@@ -22,4 +23,12 @@ public class CatalogJpaAdapter implements CatalogPort {
return catalogJpaRepository.findById(catalogId)
.map(CatalogJpaEntity::toDomain);
}
@Override
public List<Catalog> getAll() {
return catalogJpaRepository.findAll()
.stream()
.map(CatalogJpaEntity::toDomain)
.toList();
}
}