Spring BootとGridDBを使ったブログ投票ウェブ・プラットフォームの構築

@Data
public class User {
    @RowKey
    String id;
    String email;
    String fullName;
    Date createdAt;
}

@Data
public class Blog {
    @RowKey
    String id;
    String title;
    Integer voteUpCount;
    Integer voteDownCount;
    Date createdAt;
}

@Data
public class VoteMetrics {
    @RowKey
    Date timestamp;
    String blogId;
    String userId;
    Integer voteType;
}

@Configuration
public class GridDBConfig {

  @Value("${GRIDDB_NOTIFICATION_MEMBER}")
  private String notificationMember;

  @Value("${GRIDDB_CLUSTER_NAME}")
  private String clusterName;

  @Value("${GRIDDB_USER}")
  private String user;

  @Value("${GRIDDB_PASSWORD}")
  private String password;

  @Bean
  public GridStore gridStore() throws GSException {
    // Acquiring a GridStore instance
    Properties properties = new Properties();
    properties.setProperty("notificationMember", notificationMember);
    properties.setProperty("clusterName", clusterName);
    properties.setProperty("user", user);
    properties.setProperty("password", password);
    GridStore store = GridStoreFactory.getInstance().getGridStore(properties);
    return store;
  }

  @Bean
    public Collection<String, User> userCollection(GridStore gridStore) throws GSException {
        Collection<String, User> collection = gridStore.putCollection("users", User.class);
        collection.createIndex("email");
        return collection;
    }

    @Bean
    public Collection<String, Blog> blogCollection(GridStore gridStore) throws GSException {
        Collection<String, Blog> collection = gridStore.putCollection("blogs", Blog.class);
        collection.createIndex("title");
        return collection;
    }

    @Bean
    public TimeSeries<votemetrics> voteMetricContainer(GridStore gridStore) throws GSException {
        TimeSeries</votemetrics><votemetrics> timeSeries = gridStore.putTimeSeries(Constant.VOTEMETRICS_CONTAINER, VoteMetrics.class);
        timeSeries.createIndex("blogId");
        timeSeries.createIndex("userId");
        return timeSeries;
    }
}</votemetrics>

public Blog create(CreateBlogRequest createBlogRequest) {
    Blog blog = new Blog();
    blog.setId(KeyGenerator.next("bl"));
    blog.setTitle(createBlogRequest.getTitle());
    blog.setVoteDownCount(0);
    blog.setVoteUpCount(0);
    blog.setCreatedAt(new Date());
    try {
        blogCollection.put(blog);
        blogCollection.commit();
    } catch (GSException e) {
        log.error("Error create blog", e);
    }
    return blog;
}

  public List<blog> fetchAll() {
      List</blog><blog> blogs = new ArrayList<>(0);
      try {
          Query</blog><blog> query = blogCollection.query("SELECT *", Blog.class);
          RowSet</blog><blog> rowSet = query.fetch();
          while (rowSet.hasNext()) {
              blogs.add(rowSet.next());
          }
      } catch (GSException e) {
          log.error("Error fetchAll", e);
      }
      return blogs;
  }</blog>

  public void updateVoteUp(String blogId) throws GSException {
      blogCollection.setAutoCommit(false);
      Blog blog = blogCollection.get(blogId, true);
      blog.setVoteUpCount(blog.getVoteUpCount() + 1);
      blogCollection.put(blog);
      blogCollection.commit();
  }

VoteMetrics(timestamp=Sun Jan 21 03:48:10 GMT 2024, blogId=bl_0EWG3KRE8H95G, userId=us_0EWQES1BVRJAN, voteType=1)
VoteMetrics(timestamp=Sun Jan 21 03:48:03 GMT 2024, blogId=bl_0EWG3KRDCHBEM, userId=us_0EWQER8KKRHDF, voteType=1)
VoteMetrics(timestamp=Sun Jan 21 03:48:02 GMT 2024, blogId=bl_0EWQ49HPKRKWB, userId=us_0EWQER2KVRJCJ, voteType=1)
VoteMetrics(timestamp=Sun Jan 21 03:48:00 GMT 2024, blogId=bl_0EWG3KRE8H95G, userId=us_0EWQEQV6FRKKV, voteType=1)

@Controller
@RequestMapping("/votes")
public class VotesController {
    
  @GetMapping
  String votes(Model model) {
      List<blog> blogs = blogService.fetchAll();
      model.addAttribute("blogs", blogs);
      return "votes";
  }

