embedded_redis_client 0.1.0

Automatically runs a local redis-server instance
Documentation 
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

use std::process::Command;

// only works on Linux
fn kill_process_occupying_target_tcp_port(port: u16) {
    let target_port = format!("TCP:{}", port);

    // kill other processes using the same port "kill $(sudo lsof -t -i:6379)"
    let process_using_target_port = Command::new("lsof")
        .args(&["-t", "-i", &target_port])
        .output()
        .expect("Failed to identify other processes using target TCP port");
    if cfg!(debug_assertions) {
        println!("Process using target port {:?}", process_using_target_port);
    }

    let mut process_using_target_port =
        String::from_utf8(process_using_target_port.stdout).unwrap();
    trim_newline(&mut process_using_target_port);
    if cfg!(debug_assertions) {
        println!("Kill arg {:?}", process_using_target_port);
    }

    let output = Command::new("kill")
        .arg(process_using_target_port)
        .output()
        .expect("Failed to terminate other processes using target TCP port");
    if cfg!(debug_assertions) {
        println!("Killed process using target TCP port: {:?}", output);
    }
}

pub fn get_processes_using_target_port(port: u16) -> Vec<u16> {
    let target_port = format!("TCP:{}", port);

    // kill other processes using the same port "kill $(sudo lsof -t -i:6379)"
    let process_using_target_port = Command::new("lsof")
        .args(&["-t", "-i", &target_port])
        .output()
        .expect(format!("Failed to determine if local port {} is in use.", port).as_str());
    if cfg!(debug_assertions) {
        println!("Process using target port {:?}", process_using_target_port);
    }
    let process_using_target_port = String::from_utf8(process_using_target_port.stdout).unwrap();

    let process_using_target_port: Vec<u16> = process_using_target_port
        .split_whitespace()
        .map(|s| {
            s.parse()
                .expect(format!("Unable to parse {} into a u16", s).as_str())
        })
        .collect();
    return process_using_target_port;
}

fn trim_newline(s: &mut String) {
    if s.ends_with('\n') {
        s.pop();
        if s.ends_with('\r') {
            s.pop();
        }
    }
}