-
Notifications
You must be signed in to change notification settings - Fork 14
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
5 changed files
with
491 additions
and
26 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
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,216 @@ | ||
| import { crypto } from 'altcoin-js' | ||
| import { | ||
| asEither, | ||
| asJSON, | ||
| asObject, | ||
| asOptional, | ||
| asString, | ||
| asUnknown, | ||
| Cleaner | ||
| } from 'cleaners' | ||
| import { EdgeLog } from 'edge-core-js/types' | ||
|
|
||
| import { EngineEmitter } from '../../plugin/EngineEmitter' | ||
| import { PluginInfo } from '../../plugin/types' | ||
| import { addressToScriptPubkey } from '../keymanager/keymanager' | ||
| import { Blockbook, makeBlockbook } from './Blockbook' | ||
| import { AddressResponse, BlockbookAccountUtxo } from './blockbookApi' | ||
| import Deferred from './Deferred' | ||
| import { | ||
| addressTransactionsMessage, | ||
| AddressTransactionsResponse, | ||
| listUnspentMessage, | ||
| ListUnspentResponse, | ||
| pingMessage | ||
| } from './electrumApi' | ||
| import { OnQueueSpaceCB, WsResponse, WsResponseMessage, WsTask } from './Socket' | ||
| import { SocketEmitter } from './SocketEmitter' | ||
|
|
||
| export interface BlockbookElectrumConfig { | ||
| asAddress?: Cleaner<string> | ||
| connectionUri: string | ||
| engineEmitter: EngineEmitter | ||
| log: EdgeLog | ||
| onQueueSpaceCB: OnQueueSpaceCB | ||
| pluginInfo: PluginInfo | ||
| socketEmitter: SocketEmitter | ||
| walletId: string | ||
| } | ||
|
|
||
| export interface ElectrumResponseMessage { | ||
| id: number | ||
| data: unknown | ||
| error: { message: string } | undefined | ||
| } | ||
|
|
||
| const asResponseMessage = (raw: unknown): WsResponseMessage => { | ||
| const message = asJSON( | ||
| asObject({ | ||
| id: asString, | ||
| result: asUnknown, | ||
| error: asOptional( | ||
| asEither( | ||
| asObject({ message: asString }), | ||
| asObject({ connected: asString }) | ||
| ) | ||
| ) | ||
| }) | ||
| )(raw) | ||
|
|
||
| return { | ||
| id: message.id, | ||
| data: message.result, | ||
| error: message.error | ||
| } | ||
| } | ||
|
|
||
| const asResponse: Cleaner<WsResponse> = (raw: unknown) => { | ||
| const payloadString = asString(raw).trimEnd() | ||
| const messageStrings = payloadString.split('\n') | ||
| const messages = messageStrings.map(asResponseMessage) | ||
| return messages | ||
| } | ||
|
|
||
| export function makeBlockbookElectrum( | ||
| config: BlockbookElectrumConfig | ||
| ): Blockbook { | ||
| const { | ||
| asAddress, | ||
| connectionUri, | ||
| engineEmitter, | ||
| log, | ||
| onQueueSpaceCB, | ||
| pluginInfo, | ||
| socketEmitter, | ||
| walletId | ||
| } = config | ||
| log(`makeBlockbookElectrum with uri ${connectionUri}`) | ||
|
|
||
| const addressToScriptHash = (address: string): string => { | ||
| const scriptPubkey = addressToScriptPubkey({ | ||
| address, | ||
| coin: pluginInfo.coinInfo.name | ||
| }) | ||
| const scriptHashBuffer = crypto.sha256(Buffer.from(scriptPubkey, 'hex')) | ||
| const scriptHash = scriptHashBuffer.reverse().toString('hex') | ||
| return scriptHash | ||
| } | ||
|
|
||
| const instance = makeBlockbook({ | ||
| asAddress, | ||
| asResponse, | ||
| connectionUri, | ||
| engineEmitter, | ||
| log, | ||
| onQueueSpaceCB: async ( | ||
| uri: string | ||
| ): Promise<WsTask<unknown> | boolean | undefined> => { | ||
| const task = await onQueueSpaceCB(uri) | ||
| if (task == null || typeof task === 'boolean') return task | ||
|
|
||
| // Translate getAccountUtxo to blockchain.scripthash.listunspent: | ||
| if (task.method === 'getAccountUtxo') { | ||
| const params = task.params as { descriptor: string } | ||
| const address = | ||
| asAddress != null ? asAddress(params.descriptor) : params.descriptor | ||
| const scriptHash = addressToScriptHash(address) | ||
|
|
||
| const deferred = new Deferred<any>() | ||
| deferred.promise | ||
| .then((electrumUtxos: ListUnspentResponse): void => { | ||
| const blockbookUtxos: BlockbookAccountUtxo[] = electrumUtxos.map( | ||
| utxo => ({ | ||
| txid: utxo.tx_hash, | ||
| vout: utxo.tx_pos, | ||
| value: utxo.value.toString(), | ||
| height: utxo.height | ||
| }) | ||
| ) | ||
| task.deferred.resolve(blockbookUtxos) | ||
| }) | ||
| .catch((e): void => { | ||
| task.deferred.reject(e) | ||
| }) | ||
|
|
||
| const translatedTask: WsTask<unknown> = { | ||
| ...listUnspentMessage(scriptHash), | ||
| deferred | ||
| } | ||
| return translatedTask | ||
| } | ||
|
|
||
| // Get Address Transactions: | ||
| if (task.method === 'getAccountInfo') { | ||
| const params = task.params as { descriptor: string } | ||
| const address = | ||
| asAddress != null ? asAddress(params.descriptor) : params.descriptor | ||
| const scriptHash = addressToScriptHash(address) | ||
|
|
||
| const deferred = new Deferred<any>() | ||
| deferred.promise | ||
| .then((electrumUtxos: AddressTransactionsResponse): void => { | ||
| const blockbookUtxos: AddressResponse = { | ||
| address, // unused | ||
| balance: '0', // unused | ||
| totalReceived: '0', // unused | ||
| totalSent: '0', // unused | ||
| txs: electrumUtxos.length, | ||
| unconfirmedBalance: '0', // unused | ||
| unconfirmedTxs: electrumUtxos.reduce( | ||
| (sum, tx) => (sum + tx.height >= 0 ? 1 : 0), | ||
| 0 | ||
| ), | ||
| txids: [], // unused | ||
| transactions: [], // TODO: this requires an extra query per txid | ||
| page: 0, // unused | ||
| totalPages: 1, | ||
| itemsOnPage: 0 // unused | ||
| } | ||
| task.deferred.resolve(blockbookUtxos) | ||
| }) | ||
| .catch((e): void => { | ||
| task.deferred.reject(e) | ||
| }) | ||
|
|
||
| const translatedTask: WsTask<unknown> = { | ||
| ...addressTransactionsMessage(scriptHash), | ||
| deferred | ||
| } | ||
| return translatedTask | ||
| } | ||
|
|
||
| // Skip unsupported task and continue with the next one: | ||
| return true | ||
| }, | ||
| ping: async (): Promise<void> => { | ||
| return await instance.promisifyWsMessage(pingMessage()) | ||
| }, | ||
| socketEmitter, | ||
| walletId | ||
| }) | ||
|
|
||
| instance.broadcastTx = async () => { | ||
| throw new Error('broadcastTx not supported for Electrum connections') | ||
| } | ||
| instance.fetchAddress = async () => { | ||
| throw new Error('fetchAddress not supported for Electrum connections') | ||
| } | ||
| instance.fetchAddressUtxos = async () => { | ||
| throw new Error('fetchAddressUtxos not supported for Electrum connections') | ||
| } | ||
| instance.fetchInfo = async () => { | ||
| throw new Error('fetchInfo not supported for Electrum connections') | ||
| } | ||
| instance.fetchTransaction = async () => { | ||
| throw new Error('fetchTransaction not supported for Electrum connections') | ||
| } | ||
|
|
||
| instance.watchAddresses = async () => { | ||
| return // Fail gracefully | ||
| } | ||
| instance.watchBlocks = async () => { | ||
| return // Fail gracefully | ||
| } | ||
|
|
||
| return instance | ||
| } |
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
Oops, something went wrong.