ssb-chess/ssb_ctrl/ssb_chat_ctrl.js

module.exports = (sbot, nameCache) => {

    const chatMessageType = config.chatMessageType;

    function messagesSource(gameId, previousChatId, isPublic) {
        var linksFromRootMessage = sbot.backlinks.read({
          query: [{
            $filter: {
              dest: gameId
            }
          }],
          index: 'DTA', // use asserted timestamps
          live: true
        });
    
        var typeFilter = pull.filter(msg => {
          return !msg.sync && msg.value.content.type === chatMessageType
        });
    
        var privateOnlyFilter = pull.filter(msg =>
          isPublic || participants.indexOf(msg.value.author) !== -1
        )
    
        var previousChatMessages = !previousChatId ? pull.empty() : sbot.backlinks.read({
          query: [{
            $filter: {
              dest: previousChatId
            }
          }],
          index: 'DTA', // use asserted timestamps
        })
    
        var oldChatStream = pull(previousChatMessages, pull(typeFilter, privateOnlyFilter), pull.map(msg => {
          msg.isOld = true;
          return msg;
        }))
    
    
        var newChatStream = pull(linksFromRootMessage, pull(typeFilter, privateOnlyFilter));
    
        return pullCat([oldChatStream, newChatStream]);
      }

      function getNameAndChatMessage(msg, cb) {
        const message = msg.value.content[chatMessageField];
        const authorId = msg.value.author;
    
        nameCache.getDisplayName(authorId, (err, res) => cb(null, {
          displayName: res,
          message,
          isOld: msg.isOld
        }));
      }

      function getChatMessages(gameId, previousChatId, isPublic) {
          return pull(
            messagesSource(gameId, previousChatId, isPublic),
            aborter,
            pull.asyncMap(getNameAndChatMessage)
          )
      }


      return { 
          getChatMessages
      }
}