wemo 0.0.12

A library for interacting with Belkin WeMo home automation devices.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72

// Copyright (c) 2016 Brandon Thomas <bt@brand.io, echelon@gmail.com>
// This script is sort of a joke, and toggles the state of all devices found.

extern crate time;
extern crate wemo;

use std::env;
use std::thread;
use time::Duration;
use wemo::DeviceSearch;
use wemo::Switch;

#[derive(Clone, Copy)]
enum Command { On, Off, Toggle }

pub fn main() {
  let command = match get_command() {
    Some(command) => command,
    None => {
      println!("Must supply a command: on, off, toggle");
      return;
    }
  };

  let mut search = DeviceSearch::new();
  let results = search.search(1_000);

  let mut join_handles = Vec::new();

  for device in results.values() {
    let device = Switch::from_dynamic_ip_and_port(device.ip_address,
        device.port);

    let join_handle = thread::spawn(move || {
      let timeout = Duration::seconds(5);
      match command {
        Command::On => {
          println!("Turning on device: {}", device.name());
          let _r = device.turn_on_with_retry(timeout);
        },
        Command::Off => {
          println!("Turning off device: {}", device.name());
          let _r = device.turn_off_with_retry(timeout);
        },
        Command::Toggle => {
          println!("Toggling state of device: {}", device.name());
          let _r = device.toggle_with_retry(timeout);
        },
      }
    });

    join_handles.push(join_handle);
  }

  for join_handle in join_handles {
    let _r = join_handle.join();
  }
}

fn get_command() -> Option<Command> {
  match env::args().nth(1) {
    None => None,
    Some(cmd) => {
      match cmd.as_ref() {
        "on" => Some(Command::On),
        "off" => Some(Command::Off),
        "toggle" => Some(Command::Toggle),
        _ => None,
      }
    },
  }
}