From 2bc6eaa6b0960b001dd799960067914a8ebb3c1e Mon Sep 17 00:00:00 2001 From: SirCotare Date: Mon, 4 Jun 2012 00:34:26 +0200 Subject: [PATCH] #1470 initial achievement tracker --- .../_AchWebParser/AchWebParser.php | 94 +++++++++++ .../_AchWebParser/_doc/Class_scheme.dia | Bin 0 -> 1648 bytes .../_AchWebParser/_doc/Class_scheme.png | Bin 0 -> 4524 bytes .../class/DataSourceHandler_class.php | 41 +++++ .../class/DataSource_abstract.php | 24 +++ .../_AchWebParser/class/mySQL_class.php | 151 ++++++++++++++++++ .../_AchWebParser/include/functions_inc.php | 19 +++ .../source/ValueCache/ValueCache_class.php | 26 +++ .../source/XMLapi/XMLapi_class.php | 19 +++ 9 files changed, 374 insertions(+) create mode 100644 code/web/app/app_achievements/_AchWebParser/AchWebParser.php create mode 100644 code/web/app/app_achievements/_AchWebParser/_doc/Class_scheme.dia create mode 100644 code/web/app/app_achievements/_AchWebParser/_doc/Class_scheme.png create mode 100644 code/web/app/app_achievements/_AchWebParser/class/DataSourceHandler_class.php create mode 100644 code/web/app/app_achievements/_AchWebParser/class/DataSource_abstract.php create mode 100644 code/web/app/app_achievements/_AchWebParser/class/mySQL_class.php create mode 100644 code/web/app/app_achievements/_AchWebParser/include/functions_inc.php create mode 100644 code/web/app/app_achievements/_AchWebParser/source/ValueCache/ValueCache_class.php create mode 100644 code/web/app/app_achievements/_AchWebParser/source/XMLapi/XMLapi_class.php diff --git a/code/web/app/app_achievements/_AchWebParser/AchWebParser.php b/code/web/app/app_achievements/_AchWebParser/AchWebParser.php new file mode 100644 index 000000000..3e2cae8df --- /dev/null +++ b/code/web/app/app_achievements/_AchWebParser/AchWebParser.php @@ -0,0 +1,94 @@ +connect($CONF['mysql_server'],$CONF['mysql_user'],$CONF['mysql_pass'],$CONF['mysql_database']); + + #MISSING: mode -> single, cron, debug + + require_once("class/DataSourceHandler_class.php"); + require_once("class/DataSource_abstract.php"); + + //create datasource handler + $_DATA = new DataSourceHandler(); + foreach($CONF['data_source'] as $elem) { //populate + require_once("source/".$elem."/".$elem."_class.php"); + eval('$tmp = new '.$elem.'();'); + $_DATA->registerDataSource($tmp); + } + + #MISSING: fetch candidates + + foreach() { + #MISSING: fetch objectives to evaluate + foreach() { + #MISSING: fetch atoms + foreach() { + #MISSING: evaluate atoms + } + #MISSING: evaluate objective + } + #MISSING: evaluate perk + } + + #WORKPAD:#### + + Trigger: + by value + (by event) + + Sources: + XML + valuecache + (Achievement Service) + (Mirror Service) + + + VALUE dappers = c_money + if(dappers >= 5000) { + GRANT + } + + VALUE tmp = c_fame[scorchers] + if(tmp == 0) { + DENY:3600 + } + + EVENT:player_death + ON player_death { + UNLOCK + } + + ############# + + + + #MISSING: self call on cron mode + if() { + $fp = fsockopen($CONF['self_host'], 80, $errno, $errstr, 30); + if(!$fp) { + logf("ERROR: self call; socket: ".$errstr." (."$errno.")"); + } + else { + $out = "GET ".$CONF['self_path']." HTTP/1.1\r\n"; + $out .= "Host: ".$CONF['self_host']."\r\n"; + $out .= "Connection: Close\r\n\r\n"; + + fwrite($fp, $out); + fclose($fp); + } + } + + exit(0); +?> \ No newline at end of file diff --git a/code/web/app/app_achievements/_AchWebParser/_doc/Class_scheme.dia b/code/web/app/app_achievements/_AchWebParser/_doc/Class_scheme.dia new file mode 100644 index 0000000000000000000000000000000000000000..aa0d65c93a07d46cd55f38324c879282a997de35 GIT binary patch literal 1648 zcmV-$29Nn4iwFP!000003+-H4lcP2eexF}KF|RW+hi&Yg^=u`ZO6Fm=@{nvQZ!Q_j zSXqIH5HsUE2@8T^EjA7mi&Q4hKu0 zGR`38MaUJU1VJxBF~lyZ)j^95=A2gae*;NSM}g$@!P}a8uEX&9vg2l2 zlt_8OYrb8+4rH!G`fecU&p5y0v!X6EtZ) zJvbp=qo87#W!scU+NRA$RaVcpt819#RBp14AqdCJq#!V%qMqa zpilA!D29(RfYmB5pNZ~6&mri55kWlY1~Bh*tsN2~$X(i$dBxnIKXqb|IEWNg+6Rz1 zFtyBKb->yp>}+{C*aXaa0n4RJnPllFF?N5WA+ymF^wtEiv$<0fv_K4bM5FOrhS?cH z_@|3JKA3#C64wd`%>!JTc^jE1^nHecV0ri=7#xaii{X73G$p`AU&osRyPa|9VeT3 z_j*HO6)L6z4d~hEtmz%VvME&w=hj-@nGGhS8X>!2&-lF zUJo`q#wv03UWfEhaHj*ehAF4>>@jVrWNB)c=lP*a4vmXTB9#lmIYtn~45wsS_`+IB z*=(03H}wce8z5o*@H$9EN;RNXQCf`&=DTxn$P3*w>s`%Z&ak+eYp5;E7dh=Ru<7}M z(HidTdeoJi1`cPYW5~hL`q^<+uD1bnc3Ez?@p?UX zujv?C$H96Ricjbo%-uZ( z5(n`phREn4qlb(hGJ3R&9x?;@no@HaLu3r;Cx$e8u;cm!ax~PFw!QoyTP~DT!L%!j z(Yuz#=yPD+je#*_S&YCiqGA=}!5D*y_}2pFkhL)#b*fVvGXc6aK3yc94Okmv4p|Cw zg<Bg#A8hVcHiZ$WjSqk%iD}@==eHJoz`FdY`-R%5m-HIN24@%f0 zh?K7zCeWr4-q4J_n_BfAu3JKrlZaq^KVA`YuIa<8#qU+pwve7lTo)ZB9A?R4P+6)ia;N8&Rnaf*P7XD_2T=0a~ z(c8wQrswQ`@BDAbbid^33zn*JJ?K}%@6Zc7OJ6j=^2|)j=_1fuMrvo1U+ICpZ zR9azXSJH*GyfK!LG)$%$&5i%bkzfI$&WW8QiuK93vGxAq<}o0}`Nh z!vd0_pY|97My=bQr^xT!MQt&&7%MX*_n1VzH>(oBCCg2*moPIG0c{LCtP;8x3|xUG zfq++PE%LxXy8Eo6c4M^p|k1zQJU} zj2yj>)?HKbGzEYQV;LAS)i6yP7A8myz`Z_sSWIiIm5<+d6zQal?ofVC>H;nuHQVl4 z$1DknmHCb!(wEBYLpZ;p`+nuB8&#ABRyv&s5iaG=s|9z1?>H6x|hF^VK^d_Jn)&mnH8ZOjnD2ikjv`szu+=`#wy9Q&hSX};=VB+bxEVf zLK0s31KRFH+_vATuW9lH^n12;iXW>(pMAvZR<84NHl(#D{1`>7bgMFB&eKP);O_%n z-RG9xr$gilJ)Vu@EIDfP3t=fcJ@78RZIvw70`JtBf>pkEyomhFfXOhIPXDv~~T+gm+S z4a&y`u;cih9B(1;tT7~`GGC)=;uAAeb1cF(-hRc+H=HmN+abALD1I|kW+3ljJ5*r9 z)hXgoFTy*nwtPC8%U0#Zl53K&B*?f`)$jFv^dIZtQrAZ#V#3D8IXV{x>I)~TyfhXD zDG7``LF3uZ-rL}yD{E^xrHlnWF8VR_M!KTR1$@#NFc|&XDpcq~0lpM;hLO z=RU?O8I7**(H1r5Ez(ernZ7FvjyBNF?mmyyl{qXJa==%le~1VN`#m47ba`J&>94rtf)vZU(HDZH z)Op6v?Y6i5V%aAUSpU)w+rkHA){dUExi`Ll`dX;@06g*lU2Fc5LYpZ6RCS~EorNps zMlaWBG&w#n(q~ACFyftbL_g#3r-DSqtge@!gd=%%bvqRJLm(S12bmDcnSiYz*u+-hKghn&fp zG{0igmqoym{5T`;a%q!!99HEA%EgNG;LYqhn^k3px(W&4>2Jvx$CtOGq6hRBusT39 zy7z}=kBd5%*Aq=0dKWHWp=1W#Fm zOD@`Koml_?f14=j?}7#7e4g|I4tZ$ez55F;(?rsymhnxqN|G=+$SAReu9evJ$RME# z7_Dp}&Da(2X^YBvrA{sOHHl=D3gDw@bS%{0#Ig6=djmZ$A`&9gze;_k0Wyu0PKNi&Wg#;@wy7` z+U%{x72|nvz~**XGh8$7jYSuo8W!NCCmt!!rFq7Pm+HKX($xlw;CC<-)Ba}-*S^glQO z$rFcH9n+fiW^g~ZKN0Q)pGsO@A%Rkg>@jt#PXe7VydO$TWHb&5NPhj#s}zS&Cp&N| z0xrMj3r~l;9VNqe{Y0c}Lj_tWlp2)woEzE2kzo2cVV=#&m)0LdC;Q(h>_}e+SEPU@ zq5VuVZ(L<+9%pnN&(nWvC-n#hr`v}K2&mtxE;y&E3HTE8$Cc*w?kxN@Hse>tr!I_^J2Dw#_4|}!Bv)>X0qjEgY5Aps*%n`5n z$l;7C;cm07@%Koy+_iSzbQC{LJ(x}7DWCHXj-vIP$h%y`aYX79r;I=1zbq-yep0X0 z)~71E{qD}4E#4i#jcxF(QMwr(w!RO%&)zS8x+gE>_oR~H_H1G1P+^wPpI|5>x{7vL5z=y zQjD$_s$=twaa$MZ^)Wiiaw*FsP<-u-sV!A=rx$yv*`q~1Yhioaq=CO!FXC0iR8zhu zch(HGeJN@B*;1wdPY#|gWF5B3>OonUrn~A$hWFu;uKK3!zC^Z z(PL#I8@bM#+wJ&+MR)4B~i})X3WXGa}XH6 ze`d#K;$QDUa>+srZvEZ8pNkEOrA>f=LM4%t2<;sA_swjAimsD~%Xn@d-d{wV>4mCJ7qCN!j=f^dTiNe++RUl-HwQpeGi9Yqd1A%}w|vM) z+*{dxw4QKq3<{WD?KS6Q;9|cxUt^IA%sc|si-*gWE-3;Y&n)ebo^`HQ;NANHvb__N zboL?8Ou*KSL#D+5a%z2@#5b|jrZ3~_DKh|UHVGry+xS`z&>jrcGh_d1tMIbUKQ5e4 znAaYZ0(`s;WWmr5*08bD=JCl4^b>Qu&*iekUd3ME`+b*4gzXJoHrGnfAZT{nFCJ=mzTg^a5wd%Mp5G!H*nAdcGTtc z$S4+*MK=d319=H-Mq{-#rre1Zi0eMw5`VRwnsE!#(B!J*|6|}>&>vF3s-*_F>Vsi9 zN|Eap6Sed-KX4q1Xb+eJbnP$gyt{oH>xBGs(0G1{LtaAe^#x!NM+x|lFoi}eh8?D( zFIiM5N*ZX-n`-ZIBL0=rHvC;a!^Gk+P@1hjP2k_;$TyrQIIr~V#c!$my9s`GH$B3T z1WwTiCRB&bWmX#o%*DLm^Y;J|xVjQ#-x{=s`7Re8@^jY=fzyX-suWNzo+D0;4>95f+5rJhdYNy2qU9 zP6+yUzwv*E{dZgP|FFLtt{iD*r52%@P%RSE()#8WuZGxzq8eJg_!C?ivR3@f4il;n zQVG#&W*8!JWARazj(5aFD$6)?mEMRnY(NX#m?C%aibhI{T(YRb}#33qfLE!3^ z)-B&`?J)J~5yXAK;PTEJHtz*DTPh-DFlWE9mR3z=e*-zK zoi_dyakFM^V1g%49_t4m)?5*HG@uh^A=y(v(_rN3Osz_buuMYQOjUNHs|O zGG4ywqo1ul2|`|lI-(OMdQgcy58(9EcQnU@bOUyh;wkoO@0R#YB;=|7X!+O@{~rO# z&cTVJ1o|Hz40e{*2(`8Z=VpHl-vAgU0CIZRjeKff;`Fr}zZ6(99aH6k}! zda`s{C+cHr7OjVrArBTO8=u#1^Qnc3aA7bRe*%Q`5KbzHR2Bt-6X588mL0+#) ze7nc)Hv{vhUAz4YMCRV=pFsZR>*r7%A3fIjhXF>J-QVfH70)tdb#AE@x{8)x04qzo KYh@Nbzx)qj3G#&i literal 0 HcmV?d00001 diff --git a/code/web/app/app_achievements/_AchWebParser/class/DataSourceHandler_class.php b/code/web/app/app_achievements/_AchWebParser/class/DataSourceHandler_class.php new file mode 100644 index 000000000..53b64d8d6 --- /dev/null +++ b/code/web/app/app_achievements/_AchWebParser/class/DataSourceHandler_class.php @@ -0,0 +1,41 @@ +source = array(); + $this->alloc = array(); + + + } + + function registerDataSource($src) { + $i = sizeof($this->source); + $this->source[$i] = $src; + foreach($src->getTypes() as $elem) { + if(!is_array($this->alloc[$elem])) { + $this->alloc[$elem] = array(); + } + //add to list + $this->alloc[$elem][$src->getPriority($elem)] = $i; + } + } + + function getData($type,$field,$ident) { + return $this->getDataSource($type)->getData($type,$field,$ident); + } + + private function getDataSource($type) { + //find the highest priority datasource for given type + if(!$this->alloc[$type]) { + return false; //unknown type + } + $pos = array_keys($this->alloc[$type]); + if(sizeof($pos) == 0) { + return false; //no datasource for type // should not happen since type is defined by datasource + } + return $this->alloc[$type][$pos[0]]; + } + } +?> \ No newline at end of file diff --git a/code/web/app/app_achievements/_AchWebParser/class/DataSource_abstract.php b/code/web/app/app_achievements/_AchWebParser/class/DataSource_abstract.php new file mode 100644 index 000000000..4b5d64bf6 --- /dev/null +++ b/code/web/app/app_achievements/_AchWebParser/class/DataSource_abstract.php @@ -0,0 +1,24 @@ +types; + } + + function getPriority($type) { + return $this->priority[$type]; + } + + abstract function getData($type,$ident,$field = array()); + + abstract function writeData($type,$ident,$field = array(),$value = array()); + } +?> \ No newline at end of file diff --git a/code/web/app/app_achievements/_AchWebParser/class/mySQL_class.php b/code/web/app/app_achievements/_AchWebParser/class/mySQL_class.php new file mode 100644 index 000000000..4202ffcd8 --- /dev/null +++ b/code/web/app/app_achievements/_AchWebParser/class/mySQL_class.php @@ -0,0 +1,151 @@ +$elem) { + $in[$key] = mysql_real_escape_string(stripslashes($elem)); + } + } + else { + $in = mysql_real_escape_string(stripslashes($in)); + } + return $in; + } + + function mySQL($err=false) { + $this->DBstats = array(); + $this->DBc = false; + if($err === "DIE" || $err === "PRINT" || $err === "ALERT" || $err === "HIDE") { + $this->DBerror = $err; + } + else { + $this->DBerror = "HIDE"; + } + $this->resetStats(); + $this->cached = false; + } + + function connect($ip,$user,$pass,$db=false) { + $this->DBc = mysql_pconnect($ip,$user,$pass) or $this->error(mysql_error()); + if($db) { + $this->database($db); + } + $this->resetStats(); + } + + function database($db) { + mysql_select_db($db,$this->DBc) or $this->error(mysql_error()); + } + + function resetStats() { + $this->DBstats['query'] = 0; + $this->DBstats['error'] = 0; + } + + function getStats() { + return $this->DBstats; + } + + function sendSQL($query,$handling="PLAIN",$buffer=false) { // can be INSERT, DELETE, UPDATE, ARRAY, NONE, PLAIN + #if($this->cached !== false) { + #$this->unlinkSql($this->cached); + #} + + if($buffer === false && $handling !== "PLAIN") { + $res = mysql_unbuffered_query($query,$this->DBc) or $this->error(mysql_error(),$query); + } + else { + $res = mysql_query($query,$this->DBc) or $this->error(mysql_error(),$query); + } + + #$this->cached = $res; + + $this->DBstats['query']++; + + if($res) { + if($handling === "INSERT") { + $tmp = mysql_insert_id($this->DBc) or $this->error(mysql_error());; + $this->unlinkSql($res); + return $tmp; + } + elseif($handling === "DELETE" || $handling === "UPDATE") { + $tmp = mysql_affected_rows($this->DBc) or $this->error(mysql_error()); + $this->unlinkSql($res); + return $tmp; + } + elseif($handling === "ARRAY") { + $tmp = $this->parseSql($res); + $this->unlinkSql($res); + return $tmp; + } + elseif($handling === "NONE") { + $this->unlinkSql($res); + return true; + } + else { + return $res; + } + mysql_free_result($res); + } + else { + return false; + } + } + + function unlinkSql($res) { + @mysql_free_result($res); + } + + private function parseSql($res) { + $data = array(); + $k = 0; + while($tmp = mysql_fetch_array($res,MYSQL_ASSOC)) { + $data[$k] = $tmp; + $k++; + } + + return $data; + } + + function getNext($res) { + if($res) { + if($tmp = mysql_fetch_array($res,MYSQL_ASSOC)) { + return $tmp; + } + else { + return false; + } + } + else { + return false; + } + } + + private function error($error,$query = false) { + $this->DBstats['error']++; + + if($query != false) { + $error .= " -->|".$query."|<--"; + } + + switch($this->DBerror) { + case 'DIE': + die($error); + break; + case 'PRINT': + echo "
".$error."
"; + break; + case 'ALERT': + echo ""; + break; + default: + flush(); + break; + } + } + } +?> \ No newline at end of file diff --git a/code/web/app/app_achievements/_AchWebParser/include/functions_inc.php b/code/web/app/app_achievements/_AchWebParser/include/functions_inc.php new file mode 100644 index 000000000..17e9a89ae --- /dev/null +++ b/code/web/app/app_achievements/_AchWebParser/include/functions_inc.php @@ -0,0 +1,19 @@ + ".$txt; + } +?> \ No newline at end of file diff --git a/code/web/app/app_achievements/_AchWebParser/source/ValueCache/ValueCache_class.php b/code/web/app/app_achievements/_AchWebParser/source/ValueCache/ValueCache_class.php new file mode 100644 index 000000000..84c174124 --- /dev/null +++ b/code/web/app/app_achievements/_AchWebParser/source/ValueCache/ValueCache_class.php @@ -0,0 +1,26 @@ +types[] = "c_cache"; + + $this->write = true; + } + + function getData($type,$ident,$field) { + + } + + function writeData($type,$ident,$field = array(),$value = array()) { + global $DBc; + + if($type == "c_cache") { + $DBc->sendSQL("INSERT INTO ach_player_valuecache () VALUES () ON DUPLICATE KEY UPDATE "); + + return true; + } + else { + return false; + } + } + } +?> \ No newline at end of file diff --git a/code/web/app/app_achievements/_AchWebParser/source/XMLapi/XMLapi_class.php b/code/web/app/app_achievements/_AchWebParser/source/XMLapi/XMLapi_class.php new file mode 100644 index 000000000..6ae24a6ac --- /dev/null +++ b/code/web/app/app_achievements/_AchWebParser/source/XMLapi/XMLapi_class.php @@ -0,0 +1,19 @@ +types[] = "c_stats"; + $this->types[] = "c_items"; + + $this->write = false; + } + + function getData() { + + } + + function writeData() { + return false; + } + + } +?> \ No newline at end of file