wallet-fetcher: wallet address as a secret and updating sync mode

Signed-off-by: Alexis Pentori <alexis@status.im>
This commit is contained in:
Alexis Pentori 2024-01-10 15:48:26 +01:00
parent 2bf4aecade
commit 365cd2f6e4
No known key found for this signature in database
GPG Key ID: 65250D2801E47A10
5 changed files with 20 additions and 6 deletions

View File

@ -10,7 +10,7 @@ data:
connectorSubtype: api connectorSubtype: api
connectorType: source connectorType: source
definitionId: 1e55cfe0-f591-4281-9a20-18d89d45f685 definitionId: 1e55cfe0-f591-4281-9a20-18d89d45f685
dockerImageTag: 0.2.0 dockerImageTag: 0.3.0
dockerRepository: harbor.status.im/status-im/airbyte/wallet-fetcher dockerRepository: harbor.status.im/status-im/airbyte/wallet-fetcher
githubIssueLabel: source-wallet-fetcher githubIssueLabel: source-wallet-fetcher
icon: icon.svg icon: icon.svg

View File

@ -0,0 +1,12 @@
{
"wallets": [
{
"address": "bc1qcm0frkpfhsem5rdx9c4qjzeet038xhyscfgtcq",
"name": "test-wallet-btc",
"blockchain": [
"BTC"
],
"tags": "EOA,Stacking"
}
]
}

View File

@ -8,10 +8,10 @@
"type": "object" "type": "object"
}, },
"supported_sync_modes": [ "supported_sync_modes": [
"full_refresh" "full_refresh", "incremental"
] ]
}, },
"sync_mode": "full_refresh", "sync_mode": "incremental",
"destination_sync_mode": "overwrite" "destination_sync_mode": "overwrite"
}, },
{ {
@ -22,10 +22,10 @@
"type": "object" "type": "object"
}, },
"supported_sync_modes": [ "supported_sync_modes": [
"full_refresh" "full_refresh", "incremental"
] ]
}, },
"sync_mode": "full_refresh", "sync_mode": "incremental",
"destination_sync_mode": "overwrite" "destination_sync_mode": "overwrite"
} }
] ]

View File

@ -5,6 +5,7 @@ connectionSpecification:
type: object type: object
required: required:
- wallets - wallets
additionalProperties: true
properties: properties:
wallets: wallets:
title: Wallets title: Wallets
@ -12,12 +13,12 @@ connectionSpecification:
type: array type: array
items: items:
type: object type: object
additionalProperties: true
properties: properties:
address: address:
title: Address title: Address
type: string type: string
description: Address of the wallet description: Address of the wallet
airbyte_secret: true
name: name:
title: Name title: Name
type: string type: string

View File

@ -45,6 +45,7 @@ class BitcoinToken(BlockchainStream):
**kwargs **kwargs
) -> Iterable[Mapping]: ) -> Iterable[Mapping]:
logger.info("Getting Bitcoin Balance information") logger.info("Getting Bitcoin Balance information")
logger.info("Response %s", response.json())
bitcoin_data = response.json() bitcoin_data = response.json()
yield { yield {
"wallet_name": stream_slice['name'], "wallet_name": stream_slice['name'],