Testing first stratum function - getAddressInfo

app/com/bitcoinpotato/util/Func2.java

@@ -0,0 +1,5 @@
+package com.bitcoinpotato.util;
+
+public interface Func2<TArg1, TArg2, TResult> {
+    TResult apply(TArg1 arg1, TArg2 arg2);
+}

app/com/bitcoinpotato/util/Maps3.java

@@ -0,0 +1,32 @@
+package com.bitcoinpotato.util;
+
+import com.google.common.base.Function;
+
+import java.util.Map;
+
+import static com.google.common.base.Preconditions.checkArgument;
+import static com.google.common.collect.Maps.newHashMap;
+
+public class Maps3 {
+    public static <K, V> Map<K, V> build(Iterable<K> keys, Function<K, V> buildValue) {
+        Map<K, V> result = newHashMap();
+        for (K key : keys) {
+            checkArgument(!result.containsKey(key));
+            V value = buildValue.apply(key);
+            result.put(key, value);
+        }
+        return result;
+    }
+
+    public static <K, V1, V2> Map<K, V2> build(Map<K, V1> input, Func2<K, V1, V2> buildValue) {
+        Map<K, V2> result = newHashMap();
+        for (Map.Entry<K, V1> entry : input.entrySet()) {
+            checkArgument(!result.containsKey(entry.getKey()));
+            K key = entry.getKey();
+            V1 value1 = entry.getValue();
+            V2 value = buildValue.apply(key, value1);
+            result.put(key, value);
+        }
+        return result;
+    }
+}

app/jobs/Bootstrap.java

@@ -16,6 +16,9 @@ public class Bootstrap extends Job {
 
     @Override
     public void doJob() throws Exception {
+        if (Play.runingInTestMode())
+            return;
+
         // TODO - (This fails in Prod mode)
         // Logger.getRootLogger().addAppender(new DBAppender());
 

app/models/IncomingTransaction.java

@@ -43,4 +43,3 @@ public static List<IncomingTransaction> byStatusSortedChronologically(Status sta
         return find("byStatus order by created", status).fetch();
     }
 }
-

app/org/bitcoin/stratum/Stratum.java

@@ -1,22 +1,27 @@
 package org.bitcoin.stratum;
 
+import com.bitcoinpotato.util.Maps3;
 import com.google.bitcoin.core.ECKey;
 import com.google.bitcoin.core.NetworkParameters;
+import com.google.common.base.Function;
+import play.libs.WS;
 
+import javax.annotation.Nullable;
 import java.math.BigDecimal;
 import java.math.BigInteger;
 import java.util.Collection;
-import java.util.List;
 import java.util.Map;
 
-import static com.google.common.collect.Lists.newArrayList;
+import static com.google.common.base.Preconditions.checkArgument;
 
 public class Stratum {
-    public Stratum(NetworkParameters networkParameters) {
+    public Stratum(NetworkParameters networkParameters, String startumServerUrl) {
         this.networkParameters = networkParameters;
+        this.startumServerUrl = startumServerUrl;
     }
 
     private final NetworkParameters networkParameters;
+    private final String startumServerUrl;
 
     public static BigDecimal satoshisToBitcoin(BigInteger satoshis) {
         return new BigDecimal("0.00000001").multiply(new BigDecimal(satoshis));
@@ -27,24 +32,41 @@ public KeyPair newKeyPair() {
         return new KeyPair(key.toAddress(networkParameters).toString(), key.getPrivKeyBytes());
     }
 
-    /**
-     * Returns a list of all transaction that went to {@code address}, sorted by date.
-     */
-    public List<RemoteTransaction> getRemoteTransactions(String address) {
-        // TODO
-        return newArrayList();
-    }
-
     public void sendTransaction(OutgoingRemoteTransaction outgoingTx) {
+
     }
 
     public AddressInfo getAddressInfo(String publicAddress) {
+        WS.HttpResponse response = null;
+        try {
+            response = WS.url(startumServerUrl)
+                    .setHeader("content-type", "application/stratum")
+                    .setParameter("id", 1)
+                    .setParameter("method", "blockchain.address.get_history")
+                    .setParameter("params", publicAddress)
+                    .timeout("60s")
+                    .post();
+        } catch (Exception e) {
+            throw new RuntimeException("Failure doing Startum.getAddress with address " + publicAddress);
+        }
+
+        checkArgument(response.getStatus() == 200);
+
         // TODO
-        return null;
+        return new AddressInfo(new BigDecimal("0.01"));
     }
 
+    /**
+     * A bulk API version
+     */
     public Map<String, AddressInfo> getAddressInfo(Collection<String> allPublicAddress) {
-        return null;  //To change body of created methods use File | Settings | File Templates.
+        // Naive implementation for now
+
+        return Maps3.build(allPublicAddress, new Function<String, AddressInfo>() {
+            public AddressInfo apply(@Nullable String s) {
+                return null;
+            }
+        });
     }
 
     /**

app/org/bitcoin/stratum/StratumHolder.java

@@ -9,7 +9,7 @@ public class StratumHolder {
     private StratumHolder() {
     }
 
-    public static final Stratum Stratum = new Stratum(readNetworkParameters());
+    public static final Stratum Stratum = new Stratum(readNetworkParameters(), "http://chicago.stratum.bitcoin.cz:8000/");
 
     private static NetworkParameters readNetworkParameters() {
         String network = getNetworkType();

potato.ipr

@@ -1,5 +1,8 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
+  <component name="AntConfiguration">
+    <defaultAnt bundledAnt="true" />
+  </component>
   <component name="CompilerConfiguration">
     <option name="DEFAULT_COMPILER" value="Javac" />
     <resourceExtensions />
@@ -227,7 +230,7 @@
   <component name="ProjectResources">
     <default-html-doctype>http://www.w3.org/1999/xhtml</default-html-doctype>
   </component>
-  <component name="ProjectRootManager" version="2" languageLevel="JDK_1_5" assert-keyword="true" jdk-15="true" project-jdk-name="1.7" project-jdk-type="JavaSDK" />
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_1_7" assert-keyword="true" jdk-15="true" project-jdk-name="1.7" project-jdk-type="JavaSDK" />
   <component name="VcsDirectoryMappings">
     <mapping directory="" vcs="Git" />
   </component>

test/org/bitcoin/stratum/StratumTests.java

@@ -0,0 +1,17 @@
+package org.bitcoin.stratum;
+
+import com.google.bitcoin.core.NetworkParameters;
+import org.junit.Test;
+import play.test.UnitTest;
+
+public class StratumTests extends UnitTest {
+    @Test
+    public void sanity() {
+        Stratum stratum = new Stratum(NetworkParameters.testNet(), "http://chicago.stratum.bitcoin.cz:8000/");
+        String someTestnetAddress = "mw5h6BDh77GUPc4DCmzjoU7ry2R4exoaYr";
+
+        AddressInfo addressInfo = stratum.getAddressInfo(someTestnetAddress);
+
+        System.out.println("Foobar");
+    }
+}