direct-request-job_template.toml

type = "directrequest"
schemaVersion = 1
name = "Get > Uint256 {{OPERATOR_ADDRESS}} {{UUID}} (direct request)"
# Optional External Job ID: Automatically generated if unspecified
# externalJobID = "b1d42cd5-4a3a-4200-b1f7-25a68e48aad8"
contractAddress = "{{OPERATOR_ADDRESS}}"
maxTaskDuration = "0s"
observationSource = """
   decode_log   [type="ethabidecodelog"
                 abi="OracleRequest(bytes32 indexed specId, address requester, bytes32 requestId, uint256 payment, address callbackAddr, bytes4 callbackFunctionId, uint256 cancelExpiration, uint256 dataVersion, bytes data)"
                 data="$(jobRun.logData)"
                 topics="$(jobRun.logTopics)"]

   decode_cbor  [type="cborparse" data="$(decode_log.data)"]
   fetch        [type="http" method=GET url="$(decode_cbor.get)" allowUnrestrictedNetworkAccess="true"]
   parse        [type="jsonparse" path="$(decode_cbor.path)" data="$(fetch)"]
   multiply     [type="multiply" input="$(parse)" times="$(decode_cbor.times)"]
   encode_data  [type="ethabiencode" abi="(bytes32 requestId, uint256 value)" data="{ \\"requestId\\": $(decode_log.requestId), \\"value\\": $(multiply) }"]
   encode_tx    [type="ethabiencode"
                 abi="fulfillOracleRequest2(bytes32 requestId, uint256 payment, address callbackAddress, bytes4 callbackFunctionId, uint256 expiration, bytes calldata data)"
                 data="{\\"requestId\\": $(decode_log.requestId), \\"payment\\": $(decode_log.payment), \\"callbackAddress\\": $(decode_log.callbackAddr), \\"callbackFunctionId\\": $(decode_log.callbackFunctionId), \\"expiration\\": $(decode_log.cancelExpiration), \\"data\\": $(encode_data)}"
                ]
   submit_tx    [type="ethtx" to="{{OPERATOR_ADDRESS}}" data="$(encode_tx)"]

   decode_log -> decode_cbor -> fetch -> parse -> multiply -> encode_data -> encode_tx -> submit_tx
"""