PSKlient.cpp 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403
  1. #include "PSKlient.h"
  2. // Inhalt der PSKlient Klasse aus PSKlient.h
  3. // Konstruktor
  4. PSKlient::PSKlient( const char *ip, int port )
  5. : LTSKlient( ip, port )
  6. {}
  7. // Destruktor
  8. PSKlient::~PSKlient()
  9. {}
  10. // nicht constant
  11. bool PSKlient::getDateiListe( int *systemAnzahl, Array< int > *dateiAnzahl, RCArray< Text > *systeme, RCArray< RCArray< Text > > *dateien )
  12. {
  13. if( !verbunden )
  14. verbinden();
  15. if( !verbunden )
  16. return 0;
  17. lock();
  18. k->sende( "\xB", 1 );
  19. unsigned char res = 0;
  20. k->getNachricht( (char *)& res, 1 );
  21. if( res == 3 )
  22. {
  23. k->getNachricht( (char *)& res, 1 );
  24. char *txt = new char[ res + 1 ];
  25. k->getNachricht( txt, res );
  26. txt[ res ] = 0;
  27. fehler->setText( "Fehler während GetDateiListe bei PatchServer.\nServer Rückgabe:" );
  28. fehler->append( txt );
  29. delete[] txt;
  30. unlock();
  31. return 0;
  32. }
  33. *systemAnzahl = 0;
  34. int län = 0;
  35. k->getNachricht( (char *)& län, 4 );
  36. while( län )
  37. { // System Sleife
  38. char *txt = new char[ län + 1 ];
  39. txt[ län ] = 0;
  40. k->getNachricht( txt, län );
  41. systeme->set( new Text( txt ), *systemAnzahl );
  42. delete[] txt;
  43. dateien->set( new RCArray< Text >(), *systemAnzahl );
  44. int dAnzahl = 0;
  45. k->getNachricht( (char *)& län, 4 );
  46. while( län )
  47. { // Datei Schleife
  48. char *txt = new char[ län + 1 ];
  49. txt[ län ] = 0;
  50. k->getNachricht( txt, län );
  51. dateien->z( *systemAnzahl )->set( new Text( txt ), dAnzahl );
  52. delete[] txt;
  53. dAnzahl++;
  54. k->getNachricht( (char *)& län, 4 );
  55. }
  56. dateiAnzahl->set( dAnzahl, *systemAnzahl );
  57. ( *systemAnzahl )++;
  58. k->getNachricht( (char *)& län, 4 );
  59. }
  60. unlock();
  61. return 1;
  62. }
  63. bool PSKlient::updateFertig()
  64. {
  65. if( !verbunden )
  66. verbinden();
  67. if( !verbunden )
  68. return 0;
  69. lock();
  70. k->sende( "\xC", 1 );
  71. unsigned char res = 0;
  72. k->getNachricht( (char *)& res, 1 );
  73. if( res == 3 )
  74. {
  75. k->getNachricht( (char *)& res, 1 );
  76. char *txt = new char[ res + 1 ];
  77. k->getNachricht( txt, res );
  78. txt[ res ] = 0;
  79. fehler->setText( "Fehler während UpdateFertig bei PatchServer.\nServer Rückgabe:" );
  80. fehler->append( txt );
  81. delete[] txt;
  82. unlock();
  83. return 0;
  84. }
  85. unlock();
  86. return 1;
  87. }
  88. bool PSKlient::updateStarten( int dateiGruppeId )
  89. {
  90. if( !verbunden )
  91. verbinden();
  92. if( !verbunden )
  93. return 0;
  94. lock();
  95. k->sende( "\xD", 1 );
  96. unsigned char res = 0;
  97. k->getNachricht( (char *)& res, 1 );
  98. if( res == 3 )
  99. {
  100. k->getNachricht( (char *)& res, 1 );
  101. char *txt = new char[ res + 1 ];
  102. k->getNachricht( txt, res );
  103. txt[ res ] = 0;
  104. fehler->setText( "Fehler während UpdateStarten bei PatchServer.\nServer Rückgabe:" );
  105. fehler->append( txt );
  106. delete[] txt;
  107. unlock();
  108. return 0;
  109. }
  110. k->sende( (char *)& dateiGruppeId, 4 );
  111. k->getNachricht( (char *)& res, 1 );
  112. if( res == 3 )
  113. {
  114. k->getNachricht( (char *)& res, 1 );
  115. char *txt = new char[ res + 1 ];
  116. k->getNachricht( txt, res );
  117. txt[ res ] = 0;
  118. fehler->setText( "Fehler während UpdateStarten bei PatchServer.\nServer Rückgabe:" );
  119. fehler->append( txt );
  120. delete[] txt;
  121. unlock();
  122. return 0;
  123. }
  124. unlock();
  125. return 1;
  126. }
  127. bool PSKlient::getFileGroupInfoList( Array< FileGroupInfo * > *list )
  128. {
  129. if( !verbunden )
  130. verbinden();
  131. if( !verbunden )
  132. return 0;
  133. lock();
  134. k->sende( "\x10", 1 );
  135. unsigned char res = 0;
  136. k->getNachricht( (char *)& res, 1 );
  137. if( res == 1 )
  138. {
  139. int anz = 0;
  140. k->getNachricht( (char *)& anz, 4 );
  141. for( int i = 0; i < anz; i++ )
  142. {
  143. FileGroupInfo *info = new FileGroupInfo();
  144. k->getNachricht( (char *)& info->id, 4 );
  145. unsigned char len = 0;
  146. k->getNachricht( (char *)& len, 1 );
  147. info->name.fillText( ' ', len );
  148. k->getNachricht( info->name, len );
  149. k->getNachricht( (char *)& len, 1 );
  150. info->status.fillText( ' ', len );
  151. k->getNachricht( info->status, len );
  152. unsigned short l = 0;
  153. k->getNachricht( (char *)& l, 2 );
  154. info->path.fillText( ' ', l );
  155. k->getNachricht( info->path, l );
  156. k->getNachricht( (char *)& info->version, 4 );
  157. list->add( info );
  158. }
  159. }
  160. if( res == 3 )
  161. {
  162. k->getNachricht( (char *)& res, 1 );
  163. char *txt = new char[ res + 1 ];
  164. k->getNachricht( txt, res );
  165. txt[ res ] = 0;
  166. fehler->setText( "Fehler während getFileGroupInfoList bei PatchServer.\nServer Rückgabe:" );
  167. fehler->append( txt );
  168. delete[] txt;
  169. unlock();
  170. return 0;
  171. }
  172. unlock();
  173. return 1;
  174. }
  175. bool PSKlient::getSystemInfoList( RCArray< ReferenceCounting< std::pair< int, Text > > > *list )
  176. {
  177. if( !verbunden )
  178. verbinden();
  179. if( !verbunden )
  180. return 0;
  181. lock();
  182. k->sende( "\x11", 1 );
  183. unsigned char res = 0;
  184. k->getNachricht( (char *)& res, 1 );
  185. if( res == 1 )
  186. {
  187. int anz = 0;
  188. k->getNachricht( (char *)& anz, 4 );
  189. for( int i = 0; i < anz; i++ )
  190. {
  191. ReferenceCounting< std::pair< int, Text > > *obj = new ReferenceCounting< std::pair< int, Text > >();
  192. k->getNachricht( (char *)& obj->first, 4 );
  193. unsigned char len = 0;
  194. k->getNachricht( (char *)& len, 1 );
  195. obj->second.fillText( ' ', len );
  196. k->getNachricht( obj->second, len );
  197. list->add( obj );
  198. }
  199. }
  200. if( res == 3 )
  201. {
  202. k->getNachricht( (char *)& res, 1 );
  203. char *txt = new char[ res + 1 ];
  204. k->getNachricht( txt, res );
  205. txt[ res ] = 0;
  206. fehler->setText( "Fehler während getSystemInfoList bei PatchServer.\nServer Rückgabe:" );
  207. fehler->append( txt );
  208. delete[] txt;
  209. unlock();
  210. return 0;
  211. }
  212. unlock();
  213. return 1;
  214. }
  215. bool PSKlient::getFileInfoList( int system, int group, RCArray< ReferenceCounting< FileInfo > > *list )
  216. {
  217. if( !verbunden )
  218. verbinden();
  219. if( !verbunden )
  220. return 0;
  221. lock();
  222. k->sende( "\x12", 1 );
  223. unsigned char res = 0;
  224. k->getNachricht( (char *)& res, 1 );
  225. if( res == 1 )
  226. {
  227. k->sende( (char *)& system, 4 );
  228. k->sende( (char *)& group, 4 );
  229. int anz = 0;
  230. k->getNachricht( (char *)& anz, 4 );
  231. for( int i = 0; i < anz; i++ )
  232. {
  233. ReferenceCounting< FileInfo > *obj = new ReferenceCounting< FileInfo >();
  234. k->getNachricht( (char *)& obj->id, 4 );
  235. unsigned short len = 0;
  236. k->getNachricht( (char *)& len, 2 );
  237. obj->path.fillText( ' ', len );
  238. k->getNachricht( obj->path, len );
  239. k->getNachricht( (char *)& obj->version, 4 );
  240. unsigned char l = 0;
  241. k->getNachricht( (char *)& l, 1 );
  242. obj->time.fillText( ' ', l );
  243. k->getNachricht( obj->time, l );
  244. list->add( obj );
  245. }
  246. }
  247. if( res == 3 )
  248. {
  249. k->getNachricht( (char *)& res, 1 );
  250. char *txt = new char[ res + 1 ];
  251. k->getNachricht( txt, res );
  252. txt[ res ] = 0;
  253. fehler->setText( "Fehler während getSystemInfoList bei PatchServer.\nServer Rückgabe:" );
  254. fehler->append( txt );
  255. delete[] txt;
  256. unlock();
  257. return 0;
  258. }
  259. unlock();
  260. return 1;
  261. }
  262. bool PSKlient::getFileVersion( char *path, int system, int group, int *version )
  263. {
  264. if( !verbunden )
  265. verbinden();
  266. if( !verbunden )
  267. return 0;
  268. lock();
  269. k->sende( "\x13", 1 );
  270. unsigned char res = 0;
  271. k->getNachricht( (char *)& res, 1 );
  272. if( res == 1 )
  273. {
  274. unsigned short len = textLength( path );
  275. k->sende( (char *)& len, 2 );
  276. k->sende( path, len );
  277. k->sende( (char *)& group, 4 );
  278. k->sende( (char *)& system, 4 );
  279. k->getNachricht( (char *)version, 4 );
  280. }
  281. if( res == 3 )
  282. {
  283. k->getNachricht( (char *)& res, 1 );
  284. char *txt = new char[ res + 1 ];
  285. k->getNachricht( txt, res );
  286. txt[ res ] = 0;
  287. fehler->setText( "Fehler während getSystemInfoList bei PatchServer.\nServer Rückgabe:" );
  288. fehler->append( txt );
  289. delete[] txt;
  290. unlock();
  291. return 0;
  292. }
  293. unlock();
  294. return 1;
  295. }
  296. bool PSKlient::updateFile( const char *pfad, Zeit *zLetzteÄnderung, int system, int gruppe )
  297. {
  298. if( !verbunden )
  299. verbinden();
  300. if( !verbunden )
  301. return 0;
  302. lock();
  303. k->sende( "\x14", 1 );
  304. unsigned char res = 0;
  305. k->getNachricht( (char *)& res, 1 );
  306. if( res == 1 )
  307. {
  308. unsigned short len = textLength( pfad );
  309. k->sende( (char *)& len, 2 );
  310. k->sende( pfad, len );
  311. if( zLetzteÄnderung )
  312. {
  313. Text *time = zLetzteÄnderung->getZeit( "y-m-d h:i:s" );
  314. unsigned char l = (unsigned char)time->getLength();
  315. k->sende( (char *)& l, 1 );
  316. k->sende( time->getText(), l );
  317. time->release();
  318. }
  319. else
  320. k->sende( (char *)"\x0", 1 );
  321. k->sende( (char *)& system, 4 );
  322. k->sende( (char *)& gruppe, 4 );
  323. k->getNachricht( (char *)& res, 1 );
  324. }
  325. if( res == 3 )
  326. {
  327. k->getNachricht( (char *)& res, 1 );
  328. char *txt = new char[ res + 1 ];
  329. k->getNachricht( txt, res );
  330. txt[ res ] = 0;
  331. fehler->setText( "Fehler während getSystemInfoList bei PatchServer.\nServer Rückgabe:" );
  332. fehler->append( txt );
  333. delete[] txt;
  334. unlock();
  335. return 0;
  336. }
  337. unlock();
  338. return 1;
  339. }
  340. bool PSKlient::dateiGruppeUpdate( int gruppe )
  341. {
  342. if( !verbunden )
  343. verbinden();
  344. if( !verbunden )
  345. return 0;
  346. lock();
  347. k->sende( "\x15", 1 );
  348. unsigned char res = 0;
  349. k->getNachricht( (char *)& res, 1 );
  350. if( res == 1 )
  351. {
  352. k->sende( (char *)& gruppe, 4 );
  353. k->getNachricht( (char *)& res, 1 );
  354. }
  355. if( res == 3 )
  356. {
  357. k->getNachricht( (char *)& res, 1 );
  358. char *txt = new char[ res + 1 ];
  359. k->getNachricht( txt, res );
  360. txt[ res ] = 0;
  361. fehler->setText( "Fehler während getSystemInfoList bei PatchServer.\nServer Rückgabe:" );
  362. fehler->append( txt );
  363. delete[] txt;
  364. unlock();
  365. return 0;
  366. }
  367. unlock();
  368. return 1;
  369. }
  370. void PSKlient::abbruch()
  371. {
  372. if( verbunden )
  373. k->trenne();
  374. eingeloggt = 0;
  375. verbunden = 0;
  376. }
  377. // Reference Counting
  378. LTSKlient *PSKlient::getThis()
  379. {
  380. ref++;
  381. return this;
  382. }
  383. LTSKlient *PSKlient::release()
  384. {
  385. ref--;
  386. if( !ref )
  387. delete this;
  388. return 0;
  389. }