-
Notifications
You must be signed in to change notification settings - Fork 63
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #75 from xoriole/feature/liquidity-pool
Add a new Module for the Liquidity Pool project(s) Closes #56
- Loading branch information
Showing
75 changed files
with
6,230 additions
and
31 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Binary file not shown.
121 changes: 121 additions & 0 deletions
121
common/src/main/java/nl/tudelft/trustchain/common/bitcoin/WalletService.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,121 @@ | ||
| package nl.tudelft.trustchain.common.bitcoin | ||
|
|
||
| import android.util.Log | ||
| import com.google.common.util.concurrent.Service | ||
| import nl.tudelft.ipv8.keyvault.PublicKey | ||
| import nl.tudelft.trustchain.common.BuildConfig | ||
| import nl.tudelft.trustchain.common.eurotoken.TransactionRepository | ||
| import org.bitcoinj.core.ECKey | ||
| import org.bitcoinj.core.PeerAddress | ||
| import org.bitcoinj.kits.WalletAppKit | ||
| import org.bitcoinj.params.RegTestParams | ||
| import java.io.File | ||
| import java.net.InetAddress | ||
|
|
||
| class WalletService { | ||
|
|
||
| companion object { | ||
| private lateinit var globalWallet: WalletAppKit | ||
| private val walletStore: MutableMap<String, WalletAppKit> = mutableMapOf() | ||
| val params: RegTestParams = RegTestParams.get() | ||
| private lateinit var lastDir: File | ||
|
|
||
| /** | ||
| * Creates a global bitcoin wallet | ||
| */ | ||
| fun createGlobalWallet(dir: File) { | ||
| lastDir = dir | ||
| globalWallet = createWallet(dir, "global") | ||
| } | ||
|
|
||
| /** | ||
| * Returns the global bitcoin wallet, [createGlobalWallet] needs to be called at least once first for the correct cache location | ||
| */ | ||
| fun getGlobalWallet(): WalletAppKit { | ||
| globalWallet = createWallet(lastDir, "global") | ||
| return globalWallet | ||
| } | ||
|
|
||
| /** | ||
| * Creates a personal wallet and saves it continuously in the given file. If an app-kit has already | ||
| * started, this function looks up the running app-kit. | ||
| */ | ||
| fun createPersonalWallet(dir: File): WalletAppKit = | ||
| createWallet(dir, "personal") | ||
|
|
||
| /** | ||
| * Creates a wallet with the given name and saves it continuously in the given file. If an app-kit | ||
| * has already started, this function looks up the running app-kit and waits for it to be surely | ||
| * running. | ||
| */ | ||
| fun createWallet(dir: File, name: String): WalletAppKit { | ||
| // If a wallet app-kit was already stored and not terminated, retrieve it. | ||
| if (walletStore.containsKey(name) && | ||
| !setOf( | ||
| Service.State.TERMINATED, | ||
| Service.State.STOPPING, | ||
| Service.State.FAILED | ||
| ).contains(walletStore[name]?.state()) | ||
| ) { | ||
| walletStore[name]!!.awaitRunning() | ||
|
|
||
| return walletStore[name]!! | ||
| } | ||
|
|
||
| // Create an app-kit with testing bitcoins if empty. | ||
| val app = object : WalletAppKit(params, dir, name) { | ||
| override fun onSetupCompleted() { | ||
| if (wallet().keyChainGroupSize < 1) { | ||
| wallet().importKey(ECKey()) | ||
| } | ||
|
|
||
| if (wallet().balance.isZero) { | ||
| val address = wallet().issuedReceiveAddresses.first().toString() | ||
| println("Address:$address") | ||
| // TODO: Fix the faucet | ||
| // URL("${BuildConfig.BITCOIN_FAUCET}?id=$address").readBytes() | ||
| } | ||
| } | ||
| } | ||
|
|
||
| app.setPeerNodes( | ||
| PeerAddress( | ||
| params, | ||
| InetAddress.getByName(BuildConfig.BITCOIN_DEFAULT_PEER), | ||
| params.port | ||
| ) | ||
| ) | ||
|
|
||
| app.setAutoSave(true) | ||
| app.setBlockingStartup(false) | ||
|
|
||
| app.startAsync() | ||
| app.awaitRunning() | ||
|
|
||
| // Store the app-kit in the running wallet store | ||
| walletStore[name] = app | ||
|
|
||
| return app | ||
| } | ||
|
|
||
| /** | ||
| * Initializes the bitcoin side of the liquidity pool | ||
| */ | ||
| fun initializePool(transactionRepository: TransactionRepository, publicKey: PublicKey) { | ||
|
|
||
| // TODO: Look into different listeners, this event is called before the transfer is verified, not sure if this will be an issue | ||
| globalWallet.wallet().addCoinsReceivedEventListener { wallet, tx, _, _ -> | ||
| val transaction = mapOf( | ||
| "bitcoin_tx" to tx!!.txId.toString(), | ||
| "amount" to tx.getValueSentToMe(wallet).toFriendlyString() | ||
| ) | ||
| Log.d("bitcoin_received", "Bitcoins received making a note on my chain") | ||
| transactionRepository.trustChainCommunity.createProposalBlock( | ||
| "bitcoin_transfer", | ||
| transaction, | ||
| publicKey.keyToBin() | ||
| ) | ||
| } | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.