-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Adding spring integration for messages and redis for clustering (#27)
* Spring Integration * Caffeine Cache * Redis Profile for clustering
- Loading branch information
Showing
126 changed files
with
3,347 additions
and
2,453 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,209 @@ | ||
| package jasper.component; | ||
|
|
||
| import com.fasterxml.jackson.databind.ObjectMapper; | ||
| import com.fasterxml.jackson.databind.node.ObjectNode; | ||
| import jasper.component.dto.ComponentDtoMapper; | ||
| import jasper.config.Config.SecurityConfig; | ||
| import jasper.config.Config.ServerConfig; | ||
| import jasper.config.Props; | ||
| import jasper.domain.Plugin; | ||
| import jasper.domain.Template; | ||
| import jasper.repository.PluginRepository; | ||
| import jasper.repository.RefRepository; | ||
| import jasper.repository.TemplateRepository; | ||
| import jasper.repository.UserRepository; | ||
| import jasper.repository.filter.RefFilter; | ||
| import jasper.service.dto.PluginDto; | ||
| import jasper.service.dto.TemplateDto; | ||
| import jasper.service.dto.UserDto; | ||
| import org.slf4j.Logger; | ||
| import org.slf4j.LoggerFactory; | ||
| import org.springframework.beans.factory.annotation.Autowired; | ||
| import org.springframework.cache.annotation.CacheEvict; | ||
| import org.springframework.cache.annotation.Cacheable; | ||
| import org.springframework.stereotype.Component; | ||
| import org.springframework.transaction.annotation.Transactional; | ||
|
|
||
| import javax.annotation.PostConstruct; | ||
| import java.util.List; | ||
| import java.util.Optional; | ||
|
|
||
| @Component | ||
| public class ConfigCache { | ||
| private static final Logger logger = LoggerFactory.getLogger(ConfigCache.class); | ||
|
|
||
| @Autowired | ||
| Props props; | ||
|
|
||
| @Autowired | ||
| RefRepository refRepository; | ||
|
|
||
| @Autowired | ||
| UserRepository userRepository; | ||
|
|
||
| @Autowired | ||
| PluginRepository pluginRepository; | ||
|
|
||
| @Autowired | ||
| TemplateRepository templateRepository; | ||
|
|
||
| @Autowired | ||
| IngestTemplate ingest; | ||
|
|
||
| @Autowired | ||
| ObjectMapper objectMapper; | ||
|
|
||
| @Autowired | ||
| ComponentDtoMapper dtoMapper; | ||
|
|
||
| @PostConstruct | ||
| public void init() { | ||
| if (templateRepository.findByTemplateAndOrigin("_config/server", "").isEmpty()) { | ||
| ingest.push(config()); | ||
| } | ||
| } | ||
|
|
||
| @CacheEvict(value = "config-cache", allEntries = true) | ||
| public void clearConfigCache() { | ||
| logger.info("Cleared config cache."); | ||
| } | ||
|
|
||
| @CacheEvict(value = "user-cache", allEntries = true) | ||
| public void clearUserCache() { | ||
| logger.info("Cleared user cache."); | ||
| } | ||
|
|
||
| @CacheEvict(value = { | ||
| "plugin-cache", | ||
| "plugin-config-cache", | ||
| "plugin-metadata-cache", | ||
| "all-plugins-cache", | ||
| }, | ||
| allEntries = true) | ||
| public void clearPluginCache() { | ||
| logger.info("Cleared plugin cache."); | ||
| } | ||
|
|
||
| @CacheEvict(value = { | ||
| "template-cache", | ||
| "template-config-cache", | ||
| "template-cache-wrapped", | ||
| "template-schemas-cache", | ||
| "all-templates-cache", | ||
| }, | ||
| allEntries = true) | ||
| public void clearTemplateCache() { | ||
| logger.info("Cleared template cache."); | ||
| } | ||
|
|
||
| @Cacheable("user-cache") | ||
| @Transactional(readOnly = true) | ||
| public UserDto getUser(String tag) { | ||
| return userRepository.findOneByQualifiedTag(tag) | ||
| .map(dtoMapper::domainToDto) | ||
| .orElse(null); | ||
| } | ||
|
|
||
| @Cacheable(value = "config-cache", key = "#tag + #origin + '@' + #url") | ||
| @Transactional(readOnly = true) | ||
| public <T> T getConfig(String url, String origin, String tag, Class<T> toValueType) { | ||
| return refRepository.findOneByUrlAndOrigin(url, origin) | ||
| .map(r -> r.getPlugin(tag, toValueType)) | ||
| .orElse(objectMapper.convertValue(objectMapper.createObjectNode(), toValueType)); | ||
| } | ||
|
|
||
| @Cacheable(value = "config-cache", key = "#tag + #origin") | ||
| @Transactional(readOnly = true) | ||
| public <T> List<T> getAllConfigs(String origin, String tag, Class<T> toValueType) { | ||
| return refRepository.findAll( | ||
| RefFilter.builder() | ||
| .origin(origin) | ||
| .query(tag).build().spec()).stream() | ||
| .map(r -> r.getPlugin(tag, toValueType)) | ||
| .toList(); | ||
| } | ||
|
|
||
| @Cacheable(value = "plugin-config-cache", key = "#tag + #origin") | ||
| @Transactional(readOnly = true) | ||
| public <T> T getPluginConfig(String tag, String origin, Class<T> toValueType) { | ||
| return pluginRepository.findByTagAndOrigin(tag, origin) | ||
| .map(r -> r.getConfig(toValueType)) | ||
| .orElse(objectMapper.convertValue(objectMapper.createObjectNode(), toValueType)); | ||
| } | ||
|
|
||
| @Cacheable(value = "plugin-cache", key = "#tag + #origin") | ||
| @Transactional(readOnly = true) | ||
| public Optional<Plugin> getPlugin(String tag, String origin) { | ||
| return pluginRepository.findByTagAndOrigin(tag, origin); | ||
| } | ||
|
|
||
| @Cacheable("plugin-metadata-cache") | ||
| @Transactional(readOnly = true) | ||
| public List<String> getMetadataPlugins(String origin) { | ||
| return pluginRepository.findAllByGenerateMetadataByOrigin(origin); | ||
| } | ||
|
|
||
| @Cacheable("all-plugins-cache") | ||
| @Transactional(readOnly = true) | ||
| public List<PluginDto> getAllPlugins(String origin) { | ||
| return pluginRepository.findAllByOrigin(origin) | ||
| .stream() | ||
| .map(dtoMapper::domainToDto) | ||
| .toList(); | ||
| } | ||
|
|
||
| @Cacheable(value = "template-config-cache", key = "#template + #origin") | ||
| @Transactional(readOnly = true) | ||
| public <T> T getTemplateConfig(String template, String origin, Class<T> toValueType) { | ||
| return templateRepository.findByTemplateAndOrigin(template, origin) | ||
| .map(r -> r.getConfig(toValueType)) | ||
| .orElse(objectMapper.convertValue(objectMapper.createObjectNode(), toValueType)); | ||
| } | ||
|
|
||
| @Cacheable(value = "template-cache", key = "#template + #origin") | ||
| @Transactional(readOnly = true) | ||
| public Optional<Template> getTemplate(String template, String origin) { | ||
| return templateRepository.findByTemplateAndOrigin(template, origin); | ||
| } | ||
|
|
||
| @Cacheable(value = "template-cache", key = "'_config/server'") | ||
| @Transactional(readOnly = true) | ||
| public ServerConfig root() { | ||
| return getTemplateConfig("_config/server", "", ServerConfig.class); | ||
| } | ||
|
|
||
| @Cacheable(value = "template-cache-wrapped", key = "'_config/security' + #origin") | ||
| @Transactional(readOnly = true) | ||
| public SecurityConfig security(String origin) { | ||
| // TODO: crawl origin hierarchy until found | ||
| return getTemplateConfig("_config/security", origin, SecurityConfig.class) | ||
| .wrap(props); | ||
| } | ||
|
|
||
| @Cacheable("template-schemas-cache") | ||
| @Transactional(readOnly = true) | ||
| public List<TemplateDto> getSchemas(String tag, String origin) { | ||
| return templateRepository.findAllForTagAndOriginWithSchema(tag, origin) | ||
| .stream() | ||
| .map(dtoMapper::domainToDto) | ||
| .toList(); | ||
| } | ||
|
|
||
| @Cacheable("all-templates-cache") | ||
| @Transactional(readOnly = true) | ||
| public List<TemplateDto> getAllTemplates(String origin) { | ||
| return templateRepository.findAllByOrigin(origin) | ||
| .stream() | ||
| .map(dtoMapper::domainToDto) | ||
| .toList(); | ||
| } | ||
|
|
||
| private Template config() { | ||
| var config = objectMapper.convertValue(objectMapper.createObjectNode(), ServerConfig.class); | ||
| var template = new Template(); | ||
| template.setTag("_config/server"); | ||
| template.setName("Server Config"); | ||
| template.setConfig(objectMapper.convertValue(config, ObjectNode.class)); | ||
| return template; | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.