20 #undef ZYPP_BASE_LOGGER_LOGGROUP
21 #define ZYPP_BASE_LOGGER_LOGGROUP "zypp::plugin"
38 Impl(
const std::string & command_r )
41 Impl(
const std::string & command_r,
const std::string & body_r )
52 Impl( std::istream & stream_r );
63 if ( command_r.find(
'\n' ) != std::string::npos )
68 const std::string &
body()
const
74 void setBody(
const std::string & body_r )
79 typedef std::pair<HeaderList::iterator,HeaderList::iterator>
KeyRange;
87 const std::string &
getHeader(
const std::string & key_r )
const
90 if ( r.first == r.second )
92 const std::string & ret( r.first->second );
93 if ( ++r.first != r.second )
98 const std::string &
getHeader(
const std::string & key_r,
const std::string & default_r )
const
101 if ( r.first == r.second )
103 const std::string & ret( r.first->second );
104 if ( ++r.first != r.second )
109 const std::string &
getHeaderNT(
const std::string & key_r,
const std::string & default_r )
const
112 return iter !=
_header.end() ? iter->second : default_r;
115 HeaderList::value_type
mkHeaderPair(
const std::string & key_r,
const std::string & value_r )
117 if ( key_r.find_first_of(
":\n" ) != std::string::npos )
119 if ( value_r.find_first_of(
"\n" ) != std::string::npos )
121 return HeaderList::value_type( key_r, value_r );
124 void setHeader(
const std::string & key_r,
const std::string & value_r )
130 void addHeader(
const std::string & key_r,
const std::string & value_r )
137 for (
const auto & el : contents_r )
147 std::ostream &
writeTo( std::ostream & stream_r )
const;
158 static shared_ptr<Impl> _nullimpl(
new Impl );
162 friend Impl * rwcowClone<Impl>(
const Impl * rhs );
165 {
return new Impl( *
this ); }
172 return str <<
"PluginFrame[" << obj.
command() <<
"](" << obj.
headerList().size() <<
"){" << obj.
body().size() <<
"}";
190 if ( ! stream_r.good() )
196 if ( ! stream_r.good() )
203 if ( sep == std::string::npos )
206 _header.insert( HeaderList::value_type( data.substr(0,sep), data.substr(sep+1) ) );
211 if ( ! stream_r.good() )
222 stream_r << _command << endl;
224 for_( it, _header.begin(), _header.end() )
225 stream_r << it->first <<
':' << it->second << endl;
243 static std::string _val(
"ACK" );
249 static std::string _val(
"ERROR" );
255 static std::string _val(
"_ENOMETHOD" );
264 : _pimpl( new
Impl( command_r ) )
268 : _pimpl( new
Impl( command_r, body_r ) )
272 : _pimpl( new
Impl( command_r, contents_r ) )
276 : _pimpl( new
Impl( command_r, body_r, contents_r ) )
280 : _pimpl( new
Impl( stream_r ) )
334 {
return str << *obj.
_pimpl; }
PluginFrame()
Default ctor (empty frame)
static shared_ptr< Impl > nullimpl()
Offer default Impl.
#define ZYPP_THROW(EXCPT)
Drops a logline and throws the Exception.
const std::string & getHeaderNT(const std::string &key_r, const std::string &default_r) const
Command frame for communication with PluginScript.
void setCommand(const std::string &command_r)
Set the frame command.
const std::string & command() const
Return the frame command.
const std::string & getHeader(const std::string &key_r, const std::string &default_r) const
void clearHeader(const std::string &key_r)
Impl * clone() const
clone for RWCOW_pointer
Impl(const std::string &command_r, const std::string &body_r)
Impl(const std::string &command_r)
#define for_(IT, BEG, END)
Convenient for-loops using iterator.
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.
bool operator==(const SetRelation::Enum &lhs, const SetCompare &rhs)
static const std::string & errorCommand()
"ERROR" command.
void setCommand(const std::string &command_r)
Impl(const std::string &command_r, const std::string &body_r, HeaderInitializerList contents_r)
const std::string & getHeader(const std::string &key_r) const
std::pair< HeaderListIterator, HeaderListIterator > constKeyRange
std::ostream & operator<<(std::ostream &str, const Exception &obj)
static const std::string & enomethodCommand()
"_ENOMETHOD" command.
void addHeader(HeaderInitializerList contents_r)
Base class for PluginFrame Exception.
const std::initializer_list< std::pair< std::string, std::string > > & HeaderInitializerList
std::pair< HeaderList::iterator, HeaderList::iterator > KeyRange
Impl(const std::string &command_r, HeaderInitializerList contents_r)
std::string getline(std::istream &str, const Trim trim_r)
Return stream content up to (but not returning) the next newline.
static const std::string & ackCommand()
"ACK" command.
RWCOW_pointer< Impl > _pimpl
Pointer to implementation.
void setHeader(const std::string &key_r, const std::string &value_r)
HeaderList & headerList()
void setBody(const std::string &body_r)
Set the frame body.
std::multimap< std::string, std::string > HeaderList
The header list.
const std::string & getHeader(const std::string &key_r) const
Return header value for key_r.
HeaderList::value_type mkHeaderPair(const std::string &key_r, const std::string &value_r)
void addHeader(const std::string &key_r, const std::string &value_r)
HeaderList::const_iterator HeaderListIterator
Header list iterator.
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, is always read from the stream.
const std::string & command() const
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.
HeaderList & headerList()
Modifyalble header list for internal use only.
std::ostream & writeTo(std::ostream &stream_r) const
std::ostream & operator<<(std::ostream &str, const PluginFrame::Impl &obj)
PluginFrame implementation.
std::ostream & writeTo(std::ostream &stream_r) const
Write frame to stream.
std::string & bodyRef()
Return a reference to the frame body.
bool empty() const
Whether this is an empty frame.
void clearHeader(const std::string &key_r)
Remove all headers for key_r.
void setBody(const std::string &body_r)
const HeaderList & headerList() const
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.
const std::string & body() const
const std::string & body() const
Return the frame body.