AxServer.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 org.turro.alliance.provider.Projects;
import org.turro.alliance.db.AlliancePU;
import org.turro.alliance.db.entities.AxCategory;
import org.turro.alliance.db.entities.AxTalentCategory;
import org.turro.alliance.provider.Banned;
import org.turro.alliance.provider.CategoryProvider;
import org.turro.alliance.provider.PhaseProvider;
import org.turro.alliance.provider.PreferencesProvider;
import org.turro.alliance.provider.ProjectGrantProvider;
import org.turro.alliance.provider.ProjectProvider;
import org.turro.alliance.provider.TagProvider;
import org.turro.collections.KeyValueMap;
import org.turro.elephant.context.Application;
import org.turro.importer.ImportFromMembers;
import org.turro.json.Jsons;
import org.turro.server.db.entities.AxMemberPreferences;
import org.turro.sql.SqlClause;
import org.turro.string.Strings;
import org.turro.ws.WsMember;
import org.turro.ws.service.IWsService;
import org.turro.ws.service.server.SecuredServerService;
import org.turro.ws.service.WsService;
 
@WsService(path = AxServer.SERVER_SERVICE, name = "Alliance Server")
public class AxServer extends SecuredServerService implements IWsService {
 
  public static final String SERVER_SERVICE = "/axserver";
  
  @Override
  protected void doProcess(Application application, KeyValueMap map, WsMember member, Jsons json, String reason) {
    if(AxConstants.CATEGORY.equals(reason)) {
      AxCategory cat = SqlClause.select("c").from("AxCategory c")
              .where().equal("c.categoryId", json.getLong("id"))
              .dao(new AlliancePU())
              .singleResult(AxCategory.class);
      if(cat != null) {
        writeResponse(application, cat.toJson());
      }
    } else if(AxConstants.CATEGORIES.equals(reason)) {
      Jsons categories = Jsons.array();
      SqlClause.select("c").from("AxCategory c")
              .orderBy("c.uniquePath")
              .dao(new AlliancePU())
              .resultList(AxCategory.class).forEach(category -> {
        categories.addValue(Jsons.read(category.toJson()));
      });
      writeResponse(application, categories.build());
    } else if(AxConstants.PROJECT.equals(reason)) {
      writeResponse(application, Projects.from(member)
              .project(json.getString("id")).toString());
    } else if(AxConstants.PARTICIPATIONS.equals(reason)) {
      writeResponse(application, Projects.from(member)
              .participations(json.getString("id")).build());
    } else if(AxConstants.AXPARTICIPATIONS.equals(reason)) {
      writeResponse(application, Projects.from(member)
              .axParticipations(json.getString("id"), json.getString("as", null)).build());
    } else if(AxConstants.AXFULL_PARTICIPATIONS.equals(reason)) {
      writeResponse(application, Projects.from(member)
              .axFullParticipations().build());
    } else if(AxConstants.AXPENDING_REQUESTS.equals(reason)) {
      if(!Strings.isBlank(json.getString("id", null))) {
        writeResponse(application, Projects.from(member)
                .axAllParticipations(json.getString("id", null)).build());
      } else {
        writeResponse(application, Projects.from(member)
                .axPendingParticipations().build());
      }
    } else if(AxConstants.AXPENDING_VALIDATE.equals(reason)) {
      Projects.from(member).axValidatePending(Jsons.read(json.getObject("item").toString()));
    } else if(AxConstants.AXPENDING_DELETE.equals(reason)) {
      Projects.from(member).axDeleteParticipation(Jsons.read(json.getObject("item").toString()));
    } else if(AxConstants.UPDATE_SERVER.equals(reason)) {
      ImportFromMembers.connect(member);
      writeResponse(application, Jsons.object().add("imported", true).build());
    } else if(AxConstants.PROJECT_ITERATOR.equals(reason)) {
      writeResponse(application, new ProjectProvider(member, reason, json)
              .getData().build());
    } else if(AxConstants.PROJECT_GRANT_ITERATOR.equals(reason)) {
      writeResponse(application, new ProjectGrantProvider(member, reason, json)
              .getData().build());
    } else if(AxConstants.CATEGORY_ITERATOR.equals(reason)) {
      writeResponse(application, new CategoryProvider(member, reason, json)
              .getData().build());
    } else if(AxConstants.PHASE_ITERATOR.equals(reason)) {
      writeResponse(application, new PhaseProvider(member, reason, json)
              .getData().build());
    } else if(AxConstants.TAGS.equals(reason)) {
      writeResponse(application, new TagProvider(member, reason, json)
              .getData().build());
    } else if(AxConstants.MEMBER_PREFERENCES.equals(reason)) {
      writeResponse(application, new PreferencesProvider(member, reason, json)
              .getData().build());
    } else if(AxConstants.SAVE_PREFERENCES.equals(reason)) {
      new AlliancePU().saveObject(AxMemberPreferences.fromJson(json.asJsonValue()));
    } else if(AxConstants.BAN_STATUS.equals(reason)) {
      writeResponse(application, Jsons.object()
              .add("banned", Banned.of(member).status(json.getString("axId")))
              .build());      
    } else if(AxConstants.BAN_TOGGLE.equals(reason)) {
      writeResponse(application, Jsons.object()
              .add("banned", Banned.of(member).toggle(json.getString("axId")))
              .build());      
    } else if(AxConstants.AXPARTICIPATION_REQUESTED.equals(reason)) {
      writeResponse(application, Jsons.object()
              .add("requested", Projects.from(member).hasRequested(json))
              .build());      
    } else if(AxConstants.AXPARTICIPATION_STATUS.equals(reason)) {
      writeResponse(application, Jsons.object()
              .add("participant", Projects.from(member).isParticipant(json))
              .build());      
    } else if(AxConstants.AXPARTICIPATION_SAVE.equals(reason)) {
      writeResponse(application, Jsons.object()
              .add("participant", Projects.from(member).save(Jsons.read(json.getObject("item").toString())))
              .build());      
    } else if(AxConstants.AXPARTICIPATION_ASK.equals(reason)) {
      Projects.from(member).axAskParticipate(json);      
      writeResponse(application, Jsons.object()
              .add("requested", true)
              .build());      
    } else if(AxConstants.TALENT_CATEGORY.equals(reason)) {
      AxTalentCategory cat = SqlClause.select("c").from("AxTalentCategory c")
              .where().equal("c.categoryId", json.getLong("id"))
              .dao(new AlliancePU())
              .singleResult(AxTalentCategory.class);
      if(cat != null) {
        writeResponse(application, cat.toJson());
      }
    } else if(AxConstants.TALENT_CATEGORIES.equals(reason)) {
      Jsons categories = Jsons.array();
      SqlClause.select("c").from("AxTalentCategory c")
              .orderBy("c.name")
              .dao(new AlliancePU())
              .resultList(AxTalentCategory.class).forEach(category -> {
        categories.addValue(Jsons.read(category.toJson()));
      });
      writeResponse(application, categories.build());
    } else {
      writeResponse(application, "none");
    }
  }
 
}