blob: 0378bd1e074640606d8d9d66c73ac78e7d3cf1ad [file] [log] [blame]
Alexander Afanasyev4abdbf12014-08-11 12:48:54 -07001/* -*- Mode:C++; c-file-style:"gnu"; indent-tabs-mode:nil; -*- */
2/**
3 * Copyright (c) 2013-2014 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/**
23 * Original copyright notice from NFD:
24 *
25 * Copyright (c) 2014, Regents of the University of California,
26 * Arizona Board of Regents,
27 * Colorado State University,
28 * University Pierre & Marie Curie, Sorbonne University,
29 * Washington University in St. Louis,
30 * Beijing Institute of Technology,
31 * The University of Memphis
32 *
33 * This file is part of NFD (Named Data Networking Forwarding Daemon).
34 * See AUTHORS.md for complete list of NFD authors and contributors.
35 *
36 * NFD is free software: you can redistribute it and/or modify it under the terms
37 * of the GNU General Public License as published by the Free Software Foundation,
38 * either version 3 of the License, or (at your option) any later version.
39 *
40 * NFD is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
41 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
42 * PURPOSE. See the GNU General Public License for more details.
43 *
44 * You should have received a copy of the GNU General Public License along with
45 * NFD, e.g., in COPYING.md file. If not, see <http://www.gnu.org/licenses/>.
46 */
47
48#include "util/notification-stream.hpp"
49#include "simple-notification.hpp"
50
51#include "boost-test.hpp"
52#include "../dummy-client-face.hpp"
53
54namespace ndn {
55namespace tests {
56
57BOOST_AUTO_TEST_SUITE(UtilNotificationStream)
58
59BOOST_AUTO_TEST_CASE(Post)
60{
61 shared_ptr<DummyClientFace> face = makeDummyClientFace();
62 ndn::KeyChain keyChain;
63 util::NotificationStream<SimpleNotification> notificationStream(*face,
64 "/localhost/nfd/NotificationStreamTest", keyChain);
65
66 SimpleNotification event1("msg1");
67 notificationStream.postNotification(event1);
68 face->processEvents();
69 BOOST_REQUIRE_EQUAL(face->m_sentDatas.size(), 1);
70 BOOST_CHECK_EQUAL(face->m_sentDatas[0].getName(),
71 "/localhost/nfd/NotificationStreamTest/%FE%00");
72 SimpleNotification decoded1;
73 BOOST_CHECK_NO_THROW(decoded1.wireDecode(face->m_sentDatas[0].getContent().blockFromValue()));
74 BOOST_CHECK_EQUAL(decoded1.getMessage(), "msg1");
75
76 SimpleNotification event2("msg2");
77 notificationStream.postNotification(event2);
78 face->processEvents();
79 BOOST_REQUIRE_EQUAL(face->m_sentDatas.size(), 2);
80 BOOST_CHECK_EQUAL(face->m_sentDatas[1].getName(),
81 "/localhost/nfd/NotificationStreamTest/%FE%01");
82 SimpleNotification decoded2;
83 BOOST_CHECK_NO_THROW(decoded2.wireDecode(face->m_sentDatas[1].getContent().blockFromValue()));
84 BOOST_CHECK_EQUAL(decoded2.getMessage(), "msg2");
85}
86
87BOOST_AUTO_TEST_SUITE_END()
88
89} // namespace tests
90} // namespace ndn