RageStudio/comty
1
0
Fork 0
mirror of https://github.com/ragestudio/comty.git synced 2025-06-09 10:34:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix websocket to websockets global variable references to support ng

Browse Source
This commit is contained in:
SrGooglo 2025-04-24 06:10:50 +00:00
parent 7b7e7b9bb7
commit 1f0c1d5033
23 changed files with 214 additions and 208 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
packages/server/services/posts/classes/posts/methods/create.js
View File

@ -89,11 +89,15 @@ export default async (payload = {}, req) => {
// broadcast post to all users
if (visibility === "public") {
global.websocket.senders.toTopic("realtime:feed", "post:new", result[0])
global.websockets.senders.toTopic(
"realtime:feed",
"post:new",
result[0],
)
}
if (visibility === "private") {
const userSockets = await global.websocket.find.clientsByUserId(
const userSockets = await global.websockets.find.clientsByUserId(
post.user_id,
)

4
packages/server/services/posts/classes/posts/methods/delete.js
View File

@ -42,7 +42,7 @@ export default async (payload = {}) => {
// broadcast post to all users
if (post.visibility === "public") {
global.websocket.senders.toTopic(
global.websockets.senders.toTopic(
"realtime:feed",
"post:delete",
post_id,
@ -50,7 +50,7 @@ export default async (payload = {}) => {
}
if (post.visibility === "private") {
const userSockets = await global.websocket.find.clientsByUserId(
const userSockets = await global.websockets.find.clientsByUserId(
post.user_id,
)

44
packages/server/services/posts/classes/posts/methods/deletePollVote.js
View File

@ -1,33 +1,33 @@
import { VotePoll } from "@db_models"
export default async (payload = {}) => {
if (!payload.user_id) {
throw new OperationError(400, "Missing user_id")
}
if (!payload.user_id) {
throw new OperationError(400, "Missing user_id")
}
if (!payload.post_id) {
throw new OperationError(400, "Missing post_id")
}
if (!payload.post_id) {
throw new OperationError(400, "Missing post_id")
}
if (!payload.option_id) {
throw new OperationError(400, "Missing option_id")
}
if (!payload.option_id) {
throw new OperationError(400, "Missing option_id")
}
let vote = await VotePoll.find({
user_id: payload.user_id,
post_id: payload.post_id,
option_id: payload.option_id,
})
let vote = await VotePoll.find({
user_id: payload.user_id,
post_id: payload.post_id,
option_id: payload.option_id,
})
if (!vote) {
throw new OperationError(404, "Poll vote not found")
}
if (!vote) {
throw new OperationError(404, "Poll vote not found")
}
await VotePoll.deleteOne({
_id: vote._id
})
await VotePoll.deleteOne({
_id: vote._id,
})
global.websocket.io.of("/").emit(`post.poll.vote.deleted`, vote)
global.websockets.io.of("/").emit(`post.poll.vote.deleted`, vote)
return vote
return vote
}

4
packages/server/services/posts/classes/posts/methods/update.js
View File

@ -37,7 +37,7 @@ export default async (post_id, update) => {
})
if (post.visibility === "public") {
global.websocket.senders.toTopic(
global.websockets.senders.toTopic(
"realtime:feed",
`post:update`,
result[0],
@ -45,7 +45,7 @@ export default async (post_id, update) => {
}
if (post.visibility === "private") {
const userSockets = await global.websocket.find.clientsByUserId(
const userSockets = await global.websockets.find.clientsByUserId(
post.user_id,
)

2
packages/server/services/posts/classes/posts/methods/votePoll.js
View File

@ -51,7 +51,7 @@ export default async (payload = {}) => {
post = (await stage({ posts: post, for_user_id: payload.user_id }))[0]
if (post.visibility === "public") {
global.websocket.senders.toTopic("realtime:feed", `post:update`, post)
global.websockets.senders.toTopic("realtime:feed", `post:update`, post)
}
return {

0
packages/server/services/posts/log.txt Normal file
View File

13
packages/server/services/posts/posts.service.js
View File

@ -1,5 +1,5 @@
//import { Server } from "../../../../linebridge/server/src"
import { Server } from "linebridge"
import { Server } from "../../../../linebridge/server/src"
//import { Server } from "linebridge"
import DbManager from "@shared-classes/DbManager"
import RedisClient from "@shared-classes/RedisClient"
@ -10,10 +10,11 @@ import SharedMiddlewares from "@shared-middlewares"
export default class API extends Server {
static refName = "posts"
static useEngine = "hyper-express-ng"
static enableWebsockets = true
static listen_port = process.env.HTTP_LISTEN_PORT ?? 3001
//static useEngine = "hyper-express-ng"
static websockets = true
static listenPort = process.env.HTTP_LISTEN_PORT ?? 3001
// static useMiddlewares = ["logs"]
static bypassCors = true
middlewares = {
...SharedMiddlewares,

16
packages/server/services/posts/routes/posts/[post_id]/data/get.js
View File

@ -1,13 +1,13 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withOptionalAuthentication"],
fn: async (req, res) => {
const result = await Posts.data({
post_id: req.params.post_id,
for_user_id: req.auth?.session?.user_id,
})
useMiddlewares: ["withOptionalAuthentication"],
fn: async (req, res) => {
const result = await Posts.data({
post_id: req.params.post_id,
for_user_id: req.auth?.session?.user_id,
})
return result
}
return result
},
}

39
packages/server/services/posts/routes/posts/[post_id]/delete.js
View File

@ -1,27 +1,28 @@
import PostClass from "@classes/posts"
import { Post } from "@db_models"
export default {
middlewares: ["withAuthentication"],
fn: async (req, res) => {
// check if post is owned or if is admin
const post = await Post.findById(req.params.post_id).catch(() => {
return false
})
useMiddlewares: ["withAuthentication"],
fn: async (req, res) => {
// check if post is owned or if is admin
const post = await Post.findById(req.params.post_id).catch(() => {
return false
})
if (!post) {
throw new OperationError(404, "Post not found")
}
if (!post) {
throw new OperationError(404, "Post not found")
}
const user = await req.auth.user()
const user = await req.auth.user()
if (post.user_id.toString() !== user._id.toString()) {
if (!user.roles.includes("admin")) {
throw new OperationError(403, "You cannot delete this post")
}
}
if (post.user_id.toString() !== user._id.toString()) {
if (!user.roles.includes("admin")) {
throw new OperationError(403, "You cannot delete this post")
}
}
return await PostClass.delete({
post_id: req.params.post_id
})
}
return await PostClass.delete({
post_id: req.params.post_id,
})
},
}

18
packages/server/services/posts/routes/posts/[post_id]/replies/get.js
View File

@ -1,13 +1,13 @@
import PostClass from "@classes/posts"
export default {
middlewares: ["withOptionalAuthentication"],
fn: async (req) => {
return await PostClass.replies({
post_id: req.params.post_id,
for_user_id: req.auth?.session.user_id,
trim: req.query.trim,
limit: req.query.limit
})
}
useMiddlewares: ["withOptionalAuthentication"],
fn: async (req) => {
return await PostClass.replies({
post_id: req.params.post_id,
for_user_id: req.auth?.session.user_id,
trim: req.query.trim,
limit: req.query.limit,
})
},
}

18
packages/server/services/posts/routes/posts/[post_id]/toggle_like/post.js
View File

@ -1,14 +1,14 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withAuthentication"],
fn: async (req, res) => {
const result = await Posts.toggleLike({
post_id: req.params.post_id,
user_id: req.auth.session.user_id,
to: req.body?.to,
})
useMiddlewares: ["withAuthentication"],
fn: async (req, res) => {
const result = await Posts.toggleLike({
post_id: req.params.post_id,
user_id: req.auth.session.user_id,
to: req.body?.to,
})
return result
}
return result
},
}

18
packages/server/services/posts/routes/posts/[post_id]/toggle_save/post.js
View File

@ -1,14 +1,14 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withAuthentication"],
fn: async (req, res) => {
const result = await Posts.toggleSave({
post_id: req.params.post_id,
user_id: req.auth.session.user_id,
to: req.body?.to,
})
useMiddlewares: ["withAuthentication"],
fn: async (req, res) => {
const result = await Posts.toggleSave({
post_id: req.params.post_id,
user_id: req.auth.session.user_id,
to: req.body?.to,
})
return result
}
return result
},
}

2
packages/server/services/posts/routes/posts/[post_id]/update/put.js
View File

@ -15,7 +15,7 @@ const MaxStringsLengths = {
}
export default {
middlewares: ["withAuthentication"],
useMiddlewares: ["withAuthentication"],
fn: async (req) => {
let update = {}

18
packages/server/services/posts/routes/posts/[post_id]/vote_poll/[option_id]/delete.js
View File

@ -1,14 +1,14 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withAuthentication"],
fn: async (req) => {
const result = await Posts.deleteVotePoll({
user_id: req.auth.session.user_id,
post_id: req.params.post_id,
option_id: req.params.option_id,
})
useMiddlewares: ["withAuthentication"],
fn: async (req) => {
const result = await Posts.deleteVotePoll({
user_id: req.auth.session.user_id,
post_id: req.params.post_id,
option_id: req.params.option_id,
})
return result
}
return result
},
}

18
packages/server/services/posts/routes/posts/[post_id]/vote_poll/[option_id]/post.js
View File

@ -1,14 +1,14 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withAuthentication"],
fn: async (req) => {
const result = await Posts.votePoll({
user_id: req.auth.session.user_id,
post_id: req.params.post_id,
option_id: req.params.option_id,
})
useMiddlewares: ["withAuthentication"],
fn: async (req) => {
const result = await Posts.votePoll({
user_id: req.auth.session.user_id,
post_id: req.params.post_id,
option_id: req.params.option_id,
})
return result
}
return result
},
}

24
packages/server/services/posts/routes/posts/feed/global/get.js
View File

@ -1,19 +1,19 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withOptionalAuthentication"],
fn: async (req, res) => {
const payload = {
limit: req.query?.limit,
trim: req.query?.trim,
}
useMiddlewares: ["withOptionalAuthentication"],
fn: async (req, res) => {
const payload = {
limit: req.query?.limit,
trim: req.query?.trim,
}
if (req.auth) {
payload.user_id = req.auth.session.user_id
}
if (req.auth) {
payload.user_id = req.auth.session.user_id
}
const result = await Posts.globalTimeline(payload)
const result = await Posts.globalTimeline(payload)
return result
}
return result
},
}

24
packages/server/services/posts/routes/posts/feed/timeline/get.js
View File

@ -1,19 +1,19 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withOptionalAuthentication"],
fn: async (req, res) => {
const payload = {
limit: req.query?.limit,
trim: req.query?.trim,
}
useMiddlewares: ["withOptionalAuthentication"],
fn: async (req, res) => {
const payload = {
limit: req.query?.limit,
trim: req.query?.trim,
}
if (req.auth) {
payload.user_id = req.auth.session.user_id
}
if (req.auth) {
payload.user_id = req.auth.session.user_id
}
const result = await Posts.timeline(payload)
const result = await Posts.timeline(payload)
return result
}
return result
},
}

16
packages/server/services/posts/routes/posts/liked/get.js
View File

@ -1,12 +1,12 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withAuthentication"],
fn: async (req) => {
return await Posts.getLiked({
trim: req.query.trim,
limit: req.query.limit,
user_id: req.auth.session.user_id
})
}
useMiddlewares: ["withAuthentication"],
fn: async (req) => {
return await Posts.getLiked({
trim: req.query.trim,
limit: req.query.limit,
user_id: req.auth.session.user_id,
})
},
}

2
packages/server/services/posts/routes/posts/new/post.js
View File

@ -1,7 +1,7 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withAuthentication"],
useMiddlewares: ["withAuthentication"],
fn: async (req, res) => {
const result = await Posts.create(
{

16
packages/server/services/posts/routes/posts/saved/get.js
View File

@ -1,12 +1,12 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withAuthentication"],
fn: async (req) => {
return await Posts.getSaved({
trim: req.query.trim,
limit: req.query.limit,
user_id: req.auth.session.user_id
})
}
useMiddlewares: ["withAuthentication"],
fn: async (req) => {
return await Posts.getSaved({
trim: req.query.trim,
limit: req.query.limit,
user_id: req.auth.session.user_id,
})
},
}

2
packages/server/services/posts/routes/posts/trending/[trending]/get.js
View File

@ -2,7 +2,7 @@ import { Post } from "@db_models"
import stage from "@classes/posts/methods/stage"
export default {
middlewares: ["withOptionalAuthentication"],
useMiddlewares: ["withOptionalAuthentication"],
fn: async (req) => {
const { limit, trim } = req.query

70
packages/server/services/posts/routes/posts/trendings/get.js
View File

@ -5,41 +5,41 @@ const maxDaysOld = 30
const maxHashtags = 5
export default async (req) => {
// fetch all posts that contain in message an #, with a maximun of 5 diferent hashtags
const startDate = DateTime.local().minus({ days: maxDaysOld }).toISO()
// fetch all posts that contain in message an #, with a maximun of 5 diferent hashtags
const startDate = DateTime.local().minus({ days: maxDaysOld }).toISO()
const trendings = await Post.aggregate([
{
$match: {
message: { $regex: /#/gi },
created_at: { $gte: startDate }
}
},
{
$project: {
hashtags: {
$regexFindAll: {
input: "$message",
regex: /#[a-zA-Z0-9_]+/g
}
}
}
},
{ $unwind: "$hashtags" },
{
$project: {
hashtag: { $substr: ["$hashtags.match", 1, -1] }
}
},
{
$group: {
_id: "$hashtag",
count: { $sum: 1 }
}
},
{ $sort: { count: -1 } },
{ $limit: maxHashtags }
])
const trendings = await Post.aggregate([
{
$match: {
message: { $regex: /#/gi },
created_at: { $gte: startDate },
},
},
{
$project: {
hashtags: {
$regexFindAll: {
input: "$message",
regex: /#[a-zA-Z0-9_]+/g,
},
},
},
},
{ $unwind: "$hashtags" },
{
$project: {
hashtag: { $substr: ["$hashtags.match", 1, -1] },
},
},
{
$group: {
_id: "$hashtag",
count: { $sum: 1 },
},
},
{ $sort: { count: -1 } },
{ $limit: maxHashtags },
])
return trendings.map(({ _id, count }) => ({ hashtag: _id, count }));
return trendings.map(({ _id, count }) => ({ hashtag: _id, count }))
}

18
packages/server/services/posts/routes/posts/user/[user_id]/get.js
View File

@ -1,13 +1,13 @@
import Posts from "@classes/posts"
export default {
middlewares: ["withOptionalAuthentication"],
fn: async (req, res) => {
return await Posts.fromUserId({
skip: req.query.skip,
trim: req.query.trim,
user_id: req.params.user_id,
for_user_id: req.auth?.session?.user_id,
})
}
useMiddlewares: ["withOptionalAuthentication"],
fn: async (req, res) => {
return await Posts.fromUserId({
skip: req.query.skip,
trim: req.query.trim,
user_id: req.params.user_id,
for_user_id: req.auth?.session?.user_id,
})
},
}