  @GetMapping("/up/{id}")
    public String voteUp(@PathVariable("id") String blogId, Model model, RedirectAttributes redirectAttributes) {
        try {
            String userId = KeyGenerator.next("us");
            voteService.voteUp(blogId, userId);
            redirectAttributes.addFlashAttribute("message", "Voting successful!");
        } catch (Exception e) {
            redirectAttributes.addFlashAttribute("message", "Oh no!");
        }
        return "redirect:/votes";
    }
}
</blog>

  <tbody>
      <tr th:each="blog : ${blogs}">
          <th scope="row">[[${blog.title}]]</th>
          <td>
              <a th:href="@{'/votes/up/' + ${blog.id}}" title="Vote Up" class="btn btn-outline-success"
                  role="button">
                  <i class="fa fa-thumbs-up"></i>
                  <span type="text" th:text="${blog.voteUpCount}" class="btn-label"></span>
              </a>
          </td>
          <td>
              <a th:href="@{'/votes/down/' + ${blog.id}}" title="Vote Down" class="btn btn-outline-danger"
                  role="button">
                  <i class="fa fa-thumbs-down"></i>
                  <span type="text" th:text="${blog.voteDownCount}" class="btn-label"></span>
              </a>
          </td>

          <td>[[${blog.createdAt}]]</td>
      </tr>
  </tbody>

script
const ctx = document.getElementById('charts');
const voteChart = new Chart(ctx, config);
/* A small decorator for the JavaScript EventSource API that automatically reconnects */
const eventSource = new ReconnectingEventSource("/votes/chart-data");

script
eventSource.onmessage = function (event) {
    console.log("Received event: " + event.data);
    const data = JSON.parse(event.data);
    config.data.labels.splice(0, config.data.labels.length, ...data.map(row => row.label));
    config.data.datasets[0].data.splice(0, config.data.datasets[0].data.length, ...data.map(row => row.count));
    voteChart.update();
};

@GetMapping("/chart-data")
public SseEmitter streamSseMvc(@RequestHeader Map<String, String> headers) {
    SseEmitter emitter = new SseEmitter(Duration.ofMinutes(15).toMillis());
    ExecutorService sseMvcExecutor = Executors.newSingleThreadExecutor();
    sseMvcExecutor.execute(() -> {
        try {
            for (int i = 0; true; i++) {
                SseEventBuilder event = SseEmitter.event()
                        .data(voteMetricService.getVoteAggregateOverTime())
                        .id(eventId);
                emitter.send(event);
                Thread.sleep(Duration.ofSeconds(30).toMillis());
            }
        } catch (Exception ex) {
            emitter.completeWithError(ex);
        }
        emitter.complete();
    });
    return emitter;
}

FROM maven:3.9.5-eclipse-temurin-21-alpine
RUN mkdir /app
WORKDIR /app

COPY pom.xml ./
RUN mvn dependency:go-offline

COPY docker-entrypoint-dev.sh ./
COPY src ./src

#!/bin/bash
export TERM=xterm
echo "wait 5s"
sleep 5

mvn spring-boot:run -Dspring-boot.run.jvmArguments="-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=*:5005" &

while true; do
    watch -d -t -g "ls -lR . | sha1sum" && mvn compile
done

version: '3.3'
services:
  app-dev:
    container_name: blogvotingapp-dev
    build:
      context: ./
      dockerfile: dev.Dockerfile
    volumes:
      - ./src:/app/src
      - ./.m2:/root/.m2
    environment:
      - GRIDDB_NOTIFICATION_MEMBER=griddb-dev:10001
      - GRIDDB_CLUSTER_NAME=dockerGridDB
      - GRIDDB_USER=admin
      - GRIDDB_PASSWORD=admin
      - spring.thymeleaf.prefix=file:src/main/resources/templates/
    command: sh ./docker-entrypoint-dev.sh
    ports:
      - 8080:8080
      - 35729:35729
      - 5005:5005
    networks:
      - griddbvoting-dev-net
    depends_on:
      - griddb-dev
  griddb-dev:
    container_name: griddbvoting-dev
    build:
      context: ./griddbdocker
      dockerfile: Dockerfile531
    volumes:
      - griddbvoting-dev-vol:/var/lib/gridstore
    ports:
      - 10001:10001
      - 20001:20001
    networks:
      - griddbvoting-dev-net

networks:
  griddbvoting-dev-net:
volumes:
  griddbvoting-dev-vol:

  docker compose -f docker-compose-dev.yml build

  docker compose -f docker-compose-dev.yml up up