/* * Copyright 2013 Jesse Morgan */ package com.p4square.grow.frontend; import java.util.ArrayList; import java.util.Collections; import java.util.Comparator; import java.util.HashMap; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import freemarker.template.Template; import org.restlet.data.Form; import org.restlet.data.MediaType; import org.restlet.data.Status; import org.restlet.ext.freemarker.TemplateRepresentation; import org.restlet.representation.Representation; import org.restlet.representation.StringRepresentation; import org.restlet.resource.ServerResource; import org.apache.log4j.Logger; import net.jesterpm.fmfacade.json.JsonRequestClient; import net.jesterpm.fmfacade.json.JsonResponse; import net.jesterpm.fmfacade.FreeMarkerPageResource; import com.p4square.grow.config.Config; import com.p4square.grow.model.TrainingRecord; import com.p4square.grow.model.VideoRecord; import com.p4square.grow.model.Playlist; import com.p4square.grow.provider.TrainingRecordProvider; import com.p4square.grow.provider.Provider; /** * TrainingPageResource handles rendering the training page. * * This resource expects the user to be authenticated and the ClientInfo User object * to be populated. * * @author Jesse Morgan */ public class TrainingPageResource extends FreeMarkerPageResource { private static Logger cLog = Logger.getLogger(TrainingPageResource.class); private static final String[] CHAPTERS = { "introduction", "seeker", "believer", "disciple", "teacher" }; private static final Comparator> VIDEO_COMPARATOR = new Comparator>() { @Override public int compare(Map left, Map right) { String leftNumberStr = (String) left.get("number"); String rightNumberStr = (String) right.get("number"); if (leftNumberStr == null || rightNumberStr == null) { return -1; } int leftNumber = Integer.valueOf(leftNumberStr); int rightNumber = Integer.valueOf(rightNumberStr); return leftNumber - rightNumber; } }; private Config mConfig; private Template mTrainingTemplate; private JsonRequestClient mJsonClient; private Provider mTrainingRecordProvider; // Fields pertaining to this request. private String mChapter; private String mUserId; @Override public void doInit() { super.doInit(); GrowFrontend growFrontend = (GrowFrontend) getApplication(); mConfig = growFrontend.getConfig(); mTrainingTemplate = growFrontend.getTemplate("templates/training.ftl"); if (mTrainingTemplate == null) { cLog.fatal("Could not find training template."); setStatus(Status.SERVER_ERROR_INTERNAL); } mJsonClient = new JsonRequestClient(getContext().getClientDispatcher()); mTrainingRecordProvider = new TrainingRecordProvider(new JsonRequestProvider(getContext().getClientDispatcher(), TrainingRecord.class)) { @Override public String makeKey(String userid) { return getBackendEndpoint() + "/accounts/" + userid + "/training"; } }; mChapter = getAttribute("chapter"); mUserId = getRequest().getClientInfo().getUser().getIdentifier(); } /** * Return a page of videos. */ @Override protected Representation get() { try { // Get the training summary TrainingRecord trainingRecord = mTrainingRecordProvider.get(mUserId); if (trainingRecord == null) { setStatus(Status.SERVER_ERROR_INTERNAL); return new ErrorPage("Could not retrieve TrainingRecord."); } Playlist playlist = trainingRecord.getPlaylist(); Map chapters = playlist.getChapterStatuses(); Map allowedChapters = new LinkedHashMap(); // The user is not allowed to view chapters after his highest completed chapter. // In this loop we find which chapters are allowed and check if the user tried // to skip ahead. boolean allowUserToSkip = mConfig.getBoolean("allowUserToSkip", true); String defaultChapter = null; boolean userTriedToSkip = false; boolean foundRequired = false; for (String chapterId : CHAPTERS) { boolean allowed = true; if (!foundRequired) { if (!chapters.get(chapterId)) { // The first incomplete chapter is the highest allowed chapter. foundRequired = true; defaultChapter = chapterId; } } else { allowed = allowUserToSkip; if (!allowUserToSkip && chapterId.equals(mChapter)) { userTriedToSkip = true; } } allowedChapters.put(chapterId, allowed); } if (defaultChapter == null) { // Everything is completed... send them back to introduction. defaultChapter = "introduction"; } if (mChapter == null || userTriedToSkip) { // No chapter was specified or the user tried to skip ahead. // Either case, redirect. String nextPage = mConfig.getString("dynamicRoot", ""); nextPage += "/account/training/" + defaultChapter; getResponse().redirectSeeOther(nextPage); return new StringRepresentation("Redirecting to " + nextPage); } // Get videos for the chapter. List> videos = null; { JsonResponse response = backendGet("/training/" + mChapter); if (!response.getStatus().isSuccess()) { setStatus(Status.CLIENT_ERROR_NOT_FOUND); return null; } videos = (List>) response.getMap().get("videos"); Collections.sort(videos, VIDEO_COMPARATOR); } // Mark the completed videos as completed int chapterProgress = 0; for (Map video : videos) { boolean completed = false; VideoRecord record = playlist.find((String) video.get("id")); cLog.info("VideoId: " + video.get("id")); if (record != null) { cLog.info("VideoRecord: " + record.getComplete()); completed = record.getComplete(); } video.put("completed", completed); if (completed) { chapterProgress++; } } chapterProgress = chapterProgress * 100 / videos.size(); Map root = getRootObject(); root.put("chapter", mChapter); root.put("isChapterAllowed", allowedChapters); root.put("chapterProgress", chapterProgress); root.put("videos", videos); root.put("allowUserToSkip", allowUserToSkip); return new TemplateRepresentation(mTrainingTemplate, root, MediaType.TEXT_HTML); } catch (Exception e) { cLog.fatal("Could not render page: " + e.getMessage(), e); setStatus(Status.SERVER_ERROR_INTERNAL); return ErrorPage.RENDER_ERROR; } } /** * @return The backend endpoint URI */ private String getBackendEndpoint() { return mConfig.getString("backendUri", "riap://component/backend"); } /** * Helper method to send a GET to the backend. */ private JsonResponse backendGet(final String uri) { cLog.debug("Sending backend GET " + uri); final JsonResponse response = mJsonClient.get(getBackendEndpoint() + uri); final Status status = response.getStatus(); if (!status.isSuccess() && !Status.CLIENT_ERROR_NOT_FOUND.equals(status)) { cLog.warn("Error making backend request for '" + uri + "'. status = " + response.getStatus().toString()); } return response; } }