Function streamMultipartUpload

src/webInterface.cpp:387–453

}

bool streamMultipartUpload(httpd_req_t *req) {
    if (!checkUserWebAuth(req)) return false;

    String boundary = multipartBoundary(headerValue(req, "Content-Type"));
    if (boundary.isEmpty()) {
        sendText(req, 400, "text/plain", "Missing multipart boundary");
        return false;
    }

    const String delimiter = "\r\n" + boundary;
    const size_t keep = delimiter.length() + 8;
    std::vector<uint8_t> pending;
    pending.reserve(bufSize + keep + 256);
    File file;
    bool inFile = false;
    bool finishedFile = false;
    size_t written = 0;
    size_t remaining = req->content_len;

    while (remaining > 0) {
        int readLen =
            httpd_req_recv(req, reinterpret_cast<char *>(buff), remaining > bufSize ? bufSize : remaining);
        if (readLen <= 0) return false;
        pending.insert(pending.end(), buff, buff + readLen);
        remaining -= readLen;

        while (!finishedFile) {
            if (!inFile) {
                int headerEnd = findBytes(pending, "\r\n\r\n");
                if (headerEnd < 0) break;
                String headers;
                headers.reserve(headerEnd);
                for (int i = 0; i < headerEnd; ++i) headers += static_cast<char>(pending[i]);
                String filename = extractDispositionValue(headers, "filename");
                pending.erase(pending.begin(), pending.begin() + headerEnd + 4);
                if (filename.isEmpty()) continue;
                if (!beginUploadTarget(file, filename)) return false;
                inFile = true;
            }

            int boundaryAt = findBytes(pending, delimiter);
            if (boundaryAt >= 0) {
                if (boundaryAt > 0 && !writeUploadData(file, pending.data(), boundaryAt, written))
                    return false;
                written += boundaryAt;
                pending.erase(pending.begin(), pending.begin() + boundaryAt + delimiter.length());
                finishedFile = finishUploadTarget(file);
                break;
            }

            if (pending.size() > keep) {
                size_t writeLen = pending.size() - keep;
                if (!writeUploadData(file, pending.data(), writeLen, written)) return false;
                written += writeLen;
                pending.erase(pending.begin(), pending.begin() + writeLen);
            }
            break;
        }