Compare with caller from message

engineapi/engineapi/contracts_actions.py

@@ -581,6 +581,7 @@ def complete_call_request(
     db_session: Session,
     tx_hash: str,
     call_request_id: uuid.UUID,
+    caller: str,
 ) -> CallRequest:
     results = (
         db_session.query(CallRequest, RegisteredContract)
@@ -589,6 +590,7 @@ def complete_call_request(
             CallRequest.registered_contract_id == RegisteredContract.id,
         )
         .filter(CallRequest.id == call_request_id)
+        .filter(CallRequest.caller == caller)
         .all()
     )
 

engineapi/engineapi/routes/metatx.py

@@ -449,6 +449,7 @@ async def complete_call_request_route(
             db_session=db_session,
             tx_hash=tx_hash,
             call_request_id=call_request_id,
+            caller=message["caller"],
         )
     except contracts_actions.CallRequestNotFound:
         raise EngineHTTPException(