mirror of
https://github.com/aljazceru/breez-sdk-liquid.git
synced 2026-01-19 14:04:22 +01:00
Rename workspace members (subfolders) (#149)
* Rename ls-sdk-bindings workspace member * Rename ls-sdk-core workspace member * Rename ls-sdk-react-native
This commit is contained in:
ok300
@@ -0,0 +1,363 @@
|
||||
package com.breezliquidsdk
|
||||
import breez_liquid_sdk.*
|
||||
import com.facebook.react.bridge.*
|
||||
import java.util.*
|
||||
|
||||
fun asPrepareReceiveRequest(prepareReceiveRequest: ReadableMap): PrepareReceiveRequest? {
|
||||
if (!validateMandatoryFields(
|
||||
prepareReceiveRequest,
|
||||
arrayOf(
|
||||
"payerAmountSat",
|
||||
),
|
||||
)
|
||||
) {
|
||||
return null
|
||||
}
|
||||
val payerAmountSat = prepareReceiveRequest.getDouble("payerAmountSat").toULong()
|
||||
return PrepareReceiveRequest(
|
||||
payerAmountSat,
|
||||
)
|
||||
}
|
||||
|
||||
fun readableMapOf(prepareReceiveRequest: PrepareReceiveRequest): ReadableMap {
|
||||
return readableMapOf(
|
||||
"payerAmountSat" to prepareReceiveRequest.payerAmountSat,
|
||||
)
|
||||
}
|
||||
|
||||
fun asPrepareReceiveRequestList(arr: ReadableArray): List<PrepareReceiveRequest> {
|
||||
val list = ArrayList<PrepareReceiveRequest>()
|
||||
for (value in arr.toArrayList()) {
|
||||
when (value) {
|
||||
is ReadableMap -> list.add(asPrepareReceiveRequest(value)!!)
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun asPrepareReceiveResponse(prepareReceiveResponse: ReadableMap): PrepareReceiveResponse? {
|
||||
if (!validateMandatoryFields(
|
||||
prepareReceiveResponse,
|
||||
arrayOf(
|
||||
"pairHash",
|
||||
"payerAmountSat",
|
||||
"feesSat",
|
||||
),
|
||||
)
|
||||
) {
|
||||
return null
|
||||
}
|
||||
val pairHash = prepareReceiveResponse.getString("pairHash")!!
|
||||
val payerAmountSat = prepareReceiveResponse.getDouble("payerAmountSat").toULong()
|
||||
val feesSat = prepareReceiveResponse.getDouble("feesSat").toULong()
|
||||
return PrepareReceiveResponse(
|
||||
pairHash,
|
||||
payerAmountSat,
|
||||
feesSat,
|
||||
)
|
||||
}
|
||||
|
||||
fun readableMapOf(prepareReceiveResponse: PrepareReceiveResponse): ReadableMap {
|
||||
return readableMapOf(
|
||||
"pairHash" to prepareReceiveResponse.pairHash,
|
||||
"payerAmountSat" to prepareReceiveResponse.payerAmountSat,
|
||||
"feesSat" to prepareReceiveResponse.feesSat,
|
||||
)
|
||||
}
|
||||
|
||||
fun asPrepareReceiveResponseList(arr: ReadableArray): List<PrepareReceiveResponse> {
|
||||
val list = ArrayList<PrepareReceiveResponse>()
|
||||
for (value in arr.toArrayList()) {
|
||||
when (value) {
|
||||
is ReadableMap -> list.add(asPrepareReceiveResponse(value)!!)
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun asPrepareSendResponse(prepareSendResponse: ReadableMap): PrepareSendResponse? {
|
||||
if (!validateMandatoryFields(
|
||||
prepareSendResponse,
|
||||
arrayOf(
|
||||
"id",
|
||||
"payerAmountSat",
|
||||
"receiverAmountSat",
|
||||
"totalFees",
|
||||
"fundingAddress",
|
||||
"invoice",
|
||||
),
|
||||
)
|
||||
) {
|
||||
return null
|
||||
}
|
||||
val id = prepareSendResponse.getString("id")!!
|
||||
val payerAmountSat = prepareSendResponse.getDouble("payerAmountSat").toULong()
|
||||
val receiverAmountSat = prepareSendResponse.getDouble("receiverAmountSat").toULong()
|
||||
val totalFees = prepareSendResponse.getDouble("totalFees").toULong()
|
||||
val fundingAddress = prepareSendResponse.getString("fundingAddress")!!
|
||||
val invoice = prepareSendResponse.getString("invoice")!!
|
||||
return PrepareSendResponse(
|
||||
id,
|
||||
payerAmountSat,
|
||||
receiverAmountSat,
|
||||
totalFees,
|
||||
fundingAddress,
|
||||
invoice,
|
||||
)
|
||||
}
|
||||
|
||||
fun readableMapOf(prepareSendResponse: PrepareSendResponse): ReadableMap {
|
||||
return readableMapOf(
|
||||
"id" to prepareSendResponse.id,
|
||||
"payerAmountSat" to prepareSendResponse.payerAmountSat,
|
||||
"receiverAmountSat" to prepareSendResponse.receiverAmountSat,
|
||||
"totalFees" to prepareSendResponse.totalFees,
|
||||
"fundingAddress" to prepareSendResponse.fundingAddress,
|
||||
"invoice" to prepareSendResponse.invoice,
|
||||
)
|
||||
}
|
||||
|
||||
fun asPrepareSendResponseList(arr: ReadableArray): List<PrepareSendResponse> {
|
||||
val list = ArrayList<PrepareSendResponse>()
|
||||
for (value in arr.toArrayList()) {
|
||||
when (value) {
|
||||
is ReadableMap -> list.add(asPrepareSendResponse(value)!!)
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun asReceivePaymentResponse(receivePaymentResponse: ReadableMap): ReceivePaymentResponse? {
|
||||
if (!validateMandatoryFields(
|
||||
receivePaymentResponse,
|
||||
arrayOf(
|
||||
"id",
|
||||
"invoice",
|
||||
),
|
||||
)
|
||||
) {
|
||||
return null
|
||||
}
|
||||
val id = receivePaymentResponse.getString("id")!!
|
||||
val invoice = receivePaymentResponse.getString("invoice")!!
|
||||
return ReceivePaymentResponse(
|
||||
id,
|
||||
invoice,
|
||||
)
|
||||
}
|
||||
|
||||
fun readableMapOf(receivePaymentResponse: ReceivePaymentResponse): ReadableMap {
|
||||
return readableMapOf(
|
||||
"id" to receivePaymentResponse.id,
|
||||
"invoice" to receivePaymentResponse.invoice,
|
||||
)
|
||||
}
|
||||
|
||||
fun asReceivePaymentResponseList(arr: ReadableArray): List<ReceivePaymentResponse> {
|
||||
val list = ArrayList<ReceivePaymentResponse>()
|
||||
for (value in arr.toArrayList()) {
|
||||
when (value) {
|
||||
is ReadableMap -> list.add(asReceivePaymentResponse(value)!!)
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun asSendPaymentResponse(sendPaymentResponse: ReadableMap): SendPaymentResponse? {
|
||||
if (!validateMandatoryFields(
|
||||
sendPaymentResponse,
|
||||
arrayOf(
|
||||
"txid",
|
||||
),
|
||||
)
|
||||
) {
|
||||
return null
|
||||
}
|
||||
val txid = sendPaymentResponse.getString("txid")!!
|
||||
return SendPaymentResponse(
|
||||
txid,
|
||||
)
|
||||
}
|
||||
|
||||
fun readableMapOf(sendPaymentResponse: SendPaymentResponse): ReadableMap {
|
||||
return readableMapOf(
|
||||
"txid" to sendPaymentResponse.txid,
|
||||
)
|
||||
}
|
||||
|
||||
fun asSendPaymentResponseList(arr: ReadableArray): List<SendPaymentResponse> {
|
||||
val list = ArrayList<SendPaymentResponse>()
|
||||
for (value in arr.toArrayList()) {
|
||||
when (value) {
|
||||
is ReadableMap -> list.add(asSendPaymentResponse(value)!!)
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun asWalletInfo(walletInfo: ReadableMap): WalletInfo? {
|
||||
if (!validateMandatoryFields(
|
||||
walletInfo,
|
||||
arrayOf(
|
||||
"balanceSat",
|
||||
"pubkey",
|
||||
),
|
||||
)
|
||||
) {
|
||||
return null
|
||||
}
|
||||
val balanceSat = walletInfo.getDouble("balanceSat").toULong()
|
||||
val pubkey = walletInfo.getString("pubkey")!!
|
||||
return WalletInfo(
|
||||
balanceSat,
|
||||
pubkey,
|
||||
)
|
||||
}
|
||||
|
||||
fun readableMapOf(walletInfo: WalletInfo): ReadableMap {
|
||||
return readableMapOf(
|
||||
"balanceSat" to walletInfo.balanceSat,
|
||||
"pubkey" to walletInfo.pubkey,
|
||||
)
|
||||
}
|
||||
|
||||
fun asWalletInfoList(arr: ReadableArray): List<WalletInfo> {
|
||||
val list = ArrayList<WalletInfo>()
|
||||
for (value in arr.toArrayList()) {
|
||||
when (value) {
|
||||
is ReadableMap -> list.add(asWalletInfo(value)!!)
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun asNetwork(type: String): Network {
|
||||
return Network.valueOf(type.uppercase())
|
||||
}
|
||||
|
||||
fun asNetworkList(arr: ReadableArray): List<Network> {
|
||||
val list = ArrayList<Network>()
|
||||
for (value in arr.toArrayList()) {
|
||||
when (value) {
|
||||
is String -> list.add(asNetwork(value)!!)
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun readableMapOf(vararg values: Pair<String, *>): ReadableMap {
|
||||
val map = Arguments.createMap()
|
||||
for ((key, value) in values) {
|
||||
pushToMap(map, key, value)
|
||||
}
|
||||
return map
|
||||
}
|
||||
|
||||
fun hasNonNullKey(
|
||||
map: ReadableMap,
|
||||
key: String,
|
||||
): Boolean {
|
||||
return map.hasKey(key) && !map.isNull(key)
|
||||
}
|
||||
|
||||
fun validateMandatoryFields(
|
||||
map: ReadableMap,
|
||||
keys: Array<String>,
|
||||
): Boolean {
|
||||
for (k in keys) {
|
||||
if (!hasNonNullKey(map, k)) return false
|
||||
}
|
||||
|
||||
return true
|
||||
}
|
||||
|
||||
fun pushToArray(
|
||||
array: WritableArray,
|
||||
value: Any?,
|
||||
) {
|
||||
when (value) {
|
||||
null -> array.pushNull()
|
||||
is Array<*> -> array.pushArray(readableArrayOf(value.asIterable()))
|
||||
is List<*> -> array.pushArray(readableArrayOf(value))
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
|
||||
fun pushToMap(
|
||||
map: WritableMap,
|
||||
key: String,
|
||||
value: Any?,
|
||||
) {
|
||||
when (value) {
|
||||
null -> map.putNull(key)
|
||||
is Boolean -> map.putBoolean(key, value)
|
||||
is Byte -> map.putInt(key, value.toInt())
|
||||
is Double -> map.putDouble(key, value)
|
||||
is Int -> map.putInt(key, value)
|
||||
is Long -> map.putDouble(key, value.toDouble())
|
||||
is ReadableArray -> map.putArray(key, value)
|
||||
is ReadableMap -> map.putMap(key, value)
|
||||
is String -> map.putString(key, value)
|
||||
is UByte -> map.putInt(key, value.toInt())
|
||||
is UInt -> map.putInt(key, value.toInt())
|
||||
is UShort -> map.putInt(key, value.toInt())
|
||||
is ULong -> map.putDouble(key, value.toDouble())
|
||||
is Array<*> -> map.putArray(key, readableArrayOf(value.asIterable()))
|
||||
is List<*> -> map.putArray(key, readableArrayOf(value))
|
||||
else -> throw LsSdkException.Generic("Unexpected type ${value::class.java.name} for key [$key]")
|
||||
}
|
||||
}
|
||||
|
||||
fun readableArrayOf(values: Iterable<*>?): ReadableArray {
|
||||
val array = Arguments.createArray()
|
||||
if (values != null) {
|
||||
for (value in values) {
|
||||
pushToArray(array, value)
|
||||
}
|
||||
}
|
||||
|
||||
return array
|
||||
}
|
||||
|
||||
fun asUByteList(arr: ReadableArray): List<UByte> {
|
||||
val list = ArrayList<UByte>()
|
||||
for (value in arr.toArrayList()) {
|
||||
when (value) {
|
||||
is Double -> list.add(value.toInt().toUByte())
|
||||
is Int -> list.add(value.toUByte())
|
||||
is UByte -> list.add(value)
|
||||
else -> throw LsSdkException.Generic(errUnexpectedType("${value::class.java.name}"))
|
||||
}
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun asStringList(arr: ReadableArray): List<String> {
|
||||
val list = ArrayList<String>()
|
||||
for (value in arr.toArrayList()) {
|
||||
list.add(value.toString())
|
||||
}
|
||||
return list
|
||||
}
|
||||
|
||||
fun errMissingMandatoryField(
|
||||
fieldName: String,
|
||||
typeName: String,
|
||||
): String {
|
||||
return "Missing mandatory field $fieldName for type $typeName"
|
||||
}
|
||||
|
||||
fun errUnexpectedType(typeName: String): String {
|
||||
return "Unexpected type $typeName"
|
||||
}
|
||||
|
||||
fun errUnexpectedValue(fieldName: String): String {
|
||||
return "Unexpected value for optional field $fieldName"
|
||||
}
|
||||
@@ -0,0 +1,180 @@
|
||||
package com.breezliquidsdk
|
||||
|
||||
import breez_liquid_sdk.*
|
||||
import com.facebook.react.bridge.*
|
||||
import java.util.*
|
||||
import java.util.concurrent.ExecutorService
|
||||
import java.util.concurrent.Executors
|
||||
|
||||
class BreezLiquidSDKModule(reactContext: ReactApplicationContext) : ReactContextBaseJavaModule(reactContext) {
|
||||
private lateinit var executor: ExecutorService
|
||||
private var bindingWallet: BindingWallet? = null
|
||||
|
||||
companion object {
|
||||
const val TAG = "RNBreezLiquidSDK"
|
||||
}
|
||||
|
||||
override fun initialize() {
|
||||
super.initialize()
|
||||
|
||||
executor = Executors.newFixedThreadPool(3)
|
||||
}
|
||||
|
||||
override fun getName(): String {
|
||||
return TAG
|
||||
}
|
||||
|
||||
@Throws(LsSdkException::class)
|
||||
fun getBindingWallet(): BindingWallet {
|
||||
if (bindingWallet != null) {
|
||||
return bindingWallet!!
|
||||
}
|
||||
|
||||
throw LsSdkException.Generic("Not initialized")
|
||||
}
|
||||
|
||||
@ReactMethod
|
||||
fun addListener(eventName: String) {}
|
||||
|
||||
@ReactMethod
|
||||
fun removeListeners(count: Int) {}
|
||||
|
||||
@ReactMethod
|
||||
fun connect(
|
||||
mnemonic: String,
|
||||
dataDir: String,
|
||||
network: String,
|
||||
promise: Promise,
|
||||
) {
|
||||
if (bindingWallet != null) {
|
||||
promise.reject("Generic", "Already initialized")
|
||||
return
|
||||
}
|
||||
|
||||
executor.execute {
|
||||
try {
|
||||
val dataDirTmp = dataDir.takeUnless { it.isEmpty() } ?: run { reactApplicationContext.filesDir.toString() + "/breezLiquidSdk" }
|
||||
val networkTmp = asNetwork(network)
|
||||
bindingWallet = connect(mnemonic, dataDirTmp, networkTmp)
|
||||
promise.resolve(readableMapOf("status" to "ok"))
|
||||
} catch (e: Exception) {
|
||||
promise.reject(e.javaClass.simpleName.replace("Exception", "Error"), e.message, e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ReactMethod
|
||||
fun getInfo(
|
||||
withScan: Boolean,
|
||||
promise: Promise,
|
||||
) {
|
||||
executor.execute {
|
||||
try {
|
||||
val res = getBindingWallet().getInfo(withScan)
|
||||
promise.resolve(readableMapOf(res))
|
||||
} catch (e: Exception) {
|
||||
promise.reject(e.javaClass.simpleName.replace("Exception", "Error"), e.message, e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ReactMethod
|
||||
fun prepareSendPayment(
|
||||
invoice: String,
|
||||
promise: Promise,
|
||||
) {
|
||||
executor.execute {
|
||||
try {
|
||||
val res = getBindingWallet().prepareSendPayment(invoice)
|
||||
promise.resolve(readableMapOf(res))
|
||||
} catch (e: Exception) {
|
||||
promise.reject(e.javaClass.simpleName.replace("Exception", "Error"), e.message, e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ReactMethod
|
||||
fun sendPayment(
|
||||
req: ReadableMap,
|
||||
promise: Promise,
|
||||
) {
|
||||
executor.execute {
|
||||
try {
|
||||
val prepareSendResponse =
|
||||
asPrepareSendResponse(req) ?: run {
|
||||
throw LsSdkException.Generic(errMissingMandatoryField("req", "PrepareSendResponse"))
|
||||
}
|
||||
val res = getBindingWallet().sendPayment(prepareSendResponse)
|
||||
promise.resolve(readableMapOf(res))
|
||||
} catch (e: Exception) {
|
||||
promise.reject(e.javaClass.simpleName.replace("Exception", "Error"), e.message, e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ReactMethod
|
||||
fun prepareReceivePayment(
|
||||
req: ReadableMap,
|
||||
promise: Promise,
|
||||
) {
|
||||
executor.execute {
|
||||
try {
|
||||
val prepareReceiveRequest =
|
||||
asPrepareReceiveRequest(req) ?: run {
|
||||
throw LsSdkException.Generic(errMissingMandatoryField("req", "PrepareReceiveRequest"))
|
||||
}
|
||||
val res = getBindingWallet().prepareReceivePayment(prepareReceiveRequest)
|
||||
promise.resolve(readableMapOf(res))
|
||||
} catch (e: Exception) {
|
||||
promise.reject(e.javaClass.simpleName.replace("Exception", "Error"), e.message, e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ReactMethod
|
||||
fun receivePayment(
|
||||
req: ReadableMap,
|
||||
promise: Promise,
|
||||
) {
|
||||
executor.execute {
|
||||
try {
|
||||
val prepareReceiveResponse =
|
||||
asPrepareReceiveResponse(req) ?: run {
|
||||
throw LsSdkException.Generic(errMissingMandatoryField("req", "PrepareReceiveResponse"))
|
||||
}
|
||||
val res = getBindingWallet().receivePayment(prepareReceiveResponse)
|
||||
promise.resolve(readableMapOf(res))
|
||||
} catch (e: Exception) {
|
||||
promise.reject(e.javaClass.simpleName.replace("Exception", "Error"), e.message, e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ReactMethod
|
||||
fun backup(promise: Promise) {
|
||||
executor.execute {
|
||||
try {
|
||||
getBindingWallet().backup()
|
||||
promise.resolve(readableMapOf("status" to "ok"))
|
||||
} catch (e: Exception) {
|
||||
promise.reject(e.javaClass.simpleName.replace("Exception", "Error"), e.message, e)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@ReactMethod
|
||||
fun restore(
|
||||
backupPath: String,
|
||||
promise: Promise,
|
||||
) {
|
||||
executor.execute {
|
||||
try {
|
||||
val backupPathTmp = backupPath.takeUnless { it.isEmpty() }
|
||||
getBindingWallet().restore(backupPathTmp)
|
||||
promise.resolve(readableMapOf("status" to "ok"))
|
||||
} catch (e: Exception) {
|
||||
promise.reject(e.javaClass.simpleName.replace("Exception", "Error"), e.message, e)
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -0,0 +1,16 @@
|
||||
package com.breezliquidsdk
|
||||
|
||||
import android.view.View
|
||||
import com.facebook.react.ReactPackage
|
||||
import com.facebook.react.bridge.NativeModule
|
||||
import com.facebook.react.bridge.ReactApplicationContext
|
||||
import com.facebook.react.uimanager.ReactShadowNode
|
||||
import com.facebook.react.uimanager.ViewManager
|
||||
|
||||
class BreezLiquidSDKPackage : ReactPackage {
|
||||
override fun createViewManagers(reactContext: ReactApplicationContext): MutableList<ViewManager<View, ReactShadowNode<*>>> =
|
||||
mutableListOf()
|
||||
|
||||
override fun createNativeModules(reactContext: ReactApplicationContext): MutableList<NativeModule> =
|
||||
listOf(BreezLiquidSDKModule(reactContext)).toMutableList()
|
||||
}
|
||||
Reference in New Issue
Block a user