147 lines
4.6 KiB
Zig
147 lines
4.6 KiB
Zig
|
const std = @import("std");
|
||
|
const zig_builtin = @import("builtin");
|
||
|
const build_options = @import("build_options");
|
||
|
const tracy = @import("tracy.zig");
|
||
|
const known_folders = @import("known-folders");
|
||
|
const Config = @import("Config.zig");
|
||
|
const Server = @import("Server.zig");
|
||
|
const setup = @import("setup.zig");
|
||
|
const readRequestHeader = @import("header.zig").readRequestHeader;
|
||
|
|
||
|
const logger = std.log.scoped(.main);
|
||
|
|
||
|
// Always set this to debug to make std.log call into our handler, then control the runtime
|
||
|
// value in the definition below.
|
||
|
pub const log_level = .debug;
|
||
|
|
||
|
var actual_log_level: std.log.Level = switch (zig_builtin.mode) {
|
||
|
.Debug => .debug,
|
||
|
else => @intToEnum(std.log.Level, @enumToInt(build_options.log_level)), // temporary fix to build failing on release-safe due to a Zig bug
|
||
|
};
|
||
|
|
||
|
fn loop(server: *Server) !void {
|
||
|
var reader = std.io.getStdIn().reader();
|
||
|
|
||
|
while (server.keep_running) {
|
||
|
// Arena used for temporary allocations while handling a request
|
||
|
var arena = std.heap.ArenaAllocator.init(server.allocator);
|
||
|
defer arena.deinit();
|
||
|
|
||
|
const headers = readRequestHeader(arena.allocator(), reader) catch |err| {
|
||
|
logger.err("{s}; exiting!", .{@errorName(err)});
|
||
|
return;
|
||
|
};
|
||
|
const buffer = try arena.allocator().alloc(u8, headers.content_length);
|
||
|
try reader.readNoEof(buffer);
|
||
|
|
||
|
var writer = std.io.getStdOut().writer();
|
||
|
|
||
|
try server.processJsonRpc(writer, &arena, buffer);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
const ConfigWithPath = struct {
|
||
|
config: Config,
|
||
|
config_path: ?[]const u8,
|
||
|
};
|
||
|
|
||
|
fn getConfig(allocator: std.mem.Allocator, config_path: ?[]const u8) !?ConfigWithPath {
|
||
|
if (config_path) |path| {
|
||
|
if (Config.loadFromFile(allocator, path)) |conf| {
|
||
|
return ConfigWithPath{
|
||
|
.config = conf,
|
||
|
.config_path = path,
|
||
|
};
|
||
|
}
|
||
|
std.debug.print(
|
||
|
\\Could not open configuration file '{s}'
|
||
|
\\Falling back to a lookup in the local and global configuration folders
|
||
|
\\
|
||
|
, .{path});
|
||
|
}
|
||
|
|
||
|
if (try known_folders.getPath(allocator, .local_configuration)) |path| {
|
||
|
if (Config.loadFromFolder(allocator, path)) |conf| {
|
||
|
return ConfigWithPath{
|
||
|
.config = conf,
|
||
|
.config_path = path,
|
||
|
};
|
||
|
}
|
||
|
}
|
||
|
|
||
|
if (try known_folders.getPath(allocator, .global_configuration)) |path| {
|
||
|
if (Config.loadFromFolder(allocator, path)) |conf| {
|
||
|
return ConfigWithPath{
|
||
|
.config = conf,
|
||
|
.config_path = path,
|
||
|
};
|
||
|
}
|
||
|
}
|
||
|
|
||
|
return null;
|
||
|
}
|
||
|
|
||
|
const stack_frames = switch (zig_builtin.mode) {
|
||
|
.Debug => 10,
|
||
|
else => 0,
|
||
|
};
|
||
|
|
||
|
pub fn main() anyerror!void {
|
||
|
var gpa_state = std.heap.GeneralPurposeAllocator(.{ .stack_trace_frames = stack_frames }){};
|
||
|
defer _ = gpa_state.deinit();
|
||
|
|
||
|
var allocator = gpa_state.allocator();
|
||
|
if (tracy.enable_allocation) {
|
||
|
allocator = tracy.tracyAllocator(allocator).allocator();
|
||
|
}
|
||
|
|
||
|
var config_path: ?[]const u8 = null;
|
||
|
defer if (config_path) |path| allocator.free(path);
|
||
|
|
||
|
// Check arguments.
|
||
|
var args_it = try std.process.ArgIterator.initWithAllocator(allocator);
|
||
|
defer args_it.deinit();
|
||
|
if (!args_it.skip()) @panic("Could not find self argument");
|
||
|
|
||
|
while (args_it.next()) |arg| {
|
||
|
// TODO add --help --version
|
||
|
if (std.mem.eql(u8, arg, "--debug-log")) {
|
||
|
actual_log_level = .debug;
|
||
|
std.debug.print("Enabled debug logging\n", .{});
|
||
|
} else if (std.mem.eql(u8, arg, "--config-path")) {
|
||
|
var path = args_it.next() orelse {
|
||
|
std.debug.print("Expected configuration file path after --config-path argument\n", .{});
|
||
|
std.os.exit(1);
|
||
|
};
|
||
|
config_path = try allocator.dupe(u8, path);
|
||
|
} else if (std.mem.eql(u8, arg, "config") or std.mem.eql(u8, arg, "configure")) {
|
||
|
try setup.wizard(allocator);
|
||
|
return;
|
||
|
} else {
|
||
|
std.debug.print("Unrecognized argument {s}\n", .{arg});
|
||
|
std.os.exit(1);
|
||
|
}
|
||
|
}
|
||
|
|
||
|
var new_config = blk: {
|
||
|
if (try getConfig(allocator, config_path)) |config| {
|
||
|
break :blk config;
|
||
|
}
|
||
|
logger.info("No config file zls.json found.", .{});
|
||
|
break :blk ConfigWithPath{
|
||
|
.config = Config{},
|
||
|
.config_path = null,
|
||
|
};
|
||
|
};
|
||
|
|
||
|
var server = try Server.init(
|
||
|
allocator,
|
||
|
new_config.config,
|
||
|
new_config.config_path,
|
||
|
actual_log_level,
|
||
|
);
|
||
|
defer server.deinit();
|
||
|
|
||
|
try loop(&server);
|
||
|
}
|