12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- package com.provectus.kafka.ui.controller;
- import com.provectus.kafka.ui.util.ResourceUtil;
- import java.util.concurrent.atomic.AtomicReference;
- import lombok.RequiredArgsConstructor;
- import lombok.SneakyThrows;
- import lombok.extern.log4j.Log4j2;
- import org.springframework.beans.factory.annotation.Value;
- import org.springframework.boot.autoconfigure.web.ServerProperties;
- import org.springframework.core.io.Resource;
- import org.springframework.http.ResponseEntity;
- import org.springframework.web.bind.annotation.GetMapping;
- import org.springframework.web.bind.annotation.RestController;
- import reactor.core.publisher.Mono;
- @RestController
- @RequiredArgsConstructor
- @Log4j2
- public class StaticController {
- private final ServerProperties serverProperties;
- @Value("classpath:static/index.html")
- private Resource indexFile;
- private final AtomicReference<String> renderedIndexFile = new AtomicReference<>();
- @GetMapping(value = "/index.html", produces = { "text/html" })
- public Mono<ResponseEntity<String>> getIndex() {
- return Mono.just(ResponseEntity.ok(getRenderedIndexFile()));
- }
- public String getRenderedIndexFile() {
- String rendered = renderedIndexFile.get();
- if (rendered == null) {
- rendered = buildIndexFile();
- if (renderedIndexFile.compareAndSet(null, rendered)) {
- return rendered;
- } else {
- return renderedIndexFile.get();
- }
- } else {
- return rendered;
- }
- }
- @SneakyThrows
- private String buildIndexFile() {
- final String contextPath = serverProperties.getServlet().getContextPath() != null
- ? serverProperties.getServlet().getContextPath() : "";
- final String staticPath = contextPath + "/static";
- return ResourceUtil.readAsString(indexFile)
- .replace("href=\"./static", "href=\"" + staticPath)
- .replace("src=\"./static", "src=\"" + staticPath)
- .replace("window.basePath=\"/\"", "window.basePath=\"" + contextPath + "\"");
- }
- }
|