protobuf reuse

motis-project · Nov 14, 2024 · 868731e · 868731e
1 parent 91c5417
commit 868731e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 5 deletions.
diff --git a/.pkg b/.pkg
@@ -1,7 +1,7 @@
 [nigiri]
   [email protected]:motis-project/nigiri.git
   branch=master
-  commit=e3e83f7ced038401748e081c79ccd991ab6a8b61
+  commit=468657541e41d118cc74edcd6625eefd4f21df82
 [cista]
   [email protected]:felixguendling/cista.git
   branch=master

diff --git a/.pkg.lock b/.pkg.lock
@@ -1,4 +1,4 @@
-3713461052711760570
+17884592824398267590
 cista 847b27100b7e730370b810ce62206a66b0bf2d79
 zlib-ng 68ab3e2d80253ec5dc3c83691d9ff70477b32cd3
 boost 930f38eb0365ceb7853273e03da4d9e7787abfb9
@@ -24,7 +24,7 @@ opentelemetry-cpp 60770dc9dc63e3543fc87d605b2e88fd53d7a414
 pugixml 60175e80e2f5e97e027ac78f7e14c5acc009ce50
 unordered_dense b33b037377ca966bbdd9cccc3417e46e88f83bfb
 wyhash 1e012b57fc2227a9e583a57e2eacb3da99816d99
-nigiri e3e83f7ced038401748e081c79ccd991ab6a8b61
+nigiri 468657541e41d118cc74edcd6625eefd4f21df82
 conf f9bf4bd83bf55a2170725707e526cbacc45dcc66
 expat 636c9861e8e7c119f3626d1e6c260603ab624516
 libosmium 6e6d6b3081cc8bdf25dda89730e25c36eb995516

diff --git a/src/rt_update.cc b/src/rt_update.cc
@@ -34,6 +34,7 @@ void run_rt_update(boost::asio::io_context& ioc,
       ioc,
       [&c, &tt, &tags, &r]() -> awaitable<void> {
         auto executor = co_await asio::this_coro::executor;
+        auto msg = transit_realtime::FeedMessage{};
         auto timer = asio::steady_timer{executor};
         auto ec = boost::system::error_code{};
         while (true) {
@@ -75,8 +76,8 @@ void run_rt_update(boost::asio::io_context& ioc,
                       auto const res = co_await http_GET(
                           boost::urls::url{ep.url_},
                           ep.headers_.value_or(headers_t{}), timeout);
-                      co_return n::rt::gtfsrt_update_buf(tt, *rtt, src, tag,
-                                                         get_http_body(res));
+                      co_return n::rt::gtfsrt_update_buf(
+                          tt, *rtt, src, tag, get_http_body(res), msg);
                     } catch (std::exception const& e) {
                       n::log(n::log_lvl::error, "motis.rt",
                              "RT FETCH ERROR: tag={}, error={}", tag, e.what());