Leahnaya/friends
1
0
Fork 0
mirror of https://github.com/PretendoNetwork/friends.git synced 2026-08-02 16:13:00 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

notifications/3ds: Send events to the target user

Browse Source
This commit is contained in:
Daniel López Guimaraes 2024-04-20 13:43:13 +01:00
parent e2a630d1a7
commit 7aef2f1750
No known key found for this signature in database
GPG Key ID: 6AC74DE3DEF050E0
5 changed files with 20 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
notifications/3ds/send_comment_update.go
View File

@ -49,15 +49,15 @@ func SendCommentUpdate(connection *nex.PRUDPConnection, comment string) {
connectedUser, ok := globals.ConnectedUsers.Get(friend.PID.LegacyValue())
if ok && connectedUser != nil {
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connection, nil)
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connectedUser.Connection, nil)
requestPacket.SetType(constants.DataPacket)
requestPacket.AddFlag(constants.PacketFlagNeedsAck)
requestPacket.AddFlag(constants.PacketFlagReliable)
requestPacket.SetSourceVirtualPortStreamType(connection.StreamType)
requestPacket.SetSourceVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetSourceVirtualPortStreamID(globals.SecureEndpoint.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connection.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connectedUser.Connection.StreamID)
requestPacket.SetPayload(notificationRequestBytes)
globals.SecureServer.Send(requestPacket)

8
notifications/3ds/send_favorite_update.go
View File

@ -46,15 +46,15 @@ func SendFavoriteUpdate(connection *nex.PRUDPConnection, gameKey *friends_3ds_ty
connectedUser, ok := globals.ConnectedUsers.Get(friend.PID.LegacyValue())
if ok && connectedUser != nil {
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connection, nil)
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connectedUser.Connection, nil)
requestPacket.SetType(constants.DataPacket)
requestPacket.AddFlag(constants.PacketFlagNeedsAck)
requestPacket.AddFlag(constants.PacketFlagReliable)
requestPacket.SetSourceVirtualPortStreamType(connection.StreamType)
requestPacket.SetSourceVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetSourceVirtualPortStreamID(globals.SecureEndpoint.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connection.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connectedUser.Connection.StreamID)
requestPacket.SetPayload(notificationRequestBytes)
globals.SecureServer.Send(requestPacket)

8
notifications/3ds/send_mii_notification.go
View File

@ -48,15 +48,15 @@ func SendMiiUpdateNotification(connection *nex.PRUDPConnection) {
connectedUser, ok := globals.ConnectedUsers.Get(friend.PID.LegacyValue())
if ok && connectedUser != nil {
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connection, nil)
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connectedUser.Connection, nil)
requestPacket.SetType(constants.DataPacket)
requestPacket.AddFlag(constants.PacketFlagNeedsAck)
requestPacket.AddFlag(constants.PacketFlagReliable)
requestPacket.SetSourceVirtualPortStreamType(connection.StreamType)
requestPacket.SetSourceVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetSourceVirtualPortStreamID(globals.SecureEndpoint.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connection.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connectedUser.Connection.StreamID)
requestPacket.SetPayload(notificationRequestBytes)
globals.SecureServer.Send(requestPacket)

8
notifications/3ds/send_presence_update.go
View File

@ -46,15 +46,15 @@ func SendPresenceUpdate(connection *nex.PRUDPConnection, presence *friends_3ds_t
connectedUser, ok := globals.ConnectedUsers.Get(friend.PID.LegacyValue())
if ok && connectedUser != nil {
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connection, nil)
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connectedUser.Connection, nil)
requestPacket.SetType(constants.DataPacket)
requestPacket.AddFlag(constants.PacketFlagNeedsAck)
requestPacket.AddFlag(constants.PacketFlagReliable)
requestPacket.SetSourceVirtualPortStreamType(connection.StreamType)
requestPacket.SetSourceVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetSourceVirtualPortStreamID(globals.SecureEndpoint.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connection.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connectedUser.Connection.StreamID)
requestPacket.SetPayload(notificationRequestBytes)
globals.SecureServer.Send(requestPacket)

8
notifications/3ds/send_user_went_offline.go
View File

@ -55,15 +55,15 @@ func SendUserWentOffline(connection *nex.PRUDPConnection, pid *types.PID) {
connectedUser, ok := globals.ConnectedUsers.Get(pid.LegacyValue())
if ok && connectedUser != nil {
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connection, nil)
requestPacket, _ := nex.NewPRUDPPacketV0(globals.SecureEndpoint.Server, connectedUser.Connection, nil)
requestPacket.SetType(constants.DataPacket)
requestPacket.AddFlag(constants.PacketFlagNeedsAck)
requestPacket.AddFlag(constants.PacketFlagReliable)
requestPacket.SetSourceVirtualPortStreamType(connection.StreamType)
requestPacket.SetSourceVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetSourceVirtualPortStreamID(globals.SecureEndpoint.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connection.StreamID)
requestPacket.SetDestinationVirtualPortStreamType(connectedUser.Connection.StreamType)
requestPacket.SetDestinationVirtualPortStreamID(connectedUser.Connection.StreamID)
requestPacket.SetPayload(notificationRequestBytes)
globals.SecureServer.Send(requestPacket)