// Copyright 2015, 2016 Parity Technologies (UK) Ltd.
// This file is part of Parity.

// Parity 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.

// Parity 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 Parity.  If not, see <http://www.gnu.org/licenses/>.

use ethcore::log_entry::{LocalizedLogEntry, LogEntry};
use v1::types::{Bytes, H160, H256, U256};

/// Log
#[derive(Debug, Serialize, PartialEq, Eq, Hash, Clone)]
pub struct Log {
	/// H160
	pub address: H160,
	/// Topics
	pub topics: Vec<H256>,
	/// Data
	pub data: Bytes,
	/// Block Hash
	#[serde(rename="blockHash")]
	pub block_hash: Option<H256>,
	/// Block Number
	#[serde(rename="blockNumber")]
	pub block_number: Option<U256>,
	/// Transaction Hash
	#[serde(rename="transactionHash")]
	pub transaction_hash: Option<H256>,
	/// Transaction Index
	#[serde(rename="transactionIndex")]
	pub transaction_index: Option<U256>,
	/// Log Index
	#[serde(rename="logIndex")]
	pub log_index: Option<U256>,
	/// Log Type
	#[serde(rename="type")]
	pub log_type: String,
}

impl From<LocalizedLogEntry> for Log {
	fn from(e: LocalizedLogEntry) -> Log {
		Log {
			address: e.entry.address.into(),
			topics: e.entry.topics.into_iter().map(Into::into).collect(),
			data: e.entry.data.into(),
			block_hash: Some(e.block_hash.into()),
			block_number: Some(e.block_number.into()),
			transaction_hash: Some(e.transaction_hash.into()),
			transaction_index: Some(e.transaction_index.into()),
			log_index: Some(e.log_index.into()),
			log_type: "mined".to_owned(),
		}
	}
}

impl From<LogEntry> for Log {
	fn from(e: LogEntry) -> Log {
		Log {
			address: e.address.into(),
			topics: e.topics.into_iter().map(Into::into).collect(),
			data: e.data.into(),
			block_hash: None,
			block_number: None,
			transaction_hash: None,
			transaction_index: None,
			log_index: None,
			log_type: "pending".to_owned(),
		}
	}
}

#[cfg(test)]
mod tests {
	use serde_json;
	use std::str::FromStr;
	use v1::types::{Log, H160, H256, U256};

	#[test]
	fn log_serialization() {
		let s = r#"{"address":"0x33990122638b9132ca29c723bdf037f1a891a70c","topics":["0xa6697e974e6a320f454390be03f74955e8978f1a6971ea6730542e37b66179bc","0x4861736852656700000000000000000000000000000000000000000000000000"],"data":"0x","blockHash":"0xed76641c68a1c641aee09a94b3b471f4dc0316efe5ac19cf488e2674cf8d05b5","blockNumber":"0x4510c","transactionHash":"0x0000000000000000000000000000000000000000000000000000000000000000","transactionIndex":"0x0","logIndex":"0x1","type":"mined"}"#;

		let log = Log {
			address: H160::from_str("33990122638b9132ca29c723bdf037f1a891a70c").unwrap(),
			topics: vec![
				H256::from_str("a6697e974e6a320f454390be03f74955e8978f1a6971ea6730542e37b66179bc").unwrap(),
				H256::from_str("4861736852656700000000000000000000000000000000000000000000000000").unwrap(),
			],
			data: vec![].into(),
			block_hash: Some(H256::from_str("ed76641c68a1c641aee09a94b3b471f4dc0316efe5ac19cf488e2674cf8d05b5").unwrap()),
			block_number: Some(U256::from(0x4510c)),
			transaction_hash: Some(H256::default()),
			transaction_index: Some(U256::default()),
			log_index: Some(U256::from(1)),
			log_type: "mined".to_owned(),
		};

		let serialized = serde_json::to_string(&log).unwrap();
		assert_eq!(serialized, s);
	}
}