Blinker

1) /* Blinker

2)    Copyright 2011-2014 Stefan Schuermans <stefan@blinkenarea.org>

3)    Copyleft GNU public license - http://www.gnu.org/copyleft/gpl.html
4)    a blinkenarea.org project */
5) 
6) #include <iostream>
7) #include <string>
8) 

9) #include "CallMgr.h"

10) #include "Directory.h"
11) #include "File.h"
12) #include "Mgrs.h"
13) #include "Module.h"
14) #include "OpConn.h"
15) #include "OpConnIf.h"
16) #include "OpMgr.h"
17) #include "OpPrinter.h"
18) #include "OpReqIf.h"

19) #include "Time.h"
20) #include "TimeCallee.h"

21) 
22) namespace Blinker {
23) 
24) /**
25)  * @brief constructor

26)  * @param[in] name module name

27)  * @param[in] mgrs managers
28)  * @param[in] dirBase base directory
29)  */

30) OpPrinter::OpPrinter(const std::string &name, Mgrs &mgrs,
31)                      const Directory &dirBase):
32)   Module(name, mgrs, dirBase)

33) {

34)   // open operator connection interface

35)   m_mgrs.m_opMgr.open(m_name, this);

36) }
37) 
38) /// virtual destructor
39) OpPrinter::~OpPrinter()
40) {

41)   // close operator connection interface

42)   m_mgrs.m_opMgr.close(m_name);

43) 
44)   // close open operator connections
45)   while (!m_opConns.empty()) {
46)     OpConns::iterator itOpConn = m_opConns.begin();
47)     (*itOpConn)->close();
48)     m_opConns.erase(itOpConn);
49)   }

50) }
51) 
52) /// check for update of configuration
53) void OpPrinter::updateConfig()
54) {
55)   // nothing to do here for this module
56) }
57) 

58) /// callback when requested time reached
59) void OpPrinter::timeCall()
60) {
61)   while (!m_sendPlay.empty()) {
62)     OpConns::iterator it = m_sendPlay.begin();
63)     (*it)->sendPlay("opprinter");
64)     m_sendPlay.erase(it);
65)   }
66) }
67) 

68) /**
69)  * @brief check if accepting new operator connction is possible
70)  * @param[in] name operator interface name
71)  * @return if accepting new connection is possible
72)  */
73) bool OpPrinter::acceptNewOpConn(const std::string &name)
74) {
75)   return true; // accept all connections
76)   (void)name; // unused
77) }
78) 
79) /**
80)  * @brief new operator connection
81)  * @param[in] name operator interface name
82)  * @param[in] pConn operator connection object

83)  *
84)  * The new connection may not yet be used for sending inside this callback.

85)  */
86) void OpPrinter::newOpConn(const std::string &name, OpConn *pConn)
87) {

88)   m_opConns.insert(pConn);

89)   std::cout << "new connection " << pConn << std::endl;

90)   m_sendPlay.insert(pConn); // schedule sending play command
91)   m_mgrs.m_callMgr.requestTimeCall(this, Time::now());

92)   (void)name; // unused
93) }
94) 

95) /**
96)  * @brief key command received on operator connection
97)  * @param[in] pConn operator connection object
98)  * @param[in] key key that was pressed
99)  */
100) void OpPrinter::opConnRecvKey(OpConn *pConn, char key)
101) {
102)   std::cout << "key \"" << key << "\" on connection " << pConn << std::endl;
103) 
104)   // reply to some keys with play command for sounds
105)   switch (key) {
106)     case '7': pConn->sendPlay("ueber_7_bruecken"); break;
107)     case '9': pConn->sendPlay("99_luftballons"); break;

108)     case '#':
109)       std::cout << "closing connection " << pConn << std::endl;
110)       pConn->close();
111)       m_opConns.erase(pConn);
112)       m_sendPlay.erase(pConn); // could be in there, better be on safe side
113)       break;

114)   }
115) }
116) 
117) /**
118)  * @brief play command received on operator connection
119)  * @param[in] pConn operator connection object
120)  * @param[in] sound name of sound to play
121)  */
122) void OpPrinter::opConnRecvPlay(OpConn *pConn, const std::string &sound)
123) {
124)   // this interface is usually not called for incoming connections
125)   std::cout << "play sound \"" << sound << "\" on connection " << pConn
126)             << std::endl;
127) }
128) 

129) /**
130)  * @brief operator connection is closed
131)  * @param[in] pConn operator connection object

132)  *
133)  * The connection may not be used for sending any more in this callback.

134)  */
135) void OpPrinter::opConnClose(OpConn *pConn)
136) {
137)   std::cout << "connection " << pConn << " closed" << std::endl;

138)   m_opConns.erase(pConn);

139)   m_sendPlay.erase(pConn); // could be in there, better be on safe side