From fd2c907274095031917e6279db436186d95d74fc Mon Sep 17 00:00:00 2001
From: metamuffin <metamuffin@disroot.org>
Date: Sat, 29 Jun 2024 19:04:57 +0200
Subject: optionally persist messages

---
 server/src/customer/mod.rs | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

(limited to 'server/src/customer/mod.rs')

diff --git a/server/src/customer/mod.rs b/server/src/customer/mod.rs
index d1f49655..92e6e94c 100644
--- a/server/src/customer/mod.rs
+++ b/server/src/customer/mod.rs
@@ -140,6 +140,7 @@ impl DemandState {
                             id,
                             PacketS::Communicate {
                                 message: Some(Message::Item(data.demand(demand).from)),
+                                persist: true,
                             },
                         ));
                         p.state = CustomerState::Waiting {
@@ -157,7 +158,13 @@ impl DemandState {
                     debug!("{id:?} waiting");
                     *timeout -= dt;
                     if *timeout <= 0. {
-                        packets_out.push((id, PacketS::Communicate { message: None }));
+                        packets_out.push((
+                            id,
+                            PacketS::Communicate {
+                                message: None,
+                                persist: true,
+                            },
+                        ));
                         let path = find_path(
                             &self.walkable,
                             p.movement.position.as_ivec2(),
@@ -191,7 +198,13 @@ impl DemandState {
                                 }
                             });
                         if let Some(pos) = demand_pos {
-                            packets_out.push((id, PacketS::Communicate { message: None }));
+                            packets_out.push((
+                                id,
+                                PacketS::Communicate {
+                                    persist: true,
+                                    message: None,
+                                },
+                            ));
                             for edge in [true, false] {
                                 packets_out.push((id, PacketS::Interact { pos, edge }))
                             }
-- 
cgit v1.2.3-70-g09d2