who-data.js

// Methods and classes to store and modify the data used by the Who page.
// This data is used by the Czar page, too.

var WhoDataDebug = function() {
  if (0 && window.console) window.console.log.apply(window.console, arguments);
}

var Assignment = function(when, active, exclusive) {
  this.when = when == null ? 0 : when;
  this.active = active == null ? false : active;
  this.exclusive = exclusive == null ? true : exclusive;
};

var Duration = function(length) {
  this.length = length == null ? 0 : length;
};

var LastSeenTime = function(user, activity) {
  if (gLastSeenTime[user] && gLastSeenTime[user][activity]) {
    return gLastSeenTime[user][activity].when;
  } else {
    return 0;
  }
};

var LastSeenDurationString = function(user, activity) {
  if (gLastSeenTime[user] && gLastSeenTime[user][activity]) {
    var length = (new Date()).valueOf() - gLastSeenTime[user][activity].when;
    if (gDuration[user] && gDuration[user][activity])
      length += gDuration[user][activity].length;
    if (length < 60000) {
      return Math.floor(length/1000) + 's';
    } else if (length < 3600000) {
      return Math.floor(length/60000) + 'm';
    } else {
      var hrs = Math.floor(length/3600000);
      return hrs + 'h' + Math.floor((length - hrs*3600000)/60000);
    }
  }
  return "(N/A)";
};

var DurationString = function(user, activity) {
  if (gDuration[user] && gDuration[user][activity]) {
    var length = gDuration[user][activity].length;
    if (length < 60000) {
      return Math.floor(length/1000) + 's';
    } else if (length < 3600000) {
      return Math.floor(length/60000) + 'm';
    } else {
      var hrs = Math.floor(length/3600000);
      return hrs + 'h' + Math.floor((length - hrs*3600000)/60000);
    }
  }
  return "(N/A)";
};

var IsExclusiveAssignment = function(user, activity) {
  if (gLastSeenTime[user] && gLastSeenTime[user][activity]) {
    return gLastSeenTime[user][activity].exclusive;
  } else if (gActivities[activity]) {
    return gActivities[activity].exclusive;
  } else {
    return true;
  }
};

var IsActiveAssignment = function(user, activity) {
  if (gLastSeenTime[user] && gLastSeenTime[user][activity]) {
    return gLastSeenTime[user][activity].active;
  } else {
    return false;
  }
};

var GetActivityByName = function(activity_name) {
  for (a in gActivities) {
    if (gActivities[a] && activity_name == gActivities[a].name) {
      return gActivities[a];
    }
  }
  return null;
};

var GetCurrentActivity = function(userid) {
  var aid;
  for (aid in gActivities) {
    if (IsActiveAssignment(userid, aid) && gActivities[aid].name) {
      if (IsExclusiveAssignment(userid,aid)) {
        return aid;
      }
    }
  }
  return null;
};

var HasActiveUsers = function(activity_name) {
  for (u in gUsers) {
    if (IsActiveAssignment(gUsers[u].id, name)) return true;
  }
  return false;
};

// UpdateActivityHack is a hook for anyone who wants to be called when
// an activity or an assignment has changed  UpdateActivityHack is defined in
// the global scope, so, just set it to your own callable and we'll invoke it.
var UpdateActivityHack = null;

// same, but for users.
var UpdatePersonHack = null;

var UpdateAssignment = function(user, activity, when, active, exclusive) {
  if (when == null && active == null && exclusive == null) {
    // Delete this assignment.
    delete gLastSeenTime[user][activity];
    return;
  }

  if (! gLastSeenTime[user]) {
    gLastSeenTime[user] = {};
  }
  if (!gLastSeenTime[user][activity]) {
    // Create new object.
    gLastSeenTime[user][activity] = new Assignment(when, active, exclusive);
  } else {
    // Update existing object.
    if (when != null) gLastSeenTime[user][activity].when = when;
    if (active != null) gLastSeenTime[user][activity].active = active;
    if (exclusive != null) gLastSeenTime[user][activity].exclusive = exclusive;
  }

  if (UpdateActivityHack) {
    UpdateActivityHack(activity);
  }
  if (UpdatePersonHack) {
    UpdatePersonHack(user);
  }
};

var UpdateDuration = function(user, activity, length, isAddition) {
  if (length == null) {
    // Delete this duration node.
    delete gDuration[user][activity];
    return;
  }

  if (! gDuration[user]) {
    gDuration[user] = {};
  }
  if (!gDuration[user][activity]) {
    // Create new object.
    gDuration[user][activity] = new Duration(length);
  } else {
    // Update existing object.
    if (length != null) {
      if (isAddition) {
        gDuration[user][activity].length += length;
      } else {
        gDuration[user][activity].length = length;
      }
    }
  }

  if (UpdateActivityHack) {
    UpdateActivityHack(activity);
  }
  if (UpdatePersonHack) {
    UpdatePersonHack(user);
  }
};

