@@ -134,7 +134,7 @@ pub const PeerState = struct {
134134 if (success ) {
135135 // Increase quality for successful interactions
136136 // Latency bonus: faster = higher quality
137- const latency_bonus = if (latency_ms < 100 )
137+ const latency_bonus : f64 = if (latency_ms < 100 )
138138 0.05
139139 else if (latency_ms < 500 )
140140 0.02
@@ -426,26 +426,24 @@ pub const PersistenceManager = struct {
426426 try json_buffer .appendSlice (self .allocator , " \" peers\" : [\n " );
427427 for (json_obj .peers , 0.. ) | peer , i | {
428428 if (i > 0 ) try json_buffer .appendSlice (self .allocator , ",\n " );
429- try json_buffer .writer (self .allocator ).print (
430- \\ {{
431- \\ "node_id": "{s}",
432- \\ "host": "{s}",
433- \\ "port": {d},
434- \\ "cluster_id": "{s}",
435- \\ "quality_score": {d:.5},
436- \\ "last_seen": {d},
437- \\ "first_seen": {d},
438- \\ "role": "{s}",
439- \\ "tier": "{s}"
440- \\ }}
441- , .{ peer .node_id , peer .host , peer .port , peer .cluster_id , peer .quality_score , peer .last_seen , peer .first_seen , peer .role , peer .tier });
429+ try json_buffer .appendSlice (self .allocator , " {\n " );
430+ try json_buffer .writer (self .allocator ).print (" \" node_id\" : \" {s}\" ,\n " , .{peer .node_id });
431+ try json_buffer .writer (self .allocator ).print (" \" host\" : \" {s}\" ,\n " , .{peer .host });
432+ try json_buffer .writer (self .allocator ).print (" \" port\" : {d},\n " , .{peer .port });
433+ try json_buffer .writer (self .allocator ).print (" \" cluster_id\" : \" {s}\" ,\n " , .{peer .cluster_id });
434+ try json_buffer .writer (self .allocator ).print (" \" quality_score\" : {d:.5},\n " , .{peer .quality_score });
435+ try json_buffer .writer (self .allocator ).print (" \" last_seen\" : {d},\n " , .{peer .last_seen });
436+ try json_buffer .writer (self .allocator ).print (" \" first_seen\" : {d},\n " , .{peer .first_seen });
437+ try json_buffer .writer (self .allocator ).print (" \" role\" : \" {s}\" ,\n " , .{peer .role });
438+ try json_buffer .writer (self .allocator ).print (" \" tier\" : \" {s}\" \n " , .{peer .tier });
439+ try json_buffer .appendSlice (self .allocator , " }" );
442440 }
443441 try json_buffer .appendSlice (self .allocator , "\n ],\n " );
444442 try json_buffer .writer (self .allocator ).print (" \" version\" : {d},\n " , .{json_obj .version });
445443 try json_buffer .writer (self .allocator ).print (" \" last_updated\" : {d}\n " , .{json_obj .last_updated });
446444 try json_buffer .appendSlice (self .allocator , "}\n " );
447445
448- const json_string = json_buffer .toOwnedSlice (self .allocator );
446+ const json_string = try json_buffer .toOwnedSlice (self .allocator );
449447 defer self .allocator .free (json_string );
450448
451449 // Write to file
@@ -499,7 +497,7 @@ pub const PersistenceManager = struct {
499497
500498test "ClusterState init and add peer" {
501499 const allocator = std .testing .allocator ;
502- var state = ClusterState .init (allocator , "test-cluster" , "test-node" );
500+ var state = ClusterState .init ("test-cluster" , "test-node" );
503501 defer state .deinit (allocator );
504502
505503 const now = @as (u64 , @intCast (std .time .timestamp ()));
@@ -523,7 +521,7 @@ test "ClusterState init and add peer" {
523521
524522test "ClusterState get peer" {
525523 const allocator = std .testing .allocator ;
526- var state = ClusterState .init (allocator , "test-cluster" , "test-node" );
524+ var state = ClusterState .init ("test-cluster" , "test-node" );
527525 defer state .deinit (allocator );
528526
529527 const now = @as (u64 , @intCast (std .time .timestamp ()));
@@ -548,7 +546,7 @@ test "ClusterState get peer" {
548546
549547test "ClusterState healthy peers filter" {
550548 const allocator = std .testing .allocator ;
551- var state = ClusterState .init (allocator , "test-cluster" , "test-node" );
549+ var state = ClusterState .init ("test-cluster" , "test-node" );
552550 defer state .deinit (allocator );
553551
554552 const now = @as (u64 , @intCast (std .time .timestamp ()));
@@ -622,7 +620,7 @@ test "PersistenceManager save and load" {
622620 defer manager .deinit ();
623621
624622 const now = @as (u64 , @intCast (std .time .timestamp ()));
625- var state = ClusterState .init (allocator , "test-cluster" , "test-node" );
623+ var state = ClusterState .init ("test-cluster" , "test-node" );
626624
627625 const peer = PeerState {
628626 .node_id = "peer-1" ,
@@ -645,7 +643,7 @@ test "PersistenceManager save and load" {
645643 var manager2 = PersistenceManager .init (allocator );
646644 defer manager2 .deinit ();
647645
648- const loaded = try manager2 .load ();
646+ var loaded = try manager2 .load ();
649647 try std .testing .expect (loaded != null );
650648
651649 try std .testing .expectEqualStrings ("test-cluster" , loaded .? .cluster_id );
0 commit comments