diff --git a/.gitattributes b/.gitattributes new file mode 100644 index 0000000000000000000000000000000000000000..403c8ef104b8bf3476b7a5155be3158eae28734e --- /dev/null +++ b/.gitattributes @@ -0,0 +1,3 @@ +* text=auto +*.zig text eol=lf +zigmod.* text eol=lf diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000000000000000000000000000000000000..755aa68f03a30361a954cb1bfbf823ba9fa604ae --- /dev/null +++ b/.gitignore @@ -0,0 +1,6 @@ +.zig-cache +zig-out +.zigmod +deps.zig +files.zig +zigmod.lock diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000000000000000000000000000000000000..c3c054f8a15f0007a70eab1ddf01bf95c0858bed --- /dev/null +++ b/LICENSE @@ -0,0 +1,307 @@ +Mozilla Public License Version 2.0 + +1. Definitions + + 1.1. "Contributor" means each individual or legal entity that creates, +contributes to the creation of, or owns Covered Software. + + 1.2. "Contributor Version" means the combination of the Contributions of +others (if any) used by a Contributor and that particular Contributor's +Contribution. + + 1.3. "Contribution" means Covered Software of a particular Contributor. + + 1.4. "Covered Software" means Source Code Form to which the initial +Contributor has attached the notice in Exhibit A, the Executable Form of such +Source Code Form, and Modifications of such Source Code Form, in each case +including portions thereof. + + 1.5. "Incompatible With Secondary Licenses" means + + (a) that the initial Contributor has attached the notice described +in Exhibit B to the Covered Software; or + + (b) that the Covered Software was made available under the terms of +version 1.1 or earlier of the License, but not also under the terms of a +Secondary License. + + 1.6. "Executable Form" means any form of the work other than Source Code +Form. + + 1.7. "Larger Work" means a work that combines Covered Software with other +material, in a separate file or files, that is not Covered Software. + + 1.8. "License" means this document. + + 1.9. "Licensable" means having the right to grant, to the maximum extent +possible, whether at the time of the initial grant or subsequently, any and +all of the rights conveyed by this License. + + 1.10. "Modifications" means any of the following: + + (a) any file in Source Code Form that results from an addition to, +deletion from, or modification of the contents of Covered Software; or + + (b) any new file in Source Code Form that contains any Covered +Software. + + 1.11. "Patent Claims" of a Contributor means any patent claim(s), +including without limitation, method, process, and apparatus claims, in any +patent Licensable by such Contributor that would be infringed, but for the +grant of the License, by the making, using, selling, offering for sale, having +made, import, or transfer of either its Contributions or its Contributor +Version. + + 1.12. "Secondary License" means either the GNU General Public License, +Version 2.0, the GNU Lesser General Public License, Version 2.1, the GNU +Affero General Public License, Version 3.0, or any later versions of those +licenses. + + 1.13. "Source Code Form" means the form of the work preferred for making +modifications. + + 1.14. "You" (or "Your") means an individual or a legal entity exercising +rights under this License. For legal entities, "You" includes any entity that +controls, is controlled by, or is under common control with You. For purposes +of this definition, "control" means (a) the power, direct or indirect, to +cause the direction or management of such entity, whether by contract or +otherwise, or (b) ownership of more than fifty percent (50%) of the +outstanding shares or beneficial ownership of such entity. + +2. License Grants and Conditions + + 2.1. Grants + Each Contributor hereby grants You a world-wide, royalty-free, +non-exclusive license: + + (a) under intellectual property rights (other than patent or +trademark) Licensable by such Contributor to use, reproduce, make available, +modify, display, perform, distribute, and otherwise exploit its Contributions, +either on an unmodified basis, with Modifications, or as part of a Larger +Work; and + + (b) under Patent Claims of such Contributor to make, use, sell, +offer for sale, have made, import, and otherwise transfer either its +Contributions or its Contributor Version. + + 2.2. Effective Date + The licenses granted in Section 2.1 with respect to any Contribution +become effective for each Contribution on the date the Contributor first +distributes such Contribution. + + 2.3. Limitations on Grant Scope + The licenses granted in this Section 2 are the only rights granted under +this License. No additional rights or licenses will be implied from the +distribution or licensing of Covered Software under this License. +Notwithstanding Section 2.1(b) above, no patent license is granted by a +Contributor: + + (a) for any code that a Contributor has removed from Covered +Software; or + + (b) for infringements caused by: (i) Your and any other third +party's modifications of Covered Software, or (ii) the combination of its +Contributions with other software (except as part of its Contributor Version); +or + + (c) under Patent Claims infringed by Covered Software in the absence +of its Contributions. + + This License does not grant any rights in the trademarks, service marks, +or logos of any Contributor (except as may be necessary to comply with the +notice requirements in Section 3.4). + + 2.4. Subsequent Licenses + No Contributor makes additional grants as a result of Your choice to +distribute the Covered Software under a subsequent version of this License +(see Section 10.2) or under the terms of a Secondary License (if permitted +under the terms of Section 3.3). + + 2.5. Representation + Each Contributor represents that the Contributor believes its +Contributions are its original creation(s) or it has sufficient rights to +grant the rights to its Contributions conveyed by this License. + + 2.6. Fair Use + This License is not intended to limit any rights You have under +applicable copyright doctrines of fair use, fair dealing, or other +equivalents. + + 2.7. Conditions + Sections 3.1, 3.2, 3.3, and 3.4 are conditions of the licenses granted in +Section 2.1. + +3. Responsibilities + + 3.1. Distribution of Source Form + All distribution of Covered Software in Source Code Form, including any +Modifications that You create or to which You contribute, must be under the +terms of this License. You must inform recipients that the Source Code Form of +the Covered Software is governed by the terms of this License, and how they +can obtain a copy of this License. You may not attempt to alter or restrict +the recipients' rights in the Source Code Form. + + 3.2. Distribution of Executable Form + If You distribute Covered Software in Executable Form then: + + (a) such Covered Software must also be made available in Source Code +Form, as described in Section 3.1, and You must inform recipients of the +Executable Form how they can obtain a copy of such Source Code Form by +reasonable means in a timely manner, at a charge no more than the cost of +distribution to the recipient; and + + (b) You may distribute such Executable Form under the terms of this +License, or sublicense it under different terms, provided that the license for +the Executable Form does not attempt to limit or alter the recipients' rights +in the Source Code Form under this License. + + 3.3. Distribution of a Larger Work + You may create and distribute a Larger Work under terms of Your choice, +provided that You also comply with the requirements of this License for the +Covered Software. If the Larger Work is a combination of Covered Software with +a work governed by one or more Secondary Licenses, and the Covered Software is +not Incompatible With Secondary Licenses, this License permits You to +additionally distribute such Covered Software under the terms of such +Secondary License(s), so that the recipient of the Larger Work may, at their +option, further distribute the Covered Software under the terms of either this +License or such Secondary License(s). + + 3.4. Notices + You may not remove or alter the substance of any license notices +(including copyright notices, patent notices, disclaimers of warranty, or +limitations of liability) contained within the Source Code Form of the Covered +Software, except that You may alter any license notices to the extent required +to remedy known factual inaccuracies. + + 3.5. Application of Additional Terms + You may choose to offer, and to charge a fee for, warranty, support, +indemnity or liability obligations to one or more recipients of Covered +Software. However, You may do so only on Your own behalf, and not on behalf of +any Contributor. You must make it absolutely clear that any such warranty, +support, indemnity, or liability obligation is offered by You alone, and You +hereby agree to indemnify every Contributor for any liability incurred by such +Contributor as a result of warranty, support, indemnity or liability terms You +offer. You may include additional disclaimers of warranty and limitations of +liability specific to any jurisdiction. + +4. Inability to Comply Due to Statute or Regulation +If it is impossible for You to comply with any of the terms of this License +with respect to some or all of the Covered Software due to statute, judicial +order, or regulation then You must: (a) comply with the terms of this License +to the maximum extent possible; and (b) describe the limitations and the code +they affect. Such description must be placed in a text file included with all +distributions of the Covered Software under this License. Except to the extent +prohibited by statute or regulation, such description must be sufficiently +detailed for a recipient of ordinary skill to be able to understand it. + +5. Termination + + 5.1. The rights granted under this License will terminate automatically +if You fail to comply with any of its terms. However, if You become compliant, +then the rights granted under this License from a particular Contributor are +reinstated (a) provisionally, unless and until such Contributor explicitly and +finally terminates Your grants, and (b) on an ongoing basis, if such +Contributor fails to notify You of the non-compliance by some reasonable means +prior to 60 days after You have come back into compliance. Moreover, Your +grants from a particular Contributor are reinstated on an ongoing basis if +such Contributor notifies You of the non-compliance by some reasonable means, +this is the first time You have received notice of non-compliance with this +License from such Contributor, and You become compliant prior to 30 days after +Your receipt of the notice. + + 5.2. If You initiate litigation against any entity by asserting a patent +infringement claim (excluding declaratory judgment actions, counter-claims, +and cross-claims) alleging that a Contributor Version directly or indirectly +infringes any patent, then the rights granted to You by any and all +Contributors for the Covered Software under Section 2.1 of this License shall +terminate. + + 5.3. In the event of termination under Sections 5.1 or 5.2 above, all end +user license agreements (excluding distributors and resellers) which have been +validly granted by You or Your distributors under this License prior to +termination shall survive termination. + +6. Disclaimer of Warranty +Covered Software is provided under this License on an "as is" basis, without +warranty of any kind, either expressed, implied, or statutory, including, +without limitation, warranties that the Covered Software is free of defects, +merchantable, fit for a particular purpose or non-infringing. The entire risk +as to the quality and performance of the Covered Software is with You. Should +any Covered Software prove defective in any respect, You (not any Contributor) +assume the cost of any necessary servicing, repair, or correction. This +disclaimer of warranty constitutes an essential part of this License. No use +of any Covered Software is authorized under this License except under this +disclaimer. + +7. Limitation of Liability +Under no circumstances and under no legal theory, whether tort (including +negligence), contract, or otherwise, shall any Contributor, or anyone who +distributes Covered Software as permitted above, be liable to You for any +direct, indirect, special, incidental, or consequential damages of any +character including, without limitation, damages for lost profits, loss of +goodwill, work stoppage, computer failure or malfunction, or any and all other +commercial damages or losses, even if such party shall have been informed of +the possibility of such damages. This limitation of liability shall not apply +to liability for death or personal injury resulting from such party's +negligence to the extent applicable law prohibits such limitation. Some +jurisdictions do not allow the exclusion or limitation of incidental or +consequential damages, so this exclusion and limitation may not apply to You. + +8. Litigation +Any litigation relating to this License may be brought only in the courts of a +jurisdiction where the defendant maintains its principal place of business and +such litigation shall be governed by laws of that jurisdiction, without +reference to its conflict-of-law provisions. Nothing in this Section shall +prevent a party's ability to bring cross-claims or counter-claims. + +9. Miscellaneous +This License represents the complete agreement concerning the subject matter +hereof. If any provision of this License is held to be unenforceable, such +provision shall be reformed only to the extent necessary to make it +enforceable. Any law or regulation which provides that the language of a +contract shall be construed against the drafter shall not be used to construe +this License against a Contributor. + +10. Versions of the License + + 10.1. New Versions + Mozilla Foundation is the license steward. Except as provided in Section +10.3, no one other than the license steward has the right to modify or publish +new versions of this License. Each version will be given a distinguishing +version number. + + 10.2. Effect of New Versions + You may distribute the Covered Software under the terms of the version of +the License under which You originally received the Covered Software, or under +the terms of any subsequent version published by the license steward. + + 10.3. Modified Versions + If you create software not governed by this License, and you want to +create a new license for such software, you may create and use a modified +version of this License if you rename the license and remove any references to +the name of the license steward (except to note that such modified license +differs from this License). + + 10.4. Distributing Source Code Form that is Incompatible With Secondary +Licenses + If You choose to distribute Source Code Form that is Incompatible With +Secondary Licenses under the terms of this version of the License, the notice +described in Exhibit B of this License must be attached. + +Exhibit A - Source Code Form License Notice + + This Source Code Form is subject to the terms of the Mozilla Public +License, v. 2.0. If a copy of the MPL was not distributed with this file, You +can obtain one at http://mozilla.org/MPL/2.0/. + +If it is not possible or desirable to put the notice in a particular file, +then You may include the notice in a location (such as a LICENSE file in a +relevant directory) where a recipient would be likely to look for such a +notice. + +You may add additional accurate notices of copyright ownership. + +Exhibit B - "Incompatible With Secondary Licenses" Notice + + This Source Code Form is "Incompatible With Secondary Licenses", as +defined by the Mozilla Public License, v. 2.0. diff --git a/README.md b/README.md new file mode 100644 index 0000000000000000000000000000000000000000..0d78c7fccc4dc4f5fdc9cdb0d705d47776b9ba43 --- /dev/null +++ b/README.md @@ -0,0 +1,9 @@ +# zig-net-http + +![loc](https://sloc.xyz/github/nektro/zig-net-http) +[![license](https://img.shields.io/github/license/nektro/zig-net-http.svg)](https://github.com/nektro/zig-net-http/blob/master/LICENSE) +[![nektro @ github sponsors](https://img.shields.io/badge/sponsors-nektro-purple?logo=github)](https://github.com/sponsors/nektro) +[![Zig](https://img.shields.io/badge/Zig-0.14-f7a41d)](https://ziglang.org/) +[![Zigmod](https://img.shields.io/badge/Zigmod-latest-f7a41d)](https://github.com/nektro/zigmod) + +An alternative HTTP server/client layer. diff --git a/build.zig b/build.zig new file mode 100644 index 0000000000000000000000000000000000000000..3271cf016af8a1023a18d9e377fc6e89dee60990 --- /dev/null +++ b/build.zig @@ -0,0 +1,23 @@ +const std = @import("std"); +const deps = @import("./deps.zig"); + +pub fn build(b: *std.Build) void { + const target = b.standardTargetOptions(.{}); + const mode = b.option(std.builtin.Mode, "mode", "") orelse .Debug; + const disable_llvm = b.option(bool, "disable_llvm", "use the non-llvm zig codegen") orelse false; + + const tests = b.addTest(.{ + .root_source_file = b.path("test.zig"), + .target = target, + .optimize = mode, + }); + deps.addAllTo(tests); + tests.use_llvm = !disable_llvm; + tests.use_lld = !disable_llvm; + + const test_step = b.step("test", "Run all library tests"); + const tests_run = b.addRunArtifact(tests); + tests_run.setCwd(b.path(".")); + tests_run.has_side_effects = true; + test_step.dependOn(&tests_run.step); +} diff --git a/http.zig b/http.zig new file mode 100644 index 0000000000000000000000000000000000000000..ff26d186e44f3d3f1a5233dc44c104305a1294a9 --- /dev/null +++ b/http.zig @@ -0,0 +1,287 @@ +const std = @import("std"); +const builtin = @import("builtin"); +const net = @import("net"); +const url = @import("url"); +const nio = @import("nio"); + +pub const Method = enum { + GET, + HEAD, + POST, + PUT, + DELETE, + CONNECT, + OPTIONS, + TRACE, + PATCH, +}; + +pub const Status = enum(u10) { + @"continue" = 100, // RFC7231, Section 6.2.1 + switching_protocols = 101, // RFC7231, Section 6.2.2 + processing = 102, // RFC2518 + early_hints = 103, // RFC8297 + + ok = 200, // RFC7231, Section 6.3.1 + created = 201, // RFC7231, Section 6.3.2 + accepted = 202, // RFC7231, Section 6.3.3 + non_authoritative_info = 203, // RFC7231, Section 6.3.4 + no_content = 204, // RFC7231, Section 6.3.5 + reset_content = 205, // RFC7231, Section 6.3.6 + partial_content = 206, // RFC7233, Section 4.1 + multi_status = 207, // RFC4918 + already_reported = 208, // RFC5842 + im_used = 226, // RFC3229 + + multiple_choice = 300, // RFC7231, Section 6.4.1 + moved_permanently = 301, // RFC7231, Section 6.4.2 + found = 302, // RFC7231, Section 6.4.3 + see_other = 303, // RFC7231, Section 6.4.4 + not_modified = 304, // RFC7232, Section 4.1 + use_proxy = 305, // RFC7231, Section 6.4.5 + temporary_redirect = 307, // RFC7231, Section 6.4.7 + permanent_redirect = 308, // RFC7538 + + bad_request = 400, // RFC7231, Section 6.5.1 + unauthorized = 401, // RFC7235, Section 3.1 + payment_required = 402, // RFC7231, Section 6.5.2 + forbidden = 403, // RFC7231, Section 6.5.3 + not_found = 404, // RFC7231, Section 6.5.4 + method_not_allowed = 405, // RFC7231, Section 6.5.5 + not_acceptable = 406, // RFC7231, Section 6.5.6 + proxy_auth_required = 407, // RFC7235, Section 3.2 + request_timeout = 408, // RFC7231, Section 6.5.7 + conflict = 409, // RFC7231, Section 6.5.8 + gone = 410, // RFC7231, Section 6.5.9 + length_required = 411, // RFC7231, Section 6.5.10 + precondition_failed = 412, // RFC7232, Section 4.2][RFC8144, Section 3.2 + payload_too_large = 413, // RFC7231, Section 6.5.11 + uri_too_long = 414, // RFC7231, Section 6.5.12 + unsupported_media_type = 415, // RFC7231, Section 6.5.13][RFC7694, Section 3 + range_not_satisfiable = 416, // RFC7233, Section 4.4 + expectation_failed = 417, // RFC7231, Section 6.5.14 + teapot = 418, // RFC 7168, 2.3.3 + misdirected_request = 421, // RFC7540, Section 9.1.2 + unprocessable_entity = 422, // RFC4918 + locked = 423, // RFC4918 + failed_dependency = 424, // RFC4918 + too_early = 425, // RFC8470 + upgrade_required = 426, // RFC7231, Section 6.5.15 + precondition_required = 428, // RFC6585 + too_many_requests = 429, // RFC6585 + request_header_fields_too_large = 431, // RFC6585 + unavailable_for_legal_reasons = 451, // RFC7725 + + internal_server_error = 500, // RFC7231, Section 6.6.1 + not_implemented = 501, // RFC7231, Section 6.6.2 + bad_gateway = 502, // RFC7231, Section 6.6.3 + service_unavailable = 503, // RFC7231, Section 6.6.4 + gateway_timeout = 504, // RFC7231, Section 6.6.5 + http_version_not_supported = 505, // RFC7231, Section 6.6.6 + variant_also_negotiates = 506, // RFC2295 + insufficient_storage = 507, // RFC4918 + loop_detected = 508, // RFC5842 + not_extended = 510, // RFC2774 + network_authentication_required = 511, // RFC6585 + + _, + + pub fn phrase(self: Status) ?[]const u8 { + return switch (self) { + // 1xx statuses + .@"continue" => "Continue", + .switching_protocols => "Switching Protocols", + .processing => "Processing", + .early_hints => "Early Hints", + + // 2xx statuses + .ok => "OK", + .created => "Created", + .accepted => "Accepted", + .non_authoritative_info => "Non-Authoritative Information", + .no_content => "No Content", + .reset_content => "Reset Content", + .partial_content => "Partial Content", + .multi_status => "Multi-Status", + .already_reported => "Already Reported", + .im_used => "IM Used", + + // 3xx statuses + .multiple_choice => "Multiple Choice", + .moved_permanently => "Moved Permanently", + .found => "Found", + .see_other => "See Other", + .not_modified => "Not Modified", + .use_proxy => "Use Proxy", + .temporary_redirect => "Temporary Redirect", + .permanent_redirect => "Permanent Redirect", + + // 4xx statuses + .bad_request => "Bad Request", + .unauthorized => "Unauthorized", + .payment_required => "Payment Required", + .forbidden => "Forbidden", + .not_found => "Not Found", + .method_not_allowed => "Method Not Allowed", + .not_acceptable => "Not Acceptable", + .proxy_auth_required => "Proxy Authentication Required", + .request_timeout => "Request Timeout", + .conflict => "Conflict", + .gone => "Gone", + .length_required => "Length Required", + .precondition_failed => "Precondition Failed", + .payload_too_large => "Payload Too Large", + .uri_too_long => "URI Too Long", + .unsupported_media_type => "Unsupported Media Type", + .range_not_satisfiable => "Range Not Satisfiable", + .expectation_failed => "Expectation Failed", + .teapot => "I'm a teapot", + .misdirected_request => "Misdirected Request", + .unprocessable_entity => "Unprocessable Entity", + .locked => "Locked", + .failed_dependency => "Failed Dependency", + .too_early => "Too Early", + .upgrade_required => "Upgrade Required", + .precondition_required => "Precondition Required", + .too_many_requests => "Too Many Requests", + .request_header_fields_too_large => "Request Header Fields Too Large", + .unavailable_for_legal_reasons => "Unavailable For Legal Reasons", + + // 5xx statuses + .internal_server_error => "Internal Server Error", + .not_implemented => "Not Implemented", + .bad_gateway => "Bad Gateway", + .service_unavailable => "Service Unavailable", + .gateway_timeout => "Gateway Timeout", + .http_version_not_supported => "HTTP Version Not Supported", + .variant_also_negotiates => "Variant Also Negotiates", + .insufficient_storage => "Insufficient Storage", + .loop_detected => "Loop Detected", + .not_extended => "Not Extended", + .network_authentication_required => "Network Authentication Required", + + else => return null, + }; + } +}; + +pub fn open(allocator: std.mem.Allocator, method: Method, input: []const u8) !ClientRequest { + const u = try url.URL.parse(allocator, input, null); + defer allocator.free(u.href); + + const addr: net.Address = switch (u.hostFancy()) { + .unset => unreachable, + .ipv4 => |int| .initIp4(@bitCast(int), u.portFancy().?), + .ipv6 => |int| .initIp6(@bitCast(int), u.portFancy().?), + .name => |hostname| blk: { + const hostnamez = try allocator.dupeZ(u8, hostname); + defer allocator.free(hostnamez); + const portz = try std.fmt.allocPrintZ(allocator, "{d}", .{u.portFancy().?}); + defer allocator.free(portz); + const gai = try net.getaddrinfo(hostnamez, portz, null); + defer net.freeaddrinfo(gai); + break :blk switch (gai.addr.?.family) { + .INET => .{ .in = .{ .sa = @as(*net.Ip4Address.SockAddr, @ptrCast(@alignCast(gai.addr.?))).* } }, + .INET6 => .{ .in6 = .{ .sa = @as(*net.Ip6Address.SockAddr, @ptrCast(@alignCast(gai.addr.?))).* } }, + else => @panic("TODO"), + }; + }, + }; + + const conn = try addr.tcpConnect(); + errdefer conn.close(); + + var bufw: nio.BufferedWriter(4096, net.Stream) = .init(conn); + + try bufw.writeAll(@tagName(method)); + try bufw.writeAll(" "); + try bufw.writeAll(u.pathname); + try bufw.writeAll(" "); + try bufw.writeAll("HTTP/1.1"); + try bufw.writeAll("\r\n"); + + try bufw.writeAll("Host: "); + try bufw.writeAll(u.hostname); + try bufw.writeAll("\r\n"); + + try bufw.writeAll("Accept: text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\r\n"); + + try bufw.writeAll("Connection: close\r\n"); + + return .{ + .allocator = allocator, + .stream = conn, + .writer = bufw, + .reader = .init(conn), + .headers_raw = "", + }; +} + +pub const ClientRequest = struct { + allocator: std.mem.Allocator, + stream: net.Stream, + writer: nio.BufferedWriter(4096, net.Stream), + reader: nio.BufferedReader(4096, net.Stream), + headers_raw: []const u8, + + pub fn close(req: *const ClientRequest, allocator: std.mem.Allocator) void { + req.stream.close(); + allocator.free(req.headers_raw); + } + + pub fn writeHeader(req: *ClientRequest, name: []const u8, value: []const u8) !void { + try req.writer.writeAll(name); + try req.writer.writeAll(": "); + try req.writer.writeAll(value); + try req.writer.writeAll("\r\n"); + } + + pub fn writeUA(req: *ClientRequest) !void { + return req.writeHeader( + "User-Agent", + (if (builtin.is_test) "WIP " else "") ++ "https://github.com/nektro/zig-net-http", + ); + } + + pub fn send(req: *ClientRequest) !void { + try req.writer.writeAll("\r\n"); + try req.writer.flush(); + + // HTTP/1.1 200 OK + if (!std.mem.eql(u8, &try req.readArray(9), "HTTP/1.1 ")) return error.Bad; + const status_int = std.fmt.parseInt(u16, &try req.readArray(3), 10) catch return error.Bad; + const status = std.meta.intToEnum(Status, status_int) catch return error.Bad; + if (!std.mem.eql(u8, &try req.readArray(1), " ")) return error.Bad; + var phrase_buf: [64]u8 = undefined; + const actual_phrase = try req.readUntilDelimitersBuf(&phrase_buf, "\r\n"); + if (status.phrase()) |phrase| + if (!std.mem.eql(u8, actual_phrase, phrase)) + return error.Bad; + + var headers_list = std.ArrayList(u8).init(req.allocator); + errdefer headers_list.deinit(); + while (true) { + const header_len = try req.readUntilDelimitersArrayList(&headers_list, "\r\n", 1024); + if (header_len == 0) break; + } + req.headers_raw = try headers_list.toOwnedSlice(); + } + + pub const ReadError = net.Stream.ReadError; + pub usingnamespace nio.Readable(@This(), ._var); + pub fn read(req: *ClientRequest, buffer: []u8) ReadError!usize { + return req.reader.read(buffer); + } + pub fn anyReadable(self: *ClientRequest) nio.AnyReadable { + const S = struct { + fn read(s: *allowzero anyopaque, buffer: []u8) anyerror!usize { + const req: *ClientRequest = @ptrCast(@alignCast(s)); + return req.read(buffer); + } + }; + return .{ + .vtable = &.{ .read = S.read }, + .state = @ptrCast(self), + }; + } +}; diff --git a/licenses.txt b/licenses.txt new file mode 100644 index 0000000000000000000000000000000000000000..f83a17308cf7c2d0c51ed3bfc40bd89c42eeecc0 --- /dev/null +++ b/licenses.txt @@ -0,0 +1,20 @@ +MPL-2.0: += https://spdx.org/licenses/MPL-2.0 +- This +- git https://github.com/nektro/zig-intrusive-parser +- git https://github.com/nektro/zig-net +- git https://github.com/nektro/zig-nio +- git https://github.com/nektro/zig-unicode-idna +- git https://github.com/nektro/zig-whatwg-url + +MIT: += https://spdx.org/licenses/MIT +- git https://github.com/nektro/zig-expect +- git https://github.com/nektro/zig-extras +- git https://github.com/nektro/zig-json +- git https://github.com/nektro/zig-sys-linux +- git https://github.com/nektro/zig-tracer +- git https://github.com/nektro/zig-unicode-ucd + +Unspecified: +- system_lib c diff --git a/test.zig b/test.zig new file mode 100644 index 0000000000000000000000000000000000000000..72c2fd05b4497c877af98aaad4358ea859a155bf --- /dev/null +++ b/test.zig @@ -0,0 +1,31 @@ +const std = @import("std"); +const http = @import("http"); +const json = @import("json"); +const expect = @import("expect").expect; +const Scheme = enum { http }; + +test { + const allocator = std.testing.allocator; + var req = try http.open(allocator, .GET, "http://he.net/"); + defer req.close(allocator); + try req.writeUA(); + try req.send(); +} + +// zig fmt: off +test { try httpbinMethodGet(.http); } +// zig fmt: on + +fn httpbinMethodGet(comptime scheme: Scheme) !void { + const allocator = std.testing.allocator; + const url = @tagName(scheme) ++ "://httpbin.org/get"; + var req = try http.open(allocator, .GET, url); + defer req.close(allocator); + try req.writeUA(); + try req.send(); + const doc = try json.parse(allocator, "httpbinMethodGet", &req, .{ .support_trailing_commas = false, .maximum_depth = 2 }); + defer doc.deinit(allocator); + doc.acquire(); + defer doc.release(); + try expect(doc.root.object().getS("url")).toEqualString(url); +} diff --git a/zigmod.yml b/zigmod.yml new file mode 100644 index 0000000000000000000000000000000000000000..63ca8b5170d54c6fa54a0dfc24f9ab06fc6a9a1c --- /dev/null +++ b/zigmod.yml @@ -0,0 +1,12 @@ +id: zgi0a4tqvku20yrgs0gseuzf3x8bx99ex6sojjbyiokmbqc9 +name: http +main: http.zig +license: MPL-2.0 +description: An alternative HTTP server/client layer +dependencies: + - src: git https://github.com/nektro/zig-net + - src: git https://github.com/nektro/zig-whatwg-url + - src: git https://github.com/nektro/zig-nio +root_dependencies: + - src: git https://github.com/nektro/zig-json + - src: git https://github.com/nektro/zig-expect