Package org.ngengine.platform
Class NGEPlatform
- java.lang.Object
-
- org.ngengine.platform.NGEPlatform
-
public abstract class NGEPlatform extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description NGEPlatform()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Deprecated Methods Modifier and Type Method Description abstract byte[]aes256cbc(byte[] key, byte[] iv, byte[] data, boolean forEncryption)Encrypts or decrypts data using AES-256 in CBC mode with PKCS7 padding.<T> AsyncTask<java.util.List<T>>awaitAll(java.util.List<AsyncTask<T>> promises)Waits for all promises to resolve.<T> AsyncTask<java.util.List<AsyncTask<T>>>awaitAllSettled(java.util.List<AsyncTask<T>> promises)Awaits for all promises to settle (either resolve or reject).<T> AsyncTask<T>awaitAny(java.util.List<AsyncTask<T>> promises)Waits for any promise to resolve.<T> AsyncTask<T>awaitAny(java.util.List<AsyncTask<T>> promises, java.util.function.Predicate<T> filter)Waits for any promise to resolve and match the filter.abstract byte[]base64decode(java.lang.String data)abstract java.lang.Stringbase64encode(byte[] data)voidcallFunction(java.lang.String function, java.lang.Object args, java.util.function.Consumer<java.lang.Object> res, java.util.function.Consumer<java.lang.Throwable> rej)Run platform specific scriptvoidcanCallFunction(java.lang.String function, java.util.function.Consumer<java.lang.Boolean> res)abstract byte[]chacha20(byte[] key, byte[] nonce, byte[] data, boolean forEncryption)abstract <T> TfromJSON(java.lang.String json, java.lang.Class<T> claz)abstract byte[]generatePrivateKey()abstract byte[]genPubKey(byte[] secKey)static NGEPlatformget()static BrowserInterceptorgetBrowserInterceptor()abstract VStoregetCacheStore(java.lang.String appName, java.lang.String cacheName)abstract AsyncTask<java.lang.String>getClipboardContent()abstract VStoregetDataStore(java.lang.String appName, java.lang.String storeName)MemoryLimitsgetMemoryLimits()abstract NGEAllocatorgetNativeAllocator()abstract java.lang.StringgetPlatformName()static VStoreInterceptorgetStoreInterceptor()abstract longgetTimestampSeconds()ExecutionQueuegetVStoreQueue()abstract byte[]hkdf_expand(byte[] prk, byte[] info, int length)abstract byte[]hkdf_extract(byte[] salt, byte[] ikm)abstract byte[]hmac(byte[] key, byte[] data1, byte[] data2)AsyncTask<java.lang.String>httpGet(java.lang.String url, java.time.Duration timeout, java.util.Map<java.lang.String,java.lang.String> headers)AsyncTask<byte[]>httpGetBytes(java.lang.String url, java.time.Duration timeout, java.util.Map<java.lang.String,java.lang.String> headers)Deprecated.abstract AsyncTask<NGEHttpResponse>httpRequest(java.lang.String method, java.lang.String inurl, byte[] body, java.time.Duration timeout, java.util.Map<java.lang.String,java.lang.String> headers)abstract AsyncTask<NGEHttpResponseStream>httpRequestStream(java.lang.String method, java.lang.String inurl, byte[] body, java.time.Duration timeout, java.util.Map<java.lang.String,java.lang.String> headers)booleanisLoopbackAddress(java.net.URI uri)Checks if the given URI is a loopback address.AsyncExecutornewAsyncExecutor()abstract AsyncExecutornewAsyncExecutor(java.lang.Object hint)abstract <T> java.util.Queue<T>newConcurrentQueue(java.lang.Class<T> claz)ExecutionQueuenewExecutionQueue()ExecutionQueuenewExecutionQueue(AsyncExecutor exc)AsyncExecutornewPoolExecutor()Deprecated.usenewAsyncExecutor(Object)insteadAsyncExecutornewRelayExecutor()Deprecated.usenewAsyncExecutor(Object)insteadabstract RTCTransportnewRTCTransport(java.time.Duration p2pAttemptTimeout, java.lang.String connId, java.util.Collection<java.lang.String> stunServers)AsyncExecutornewSignerExecutor()Deprecated.usenewAsyncExecutor(Object)insteadAsyncExecutornewSubscriptionExecutor()Deprecated.usenewAsyncExecutor(Object)insteadabstract WebsocketTransportnewTransport()abstract java.lang.Stringnfkc(java.lang.String str)abstract voidopenInWebBrowser(java.lang.String url)abstract java.io.InputStreamopenResource(java.lang.String resourceName)voidpanic(java.lang.String err)abstract <T> AsyncTask<T>promisify(java.util.function.BiConsumer<java.util.function.Consumer<T>,java.util.function.Consumer<java.lang.Throwable>> func, AsyncExecutor executor)abstract byte[]randomBytes(int n)abstract java.lang.RunnableregisterFinalizer(java.lang.Object obj, java.lang.Runnable finalizer)voidrunInThread(java.lang.Thread thread, java.util.function.Consumer<java.lang.Runnable> enqueue, java.lang.Runnable action)abstract java.lang.StringschnorrSign(java.lang.String data, byte[] privKey)abstract AsyncTask<java.lang.String>schnorrSignAsync(java.lang.String data, byte[] privKey)abstract booleanschnorrVerify(java.lang.String data, java.lang.String sign, byte[] pubKey)abstract AsyncTask<java.lang.Boolean>schnorrVerifyAsync(java.lang.String data, java.lang.String sign, byte[] pubKey)abstract byte[]scrypt(byte[] P, byte[] S, int N, int r, int p, int dkLen)abstract booleansecp256k1PrivateKeyVerify(byte[] privateKey)Verifies whether a secp256k1 private key is valid.abstract byte[]secp256k1PublicKeyCreate(byte[] privateKey, boolean compressed)Derives a secp256k1 public key from a private key.abstract booleansecp256k1PublicKeyVerify(byte[] publicKey)Verifies whether a secp256k1 public key is valid.abstract byte[]secp256k1RecoverPublicKey(byte[] hash32, byte[] signature64, int recoveryId, boolean compressed)Recovers a secp256k1 public key from hash + recoverable signature.abstract byte[]secp256k1SharedSecret(byte[] privKey, byte[] pubKey)abstract Secp256k1RecoverableSignaturesecp256k1SignRecoverable(byte[] hash32, byte[] privateKey)Signs a 32-byte hash with ECDSA over secp256k1 and returns a recoverable signature.static voidset(NGEPlatform platform)static voidsetBrowserInterceptor(BrowserInterceptor interceptor)abstract voidsetClipboardContent(java.lang.String data)static voidsetStoreInterceptor(VStoreInterceptor interceptor)abstract byte[]sha256(byte[] data)abstract java.lang.Stringsha256(java.lang.String data)java.lang.Stringsign(java.lang.String data, byte[] privKey)Deprecated.AsyncTask<java.lang.String>signAsync(java.lang.String data, byte[] privKey)Deprecated.abstract java.lang.StringtoJSON(java.util.Collection obj)abstract java.lang.StringtoJSON(java.util.Map obj)booleanverify(java.lang.String data, java.lang.String sign, byte[] pubKey)Deprecated.AsyncTask<java.lang.Boolean>verifyAsync(java.lang.String data, java.lang.String sign, byte[] pubKey)Deprecated.abstract <T> AsyncTask<T>wrapPromise(java.util.function.BiConsumer<java.util.function.Consumer<T>,java.util.function.Consumer<java.lang.Throwable>> func)abstract byte[]xchacha20poly1305(byte[] key, byte[] nonce, byte[] data, byte[] associatedData, boolean forEncryption)
-
-
-
Method Detail
-
set
public static void set(NGEPlatform platform)
-
get
public static NGEPlatform get()
-
setBrowserInterceptor
public static void setBrowserInterceptor(BrowserInterceptor interceptor)
-
getBrowserInterceptor
public static BrowserInterceptor getBrowserInterceptor()
-
setStoreInterceptor
public static void setStoreInterceptor(VStoreInterceptor interceptor)
-
getStoreInterceptor
public static VStoreInterceptor getStoreInterceptor()
-
generatePrivateKey
public abstract byte[] generatePrivateKey()
-
genPubKey
public abstract byte[] genPubKey(byte[] secKey)
-
toJSON
public abstract java.lang.String toJSON(java.util.Collection obj)
-
toJSON
public abstract java.lang.String toJSON(java.util.Map obj)
-
fromJSON
public abstract <T> T fromJSON(java.lang.String json, java.lang.Class<T> claz)
-
secp256k1SharedSecret
public abstract byte[] secp256k1SharedSecret(byte[] privKey, byte[] pubKey)
-
secp256k1PrivateKeyVerify
public abstract boolean secp256k1PrivateKeyVerify(byte[] privateKey)
Verifies whether a secp256k1 private key is valid. A key is valid if it is 32 bytes long and its integer value is in [1, n-1], where n is the secp256k1 curve order.- Parameters:
privateKey- raw private key (32 bytes)- Returns:
- true if valid, otherwise false
-
secp256k1PublicKeyVerify
public abstract boolean secp256k1PublicKeyVerify(byte[] publicKey)
Verifies whether a secp256k1 public key is valid. It must be an SEC1 compressed key (33 bytes) or uncompressed key (65 bytes), decodable on the curve and not at infinity.- Parameters:
publicKey- SEC1 compressed or uncompressed public key- Returns:
- true if valid, otherwise false
-
secp256k1PublicKeyCreate
public abstract byte[] secp256k1PublicKeyCreate(byte[] privateKey, boolean compressed)Derives a secp256k1 public key from a private key.- Parameters:
privateKey- raw private key (32 bytes), validcompressed- true for compressed output (33 bytes), false for uncompressed output (65 bytes)- Returns:
- SEC1 public key in the requested format
- Throws:
java.lang.IllegalArgumentException- if the private key is invalid
-
secp256k1SignRecoverable
public abstract Secp256k1RecoverableSignature secp256k1SignRecoverable(byte[] hash32, byte[] privateKey)
Signs a 32-byte hash with ECDSA over secp256k1 and returns a recoverable signature. The signature must be in compact 64-byte format: r(32) || s(32), with low-S normalization (BIP-62 style) for cross-platform stability. recoveryId must be in [0..3].- Parameters:
hash32- message hash (exactly 32 bytes)privateKey- raw private key (32 bytes), valid- Returns:
- recoverable signature containing signature64 and recoveryId
- Throws:
java.lang.IllegalArgumentException- if inputs are invalid
-
secp256k1RecoverPublicKey
public abstract byte[] secp256k1RecoverPublicKey(byte[] hash32, byte[] signature64, int recoveryId, boolean compressed)Recovers a secp256k1 public key from hash + recoverable signature.- Parameters:
hash32- message hash (exactly 32 bytes)signature64- compact 64-byte signature: r||srecoveryId- recovery id in [0..3]compressed- true for compressed output (33 bytes), false for uncompressed output (65 bytes)- Returns:
- recovered public key in the requested format
- Throws:
java.lang.IllegalArgumentException- if inputs are invalid or recovery is impossible
-
hmac
public abstract byte[] hmac(byte[] key, byte[] data1, byte[] data2)
-
hkdf_extract
public abstract byte[] hkdf_extract(byte[] salt, byte[] ikm)
-
hkdf_expand
public abstract byte[] hkdf_expand(byte[] prk, byte[] info, int length)
-
base64encode
public abstract java.lang.String base64encode(byte[] data)
-
base64decode
public abstract byte[] base64decode(java.lang.String data)
-
chacha20
public abstract byte[] chacha20(byte[] key, byte[] nonce, byte[] data, boolean forEncryption)
-
newTransport
public abstract WebsocketTransport newTransport()
-
newRTCTransport
public abstract RTCTransport newRTCTransport(java.time.Duration p2pAttemptTimeout, java.lang.String connId, java.util.Collection<java.lang.String> stunServers)
-
sha256
public abstract java.lang.String sha256(java.lang.String data)
-
sha256
public abstract byte[] sha256(byte[] data)
-
schnorrSign
public abstract java.lang.String schnorrSign(java.lang.String data, byte[] privKey) throws FailedToSignException- Throws:
FailedToSignException
-
schnorrVerify
public abstract boolean schnorrVerify(java.lang.String data, java.lang.String sign, byte[] pubKey)
-
schnorrSignAsync
public abstract AsyncTask<java.lang.String> schnorrSignAsync(java.lang.String data, byte[] privKey)
-
schnorrVerifyAsync
public abstract AsyncTask<java.lang.Boolean> schnorrVerifyAsync(java.lang.String data, java.lang.String sign, byte[] pubKey)
-
sign
@Deprecated public java.lang.String sign(java.lang.String data, byte[] privKey) throws FailedToSignExceptionDeprecated.This generically named method is deprecated in favor ofschnorrSign(String, byte[])that does the same- Throws:
FailedToSignException
-
verify
@Deprecated public boolean verify(java.lang.String data, java.lang.String sign, byte[] pubKey)Deprecated.This generically named method is deprecated in favor ofschnorrVerify(String, String, byte[])that does the same
-
signAsync
@Deprecated public AsyncTask<java.lang.String> signAsync(java.lang.String data, byte[] privKey)
Deprecated.This generically named method is deprecated in favor ofschnorrSignAsync(String, byte[])that does the same
-
verifyAsync
@Deprecated public AsyncTask<java.lang.Boolean> verifyAsync(java.lang.String data, java.lang.String sign, byte[] pubKey)
Deprecated.This generically named method is deprecated in favor ofschnorrVerifyAsync(String, String, byte[])that does the same
-
randomBytes
public abstract byte[] randomBytes(int n)
-
newAsyncExecutor
public final AsyncExecutor newAsyncExecutor()
-
newAsyncExecutor
public abstract AsyncExecutor newAsyncExecutor(java.lang.Object hint)
-
newRelayExecutor
@Deprecated public final AsyncExecutor newRelayExecutor()
Deprecated.usenewAsyncExecutor(Object)instead
-
newSubscriptionExecutor
@Deprecated public final AsyncExecutor newSubscriptionExecutor()
Deprecated.usenewAsyncExecutor(Object)instead
-
newSignerExecutor
@Deprecated public final AsyncExecutor newSignerExecutor()
Deprecated.usenewAsyncExecutor(Object)instead
-
newPoolExecutor
@Deprecated public final AsyncExecutor newPoolExecutor()
Deprecated.usenewAsyncExecutor(Object)instead
-
promisify
public abstract <T> AsyncTask<T> promisify(java.util.function.BiConsumer<java.util.function.Consumer<T>,java.util.function.Consumer<java.lang.Throwable>> func, AsyncExecutor executor)
-
wrapPromise
public abstract <T> AsyncTask<T> wrapPromise(java.util.function.BiConsumer<java.util.function.Consumer<T>,java.util.function.Consumer<java.lang.Throwable>> func)
-
awaitAll
public <T> AsyncTask<java.util.List<T>> awaitAll(java.util.List<AsyncTask<T>> promises)
Waits for all promises to resolve.If one of the promises fails, the returned promise is fails with the same error.
- Type Parameters:
T- the type of the promises- Parameters:
promises- the list of promises- Returns:
- a promise that resolves to a list of results
-
awaitAny
public <T> AsyncTask<T> awaitAny(java.util.List<AsyncTask<T>> promises)
Waits for any promise to resolve.- Type Parameters:
T- the type of the promises- Parameters:
promises- the list of promises- Returns:
- a promise that resolves to the result of the first resolved promise
If all promises fail, the returned promise fails with an exception, otherwise it resolves with the result of the first resolved promise.
-
awaitAny
public <T> AsyncTask<T> awaitAny(java.util.List<AsyncTask<T>> promises, java.util.function.Predicate<T> filter)
Waits for any promise to resolve and match the filter. Same as awaitAny but with a filter that the result must match. If the result does not match the filter, it is ignored and the next promise is waited for.If all promises fail or none match the filter, the returned promise fails with an exception, otherwise it resolves with the result of the first resolved promise that matches the filter.
- Type Parameters:
T- the type of the promises- Parameters:
promises- the list of promisesfilter- the filter to match- Returns:
- a promise that resolves to the result of the first resolved promise that matches the filter
-
awaitAllSettled
public <T> AsyncTask<java.util.List<AsyncTask<T>>> awaitAllSettled(java.util.List<AsyncTask<T>> promises)
Awaits for all promises to settle (either resolve or reject). The returned promise always resolves with the list of all promises.- Type Parameters:
T- the type of the promises- Parameters:
promises- the list of promises- Returns:
- a promise that resolves to the list of all promises
-
getTimestampSeconds
public abstract long getTimestampSeconds()
-
newConcurrentQueue
public abstract <T> java.util.Queue<T> newConcurrentQueue(java.lang.Class<T> claz)
-
httpGet
public AsyncTask<java.lang.String> httpGet(java.lang.String url, java.time.Duration timeout, java.util.Map<java.lang.String,java.lang.String> headers)
-
httpGetBytes
@Deprecated public AsyncTask<byte[]> httpGetBytes(java.lang.String url, java.time.Duration timeout, java.util.Map<java.lang.String,java.lang.String> headers)
Deprecated.
-
httpRequest
public abstract AsyncTask<NGEHttpResponse> httpRequest(java.lang.String method, java.lang.String inurl, byte[] body, java.time.Duration timeout, java.util.Map<java.lang.String,java.lang.String> headers)
-
httpRequestStream
public abstract AsyncTask<NGEHttpResponseStream> httpRequestStream(java.lang.String method, java.lang.String inurl, byte[] body, java.time.Duration timeout, java.util.Map<java.lang.String,java.lang.String> headers)
-
setClipboardContent
public abstract void setClipboardContent(java.lang.String data)
-
getClipboardContent
public abstract AsyncTask<java.lang.String> getClipboardContent()
-
openInWebBrowser
public abstract void openInWebBrowser(java.lang.String url)
-
scrypt
public abstract byte[] scrypt(byte[] P, byte[] S, int N, int r, int p, int dkLen)
-
xchacha20poly1305
public abstract byte[] xchacha20poly1305(byte[] key, byte[] nonce, byte[] data, byte[] associatedData, boolean forEncryption)
-
nfkc
public abstract java.lang.String nfkc(java.lang.String str)
-
getDataStore
public abstract VStore getDataStore(java.lang.String appName, java.lang.String storeName)
-
getCacheStore
public abstract VStore getCacheStore(java.lang.String appName, java.lang.String cacheName)
-
registerFinalizer
public abstract java.lang.Runnable registerFinalizer(java.lang.Object obj, java.lang.Runnable finalizer)
-
isLoopbackAddress
public boolean isLoopbackAddress(java.net.URI uri)
Checks if the given URI is a loopback address. Polyfill for non jcl compliant platforms. This method should be overriden by a platform specific implementation- Parameters:
uri- the URI to check- Returns:
- true if the URI is a loopback address, false otherwise
-
openResource
public abstract java.io.InputStream openResource(java.lang.String resourceName) throws java.io.IOException- Throws:
java.io.IOException
-
aes256cbc
public abstract byte[] aes256cbc(byte[] key, byte[] iv, byte[] data, boolean forEncryption)Encrypts or decrypts data using AES-256 in CBC mode with PKCS7 padding.- Parameters:
key- A 32-byte key for AES-256iv- A 16-byte initialization vectordata- The data to encrypt or decryptforEncryption- True for encryption, false for decryption- Returns:
- The encrypted or decrypted data
-
getVStoreQueue
public ExecutionQueue getVStoreQueue()
-
newExecutionQueue
public ExecutionQueue newExecutionQueue()
-
newExecutionQueue
public ExecutionQueue newExecutionQueue(AsyncExecutor exc)
-
callFunction
public void callFunction(java.lang.String function, java.lang.Object args, java.util.function.Consumer<java.lang.Object> res, java.util.function.Consumer<java.lang.Throwable> rej)Run platform specific script
-
canCallFunction
public void canCallFunction(java.lang.String function, java.util.function.Consumer<java.lang.Boolean> res)
-
getPlatformName
public abstract java.lang.String getPlatformName()
-
runInThread
public void runInThread(java.lang.Thread thread, java.util.function.Consumer<java.lang.Runnable> enqueue, java.lang.Runnable action)
-
panic
public void panic(java.lang.String err)
-
getMemoryLimits
public MemoryLimits getMemoryLimits()
-
getNativeAllocator
public abstract NGEAllocator getNativeAllocator()
-
-