CommonsActivity.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2023 Lluis Turró Cutiller <http://www.turro.org/>
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Affero General Public License as published by
 * the Free Software Foundation, either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */
 
package org.turro.activity;
 
import org.turro.elephant.db.ElephantPU;
import org.turro.elephant.entities.db.EntityParticipation;
import org.turro.elephant.entities.db.Poll;
import org.turro.elephant.entities.db.Post;
import org.turro.elephant.entities.db.Topic;
import org.turro.entities.Entities;
import org.turro.entities.IElephantEntity;
import org.turro.jpa.Dao;
import org.turro.participation.ParticipationReason;
import org.turro.sql.SqlClause;
import org.turro.util.Cached;
 
@ElephantActivity
public class CommonsActivity implements IElephantActivity {
 
  @Override
  public void generate() {
    Activities topacts = Activities.of("New topic");
    SqlClause.select("topic").from("Topic topic")
            .where().greater("topic.creation", topacts.lastDate())
            .dao(dao.get()).forEach(Topic.class, topic -> {
              if(!topic.getEntity().isEmpty()) {
                IElephantEntity itopic = Entities.getController(topic);
                if(!itopic.isEmpty()) {
                  topacts.add(topic.getCreation(), itopic.getPath(), topic.getEntityPath(), itopic.getHierarchicalPath());
                }
              }
            });
    Activities ansacts = Activities.of("New answer");
    SqlClause.select("post").from("Post post")
            .where().greater("topic.creation", ansacts.lastDate())
            .dao(dao.get()).forEach(Post.class, post -> {
              if(!post.getTopic().getEntity().isEmpty()) {
                IElephantEntity ipost = Entities.getController(post);
                if(!ipost.isEmpty()) {
                  ansacts.add(post.getCreation(), ipost.getPath(), post.getTopic().getEntityPath(), ipost.getHierarchicalPath());
                }
              }
            });
    Activities pollacts = Activities.of("Related polls");
    SqlClause.select("poll").from("Poll poll")
            .where().greater("poll.deadline", pollacts.lastDate())
            .dao(dao.get()).forEach(Poll.class, poll -> {
              if(!poll.getEntity().isEmpty()) {
                IElephantEntity ipoll = Entities.getController(poll);
                if(!ipoll.isEmpty()) {
                  pollacts.add(poll.getDeadline(), ipoll.getPath(), poll.getEntityPath(), ipoll.getHierarchicalPath());
                }
              }
            });
    for(ParticipationReason reason : ParticipationReason.values()) {
      Activities epacts = Activities.of(reason.toString());
      SqlClause.select("ep").from("EntityParticipation ep")
              .where().greater("ep.participationDate", epacts.lastDate())
              .and().equal("ep.reason", reason)
              .dao(dao.get()).forEach(EntityParticipation.class, ep -> {
                if(!ep.getEntity().isEmpty()) {
                  String path = ElephantPU.getObjectPath(ep);
                  epacts.add(ep.getParticipationDate(), path, ep.getEntityPath(), ep.getEntity().getHierarchicalPath());
                }
              });
    }
  }
 
  /* Dao */
  
  private final Cached<Dao> dao = Cached.instance(() -> new ElephantPU());
 
}