var User = function(id, name) {
  if (id < 0) {
    // Generate a new ID.
    do id = "u" + Math.floor(Math.random() * 10000);
    while (gUsers[id]);
  }
  this.id = id;
  this.name = name;
};

var Activity = function(id, name) {
  if (id < 0) {
    // Generate a new ID.
    do id = "a" + Math.floor(Math.random() * 10000);
    while (gActivities[id]);
  }
  this.id = id;
  this.name = name;
  this.tags = '';
  this.exclusive = true;
};

Activity.prototype.IsNonPuzzleActivity = function() {
  return this.id[0] == 'a';
};

Activity.prototype.IsJobToDisplay = function() {
  for (j in config.jobs_to_display) {
    if (config.jobs_to_display[j] == this.name) {
      return true;
    }
  }
  return false;  
}

var gUsers = {};
var gActivities = {};
// Map from person to {map of activity to Assignment} wherein this person most
// recently worked on this activity at this time.
var gLastSeenTime = {};
// Map from person to {map of activity to Assignment} that tries to store how
// long this person worked on this activity in the past.  Not accurate for the
// person's current activity.
var gDuration = {};


var HandleUpdateFromStateserver = function(key, value) {
  WhoDataDebug("HandleUpdateFromStateserver(" + key + ", " + value + ")");

  // p####.field................ Puzzle.
  // x####.field................ Puzzle (deprecated).
  // u####.field................ Person ("user").  #### is ID, field is name.
  // a####.field................ Activity (excl. puzzle).  #### is ID, field
  //                             is name.
  // t.u####.?####.field........ Assignment.  field is when, exclusive, active.
  //                             ####s are IDs.
  // d.u####.?####.field........ Duration.  field is length, exclusive, active.
  //                             ####s are IDs.

  var dot = key.indexOf(".");
  var id = dot >= 0 ? key.substring(0, dot) : null;
  var field = dot >= 0 ? key.substring(dot+1) : null;

  if (key[0] == 'p' || key[0] == 'x') {
    // Puzzle.
    if (dot >= 0 && field == 'label') {
      if (value) {
        InternalUpdateActivity(id, value);
      } else {
        ForgetActivity(id);
      }
    } else if (dot >= 0 && field == 'tags') {
      UpdateTags(id, value);
    }
    if (UpdateActivityHack) {
      UpdateActivityHack(id);
    }
  } else if (key[0] == 'a') {
    // Activity.
    var dot = key.indexOf(".");
    if (dot >= 0 && key.substring(dot+1) == 'name') {
      if (value) {
        InternalUpdateActivity(key.substring(0, dot), value);
      } else {
        ForgetActivity(key.substring(0, dot));
      }
    }
    if (UpdateActivityHack) {
      UpdateActivityHack(id);
    }
  } else if (key[0] == 'u') {
    // Person.
    var dot = key.indexOf(".");
    if (dot >= 0 && key.substring(dot+1) == 'name') {
      if (value) {
        InternalAddPerson(key.substring(0, dot), value);
      } else {
        ForgetPerson(key.substring(0, dot));
      }
    }
    if (UpdatePersonHack) {
      UpdatePersonHack(id);
    }
  } else if (key[0] == 't') {
    // Assignment.
    var parts = key.match(/t\.([^.]*)\.([^.]*)(\.([^.]*))?/);
    if (parts && parts.length == 5) {
      var uid = parts[1];
      var aid = parts[2];
      var field = parts[4];

      InternalAddPerson(uid, null);
      InternalUpdateActivity(aid, null);

      var when;
      var active;
      var exclusive;

      if (field == null || field == 'when') {
        when = value;
      } else if (field == 'active') {
        active = value;
      } else if (field == 'exclusive') {
        exclusive = value;
      }
      UpdateAssignment(uid, aid, when, active, exclusive);
    }
  } else if (key[0] == 'd') {
    // Duration.
    var parts = key.match(/d\.([^.]*)\.([^.]*)(\.([^.]*))?/);
    if (parts && parts.length == 5) {
      var uid = parts[1];
      var aid = parts[2];
      var field = parts[4];

      InternalAddPerson(uid, null);
      InternalUpdateActivity(aid, null);

      var length;

      if (field == null || field == 'length') {
        length = value;
      }
      UpdateDuration(uid, aid, length, false);
    }
  }
};

