adolforeyna/EMI-Backend
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Add promotional endpoint (extended) for new users

Browse Source
This commit is contained in:
Adolfo Reyna
2025-02-05 20:46:24 -05:00
parent bf2cdd4696
commit 309ae1b69b
2 changed files with 39 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
dbTools/post.js
View File

@@ -176,29 +176,33 @@ postDB = (DB)=>{
}); });
} }
// Filter out posts that are posted by private groups that the viewer is not part of.
filterPrivateGroups = async (posts, profile) =>{ filterPrivateGroups = async (posts, profile) =>{
let filteredPosts = []; let validatedPosts = [];
let following = {}; let following = {};
profile.following.forEach(element => { profile.following.forEach(element => {
following[element] = 1; following[element] = 1;
}); });
for(i in posts){ for(i in posts){
let p = posts[i]; let p = posts[i];
let isPostingAPrivateGroup = await DB.isGroupPrivate(p.profileid); let isPostedByAPrivateGroup = await DB.isGroupPrivate(p.profileid);
let isPostingToAPrivateGroup = p.toProfile ? await DB.isGroupPrivate(p.toProfile) : false; let isPostedToAPrivateGroup = p.toProfile ? await DB.isGroupPrivate(p.toProfile) : false;
if(!isPostingAPrivateGroup && !isPostingToAPrivateGroup){ // Not private posts
filteredPosts.push(p); if(!isPostedByAPrivateGroup && !isPostedToAPrivateGroup){
validatedPosts.push(p);
continue; continue;
} }
if(isPostingAPrivateGroup && !following[p.profileid]){ // skipps private post if viewer is not part of the group
if(isPostedByAPrivateGroup && !following[p.profileid]){
continue; continue;
} }
if(isPostingToAPrivateGroup && !following[p.toProfile]){ if(isPostedToAPrivateGroup && !following[p.toProfile]){
continue; continue;
} }
filteredPosts.push(p); // Private but the user is part of the group
validatedPosts.push(p);
} }
return filteredPosts; return validatedPosts;
} }
DB.getFeed = async (profileId) => { DB.getFeed = async (profileId) => {
@@ -217,7 +221,22 @@ postDB = (DB)=>{
], ],
nonOrganicType: null // Exlcude news nonOrganicType: null // Exlcude news
}; };
return DB.postCols.find(query).sort({lastUpdated: -1}).limit(20).toArray().then(async (posts)=>{ return DB.postCols.find(query).sort({lastUpdated: -1}).limit(30).toArray().then(async (posts)=>{
return await filterPrivateGroups(posts, profile);
}).catch((err)=>{
console.log(err);
return false;
});
}
DB.getPromotionalPosts = async (profileId) => {
if(!DB.ObjectID.isValid(profileId)) return [];
const profile = await DB.getProfile(profileId);
if(!profile) return [];
query = {
nonOrganicType: null // Exlcude news
};
return DB.postCols.find(query).sort({lastUpdated: -1}).limit(50).toArray().then(async (posts)=>{
return await filterPrivateGroups(posts, profile); return await filterPrivateGroups(posts, profile);
}).catch((err)=>{ }).catch((err)=>{
console.log(err); console.log(err);

11
routes/post.js
View File

@@ -82,7 +82,16 @@ DB.getDB.then((DB) => {
let organicPosts = await DB.getFeed(profileid); let organicPosts = await DB.getFeed(profileid);
//Add non-organic posts //Add non-organic posts
const nonOrganicPosts = await generateNonOrganicPosts(req, profileid); const nonOrganicPosts = await generateNonOrganicPosts(req, profileid);
const posts = mergePosts(organicPosts, nonOrganicPosts); const posts = mergePosts(promotionalPosts, nonOrganicPosts);
return res.json(posts);
});
router.get("/extended", async (req, res) => {
const profileid = getProfileId(req);
//Add non-organic posts
const nonOrganicPosts = await generateNonOrganicPosts(req, profileid);
let promotionalPosts = await DB.getPromotionalPosts(profileid);
const posts = mergePosts(promotionalPosts, nonOrganicPosts);
return res.json(posts); return res.json(posts);
}); });