uni-society-manager/presenters/society-cont...

var Redis = require("ioredis");
var redis = new Redis();
var permissions_controller = require("./permissions-controller.js");
var user_controller = require("./user-controller.js");

module.exports = {
  get_society: function (soc_name, complete) {
    redis.hgetall(("society:" + soc_name).toLowerCase(), function (err, result) {
      if (result.name) {
        result.users = JSON.parse(result.users);
        result.admins = JSON.parse(result.admins);
        result.events = JSON.parse(result.events);
        complete({
          "society": result,
          "error": 0
        })
      } else {
        complete({
          "society": {},
          "error": 1
        })
      }
    });
  },

  create_society: function (soc_name, admins, description, auth, complete) {
    var society_name = decodeURIComponent(soc_name);
    var soc_query = ("society:" + society_name).toLowerCase();
    admins = decodeURIComponent(admins).toLowerCase();
    description = decodeURIComponent(description);
    var admins_str = admins;
    admins = JSON.parse(admins);

    redis.hget(soc_query, "name", function (err, result) {
      if (result) {
        complete({"success": 0,
                 "error": 2});
      } else {
        redis.get("auth-key:" + auth, function (err,result) {
          var username = result;
          var user_query = "user:" + username;
          var users_exist = true;
          if (admins.indexOf(result) !== -1) {
            admins.map(function (admin_name, idx, adm) {
              user_controller.user_exists(admin_name, function (exists) {
                if (!exists) {
                  users_exist = false;
                }
                if (idx === adm.length-1 && users_exist) {
                  redis.hset(soc_query, "name", society_name);
                  redis.hset(soc_query, "admins", admins_str);
                  redis.hset(soc_query, "description", description);
                  redis.hset(soc_query, "users", admins_str);
                  redis.hset(soc_query, "events", JSON.stringify([]));
                  admins.map(function (admin_name) {
                    redis.hget("user:" + admin_name, "societies", function (err, result) {
                      if (result) {
                        result = JSON.parse(result);
                        redis.hset("user:" + admin_name, "societies", JSON.stringify(result.concat(society_name)));
                      } else {
                        redis.hset("user:" + admin_name, "societies", JSON.stringify([society_name]));
                      }
                    });
                  });
                  complete({"success": 1,
                           "society" : {
                             "name": society_name,
                             "admins": admins,
                             "description": description,
                             "users": admins
                           },
                           "error": 0});
                } else if (idx === adm.length-1) {
                  complete({"success": 0,
                           "error": 4});
                }
              });
            });
          } else {
            complete({"success": 0,
                     "error": 3});
          }
        });
      }
    });
  },

  get_user_list: function (soc_name, complete) {
    this.get_society(soc_name, function (result) {
      if (result.society.name) {
        complete(result.society.users);
      } else {
        complete([]);
      }
    });
  },

  get_admin_list: function (soc_name, complete) {
    this.get_society(soc_name, function (result) {
      if (result.society.name) {
        complete(result.society.admins);
      } else {
        complete([]);
      }
    })
  },

  join_society: function (soc_name, auth, complete) {
    permissions_controller.user_is_in_society(auth, soc_name, function (user_in_soc) {
      if (user_in_soc) {
        complete({
          "success": 0,
          "error": 1
        });
      } else {
        user_controller.get_user_from_auth(auth, function (username) {
          user_query = "user:" + username;
          redis.hget(user_query, "societies", function (err, result) {
            if (result) {
              result = JSON.parse(result);
              redis.hset(user_query, "societies", JSON.stringify(result.concat(soc_name)));
            } else {
              redis.hset(user_query, "societies", JSON.stringify([soc_name]));
            }
          });
          redis.hget(("society:" + soc_name).toLowerCase(), "users", function (err, users_result) {
            users_result = JSON.parse(users_result);
            redis.hset(("society:" + soc_name).toLowerCase(), "users", JSON.stringify(users_result.concat(username)));
          });
        });
        complete({
          "success": 1,
          "error": 0
        });
      }
    });
  },

  get_all_societies: function (complete) {
    var self = this;
    var stream = redis.scanStream({
      match: "society:*"
    });
    var society_names = [];
    stream.on('data', function (keys) {
      keys.map(function(key) {
        society_names.push(key.split(":")[1]);
      });
    });
    stream.on('end', function () {
      var soc_objects = [];
      if (society_names.length === 0) {
        complete({
          "societies": []
        });
        return;
      }
      for (var ii = 0; ii < society_names.length; ii++) {
        self.get_society(society_names[ii], function(response) {
          soc_objects.push(response.society);
          if (soc_objects.length === society_names.length) {
            soc_objects.sort(function(a, b) {
              var textA = a.name.toLowerCase();
              var textB = b.name.toLowerCase();
              return (textA < textB) ? -1 : (textA > textB) ? 1 : 0;
            });
            complete({
              "societies": soc_objects
            });
          }
        });
      }
    });
  },

  leave_society: function (soc_name, auth, complete) {
    permissions_controller.user_is_in_society(auth, soc_name, function(user_in_soc) {
      if (user_in_soc) {
        soc_name = soc_name.toLowerCase();
        user_controller.get_user_from_auth(auth, function (username) {
          var user_query = "user:" + username;
          var soc_query = "society:" + soc_name.toLowerCase();
          redis.hget(user_query, "societies", function (err, result) {
            if (result) {
              result = JSON.parse(result);
              var idx = result.indexOf(soc_name);
              if (idx > -1) {
                result.splice(idx, 1);
              }
              redis.hset(user_query, "societies", JSON.stringify(result));
            } else {
              console.error("Error could not find society to remove.");
            }
          });
          redis.hget(soc_query, "users", function (err, result) {
            if (result) {
              result = JSON.parse(result);
              var idx = result.indexOf(username);
              if (idx > -1) {
                result.splice(idx, 1);
              }
              redis.hset(soc_query, "users", JSON.stringify(result));
            } else {
              console.error("Error could not find society user list.");
            }
          });
          permissions_controller.user_can_manage_society(auth, soc_name, function (isadmin) {
            if (isadmin) {
              redis.hget(soc_query, "admins", function (err, result) {
                if (result) {
                  result = JSON.parse(result);
                  var idx = result.indexOf(username);
                  if (idx > -1) {
                    result.splice(idx, 1);
                  }
                  redis.hset(soc_query, "admins", JSON.stringify(result));
                } else {
                  console.error("Error could not find society admin list.");
                }
              });
            }
          });
          complete({
            "success": 1,
            "error": 0
          });
        });
      } else {
        complete({
          "success": 0,
          "error": 1
        });
      }
    });
  },

  promote_user: function (promotee, soc_name, auth, complete) {
    var self = this;
    permissions_controller.user_can_manage_society(auth, soc_name, function (isadmin) {
      if (isadmin) {
        self.get_user_list(soc_name, function (userlist) {
          if (userlist.indexOf(promotee) !== -1) {
            redis.hget("society:" + soc_name.toLowerCase(), "admins", function (err, result) {
              if (result) {
                result = JSON.parse(result);
                if (result.indexOf(promotee) > -1) {
                  complete({
                    "success": 0,
                    "error": 3
                  });
                } else {
                redis.hset("society:" + soc_name.toLowerCase(), "admins", JSON.stringify(result.concat(promotee)));
                complete({
                  "success": 1,
                  "error": 0
                });
              }
              }else {
                console.error("Error could not find admin list in society.");
              }
            });
          } else {
            complete({
              "success": 0,
              "error": 2
            })
          }
        });
      } else {
        complete({
          "success": 0,
          "error": 1
        })
      }
    });
  }
}