// Copyright 2019-2021 Parity Technologies (UK) Ltd.
// This file is part of subxt.
//
// subxt 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.
//
// subxt 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 subxt.  If not, see <http://www.gnu.org/licenses/>.

use crate::{
    DatabaseSource,
    KeystoreConfig,
    Role,
    SubxtClient,
    SubxtClientConfig,
    WasmExecutionMethod,
};
use node_cli::service::NewFullBase;
use sp_keyring::AccountKeyring;
use subxt::{
    ClientBuilder,
    PairSigner,
};
use tempdir::TempDir;
use test_runtime::node_runtime::{
    self,
    system,
    DefaultConfig,
};

#[async_std::test]
pub async fn test_embedded_client() {
    let tmp = TempDir::new("subxt-").expect("failed to create tempdir");
    let config = SubxtClientConfig {
        impl_name: "full-client",
        impl_version: "0.0.1",
        author: "",
        copyright_start_year: 2020,
        db: DatabaseSource::RocksDb {
            path: tmp.path().join("db"),
            cache_size: 16,
        },
        keystore: KeystoreConfig::Path {
            path: tmp.path().join("keystore"),
            password: None,
        },
        chain_spec: node_cli::chain_spec::development_config(),
        role: Role::Authority(AccountKeyring::Alice),
        telemetry: None,
        wasm_method: WasmExecutionMethod::Compiled,
        tokio_handle: tokio::runtime::Handle::current(),
    };

    let NewFullBase {
        task_manager,
        rpc_handlers,
        ..
    } = node_cli::service::new_full_base(config.into_service_config(), |_, _| ())
        .unwrap();

    let client = SubxtClient::new(task_manager, rpc_handlers);

    let ext_client = ClientBuilder::new()
        .set_client(client)
        .build::<DefaultConfig>()
        .await
        .unwrap();
    let api: node_runtime::RuntimeApi<DefaultConfig> =
        ext_client.clone().to_runtime_api();

    // verify that we can read storage
    api.storage()
        .system()
        .account(AccountKeyring::Alice.to_account_id().into(), None)
        .await
        .unwrap();

    let alice = PairSigner::<DefaultConfig, _>::new(AccountKeyring::Alice.pair());
    let bob_address = AccountKeyring::Bob.to_account_id().into();

    // verify that we can call dispatchable functions
    let success = api
        .tx()
        .balances()
        .transfer(bob_address, 100_000_000_000_000_000)
        .sign_and_submit_then_watch(&alice)
        .await
        .unwrap()
        .wait_for_finalized_success()
        .await
        .unwrap()
        .has_event::<system::events::ExtrinsicSuccess>()
        .unwrap();

    // verify that we receive events
    assert!(success);
}