You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
141 lines
3.7 KiB
141 lines
3.7 KiB
/*
|
|
This file is part of cpp-ethereum.
|
|
|
|
cpp-ethereum is free software: you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation, either version 3 of the License, or
|
|
(at your option) any later version.
|
|
|
|
cpp-ethereum is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with cpp-ethereum. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
/** @file Common.h
|
|
* @author Gav Wood <i@gavwood.com>
|
|
* @date 2014
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <string>
|
|
#include <chrono>
|
|
|
|
#include <libdevcore/Common.h>
|
|
#include <libdevcore/Log.h>
|
|
#include <libdevcore/RLP.h>
|
|
#include <libp2p/Capability.h>
|
|
|
|
namespace dev
|
|
{
|
|
namespace shh
|
|
{
|
|
|
|
/* this makes these symbols ambiguous on VS2013
|
|
using h256 = dev::h256;
|
|
using h256s = dev::h256s;
|
|
using bytes = dev::bytes;
|
|
using RLPStream = dev::RLPStream;
|
|
using RLP = dev::RLP;
|
|
using bytesRef = dev::bytesRef;
|
|
using bytesConstRef = dev::bytesConstRef;
|
|
using h256Set = dev::h256Set;
|
|
*/
|
|
|
|
class WhisperHost;
|
|
class WhisperPeer;
|
|
class Whisper;
|
|
|
|
class Envelope;
|
|
|
|
enum WhisperPacket
|
|
{
|
|
StatusPacket = 0,
|
|
MessagesPacket,
|
|
AddFilterPacket,
|
|
RemoveFilterPacket,
|
|
PacketCount
|
|
};
|
|
|
|
using CollapsedTopicPart = FixedHash<4>;
|
|
using FullTopicPart = h256;
|
|
|
|
using CollapsedTopic = std::vector<CollapsedTopicPart>;
|
|
using FullTopic = h256s;
|
|
|
|
CollapsedTopicPart collapse(FullTopicPart const& _fullTopicPart);
|
|
CollapsedTopic collapse(FullTopic const& _fullTopic);
|
|
|
|
class BuildTopic
|
|
{
|
|
public:
|
|
BuildTopic() {}
|
|
template <class T> BuildTopic(T const& _t) { shift(_t); }
|
|
|
|
template <class T> BuildTopic& shift(T const& _r) { return shiftBytes(RLPStream().append(_r).out()); }
|
|
template <class T> BuildTopic& operator()(T const& _t) { return shift(_t); }
|
|
|
|
BuildTopic& shiftRaw(h256 const& _part) { m_parts.push_back(_part); return *this; }
|
|
|
|
operator CollapsedTopic() const { return toTopic(); }
|
|
operator FullTopic() const { return toFullTopic(); }
|
|
CollapsedTopic toTopic() const;
|
|
FullTopic toFullTopic() const { return m_parts; }
|
|
|
|
protected:
|
|
BuildTopic& shiftBytes(bytes const& _b);
|
|
|
|
h256s m_parts;
|
|
};
|
|
|
|
using TopicMask = std::vector<std::pair<CollapsedTopicPart, CollapsedTopicPart>>;
|
|
using TopicMasks = std::vector<TopicMask>;
|
|
|
|
class TopicFilter
|
|
{
|
|
public:
|
|
TopicFilter() {}
|
|
TopicFilter(FullTopic const& _m) { m_topicMasks.push_back(TopicMask()); for (auto const& h: _m) m_topicMasks.back().push_back(std::make_pair(collapse(h), h ? ~CollapsedTopicPart() : CollapsedTopicPart())); }
|
|
TopicFilter(TopicMask const& _m): m_topicMasks(1, _m) {}
|
|
TopicFilter(TopicMasks const& _m): m_topicMasks(_m) {}
|
|
TopicFilter(RLP const& _r)//: m_topicMasks(_r.toVector<std::vector<>>())
|
|
{
|
|
for (RLP i: _r)
|
|
{
|
|
m_topicMasks.push_back(TopicMask());
|
|
for (RLP j: i)
|
|
m_topicMasks.back().push_back(j.toPair<FixedHash<4>, FixedHash<4>>());
|
|
}
|
|
}
|
|
|
|
void streamRLP(RLPStream& _s) const { _s << m_topicMasks; }
|
|
h256 sha3() const;
|
|
|
|
bool matches(Envelope const& _m) const;
|
|
|
|
private:
|
|
TopicMasks m_topicMasks;
|
|
};
|
|
|
|
class BuildTopicMask: BuildTopic
|
|
{
|
|
public:
|
|
BuildTopicMask() {}
|
|
template <class T> BuildTopicMask(T const& _t) { shift(_t); }
|
|
|
|
template <class T> BuildTopicMask& shift(T const& _r) { BuildTopic::shift(_r); return *this; }
|
|
BuildTopicMask& shiftRaw(h256 const& _h) { BuildTopic::shiftRaw(_h); return *this; }
|
|
|
|
template <class T> BuildTopicMask& operator()(T const& _t) { shift(_t); return *this; }
|
|
|
|
operator TopicMask() const { return toTopicMask(); }
|
|
operator FullTopic() const { return toFullTopic(); }
|
|
TopicMask toTopicMask() const;
|
|
FullTopic toFullTopic() const { return m_parts; }
|
|
};
|
|
|
|
}
|
|
}
|
|
|