AxClient.java

Go to the documentation of this file.

/*
 * Turró i Cutiller Foundation. License notice.
 * Copyright (C) 2022 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.alliance.service;
 
import java.util.HashSet;
import java.util.Set;
import org.turro.action.Contacts;
import org.turro.alliance.db.AlliancePU;
import org.turro.alliance.db.entities.AxCenter;
import org.turro.alliance.db.entities.AxChallenge;
import org.turro.alliance.db.entities.AxContact;
import org.turro.alliance.db.entities.AxProject;
import org.turro.alliance.db.entities.AxProjectGrant;
import org.turro.alliance.db.entities.AxStudent;
import org.turro.alliance.db.entities.AxTag;
import org.turro.collections.KeyValueMap;
import org.turro.dossier.db.DossierPU;
import org.turro.dossier.entity.Dossier;
import org.turro.dossier.entity.ParticipantRole;
import org.turro.dossier.entity.ProjectGrant;
import org.turro.elephant.context.Application;
import org.turro.jpa.Dao;
import org.turro.json.Jsons;
import org.turro.member.db.entities.AxChallengeCategory;
import org.turro.member.db.entities.AxProjectCategory;
import org.turro.member.db.entities.AxProjectGrantPublic;
import org.turro.sql.SqlClause;
import org.turro.students.db.StudentsPU;
import org.turro.students.entities.Challenge;
import org.turro.ws.WsServer;
import org.turro.ws.service.IWsService;
import org.turro.ws.service.member.SecuredClientService;
import org.turro.ws.service.WsService;
 
@WsService(path = AxClient.CLIENT_SERVICE, name = "Alliance Member")
public class AxClient extends SecuredClientService implements IWsService {
 
  public static final String CLIENT_SERVICE = "/axclient";
 
  @Override
  protected void doProcess(Application application, KeyValueMap map, WsServer server, Jsons json, String reason) {
    if(AxConstants.USERS.equals(reason)) {
      long memberId = json.getInt("memberId");
      Jsons users = Jsons.array();
      getParticipantsIds().forEach(id -> {
        users.addValue(Jsons.read(AxContact.from(memberId, id).toJson()));
      });
      writeResponse(application, users.build());
    } else if(AxConstants.PROJECTS.equals(reason)) {
      long memberId = json.getInt("memberId");
      Jsons projects = Jsons.array();
      Dao dao = new DossierPU();
      SqlClause.select("pc").from("AxProjectCategory pc")
              .where().equal("pc.serverDomain", server.getServerDomain())
              .dao(new AlliancePU())
              .resultList(AxProjectCategory.class).forEach(pc -> {
        Dossier dossier = dao.find(Dossier.class, Long.valueOf(pc.getProjectId()));
        if(dossier != null && dossier.getProject() != null) {
          projects.addValue(Jsons.read(AxProject.from(memberId, server, dossier, pc).toJson()));
        }
      });
      writeResponse(application, projects.build());
    } else if(AxConstants.PROJECT_GRANTS.equals(reason)) {
      long memberId = json.getInt("memberId");
      Jsons projectGrants = Jsons.array();
      Dao dao = new DossierPU();
      SqlClause.select("pc").from("AxProjectGrantPublic pc")
              .where().equal("pc.serverDomain", server.getServerDomain())
              .dao(new AlliancePU())
              .resultList(AxProjectGrantPublic.class).forEach(pc -> {
        ProjectGrant projectGrant = dao.find(ProjectGrant.class, Long.valueOf(pc.getProjectGrantId()));
        if(projectGrant != null) {
          projectGrants.addValue(Jsons.read(AxProjectGrant.from(memberId, projectGrant).toJson()));
        }
      });
      writeResponse(application, projectGrants.build());
    } else if(AxConstants.CENTERS.equals(reason)) {
      long memberId = json.getInt("memberId");
      Jsons centers = Jsons.array();
      Contacts.getCenters().forEach(center -> {
        centers.addValue(Jsons.read(AxCenter.from(memberId, center).toJson()));
      });
      writeResponse(application, centers.build());
    } else if(AxConstants.STUDENTS.equals(reason)) {
      long memberId = json.getInt("memberId");
      Jsons students = Jsons.array();
      Contacts.getStudents().forEach(student -> {
        if(student.isStudent() && !student.isWorker()) {
          students.addValue(Jsons.read(AxStudent.from(memberId, student).toJson()));
        }
      });
      writeResponse(application, students.build());
    } else if(AxConstants.CHALLENGES.equals(reason)) {
      long memberId = json.getInt("memberId");
      Jsons challenges = Jsons.array();
      Dao dao = new StudentsPU();
      SqlClause.select("pc").from("AxChallengeCategory pc")
              .where().equal("pc.serverDomain", server.getServerDomain())
              .dao(new AlliancePU())
              .resultList(AxChallengeCategory.class).forEach(pc -> {
        Challenge challenge = dao.find(Challenge.class, Long.valueOf(pc.getChallengeId()));
        if(challenge != null) {
          challenges.addValue(Jsons.read(AxChallenge.from(memberId, server, challenge, pc).toJson()));
        }
      });
      writeResponse(application, challenges.build());
    } else if(AxConstants.TAGS.equals(reason)) {
      long memberId = json.getInt("memberId");
      Jsons tags = Jsons.array();
      Dao dao = new DossierPU();
      SqlClause.select("pc").from("AxProjectCategory pc")
              .where().equal("pc.serverDomain", server.getServerDomain())
              .dao(new AlliancePU())
              .resultList(AxProjectCategory.class).forEach(pc -> {
        Dossier dossier = dao.find(Dossier.class, Long.valueOf(pc.getProjectId()));
        if(dossier != null && dossier.getProject() != null) {
          AxTag.from(memberId, dossier).forEach(tag -> {
            tags.addValue(Jsons.read(tag.toJson()));
          });          
        }
      });
      SqlClause.select("pc").from("AxProjectGrantPublic pc")
              .where().equal("pc.serverDomain", server.getServerDomain())
              .dao(new AlliancePU())
              .resultList(AxProjectGrantPublic.class).forEach(pc -> {
        ProjectGrant projectGrant = dao.find(ProjectGrant.class, Long.valueOf(pc.getProjectGrantId()));
        if(projectGrant != null) {
          AxTag.from(memberId, projectGrant).forEach(tag -> {
            tags.addValue(Jsons.read(tag.toJson()));
          });          
        }
      });
      writeResponse(application, tags.build());
    }
  }
  
  private Set<String> getParticipantsIds() {
    Set<String> ids = new HashSet<>();
    ids.addAll(SqlClause.select("distinct p.idContact").from("Participant p")
            .where().notEqual("role", ParticipantRole.PARTICIPANT_SUBJECT)
            .dao(new DossierPU())
            .resultList(String.class));
    ids.addAll(SqlClause.select("distinct p.idContact").from("CategoryParticipant p")
            .where().notEqual("role", ParticipantRole.PARTICIPANT_SUBJECT)
            .dao(new DossierPU())
            .resultList(String.class));
    return ids;
  }
 
}