systemd 0.1.0

#[macro_use]
extern crate systemd;
#[macro_use]
extern crate log;

use std::path::Path;
use systemd::journal;

// Some systems don't have a running journal, which causes our tests to fail currently
//
// TODO: adjust tests that use this to generate a fixed journal if possible, or ship some test
// data.
fn have_journal() -> bool {
    if !Path::new("/run/systemd/journal/").exists() {
        println!("missing journal files");
        false
    } else {
        true
    }
}

#[test]
fn test() {
    journal::send(&["CODE_FILE=HI", "CODE_LINE=1213", "CODE_FUNCTION=LIES"]);
    journal::print(1, &format!("Rust can talk to the journal: {}", 4));

    journal::JournalLog::init().ok().unwrap();
    log!(log::LogLevel::Info, "HI");
    sd_journal_log!(4, "HI {:?}", 2);
}

#[test]
fn cursor() {
    if ! have_journal() {
        return;
    }

    let mut j = journal::Journal::open(journal::JournalFiles::All, false, false).unwrap();
    log!(log::LogLevel::Info, "rust-systemd test_seek entry");
    assert!(j.seek(journal::JournalSeek::Head).is_ok());
    let _s = j.cursor().unwrap();
}

#[test]
fn ts() {
    if ! have_journal() {
        return;
    }

    let mut j = journal::Journal::open(journal::JournalFiles::All, false, false).unwrap();
    log!(log::LogLevel::Info, "rust-systemd test_seek entry");
    assert!(j.seek(journal::JournalSeek::Head).is_ok());
    let _s = j.timestamp().unwrap();
}


#[test]
fn test_seek() {
    let mut j = journal::Journal::open(journal::JournalFiles::All, false, false).unwrap();
    if ! have_journal() {
        return;
    }
    log!(log::LogLevel::Info, "rust-systemd test_seek entry");
    assert!(j.seek(journal::JournalSeek::Head).is_ok());
    assert!(j.next_record().is_ok());
    let c1 = j.seek(journal::JournalSeek::Current);
    assert!(c1.is_ok());
    let c2 = j.seek(journal::JournalSeek::Current);
    assert!(c2.is_ok());
    assert_eq!(c1.unwrap(), c2.unwrap());
    assert!(j.seek(journal::JournalSeek::Tail).is_ok());
    assert!(j.next_record().is_ok());
    let c3 = j.cursor().unwrap();
    let valid_cursor = journal::JournalSeek::Cursor { cursor: c3 };
    assert!(j.seek(valid_cursor).is_ok());
    let invalid_cursor = journal::JournalSeek::Cursor { cursor: "".to_string() };
    assert!(j.seek(invalid_cursor).is_err());
}

#[test]
fn test_simple_match() {
    if ! have_journal() {
        return;
    }
    let key = "RUST_TEST_MARKER";
    let value = "RUST_SYSTEMD_SIMPLE_MATCH";
    let msg = "MESSAGE=rust-systemd test_match";
    let filter = format!("{}={}", key, value);
    let mut j = journal::Journal::open(journal::JournalFiles::All, false, false).unwrap();

    // check for positive matches
    assert!(j.seek(journal::JournalSeek::Tail).is_ok());
    journal::send(&[&filter, &msg]);
    assert!(j.match_flush().unwrap().match_add(key, value).is_ok());
    let r = j.next_record().unwrap();
    assert!(r.is_some());
    let entry = r.unwrap();
    let entryval = entry.get(key);
    assert!(entryval.is_some());
    assert_eq!(entryval.unwrap(), value);

    // check for negative matches
    assert!(j.seek(journal::JournalSeek::Tail).is_ok());
    assert!(j.match_flush().unwrap().match_add("NOKEY", "NOVALUE").is_ok());
    journal::send(&[&msg]);
    assert!(j.next_record().unwrap().is_none());
}