notification-stream.hpp
Go to the documentation of this file.
1 /* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2 /*
3  * Copyright (c) 2013-2021 Regents of the University of California.
4  *
5  * This file is part of ndn-cxx library (NDN C++ library with eXperimental eXtensions).
6  *
7  * ndn-cxx library is free software: you can redistribute it and/or modify it under the
8  * terms of the GNU Lesser General Public License as published by the Free Software
9  * Foundation, either version 3 of the License, or (at your option) any later version.
10  *
11  * ndn-cxx library is distributed in the hope that it will be useful, but WITHOUT ANY
12  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
13  * PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details.
14  *
15  * You should have received copies of the GNU General Public License and GNU Lesser
16  * General Public License along with ndn-cxx, e.g., in COPYING.md file. If not, see
17  * <http://www.gnu.org/licenses/>.
18  *
19  * See AUTHORS.md for complete list of ndn-cxx authors and contributors.
20  */
21 
22 #ifndef NDN_CXX_UTIL_NOTIFICATION_STREAM_HPP
23 #define NDN_CXX_UTIL_NOTIFICATION_STREAM_HPP
24 
25 #include "ndn-cxx/face.hpp"
26 #include "ndn-cxx/name.hpp"
29 
30 namespace ndn {
31 namespace util {
32 
36 template<typename Notification>
37 class NotificationStream : noncopyable
38 {
39 public:
40  BOOST_CONCEPT_ASSERT((WireEncodable<Notification>));
41 
42  NotificationStream(Face& face, const Name& prefix, KeyChain& keyChain)
43  : m_face(face)
44  , m_prefix(prefix)
45  , m_keyChain(keyChain)
46  , m_sequenceNo(0)
47  {
48  }
49 
50  virtual
51  ~NotificationStream() = default;
52 
53  void
54  postNotification(const Notification& notification)
55  {
56  Name dataName = m_prefix;
57  dataName.appendSequenceNumber(m_sequenceNo);
58 
59  shared_ptr<Data> data = make_shared<Data>(dataName);
60  data->setContent(notification.wireEncode());
61  data->setFreshnessPeriod(1_s);
62 
63  m_keyChain.sign(*data);
64  m_face.put(*data);
65 
66  ++m_sequenceNo;
67  }
68 
69 private:
70  Face& m_face;
71  const Name m_prefix;
72  KeyChain& m_keyChain;
73  uint64_t m_sequenceNo;
74 };
75 
76 } // namespace util
77 } // namespace ndn
78 
79 #endif // NDN_CXX_UTIL_NOTIFICATION_STREAM_HPP
Provide a communication channel with local or remote NDN forwarder.
Definition: face.hpp:91
void put(Data data)
Publish data packet.
Definition: face.cpp:196
Represents an absolute name.
Definition: name.hpp:46
Name & appendSequenceNumber(uint64_t seqNo)
Append a sequence number component.
Definition: name.hpp:458
a concept check for TLV abstraction with .wireEncode method
Definition: concepts.hpp:45
provides a publisher of Notification Stream
virtual ~NotificationStream()=default
NotificationStream(Face &face, const Name &prefix, KeyChain &keyChain)
void postNotification(const Notification &notification)
Definition: data.cpp:25