Xinwen Deng / aem-src

/*
 * Decompiled with CFR 0_118.
 * 
 * Could not load the following classes:
 *  com.adobe.granite.security.user.UserProperties
 *  com.adobe.granite.security.user.UserPropertiesManager
 *  com.adobe.granite.taskmanagement.Task
 *  com.adobe.granite.taskmanagement.TaskAction
 *  com.adobe.granite.workflow.exec.InboxItem
 *  com.adobe.granite.workflow.exec.Status
 *  com.adobe.granite.workflow.payload.PayloadInfo
 *  com.adobe.granite.workflow.payload.PayloadInfoBuilderManager
 *  com.day.cq.commons.TidyJSONWriter
 *  javax.jcr.RepositoryException
 *  javax.jcr.Session
 *  javax.servlet.ServletException
 *  javax.servlet.http.HttpServletResponse
 *  org.apache.commons.lang.StringUtils
 *  org.apache.jackrabbit.api.security.user.Authorizable
 *  org.apache.jackrabbit.api.security.user.UserManager
 *  org.apache.sling.api.SlingHttpServletRequest
 *  org.apache.sling.api.resource.Resource
 *  org.apache.sling.api.resource.ResourceResolver
 *  org.apache.sling.commons.json.JSONException
 *  org.slf4j.Logger
 *  org.slf4j.LoggerFactory
 */
package com.adobe.cq.projects.impl.servlet;

