ssb-chess/ssb_ctrl/social.js

const pull = require('pull-stream');

module.exports = (sbot, myIdent, chessIndex) => {
  // untested
  function followPlayer(playerPubKey) {
    sbot.publish({
      type: 'contact',
      contact: playerPubKey,
      following: true,
    });
  }

  // untested
  function unfollowPlayer(playerPubKey) {
    sbot.publish({
      type: 'contact',
      contact: playerPubKey,
      following: false,
    });
  }

  function consumeStreamIntoArrayPromise(source, through) {
    return new Promise((resolve, reject) => {
      pull(source, through, pull.collect((err, results) => {
        if (err) {
          reject(err);
        } else {
          resolve(results);
        }
      }));
    });
  }

  function followedByMe() {
    const followsMe = sbot.links({
      source: myIdent,
      rel: 'contact',
      values: true,
      reverse: true,
    });

    const onlyStillFollowingsThrough = pull(
      pull.unique('dest'),
      pull.filter(msg => msg.value.content.following !== false),
    );

    return consumeStreamIntoArrayPromise(followsMe, onlyStillFollowingsThrough)
      .then(results => results.map(a => a.dest));
  }

  function followingMe() {
    const followsMe = sbot.links({
      dest: myIdent,
      rel: 'contact',
      values: true,
      reverse: true,
    });

    const onlyStillFollowingsThrough = pull(
      pull.unique('source'),
      pull.filter(msg => msg.value.content.following !== false),
    );

    return consumeStreamIntoArrayPromise(followsMe, onlyStillFollowingsThrough)
      .then(results => results.map(a => a.source));
  }

  function getPlayerDisplayName(playerPubKey) {
    // TODO: have some way to mark a game as corrupted.
    if (!playerPubKey || !playerPubKey.startsWith('@')) {
      return Promise.resolve('<error>');
    }

    const aboutStream = sbot.links({
      dest: playerPubKey,
      rel: 'about',
      reverse: true,
      values: true,
      source: playerPubKey,
    });

    return new Promise((resolve, reject) => {
      pull(aboutStream, pull.find(msg => msg.value.content.name, (err, result) => {
        if (err) {
          reject(err);
        } else {
          result = (result && result.value.content.name) ? result.value.content.name : playerPubKey;
          resolve(result);
        }
      }));
    });
  }

  function getWeightedPlayFrequencyList() {

    return new Promise( (resolve, reject) => {
      chessIndex.weightedPlayFrequencyList(myIdent, (err, result) => {
        if (err) {
          reject(err);
        } else {
          resolve(result);
        }
      });
      
    });
  }

  return {
    followingMe,
    followedByMe,
    followPlayer,
    unfollowPlayer,
    getPlayerDisplayName,
    getWeightedPlayFrequencyList
  };
};