ocelot-Social-Community/Ocelot-Social
1
0
Fork 0
mirror of https://github.com/Ocelot-Social-Community/Ocelot-Social.git synced 2025-12-13 07:46:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'master' into remove-activity-pub

Browse Source
This commit is contained in:
Ulf Gebhardt 2023-06-21 06:55:22 +02:00 committed by GitHub
commit 4d91b3f5b0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
6 changed files with 80 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/graphql/rooms.ts
View File

@ -9,6 +9,7 @@ export const createRoomMutation = () => {
userId: $userId
) {
id
roomId
}
}
`
@ -19,8 +20,15 @@ export const roomQuery = () => {
query {
Room {
id
roomId
roomName
users {
_id
id
name
avatar {
url
}
}
}
}

21
backend/src/schema/resolvers/messages.spec.ts
View File

@ -209,9 +209,17 @@ describe('Message', () => {
mutation: createMessageMutation(),
variables: {
roomId,
content: 'Another nice message to other chatting user',
content: 'A nice response message to chatting user',
}
})
authenticatedUser = await chattingUser.toJson()
await mutate({
mutation: createMessageMutation(),
variables: {
roomId,
content: 'And another nice message to other chatting user',
}
})
})
it('returns the messages', async () => {
@ -233,11 +241,18 @@ describe('Message', () => {
},
{
id: expect.any(String),
content: 'Another nice message to other chatting user',
content: 'A nice response message to chatting user',
author: {
id: 'other-chatting-user',
},
}
},
{
id: expect.any(String),
content: 'And another nice message to other chatting user',
author: {
id: 'chatting-user',
},
}
],
},
})

10
backend/src/schema/resolvers/messages.ts
View File

@ -24,11 +24,11 @@ export default {
const writeTxResultPromise = session.writeTransaction(async (transaction) => {
const createMessageCypher = `
MATCH (currentUser:User { id: $currentUserId })-[:CHATS_IN]->(room:Room { id: $roomId })
MERGE (currentUser)-[:CREATED]->(message:Message)-[:INSIDE]->(room)
ON CREATE SET
message.createdAt = toString(datetime()),
message.id = apoc.create.uuid(),
message.content = $content
CREATE (currentUser)-[:CREATED]->(message:Message {
createdAt: toString(datetime()),
id: apoc.create.uuid(),
content: $content
})-[:INSIDE]->(room)
RETURN message { .* }
`
const createMessageTxResponse = await transaction.run(

33
backend/src/schema/resolvers/rooms.spec.ts
View File

@ -102,11 +102,12 @@ describe('Room', () => {
},
})
roomId = result.data.CreateRoom.id
await expect(result).toMatchObject({
expect(result).toMatchObject({
errors: undefined,
data: {
CreateRoom: {
id: expect.any(String),
roomId: result.data.CreateRoom.id,
},
},
})
@ -153,18 +154,31 @@ describe('Room', () => {
})
it('returns the room', async () => {
await expect(query({ query: roomQuery() })).resolves.toMatchObject({
const result = await query({ query: roomQuery() })
expect(result).toMatchObject({
errors: undefined,
data: {
Room: [
{
id: expect.any(String),
roomId: result.data.Room[0].id,
roomName: 'Other Chatting User',
users: expect.arrayContaining([
{
_id: 'chatting-user',
id: 'chatting-user',
name: 'Chatting User',
avatar: {
url: expect.any(String),
},
},
{
_id: 'other-chatting-user',
id: 'other-chatting-user',
name: 'Other Chatting User',
avatar: {
url: expect.any(String),
},
},
]),
},
@ -180,18 +194,31 @@ describe('Room', () => {
})
it('returns the room', async () => {
await expect(query({ query: roomQuery() })).resolves.toMatchObject({
const result = await query({ query: roomQuery() })
expect(result).toMatchObject({
errors: undefined,
data: {
Room: [
{
id: expect.any(String),
roomId: result.data.Room[0].id,
roomName: 'Chatting User',
users: expect.arrayContaining([
{
_id: 'chatting-user',
id: 'chatting-user',
name: 'Chatting User',
avatar: {
url: expect.any(String),
},
},
{
_id: 'other-chatting-user',
id: 'other-chatting-user',
name: 'Other Chatting User',
avatar: {
url: expect.any(String),
},
},
]),
},

16
backend/src/schema/resolvers/rooms.ts
View File

@ -8,7 +8,18 @@ export default {
params.filter.users_some = {
id: context.user.id,
}
return neo4jgraphql(object, params, context, resolveInfo)
const resolved = await neo4jgraphql(object, params, context, resolveInfo)
if (resolved) {
resolved.forEach((room) => {
if (room.users) {
room.roomName = room.users.filter((user) => user.id !== context.user.id)[0].name
room.users.forEach((user) => {
user._id = user.id
})
}
})
}
return resolved
},
},
Mutation: {
@ -37,6 +48,9 @@ export default {
})
try {
const room = await writeTxResultPromise
if (room) {
room.roomId = room.id
}
return room
} catch (error) {
throw new Error(error)

5
backend/src/schema/types/type/Room.gql
View File

@ -10,7 +10,10 @@ type Room {
createdAt: String
updatedAt: String
users: [User]! @relation(name: "CHATS_IN", direction: "IN")
users: [User]! @relation(name: "CHATS_IN", direction: "IN")
roomId: String! @cypher(statement: "RETURN this.id")
roomName: String! ## @cypher(statement: "MATCH (this)<-[:CHATS_IN]-(user:User) WHERE NOT user.id = $cypherParams.currentUserId RETURN user[0].name")
}
type Mutation {