mirror of
https://github.com/jetzig-framework/jetzig.git
synced 2025-05-14 22:16:08 +00:00
47c35632b5
Create mailers with `jetzig generate mailer <name>`. Mailers define
default values for email fields (e.g. subject, from address, etc.).
Mailers use Zmpl for rendering text/HTML parts.
Send an email from a request with `request.mail()`. Call
`deliver(.background, .{})` on the return value to use the built-in
mail job to send the email asynchronously.
Improve query/HTTP request body param parsing - unescape `+` and `%XX`
characters.
69 lines
2.5 KiB
Zig
69 lines
2.5 KiB
Zig
const std = @import("std");
|
|
|
|
/// Run the job generator. Create a job in `src/app/jobs/`
|
|
pub fn run(allocator: std.mem.Allocator, cwd: std.fs.Dir, args: [][]const u8, help: bool) !void {
|
|
if (help or args.len != 1) {
|
|
std.debug.print(
|
|
\\Generate a new Job. Jobs can be scheduled to run in the background.
|
|
\\Use a Job when you need to return a request immediately and perform
|
|
\\another task asynchronously.
|
|
\\
|
|
\\Example:
|
|
\\
|
|
\\ jetzig generate job iguana
|
|
\\
|
|
, .{});
|
|
|
|
if (help) return;
|
|
|
|
return error.JetzigCommandError;
|
|
}
|
|
|
|
const dir_path = try std.fs.path.join(allocator, &[_][]const u8{ "src", "app", "jobs" });
|
|
defer allocator.free(dir_path);
|
|
|
|
var dir = try cwd.makeOpenPath(dir_path, .{});
|
|
defer dir.close();
|
|
|
|
const filename = try std.mem.concat(allocator, u8, &[_][]const u8{ args[0], ".zig" });
|
|
defer allocator.free(filename);
|
|
|
|
const file = dir.createFile(filename, .{ .exclusive = true }) catch |err| {
|
|
switch (err) {
|
|
error.PathAlreadyExists => {
|
|
std.debug.print("Job already exists: {s}\n", .{filename});
|
|
return error.JetzigCommandError;
|
|
},
|
|
else => return err,
|
|
}
|
|
};
|
|
|
|
try file.writeAll(
|
|
\\const std = @import("std");
|
|
\\const jetzig = @import("jetzig");
|
|
\\
|
|
\\// The `run` function for a job is invoked every time the job is processed by a queue worker
|
|
\\// (or by the Jetzig server if the job is processed in-line).
|
|
\\//
|
|
\\// Arguments:
|
|
\\// * allocator: Arena allocator for use during the job execution process.
|
|
\\// * params: Params assigned to a job (from a request, any values added to `data`).
|
|
\\// * env: Provides the following fields:
|
|
\\// - logger: Logger attached to the same stream as the Jetzig server.
|
|
\\// - environment: Enum of `{ production, development }`.
|
|
\\pub fn run(allocator: std.mem.Allocator, params: *jetzig.data.Value, logger: jetzig.Logger) !void {
|
|
\\ _ = allocator;
|
|
\\ _ = params;
|
|
\\ // Job execution code goes here. Add any code that you would like to run in the background.
|
|
\\ try env.logger.INFO("Running a job.", .{});
|
|
\\}
|
|
\\
|
|
);
|
|
|
|
file.close();
|
|
|
|
const realpath = try dir.realpathAlloc(allocator, filename);
|
|
defer allocator.free(realpath);
|
|
std.debug.print("Generated job: {s}\n", .{realpath});
|
|
}
|