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,
                    abs_tarball_path,
                );

                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 = bun.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,
        abs_tarball_path: stringZ,
    ) 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}", .{bun.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}", .{bun.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 bun.fmt.allocPrint(allocator, "http://{s}/{s}/-/{s}", .{
                        strings.withoutTrailingSlash(registry.url.href),
                        package_name,
                        std.fs.path.basename(abs_tarball_path),
                    }),
                },
                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 bun.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\":{{\"{s}\":{{\"content_type\":\"{s}\",\"data\":\"", .{
                std.fs.path.basename(ctx.abs_tarball_path),
                "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;
    }
};