apitech
/
Rocket.Chat
mirror of https://github.com/RocketChat/Rocket.Chat
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
The communications platform that puts data protection first.
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
5487 Commits
705 Branches
1182 Tags
2.0 GiB
 
 
 
 
 
Tag: Branch: Tree: 5bcc8cb4fc
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from '5bcc8cb4fc'
${ noResults }
Rocket.Chat/server/stream/messages.coffee

50 lines
1.1 KiB
Raw Blame History

# COMPATIBILITY
oldMsgStream = new Meteor.Stream 'messages'
oldMsgStream.permissions.write (eventName) ->
return false
oldMsgStream.permissions.read (eventName) ->
try
canAccess = Meteor.call 'canAccessRoom', eventName, this.userId
return false if not canAccess
return true
catch e
return false
# COMPATIBILITY
@msgStream = new Meteor.Streamer 'room-messages'
msgStream.allowWrite('none')
msgStream.allowRead (eventName) ->
# console.log('stream.permissions.read', this.userId, eventName);
# return this.userId == eventName;
try
canAccess = Meteor.call 'canAccessRoom', eventName, this.userId
return false if not canAccess
return true
catch e
return false
Meteor.startup ->
options = {}
if not RocketChat.settings.get 'Message_ShowEditedStatus'
options.fields = { 'editedAt': 0 }
RocketChat.models.Messages.findVisibleCreatedOrEditedAfterTimestamp(new Date(), options).observe
added: (record) ->
oldMsgStream.emit record.rid, record
msgStream.emitWithoutBroadcast record.rid, record
changed: (record) ->
oldMsgStream.emit record.rid, record
msgStream.emitWithoutBroadcast record.rid, record