diff --git a/src/Config.zig b/src/Config.zig index 1a93c88c..da5aa0c8 100644 --- a/src/Config.zig +++ b/src/Config.zig @@ -559,7 +559,7 @@ fn parseMcpArgs( continue; } - log.fatal(.app, "unknown argument", .{ .mode = "mcp", .arg = opt }); + log.fatal(.mcp, "unknown argument", .{ .mode = "mcp", .arg = opt }); return error.UnkownOption; } diff --git a/src/main.zig b/src/main.zig index 1d3b51fb..4a131257 100644 --- a/src/main.zig +++ b/src/main.zig @@ -131,7 +131,7 @@ fn run(allocator: Allocator, main_arena: Allocator) !void { }; }, .mcp => { - log.info(.app, "starting MCP server", .{}); + log.info(.mcp, "starting server", .{}); log.opts.format = .logfmt; diff --git a/src/mcp/Server.zig b/src/mcp/Server.zig index c8843b5a..535123fb 100644 --- a/src/mcp/Server.zig +++ b/src/mcp/Server.zig @@ -15,7 +15,7 @@ browser: *lp.Browser, session: *lp.Session, page: *lp.Page, -is_running: std.atomic.Value(bool) = std.atomic.Value(bool).init(false), +is_running: std.atomic.Value(bool) = .init(false), stdout_mutex: std.Thread.Mutex = .{}, @@ -29,12 +29,12 @@ pub fn init(allocator: std.mem.Allocator, app: *App) !*Self { self.http_client = try app.http.createClient(allocator); errdefer self.http_client.deinit(); - self.notification = try lp.Notification.init(allocator); + self.notification = try .init(allocator); errdefer self.notification.deinit(); self.browser = try allocator.create(lp.Browser); errdefer allocator.destroy(self.browser); - self.browser.* = try lp.Browser.init(app, .{ .http_client = self.http_client }); + self.browser.* = try .init(app, .{ .http_client = self.http_client }); errdefer self.browser.deinit(); self.session = try self.browser.newSession(self.notification); diff --git a/src/mcp/router.zig b/src/mcp/router.zig index 213db4fe..8966b922 100644 --- a/src/mcp/router.zig +++ b/src/mcp/router.zig @@ -28,7 +28,7 @@ pub fn processRequests(server: *Server) !void { defer arena.deinit(); handleMessage(server, arena.allocator(), msg) catch |err| { - log.err(.app, "MCP Error processing message", .{ .err = err }); + log.warn(.mcp, "Error processing message", .{ .err = err }); // We should ideally send a parse error response back, but it's hard to extract the ID if parsing failed entirely. }; } @@ -38,14 +38,14 @@ fn handleMessage(server: *Server, arena: std.mem.Allocator, msg: []const u8) !vo const parsed = std.json.parseFromSliceLeaky(protocol.Request, arena, msg, .{ .ignore_unknown_fields = true, }) catch |err| { - log.err(.app, "MCP JSON Parse Error", .{ .err = err, .msg = msg }); + log.warn(.mcp, "JSON Parse Error", .{ .err = err, .msg = msg }); return; }; if (parsed.id == null) { // It's a notification if (std.mem.eql(u8, parsed.method, "notifications/initialized")) { - log.info(.app, "MCP Client Initialized", .{}); + log.info(.mcp, "Client Initialized", .{}); } return; }