Bugfix #46

- Fixed a bug causing the allserver rank to not be prioritized

Author: ApertureDevelopment

lua/msync/server/modules/sv_mrsync.lua

@@ -36,6 +36,7 @@ function MSync.modules.MRSync.init( transaction )
     ]] ))
 
     --[[
+        OBSOLETE
         Description: Function to save a players rank
         Returns: nothing
     ]]
@@ -93,20 +94,61 @@ function MSync.modules.MRSync.init( transaction )
         addUserRankQ:start()
     end
 
+    --[[
+        Description: Function to validate user rank in DB is correct
+        Arguments:
+            - steamid [STRING] - the steamid of the user to validate
+            - group [STRING] - the group of the user to validate
+    ]]
+    function MSync.modules.MRSync.validateData( steamid, group )
+
+        if MSync.modules.MRSync.settings.nosync[group] then return end;
+
+        local removeOldRanksQ
+
+        if not MSync.modules.MRSync.settings.syncall[group] then
+
+            removeOldRanksQ = MSync.DBServer:prepare( [[
+                DELETE FROM `tbl_mrsync` WHERE user_id=(SELECT p_user_id FROM tbl_users WHERE steamid=? AND steamid64=?) AND server_group=(SELECT p_group_id FROM tbl_server_grp WHERE group_name='allservers');
+            ]] )
+            removeOldRanksQ:setString(1, steamid)
+            removeOldRanksQ:setString(2, util.SteamIDTo64(steamid))
+
+            removeOldRanksQ.onSuccess = function( q, data )
+                MSync.modules.MRSync.saveRankByID(steamid, group)
+            end
+        else
+
+            removeOldRanksQ = MSync.DBServer:prepare( [[
+                DELETE FROM `tbl_mrsync` WHERE user_id=(SELECT p_user_id FROM tbl_users WHERE steamid=? AND steamid64=?);
+            ]] )
+            removeOldRanksQ:setString(1, steamid)
+            removeOldRanksQ:setString(2, util.SteamIDTo64(steamid))
+
+            removeOldRanksQ.onSuccess = function( q, data )
+                MSync.modules.MRSync.saveRankByID(steamid, group)
+            end
+        end
+
+        removeOldRanksQ:start()
+    end
+
     --[[
         Description: Function to load a players rank
         Returns: nothing
     ]]
     function MSync.modules.MRSync.loadRank(ply)
         local loadUserQ = MSync.DBServer:prepare( [[
-            SELECT rank FROM `tbl_mrsync` 
+            SELECT `rank` FROM `tbl_mrsync` 
             WHERE user_id=(
                 SELECT p_user_id FROM tbl_users WHERE steamid=? AND steamid64=?
             ) AND (server_group=(
                 SELECT p_group_id FROM tbl_server_grp WHERE group_name=?
             ) OR server_group=(
                 SELECT p_group_id FROM tbl_server_grp WHERE group_name='allservers'
-            ));
+            ))
+            ORDER BY server_group ASC
+            LIMIT 1;
         ]] )
         loadUserQ:setString(1, ply:SteamID())
         loadUserQ:setString(2, ply:SteamID64())
@@ -226,12 +268,14 @@ function MSync.modules.MRSync.hooks()
 
     -- Save rank on disconnect
     hook.Add("PlayerDisconnected", "mrsync.H.saveRank", function(ply)
-        MSync.modules.MRSync.saveRank(ply)
+        --MSync.modules.MRSync.saveRank(ply)
+        MSync.modules.MRSync.validateData(ply:SteamID(), ply:GetUserGroup())
     end)
 
     -- Save rank on GroupChange
     hook.Add("ULibUserGroupChange", "mrsync.H.saveRankOnUpdate", function(sid, _, _, new_group, _)
-        MSync.modules.MRSync.saveRankByID(sid, new_group)
+        --MSync.modules.MRSync.saveRankByID(sid, new_group)
+        MSync.modules.MRSync.validateData(sid, new_group)
     end)
 end