Much better cleanup, still fast B)

1 files changed, 11 insertions, 1 deletions

diff --git a/src/server/message_parser.zig b/src/server/message_parser.zig
index bd14ec7..68e7a20 100644
--- a/src/server/message_parser.zig
+++ b/src/server/message_parser.zig
@@ -137,6 +137,16 @@ pub const Message = union(MessageType) {
             alloc.free(self.payload);
             if (self.reply_to) |r| alloc.free(r);
         }
+
+        pub fn toMsg(self: Pub, alloc: std.mem.Allocator, sid: []const u8) !Msg {
+            const res: Msg = .{
+                .subject = self.subject,
+                .sid = sid,
+                .reply_to = self.reply_to,
+                .payload = self.payload,
+            };
+            return res.dupe(alloc);
+        }
     };
     pub const Sub = struct {
         /// The subject name to subscribe to.
@@ -177,7 +187,7 @@ pub const Message = union(MessageType) {
             errdefer alloc.free(res.subject);
             res.sid = try alloc.dupe(u8, self.sid);
             errdefer alloc.free(res.sid);
-            res.reply_to = if (self.reply_to) |r| alloc.dupe(u8, r) else null;
+            res.reply_to = if (self.reply_to) |r| try alloc.dupe(u8, r) else null;
             errdefer if (res.reply_to) |r| alloc.free(r);
             res.payload = try alloc.dupe(u8, self.payload);
             errdefer alloc.free(res.payload);