added test for init sequence

eclair-demo/pom.xml

@@ -56,5 +56,10 @@
             <artifactId>janino</artifactId>
             <version>2.5.10</version>
         </dependency>
+        <dependency>
+            <groupId>com.typesafe.akka</groupId>
+            <artifactId>akka-testkit_${scala.version.short}</artifactId>
+            <version>${akka.version}</version>
+        </dependency>
     </dependencies>
 </project>

eclair-demo/src/test/resources/logback.xml

@@ -0,0 +1,15 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<configuration scan="true" debug="false">
+
+    <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
+        <target>System.out</target>
+        <encoder>
+            <pattern>%d %-5level %logger{36} %X{akkaSource} - %msg%ex{12}%n</pattern>
+        </encoder>
+    </appender>
+
+    <root level="DEBUG">
+        <appender-ref ref="CONSOLE"/>
+    </root>
+
+</configuration>

eclair-demo/src/test/scala/fr/acinq/eclair/ChannelOpenSpec.scala

@@ -0,0 +1,74 @@
+package fr.acinq.eclair
+
+import akka.actor.{Props, ActorSystem}
+import akka.testkit.{TestKit, ImplicitSender}
+import com.google.protobuf.ByteString
+import fr.acinq.bitcoin._
+import fr.acinq.lightning._
+import lightning.locktime.Locktime.Blocks
+import lightning._
+import lightning.open_channel.anchor_offer.WILL_CREATE_ANCHOR
+import org.bouncycastle.util.encoders.Hex
+import org.scalatest.{BeforeAndAfterAll, WordSpecLike, Matchers}
+
+/**
+ * Created by PM on 02/09/2015.
+ */
+class ChannelOpenSpec(_system: ActorSystem) extends TestKit(_system) with ImplicitSender with WordSpecLike with Matchers with BeforeAndAfterAll {
+
+  def this() = this(ActorSystem("MySpec"))
+
+  override def afterAll {
+    TestKit.shutdownActorSystem(system)
+  }
+
+  val anchorInput = AnchorInput(100100000L, OutPoint(Hex.decode("7727730d21428276a4d6b0e16f3a3e6f3a07a07dc67151e6a88d4a8c3e8edb24").reverse, 1), SignData("76a914e093fbc19866b98e0fbc25d79d0ad0f0375170af88ac", Base58Check.decode("cU1YgK56oUKAtV6XXHZeJQjEx1KGXkZS1pGiKpyW4mUyKYFJwWFg")._2))
+
+  val bob_commit_priv = Base58Check.decode("cSUwLtdZ2tht9ZmHhdQue48pfe7tY2GT2TGWJDtjoZgo6FHrubGk")._2
+  val bob_final_priv = Base58Check.decode("cPR7ZgXpUaDPA3GwGceMDS5pfnSm955yvks3yELf3wMJwegsdGTg")._2
+
+  val our_delay = locktime(Blocks(1))
+  val our_mindepth = 2
+  val our_commitment_fee = 100000
+  val commitPrivKey = Base58Check.decode("cQPmcNr6pwBQPyGfab3SksE9nTCtx9ism9T4dkS9dETNU2KKtJHk")._2
+  val our_commitkey_pub = bitcoin_pubkey(ByteString.copyFrom(Crypto.publicKeyFromPrivateKey(commitPrivKey.key.toByteArray)))
+  val our_finalkey_priv = Base58Check.decode("cUrAtLtV7GGddqdkhUxnbZVDWGJBTducpPoon3eKp9Vnr1zxs6BG")._2
+  val our_finalkey_pub = bitcoin_pubkey(ByteString.copyFrom(Crypto.publicKeyFromPrivateKey(our_finalkey_priv.key.toByteArray)))
+
+  val ourParams = ChannelParams(our_delay, our_commitkey_pub, our_finalkey_pub, our_mindepth, our_commitment_fee)
+
+  "Bob" must {
+
+    "correctly open a channel in ANCHOR_NOINPUT" in {
+      val bob = system.actorOf(Props(new Node(self, bob_commit_priv, bob_final_priv, 2, None)), name = "bob")
+      bob ! INPUT_NONE
+      val their_open_channel = expectMsgClass(classOf[open_channel])
+      val theirParams = ChannelParams(their_open_channel.delay, their_open_channel.commitKey, their_open_channel.finalKey, their_open_channel.minDepth.get, their_open_channel.commitmentFee)
+      val theirRevocationHash = their_open_channel.revocationHash
+      val ourRevocationHashPreimage = sha256_hash(4, 3, 2, 1)
+      val ourRevocationHash = Crypto.sha256(ourRevocationHashPreimage)
+      bob ! open_channel(ourParams.delay, ourRevocationHash, ourParams.commitKey, ourParams.finalKey, WILL_CREATE_ANCHOR, Some(ourParams.minDepth), ourParams.commitmentFee)
+      val anchorTx = makeAnchorTx(ourParams.commitKey, theirParams.commitKey, anchorInput.amount, anchorInput.previousTxOutput, anchorInput.signData)
+      val anchorOutputIndex = 0
+      // we fund the channel with the anchor tx, so the money is ours
+      val state = ChannelState(them = ChannelOneSide(0, 0, Seq()), us = ChannelOneSide(anchorInput.amount - our_commitment_fee, 0, Seq()))
+      // we build our commitment tx, leaving it unsigned
+      val ourCommitTx = makeCommitTx(ourParams.finalKey, theirParams.finalKey, theirParams.delay, anchorTx.hash, anchorOutputIndex, Crypto.sha256(ourRevocationHashPreimage), state)
+      //val ourCommitTx = makeCommitTx(ourParams.finalKey, theirParams.finalKey, theirParams.delay, anchorTx.hash, anchorOutputIndex, theirRevocationHash, state)
+      // then we build their commitment tx and sign it
+      val theirCommitTx = makeCommitTx(theirParams.finalKey, ourParams.finalKey, ourParams.delay, anchorTx.hash, anchorOutputIndex, theirRevocationHash, state.reverse)
+      //val theirCommitTx = makeCommitTx(theirParams.finalKey, ourParams.finalKey, ourParams.delay, anchorTx.hash, anchorOutputIndex, Crypto.sha256(ourRevocationHashPreimage), state.reverse)
+      val ourSigForThem = bin2signature(Transaction.signInput(theirCommitTx, 0, multiSig2of2(ourParams.commitKey, theirParams.commitKey), SIGHASH_ALL, commitPrivKey))
+      bob ! open_anchor(anchorTx.hash, 0, anchorInput.amount, ourSigForThem)
+      expectMsgClass(classOf[open_commit_sig])
+      expectMsgClass(classOf[Watch])
+      bob ! BITCOIN_ANCHOR_DEPTHOK
+      expectMsgClass(classOf[open_complete])
+      bob ! open_complete(None)
+      bob ! CMD_GETSTATE
+      expectMsg(NORMAL_LOWPRIO)
+    }
+
+  }
+
+}