mirror of
https://github.com/oven-sh/bun
synced 2026-02-10 02:48:50 +00:00
1383 lines
56 KiB
Zig
1383 lines
56 KiB
Zig
const std = @import("std");
|
|
const bun = @import("root").bun;
|
|
const Command = bun.CLI.Command;
|
|
const Output = bun.Output;
|
|
const Global = bun.Global;
|
|
const http = bun.http;
|
|
const OOM = bun.OOM;
|
|
const Headers = http.Headers;
|
|
const HeaderBuilder = http.HeaderBuilder;
|
|
const MutableString = bun.MutableString;
|
|
const URL = bun.URL;
|
|
const install = bun.install;
|
|
const PackageManager = install.PackageManager;
|
|
const strings = bun.strings;
|
|
const string = bun.string;
|
|
const stringZ = bun.stringZ;
|
|
const File = bun.sys.File;
|
|
const JSON = bun.JSON;
|
|
const sha = bun.sha;
|
|
const path = bun.path;
|
|
const FileSystem = bun.fs.FileSystem;
|
|
const Environment = bun.Environment;
|
|
const Archive = bun.libarchive.lib.Archive;
|
|
const logger = bun.logger;
|
|
const Dependency = install.Dependency;
|
|
const Pack = bun.CLI.PackCommand;
|
|
const Lockfile = install.Lockfile;
|
|
const MimeType = http.MimeType;
|
|
const Expr = bun.js_parser.Expr;
|
|
const prompt = bun.CLI.InitCommand.prompt;
|
|
const Npm = install.Npm;
|
|
const Run = bun.CLI.RunCommand;
|
|
const DotEnv = bun.DotEnv;
|
|
const Open = @import("../open.zig");
|
|
const E = bun.JSAst.E;
|
|
const G = bun.JSAst.G;
|
|
const BabyList = bun.BabyList;
|
|
|
|
pub const PublishCommand = struct {
|
|
pub fn Context(comptime directory_publish: bool) type {
|
|
return struct {
|
|
manager: *PackageManager,
|
|
allocator: std.mem.Allocator,
|
|
command_ctx: Command.Context,
|
|
|
|
package_name: string,
|
|
package_version: string,
|
|
abs_tarball_path: stringZ,
|
|
tarball_bytes: string,
|
|
shasum: sha.SHA1.Digest,
|
|
integrity: sha.SHA512.Digest,
|
|
uses_workspaces: bool,
|
|
|
|
normalized_pkg_info: string,
|
|
|
|
publish_script: if (directory_publish) ?[]const u8 else void = if (directory_publish) null,
|
|
postpublish_script: if (directory_publish) ?[]const u8 else void = if (directory_publish) null,
|
|
script_env: if (directory_publish) *DotEnv.Loader else void,
|
|
|
|
const FromTarballError = OOM || error{
|
|
MissingPackageJSON,
|
|
InvalidPackageJSON,
|
|
MissingPackageName,
|
|
MissingPackageVersion,
|
|
InvalidPackageName,
|
|
InvalidPackageVersion,
|
|
PrivatePackage,
|
|
RestrictedUnscopedPackage,
|
|
};
|
|
|
|
/// Retrieve information for publishing from a tarball path, `bun publish path/to/tarball.tgz`
|
|
pub fn fromTarballPath(
|
|
ctx: Command.Context,
|
|
manager: *PackageManager,
|
|
tarball_path: string,
|
|
) FromTarballError!Context(directory_publish) {
|
|
var abs_buf: bun.PathBuffer = undefined;
|
|
const abs_tarball_path = path.joinAbsStringBufZ(
|
|
FileSystem.instance.top_level_dir,
|
|
&abs_buf,
|
|
&[_]string{tarball_path},
|
|
.auto,
|
|
);
|
|
|
|
const tarball_bytes = File.readFrom(bun.invalid_fd, abs_tarball_path, ctx.allocator).unwrap() catch |err| {
|
|
Output.err(err, "failed to read tarball: '{s}'", .{tarball_path});
|
|
Global.crash();
|
|
};
|
|
|
|
var maybe_package_json_contents: ?[]const u8 = null;
|
|
|
|
var iter = switch (Archive.Iterator.init(tarball_bytes)) {
|
|
.err => |err| {
|
|
Output.errGeneric("{s}: {s}", .{
|
|
err.message,
|
|
err.archive.errorString(),
|
|
});
|
|
|
|
Global.crash();
|
|
},
|
|
.result => |res| res,
|
|
};
|
|
|
|
var unpacked_size: usize = 0;
|
|
var total_files: usize = 0;
|
|
|
|
Output.print("\n", .{});
|
|
|
|
while (switch (iter.next()) {
|
|
.err => |err| {
|
|
Output.errGeneric("{s}: {s}", .{ err.message, err.archive.errorString() });
|
|
Global.crash();
|
|
},
|
|
.result => |res| res,
|
|
}) |next| {
|
|
const pathname = if (comptime Environment.isWindows)
|
|
next.entry.pathnameW()
|
|
else
|
|
next.entry.pathname();
|
|
|
|
const size = next.entry.size();
|
|
|
|
unpacked_size += @intCast(@max(0, size));
|
|
total_files += @intFromBool(next.kind == .file);
|
|
|
|
// this is option `strip: 1` (npm expects a `package/` prefix for all paths)
|
|
if (strings.indexOfAnyT(bun.OSPathChar, pathname, "/\\")) |slash| {
|
|
const stripped = pathname[slash + 1 ..];
|
|
if (stripped.len == 0) continue;
|
|
|
|
Output.pretty("<b><cyan>packed<r> {} {}\n", .{
|
|
bun.fmt.size(size, .{ .space_between_number_and_unit = false }),
|
|
bun.fmt.fmtOSPath(stripped, .{}),
|
|
});
|
|
|
|
if (next.kind != .file) continue;
|
|
|
|
if (strings.indexOfAnyT(bun.OSPathChar, stripped, "/\\") == null) {
|
|
|
|
// check for package.json, readme.md, ...
|
|
const filename = pathname[slash + 1 ..];
|
|
|
|
if (maybe_package_json_contents == null and strings.eqlCaseInsensitiveT(bun.OSPathChar, filename, "package.json")) {
|
|
maybe_package_json_contents = switch (try next.readEntryData(ctx.allocator, iter.archive)) {
|
|
.err => |err| {
|
|
Output.errGeneric("{s}: {s}", .{ err.message, err.archive.errorString() });
|
|
Global.crash();
|
|
},
|
|
.result => |bytes| bytes,
|
|
};
|
|
}
|
|
}
|
|
} else {
|
|
Output.pretty("<b><cyan>packed<r> {} {}\n", .{
|
|
bun.fmt.size(size, .{ .space_between_number_and_unit = false }),
|
|
bun.fmt.fmtOSPath(pathname, .{}),
|
|
});
|
|
}
|
|
}
|
|
|
|
switch (iter.deinit()) {
|
|
.err => |err| {
|
|
Output.errGeneric("{s}: {s}", .{ err.message, err.archive.errorString() });
|
|
Global.crash();
|
|
},
|
|
.result => {},
|
|
}
|
|
|
|
const package_json_contents = maybe_package_json_contents orelse return error.MissingPackageJSON;
|
|
|
|
const package_name, const package_version, var json, const json_source = package_info: {
|
|
const source = logger.Source.initPathString("package.json", package_json_contents);
|
|
const json = JSON.parsePackageJSONUTF8(&source, manager.log, ctx.allocator) catch |err| {
|
|
return switch (err) {
|
|
error.OutOfMemory => |oom| return oom,
|
|
else => error.InvalidPackageJSON,
|
|
};
|
|
};
|
|
|
|
if (json.get("private")) |private| {
|
|
if (private.asBool()) |is_private| {
|
|
if (is_private) {
|
|
return error.PrivatePackage;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (json.get("publishConfig")) |config| {
|
|
if (manager.options.publish_config.tag.len == 0) {
|
|
if (try config.getStringCloned(ctx.allocator, "tag")) |tag| {
|
|
manager.options.publish_config.tag = tag;
|
|
}
|
|
}
|
|
|
|
if (manager.options.publish_config.access == null) {
|
|
if (try config.getString(ctx.allocator, "access")) |access| {
|
|
manager.options.publish_config.access = PackageManager.Options.Access.fromStr(access[0]) orelse {
|
|
Output.errGeneric("invalid `access` value: '{s}'", .{access[0]});
|
|
Global.crash();
|
|
};
|
|
}
|
|
}
|
|
|
|
// maybe otp
|
|
}
|
|
|
|
const name = try json.getStringCloned(ctx.allocator, "name") orelse return error.MissingPackageName;
|
|
const is_scoped = try Dependency.isScopedPackageName(name);
|
|
|
|
if (manager.options.publish_config.access) |access| {
|
|
if (access == .restricted and !is_scoped) {
|
|
return error.RestrictedUnscopedPackage;
|
|
}
|
|
}
|
|
|
|
const version = try json.getStringCloned(ctx.allocator, "version") orelse return error.MissingPackageVersion;
|
|
if (version.len == 0) return error.InvalidPackageVersion;
|
|
|
|
break :package_info .{ name, version, json, source };
|
|
};
|
|
|
|
var shasum: sha.SHA1.Digest = undefined;
|
|
var sha1 = sha.SHA1.init();
|
|
defer sha1.deinit();
|
|
|
|
sha1.update(tarball_bytes);
|
|
sha1.final(&shasum);
|
|
|
|
var integrity: sha.SHA512.Digest = undefined;
|
|
var sha512 = sha.SHA512.init();
|
|
defer sha512.deinit();
|
|
|
|
sha512.update(tarball_bytes);
|
|
sha512.final(&integrity);
|
|
|
|
const normalized_pkg_info = try normalizedPackage(
|
|
ctx.allocator,
|
|
manager,
|
|
package_name,
|
|
package_version,
|
|
&json,
|
|
json_source,
|
|
shasum,
|
|
integrity,
|
|
);
|
|
|
|
Pack.Context.printSummary(
|
|
.{
|
|
.total_files = total_files,
|
|
.unpacked_size = unpacked_size,
|
|
.packed_size = tarball_bytes.len,
|
|
},
|
|
shasum,
|
|
integrity,
|
|
manager.options.log_level,
|
|
);
|
|
|
|
return .{
|
|
.manager = manager,
|
|
.allocator = ctx.allocator,
|
|
.package_name = package_name,
|
|
.package_version = package_version,
|
|
.abs_tarball_path = try ctx.allocator.dupeZ(u8, abs_tarball_path),
|
|
.tarball_bytes = tarball_bytes,
|
|
.shasum = shasum,
|
|
.integrity = integrity,
|
|
.uses_workspaces = false,
|
|
.command_ctx = ctx,
|
|
.script_env = {},
|
|
.normalized_pkg_info = normalized_pkg_info,
|
|
};
|
|
}
|
|
|
|
const FromWorkspaceError = Pack.PackError(true);
|
|
|
|
/// `bun publish` without a tarball path. Automatically pack the current workspace and get
|
|
/// information required for publishing
|
|
pub fn fromWorkspace(
|
|
ctx: Command.Context,
|
|
manager: *PackageManager,
|
|
) FromWorkspaceError!Context(directory_publish) {
|
|
var lockfile: Lockfile = undefined;
|
|
const load_from_disk_result = lockfile.loadFromCwd(
|
|
manager,
|
|
manager.allocator,
|
|
manager.log,
|
|
false,
|
|
);
|
|
|
|
var pack_ctx: Pack.Context = .{
|
|
.allocator = ctx.allocator,
|
|
.manager = manager,
|
|
.command_ctx = ctx,
|
|
.lockfile = switch (load_from_disk_result) {
|
|
.ok => |ok| ok.lockfile,
|
|
.not_found => null,
|
|
.err => |cause| err: {
|
|
switch (cause.step) {
|
|
.open_file => {
|
|
if (cause.value == error.ENOENT) break :err null;
|
|
Output.errGeneric("failed to open lockfile: {s}", .{@errorName(cause.value)});
|
|
},
|
|
.parse_file => {
|
|
Output.errGeneric("failed to parse lockfile: {s}", .{@errorName(cause.value)});
|
|
},
|
|
.read_file => {
|
|
Output.errGeneric("failed to read lockfile: {s}", .{@errorName(cause.value)});
|
|
},
|
|
.migrating => {
|
|
Output.errGeneric("failed to migrate lockfile: {s}", .{@errorName(cause.value)});
|
|
},
|
|
}
|
|
|
|
if (manager.log.hasErrors()) {
|
|
manager.log.print(Output.errorWriter()) catch {};
|
|
}
|
|
|
|
Global.crash();
|
|
},
|
|
},
|
|
};
|
|
|
|
return switch (manager.options.log_level) {
|
|
inline else => |log_level| Pack.pack(&pack_ctx, manager.original_package_json_path, log_level, true),
|
|
};
|
|
}
|
|
};
|
|
}
|
|
|
|
pub fn exec(ctx: Command.Context) !void {
|
|
Output.prettyln("<r><b>bun publish <r><d>v" ++ Global.package_json_version_with_sha ++ "<r>", .{});
|
|
Output.flush();
|
|
|
|
const cli = try PackageManager.CommandLineArguments.parse(ctx.allocator, .publish);
|
|
|
|
const manager, const original_cwd = PackageManager.init(ctx, cli, .publish) catch |err| {
|
|
if (!cli.silent) {
|
|
if (err == error.MissingPackageJSON) {
|
|
Output.errGeneric("missing package.json, nothing to publish", .{});
|
|
}
|
|
Output.errGeneric("failed to initialize bun install: {s}", .{@errorName(err)});
|
|
}
|
|
Global.crash();
|
|
};
|
|
defer ctx.allocator.free(original_cwd);
|
|
|
|
if (cli.positionals.len > 1) {
|
|
const context = Context(false).fromTarballPath(ctx, manager, cli.positionals[1]) catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => bun.outOfMemory(),
|
|
error.MissingPackageName => {
|
|
Output.errGeneric("missing `name` string in package.json", .{});
|
|
},
|
|
error.MissingPackageVersion => {
|
|
Output.errGeneric("missing `version` string in package.json", .{});
|
|
},
|
|
error.InvalidPackageName, error.InvalidPackageVersion => {
|
|
Output.errGeneric("package.json `name` and `version` fields must be non-empty strings", .{});
|
|
},
|
|
error.MissingPackageJSON => {
|
|
Output.errGeneric("failed to find package.json in tarball '{s}'", .{cli.positionals[1]});
|
|
},
|
|
error.InvalidPackageJSON => {
|
|
manager.log.print(Output.errorWriter()) catch {};
|
|
Output.errGeneric("failed to parse tarball package.json", .{});
|
|
},
|
|
error.PrivatePackage => {
|
|
Output.errGeneric("attempted to publish a private package", .{});
|
|
},
|
|
error.RestrictedUnscopedPackage => {
|
|
Output.errGeneric("unable to restrict access to unscoped package", .{});
|
|
},
|
|
}
|
|
Global.crash();
|
|
};
|
|
|
|
publish(false, &context) catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => bun.outOfMemory(),
|
|
error.NeedAuth => {
|
|
Output.errGeneric("missing authentication (run <cyan>`bunx npm login`<r>)", .{});
|
|
Global.crash();
|
|
},
|
|
}
|
|
};
|
|
|
|
Output.prettyln("\n<green> +<r> {s}@{s}{s}", .{
|
|
context.package_name,
|
|
Dependency.withoutBuildTag(context.package_version),
|
|
if (manager.options.dry_run) " (dry-run)" else "",
|
|
});
|
|
|
|
return;
|
|
}
|
|
|
|
const context = Context(true).fromWorkspace(ctx, manager) catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => bun.outOfMemory(),
|
|
error.MissingPackageName => {
|
|
Output.errGeneric("missing `name` string in package.json", .{});
|
|
},
|
|
error.MissingPackageVersion => {
|
|
Output.errGeneric("missing `version` string in package.json", .{});
|
|
},
|
|
error.InvalidPackageName, error.InvalidPackageVersion => {
|
|
Output.errGeneric("package.json `name` and `version` fields must be non-empty strings", .{});
|
|
},
|
|
error.MissingPackageJSON => {
|
|
Output.errGeneric("failed to find package.json from: '{s}'", .{FileSystem.instance.top_level_dir});
|
|
},
|
|
error.RestrictedUnscopedPackage => {
|
|
Output.errGeneric("unable to restrict access to unscoped package", .{});
|
|
},
|
|
error.PrivatePackage => {
|
|
Output.errGeneric("attempted to publish a private package", .{});
|
|
},
|
|
}
|
|
Global.crash();
|
|
};
|
|
|
|
// TODO: read this into memory
|
|
_ = bun.sys.unlink(context.abs_tarball_path);
|
|
|
|
publish(true, &context) catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => bun.outOfMemory(),
|
|
error.NeedAuth => {
|
|
Output.errGeneric("missing authentication (run <cyan>`bunx npm login`<r>)", .{});
|
|
Global.crash();
|
|
},
|
|
}
|
|
};
|
|
|
|
Output.prettyln("\n<green> +<r> {s}@{s}{s}", .{
|
|
context.package_name,
|
|
Dependency.withoutBuildTag(context.package_version),
|
|
if (manager.options.dry_run) " (dry-run)" else "",
|
|
});
|
|
|
|
if (manager.options.do.run_scripts) {
|
|
const abs_workspace_path: string = strings.withoutTrailingSlash(strings.withoutSuffixComptime(manager.original_package_json_path, "package.json"));
|
|
try context.script_env.map.put("npm_command", "publish");
|
|
|
|
if (context.publish_script) |publish_script| {
|
|
_ = Run.runPackageScriptForeground(
|
|
context.command_ctx,
|
|
context.allocator,
|
|
publish_script,
|
|
"publish",
|
|
abs_workspace_path,
|
|
context.script_env,
|
|
&.{},
|
|
context.manager.options.log_level == .silent,
|
|
context.command_ctx.debug.use_system_shell,
|
|
) catch |err| {
|
|
switch (err) {
|
|
error.MissingShell => {
|
|
Output.errGeneric("failed to find shell executable to run publish script", .{});
|
|
Global.crash();
|
|
},
|
|
error.OutOfMemory => |oom| return oom,
|
|
}
|
|
};
|
|
}
|
|
|
|
if (context.postpublish_script) |postpublish_script| {
|
|
_ = Run.runPackageScriptForeground(
|
|
context.command_ctx,
|
|
context.allocator,
|
|
postpublish_script,
|
|
"postpublish",
|
|
abs_workspace_path,
|
|
context.script_env,
|
|
&.{},
|
|
context.manager.options.log_level == .silent,
|
|
context.command_ctx.debug.use_system_shell,
|
|
) catch |err| {
|
|
switch (err) {
|
|
error.MissingShell => {
|
|
Output.errGeneric("failed to find shell executable to run postpublish script", .{});
|
|
Global.crash();
|
|
},
|
|
error.OutOfMemory => |oom| return oom,
|
|
}
|
|
};
|
|
}
|
|
}
|
|
}
|
|
|
|
const PublishError = OOM || error{
|
|
NeedAuth,
|
|
};
|
|
|
|
pub fn publish(
|
|
comptime directory_publish: bool,
|
|
ctx: *const Context(directory_publish),
|
|
) PublishError!void {
|
|
const registry = ctx.manager.scopeForPackageName(ctx.package_name);
|
|
|
|
if (registry.token.len == 0 and (registry.url.password.len == 0 or registry.url.username.len == 0)) {
|
|
return error.NeedAuth;
|
|
}
|
|
|
|
// continues from `printSummary`
|
|
Output.pretty(
|
|
\\<b><blue>Tag<r>: {s}
|
|
\\<b><blue>Access<r>: {s}
|
|
\\<b><blue>Registry<r>: {s}
|
|
\\
|
|
, .{
|
|
if (ctx.manager.options.publish_config.tag.len > 0) ctx.manager.options.publish_config.tag else "latest",
|
|
if (ctx.manager.options.publish_config.access) |access| @tagName(access) else "default",
|
|
registry.url.href,
|
|
});
|
|
|
|
// dry-run stops here
|
|
if (ctx.manager.options.dry_run) return;
|
|
|
|
const publish_req_body = try constructPublishRequestBody(directory_publish, ctx);
|
|
|
|
var print_buf: std.ArrayListUnmanaged(u8) = .{};
|
|
defer print_buf.deinit(ctx.allocator);
|
|
var print_writer = print_buf.writer(ctx.allocator);
|
|
|
|
const publish_headers = try constructPublishHeaders(
|
|
ctx.allocator,
|
|
&print_buf,
|
|
registry,
|
|
publish_req_body.len,
|
|
if (ctx.manager.options.publish_config.otp.len > 0) ctx.manager.options.publish_config.otp else null,
|
|
ctx.uses_workspaces,
|
|
ctx.manager.options.publish_config.auth_type,
|
|
);
|
|
|
|
var response_buf = try MutableString.init(ctx.allocator, 1024);
|
|
|
|
try print_writer.print("{s}/{s}", .{
|
|
strings.withoutTrailingSlash(registry.url.href),
|
|
bun.fmt.dependencyUrl(ctx.package_name),
|
|
});
|
|
const publish_url = URL.parse(try ctx.allocator.dupe(u8, print_buf.items));
|
|
print_buf.clearRetainingCapacity();
|
|
|
|
var req = http.AsyncHTTP.initSync(
|
|
ctx.allocator,
|
|
.PUT,
|
|
publish_url,
|
|
publish_headers.entries,
|
|
publish_headers.content.ptr.?[0..publish_headers.content.len],
|
|
&response_buf,
|
|
publish_req_body,
|
|
null,
|
|
null,
|
|
.follow,
|
|
);
|
|
|
|
const res = req.sendSync() catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => |oom| return oom,
|
|
else => {
|
|
Output.err(err, "failed to publish package", .{});
|
|
Global.crash();
|
|
},
|
|
}
|
|
};
|
|
|
|
switch (res.status_code) {
|
|
400...std.math.maxInt(@TypeOf(res.status_code)) => {
|
|
const prompt_for_otp = prompt_for_otp: {
|
|
if (res.status_code != 401) break :prompt_for_otp false;
|
|
|
|
if (res.headers.get("www-authenticate")) |@"www-authenticate"| {
|
|
var iter = strings.split(@"www-authenticate", ",");
|
|
while (iter.next()) |part| {
|
|
const trimmed = strings.trim(part, &strings.whitespace_chars);
|
|
if (strings.eqlCaseInsensitiveASCII(trimmed, "ipaddress", true)) {
|
|
Output.errGeneric("login is not allowed from your IP address", .{});
|
|
Global.crash();
|
|
} else if (strings.eqlCaseInsensitiveASCII(trimmed, "otp", true)) {
|
|
break :prompt_for_otp true;
|
|
}
|
|
}
|
|
|
|
Output.errGeneric("unable to authenticate, need: {s}", .{@"www-authenticate"});
|
|
Global.crash();
|
|
} else if (strings.containsComptime(response_buf.list.items, "one-time pass")) {
|
|
// missing www-authenicate header but one-time pass is still included
|
|
break :prompt_for_otp true;
|
|
}
|
|
|
|
break :prompt_for_otp false;
|
|
};
|
|
|
|
if (!prompt_for_otp) {
|
|
// general error
|
|
const otp_response = false;
|
|
try Npm.responseError(
|
|
ctx.allocator,
|
|
&req,
|
|
&res,
|
|
.{ ctx.package_name, ctx.package_version },
|
|
&response_buf,
|
|
otp_response,
|
|
);
|
|
}
|
|
|
|
// https://github.com/npm/cli/blob/534ad7789e5c61f579f44d782bdd18ea3ff1ee20/node_modules/npm-registry-fetch/lib/check-response.js#L14
|
|
// ignore if x-local-cache exists
|
|
if (res.headers.getIfOtherIsAbsent("npm-notice", "x-local-cache")) |notice| {
|
|
Output.printError("\n", .{});
|
|
Output.note("{s}", .{notice});
|
|
Output.flush();
|
|
}
|
|
|
|
const otp = try getOTP(directory_publish, ctx, registry, &response_buf, &print_buf);
|
|
|
|
const otp_headers = try constructPublishHeaders(
|
|
ctx.allocator,
|
|
&print_buf,
|
|
registry,
|
|
publish_req_body.len,
|
|
otp,
|
|
ctx.uses_workspaces,
|
|
ctx.manager.options.publish_config.auth_type,
|
|
);
|
|
|
|
response_buf.reset();
|
|
|
|
var otp_req = http.AsyncHTTP.initSync(
|
|
ctx.allocator,
|
|
.PUT,
|
|
publish_url,
|
|
otp_headers.entries,
|
|
otp_headers.content.ptr.?[0..otp_headers.content.len],
|
|
&response_buf,
|
|
publish_req_body,
|
|
null,
|
|
null,
|
|
.follow,
|
|
);
|
|
|
|
const otp_res = otp_req.sendSync() catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => |oom| return oom,
|
|
else => {
|
|
Output.err(err, "failed to publish package", .{});
|
|
Global.crash();
|
|
},
|
|
}
|
|
};
|
|
|
|
switch (otp_res.status_code) {
|
|
400...std.math.maxInt(@TypeOf(otp_res.status_code)) => {
|
|
const otp_response = true;
|
|
try Npm.responseError(
|
|
ctx.allocator,
|
|
&otp_req,
|
|
&otp_res,
|
|
.{ ctx.package_name, ctx.package_version },
|
|
&response_buf,
|
|
otp_response,
|
|
);
|
|
},
|
|
else => {
|
|
// https://github.com/npm/cli/blob/534ad7789e5c61f579f44d782bdd18ea3ff1ee20/node_modules/npm-registry-fetch/lib/check-response.js#L14
|
|
// ignore if x-local-cache exists
|
|
if (otp_res.headers.getIfOtherIsAbsent("npm-notice", "x-local-cache")) |notice| {
|
|
Output.printError("\n", .{});
|
|
Output.note("{s}", .{notice});
|
|
Output.flush();
|
|
}
|
|
},
|
|
}
|
|
},
|
|
else => {},
|
|
}
|
|
}
|
|
|
|
const GetOTPError = OOM || error{};
|
|
|
|
fn pressEnterToOpenInBrowser(auth_url: stringZ) void {
|
|
// unset `ENABLE_VIRTUAL_TERMINAL_INPUT` on windows. This prevents backspace from
|
|
// deleting the entire line
|
|
const original_mode: if (Environment.isWindows) ?bun.windows.DWORD else void = if (comptime Environment.isWindows)
|
|
bun.win32.unsetStdioModeFlags(0, bun.windows.ENABLE_VIRTUAL_TERMINAL_INPUT) catch null;
|
|
|
|
defer if (comptime Environment.isWindows) {
|
|
if (original_mode) |mode| {
|
|
_ = bun.windows.SetConsoleMode(bun.win32.STDIN_FD.cast(), mode);
|
|
}
|
|
};
|
|
|
|
while ('\n' != Output.buffered_stdin.reader().readByte() catch return) {}
|
|
|
|
var child = std.process.Child.init(&.{ Open.opener, auth_url }, bun.default_allocator);
|
|
_ = child.spawnAndWait() catch return;
|
|
}
|
|
|
|
fn getOTP(
|
|
comptime directory_publish: bool,
|
|
ctx: *const Context(directory_publish),
|
|
registry: *const Npm.Registry.Scope,
|
|
response_buf: *MutableString,
|
|
print_buf: *std.ArrayListUnmanaged(u8),
|
|
) GetOTPError![]const u8 {
|
|
const res_source = logger.Source.initPathString("???", response_buf.list.items);
|
|
|
|
if (JSON.parseUTF8(&res_source, ctx.manager.log, ctx.allocator) catch |err| res_json: {
|
|
switch (err) {
|
|
error.OutOfMemory => |oom| return oom,
|
|
|
|
// https://github.com/npm/cli/blob/63d6a732c3c0e9c19fd4d147eaa5cc27c29b168d/node_modules/npm-registry-fetch/lib/check-response.js#L65
|
|
// invalid json is ignored
|
|
else => break :res_json null,
|
|
}
|
|
}) |json| try_web: {
|
|
const auth_url_str = try json.getStringClonedZ(ctx.allocator, "authUrl") orelse break :try_web;
|
|
|
|
// important to clone because it belongs to `response_buf`, and `response_buf` will be
|
|
// reused with the following requests
|
|
const done_url_str = try json.getStringCloned(ctx.allocator, "doneUrl") orelse break :try_web;
|
|
const done_url = URL.parse(done_url_str);
|
|
|
|
Output.prettyln("\nAuthenticate your account at (press <b>ENTER<r> to open in browser):\n", .{});
|
|
|
|
const offset = 0;
|
|
const padding = 1;
|
|
|
|
const horizontal = if (Output.enable_ansi_colors) "─" else "-";
|
|
const vertical = if (Output.enable_ansi_colors) "│" else "|";
|
|
const top_left = if (Output.enable_ansi_colors) "┌" else "|";
|
|
const top_right = if (Output.enable_ansi_colors) "┐" else "|";
|
|
const bottom_left = if (Output.enable_ansi_colors) "└" else "|";
|
|
const bottom_right = if (Output.enable_ansi_colors) "┘" else "|";
|
|
|
|
const width = (padding * 2) + auth_url_str.len;
|
|
|
|
for (0..offset) |_| Output.print(" ", .{});
|
|
Output.print("{s}", .{top_left});
|
|
for (0..width) |_| Output.print("{s}", .{horizontal});
|
|
Output.println("{s}", .{top_right});
|
|
|
|
for (0..offset) |_| Output.print(" ", .{});
|
|
Output.print("{s}", .{vertical});
|
|
for (0..padding) |_| Output.print(" ", .{});
|
|
Output.pretty("<b>{s}<r>", .{auth_url_str});
|
|
for (0..padding) |_| Output.print(" ", .{});
|
|
Output.println("{s}", .{vertical});
|
|
|
|
for (0..offset) |_| Output.print(" ", .{});
|
|
Output.print("{s}", .{bottom_left});
|
|
for (0..width) |_| Output.print("{s}", .{horizontal});
|
|
Output.println("{s}", .{bottom_right});
|
|
Output.flush();
|
|
|
|
// on another thread because pressing enter is not required
|
|
(std.Thread.spawn(.{}, pressEnterToOpenInBrowser, .{auth_url_str}) catch |err| {
|
|
Output.err(err, "failed to spawn thread for opening auth url", .{});
|
|
Global.crash();
|
|
}).detach();
|
|
|
|
var auth_headers = try constructPublishHeaders(
|
|
ctx.allocator,
|
|
print_buf,
|
|
registry,
|
|
null,
|
|
null,
|
|
ctx.uses_workspaces,
|
|
ctx.manager.options.publish_config.auth_type,
|
|
);
|
|
|
|
while (true) {
|
|
response_buf.reset();
|
|
|
|
var req = http.AsyncHTTP.initSync(
|
|
ctx.allocator,
|
|
.GET,
|
|
done_url,
|
|
auth_headers.entries,
|
|
auth_headers.content.ptr.?[0..auth_headers.content.len],
|
|
response_buf,
|
|
"",
|
|
null,
|
|
null,
|
|
.follow,
|
|
);
|
|
|
|
const res = req.sendSync() catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => |oom| return oom,
|
|
else => {
|
|
Output.err(err, "failed to send OTP request", .{});
|
|
Global.crash();
|
|
},
|
|
}
|
|
};
|
|
|
|
switch (res.status_code) {
|
|
202 => {
|
|
// retry
|
|
const nanoseconds = nanoseconds: {
|
|
if (res.headers.get("retry-after")) |retry| default: {
|
|
const trimmed = strings.trim(retry, &strings.whitespace_chars);
|
|
const seconds = std.fmt.parseInt(u32, trimmed, 10) catch break :default;
|
|
break :nanoseconds seconds * std.time.ns_per_s;
|
|
}
|
|
|
|
break :nanoseconds 500 * std.time.ns_per_ms;
|
|
};
|
|
|
|
std.time.sleep(nanoseconds);
|
|
continue;
|
|
},
|
|
200 => {
|
|
// login successful
|
|
const otp_done_source = logger.Source.initPathString("???", response_buf.list.items);
|
|
const otp_done_json = JSON.parseUTF8(&otp_done_source, ctx.manager.log, ctx.allocator) catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => |oom| return oom,
|
|
else => {
|
|
Output.err("WebLogin", "failed to parse response json", .{});
|
|
Global.crash();
|
|
},
|
|
}
|
|
};
|
|
|
|
const token = try otp_done_json.getStringCloned(ctx.allocator, "token") orelse {
|
|
Output.err("WebLogin", "missing `token` field in reponse json", .{});
|
|
Global.crash();
|
|
};
|
|
|
|
// https://github.com/npm/cli/blob/534ad7789e5c61f579f44d782bdd18ea3ff1ee20/node_modules/npm-registry-fetch/lib/check-response.js#L14
|
|
// ignore if x-local-cache exists
|
|
if (res.headers.getIfOtherIsAbsent("npm-notice", "x-local-cache")) |notice| {
|
|
Output.printError("\n", .{});
|
|
Output.note("{s}", .{notice});
|
|
Output.flush();
|
|
}
|
|
|
|
return token;
|
|
},
|
|
else => {
|
|
const otp_response = false;
|
|
try Npm.responseError(
|
|
ctx.allocator,
|
|
&req,
|
|
&res,
|
|
.{ ctx.package_name, ctx.package_version },
|
|
response_buf,
|
|
otp_response,
|
|
);
|
|
},
|
|
}
|
|
}
|
|
}
|
|
|
|
// classic
|
|
return prompt(ctx.allocator, "\nThis operation requires a one-time password.\nEnter OTP: ", "") catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => |oom| return oom,
|
|
else => {
|
|
Output.err(err, "failed to read OTP input", .{});
|
|
Global.crash();
|
|
},
|
|
}
|
|
};
|
|
}
|
|
|
|
pub fn normalizedPackage(
|
|
allocator: std.mem.Allocator,
|
|
manager: *PackageManager,
|
|
package_name: string,
|
|
package_version: string,
|
|
json: *Expr,
|
|
json_source: logger.Source,
|
|
shasum: sha.SHA1.Digest,
|
|
integrity: sha.SHA512.Digest,
|
|
) OOM!string {
|
|
bun.assertWithLocation(json.isObject(), @src());
|
|
|
|
const registry = manager.scopeForPackageName(package_name);
|
|
|
|
const version_without_build_tag = Dependency.withoutBuildTag(package_version);
|
|
|
|
const integrity_fmt = try std.fmt.allocPrint(allocator, "{}", .{bun.fmt.integrity(integrity, .full)});
|
|
|
|
try json.setString(allocator, "_id", try std.fmt.allocPrint(allocator, "{s}@{s}", .{ package_name, version_without_build_tag }));
|
|
try json.setString(allocator, "_integrity", integrity_fmt);
|
|
try json.setString(allocator, "_nodeVersion", Environment.reported_nodejs_version);
|
|
// TODO: npm version
|
|
try json.setString(allocator, "_npmVersion", "10.8.3");
|
|
try json.setString(allocator, "integrity", integrity_fmt);
|
|
try json.setString(allocator, "shasum", try std.fmt.allocPrint(allocator, "{s}", .{std.fmt.bytesToHex(shasum, .lower)}));
|
|
|
|
var dist_props = try allocator.alloc(G.Property, 3);
|
|
dist_props[0] = .{
|
|
.key = Expr.init(
|
|
E.String,
|
|
.{ .data = "integrity" },
|
|
logger.Loc.Empty,
|
|
),
|
|
.value = Expr.init(
|
|
E.String,
|
|
.{ .data = try std.fmt.allocPrint(allocator, "{}", .{bun.fmt.integrity(integrity, .full)}) },
|
|
logger.Loc.Empty,
|
|
),
|
|
};
|
|
dist_props[1] = .{
|
|
.key = Expr.init(
|
|
E.String,
|
|
.{ .data = "shasum" },
|
|
logger.Loc.Empty,
|
|
),
|
|
.value = Expr.init(
|
|
E.String,
|
|
.{ .data = try std.fmt.allocPrint(allocator, "{s}", .{std.fmt.bytesToHex(shasum, .lower)}) },
|
|
logger.Loc.Empty,
|
|
),
|
|
};
|
|
dist_props[2] = .{
|
|
.key = Expr.init(
|
|
E.String,
|
|
.{ .data = "tarball" },
|
|
logger.Loc.Empty,
|
|
),
|
|
.value = Expr.init(
|
|
E.String,
|
|
.{
|
|
.data = try std.fmt.allocPrint(allocator, "http://{s}/{s}/-/{}", .{
|
|
// always use replace https with http
|
|
// https://github.com/npm/cli/blob/9281ebf8e428d40450ad75ba61bc6f040b3bf896/workspaces/libnpmpublish/lib/publish.js#L120
|
|
strings.withoutTrailingSlash(strings.withoutPrefixComptime(registry.url.href, "https://")),
|
|
package_name,
|
|
Pack.fmtTarballFilename(package_name, package_version, .raw),
|
|
}),
|
|
},
|
|
logger.Loc.Empty,
|
|
),
|
|
};
|
|
|
|
try json.set(allocator, "dist", Expr.init(
|
|
E.Object,
|
|
.{ .properties = G.Property.List.init(dist_props) },
|
|
logger.Loc.Empty,
|
|
));
|
|
|
|
{
|
|
const workspace_root = bun.sys.openA(
|
|
strings.withoutSuffixComptime(manager.original_package_json_path, "package.json"),
|
|
bun.O.DIRECTORY,
|
|
0,
|
|
).unwrap() catch |err| {
|
|
Output.err(err, "failed to open workspace directory", .{});
|
|
Global.crash();
|
|
};
|
|
defer _ = bun.sys.close(workspace_root);
|
|
|
|
try normalizeBin(
|
|
allocator,
|
|
json,
|
|
package_name,
|
|
workspace_root,
|
|
);
|
|
}
|
|
|
|
const buffer_writer = try bun.js_printer.BufferWriter.init(allocator);
|
|
var writer = bun.js_printer.BufferPrinter.init(buffer_writer);
|
|
|
|
const written = bun.js_printer.printJSON(
|
|
@TypeOf(&writer),
|
|
&writer,
|
|
json.*,
|
|
&json_source,
|
|
.{
|
|
.minify_whitespace = true,
|
|
},
|
|
) catch |err| {
|
|
switch (err) {
|
|
error.OutOfMemory => |oom| return oom,
|
|
else => {
|
|
Output.errGeneric("failed to print normalized package.json: {s}", .{@errorName(err)});
|
|
Global.crash();
|
|
},
|
|
}
|
|
};
|
|
_ = written;
|
|
|
|
return writer.ctx.writtenWithoutTrailingZero();
|
|
}
|
|
|
|
fn normalizeBin(
|
|
allocator: std.mem.Allocator,
|
|
json: *Expr,
|
|
package_name: string,
|
|
workspace_root: bun.FileDescriptor,
|
|
) OOM!void {
|
|
var path_buf: bun.PathBuffer = undefined;
|
|
if (json.asProperty("bin")) |bin_query| {
|
|
switch (bin_query.expr.data) {
|
|
.e_string => |bin_str| {
|
|
var bin_props = std.ArrayList(G.Property).init(allocator);
|
|
const normalized = strings.withoutPrefixComptimeZ(
|
|
path.normalizeBufZ(
|
|
try bin_str.string(allocator),
|
|
&path_buf,
|
|
.posix,
|
|
),
|
|
"./",
|
|
);
|
|
if (!bun.sys.existsAt(workspace_root, normalized)) {
|
|
Output.warn("bin '{s}' does not exist", .{normalized});
|
|
}
|
|
|
|
try bin_props.append(.{
|
|
.key = Expr.init(
|
|
E.String,
|
|
.{ .data = package_name },
|
|
logger.Loc.Empty,
|
|
),
|
|
.value = Expr.init(
|
|
E.String,
|
|
.{ .data = try allocator.dupe(u8, normalized) },
|
|
logger.Loc.Empty,
|
|
),
|
|
});
|
|
|
|
json.data.e_object.properties.ptr[bin_query.i].value = Expr.init(
|
|
E.Object,
|
|
.{
|
|
.properties = G.Property.List.fromList(bin_props),
|
|
},
|
|
logger.Loc.Empty,
|
|
);
|
|
},
|
|
.e_object => |bin_obj| {
|
|
var bin_props = std.ArrayList(G.Property).init(allocator);
|
|
for (bin_obj.properties.slice()) |bin_prop| {
|
|
const key = key: {
|
|
if (bin_prop.key) |key| {
|
|
if (key.isString() and key.data.e_string.len() != 0) {
|
|
break :key try allocator.dupeZ(
|
|
u8,
|
|
strings.withoutPrefixComptime(
|
|
path.normalizeBuf(
|
|
try key.data.e_string.string(allocator),
|
|
&path_buf,
|
|
.posix,
|
|
),
|
|
"./",
|
|
),
|
|
);
|
|
}
|
|
}
|
|
|
|
continue;
|
|
};
|
|
|
|
if (key.len == 0) {
|
|
continue;
|
|
}
|
|
|
|
const value = value: {
|
|
if (bin_prop.value) |value| {
|
|
if (value.isString() and value.data.e_string.len() != 0) {
|
|
break :value try allocator.dupeZ(
|
|
u8,
|
|
strings.withoutPrefixComptimeZ(
|
|
// replace separators
|
|
path.normalizeBufZ(
|
|
try value.data.e_string.string(allocator),
|
|
&path_buf,
|
|
.posix,
|
|
),
|
|
"./",
|
|
),
|
|
);
|
|
}
|
|
}
|
|
|
|
continue;
|
|
};
|
|
if (value.len == 0) {
|
|
continue;
|
|
}
|
|
|
|
if (!bun.sys.existsAt(workspace_root, value)) {
|
|
Output.warn("bin '{s}' does not exist", .{value});
|
|
}
|
|
|
|
try bin_props.append(.{
|
|
.key = Expr.init(
|
|
E.String,
|
|
.{ .data = key },
|
|
logger.Loc.Empty,
|
|
),
|
|
.value = Expr.init(
|
|
E.String,
|
|
.{ .data = value },
|
|
logger.Loc.Empty,
|
|
),
|
|
});
|
|
}
|
|
|
|
json.data.e_object.properties.ptr[bin_query.i].value = Expr.init(
|
|
E.Object,
|
|
.{ .properties = G.Property.List.fromList(bin_props) },
|
|
logger.Loc.Empty,
|
|
);
|
|
},
|
|
else => {},
|
|
}
|
|
} else if (json.asProperty("directories")) |directories_query| {
|
|
if (directories_query.expr.asProperty("bin")) |bin_query| {
|
|
const bin_dir_str = bin_query.expr.asString(allocator) orelse {
|
|
return;
|
|
};
|
|
var bin_props = std.ArrayList(G.Property).init(allocator);
|
|
const normalized_bin_dir = try allocator.dupeZ(
|
|
u8,
|
|
strings.withoutTrailingSlash(
|
|
strings.withoutPrefixComptime(
|
|
path.normalizeBuf(
|
|
bin_dir_str,
|
|
&path_buf,
|
|
.posix,
|
|
),
|
|
"./",
|
|
),
|
|
),
|
|
);
|
|
|
|
if (normalized_bin_dir.len == 0) {
|
|
return;
|
|
}
|
|
|
|
const bin_dir = bun.sys.openat(workspace_root, normalized_bin_dir, bun.O.DIRECTORY, 0).unwrap() catch |err| {
|
|
if (err == error.ENOENT) {
|
|
Output.warn("bin directory '{s}' does not exist", .{normalized_bin_dir});
|
|
return;
|
|
} else {
|
|
Output.err(err, "failed to open bin directory: '{s}'", .{normalized_bin_dir});
|
|
Global.crash();
|
|
}
|
|
};
|
|
|
|
var dirs: std.ArrayListUnmanaged(struct { std.fs.Dir, string, bool }) = .{};
|
|
defer dirs.deinit(allocator);
|
|
|
|
try dirs.append(allocator, .{ bin_dir.asDir(), normalized_bin_dir, false });
|
|
|
|
while (dirs.popOrNull()) |dir_info| {
|
|
var dir, const dir_subpath, const close_dir = dir_info;
|
|
defer if (close_dir) dir.close();
|
|
|
|
var iter = bun.DirIterator.iterate(dir, .u8);
|
|
while (iter.next().unwrap() catch null) |entry| {
|
|
const name, const subpath = name_and_subpath: {
|
|
const name = entry.name.slice();
|
|
const join = try std.fmt.allocPrintZ(allocator, "{s}{s}{s}", .{
|
|
dir_subpath,
|
|
// only using posix separators
|
|
if (dir_subpath.len == 0) "" else std.fs.path.sep_str_posix,
|
|
strings.withoutTrailingSlash(name),
|
|
});
|
|
|
|
break :name_and_subpath .{ join[join.len - name.len ..][0..name.len :0], join };
|
|
};
|
|
|
|
if (name.len == 0 or (name.len == 1 and name[0] == '.') or (name.len == 2 and name[0] == '.' and name[1] == '.')) {
|
|
continue;
|
|
}
|
|
|
|
try bin_props.append(.{
|
|
.key = Expr.init(
|
|
E.String,
|
|
.{ .data = std.fs.path.basenamePosix(subpath) },
|
|
logger.Loc.Empty,
|
|
),
|
|
.value = Expr.init(
|
|
E.String,
|
|
.{ .data = subpath },
|
|
logger.Loc.Empty,
|
|
),
|
|
});
|
|
|
|
if (entry.kind == .directory) {
|
|
const subdir = dir.openDirZ(name, .{ .iterate = true }) catch {
|
|
continue;
|
|
};
|
|
try dirs.append(allocator, .{ subdir, subpath, true });
|
|
}
|
|
}
|
|
}
|
|
|
|
try json.set(allocator, "bin", Expr.init(E.Object, .{ .properties = G.Property.List.fromList(bin_props) }, logger.Loc.Empty));
|
|
}
|
|
}
|
|
|
|
// no bins
|
|
}
|
|
|
|
fn constructPublishHeaders(
|
|
allocator: std.mem.Allocator,
|
|
print_buf: *std.ArrayListUnmanaged(u8),
|
|
registry: *const Npm.Registry.Scope,
|
|
maybe_json_len: ?usize,
|
|
maybe_otp: ?[]const u8,
|
|
uses_workspaces: bool,
|
|
auth_type: ?PackageManager.Options.AuthType,
|
|
) OOM!http.HeaderBuilder {
|
|
var print_writer = print_buf.writer(allocator);
|
|
var headers: http.HeaderBuilder = .{};
|
|
const npm_auth_type = if (maybe_otp == null)
|
|
if (auth_type) |auth| @tagName(auth) else "web"
|
|
else
|
|
"legacy";
|
|
const ci_name = bun.detectCI();
|
|
|
|
{
|
|
headers.count("accept", "*/*");
|
|
headers.count("accept-encoding", "gzip,deflate");
|
|
|
|
if (registry.token.len > 0) {
|
|
try print_writer.print("Bearer {s}", .{registry.token});
|
|
headers.count("authorization", print_buf.items);
|
|
print_buf.clearRetainingCapacity();
|
|
} else if (registry.auth.len > 0) {
|
|
try print_writer.print("Basic {s}", .{registry.auth});
|
|
headers.count("authorization", print_buf.items);
|
|
print_buf.clearRetainingCapacity();
|
|
}
|
|
|
|
if (maybe_json_len != null) {
|
|
// not using `MimeType.json.value`, verdaccio will fail if it's anything other than `application/json`
|
|
headers.count("content-type", "application/json");
|
|
}
|
|
|
|
headers.count("npm-auth-type", npm_auth_type);
|
|
if (maybe_otp) |otp| {
|
|
headers.count("npm-otp", otp);
|
|
}
|
|
headers.count("npm-command", "publish");
|
|
|
|
try print_writer.print("{s} {s} {s} workspaces/{}{s}{s}", .{
|
|
Global.user_agent,
|
|
Global.os_name,
|
|
Global.arch_name,
|
|
uses_workspaces,
|
|
if (ci_name != null) " ci/" else "",
|
|
ci_name orelse "",
|
|
});
|
|
// headers.count("user-agent", "npm/10.8.3 node/v22.6.0 darwin arm64 workspaces/false");
|
|
headers.count("user-agent", print_buf.items);
|
|
print_buf.clearRetainingCapacity();
|
|
|
|
headers.count("Connection", "keep-alive");
|
|
headers.count("Host", registry.url.host);
|
|
|
|
if (maybe_json_len) |json_len| {
|
|
try print_writer.print("{d}", .{json_len});
|
|
headers.count("Content-Length", print_buf.items);
|
|
print_buf.clearRetainingCapacity();
|
|
}
|
|
}
|
|
|
|
try headers.allocate(allocator);
|
|
|
|
{
|
|
headers.append("accept", "*/*");
|
|
headers.append("accept-encoding", "gzip,deflate");
|
|
|
|
if (registry.token.len > 0) {
|
|
try print_writer.print("Bearer {s}", .{registry.token});
|
|
headers.append("authorization", print_buf.items);
|
|
print_buf.clearRetainingCapacity();
|
|
} else if (registry.auth.len > 0) {
|
|
try print_writer.print("Basic {s}", .{registry.auth});
|
|
headers.append("authorization", print_buf.items);
|
|
print_buf.clearRetainingCapacity();
|
|
}
|
|
|
|
if (maybe_json_len != null) {
|
|
// not using `MimeType.json.value`, verdaccio will fail if it's anything other than `application/json`
|
|
headers.append("content-type", "application/json");
|
|
}
|
|
|
|
headers.append("npm-auth-type", npm_auth_type);
|
|
if (maybe_otp) |otp| {
|
|
headers.append("npm-otp", otp);
|
|
}
|
|
headers.append("npm-command", "publish");
|
|
|
|
try print_writer.print("{s} {s} {s} workspaces/{}{s}{s}", .{
|
|
Global.user_agent,
|
|
Global.os_name,
|
|
Global.arch_name,
|
|
uses_workspaces,
|
|
if (ci_name != null) " ci/" else "",
|
|
ci_name orelse "",
|
|
});
|
|
// headers.append("user-agent", "npm/10.8.3 node/v22.6.0 darwin arm64 workspaces/false");
|
|
headers.append("user-agent", print_buf.items);
|
|
print_buf.clearRetainingCapacity();
|
|
|
|
headers.append("Connection", "keep-alive");
|
|
headers.append("Host", registry.url.host);
|
|
|
|
if (maybe_json_len) |json_len| {
|
|
try print_writer.print("{d}", .{json_len});
|
|
headers.append("Content-Length", print_buf.items);
|
|
print_buf.clearRetainingCapacity();
|
|
}
|
|
}
|
|
|
|
return headers;
|
|
}
|
|
|
|
fn constructPublishRequestBody(
|
|
comptime directory_publish: bool,
|
|
ctx: *const Context(directory_publish),
|
|
) OOM![]const u8 {
|
|
const tag = if (ctx.manager.options.publish_config.tag.len > 0)
|
|
ctx.manager.options.publish_config.tag
|
|
else
|
|
"latest";
|
|
|
|
const encoded_tarball_len = std.base64.standard.Encoder.calcSize(ctx.tarball_bytes.len);
|
|
const version_without_build_tag = Dependency.withoutBuildTag(ctx.package_version);
|
|
|
|
var buf = try std.ArrayListUnmanaged(u8).initCapacity(
|
|
ctx.allocator,
|
|
ctx.package_name.len * 5 +
|
|
version_without_build_tag.len * 4 +
|
|
ctx.abs_tarball_path.len +
|
|
encoded_tarball_len,
|
|
);
|
|
var writer = buf.writer(ctx.allocator);
|
|
|
|
try writer.print("{{\"_id\":\"{s}\",\"name\":\"{s}\"", .{
|
|
ctx.package_name,
|
|
ctx.package_name,
|
|
});
|
|
|
|
try writer.print(",\"dist-tags\":{{\"{s}\":\"{s}\"}}", .{
|
|
tag,
|
|
version_without_build_tag,
|
|
});
|
|
|
|
// "versions"
|
|
{
|
|
try writer.print(",\"versions\":{{\"{s}\":{s}}}", .{
|
|
version_without_build_tag,
|
|
ctx.normalized_pkg_info,
|
|
});
|
|
}
|
|
|
|
if (ctx.manager.options.publish_config.access) |access| {
|
|
try writer.print(",\"access\":\"{s}\"", .{@tagName(access)});
|
|
} else {
|
|
try writer.writeAll(",\"access\":null");
|
|
}
|
|
|
|
// "_attachments"
|
|
{
|
|
try writer.print(",\"_attachments\":{{\"{}\":{{\"content_type\":\"{s}\",\"data\":\"", .{
|
|
Pack.fmtTarballFilename(ctx.package_name, ctx.package_version, .raw),
|
|
"application/octet-stream",
|
|
});
|
|
|
|
try buf.ensureUnusedCapacity(ctx.allocator, encoded_tarball_len);
|
|
buf.items.len += encoded_tarball_len;
|
|
const count = bun.simdutf.base64.encode(ctx.tarball_bytes, buf.items[buf.items.len - encoded_tarball_len ..], false);
|
|
bun.assertWithLocation(count == encoded_tarball_len, @src());
|
|
|
|
try writer.print("\",\"length\":{d}}}}}}}", .{
|
|
ctx.tarball_bytes.len,
|
|
});
|
|
}
|
|
|
|
return buf.items;
|
|
}
|
|
};
|