16#include <zypp-core/zyppng/core/String>
20#undef ZYPP_BASE_LOGGER_LOGGROUP
21#define ZYPP_BASE_LOGGER_LOGGROUP "zypp::plugin"
38 Impl(
const std::string & command_r )
52 Impl( std::istream & stream_r );
63 if ( command_r.find(
'\n' ) != std::string::npos )
75 {
_body = std::move(body_r); }
88 for (
auto c = val.begin (); c!= val.end(); c++ ) {
91 escaped.push_back(
'\\');
92 escaped.push_back(
'n');
96 escaped.push_back(
'\\');
97 escaped.push_back(
'r');
101 escaped.push_back(
'\\');
102 escaped.push_back(
'\\');
106 escaped.push_back(
'\\');
107 escaped.push_back(
'c');
111 escaped.push_back (*c);
119 std::string unescaped;
120 for (
auto c = val.begin (); c!= val.end(); ) {
122 unescaped.push_back (*c);
128 if ( c == val.end() )
133 unescaped.push_back(
'\n');
138 unescaped.push_back(
'\r');
143 unescaped.push_back(
'\\');
148 unescaped.push_back(
':');
162 using KeyRange = std::pair<HeaderList::iterator, HeaderList::iterator>;
170 const std::string &
getHeader(
const std::string & key_r )
const
173 if ( r.first == r.second )
175 const std::string & ret( r.first->second );
176 if ( ++r.first != r.second )
181 const std::string &
getHeader(
const std::string & key_r,
const std::string & default_r )
const
184 if ( r.first == r.second )
186 const std::string & ret( r.first->second );
187 if ( ++r.first != r.second )
192 const std::string &
getHeaderNT(
const std::string & key_r,
const std::string & default_r )
const
195 return iter !=
_header.end() ? iter->second : default_r;
198 HeaderList::value_type
mkHeaderPair(
const std::string & key_r,
const std::string & value_r )
200 return HeaderList::value_type( key_r, value_r );
203 void setHeader(
const std::string & key_r,
const std::string & value_r )
209 void addHeader(
const std::string & key_r,
const std::string & value_r )
216 for (
const auto & el : contents_r )
222 std::string::size_type sep( data.find(
':') );
223 if ( sep == std::string::npos )
235 std::ostream &
writeTo( std::ostream & stream_r )
const;
246 static shared_ptr<Impl> _nullimpl(
new Impl );
253 {
return new Impl( *
this ); }
260 return str <<
"PluginFrame[" << obj.
command() <<
"](" << obj.
headerList().size() <<
"){" << obj.
body().size() <<
"}";
281 if ( ! stream_r.good() )
287 if ( ! stream_r.good() )
299 std::optional<uint64_t> cLen;
302 if ( !contentLen.empty() ) {
317 _body.resize ( (*cLen)+1,
'\0' );
318 stream_r.read (
_body.data(), (*cLen)+1 );
320 if ( ! stream_r.good() )
322 if (
_body.back() !=
'\0' )
330 if ( ! stream_r.good() )
342 stream_r << _command <<
"\n";
348 for_( it, _header.begin(), _header.end() )
349 stream_r << escapeHeader(it->first) <<
':' << escapeHeader(it->second) <<
"\n";
355 stream_r.write( _body.data(), _body.size() );
374 static std::string _val(
"ACK" );
380 static std::string _val(
"ERROR" );
386 static std::string _val(
"_ENOMETHOD" );
392 static std::string _val(
"content-length");
401 : _pimpl( new
Impl( command_r ) )
409 : _pimpl( new
Impl( command_r,
std::move(body_r) ) )
413 : _pimpl( new
Impl( command_r, contents_r ) )
417 : _pimpl( new
Impl( command_r,
std::move(body_r), contents_r ) )
421 : _pimpl( new
Impl( stream_r ) )
Base class for PluginFrame Exception.
Command frame for communication with PluginScript.
static const std::string & ackCommand()
"ACK" command.
ByteArray & bodyRef()
Return a reference to the frame body.
void setCommand(const std::string &command_r)
Set the frame command.
HeaderList::const_iterator HeaderListIterator
Header list iterator.
void setBody(const std::string &body_r)
Set the frame body.
const std::initializer_list< std::pair< std::string, std::string > > & HeaderInitializerList
PluginFrame()
Default ctor (empty frame)
void clearHeader(const std::string &key_r)
Remove all headers for key_r.
static const std::string & contentLengthHeader()
"content-lenght" header name
bool empty() const
Whether this is an empty frame.
const ByteArray & body() const
Return the frame body.
static const std::string & enomethodCommand()
"_ENOMETHOD" command.
const std::string & command() const
Return the frame command.
void addHeader(const std::string &key_r, const std::string &value_r=std::string())
Add header for key_r leaving already existing headers for key_r unchanged.
RWCOW_pointer< Impl > _pimpl
Pointer to implementation.
static const std::string & errorCommand()
"ERROR" command.
const std::string & getHeader(const std::string &key_r) const
Return header value for key_r.
std::multimap< std::string, std::string > HeaderList
The header list.
HeaderList & headerList()
Modifyalble header list for internal use only.
void addRawHeader(const ByteArray &header)
void setHeader(const std::string &key_r, const std::string &value_r=std::string())
Set header for key_r removing all other occurrences of key_r.
const std::string & getHeaderNT(const std::string &key_r, const std::string &default_r=std::string()) const
Not throwing version returing one of the matching header values or default_r string.
std::ostream & writeTo(std::ostream &stream_r) const
Write frame to stream.
String related utilities and Regular expression matching.
std::string numstring(char n, int w=0)
std::string receiveUpTo(std::istream &str, const char delim_r, bool returnDelim_r)
Return stream content up to the next ocurrence of delim_r or EOF delim_r, if found,...
std::string getline(std::istream &str, const Trim trim_r)
Return stream content up to (but not returning) the next newline.
Easy-to use interface to the ZYPP dependency resolver.
bool operator==(const SetRelation::Enum &lhs, const SetCompare &rhs)
This is an overloaded member function, provided for convenience. It differs from the above function o...
std::ostream & operator<<(std::ostream &str, const SerialNumber &obj)
std::optional< T > safe_strtonum(const std::string_view &val)
PluginFrame implementation.
std::ostream & writeTo(std::ostream &stream_r) const
void setCommand(const std::string &command_r)
Impl(const std::string &command_r, HeaderInitializerList contents_r)
const std::string & getHeader(const std::string &key_r) const
static shared_ptr< Impl > nullimpl()
Offer default Impl.
const std::string & command() const
const std::string & getHeaderNT(const std::string &key_r, const std::string &default_r) const
Impl(const std::string &command_r, ByteArray &&body_r)
HeaderList & headerList()
friend Impl * rwcowClone(const Impl *rhs)
static std::string unescapeHeader(std::string_view val)
Impl(const std::string &command_r)
const HeaderList & headerList() const
std::pair< HeaderListIterator, HeaderListIterator > constKeyRange
const std::string & getHeader(const std::string &key_r, const std::string &default_r) const
void setHeader(const std::string &key_r, const std::string &value_r)
void clearHeader(const std::string &key_r)
void addHeader(const std::string &key_r, const std::string &value_r)
std::pair< HeaderList::iterator, HeaderList::iterator > KeyRange
Impl * clone() const
clone for RWCOW_pointer
static std::string escapeHeader(std::string_view val)
void addRawHeader(const std::string_view data)
void addHeader(HeaderInitializerList contents_r)
HeaderList::value_type mkHeaderPair(const std::string &key_r, const std::string &value_r)
void setBody(ByteArray &&body_r)
std::ostream & operator<<(std::ostream &str, const PluginFrame::Impl &obj)
Stream output.
Impl(const std::string &command_r, ByteArray &&body_r, HeaderInitializerList contents_r)
const ByteArray & body() const
#define for_(IT, BEG, END)
Convenient for-loops using iterator.
#define ZYPP_THROW(EXCPT)
Drops a logline and throws the Exception.