ShopK.cpp 32 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150
  1. #include "../KSGKlient.h"
  2. #include "../KSGServer.h"
  3. #include <Datei.h>
  4. #include "../Keys.h"
  5. // Inhalt der ShopKlient Klasse aus KSGKtient.h
  6. // Konstruktor
  7. ShopKlient::ShopKlient()
  8. {
  9. verbunden = 0;
  10. klient = 0;
  11. fehler = new Text( "" );
  12. klientId = getKlientId();
  13. ref = 1;
  14. }
  15. // Destruktor
  16. ShopKlient::~ShopKlient()
  17. {
  18. cs.lock();
  19. if( klient )
  20. {
  21. char serverReturn = 0;
  22. if( verbunden )
  23. {
  24. klient->sendeEncrypted( "\4", 1 );
  25. klient->getNachrichtEncrypted( &serverReturn, 1 );
  26. if( serverReturn == 3 )
  27. {
  28. char län = 0;
  29. klient->getNachrichtEncrypted( &län, 1 );
  30. char *nachricht = new char[ län + 1 ];
  31. nachricht[ län ] = 0;
  32. klient->getNachrichtEncrypted( nachricht, län );
  33. delete[]nachricht;
  34. }
  35. klient->sendeEncrypted( "\3", 1 );
  36. klient->getNachrichtEncrypted( &serverReturn, 1 );
  37. klient->trenne();
  38. }
  39. else
  40. {
  41. int keyLen = 0;
  42. char *key = 0;
  43. Keys::getServerKey( &key, keyLen, Keys::SHOP, Keys::SENDEN );
  44. klient->setSendeKey( key, keyLen );
  45. delete[] key;
  46. Keys::getServerKey( &key, keyLen, Keys::SHOP, Keys::EMPFANGEN );
  47. klient->setEmpfangKey( key, keyLen );
  48. delete[] key;
  49. klient->verbinde( klient->getServerPort(), klient->getServerIp() );
  50. klient->sendeEncrypted( "\1", 1 );
  51. klient->sendeEncrypted( (char*)&klientId, 4 );
  52. klient->getNachrichtEncrypted( &serverReturn, 1 );
  53. if( serverReturn == 3 )
  54. {
  55. char län = 0;
  56. klient->getNachrichtEncrypted( &län, 1 );
  57. char *nachricht = new char[ län + 1 ];
  58. nachricht[ län ] = 0;
  59. klient->getNachrichtEncrypted( nachricht, län );
  60. delete[]nachricht;
  61. }
  62. else
  63. {
  64. char *sl = 0;
  65. char slLän = getSchlüssel( &sl );
  66. klient->setSendeKey( sl, slLän );
  67. klient->setEmpfangKey( sl, slLän );
  68. delete[] sl;
  69. klient->sendeEncrypted( "\4", 1 );
  70. klient->getNachrichtEncrypted( &serverReturn, 1 );
  71. if( serverReturn == 3 )
  72. {
  73. char län = 0;
  74. klient->getNachrichtEncrypted( &län, 1 );
  75. char *nachricht = new char[ län + 1 ];
  76. nachricht[ län ] = 0;
  77. klient->getNachrichtEncrypted( nachricht, län );
  78. delete[]nachricht;
  79. }
  80. }
  81. klient->sendeEncrypted( "\3", 1 );
  82. klient->getNachrichtEncrypted( &serverReturn, 1 );
  83. klient->trenne();
  84. }
  85. klient = klient->release();
  86. }
  87. fehler = fehler->release();
  88. cs.unlock();
  89. }
  90. // privat
  91. bool ShopKlient::verbinde( int port, char *ip ) // verbindet sich mit vorgegebenem Server
  92. {
  93. int keyLen = 0;
  94. char *key = 0;
  95. Keys::getServerKey( &key, keyLen, Keys::SHOP, Keys::SENDEN );
  96. klient->setSendeKey( key, keyLen );
  97. delete[] key;
  98. Keys::getServerKey( &key, keyLen, Keys::SHOP, Keys::EMPFANGEN );
  99. klient->setEmpfangKey( key, keyLen );
  100. delete[] key;
  101. if( klient->verbinde( port, ip ) )
  102. {
  103. if( klient->sendeEncrypted( "\1", 1 ) )
  104. {
  105. klient->sendeEncrypted( (char*)&klientId, 4 );
  106. char serverReturn = 0;
  107. klient->getNachrichtEncrypted( &serverReturn, 1 );
  108. if( serverReturn == 3 )
  109. {
  110. char byte = 0;
  111. klient->getNachrichtEncrypted( &byte, 1 );
  112. char *f = new char[ byte + 1 ];
  113. f[ byte ] = 0;
  114. klient->getNachrichtEncrypted( f, byte );
  115. fehler->setText( f );
  116. delete[]f;
  117. return 0;
  118. }
  119. char *sl = 0;
  120. char slLän = getSchlüssel( &sl );
  121. klient->setSendeKey( sl, slLän );
  122. klient->setEmpfangKey( sl, slLän );
  123. delete[] sl;
  124. return 1;
  125. }
  126. else
  127. {
  128. fehler->setText( "Der dir zugewiesene Shop Server hat die Verbindung abgebrochen. Bitte versuche es Später erneut." );
  129. klient = klient->release();
  130. }
  131. }
  132. else
  133. {
  134. fehler->setText( "Der dir zugewiesene Shop Server antwortet nicht. Bitte versuche es Später erneut." );
  135. klient = klient->release();
  136. }
  137. return 0;
  138. }
  139. // nicht constant
  140. bool ShopKlient::verbinde() // verbindet ich mit dem Shop Server
  141. {
  142. cs.lock();
  143. if( verbunden )
  144. {
  145. cs.unlock();
  146. return 1;
  147. }
  148. if( !klient )
  149. {
  150. char *msIp = getMainServerIp();
  151. unsigned short msPort = getMainServerPort();
  152. klient = new Klient();
  153. int keyLen = 0;
  154. char *key = 0;
  155. Keys::getServerKey( &key, keyLen, Keys::MAIN, Keys::SENDEN );
  156. klient->setSendeKey( key, keyLen );
  157. delete[] key;
  158. Keys::getServerKey( &key, keyLen, Keys::MAIN, Keys::EMPFANGEN );
  159. klient->setEmpfangKey( key, keyLen );
  160. delete[] key;
  161. if( !klient->verbinde( msPort, msIp ) )
  162. {
  163. fehler->setText( "Fehler beim verbinden mit dem Main Server. Bitte versuche es Später erneut." );
  164. klient = klient->release();
  165. delete[]msIp;
  166. cs.unlock();
  167. return 0;
  168. }
  169. delete[]msIp;
  170. klient->sende( "\0", 1 ); // Verschlüsselung aktivieren
  171. klient->sendeEncrypted( "\1", 1 );
  172. klient->sendeEncrypted( (char*)&klientId, 4 );
  173. char serverReturn = 0;
  174. klient->getNachrichtEncrypted( &serverReturn, 1 );
  175. if( serverReturn == 3 )
  176. {
  177. char län = 0;
  178. klient->getNachrichtEncrypted( &län, 1 );
  179. char *nachricht = new char[ län + 1 ];
  180. nachricht[ län ] = 0;
  181. klient->getNachrichtEncrypted( nachricht, län );
  182. fehler->setText( nachricht );
  183. delete[]nachricht;
  184. klient->sendeEncrypted( "\3", 1 );
  185. klient->getNachrichtEncrypted( &serverReturn, 1 );
  186. klient->trenne();
  187. klient = klient->release();
  188. cs.unlock();
  189. return 0;
  190. }
  191. char *sl = 0;
  192. char slLän = getSchlüssel( &sl );
  193. klient->setSendeKey( sl, slLän );
  194. klient->setEmpfangKey( sl, slLän );
  195. delete[] sl;
  196. klient->sendeEncrypted( "\6\7", 2 );
  197. char byte = 0;
  198. klient->getNachrichtEncrypted( &byte, 1 );
  199. if( byte == 2 )
  200. {
  201. unsigned char lsIp[ 4 ];
  202. klient->getNachrichtEncrypted( (char *)lsIp, 4 );
  203. unsigned short lsPort = 0;
  204. klient->getNachrichtEncrypted( (char*)&lsPort, 2 );
  205. klient->sendeEncrypted( "\3", 1 );
  206. klient->getNachrichtEncrypted( &serverReturn, 1 );
  207. klient->trenne();
  208. Text *lsIpT = new Text( "" );
  209. lsIpT->append( (int)lsIp[ 0 ] );
  210. lsIpT->append( "." );
  211. lsIpT->append( (int)lsIp[ 1 ] );
  212. lsIpT->append( "." );
  213. lsIpT->append( (int)lsIp[ 2 ] );
  214. lsIpT->append( "." );
  215. lsIpT->append( (int)lsIp[ 3 ] );
  216. int keyLen = 0;
  217. char *key = 0;
  218. Keys::getServerKey( &key, keyLen, Keys::SHOP, Keys::SENDEN );
  219. klient->setSendeKey( key, keyLen );
  220. delete[] key;
  221. Keys::getServerKey( &key, keyLen, Keys::SHOP, Keys::EMPFANGEN );
  222. klient->setEmpfangKey( key, keyLen );
  223. delete[] key;
  224. klient->verbinde( lsPort, lsIpT->getText() );
  225. lsIpT = lsIpT->release();
  226. klient->sendeEncrypted( "\3", 1 );
  227. klient->getNachrichtEncrypted( &serverReturn, 1 );
  228. klient->trenne();
  229. }
  230. if( byte == 3 )
  231. {
  232. klient->getNachrichtEncrypted( &byte, 1 );
  233. char *f = new char[ byte + 1 ];
  234. f[ byte ] = 0;
  235. klient->getNachrichtEncrypted( f, byte );
  236. fehler->setText( f );
  237. delete[]f;
  238. klient->sendeEncrypted( "\3", 1 );
  239. klient->getNachrichtEncrypted( &serverReturn, 1 );
  240. klient->trenne();
  241. klient = klient->release();
  242. cs.unlock();
  243. return 0;
  244. }
  245. }
  246. int keyLen = 0;
  247. char *key = 0;
  248. Keys::getServerKey( &key, keyLen, Keys::SHOP, Keys::SENDEN );
  249. klient->setSendeKey( key, keyLen );
  250. delete[] key;
  251. Keys::getServerKey( &key, keyLen, Keys::SHOP, Keys::EMPFANGEN );
  252. klient->setEmpfangKey( key, keyLen );
  253. delete[] key;
  254. if( klient->verbinde( klient->getServerPort(), klient->getServerIp() ) )
  255. {
  256. if( klient->sendeEncrypted( "\1", 1 ) )
  257. {
  258. klient->sendeEncrypted( (char*)&klientId, 4 );
  259. char serverReturn = 0;
  260. klient->getNachrichtEncrypted( &serverReturn, 1 );
  261. if( serverReturn == 3 )
  262. {
  263. char byte = 0;
  264. klient->getNachrichtEncrypted( &byte, 1 );
  265. char *f = new char[ byte + 1 ];
  266. f[ byte ] = 0;
  267. klient->getNachrichtEncrypted( f, byte );
  268. fehler->setText( f );
  269. delete[]f;
  270. klient->sendeEncrypted( "\3", 1 );
  271. klient->getNachrichtEncrypted( &serverReturn, 1 );
  272. klient->trenne();
  273. cs.unlock();
  274. return 0;
  275. }
  276. char *sl = 0;
  277. char slLän = getSchlüssel( &sl );
  278. klient->setSendeKey( sl, slLän );
  279. klient->setEmpfangKey( sl, slLän );
  280. delete[] sl;
  281. verbunden = 1;
  282. cs.unlock();
  283. return 1;
  284. }
  285. else
  286. {
  287. fehler->setText( "Der dir zugewiesene Shop Server hat die Verbindung abgebrochen. Bitte versuche es Später erneut." );
  288. klient = klient->release();
  289. }
  290. }
  291. else
  292. {
  293. fehler->setText( "Der dir zugewiesene Shop Server antwortet nicht. Bitte versuche es Später erneut." );
  294. klient = klient->release();
  295. }
  296. cs.unlock();
  297. return 0;
  298. }
  299. Array< int > *ShopKlient::suchSpiele( const char *suche ) // sucht nach Spielen
  300. {
  301. char län = (char)textLength( suche );
  302. char ret = 0;
  303. cs.lock();
  304. if( !verbunden )
  305. verbinde();
  306. if( !verbunden )
  307. {
  308. cs.unlock();
  309. return 0;
  310. }
  311. klient->sendeEncrypted( "\5", 1 );
  312. klient->getNachrichtEncrypted( &ret, 1 );
  313. if( ret == 1 )
  314. {
  315. klient->sendeEncrypted( &län, 1 );
  316. if( län )
  317. klient->sendeEncrypted( suche, län );
  318. klient->getNachrichtEncrypted( &ret, 1 );
  319. if( ret == 1 )
  320. {
  321. int anz = 0;
  322. klient->getNachrichtEncrypted( (char*)&anz, 4 );
  323. Array< int > *ret = new Array< int >();
  324. for( int i = 0; i < anz; i++ )
  325. {
  326. int w = 0;
  327. klient->getNachrichtEncrypted( (char*)&w, 4 );
  328. ret->add( w );
  329. }
  330. cs.unlock();
  331. return ret;
  332. }
  333. }
  334. if( ret == 3 )
  335. {
  336. klient->getNachrichtEncrypted( &län, 1 );
  337. char *err = new char[ län + 1 ];
  338. err[ län ] = 0;
  339. if( län )
  340. klient->getNachrichtEncrypted( err, län );
  341. fehler->setText( err );
  342. delete[] err;
  343. }
  344. cs.unlock();
  345. return 0;
  346. }
  347. bool ShopKlient::ladeSpielTitel( int id ) // läd Titelbild des Spieles herunter
  348. {
  349. char ret = 0;
  350. cs.lock();
  351. if( !verbunden )
  352. verbinde();
  353. if( !verbunden )
  354. {
  355. cs.unlock();
  356. return 0;
  357. }
  358. klient->sendeEncrypted( "\6", 1 );
  359. klient->getNachrichtEncrypted( &ret, 1 );
  360. if( ret == 1 )
  361. {
  362. klient->sendeEncrypted( (char*)&id, 4 );
  363. klient->getNachrichtEncrypted( &ret, 1 );
  364. if( ret == 1 )
  365. {
  366. Text *pf = new Text( "data/tmp/shop/kaufen/spiele/" );
  367. pf->append( id );
  368. pf->append( "/titelbg.ltdb" );
  369. Datei *dat = new Datei();
  370. dat->setDatei( pf );
  371. dat->erstellen();
  372. dat->open( Datei::Style::schreiben );
  373. __int64 gr = 0;
  374. klient->getNachrichtEncrypted( (char*)&gr, 8 );
  375. char bytes[ 2048 ];
  376. while( gr > 0 )
  377. {
  378. int län = gr > 2048 ? 2048 : (int)gr;
  379. klient->getNachricht( bytes, län );
  380. dat->schreibe( bytes, län );
  381. gr -= län;
  382. }
  383. dat->close();
  384. dat->release();
  385. }
  386. if( ret == 2 )
  387. { // Verweis auf anderen ShopServer
  388. int port = 0;
  389. char län = 0;
  390. klient->getNachrichtEncrypted( (char*)&port, 4 );
  391. klient->getNachrichtEncrypted( &län, 1 );
  392. char *ip = new char[ län + 1 ];
  393. klient->getNachrichtEncrypted( ip, län );
  394. ip[ län ] = 0;
  395. klient->trenne();
  396. if( !verbinde( port, ip ) )
  397. {
  398. delete[] ip;
  399. trenne();
  400. cs.unlock();
  401. return 0;
  402. }
  403. delete[] ip;
  404. cs.unlock();
  405. return ladeSpielTitel( id );
  406. }
  407. }
  408. if( ret == 3 )
  409. {
  410. klient->getNachrichtEncrypted( &ret, 1 );
  411. char *err = new char[ ret + 1 ];
  412. err[ ret ] = 0;
  413. if( ret )
  414. klient->getNachrichtEncrypted( err, ret );
  415. fehler->setText( err );
  416. delete[] err;
  417. cs.unlock();
  418. return 0;
  419. }
  420. cs.unlock();
  421. return 1;
  422. }
  423. bool ShopKlient::ladeSpielSeite( int id ) // läd Seite des Spieles herunter
  424. {
  425. char ret = 0;
  426. cs.lock();
  427. if( !verbunden )
  428. verbinde();
  429. if( !verbunden )
  430. {
  431. cs.unlock();
  432. return 0;
  433. }
  434. klient->sendeEncrypted( "\7", 1 );
  435. klient->getNachrichtEncrypted( &ret, 1 );
  436. if( ret == 1 )
  437. {
  438. klient->sendeEncrypted( (char*)&id, 4 );
  439. klient->getNachrichtEncrypted( &ret, 1 );
  440. if( ret == 1 )
  441. {
  442. Text *pf = new Text( "data/tmp/shop/kaufen/spiele/" );
  443. pf->append( id );
  444. pf->append( "/" );
  445. int anz = 0;
  446. klient->getNachrichtEncrypted( (char*)&anz, 4 );
  447. for( int i = 0; i < anz; i++ )
  448. {
  449. char län = 0;
  450. klient->getNachrichtEncrypted( &län, 1 );
  451. char *name = new char[ län + 1 ];
  452. name[ län ] = 0;
  453. klient->getNachrichtEncrypted( name, län );
  454. Text *pfad = new Text( pf->getText() );
  455. pfad->append( name );
  456. delete[] name;
  457. Datei *d = new Datei();
  458. d->setDatei( pfad );
  459. d->erstellen();
  460. d->open( Datei::Style::schreiben );
  461. __int64 gr = 0;
  462. klient->getNachrichtEncrypted( (char*)&gr, 8 );
  463. char bytes[ 2048 ];
  464. while( gr > 0 )
  465. {
  466. int län = gr > 2048 ? 2048 : (int)gr;
  467. klient->getNachricht( bytes, län );
  468. d->schreibe( bytes, län );
  469. gr -= län;
  470. }
  471. d->close();
  472. d->release();
  473. }
  474. pf->release();
  475. }
  476. if( ret == 2 )
  477. { // Verweis auf anderen ShopServer
  478. int port = 0;
  479. char län = 0;
  480. klient->getNachrichtEncrypted( (char*)&port, 4 );
  481. klient->getNachrichtEncrypted( &län, 1 );
  482. char *ip = new char[ län + 1 ];
  483. klient->getNachrichtEncrypted( ip, län );
  484. ip[ län ] = 0;
  485. klient->trenne();
  486. if( !verbinde( port, ip ) )
  487. {
  488. delete[] ip;
  489. trenne();
  490. cs.unlock();
  491. return 0;
  492. }
  493. delete[] ip;
  494. cs.unlock();
  495. return ladeSpielSeite( id );
  496. }
  497. }
  498. if( ret == 3 )
  499. {
  500. klient->getNachrichtEncrypted( &ret, 1 );
  501. char *err = new char[ ret + 1 ];
  502. err[ ret ] = 0;
  503. if( ret )
  504. klient->getNachrichtEncrypted( err, ret );
  505. fehler->setText( err );
  506. delete[] err;
  507. cs.unlock();
  508. return 0;
  509. }
  510. cs.unlock();
  511. return 1;
  512. }
  513. int ShopKlient::getSpielBesitzStatus( int id ) // 0 = nicht im Besitz, 1 = Testversion, 2 = gekauft
  514. {
  515. char ret = 0;
  516. cs.lock();
  517. if( !verbunden )
  518. verbinde();
  519. if( !verbunden )
  520. {
  521. cs.unlock();
  522. return 0;
  523. }
  524. klient->sendeEncrypted( "\x8", 1 );
  525. klient->getNachrichtEncrypted( &ret, 1 );
  526. if( ret == 1 )
  527. {
  528. klient->sendeEncrypted( (char*)&id, 4 );
  529. int ret = 0;
  530. klient->getNachrichtEncrypted( (char*)&ret, 4 );
  531. cs.unlock();
  532. return ret;
  533. }
  534. if( ret == 3 )
  535. {
  536. klient->getNachrichtEncrypted( &ret, 1 );
  537. char *err = new char[ ret + 1 ];
  538. err[ ret ] = 0;
  539. if( ret )
  540. klient->getNachrichtEncrypted( err, ret );
  541. fehler->setText( err );
  542. delete[] err;
  543. }
  544. cs.unlock();
  545. return 0;
  546. }
  547. int ShopKlient::getSpielTestversion( int id ) // gibt die Anzahl der verbleibenden Spiele zurück
  548. {
  549. char ret = 0;
  550. cs.lock();
  551. if( !verbunden )
  552. verbinde();
  553. if( !verbunden )
  554. {
  555. cs.unlock();
  556. return 0;
  557. }
  558. klient->sendeEncrypted( "\x9", 1 );
  559. klient->getNachrichtEncrypted( &ret, 1 );
  560. if( ret == 1 )
  561. {
  562. klient->sendeEncrypted( (char*)&id, 4 );
  563. int ret = 0;
  564. klient->getNachrichtEncrypted( (char*)&ret, 4 );
  565. cs.unlock();
  566. return ret;
  567. }
  568. if( ret == 3 )
  569. {
  570. klient->getNachrichtEncrypted( &ret, 1 );
  571. char *err = new char[ ret + 1 ];
  572. err[ ret ] = 0;
  573. if( ret )
  574. klient->getNachrichtEncrypted( err, ret );
  575. fehler->setText( err );
  576. delete[] err;
  577. }
  578. cs.unlock();
  579. return 0;
  580. }
  581. int ShopKlient::istSpielErwerbbar( int id ) // prüft, ob das Spiel erworben werden kann
  582. {
  583. char ret = 0;
  584. cs.lock();
  585. if( !verbunden )
  586. verbinde();
  587. if( !verbunden )
  588. {
  589. cs.unlock();
  590. return 0;
  591. }
  592. klient->sendeEncrypted( "\xA", 1 );
  593. klient->getNachrichtEncrypted( &ret, 1 );
  594. if( ret == 1 )
  595. {
  596. klient->sendeEncrypted( (char*)&id, 4 );
  597. int ret = 0;
  598. klient->getNachrichtEncrypted( (char*)&ret, 4 );
  599. cs.unlock();
  600. return ret;
  601. }
  602. if( ret == 3 )
  603. {
  604. klient->getNachrichtEncrypted( &ret, 1 );
  605. char *err = new char[ ret + 1 ];
  606. err[ ret ] = 0;
  607. if( ret )
  608. klient->getNachrichtEncrypted( err, ret );
  609. fehler->setText( err );
  610. delete[] err;
  611. }
  612. cs.unlock();
  613. return 0;
  614. }
  615. int ShopKlient::getSpielPreis( int id, bool testVersion ) // gibt den Preis eines Spieles zurück
  616. {
  617. char ret = 0;
  618. cs.lock();
  619. if( !verbunden )
  620. verbinde();
  621. if( !verbunden )
  622. {
  623. cs.unlock();
  624. return 0;
  625. }
  626. klient->sendeEncrypted( "\xB", 1 );
  627. klient->getNachrichtEncrypted( &ret, 1 );
  628. if( ret == 1 )
  629. {
  630. klient->sendeEncrypted( (char*)&id, 4 );
  631. klient->sendeEncrypted( (char*)&testVersion, 1 );
  632. int ret = 0;
  633. klient->getNachrichtEncrypted( (char*)&ret, 4 );
  634. cs.unlock();
  635. return ret;
  636. }
  637. if( ret == 3 )
  638. {
  639. klient->getNachrichtEncrypted( &ret, 1 );
  640. char *err = new char[ ret + 1 ];
  641. err[ ret ] = 0;
  642. if( ret )
  643. klient->getNachrichtEncrypted( err, ret );
  644. fehler->setText( err );
  645. delete[] err;
  646. }
  647. cs.unlock();
  648. return 0;
  649. }
  650. bool ShopKlient::spielErwerben( int spielId, bool testVersion ) // Spiel kaufen
  651. {
  652. char ret = 0;
  653. cs.lock();
  654. if( !verbunden )
  655. verbinde();
  656. if( !verbunden )
  657. {
  658. cs.unlock();
  659. return 0;
  660. }
  661. klient->sendeEncrypted( "\xC", 1 );
  662. klient->getNachrichtEncrypted( &ret, 1 );
  663. if( ret == 1 )
  664. {
  665. klient->sendeEncrypted( (char*)&spielId, 4 );
  666. klient->sendeEncrypted( (char*)&testVersion, 1 );
  667. klient->getNachrichtEncrypted( &ret, 1 );
  668. if( ret == 1 )
  669. {
  670. cs.unlock();
  671. return 1;
  672. }
  673. }
  674. if( ret == 3 )
  675. {
  676. klient->getNachrichtEncrypted( &ret, 1 );
  677. char *err = new char[ ret + 1 ];
  678. err[ ret ] = 0;
  679. if( ret )
  680. klient->getNachrichtEncrypted( err, ret );
  681. fehler->setText( err );
  682. delete[] err;
  683. }
  684. cs.unlock();
  685. return 0;
  686. }
  687. Array< int > *ShopKlient::suchKarten( const char *suche, int spielId ) // sucht nach Karten
  688. {
  689. char län = (char)textLength( suche );
  690. char ret = 0;
  691. cs.lock();
  692. if( !verbunden )
  693. verbinde();
  694. if( !verbunden )
  695. {
  696. cs.unlock();
  697. return 0;
  698. }
  699. klient->sendeEncrypted( "\xD", 1 );
  700. klient->getNachrichtEncrypted( &ret, 1 );
  701. if( ret == 1 )
  702. {
  703. klient->sendeEncrypted( (char*)&spielId, 4 );
  704. klient->sendeEncrypted( &län, 1 );
  705. if( län )
  706. klient->sendeEncrypted( suche, län );
  707. klient->getNachrichtEncrypted( &ret, 1 );
  708. if( ret == 1 )
  709. {
  710. int anz = 0;
  711. klient->getNachrichtEncrypted( (char*)&anz, 4 );
  712. Array< int > *ret = new Array< int >();
  713. for( int i = 0; i < anz; i++ )
  714. {
  715. int w = 0;
  716. klient->getNachrichtEncrypted( (char*)&w, 4 );
  717. ret->add( w );
  718. }
  719. cs.unlock();
  720. return ret;
  721. }
  722. }
  723. if( ret == 3 )
  724. {
  725. klient->getNachrichtEncrypted( &län, 1 );
  726. char *err = new char[ län + 1 ];
  727. err[ län ] = 0;
  728. if( län )
  729. klient->getNachrichtEncrypted( err, län );
  730. fehler->setText( err );
  731. delete[] err;
  732. }
  733. cs.unlock();
  734. return 0;
  735. }
  736. bool ShopKlient::ladeKarteTitel( int id ) // läd Titelbild der Karte herunter
  737. {
  738. char ret = 0;
  739. cs.lock();
  740. if( !verbunden )
  741. verbinde();
  742. if( !verbunden )
  743. {
  744. cs.unlock();
  745. return 0;
  746. }
  747. klient->sendeEncrypted( "\xE", 1 );
  748. klient->getNachrichtEncrypted( &ret, 1 );
  749. if( ret == 1 )
  750. {
  751. klient->sendeEncrypted( (char*)&id, 4 );
  752. klient->getNachrichtEncrypted( &ret, 1 );
  753. if( ret == 1 )
  754. {
  755. Text *pf = new Text( "data/tmp/shop/kaufen/karten/" );
  756. pf->append( id );
  757. pf->append( "/titelbg.ltdb" );
  758. Datei *dat = new Datei();
  759. dat->setDatei( pf );
  760. dat->erstellen();
  761. dat->open( Datei::Style::schreiben );
  762. __int64 gr = 0;
  763. klient->getNachrichtEncrypted( (char*)&gr, 8 );
  764. char bytes[ 2048 ];
  765. while( gr > 0 )
  766. {
  767. int län = gr > 2048 ? 2048 : (int)gr;
  768. klient->getNachricht( bytes, län );
  769. dat->schreibe( bytes, län );
  770. gr -= län;
  771. }
  772. dat->close();
  773. dat->release();
  774. }
  775. if( ret == 2 )
  776. { // Verweis auf anderen ShopServer
  777. int port = 0;
  778. char län = 0;
  779. klient->getNachrichtEncrypted( (char*)&port, 4 );
  780. klient->getNachrichtEncrypted( &län, 1 );
  781. char *ip = new char[ län + 1 ];
  782. klient->getNachrichtEncrypted( ip, län );
  783. ip[ län ] = 0;
  784. klient->trenne();
  785. if( !verbinde( port, ip ) )
  786. {
  787. delete[] ip;
  788. trenne();
  789. cs.unlock();
  790. return 0;
  791. }
  792. delete[] ip;
  793. cs.unlock();
  794. return ladeKarteTitel( id );
  795. }
  796. }
  797. if( ret == 3 )
  798. {
  799. klient->getNachrichtEncrypted( &ret, 1 );
  800. char *err = new char[ ret + 1 ];
  801. err[ ret ] = 0;
  802. if( ret )
  803. klient->getNachrichtEncrypted( err, ret );
  804. fehler->setText( err );
  805. delete[] err;
  806. cs.unlock();
  807. return 0;
  808. }
  809. cs.unlock();
  810. return 1;
  811. }
  812. bool ShopKlient::ladeKarteSeite( int id ) // läd Seite der Karte herunter
  813. {
  814. char ret = 0;
  815. cs.lock();
  816. if( !verbunden )
  817. verbinde();
  818. if( !verbunden )
  819. {
  820. cs.unlock();
  821. return 0;
  822. }
  823. klient->sendeEncrypted( "\xF", 1 );
  824. klient->getNachrichtEncrypted( &ret, 1 );
  825. if( ret == 1 )
  826. {
  827. klient->sendeEncrypted( (char*)&id, 4 );
  828. klient->getNachrichtEncrypted( &ret, 1 );
  829. if( ret == 1 )
  830. {
  831. Text *pf = new Text( "data/tmp/shop/kaufen/karten/" );
  832. pf->append( id );
  833. pf->append( "/" );
  834. int anz = 0;
  835. klient->getNachrichtEncrypted( (char*)&anz, 4 );
  836. for( int i = 0; i < anz; i++ )
  837. {
  838. char län = 0;
  839. klient->getNachrichtEncrypted( &län, 1 );
  840. char *name = new char[ län + 1 ];
  841. name[ län ] = 0;
  842. klient->getNachrichtEncrypted( name, län );
  843. Text *pfad = new Text( pf->getText() );
  844. pfad->append( name );
  845. delete[] name;
  846. Datei *d = new Datei();
  847. d->setDatei( pfad );
  848. d->erstellen();
  849. d->open( Datei::Style::schreiben );
  850. __int64 gr = 0;
  851. klient->getNachrichtEncrypted( (char*)&gr, 8 );
  852. char bytes[ 2048 ];
  853. while( gr > 0 )
  854. {
  855. int län = gr > 2048 ? 2048 : (int)gr;
  856. klient->getNachricht( bytes, län );
  857. d->schreibe( bytes, län );
  858. gr -= län;
  859. }
  860. d->close();
  861. d->release();
  862. }
  863. pf->release();
  864. }
  865. if( ret == 2 )
  866. { // Verweis auf anderen ShopServer
  867. int port = 0;
  868. char län = 0;
  869. klient->getNachrichtEncrypted( (char*)&port, 4 );
  870. klient->getNachrichtEncrypted( &län, 1 );
  871. char *ip = new char[ län + 1 ];
  872. klient->getNachrichtEncrypted( ip, län );
  873. ip[ län ] = 0;
  874. klient->trenne();
  875. if( !verbinde( port, ip ) )
  876. {
  877. delete[] ip;
  878. trenne();
  879. cs.unlock();
  880. return 0;
  881. }
  882. delete[] ip;
  883. cs.unlock();
  884. return ladeKarteSeite( id );
  885. }
  886. }
  887. if( ret == 3 )
  888. {
  889. klient->getNachrichtEncrypted( &ret, 1 );
  890. char *err = new char[ ret + 1 ];
  891. err[ ret ] = 0;
  892. if( ret )
  893. klient->getNachrichtEncrypted( err, ret );
  894. fehler->setText( err );
  895. delete[] err;
  896. cs.unlock();
  897. return 0;
  898. }
  899. cs.unlock();
  900. return 1;
  901. }
  902. int ShopKlient::getKarteBesitzStatus( int id ) // 0 = nicht im Besitz, 1 = Testversion, 2 = gekauft
  903. {
  904. char ret = 0;
  905. cs.lock();
  906. if( !verbunden )
  907. verbinde();
  908. if( !verbunden )
  909. {
  910. cs.unlock();
  911. return 0;
  912. }
  913. klient->sendeEncrypted( "\x10", 1 );
  914. klient->getNachrichtEncrypted( &ret, 1 );
  915. if( ret == 1 )
  916. {
  917. klient->sendeEncrypted( (char*)&id, 4 );
  918. int ret = 0;
  919. klient->getNachrichtEncrypted( (char*)&ret, 4 );
  920. cs.unlock();
  921. return ret;
  922. }
  923. if( ret == 3 )
  924. {
  925. klient->getNachrichtEncrypted( &ret, 1 );
  926. char *err = new char[ ret + 1 ];
  927. err[ ret ] = 0;
  928. if( ret )
  929. klient->getNachrichtEncrypted( err, ret );
  930. fehler->setText( err );
  931. delete[] err;
  932. }
  933. cs.unlock();
  934. return 0;
  935. }
  936. int ShopKlient::getKarteTestversion( int id ) // gibt die Anzahl der verbleibenden Spiele zurück
  937. {
  938. char ret = 0;
  939. cs.lock();
  940. if( !verbunden )
  941. verbinde();
  942. if( !verbunden )
  943. {
  944. cs.unlock();
  945. return 0;
  946. }
  947. klient->sendeEncrypted( "\x11", 1 );
  948. klient->getNachrichtEncrypted( &ret, 1 );
  949. if( ret == 1 )
  950. {
  951. klient->sendeEncrypted( (char*)&id, 4 );
  952. int ret = 0;
  953. klient->getNachrichtEncrypted( (char*)&ret, 4 );
  954. cs.unlock();
  955. return ret;
  956. }
  957. if( ret == 3 )
  958. {
  959. klient->getNachrichtEncrypted( &ret, 1 );
  960. char *err = new char[ ret + 1 ];
  961. err[ ret ] = 0;
  962. if( ret )
  963. klient->getNachrichtEncrypted( err, ret );
  964. fehler->setText( err );
  965. delete[] err;
  966. }
  967. cs.unlock();
  968. return 0;
  969. }
  970. int ShopKlient::istKarteErwerbbar( int id ) // prüft, ob die Karte erworben werden kann
  971. {
  972. char ret = 0;
  973. cs.lock();
  974. if( !verbunden )
  975. verbinde();
  976. if( !verbunden )
  977. {
  978. cs.unlock();
  979. return 0;
  980. }
  981. klient->sendeEncrypted( "\x12", 1 );
  982. klient->getNachrichtEncrypted( &ret, 1 );
  983. if( ret == 1 )
  984. {
  985. klient->sendeEncrypted( (char*)&id, 4 );
  986. int ret = 0;
  987. klient->getNachrichtEncrypted( (char*)&ret, 4 );
  988. cs.unlock();
  989. return ret;
  990. }
  991. if( ret == 3 )
  992. {
  993. klient->getNachrichtEncrypted( &ret, 1 );
  994. char *err = new char[ ret + 1 ];
  995. err[ ret ] = 0;
  996. if( ret )
  997. klient->getNachrichtEncrypted( err, ret );
  998. fehler->setText( err );
  999. delete[] err;
  1000. }
  1001. cs.unlock();
  1002. return 0;
  1003. }
  1004. int ShopKlient::getKartePreis( int id, bool testVersion ) // gibt den Preis einer Karte zurück
  1005. {
  1006. char ret = 0;
  1007. cs.lock();
  1008. if( !verbunden )
  1009. verbinde();
  1010. if( !verbunden )
  1011. {
  1012. cs.unlock();
  1013. return 0;
  1014. }
  1015. klient->sendeEncrypted( "\x13", 1 );
  1016. klient->getNachrichtEncrypted( &ret, 1 );
  1017. if( ret == 1 )
  1018. {
  1019. klient->sendeEncrypted( (char*)&id, 4 );
  1020. klient->sendeEncrypted( (char*)&testVersion, 1 );
  1021. int ret = 0;
  1022. klient->getNachrichtEncrypted( (char*)&ret, 4 );
  1023. cs.unlock();
  1024. return ret;
  1025. }
  1026. if( ret == 3 )
  1027. {
  1028. klient->getNachrichtEncrypted( &ret, 1 );
  1029. char *err = new char[ ret + 1 ];
  1030. err[ ret ] = 0;
  1031. if( ret )
  1032. klient->getNachrichtEncrypted( err, ret );
  1033. fehler->setText( err );
  1034. delete[] err;
  1035. }
  1036. cs.unlock();
  1037. return 0;
  1038. }
  1039. bool ShopKlient::karteErwerben( int karteId, bool testVersion ) // Karte kaufen
  1040. {
  1041. char ret = 0;
  1042. cs.lock();
  1043. if( !verbunden )
  1044. verbinde();
  1045. if( !verbunden )
  1046. {
  1047. cs.unlock();
  1048. return 0;
  1049. }
  1050. klient->sendeEncrypted( "\x14", 1 );
  1051. klient->getNachrichtEncrypted( &ret, 1 );
  1052. if( ret == 1 )
  1053. {
  1054. klient->sendeEncrypted( (char*)&karteId, 4 );
  1055. klient->sendeEncrypted( (char*)&testVersion, 1 );
  1056. klient->getNachrichtEncrypted( &ret, 1 );
  1057. if( ret == 1 )
  1058. {
  1059. cs.unlock();
  1060. return 1;
  1061. }
  1062. }
  1063. if( ret == 3 )
  1064. {
  1065. klient->getNachrichtEncrypted( &ret, 1 );
  1066. char *err = new char[ ret + 1 ];
  1067. err[ ret ] = 0;
  1068. if( ret )
  1069. klient->getNachrichtEncrypted( err, ret );
  1070. fehler->setText( err );
  1071. delete[] err;
  1072. }
  1073. cs.unlock();
  1074. return 0;
  1075. }
  1076. bool ShopKlient::keepAlive() // Erhält die Verbindung aufrecht
  1077. {
  1078. if( !verbunden )
  1079. return 0;
  1080. char res = 0;
  1081. if( !cs.tryLock() )
  1082. return 1;
  1083. klient->sendeEncrypted( "\x15", 1 );
  1084. klient->getNachrichtEncrypted( &res, 1 );
  1085. cs.unlock();
  1086. if( res != 1 )
  1087. trenne();
  1088. return res == 1;
  1089. }
  1090. bool ShopKlient::trenne() // trennt sich von dem Shop Server
  1091. {
  1092. if( !verbunden )
  1093. return 1;
  1094. cs.lock();
  1095. klient->sendeEncrypted( "\3", 1 );
  1096. char serverReturn = 0;
  1097. klient->getNachrichtEncrypted( &serverReturn, 1 );
  1098. klient->trenne();
  1099. verbunden = 0;
  1100. cs.unlock();
  1101. return 1;
  1102. }
  1103. // constant
  1104. bool ShopKlient::istVerbunden() const // prüft, ob mit Shop Server verbunden
  1105. {
  1106. return verbunden;
  1107. }
  1108. char *ShopKlient::getLetzterFehler() const // gibt den Letzten Fehlertext zuück
  1109. {
  1110. return fehler->getText();
  1111. }
  1112. // Reference Counting
  1113. ShopKlient *ShopKlient::getThis()
  1114. {
  1115. ref++;
  1116. return this;
  1117. }
  1118. ShopKlient *ShopKlient::release()
  1119. {
  1120. ref--;
  1121. if( !ref )
  1122. delete this;
  1123. return 0;
  1124. }