feat(coprocessor): add copro context ID for input proofs

Add support for a separate uin256 context ID in the event listened to
by the gw-listener and using it to sign a `CiphertextVerification` in
transaction-sender.

Related to #211

Author: dartdart26

coprocessor/fhevm-engine/db-migration/migrations/20250924120045_verify_proofs_coprocessor_context_id.sql

@@ -0,0 +1,2 @@
+ALTER TABLE verify_proofs
+ADD COLUMN IF NOT EXISTS coprocessor_context_id BYTEA NOT NULL DEFAULT ''::BYTEA;

…4083caf37a564283a97822f0efb309f2ea8.json …6b78eb1966540df01871b27fe8383c0d52e.jsoncoprocessor/fhevm-engine/gw-listener/.sqlx/query-774d0833f523257d42044019619094083caf37a564283a97822f0efb309f2ea8.json renamed to coprocessor/fhevm-engine/gw-listener/.sqlx/query-989cdc420a832541b7df7be83086f6b78eb1966540df01871b27fe8383c0d52e.json coprocessor/fhevm-engine/gw-listener/.sqlx/query-774d0833f523257d42044019619094083caf37a564283a97822f0efb309f2ea8.json renamed to coprocessor/fhevm-engine/gw-listener/.sqlx/query-989cdc420a832541b7df7be83086f6b78eb1966540df01871b27fe8383c0d52e.json

@@ -6,6 +6,7 @@ pragma solidity ^0.8.28;
 contract InputVerification {
     event VerifyProofRequest(
         uint256 indexed zkProofId,
+        uint256 indexed coprocessorContextId,
         uint256 indexed contractChainId,
         address contractAddress,
         address userAddress,
@@ -14,6 +15,7 @@ contract InputVerification {
     );
 
     uint256 zkProofIdCounter = 0;
+    uint256 public coprocessorContextId = 7;
 
     function verifyProofRequest(
         uint256 contractChainId,
@@ -26,6 +28,7 @@ contract InputVerification {
         zkProofIdCounter += 1;
         emit VerifyProofRequest(
             zkProofId,
+            coprocessorContextId,
             contractChainId,
             contractAddress,
             userAddress,

…64262d55e5d5b1dcbf40ae6d829fbc02970.json …351137d9561c952cceb0eb1fdf66c33c59d.jsoncoprocessor/fhevm-engine/gw-listener/.sqlx/query-d1a294c48d897dc9685c95c8a59be64262d55e5d5b1dcbf40ae6d829fbc02970.json renamed to coprocessor/fhevm-engine/gw-listener/.sqlx/query-a06d342308b9f63791f9fdfc1568b351137d9561c952cceb0eb1fdf66c33c59d.json coprocessor/fhevm-engine/gw-listener/.sqlx/query-d1a294c48d897dc9685c95c8a59be64262d55e5d5b1dcbf40ae6d829fbc02970.json renamed to coprocessor/fhevm-engine/gw-listener/.sqlx/query-a06d342308b9f63791f9fdfc1568b351137d9561c952cceb0eb1fdf66c33c59d.json

@@ -136,12 +136,13 @@ impl<P: Provider<Ethereum> + Clone + 'static> GatewayListener<P> {
                     // TODO: check if we can avoid the cast from u256 to i64
                     sqlx::query!(
                         "WITH ins AS (
-                            INSERT INTO verify_proofs (zk_proof_id, chain_id, contract_address, user_address, input, extra_data)
-                            VALUES ($1, $2, $3, $4, $5, $6)
+                            INSERT INTO verify_proofs (zk_proof_id, coprocessor_context_id, chain_id, contract_address, user_address, input, extra_data)
+                            VALUES ($1, $2, $3, $4, $5, $6, $7)
                             ON CONFLICT(zk_proof_id) DO NOTHING
                         )
-                        SELECT pg_notify($7, '')",
+                        SELECT pg_notify($8, '')",
                         request.zkProofId.to::<i64>(),
+                        &request.coprocessorContextId.to_le_bytes::<32>(),
                         request.contractChainId.to::<i64>(),
                         request.contractAddress.to_string(),
                         request.userAddress.to_string(),

coprocessor/fhevm-engine/gw-listener/contracts/InputVerification.sol

@@ -101,15 +101,22 @@ async fn verify_proof_request_inserted_into_db() -> anyhow::Result<()> {
     let receipt = pending_txn.get_receipt().await?;
     assert!(receipt.status());
 
+    let coprocessor_context_id = input_verification
+        .coprocessorContextId()
+        .call()
+        .await?
+        .to_le_bytes::<32>();
+
     loop {
         let rows = sqlx::query!(
-            "SELECT zk_proof_id, chain_id, contract_address, user_address, input, extra_data
+            "SELECT zk_proof_id, coprocessor_context_id, chain_id, contract_address, user_address, input, extra_data
              FROM verify_proofs",
         )
         .fetch_all(&env.db_pool)
         .await?;
         if !rows.is_empty() {
             let row = &rows[0];
+            assert_eq!(row.coprocessor_context_id, coprocessor_context_id);
             assert_eq!(row.chain_id, 42);
             assert_eq!(row.contract_address, contract_address.to_string());
             assert_eq!(row.user_address, user_address.to_string());