1 package de.juplo.kafka.chat.backend;
3 import de.juplo.kafka.chat.backend.domain.ChatHome;
4 import com.fasterxml.jackson.databind.ObjectMapper;
5 import de.juplo.kafka.chat.backend.domain.ChatHomeService;
6 import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatHomeService;
7 import de.juplo.kafka.chat.backend.persistence.storage.files.FilesStorageStrategy;
8 import de.juplo.kafka.chat.backend.persistence.StorageStrategy;
9 import de.juplo.kafka.chat.backend.persistence.inmemory.InMemoryChatRoomService;
10 import org.springframework.boot.context.properties.EnableConfigurationProperties;
11 import org.springframework.context.annotation.Bean;
12 import org.springframework.context.annotation.Configuration;
14 import java.nio.file.Paths;
15 import java.time.Clock;
19 @EnableConfigurationProperties(ChatBackendProperties.class)
20 public class ChatBackendConfiguration
23 public ChatHome chatHome(ChatHomeService chatHomeService)
25 return new ChatHome(chatHomeService);
29 InMemoryChatHomeService chatHomeService(
30 StorageStrategy storageStrategy,
32 ChatBackendProperties properties)
34 return new InMemoryChatHomeService(
35 storageStrategy.read(),
37 properties.getChatroomBufferSize());
41 public StorageStrategy storageStrategy(
42 ChatBackendProperties properties,
46 return new FilesStorageStrategy(
47 Paths.get(properties.getStorageDirectory()),
49 properties.getChatroomBufferSize(),
50 messageFlux -> new InMemoryChatRoomService(messageFlux),
57 return Clock.systemDefaultZone();