lobo/universal-lambda-zig
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add context/adjust how body is read

Browse Source
This commit is contained in:
Emil Lerch 2023-09-18 15:49:25 -07:00
parent 3b97559b5d
commit d23dbd126b
Signed by: lobo
GPG Key ID: A7B62D657EF764F8
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/lambda.zig
View File

@ -2,6 +2,7 @@ const std = @import("std");
const builtin = @import("builtin"); const builtin = @import("builtin");
const HandlerFn = @import("universal_lambda.zig").HandlerFn; const HandlerFn = @import("universal_lambda.zig").HandlerFn;
const Context = @import("universal_lambda.zig").Context;
const log = std.log.scoped(.lambda); const log = std.log.scoped(.lambda);
@ -261,12 +262,17 @@ fn getEvent(allocator: std.mem.Allocator, event_data_uri: std.Uri) !?Event {
const req_id = request_id.?; const req_id = request_id.?;
log.debug("got lambda request with id {s}", .{req_id}); log.debug("got lambda request with id {s}", .{req_id});
var resp_payload = try std.ArrayList(u8).initCapacity(allocator, content_length.?); var response_data: []u8 =
defer resp_payload.deinit(); if (req.response.transfer_encoding) |_| // the only value here is "chunked"
try resp_payload.resize(content_length.?); try req.reader().readAllAlloc(allocator, std.math.maxInt(usize))
var response_data = try resp_payload.toOwnedSlice(); else blk: {
errdefer allocator.free(response_data); // content length
_ = try req.readAll(response_data); var tmp_data = try allocator.alloc(u8, content_length.?);
errdefer allocator.free(tmp_data);
_ = try req.readAll(tmp_data);
break :blk tmp_data;
};
std.debug.print("response_data: {s}", .{response_data});
return Event.init( return Event.init(
allocator, allocator,
@ -391,8 +397,9 @@ fn serve(allocator: std.mem.Allocator, res: *std.http.Server.Response) ![]const
return server_response; return server_response;
} }
fn handler(allocator: std.mem.Allocator, event_data: []const u8) ![]const u8 { fn handler(allocator: std.mem.Allocator, event_data: []const u8, context: Context) ![]const u8 {
_ = allocator; _ = allocator;
_ = context;
return event_data; return event_data;
} }
fn test_run(allocator: std.mem.Allocator, event_handler: HandlerFn) !std.Thread { fn test_run(allocator: std.mem.Allocator, event_handler: HandlerFn) !std.Thread {