Reseller Payment Webhook

import requests
from datetime import datetime

# Your parent company API credentials
PARENT_API_KEY = "YOUR_PARENT_API_KEY_HERE"
API_URL = "https://roycetalk.com/api/v1/sms-api/webhooks/payment/"

def process_child_payment(child_account_name, amount, mpesa_reference):
    """
    Process payment from child company and transfer SMS units.
    
    Args:
        child_account_name: Child company's account name
        amount: Payment amount received from child
        mpesa_reference: M-Pesa transaction reference
    
    Returns:
        dict: Transfer result with balance updates
    """
    
    # Prepare the request
    headers = {
        "Authorization": f"Bearer {PARENT_API_KEY}",
        "Content-Type": "application/json"
    }
    
    payload = {
        "account_name": child_account_name,
        "amount": str(amount),
        "payment_reference": mpesa_reference,
        "currency": "KES"
    }
    
    try:
        # Send the request
        response = requests.post(API_URL, json=payload, headers=headers)
        
        # Check response status
        if response.status_code == 200:
            result = response.json()
            
            print("✓ Payment processed successfully!")
            print(f"Transfer Reference: {result['data']['transfer_reference']}")
            print(f"SMS Units Transferred: {result['data']['transfer_details']['sms_units_transferred']}")
            print(f"Parent Balance After: {result['data']['parent_company']['balance_after']}")
            print(f"Child Balance After: {result['data']['child_company']['balance_after']}")
            print(f"Parent Profit: KES {result['data']['parent_company']['profit']}")
            
            return result
            
        elif response.status_code == 409:
            # Duplicate payment reference
            error = response.json()
            print(f"⚠ Duplicate payment: {error['errors'][0]['message']}")
            print(f"Original transaction: {error['errors'][0]['details']['existing_transfer']}")
            return None
            
        elif response.status_code == 404:
            # Child company not found
            error = response.json()
            print(f"✗ Child company not found: {error['errors'][0]['message']}")
            return None
            
        elif response.status_code == 400:
            # Validation error or insufficient balance
            error = response.json()
            print(f"✗ Error: {error['errors'][0]['message']}")
            if 'details' in error['errors'][0]:
                print(f"Details: {error['errors'][0]['details']}")
            return None
            
        else:
            print(f"✗ Unexpected error: {response.status_code}")
            print(response.text)
            return None
            
    except requests.exceptions.RequestException as e:
        print(f"✗ Request failed: {str(e)}")
        return None


# Example usage
if __name__ == "__main__":
    # Process a payment from child company
    result = process_child_payment(
        child_account_name="child_company_abc",
        amount=1100.00,
        mpesa_reference="MPESA_ABC123XYZ"
    )
    
    if result:
        # Payment processed successfully
        # You can store the transfer_reference in your database
        transfer_ref = result['data']['transfer_reference']
        print(f"\n✓ Store this transfer reference: {transfer_ref}")