Merge pull request #62 from skalenetwork/fix-decimals-distributor

Fix payment wei value - credit distributor

Author: dmytrotkk

credit-distributor/config.toml.example

@@ -6,6 +6,7 @@ state_file = 'state.json' # optional
 [destination]
 endpoint = 'https://example.com' # required - destination schain RPC
 contract = '0x0' # required - Ledger contract address on destination schain
+credit_decimals = 18 # optional - decimals to scale credit count to native wei (default 18)
 
 # One [[sources]] entry per CreditStation deployment to monitor.
 # Each deployment must have been initialized with a unique on-chain `sourceId`

credit-distributor/src/configs.py

@@ -45,6 +45,7 @@ class Source(BaseModel):
 class Destination(BaseModel):
     endpoint: str
     contract: str
+    credit_decimals: int = 18
 
 
 class Agent(BaseModel):

credit-distributor/src/main.py

@@ -93,7 +93,7 @@ def distribute_credits_for_source(
         chunk_size=config.agent.events_chunk_size,
     )
     for event in all_events:
-        fulfill_payment(source, event, schain_cs)
+        fulfill_payment(source, event, schain_cs, config.destination.credit_decimals)
 
     if all_events:
         state.from_blocks[source.name] = all_events[-1]['block_number'] + 1
@@ -106,13 +106,15 @@ def fulfill_payment(
     source: Source,
     event: PaymentReceivedEvent,
     schain_cs: SchainCreditStation,
+    credit_decimals: int,
 ) -> None:
     payment_id = event['payment_id']
     logger.info(f'[{source.name}] Checking payment: {payment_id}')
     is_fulfilled = schain_cs.ledger.is_fulfilled(payment_id)
     if not is_fulfilled:
-        logger.info(f'[{source.name}] Fulfilling payment: {payment_id}')
-        schain_cs.ledger.fulfill(payment_id, event['to_address'], value=event['value'])
+        amount = event['value'] * (10 ** credit_decimals)
+        logger.info(f'[{source.name}] Fulfilling payment: {payment_id} with amount {amount} wei')
+        schain_cs.ledger.fulfill(payment_id, event['to_address'], value=amount)
         logger.info(f'[{source.name}] Payment {payment_id} fulfilled successfully.')
     else:
         logger.debug(f'[{source.name}] Payment {payment_id} is already fulfilled.')