import com.adobe.cq.projects.impl.servlet.ProjectServletUtil;
import com.adobe.granite.security.user.UserProperties;
import com.adobe.granite.security.user.UserPropertiesManager;
import com.adobe.granite.taskmanagement.Task;
import com.adobe.granite.taskmanagement.TaskAction;
import com.adobe.granite.workflow.exec.InboxItem;
import com.adobe.granite.workflow.exec.Status;
import com.adobe.granite.workflow.payload.PayloadInfo;
import com.adobe.granite.workflow.payload.PayloadInfoBuilderManager;
import com.day.cq.commons.TidyJSONWriter;
import java.io.IOException;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import javax.jcr.RepositoryException;
import javax.jcr.Session;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletResponse;
import org.apache.commons.lang.StringUtils;
import org.apache.jackrabbit.api.security.user.Authorizable;
import org.apache.jackrabbit.api.security.user.UserManager;
import org.apache.sling.api.SlingHttpServletRequest;
import org.apache.sling.api.resource.Resource;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.commons.json.JSONException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public abstract class ListItem {
    private static final Logger LOGGER = LoggerFactory.getLogger(ListItem.class);
    public static final String NO_WORKFLOW_INSTANCE = "_no_workflow_instance_";
    public static final String PROP_NAME_WFINSTANCE_ID = "wfInstanceId";
    private final String mapId;

    public ListItem(String mapId) {
        this.mapId = mapId;
    }

    public String getMapId() {
        return this.mapId;
    }

    public abstract void write(TidyJSONWriter var1, UserManager var2, UserPropertiesManager var3, ResourceResolver var4, SlingHttpServletRequest var5, HttpServletResponse var6, Map<String, String> var7) throws JSONException, ServletException, IOException;

    public abstract Date getDueDate();

    public abstract boolean isActive();

    public int countSubItems() {
        return 0;
    }

    protected void writeTask(ResourceResolver resolver, UserManager usrMgr, UserPropertiesManager userPropertiesManager, TidyJSONWriter writer, Task inboxItem, SlingHttpServletRequest slingRequest, HttpServletResponse response, boolean isTaskGroupMember, boolean isRootTask, boolean isLastGroupMember, Map<String, String> config) throws JSONException, ServletException, IOException {
        writer.key("item").value((Object)inboxItem.getId());
        writer.key("title").value((Object)inboxItem.getName());
        writer.key("description").value((Object)inboxItem.getDescription());
        this.writeCurrentAssignee(usrMgr, userPropertiesManager, writer, inboxItem.getCurrentAssignee());
        writer.key("startTime").value(inboxItem.getTimeStarted().getTime());
        String computedInboxType = this.getComputedInboxType((InboxItem)inboxItem);
        writer.key("actionNames");
        writer.array();
        List taskActions = inboxItem.getActions();
        if (taskActions != null) {
            for (TaskAction action : taskActions) {
                writer.value((Object)action.getActionID());
            }
        }
        writer.endArray();
        writer.key("taskInfo");
        this.writeTaskInfo(slingRequest.getResourceResolver(), writer, inboxItem, config);
        if (isTaskGroupMember) {
            writer.key("isGroupRoot").value(isRootTask);
            writer.key("isLastGroupMember").value(isLastGroupMember);
            writer.key("inboxItemType").value((Object)"TaskGroupMember");
        } else {
            writer.key("inboxItemType").value((Object)"ProjectTask");
        }
        writer.key("computedItemType").value((Object)this.firstUpper(computedInboxType));
        String payloadType = this.getPayloadType((InboxItem)inboxItem);
        if (inboxItem.getContentPath() != null) {
            this.writePayloadObject(resolver, writer, (InboxItem)inboxItem, payloadType);
            String comment = this.getComment((InboxItem)inboxItem);
            if (comment != null && !comment.equals("")) {
                writer.key("comment").value((Object)comment);
            }
        }
    }

    private String firstUpper(String taskTypeName) {
        if (taskTypeName == null || taskTypeName.length() < 1) {
            return taskTypeName;
        }
        if (taskTypeName.length() < 2) {
            return taskTypeName.toUpperCase();
        }
        return "" + Character.toUpperCase(taskTypeName.charAt(0)) + taskTypeName.substring(1);
    }

    private String getComment(InboxItem inboxItem) {
        Task task;
        String comment = null;
        if (inboxItem instanceof Task && (task = (Task)inboxItem).getProperty("comment") instanceof String) {
            comment = (String)task.getProperty("comment");
        }
        return comment;
    }

    protected void writePayloadObject(ResourceResolver resolver, TidyJSONWriter writer, InboxItem item, String payloadType) {
        block11 : {
            if ("JCR_PATH".equals(payloadType)) {
                try {
                    PayloadInfoBuilderManager payloadBuilder = (PayloadInfoBuilderManager)resolver.adaptTo(PayloadInfoBuilderManager.class);
                    PayloadInfo info = payloadBuilder.getPayloadInfo(item, null);
                    if (StringUtils.isNotBlank((String)info.getBrowserPath())) {
                        writer.key("payload").value((Object)info.getBrowserPath());
                    } else {
                        writer.key("payload").value((Object)item.getContentPath());
                    }
                    String payloadPath = info.getPath();
                    Resource res = resolver.getResource(payloadPath);
                    if (res != null) {
                        writer.key("payloadPath").value((Object)payloadPath);
                        this.writePayloadSummary(writer, info);
                        String payloadTitle = info.getTitle();
                        if (payloadTitle != null) {
                            writer.key("payloadTitle").value((Object)payloadTitle);
                        }
                        break block11;
                    }
                    LOGGER.error("Payload not found for work item: " + this.mapId + " (" + payloadPath + ")");
                }
                catch (Exception e) {
                    LOGGER.error("Unable to process inboxitem: " + this.mapId, (Throwable)e);
                }
            } else if ("URL".equals(payloadType)) {
                try {
                    String payloadUrl = item.getContentPath();
                    writer.key("payload").value((Object)payloadUrl);
                    writer.key("payloadPath").value((Object)payloadUrl);
                    writer.key("payloadTitle").value((Object)payloadUrl);
                    writer.key("payloadType").value((Object)"URL");
                }
                catch (Exception e) {
                    LOGGER.error("Unable to process inboxitem: " + this.mapId, (Throwable)e);
                }
            }
        }
    }

    private void writePayloadSummary(TidyJSONWriter out, PayloadInfo info) throws JSONException {
        out.key("payloadSummary").object();
        if (StringUtils.isNotBlank((String)info.getDescription())) {
            out.key("description").value((Object)info.getDescription());
        }
        if (StringUtils.isNotBlank((String)info.getThumbnailPath())) {
            out.key("icon").value((Object)info.getThumbnailPath());
        }
        out.endObject();
    }

    protected void writeCurrentAssignee(UserManager usrMgr, UserPropertiesManager userPropertiesManager, TidyJSONWriter writer, String currAssignee) throws JSONException {
        String currentAssigneeType = "user";
        if (currAssignee != null) {
            Authorizable auth = null;
            UserProperties up = null;
            try {
                auth = usrMgr.getAuthorizable(currAssignee);
                if (auth != null && (up = userPropertiesManager.getUserProperties(auth, "profile")) != null) {
                    String alternateTitle = up.getProperty("alternateTitle");
                    if (StringUtils.isNotBlank((String)alternateTitle)) {
                        currAssignee = alternateTitle;
                    } else {
                        String newAssignee = up.getDisplayName();
                        if (!StringUtils.isBlank((String)newAssignee)) {
                            currAssignee = newAssignee;
                        }
                    }
                }
            }
            catch (RepositoryException e) {
                // empty catch block
            }
            String thumbnailPath = "/libs/granite/security/clientlib/themes/default/resources/sample-user-thumbnail.36.png";
            if (auth != null) {
                thumbnailPath = ProjectServletUtil.getUserThumbnailPath(auth, up);
                if (auth.isGroup()) {
                    currentAssigneeType = "group";
                }
            }
            writer.key("participant").value((Object)currAssignee);
            writer.key("currentAssigneeType").value((Object)currentAssigneeType);
            writer.key("currentAssigneeThumbnail").value((Object)thumbnailPath);
            writer.key("currentAssignee").value((Object)currAssignee);
        }
    }

    private String getComputedInboxType(InboxItem inboxItem) {
        Task task;
        String computedInboxType = inboxItem.getItemType();
        if (inboxItem instanceof Task && (task = (Task)inboxItem).getTaskTypeName() != null) {
            computedInboxType = task.getTaskTypeName();
        }
        return computedInboxType;
    }

    private String getPayloadType(InboxItem inboxItem) {
        if (inboxItem instanceof Task) {
            return "JCR_PATH";
        }
        return null;
    }

    private void writeTaskInfo(ResourceResolver resourceResolver, TidyJSONWriter w, Task task, Map<String, String> taskTypeContentMapping) throws JSONException {
        w.object();
        w.key("id").value((Object)task.getId());
        w.key("parentTaskId").value((Object)task.getParentId());
        w.key("actionNames");
        w.array();
        List taskActions = task.getActions();
        if (taskActions != null) {
            for (TaskAction action : taskActions) {
                w.value((Object)action.getActionID());
            }
        }
        w.endArray();
        Calendar calendar = Calendar.getInstance();
        if (task.getLastModified() != null) {
            calendar.setTime(task.getLastModified());
            this.writeCalendar(w, "updateTime", calendar);
        }
        if (task.getTimeStarted() != null) {
            calendar.setTime(task.getTimeStarted());
            this.writeCalendar(w, "createTime", calendar);
        }
        if (task.getTimeEnded() != null) {
            calendar.setTime(task.getTimeEnded());
            this.writeCalendar(w, "completeTime", calendar);
        }
        w.key("description").value((Object)task.getDescription());
        w.key("instructions").value((Object)task.getInstructions());
        w.key("contentPath").value((Object)task.getContentPath());
        w.key("hasSubTasks").value(task.hasSubTasks());
        w.key("name").value((Object)task.getName());
        w.key("ownerId").value((Object)task.getCurrentAssignee());
        w.key("createdBy").value((Object)task.getCreatedBy());
        String selectedActionId = null;
        if (task.getSelectedAction() != null) {
            selectedActionId = task.getSelectedAction().getActionID();
        }
        w.key("selectedAction").value((Object)selectedActionId);
        w.key("properties");
        boolean hasWorkflowInstanceId = false;
        w.object();
        Iterator propertyNameIterator = task.getPropertyNames();
        if (propertyNameIterator != null) {
            while (propertyNameIterator.hasNext()) {
                Object propertyValue;
                String key = (String)propertyNameIterator.next();
                if ("wfInstanceId".equals(key)) {
                    hasWorkflowInstanceId = true;
                }
                if ((propertyValue = task.getProperty(key)) == null) continue;
                w.key(key).value(propertyValue);
            }
        }
        if (!hasWorkflowInstanceId) {
            w.key("wfInstanceId").value((Object)"_no_workflow_instance_");
        }
        w.endObject();
        w.key("status").value((Object)task.getStatus());
        w.key("taskType").value((Object)task.getTaskTypeName());
        w.key("writeAccess").value(this.hasWriteAccess(resourceResolver, task));
        if (taskTypeContentMapping != null) {
            w.key("url").value((Object)taskTypeContentMapping.get(task.getTaskTypeName()));
        }
        w.endObject();
    }

    private void writeCalendar(TidyJSONWriter out, String key, Calendar value) throws JSONException {
        if (value != null) {
            out.key(key).value(value.getTimeInMillis());
        }
    }

    private boolean hasWriteAccess(ResourceResolver resourceResolver, Task task) {
        Session session = (Session)resourceResolver.adaptTo(Session.class);
        if (task.getCurrentAssignee().equals(session.getUserID())) {
            return true;
        }
        try {
            return session.hasPermission(task.getId(), "set_property");
        }
        catch (RepositoryException e) {
            LOGGER.error("error checking access for task: " + task.getId(), (Throwable)e);
            return false;
        }
    }

    protected Date parseDate(String dueDateString) {
        if (StringUtils.isBlank((String)dueDateString)) {
            return null;
        }
        SimpleDateFormat formatterWithSeconds = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss");
        try {
            return formatterWithSeconds.parse(dueDateString);
        }
        catch (ParseException e) {
            SimpleDateFormat formatterWithoutSeconds = new SimpleDateFormat("yyyy-MM-dd HH:mm");
            try {
                return formatterWithoutSeconds.parse(dueDateString);
            }
            catch (ParseException e2) {
                LOGGER.debug("Failed to parse date {}", (Object)dueDateString, (Object)e2);
                return null;
            }
        }
    }

    protected Date getTaskDueDate(Task task) {
        Object dueDate;
        if (task != null && (dueDate = task.getProperty("taskDueDate")) != null) {
            if (dueDate instanceof String) {
                return this.parseDate((String)dueDate);
            }
            if (dueDate instanceof Date) {
                LOGGER.debug("task due date is a date, value '{}'", dueDate);
                return (Date)dueDate;
            }
            LOGGER.debug("task due date is not of type 'date', instead it is {}", (Object)dueDate.getClass().getSimpleName());
        }
        return null;
    }

    public void sortTasks() {
    }

    public int compareDueDates(ListItem listItem) {
        int statusComparison = this.compareStatusWith(listItem);
        if (statusComparison != 0) {
            return statusComparison;
        }
        Date leftDueDate = this.getDueDate();
        Date rightDueDate = listItem.getDueDate();
        if (leftDueDate != null) {
            if (rightDueDate != null) {
                return leftDueDate.compareTo(rightDueDate);
            }
            return -1;
        }
        if (rightDueDate != null) {
            return 1;
        }
        return 0;
    }

    protected int compareStatusWith(ListItem listItem) {
        if (this.isActive()) {
            if (listItem.isActive()) {
                return 0;
            }
            return -1;
        }
        if (listItem.isActive()) {
            return 1;
        }
        return 0;
    }
}