Function insert_relationships

server/db.js:164–226

* insert_relationship saves the list of people who related to another record. * @param {object} data - a valid JSON object containing data to be inserted. * @param {function} callback - callback function to be executed on success.

(data, callback)

 * @param {function} callback - callback function to be executed on success.
 */
function insert_relationships (data, callback) {
  let fields, rel_id, url, username;
  const len = data.entries.length - 1;

  function insert_rows () { // inner function has access to outer variables
    data.entries.forEach((p, i) => { // poor person's "async parallel":
      const username = p.username;
      // console.log('username:', username);
      select_person(username, function(error1, result1) {
        // console.log('L251 > result1: ', result1.rows[0]);
        const person_id = result1.rows[0].id;
        const query = `INSERT INTO relationships (${fields}) VALUES ($1, $2)`
        const values = [person_id, rel_id];
        // console.log('query:', query, 'values:', values);
        PG_CLIENT.query(query, values, function(error2, result2) {
          utils.log_error(error2, result2, new Error().stack);

          if(i === len) {
            return insert_next_page(data, callback);
          }
        });
      });
    }); // END data.entries.forEach
  }
  // there are three types of relationships, we switch based on data.type
  switch (data.type) {
    case 'stars':
      fields = 'person_id, repo_id';
      select_repo(data.url, function (error, result) {
        rel_id = result.rows[0].id;
        insert_rows();
      }); // END select_repo
      break;
    case 'people': // this is a list of members of an organisation
      fields = 'person_id, org_id';
      url =  '/' + data.url.split('/')[2];// /orgs/dwyl/people > /dwyl
      select_org(url, function (error, result) {
        rel_id = result.rows[0].id;
        insert_rows();
      }); // END select_org
      break;
    case 'followers': // this is a list of followers/following
      fields = 'person_id, leader_id';
      username =  data.url.split('/')[1]; // /dwylbot/followers > dwylbot
      // console.log('username', username);
      // list of followers:
      select_person(username, function (error, result) {
        rel_id = result.rows[0].id;
        insert_rows();
      }); // END select_org
      break;
    case 'following': // pay attention to the subtle difference in fields order
      fields = 'leader_id, person_id';
      username =  data.url.split('/')[1]; // /dwylbot/following > dwylbot
      // console.log('username', username);
      // list of followers:
      select_person(username, function (error, result) {
        rel_id = result.rows[0].id;