From Code to Community: Sponsoring The Perl and Raku Conference 2025 Learn more

SYBER / UniEvent-HTTP-1.2.3 / clib / src / panda / unievent / http / Form.h 

            

              
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68

              
#pragma once
#include <panda/string.h>
#include <panda/error.h>
#include <panda/protocol/http/Request.h>
#include <panda/unievent/Streamer.h>
#include <panda/unievent/streamer/Stream.h>
namespace panda { namespace unievent { namespace http {
namespace proto = protocol::http;
struct Client;
using Chunk = proto::Request::wrapped_chunk;
struct IFormItem: panda::Refcnt {
    string name;
    IFormItem(const string& name_) noexcept: name{name_}{};
    virtual bool start(proto::Request& req, Client& out) = 0;
    virtual void stop() {}
protected:
    void produce(const Chunk& chunk, Client& out) noexcept;
};
using FormItemSP = iptr<IFormItem>;
struct FormField: IFormItem {
    string content;
    inline FormField(const string& name_, const string& content_) noexcept: IFormItem(name_), content{content_} {}
    bool start(proto::Request& req, Client& out) override;
};
struct FormEmbeddedFile: FormField {
    string mime_type;
    string filename;
    FormEmbeddedFile(const string& name_, const string& content_, const string& mime_ = "application/octet-stream", const string& filename_ = "") noexcept:
        FormField(name_, content_), mime_type{mime_}, filename{filename_} {}
    bool start(proto::Request& req, Client& out) override;
};
struct FormFile: IFormItem {
    Streamer::IInputSP in;
    string mime_type;
    string filename;
    StreamerSP streamer;
    size_t max_buf;
    struct ClientOutput: streamer::StreamOutput {
        proto::RequestSP req;
        ClientOutput(const StreamSP& stream, const proto::RequestSP& req_):StreamOutput(stream), req{req_} {}
        ErrorCode write (const string& data) override;
    };
    FormFile(const string& name_, Streamer::IInputSP in_, const string& mime_, const string& filename_, size_t max_buf_ = 10000000) noexcept:
        IFormItem(name_), in{in_}, mime_type{mime_}, filename{filename_}, max_buf{max_buf_}  {
    }
    bool start(proto::Request& req, Client& out) override;
    void stop() override;
};
}}}