juplo.de Git - demos/kafka/chat/blob - src/test/java/de/juplo/kafka/chat/backend/implementation/inmemory/SimpleChatHomeServiceTest.java

   1 package de.juplo.kafka.chat.backend.implementation.inmemory;
   2
   3 import com.fasterxml.jackson.databind.ObjectMapper;
   4 import de.juplo.kafka.chat.backend.domain.ChatHomeServiceTest;
   5 import de.juplo.kafka.chat.backend.implementation.StorageStrategy;
   6 import de.juplo.kafka.chat.backend.storage.files.FilesStorageStrategy;
   7 import org.springframework.boot.test.context.TestConfiguration;
   8 import org.springframework.context.annotation.Bean;
   9
  10 import java.nio.file.Paths;
  11 import java.time.Clock;
  12
  13
  14 public class SimpleChatHomeServiceTest extends ChatHomeServiceTest
  15 {
  16   @TestConfiguration
  17   static class Configuration
  18   {
  19     @Bean
  20     SimpleChatHomeService chatHome(
  21         StorageStrategy storageStrategy,
  22         Clock clock)
  23     {
  24       return new SimpleChatHomeService(
  25           storageStrategy,
  26           clock,
  27           bufferSize());
  28     }
  29
  30     @Bean
  31     public FilesStorageStrategy storageStrategy(Clock clock)
  32     {
  33       return new FilesStorageStrategy(
  34           Paths.get("target", "test-classes", "data", "files"),
  35           chatRoomId -> 0,
  36           new ObjectMapper());
  37     }
  38
  39     @Bean
  40     Clock clock()
  41     {
  42       return Clock.systemDefaultZone();
  43     }
  44
  45     int bufferSize()
  46     {
  47       return 8;
  48     }
  49   }
  50 }