fix(cluster) : moved error port number on migration finish (#4776)

Signed-off-by: adi_holden <[email protected]>

Author: adiholden

src/server/cluster/cluster_config.cc

@@ -327,15 +327,18 @@ bool ClusterConfig::IsMySlot(std::string_view key) const {
 
 ClusterNodeInfo ClusterConfig::GetMasterNodeForSlot(SlotId id) const {
   CHECK_LE(id, kMaxSlotNum) << "Requesting a non-existing slot id " << id;
-
   for (const auto& shard : config_) {
     if (shard.slot_ranges.Contains(id)) {
       if (shard.master.id == my_id_) {
         // The only reason why this function call and shard.master == my_id_ is the slot was
         // migrated
         for (const auto& m : shard.migrations) {
           if (m.slot_ranges.Contains(id)) {
-            return m.node_info;
+            for (const auto& shard : config_) {
+              if (shard.master.id == m.node_info.id) {
+                return shard.master;
+              }
+            }
           }
         }
       }

tests/dragonfly/cluster_test.py

@@ -2702,6 +2702,10 @@ async def test_migration_timeout_on_sync(df_factory: DflyInstanceFactory, df_see
     await wait_for_status(nodes[0].admin_client, nodes[1].id, "FINISHED", 300)
     await wait_for_status(nodes[1].admin_client, nodes[0].id, "FINISHED")
 
+    with pytest.raises(aioredis.ResponseError) as e_info:
+        await nodes[0].client.get("x")
+    assert f"MOVED 16287 127.0.0.1:{instances[1].port}" == str(e_info.value)
+
     nodes[0].migrations = []
     nodes[0].slots = []
     nodes[1].slots = [(0, 16383)]