pragma solidity ^0.8.0;

import {LinkTokenInterface} from "../../../shared/interfaces/LinkTokenInterface.sol";
import {Chainlink, Chainlinked} from "./Chainlinked.sol";
import {MaliciousChainlink} from "./MaliciousChainlink.sol";

// solhint-disable
contract MaliciousChainlinked is Chainlinked {
  using MaliciousChainlink for MaliciousChainlink.Request;
  using MaliciousChainlink for MaliciousChainlink.WithdrawRequest;
  using Chainlink for Chainlink.Request;

  uint256 private s_maliciousRequests = 1;
  mapping(bytes32 => address) private s_maliciousPendingRequests;

  function newWithdrawRequest(
    bytes32 _specId,
    address _callbackAddress,
    bytes4 _callbackFunction
  ) internal pure returns (MaliciousChainlink.WithdrawRequest memory) {
    MaliciousChainlink.WithdrawRequest memory req;
    return req.initializeWithdraw(_specId, _callbackAddress, _callbackFunction);
  }

  function chainlinkTargetRequest(
    address _target,
    Chainlink.Request memory _req,
    uint256 _amount
  ) internal returns (bytes32 requestId) {
    requestId = keccak256(abi.encodePacked(_target, s_maliciousRequests));
    _req.nonce = s_maliciousRequests;
    s_maliciousPendingRequests[requestId] = oracleAddress();
    emit ChainlinkRequested(requestId);
    LinkTokenInterface link = LinkTokenInterface(chainlinkToken());
    require(
      link.transferAndCall(oracleAddress(), _amount, encodeTargetRequest(_req)), "Unable to transferAndCall to oracle"
    );
    s_maliciousRequests += 1;

    return requestId;
  }

  function chainlinkPriceRequest(Chainlink.Request memory _req, uint256 _amount) internal returns (bytes32 requestId) {
    requestId = keccak256(abi.encodePacked(this, s_maliciousRequests));
    _req.nonce = s_maliciousRequests;
    s_maliciousPendingRequests[requestId] = oracleAddress();
    emit ChainlinkRequested(requestId);
    LinkTokenInterface link = LinkTokenInterface(chainlinkToken());
    require(
      link.transferAndCall(oracleAddress(), _amount, encodePriceRequest(_req)), "Unable to transferAndCall to oracle"
    );
    s_maliciousRequests += 1;

    return requestId;
  }

  function chainlinkWithdrawRequest(
    MaliciousChainlink.WithdrawRequest memory _req,
    uint256 _wei
  ) internal returns (bytes32 requestId) {
    requestId = keccak256(abi.encodePacked(this, s_maliciousRequests));
    _req.nonce = s_maliciousRequests;
    s_maliciousPendingRequests[requestId] = oracleAddress();
    emit ChainlinkRequested(requestId);
    LinkTokenInterface link = LinkTokenInterface(chainlinkToken());
    require(
      link.transferAndCall(oracleAddress(), _wei, encodeWithdrawRequest(_req)), "Unable to transferAndCall to oracle"
    );
    s_maliciousRequests += 1;
    return requestId;
  }

  function encodeWithdrawRequest(
    MaliciousChainlink.WithdrawRequest memory _req
  ) internal pure returns (bytes memory) {
    return abi.encodeWithSelector(
      bytes4(keccak256("withdraw(address,uint256)")),
      _req.callbackAddress,
      _req.callbackFunctionId,
      _req.nonce,
      _req.buf.buf
    );
  }

  function encodeTargetRequest(
    Chainlink.Request memory _req
  ) internal pure returns (bytes memory) {
    return abi.encodeWithSelector(
      bytes4(keccak256("oracleRequest(address,uint256,bytes32,address,bytes4,uint256,uint256,bytes)")),
      0, // overridden by onTokenTransfer
      0, // overridden by onTokenTransfer
      _req.id,
      _req.callbackAddress,
      _req.callbackFunctionId,
      _req.nonce,
      1,
      _req.buf.buf
    );
  }

  function encodePriceRequest(
    Chainlink.Request memory _req
  ) internal pure returns (bytes memory) {
    return abi.encodeWithSelector(
      bytes4(keccak256("oracleRequest(address,uint256,bytes32,address,bytes4,uint256,uint256,bytes)")),
      0, // overridden by onTokenTransfer
      2_000_000_000_000_000_000, // overridden by onTokenTransfer
      _req.id,
      _req.callbackAddress,
      _req.callbackFunctionId,
      _req.nonce,
      1,
      _req.buf.buf
    );
  }
}