// SPDX-License-Identifier: BUSL-1.1

//
// Note: you will need to fund each deployed contract with gas
//
// PingPong sends a LayerZero message back and forth between chains until stopped!
//
// Demonstrates:
//  1. a recursive feature of calling send() from inside lzReceive()
//  2. how to `estimateFees` for a send()'ing a LayerZero message
//  3. the contract pays the message fee

pragma solidity ^0.7.6;
pragma abicoder v2;
import "../interfaces/ILayerZeroReceiver.sol";
import "../interfaces/ILayerZeroEndpoint.sol";
import "../interfaces/ILayerZeroUserApplicationConfig.sol";

contract PingPong is ILayerZeroReceiver, ILayerZeroUserApplicationConfig {
    // the LayerZero endpoint calls .send() to send a cross chain message
    ILayerZeroEndpoint public endpoint;
    // whether PingPong is ping-ponging
    bool public pingsEnabled;
    // event emitted every ping() to keep track of consecutive pings count
    event Ping(uint pings);
    // the maxPings before ending the loop
    uint public maxPings;
    // keep track of the totalPings sent
    uint public numPings;
    bool public isUlnV2;

    // constructor requires the LayerZero endpoint for this chain
    constructor(address _layerZeroEndpoint, bool _isUlnV2) {
        pingsEnabled = true;
        endpoint = ILayerZeroEndpoint(_layerZeroEndpoint);
        maxPings = 5;
        isUlnV2 = _isUlnV2;
    }

    // disable ping-ponging
    function disable() external {
        pingsEnabled = false;
    }

    // pings the destination chain, along with the current number of pings sent
    function ping(
        uint16 _dstChainId, // send a ping to this destination chainId
        address _dstPingPongAddr, // destination address of PingPong contract
        uint pings // the uint to start at. use 0 as a default
    ) public {
        require(address(this).balance > 0, "the balance of this contract is 0. pls send gas for message fees");
        require(pingsEnabled, "pingsEnabled is false. messages stopped");
        require(maxPings > pings, "maxPings has been reached, no more looping");

        emit Ping(pings);

        // abi.encode() the payload with the number of pings sent
        bytes memory payload = abi.encode(pings);

        // encode adapterParams to specify more gas for the destination
        uint16 version = 1;
        uint gasForDestinationLzReceive = 350000;
        bytes memory adapterParams = abi.encodePacked(version, gasForDestinationLzReceive);

        // get the fees we need to pay to LayerZero + Relayer to cover message delivery
        // see Communicator.sol's .estimateNativeFees() function for more details.
        (uint messageFee, ) = endpoint.estimateFees(_dstChainId, address(this), payload, false, adapterParams);
        require(
            address(this).balance >= messageFee,
            "address(this).balance < messageFee. pls send gas for message fees"
        );

        bytes memory path = isUlnV2
            ? abi.encodePacked(_dstPingPongAddr, address(this))
            : abi.encodePacked(_dstPingPongAddr);

        // send LayerZero message
        endpoint.send{value: messageFee}( // {value: messageFee} will be paid out of this contract!
            _dstChainId, // destination chainId
            path,
            payload, // abi.encode()'ed bytes
            payable(this), // (msg.sender will be this contract) refund address (LayerZero will refund any extra gas back to caller of send()
            address(0x0), // 'zroPaymentAddress' unused for this mock/example
            adapterParams // 'adapterParams' unused for this mock/example
        );
    }

    // receive the bytes payload from the source chain via LayerZero
    // _srcChainId: the chainId that we are receiving the message from.
    // _fromAddress: the source PingPong address
    function lzReceive(
        uint16 _srcChainId,
        bytes memory _fromAddress,
        uint64 /*_nonce*/,
        bytes memory _payload
    ) external override {
        require(msg.sender == address(endpoint)); // boilerplate! lzReceive must be called by the endpoint for security

        // use assembly to extract the address from the bytes memory parameter
        address fromAddress;
        assembly {
            fromAddress := mload(add(_fromAddress, 20))
        }

        // decode the number of pings sent thus far
        uint pings = abi.decode(_payload, (uint));

        // "recursively" call ping in order to *pong*     (and increment pings)
        ++pings;
        numPings = pings;

        ping(_srcChainId, fromAddress, pings);
    }

    function setConfig(
        uint16 /*_version*/,
        uint16 _dstChainId,
        uint _configType,
        bytes memory _config
    ) external override {
        endpoint.setConfig(_dstChainId, endpoint.getSendVersion(address(this)), _configType, _config);
    }

    function getConfig(
        uint16 /*_dstChainId*/,
        uint16 _chainId,
        address,
        uint _configType
    ) external view returns (bytes memory) {
        return endpoint.getConfig(endpoint.getSendVersion(address(this)), _chainId, address(this), _configType);
    }

    function setSendVersion(uint16 version) external override {
        endpoint.setSendVersion(version);
    }

    function setReceiveVersion(uint16 version) external override {
        endpoint.setReceiveVersion(version);
    }

    function getSendVersion() external view returns (uint16) {
        return endpoint.getSendVersion(address(this));
    }

    function getReceiveVersion() external view returns (uint16) {
        return endpoint.getReceiveVersion(address(this));
    }

    function forceResumeReceive(uint16 _srcChainId, bytes calldata _srcAddress) external override {
        // do nth
    }

    // allow this contract to receive ether
    fallback() external payable {}

    receive() external payable {}
}