status-im
/
ethereumj-personal
mirror of https://github.com/status-im/ethereumj-personal.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge after merge

This commit is contained in:
nicksavers 2014-05-29 22:06:14 +02:00
parent af86249019 6b22137c05
commit 1edf4ad278
36 changed files with 783 additions and 384 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
build-post-package.xml
View File

@ -37,6 +37,11 @@
<copy file="./target/classes/system.properties" todir="./target/package/ethereumj/config"/> <copy file="./target/classes/system.properties" todir="./target/package/ethereumj/config"/>
<copy file="./target/classes/GeoLiteCity.dat" todir="./target/package/ethereumj/config"/> <copy file="./target/classes/GeoLiteCity.dat" todir="./target/package/ethereumj/config"/>
<copy todir="./target/package/ethereumj/samples">
<fileset dir="./samples"/>
</copy>
<zip destfile="ethereumj-${DSTAMP}-${TSTAMP}.zip" basedir="./target/package"> <zip destfile="ethereumj-${DSTAMP}-${TSTAMP}.zip" basedir="./target/package">
</zip> </zip>

15
ethereumj-core/src/main/java/org/ethereum/config/SystemProperties.java
View File

@ -97,6 +97,21 @@ public class SystemProperties {
return Boolean.parseBoolean(prop.getProperty("database.reset")); return Boolean.parseBoolean(prop.getProperty("database.reset"));
} }
public String activePeerIP(){
if(prop.isEmpty()) return "54.201.28.117";
return prop.getProperty("peer.active.ip");
}
public int activePeerPort(){
if(prop.isEmpty()) return 30303;
return Integer.parseInt(prop.getProperty("peer.active.port"));
}
public String samplesDir(){
if(prop.isEmpty()) return "samples";
return prop.getProperty("samples.dir");
}
public String toString() { public String toString() {
Enumeration<?> e = prop.propertyNames(); Enumeration<?> e = prop.propertyNames();
while (e.hasMoreElements()) { while (e.hasMoreElements()) {

92
ethereumj-core/src/main/java/org/ethereum/core/AccountState.java Normal file
View File

@ -0,0 +1,92 @@
package org.ethereum.core;
import org.ethereum.crypto.ECKey;
import org.ethereum.crypto.HashUtil;
import org.ethereum.util.RLP;
import org.ethereum.util.Utils;
import java.math.BigInteger;
public class AccountState {
private ECKey ecKey;
private byte[] rlpEncoded;
/* A value equal to the number of transactions sent
* from this address, or, in the case of contract accounts,
* the number of contract-creations made by this account */
private BigInteger nonce;
/* A scalar value equal to the number of Wei owned by this address */
private BigInteger balance;
/* A 256-bit hash of the root node of a trie structure
* that encodes the storage contents of the contract,
* itself a simple mapping between byte arrays of size 32.
* The hash is formally denoted σ[a] s .
*
* Since I typically wish to refer not to the trie’s root hash
* but to the underlying set of key/value pairs stored within,
* I define a convenient equi valence TRIE (σ[a] s ) ≡ σ[a] s .
* It shall be understood that σ[a] s is not a ‘physical’ member
* of the account and does not contribute to its later serialisation */
private byte[] stateRoot = new byte[0];
/* The hash of the EVM code of this contract—this is the code
* that gets executed should this address receive a message call;
* it is immutable and thus, unlike all other fields, cannot be changed
* after construction. All such code fragments are contained in
* the state database under their corresponding hashes for later
* retrieval */
private byte[] codeHash = HashUtil.sha3(new byte[0]);
public AccountState() {
this(new ECKey(Utils.getRandom()));
}
public AccountState(ECKey ecKey) {
this(ecKey, BigInteger.ZERO, BigInteger.ZERO);
}
public AccountState(ECKey ecKey, BigInteger nonce, BigInteger balance) {
this.ecKey = ecKey;
this.nonce = nonce;
this.balance = balance;
}
public AccountState(BigInteger nonce, BigInteger balance) {
this.nonce = nonce;
this.balance = balance;
}
public ECKey getEcKey() {
return ecKey;
}
public BigInteger getNonce() {
return nonce;
}
public void incrementNonce(){
this.nonce = nonce.add(BigInteger.ONE);
}
public BigInteger getBalance() {
return balance;
}
public void addToBalance(BigInteger value){
this.balance = balance.add(value);
}
public byte[] getEncoded() {
if(rlpEncoded == null) {
byte[] nonce = RLP.encodeBigInteger(this.nonce);
byte[] balance = RLP.encodeBigInteger(this.balance);
byte[] stateRoot = RLP.encodeElement(this.stateRoot);
byte[] codeHash = RLP.encodeElement(this.codeHash);
this.rlpEncoded = RLP.encodeList(balance, nonce, stateRoot, codeHash);
}
return rlpEncoded;
}
}

52
ethereumj-core/src/main/java/org/ethereum/core/AddressState.java
View File

@ -1,52 +0,0 @@
package org.ethereum.core;
import org.ethereum.crypto.ECKey;
import org.ethereum.util.Utils;
import java.math.BigInteger;
/**
* www.ethereumJ.com
* User: Roman Mandeleil
* Created on: 21/05/2014 10:43
*/
public class AddressState {
private ECKey ecKey;
private BigInteger nonce;
private BigInteger balance;
public AddressState() {
this(new ECKey(Utils.getRandom()));
}
public AddressState(ECKey ecKey) {
this(ecKey, BigInteger.ZERO, BigInteger.ZERO);
}
public AddressState(ECKey ecKey, BigInteger nonce, BigInteger balance) {
this.ecKey = ecKey;
this.nonce = nonce;
this.balance = balance;
}
public ECKey getEcKey() {
return ecKey;
}
public BigInteger getNonce() {
return nonce;
}
public void incrementNonce(){
this.nonce = nonce.add(BigInteger.ONE);
}
public BigInteger getBalance() {
return balance;
}
public void addToBalance(BigInteger value){
this.balance = balance.add(value);
}
}

33
ethereumj-core/src/main/java/org/ethereum/core/Block.java
View File

@ -1,6 +1,8 @@
package org.ethereum.core; package org.ethereum.core;
import org.ethereum.crypto.HashUtil; import org.ethereum.crypto.HashUtil;
import org.ethereum.db.Config;
import org.ethereum.trie.Trie;
import org.ethereum.util.ByteUtil; import org.ethereum.util.ByteUtil;
import org.ethereum.util.RLP; import org.ethereum.util.RLP;
import org.ethereum.util.RLPElement; import org.ethereum.util.RLPElement;
@ -71,6 +73,7 @@ public class Block {
private List<Transaction> transactionsList = new ArrayList<Transaction>(); private List<Transaction> transactionsList = new ArrayList<Transaction>();
private List<Block> uncleList = new ArrayList<Block>(); private List<Block> uncleList = new ArrayList<Block>();
private Trie state;
public Block(byte[] rawData) { public Block(byte[] rawData) {
this.rlpEncoded = rawData; this.rlpEncoded = rawData;
@ -78,14 +81,15 @@ public class Block {
} }
public Block(byte[] parentHash, byte[] unclesHash, byte[] coinbase, public Block(byte[] parentHash, byte[] unclesHash, byte[] coinbase,
byte[] stateRoot, byte[] txTrieRoot, byte[] difficulty, byte[] txTrieRoot, byte[] difficulty, long number,
long number, long minGasPrice, long gasLimit, long gasUsed, long minGasPrice, long gasLimit, long gasUsed, long timestamp,
long timestamp, byte[] extraData, byte[] nonce, byte[] extraData, byte[] nonce, List<Transaction> transactionsList,
List<Transaction> transactionsList, List<Block> uncleList) { List<Block> uncleList) {
this.parentHash = parentHash; this.parentHash = parentHash;
this.unclesHash = unclesHash; this.unclesHash = unclesHash;
this.coinbase = coinbase; this.coinbase = coinbase;
this.stateRoot = stateRoot; this.state = new Trie(Config.STATE_DB.getDb());
this.stateRoot = state.getRootHash();
this.txTrieRoot = txTrieRoot; this.txTrieRoot = txTrieRoot;
this.difficulty = difficulty; this.difficulty = difficulty;
this.number = number; this.number = number;
@ -106,10 +110,9 @@ public class Block {
private void parseRLP() { private void parseRLP() {
RLPList params = (RLPList) RLP.decode2(rlpEncoded); RLPList params = (RLPList) RLP.decode2(rlpEncoded);
this.hash = HashUtil.sha3(rlpEncoded);
RLPList block = (RLPList) params.get(0); RLPList block = (RLPList) params.get(0);
// Parse Header
RLPList header = (RLPList) block.get(0); RLPList header = (RLPList) block.get(0);
this.parentHash = ((RLPItem) header.get(0)).getRLPData(); this.parentHash = ((RLPItem) header.get(0)).getRLPData();
@ -129,12 +132,12 @@ public class Block {
this.minGasPrice = gpBytes == null ? 0 : (new BigInteger(1, gpBytes)).longValue(); this.minGasPrice = gpBytes == null ? 0 : (new BigInteger(1, gpBytes)).longValue();
this.gasLimit = glBytes == null ? 0 : (new BigInteger(1, glBytes)).longValue(); this.gasLimit = glBytes == null ? 0 : (new BigInteger(1, glBytes)).longValue();
this.gasUsed = guBytes == null ? 0 : (new BigInteger(1, guBytes)).longValue(); this.gasUsed = guBytes == null ? 0 : (new BigInteger(1, guBytes)).longValue();
this.timestamp = tsBytes == null ? 0 : (new BigInteger(tsBytes)).longValue(); this.timestamp = tsBytes == null ? 0 : (new BigInteger(1, tsBytes)).longValue();
this.extraData = ((RLPItem) header.get(11)).getRLPData(); this.extraData = ((RLPItem) header.get(11)).getRLPData();
this.nonce = ((RLPItem) header.get(12)).getRLPData(); this.nonce = ((RLPItem) header.get(12)).getRLPData();
// parse transactions // Parse Transactions
RLPList transactions = (RLPList) block.get(1); RLPList transactions = (RLPList) block.get(1);
for (RLPElement rlpTx : transactions){ for (RLPElement rlpTx : transactions){
@ -148,13 +151,14 @@ public class Block {
RLPElement txRecipe2 = ((RLPList)rlpTx).get(2); RLPElement txRecipe2 = ((RLPList)rlpTx).get(2);
} }
// parse uncles // Parse Uncles
RLPList uncleBlocks = (RLPList) block.get(2); RLPList uncleBlocks = (RLPList) block.get(2);
for (RLPElement rawUncle : uncleBlocks){ for (RLPElement rawUncle : uncleBlocks){
Block blockData = new Block(rawUncle.getRLPData()); Block blockData = new Block(rawUncle.getRLPData());
this.uncleList.add(blockData); this.uncleList.add(blockData);
} }
this.parsed = true; this.parsed = true;
this.hash = this.getHash();
} }
public byte[] getHash(){ public byte[] getHash(){
@ -184,7 +188,7 @@ public class Block {
public byte[] getStateRoot() { public byte[] getStateRoot() {
if (!parsed) parseRLP(); if (!parsed) parseRLP();
return stateRoot; return this.stateRoot;
} }
public byte[] getTxTrieRoot() { public byte[] getTxTrieRoot() {
@ -314,6 +318,11 @@ public class Block {
return toStringBuff.toString(); return toStringBuff.toString();
} }
public byte[] updateState(byte[] key, byte[] value) {
this.state.update(key, value);
return this.stateRoot = this.state.getRootHash();
}
/** /**
* This mechanism enforces a homeostasis in terms of the time between blocks; * This mechanism enforces a homeostasis in terms of the time between blocks;
* a smaller period between the last two blocks results in an increase in the * a smaller period between the last two blocks results in an increase in the

27
ethereumj-core/src/main/java/org/ethereum/core/Genesis.java
View File

@ -19,8 +19,6 @@ public class Genesis extends Block {
public static byte[] PARENT_HASH = zeroHash256; public static byte[] PARENT_HASH = zeroHash256;
public static byte[] UNCLES_HASH = sha3EmptyList; public static byte[] UNCLES_HASH = sha3EmptyList;
public static byte[] COINBASE = zeroHash160; public static byte[] COINBASE = zeroHash160;
public static byte[] STATE_ROOT = // TODO: Get stateRoot from actual state
Hex.decode("12582945fc5ad12c3e7b67c4fc37a68fc0d52d995bb7f7291ff41a2739a7ca16");
public static byte[] TX_TRIE_ROOT = new byte[0]; public static byte[] TX_TRIE_ROOT = new byte[0];
public static byte[] DIFFICULTY = BigInteger.valueOf(2).pow(22).toByteArray(); public static byte[] DIFFICULTY = BigInteger.valueOf(2).pow(22).toByteArray();
public static long NUMBER = 0; public static long NUMBER = 0;
@ -32,9 +30,28 @@ public class Genesis extends Block {
public static byte[] NONCE = HashUtil.sha3(new byte[]{42}); public static byte[] NONCE = HashUtil.sha3(new byte[]{42});
public Genesis() { public Genesis() {
super(PARENT_HASH, UNCLES_HASH, COINBASE, STATE_ROOT, super(PARENT_HASH, UNCLES_HASH, COINBASE, TX_TRIE_ROOT, DIFFICULTY,
TX_TRIE_ROOT, DIFFICULTY, NUMBER, MIN_GAS_PRICE, GAS_LIMIT, GAS_USED, NUMBER, MIN_GAS_PRICE, GAS_LIMIT, GAS_USED, TIMESTAMP,
TIMESTAMP, EXTRA_DATA, NONCE, null, null); EXTRA_DATA, NONCE, null, null);
// Premine state
AccountState acct = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
// # (M)
this.updateState(Hex.decode("2ef47100e0787b915105fd5e3f4ff6752079d5cb"), acct.getEncoded());
// # (A)
this.updateState(Hex.decode("1a26338f0d905e295fccb71fa9ea849ffa12aaf4"), acct.getEncoded());
// # (J)
this.updateState(Hex.decode("e6716f9544a56c530d868e4bfbacb172315bdead"), acct.getEncoded());
// # (G)
this.updateState(Hex.decode("8a40bfaa73256b60764c1bf40675a99083efb075"), acct.getEncoded());
// # (CH)
this.updateState(Hex.decode("e4157b34ea9615cfbde6b4fda419828124b70c78"), acct.getEncoded());
// # (V)
this.updateState(Hex.decode("1e12515ce3e0f817a4ddef9ca55788a1d66bd2df"), acct.getEncoded());
// # (HH)
this.updateState(Hex.decode("6c386a4b26f73c802f34673f7248bb118f97424a"), acct.getEncoded());
// # (R)
this.updateState(Hex.decode("cd2a3d9f938e13cd947ec05abc7fe734df8dd826"), acct.getEncoded());
System.out.println(Hex.toHexString(this.getStateRoot()));
logger.info("Genesis-hash: " + Hex.toHexString(this.getHash())); logger.info("Genesis-hash: " + Hex.toHexString(this.getHash()));
} }
} }

16
ethereumj-core/src/main/java/org/ethereum/core/GoState.java
View File

@ -55,13 +55,13 @@ public class GoState {
} }
public StateObject getContract(byte[] address) { public StateObject getContract(byte[] address) {
String data = this.trie.get(new String(address)); byte[] data = this.trie.get(new String(address));
if (data == "") { if (data == null || data.length == 0) {
return null; return null;
} }
// build contract // build contract
StateObject contract = new StateObject(address, data.getBytes()); StateObject contract = new StateObject(address, data);
// Check if there's a cached state for this contract // Check if there's a cached state for this contract
GoState cachedState = this.states.get(new String(address)); GoState cachedState = this.states.get(new String(address));
@ -76,11 +76,11 @@ public class GoState {
} }
public StateObject getAccount(byte[] address) { public StateObject getAccount(byte[] address) {
String data = this.trie.get(new String(address)); byte[] data = this.trie.get(new String(address));
if (data == "") { if (data == null || data.length == 0) {
return StateObject.createAccount(address, BigInteger.ZERO); return StateObject.createAccount(address, BigInteger.ZERO);
} else { } else {
return new StateObject(address, data.getBytes()); return new StateObject(address, data);
} }
} }
@ -138,11 +138,11 @@ public class GoState {
this.states.put(new String(addr), stateObject.getState()); this.states.put(new String(addr), stateObject.getState());
} }
this.trie.update(new String(addr), new String(stateObject.rlpEncode())); this.trie.update(addr, stateObject.rlpEncode());
} }
public void put(byte[] key, byte[] object) { public void put(byte[] key, byte[] object) {
this.trie.update(new String(key), new String(object)); this.trie.update(key, object);
} }
/** /**

6
ethereumj-core/src/main/java/org/ethereum/core/StateObject.java
View File

@ -58,11 +58,11 @@ public class StateObject {
} }
public Value getAddress(byte[] address) { public Value getAddress(byte[] address) {
return new Value(this.state.getTrie().get(new String(address)).getBytes()); return new Value(this.state.getTrie().get(new String(address)));
} }
public void setAddress(byte[] address, Object value) { public void setAddress(byte[] address, Object value) {
this.state.getTrie().update(new String(address), new String(new Value(value).encode())); this.state.getTrie().update(address, new Value(value).encode());
} }
public GoState getState() { public GoState getState() {
@ -89,7 +89,7 @@ public class StateObject {
public void setMem(BigInteger num, Value val) { public void setMem(BigInteger num, Value val) {
byte[] address = num.toByteArray(); byte[] address = num.toByteArray();
this.state.getTrie().update(new String(address), new String(val.encode())); this.state.getTrie().update(address, val.encode());
} }
// Return the gas back to the origin. Used by the Virtual machine or Closures // Return the gas back to the origin. Used by the Virtual machine or Closures

18
ethereumj-core/src/main/java/org/ethereum/core/Wallet.java
View File

@ -34,7 +34,7 @@ public class Wallet {
// private HashMap<Address, BigInteger> rows = new HashMap<>(); // private HashMap<Address, BigInteger> rows = new HashMap<>();
// <address, info> table for a wallet // <address, info> table for a wallet
private HashMap<String, AddressState> rows = new HashMap<String, AddressState>(); private HashMap<String, AccountState> rows = new HashMap<String, AccountState>();
private long high; private long high;
private List<WalletListener> listeners = new ArrayList<WalletListener>(); private List<WalletListener> listeners = new ArrayList<WalletListener>();
@ -42,14 +42,14 @@ public class Wallet {
private HashMap<BigInteger, Transaction> transactionMap = new HashMap<BigInteger, Transaction>(); private HashMap<BigInteger, Transaction> transactionMap = new HashMap<BigInteger, Transaction>();
public void addNewKey(){ public void addNewKey(){
AddressState addressState = new AddressState(); AccountState addressState = new AccountState();
String address = Hex.toHexString(addressState.getEcKey().getAddress()); String address = Hex.toHexString(addressState.getEcKey().getAddress());
rows.put(address, addressState); rows.put(address, addressState);
for (WalletListener listener : listeners) listener.valueChanged(); for (WalletListener listener : listeners) listener.valueChanged();
} }
public void importKey(byte[] privKey){ public void importKey(byte[] privKey){
AddressState addressState = new AddressState(ECKey.fromPrivate(privKey)); AccountState addressState = new AccountState(ECKey.fromPrivate(privKey));
String address = Hex.toHexString(addressState.getEcKey().getAddress()); String address = Hex.toHexString(addressState.getEcKey().getAddress());
rows.put(address, addressState); rows.put(address, addressState);
notifyListeners(); notifyListeners();
@ -59,11 +59,11 @@ public class Wallet {
this.listeners.add(walletListener); this.listeners.add(walletListener);
} }
public Collection<AddressState> getAddressStateCollection(){ public Collection<AccountState> getAddressStateCollection(){
return rows.values(); return rows.values();
} }
public AddressState getAddressState(byte[] addressBytes){ public AccountState getAddressState(byte[] addressBytes){
String address = Hex.toHexString(addressBytes); String address = Hex.toHexString(addressBytes);
return rows.get(address); return rows.get(address);
} }
@ -75,7 +75,7 @@ public class Wallet {
public BigInteger totalBalance(){ public BigInteger totalBalance(){
BigInteger sum = BigInteger.ZERO; BigInteger sum = BigInteger.ZERO;
for (AddressState addressState : rows.values()){ for (AccountState addressState : rows.values()){
sum = sum.add(addressState.getBalance()); sum = sum.add(addressState.getBalance());
} }
return sum; return sum;
@ -86,7 +86,7 @@ public class Wallet {
transactionMap.put(new BigInteger(transaction.getHash()), transaction ); transactionMap.put(new BigInteger(transaction.getHash()), transaction );
byte[] senderAddress = transaction.getSender(); byte[] senderAddress = transaction.getSender();
AddressState senderState = rows.get(Hex.toHexString(senderAddress)); AccountState senderState = rows.get(Hex.toHexString(senderAddress));
if (senderState != null){ if (senderState != null){
BigInteger value = new BigInteger(transaction.getValue()); BigInteger value = new BigInteger(transaction.getValue());
@ -95,7 +95,7 @@ public class Wallet {
} }
byte[] receiveAddress = transaction.getReceiveAddress(); byte[] receiveAddress = transaction.getReceiveAddress();
AddressState receiverState = rows.get(Hex.toHexString(receiveAddress)); AccountState receiverState = rows.get(Hex.toHexString(receiveAddress));
if (receiverState != null){ if (receiverState != null){
receiverState.addToBalance(new BigInteger(1, transaction.getValue())); receiverState.addToBalance(new BigInteger(1, transaction.getValue()));
} }
@ -214,7 +214,7 @@ public class Wallet {
walletElement.setAttributeNode(high); walletElement.setAttributeNode(high);
int i = 0; int i = 0;
for (AddressState addressState : getAddressStateCollection()){ for (AccountState addressState : getAddressStateCollection()){
Element raw = doc.createElement("raw"); Element raw = doc.createElement("raw");
Attr id = doc.createAttribute("id"); Attr id = doc.createAttribute("id");

26
ethereumj-core/src/main/java/org/ethereum/gui/BlockChainTable.java
View File

@ -9,10 +9,7 @@ import javax.swing.table.TableCellRenderer;
import java.awt.*; import java.awt.*;
import java.awt.datatransfer.Clipboard; import java.awt.datatransfer.Clipboard;
import java.awt.datatransfer.StringSelection; import java.awt.datatransfer.StringSelection;
import java.awt.event.ActionEvent; import java.awt.event.*;
import java.awt.event.KeyEvent;
import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent;
/** /**
* www.ethereumJ.com * www.ethereumJ.com
@ -27,7 +24,12 @@ public class BlockChainTable extends JFrame {
private int lastFindIndex = 0; private int lastFindIndex = 0;
public BlockChainTable() { ToolBar toolBar;
public BlockChainTable(ToolBar toolBar) {
this.toolBar = toolBar;
addCloseAction();
final BlockChainTable blockChainTable = this; final BlockChainTable blockChainTable = this;
@ -126,8 +128,20 @@ public class BlockChainTable extends JFrame {
topPanel.add(scrollPane, BorderLayout.CENTER); topPanel.add(scrollPane, BorderLayout.CENTER);
} }
public void addCloseAction(){
this.addWindowListener( new WindowAdapter()
{
public void windowClosing(WindowEvent e)
{
toolBar.chainToggle.setSelected(false);
}
});
}
public static void main(String args[]){ public static void main(String args[]){
BlockChainTable mainFrame = new BlockChainTable(); BlockChainTable mainFrame = new BlockChainTable(null);
mainFrame.setVisible(true); mainFrame.setVisible(true);
mainFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); mainFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
} }

60
ethereumj-core/src/main/java/org/ethereum/gui/ConnectionConsoleWindow.java
View File

@ -1,16 +1,17 @@
package org.ethereum.gui; package org.ethereum.gui;
import java.awt.*; import java.awt.*;
import java.awt.event.ComponentAdapter; import java.awt.event.WindowAdapter;
import java.awt.event.ComponentEvent; import java.awt.event.WindowEvent;
import javax.swing.JFrame; import javax.swing.*;
import javax.swing.JPanel;
import javax.swing.SwingUtilities;
import org.ethereum.config.SystemProperties;
import org.ethereum.net.client.ClientPeer; import org.ethereum.net.client.ClientPeer;
import org.fife.ui.rsyntaxtextarea.*; import org.fife.ui.rsyntaxtextarea.*;
import org.fife.ui.rtextarea.RTextScrollPane; import org.fife.ui.rtextarea.RTextScrollPane;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/** /**
* A simple example showing how to modify the fonts and colors used in an * A simple example showing how to modify the fonts and colors used in an
@ -25,12 +26,17 @@ import org.fife.ui.rtextarea.RTextScrollPane;
*/ */
public class ConnectionConsoleWindow extends JFrame implements PeerListener{ public class ConnectionConsoleWindow extends JFrame implements PeerListener{
Logger logger = LoggerFactory.getLogger(getClass());
private static final long serialVersionUID = 1L; private static final long serialVersionUID = 1L;
private boolean autoScroll = false; private boolean autoScroll = false;
private RSyntaxTextArea textArea; private RSyntaxTextArea textArea;
ToolBar toolBar = null;
/** /**
* ERROR (exceptions) WARN (when something happens that's not supposed to) * ERROR (exceptions) WARN (when something happens that's not supposed to)
* INFO (wire output) * INFO (wire output)
@ -38,13 +44,15 @@ public class ConnectionConsoleWindow extends JFrame implements PeerListener{
* TRACE (start/end method) * TRACE (start/end method)
*/ */
public ConnectionConsoleWindow() { public ConnectionConsoleWindow(ToolBar toolBar) {
final ConnectionConsoleWindow thisConsole = this; final ConnectionConsoleWindow thisConsole = this;
this.toolBar = toolBar;
java.net.URL url = ClassLoader.getSystemResource("ethereum-icon.png"); java.net.URL url = ClassLoader.getSystemResource("ethereum-icon.png");
Toolkit kit = Toolkit.getDefaultToolkit(); Toolkit kit = Toolkit.getDefaultToolkit();
Image img = kit.createImage(url); Image img = kit.createImage(url);
this.setIconImage(img); this.setIconImage(img);
addCloseAction();
JPanel cp = new JPanel(new BorderLayout()); JPanel cp = new JPanel(new BorderLayout());
@ -68,37 +76,15 @@ public class ConnectionConsoleWindow extends JFrame implements PeerListener{
pack(); pack();
setLocation(775, 390); setLocation(775, 390);
this.addComponentListener(new ComponentAdapter() {
@Override
public void componentShown(ComponentEvent e) {
Thread t = new Thread() { Thread t = new Thread() {
public void run() { public void run() {
// Peer Server Zero: peer discovery new ClientPeer(thisConsole).connect(SystemProperties.CONFIG.activePeerIP(),
// new ClientPeer(thisConsole).connect("54.201.28.117", 30303); SystemProperties.CONFIG.activePeerPort());
// Peer Server One: peer discovery
// new ClientPeer(thisConsole).connect("54.204.10.41", 30303);
// Some dude in Canada
// new ClientPeer(thisConsole).connect("131.104.247.135", 30303);
// Nick
// new ClientPeer(thisConsole).connect("82.217.72.169", 30303);
// c++: ZeroGox
new ClientPeer(thisConsole).connect("54.204.10.41", 30303);
// RomanJ
// new ClientPeer(thisConsole).connect("54.211.14.10", 40404);
} }
}; };
t.start(); t.start();
} }
});
}
@Override @Override
public void console(final String output) { public void console(final String output) {
@ -149,11 +135,23 @@ public class ConnectionConsoleWindow extends JFrame implements PeerListener{
} }
} }
public void addCloseAction(){
this.addWindowListener( new WindowAdapter()
{
public void windowClosing(WindowEvent e)
{
toolBar.logToggle.setSelected(false);
}
});
}
public static void main(String[] args) { public static void main(String[] args) {
// Start all Swing applications on the EDT. // Start all Swing applications on the EDT.
SwingUtilities.invokeLater(new Runnable() { SwingUtilities.invokeLater(new Runnable() {
public void run() { public void run() {
new ConnectionConsoleWindow().setVisible(true); new ConnectionConsoleWindow(null).setVisible(true);
} }
}); });
} }

14
ethereumj-core/src/main/java/org/ethereum/gui/ContractCallDialog.java
View File

@ -1,6 +1,6 @@
package org.ethereum.gui; package org.ethereum.gui;
import org.ethereum.core.AddressState; import org.ethereum.core.AccountState;
import org.ethereum.core.Transaction; import org.ethereum.core.Transaction;
import org.ethereum.manager.MainData; import org.ethereum.manager.MainData;
import org.ethereum.net.client.ClientPeer; import org.ethereum.net.client.ClientPeer;
@ -135,10 +135,10 @@ class ContractCallDialog extends JDialog implements MessageAwareDialog{
JComponent editor = (JComponent)(creatorAddressCombo.getEditor().getEditorComponent()); JComponent editor = (JComponent)(creatorAddressCombo.getEditor().getEditorComponent());
editor.setForeground(Color.RED); editor.setForeground(Color.RED);
Collection<AddressState> addressStates = Collection<AccountState> addressStates =
MainData.instance.getWallet().getAddressStateCollection(); MainData.instance.getWallet().getAddressStateCollection();
for (AddressState addressState : addressStates){ for (AccountState addressState : addressStates){
creatorAddressCombo.addItem(new AddressStateWraper(addressState)); creatorAddressCombo.addItem(new AddressStateWraper(addressState));
} }
@ -229,7 +229,7 @@ class ContractCallDialog extends JDialog implements MessageAwareDialog{
byte[] contractAddress = Hex.decode( contractAddrInput.getText()); byte[] contractAddress = Hex.decode( contractAddrInput.getText());
AddressState addressState = ((AddressStateWraper)creatorAddressCombo.getSelectedItem()).getAddressState(); AccountState addressState = ((AddressStateWraper)creatorAddressCombo.getSelectedItem()).getAddressState();
byte[] senderPrivKey = addressState.getEcKey().getPrivKeyBytes(); byte[] senderPrivKey = addressState.getEcKey().getPrivKeyBytes();
byte[] nonce = addressState.getNonce() == BigInteger.ZERO ? null : addressState.getNonce().toByteArray(); byte[] nonce = addressState.getNonce() == BigInteger.ZERO ? null : addressState.getNonce().toByteArray();
@ -271,13 +271,13 @@ class ContractCallDialog extends JDialog implements MessageAwareDialog{
public class AddressStateWraper { public class AddressStateWraper {
private AddressState addressState; private AccountState addressState;
public AddressStateWraper(AddressState addressState) { public AddressStateWraper(AccountState addressState) {
this.addressState = addressState; this.addressState = addressState;
} }
public AddressState getAddressState() { public AccountState getAddressState() {
return addressState; return addressState;
} }

16
ethereumj-core/src/main/java/org/ethereum/gui/ContractSubmitDialog.java
View File

@ -1,6 +1,6 @@
package org.ethereum.gui; package org.ethereum.gui;
import org.ethereum.core.AddressState; import org.ethereum.core.AccountState;
import org.ethereum.core.Transaction; import org.ethereum.core.Transaction;
import org.ethereum.manager.MainData; import org.ethereum.manager.MainData;
import org.ethereum.net.client.ClientPeer; import org.ethereum.net.client.ClientPeer;
@ -143,10 +143,10 @@ class ContractSubmitDialog extends JDialog implements MessageAwareDialog{
JComponent editor = (JComponent)(creatorAddressCombo.getEditor().getEditorComponent()); JComponent editor = (JComponent)(creatorAddressCombo.getEditor().getEditorComponent());
editor.setForeground(Color.RED); editor.setForeground(Color.RED);
Collection<AddressState> addressStates = Collection<AccountState> addressStates =
MainData.instance.getWallet().getAddressStateCollection(); MainData.instance.getWallet().getAddressStateCollection();
for (AddressState addressState : addressStates){ for (AccountState addressState : addressStates){
creatorAddressCombo.addItem(new AddressStateWraper(addressState)); creatorAddressCombo.addItem(new AddressStateWraper(addressState));
} }
@ -234,7 +234,7 @@ class ContractSubmitDialog extends JDialog implements MessageAwareDialog{
public void submitContract(){ public void submitContract(){
AddressState addressState = ((AddressStateWraper)creatorAddressCombo.getSelectedItem()).getAddressState(); AccountState addressState = ((AddressStateWraper)creatorAddressCombo.getSelectedItem()).getAddressState();
byte[] senderPrivKey = addressState.getEcKey().getPrivKeyBytes(); byte[] senderPrivKey = addressState.getEcKey().getPrivKeyBytes();
byte[] nonce = addressState.getNonce() == BigInteger.ZERO ? null : addressState.getNonce().toByteArray(); byte[] nonce = addressState.getNonce() == BigInteger.ZERO ? null : addressState.getNonce().toByteArray();
@ -276,7 +276,7 @@ class ContractSubmitDialog extends JDialog implements MessageAwareDialog{
public static void main(String args[]) { public static void main(String args[]) {
AddressState as = new AddressState(); AccountState as = new AccountState();
ContractSubmitDialog pod = new ContractSubmitDialog(null, null); ContractSubmitDialog pod = new ContractSubmitDialog(null, null);
pod.setVisible(true); pod.setVisible(true);
@ -284,13 +284,13 @@ class ContractSubmitDialog extends JDialog implements MessageAwareDialog{
public class AddressStateWraper{ public class AddressStateWraper{
private AddressState addressState; private AccountState addressState;
public AddressStateWraper(AddressState addressState) { public AddressStateWraper(AccountState addressState) {
this.addressState = addressState; this.addressState = addressState;
} }
public AddressState getAddressState() { public AccountState getAddressState() {
return addressState; return addressState;
} }

8
ethereumj-core/src/main/java/org/ethereum/gui/PayOutDialog.java
View File

@ -1,6 +1,6 @@
package org.ethereum.gui; package org.ethereum.gui;
import org.ethereum.core.AddressState; import org.ethereum.core.AccountState;
import org.ethereum.core.Transaction; import org.ethereum.core.Transaction;
import org.ethereum.manager.MainData; import org.ethereum.manager.MainData;
import org.ethereum.net.client.ClientPeer; import org.ethereum.net.client.ClientPeer;
@ -26,14 +26,14 @@ class PayOutDialog extends JDialog implements MessageAwareDialog{
PayOutDialog dialog; PayOutDialog dialog;
AddressState addressState = null; AccountState addressState = null;
JLabel statusMsg = null; JLabel statusMsg = null;
final JTextField receiverInput; final JTextField receiverInput;
final JTextField amountInput; final JTextField amountInput;
final JTextField feeInput; final JTextField feeInput;
public PayOutDialog(Frame parent, final AddressState addressState) { public PayOutDialog(Frame parent, final AccountState addressState) {
super(parent, "Payout details: ", false); super(parent, "Payout details: ", false);
dialog = this; dialog = this;
@ -260,7 +260,7 @@ class PayOutDialog extends JDialog implements MessageAwareDialog{
} }
public static void main(String args[]) { public static void main(String args[]) {
AddressState as = new AddressState(); AccountState as = new AccountState();
PayOutDialog pod = new PayOutDialog(null, as); PayOutDialog pod = new PayOutDialog(null, as);
pod.setVisible(true); pod.setVisible(true);
} }

29
ethereumj-core/src/main/java/org/ethereum/gui/PeersTableWindow.java
View File

@ -3,15 +3,12 @@ package org.ethereum.gui;
import org.ethereum.manager.MainData; import org.ethereum.manager.MainData;
import java.awt.*; import java.awt.*;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.util.Timer; import java.util.Timer;
import java.util.TimerTask; import java.util.TimerTask;
import javax.swing.JFrame; import javax.swing.*;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTable;
import javax.swing.ListSelectionModel;
import javax.swing.SwingConstants;
import javax.swing.table.DefaultTableCellRenderer; import javax.swing.table.DefaultTableCellRenderer;
import javax.swing.table.TableCellRenderer; import javax.swing.table.TableCellRenderer;
@ -30,9 +27,13 @@ public class PeersTableWindow extends JFrame{
private JScrollPane scrollPane; private JScrollPane scrollPane;
private Timer updater = new Timer(); private Timer updater = new Timer();
private ToolBar toolBar;
// Constructor of main frame // Constructor of main frame
public PeersTableWindow() { public PeersTableWindow(ToolBar toolBar) {
this.toolBar = toolBar;
addCloseAction();
// Set the frame characteristics // Set the frame characteristics
setTitle("Ethereum Peers"); setTitle("Ethereum Peers");
@ -96,9 +97,21 @@ public class PeersTableWindow extends JFrame{
MainData.instance.startPeerDiscovery(); MainData.instance.startPeerDiscovery();
} }
public void addCloseAction(){
this.addWindowListener( new WindowAdapter()
{
public void windowClosing(WindowEvent e)
{
toolBar.peersToggle.setSelected(false);
}
});
}
public static void main(String args[]) { public static void main(String args[]) {
PeersTableWindow mainFrame = new PeersTableWindow(); PeersTableWindow mainFrame = new PeersTableWindow(null);
mainFrame.setVisible(true); mainFrame.setVisible(true);
mainFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); mainFrame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
} }

104
ethereumj-core/src/main/java/org/ethereum/gui/SerpentEditor.java
View File

@ -6,13 +6,14 @@ import org.fife.ui.rtextarea.RTextScrollPane;
import javax.swing.*; import javax.swing.*;
import java.awt.*; import java.awt.*;
import java.awt.event.ActionEvent; import java.awt.event.*;
import java.awt.event.ActionListener; import java.io.*;
import java.awt.event.InputEvent; import java.util.Scanner;
import java.awt.event.KeyEvent;
import java.util.regex.Matcher; import java.util.regex.Matcher;
import java.util.regex.Pattern; import java.util.regex.Pattern;
import static org.ethereum.config.SystemProperties.CONFIG;
/** /**
* www.ethereumJ.com * www.ethereumJ.com
* User: Roman Mandeleil * User: Roman Mandeleil
@ -46,7 +47,7 @@ public class SerpentEditor extends JFrame {
"\n" + "\n" +
"return(0)\n"; "return(0)\n";
private String codeSample3 = "\n" + private String defaultCode = "\n" +
"\n" + "\n" +
"init: \n" + "init: \n" +
"\n" + "\n" +
@ -69,9 +70,14 @@ public class SerpentEditor extends JFrame {
final JSplitPane splitPanel; final JSplitPane splitPanel;
final JTextArea result; final JTextArea result;
final JPanel contentPane; final JPanel contentPane;
JFileChooser fileChooser = null;
public SerpentEditor() { ToolBar toolBar = null;
public SerpentEditor(ToolBar toolBar) {
this.toolBar = toolBar;
addCloseAction();
contentPane = new JPanel(new BorderLayout()); contentPane = new JPanel(new BorderLayout());
final JFrame mainWindow = this; final JFrame mainWindow = this;
@ -88,7 +94,7 @@ public class SerpentEditor extends JFrame {
codeArea.setSyntaxEditingStyle("text/serpent"); codeArea.setSyntaxEditingStyle("text/serpent");
codeArea.setCodeFoldingEnabled(true); codeArea.setCodeFoldingEnabled(true);
codeArea.setAntiAliasingEnabled(true); codeArea.setAntiAliasingEnabled(true);
codeArea.setText(codeSample3); codeArea.setText(defaultCode);
changeStyleProgrammatically(); changeStyleProgrammatically();
@ -103,6 +109,7 @@ public class SerpentEditor extends JFrame {
splitPanel.setContinuousLayout(true); splitPanel.setContinuousLayout(true);
contentPane.add(splitPanel, BorderLayout.CENTER); contentPane.add(splitPanel, BorderLayout.CENTER);
splitPanel.add(sp); splitPanel.add(sp);
@ -123,6 +130,7 @@ public class SerpentEditor extends JFrame {
contentPane.add(controlsPanel, BorderLayout.SOUTH); contentPane.add(controlsPanel, BorderLayout.SOUTH);
createToolBar(); createToolBar();
setContentPane(contentPane); setContentPane(contentPane);
@ -130,6 +138,8 @@ public class SerpentEditor extends JFrame {
pack(); pack();
this.revalidate();
this.repaint();
} }
@ -187,19 +197,20 @@ public class SerpentEditor extends JFrame {
} catch (Throwable th) { } catch (Throwable th) {
th.printStackTrace(); th.printStackTrace();
splitPanel.setDividerLocation(0.7); splitPanel.setDividerLocation(0.8);
result.setVisible(true); result.setVisible(true);
result.setText(th.getMessage()); result.setText(th.getMessage());
result.setForeground(Color.RED); result.setForeground(Color.RED);
return ; return ;
} }
result.setForeground(Color.BLACK.brighter()); result.setForeground(Color.BLACK.brighter());
result.setVisible(true); result.setVisible(true);
result.setText(asmResult); result.setText(asmResult);
splitPanel.setDividerLocation(0.7); splitPanel.setDividerLocation(
1 - result.getPreferredSize().getHeight() / codeArea.getPreferredSize().getHeight());
this.repaint(); this.repaint();
} }
@ -245,10 +256,7 @@ public class SerpentEditor extends JFrame {
toolbar.setFloatable(false); toolbar.setFloatable(false);
final JPanel mainContentPane = SerpentEditor.this.contentPane; final JPanel mainContentPane = SerpentEditor.this.contentPane;
{ {
java.net.URL url = ClassLoader.getSystemResource("buttons/open-file.png"); java.net.URL url = ClassLoader.getSystemResource("buttons/open-file.png");
Toolkit kit = Toolkit.getDefaultToolkit(); Toolkit kit = Toolkit.getDefaultToolkit();
Image img = kit.createImage(url); Image img = kit.createImage(url);
@ -273,7 +281,21 @@ public class SerpentEditor extends JFrame {
new ActionListener() { new ActionListener() {
@Override @Override
public void actionPerformed(ActionEvent e) { public void actionPerformed(ActionEvent e) {
System.out.println("open file");
File file = callFileChooser();
try {
if (file == null) return;
String content = new Scanner(file).useDelimiter("\\Z").next();
codeArea.setText(content);
} catch (FileNotFoundException e1) {
e1.printStackTrace();
} catch (java.util.NoSuchElementException e2){
// don't worry it's just the file is empty
codeArea.setText("");
}
} }
} }
); );
@ -306,7 +328,24 @@ public class SerpentEditor extends JFrame {
new ActionListener() { new ActionListener() {
@Override @Override
public void actionPerformed(ActionEvent e) { public void actionPerformed(ActionEvent e) {
System.out.println("save file");
File file = null;
if (fileChooser == null || fileChooser.getSelectedFile() == null) {
file = callFileChooser();
if (fileChooser.getSelectedFile() == null)
return;
}
else{
file = fileChooser.getSelectedFile();
}
try {
BufferedWriter out = new BufferedWriter(new FileWriter(file), 32768);
out.write(codeArea.getText());
out.close();
} catch (IOException e1) {
e1.printStackTrace();
}
} }
} }
); );
@ -431,11 +470,44 @@ public class SerpentEditor extends JFrame {
this.contentPane.add(toolbar, BorderLayout.EAST); this.contentPane.add(toolbar, BorderLayout.EAST);
} }
protected File callFileChooser(){
File file = null;
if (fileChooser == null) {
fileChooser = new JFileChooser(CONFIG.samplesDir());
fileChooser.setMultiSelectionEnabled(false);
}
switch (fileChooser.showOpenDialog(SerpentEditor.this))
{
case JFileChooser.APPROVE_OPTION:
file = fileChooser.getSelectedFile();
break;
}
return file;
}
public void addCloseAction(){
this.addWindowListener( new WindowAdapter()
{
public void windowClosing(WindowEvent e)
{
toolBar.editorToggle.setSelected(false);
}
});
}
public static void main(String[] args) { public static void main(String[] args) {
// Start all Swing applications on the EDT. // Start all Swing applications on the EDT.
SwingUtilities.invokeLater(new Runnable() { SwingUtilities.invokeLater(new Runnable() {
public void run() { public void run() {
new SerpentEditor().setVisible(true); new SerpentEditor(null).setVisible(true);
} }
}); });
} }

35
ethereumj-core/src/main/java/org/ethereum/gui/ToolBar.java
View File

@ -18,7 +18,6 @@ import java.awt.event.ItemListener;
*/ */
public class ToolBar extends JFrame { public class ToolBar extends JFrame {
Logger logger = LoggerFactory.getLogger(getClass()); Logger logger = LoggerFactory.getLogger(getClass());
Logger introLogger = LoggerFactory.getLogger("Intro"); Logger introLogger = LoggerFactory.getLogger("Intro");
@ -28,6 +27,13 @@ public class ToolBar extends JFrame {
WalletWindow walletWindow = null; WalletWindow walletWindow = null;
SerpentEditor serpentEditor = null; SerpentEditor serpentEditor = null;
JToggleButton editorToggle;
JToggleButton logToggle;
JToggleButton peersToggle;
JToggleButton chainToggle;
JToggleButton walletToggle;
public ToolBar() throws HeadlessException { public ToolBar() throws HeadlessException {
introLogger.info(""); introLogger.info("");
@ -80,7 +86,7 @@ public class ToolBar extends JFrame {
ImageIcon image_5 = new ImageIcon(imageURL_5); ImageIcon image_5 = new ImageIcon(imageURL_5);
JToggleButton editorToggle = new JToggleButton(""); editorToggle = new JToggleButton("");
editorToggle.setIcon(image_1); editorToggle.setIcon(image_1);
editorToggle.setContentAreaFilled(true); editorToggle.setContentAreaFilled(true);
editorToggle.setToolTipText("Serpent Editor"); editorToggle.setToolTipText("Serpent Editor");
@ -95,7 +101,7 @@ public class ToolBar extends JFrame {
SwingUtilities.invokeLater(new Runnable() { SwingUtilities.invokeLater(new Runnable() {
public void run() { public void run() {
if (serpentEditor == null) if (serpentEditor == null)
serpentEditor = new SerpentEditor(); serpentEditor = new SerpentEditor(ToolBar.this);
serpentEditor.setVisible(true); serpentEditor.setVisible(true);
} }
}); });
@ -105,7 +111,7 @@ public class ToolBar extends JFrame {
} }
}); });
JToggleButton logToggle = new JToggleButton(); logToggle = new JToggleButton();
logToggle.setIcon(image_2); logToggle.setIcon(image_2);
logToggle.setToolTipText("Log Console"); logToggle.setToolTipText("Log Console");
logToggle.setContentAreaFilled(true); logToggle.setContentAreaFilled(true);
@ -121,7 +127,7 @@ public class ToolBar extends JFrame {
SwingUtilities.invokeLater(new Runnable() { SwingUtilities.invokeLater(new Runnable() {
public void run() { public void run() {
if (connectionConsoleWindow == null) if (connectionConsoleWindow == null)
connectionConsoleWindow = new ConnectionConsoleWindow(); connectionConsoleWindow = new ConnectionConsoleWindow(ToolBar.this);
connectionConsoleWindow.setVisible(true); connectionConsoleWindow.setVisible(true);
} }
}); });
@ -131,7 +137,7 @@ public class ToolBar extends JFrame {
} }
}); });
JToggleButton peersToggle = new JToggleButton(); peersToggle = new JToggleButton();
peersToggle.setIcon(image_3); peersToggle.setIcon(image_3);
peersToggle.setToolTipText("Peers"); peersToggle.setToolTipText("Peers");
peersToggle.setContentAreaFilled(true); peersToggle.setContentAreaFilled(true);
@ -146,7 +152,7 @@ public class ToolBar extends JFrame {
SwingUtilities.invokeLater(new Runnable() { SwingUtilities.invokeLater(new Runnable() {
public void run() { public void run() {
if (mainFrame == null) if (mainFrame == null)
mainFrame = new PeersTableWindow(); mainFrame = new PeersTableWindow(ToolBar.this);
mainFrame.setVisible( true ); mainFrame.setVisible( true );
} }
}); });
@ -156,7 +162,7 @@ public class ToolBar extends JFrame {
} }
}); });
JToggleButton chainToggle = new JToggleButton(); chainToggle = new JToggleButton();
chainToggle.setIcon(image_4); chainToggle.setIcon(image_4);
chainToggle.setToolTipText("Block Chain"); chainToggle.setToolTipText("Block Chain");
chainToggle.setContentAreaFilled(true); chainToggle.setContentAreaFilled(true);
@ -172,7 +178,7 @@ public class ToolBar extends JFrame {
public void run() { public void run() {
if (blockChainWindow == null) if (blockChainWindow == null)
blockChainWindow = new BlockChainTable(); blockChainWindow = new BlockChainTable(ToolBar.this);
blockChainWindow.setVisible(true); blockChainWindow.setVisible(true);
} }
}); });
@ -182,7 +188,7 @@ public class ToolBar extends JFrame {
} }
}); });
JToggleButton walletToggle = new JToggleButton(); walletToggle = new JToggleButton();
walletToggle.setIcon(image_5); walletToggle.setIcon(image_5);
walletToggle.setToolTipText("Wallet"); walletToggle.setToolTipText("Wallet");
walletToggle.setContentAreaFilled(true); walletToggle.setContentAreaFilled(true);
@ -190,14 +196,15 @@ public class ToolBar extends JFrame {
walletToggle.setBorderPainted(false); walletToggle.setBorderPainted(false);
walletToggle.setFocusPainted(false); walletToggle.setFocusPainted(false);
walletToggle.setCursor(new Cursor(Cursor.HAND_CURSOR)); walletToggle.setCursor(new Cursor(Cursor.HAND_CURSOR));
walletToggle.addItemListener(new ItemListener() { walletToggle.addItemListener(
new ItemListener() {
@Override @Override
public void itemStateChanged(ItemEvent e) { public void itemStateChanged(ItemEvent e) {
if (e.getStateChange() == ItemEvent.SELECTED){ if (e.getStateChange() == ItemEvent.SELECTED){
SwingUtilities.invokeLater(new Runnable() { SwingUtilities.invokeLater(new Runnable() {
public void run() { public void run() {
if (walletWindow == null) if (walletWindow == null)
walletWindow = new WalletWindow(); walletWindow = new WalletWindow(ToolBar.this);
walletWindow.setVisible(true); walletWindow.setVisible(true);
} }
}); });
@ -206,7 +213,9 @@ public class ToolBar extends JFrame {
} }
} }
}); }
);
cp.add(editorToggle); cp.add(editorToggle);
cp.add(logToggle); cp.add(logToggle);
cp.add(peersToggle); cp.add(peersToggle);

4
ethereumj-core/src/main/java/org/ethereum/gui/WalletAddressPanel.java
View File

@ -1,6 +1,6 @@
package org.ethereum.gui; package org.ethereum.gui;
import org.ethereum.core.AddressState; import org.ethereum.core.AccountState;
import org.ethereum.util.Utils; import org.ethereum.util.Utils;
import org.spongycastle.util.encoders.Hex; import org.spongycastle.util.encoders.Hex;
@ -21,7 +21,7 @@ import java.net.URL;
*/ */
public class WalletAddressPanel extends JPanel{ public class WalletAddressPanel extends JPanel{
public WalletAddressPanel(final AddressState addressState) { public WalletAddressPanel(final AccountState addressState) {
final WalletAddressPanel walletAddressPanel = this; final WalletAddressPanel walletAddressPanel = this;

2
ethereumj-core/src/main/java/org/ethereum/gui/WalletSumPanel.java
View File

@ -53,7 +53,7 @@ public class WalletSumPanel extends JPanel{
payOutLabel.addMouseListener(new MouseAdapter() { payOutLabel.addMouseListener(new MouseAdapter() {
@Override @Override
public void mouseClicked(MouseEvent e) { public void mouseClicked(MouseEvent e) {
System.out.println("boom"); JOptionPane.showMessageDialog(null, "Under construction");
} }
}); });

24
ethereumj-core/src/main/java/org/ethereum/gui/WalletWindow.java
View File

@ -1,6 +1,6 @@
package org.ethereum.gui; package org.ethereum.gui;
import org.ethereum.core.AddressState; import org.ethereum.core.AccountState;
import org.ethereum.core.Wallet; import org.ethereum.core.Wallet;
import org.ethereum.manager.MainData; import org.ethereum.manager.MainData;
@ -9,6 +9,8 @@ import javax.swing.*;
import java.awt.*; import java.awt.*;
import java.awt.event.MouseAdapter; import java.awt.event.MouseAdapter;
import java.awt.event.MouseEvent; import java.awt.event.MouseEvent;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.net.URL; import java.net.URL;
/** /**
@ -19,8 +21,12 @@ import java.net.URL;
public class WalletWindow extends JFrame implements Wallet.WalletListener{ public class WalletWindow extends JFrame implements Wallet.WalletListener{
WalletWindow walletWindow; WalletWindow walletWindow;
ToolBar toolBar;
public WalletWindow() { public WalletWindow(ToolBar toolBar) {
addCloseAction();
this.toolBar = toolBar;
walletWindow = this; walletWindow = this;
java.net.URL url = ClassLoader.getSystemResource("ethereum-icon.png"); java.net.URL url = ClassLoader.getSystemResource("ethereum-icon.png");
@ -50,7 +56,7 @@ public class WalletWindow extends JFrame implements Wallet.WalletListener{
Wallet wallet = MainData.instance.getWallet(); Wallet wallet = MainData.instance.getWallet();
for (AddressState addressState : wallet.getAddressStateCollection()){ for (AccountState addressState : wallet.getAddressStateCollection()){
WalletAddressPanel rowPanel = WalletAddressPanel rowPanel =
new WalletAddressPanel(addressState); new WalletAddressPanel(addressState);
@ -92,6 +98,18 @@ public class WalletWindow extends JFrame implements Wallet.WalletListener{
contentPane.repaint(); contentPane.repaint();
} }
public void addCloseAction(){
this.addWindowListener( new WindowAdapter()
{
public void windowClosing(WindowEvent e)
{
toolBar.walletToggle.setSelected(false);
}
});
}
@Override @Override
public void valueChanged() { public void valueChanged() {
loadWallet(); loadWallet();

8
ethereumj-core/src/main/java/org/ethereum/manager/MainData.java
View File

@ -7,17 +7,13 @@ import java.net.InetAddress;
import java.net.UnknownHostException; import java.net.UnknownHostException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Collections; import java.util.Collections;
import java.util.HashMap;
import java.util.List; import java.util.List;
import java.util.Map;
import org.ethereum.core.AddressState; import org.ethereum.core.AccountState;
import org.ethereum.core.Blockchain; import org.ethereum.core.Blockchain;
import org.ethereum.core.Transaction;
import org.ethereum.core.Wallet; import org.ethereum.core.Wallet;
import org.ethereum.crypto.ECKey; import org.ethereum.crypto.ECKey;
import org.ethereum.crypto.HashUtil; import org.ethereum.crypto.HashUtil;
import org.ethereum.db.Config;
import org.ethereum.db.IpGeoDB; import org.ethereum.db.IpGeoDB;
import org.ethereum.net.client.ClientPeer; import org.ethereum.net.client.ClientPeer;
import org.ethereum.net.client.PeerData; import org.ethereum.net.client.PeerData;
@ -51,7 +47,7 @@ public class MainData {
ECKey key = ECKey.fromPrivate(cowAddr); ECKey key = ECKey.fromPrivate(cowAddr);
wallet.importKey(cowAddr); wallet.importKey(cowAddr);
AddressState state = wallet.getAddressState(key.getAddress()); AccountState state = wallet.getAddressState(key.getAddress());
state.addToBalance(BigInteger.valueOf(2).pow(200)); // 1606938044258990275541962092341162602522202993782792835301376 state.addToBalance(BigInteger.valueOf(2).pow(200)); // 1606938044258990275541962092341162602522202993782792835301376
wallet.importKey(HashUtil.sha3("cat".getBytes())); wallet.importKey(HashUtil.sha3("cat".getBytes()));

6
ethereumj-core/src/main/java/org/ethereum/trie/Cache.java
View File

@ -19,6 +19,12 @@ public class Cache {
nodes = new HashMap<byte[], Node>(); nodes = new HashMap<byte[], Node>();
} }
/**
* Put the node in the cache if RLP encoded value is longer than 32 bytes
*
* @param o the Node which could be a pair-, multi-item Node or single Value
* @return sha3 hash of RLP encoded node if length > 32 otherwise return node itself
*/
public Object put(Object o) { public Object put(Object o) {
Value value = new Value(o); Value value = new Value(o);
byte[] enc = value.encode(); byte[] enc = value.encode();

32
ethereumj-core/src/main/java/org/ethereum/trie/Trie.java
View File

@ -9,7 +9,6 @@ import java.util.Arrays;
import org.ethereum.crypto.HashUtil; import org.ethereum.crypto.HashUtil;
import org.ethereum.util.Value; import org.ethereum.util.Value;
import org.iq80.leveldb.DB; import org.iq80.leveldb.DB;
import org.spongycastle.util.encoders.Hex;
/** /**
* The modified Merkle Patricia tree (trie) provides a persistent data structure * The modified Merkle Patricia tree (trie) provides a persistent data structure
@ -82,10 +81,20 @@ public class Trie {
* @param value * @param value
*/ */
public void update(String key, String value) { public void update(String key, String value) {
this.update(key.getBytes(), value.getBytes());
}
/**
* Insert key/value pair into trie
*
* @param key
* @param value
*/
public void update(byte[] key, byte[] value) {
if (key == null) if (key == null)
throw new NullPointerException("Key should not be blank"); throw new NullPointerException("Key should not be blank");
byte[] k = binToNibbles(key.getBytes()); byte[] k = binToNibbles(key);
this.root = this.insertOrDelete(this.root, k, value.getBytes()); this.root = this.insertOrDelete(this.root, k, value);
} }
/** /**
@ -94,10 +103,10 @@ public class Trie {
* @param key * @param key
* @return value * @return value
*/ */
public String get(String key) { public byte[] get(String key) {
byte[] k = binToNibbles(key.getBytes()); byte[] k = binToNibbles(key.getBytes());
Value c = new Value( this.get(this.root, k) ); Value c = new Value( this.get(this.root, k) );
return c.asString(); return c.asBytes();
} }
/** /**
@ -106,7 +115,7 @@ public class Trie {
* @param key * @param key
*/ */
public void delete(String key) { public void delete(String key) {
this.update(key, ""); this.update(key.getBytes(), "".getBytes());
} }
/**************************************** /****************************************
@ -322,7 +331,7 @@ public class Trie {
// Simple compare function which compared the tries based on their stateRoot // Simple compare function which compared the tries based on their stateRoot
public boolean cmp(Trie trie) { public boolean cmp(Trie trie) {
return this.getRootHash().equals(trie.getRootHash()); return Arrays.equals(this.getRootHash(), trie.getRootHash());
} }
// Save the cached value to the database. // Save the cached value to the database.
@ -368,19 +377,18 @@ public class Trie {
return slice; return slice;
} }
public String getRootHash() { public byte[] getRootHash() {
Object root = this.getRoot(); Object root = this.getRoot();
if (root == null if (root == null
|| (root instanceof byte[] && ((byte[]) root).length == 0) || (root instanceof byte[] && ((byte[]) root).length == 0)
|| (root instanceof String && "".equals((String) root))) { || (root instanceof String && "".equals((String) root))) {
return ""; return new byte[0];
} else if (root instanceof byte[]) { } else if (root instanceof byte[]) {
return Hex.toHexString((byte[])this.getRoot()); return (byte[]) this.getRoot();
} else { } else {
Value rootValue = new Value(this.getRoot()); Value rootValue = new Value(this.getRoot());
byte[] val = rootValue.encode(); byte[] val = rootValue.encode();
byte[] key = HashUtil.sha3(val); return HashUtil.sha3(val);
return Hex.toHexString(key);
} }
} }
} }

11
ethereumj-core/src/main/java/org/ethereum/util/RLP.java
View File

@ -9,6 +9,7 @@ import java.util.Queue;
import static java.util.Arrays.copyOfRange; import static java.util.Arrays.copyOfRange;
import static org.ethereum.util.ByteUtil.byteArrayToInt; import static org.ethereum.util.ByteUtil.byteArrayToInt;
import static org.spongycastle.util.Arrays.concatenate; import static org.spongycastle.util.Arrays.concatenate;
import static org.spongycastle.util.BigIntegers.asUnsignedByteArray;
import java.util.List; import java.util.List;
@ -233,7 +234,7 @@ public class RLP {
} }
byte[] valueBytes = new byte[length]; byte[] valueBytes = new byte[length];
System.arraycopy(data, index, valueBytes, 0, length); System.arraycopy(data, index, valueBytes, 0, length);
value = new BigInteger(valueBytes); value = new BigInteger(1, valueBytes);
return value; return value;
} }
@ -783,7 +784,7 @@ public class RLP {
if(srcBigInteger == BigInteger.ZERO) if(srcBigInteger == BigInteger.ZERO)
return encodeByte((byte)0); return encodeByte((byte)0);
else else
return encodeElement(srcBigInteger.toByteArray()); return encodeElement(asUnsignedByteArray(srcBigInteger));
} }
public static byte[] encodeElement(byte[] srcData) { public static byte[] encodeElement(byte[] srcData) {
@ -878,13 +879,13 @@ public class RLP {
return inputString.getBytes(); return inputString.getBytes();
} else if(input instanceof Long) { } else if(input instanceof Long) {
Long inputLong = (Long) input; Long inputLong = (Long) input;
return (inputLong == 0) ? new byte[0] : BigInteger.valueOf(inputLong).toByteArray(); return (inputLong == 0) ? new byte[0] : asUnsignedByteArray(BigInteger.valueOf(inputLong));
} else if(input instanceof Integer) { } else if(input instanceof Integer) {
Integer inputInt = (Integer) input; Integer inputInt = (Integer) input;
return (inputInt == 0) ? new byte[0] : BigInteger.valueOf(inputInt.longValue()).toByteArray(); return (inputInt == 0) ? new byte[0] : asUnsignedByteArray(BigInteger.valueOf(inputInt.intValue()));
} else if(input instanceof BigInteger) { } else if(input instanceof BigInteger) {
BigInteger inputBigInt = (BigInteger) input; BigInteger inputBigInt = (BigInteger) input;
return (inputBigInt == BigInteger.ZERO) ? new byte[0] : inputBigInt.toByteArray(); return (inputBigInt == BigInteger.ZERO) ? new byte[0] : asUnsignedByteArray(inputBigInt);
} else if (input instanceof Value) { } else if (input instanceof Value) {
Value val = (Value) input; Value val = (Value) input;
return toBytes(val.asObj()); return toBytes(val.asObj());

4
ethereumj-core/src/main/java/org/ethereum/util/Value.java
View File

@ -44,7 +44,7 @@ public class Value {
if (isInt()) { if (isInt()) {
return (Integer) value; return (Integer) value;
} else if (isBytes()) { } else if (isBytes()) {
return new BigInteger(asBytes()).intValue(); return new BigInteger(1, asBytes()).intValue();
} }
return 0; return 0;
} }
@ -53,7 +53,7 @@ public class Value {
if (isLong()) { if (isLong()) {
return (Long) value; return (Long) value;
} else if (isBytes()) { } else if (isBytes()) {
return new BigInteger(asBytes()).longValue(); return new BigInteger(1, asBytes()).longValue();
} }
return 0; return 0;
} }

2
ethereumj-core/src/main/resources/log4j.properties
View File

@ -9,3 +9,5 @@ log4j.appender.stdout.layout.ConversionPattern= %d{HH:mm:ss} [%c{1}] %m%n
# filter noisy classes # filter noisy classes
log4j.logger.org.ethereum.net.peerdiscovery = WARN log4j.logger.org.ethereum.net.peerdiscovery = WARN
log4j.logger.java.nio = WARN
log4j.logger.io.netty = WARN

45
ethereumj-core/src/main/resources/system.properties
View File

@ -7,6 +7,39 @@ server.acceptConnections = false
peer.discovery.ip = 54.201.28.117 peer.discovery.ip = 54.201.28.117
peer.discovery.port = 30303 peer.discovery.port = 30303
# Peer Server Zero: peer discovery
#peer.discovery.ip = 54.201.28.117
#peer.discovery.port = 30303
# Peer Server One: peer discovery
#peer.discovery.ip = 54.204.10.41
#peer.discovery.port = 30303
# Some dude in Canada
#peer.discovery.ip = 131.104.247.135
#peer.discovery.port = 30303
# Nick
#peer.discovery.ip = 82.217.72.169
#peer.discovery.port = 30303
# ZeroGox
#peer.discovery.ip = 54.204.10.41
#peer.discovery.port = 30303
# RomanJ
# peer.discovery.ip = 54.211.14.10
# peer.discovery.port = 40404
# active peer ip and port
# that is the peer through
# we get the chain: [54.201.28.117] port: [30303]
peer.active.ip = 151.64.223.120
peer.active.port = 30304
# specify if the mechanism # specify if the mechanism
# to discover more and more # to discover more and more
# peers and check the already # peers and check the already
@ -33,10 +66,22 @@ peer.discovery.timeout = 2
# retrieved from the peer [seconds] # retrieved from the peer [seconds]
transaction.approve.timeout = 5 transaction.approve.timeout = 5
<<<<<<< HEAD
=======
# default directory where we keep
# basic Serpent samples relative
# to home.dir
samples.dir = samples
>>>>>>> merge
# everytime the application starts # everytime the application starts
# the existing database will be # the existing database will be
# destroyed and all the data will be # destroyed and all the data will be
# downloaded from peers again # downloaded from peers again
<<<<<<< HEAD
database.reset = true database.reset = true
=======
database.reset = true
>>>>>>> merge

19
ethereumj-core/src/test/java/org/ethereum/core/AccountStateTest.java Normal file
View File

@ -0,0 +1,19 @@
package org.ethereum.core;
import static org.junit.Assert.*;
import java.math.BigInteger;
import org.junit.Test;
import org.spongycastle.util.encoders.Hex;
public class AccountStateTest {
@Test
public void testGetEncoded() {
String expected = "f83e9a01000000000000000000000000000000000000000000000000008080a0c5d2460186f7233c927e7db2dcc703c0e500b653ca82273b7bfad8045d85a470";
AccountState acct = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
assertEquals(expected, Hex.toHexString(acct.getEncoded()));
}
}

53
ethereumj-core/src/test/java/org/ethereum/core/StateTest.java Normal file
View File

@ -0,0 +1,53 @@
package org.ethereum.core;
import static org.junit.Assert.*;
import java.math.BigInteger;
import org.ethereum.trie.MockDB;
import org.ethereum.trie.Trie;
import org.junit.Test;
import org.spongycastle.util.encoders.Hex;
public class StateTest {
@Test
public void testGenesisAccounts() {
Trie trie = new Trie(new MockDB());
// 2ef47100e0787b915105fd5e3f4ff6752079d5cb # (M)
AccountState acct5 = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
trie.update(Hex.decode("2ef47100e0787b915105fd5e3f4ff6752079d5cb"), acct5.getEncoded());
// 1a26338f0d905e295fccb71fa9ea849ffa12aaf4 # (A)
AccountState acct4 = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
trie.update(Hex.decode("1a26338f0d905e295fccb71fa9ea849ffa12aaf4"), acct4.getEncoded());
// e6716f9544a56c530d868e4bfbacb172315bdead # (J)
AccountState acct2 = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
trie.update(Hex.decode("e6716f9544a56c530d868e4bfbacb172315bdead"), acct2.getEncoded());
// 8a40bfaa73256b60764c1bf40675a99083efb075 # (G)
AccountState acct1 = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
trie.update(Hex.decode("8a40bfaa73256b60764c1bf40675a99083efb075"), acct1.getEncoded());
// e4157b34ea9615cfbde6b4fda419828124b70c78 # (CH)
AccountState acct8 = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
trie.update(Hex.decode("e4157b34ea9615cfbde6b4fda419828124b70c78"), acct8.getEncoded());
// 1e12515ce3e0f817a4ddef9ca55788a1d66bd2df # (V)
AccountState acct3 = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
trie.update(Hex.decode("1e12515ce3e0f817a4ddef9ca55788a1d66bd2df"), acct3.getEncoded());
// 6c386a4b26f73c802f34673f7248bb118f97424a # (HH)
AccountState acct7 = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
trie.update(Hex.decode("6c386a4b26f73c802f34673f7248bb118f97424a"), acct7.getEncoded());
// cd2a3d9f938e13cd947ec05abc7fe734df8dd826 # (R)
AccountState acct6 = new AccountState(BigInteger.ZERO, BigInteger.valueOf(2).pow(200));
trie.update(Hex.decode("cd2a3d9f938e13cd947ec05abc7fe734df8dd826"), acct6.getEncoded());
assertEquals("12582945fc5ad12c3e7b67c4fc37a68fc0d52d995bb7f7291ff41a2739a7ca16", Hex.toHexString(trie.getRootHash()));
}
}

4
ethereumj-core/src/test/java/org/ethereum/core/WalletTest.java
View File

@ -29,8 +29,8 @@ public class WalletTest {
wallet.importKey(catKey.getPrivKeyBytes()); wallet.importKey(catKey.getPrivKeyBytes());
AddressState cowAddressState = (AddressState) wallet.getAddressState(cowKey.getAddress()); AccountState cowAddressState = (AccountState) wallet.getAddressState(cowKey.getAddress());
AddressState catAddressState = (AddressState) wallet.getAddressState(catKey.getAddress()); AccountState catAddressState = (AccountState) wallet.getAddressState(catKey.getAddress());
cowAddressState.addToBalance(new BigInteger("234234")); cowAddressState.addToBalance(new BigInteger("234234"));
catAddressState.addToBalance(new BigInteger("84758")); catAddressState.addToBalance(new BigInteger("84758"));

2
ethereumj-core/src/test/java/org/ethereum/crypto/CryptoTest.java
View File

@ -90,7 +90,7 @@ public class CryptoTest {
// todo: https://tools.ietf.org/html/rfc6979#section-2.2 // todo: https://tools.ietf.org/html/rfc6979#section-2.2
// todo: https://github.com/bcgit/bc-java/blob/master/core/src/main/java/org/bouncycastle/crypto/signers/ECDSASigner.java // todo: https://github.com/bcgit/bc-java/blob/master/core/src/main/java/org/bouncycastle/crypto/signers/ECDSASigner.java
System.out.println(new BigInteger(1, Hex.decode("3913517ebd3c0c65000000"))); System.out.println(new BigInteger(Hex.decode("3913517ebd3c0c65000000")));
System.out.println(Utils.getValueShortString(new BigInteger("69000000000000000000000000"))); System.out.println(Utils.getValueShortString(new BigInteger("69000000000000000000000000")));

207
ethereumj-core/src/test/java/org/ethereum/trie/TrieTest.java
View File

@ -4,6 +4,7 @@ import static org.junit.Assert.*;
import org.ethereum.trie.Trie; import org.ethereum.trie.Trie;
import org.junit.Test; import org.junit.Test;
import org.spongycastle.util.encoders.Hex;
public class TrieTest { public class TrieTest {
@ -34,7 +35,7 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update("", dog); trie.update("", dog);
assertEquals(dog, trie.get("")); assertEquals(dog, new String(trie.get("")));
} }
@Test @Test
@ -42,7 +43,7 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, dog); trie.update(cat, dog);
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
} }
@Test @Test
@ -50,33 +51,33 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, LONG_STRING); trie.update(cat, LONG_STRING);
assertEquals(LONG_STRING, trie.get(cat)); assertEquals(LONG_STRING, new String(trie.get(cat)));
} }
@Test @Test
public void testInsertMultipleItems1() { public void testInsertMultipleItems1() {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(ca, dude); trie.update(ca, dude);
assertEquals(dude, trie.get(ca)); assertEquals(dude, new String(trie.get(ca)));
trie.update(cat, dog); trie.update(cat, dog);
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
trie.update(dog, test); trie.update(dog, test);
assertEquals(test, trie.get(dog)); assertEquals(test, new String(trie.get(dog)));
trie.update(doge, LONG_STRING); trie.update(doge, LONG_STRING);
assertEquals(LONG_STRING, trie.get(doge)); assertEquals(LONG_STRING, new String(trie.get(doge)));
trie.update(test, LONG_STRING); trie.update(test, LONG_STRING);
assertEquals(LONG_STRING, trie.get(test)); assertEquals(LONG_STRING, new String(trie.get(test)));
// Test if everything is still there // Test if everything is still there
assertEquals(dude, trie.get(ca)); assertEquals(dude, new String(trie.get(ca)));
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
assertEquals(test, trie.get(dog)); assertEquals(test, new String(trie.get(dog)));
assertEquals(LONG_STRING, trie.get(doge)); assertEquals(LONG_STRING, new String(trie.get(doge)));
assertEquals(LONG_STRING, trie.get(test)); assertEquals(LONG_STRING, new String(trie.get(test)));
} }
@Test @Test
@ -84,26 +85,26 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, dog); trie.update(cat, dog);
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
trie.update(ca, dude); trie.update(ca, dude);
assertEquals(dude, trie.get(ca)); assertEquals(dude, new String(trie.get(ca)));
trie.update(doge, LONG_STRING); trie.update(doge, LONG_STRING);
assertEquals(LONG_STRING, trie.get(doge)); assertEquals(LONG_STRING, new String(trie.get(doge)));
trie.update(dog, test); trie.update(dog, test);
assertEquals(test, trie.get(dog)); assertEquals(test, new String(trie.get(dog)));
trie.update(test, LONG_STRING); trie.update(test, LONG_STRING);
assertEquals(LONG_STRING, trie.get(test)); assertEquals(LONG_STRING, new String(trie.get(test)));
// Test if everything is still there // Test if everything is still there
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
assertEquals(dude, trie.get(ca)); assertEquals(dude, new String(trie.get(ca)));
assertEquals(LONG_STRING, trie.get(doge)); assertEquals(LONG_STRING, new String(trie.get(doge)));
assertEquals(test, trie.get(dog)); assertEquals(test, new String(trie.get(dog)));
assertEquals(LONG_STRING, trie.get(test)); assertEquals(LONG_STRING, new String(trie.get(test)));
} }
@Test @Test
@ -111,19 +112,19 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, dog); trie.update(cat, dog);
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
trie.update(cat, dog+"1"); trie.update(cat, dog+"1");
assertEquals(dog+"1", trie.get(cat)); assertEquals(dog+"1", new String(trie.get(cat)));
} }
@Test @Test
public void testUpdateLongToLongString() { public void testUpdateLongToLongString() {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, LONG_STRING); trie.update(cat, LONG_STRING);
assertEquals(LONG_STRING, trie.get(cat)); assertEquals(LONG_STRING, new String(trie.get(cat)));
trie.update(cat, LONG_STRING+"1"); trie.update(cat, LONG_STRING+"1");
assertEquals(LONG_STRING+"1", trie.get(cat)); assertEquals(LONG_STRING+"1", new String(trie.get(cat)));
} }
@Test @Test
@ -131,10 +132,10 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, dog); trie.update(cat, dog);
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
trie.update(cat, LONG_STRING+"1"); trie.update(cat, LONG_STRING+"1");
assertEquals(LONG_STRING+"1", trie.get(cat)); assertEquals(LONG_STRING+"1", new String(trie.get(cat)));
} }
@Test @Test
@ -142,10 +143,10 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, LONG_STRING); trie.update(cat, LONG_STRING);
assertEquals(LONG_STRING, trie.get(cat)); assertEquals(LONG_STRING, new String(trie.get(cat)));
trie.update(cat, dog+"1"); trie.update(cat, dog+"1");
assertEquals(dog+"1", trie.get(cat)); assertEquals(dog+"1", new String(trie.get(cat)));
} }
@Test @Test
@ -155,15 +156,15 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, dog); trie.update(cat, dog);
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
trie.update(ca, dude); trie.update(ca, dude);
assertEquals(dude, trie.get(ca)); assertEquals(dude, new String(trie.get(ca)));
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(ca); trie.delete(ca);
assertEquals("", trie.get(ca)); assertEquals("", new String(trie.get(ca)));
assertEquals(ROOT_HASH_AFTER, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -173,15 +174,15 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(ca, dude); trie.update(ca, dude);
assertEquals(dude, trie.get(ca)); assertEquals(dude, new String(trie.get(ca)));
trie.update(cat, dog); trie.update(cat, dog);
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(cat); trie.delete(cat);
assertEquals("", trie.get(cat)); assertEquals("", new String(trie.get(cat)));
assertEquals(ROOT_HASH_AFTER, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -191,15 +192,15 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, dude); trie.update(cat, dude);
assertEquals(dude, trie.get(cat)); assertEquals(dude, new String(trie.get(cat)));
trie.update(dog, test); trie.update(dog, test);
assertEquals(test, trie.get(dog)); assertEquals(test, new String(trie.get(dog)));
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(dog); trie.delete(dog);
assertEquals("", trie.get(dog)); assertEquals("", new String(trie.get(dog)));
assertEquals(ROOT_HASH_AFTER, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -209,15 +210,15 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, LONG_STRING); trie.update(cat, LONG_STRING);
assertEquals(LONG_STRING, trie.get(cat)); assertEquals(LONG_STRING, new String(trie.get(cat)));
trie.update(dog, LONG_STRING); trie.update(dog, LONG_STRING);
assertEquals(LONG_STRING, trie.get(dog)); assertEquals(LONG_STRING, new String(trie.get(dog)));
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(dog); trie.delete(dog);
assertEquals("", trie.get(dog)); assertEquals("", new String(trie.get(dog)));
assertEquals(ROOT_HASH_AFTER, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -227,15 +228,15 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(ca, LONG_STRING); trie.update(ca, LONG_STRING);
assertEquals(LONG_STRING, trie.get(ca)); assertEquals(LONG_STRING, new String(trie.get(ca)));
trie.update(cat, LONG_STRING); trie.update(cat, LONG_STRING);
assertEquals(LONG_STRING, trie.get(cat)); assertEquals(LONG_STRING, new String(trie.get(cat)));
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(cat); trie.delete(cat);
assertEquals("", trie.get(cat)); assertEquals("", new String(trie.get(cat)));
assertEquals(ROOT_HASH_AFTER, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -245,15 +246,15 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, LONG_STRING); trie.update(cat, LONG_STRING);
assertEquals(LONG_STRING, trie.get(cat)); assertEquals(LONG_STRING, new String(trie.get(cat)));
trie.update(ca, LONG_STRING); trie.update(ca, LONG_STRING);
assertEquals(LONG_STRING, trie.get(ca)); assertEquals(LONG_STRING, new String(trie.get(ca)));
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(ca); trie.delete(ca);
assertEquals("", trie.get(ca)); assertEquals("", new String(trie.get(ca)));
assertEquals(ROOT_HASH_AFTER, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -264,28 +265,28 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(cat, dog); trie.update(cat, dog);
assertEquals(dog, trie.get(cat)); assertEquals(dog, new String(trie.get(cat)));
trie.update(ca, dude); trie.update(ca, dude);
assertEquals(dude, trie.get(ca)); assertEquals(dude, new String(trie.get(ca)));
trie.update(doge, LONG_STRING); trie.update(doge, LONG_STRING);
assertEquals(LONG_STRING, trie.get(doge)); assertEquals(LONG_STRING, new String(trie.get(doge)));
trie.update(dog, test); trie.update(dog, test);
assertEquals(test, trie.get(dog)); assertEquals(test, new String(trie.get(dog)));
trie.update(test, LONG_STRING); trie.update(test, LONG_STRING);
assertEquals(LONG_STRING, trie.get(test)); assertEquals(LONG_STRING, new String(trie.get(test)));
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(dog); trie.delete(dog);
assertEquals("", trie.get(dog)); assertEquals("", new String(trie.get(dog)));
assertEquals(ROOT_HASH_AFTER1, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER1, Hex.toHexString(trie.getRootHash()));
trie.delete(test); trie.delete(test);
assertEquals("", trie.get(test)); assertEquals("", new String(trie.get(test)));
assertEquals(ROOT_HASH_AFTER2, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER2, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -296,39 +297,39 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update(c, LONG_STRING); trie.update(c, LONG_STRING);
assertEquals(LONG_STRING, trie.get(c)); assertEquals(LONG_STRING, new String(trie.get(c)));
trie.update(ca, LONG_STRING); trie.update(ca, LONG_STRING);
assertEquals(LONG_STRING, trie.get(ca)); assertEquals(LONG_STRING, new String(trie.get(ca)));
trie.update(cat, LONG_STRING); trie.update(cat, LONG_STRING);
assertEquals(LONG_STRING, trie.get(cat)); assertEquals(LONG_STRING, new String(trie.get(cat)));
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(ca); trie.delete(ca);
assertEquals("", trie.get(ca)); assertEquals("", new String(trie.get(ca)));
assertEquals(ROOT_HASH_AFTER1, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER1, Hex.toHexString(trie.getRootHash()));
trie.delete(cat); trie.delete(cat);
assertEquals("", trie.get(cat)); assertEquals("", new String(trie.get(cat)));
assertEquals(ROOT_HASH_AFTER2, trie.getRootHash()); assertEquals(ROOT_HASH_AFTER2, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
public void testDeleteAll() { public void testDeleteAll() {
String ROOT_HASH_BEFORE = "a84739b4762ddf15e3acc4e6957e5ab2bbfaaef00fe9d436a7369c6f058ec90d"; String ROOT_HASH_BEFORE = "a84739b4762ddf15e3acc4e6957e5ab2bbfaaef00fe9d436a7369c6f058ec90d";
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
assertEquals(ROOT_HASH_EMPTY, trie.getRootHash()); assertEquals(ROOT_HASH_EMPTY, Hex.toHexString(trie.getRootHash()));
trie.update(ca, dude); trie.update(ca, dude);
trie.update(cat, dog); trie.update(cat, dog);
trie.update(doge, LONG_STRING); trie.update(doge, LONG_STRING);
assertEquals(ROOT_HASH_BEFORE, trie.getRootHash()); assertEquals(ROOT_HASH_BEFORE, Hex.toHexString(trie.getRootHash()));
trie.delete(ca); trie.delete(ca);
trie.delete(cat); trie.delete(cat);
trie.delete(doge); trie.delete(doge);
assertEquals(ROOT_HASH_EMPTY, trie.getRootHash()); assertEquals(ROOT_HASH_EMPTY, Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -339,12 +340,12 @@ public class TrieTest {
trie1.update(doge, LONG_STRING); trie1.update(doge, LONG_STRING);
trie2.update(doge, LONG_STRING); trie2.update(doge, LONG_STRING);
assertTrue("Expected tries to be equal", trie1.cmp(trie2)); assertTrue("Expected tries to be equal", trie1.cmp(trie2));
assertEquals(trie1.getRootHash(), trie2.getRootHash()); assertEquals(Hex.toHexString(trie1.getRootHash()), Hex.toHexString(trie2.getRootHash()));
trie1.update(dog, LONG_STRING); trie1.update(dog, LONG_STRING);
trie2.update(cat, LONG_STRING); trie2.update(cat, LONG_STRING);
assertFalse("Expected tries not to be equal", trie1.cmp(trie2)); assertFalse("Expected tries not to be equal", trie1.cmp(trie2));
assertNotEquals(trie1.getRootHash(), trie2.getRootHash()); assertNotEquals(Hex.toHexString(trie1.getRootHash()), Hex.toHexString(trie2.getRootHash()));
} }
@Test @Test
@ -386,12 +387,26 @@ public class TrieTest {
@Test @Test
public void testTrieCopy() { public void testTrieCopy() {
fail("To be implemented"); Trie trie = new Trie(mockDb);
trie.update("doe", "reindeer");
Trie trie2 = trie.copy();
assertFalse(trie.equals(trie2)); // avoid possibility that its just a reference copy
assertEquals(Hex.toHexString(trie.getRootHash()), Hex.toHexString(trie2.getRootHash()));
assertTrue(trie.cmp(trie2));
} }
@Test @Test
public void testTrieUndo() { public void testTrieUndo() {
fail("To be implemented"); Trie trie = new Trie(mockDb);
trie.update("doe", "reindeer");
assertEquals("11a0327cfcc5b7689b6b6d727e1f5f8846c1137caaa9fc871ba31b7cce1b703e", Hex.toHexString(trie.getRootHash()));
trie.sync();
trie.update("dog", "puppy");
assertEquals("05ae693aac2107336a79309e0c60b24a7aac6aa3edecaef593921500d33c63c4", Hex.toHexString(trie.getRootHash()));
trie.undo();
assertEquals("11a0327cfcc5b7689b6b6d727e1f5f8846c1137caaa9fc871ba31b7cce1b703e", Hex.toHexString(trie.getRootHash()));
} }
// Using tests from: https://github.com/ethereum/tests/blob/master/trietest.json // Using tests from: https://github.com/ethereum/tests/blob/master/trietest.json
@ -401,20 +416,20 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update("A", "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"); trie.update("A", "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa");
assertEquals("d23786fb4a010da3ce639d66d5e904a11dbc02746d1ce25029e53290cabf28ab", trie.getRootHash()); assertEquals("d23786fb4a010da3ce639d66d5e904a11dbc02746d1ce25029e53290cabf28ab", Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
public void testDogs() { public void testDogs() {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update("doe", "reindeer"); trie.update("doe", "reindeer");
assertEquals("11a0327cfcc5b7689b6b6d727e1f5f8846c1137caaa9fc871ba31b7cce1b703e", trie.getRootHash()); assertEquals("11a0327cfcc5b7689b6b6d727e1f5f8846c1137caaa9fc871ba31b7cce1b703e", Hex.toHexString(trie.getRootHash()));
trie.update("dog", "puppy"); trie.update("dog", "puppy");
assertEquals("05ae693aac2107336a79309e0c60b24a7aac6aa3edecaef593921500d33c63c4", trie.getRootHash()); assertEquals("05ae693aac2107336a79309e0c60b24a7aac6aa3edecaef593921500d33c63c4", Hex.toHexString(trie.getRootHash()));
trie.update("dogglesworth", "cat"); trie.update("dogglesworth", "cat");
assertEquals("8aad789dff2f538bca5d8ea56e8abe10f4c7ba3a5dea95fea4cd6e7c3a1168d3", trie.getRootHash()); assertEquals("8aad789dff2f538bca5d8ea56e8abe10f4c7ba3a5dea95fea4cd6e7c3a1168d3", Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -425,7 +440,7 @@ public class TrieTest {
trie.update("doge", "coin"); trie.update("doge", "coin");
trie.update("dog", "puppy"); trie.update("dog", "puppy");
assertEquals("5991bb8c6514148a29db676a14ac506cd2cd5775ace63c30a4fe457715e9ac84", trie.getRootHash()); assertEquals("5991bb8c6514148a29db676a14ac506cd2cd5775ace63c30a4fe457715e9ac84", Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -440,7 +455,7 @@ public class TrieTest {
trie.update("dog", "puppy"); trie.update("dog", "puppy");
trie.update("shaman", ""); trie.update("shaman", "");
assertEquals("5991bb8c6514148a29db676a14ac506cd2cd5775ace63c30a4fe457715e9ac84", trie.getRootHash()); assertEquals("5991bb8c6514148a29db676a14ac506cd2cd5775ace63c30a4fe457715e9ac84", Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -450,7 +465,7 @@ public class TrieTest {
trie.update("food", "bat"); trie.update("food", "bat");
trie.update("food", "bass"); trie.update("food", "bass");
assertEquals("17beaa1648bafa633cda809c90c04af50fc8aed3cb40d16efbddee6fdf63c4c3", trie.getRootHash()); assertEquals("17beaa1648bafa633cda809c90c04af50fc8aed3cb40d16efbddee6fdf63c4c3", Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -460,7 +475,7 @@ public class TrieTest {
trie.update("be", "e"); trie.update("be", "e");
trie.update("dog", "puppy"); trie.update("dog", "puppy");
trie.update("bed", "d"); trie.update("bed", "d");
assertEquals("3f67c7a47520f79faa29255d2d3c084a7a6df0453116ed7232ff10277a8be68b", trie.getRootHash()); assertEquals("3f67c7a47520f79faa29255d2d3c084a7a6df0453116ed7232ff10277a8be68b", Hex.toHexString(trie.getRootHash()));
} }
@Test @Test
@ -468,9 +483,9 @@ public class TrieTest {
Trie trie = new Trie(mockDb); Trie trie = new Trie(mockDb);
trie.update("test", "test"); trie.update("test", "test");
assertEquals("85d106d4edff3b7a4889e91251d0a87d7c17a1dda648ebdba8c6060825be23b8", trie.getRootHash()); assertEquals("85d106d4edff3b7a4889e91251d0a87d7c17a1dda648ebdba8c6060825be23b8", Hex.toHexString(trie.getRootHash()));
trie.update("te", "testy"); trie.update("te", "testy");
assertEquals("8452568af70d8d140f58d941338542f645fcca50094b20f3c3d8c3df49337928", trie.getRootHash()); assertEquals("8452568af70d8d140f58d941338542f645fcca50094b20f3c3d8c3df49337928", Hex.toHexString(trie.getRootHash()));
} }
} }

10
ethereumj-core/src/test/java/org/ethereum/util/RLPTest.java
View File

@ -85,7 +85,7 @@ public class RLPTest {
BigInteger peerId = RLP.decodeBigInteger(payload, nextIndex); BigInteger peerId = RLP.decodeBigInteger(payload, nextIndex);
BigInteger expectedPeerId = BigInteger expectedPeerId =
new BigInteger("-3757679129454624401847229560118336025674165800491763435653406124634392418475888088940922052683656239666728251000337405781915693264977453978537202650777524"); new BigInteger("9650128800487972697726795438087510101805200020100629942070155319087371611597658887860952245483247188023303607186148645071838189546969115967896446355306572");
assertEquals(expectedPeerId, peerId); assertEquals(expectedPeerId, peerId);
nextIndex = RLP.getNextElementIndex(payload, nextIndex); nextIndex = RLP.getNextElementIndex(payload, nextIndex);
@ -101,7 +101,7 @@ public class RLPTest {
peerId = RLP.decodeBigInteger(payload, nextIndex); peerId = RLP.decodeBigInteger(payload, nextIndex);
expectedPeerId = expectedPeerId =
new BigInteger("-3757679129454624401847229560118336025674165800491763435653406124634392418475888088940922052683656239666728251000337405781915693264977453978537202650777524"); new BigInteger("9650128800487972697726795438087510101805200020100629942070155319087371611597658887860952245483247188023303607186148645071838189546969115967896446355306572");
assertEquals(expectedPeerId ,peerId); assertEquals(expectedPeerId ,peerId);
@ -429,7 +429,7 @@ public class RLPTest {
assertEquals(expected, Hex.toHexString(encoderesult)); assertEquals(expected, Hex.toHexString(encoderesult));
byte[] decodeResult = (byte[]) RLP.decode(encoderesult, 0).getDecoded(); byte[] decodeResult = (byte[]) RLP.decode(encoderesult, 0).getDecoded();
assertEquals(test, new BigInteger(decodeResult)); assertEquals(test, new BigInteger(1, decodeResult));
} }
@Test @Test
@ -615,10 +615,10 @@ public class RLPTest {
assertEquals(test11, byteArrayToInt(decodedData)); assertEquals(test11, byteArrayToInt(decodedData));
decodedData = (byte[]) RLP.decode(Hex.decode(result12), pos).getDecoded(); decodedData = (byte[]) RLP.decode(Hex.decode(result12), pos).getDecoded();
assertTrue(test12.compareTo(new BigInteger(decodedData)) == 0); assertTrue(test12.compareTo(new BigInteger(1, decodedData)) == 0);
decodedData = (byte[]) RLP.decode(Hex.decode(result13), pos).getDecoded(); decodedData = (byte[]) RLP.decode(Hex.decode(result13), pos).getDecoded();
assertTrue(test13.compareTo(new BigInteger(decodedData)) == 0); assertTrue(test13.compareTo(new BigInteger(1, decodedData)) == 0);
// Need to test with different expected value, because decoding doesn't recognize types // Need to test with different expected value, because decoding doesn't recognize types
Object testObject1 = RLP.decode(Hex.decode(result14), pos).getDecoded(); Object testObject1 = RLP.decode(Hex.decode(result14), pos).getDecoded();

2
ethereumj-core/src/test/java/org/ethereum/util/RlpTestData.java
View File

@ -41,7 +41,7 @@ public class RlpTestData {
public static String result11 = "8203e8"; public static String result11 = "8203e8";
public static BigInteger test12 = new BigInteger("115792089237316195423570985008687907853269984665640564039457584007913129639935"); public static BigInteger test12 = new BigInteger("115792089237316195423570985008687907853269984665640564039457584007913129639935");
public static String result12 = "a100ffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffff"; public static String result12 = "a0ffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffff";
public static BigInteger test13 = new BigInteger("115792089237316195423570985008687907853269984665640564039457584007913129639936"); public static BigInteger test13 = new BigInteger("115792089237316195423570985008687907853269984665640564039457584007913129639936");
public static String result13 = "a1010000000000000000000000000000000000000000000000000000000000000000"; public static String result13 = "a1010000000000000000000000000000000000000000000000000000000000000000";

34
samples/my-currency.se Normal file
View File

@ -0,0 +1,34 @@
# the sample is good example how one can
# save program that manage his own currency
init:
# this part run only on init stage
# we are about to set the maxim
# amount of currency
contract.storage[0xcd2a3d9f938e13cd947ec05abc7fe734df8dd826] = 1000000
code:
# the currency manager
# support two functions
if msg.datasize == 1:
# 1. balance check
addr = msg.data[0]
return(contract.storage[addr])
else:
# 2. balance manipulation
from = msg.sender
fromvalue = contract.storage[from]
to = msg.data[0]
value = msg.data[1]
if fromvalue >= value:
contract.storage[from] = fromvalue - value
contract.storage[to] = contract.storage[to] + value
return(1)
else:
return(0)

10
samples/namecoin.se Normal file
View File

@ -0,0 +1,10 @@
# The sample demonstrates how you
# can simply create a program running
# on top of chain and saving values for
# futre use
if !(contract.storage[msg.data[0]]):
contract.storage[msg.data[0]] = msg.data[1]
return(1)
else:
return(0)