Merge branch 'master' into product-detecting
This commit is contained in:
commit
ce6b78d045
9 changed files with 39 additions and 28 deletions
|
@ -1,6 +1,7 @@
|
|||
package im.angry.openeuicc.core
|
||||
|
||||
import im.angry.openeuicc.util.*
|
||||
import net.typeblog.lpac_jni.ApduInterface
|
||||
import net.typeblog.lpac_jni.LocalProfileAssistant
|
||||
|
||||
interface EuiccChannel {
|
||||
|
@ -28,5 +29,10 @@ interface EuiccChannel {
|
|||
*/
|
||||
val intrinsicChannelName: String?
|
||||
|
||||
/**
|
||||
* The underlying APDU interface for this channel
|
||||
*/
|
||||
val apduInterface: ApduInterface
|
||||
|
||||
fun close()
|
||||
}
|
|
@ -1,6 +1,7 @@
|
|||
package im.angry.openeuicc.core
|
||||
|
||||
import im.angry.openeuicc.util.*
|
||||
import im.angry.openeuicc.util.UiccPortInfoCompat
|
||||
import im.angry.openeuicc.util.decodeHex
|
||||
import kotlinx.coroutines.flow.Flow
|
||||
import net.typeblog.lpac_jni.ApduInterface
|
||||
import net.typeblog.lpac_jni.LocalProfileAssistant
|
||||
|
@ -11,7 +12,7 @@ class EuiccChannelImpl(
|
|||
override val type: String,
|
||||
override val port: UiccPortInfoCompat,
|
||||
override val intrinsicChannelName: String?,
|
||||
private val apduInterface: ApduInterface,
|
||||
override val apduInterface: ApduInterface,
|
||||
verboseLoggingFlow: Flow<Boolean>,
|
||||
ignoreTLSCertificateFlow: Flow<Boolean>
|
||||
) : EuiccChannel {
|
||||
|
|
|
@ -1,6 +1,7 @@
|
|||
package im.angry.openeuicc.core
|
||||
|
||||
import im.angry.openeuicc.util.*
|
||||
import net.typeblog.lpac_jni.ApduInterface
|
||||
import net.typeblog.lpac_jni.LocalProfileAssistant
|
||||
|
||||
class EuiccChannelWrapper(orig: EuiccChannel) : EuiccChannel {
|
||||
|
@ -33,6 +34,8 @@ class EuiccChannelWrapper(orig: EuiccChannel) : EuiccChannel {
|
|||
get() = channel.valid
|
||||
override val intrinsicChannelName: String?
|
||||
get() = channel.intrinsicChannelName
|
||||
override val apduInterface: ApduInterface
|
||||
get() = channel.apduInterface
|
||||
override val atr: ByteArray?
|
||||
get() = channel.atr
|
||||
|
||||
|
|
|
@ -7,9 +7,9 @@ import android.util.Log
|
|||
import im.angry.openeuicc.util.*
|
||||
import kotlinx.coroutines.flow.Flow
|
||||
import kotlinx.coroutines.flow.first
|
||||
import kotlinx.coroutines.flow.single
|
||||
import kotlinx.coroutines.runBlocking
|
||||
import net.typeblog.lpac_jni.ApduInterface
|
||||
import java.util.concurrent.atomic.AtomicInteger
|
||||
|
||||
class OmapiApduInterface(
|
||||
private val service: SEService,
|
||||
|
@ -21,8 +21,12 @@ class OmapiApduInterface(
|
|||
}
|
||||
|
||||
private lateinit var session: Session
|
||||
private val channels = mutableMapOf<Int, Channel>()
|
||||
private val index = AtomicInteger(0)
|
||||
private val channels = arrayOf<Channel?>(
|
||||
null,
|
||||
null,
|
||||
null,
|
||||
null,
|
||||
)
|
||||
|
||||
override val valid: Boolean
|
||||
get() = service.isConnected && (this::session.isInitialized && !session.isClosed)
|
||||
|
@ -41,23 +45,22 @@ class OmapiApduInterface(
|
|||
override fun logicalChannelOpen(aid: ByteArray): Int {
|
||||
val channel = session.openLogicalChannel(aid)
|
||||
check(channel != null) { "Failed to open logical channel (${aid.encodeHex()})" }
|
||||
val id = index.addAndGet(1)
|
||||
channels[id] = channel
|
||||
return id
|
||||
val index = channels.indexOf(null)
|
||||
check(index != -1) { "No free logical channel slots" }
|
||||
synchronized(channels) { channels[index] = channel }
|
||||
return index
|
||||
}
|
||||
|
||||
override fun logicalChannelClose(handle: Int) {
|
||||
val channel = channels[handle]
|
||||
val channel = channels.getOrNull(handle)
|
||||
check(channel != null) { "Invalid logical channel handle $handle" }
|
||||
channels.remove(handle)
|
||||
if (channel.isOpen) channel.close()
|
||||
synchronized(channels) { channels[handle] = null }
|
||||
}
|
||||
|
||||
override fun transmit(handle: Int, tx: ByteArray): ByteArray {
|
||||
val channel = channels[handle]
|
||||
check(channel != null) {
|
||||
"Invalid logical channel handle $handle"
|
||||
}
|
||||
val channel = channels.getOrNull(handle)
|
||||
check(channel != null) { "Invalid logical channel handle $handle" }
|
||||
|
||||
if (runBlocking { verboseLoggingFlow.first() }) {
|
||||
Log.d(TAG, "OMAPI APDU: ${tx.encodeHex()}")
|
||||
|
|
|
@ -32,8 +32,8 @@ fun getESTKmeInfo(iface: ApduInterface): ESTKmeInfo? {
|
|||
return b.sliceArray(0 until b.size - 2).decodeToString()
|
||||
}
|
||||
return try {
|
||||
iface.openChannel("A06573746B6D65FFFFFFFFFFFF6D6774".decodeHex()) {
|
||||
fun invoke(p1: Byte) = decode(it.transmit(byteArrayOf(0x00, 0x00, p1, 0x00, 0x00)))
|
||||
iface.withLogicalChannel("A06573746B6D65FFFFFFFFFFFF6D6774".decodeHex()) { transmit ->
|
||||
fun invoke(p1: Byte) = decode(transmit(byteArrayOf(0x00, 0x00, p1, 0x00, 0x00)))
|
||||
ESTKmeInfo(
|
||||
invoke(0x00), // serial number
|
||||
invoke(0x01), // bootloader version
|
||||
|
|
|
@ -17,18 +17,12 @@ interface ApduInterface {
|
|||
*/
|
||||
val valid: Boolean
|
||||
|
||||
fun <T> openChannel(aid: ByteArray, callback: (TransmitProvider) -> T): T {
|
||||
fun <T> withLogicalChannel(aid: ByteArray, callback: ((ByteArray) -> ByteArray) -> T): T {
|
||||
val handle = logicalChannelOpen(aid)
|
||||
return try {
|
||||
callback(object : TransmitProvider {
|
||||
override fun transmit(tx: ByteArray) = transmit(handle, tx)
|
||||
})
|
||||
callback { tx -> transmit(handle, tx) }
|
||||
} finally {
|
||||
logicalChannelClose(handle)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
interface TransmitProvider {
|
||||
fun transmit(tx: ByteArray): ByteArray
|
||||
}
|
|
@ -53,20 +53,23 @@ apdu_interface_logical_channel_open(struct euicc_ctx *ctx, const uint8_t *aid, u
|
|||
jint ret = (*env)->CallIntMethod(env, LPAC_JNI_CTX(ctx)->apdu_interface,
|
||||
method_apdu_logical_channel_open, jbarr);
|
||||
LPAC_JNI_EXCEPTION_RETURN;
|
||||
LPAC_JNI_CTX(ctx)->logical_channel_id = ret;
|
||||
return ret;
|
||||
}
|
||||
|
||||
static void apdu_interface_logical_channel_close(struct euicc_ctx *ctx, uint8_t channel) {
|
||||
static void apdu_interface_logical_channel_close(struct euicc_ctx *ctx,
|
||||
__attribute__((unused)) uint8_t channel) {
|
||||
LPAC_JNI_SETUP_ENV;
|
||||
jint logical_channel_id = LPAC_JNI_CTX(ctx)->logical_channel_id;
|
||||
(*env)->CallVoidMethod(env, LPAC_JNI_CTX(ctx)->apdu_interface,
|
||||
method_apdu_logical_channel_close, channel);
|
||||
method_apdu_logical_channel_close, logical_channel_id);
|
||||
(*env)->ExceptionClear(env);
|
||||
}
|
||||
|
||||
static int
|
||||
apdu_interface_transmit(struct euicc_ctx *ctx, uint8_t **rx, uint32_t *rx_len, const uint8_t *tx,
|
||||
uint32_t tx_len) {
|
||||
const int logic_channel = ctx->apdu._internal.logic_channel;
|
||||
const int logic_channel = LPAC_JNI_CTX(ctx)->logical_channel_id;
|
||||
LPAC_JNI_SETUP_ENV;
|
||||
jbyteArray txArr = (*env)->NewByteArray(env, tx_len);
|
||||
(*env)->SetByteArrayRegion(env, txArr, 0, tx_len, (const jbyte *) tx);
|
||||
|
|
|
@ -28,7 +28,7 @@ jint JNI_OnLoad(JavaVM *vm, void *reserved) {
|
|||
string_constructor = (*env)->GetMethodID(env, string_class, "<init>",
|
||||
"([BLjava/lang/String;)V");
|
||||
|
||||
const char _unused[1];
|
||||
const jchar _unused[1];
|
||||
empty_string = (*env)->NewString(env, _unused, 0);
|
||||
empty_string = (*env)->NewGlobalRef(env, empty_string);
|
||||
|
||||
|
|
|
@ -8,6 +8,7 @@ _Static_assert(sizeof(void *) <= sizeof(jlong),
|
|||
"jlong must be big enough to hold a platform raw pointer");
|
||||
|
||||
struct lpac_jni_ctx {
|
||||
jint logical_channel_id;
|
||||
jobject apdu_interface;
|
||||
jobject http_interface;
|
||||
};
|
||||
|
|
Loading…
Add table
Reference in a new issue