]> git.vomp.tv Git - vompclient.git/blob - vconnect.cc
*** empty log message ***
[vompclient.git] / vconnect.cc
1 /*
2     Copyright 2004-2005 Chris Tallon
3
4     This file is part of VOMP.
5
6     VOMP is free software; you can redistribute it and/or modify
7     it under the terms of the GNU General Public License as published by
8     the Free Software Foundation; either version 2 of the License, or
9     (at your option) any later version.
10
11     VOMP is distributed in the hope that it will be useful,
12     but WITHOUT ANY WARRANTY; without even the implied warranty of
13     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14     GNU General Public License for more details.
15
16     You should have received a copy of the GNU General Public License
17     along with VOMP; if not, write to the Free Software
18     Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.
19 */
20
21 #include "vconnect.h"
22
23 #include "video.h"
24 #include "colour.h"
25 #include "command.h"
26 #include "i18n.h"
27 #include "boxstack.h"
28 #include "message.h"
29 #include "log.h"
30 #include "wol.h"
31 #include "vserverselect.h"
32
33 VConnect::VConnect(char* tServer)
34 {
35   boxstack = BoxStack::getInstance();
36   vdr = VDR::getInstance();
37   logger = Log::getInstance();
38
39   setSize(400, 200);
40   createBuffer();
41   if (Video::getInstance()->getFormat() == Video::PAL)
42   {
43     setPosition(170, 200);
44   }
45   else
46   {
47     setPosition(160, 150);
48   }
49
50   exitable = 0;
51   irun = 0;
52   server = tServer;
53 }
54
55 VConnect::~VConnect()
56 {
57   irun = 0;
58   vdr->cancelFindingServer();
59   threadStop();
60 }
61
62 void VConnect::draw()
63 {
64   VInfo::draw();
65   logger->log("VConnect", Log::DEBUG, "Draw done");
66 }
67
68 int VConnect::handleCommand(int command)
69 {
70   return 1;
71 }
72
73 void VConnect::run()
74 {
75   threadStart();
76 }
77
78 void VConnect::threadMethod()
79 {
80   ULONG delay = 0;
81   int success;
82   irun = 1;
83
84   do
85   {
86     if (server) // Server is specified, fake a servers array
87     {
88       VDRServer vdrserver;
89       vdrserver.ip = new char[strlen(server)+1];
90       strcpy(vdrserver.ip, server);
91       vdrserver.name = new char[1];
92       vdrserver.name[0] = '\0';
93       servers.push_back(vdrserver);
94     }
95     else
96     {
97       setOneLiner(tr("Locating server"));
98       draw();
99       boxstack->update(this);
100
101       vdr->findServers(servers);
102       if (!irun)
103       {
104         for(UINT k = 0; k < servers.size(); k++)
105         {
106           delete[] servers[k].ip;
107           delete[] servers[k].name;
108         }
109         servers.clear();
110         return;
111       }
112     }
113
114     if (servers.size() == 1)
115     {
116       selectedServer = 0;
117     }
118     else
119     {
120       selectedServer = -1;
121       VServerSelect* vs = new VServerSelect(servers, this);
122       vs->draw();
123       boxstack->add(vs);
124       boxstack->update(vs);
125
126       threadLock();
127       threadWaitForSignal();
128       threadUnlock();
129     }
130
131     if (!irun)
132     {
133       for(UINT k = 0; k < servers.size(); k++)
134       {
135         delete[] servers[k].ip;
136         delete[] servers[k].name;
137       }
138       servers.clear();
139       return;
140     }
141
142     logger->log("VConnect", Log::NOTICE, "Connecting to server at %s", servers[selectedServer].ip);
143     Wol::getInstance()->setWakeUpIP(servers[selectedServer].ip);
144     vdr->setServerIP(servers[selectedServer].ip);
145
146     // Clear the serverIPs vector
147     for(UINT k = 0; k < servers.size(); k++)
148     {
149       delete[] servers[k].ip;
150       delete[] servers[k].name;
151     }
152     servers.clear();
153
154     setOneLiner(tr("Connecting to VDR"));
155     draw();
156     boxstack->update(this);
157
158     success = vdr->connect();
159     if (success)
160     {
161       logger->log("Command", Log::DEBUG, "Connected ok, doing login");
162       success = vdr->doLogin();
163
164       if (!success)
165       {
166         vdr->disconnect();
167         setOneLiner(tr("Login failed"));
168         delay = 3000;
169       }
170     }
171     else
172     {
173       setOneLiner(tr("Connection failed"));
174       delay = 3000;
175     }
176
177     draw();
178     boxstack->update(this);
179     MILLISLEEP(delay);
180
181   } while(!success);
182
183   Message* m = new Message(); // Must be done after this thread ends
184   m->from = this;
185   m->to = Command::getInstance();
186   m->message = Message::VDR_CONNECTED;
187   Command::getInstance()->postMessage(m);
188 }
189
190 void VConnect::processMessage(Message* m)
191 {
192   if (m->message == Message::SERVER_SELECTED)
193   {
194     selectedServer = m->parameter;
195     threadSignal();
196   }
197 }