jobbid fixed

iosis-tech · Aug 10, 2024 · 142a840 · 142a840
1 parent 26bbc38
commit 142a840
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 4 deletions.
diff --git a/crates/common/src/job.rs b/crates/common/src/job.rs
@@ -103,6 +103,7 @@ impl Display for Job {
 
 #[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Serialize, Deserialize)]
 pub struct JobBid {
+    pub identity: PeerId,
     pub job_hash: u64,
     pub price: u64,
 }

diff --git a/crates/delegator/src/delegator.rs b/crates/delegator/src/delegator.rs
@@ -52,14 +52,14 @@ impl Delegator {
                         },
                         Some(event) = swarm_events.next() => {
                             match event {
-                                PeerBehaviourEvent::Gossipsub(gossipsub::Event::Message { message, propagation_source, .. }) => {
+                                PeerBehaviourEvent::Gossipsub(gossipsub::Event::Message { message, .. }) => {
                                     if message.topic == Topic::Market.into() {
                                         match serde_json::from_slice::<MarketMessage>(&message.data)? {
                                             MarketMessage::JobBid(job_bid) => {
                                                 if let Some(bid_tx) =  job_hash_store.get_mut(&job_bid.job_hash) {
-                                                    info!("Received job bid: {} price: {} from: {}", job_bid.job_hash, job_bid.price, propagation_source);
-                                                    bid_tx.send((job_bid.price, propagation_source)).await?;
-                                                    events_tx.send((job_bid.job_hash, DelegatorEvent::BidReceived(propagation_source)))?;
+                                                    info!("Received job bid: {} price: {} from: {}", job_bid.job_hash, job_bid.price, job_bid.identity);
+                                                    bid_tx.send((job_bid.price, job_bid.identity)).await?;
+                                                    events_tx.send((job_bid.job_hash, DelegatorEvent::BidReceived(job_bid.identity)))?;
                                                 }
                                             }
                                             _ => {}

diff --git a/crates/executor/src/executor.rs b/crates/executor/src/executor.rs
@@ -53,6 +53,7 @@ impl Executor {
                                                     .send(GossipsubMessage {
                                                         topic: Topic::Market.into(),
                                                         data: serde_json::to_vec(&MarketMessage::JobBid(JobBid {
+                                                            identity,
                                                             job_hash: hash!(job),
                                                             price: (runner_scheduler.len() * prover_scheduler.len()) as u64,
                                                         }))?