MSBD5017-Depin-WebClient/app/Components/Contracts/Connections.tsx

import { Web3, type Bytes } from 'web3';
import type { Node, NodeInfo, PaymentChannelInfo } from '../Util';
import clearNetJson from './ClearNet/ClearNet.json';
import clrTokenJson from './CLRToken/CLRToken.json';

const clearNetABI = (clearNetJson as any).abi ?? clearNetJson;
const clrTokenABI = (clrTokenJson as any).abi ?? clrTokenJson;
const clearNetAddress = "0x0305e95225f65db13e98c775dbb95b98178ae73b";
const clrTokenAddress = "0xf1664c17887767c8f58695846babb349ca61d2e9";
// const clearNetAddress = "0x9a9f2ccfde556a7e9ff0848998aa4a0cfd8863ae";
// const clrTokenAddress = "0x5fc8d32690cc91d4c39d9d3abcbd16989f875707";

const DEFAULT_MIN_STAKE = BigInt(100) * BigInt(1e18); // 100 CLR


export const getActiveNodes = async (provider: any): Promise<Node[]> => {
    if (!provider) {
        return [];
    }
    const web3 = new Web3(provider);
    const clearnet_contract = new web3.eth.Contract(clearNetABI, clearNetAddress);
    const activeNodes: string[] = await clearnet_contract.methods.getActiveNodes().call();
    const nodes: Node[] = await Promise.all(activeNodes.map(async (node: string) => {
        const nodeInfo: NodeInfo = await clearnet_contract.methods.getNodeInfo(node).call();
        return {
            address: node,
            ip: nodeInfo.ipAddress,
            port: Number(nodeInfo.port),
            traffic: 0,
            price: Number(nodeInfo.pricePerMinute) / 1e18,
            pricePerMinute: nodeInfo.pricePerMinute,
            rating: Number(nodeInfo.reputationScore) / 1000,
        };
    }));
    console.log("Fetched nodes:", nodes);
    return nodes;
}

export async function approveCLRTokenSpending(provider: any,account: string) {
    const web3 = new Web3(provider);
    const clr_token_contract = new web3.eth.Contract(clrTokenABI, clrTokenAddress);
    const gasPrice = await web3.eth.getGasPrice();
    const gasLimit = 300000;
    const tx = await clr_token_contract.methods.approve(clearNetAddress, DEFAULT_MIN_STAKE).send({
        from: account,
        gas: String(gasLimit),
        gasPrice: String(gasPrice),
    });
    console.log(tx);
}

export async function openPaymentChannel(provider: any,account: string,amount: BigInt) {
    const web3 = new Web3(provider);
    const clearnet_contract = new web3.eth.Contract(clearNetABI, clearNetAddress);
    const gasPrice = await web3.eth.getGasPrice();
    const gasLimit = 300000;
    const tx = await clearnet_contract.methods.openPaymentChannel(amount).send({
        from: account,
        gas: String(gasLimit),
        gasPrice: String(gasPrice),
    });

    console.log(tx);
}

export async function closePaymentChannel(provider: any,account: string) {
    const web3 = new Web3(provider);
    const clearnet_contract = new web3.eth.Contract(clearNetABI, clearNetAddress);
    const gasPrice = await web3.eth.getGasPrice();
    const gasLimit = 300000;
    const tx = await clearnet_contract.methods.closePaymentChannel().send({
        from: account,
        gas: String(gasLimit),
        gasPrice: String(gasPrice),
    });
    console.log(tx);

}

export async function processPayment(provider: any,account: string,nodeAddress: string,
    vpnClientPublicKey: string, connectionStartTime: BigInt, agreedPricePerMinute: BigInt,
    isRatingProvided: boolean, rating: BigInt, clientSignature: string, nodeSignature: string) {
        const web3 = new Web3(provider);
        const clearnet_contract = new web3.eth.Contract(clearNetABI, clearNetAddress);
        const gasPrice = await web3.eth.getGasPrice();
        const gasLimit = 300000;
        const tx = await clearnet_contract.methods.processPayment(
            account,
            nodeAddress,
            vpnClientPublicKey,
            connectionStartTime,
            agreedPricePerMinute,
            isRatingProvided,
            rating,
            clientSignature,
            nodeSignature
        ).send({
            from: account,
            gas: String(gasLimit),
            gasPrice: String(gasPrice),
        });
        console.log(tx);
}

export async function abortConnection(provider: any,account: string,vpnClientPublicKey: string,
    connectionStartTime: BigInt,agreedPricePerMinute: BigInt,clientSignature: Bytes) {
    const web3 = new Web3(provider);
    const clearnet_contract = new web3.eth.Contract(clearNetABI, clearNetAddress);
    const gasPrice = await web3.eth.getGasPrice();
    const gasLimit = 300000;
    const tx = await clearnet_contract.methods.abortConnection(
        vpnClientPublicKey,
        connectionStartTime,
        agreedPricePerMinute,
        clientSignature
    ).send({
        from: account,
        gas: String(gasLimit),
        gasPrice: String(gasPrice),
    });
    console.log(tx);
}

export async function getPaymentChannelInfo(provider: any,account: string) : Promise<PaymentChannelInfo> {
    if (!provider) {
        return { balance: BigInt(0), nonce: BigInt(0), isActive: false};
    }
    const web3 = new Web3(provider);
    const clearnet_contract = new web3.eth.Contract(clearNetABI, clearNetAddress);
    const channelInfo: PaymentChannelInfo = await clearnet_contract.methods.getPaymentChannelInfo(account).call();
    return {
        balance: channelInfo.balance,
        nonce: channelInfo.nonce,
        isActive: channelInfo.isActive,
    };
}

export async function getNextNonce(provider: any,account: string) : Promise<BigInt> {
    const channelInfo = await getPaymentChannelInfo(provider, account);
    return channelInfo.nonce.valueOf() + BigInt(1);
}