Fix sample and use local oracle

docker-compose.yml

@@ -23,6 +23,47 @@ services:
       - bitcoind-data:/home/bitcoin/.bitcoin
     ports:
       - 3004:3004
+  oracle-server:
+    image: ghcr.io/p2pderivatives/oracle:v0.2.3
+    profiles: [oracle]
+    command: |
+      -config /config
+      -appname p2pdoracle
+      -e integration
+      -migrate
+    environment:
+      - P2PDORACLE_DATABASE_HOST=oracle-db
+      - P2PDORACLE_ORACLE_KEYFILE=/key/key.pem
+      - P2PDORACLE_ORACLE_KEYPASS_FILE=/key/pass.txt
+    restart: always
+    depends_on:
+      - oracle-db
+    ports:
+      - 8080:8080
+    volumes:
+      - ./testconfig/oracle:/config
+      - ./testconfig/oracle/certs/oracle:/key
+
+  oracle-db:
+    image: "postgres:12.2"
+    profiles: [oracle]
+    command: |
+      -c log_statement=all
+      -c ssl=on
+      -c ssl_cert_file=/certs/db.crt
+      -c ssl_key_file=/certs/db.key
+    restart: always
+    ports:
+      - 5432:5432
+    environment:
+      - POSTGRES_USER=postgres
+      - POSTGRES_PASSWORD=1234
+      - POSTGRES_DB=db
+    volumes:
+      - oracle-db-data:/var/lib/postgresql/data/ # persist data even if container shuts down
+      - ./testconfig/oracle/certs/db:/certs
+
 
 volumes:
   bitcoind-data:
+  oracle-db-data:

sample/Cargo.toml

@@ -20,3 +20,8 @@ serde_json = "1.0"
 serde_yaml = "0.9.14"
 time = "0.3.16"
 tokio = {version = "1.5", features = ["io-util", "macros", "rt", "rt-multi-thread", "sync", "net", "time"]}
+
+[dev-dependencies]
+assert_cmd = "2.0.12"
+rexpect = "0.5.0"
+predicates = "3.0.3"

sample/Readme.md

@@ -8,10 +8,10 @@ Example configurations and contract input are available in the [examples](./exam
 
 ## Quick run
 
-To give a quick try to this sample, run the following set of commands (assuming that the working directory is the one in which this readme is located and that docker or podman is available on your machine):
+To give a quick try to this sample, run the following set of commands (assuming that the working directory is the one in which this readme is located and that docker and docker-compose is available on your machine):
 
 ```bash
-../scripts/start_node.sh
+docker-compose --profile oracle up -d
 ../scripts/create_wallets.sh
 cargo run ./examples/configurations/alice.yml
 ```
@@ -21,6 +21,8 @@ In a different terminal:
 cargo run ./examples/configurations/bob.yml
 ```
 
+Update the [example contract](./examples/contracts/numerical_contract_input.json#L82) replacing the number after `btcusd` with a unix timestamp sometimes in the future (this will correspond to the contract maturity date).
+
 ### On chain DLC
 
 From the second instance (Bob), type:
@@ -114,4 +116,4 @@ In the other terminal, use the `listrenewchanneloffers` to display the received
 To accept the offer, use the `acceptrenewchanneloffer` passing the channel id as a parameter.
 Three messages need to be exchanged between the peers to properly settle the channel, press `Enter` once in the terminal where the settle offer was made, once where the settle offer was received and once more where the settle offer was made for the settlement to be finalized. 
 
-To reject the offer, use the `rejectrenewchanneloffer` command, passing the channel id as a parameter.
+To reject the offer, use the `rejectrenewchanneloffer` command, passing the channel id as a parameter.

sample/examples/configurations/alice.yml

@@ -9,4 +9,4 @@ networkConfiguration:
   peerListeningPort: 9000
 network: regtest
 oracleConfig:
-  host: 'https://oracle.p2pderivatives.io/'
+  host: 'http://localhost:8080/'

sample/examples/configurations/bob.yml

@@ -9,4 +9,4 @@ networkConfiguration:
   peerListeningPort: 9001
 network: regtest
 oracleConfig:
-  host: 'https://oracle.p2pderivatives.io/'
+  host: 'http://localhost:8080/'

sample/examples/contracts/numerical_contract_input.json

@@ -1,7 +1,6 @@
 {
   "offerCollateral": 100000000,
   "acceptCollateral": 100000000,
-  "maturityTime": 1653378780,
   "feeRate": 2,
   "contractInfos": [
     {
@@ -76,9 +75,9 @@
       },
       "oracles": {
         "publicKeys": [
-          "ce4b7ad2b45de01f0897aa716f67b4c2f596e54506431e693f898712fe7e9bf3"
+          "0d829c1cc556aa59060df5a9543c5357199ace5db9bcd5a8ddd6ee2fc7b6d174"
         ],
-        "eventId": "btcusd1653378780",
+        "eventId": "btcusd1707120297",
         "threshold": 1
       }
     }

sample/src/main.rs

@@ -5,14 +5,14 @@ mod hex_utils;
 use disk::FilesystemLogger;
 
 use bitcoin::secp256k1::rand::{thread_rng, RngCore};
-use bitcoin::secp256k1::{PublicKey, Secp256k1, SecretKey};
+use bitcoin::secp256k1::SecretKey;
 use bitcoin_rpc_provider::BitcoinCoreProvider;
 use dlc_manager::{Oracle, SystemTimeProvider};
 use dlc_messages::message_handler::MessageHandler as DlcMessageHandler;
 use lightning::ln::peer_handler::{
     ErroringMessageHandler, IgnoringMessageHandler, MessageHandler, PeerManager as LdkPeerManager,
 };
-use lightning::sign::KeysManager;
+use lightning::sign::{KeysManager, NodeSigner};
 use lightning_net_tokio::SocketDescriptor;
 use p2pd_oracle_client::P2PDOracleClient;
 use std::collections::hash_map::HashMap;
@@ -115,10 +115,6 @@ async fn main() {
 
     // Setup a handler for the DLC messages that will be sent/received through LDK.
     let dlc_message_handler = Arc::new(DlcMessageHandler::new());
-    println!(
-        "Node public key: {}",
-        PublicKey::from_secret_key(&Secp256k1::new(), &sk)
-    );
 
     let time = SystemTime::now()
         .duration_since(SystemTime::UNIX_EPOCH)
@@ -130,6 +126,11 @@ async fn main() {
         time.as_nanos() as u32,
     ));
 
+    println!(
+        "Node public key: {}",
+        km.get_node_id(lightning::sign::Recipient::Node).unwrap()
+    );
+
     // The peer manager helps us establish connections and communicate with our peers.
     let peer_manager: Arc<PeerManager> = Arc::new(PeerManager::new(
         MessageHandler {