used cached post
This commit is contained in:
parent
3052abf0d6
commit
e2935a628f
@ -1,7 +1,38 @@
|
|||||||
import { error, fail, redirect } from "@sveltejs/kit";
|
import { error, fail, redirect } from "@sveltejs/kit";
|
||||||
import { validateData } from "$lib/utils";
|
import { validateData } from "$lib/utils";
|
||||||
import { loginUserSchema, registerUserSchema } from "$lib/schemas";
|
import { loginUserSchema, registerUserSchema } from "$lib/schemas";
|
||||||
import { oauthState, oauthVerifier, oauthProvider } from '$lib/store';
|
import { userRegion, oauthState, oauthVerifier, oauthProvider } from '$lib/store';
|
||||||
|
|
||||||
|
|
||||||
|
const usRegion = ['cle1','iad1','pdx1','sfo1'];
|
||||||
|
let fastifyURL = import.meta.env.VITE_EU_FASTIFY_URL;
|
||||||
|
|
||||||
|
userRegion.subscribe(value => {
|
||||||
|
if (usRegion.includes(value)) {
|
||||||
|
fastifyURL = import.meta.env.VITE_USEAST_FASTIFY_URL;
|
||||||
|
} else {
|
||||||
|
fastifyURL = import.meta.env.VITE_EU_FASTIFY_URL;
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
|
||||||
|
export const load = async ({ params }) => {
|
||||||
|
|
||||||
|
|
||||||
|
const getPostId = async () => {
|
||||||
|
|
||||||
|
return params.postId;
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
return {
|
||||||
|
getPostId: await getPostId(),
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
export const actions = {
|
export const actions = {
|
||||||
|
|||||||
@ -6,10 +6,8 @@ import Downvote from '$lib/components/Downvote.svelte';
|
|||||||
import Upvote from '$lib/components/Upvote.svelte';
|
import Upvote from '$lib/components/Upvote.svelte';
|
||||||
import VideoPlayer from '$lib/components/VideoPlayer.svelte';
|
import VideoPlayer from '$lib/components/VideoPlayer.svelte';
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
import { onMount, onDestroy } from 'svelte';
|
import { onMount, onDestroy } from 'svelte';
|
||||||
import {userRegion, screenWidth, scrollToComment, postIdDeleted, setCache, getCache, tagList, numberOfUnreadNotification, commentAdded, commentUpdated, commentIdDeleted } from '$lib/store';
|
import {cachedPosts, userRegion, screenWidth, scrollToComment, postIdDeleted, setCache, getCache, tagList, numberOfUnreadNotification, commentAdded, commentUpdated, commentIdDeleted } from '$lib/store';
|
||||||
import { goto, afterNavigate } from '$app/navigation';
|
import { goto, afterNavigate } from '$app/navigation';
|
||||||
import { base } from '$app/paths'
|
import { base } from '$app/paths'
|
||||||
|
|
||||||
@ -32,7 +30,7 @@ userRegion.subscribe(value => {
|
|||||||
});
|
});
|
||||||
|
|
||||||
|
|
||||||
let post = data?.getOnePost;
|
let post = {'id': 'test', 'upvote': 0, 'downvote': 0};
|
||||||
let isScrolled = false;
|
let isScrolled = false;
|
||||||
let isLoaded = false;
|
let isLoaded = false;
|
||||||
|
|
||||||
@ -42,6 +40,22 @@ let upvoteCounter = {};
|
|||||||
let downvoteCounter = {};
|
let downvoteCounter = {};
|
||||||
let userAlreadyVoted;
|
let userAlreadyVoted;
|
||||||
|
|
||||||
|
async function getOnePost() {
|
||||||
|
|
||||||
|
const postData = {'postId': data?.getPostId};
|
||||||
|
|
||||||
|
const response = await fetch(fastifyURL+'/get-one-post', {
|
||||||
|
method: 'POST',
|
||||||
|
headers: {
|
||||||
|
'Content-Type': 'application/json',
|
||||||
|
},
|
||||||
|
body: JSON.stringify(postData),
|
||||||
|
});
|
||||||
|
|
||||||
|
const output = await response.json()
|
||||||
|
return output?.items
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
const handleUpvote = async (event) => {
|
const handleUpvote = async (event) => {
|
||||||
@ -258,9 +272,9 @@ const getModerators = async () => {
|
|||||||
|
|
||||||
|
|
||||||
|
|
||||||
function isModerator(userId) {
|
function isModerator(userId) {
|
||||||
return moderators?.some(moderator => userId === moderator?.user);
|
return moderators?.some(moderator => userId === moderator?.user);
|
||||||
}
|
}
|
||||||
|
|
||||||
function countAllComments(comments) {
|
function countAllComments(comments) {
|
||||||
// Helper function to recursively count comments
|
// Helper function to recursively count comments
|
||||||
@ -281,6 +295,26 @@ let LoginPopup;
|
|||||||
|
|
||||||
onMount(async () => {
|
onMount(async () => {
|
||||||
|
|
||||||
|
post = $cachedPosts?.at(0)?.posts?.find(item => item?.id === data?.getPostId) ?? {};
|
||||||
|
|
||||||
|
if (Object?.keys(post)?.length !== 0) {
|
||||||
|
[moderators, comments] = await Promise?.all([
|
||||||
|
getModerators(),
|
||||||
|
getAllComments(),
|
||||||
|
]);
|
||||||
|
|
||||||
|
} else {
|
||||||
|
[post, moderators, comments] = await Promise?.all([
|
||||||
|
getOnePost(),
|
||||||
|
getModerators(),
|
||||||
|
getAllComments(),
|
||||||
|
]);
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
numberOfComments = countAllComments(comments) || 0;
|
||||||
|
|
||||||
|
|
||||||
upvoteCounter[post.id] = post?.upvote;
|
upvoteCounter[post.id] = post?.upvote;
|
||||||
downvoteCounter[post.id] = post?.downvote;
|
downvoteCounter[post.id] = post?.downvote;
|
||||||
userAlreadyVoted = post?.expand['alreadyVoted(post)']?.some(item => item?.user === data?.user?.id);
|
userAlreadyVoted = post?.expand['alreadyVoted(post)']?.some(item => item?.user === data?.user?.id);
|
||||||
@ -300,13 +334,8 @@ onMount(async () => {
|
|||||||
LoginPopup = (await import('$lib/components/LoginPopup.svelte')).default;
|
LoginPopup = (await import('$lib/components/LoginPopup.svelte')).default;
|
||||||
}
|
}
|
||||||
|
|
||||||
[moderators, comments] = await Promise.all([
|
|
||||||
getModerators(),
|
|
||||||
getAllComments(),
|
|
||||||
]);
|
|
||||||
|
|
||||||
numberOfComments = countAllComments(comments) || 0;
|
|
||||||
console.log(moderators)
|
|
||||||
|
|
||||||
if (post?.postType === 'link') {
|
if (post?.postType === 'link') {
|
||||||
const url = new URL(post.link);
|
const url = new URL(post.link);
|
||||||
@ -319,18 +348,18 @@ if (post?.postType === 'link') {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
loadTextEditor = true;
|
loadTextEditor = true;
|
||||||
isLoaded = true;
|
isLoaded = true;
|
||||||
|
|
||||||
//comments = data?.allComments?.items.reverse() || []
|
//comments = data?.allComments?.items.reverse() || []
|
||||||
//replyComments = data?.allReplyComments?.items.reverse() || []
|
//replyComments = data?.allReplyComments?.items.reverse() || []
|
||||||
// Add a scroll event listener
|
// Add a scroll event listener
|
||||||
window.addEventListener('scroll', handleScroll);
|
window.addEventListener('scroll', handleScroll);
|
||||||
|
|
||||||
return () => {
|
return () => {
|
||||||
// Remove the event listener when the component is unmounted
|
// Remove the event listener when the component is unmounted
|
||||||
window.removeEventListener('scroll', handleScroll);
|
window.removeEventListener('scroll', handleScroll);
|
||||||
};
|
};
|
||||||
|
|
||||||
});
|
});
|
||||||
|
|
||||||
@ -351,8 +380,6 @@ function closePost(event) {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
onDestroy( () => {
|
onDestroy( () => {
|
||||||
$commentAdded = '';
|
$commentAdded = '';
|
||||||
$commentIdDeleted = '';
|
$commentIdDeleted = '';
|
||||||
@ -499,6 +526,7 @@ $: {
|
|||||||
<!--<section on:click={closePost} class="bg-[#0F0F0F] cursor-zoom-out min-h-screen">-->
|
<!--<section on:click={closePost} class="bg-[#0F0F0F] cursor-zoom-out min-h-screen">-->
|
||||||
|
|
||||||
<!--in:pageTransitionIn={{ duration: 250, screenWidth: $screenWidth }}-->
|
<!--in:pageTransitionIn={{ duration: 250, screenWidth: $screenWidth }}-->
|
||||||
|
{#if isLoaded}
|
||||||
<div class="overflow-hidden flex flex-row item-start w-full lg:mt-5 relative max-w-6xl m-auto lg:px-5 sm:pb-40">
|
<div class="overflow-hidden flex flex-row item-start w-full lg:mt-5 relative max-w-6xl m-auto lg:px-5 sm:pb-40">
|
||||||
<!--Start Voting-->
|
<!--Start Voting-->
|
||||||
<div style="top: 4rem;" class="hidden lg:flex flex-col items-center relative h-fit sticky z-20 lg:mr-3 ">
|
<div style="top: 4rem;" class="hidden lg:flex flex-col items-center relative h-fit sticky z-20 lg:mr-3 ">
|
||||||
@ -897,7 +925,11 @@ $: {
|
|||||||
|
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
|
{:else}
|
||||||
|
<div class="flex justify-center items-center m-auto h-full w-full max-w-6xl">
|
||||||
|
<div class="loader">Loading...</div>
|
||||||
|
</div>
|
||||||
|
{/if}
|
||||||
|
|
||||||
<!--Start Login Modal-->
|
<!--Start Login Modal-->
|
||||||
{#if LoginPopup}
|
{#if LoginPopup}
|
||||||
|
|||||||
@ -1,114 +0,0 @@
|
|||||||
import { userRegion } from '$lib/store';
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
export const load = async ({ params }) => {
|
|
||||||
|
|
||||||
const usRegion = ['cle1','iad1','pdx1','sfo1'];
|
|
||||||
let fastifyURL = import.meta.env.VITE_EU_FASTIFY_URL;
|
|
||||||
|
|
||||||
userRegion.subscribe(value => {
|
|
||||||
if (usRegion.includes(value)) {
|
|
||||||
fastifyURL = import.meta.env.VITE_USEAST_FASTIFY_URL;
|
|
||||||
} else {
|
|
||||||
fastifyURL = import.meta.env.VITE_EU_FASTIFY_URL;
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
async function getOnePost() {
|
|
||||||
|
|
||||||
|
|
||||||
const postData = {'postId': params.postId};
|
|
||||||
|
|
||||||
const response = await fetch(fastifyURL+'/get-one-post', {
|
|
||||||
method: 'POST',
|
|
||||||
headers: {
|
|
||||||
'Content-Type': 'application/json',
|
|
||||||
},
|
|
||||||
body: JSON.stringify(postData),
|
|
||||||
});
|
|
||||||
|
|
||||||
const output = await response.json()
|
|
||||||
|
|
||||||
return output?.items
|
|
||||||
}
|
|
||||||
|
|
||||||
const getPostId = async () => {
|
|
||||||
|
|
||||||
return params.postId;
|
|
||||||
};
|
|
||||||
|
|
||||||
|
|
||||||
return {
|
|
||||||
getPostId: await getPostId(),
|
|
||||||
getOnePost: await getOnePost(),
|
|
||||||
};
|
|
||||||
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/*
|
|
||||||
export const actions = {
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
replycomment: async ({ request, locals }) => {
|
|
||||||
const body = await request.formData();
|
|
||||||
|
|
||||||
body.append('user', locals.user.id);
|
|
||||||
|
|
||||||
if (body.get('description') === 'undefined')
|
|
||||||
{
|
|
||||||
body.delete('description');
|
|
||||||
body.append('description', '');
|
|
||||||
console.log('I GOT TRIGGERED')
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
const {formData, errors} = await validateData( body, createReplyCommentSchema);
|
|
||||||
|
|
||||||
|
|
||||||
if (errors) {
|
|
||||||
return fail(400, {
|
|
||||||
data: formData,
|
|
||||||
errors: errors.fieldErrors
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
//Each comment gives the user +1 Karma points
|
|
||||||
await locals.pb.collection("users").update(locals.user.id, {
|
|
||||||
"karma+": 1,
|
|
||||||
})
|
|
||||||
|
|
||||||
try {
|
|
||||||
let newReplyComment = await locals.pb.collection('replycomments').create(serialize(formData));
|
|
||||||
|
|
||||||
//User always upvotes their post in the intial state
|
|
||||||
await locals.pb.collection("replycomments").update(newReplyComment.id, {
|
|
||||||
"vote+": 1,
|
|
||||||
})
|
|
||||||
|
|
||||||
} catch (err) {
|
|
||||||
console.log('Error: ', err);
|
|
||||||
throw error(err.status, err.message);
|
|
||||||
}
|
|
||||||
|
|
||||||
throw redirect(303, '/community/'+body.get('post'));
|
|
||||||
|
|
||||||
|
|
||||||
},
|
|
||||||
|
|
||||||
|
|
||||||
};
|
|
||||||
*/
|
|
||||||
Loading…
x
Reference in New Issue
Block a user