// Smoldot
// Copyright (C) 2023  Pierre Krieger
// SPDX-License-Identifier: GPL-3.0-or-later WITH Classpath-exception-2.0

// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.

// You should have received a copy of the GNU General Public License
// along with this program.  If not, see <http://www.gnu.org/licenses/>.

use smoldot::json_rpc;
use std::sync::Arc;

#[test]
#[ignore] // TODO: restore after https://github.com/smol-dot/smoldot/issues/1109
fn basic_block_generated() {
    smol::block_on(async move {
        let client = smoldot_full_node::start(smoldot_full_node::Config {
            chain: smoldot_full_node::ChainConfig {
                chain_spec: (&include_bytes!("./substrate-node-template.json")[..]).into(),
                additional_bootnodes: Vec::new(),
                keystore_memory: vec![smoldot::identity::seed_phrase::decode_sr25519_private_key(
                    "//Alice",
                )
                .unwrap()],
                sqlite_database_path: None,
                sqlite_cache_size: 256 * 1024 * 1024,
                keystore_path: None,
                json_rpc_listen: None,
            },
            relay_chain: None,
            libp2p_key: Box::new([0; 32]),
            listen_addresses: Vec::new(),
            tasks_executor: Arc::new(|task| smol::spawn(task).detach()),
            log_callback: Arc::new(move |_, _| {}),
            jaeger_agent: None,
        })
        .await
        .unwrap();

        loop {
            client.send_json_rpc_request(
                r#"{"jsonrpc":"2.0","id":1,"method":"chainHead_v1_follow","params":[false]}"#
                    .to_owned(),
            );

            let _ = json_rpc::parse::parse_response(&client.next_json_rpc_response().await)
                .unwrap()
                .into_success()
                .unwrap();

            loop {
                match json_rpc::methods::parse_notification(&client.next_json_rpc_response().await)
                    .unwrap()
                {
                    json_rpc::methods::ServerToClient::chainHead_v1_followEvent {
                        result: json_rpc::methods::FollowEvent::NewBlock { .. },
                        ..
                    } => return, // Test success
                    json_rpc::methods::ServerToClient::chainHead_v1_followEvent {
                        result: json_rpc::methods::FollowEvent::Stop { .. },
                        ..
                    } => break,
                    _ => {}
                }
            }
        }
    });
}