Function streamBodyToFile

3ds/source/server.cpp:161–199

Streams the body of an upload request to `tmpPath`, tracking progress and honouring a receive cancel. `leftover` is the body already read while parsing the header. Returns true when the full body was written.

    // honouring a receive cancel. `leftover` is the body already read while
    // parsing the header. Returns true when the full body was written.
    static bool streamBodyToFile(s32 clientSocket, const std::u16string& tmpPath, size_t contentLength, const char* leftover, size_t leftoverLen)
    {
        FSStream out(Archive::sdmc(), tmpPath, FS_OPEN_WRITE, (u32)contentLength);
        if (!out.good()) {
            Logging::error("Failed to open upload temp file (0x{:08X}).", (u32)out.result());
            return false;
        }

        TransferStatus::beginNetwork(i18n::t("transfer.downloading"), contentLength);

        size_t written = 0;
        if (leftoverLen > 0) {
            size_t toWrite = leftoverLen > contentLength ? contentLength : leftoverLen;
            out.write(leftover, (u32)toWrite);
            written += toWrite;
            TransferStatus::setBytesDone(written);
        }

        constexpr size_t RECV_CHUNK = 32 * 1024;
        std::unique_ptr<char[]> buffer(new char[RECV_CHUNK]);
        int idleMs = 0;
        bool ok    = true;
        while (written < contentLength) {
            ssize_t received = pollRecv(clientSocket, buffer.get(), RECV_CHUNK, idleMs, true);
            if (received <= 0) {
                ok = false; // clean close, idle timeout, or cancel: incomplete body
                break;
            }
            size_t toWrite = (size_t)received;
            if (written + toWrite > contentLength) {
                toWrite = contentLength - written;
            }
            out.write(buffer.get(), (u32)toWrite);
            written += toWrite;
            TransferStatus::setBytesDone(written);
        }
        out.close();
        return ok && written == contentLength;
    }

    static void handleHttpRequest(s32 clientSocket)
    {