var InternalAdd = function(id, name, Type, storage) {
  var o = null;

  // Does it exist identically already?
  if (storage[id]) {
    o = storage[id];
    // Update name.
    if (name) {
      o.name = name;
    }
  } else {
    o = new Type(id, name);
    storage[o.id] = o;
 }

  if (id < 0) {
    // Created a new object; store this data with stateserver.
    gStateServer.set(o.id + '.name', o.name);
  }

  return o;
};

var InternalAddPerson = function(id, name) {
  user = InternalAdd(id, name, User, gUsers);
  if (! gLastSeenTime[user.id]) {
    gLastSeenTime[user.id] = {};
  }
  return user;
};

var InternalUpdateActivity = function(id, name, tags) {
  activity = InternalAdd(id, name, Activity, gActivities);
  if (activity.IsNonPuzzleActivity()) {
    // TODO(corin): We can make all non-puzzle activities non-exclusive
    // by changing this next line.  OTOH that exposes the notion of being
    // non-exclusive to everyone.
    activity.exclusive = true;
  }
  if (tags != null) {
    activity.tags = tags;
  } else if (tags == null && activity.IsNonPuzzleActivity()) {
    activity.tags = 'activity';
  }
  return activity;
};

var ForgetPerson = function(id) {
  delete gUsers[id];
}
var ForgetActivity = function(id) {
  delete gActivities[id];
}

var UpdateTags = function(id, taglist) {
  if (taglist) {
    InternalUpdateActivity(id, null, taglist);
  } else {
    InternalUpdateActivity(id, null, '');
  }

  if (UpdateTagsSelector) {
    UpdateTagsSelector();
  }
};

var UpdateStatus = function(user, activity, when, active, exclusive) {
  // Record that user has worked on activity at the given time.
  WhoDataDebug('UpdateStatus(' +
      [user.id, activity.id, when, active, exclusive].join(', ') + ')');

  // If this assignment is a refresh on the same (exclusive) assignment,
  // add the time to the duration.
  if (active == true && when != null
      && GetCurrentActivity(user.id) == activity.id) {
    UpdateDuration(user.id, activity.id, 
          when - gLastSeenTime[user.id][activity.id].when, true);
    var key = 'd.' + user.id + '.' + activity.id;
    gStateServer.set(key + '.length', gDuration[user.id][activity.id].length);
    
  }

  UpdateAssignment(user.id, activity.id, when, active, exclusive);

  // If this assignment is exclusive of all other exclusive assignments,
  // update those other assignments to be inactive
  if (IsActiveAssignment(user.id, activity.id) &&
      IsExclusiveAssignment(user.id, activity.id)) {
    for (a in gLastSeenTime[user.id]) {
      var otherActivity = gActivities[a];
      if (otherActivity && otherActivity != activity &&
          IsActiveAssignment(user.id, otherActivity.id) &&
          IsExclusiveAssignment(user.id, otherActivity.id)) {
        UpdateStatus(user, otherActivity, null, false, true);
      }
    }
  }

  // If this was an unassignment (probably because a puzzle was 
  // marked solved), add the appropriate time to the Duration.
  // Also do this if this was a setting of active to false with a non-zero time 
  // (because "No longer" was selected on Who).
  if ((when == null || (active == false && when != 0)) 
        && IsExclusiveAssignment(user.id, activity.id)) {
    UpdateDuration(user.id, activity.id, 
          (new Date()).valueOf() - gLastSeenTime[user.id][activity.id].when, true);
    var key = 'd.' + user.id + '.' + activity.id;
    gStateServer.set(key + '.length', gDuration[user.id][activity.id].length);
  }
  // However, if "Never" was selected on Who, then remove the Duration entirely.
  if ((when == 0 && active == false && exclusive == true)) {
    UpdateDuration(user.id, activity.id, 0, false);
    var key = 'd.' + user.id + '.' + activity.id;
    gStateServer.set(key + '.length', null);
  }


  // Update stateserver with this information.
  var key = 't.' + user.id + '.' + activity.id;
  if (when != null) gStateServer.set(key + '.when', when);
  if (active != null) gStateServer.set(key + '.active', Boolean(active));
  if (exclusive != null) gStateServer.set(key + '.exclusive', Boolean(exclusive));
};

var MakeAgoString = function(now, then) {
  var ms_ago = now - then;  // Milliseconds.
  var minutes_ago = parseInt(ms_ago / 1000.0 / 60.0);
  var hours_ago = parseInt(minutes_ago / 60);
  minutes_ago = minutes_ago - (hours_ago * 60);

  var ago = '';
  if (hours_ago > 0) {
    ago += hours_ago;
  }

  ago += ':' + PadWithZeroes(minutes_ago, 2);

  return ago;
};


var PadWithZeroes = function(x, len) {
  var s = String(x);
  if (s.length < len) {
    s = '0' * (len - s.length) + s;
  }

  return s;
};