ProjectJsonIterator.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.alliance.client;
 
import java.io.Writer;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Objects;
import javax.json.JsonObject;
import org.turro.alliance.content.control.ProjectAction;
import org.turro.alliance.content.control.ProjectCtrl;
import org.turro.alliance.service.AxConstants;
import org.turro.alliance.service.AxP2PServer;
import org.turro.collections.Item;
import org.turro.elephant.context.ElephantContext;
import org.turro.elephant.context.IConstructor;
import org.turro.elephant.impl.repository.RepositoryFile;
import org.turro.elephant.web.SocialNet;
import org.turro.entities.Entities;
import org.turro.jpa.search.DaoSearchKey;
import org.turro.json.JsonSearch;
import org.turro.json.Jsons;
import org.turro.marker.ElephantMarker;
import org.turro.plugin.contacts.IContact;
import org.turro.string.Strings;
import org.turro.util.Converter;
import org.turro.ws.WsServer;
import org.turro.ws.content.iterator.JsonHtmlClientIterator;
import org.turro.ws.content.search.JsonHtmlSearch;
import org.turro.ws.service.WsConstants;
import org.turro.ws.service.member.Servers;
import org.turro.ws.service.p2p.P2Ps;
 
public class ProjectJsonIterator extends JsonHtmlClientIterator {
 
  public ProjectJsonIterator(IConstructor constructor, IContact contact, WsServer server, Writer writer, boolean mail) {
    super(constructor, contact, server, writer, mail);
  }
 
  @Override
  protected String entityRoot() {
    // c for client?
    return "caxproject";
  }
 
  @Override
  protected Jsons entity(String value) {
    return items.getStructure().getArrayValues(JsonObject.class).stream()
            .filter(item -> item.getString("id").equals(value.replaceAll("_", "#")))
            .map(item -> Jsons.read(item.toString()))
            .findFirst().orElse(null);
  }
 
  @Override
  protected void renderSummary(ElephantMarker marker, Jsons e, int page) {
    if(e != null) {
      ProjectCtrl pctrl = new ProjectCtrl();
      pctrl.setServer(getServer());
      pctrl.setAxId(e.getString("id"));
      pctrl.setAction(ProjectAction.TOGGLE_BAN);
      marker.put("banctrl", pctrl);
      marker.put("itemLink", getItemLink(e));
      marker.put("project", JsonSearch.of(e).silent().root());
      marker.put("server", getServer());
    }
    marker.process(getTemplateRoot(), getSummaryTemplate(), getWriter());
  }
 
  @Override
  protected void renderItem(ElephantMarker marker, Jsons e, int page) {
    Jsons criteria = Jsons.object();
    criteria.add("projectId", e.context().read("$.projectId.entityId", String.class));
    Jsons project = P2Ps.getP2PData(getServer().getServerDomain(), 
            e.context().read("$.projectId.memberId", Long.class), 
            AxP2PServer.AX_P2P_SERVICE, AxConstants.PROJECT, criteria);
    if(project != null) {
      Jsons memberInfo = Servers.getData(getServer(), WsConstants.CLIENT_INFO);
      ProjectCtrl banctrl = new ProjectCtrl();
      banctrl.setServer(getServer());
      banctrl.setAxId(e.getString("id"));
      banctrl.setAction(ProjectAction.TOGGLE_BAN);
      marker.put("banctrl", banctrl);
      ProjectCtrl offctrl = new ProjectCtrl();
      offctrl.setServer(getServer());
      offctrl.setAxId(e.getString("id"));
      offctrl.setAction(ProjectAction.PARTICIPATE);
      offctrl.setParticiationLabel("Offerer");
      marker.put("offctrl", offctrl);
      ProjectCtrl benctrl = new ProjectCtrl();
      benctrl.setServer(getServer());
      benctrl.setAxId(e.getString("id"));
      benctrl.setAction(ProjectAction.PARTICIPATE);
      benctrl.setParticiationLabel("Beneficiary");
      marker.put("benctrl", benctrl);
      ProjectCtrl conctrl = new ProjectCtrl();
      conctrl.setServer(getServer());
      conctrl.setAxId(e.getString("id"));
      conctrl.setAction(ProjectAction.PARTICIPATE);
      conctrl.setParticiationLabel("Consortium");
      marker.put("conctrl", conctrl);
      marker.put("itemLink", getItemLink(e));
      marker.put("dossier", JsonSearch.of(project).silent().root());
      criteria = Jsons.object();
      criteria.add("projectId", e.context().read("$.projectId.entityId", String.class));
      Jsons attachments = P2Ps.getP2PData(getServer().getServerDomain(), 
              e.context().read("$.projectId.memberId", Long.class), 
              AxP2PServer.AX_P2P_SERVICE, AxConstants.ATTACHMENTS, criteria);
      marker.put("attachments", JsonSearch.of(attachments).silent().root());
      marker.put("server", getServer());
      marker.put("domain", getServer().getServerDomain());
      marker.put("service", getServer().getService());
      marker.put("member", e.context().read("$.projectId.memberId", Long.class));
      marker.put("serverFace", getServer().getContact().getFaces().getUrl());
      marker.put("axid", e.getString("id"));
      marker.put("selfMember", memberInfo.getLong("id"));
      if(Objects.equals(marker.get("member"), marker.get("selfMember"))) {
        marker.put("internalLink", Entities.getController("/dossier/" + e.context().read("$.projectId.entityId")).getEntityUrl());
      }
    }
    marker.process(getTemplateRoot(), getFullTemplate(), getWriter());
  }
 
  @Override
  protected String title(Jsons e) {
    return Strings.isBlank(e.getString("name"), null);
  }
 
  @Override
  protected Collection<String> metas(Jsons e) {
    ArrayList<RepositoryFile> files = new ArrayList<>();
    String path = getItemLink(e);
    SocialNet sn = new SocialNet(path, e.getString("name"), e.getString("summary", "*"), files);
    return sn.getMetas();
  }
 
  @Override
  protected String getTemplateRoot() {
    return isMail() ? "content/newsletter/sections/alliance/client/projects" : "alliance/client/project";
  }
 
  @Override
  protected String getItemLink(Jsons e) {
    return constructor.getCurrentContext().getFullPath() + 
            "?item=" + e.getString("id").replaceAll("#", "_");
  }
 
  @Override
  protected String reason() {
    return AxConstants.PROJECT_ITERATOR;
  }
 
  @Override
  protected Jsons criteria() {
    Jsons criteria = Jsons.object();
    criteria.add("withBanned", contact.isAdmin());
    Item<Jsons, Long> selected = getNavigationTree().getSelectedItem();
    if(selected != null) {
      criteria.addArray("categoryIds");
      selected.selfAndChildrenIds().forEach(id -> {
        criteria.add(id);
      });
    }
    if(isSearchOption()) {
      criteria.toRoot();
      JsonHtmlSearch dhs = JsonHtmlSearch.getInstance(constructor, ElephantContext.getContextVariable(constructor));
      if(dhs != null) {
        DaoSearchKey dsk = dhs.get("search-value");
        criteria.add("search", dsk.getValue());
        dsk = dhs.get("phase");
        criteria.add("phase", Converter.STANDARD.convert(Strings.isBlank(dsk.getValue(), "-1"), Integer.class, -1));
      }
    }
    return criteria;
  }
 
}