/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

use push::{BridgeType, PushConfiguration, PushManager};

/** Perform a "Live" test against a locally configured push server
 *
 * See https://autopush.readthedocs.io/en/latest/testing.html on
 * setting up a local push server. This will also create a local
 * test database under "/tmp". This database should be deleted before
 * you re-run this test.
 *
 */
fn test_live_server() {
    let tempdir = tempfile::tempdir().unwrap();
    viaduct_hyper::viaduct_init_backend_hyper().expect("Error initializing viaduct");

    let push_config = PushConfiguration {
        server_host: "localhost:8082".to_string(),

        http_protocol: push::PushHttpProtocol::Http,
        bridge_type: BridgeType::Fcm,
        sender_id: "".to_string(),
        database_path: tempdir.path().join("test.db").to_string_lossy().to_string(),
        verify_connection_rate_limiter: Some(0),
    };

    let pm = PushManager::new(push_config).unwrap();
    let scope1 = "scope1";
    let scope2 = "scope2";

    pm.update("new-token").unwrap();

    println!("Scopes: [{}, {}]", scope1, scope2);

    println!("\n == Subscribing channels");
    let sub1 = pm.subscribe(scope1, &None).expect("subscribe failed");

    println!("## Subscription 1: {:?}", sub1);
    println!("## Info: {:?}", pm.get_subscription(scope1));
    let sub2 = pm.subscribe(scope2, &None).unwrap();
    println!("## Subscription 2: {:?}", sub2);

    println!("\n == Unsubscribing single channel");
    pm.unsubscribe(scope1).expect("chid unsub failed");

    // the list of known channels should come from whatever is
    // holding the index of channels to recipient applications.
    println!("Verify: {:?}", pm.verify_connection(true).unwrap());

    // Unsubscribe all channels.
    pm.unsubscribe_all().unwrap();

    println!("Done");
}

fn main() {
    test_live_server()
}