import { RequestHandler } from "../entities/RequestHandler"; import { UserHelper } from "../helpers/UserHelper"; import { PostsHelper } from "../helpers/PostsHelper"; import { Post, PostVisibilityLevel, PostKind, PostAccessLevel, PostPageKind, PostFile } from "../entities/Post"; import { MoviesController } from "./MoviesController"; import { MoviesHelper } from "../helpers/MoviesHelper"; import { SurveyHelper } from "../helpers/SurveyHelper"; import { SurveyController } from "./SurveyController"; import { LikesHelper, LikesType } from "../helpers/LikesHelper"; import { CommentsHelper } from "../helpers/CommentsHelper"; import { CommentsController } from "./CommentsController"; import { GroupsAccessLevel } from "../entities/Group"; import { GroupsHelper } from "../helpers/GroupsHelper"; import { time } from "../utils/DateUtils"; import { findKey } from "../utils/ArrayUtils"; import { check_string_before_insert, check_youtube_id } from "../utils/StringUtils"; import { pathUserData } from "../utils/UserDataUtils"; import { statSync } from "fs"; import { lookup } from "mime-types"; /** * Posts controller * * @author Pierre HUBERT */ const VISIBILITY_LEVELS_API = {}; VISIBILITY_LEVELS_API[PostVisibilityLevel.VISIBILITY_PUBLIC] = "public"; VISIBILITY_LEVELS_API[PostVisibilityLevel.VISIBILITY_FRIENDS] = "friends"; VISIBILITY_LEVELS_API[PostVisibilityLevel.VISIBILITY_USER] = "private"; VISIBILITY_LEVELS_API[PostVisibilityLevel.VISIBILITY_GROUP_MEMBERS] = "members"; const ACCESS_LEVELS_API = {}; ACCESS_LEVELS_API[PostAccessLevel.NO_ACCESS] = "no-access"; ACCESS_LEVELS_API[PostAccessLevel.BASIC_ACCESS] = "basic"; ACCESS_LEVELS_API[PostAccessLevel.INTERMEDIATE_ACCESS] = "intermediate"; ACCESS_LEVELS_API[PostAccessLevel.FULL_ACCESS] = "full"; export class PostsController { /** * Get the posts of a user * * @param h Request handler */ public static async GetListUser(h: RequestHandler) { const userID = await h.postUserId("userID"); const startFrom = h.postInt("startFrom", 0); if(!await UserHelper.CanSeeUserPage(h.optionnalUserID, userID)) h.error(401, "You are not allowed to access this user posts !"); const posts = await PostsHelper.GetUserPosts(h.optionnalUserID, userID, startFrom); await this.SendMultiplePosts(h, posts); } /** * Get the list of posts of a group * * @param h Request handler */ public static async GetListGroup(h: RequestHandler) { const groupID = await h.postGroupIDWithAccess("groupID", GroupsAccessLevel.VIEW_ACCESS); const startFrom = h.postInt("startFrom", 0); const posts = await PostsHelper.GetGroupPosts(h.optionnalUserID, groupID, startFrom); await this.SendMultiplePosts(h, posts); } /** * Get the list of latest posts * * @param h Request handler */ public static async GetLatest(h: RequestHandler) { const startFrom = h.postInt("startFrom", 0); const includeGroups = h.postBool('include_groups', false); const posts = await PostsHelper.GetLatest(h.getUserId(), startFrom, 10, includeGroups); await this.SendMultiplePosts(h, posts); } /** * Get information about a single post * * @param h Request handler */ public static async GetSingle(h: RequestHandler) { const postID = await h.postPostIDWithAccess("postID"); const post = await PostsHelper.GetSingle(postID); h.send(await this.PostToAPI(h, post)); } /** * Create a new post * * @param h Request handler */ public static async CreatePost(h: RequestHandler) { // Determine the target for the new post let kindPage: PostPageKind; let pageID: number; switch(h.postString("kind-page")) { // If the post is targetting a user case "user": kindPage = PostPageKind.PAGE_KIND_USER; pageID = await h.postUserId("kind-id"); if(!await UserHelper.CanCreatePosts(h.getUserId(), pageID)) h.error(401, "You are not allowed to create posts on this page!"); break; // For groups case "group": kindPage = PostPageKind.PAGE_KIND_GROUP; pageID = await h.postGroupIDWithAccess("kind-id", GroupsAccessLevel.MEMBER_ACCESS); // Check if the user can create posts on this group if(!await GroupsHelper.CanUserCreatePosts(pageID, h.getUserId())) h.error(401, "You are not allowed to create posts on this group!"); break; default: h.error(500, "Unsupported kind of page!"); } // Initialize new post information const newPost = new Post({ // Basic information about the post id: -1, userID: h.getUserId(), timeCreate: time(), kind: h.postString("kind"), content: h.postContent("content", 0), visibilityLevel: this.PostVisibilityLevel(h, "visibility"), // Post target kindPage: kindPage, pageID: pageID, }); // Process each kind of post switch(newPost.kind) { // Text posts case PostKind.POST_KIND_TEXT: // Check the string if(!check_string_before_insert(newPost.content)) h.error(400, "Specified post content is invalid!"); break; // Image posts case PostKind.POST_KIND_IMAGE: if(!h.hasFile("image")) h.error(400, "An error occured while receiving the image!"); // Save image const path = await h.savePostImage("image", "imgpost", 2000, 2000); newPost.file = new PostFile({ path: path, type: lookup(pathUserData(path, true)), size: statSync(pathUserData(path, true)).size }); break; // YouTube posts case PostKind.POST_KIND_YOUTUBE: const youtubeID = h.postString("youtube_id"); if(!check_youtube_id(youtubeID)) h.error(400, "Invalid YouTube ID!"); newPost.file = new PostFile({ path: youtubeID, size: 0, type: "youtube" }) break; default: h.error(500, "Unsupported kind of post!"); } // Create the post const postID = await PostsHelper.Create(newPost); // TODO : create a notification h.send({ success: "The post has been created!", postID: postID }); } /** * Send multiple posts to the API * * @param h Request handler * @param posts The list of post to send */ private static async SendMultiplePosts(h: RequestHandler, posts: Array) { let list = []; for (const p of posts) { list.push(await this.PostToAPI(h, p)); } h.send(list); } /** * Turn a post object into an API entry * * @param h Request handler * @param p The post */ public static async PostToAPI(h: RequestHandler, p: Post) : Promise { let data : any = { ID: p.id, userID: p.userID, user_page_id: p.userPageID, group_id: p.groupID, post_time: p.timeCreate, content: p.hasContent ? p.content : null, visibility_level: VISIBILITY_LEVELS_API[p.visibilityLevel], kind: p.kind, // File specific file_size: !p.hasFile ? null : p.file.size, file_type: !p.hasFile ? null : p.file.type, file_path: !p.hasFile ? null : p.file.path, file_path_url: !p.hasFile ? null : p.file.url, // Movie specific video_id: p.hasMovie ? p.movieID : null, video_info: p.hasMovie ? MoviesController.MovieToAPI(await MoviesHelper.GetInfo(p.movieID)) : null, // Countdown timer specific time_end: p.hasTimeEnd ? p.timeEnd : null, // Weblink specific link_url: !p.hasLink ? null : p.link.url, link_title: !p.hasLink ? null : p.link.title, link_description: !p.hasLink ? null : p.link.description, link_image: !p.hasLink ? null : p.link.image, // Survey specific data_survey: !p.hasSurvey ? null : await SurveyController.SurveyToAPI(h, await SurveyHelper.GetInfo(p.id)), // Likes information likes: await LikesHelper.Count(p.id, LikesType.POST), userlike: h.signedIn ? await LikesHelper.IsLiking(h.getUserId(), p.id, LikesType.POST) : false, // Determine user access level user_access: ACCESS_LEVELS_API[await PostsHelper.GetAccessLevel(h.optionnalUserID, p)], // Load comments (if possible) comments: await PostsHelper.AllowCommentsOnPost(p) ? await CommentsController.CommentsToAPI(h, await CommentsHelper.Get(p.id)) : null, }; return data; } /** * Get the visibility level for a POST included in a request * * @param h Request handler * @param name The name of the POST field containing the visibility level of the user */ private static PostVisibilityLevel(h: RequestHandler, name: string) : PostVisibilityLevel { const levelKey = findKey(VISIBILITY_LEVELS_API, h.postString(name, 3)); if(levelKey == null) h.error(400, "Post visibility level level not recognized!"); return Number(levelKey); } }