1
import asyncio
2
import sys
3
from kasa import Discover, KasaException
4

5
# --- CONFIGURATION ---
6
# Your TP-Link / Tapo Cloud credentials
7
# REQUIRED: Modern firmware rejects local control without cloud auth
8
TAPO_EMAIL = "[email protected]"
9
TAPO_PASSWORD = "your_cloud_password"
10

11
# The DESTINATION Network (Where you want devices to go)
12
NEW_SSID = "Roze_IoT"
13
NEW_PASSWORD = "your_iot_password"
14

15
# Targeted broadcast IP.
16
# If you are on Windows, use the broadcast address of your interface.
17
# Example: 192.168.1.255 for a /24 network.
18
BROADCAST_IP = "192.168.1.255"
19

20
async def main():
21
    print(f"🔍 Scanning subnet {BROADCAST_IP} for ALL Tapo/Kasa devices...")
22

23
    try:
24
        # We pass credentials immediately to ensure we can identify locked devices
25
        found_devices = await Discover.discover(
26
            target=BROADCAST_IP,
27
            discovery_timeout=5,
28
            username=TAPO_EMAIL,
29
            password=TAPO_PASSWORD
30
        )
31
    except Exception as e:
32
        print(f"❌ Error during discovery: {e}")
33
        return
34

35
    if not found_devices:
36
        print("❌ No devices found. Check your firewall or IP configuration.")
37
        return
38

39
    print(f"🔍 Found {len(found_devices)} devices. Starting migration...\n")
40

41
    for ip, dev in found_devices.items():
42
        try:
43
            # Refresh device state
44
            await dev.update()
45

46
            print(f"🤖 Processing: {dev.alias} ({dev.model})")
47
            print(f"   => Sending command to join '{NEW_SSID}'...")
48

49
            try:
50
                # The wifi_join command pushes the new credentials to the device.
51
                await dev.wifi_join(NEW_SSID, NEW_PASSWORD)
52

53
                # If we get here, the device accepted the command.
54
                print(f"   ✅ Command sent! Device should switch networks now.")
55

56
            except Exception as e:
57
                # A disconnect error here is actually a SUCCESS.
58
                # It means the device dropped the current connection to switch to the new one.
59
                print(f"   ✅ Command sent (Device disconnected as expected).")
60

61
        except Exception as e:
62
            print(f"   ❌ Error processing {dev.alias}: {e}")
63

64
        finally:
65
            # Cleanup connection
66
            try:
67
                await dev.disconnect()
68
            except:
69
                pass
70

71
        # Small delay to prevent network congestion
72
        await asyncio.sleep(2)
73

74
    print("\n🏁 Process complete. Check your IoT VLAN for new clients.")
75

76
if __name__ == "__main__":
77
    # Windows-specific fix for asyncio event loops
78
    if sys.platform == "win32":
79
        asyncio.set_event_loop_policy(asyncio.WindowsSelectorEventLoopPolicy())
80
    asyncio.run(main())