").append(bD.replace(a6,"")).find(e):bD)}if(bA){bv.each(bA,[bD,bB,bC])}}});return this},serialize:function(){return b.param(this.serializeArray())},serializeArray:function(){return this.map(function(){return this.elements?b.makeArray(this.elements):this}).filter(function(){return this.name&&!this.disabled&&(this.checked||q.test(this.nodeName)||aZ.test(this.type))}).map(function(e,bv){var bw=b(this).val();return bw==null?null:b.isArray(bw)?b.map(bw,function(by,bx){return{name:bv.name,value:by.replace(bs,"\r\n")}}):{name:bv.name,value:bw.replace(bs,"\r\n")}}).get()}});b.each("ajaxStart ajaxStop ajaxComplete ajaxError ajaxSuccess ajaxSend".split(" "),function(e,bv){b.fn[bv]=function(bw){return this.on(bv,bw)}});b.each(["get","post"],function(e,bv){b[bv]=function(bw,by,bz,bx){if(b.isFunction(by)){bx=bx||bz;bz=by;by=L}return b.ajax({type:bv,url:bw,data:by,success:bz,dataType:bx})}});b.extend({getScript:function(e,bv){return b.get(e,L,bv,"script")},getJSON:function(e,bv,bw){return b.get(e,bv,bw,"json")},ajaxSetup:function(bv,e){if(e){am(bv,b.ajaxSettings)}else{e=bv;bv=b.ajaxSettings}am(bv,e);return bv},ajaxSettings:{url:aE,isLocal:aM.test(s[1]),global:true,type:"GET",contentType:"application/x-www-form-urlencoded",processData:true,async:true,accepts:{xml:"application/xml, text/xml",html:"text/html",text:"text/plain",json:"application/json, text/javascript","*":aV},contents:{xml:/xml/,html:/html/,json:/json/},responseFields:{xml:"responseXML",text:"responseText"},converters:{"* text":bb.String,"text html":true,"text json":b.parseJSON,"text xml":b.parseXML},flatOptions:{context:true,url:true}},ajaxPrefilter:f(aa),ajaxTransport:f(r),ajax:function(bz,bx){if(typeof bz==="object"){bx=bz;bz=L}bx=bx||{};var bD=b.ajaxSetup({},bx),bS=bD.context||bD,bG=bS!==bD&&(bS.nodeType||bS instanceof b)?b(bS):b.event,bR=b.Deferred(),bN=b.Callbacks("once memory"),bB=bD.statusCode||{},bC,bH={},bO={},bQ,by,bL,bE,bI,bA=0,bw,bK,bJ={readyState:0,setRequestHeader:function(bT,bU){if(!bA){var e=bT.toLowerCase();bT=bO[e]=bO[e]||bT;bH[bT]=bU}return this},getAllResponseHeaders:function(){return bA===2?bQ:null},getResponseHeader:function(bT){var e;if(bA===2){if(!by){by={};while((e=aD.exec(bQ))){by[e[1].toLowerCase()]=e[2]}}e=by[bT.toLowerCase()]}return e===L?null:e},overrideMimeType:function(e){if(!bA){bD.mimeType=e}return this},abort:function(e){e=e||"abort";if(bL){bL.abort(e)}bF(0,e);return this}};function bF(bZ,bU,b0,bW){if(bA===2){return}bA=2;if(bE){clearTimeout(bE)}bL=L;bQ=bW||"";bJ.readyState=bZ>0?4:0;var bT,b4,b3,bX=bU,bY=b0?bj(bD,bJ,b0):L,bV,b2;if(bZ>=200&&bZ<300||bZ===304){if(bD.ifModified){if((bV=bJ.getResponseHeader("Last-Modified"))){b.lastModified[bC]=bV}if((b2=bJ.getResponseHeader("Etag"))){b.etag[bC]=b2}}if(bZ===304){bX="notmodified";bT=true}else{try{b4=G(bD,bY);bX="success";bT=true}catch(b1){bX="parsererror";b3=b1}}}else{b3=bX;if(!bX||bZ){bX="error";if(bZ<0){bZ=0}}}bJ.status=bZ;bJ.statusText=""+(bU||bX);if(bT){bR.resolveWith(bS,[b4,bX,bJ])}else{bR.rejectWith(bS,[bJ,bX,b3])}bJ.statusCode(bB);bB=L;if(bw){bG.trigger("ajax"+(bT?"Success":"Error"),[bJ,bD,bT?b4:b3])}bN.fireWith(bS,[bJ,bX]);if(bw){bG.trigger("ajaxComplete",[bJ,bD]);if(!(--b.active)){b.event.trigger("ajaxStop")}}}bR.promise(bJ);bJ.success=bJ.done;bJ.error=bJ.fail;bJ.complete=bN.add;bJ.statusCode=function(bT){if(bT){var e;if(bA<2){for(e in bT){bB[e]=[bB[e],bT[e]]}}else{e=bT[bJ.status];bJ.then(e,e)}}return this};bD.url=((bz||bD.url)+"").replace(bq,"").replace(c,s[1]+"//");bD.dataTypes=b.trim(bD.dataType||"*").toLowerCase().split(h);if(bD.crossDomain==null){bI=K.exec(bD.url.toLowerCase());bD.crossDomain=!!(bI&&(bI[1]!=s[1]||bI[2]!=s[2]||(bI[3]||(bI[1]==="http:"?80:443))!=(s[3]||(s[1]==="http:"?80:443))))}if(bD.data&&bD.processData&&typeof bD.data!=="string"){bD.data=b.param(bD.data,bD.traditional)}aW(aa,bD,bx,bJ);if(bA===2){return false}bw=bD.global;bD.type=bD.type.toUpperCase();bD.hasContent=!aQ.test(bD.type);if(bw&&b.active++===0){b.event.trigger("ajaxStart")}if(!bD.hasContent){if(bD.data){bD.url+=(M.test(bD.url)?"&":"?")+bD.data;delete bD.data}bC=bD.url;if(bD.cache===false){var bv=b.now(),bP=bD.url.replace(br,"$1_="+bv);bD.url=bP+((bP===bD.url)?(M.test(bD.url)?"&":"?")+"_="+bv:"")}}if(bD.data&&bD.hasContent&&bD.contentType!==false||bx.contentType){bJ.setRequestHeader("Content-Type",bD.contentType)}if(bD.ifModified){bC=bC||bD.url;if(b.lastModified[bC]){bJ.setRequestHeader("If-Modified-Since",b.lastModified[bC])}if(b.etag[bC]){bJ.setRequestHeader("If-None-Match",b.etag[bC])}}bJ.setRequestHeader("Accept",bD.dataTypes[0]&&bD.accepts[bD.dataTypes[0]]?bD.accepts[bD.dataTypes[0]]+(bD.dataTypes[0]!=="*"?", "+aV+"; q=0.01":""):bD.accepts["*"]);for(bK in bD.headers){bJ.setRequestHeader(bK,bD.headers[bK])}if(bD.beforeSend&&(bD.beforeSend.call(bS,bJ,bD)===false||bA===2)){bJ.abort();return false}for(bK in {success:1,error:1,complete:1}){bJ[bK](bD[bK])}bL=aW(r,bD,bx,bJ);if(!bL){bF(-1,"No Transport")}else{bJ.readyState=1;if(bw){bG.trigger("ajaxSend",[bJ,bD])}if(bD.async&&bD.timeout>0){bE=setTimeout(function(){bJ.abort("timeout")},bD.timeout)}try{bA=1;bL.send(bH,bF)}catch(bM){if(bA<2){bF(-1,bM)}else{throw bM}}}return bJ},param:function(e,bw){var bv=[],by=function(bz,bA){bA=b.isFunction(bA)?bA():bA;bv[bv.length]=encodeURIComponent(bz)+"="+encodeURIComponent(bA)};if(bw===L){bw=b.ajaxSettings.traditional}if(b.isArray(e)||(e.jquery&&!b.isPlainObject(e))){b.each(e,function(){by(this.name,this.value)})}else{for(var bx in e){v(bx,e[bx],bw,by)}}return bv.join("&").replace(k,"+")}});function v(bw,by,bv,bx){if(b.isArray(by)){b.each(by,function(bA,bz){if(bv||ap.test(bw)){bx(bw,bz)}else{v(bw+"["+(typeof bz==="object"||b.isArray(bz)?bA:"")+"]",bz,bv,bx)}})}else{if(!bv&&by!=null&&typeof by==="object"){for(var e in by){v(bw+"["+e+"]",by[e],bv,bx)}}else{bx(bw,by)}}}b.extend({active:0,lastModified:{},etag:{}});function bj(bD,bC,bz){var bv=bD.contents,bB=bD.dataTypes,bw=bD.responseFields,by,bA,bx,e;for(bA in bw){if(bA in bz){bC[bw[bA]]=bz[bA]}}while(bB[0]==="*"){bB.shift();if(by===L){by=bD.mimeType||bC.getResponseHeader("content-type")}}if(by){for(bA in bv){if(bv[bA]&&bv[bA].test(by)){bB.unshift(bA);break}}}if(bB[0] in bz){bx=bB[0]}else{for(bA in bz){if(!bB[0]||bD.converters[bA+" "+bB[0]]){bx=bA;break}if(!e){e=bA}}bx=bx||e}if(bx){if(bx!==bB[0]){bB.unshift(bx)}return bz[bx]}}function G(bH,bz){if(bH.dataFilter){bz=bH.dataFilter(bz,bH.dataType)}var bD=bH.dataTypes,bG={},bA,bE,bw=bD.length,bB,bC=bD[0],bx,by,bF,bv,e;for(bA=1;bA
=bw.duration+this.startTime){this.now=this.end;this.pos=this.state=1;this.update();bw.animatedProperties[this.prop]=true;for(bA in bw.animatedProperties){if(bw.animatedProperties[bA]!==true){e=false}}if(e){if(bw.overflow!=null&&!b.support.shrinkWrapBlocks){b.each(["","X","Y"],function(bC,bD){bz.style["overflow"+bD]=bw.overflow[bC]})}if(bw.hide){b(bz).hide()}if(bw.hide||bw.show){for(bA in bw.animatedProperties){b.style(bz,bA,bw.orig[bA]);b.removeData(bz,"fxshow"+bA,true);b.removeData(bz,"toggle"+bA,true)}}bv=bw.complete;if(bv){bw.complete=false;bv.call(bz)}}return false}else{if(bw.duration==Infinity){this.now=bx}else{bB=bx-this.startTime;this.state=bB/bw.duration;this.pos=b.easing[bw.animatedProperties[this.prop]](this.state,bB,0,1,bw.duration);this.now=this.start+((this.end-this.start)*this.pos)}this.update()}return true}};b.extend(b.fx,{tick:function(){var bw,bv=b.timers,e=0;for(;e").appendTo(e),bw=bv.css("display");bv.remove();if(bw==="none"||bw===""){if(!a8){a8=av.createElement("iframe");a8.frameBorder=a8.width=a8.height=0}e.appendChild(a8);if(!m||!a8.createElement){m=(a8.contentWindow||a8.contentDocument).document;m.write((av.compatMode==="CSS1Compat"?"":"")+"");m.close()}bv=m.createElement(bx);m.body.appendChild(bv);bw=b.css(bv,"display");e.removeChild(a8)}Q[bx]=bw}return Q[bx]}var V=/^t(?:able|d|h)$/i,ad=/^(?:body|html)$/i;if("getBoundingClientRect" in av.documentElement){b.fn.offset=function(bI){var by=this[0],bB;if(bI){return this.each(function(e){b.offset.setOffset(this,bI,e)})}if(!by||!by.ownerDocument){return null}if(by===by.ownerDocument.body){return b.offset.bodyOffset(by)}try{bB=by.getBoundingClientRect()}catch(bF){}var bH=by.ownerDocument,bw=bH.documentElement;if(!bB||!b.contains(bw,by)){return bB?{top:bB.top,left:bB.left}:{top:0,left:0}}var bC=bH.body,bD=aK(bH),bA=bw.clientTop||bC.clientTop||0,bE=bw.clientLeft||bC.clientLeft||0,bv=bD.pageYOffset||b.support.boxModel&&bw.scrollTop||bC.scrollTop,bz=bD.pageXOffset||b.support.boxModel&&bw.scrollLeft||bC.scrollLeft,bG=bB.top+bv-bA,bx=bB.left+bz-bE;return{top:bG,left:bx}}}else{b.fn.offset=function(bF){var bz=this[0];if(bF){return this.each(function(bG){b.offset.setOffset(this,bF,bG)})}if(!bz||!bz.ownerDocument){return null}if(bz===bz.ownerDocument.body){return b.offset.bodyOffset(bz)}var bC,bw=bz.offsetParent,bv=bz,bE=bz.ownerDocument,bx=bE.documentElement,bA=bE.body,bB=bE.defaultView,e=bB?bB.getComputedStyle(bz,null):bz.currentStyle,bD=bz.offsetTop,by=bz.offsetLeft;while((bz=bz.parentNode)&&bz!==bA&&bz!==bx){if(b.support.fixedPosition&&e.position==="fixed"){break}bC=bB?bB.getComputedStyle(bz,null):bz.currentStyle;bD-=bz.scrollTop;by-=bz.scrollLeft;if(bz===bw){bD+=bz.offsetTop;by+=bz.offsetLeft;if(b.support.doesNotAddBorder&&!(b.support.doesAddBorderForTableAndCells&&V.test(bz.nodeName))){bD+=parseFloat(bC.borderTopWidth)||0;by+=parseFloat(bC.borderLeftWidth)||0}bv=bw;bw=bz.offsetParent}if(b.support.subtractsBorderForOverflowNotVisible&&bC.overflow!=="visible"){bD+=parseFloat(bC.borderTopWidth)||0;by+=parseFloat(bC.borderLeftWidth)||0}e=bC}if(e.position==="relative"||e.position==="static"){bD+=bA.offsetTop;by+=bA.offsetLeft}if(b.support.fixedPosition&&e.position==="fixed"){bD+=Math.max(bx.scrollTop,bA.scrollTop);by+=Math.max(bx.scrollLeft,bA.scrollLeft)}return{top:bD,left:by}}}b.offset={bodyOffset:function(e){var bw=e.offsetTop,bv=e.offsetLeft;if(b.support.doesNotIncludeMarginInBodyOffset){bw+=parseFloat(b.css(e,"marginTop"))||0;bv+=parseFloat(b.css(e,"marginLeft"))||0}return{top:bw,left:bv}},setOffset:function(bx,bG,bA){var bB=b.css(bx,"position");if(bB==="static"){bx.style.position="relative"}var bz=b(bx),bv=bz.offset(),e=b.css(bx,"top"),bE=b.css(bx,"left"),bF=(bB==="absolute"||bB==="fixed")&&b.inArray("auto",[e,bE])>-1,bD={},bC={},bw,by;if(bF){bC=bz.position();bw=bC.top;by=bC.left}else{bw=parseFloat(e)||0;by=parseFloat(bE)||0}if(b.isFunction(bG)){bG=bG.call(bx,bA,bv)}if(bG.top!=null){bD.top=(bG.top-bv.top)+bw}if(bG.left!=null){bD.left=(bG.left-bv.left)+by}if("using" in bG){bG.using.call(bx,bD)}else{bz.css(bD)}}};b.fn.extend({position:function(){if(!this[0]){return null}var bw=this[0],bv=this.offsetParent(),bx=this.offset(),e=ad.test(bv[0].nodeName)?{top:0,left:0}:bv.offset();bx.top-=parseFloat(b.css(bw,"marginTop"))||0;bx.left-=parseFloat(b.css(bw,"marginLeft"))||0;e.top+=parseFloat(b.css(bv[0],"borderTopWidth"))||0;e.left+=parseFloat(b.css(bv[0],"borderLeftWidth"))||0;return{top:bx.top-e.top,left:bx.left-e.left}},offsetParent:function(){return this.map(function(){var e=this.offsetParent||av.body;while(e&&(!ad.test(e.nodeName)&&b.css(e,"position")==="static")){e=e.offsetParent}return e})}});b.each(["Left","Top"],function(bv,e){var bw="scroll"+e;b.fn[bw]=function(bz){var bx,by;if(bz===L){bx=this[0];if(!bx){return null}by=aK(bx);return by?("pageXOffset" in by)?by[bv?"pageYOffset":"pageXOffset"]:b.support.boxModel&&by.document.documentElement[bw]||by.document.body[bw]:bx[bw]}return this.each(function(){by=aK(this);if(by){by.scrollTo(!bv?bz:b(by).scrollLeft(),bv?bz:b(by).scrollTop())}else{this[bw]=bz}})}});function aK(e){return b.isWindow(e)?e:e.nodeType===9?e.defaultView||e.parentWindow:false}b.each(["Height","Width"],function(bv,e){var bw=e.toLowerCase();b.fn["inner"+e]=function(){var bx=this[0];return bx?bx.style?parseFloat(b.css(bx,bw,"padding")):this[bw]():null};b.fn["outer"+e]=function(by){var bx=this[0];return bx?bx.style?parseFloat(b.css(bx,bw,by?"margin":"border")):this[bw]():null};b.fn[bw]=function(bz){var bA=this[0];if(!bA){return bz==null?null:this}if(b.isFunction(bz)){return this.each(function(bE){var bD=b(this);bD[bw](bz.call(this,bE,bD[bw]()))})}if(b.isWindow(bA)){var bB=bA.document.documentElement["client"+e],bx=bA.document.body;return bA.document.compatMode==="CSS1Compat"&&bB||bx&&bx["client"+e]||bB}else{if(bA.nodeType===9){return Math.max(bA.documentElement["client"+e],bA.body["scroll"+e],bA.documentElement["scroll"+e],bA.body["offset"+e],bA.documentElement["offset"+e])}else{if(bz===L){var bC=b.css(bA,bw),by=parseFloat(bC);return b.isNumeric(by)?by:bC}else{return this.css(bw,typeof bz==="string"?bz:bz+"px")}}}}});bb.jQuery=bb.$=b;if(typeof define==="function"&&define.amd&&define.amd.jQuery){define("jquery",[],function(){return b
+})}})(window);
diff --git a/management-interface/lib/api/nav_f.png b/management-interface/lib/api/nav_f.png
new file mode 100644
index 0000000..5ceae87
Binary files /dev/null and b/management-interface/lib/api/nav_f.png differ
diff --git a/management-interface/lib/api/nav_g.png b/management-interface/lib/api/nav_g.png
new file mode 100644
index 0000000..2093a23
Binary files /dev/null and b/management-interface/lib/api/nav_g.png differ
diff --git a/management-interface/lib/api/nav_h.png b/management-interface/lib/api/nav_h.png
new file mode 100644
index 0000000..e619809
Binary files /dev/null and b/management-interface/lib/api/nav_h.png differ
diff --git a/management-interface/lib/api/open.png b/management-interface/lib/api/open.png
new file mode 100644
index 0000000..7e740cc
Binary files /dev/null and b/management-interface/lib/api/open.png differ
diff --git a/management-interface/lib/api/sync_off.png b/management-interface/lib/api/sync_off.png
new file mode 100644
index 0000000..b856624
Binary files /dev/null and b/management-interface/lib/api/sync_off.png differ
diff --git a/management-interface/lib/api/sync_on.png b/management-interface/lib/api/sync_on.png
new file mode 100644
index 0000000..e5044af
Binary files /dev/null and b/management-interface/lib/api/sync_on.png differ
diff --git a/management-interface/lib/api/tab_a.png b/management-interface/lib/api/tab_a.png
new file mode 100644
index 0000000..170a784
Binary files /dev/null and b/management-interface/lib/api/tab_a.png differ
diff --git a/management-interface/lib/api/tab_b.png b/management-interface/lib/api/tab_b.png
new file mode 100644
index 0000000..7774499
Binary files /dev/null and b/management-interface/lib/api/tab_b.png differ
diff --git a/management-interface/lib/api/tab_h.png b/management-interface/lib/api/tab_h.png
new file mode 100644
index 0000000..e1dddef
Binary files /dev/null and b/management-interface/lib/api/tab_h.png differ
diff --git a/management-interface/lib/api/tab_s.png b/management-interface/lib/api/tab_s.png
new file mode 100644
index 0000000..3dc07b0
Binary files /dev/null and b/management-interface/lib/api/tab_s.png differ
diff --git a/management-interface/lib/api/tabs.css b/management-interface/lib/api/tabs.css
new file mode 100644
index 0000000..71145bb
--- /dev/null
+++ b/management-interface/lib/api/tabs.css
@@ -0,0 +1,60 @@
+.tabs, .tabs2, .tabs3 {
+ background-image: url('tab_b.png');
+ width: 100%;
+ z-index: 101;
+ font-size: 13px;
+ font-family: 'Lucida Grande',Geneva,Helvetica,Arial,sans-serif;
+}
+
+.tabs2 {
+ font-size: 10px;
+}
+.tabs3 {
+ font-size: 9px;
+}
+
+.tablist {
+ margin: 0;
+ padding: 0;
+ display: table;
+}
+
+.tablist li {
+ float: left;
+ display: table-cell;
+ background-image: url('tab_b.png');
+ line-height: 36px;
+ list-style: none;
+}
+
+.tablist a {
+ display: block;
+ padding: 0 20px;
+ font-weight: bold;
+ background-image:url('tab_s.png');
+ background-repeat:no-repeat;
+ background-position:right;
+ color: #434343;
+ text-shadow: 0px 1px 1px rgba(255, 255, 255, 0.9);
+ text-decoration: none;
+ outline: none;
+}
+
+.tabs3 .tablist a {
+ padding: 0 10px;
+}
+
+.tablist a:hover {
+ background-image: url('tab_h.png');
+ background-repeat:repeat-x;
+ color: #fff;
+ text-shadow: 0px 1px 1px rgba(0, 0, 0, 1.0);
+ text-decoration: none;
+}
+
+.tablist li.current a {
+ background-image: url('tab_a.png');
+ background-repeat:repeat-x;
+ color: #fff;
+ text-shadow: 0px 1px 1px rgba(0, 0, 0, 1.0);
+}
diff --git a/management-interface/lib/audit.php b/management-interface/lib/audit.php
new file mode 100644
index 0000000..32a64a9
--- /dev/null
+++ b/management-interface/lib/audit.php
@@ -0,0 +1,177 @@
+get('AGENT');
+ return (bool)preg_match('/('.self::UA_Desktop.')/i',$agent) &&
+ !$this->ismobile();
+ }
+
+ /**
+ * Return TRUE if user agent is a mobile device
+ * @return bool
+ **/
+ function ismobile() {
+ $agent=Base::instance()->get('AGENT');
+ return (bool)preg_match('/('.self::UA_Mobile.')/i',$agent);
+ }
+
+ /**
+ * Return TRUE if user agent is a Web bot
+ * @return bool
+ **/
+ function isbot() {
+ $agent=Base::instance()->get('AGENT');
+ return (bool)preg_match('/('.self::UA_Bot.')/i',$agent);
+ }
+
+ /**
+ * Return TRUE if specified ID has a valid (Luhn) Mod-10 check digit
+ * @return bool
+ * @param $id string
+ **/
+ function mod10($id) {
+ if (!ctype_digit($id))
+ return FALSE;
+ $id=strrev($id);
+ $sum=0;
+ for ($i=0,$l=strlen($id);$i<$l;$i++)
+ $sum+=$id[$i]+$i%2*(($id[$i]>4)*-4+$id[$i]%5);
+ return !($sum%10);
+ }
+
+ /**
+ * Return credit card type if number is valid
+ * @return string|FALSE
+ * @param $id string
+ **/
+ function card($id) {
+ $id=preg_replace('/[^\d]/','',$id);
+ if ($this->mod10($id)) {
+ if (preg_match('/^3[47][0-9]{13}$/',$id))
+ return 'American Express';
+ if (preg_match('/^3(?:0[0-5]|[68][0-9])[0-9]{11}$/',$id))
+ return 'Diners Club';
+ if (preg_match('/^6(?:011|5[0-9][0-9])[0-9]{12}$/',$id))
+ return 'Discover';
+ if (preg_match('/^(?:2131|1800|35\d{3})\d{11}$/',$id))
+ return 'JCB';
+ if (preg_match('/^5[1-5][0-9]{14}$/',$id))
+ return 'MasterCard';
+ if (preg_match('/^4[0-9]{12}(?:[0-9]{3})?$/',$id))
+ return 'Visa';
+ }
+ return FALSE;
+ }
+
+ /**
+ * Return entropy estimate of a password (NIST 800-63)
+ * @return int|float
+ * @param $str string
+ **/
+ function entropy($str) {
+ $len=strlen($str);
+ return 4*min($len,1)+($len>1?(2*(min($len,8)-1)):0)+
+ ($len>8?(1.5*(min($len,20)-8)):0)+($len>20?($len-20):0)+
+ 6*(bool)(preg_match(
+ '/[A-Z].*?[0-9[:punct:]]|[0-9[:punct:]].*?[A-Z]/',$str));
+ }
+
+}
diff --git a/management-interface/lib/auth.php b/management-interface/lib/auth.php
new file mode 100644
index 0000000..78a068c
--- /dev/null
+++ b/management-interface/lib/auth.php
@@ -0,0 +1,233 @@
+mapper,'load'),
+ array(
+ array_merge(
+ array(
+ '@'.$this->args['id'].'==? AND '.
+ '@'.$this->args['pw'].'==?'.
+ (isset($this->args['realm'])?
+ (' AND @'.$this->args['realm'].'==?'):''),
+ $id,$pw
+ ),
+ (isset($this->args['realm'])?array($realm):array())
+ )
+ )
+ );
+ }
+
+ /**
+ * MongoDB storage handler
+ * @return bool
+ * @param $id string
+ * @param $pw string
+ * @param $realm string
+ **/
+ protected function _mongo($id,$pw,$realm) {
+ return (bool)
+ $this->mapper->load(
+ array(
+ $this->args['id']=>$id,
+ $this->args['pw']=>$pw
+ )+
+ (isset($this->args['realm'])?
+ array($this->args['realm']=>$realm):array())
+ );
+ }
+
+ /**
+ * SQL storage handler
+ * @return bool
+ * @param $id string
+ * @param $pw string
+ * @param $realm string
+ **/
+ protected function _sql($id,$pw,$realm) {
+ return (bool)
+ call_user_func_array(
+ array($this->mapper,'load'),
+ array(
+ array_merge(
+ array(
+ $this->args['id'].'=? AND '.
+ $this->args['pw'].'=?'.
+ (isset($this->args['realm'])?
+ (' AND '.$this->args['realm'].'=?'):''),
+ $id,$pw
+ ),
+ (isset($this->args['realm'])?array($realm):array())
+ )
+ )
+ );
+ }
+
+ /**
+ * LDAP storage handler
+ * @return bool
+ * @param $id string
+ * @param $pw string
+ **/
+ protected function _ldap($id,$pw) {
+ $dc=@ldap_connect($this->args['dc']);
+ if ($dc &&
+ ldap_set_option($dc,LDAP_OPT_PROTOCOL_VERSION,3) &&
+ ldap_set_option($dc,LDAP_OPT_REFERRALS,0) &&
+ ldap_bind($dc,$this->args['rdn'],$this->args['pw']) &&
+ ($result=ldap_search($dc,$this->args['base_dn'],
+ 'uid='.$id)) &&
+ ldap_count_entries($dc,$result) &&
+ ($info=ldap_get_entries($dc,$result)) &&
+ @ldap_bind($dc,$info[0]['dn'],$pw) &&
+ @ldap_close($dc)) {
+ return $info[0]['uid'][0]==$id;
+ }
+ user_error(self::E_LDAP);
+ }
+
+ /**
+ * SMTP storage handler
+ * @return bool
+ * @param $id string
+ * @param $pw string
+ **/
+ protected function _smtp($id,$pw) {
+ $socket=@fsockopen(
+ (strtolower($this->args['scheme'])=='ssl'?
+ 'ssl://':'').$this->args['host'],
+ $this->args['port']);
+ $dialog=function($cmd=NULL) use($socket) {
+ if (!is_null($cmd))
+ fputs($socket,$cmd."\r\n");
+ $reply='';
+ while (!feof($socket) &&
+ ($info=stream_get_meta_data($socket)) &&
+ !$info['timed_out'] && $str=fgets($socket,4096)) {
+ $reply.=$str;
+ if (preg_match('/(?:^|\n)\d{3} .+\r\n/s',
+ $reply))
+ break;
+ }
+ return $reply;
+ };
+ if ($socket) {
+ stream_set_blocking($socket,TRUE);
+ $dialog();
+ $fw=Base::instance();
+ $dialog('EHLO '.$fw->get('HOST'));
+ if (strtolower($this->args['scheme'])=='tls') {
+ $dialog('STARTTLS');
+ stream_socket_enable_crypto(
+ $socket,TRUE,STREAM_CRYPTO_METHOD_TLS_CLIENT);
+ $dialog('EHLO '.$fw->get('HOST'));
+ }
+ // Authenticate
+ $dialog('AUTH LOGIN');
+ $dialog(base64_encode($id));
+ $reply=$dialog(base64_encode($pw));
+ $dialog('QUIT');
+ fclose($socket);
+ return (bool)preg_match('/^235 /',$reply);
+ }
+ user_error(self::E_SMTP);
+ }
+
+ /**
+ * Login auth mechanism
+ * @return bool
+ * @param $id string
+ * @param $pw string
+ * @param $realm string
+ **/
+ function login($id,$pw,$realm=NULL) {
+ return $this->{'_'.$this->storage}($id,$pw,$realm);
+ }
+
+ /**
+ * HTTP basic auth mechanism
+ * @return bool
+ * @param $func callback
+ **/
+ function basic($func=NULL) {
+ $fw=Base::instance();
+ $realm=$fw->get('REALM');
+ $hdr=NULL;
+ if (isset($_SERVER['HTTP_AUTHORIZATION']))
+ $hdr=$_SERVER['HTTP_AUTHORIZATION'];
+ elseif (isset($_SERVER['REDIRECT_HTTP_AUTHORIZATION']))
+ $hdr=$_SERVER['REDIRECT_HTTP_AUTHORIZATION'];
+ if (!empty($hdr))
+ list($_SERVER['PHP_AUTH_USER'],$_SERVER['PHP_AUTH_PW'])=
+ explode(':',base64_decode(substr($hdr,6)));
+ if (isset($_SERVER['PHP_AUTH_USER'],$_SERVER['PHP_AUTH_PW']) &&
+ $this->login(
+ $_SERVER['PHP_AUTH_USER'],
+ $func?
+ $fw->call($func,$_SERVER['PHP_AUTH_PW']):
+ $_SERVER['PHP_AUTH_PW'],
+ $realm
+ ))
+ return TRUE;
+ if (PHP_SAPI!='cli')
+ header('WWW-Authenticate: Basic realm="'.$realm.'"');
+ $fw->status(401);
+ return FALSE;
+ }
+
+ /**
+ * Instantiate class
+ * @return object
+ * @param $storage string|object
+ * @param $args array
+ **/
+ function __construct($storage,array $args=NULL) {
+ if (is_object($storage) && is_a($storage,'DB\Cursor')) {
+ $this->storage=$storage->dbtype();
+ $this->mapper=$storage;
+ unset($ref);
+ }
+ else
+ $this->storage=$storage;
+ $this->args=$args;
+ }
+
+}
diff --git a/management-interface/lib/basket.php b/management-interface/lib/basket.php
new file mode 100644
index 0000000..3db2b5d
--- /dev/null
+++ b/management-interface/lib/basket.php
@@ -0,0 +1,229 @@
+item);
+ }
+
+ /**
+ * Assign value to field
+ * @return scalar|FALSE
+ * @param $key string
+ * @param $val scalar
+ **/
+ function set($key,$val) {
+ return ($key=='_id')?FALSE:($this->item[$key]=$val);
+ }
+
+ /**
+ * Retrieve value of field
+ * @return scalar|FALSE
+ * @param $key string
+ **/
+ function get($key) {
+ if ($key=='_id')
+ return $this->id;
+ if (array_key_exists($key,$this->item))
+ return $this->item[$key];
+ user_error(sprintf(self::E_Field,$key));
+ return FALSE;
+ }
+
+ /**
+ * Delete field
+ * @return NULL
+ * @param $key string
+ **/
+ function clear($key) {
+ unset($this->item[$key]);
+ }
+
+ /**
+ * Return items that match key/value pair;
+ * If no key/value pair specified, return all items
+ * @return array|FALSE
+ * @param $key string
+ * @param $val mixed
+ **/
+ function find($key=NULL,$val=NULL) {
+ if (isset($_SESSION[$this->key])) {
+ $out=array();
+ foreach ($_SESSION[$this->key] as $id=>$item)
+ if (!isset($key) ||
+ array_key_exists($key,$item) && $item[$key]==$val) {
+ $obj=clone($this);
+ $obj->id=$id;
+ $obj->item=$item;
+ $out[]=$obj;
+ }
+ return $out;
+ }
+ return FALSE;
+ }
+
+ /**
+ * Return first item that matches key/value pair
+ * @return object|FALSE
+ * @param $key string
+ * @param $val mixed
+ **/
+ function findone($key,$val) {
+ return ($data=$this->find($key,$val))?$data[0]:FALSE;
+ }
+
+ /**
+ * Map current item to matching key/value pair
+ * @return array
+ * @param $key string
+ * @param $val mixed
+ **/
+ function load($key,$val) {
+ if ($found=$this->find($key,$val)) {
+ $this->id=$found[0]->id;
+ return $this->item=$found[0]->item;
+ }
+ $this->reset();
+ return array();
+ }
+
+ /**
+ * Return TRUE if current item is empty/undefined
+ * @return bool
+ **/
+ function dry() {
+ return !$this->item;
+ }
+
+ /**
+ * Return number of items in basket
+ * @return int
+ **/
+ function count() {
+ return isset($_SESSION[$this->key])?count($_SESSION[$this->key]):0;
+ }
+
+ /**
+ * Save current item
+ * @return array
+ **/
+ function save() {
+ if (!$this->id)
+ $this->id=uniqid(NULL,TRUE);
+ $_SESSION[$this->key][$this->id]=$this->item;
+ return $this->item;
+ }
+
+ /**
+ * Erase item matching key/value pair
+ * @return bool
+ * @param $key string
+ * @param $val mixed
+ **/
+ function erase($key,$val) {
+ $found=$this->find($key,$val);
+ if ($found && $id=$found[0]->id) {
+ unset($_SESSION[$this->key][$id]);
+ if ($id==$this->id)
+ $this->reset();
+ return TRUE;
+ }
+ return FALSE;
+ }
+
+ /**
+ * Reset cursor
+ * @return NULL
+ **/
+ function reset() {
+ $this->id=NULL;
+ $this->item=array();
+ }
+
+ /**
+ * Empty basket
+ * @return NULL
+ **/
+ function drop() {
+ unset($_SESSION[$this->key]);
+ }
+
+ /**
+ * Hydrate item using hive array variable
+ * @return NULL
+ * @param $key string
+ **/
+ function copyfrom($key) {
+ foreach (\Base::instance()->get($key) as $key=>$val)
+ $this->item[$key]=$val;
+ }
+
+ /**
+ * Populate hive array variable with item contents
+ * @return NULL
+ * @param $key string
+ **/
+ function copyto($key) {
+ $var=&\Base::instance()->ref($key);
+ foreach ($this->item as $key=>$field)
+ $var[$key]=$field;
+ }
+
+ /**
+ * Check out basket contents
+ * @return array
+ **/
+ function checkout() {
+ if (isset($_SESSION[$this->key])) {
+ $out=$_SESSION[$this->key];
+ unset($_SESSION[$this->key]);
+ return $out;
+ }
+ return array();
+ }
+
+ /**
+ * Instantiate class
+ * @return void
+ * @param $key string
+ **/
+ function __construct($key='basket') {
+ $this->key=$key;
+ @session_start();
+ Base::instance()->sync('SESSION');
+ $this->reset();
+ }
+
+}
diff --git a/management-interface/lib/bcrypt.php b/management-interface/lib/bcrypt.php
new file mode 100644
index 0000000..311c1e3
--- /dev/null
+++ b/management-interface/lib/bcrypt.php
@@ -0,0 +1,89 @@
+31)
+ user_error(self::E_CostArg);
+ $len=22;
+ if ($salt) {
+ if (!preg_match('/^[[:alnum:]\.\/]{'.$len.',}$/',$salt))
+ user_error(self::E_SaltArg);
+ }
+ else {
+ $raw=16;
+ $iv='';
+ if (extension_loaded('mcrypt'))
+ $iv=mcrypt_create_iv($raw,MCRYPT_DEV_URANDOM);
+ if (!$iv && extension_loaded('openssl'))
+ $iv=openssl_random_pseudo_bytes($raw);
+ if (!$iv)
+ for ($i=0;$i<$raw;$i++)
+ $iv.=chr(mt_rand(0,255));
+ $salt=str_replace('+','.',base64_encode($iv));
+ }
+ $salt=substr($salt,0,$len);
+ $hash=crypt($pw,sprintf('$2y$%02d$',$cost).$salt);
+ return strlen($hash)>13?$hash:FALSE;
+ }
+
+ /**
+ * Check if password is still strong enough
+ * @return bool
+ * @param $hash string
+ * @param $cost int
+ **/
+ function needs_rehash($hash,$cost=self::COST) {
+ list($pwcost)=sscanf($hash,"$2y$%d$");
+ return $pwcost<$cost;
+ }
+
+ /**
+ * Verify password against hash using timing attack resistant approach
+ * @return bool
+ * @param $pw string
+ * @param $hash string
+ **/
+ function verify($pw,$hash) {
+ $val=crypt($pw,$hash);
+ $len=strlen($val);
+ if ($len!=strlen($hash) || $len<14)
+ return FALSE;
+ $out=0;
+ for ($i=0;$i<$len;$i++)
+ $out|=(ord($val[$i])^ord($hash[$i]));
+ return $out===0;
+ }
+
+}
diff --git a/management-interface/lib/changelog.txt b/management-interface/lib/changelog.txt
new file mode 100644
index 0000000..7ae905b
--- /dev/null
+++ b/management-interface/lib/changelog.txt
@@ -0,0 +1,416 @@
+CHANGELOG
+
+3.2.2 (19 March 2014)
+* NEW: Locales set automatically (Feature request #522)
+* NEW: Mapper dbtype()
+* NEW: before- and after- triggers for all mappers
+* NEW: Decode HTML5 entities if PHP>5.3 detected (Feature request #552)
+* NEW: Send credentials only if AUTH is present in the SMTP extension
+ response (Feature request #545)
+* NEW: BITMASK variable to allow ENT_COMPAT override
+* NEW: Redis support for caching
+* Enable SMTP feature detection
+* Enable extended ICU custom date format (Feature request #555)
+* Enable custom time ICU format
+* Add option to turn off session table creation (Feature request #557)
+* Enhanced template token rendering and custom filters (Feature request
+ #550)
+* Avert multiple loads in DB-managed sessions (Feature request #558)
+* Add EXEC to associative fetch
+* Bug fix: Building template tokens breaks on inline OR condition (Issue
+ #573)
+* Bug fix: SMTP->send does not use the $log parameter (Issue #571)
+* Bug fix: Allow setting sqlsrv primary keys on insert (Issue #570)
+* Bug fix: Generated query for obtaining table schema in sqlsrv incorrect
+ (Bug #565)
+* Bug fix: SQL mapper flag set even when value has not changed (Bug #562)
+* Bug fix: Add XFRAME config option (Feature request #546)
+* Bug fix: Incorrect parsing of comments (Issue #541)
+* Bug fix: Multiple Set-Cookie headers (Issue #533)
+* Bug fix: Mapper is dry after save()
+* Bug fix: Prevent infinite loop when error handler is triggered
+ (Issue #361)
+* Bug fix: Mapper tweaks not passing primary keys as arguments
+* Bug fix: Zero indexes in dot-notated arrays fail to compile
+* Bug fix: Prevent GROUP clause double-escaping
+* Bug fix: Regression of zlib compression bug
+* Bug fix: Method copyto() does not include ad hoc fields
+* Check existence of OpenID mode (Issue #529)
+* Generate a 404 when a tokenized class doesn't exist
+* Fix SQLite quotes (Issue #521)
+* Bug fix: BASE is incorrect on Windows
+
+3.2.1 (7 January 2014)
+* NEW: EMOJI variable, UTF->translate(), UTF->emojify(), and UTF->strrev()
+* Allow empty strings in config()
+* Add support for turning off php://input buffering via RAW
+ (FALSE by default)
+* Add Cursor->load() and Cursor->find() TTL support
+* Support Web->receive() large file downloads via PUT
+* ONERROR safety check
+* Fix session CSRF cookie detection
+* Framework object now passed to route handler contructors
+* Allow override of DIACRITICS
+* Various code optimizations
+* Support log disabling (Issue #483)
+* Implicit mapper load() on authentication
+* Declare abstract methods for Cursor derivatives
+* Support single-quoted HTML/XML attributes (Feature request #503)
+* Relax property visibility of mappers and derivatives
+* Deprecated: {{~ ~}} instructions and {{* *}} comments; Use {~ ~} and
+ {* *} instead
+* Minor fix: Audit->ipv4() return value
+* Bug fix: Backslashes in BASE not converted on Windows
+* Bug fix: UTF->substr() with negative offset and specified length
+* Bug fix: Replace named URL tokens on render()
+* Bug fix: BASE is not empty when run from document root
+* Bug fix: stringify() recursion
+
+3.2.0 (18 December 2013)
+* NEW: Automatic CSRF protection (with IP and User-Agent checks) for
+ sessions mapped to SQL-, Jig-, Mongo- and Cache-based backends
+* NEW: Named routes
+* NEW: PATH variable; returns the URL relative to BASE
+* NEW: Image->captcha() color parameters
+* NEW: Ability to access MongoCuror thru the cursor() method
+* NEW: Mapper->fields() method returns array of field names
+* NEW: Mapper onload(), oninsert(), onupdate(), and onerase() event
+ listeners/triggers
+* NEW: Preview class (a lightweight template engine)
+* NEW: rel() method derives path from URL relative to BASE; useful for
+ rerouting
+* NEW: PREFIX variable for prepending a string to a dictionary term;
+ Enable support for prefixed dictionary arrays and .ini files (Feature
+ request #440)
+* NEW: Google static map plugin
+* NEW: devoid() method
+* Introduce clean(); similar to scrub(), except that arg is passed by
+ value
+* Use $ttl for cookie expiration (Issue #457)
+* Fix needs_rehash() cost comparison
+* Add pass-by-reference argument to exists() so if method returns TRUE,
+ a subsequent get() is unnecessary
+* Improve MySQL support
+* Move esc(), raw(), and dupe() to View class where they more
+ appropriately belong
+* Allow user-defined fields in SQL mapper constructor (Feature request
+ #450)
+* Re-implement the pre-3.0 template resolve() feature
+* Remove redundant instances of session_commit()
+* Add support for input filtering in Mapper->copyfrom()
+* Prevent intrusive behavior of Mapper->copyfrom()
+* Support multiple SQL primary keys
+* Support custom tag attributes/inline tokens defined at runtime
+ (Feature request #438)
+* Broader support for HTTP basic auth
+* Prohibit Jig _id clear()
+* Add support for detailed stringify() output
+* Add base directory to UI path as fallback
+* Support Test->expect() chaining
+* Support __tostring() in stringify()
+* Trigger error on invalid CAPTCHA length (Issue #458)
+* Bug fix: exists() pass-by-reference argument returns incorrect value
+* Bug fix: DB Exec does not return affected row if query contains a
+ sub-SELECT (Issue #437)
+* Improve seed generator and add code for detecting of acceptable
+ limits in Image->captcha() (Feature request #460)
+* Add decimal format ICU extension
+* Bug fix: 404-reported URI contains HTTP query
+* Bug fix: Data type detection in DB->schema()
+* Bug fix: TZ initialization
+* Bug fix: paginate() passes incorrect argument to count()
+* Bug fix: Incorrect query when reloading after insert()
+* Bug fix: SQL preg_match error in pdo_type matching (Issue #447)
+* Bug fix: Missing merge() function (Issue #444)
+* Bug fix: BASE misdefined in command line mode
+* Bug fix: Stringifying hive may run infinite (Issue #436)
+* Bug fix: Incomplete stringify() when DEBUG<3 (Issue #432)
+* Bug fix: Redirection of basic auth (Issue #430)
+* Bug fix: Filter only PHP code (including short tags) in templates
+* Bug fix: Markdown paragraph parser does not convert PHP code blocks
+ properly
+* Bug fix: identicon() colors on same keys are randomized
+* Bug fix: quotekey() fails on aliased keys
+* Bug fix: Missing _id in Jig->find() return value
+* Bug fix: LANGUAGE/LOCALES handling
+* Bug fix: Loose comparison in stringify()
+
+3.1.2 (5 November 2013)
+* Abandon .chm help format; Package API documentation in plain HTML;
+ (Launch lib/api/index.html in your browser)
+* Deprecate BAIL in favor of HALT (default: TRUE)
+* Revert to 3.1.0 autoload behavior; Add support for lowercase folder
+ names
+* Allow Spring-style HTTP method overrides
+* Add support for SQL Server-based sessions
+* Capture full X-Forwarded-For header
+* Add protection against malicious scripts; Extra check if file was really
+ uploaded
+* Pass-thru page limit in return value of Cursor->paginate()
+* Optimize code: Implement single-pass escaping
+* Short circuit Jig->find() if source file is empty
+* Bug fix: PHP globals passed by reference in hive() result (Issue #424)
+* Bug fix: ZIP mime type incorrect behavior
+* Bug fix: Jig->erase() filter malfunction
+* Bug fix: Mongo->select() group
+* Bug fix: Unknown bcrypt constant
+
+3.1.1 (13 October 2013)
+* NEW: Support OpenID attribute exchange
+* NEW: BAIL variable enables/disables continuance of execution on non-fatal
+ errors
+* Deprecate BAIL in favor of HALT (default: FALSE)
+* Add support for Oracle
+* Mark cached queries in log (Feature Request #405)
+* Implement Bcrypt->needs_reshash()
+* Add entropy to SQL cache hash; Add uuid() method to DB backends
+* Find real document root; Simplify debug paths
+* Permit OpenID required fields to be declared as comma-separated string or
+ array
+* Pass modified filename as argument to user-defined function in
+ Web->receive()
+* Quote keys in optional SQL clauses (Issue #408)
+* Allow UNLOAD to override fatal error detection (Issue #404)
+* Mutex operator precedence error (Issue #406)
+* Bug fix: exists() malfunction (Issue #401)
+* Bug fix: Jig mapper triggers error when loading from CACHE (Issue #403)
+* Bug fix: Array index check
+* Bug fix: OpenID verified() return value
+* Bug fix: Basket->find() should return a set of results (Issue #407);
+ Also implemented findone() for consistency with mappers
+* Bug fix: PostgreSQL last insert ID (Issue #410)
+* Bug fix: $port component URL overwritten by _socket()
+* Bug fix: Calculation of elapsed time
+
+3.1.0 (20 August 2013)
+* NEW: Web->filler() returns a chunk of text from the standard
+ Lorem Ipsum passage
+* Change in behavior: Drop support for JSON serialization
+* SQL->exec() now returns value of RETURNING clause
+* Add support for $ttl argument in count() (Issue #393)
+* Allow UI to be overridden by custom $path
+* Return result of PDO primitives: begintransaction(), rollback(), and
+ commit()
+* Full support for PHP 5.5
+* Flush buffers only when DEBUG=0
+* Support class->method, class::method, and lambda functions as
+ Web->basic() arguments
+* Commit session on Basket->save()
+* Optional enlargement in Image->resize()
+* Support authentication on hosts running PHP-CGI
+* Change visibility level of Cache properties
+* Prevent ONERROR recursion
+* Work around Apache pre-2.4 VirtualDocumentRoot bug
+* Prioritize cURL in HTTP engine detection
+* Bug fix: Minify tricky JS
+* Bug fix: desktop() detection
+* Bug fix: Double-slash on TEMP-relative path
+* Bug fix: Cursor mapping of first() and last() records
+* Bug fix: Premature end of Web->receive() on multiple files
+* Bug fix: German umlaute to its corresponding grammatically-correct
+ equivalent
+
+3.0.9 (12 June 2013)
+* NEW: Web->whois()
+* NEW: Template tags
+* Improve CACHE consistency
+* Case-insensitive MIME type detection
+* Support pre-PHP 5.3.4 in Prefab->instance()
+* Refactor isdesktop() and ismobile(); Add isbot()
+* Add support for Markdown strike-through
+* Work around ODBC's lack of quote() support
+* Remove useless Prefab destructor
+* Support multiple cache instances
+* Bug fix: Underscores in OpenId keys mangled
+* Refactor format()
+* Numerous tweaks
+* Bug fix: MongoId object not preserved
+* Bug fix: Double-quotes included in lexicon() string (Issue #341)
+* Bug fix: UTF-8 formatting mangled on Windows (Issue #342)
+* Bug fix: Cache->load() error when CACHE is FALSE (Issue #344)
+* Bug fix: send() ternary expression
+* Bug fix: Country code constants
+
+3.0.8 (17 May 2013)
+* NEW: Bcrypt lightweight hashing library\
+* Return total number of records in superset in Cursor->paginate()
+* ONERROR short-circuit (Enhancement #334)
+* Apply quotes/backticks on DB identifiers
+* Allow enabling/disabling of SQL log
+* Normalize glob() behavior (Issue #330)
+* Bug fix: mbstring 2-byte text truncation (Issue #325)
+* Bug fix: Unsupported operand types (Issue #324)
+
+3.0.7 (2 May 2013)
+* NEW: route() now allows an array of routing patterns as first argument;
+ support array as first argument of map()
+* NEW: entropy() for calculating password strength (NIST 800-63)
+* NEW: AGENT variable containing auto-detected HTTP user agent string
+* NEW: ismobile() and isdesktop() methods
+* NEW: Prefab class and descendants now accept constructor arguments
+* Change in behavior: Cache->exists() now returns timestamp and TTL of
+ cache entry or FALSE if not found (Feature request #315)
+* Preserve timestamp and TTL when updating cache entry (Feature request
+ #316)
+* Improved currency formatting with C99 compliance
+* Suppress unnecessary program halt at startup caused by misconfigured
+ server
+* Add support for dashes in custom attribute names in templates
+* Bug fix: Routing precedene (Issue #313)
+* Bug fix: Remove Jig _id element from document property
+* Bug fix: Web->rss() error when not enough items in the feed (Issue #299)
+* Bug fix: Web engine fallback (Issue #300)
+* Bug fix: and formatting
+* Bug fix: Text rendering of text with trailing punctuation (Issue #303)
+* Bug fix: Incorrect regex in SMTP
+
+3.0.6 (31 Mar 2013)
+* NEW: Image->crop()
+* Modify documentation blocks for PHPDoc interoperability
+* Allow user to control whether Base->rerouet() uses a permanent or
+ temporary redirect
+* Allow JAR elements to be set individually
+* Refactor DB\SQL\Mapper->insert() to cope with autoincrement fields
+* Trigger error when captcha() font is missing
+* Remove unnecessary markdown regex recursion
+* Check for scalars instead of DB\SQL strings
+* Implement more comprehensive diacritics table
+* Add option for disabling 401 errors when basic auth() fails
+* Add markdown syntax highlighting for Apache configuration
+* Markdown->render() deprecated to remove dependency on UI variable;
+ Feature replaced by Markdown->convert() to enable translation from
+ markdown string to HTML
+* Optimize factory() code of all data mappers
+* Apply backticks on MySQL table names
+* Bug fix: Routing failure when directory path contains a tilde (Issue #291)
+* Bug fix: Incorrect markdown parsing of strong/em sequences and inline HTML
+* Bug fix: Cached page not echoed (Issue #278)
+* Bug fix: Object properties not escaped when rendering
+* Bug fix: OpenID error response ignored
+* Bug fix: memcache_get_extended_stats() timeout
+* Bug fix: Base->set() doesn't pass TTL to Cache->set()
+* Bug fix: Base->scrub() ignores pass-thru * argument (Issue #274)
+
+3.0.5 (16 Feb 2013)
+* NEW: Markdown class with PHP, HTML, and .ini syntax highlighting support
+* NEW: Options for caching of select() and find() results
+* NEW: Web->acceptable()
+* Add send() argument for forcing downloads
+* Provide read() option for applying Unix LF as standard line ending
+* Bypass lexicon() call if LANGUAGE is undefined
+* Load fallback language dictionary if LANGUAGE is undefined
+* map() now checks existence of class/methods for non-tokenized URLs
+* Improve error reporting of non-existent Template methods
+* Address output buffer issues on some servers
+* Bug fix: Setting DEBUG to 0 won't suppress the stack trace when the
+ content type is application/json (Issue #257)
+* Bug fix: Image dump/render additional arguments shifted
+* Bug fix: ob_clean() causes buffer issues with zlib compression
+* Bug fix: minify() fails when commenting CSS @ rules (Issue #251)
+* Bug fix: Handling of commas inside quoted strings
+* Bug fix: Glitch in stringify() handling of closures
+* Bug fix: dry() in mappers returns TRUE despite being hydrated by
+ factory() (Issue #265)
+* Bug fix: expect() not handling flags correctly
+* Bug fix: weather() fails when server is unreachable
+
+3.0.4 (29 Jan 2013)
+* NEW: Support for ICU/CLDR pluralization
+* NEW: User-defined FALLBACK language
+* NEW: minify() now recognizes CSS @import directives
+* NEW: UTF->bom() returns byte order mark for UTF-8 encoding
+* Expose SQL\Mapper->schema()
+* Change in behavior: Send error response as JSON string if AJAX request is
+ detected
+* Deprecated: afind*() methods
+* Discard output buffer in favor of debug output
+* Make _id available to Jig queries
+* Magic class now implements ArrayAccess
+* Abort execution on startup errors
+* Suppress stack trace on DEBUG level 0
+* Allow single = as equality operator in Jig query expressions
+* Abort OpenID discovery if Web->request() fails
+* Mimic PHP *RECURSION* in stringify()
+* Modify Jig parser to allow wildcard-search using preg_match()
+* Abort execution after error() execution
+* Concatenate cached/uncached minify() iterations; Prevent spillover
+ caching of previous minify() result
+* Work around obscure PHP session id regeneration bug
+* Revise algorithm for Jig filter involving undefined fields (Issue #230)
+* Use checkdnsrr() instead of gethostbyname() in DNSBL check
+* Auto-adjust pagination to cursor boundaries
+* Add Romanian diacritics
+* Bug fix: Root namespace reference and sorting with undefined Jig fields
+* Bug fix: Greedy receive() regex
+* Bug fix: Default LANGUAGE always 'en'
+* Bug fix: minify() hammers cache backend
+* Bug fix: Previous values of primary keys not saved during factory()
+ instantiation
+* Bug fix: Jig find() fails when search key is not present in all records
+* Bug fix: Jig SORT_DESC (Issue #233)
+* Bug fix: Error reporting (Issue #225)
+* Bug fix: language() return value
+
+3.0.3 (29 Dec 2013)
+* NEW: [ajax] and [sync] routing pattern modifiers
+* NEW: Basket class (session-based pseudo-mapper, shopping cart, etc.)
+* NEW: Test->message() method
+* NEW: DB profiling via DB->log()
+* NEW: Matrix->calendar()
+* NEW: Audit->card() and Audit->mod10() for credit card verification
+* NEW: Geo->weather()
+* NEW: Base->relay() accepts comma-separated callbacks; but unlike
+ Base->chain(), result of previous callback becomes argument of the next
+* Numerous performance tweaks
+* Interoperability with new MongoClient class
+* Web->request() now recognizes gzip and deflate encoding
+* Differences in behavior of Web->request() engines rectified
+* mutex() now uses an ID as argument (instead of filename to make it clear
+ that specified file is not the target being locked, but a primitive
+ cross-platform semaphore)
+* DB\SQL\Mapper field _id now returned even in the absence of any
+ auto-increment field
+* Magic class spinned off as a separate file
+* ISO 3166-1 alpha-2 table updated
+* Apache redirect emulation for PHP 5.4 CLI server mode
+* Framework instance now passed as argument to any user-defined shutdown
+ function
+* Cache engine now used as storage for Web->minify() output
+* Flag added for enabling/disabling Image class filter history
+* Bug fix: Trailing routing token consumes HTTP query
+* Bug fix: LANGUAGE spills over to LOCALES setting
+* Bug fix: Inconsistent dry() return value
+* Bug fix: URL-decoding
+
+3.0.2 (23 Dec 2013)
+* NEW: Syntax-highlighted stack traces via Base->highlight(); boolean
+ HIGHLIGHT global variable can be used to enable/disable this feature
+* NEW: Template engine tag
+* NEW: Image->captcha()
+* NEW: DNSBL-based spammer detection (ported from 2.x)
+* NEW: paginate(), first(), and last() methods for data mappers
+* NEW: X-HTTP-Method-Override header now recognized
+* NEW: Base->chain() method for executing callbacks in succession
+* NEW: HOST global variable; derived from either $_SERVER['SERVER_NAME'] or
+ gethostname()
+* NEW: REALM global variable representing full canonical URI
+* NEW: Auth plug-in
+* NEW: Pingback plug-in (implements both Pingback 1.0 protocol client and
+ server)
+* NEW: DEBUG verbosity can now reach up to level 3; Base->stringify() drills
+ down to object properties at this setting
+* NEW: HTTP PATCH method added to recognized HTTP ReST methods
+* Web->slug() now trims trailing dashes
+* Web->request() now allows relative local URLs as argument
+* Use of PARAMS in route handlers now unnecessary; framework now passes two
+ arguments to route handlers: the framework object instance and an array
+ containing the captured values of tokens in route patterns
+* Standardized timeout settings among Web->request() backends
+* Session IDs regenerated for additional security
+* Automatic HTTP 404 responses by Base->call() now restricted to route
+ handlers
+* Empty comments in ini-style files now parsed properly
+* Use file_get_contents() in methods that don't involve high concurrency
+
+3.0.1 (14 Dec 2013)
+* Major rewrite of much of the framework's core features
diff --git a/management-interface/lib/code.css b/management-interface/lib/code.css
new file mode 100644
index 0000000..618703f
--- /dev/null
+++ b/management-interface/lib/code.css
@@ -0,0 +1 @@
+code{word-wrap:break-word;color:black}.comment,.doc_comment,.ml_comment{color:dimgray;font-style:italic}.variable{color:blueviolet}.const,.constant_encapsed_string,.class_c,.dir,.file,.func_c,.halt_compiler,.line,.method_c,.lnumber,.dnumber{color:crimson}.string,.and_equal,.boolean_and,.boolean_or,.concat_equal,.dec,.div_equal,.inc,.is_equal,.is_greater_or_equal,.is_identical,.is_not_equal,.is_not_identical,.is_smaller_or_equal,.logical_and,.logical_or,.logical_xor,.minus_equal,.mod_equal,.mul_equal,.ns_c,.ns_separator,.or_equal,.plus_equal,.sl,.sl_equal,.sr,.sr_equal,.xor_equal,.start_heredoc,.end_heredoc,.object_operator,.paamayim_nekudotayim{color:black}.abstract,.array,.array_cast,.as,.break,.case,.catch,.class,.clone,.continue,.declare,.default,.do,.echo,.else,.elseif,.empty.enddeclare,.endfor,.endforach,.endif,.endswitch,.endwhile,.eval,.exit,.extends,.final,.for,.foreach,.function,.global,.goto,.if,.implements,.include,.include_once,.instanceof,.interface,.isset,.list,.namespace,.new,.print,.private,.public,.protected,.require,.require_once,.return,.static,.switch,.throw,.try,.unset,.use,.var,.while{color:royalblue}.open_tag,.open_tag_with_echo,.close_tag{color:orange}.ini_section{color:black}.ini_key{color:royalblue}.ini_value{color:crimson}.xml_tag{color:dodgerblue}.xml_attr{color:blueviolet}.xml_data{color:red}.section{color:black}.directive{color:blue}.data{color:dimgray}
diff --git a/management-interface/lib/db/cursor.php b/management-interface/lib/db/cursor.php
new file mode 100644
index 0000000..354c683
--- /dev/null
+++ b/management-interface/lib/db/cursor.php
@@ -0,0 +1,313 @@
+query[$this->ptr]);
+ }
+
+ /**
+ * Return first record (mapper object) that matches criteria
+ * @return object|FALSE
+ * @param $filter string|array
+ * @param $options array
+ * @param $ttl int
+ **/
+ function findone($filter=NULL,array $options=NULL,$ttl=0) {
+ return ($data=$this->find($filter,$options,$ttl))?$data[0]:FALSE;
+ }
+
+ /**
+ * Return array containing subset of records matching criteria,
+ * total number of records in superset, specified limit, number of
+ * subsets available, and actual subset position
+ * @return array
+ * @param $pos int
+ * @param $size int
+ * @param $filter string|array
+ * @param $options array
+ * @param $ttl int
+ **/
+ function paginate(
+ $pos=0,$size=10,$filter=NULL,array $options=NULL,$ttl=0) {
+ $total=$this->count($filter,$ttl);
+ $count=ceil($total/$size);
+ $pos=max(0,min($pos,$count-1));
+ return array(
+ 'subset'=>$this->find($filter,
+ array_merge(
+ $options?:array(),
+ array('limit'=>$size,'offset'=>$pos*$size)
+ ),
+ $ttl
+ ),
+ 'total'=>$total,
+ 'limit'=>$size,
+ 'count'=>$count,
+ 'pos'=>$pos<$count?$pos:0
+ );
+ }
+
+ /**
+ * Map to first record that matches criteria
+ * @return array|FALSE
+ * @param $filter string|array
+ * @param $options array
+ * @param $ttl int
+ **/
+ function load($filter=NULL,array $options=NULL,$ttl=0) {
+ return ($this->query=$this->find($filter,$options,$ttl)) &&
+ $this->skip(0)?$this->query[$this->ptr=0]:FALSE;
+ }
+
+ /**
+ * Map to first record in cursor
+ * @return mixed
+ **/
+ function first() {
+ return $this->skip(-$this->ptr);
+ }
+
+ /**
+ * Map to last record in cursor
+ * @return mixed
+ **/
+ function last() {
+ return $this->skip(($ofs=count($this->query)-$this->ptr)?$ofs-1:0);
+ }
+
+ /**
+ * Map to nth record relative to current cursor position
+ * @return mixed
+ * @param $ofs int
+ **/
+ function skip($ofs=1) {
+ $this->ptr+=$ofs;
+ return $this->ptr>-1 && $this->ptrquery)?
+ $this->query[$this->ptr]:FALSE;
+ }
+
+ /**
+ * Map next record
+ * @return mixed
+ **/
+ function next() {
+ return $this->skip();
+ }
+
+ /**
+ * Map previous record
+ * @return mixed
+ **/
+ function prev() {
+ return $this->skip(-1);
+ }
+
+ /**
+ * Save mapped record
+ * @return mixed
+ **/
+ function save() {
+ return $this->query?$this->update():$this->insert();
+ }
+
+ /**
+ * Delete current record
+ * @return int|bool
+ **/
+ function erase() {
+ $this->query=array_slice($this->query,0,$this->ptr,TRUE)+
+ array_slice($this->query,$this->ptr,NULL,TRUE);
+ $this->ptr=0;
+ }
+
+ /**
+ * Define onload trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function onload($func) {
+ return $this->trigger['load']=$func;
+ }
+
+ /**
+ * Define beforeinsert trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function beforeinsert($func) {
+ return $this->trigger['beforeinsert']=$func;
+ }
+
+ /**
+ * Define afterinsert trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function afterinsert($func) {
+ return $this->trigger['afterinsert']=$func;
+ }
+
+ /**
+ * Define oninsert trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function oninsert($func) {
+ return $this->afterinsert($func);
+ }
+
+ /**
+ * Define beforeupdate trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function beforeupdate($func) {
+ return $this->trigger['beforeupdate']=$func;
+ }
+
+ /**
+ * Define afterupdate trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function afterupdate($func) {
+ return $this->trigger['afterupdate']=$func;
+ }
+
+ /**
+ * Define onupdate trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function onupdate($func) {
+ return $this->afterupdate($func);
+ }
+
+ /**
+ * Define beforeerase trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function beforeerase($func) {
+ return $this->trigger['beforeerase']=$func;
+ }
+
+ /**
+ * Define aftererase trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function aftererase($func) {
+ return $this->trigger['aftererase']=$func;
+ }
+
+ /**
+ * Define onerase trigger
+ * @return callback
+ * @param $func callback
+ **/
+ function onerase($func) {
+ return $this->aftererase($func);
+ }
+
+ /**
+ * Reset cursor
+ * @return NULL
+ **/
+ function reset() {
+ $this->query=array();
+ $this->ptr=0;
+ }
+
+}
diff --git a/management-interface/lib/db/jig.php b/management-interface/lib/db/jig.php
new file mode 100644
index 0000000..16f2255
--- /dev/null
+++ b/management-interface/lib/db/jig.php
@@ -0,0 +1,133 @@
+dir.$file))
+ return array();
+ $raw=$fw->read($dst);
+ switch ($this->format) {
+ case self::FORMAT_JSON:
+ $data=json_decode($raw,TRUE);
+ break;
+ case self::FORMAT_Serialized:
+ $data=$fw->unserialize($raw);
+ break;
+ }
+ return $data;
+ }
+
+ /**
+ * Write data to file
+ * @return int
+ * @param $file string
+ * @param $data array
+ **/
+ function write($file,array $data=NULL) {
+ $fw=\Base::instance();
+ switch ($this->format) {
+ case self::FORMAT_JSON:
+ $out=json_encode($data,@constant('JSON_PRETTY_PRINT'));
+ break;
+ case self::FORMAT_Serialized:
+ $out=$fw->serialize($data);
+ break;
+ }
+ return $fw->write($this->dir.$file,$out);
+ }
+
+ /**
+ * Return directory
+ * @return string
+ **/
+ function dir() {
+ return $this->dir;
+ }
+
+ /**
+ * Return UUID
+ * @return string
+ **/
+ function uuid() {
+ return $this->uuid;
+ }
+
+ /**
+ * Return SQL profiler results
+ * @return string
+ **/
+ function log() {
+ return $this->log;
+ }
+
+ /**
+ * Jot down log entry
+ * @return NULL
+ * @param $frame string
+ **/
+ function jot($frame) {
+ if ($frame)
+ $this->log.=date('r').' '.$frame.PHP_EOL;
+ }
+
+ /**
+ * Clean storage
+ * @return NULL
+ **/
+ function drop() {
+ if ($glob=@glob($this->dir.'/*',GLOB_NOSORT))
+ foreach ($glob as $file)
+ @unlink($file);
+ }
+
+ /**
+ * Instantiate class
+ * @param $dir string
+ * @param $format int
+ **/
+ function __construct($dir,$format=self::FORMAT_JSON) {
+ if (!is_dir($dir))
+ mkdir($dir,\Base::MODE,TRUE);
+ $this->uuid=\Base::instance()->hash($this->dir=$dir);
+ $this->format=$format;
+ }
+
+}
diff --git a/management-interface/lib/db/jig/mapper.php b/management-interface/lib/db/jig/mapper.php
new file mode 100644
index 0000000..3ac3d21
--- /dev/null
+++ b/management-interface/lib/db/jig/mapper.php
@@ -0,0 +1,459 @@
+document);
+ }
+
+ /**
+ * Assign value to field
+ * @return scalar|FALSE
+ * @param $key string
+ * @param $val scalar
+ **/
+ function set($key,$val) {
+ return ($key=='_id')?FALSE:($this->document[$key]=$val);
+ }
+
+ /**
+ * Retrieve value of field
+ * @return scalar|FALSE
+ * @param $key string
+ **/
+ function get($key) {
+ if ($key=='_id')
+ return $this->id;
+ if (array_key_exists($key,$this->document))
+ return $this->document[$key];
+ user_error(sprintf(self::E_Field,$key));
+ return FALSE;
+ }
+
+ /**
+ * Delete field
+ * @return NULL
+ * @param $key string
+ **/
+ function clear($key) {
+ if ($key!='_id')
+ unset($this->document[$key]);
+ }
+
+ /**
+ * Convert array to mapper object
+ * @return object
+ * @param $id string
+ * @param $row array
+ **/
+ protected function factory($id,$row) {
+ $mapper=clone($this);
+ $mapper->reset();
+ $mapper->id=$id;
+ foreach ($row as $field=>$val)
+ $mapper->document[$field]=$val;
+ $mapper->query=array(clone($mapper));
+ if (isset($mapper->trigger['load']))
+ \Base::instance()->call($mapper->trigger['load'],$mapper);
+ return $mapper;
+ }
+
+ /**
+ * Return fields of mapper object as an associative array
+ * @return array
+ * @param $obj object
+ **/
+ function cast($obj=NULL) {
+ if (!$obj)
+ $obj=$this;
+ return $obj->document+array('_id'=>$this->id);
+ }
+
+ /**
+ * Convert tokens in string expression to variable names
+ * @return string
+ * @param $str string
+ **/
+ function token($str) {
+ $self=$this;
+ $str=preg_replace_callback(
+ '/(?stringify(substr($expr[1],1)):
+ (preg_match('/^\w+/',
+ $mix=$self->token($expr[2]))?
+ $fw->stringify($mix):
+ $mix)).
+ ']';
+ },
+ $token[1]
+ );
+ },
+ $str
+ );
+ return trim($str);
+ }
+
+ /**
+ * Return records that match criteria
+ * @return array|FALSE
+ * @param $filter array
+ * @param $options array
+ * @param $ttl int
+ * @param $log bool
+ **/
+ function find($filter=NULL,array $options=NULL,$ttl=0,$log=TRUE) {
+ if (!$options)
+ $options=array();
+ $options+=array(
+ 'order'=>NULL,
+ 'limit'=>0,
+ 'offset'=>0
+ );
+ $fw=\Base::instance();
+ $cache=\Cache::instance();
+ $db=$this->db;
+ $now=microtime(TRUE);
+ $data=array();
+ if (!$fw->get('CACHE') || !$ttl || !($cached=$cache->exists(
+ $hash=$fw->hash($this->db->dir().
+ $fw->stringify(array($filter,$options))).'.jig',$data)) ||
+ $cached[0]+$ttlread($this->file);
+ if (is_null($data))
+ return FALSE;
+ foreach ($data as $id=>&$doc) {
+ $doc['_id']=$id;
+ unset($doc);
+ }
+ if ($filter) {
+ if (!is_array($filter))
+ return FALSE;
+ // Normalize equality operator
+ $expr=preg_replace('/(?<=[^<>!=])=(?!=)/','==',$filter[0]);
+ // Prepare query arguments
+ $args=isset($filter[1]) && is_array($filter[1])?
+ $filter[1]:
+ array_slice($filter,1,NULL,TRUE);
+ $args=is_array($args)?$args:array(1=>$args);
+ $keys=$vals=array();
+ $tokens=array_slice(
+ token_get_all('token($expr)),1);
+ $data=array_filter($data,
+ function($_row) use($fw,$args,$tokens) {
+ $_expr='';
+ $ctr=0;
+ $named=FALSE;
+ foreach ($tokens as $token) {
+ if (is_string($token))
+ if ($token=='?') {
+ // Positional
+ $ctr++;
+ $key=$ctr;
+ }
+ else {
+ if ($token==':')
+ $named=TRUE;
+ else
+ $_expr.=$token;
+ continue;
+ }
+ elseif ($named &&
+ token_name($token[0])=='T_STRING') {
+ $key=':'.$token[1];
+ $named=FALSE;
+ }
+ else {
+ $_expr.=$token[1];
+ continue;
+ }
+ $_expr.=$fw->stringify(
+ is_string($args[$key])?
+ addcslashes($args[$key],'\''):
+ $args[$key]);
+ }
+ // Avoid conflict with user code
+ unset($fw,$tokens,$args,$ctr,$token,$key,$named);
+ extract($_row);
+ // Evaluate pseudo-SQL expression
+ return eval('return '.$_expr.';');
+ }
+ );
+ }
+ if (isset($options['order'])) {
+ $cols=$fw->split($options['order']);
+ uasort(
+ $data,
+ function($val1,$val2) use($cols) {
+ foreach ($cols as $col) {
+ $parts=explode(' ',$col,2);
+ $order=empty($parts[1])?
+ SORT_ASC:
+ constant($parts[1]);
+ $col=$parts[0];
+ if (!array_key_exists($col,$val1))
+ $val1[$col]=NULL;
+ if (!array_key_exists($col,$val2))
+ $val2[$col]=NULL;
+ list($v1,$v2)=array($val1[$col],$val2[$col]);
+ if ($out=strnatcmp($v1,$v2)*
+ (($order==SORT_ASC)*2-1))
+ return $out;
+ }
+ return 0;
+ }
+ );
+ }
+ $data=array_slice($data,
+ $options['offset'],$options['limit']?:NULL,TRUE);
+ if ($fw->get('CACHE') && $ttl)
+ // Save to cache backend
+ $cache->set($hash,$data,$ttl);
+ }
+ $out=array();
+ foreach ($data as $id=>&$doc) {
+ unset($doc['_id']);
+ $out[]=$this->factory($id,$doc);
+ unset($doc);
+ }
+ if ($log && isset($args)) {
+ if ($filter)
+ foreach ($args as $key=>$val) {
+ $vals[]=$fw->stringify(is_array($val)?$val[0]:$val);
+ $keys[]='/'.(is_numeric($key)?'\?':preg_quote($key)).'/';
+ }
+ $db->jot('('.sprintf('%.1f',1e3*(microtime(TRUE)-$now)).'ms) '.
+ $this->file.' [find] '.
+ ($filter?preg_replace($keys,$vals,$filter[0],1):''));
+ }
+ return $out;
+ }
+
+ /**
+ * Count records that match criteria
+ * @return int
+ * @param $filter array
+ * @param $ttl int
+ **/
+ function count($filter=NULL,$ttl=0) {
+ $now=microtime(TRUE);
+ $out=count($this->find($filter,NULL,$ttl,FALSE));
+ $this->db->jot('('.sprintf('%.1f',1e3*(microtime(TRUE)-$now)).'ms) '.
+ $this->file.' [count] '.($filter?json_encode($filter):''));
+ return $out;
+ }
+
+ /**
+ * Return record at specified offset using criteria of previous
+ * load() call and make it active
+ * @return array
+ * @param $ofs int
+ **/
+ function skip($ofs=1) {
+ $this->document=($out=parent::skip($ofs))?$out->document:array();
+ $this->id=$out?$out->id:NULL;
+ if ($this->document && isset($this->trigger['load']))
+ \Base::instance()->call($this->trigger['load'],$this);
+ return $out;
+ }
+
+ /**
+ * Insert new record
+ * @return array
+ **/
+ function insert() {
+ if ($this->id)
+ return $this->update();
+ $db=$this->db;
+ $now=microtime(TRUE);
+ while (($id=uniqid(NULL,TRUE)) &&
+ ($data=$db->read($this->file)) && isset($data[$id]) &&
+ !connection_aborted())
+ usleep(mt_rand(0,100));
+ $this->id=$id;
+ $data[$id]=$this->document;
+ $pkey=array('_id'=>$this->id);
+ if (isset($this->trigger['beforeinsert']))
+ \Base::instance()->call($this->trigger['beforeinsert'],
+ array($this,$pkey));
+ $db->write($this->file,$data);
+ $db->jot('('.sprintf('%.1f',1e3*(microtime(TRUE)-$now)).'ms) '.
+ $this->file.' [insert] '.json_encode($this->document));
+ if (isset($this->trigger['afterinsert']))
+ \Base::instance()->call($this->trigger['afterinsert'],
+ array($this,$pkey));
+ $this->load(array('@_id=?',$this->id));
+ return $this->document;
+ }
+
+ /**
+ * Update current record
+ * @return array
+ **/
+ function update() {
+ $db=$this->db;
+ $now=microtime(TRUE);
+ $data=$db->read($this->file);
+ $data[$this->id]=$this->document;
+ if (isset($this->trigger['beforeupdate']))
+ \Base::instance()->call($this->trigger['beforeupdate'],
+ array($this,array('_id'=>$this->id)));
+ $db->write($this->file,$data);
+ $db->jot('('.sprintf('%.1f',1e3*(microtime(TRUE)-$now)).'ms) '.
+ $this->file.' [update] '.json_encode($this->document));
+ if (isset($this->trigger['afterupdate']))
+ \Base::instance()->call($this->trigger['afterupdate'],
+ array($this,array('_id'=>$this->id)));
+ return $this->document;
+ }
+
+ /**
+ * Delete current record
+ * @return bool
+ * @param $filter array
+ **/
+ function erase($filter=NULL) {
+ $db=$this->db;
+ $now=microtime(TRUE);
+ $data=$db->read($this->file);
+ if ($filter) {
+ foreach ($this->find($filter,NULL,FALSE) as $mapper)
+ if (!$mapper->erase())
+ return FALSE;
+ return TRUE;
+ }
+ elseif (isset($this->id)) {
+ $pkey=array('_id'=>$this->id);
+ unset($data[$this->id]);
+ parent::erase();
+ $this->skip(0);
+ }
+ else
+ return FALSE;
+ if (isset($this->trigger['beforeerase']))
+ \Base::instance()->call($this->trigger['beforeerase'],
+ array($this,$pkey));
+ $db->write($this->file,$data);
+ if ($filter) {
+ $args=isset($filter[1]) && is_array($filter[1])?
+ $filter[1]:
+ array_slice($filter,1,NULL,TRUE);
+ $args=is_array($args)?$args:array(1=>$args);
+ foreach ($args as $key=>$val) {
+ $vals[]=\Base::instance()->
+ stringify(is_array($val)?$val[0]:$val);
+ $keys[]='/'.(is_numeric($key)?'\?':preg_quote($key)).'/';
+ }
+ }
+ $db->jot('('.sprintf('%.1f',1e3*(microtime(TRUE)-$now)).'ms) '.
+ $this->file.' [erase] '.
+ ($filter?preg_replace($keys,$vals,$filter[0],1):''));
+ if (isset($this->trigger['aftererase']))
+ \Base::instance()->call($this->trigger['aftererase'],
+ array($this,$pkey));
+ return TRUE;
+ }
+
+ /**
+ * Reset cursor
+ * @return NULL
+ **/
+ function reset() {
+ $this->id=NULL;
+ $this->document=array();
+ parent::reset();
+ }
+
+ /**
+ * Hydrate mapper object using hive array variable
+ * @return NULL
+ * @param $key string
+ * @param $func callback
+ **/
+ function copyfrom($key,$func=NULL) {
+ $var=\Base::instance()->get($key);
+ if ($func)
+ $var=$func($var);
+ foreach ($var as $key=>$val)
+ $this->document[$key]=$val;
+ }
+
+ /**
+ * Populate hive array variable with mapper fields
+ * @return NULL
+ * @param $key string
+ **/
+ function copyto($key) {
+ $var=&\Base::instance()->ref($key);
+ foreach ($this->document as $key=>$field)
+ $var[$key]=$field;
+ }
+
+ /**
+ * Return field names
+ * @return array
+ **/
+ function fields() {
+ return array_keys($this->document);
+ }
+
+ /**
+ * Instantiate class
+ * @return void
+ * @param $db object
+ * @param $file string
+ **/
+ function __construct(\DB\Jig $db,$file) {
+ $this->db=$db;
+ $this->file=$file;
+ $this->reset();
+ }
+
+}
diff --git a/management-interface/lib/db/jig/session.php b/management-interface/lib/db/jig/session.php
new file mode 100644
index 0000000..705cbce
--- /dev/null
+++ b/management-interface/lib/db/jig/session.php
@@ -0,0 +1,168 @@
+sid)
+ $this->load(array('@session_id=?',$this->sid=$id));
+ return $this->dry()?FALSE:$this->get('data');
+ }
+
+ /**
+ * Write session data
+ * @return TRUE
+ * @param $id string
+ * @param $data string
+ **/
+ function write($id,$data) {
+ $fw=\Base::instance();
+ $sent=headers_sent();
+ $headers=$fw->get('HEADERS');
+ if ($id!=$this->sid)
+ $this->load(array('@session_id=?',$this->sid=$id));
+ $csrf=$fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(mt_rand());
+ $this->set('session_id',$id);
+ $this->set('data',$data);
+ $this->set('csrf',$sent?$this->csrf():$csrf);
+ $this->set('ip',$fw->get('IP'));
+ $this->set('agent',
+ isset($headers['User-Agent'])?$headers['User-Agent']:'');
+ $this->set('stamp',time());
+ $this->save();
+ return TRUE;
+ }
+
+ /**
+ * Destroy session
+ * @return TRUE
+ * @param $id string
+ **/
+ function destroy($id) {
+ $this->erase(array('@session_id=?',$id));
+ setcookie(session_name(),'',strtotime('-1 year'));
+ unset($_COOKIE[session_name()]);
+ header_remove('Set-Cookie');
+ return TRUE;
+ }
+
+ /**
+ * Garbage collector
+ * @return TRUE
+ * @param $max int
+ **/
+ function cleanup($max) {
+ $this->erase(array('@stamp+?dry()?FALSE:$this->get('csrf');
+ }
+
+ /**
+ * Return IP address
+ * @return string|FALSE
+ **/
+ function ip() {
+ return $this->dry()?FALSE:$this->get('ip');
+ }
+
+ /**
+ * Return Unix timestamp
+ * @return string|FALSE
+ **/
+ function stamp() {
+ return $this->dry()?FALSE:$this->get('stamp');
+ }
+
+ /**
+ * Return HTTP user agent
+ * @return string|FALSE
+ **/
+ function agent() {
+ return $this->dry()?FALSE:$this->get('agent');
+ }
+
+ /**
+ * Instantiate class
+ * @param $db object
+ * @param $table string
+ **/
+ function __construct(\DB\Jig $db,$table='sessions') {
+ parent::__construct($db,'sessions');
+ session_set_save_handler(
+ array($this,'open'),
+ array($this,'close'),
+ array($this,'read'),
+ array($this,'write'),
+ array($this,'destroy'),
+ array($this,'cleanup')
+ );
+ register_shutdown_function('session_commit');
+ @session_start();
+ $fw=\Base::instance();
+ $headers=$fw->get('HEADERS');
+ if (($ip=$this->ip()) && $ip!=$fw->get('IP') ||
+ ($agent=$this->agent()) &&
+ (!isset($headers['User-Agent']) ||
+ $agent!=$headers['User-Agent'])) {
+ session_destroy();
+ $fw->error(403);
+ }
+ $csrf=$fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(mt_rand());
+ if ($this->load(array('@session_id=?',$this->sid=session_id()))) {
+ $this->set('csrf',$csrf);
+ $this->save();
+ }
+ }
+
+}
diff --git a/management-interface/lib/db/mongo.php b/management-interface/lib/db/mongo.php
new file mode 100644
index 0000000..833f160
--- /dev/null
+++ b/management-interface/lib/db/mongo.php
@@ -0,0 +1,92 @@
+dsn;
+ }
+
+ /**
+ * Return UUID
+ * @return string
+ **/
+ function uuid() {
+ return $this->uuid;
+ }
+
+ /**
+ * Return MongoDB profiler results
+ * @return string
+ **/
+ function log() {
+ $cursor=$this->selectcollection('system.profile')->find();
+ foreach (iterator_to_array($cursor) as $frame)
+ if (!preg_match('/\.system\..+$/',$frame['ns']))
+ $this->log.=date('r',$frame['ts']->sec).' ('.
+ sprintf('%.1f',$frame['millis']).'ms) '.
+ $frame['ns'].' ['.$frame['op'].'] '.
+ (empty($frame['query'])?
+ '':json_encode($frame['query'])).
+ (empty($frame['command'])?
+ '':json_encode($frame['command'])).
+ PHP_EOL;
+ return $this->log;
+ }
+
+ /**
+ * Intercept native call to re-enable profiler
+ * @return int
+ **/
+ function drop() {
+ $out=parent::drop();
+ $this->setprofilinglevel(2);
+ return $out;
+ }
+
+ /**
+ * Instantiate class
+ * @param $dsn string
+ * @param $dbname string
+ * @param $options array
+ **/
+ function __construct($dsn,$dbname,array $options=NULL) {
+ $this->uuid=\Base::instance()->hash($this->dsn=$dsn);
+ $class=class_exists('\MongoClient')?'\MongoClient':'\Mongo';
+ parent::__construct(new $class($dsn,$options?:array()),$dbname);
+ $this->setprofilinglevel(2);
+ }
+
+}
diff --git a/management-interface/lib/db/mongo/mapper.php b/management-interface/lib/db/mongo/mapper.php
new file mode 100644
index 0000000..bcb7f6e
--- /dev/null
+++ b/management-interface/lib/db/mongo/mapper.php
@@ -0,0 +1,346 @@
+document);
+ }
+
+ /**
+ * Assign value to field
+ * @return scalar|FALSE
+ * @param $key string
+ * @param $val scalar
+ **/
+ function set($key,$val) {
+ return $this->document[$key]=$val;
+ }
+
+ /**
+ * Retrieve value of field
+ * @return scalar|FALSE
+ * @param $key string
+ **/
+ function get($key) {
+ if ($this->exists($key))
+ return $this->document[$key];
+ user_error(sprintf(self::E_Field,$key));
+ return FALSE;
+ }
+
+ /**
+ * Delete field
+ * @return NULL
+ * @param $key string
+ **/
+ function clear($key) {
+ unset($this->document[$key]);
+ }
+
+ /**
+ * Convert array to mapper object
+ * @return object
+ * @param $row array
+ **/
+ protected function factory($row) {
+ $mapper=clone($this);
+ $mapper->reset();
+ foreach ($row as $key=>$val)
+ $mapper->document[$key]=$val;
+ $mapper->query=array(clone($mapper));
+ if (isset($mapper->trigger['load']))
+ \Base::instance()->call($mapper->trigger['load'],$mapper);
+ return $mapper;
+ }
+
+ /**
+ * Return fields of mapper object as an associative array
+ * @return array
+ * @param $obj object
+ **/
+ function cast($obj=NULL) {
+ if (!$obj)
+ $obj=$this;
+ return $obj->document;
+ }
+
+ /**
+ * Build query and execute
+ * @return array
+ * @param $fields string
+ * @param $filter array
+ * @param $options array
+ * @param $ttl int
+ **/
+ function select($fields=NULL,$filter=NULL,array $options=NULL,$ttl=0) {
+ if (!$options)
+ $options=array();
+ $options+=array(
+ 'group'=>NULL,
+ 'order'=>NULL,
+ 'limit'=>0,
+ 'offset'=>0
+ );
+ $fw=\Base::instance();
+ $cache=\Cache::instance();
+ if (!($cached=$cache->exists($hash=$fw->hash($this->db->dsn().
+ $fw->stringify(array($fields,$filter,$options))).'.mongo',
+ $result)) || !$ttl || $cached[0]+$ttlcollection->group(
+ $options['group']['keys'],
+ $options['group']['initial'],
+ $options['group']['reduce'],
+ array(
+ 'condition'=>$filter,
+ 'finalize'=>$options['group']['finalize']
+ )
+ );
+ $tmp=$this->db->selectcollection(
+ $fw->get('HOST').'.'.$fw->get('BASE').'.'.
+ uniqid(NULL,TRUE).'.tmp'
+ );
+ $tmp->batchinsert($grp['retval'],array('safe'=>TRUE));
+ $filter=array();
+ $collection=$tmp;
+ }
+ else {
+ $filter=$filter?:array();
+ $collection=$this->collection;
+ }
+ $this->cursor=$collection->find($filter,$fields?:array());
+ if ($options['order'])
+ $this->cursor=$this->cursor->sort($options['order']);
+ if ($options['limit'])
+ $this->cursor=$this->cursor->limit($options['limit']);
+ if ($options['offset'])
+ $this->cursor=$this->cursor->skip($options['offset']);
+ $result=array();
+ while ($this->cursor->hasnext())
+ $result[]=$this->cursor->getnext();
+ if ($options['group'])
+ $tmp->drop();
+ if ($fw->get('CACHE') && $ttl)
+ // Save to cache backend
+ $cache->set($hash,$result,$ttl);
+ }
+ $out=array();
+ foreach ($result as $doc)
+ $out[]=$this->factory($doc);
+ return $out;
+ }
+
+ /**
+ * Return records that match criteria
+ * @return array
+ * @param $filter array
+ * @param $options array
+ * @param $ttl int
+ **/
+ function find($filter=NULL,array $options=NULL,$ttl=0) {
+ if (!$options)
+ $options=array();
+ $options+=array(
+ 'group'=>NULL,
+ 'order'=>NULL,
+ 'limit'=>0,
+ 'offset'=>0
+ );
+ return $this->select(NULL,$filter,$options,$ttl);
+ }
+
+ /**
+ * Count records that match criteria
+ * @return int
+ * @param $filter array
+ * @param $ttl int
+ **/
+ function count($filter=NULL,$ttl=0) {
+ $fw=\Base::instance();
+ $cache=\Cache::instance();
+ if (!($cached=$cache->exists($hash=$fw->hash($fw->stringify(
+ array($filter))).'.mongo',$result)) || !$ttl ||
+ $cached[0]+$ttlcollection->count($filter);
+ if ($fw->get('CACHE') && $ttl)
+ // Save to cache backend
+ $cache->set($hash,$result,$ttl);
+ }
+ return $result;
+ }
+
+ /**
+ * Return record at specified offset using criteria of previous
+ * load() call and make it active
+ * @return array
+ * @param $ofs int
+ **/
+ function skip($ofs=1) {
+ $this->document=($out=parent::skip($ofs))?$out->document:array();
+ if ($this->document && isset($this->trigger['load']))
+ \Base::instance()->call($this->trigger['load'],$this);
+ return $out;
+ }
+
+ /**
+ * Insert new record
+ * @return array
+ **/
+ function insert() {
+ if (isset($this->document['_id']))
+ return $this->update();
+ if (isset($this->trigger['beforeinsert']))
+ \Base::instance()->call($this->trigger['beforeinsert'],
+ array($this,$pkey));
+ $this->collection->insert($this->document);
+ $pkey=array('_id'=>$this->document['_id']);
+ if (isset($this->trigger['afterinsert']))
+ \Base::instance()->call($this->trigger['afterinsert'],
+ array($this,$pkey));
+ $this->load(array('_id'=>$this->document['_id']));
+ return $this->document;
+ }
+
+ /**
+ * Update current record
+ * @return array
+ **/
+ function update() {
+ if (isset($this->trigger['beforeupdate']))
+ \Base::instance()->call($this->trigger['beforeupdate'],
+ array($this,$pkey));
+ $this->collection->update(
+ $pkey=array('_id'=>$this->document['_id']),
+ $this->document,
+ array('upsert'=>TRUE)
+ );
+ if (isset($this->trigger['afterupdate']))
+ \Base::instance()->call($this->trigger['afterupdate'],
+ array($this,$pkey));
+ return $this->document;
+ }
+
+ /**
+ * Delete current record
+ * @return bool
+ * @param $filter array
+ **/
+ function erase($filter=NULL) {
+ if ($filter)
+ return $this->collection->remove($filter);
+ $pkey=array('_id'=>$this->document['_id']);
+ if (isset($this->trigger['beforeerase']))
+ \Base::instance()->call($this->trigger['beforeerase'],
+ array($this,$pkey));
+ $result=$this->collection->
+ remove(array('_id'=>$this->document['_id']));
+ parent::erase();
+ $this->skip(0);
+ if (isset($this->trigger['aftererase']))
+ \Base::instance()->call($this->trigger['aftererase'],
+ array($this,$pkey));
+ return $result;
+ }
+
+ /**
+ * Reset cursor
+ * @return NULL
+ **/
+ function reset() {
+ $this->document=array();
+ parent::reset();
+ }
+
+ /**
+ * Hydrate mapper object using hive array variable
+ * @return NULL
+ * @param $key string
+ * @param $func callback
+ **/
+ function copyfrom($key,$func=NULL) {
+ $var=\Base::instance()->get($key);
+ if ($func)
+ $var=$func($var);
+ foreach ($var as $key=>$val)
+ $this->document[$key]=$val;
+ }
+
+ /**
+ * Populate hive array variable with mapper fields
+ * @return NULL
+ * @param $key string
+ **/
+ function copyto($key) {
+ $var=&\Base::instance()->ref($key);
+ foreach ($this->document as $key=>$field)
+ $var[$key]=$field;
+ }
+
+ /**
+ * Return field names
+ * @return array
+ **/
+ function fields() {
+ return array_keys($this->document);
+ }
+
+ /**
+ * Return the cursor from last query
+ * @return object|NULL
+ **/
+ function cursor() {
+ return $this->cursor;
+ }
+
+ /**
+ * Instantiate class
+ * @return void
+ * @param $db object
+ * @param $collection string
+ **/
+ function __construct(\DB\Mongo $db,$collection) {
+ $this->db=$db;
+ $this->collection=$db->{$collection};
+ $this->reset();
+ }
+
+}
diff --git a/management-interface/lib/db/mongo/session.php b/management-interface/lib/db/mongo/session.php
new file mode 100644
index 0000000..e3c6665
--- /dev/null
+++ b/management-interface/lib/db/mongo/session.php
@@ -0,0 +1,174 @@
+sid)
+ $this->load(array('session_id'=>$this->sid=$id));
+ return $this->dry()?FALSE:$this->get('data');
+ }
+
+ /**
+ * Write session data
+ * @return TRUE
+ * @param $id string
+ * @param $data string
+ **/
+ function write($id,$data) {
+ $fw=\Base::instance();
+ $sent=headers_sent();
+ $headers=$fw->get('HEADERS');
+ if ($id!=$this->sid)
+ $this->load(array('session_id'=>$this->sid=$id));
+ $csrf=$fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(mt_rand());
+ $this->set('session_id',$id);
+ $this->set('data',$data);
+ $this->set('csrf',$sent?$this->csrf():$csrf);
+ $this->set('ip',$fw->get('IP'));
+ $this->set('agent',
+ isset($headers['User-Agent'])?$headers['User-Agent']:'');
+ $this->set('stamp',time());
+ $this->save();
+ if (!$sent) {
+ if (isset($_COOKIE['_']))
+ setcookie('_','',strtotime('-1 year'));
+ call_user_func_array('setcookie',
+ array('_',$csrf)+$fw->get('JAR'));
+ }
+ return TRUE;
+ }
+
+ /**
+ * Destroy session
+ * @return TRUE
+ * @param $id string
+ **/
+ function destroy($id) {
+ $this->erase(array('session_id'=>$id));
+ setcookie(session_name(),'',strtotime('-1 year'));
+ unset($_COOKIE[session_name()]);
+ header_remove('Set-Cookie');
+ return TRUE;
+ }
+
+ /**
+ * Garbage collector
+ * @return TRUE
+ * @param $max int
+ **/
+ function cleanup($max) {
+ $this->erase(array('$where'=>'this.stamp+'.$max.'<'.time()));
+ return TRUE;
+ }
+
+ /**
+ * Return anti-CSRF token
+ * @return string|FALSE
+ **/
+ function csrf() {
+ return $this->dry()?FALSE:$this->get('csrf');
+ }
+
+ /**
+ * Return IP address
+ * @return string|FALSE
+ **/
+ function ip() {
+ return $this->dry()?FALSE:$this->get('ip');
+ }
+
+ /**
+ * Return Unix timestamp
+ * @return string|FALSE
+ **/
+ function stamp() {
+ return $this->dry()?FALSE:$this->get('stamp');
+ }
+
+ /**
+ * Return HTTP user agent
+ * @return string|FALSE
+ **/
+ function agent() {
+ return $this->dry()?FALSE:$this->get('agent');
+ }
+
+ /**
+ * Instantiate class
+ * @param $db object
+ * @param $table string
+ **/
+ function __construct(\DB\Mongo $db,$table='sessions') {
+ parent::__construct($db,$table);
+ session_set_save_handler(
+ array($this,'open'),
+ array($this,'close'),
+ array($this,'read'),
+ array($this,'write'),
+ array($this,'destroy'),
+ array($this,'cleanup')
+ );
+ register_shutdown_function('session_commit');
+ @session_start();
+ $fw=\Base::instance();
+ $headers=$fw->get('HEADERS');
+ if (($ip=$this->ip()) && $ip!=$fw->get('IP') ||
+ ($agent=$this->agent()) &&
+ (!isset($headers['User-Agent']) ||
+ $agent!=$headers['User-Agent'])) {
+ session_destroy();
+ $fw->error(403);
+ }
+ $csrf=$fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(mt_rand());
+ if ($this->load(array('session_id'=>$this->sid=session_id()))) {
+ $this->set('csrf',$csrf);
+ $this->save();
+ }
+ }
+
+}
diff --git a/management-interface/lib/db/sql.php b/management-interface/lib/db/sql.php
new file mode 100644
index 0000000..88e34dc
--- /dev/null
+++ b/management-interface/lib/db/sql.php
@@ -0,0 +1,403 @@
+trans=TRUE;
+ return $out;
+ }
+
+ /**
+ * Rollback SQL transaction
+ * @return bool
+ **/
+ function rollback() {
+ $out=parent::rollback();
+ $this->trans=FALSE;
+ return $out;
+ }
+
+ /**
+ * Commit SQL transaction
+ * @return bool
+ **/
+ function commit() {
+ $out=parent::commit();
+ $this->trans=FALSE;
+ return $out;
+ }
+
+ /**
+ * Map data type of argument to a PDO constant
+ * @return int
+ * @param $val scalar
+ **/
+ function type($val) {
+ switch (gettype($val)) {
+ case 'NULL':
+ return \PDO::PARAM_NULL;
+ case 'boolean':
+ return \PDO::PARAM_BOOL;
+ case 'integer':
+ return \PDO::PARAM_INT;
+ default:
+ return \PDO::PARAM_STR;
+ }
+ }
+
+ /**
+ * Cast value to PHP type
+ * @return scalar
+ * @param $type string
+ * @param $val scalar
+ **/
+ function value($type,$val) {
+ switch ($type) {
+ case \PDO::PARAM_NULL:
+ return (unset)$val;
+ case \PDO::PARAM_INT:
+ return (int)$val;
+ case \PDO::PARAM_BOOL:
+ return (bool)$val;
+ case \PDO::PARAM_STR:
+ return (string)$val;
+ }
+ }
+
+ /**
+ * Execute SQL statement(s)
+ * @return array|int|FALSE
+ * @param $cmds string|array
+ * @param $args string|array
+ * @param $ttl int
+ * @param $log bool
+ **/
+ function exec($cmds,$args=NULL,$ttl=0,$log=TRUE) {
+ $auto=FALSE;
+ if (is_null($args))
+ $args=array();
+ elseif (is_scalar($args))
+ $args=array(1=>$args);
+ if (is_array($cmds)) {
+ if (count($args)<($count=count($cmds)))
+ // Apply arguments to SQL commands
+ $args=array_fill(0,$count,$args);
+ if (!$this->trans) {
+ $this->begin();
+ $auto=TRUE;
+ }
+ }
+ else {
+ $cmds=array($cmds);
+ $args=array($args);
+ }
+ $fw=\Base::instance();
+ $cache=\Cache::instance();
+ $result=FALSE;
+ foreach (array_combine($cmds,$args) as $cmd=>$arg) {
+ if (!preg_replace('/(^\s+|[\s;]+$)/','',$cmd))
+ continue;
+ $now=microtime(TRUE);
+ $keys=$vals=array();
+ if ($fw->get('CACHE') && $ttl && ($cached=$cache->exists(
+ $hash=$fw->hash($this->dsn.$cmd.
+ $fw->stringify($arg)).'.sql',$result)) &&
+ $cached[0]+$ttl>microtime(TRUE)) {
+ foreach ($arg as $key=>$val) {
+ $vals[]=$fw->stringify(is_array($val)?$val[0]:$val);
+ $keys[]='/'.(is_numeric($key)?'\?':preg_quote($key)).'/';
+ }
+ }
+ elseif (is_object($query=$this->prepare($cmd))) {
+ foreach ($arg as $key=>$val) {
+ if (is_array($val)) {
+ // User-specified data type
+ $query->bindvalue($key,$val[0],$val[1]);
+ $vals[]=$fw->stringify($this->value($val[1],$val[0]));
+ }
+ else {
+ // Convert to PDO data type
+ $query->bindvalue($key,$val,
+ $type=$this->type($val));
+ $vals[]=$fw->stringify($this->value($type,$val));
+ }
+ $keys[]='/'.(is_numeric($key)?'\?':preg_quote($key)).'/';
+ }
+ $query->execute();
+ $error=$query->errorinfo();
+ if ($error[0]!=\PDO::ERR_NONE) {
+ // Statement-level error occurred
+ if ($this->trans)
+ $this->rollback();
+ user_error('PDOStatement: '.$error[2]);
+ }
+ if (preg_match('/^\s*'.
+ '(?:CALL|EXPLAIN|SELECT|PRAGMA|SHOW|RETURNING|EXEC)\b/is',
+ $cmd)) {
+ $result=$query->fetchall(\PDO::FETCH_ASSOC);
+ // Work around SQLite quote bug
+ if (preg_match('/sqlite2?/',$this->engine))
+ foreach ($result as $pos=>$rec) {
+ unset($result[$pos]);
+ $result[$pos]=array();
+ foreach ($rec as $key=>$val)
+ $result[$pos][trim($key,'\'"[]`')]=$val;
+ }
+ $this->rows=count($result);
+ if ($fw->get('CACHE') && $ttl)
+ // Save to cache backend
+ $cache->set($hash,$result,$ttl);
+ }
+ else
+ $this->rows=$result=$query->rowcount();
+ $query->closecursor();
+ unset($query);
+ }
+ else {
+ $error=$this->errorinfo();
+ if ($error[0]!=\PDO::ERR_NONE) {
+ // PDO-level error occurred
+ if ($this->trans)
+ $this->rollback();
+ user_error('PDO: '.$error[2]);
+ }
+ }
+ if ($log)
+ $this->log.=date('r').' ('.
+ sprintf('%.1f',1e3*(microtime(TRUE)-$now)).'ms) '.
+ (empty($cached)?'':'[CACHED] ').
+ preg_replace($keys,$vals,$cmd,1).PHP_EOL;
+ }
+ if ($this->trans && $auto)
+ $this->commit();
+ return $result;
+ }
+
+ /**
+ * Return number of rows affected by last query
+ * @return int
+ **/
+ function count() {
+ return $this->rows;
+ }
+
+ /**
+ * Return SQL profiler results
+ * @return string
+ **/
+ function log() {
+ return $this->log;
+ }
+
+ /**
+ * Retrieve schema of SQL table
+ * @return array|FALSE
+ * @param $table string
+ * @param $fields array|string
+ * @param $ttl int
+ **/
+ function schema($table,$fields=NULL,$ttl=0) {
+ // Supported engines
+ $cmd=array(
+ 'sqlite2?'=>array(
+ 'PRAGMA table_info("'.$table.'");',
+ 'name','type','dflt_value','notnull',0,'pk',TRUE),
+ 'mysql'=>array(
+ 'SHOW columns FROM `'.$this->dbname.'`.`'.$table.'`;',
+ 'Field','Type','Default','Null','YES','Key','PRI'),
+ 'mssql|sqlsrv|sybase|dblib|pgsql|odbc'=>array(
+ 'SELECT '.
+ 'c.column_name AS field,'.
+ 'c.data_type AS type,'.
+ 'c.column_default AS defval,'.
+ 'c.is_nullable AS nullable,'.
+ 't.constraint_type AS pkey '.
+ 'FROM information_schema.columns AS c '.
+ 'LEFT OUTER JOIN '.
+ 'information_schema.key_column_usage AS k '.
+ 'ON '.
+ 'c.table_name=k.table_name AND '.
+ 'c.column_name=k.column_name AND '.
+ 'c.table_schema=k.table_schema '.
+ ($this->dbname?
+ ('AND c.table_catalog=k.table_catalog '):'').
+ 'LEFT OUTER JOIN '.
+ 'information_schema.table_constraints AS t ON '.
+ 'k.table_name=t.table_name AND '.
+ 'k.constraint_name=t.constraint_name '.
+ 'k.table_schema=t.table_schema '.
+ ($this->dbname?
+ ('AND k.table_catalog=t.table_catalog '):'').
+ 'WHERE '.
+ 'c.table_name='.$this->quote($table).' '.
+ ($this->dbname?
+ ('AND c.table_catalog='.
+ $this->quote($this->dbname)):'').
+ ';',
+ 'field','type','defval','nullable','YES','pkey','PRIMARY KEY'),
+ 'oci'=>array(
+ 'SELECT c.column_name AS field, '.
+ 'c.data_type AS type, '.
+ 'c.data_default AS defval, '.
+ 'c.nullable AS nullable, '.
+ '(SELECT t.constraint_type '.
+ 'FROM all_cons_columns acc '.
+ 'LEFT OUTER JOIN all_constraints t '.
+ 'ON acc.constraint_name=t.constraint_name '.
+ 'WHERE acc.table_name='.$this->quote($table).' '.
+ 'AND acc.column_name=c.column_name '.
+ 'AND constraint_type='.$this->quote('P').') AS pkey '.
+ 'FROM all_tab_cols c '.
+ 'WHERE c.table_name='.$this->quote($table),
+ 'FIELD','TYPE','DEFVAL','NULLABLE','Y','PKEY','P')
+ );
+ if (is_string($fields))
+ $fields=\Base::instance()->split($fields);
+ foreach ($cmd as $key=>$val)
+ if (preg_match('/'.$key.'/',$this->engine)) {
+ // Improve InnoDB performance on MySQL with
+ // SET GLOBAL innodb_stats_on_metadata=0;
+ // This requires SUPER privilege!
+ $rows=array();
+ foreach ($this->exec($val[0],NULL,$ttl) as $row) {
+ if (!$fields || in_array($row[$val[1]],$fields))
+ $rows[$row[$val[1]]]=array(
+ 'type'=>$row[$val[2]],
+ 'pdo_type'=>
+ preg_match('/int\b|int(?=eger)|bool/i',
+ $row[$val[2]],$parts)?
+ constant('\PDO::PARAM_'.
+ strtoupper($parts[0])):
+ \PDO::PARAM_STR,
+ 'default'=>$row[$val[3]],
+ 'nullable'=>$row[$val[4]]==$val[5],
+ 'pkey'=>$row[$val[6]]==$val[7]
+ );
+ }
+ return $rows;
+ }
+ return FALSE;
+ }
+
+ /**
+ * Quote string
+ * @return string
+ * @param $val mixed
+ * @param $type int
+ **/
+ function quote($val,$type=\PDO::PARAM_STR) {
+ return $this->engine=='odbc'?
+ (is_string($val)?
+ \Base::instance()->stringify(str_replace('\'','\'\'',$val)):
+ $val):
+ parent::quote($val,$type);
+ }
+
+ /**
+ * Return UUID
+ * @return string
+ **/
+ function uuid() {
+ return $this->uuid;
+ }
+
+ /**
+ * Return database engine
+ * @return string
+ **/
+ function driver() {
+ return $this->engine;
+ }
+
+ /**
+ * Return server version
+ * @return string
+ **/
+ function version() {
+ return parent::getattribute(parent::ATTR_SERVER_VERSION);
+ }
+
+ /**
+ * Return database name
+ * @return string
+ **/
+ function name() {
+ return $this->dbname;
+ }
+
+ /**
+ * Return quoted identifier name
+ * @return string
+ * @param $key
+ **/
+ function quotekey($key) {
+ if ($this->engine=='mysql')
+ $key="`".implode('`.`',explode('.',$key))."`";
+ elseif (preg_match('/sybase|dblib/',$this->engine))
+ $key="'".implode("'.'",explode('.',$key))."'";
+ elseif (preg_match('/sqlite2?|pgsql|oci/',$this->engine))
+ $key='"'.implode('"."',explode('.',$key)).'"';
+ elseif (preg_match('/mssql|sqlsrv|odbc/',$this->engine))
+ $key="[".implode('].[',explode('.',$key))."]";
+ return $key;
+ }
+
+ /**
+ * Instantiate class
+ * @param $dsn string
+ * @param $user string
+ * @param $pw string
+ * @param $options array
+ **/
+ function __construct($dsn,$user=NULL,$pw=NULL,array $options=NULL) {
+ $fw=\Base::instance();
+ $this->uuid=$fw->hash($this->dsn=$dsn);
+ if (preg_match('/^.+?(?:dbname|database)=(.+?)(?=;|$)/i',$dsn,$parts))
+ $this->dbname=$parts[1];
+ if (!$options)
+ $options=array();
+ if (isset($parts[0]) && strstr($parts[0],':',TRUE)=='mysql')
+ $options+=array(\PDO::MYSQL_ATTR_INIT_COMMAND=>'SET NAMES '.
+ strtolower(str_replace('-','',$fw->get('ENCODING'))).';');
+ parent::__construct($dsn,$user,$pw,$options);
+ $this->engine=parent::getattribute(parent::ATTR_DRIVER_NAME);
+ }
+
+}
diff --git a/management-interface/lib/db/sql/mapper.php b/management-interface/lib/db/sql/mapper.php
new file mode 100644
index 0000000..6af4675
--- /dev/null
+++ b/management-interface/lib/db/sql/mapper.php
@@ -0,0 +1,552 @@
+fields+$this->adhoc);
+ }
+
+ /**
+ * Assign value to field
+ * @return scalar
+ * @param $key string
+ * @param $val scalar
+ **/
+ function set($key,$val) {
+ if (array_key_exists($key,$this->fields)) {
+ $val=is_null($val) && $this->fields[$key]['nullable']?
+ NULL:$this->db->value($this->fields[$key]['pdo_type'],$val);
+ if ($this->fields[$key]['value']!==$val ||
+ $this->fields[$key]['default']!==$val && is_null($val))
+ $this->fields[$key]['changed']=TRUE;
+ return $this->fields[$key]['value']=$val;
+ }
+ // Parenthesize expression in case it's a subquery
+ $this->adhoc[$key]=array('expr'=>'('.$val.')','value'=>NULL);
+ return $val;
+ }
+
+ /**
+ * Retrieve value of field
+ * @return scalar
+ * @param $key string
+ **/
+ function get($key) {
+ if ($key=='_id')
+ return $this->_id;
+ elseif (array_key_exists($key,$this->fields))
+ return $this->fields[$key]['value'];
+ elseif (array_key_exists($key,$this->adhoc))
+ return $this->adhoc[$key]['value'];
+ user_error(sprintf(self::E_Field,$key));
+ }
+
+ /**
+ * Clear value of field
+ * @return NULL
+ * @param $key string
+ **/
+ function clear($key) {
+ if (array_key_exists($key,$this->adhoc))
+ unset($this->adhoc[$key]);
+ }
+
+ /**
+ * Get PHP type equivalent of PDO constant
+ * @return string
+ * @param $pdo string
+ **/
+ function type($pdo) {
+ switch ($pdo) {
+ case \PDO::PARAM_NULL:
+ return 'unset';
+ case \PDO::PARAM_INT:
+ return 'int';
+ case \PDO::PARAM_BOOL:
+ return 'bool';
+ case \PDO::PARAM_STR:
+ return 'string';
+ }
+ }
+
+ /**
+ * Convert array to mapper object
+ * @return object
+ * @param $row array
+ **/
+ protected function factory($row) {
+ $mapper=clone($this);
+ $mapper->reset();
+ foreach ($row as $key=>$val) {
+ if (array_key_exists($key,$this->fields))
+ $var='fields';
+ elseif (array_key_exists($key,$this->adhoc))
+ $var='adhoc';
+ else
+ continue;
+ $mapper->{$var}[$key]['value']=$val;
+ if ($var=='fields' && $mapper->{$var}[$key]['pkey'])
+ $mapper->{$var}[$key]['previous']=$val;
+ }
+ $mapper->query=array(clone($mapper));
+ if (isset($mapper->trigger['load']))
+ \Base::instance()->call($mapper->trigger['load'],$mapper);
+ return $mapper;
+ }
+
+ /**
+ * Return fields of mapper object as an associative array
+ * @return array
+ * @param $obj object
+ **/
+ function cast($obj=NULL) {
+ if (!$obj)
+ $obj=$this;
+ return array_map(
+ function($row) {
+ return $row['value'];
+ },
+ $obj->fields+$obj->adhoc
+ );
+ }
+
+ /**
+ * Build query string and execute
+ * @return array
+ * @param $fields string
+ * @param $filter string|array
+ * @param $options array
+ * @param $ttl int
+ **/
+ function select($fields,$filter=NULL,array $options=NULL,$ttl=0) {
+ if (!$options)
+ $options=array();
+ $options+=array(
+ 'group'=>NULL,
+ 'order'=>NULL,
+ 'limit'=>0,
+ 'offset'=>0
+ );
+ $sql='SELECT '.$fields.' FROM '.$this->table;
+ $args=array();
+ if ($filter) {
+ if (is_array($filter)) {
+ $args=isset($filter[1]) && is_array($filter[1])?
+ $filter[1]:
+ array_slice($filter,1,NULL,TRUE);
+ $args=is_array($args)?$args:array(1=>$args);
+ list($filter)=$filter;
+ }
+ $sql.=' WHERE '.$filter;
+ }
+ $db=$this->db;
+ if ($options['group'])
+ $sql.=' GROUP BY '.implode(',',array_map(
+ function($str) use($db) {
+ return preg_match('/^(\w+)(?:\h+HAVING|\h*(?:,|$))/i',
+ $str,$parts)?
+ ($db->quotekey($parts[1]).
+ (isset($parts[2])?(' '.$parts[2]):'')):$str;
+ },
+ explode(',',$options['group'])));
+ if ($options['order']) {
+ $sql.=' ORDER BY '.implode(',',array_map(
+ function($str) use($db) {
+ return preg_match('/^(\w+)(?:\h+(ASC|DESC))?\h*(?:,|$)/i',
+ $str,$parts)?
+ ($db->quotekey($parts[1]).
+ (isset($parts[2])?(' '.$parts[2]):'')):$str;
+ },
+ explode(',',$options['order'])));
+ }
+ if ($options['limit'])
+ $sql.=' LIMIT '.(int)$options['limit'];
+ if ($options['offset'])
+ $sql.=' OFFSET '.(int)$options['offset'];
+ $result=$this->db->exec($sql,$args,$ttl);
+ $out=array();
+ foreach ($result as &$row) {
+ foreach ($row as $field=>&$val) {
+ if (array_key_exists($field,$this->fields)) {
+ if (!is_null($val) || !$this->fields[$field]['nullable'])
+ $val=$this->db->value(
+ $this->fields[$field]['pdo_type'],$val);
+ }
+ elseif (array_key_exists($field,$this->adhoc))
+ $this->adhoc[$field]['value']=$val;
+ unset($val);
+ }
+ $out[]=$this->factory($row);
+ unset($row);
+ }
+ return $out;
+ }
+
+ /**
+ * Return records that match criteria
+ * @return array
+ * @param $filter string|array
+ * @param $options array
+ * @param $ttl int
+ **/
+ function find($filter=NULL,array $options=NULL,$ttl=0) {
+ if (!$options)
+ $options=array();
+ $options+=array(
+ 'group'=>NULL,
+ 'order'=>NULL,
+ 'limit'=>0,
+ 'offset'=>0
+ );
+ $adhoc='';
+ foreach ($this->adhoc as $key=>$field)
+ $adhoc.=','.$field['expr'].' AS '.$this->db->quotekey($key);
+ return $this->select(implode(',',
+ array_map(array($this->db,'quotekey'),array_keys($this->fields))).
+ $adhoc,$filter,$options,$ttl);
+ }
+
+ /**
+ * Count records that match criteria
+ * @return int
+ * @param $filter string|array
+ * @param $ttl int
+ **/
+ function count($filter=NULL,$ttl=0) {
+ $sql='SELECT COUNT(*) AS '.
+ $this->db->quotekey('rows').' FROM '.$this->table;
+ $args=array();
+ if ($filter) {
+ if (is_array($filter)) {
+ $args=isset($filter[1]) && is_array($filter[1])?
+ $filter[1]:
+ array_slice($filter,1,NULL,TRUE);
+ $args=is_array($args)?$args:array(1=>$args);
+ list($filter)=$filter;
+ }
+ $sql.=' WHERE '.$filter;
+ }
+ $result=$this->db->exec($sql,$args,$ttl);
+ return $result[0]['rows'];
+ }
+
+ /**
+ * Return record at specified offset using same criteria as
+ * previous load() call and make it active
+ * @return array
+ * @param $ofs int
+ **/
+ function skip($ofs=1) {
+ $out=parent::skip($ofs);
+ $dry=$this->dry();
+ foreach ($this->fields as $key=>&$field) {
+ $field['value']=$dry?NULL:$out->fields[$key]['value'];
+ $field['changed']=FALSE;
+ if ($field['pkey'])
+ $field['previous']=$dry?NULL:$out->fields[$key]['value'];
+ unset($field);
+ }
+ foreach ($this->adhoc as $key=>&$field) {
+ $field['value']=$dry?NULL:$out->adhoc[$key]['value'];
+ unset($field);
+ }
+ if (isset($this->trigger['load']))
+ \Base::instance()->call($this->trigger['load'],$this);
+ return $out;
+ }
+
+ /**
+ * Insert new record
+ * @return object
+ **/
+ function insert() {
+ $args=array();
+ $ctr=0;
+ $fields='';
+ $values='';
+ $filter='';
+ $pkeys=array();
+ $nkeys=array();
+ $ckeys=array();
+ $inc=NULL;
+ foreach ($this->fields as $key=>$field)
+ if ($field['pkey'])
+ $pkeys[$key]=$field['previous'];
+ if (isset($this->trigger['beforeinsert']))
+ \Base::instance()->call($this->trigger['beforeinsert'],
+ array($this,$pkeys));
+ foreach ($this->fields as $key=>&$field) {
+ if ($field['pkey']) {
+ $field['previous']=$field['value'];
+ if (!$inc && $field['pdo_type']==\PDO::PARAM_INT &&
+ empty($field['value']) && !$field['nullable'])
+ $inc=$key;
+ $filter.=($filter?' AND ':'').$this->db->quotekey($key).'=?';
+ $nkeys[$ctr+1]=array($field['value'],$field['pdo_type']);
+ }
+ if ($field['changed'] && $key!=$inc) {
+ $fields.=($ctr?',':'').$this->db->quotekey($key);
+ $values.=($ctr?',':'').'?';
+ $args[$ctr+1]=array($field['value'],$field['pdo_type']);
+ $ctr++;
+ $ckeys[]=$key;
+ }
+ $field['changed']=FALSE;
+ unset($field);
+ }
+ if ($fields) {
+ $this->db->exec(
+ (preg_match('/mssql|dblib|sqlsrv/',$this->engine) &&
+ array_intersect(array_keys($pkeys),$ckeys)?
+ 'SET IDENTITY_INSERT '.$this->table.' ON;':'').
+ 'INSERT INTO '.$this->table.' ('.$fields.') '.
+ 'VALUES ('.$values.')',$args
+ );
+ $seq=NULL;
+ if ($this->engine=='pgsql') {
+ $names=array_keys($pkeys);
+ $seq=$this->source.'_'.end($names).'_seq';
+ }
+ if ($this->engine!='oci')
+ $this->_id=$this->db->lastinsertid($seq);
+ // Reload to obtain default and auto-increment field values
+ $this->load($inc?
+ array($inc.'=?',$this->db->value(
+ $this->fields[$inc]['pdo_type'],$this->_id)):
+ array($filter,$nkeys));
+ if (isset($this->trigger['afterinsert']))
+ \Base::instance()->call($this->trigger['afterinsert'],
+ array($this,$pkeys));
+ }
+ return $this;
+ }
+
+ /**
+ * Update current record
+ * @return object
+ **/
+ function update() {
+ $args=array();
+ $ctr=0;
+ $pairs='';
+ $filter='';
+ $pkeys=array();
+ foreach ($this->fields as $key=>$field)
+ if ($field['pkey'])
+ $pkeys[$key]=$field['previous'];
+ if (isset($this->trigger['beforeupdate']))
+ \Base::instance()->call($this->trigger['beforeupdate'],
+ array($this,$pkeys));
+ foreach ($this->fields as $key=>$field)
+ if ($field['changed']) {
+ $pairs.=($pairs?',':'').$this->db->quotekey($key).'=?';
+ $args[$ctr+1]=array($field['value'],$field['pdo_type']);
+ $ctr++;
+ }
+ foreach ($this->fields as $key=>$field)
+ if ($field['pkey']) {
+ $filter.=($filter?' AND ':'').$this->db->quotekey($key).'=?';
+ $args[$ctr+1]=array($field['previous'],$field['pdo_type']);
+ $ctr++;
+ }
+ if ($pairs) {
+ $sql='UPDATE '.$this->table.' SET '.$pairs;
+ if ($filter)
+ $sql.=' WHERE '.$filter;
+ $this->db->exec($sql,$args);
+ if (isset($this->trigger['afterupdate']))
+ \Base::instance()->call($this->trigger['afterupdate'],
+ array($this,$pkeys));
+ }
+ return $this;
+ }
+
+ /**
+ * Delete current record
+ * @return int
+ * @param $filter string|array
+ **/
+ function erase($filter=NULL) {
+ if ($filter) {
+ $args=array();
+ if (is_array($filter)) {
+ $args=isset($filter[1]) && is_array($filter[1])?
+ $filter[1]:
+ array_slice($filter,1,NULL,TRUE);
+ $args=is_array($args)?$args:array(1=>$args);
+ list($filter)=$filter;
+ }
+ return $this->db->
+ exec('DELETE FROM '.$this->table.' WHERE '.$filter.';',$args);
+ }
+ $args=array();
+ $ctr=0;
+ $filter='';
+ $pkeys=array();
+ foreach ($this->fields as $key=>&$field) {
+ if ($field['pkey']) {
+ $filter.=($filter?' AND ':'').$this->db->quotekey($key).'=?';
+ $args[$ctr+1]=array($field['previous'],$field['pdo_type']);
+ $pkeys[$key]=$field['previous'];
+ $ctr++;
+ }
+ $field['value']=NULL;
+ $field['changed']=(bool)$field['default'];
+ if ($field['pkey'])
+ $field['previous']=NULL;
+ unset($field);
+ }
+ foreach ($this->adhoc as &$field) {
+ $field['value']=NULL;
+ unset($field);
+ }
+ parent::erase();
+ $this->skip(0);
+ if (isset($this->trigger['beforeerase']))
+ \Base::instance()->call($this->trigger['beforeerase'],
+ array($this,$pkeys));
+ $out=$this->db->
+ exec('DELETE FROM '.$this->table.' WHERE '.$filter.';',$args);
+ if (isset($this->trigger['aftererase']))
+ \Base::instance()->call($this->trigger['aftererase'],
+ array($this,$pkeys));
+ return $out;
+ }
+
+ /**
+ * Reset cursor
+ * @return NULL
+ **/
+ function reset() {
+ foreach ($this->fields as &$field) {
+ $field['value']=NULL;
+ $field['changed']=FALSE;
+ if ($field['pkey'])
+ $field['previous']=NULL;
+ unset($field);
+ }
+ foreach ($this->adhoc as &$field) {
+ $field['value']=NULL;
+ unset($field);
+ }
+ parent::reset();
+ }
+
+ /**
+ * Hydrate mapper object using hive array variable
+ * @return NULL
+ * @param $key string
+ * @param $func callback
+ **/
+ function copyfrom($key,$func=NULL) {
+ $var=\Base::instance()->get($key);
+ if ($func)
+ $var=$func($var);
+ foreach ($var as $key=>$val)
+ if (in_array($key,array_keys($this->fields))) {
+ $field=&$this->fields[$key];
+ if ($field['value']!==$val) {
+ $field['value']=$val;
+ $field['changed']=TRUE;
+ }
+ unset($field);
+ }
+ }
+
+ /**
+ * Populate hive array variable with mapper fields
+ * @return NULL
+ * @param $key string
+ **/
+ function copyto($key) {
+ $var=&\Base::instance()->ref($key);
+ foreach ($this->fields+$this->adhoc as $key=>$field)
+ $var[$key]=$field['value'];
+ }
+
+ /**
+ * Return schema
+ * @return array
+ **/
+ function schema() {
+ return $this->fields;
+ }
+
+ /**
+ * Return field names
+ * @return array
+ * @param $adhoc bool
+ **/
+ function fields($adhoc=TRUE) {
+ return array_keys($this->fields+($adhoc?$this->adhoc:array()));
+ }
+
+ /**
+ * Instantiate class
+ * @param $db object
+ * @param $table string
+ * @param $fields array|string
+ * @param $ttl int
+ **/
+ function __construct(\DB\SQL $db,$table,$fields=NULL,$ttl=60) {
+ $this->db=$db;
+ $this->engine=$db->driver();
+ if ($this->engine=='oci')
+ $table=strtoupper($table);
+ $this->source=$table;
+ $this->table=$this->db->quotekey($table);
+ $this->fields=$db->schema($table,$fields,$ttl);
+ $this->reset();
+ }
+
+}
diff --git a/management-interface/lib/db/sql/session.php b/management-interface/lib/db/sql/session.php
new file mode 100644
index 0000000..48050ec
--- /dev/null
+++ b/management-interface/lib/db/sql/session.php
@@ -0,0 +1,187 @@
+sid)
+ $this->load(array('session_id=?',$this->sid=$id));
+ return $this->dry()?FALSE:$this->get('data');
+ }
+
+ /**
+ * Write session data
+ * @return TRUE
+ * @param $id string
+ * @param $data string
+ **/
+ function write($id,$data) {
+ $fw=\Base::instance();
+ $sent=headers_sent();
+ $headers=$fw->get('HEADERS');
+ if ($id!=$this->sid)
+ $this->load(array('session_id=?',$this->sid=$id));
+ $csrf=$fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(mt_rand());
+ $this->set('session_id',$id);
+ $this->set('data',$data);
+ $this->set('csrf',$sent?$this->csrf():$csrf);
+ $this->set('ip',$fw->get('IP'));
+ $this->set('agent',
+ isset($headers['User-Agent'])?$headers['User-Agent']:'');
+ $this->set('stamp',time());
+ $this->save();
+ return TRUE;
+ }
+
+ /**
+ * Destroy session
+ * @return TRUE
+ * @param $id string
+ **/
+ function destroy($id) {
+ $this->erase(array('session_id=?',$id));
+ setcookie(session_name(),'',strtotime('-1 year'));
+ unset($_COOKIE[session_name()]);
+ header_remove('Set-Cookie');
+ return TRUE;
+ }
+
+ /**
+ * Garbage collector
+ * @return TRUE
+ * @param $max int
+ **/
+ function cleanup($max) {
+ $this->erase(array('stamp+?dry()?FALSE:$this->get('csrf');
+ }
+
+ /**
+ * Return IP address
+ * @return string|FALSE
+ **/
+ function ip() {
+ return $this->dry()?FALSE:$this->get('ip');
+ }
+
+ /**
+ * Return Unix timestamp
+ * @return string|FALSE
+ **/
+ function stamp() {
+ return $this->dry()?FALSE:$this->get('stamp');
+ }
+
+ /**
+ * Return HTTP user agent
+ * @return string|FALSE
+ **/
+ function agent() {
+ return $this->dry()?FALSE:$this->get('agent');
+ }
+
+ /**
+ * Instantiate class
+ * @param $db object
+ * @param $table string
+ * @param $force bool
+ **/
+ function __construct(\DB\SQL $db,$table='sessions',$force=TRUE) {
+ if ($force)
+ $db->exec(
+ (preg_match('/mssql|sqlsrv|sybase/',$db->driver())?
+ ('IF NOT EXISTS (SELECT * FROM sysobjects WHERE '.
+ 'name='.$db->quote($table).' AND xtype=\'U\') '.
+ 'CREATE TABLE dbo.'):
+ ('CREATE TABLE IF NOT EXISTS '.
+ (($name=$db->name())?($name.'.'):''))).
+ $table.' ('.
+ 'session_id VARCHAR(40),'.
+ 'data TEXT,'.
+ 'csrf TEXT,'.
+ 'ip VARCHAR(40),'.
+ 'agent VARCHAR(255),'.
+ 'stamp INTEGER,'.
+ 'PRIMARY KEY(session_id)'.
+ ');'
+ );
+ parent::__construct($db,$table);
+ session_set_save_handler(
+ array($this,'open'),
+ array($this,'close'),
+ array($this,'read'),
+ array($this,'write'),
+ array($this,'destroy'),
+ array($this,'cleanup')
+ );
+ register_shutdown_function('session_commit');
+ @session_start();
+ $fw=\Base::instance();
+ $headers=$fw->get('HEADERS');
+ if (($ip=$this->ip()) && $ip!=$fw->get('IP') ||
+ ($agent=$this->agent()) &&
+ (!isset($headers['User-Agent']) ||
+ $agent!=$headers['User-Agent'])) {
+ session_destroy();
+ $fw->error(403);
+ }
+ $csrf=$fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(mt_rand());
+ if ($this->load(array('session_id=?',$this->sid=session_id()))) {
+ $this->set('csrf',$csrf);
+ $this->save();
+ }
+ }
+
+}
diff --git a/management-interface/lib/f3.php b/management-interface/lib/f3.php
new file mode 100644
index 0000000..4788d58
--- /dev/null
+++ b/management-interface/lib/f3.php
@@ -0,0 +1,35 @@
+6)
+ user_error(sprintf(self::E_Color,'0x'.$hex));
+ $color=str_split($hex,$len/3);
+ foreach ($color as &$hue) {
+ $hue=hexdec(str_repeat($hue,6/$len));
+ unset($hue);
+ }
+ return $color;
+ }
+
+ /**
+ * Invert image
+ * @return object
+ **/
+ function invert() {
+ imagefilter($this->data,IMG_FILTER_NEGATE);
+ return $this->save();
+ }
+
+ /**
+ * Adjust brightness (range:-255 to 255)
+ * @return object
+ * @param $level int
+ **/
+ function brightness($level) {
+ imagefilter($this->data,IMG_FILTER_BRIGHTNESS,$level);
+ return $this->save();
+ }
+
+ /**
+ * Adjust contrast (range:-100 to 100)
+ * @return object
+ * @param $level int
+ **/
+ function contrast($level) {
+ imagefilter($this->data,IMG_FILTER_CONTRAST,$level);
+ return $this->save();
+ }
+
+ /**
+ * Convert to grayscale
+ * @return object
+ **/
+ function grayscale() {
+ imagefilter($this->data,IMG_FILTER_GRAYSCALE);
+ return $this->save();
+ }
+
+ /**
+ * Adjust smoothness
+ * @return object
+ * @param $level int
+ **/
+ function smooth($level) {
+ imagefilter($this->data,IMG_FILTER_SMOOTH,$level);
+ return $this->save();
+ }
+
+ /**
+ * Emboss the image
+ * @return object
+ **/
+ function emboss() {
+ imagefilter($this->data,IMG_FILTER_EMBOSS);
+ return $this->save();
+ }
+
+ /**
+ * Apply sepia effect
+ * @return object
+ **/
+ function sepia() {
+ imagefilter($this->data,IMG_FILTER_GRAYSCALE);
+ imagefilter($this->data,IMG_FILTER_COLORIZE,90,60,45);
+ return $this->save();
+ }
+
+ /**
+ * Pixelate the image
+ * @return object
+ * @param $size int
+ **/
+ function pixelate($size) {
+ imagefilter($this->data,IMG_FILTER_PIXELATE,$size,TRUE);
+ return $this->save();
+ }
+
+ /**
+ * Blur the image using Gaussian filter
+ * @return object
+ * @param $selective bool
+ **/
+ function blur($selective=FALSE) {
+ imagefilter($this->data,
+ $selective?IMG_FILTER_SELECTIVE_BLUR:IMG_FILTER_GAUSSIAN_BLUR);
+ return $this->save();
+ }
+
+ /**
+ * Apply sketch effect
+ * @return object
+ **/
+ function sketch() {
+ imagefilter($this->data,IMG_FILTER_MEAN_REMOVAL);
+ return $this->save();
+ }
+
+ /**
+ * Flip on horizontal axis
+ * @return object
+ **/
+ function hflip() {
+ $tmp=imagecreatetruecolor(
+ $width=$this->width(),$height=$this->height());
+ imagesavealpha($tmp,TRUE);
+ imagefill($tmp,0,0,IMG_COLOR_TRANSPARENT);
+ imagecopyresampled($tmp,$this->data,
+ 0,0,$width-1,0,$width,$height,-$width,$height);
+ imagedestroy($this->data);
+ $this->data=$tmp;
+ return $this->save();
+ }
+
+ /**
+ * Flip on vertical axis
+ * @return object
+ **/
+ function vflip() {
+ $tmp=imagecreatetruecolor(
+ $width=$this->width(),$height=$this->height());
+ imagesavealpha($tmp,TRUE);
+ imagefill($tmp,0,0,IMG_COLOR_TRANSPARENT);
+ imagecopyresampled($tmp,$this->data,
+ 0,0,0,$height-1,$width,$height,$width,-$height);
+ imagedestroy($this->data);
+ $this->data=$tmp;
+ return $this->save();
+ }
+
+ /**
+ * Crop the image
+ * @return object
+ * @param $x1 int
+ * @param $y1 int
+ * @param $x2 int
+ * @param $y2 int
+ **/
+ function crop($x1,$y1,$x2,$y2) {
+ $tmp=imagecreatetruecolor($width=$x2-$x1+1,$height=$y2-$y1+1);
+ imagesavealpha($tmp,TRUE);
+ imagefill($tmp,0,0,IMG_COLOR_TRANSPARENT);
+ imagecopyresampled($tmp,$this->data,
+ 0,0,$x1,$y1,$width,$height,$width,$height);
+ imagedestroy($this->data);
+ $this->data=$tmp;
+ return $this->save();
+ }
+
+ /**
+ * Resize image (Maintain aspect ratio); Crop relative to center
+ * if flag is enabled; Enlargement allowed if flag is enabled
+ * @return object
+ * @param $width int
+ * @param $height int
+ * @param $crop bool
+ * @param $enlarge bool
+ **/
+ function resize($width,$height,$crop=TRUE,$enlarge=TRUE) {
+ // Adjust dimensions; retain aspect ratio
+ $ratio=($origw=imagesx($this->data))/($origh=imagesy($this->data));
+ if (!$crop)
+ if ($width/$ratio<=$height)
+ $height=$width/$ratio;
+ else
+ $width=$height*$ratio;
+ if (!$enlarge) {
+ $width=min($origw,$width);
+ $height=min($origh,$height);
+ }
+ // Create blank image
+ $tmp=imagecreatetruecolor($width,$height);
+ imagesavealpha($tmp,TRUE);
+ imagefill($tmp,0,0,IMG_COLOR_TRANSPARENT);
+ // Resize
+ if ($crop) {
+ if ($width/$ratio<=$height) {
+ $cropw=$origh*$width/$height;
+ imagecopyresampled($tmp,$this->data,
+ 0,0,($origw-$cropw)/2,0,$width,$height,$cropw,$origh);
+ }
+ else {
+ $croph=$origw*$height/$width;
+ imagecopyresampled($tmp,$this->data,
+ 0,0,0,($origh-$croph)/2,$width,$height,$origw,$croph);
+ }
+ }
+ else
+ imagecopyresampled($tmp,$this->data,
+ 0,0,0,0,$width,$height,$origw,$origh);
+ imagedestroy($this->data);
+ $this->data=$tmp;
+ return $this->save();
+ }
+
+ /**
+ * Rotate image
+ * @return object
+ * @param $angle int
+ **/
+ function rotate($angle) {
+ $this->data=imagerotate($this->data,$angle,
+ imagecolorallocatealpha($this->data,0,0,0,127));
+ imagesavealpha($this->data,TRUE);
+ return $this->save();
+ }
+
+ /**
+ * Apply an image overlay
+ * @return object
+ * @param $img object
+ * @param $align int
+ **/
+ function overlay(Image $img,$align=NULL) {
+ if (is_null($align))
+ $align=self::POS_Right|self::POS_Bottom;
+ $ovr=imagecreatefromstring($img->dump());
+ imagesavealpha($ovr,TRUE);
+ $imgw=$this->width();
+ $imgh=$this->height();
+ $ovrw=imagesx($ovr);
+ $ovrh=imagesy($ovr);
+ if ($align & self::POS_Left)
+ $posx=0;
+ if ($align & self::POS_Center)
+ $posx=($imgw-$ovrw)/2;
+ if ($align & self::POS_Right)
+ $posx=$imgw-$ovrw;
+ if ($align & self::POS_Top)
+ $posy=0;
+ if ($align & self::POS_Middle)
+ $posy=($imgh-$ovrh)/2;
+ if ($align & self::POS_Bottom)
+ $posy=$imgh-$ovrh;
+ if (empty($posx))
+ $posx=0;
+ if (empty($posy))
+ $posy=0;
+ imagecopy($this->data,$ovr,$posx,$posy,0,0,$ovrw,$ovrh);
+ return $this->save();
+ }
+
+ /**
+ * Generate identicon
+ * @return object
+ * @param $str string
+ * @param $size int
+ * @param $blocks int
+ **/
+ function identicon($str,$size=64,$blocks=4) {
+ $sprites=array(
+ array(.5,1,1,0,1,1),
+ array(.5,0,1,0,.5,1,0,1),
+ array(.5,0,1,0,1,1,.5,1,1,.5),
+ array(0,.5,.5,0,1,.5,.5,1,.5,.5),
+ array(0,.5,1,0,1,1,0,1,1,.5),
+ array(1,0,1,1,.5,1,1,.5,.5,.5),
+ array(0,0,1,0,1,.5,0,0,.5,1,0,1),
+ array(0,0,.5,0,1,.5,.5,1,0,1,.5,.5),
+ array(.5,0,.5,.5,1,.5,1,1,.5,1,.5,.5,0,.5),
+ array(0,0,1,0,.5,.5,1,.5,.5,1,.5,.5,0,1),
+ array(0,.5,.5,1,1,.5,.5,0,1,0,1,1,0,1),
+ array(.5,0,1,0,1,1,.5,1,1,.75,.5,.5,1,.25),
+ array(0,.5,.5,0,.5,.5,1,0,1,.5,.5,1,.5,.5,0,1),
+ array(0,0,1,0,1,1,0,1,1,.5,.5,.25,.5,.75,0,.5,.5,.25),
+ array(0,.5,.5,.5,.5,0,1,0,.5,.5,1,.5,.5,1,.5,.5,0,1),
+ array(0,0,1,0,.5,.5,.5,0,0,.5,1,.5,.5,1,.5,.5,0,1)
+ );
+ $hash=sha1($str);
+ $this->data=imagecreatetruecolor($size,$size);
+ list($r,$g,$b)=$this->rgb(hexdec(substr($hash,-3)));
+ $fg=imagecolorallocate($this->data,$r,$g,$b);
+ imagefill($this->data,0,0,IMG_COLOR_TRANSPARENT);
+ $ctr=count($sprites);
+ $dim=$blocks*floor($size/$blocks)*2/$blocks;
+ for ($j=0,$y=ceil($blocks/2);$j<$y;$j++)
+ for ($i=$j,$x=$blocks-1-$j;$i<$x;$i++) {
+ $sprite=imagecreatetruecolor($dim,$dim);
+ imagefill($sprite,0,0,IMG_COLOR_TRANSPARENT);
+ if ($block=$sprites[
+ hexdec($hash[($j*$blocks+$i)*2])%$ctr]) {
+ for ($k=0,$pts=count($block);$k<$pts;$k++)
+ $block[$k]*=$dim;
+ imagefilledpolygon($sprite,$block,$pts/2,$fg);
+ }
+ $sprite=imagerotate($sprite,
+ 90*(hexdec($hash[($j*$blocks+$i)*2+1])%4),
+ imagecolorallocatealpha($sprite,0,0,0,127));
+ for ($k=0;$k<4;$k++) {
+ imagecopyresampled($this->data,$sprite,
+ $i*$dim/2,$j*$dim/2,0,0,$dim/2,$dim/2,$dim,$dim);
+ $this->data=imagerotate($this->data,90,
+ imagecolorallocatealpha($this->data,0,0,0,127));
+ }
+ imagedestroy($sprite);
+ }
+ imagesavealpha($this->data,TRUE);
+ return $this->save();
+ }
+
+ /**
+ * Generate CAPTCHA image
+ * @return object|FALSE
+ * @param $font string
+ * @param $size int
+ * @param $len int
+ * @param $key string
+ * @param $path string
+ * @param $fg int
+ * @param $bg int
+ **/
+ function captcha($font,$size=24,$len=5,
+ $key=NULL,$path='',$fg=0xFFFFFF,$bg=0x000000) {
+ if ((!$ssl=extension_loaded('openssl')) && ($len<4 || $len>13)) {
+ user_error(sprintf(self::E_Length,$len));
+ return FALSE;
+ }
+ $fw=Base::instance();
+ foreach ($fw->split($path?:$fw->get('UI').';./') as $dir)
+ if (is_file($path=$dir.$font)) {
+ $seed=strtoupper(substr(
+ $ssl?bin2hex(openssl_random_pseudo_bytes($len)):uniqid(),
+ -$len));
+ $block=$size*3;
+ $tmp=array();
+ for ($i=0,$width=0,$height=0;$i<$len;$i++) {
+ // Process at 2x magnification
+ $box=imagettfbbox($size*2,0,$path,$seed[$i]);
+ $w=$box[2]-$box[0];
+ $h=$box[1]-$box[5];
+ $char=imagecreatetruecolor($block,$block);
+ imagefill($char,0,0,$bg);
+ imagettftext($char,$size*2,0,
+ ($block-$w)/2,$block-($block-$h)/2,
+ $fg,$path,$seed[$i]);
+ $char=imagerotate($char,mt_rand(-30,30),
+ imagecolorallocatealpha($char,0,0,0,127));
+ // Reduce to normal size
+ $tmp[$i]=imagecreatetruecolor(
+ ($w=imagesx($char))/2,($h=imagesy($char))/2);
+ imagefill($tmp[$i],0,0,IMG_COLOR_TRANSPARENT);
+ imagecopyresampled($tmp[$i],$char,0,0,0,0,$w/2,$h/2,$w,$h);
+ imagedestroy($char);
+ $width+=$i+1<$len?$block/2:$w/2;
+ $height=max($height,$h/2);
+ }
+ $this->data=imagecreatetruecolor($width,$height);
+ imagefill($this->data,0,0,IMG_COLOR_TRANSPARENT);
+ for ($i=0;$i<$len;$i++) {
+ imagecopy($this->data,$tmp[$i],
+ $i*$block/2,($height-imagesy($tmp[$i]))/2,0,0,
+ imagesx($tmp[$i]),imagesy($tmp[$i]));
+ imagedestroy($tmp[$i]);
+ }
+ imagesavealpha($this->data,TRUE);
+ if ($key)
+ $fw->set($key,$seed);
+ return $this->save();
+ }
+ user_error(self::E_Font);
+ return FALSE;
+ }
+
+ /**
+ * Return image width
+ * @return int
+ **/
+ function width() {
+ return imagesx($this->data);
+ }
+
+ /**
+ * Return image height
+ * @return int
+ **/
+ function height() {
+ return imagesy($this->data);
+ }
+
+ /**
+ * Send image to HTTP client
+ * @return NULL
+ **/
+ function render() {
+ $args=func_get_args();
+ $format=$args?array_shift($args):'png';
+ if (PHP_SAPI!='cli') {
+ header('Content-Type: image/'.$format);
+ header('X-Powered-By: '.Base::instance()->get('PACKAGE'));
+ }
+ call_user_func_array('image'.$format,
+ array_merge(array($this->data),$args));
+ }
+
+ /**
+ * Return image as a string
+ * @return string
+ **/
+ function dump() {
+ $args=func_get_args();
+ $format=$args?array_shift($args):'png';
+ ob_start();
+ call_user_func_array('image'.$format,
+ array_merge(array($this->data),$args));
+ return ob_get_clean();
+ }
+
+ /**
+ * Save current state
+ * @return object
+ **/
+ function save() {
+ $fw=Base::instance();
+ if ($this->flag) {
+ if (!is_dir($dir=$fw->get('TEMP')))
+ mkdir($dir,Base::MODE,TRUE);
+ $this->count++;
+ $fw->write($dir.'/'.
+ $fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash($this->file).'-'.$this->count.'.png',
+ $this->dump());
+ }
+ return $this;
+ }
+
+ /**
+ * Revert to specified state
+ * @return object
+ * @param $state int
+ **/
+ function restore($state=1) {
+ $fw=Base::instance();
+ if ($this->flag && is_file($file=($path=$fw->get('TEMP').
+ $fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash($this->file).'-').$state.'.png')) {
+ if (is_resource($this->data))
+ imagedestroy($this->data);
+ $this->data=imagecreatefromstring($fw->read($file));
+ imagesavealpha($this->data,TRUE);
+ foreach (glob($path.'*.png',GLOB_NOSORT) as $match)
+ if (preg_match('/-(\d+)\.png/',$match,$parts) &&
+ $parts[1]>$state)
+ @unlink($match);
+ $this->count=$state;
+ }
+ return $this;
+ }
+
+ /**
+ * Undo most recently applied filter
+ * @return object
+ **/
+ function undo() {
+ if ($this->flag) {
+ if ($this->count)
+ $this->count--;
+ return $this->restore($this->count);
+ }
+ return $this;
+ }
+
+ /**
+ * Load string
+ * @return object
+ * @param $str string
+ **/
+ function load($str) {
+ $this->data=imagecreatefromstring($str);
+ imagesavealpha($this->data,TRUE);
+ $this->save();
+ return $this;
+ }
+
+ /**
+ * Instantiate image
+ * @param $file string
+ * @param $flag bool
+ * @param $path string
+ **/
+ function __construct($file=NULL,$flag=FALSE,$path='') {
+ $this->flag=$flag;
+ if ($file) {
+ $fw=Base::instance();
+ // Create image from file
+ $this->file=$file;
+ foreach ($fw->split($path?:$fw->get('UI').';./') as $dir)
+ if (is_file($dir.$file))
+ return $this->load($fw->read($dir.$file));
+ }
+ }
+
+ /**
+ * Wrap-up
+ * @return NULL
+ **/
+ function __destruct() {
+ if (is_resource($this->data)) {
+ imagedestroy($this->data);
+ $fw=Base::instance();
+ $path=$fw->get('TEMP').
+ $fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash($this->file);
+ if ($glob=@glob($path.'*.png',GLOB_NOSORT))
+ foreach ($glob as $match)
+ if (preg_match('/-(\d+)\.png/',$match))
+ @unlink($match);
+ }
+ }
+
+}
diff --git a/management-interface/lib/license.txt b/management-interface/lib/license.txt
new file mode 100644
index 0000000..3c7236c
--- /dev/null
+++ b/management-interface/lib/license.txt
@@ -0,0 +1,621 @@
+GNU GENERAL PUBLIC LICENSE
+Version 3, 29 June 2007
+
+Copyright (C) 2007 Free Software Foundation, Inc. '.$this->build($str).' '."\n\n"):'';
+ }
+
+ /**
+ * Process whitespace-prefixed code block
+ * @return string
+ * @param $str string
+ **/
+ protected function _pre($str) {
+ $str=preg_replace('/(?<=^|\n)(?: {4}|\t)(.+?(?:\n+|$))/','\1',
+ $this->esc($str));
+ return strlen($str)?
+ (''.
+ $this->esc($this->snip($str)).
+ ''.
+ $this->esc($match[2]).$match[3].
+ ' '.
+ ($match[4]?
+ (''.
+ $this->esc($match[4]).
+ ' '):
+ '').
+ ''.
+ $this->esc($match[5]).
+ ' '):
+ (''.
+ $match[6].
+ ' '.
+ ''.
+ $this->esc($match[7]).
+ ' ')).
+ $match[8];
+ $str=''.$out.'';
+ break;
+ case 'html':
+ preg_match_all(
+ '/(?:(?:<(\/?)(\w+)'.
+ '((?:\h+(?:\w+\h*=\h*)?".+?"|[^>]+)*|'.
+ '\h+.+?)(\h*\/?)>)|(.+?))/s',
+ $str,$matches,PREG_SET_ORDER
+ );
+ $out='';
+ foreach ($matches as $match) {
+ if ($match[2]) {
+ $out.='<'.
+ $match[1].$match[2].' ';
+ if ($match[3]) {
+ preg_match_all(
+ '/(?:\h+(?:(?:(\w+)\h*=\h*)?'.
+ '(".+?")|(.+)))/',
+ $match[3],$parts,PREG_SET_ORDER
+ );
+ foreach ($parts as $part)
+ $out.=' '.
+ (empty($part[3])?
+ ((empty($part[1])?
+ '':
+ (''.
+ $part[1].' =')).
+ ''.
+ $part[2].' '):
+ (''.
+ $part[3].' '));
+ }
+ $out.=''.
+ $match[4].'> ';
+ }
+ else
+ $out.=$this->esc($match[5]);
+ }
+ $str=''.$out.'';
+ break;
+ case 'ini':
+ preg_match_all(
+ '/(?<=^|\n)(?:'.
+ '(;[^\n]*)|(?:<\?php.+?\?>?)|'.
+ '(?:\[(.+?)\])|'.
+ '(.+?)\h*=\h*'.
+ '((?:\\\\\h*\r?\n|.+?)*)'.
+ ')((?:\r?\n)+|$)/',
+ $str,$matches,PREG_SET_ORDER
+ );
+ $out='';
+ foreach ($matches as $match) {
+ if ($match[1])
+ $out.='';
+ elseif ($match[2])
+ $out.='['.$match[2].']'.
+ ' ';
+ elseif ($match[3])
+ $out.=''.$match[3].
+ ' ='.
+ ($match[4]?
+ (''.
+ $match[4].' '):'');
+ else
+ $out.=$match[0];
+ if (isset($match[5]))
+ $out.=$match[5];
+ }
+ $str=''.$out.'';
+ break;
+ default:
+ $str=''.$this->esc($str).'';
+ break;
+ }
+ }
+ else
+ $str=''.$this->esc($str).'';
+ return ''.$str.' '."\n\n";
+ }
+
+ /**
+ * Process horizontal rule
+ * @return string
+ **/
+ protected function _hr() {
+ return ''.
+ $this->scan($str).' '."\n\n";
+ }
+
+ /**
+ * Process setext-style heading
+ * @return string
+ * @param $str string
+ * @param $type string
+ **/
+ protected function _setext($str,$type) {
+ $level=strpos('=-',$type)+1;
+ return ''.
+ $this->scan($str).' '."\n\n";
+ }
+
+ /**
+ * Process ordered/unordered list
+ * @return string
+ * @param $str string
+ **/
+ protected function _li($str) {
+ // Initialize list parser
+ $len=strlen($str);
+ $ptr=0;
+ $dst='';
+ $first=TRUE;
+ $tight=TRUE;
+ $type='ul';
+ // Main loop
+ while ($ptr<$len) {
+ if (preg_match('/^\h*[*-](?:\h?[*-]){2,}(?:\n+|$)/',
+ substr($str,$ptr),$match)) {
+ $ptr+=strlen($match[0]);
+ // Embedded horizontal rule
+ return (strlen($dst)?
+ ('<'.$type.'>'."\n".$dst.''."\n\n"):'').
+ ''.$this->scan(trim($tmp)).' '."\n";
+ }
+ }
+ return strlen($dst)?
+ ('<'.$type.'>'."\n".$dst.''."\n\n"):'';
+ }
+
+ /**
+ * Ignore raw HTML
+ * @return string
+ * @param $str string
+ **/
+ protected function _raw($str) {
+ return $str;
+ }
+
+ /**
+ * Process paragraph
+ * @return string
+ * @param $str string
+ **/
+ protected function _p($str) {
+ $str=trim($str);
+ if (strlen($str)) {
+ if (preg_match('/^(.+?\n)([>#].+)$/s',$str,$parts))
+ return $this->_p($parts[1]).$this->build($parts[2]);
+ $self=$this;
+ $str=preg_replace_callback(
+ '/([^<>\[]+)?(<[\?%].+?[\?%]>|<.+?>|\[.+?\]\s*\(.+?\))|'.
+ '(.+)/s',
+ function($expr) use($self) {
+ $tmp='';
+ if (isset($expr[4]))
+ $tmp.=$self->esc($expr[4]);
+ else {
+ if (isset($expr[1]))
+ $tmp.=$self->esc($expr[1]);
+ $tmp.=$expr[2];
+ if (isset($expr[3]))
+ $tmp.=$self->esc($expr[3]);
+ }
+ return $tmp;
+ },
+ $str
+ );
+ return ''.$this->scan($str).'
'."\n\n";
+ }
+ return '';
+ }
+
+ /**
+ * Process strong/em/strikethrough spans
+ * @return string
+ * @param $str string
+ **/
+ protected function _text($str) {
+ $tmp='';
+ while ($str!=$tmp)
+ $str=preg_replace_callback(
+ '/(?'.$expr[2].' ';
+ case 2:
+ return ''.$expr[2].' ';
+ case 3:
+ return ''.$expr[2].' '.$self->scan($expr[1]).' ';
+ },
+ $str
+ );
+ }
+
+ /**
+ * Auto-convert links
+ * @return string
+ * @param $str string
+ **/
+ protected function _auto($str) {
+ $self=$this;
+ return preg_replace_callback(
+ '/`.*?<(.+?)>.*?`|<(.+?)>/',
+ function($expr) use($self) {
+ if (empty($expr[1]) && parse_url($expr[2],PHP_URL_SCHEME)) {
+ $expr[2]=$self->esc($expr[2]);
+ return ''.$expr[2].' ';
+ }
+ return $expr[0];
+ },
+ $str
+ );
+ }
+
+ /**
+ * Process code span
+ * @return string
+ * @param $str string
+ **/
+ protected function _code($str) {
+ $self=$this;
+ return preg_replace_callback(
+ '/`` (.+?) ``|(?'.
+ $self->esc(empty($expr[1])?$expr[2]:$expr[1]).'';
+ },
+ $str
+ );
+ }
+
+ /**
+ * Convert characters to HTML entities
+ * @return string
+ * @param $str string
+ **/
+ function esc($str) {
+ if (!$this->special)
+ $this->special=array(
+ '...'=>'…',
+ '(tm)'=>'™',
+ '(r)'=>'®',
+ '(c)'=>'©'
+ );
+ foreach ($this->special as $key=>$val)
+ $str=preg_replace('/'.preg_quote($key,'/').'/i',$val,$str);
+ return htmlspecialchars($str,ENT_COMPAT,
+ Base::instance()->get('ENCODING'),FALSE);
+ }
+
+ /**
+ * Reduce multiple line feeds
+ * @return string
+ * @param $str string
+ **/
+ protected function snip($str) {
+ return preg_replace('/(?:(?<=\n)\n+)|\n+$/',"\n",$str);
+ }
+
+ /**
+ * Scan line for convertible spans
+ * @return string
+ * @param $str string
+ **/
+ function scan($str) {
+ $inline=array('img','a','text','auto','code');
+ foreach ($inline as $func)
+ $str=$this->{'_'.$func}($str);
+ return $str;
+ }
+
+ /**
+ * Assemble blocks
+ * @return string
+ * @param $str string
+ **/
+ protected function build($str) {
+ if (!$this->blocks) {
+ // Regexes for capturing entire blocks
+ $this->blocks=array(
+ 'blockquote'=>'/^(?:\h?>\h?.*?(?:\n+|$))+/',
+ 'pre'=>'/^(?:(?: {4}|\t).+?(?:\n+|$))+/',
+ 'fence'=>'/^`{3}\h*(\w+)?.*?[^\n]*\n+(.+?)`{3}[^\n]*'.
+ '(?:\n+|$)/s',
+ 'hr'=>'/^\h*[*_-](?:\h?[\*_-]){2,}\h*(?:\n+|$)/',
+ 'atx'=>'/^\h*(#{1,6})\h?(.+?)\h*(?:#.*)?(?:\n+|$)/',
+ 'setext'=>'/^\h*(.+?)\h*\n([=-])+\h*(?:\n+|$)/',
+ 'li'=>'/^(?:(?:[*+-]|\d+\.)\h.+?(?:\n+|$)'.
+ '(?:(?: {4}|\t)+.+?(?:\n+|$))*)+/s',
+ 'raw'=>'/^((?:|'.
+ '<(address|article|aside|audio|blockquote|canvas|dd|'.
+ 'div|dl|fieldset|figcaption|figure|footer|form|h\d|'.
+ 'header|hgroup|hr|noscript|object|ol|output|p|pre|'.
+ 'section|table|tfoot|ul|video).*?'.
+ '(?:\/>|>(?:(?>[^><]+)|(?R))*<\/\2>))'.
+ '\h*(?:\n{2,}|\n*$)|<[\?%].+?[\?%]>\h*(?:\n?$|\n*))/s',
+ 'p'=>'/^(.+?(?:\n{2,}|\n*$))/s'
+ );
+ }
+ $self=$this;
+ // Treat lines with nothing but whitespaces as empty lines
+ $str=preg_replace('/\n\h+(?=\n)/',"\n",$str);
+ // Initialize block parser
+ $len=strlen($str);
+ $ptr=0;
+ $dst='';
+ // Main loop
+ while ($ptr<$len) {
+ if (preg_match('/^ {0,3}\[([^\[\]]+)\]:\s*?\s*'.
+ '(?:"([^\n]*)")?(?:\n+|$)/s',substr($str,$ptr),$match)) {
+ // Reference-style link; Backtrack
+ $ptr+=strlen($match[0]);
+ $tmp='';
+ // Catch line breaks in title attribute
+ $ref=preg_replace('/\h/','\s',preg_quote($match[1],'/'));
+ while ($dst!=$tmp) {
+ $dst=preg_replace_callback(
+ '/(?esc($match[2]).'"'.
+ (empty($match[3])?
+ '':
+ (' title="'.
+ $self->esc($match[3]).'"')).'>'.
+ // Link
+ $self->scan(
+ empty($expr[3])?
+ (empty($expr[1])?
+ $expr[4]:
+ $expr[1]):
+ $expr[3]
+ ).''):
+ // Image
+ ('.+?<\/code>|'.
+ '<[^>\n]+>|\([^\n\)]+\)|"[^"\n]+")|'.
+ '\\\\(.)/s',
+ function($expr) {
+ // Process escaped characters
+ return empty($expr[1])?$expr[2]:$expr[1];
+ },
+ $this->build(preg_replace('/\r\n|\r/',"\n",$txt))
+ );
+ return $this->snip($txt);
+ }
+
+}
diff --git a/management-interface/lib/matrix.php b/management-interface/lib/matrix.php
new file mode 100644
index 0000000..70ae3de
--- /dev/null
+++ b/management-interface/lib/matrix.php
@@ -0,0 +1,101 @@
+$cols)
+ foreach ($cols as $keyy=>$valy)
+ $out[$keyy][$keyx]=$valy;
+ $var=$out;
+ }
+
+ /**
+ * Sort a multi-dimensional array variable on a specified column
+ * @return bool
+ * @param $var array
+ * @param $col mixed
+ * @param $order int
+ **/
+ function sort(array &$var,$col,$order=SORT_ASC) {
+ uasort(
+ $var,
+ function($val1,$val2) use($col,$order) {
+ list($v1,$v2)=array($val1[$col],$val2[$col]);
+ $out=is_numeric($v1) && is_numeric($v2)?
+ Base::instance()->sign($v1-$v2):strcmp($v1,$v2);
+ if ($order==SORT_DESC)
+ $out=-$out;
+ return $out;
+ }
+ );
+ $var=array_values($var);
+ }
+
+ /**
+ * Change the key of a two-dimensional array element
+ * @return NULL
+ * @param $var array
+ * @param $old string
+ * @param $new string
+ **/
+ function changekey(array &$var,$old,$new) {
+ $keys=array_keys($var);
+ $vals=array_values($var);
+ $keys[array_search($old,$keys)]=$new;
+ $var=array_combine($keys,$vals);
+ }
+
+ /**
+ * Return month calendar of specified date, with optional setting for
+ * first day of week (0 for Sunday)
+ * @return array
+ * @param $date string
+ * @param $first int
+ **/
+ function calendar($date='now',$first=0) {
+ $parts=getdate(strtotime($date));
+ $days=cal_days_in_month(CAL_GREGORIAN,$parts['mon'],$parts['year']);
+ $ref=date('w',strtotime(date('Y-m',$parts[0]).'-01'))+(7-$first)%7;
+ $out=array();
+ for ($i=0;$i<$days;$i++)
+ $out[floor(($ref+$i)/7)][($ref+$i)%7]=$i+1;
+ return $out;
+ }
+
+}
diff --git a/management-interface/lib/session.php b/management-interface/lib/session.php
new file mode 100644
index 0000000..fcc45fc
--- /dev/null
+++ b/management-interface/lib/session.php
@@ -0,0 +1,180 @@
+sid)
+ $this->sid=$id;
+ return Cache::instance()->exists($id.'.@',$data)?$data['data']:FALSE;
+ }
+
+ /**
+ * Write session data
+ * @return TRUE
+ * @param $id string
+ * @param $data string
+ **/
+ function write($id,$data) {
+ $fw=Base::instance();
+ $sent=headers_sent();
+ $headers=$fw->get('HEADERS');
+ $csrf=$fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(mt_rand());
+ $jar=$fw->get('JAR');
+ if ($id!=$this->sid)
+ $this->sid=$id;
+ Cache::instance()->set($id.'.@',
+ array(
+ 'data'=>$data,
+ 'csrf'=>$sent?$this->csrf():$csrf,
+ 'ip'=>$fw->get('IP'),
+ 'agent'=>isset($headers['User-Agent'])?
+ $headers['User-Agent']:'',
+ 'stamp'=>time()
+ ),
+ $jar['expire']?($jar['expire']-time()):0
+ );
+ return TRUE;
+ }
+
+ /**
+ * Destroy session
+ * @return TRUE
+ * @param $id string
+ **/
+ function destroy($id) {
+ Cache::instance()->clear($id.'.@');
+ setcookie(session_name(),'',strtotime('-1 year'));
+ unset($_COOKIE[session_name()]);
+ header_remove('Set-Cookie');
+ return TRUE;
+ }
+
+ /**
+ * Garbage collector
+ * @return TRUE
+ * @param $max int
+ **/
+ function cleanup($max) {
+ Cache::instance()->reset('.@',$max);
+ return TRUE;
+ }
+
+ /**
+ * Return anti-CSRF token
+ * @return string|FALSE
+ **/
+ function csrf() {
+ return Cache::instance()->
+ exists(($this->sid?:session_id()).'.@',$data)?
+ $data['csrf']:FALSE;
+ }
+
+ /**
+ * Return IP address
+ * @return string|FALSE
+ **/
+ function ip() {
+ return Cache::instance()->
+ exists(($this->sid?:session_id()).'.@',$data)?
+ $data['ip']:FALSE;
+ }
+
+ /**
+ * Return Unix timestamp
+ * @return string|FALSE
+ **/
+ function stamp() {
+ return Cache::instance()->
+ exists(($this->sid?:session_id()).'.@',$data)?
+ $data['stamp']:FALSE;
+ }
+
+ /**
+ * Return HTTP user agent
+ * @return string|FALSE
+ **/
+ function agent() {
+ return Cache::instance()->
+ exists(($this->sid?:session_id()).'.@',$data)?
+ $data['agent']:FALSE;
+ }
+
+ /**
+ * Instantiate class
+ * @return object
+ **/
+ function __construct() {
+ session_set_save_handler(
+ array($this,'open'),
+ array($this,'close'),
+ array($this,'read'),
+ array($this,'write'),
+ array($this,'destroy'),
+ array($this,'cleanup')
+ );
+ register_shutdown_function('session_commit');
+ @session_start();
+ $fw=\Base::instance();
+ $headers=$fw->get('HEADERS');
+ if (($ip=$this->ip()) && $ip!=$fw->get('IP') ||
+ ($agent=$this->agent()) &&
+ (!isset($headers['User-Agent']) ||
+ $agent!=$headers['User-Agent'])) {
+ session_destroy();
+ \Base::instance()->error(403);
+ }
+ $csrf=$fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(mt_rand());
+ $jar=$fw->get('JAR');
+ if (Cache::instance()->exists(($this->sid=session_id()).'.@',$data)) {
+ $data['csrf']=$csrf;
+ Cache::instance()->set($this->sid.'.@',
+ $data,
+ $jar['expire']?($jar['expire']-time()):0
+ );
+ }
+ }
+
+}
diff --git a/management-interface/lib/smtp.php b/management-interface/lib/smtp.php
new file mode 100644
index 0000000..d9041b5
--- /dev/null
+++ b/management-interface/lib/smtp.php
@@ -0,0 +1,274 @@
+fixheader($key);
+ return isset($this->headers[$key]);
+ }
+
+ /**
+ * Bind value to e-mail header
+ * @return string
+ * @param $key string
+ * @param $val string
+ **/
+ function set($key,$val) {
+ $key=$this->fixheader($key);
+ return $this->headers[$key]=$val;
+ }
+
+ /**
+ * Return value of e-mail header
+ * @return string|NULL
+ * @param $key string
+ **/
+ function get($key) {
+ $key=$this->fixheader($key);
+ return isset($this->headers[$key])?$this->headers[$key]:NULL;
+ }
+
+ /**
+ * Remove header
+ * @return NULL
+ * @param $key string
+ **/
+ function clear($key) {
+ $key=$this->fixheader($key);
+ unset($this->headers[$key]);
+ }
+
+ /**
+ * Return client-server conversation history
+ * @return string
+ **/
+ function log() {
+ return str_replace("\n",PHP_EOL,$this->log);
+ }
+
+ /**
+ * Send SMTP command and record server response
+ * @return string
+ * @param $cmd string
+ * @param $log bool
+ **/
+ protected function dialog($cmd=NULL,$log=TRUE) {
+ $socket=&$this->socket;
+ if (!is_null($cmd))
+ fputs($socket,$cmd."\r\n");
+ $reply='';
+ while (!feof($socket) && ($info=stream_get_meta_data($socket)) &&
+ !$info['timed_out'] && $str=fgets($socket,4096)) {
+ $reply.=$str;
+ if (preg_match('/(?:^|\n)\d{3} .+?\r\n/s',$reply))
+ break;
+ }
+ if ($log) {
+ $this->log.=$cmd."\n";
+ $this->log.=str_replace("\r",'',$reply);
+ }
+ return $reply;
+ }
+
+ /**
+ * Add e-mail attachment
+ * @return NULL
+ * @param $file
+ **/
+ function attach($file) {
+ if (!is_file($file))
+ user_error(sprintf(self::E_Attach,$file));
+ $this->attachments[]=$file;
+ }
+
+ /**
+ * Transmit message
+ * @return bool
+ * @param $message string
+ * @param $log bool
+ **/
+ function send($message,$log=TRUE) {
+ if ($this->scheme=='ssl' && !extension_loaded('openssl'))
+ return FALSE;
+ // Message should not be blank
+ if (!$message)
+ user_error(self::E_Blank);
+ $fw=Base::instance();
+ // Retrieve headers
+ $headers=$this->headers;
+ // Connect to the server
+ $socket=&$this->socket;
+ $socket=@fsockopen($this->host,$this->port);
+ if (!$socket)
+ return FALSE;
+ stream_set_blocking($socket,TRUE);
+ // Get server's initial response
+ $this->dialog(NULL,FALSE);
+ // Announce presence
+ $reply=$this->dialog('EHLO '.$fw->get('HOST'),$log);
+ if (strtolower($this->scheme)=='tls') {
+ $this->dialog('STARTTLS',$log);
+ stream_socket_enable_crypto(
+ $socket,TRUE,STREAM_CRYPTO_METHOD_TLS_CLIENT);
+ $reply=$this->dialog('EHLO '.$fw->get('HOST'),$log);
+ if (preg_match('/8BITMIME/',$reply))
+ $headers['Content-Transfer-Encoding']='8bit';
+ else {
+ $headers['Content-Transfer-Encoding']='quoted-printable';
+ $message=quoted_printable_encode($message);
+ }
+ }
+ if ($this->user && $this->pw && preg_match('/AUTH/',$reply)) {
+ // Authenticate
+ $this->dialog('AUTH LOGIN',$log);
+ $this->dialog(base64_encode($this->user),$log);
+ $this->dialog(base64_encode($this->pw),$log);
+ }
+ // Required headers
+ $reqd=array('From','To','Subject');
+ foreach ($reqd as $id)
+ if (empty($headers[$id]))
+ user_error(sprintf(self::E_Header,$id));
+ $eol="\r\n";
+ $str='';
+ // Stringify headers
+ foreach ($headers as $key=>$val)
+ if (!in_array($key,$reqd))
+ $str.=$key.': '.$val.$eol;
+ // Start message dialog
+ $this->dialog('MAIL FROM: '.strstr($headers['From'],'<'),$log);
+ foreach ($fw->split($headers['To'].
+ (isset($headers['Cc'])?(';'.$headers['Cc']):'').
+ (isset($headers['Bcc'])?(';'.$headers['Bcc']):'')) as $dst)
+ $this->dialog('RCPT TO: '.strstr($dst,'<'),$log);
+ $this->dialog('DATA',$log);
+ if ($this->attachments) {
+ // Replace Content-Type
+ $hash=uniqid(NULL,TRUE);
+ $type=$headers['Content-Type'];
+ $headers['Content-Type']='multipart/mixed; '.
+ 'boundary="'.$hash.'"';
+ // Send mail headers
+ $out='';
+ foreach ($headers as $key=>$val)
+ if ($key!='Bcc')
+ $out.=$key.': '.$val.$eol;
+ $out.=$eol;
+ $out.='This is a multi-part message in MIME format'.$eol;
+ $out.=$eol;
+ $out.='--'.$hash.$eol;
+ $out.='Content-Type: '.$type.$eol;
+ $out.=$eol;
+ $out.=$message.$eol;
+ foreach ($this->attachments as $attachment) {
+ $out.='--'.$hash.$eol;
+ $out.='Content-Type: application/octet-stream'.$eol;
+ $out.='Content-Transfer-Encoding: base64'.$eol;
+ $out.='Content-Disposition: attachment; '.
+ 'filename="'.basename($attachment).'"'.$eol;
+ $out.=$eol;
+ $out.=chunk_split(
+ base64_encode(file_get_contents($attachment))).$eol;
+ }
+ $out.=$eol;
+ $out.='--'.$hash.'--'.$eol;
+ $out.='.';
+ $this->dialog($out,FALSE);
+ }
+ else {
+ // Send mail headers
+ $out='';
+ foreach ($headers as $key=>$val)
+ if ($key!='Bcc')
+ $out.=$key.': '.$val.$eol;
+ $out.=$eol;
+ $out.=$message.$eol;
+ $out.='.';
+ // Send message
+ $this->dialog($out);
+ }
+ $this->dialog('QUIT',$log);
+ if ($socket)
+ fclose($socket);
+ return TRUE;
+ }
+
+ /**
+ * Instantiate class
+ * @param $host string
+ * @param $port int
+ * @param $scheme string
+ * @param $user string
+ * @param $pw string
+ **/
+ function __construct($host,$port,$scheme,$user,$pw) {
+ $this->headers=array(
+ 'MIME-Version'=>'1.0',
+ 'Content-Type'=>'text/plain; '.
+ 'charset='.Base::instance()->get('ENCODING')
+ );
+ $this->host=$host;
+ if (strtolower($this->scheme=strtolower($scheme))=='ssl')
+ $this->host='ssl://'.$host;
+ $this->port=$port;
+ $this->user=$user;
+ $this->pw=$pw;
+ }
+
+}
diff --git a/management-interface/lib/template.php b/management-interface/lib/template.php
new file mode 100644
index 0000000..59ccb97
--- /dev/null
+++ b/management-interface/lib/template.php
@@ -0,0 +1,335 @@
+$val)
+ $out.='$'.$key.'='.
+ (preg_match('/\{\{(.+?)\}\}/',$val)?
+ $this->token($val):
+ Base::instance()->stringify($val)).'; ';
+ return '';
+ }
+
+ /**
+ * Template -include- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _include(array $node) {
+ $attrib=$node['@attrib'];
+ return
+ 'token($attrib['if']).') '):'').
+ ('echo $this->render('.
+ (preg_match('/\{\{(.+?)\}\}/',$attrib['href'])?
+ $this->token($attrib['href']):
+ Base::instance()->stringify($attrib['href'])).','.
+ '$this->mime,get_defined_vars()); ?>');
+ }
+
+ /**
+ * Template -exclude- tag handler
+ * @return string
+ **/
+ protected function _exclude() {
+ return '';
+ }
+
+ /**
+ * Template -ignore- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _ignore(array $node) {
+ return $node[0];
+ }
+
+ /**
+ * Template -loop- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _loop(array $node) {
+ $attrib=$node['@attrib'];
+ unset($node['@attrib']);
+ return
+ 'token($attrib['from']).';'.
+ $this->token($attrib['to']).';'.
+ $this->token($attrib['step']).'): ?>'.
+ $this->build($node).
+ '';
+ }
+
+ /**
+ * Template -repeat- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _repeat(array $node) {
+ $attrib=$node['@attrib'];
+ unset($node['@attrib']);
+ return
+ 'token($attrib['counter'])).'=0; '):'').
+ 'foreach (('.
+ $this->token($attrib['group']).'?:array()) as '.
+ (isset($attrib['key'])?
+ ($this->token($attrib['key']).'=>'):'').
+ $this->token($attrib['value']).'):'.
+ (isset($ctr)?(' '.$ctr.'++;'):'').' ?>'.
+ $this->build($node).
+ '';
+ }
+
+ /**
+ * Template -check- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _check(array $node) {
+ $attrib=$node['@attrib'];
+ unset($node['@attrib']);
+ // Grab and blocks
+ foreach ($node as $pos=>$block)
+ if (isset($block['true']))
+ $true=array($pos,$block);
+ elseif (isset($block['false']))
+ $false=array($pos,$block);
+ if (isset($true,$false) && $true[0]>$false[0])
+ // Reverse and blocks
+ list($node[$true[0]],$node[$false[0]])=array($false[1],$true[1]);
+ return
+ 'token($attrib['if']).'): ?>'.
+ $this->build($node).
+ '';
+ }
+
+ /**
+ * Template -true- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _true(array $node) {
+ return $this->build($node);
+ }
+
+ /**
+ * Template -false- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _false(array $node) {
+ return ''.$this->build($node);
+ }
+
+ /**
+ * Template -switch- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _switch(array $node) {
+ $attrib=$node['@attrib'];
+ unset($node['@attrib']);
+ foreach ($node as $pos=>$block)
+ if (is_string($block) && !preg_replace('/\s+/','',$block))
+ unset($node[$pos]);
+ return
+ 'token($attrib['expr']).'): ?>'.
+ $this->build($node).
+ '';
+ }
+
+ /**
+ * Template -case- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _case(array $node) {
+ $attrib=$node['@attrib'];
+ unset($node['@attrib']);
+ return
+ 'token($attrib['value']):
+ Base::instance()->stringify($attrib['value'])).': ?>'.
+ $this->build($node).
+ 'token($attrib['break']).') ':'').
+ 'break; ?>';
+ }
+
+ /**
+ * Template -default- tag handler
+ * @return string
+ * @param $node array
+ **/
+ protected function _default(array $node) {
+ return
+ ''.
+ $this->build($node).
+ '';
+ }
+
+ /**
+ * Assemble markup
+ * @return string
+ * @param $node array|string
+ **/
+ protected function build($node) {
+ if (is_string($node))
+ return parent::build($node);
+ $out='';
+ foreach ($node as $key=>$val)
+ $out.=is_int($key)?$this->build($val):$this->{'_'.$key}($val);
+ return $out;
+ }
+
+ /**
+ * Extend template with custom tag
+ * @return NULL
+ * @param $tag string
+ * @param $func callback
+ **/
+ function extend($tag,$func) {
+ $this->tags.='|'.$tag;
+ $this->custom['_'.$tag]=$func;
+ }
+
+ /**
+ * Call custom tag handler
+ * @return string|FALSE
+ * @param $func callback
+ * @param $args array
+ **/
+ function __call($func,array $args) {
+ if ($func[0]=='_')
+ return call_user_func_array($this->custom[$func],$args);
+ if (method_exists($this,$func))
+ return call_user_func_array(array($this,$func),$args);
+ user_error(sprintf(self::E_Method,$func));
+ }
+
+ /**
+ * Parse string for template directives and tokens
+ * @return string|array
+ * @param $text string
+ **/
+ function parse($text) {
+ // Build tree structure
+ for ($ptr=0,$len=strlen($text),$tree=array(),$node=&$tree,
+ $stack=array(),$depth=0,$tmp='';$ptr<$len;)
+ if (preg_match('/^<(\/?)(?:F3:)?'.
+ '('.$this->tags.')\b((?:\h+[\w-]+'.
+ '(?:\h*=\h*(?:"(?:.+?)"|\'(?:.+?)\'))?|'.
+ '\h*\{\{.+?\}\})*)\h*(\/?)>/is',
+ substr($text,$ptr),$match)) {
+ if (strlen($tmp))
+ $node[]=$tmp;
+ // Element node
+ if ($match[1]) {
+ // Find matching start tag
+ $save=$depth;
+ $found=FALSE;
+ while ($depth>0) {
+ $depth--;
+ foreach ($stack[$depth] as $item)
+ if (is_array($item) && isset($item[$match[2]])) {
+ // Start tag found
+ $found=TRUE;
+ break 2;
+ }
+ }
+ if (!$found)
+ // Unbalanced tag
+ $depth=$save;
+ $node=&$stack[$depth];
+ }
+ else {
+ // Start tag
+ $stack[$depth]=&$node;
+ $node=&$node[][$match[2]];
+ if ($match[3]) {
+ // Process attributes
+ preg_match_all(
+ '/(?:\b([\w-]+)\h*'.
+ '(?:=\h*(?:"(.+?)"|\'(.+?)\'))?|'.
+ '(\{\{.+?\}\}))/s',
+ $match[3],$attr,PREG_SET_ORDER);
+ foreach ($attr as $kv)
+ if (isset($kv[4]))
+ $node['@attrib'][]=$kv[4];
+ else
+ $node['@attrib'][$kv[1]]=
+ (empty($kv[2])?
+ (empty($kv[3])?NULL:$kv[3]):$kv[2]);
+ }
+ if ($match[4])
+ // Empty tag
+ $node=&$stack[$depth];
+ else
+ $depth++;
+ }
+ $tmp='';
+ $ptr+=strlen($match[0]);
+ }
+ else {
+ // Text node
+ $tmp.=substr($text,$ptr,1);
+ $ptr++;
+ }
+ if (strlen($tmp))
+ // Append trailing text
+ $node[]=$tmp;
+ // Break references
+ unset($node);
+ unset($stack);
+ return $tree;
+ }
+
+ /**
+ * Class constructor
+ * return object
+ **/
+ function __construct() {
+ $ref=new ReflectionClass(__CLASS__);
+ $this->tags='';
+ foreach ($ref->getmethods() as $method)
+ if (preg_match('/^_(?=[[:alpha:]])/',$method->name))
+ $this->tags.=(strlen($this->tags)?'|':'').
+ substr($method->name,1);
+ }
+
+}
diff --git a/management-interface/lib/test.php b/management-interface/lib/test.php
new file mode 100644
index 0000000..3a36abd
--- /dev/null
+++ b/management-interface/lib/test.php
@@ -0,0 +1,77 @@
+data;
+ }
+
+ /**
+ * Evaluate condition and save test result
+ * @return object
+ * @param $cond bool
+ * @param $text string
+ **/
+ function expect($cond,$text=NULL) {
+ $out=(bool)$cond;
+ if ($this->level==$out || $this->level==self::FLAG_Both) {
+ $data=array('status'=>$out,'text'=>$text,'source'=>NULL);
+ foreach (debug_backtrace() as $frame)
+ if (isset($frame['file'])) {
+ $data['source']=Base::instance()->
+ fixslashes($frame['file']).':'.$frame['line'];
+ break;
+ }
+ $this->data[]=$data;
+ }
+ return $this;
+ }
+
+ /**
+ * Append message to test results
+ * @return NULL
+ * @param $text string
+ **/
+ function message($text) {
+ $this->expect(TRUE,$text);
+ }
+
+ /**
+ * Class constructor
+ * @return NULL
+ * @param $level int
+ **/
+ function __construct($level=self::FLAG_Both) {
+ $this->level=$level;
+ }
+
+}
diff --git a/management-interface/lib/utf.php b/management-interface/lib/utf.php
new file mode 100644
index 0000000..63dcb3a
--- /dev/null
+++ b/management-interface/lib/utf.php
@@ -0,0 +1,192 @@
+strpos($stack,$needle,$ofs,TRUE);
+ }
+
+ /**
+ * Find position of first occurrence of a string
+ * @return int|FALSE
+ * @param $stack string
+ * @param $needle string
+ * @param $ofs int
+ * @param $case bool
+ **/
+ function strpos($stack,$needle,$ofs=0,$case=FALSE) {
+ return preg_match('/^(.{'.$ofs.'}.*?)'.
+ preg_quote($needle,'/').'/us'.($case?'i':''),$stack,$match)?
+ $this->strlen($match[1]):FALSE;
+ }
+
+ /**
+ * Returns part of haystack string from the first occurrence of
+ * needle to the end of haystack (case-insensitive)
+ * @return string|FALSE
+ * @param $stack string
+ * @param $needle string
+ * @param $before bool
+ **/
+ function stristr($stack,$needle,$before=FALSE) {
+ return $this->strstr($stack,$needle,$before,TRUE);
+ }
+
+ /**
+ * Returns part of haystack string from the first occurrence of
+ * needle to the end of haystack
+ * @return string|FALSE
+ * @param $stack string
+ * @param $needle string
+ * @param $before bool
+ * @param $case bool
+ **/
+ function strstr($stack,$needle,$before=FALSE,$case=FALSE) {
+ if (!$needle)
+ return FALSE;
+ preg_match('/^(.*?)'.preg_quote($needle,'/').'/us'.($case?'i':''),
+ $stack,$match);
+ return isset($match[1])?
+ ($before?
+ $match[1]:
+ $this->substr($stack,$this->strlen($match[1]))):
+ FALSE;
+ }
+
+ /**
+ * Return part of a string
+ * @return string|FALSE
+ * @param $str string
+ * @param $start int
+ * @param $len int
+ **/
+ function substr($str,$start,$len=0) {
+ if ($start<0)
+ $start=$this->strlen($str)+$start;
+ if (!$len)
+ $len=$this->strlen($str)-$start;
+ return preg_match('/^.{'.$start.'}(.{0,'.$len.'})/us',$str,$match)?
+ $match[1]:FALSE;
+ }
+
+ /**
+ * Count the number of substring occurrences
+ * @return int
+ * @param $stack string
+ * @param $needle string
+ **/
+ function substr_count($stack,$needle) {
+ preg_match_all('/'.preg_quote($needle,'/').'/us',$stack,
+ $matches,PREG_SET_ORDER);
+ return count($matches);
+ }
+
+ /**
+ * Strip whitespaces from the beginning of a string
+ * @return string
+ * @param $str string
+ **/
+ function ltrim($str) {
+ return preg_replace('/^[\pZ\pC]+/u','',$str);
+ }
+
+ /**
+ * Strip whitespaces from the end of a string
+ * @return string
+ * @param $str string
+ **/
+ function rtrim($str) {
+ return preg_replace('/[\pZ\pC]+$/u','',$str);
+ }
+
+ /**
+ * Strip whitespaces from the beginning and end of a string
+ * @return string
+ * @param $str string
+ **/
+ function trim($str) {
+ return preg_replace('/^[\pZ\pC]+|[\pZ\pC]+$/u','',$str);
+ }
+
+ /**
+ * Return UTF-8 byte order mark
+ * @return string
+ **/
+ function bom() {
+ return chr(0xef).chr(0xbb).chr(0xbf);
+ }
+
+ /**
+ * Convert code points to Unicode symbols
+ * @return string
+ * @param $str string
+ **/
+ function translate($str) {
+ return html_entity_decode(
+ preg_replace('/\\\\u([[:xdigit:]]+)/i','&#x\1;',$str));
+ }
+
+ /**
+ * Translate emoji tokens to Unicode font-supported symbols
+ * @return string
+ * @param $str string
+ **/
+ function emojify($str) {
+ $map=array(
+ ':('=>'\u2639', // frown
+ ':)'=>'\u263a', // smile
+ '<3'=>'\u2665', // heart
+ ':D'=>'\u1f603', // grin
+ 'XD'=>'\u1f606', // laugh
+ ';)'=>'\u1f609', // wink
+ ':P'=>'\u1f60b', // tongue
+ ':,'=>'\u1f60f', // think
+ ':/'=>'\u1f623', // skeptic
+ '8O'=>'\u1f632', // oops
+ )+Base::instance()->get('EMOJI');
+ return $this->translate(str_replace(array_keys($map),
+ array_values($map),$str));
+ }
+
+}
diff --git a/management-interface/lib/web.php b/management-interface/lib/web.php
new file mode 100644
index 0000000..6af5a83
--- /dev/null
+++ b/management-interface/lib/web.php
@@ -0,0 +1,838 @@
+'audio/basic',
+ 'avi'=>'video/avi',
+ 'bmp'=>'image/bmp',
+ 'bz2'=>'application/x-bzip2',
+ 'css'=>'text/css',
+ 'dtd'=>'application/xml-dtd',
+ 'doc'=>'application/msword',
+ 'gif'=>'image/gif',
+ 'gz'=>'application/x-gzip',
+ 'hqx'=>'application/mac-binhex40',
+ 'html?'=>'text/html',
+ 'jar'=>'application/java-archive',
+ 'jpe?g'=>'image/jpeg',
+ 'js'=>'application/x-javascript',
+ 'midi'=>'audio/x-midi',
+ 'mp3'=>'audio/mpeg',
+ 'mpe?g'=>'video/mpeg',
+ 'ogg'=>'audio/vorbis',
+ 'pdf'=>'application/pdf',
+ 'png'=>'image/png',
+ 'ppt'=>'application/vnd.ms-powerpoint',
+ 'ps'=>'application/postscript',
+ 'qt'=>'video/quicktime',
+ 'ram?'=>'audio/x-pn-realaudio',
+ 'rdf'=>'application/rdf',
+ 'rtf'=>'application/rtf',
+ 'sgml?'=>'text/sgml',
+ 'sit'=>'application/x-stuffit',
+ 'svg'=>'image/svg+xml',
+ 'swf'=>'application/x-shockwave-flash',
+ 'tgz'=>'application/x-tar',
+ 'tiff'=>'image/tiff',
+ 'txt'=>'text/plain',
+ 'wav'=>'audio/wav',
+ 'xls'=>'application/vnd.ms-excel',
+ 'xml'=>'application/xml',
+ 'zip'=>'application/x-zip-compressed'
+ );
+ foreach ($map as $key=>$val)
+ if (preg_match('/'.$key.'/',strtolower($ext[0])))
+ return $val;
+ }
+ return 'application/octet-stream';
+ }
+
+ /**
+ * Return the MIME types stated in the HTTP Accept header as an array;
+ * If a list of MIME types is specified, return the best match; or
+ * FALSE if none found
+ * @return array|string|FALSE
+ * @param $list string|array
+ **/
+ function acceptable($list=NULL) {
+ $accept=array();
+ foreach (explode(',',str_replace(' ','',$_SERVER['HTTP_ACCEPT']))
+ as $mime)
+ if (preg_match('/(.+?)(?:;q=([\d\.]+)|$)/',$mime,$parts))
+ $accept[$parts[1]]=isset($parts[2])?$parts[2]:1;
+ if (!$accept)
+ $accept['*/*']=1;
+ else {
+ krsort($accept);
+ arsort($accept);
+ }
+ if ($list) {
+ if (is_string($list))
+ $list=explode(',',$list);
+ foreach ($accept as $mime=>$q)
+ if ($q && $out=preg_grep('/'.
+ str_replace('\*','.*',preg_quote($mime,'/')).'/',$list))
+ return current($out);
+ return FALSE;
+ }
+ return $accept;
+ }
+
+ /**
+ * Transmit file to HTTP client; Return file size if successful,
+ * FALSE otherwise
+ * @return int|FALSE
+ * @param $file string
+ * @param $mime string
+ * @param $kbps int
+ * @param $force bool
+ **/
+ function send($file,$mime=NULL,$kbps=0,$force=TRUE) {
+ if (!is_file($file))
+ return FALSE;
+ if (PHP_SAPI!='cli') {
+ header('Content-Type: '.($mime?:$this->mime($file)));
+ if ($force)
+ header('Content-Disposition: attachment; '.
+ 'filename='.basename($file));
+ header('Accept-Ranges: bytes');
+ header('Content-Length: '.$size=filesize($file));
+ header('X-Powered-By: '.Base::instance()->get('PACKAGE'));
+ }
+ $ctr=0;
+ $handle=fopen($file,'rb');
+ $start=microtime(TRUE);
+ while (!feof($handle) &&
+ ($info=stream_get_meta_data($handle)) &&
+ !$info['timed_out'] && !connection_aborted()) {
+ if ($kbps) {
+ // Throttle output
+ $ctr++;
+ if ($ctr/$kbps>$elapsed=microtime(TRUE)-$start)
+ usleep(1e6*($ctr/$kbps-$elapsed));
+ }
+ // Send 1KiB and reset timer
+ echo fread($handle,1024);
+ }
+ fclose($handle);
+ return $size;
+ }
+
+ /**
+ * Receive file(s) from HTTP client
+ * @return array|bool
+ * @param $func callback
+ * @param $overwrite bool
+ * @param $slug callback|bool
+ **/
+ function receive($func=NULL,$overwrite=FALSE,$slug=TRUE) {
+ $fw=Base::instance();
+ $dir=$fw->get('UPLOADS');
+ if (!is_dir($dir))
+ mkdir($dir,Base::MODE,TRUE);
+ if ($fw->get('VERB')=='PUT') {
+ $tmp=$fw->get('TEMP').
+ $fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(uniqid());
+ if (!$fw->get('RAW'))
+ $fw->write($tmp,$fw->get('BODY'));
+ else {
+ $src=@fopen('php://input','r');
+ $dst=@fopen($tmp,'w');
+ if (!$src || !$dst)
+ return FALSE;
+ while (!feof($src) &&
+ ($info=stream_get_meta_data($src)) &&
+ !$info['timed_out'] && $str=fgets($src,4096))
+ fputs($dst,$str,strlen($str));
+ fclose($dst);
+ fclose($src);
+ }
+ $base=basename($fw->get('URI'));
+ $file=array(
+ 'name'=>$dir.
+ ($slug && preg_match('/(.+?)(\.\w+)?$/',$base,$parts)?
+ (is_callable($slug)?
+ $slug($base):
+ ($this->slug($parts[1]).
+ (isset($parts[2])?$parts[2]:''))):
+ $base),
+ 'tmp_name'=>$tmp,
+ 'type'=>$this->mime($base),
+ 'size'=>filesize($tmp)
+ );
+ return (!file_exists($file['name']) || $overwrite) &&
+ (!$func || $fw->call($func,array($file))!==FALSE) &&
+ rename($tmp,$file['name']);
+ }
+ $out=array();
+ foreach ($_FILES as $item) {
+ if (is_array($item['name'])) {
+ // Transpose array
+ $tmp=array();
+ foreach ($item as $keyx=>$cols)
+ foreach ($cols as $keyy=>$valy)
+ $tmp[$keyy][$keyx]=$valy;
+ $item=$tmp;
+ }
+ else
+ $item=array($item);
+ foreach ($item as $file) {
+ if (empty($file['name']))
+ continue;
+ $base=basename($file['name']);
+ $file['name']=$dir.
+ ($slug && preg_match('/(.+?)(\.\w+)?$/',$base,$parts)?
+ (is_callable($slug)?
+ $slug($base):
+ ($this->slug($parts[1]).
+ (isset($parts[2])?$parts[2]:''))):
+ $base);
+ $out[$file['name']]=!$file['error'] &&
+ is_uploaded_file($file['tmp_name']) &&
+ (!file_exists($file['name']) || $overwrite) &&
+ (!$func || $fw->call($func,array($file))!==FALSE) &&
+ move_uploaded_file($file['tmp_name'],$file['name']);
+ }
+ }
+ return $out;
+ }
+
+ /**
+ * Return upload progress in bytes, FALSE on failure
+ * @return int|FALSE
+ * @param $id string
+ **/
+ function progress($id) {
+ // ID returned by session.upload_progress.name
+ return ini_get('session.upload_progress.enabled') &&
+ isset($_SESSION[$id]['bytes_processed'])?
+ $_SESSION[$id]['bytes_processed']:FALSE;
+ }
+
+ /**
+ * HTTP request via cURL
+ * @return array
+ * @param $url string
+ * @param $options array
+ **/
+ protected function _curl($url,$options) {
+ $curl=curl_init($url);
+ curl_setopt($curl,CURLOPT_FOLLOWLOCATION,
+ $options['follow_location']);
+ curl_setopt($curl,CURLOPT_MAXREDIRS,
+ $options['max_redirects']);
+ curl_setopt($curl,CURLOPT_CUSTOMREQUEST,$options['method']);
+ if (isset($options['header']))
+ curl_setopt($curl,CURLOPT_HTTPHEADER,$options['header']);
+ if (isset($options['user_agent']))
+ curl_setopt($curl,CURLOPT_USERAGENT,$options['user_agent']);
+ if (isset($options['content']))
+ curl_setopt($curl,CURLOPT_POSTFIELDS,$options['content']);
+ curl_setopt($curl,CURLOPT_ENCODING,'gzip,deflate');
+ $timeout=isset($options['timeout'])?
+ $options['timeout']:
+ ini_get('default_socket_timeout');
+ curl_setopt($curl,CURLOPT_CONNECTTIMEOUT,$timeout);
+ curl_setopt($curl,CURLOPT_TIMEOUT,$timeout);
+ $headers=array();
+ curl_setopt($curl,CURLOPT_HEADERFUNCTION,
+ // Callback for response headers
+ function($curl,$line) use(&$headers) {
+ if ($trim=trim($line))
+ $headers[]=$trim;
+ return strlen($line);
+ }
+ );
+ curl_setopt($curl,CURLOPT_SSL_VERIFYPEER,FALSE);
+ ob_start();
+ curl_exec($curl);
+ curl_close($curl);
+ $body=ob_get_clean();
+ return array(
+ 'body'=>$body,
+ 'headers'=>$headers,
+ 'engine'=>'cURL',
+ 'cached'=>FALSE
+ );
+ }
+
+ /**
+ * HTTP request via PHP stream wrapper
+ * @return array
+ * @param $url string
+ * @param $options array
+ **/
+ protected function _stream($url,$options) {
+ $eol="\r\n";
+ $options['header']=implode($eol,$options['header']);
+ $body=@file_get_contents($url,FALSE,
+ stream_context_create(array('http'=>$options)));
+ $headers=isset($http_response_header)?
+ $http_response_header:array();
+ $match=NULL;
+ foreach ($headers as $header)
+ if (preg_match('/Content-Encoding: (.+)/',$header,$match))
+ break;
+ if ($match)
+ switch ($match[1]) {
+ case 'gzip':
+ $body=gzdecode($body);
+ break;
+ case 'deflate':
+ $body=gzuncompress($body);
+ break;
+ }
+ return array(
+ 'body'=>$body,
+ 'headers'=>$headers,
+ 'engine'=>'stream',
+ 'cached'=>FALSE
+ );
+ }
+
+ /**
+ * HTTP request via low-level TCP/IP socket
+ * @return array
+ * @param $url string
+ * @param $options array
+ **/
+ protected function _socket($url,$options) {
+ $eol="\r\n";
+ $headers=array();
+ $body='';
+ $parts=parse_url($url);
+ $empty=empty($parts['port']);
+ if ($parts['scheme']=='https') {
+ $parts['host']='ssl://'.$parts['host'];
+ if ($empty)
+ $parts['port']=443;
+ }
+ elseif ($empty)
+ $parts['port']=80;
+ if (empty($parts['path']))
+ $parts['path']='/';
+ if (empty($parts['query']))
+ $parts['query']='';
+ $socket=@fsockopen($parts['host'],$parts['port']);
+ if (!$socket)
+ return FALSE;
+ stream_set_blocking($socket,TRUE);
+ fputs($socket,$options['method'].' '.$parts['path'].
+ ($parts['query']?('?'.$parts['query']):'').' HTTP/1.0'.$eol
+ );
+ fputs($socket,implode($eol,$options['header']).$eol.$eol);
+ if (isset($options['content']))
+ fputs($socket,$options['content'].$eol);
+ // Get response
+ $content='';
+ while (!feof($socket) &&
+ ($info=stream_get_meta_data($socket)) &&
+ !$info['timed_out'] && $str=fgets($socket,4096))
+ $content.=$str;
+ fclose($socket);
+ $html=explode($eol.$eol,$content,2);
+ $body=isset($html[1])?$html[1]:'';
+ $headers=array_merge($headers,$current=explode($eol,$html[0]));
+ $match=NULL;
+ foreach ($current as $header)
+ if (preg_match('/Content-Encoding: (.+)/',$header,$match))
+ break;
+ if ($match)
+ switch ($match[1]) {
+ case 'gzip':
+ $body=gzdecode($body);
+ break;
+ case 'deflate':
+ $body=gzuncompress($body);
+ break;
+ }
+ if ($options['follow_location'] &&
+ preg_match('/Location: (.+?)'.preg_quote($eol).'/',
+ $html[0],$loc)) {
+ $options['max_redirects']--;
+ return $this->request($loc[1],$options);
+ }
+ return array(
+ 'body'=>$body,
+ 'headers'=>$headers,
+ 'engine'=>'socket',
+ 'cached'=>FALSE
+ );
+ }
+
+ /**
+ * Specify the HTTP request engine to use; If not available,
+ * fall back to an applicable substitute
+ * @return string
+ * @param $arg string
+ **/
+ function engine($arg='curl') {
+ $arg=strtolower($arg);
+ $flags=array(
+ 'curl'=>extension_loaded('curl'),
+ 'stream'=>ini_get('allow_url_fopen'),
+ 'socket'=>function_exists('fsockopen')
+ );
+ if ($flags[$arg])
+ return $this->wrapper=$arg;
+ foreach ($flags as $key=>$val)
+ if ($val)
+ return $this->wrapper=$key;
+ user_error(E_Request);
+ }
+
+ /**
+ * Replace old headers with new elements
+ * @return NULL
+ * @param $old array
+ * @param $new string|array
+ **/
+ function subst(array &$old,$new) {
+ if (is_string($new))
+ $new=array($new);
+ foreach ($new as $hdr) {
+ $old=preg_grep('/'.preg_quote(strstr($hdr,':',TRUE),'/').':.+/',
+ $old,PREG_GREP_INVERT);
+ array_push($old,$hdr);
+ }
+ }
+
+ /**
+ * Submit HTTP request; Use HTTP context options (described in
+ * http://www.php.net/manual/en/context.http.php) if specified;
+ * Cache the page as instructed by remote server
+ * @return array|FALSE
+ * @param $url string
+ * @param $options array
+ **/
+ function request($url,array $options=NULL) {
+ $fw=Base::instance();
+ $parts=parse_url($url);
+ if (empty($parts['scheme'])) {
+ // Local URL
+ $url=$fw->get('SCHEME').'://'.
+ $fw->get('HOST').
+ ($url[0]!='/'?($fw->get('BASE').'/'):'').$url;
+ $parts=parse_url($url);
+ }
+ elseif (!preg_match('/https?/',$parts['scheme']))
+ return FALSE;
+ if (!is_array($options))
+ $options=array();
+ if (empty($options['header']))
+ $options['header']=array();
+ elseif (is_string($options['header']))
+ $options['header']=array($options['header']);
+ if (!$this->wrapper)
+ $this->engine();
+ if ($this->wrapper!='stream') {
+ // PHP streams can't cope with redirects when Host header is set
+ foreach ($options['header'] as &$header)
+ if (preg_match('/^Host:/',$header)) {
+ $header='Host: '.$parts['host'];
+ unset($header);
+ break;
+ }
+ $this->subst($options['header'],'Host: '.$parts['host']);
+ }
+ $this->subst($options['header'],
+ array(
+ 'Accept-Encoding: gzip,deflate',
+ 'User-Agent: Mozilla/5.0 (compatible; '.php_uname('s').')',
+ 'Connection: close'
+ )
+ );
+ if (isset($options['content'])) {
+ if ($options['method']=='POST')
+ $this->subst($options['header'],
+ 'Content-Type: application/x-www-form-urlencoded');
+ $this->subst($options['header'],
+ 'Content-Length: '.strlen($options['content']));
+ }
+ if (isset($parts['user'],$parts['pass']))
+ $this->subst($options['header'],
+ 'Authorization: Basic '.
+ base64_encode($parts['user'].':'.$parts['pass'])
+ );
+ $options+=array(
+ 'method'=>'GET',
+ 'header'=>$options['header'],
+ 'follow_location'=>TRUE,
+ 'max_redirects'=>20,
+ 'ignore_errors'=>FALSE
+ );
+ $eol="\r\n";
+ if ($fw->get('CACHE') &&
+ preg_match('/GET|HEAD/',$options['method'])) {
+ $cache=Cache::instance();
+ if ($cache->exists(
+ $hash=$fw->hash($options['method'].' '.$url).'.url',$data)) {
+ if (preg_match('/Last-Modified: (.+?)'.preg_quote($eol).'/',
+ implode($eol,$data['headers']),$mod))
+ $this->subst($options['header'],
+ 'If-Modified-Since: '.$mod[1]);
+ }
+ }
+ $result=$this->{'_'.$this->wrapper}($url,$options);
+ if ($result && isset($cache)) {
+ if (preg_match('/HTTP\/1\.\d 304/',
+ implode($eol,$result['headers']))) {
+ $result=$cache->get($hash);
+ $result['cached']=TRUE;
+ }
+ elseif (preg_match('/Cache-Control: max-age=(.+?)'.
+ preg_quote($eol).'/',implode($eol,$result['headers']),$exp))
+ $cache->set($hash,$result,$exp[1]);
+ }
+ return $result;
+ }
+
+ /**
+ * Strip Javascript/CSS files of extraneous whitespaces and comments;
+ * Return combined output as a minified string
+ * @return string
+ * @param $files string|array
+ * @param $mime string
+ * @param $header bool
+ * @param $path string
+ **/
+ function minify($files,$mime=NULL,$header=TRUE,$path='') {
+ $fw=Base::instance();
+ if (is_string($files))
+ $files=$fw->split($files);
+ if (!$mime)
+ $mime=$this->mime($files[0]);
+ preg_match('/\w+$/',$files[0],$ext);
+ $cache=Cache::instance();
+ $dst='';
+ foreach ($fw->split($path?:$fw->get('UI').';./') as $dir)
+ foreach ($files as $file)
+ if (is_file($save=$fw->fixslashes($dir.$file))) {
+ if ($fw->get('CACHE') &&
+ ($cached=$cache->exists(
+ $hash=$fw->hash($save).'.'.$ext[0],$data)) &&
+ $cached[0]>filemtime($save))
+ $dst.=$data;
+ else {
+ $data='';
+ $src=$fw->read($save);
+ for ($ptr=0,$len=strlen($src);$ptr<$len;) {
+ if (preg_match('/^@import\h+url'.
+ '\(\h*([\'"])(.+?)\1\h*\)[^;]*;/',
+ substr($src,$ptr),$parts)) {
+ $path=dirname($file);
+ $data.=$this->minify(
+ ($path?($path.'/'):'').$parts[2],
+ $mime,$header
+ );
+ $ptr+=strlen($parts[0]);
+ continue;
+ }
+ if ($src[$ptr]=='/') {
+ if ($src[$ptr+1]=='*') {
+ // Multiline comment
+ $str=strstr(
+ substr($src,$ptr+2),'*/',TRUE);
+ $ptr+=strlen($str)+4;
+ }
+ elseif ($src[$ptr+1]=='/') {
+ // Single-line comment
+ $str=strstr(
+ substr($src,$ptr+2),"\n",TRUE);
+ $ptr+=strlen($str)+2;
+ }
+ else {
+ // Presume it's a regex pattern
+ $regex=TRUE;
+ // Backtrack and validate
+ for ($ofs=$ptr;$ofs;$ofs--) {
+ // Pattern should be preceded by
+ // open parenthesis, colon,
+ // object property or operator
+ if (preg_match(
+ '/(return|[(:=!+\-*&|])$/',
+ substr($src,0,$ofs))) {
+ $data.='/';
+ $ptr++;
+ while ($ptr<$len) {
+ $data.=$src[$ptr];
+ $ptr++;
+ if ($src[$ptr-1]=='\\') {
+ $data.=$src[$ptr];
+ $ptr++;
+ }
+ elseif ($src[$ptr-1]=='/')
+ break;
+ }
+ break;
+ }
+ elseif (!ctype_space($src[$ofs-1])) {
+ // Not a regex pattern
+ $regex=FALSE;
+ break;
+ }
+ }
+ if (!$regex) {
+ // Division operator
+ $data.=$src[$ptr];
+ $ptr++;
+ }
+ }
+ continue;
+ }
+ if (in_array($src[$ptr],array('\'','"'))) {
+ $match=$src[$ptr];
+ $data.=$match;
+ $ptr++;
+ // String literal
+ while ($ptr<$len) {
+ $data.=$src[$ptr];
+ $ptr++;
+ if ($src[$ptr-1]=='\\') {
+ $data.=$src[$ptr];
+ $ptr++;
+ }
+ elseif ($src[$ptr-1]==$match)
+ break;
+ }
+ continue;
+ }
+ if (ctype_space($src[$ptr])) {
+ if ($ptr+1get('CACHE'))
+ $cache->set($hash,$data);
+ $dst.=$data;
+ }
+ }
+ if (PHP_SAPI!='cli' && $header)
+ header('Content-Type: '.$mime.'; charset='.$fw->get('ENCODING'));
+ return $dst;
+ }
+
+ /**
+ * Retrieve RSS feed and return as an array
+ * @return array|FALSE
+ * @param $url string
+ * @param $max int
+ * @param $tags string
+ **/
+ function rss($url,$max=10,$tags=NULL) {
+ if (!$data=$this->request($url))
+ return FALSE;
+ // Suppress errors caused by invalid XML structures
+ libxml_use_internal_errors(TRUE);
+ $xml=simplexml_load_string($data['body'],
+ NULL,LIBXML_NOBLANKS|LIBXML_NOERROR);
+ if (!is_object($xml))
+ return FALSE;
+ $out=array();
+ if (isset($xml->channel)) {
+ $out['source']=(string)$xml->channel->title;
+ $max=min($max,count($xml->channel->item));
+ for ($i=0;$i<$max;$i++) {
+ $item=$xml->channel->item[$i];
+ $list=array(''=>NULL)+$item->getnamespaces(TRUE);
+ $fields=array();
+ foreach ($list as $ns=>$uri)
+ foreach ($item->children($uri) as $key=>$val)
+ $fields[$ns.($ns?':':'').$key]=(string)$val;
+ $out['feed'][]=$fields;
+ }
+ }
+ else
+ return FALSE;
+ Base::instance()->scrub($out,$tags);
+ return $out;
+ }
+
+ /**
+ * Retrieve information from whois server
+ * @return string|FALSE
+ * @param $addr string
+ * @param $server string
+ **/
+ function whois($addr,$server='whois.internic.net') {
+ $socket=@fsockopen($server,43,$errno,$errstr);
+ if (!$socket)
+ // Can't establish connection
+ return FALSE;
+ // Set connection timeout parameters
+ stream_set_blocking($socket,TRUE);
+ stream_set_timeout($socket,ini_get('default_socket_timeout'));
+ // Send request
+ fputs($socket,$addr."\r\n");
+ $info=stream_get_meta_data($socket);
+ // Get response
+ $response='';
+ while (!feof($socket) && !$info['timed_out']) {
+ $response.=fgets($socket,4096); // MDFK97
+ $info=stream_get_meta_data($socket);
+ }
+ fclose($socket);
+ return $info['timed_out']?FALSE:trim($response);
+ }
+
+ /**
+ * Return a URL/filesystem-friendly version of string
+ * @return string
+ * @param $text string
+ **/
+ function slug($text) {
+ return trim(strtolower(preg_replace('/([^\pL\pN])+/u','-',
+ trim(strtr(str_replace('\'','',$text),
+ array(
+ 'Ǎ'=>'A','А'=>'A','Ā'=>'A','Ă'=>'A','Ą'=>'A','Å'=>'A',
+ 'Ǻ'=>'A','Ä'=>'Ae','Á'=>'A','À'=>'A','Ã'=>'A','Â'=>'A',
+ 'Æ'=>'AE','Ǽ'=>'AE','Б'=>'B','Ç'=>'C','Ć'=>'C','Ĉ'=>'C',
+ 'Č'=>'C','Ċ'=>'C','Ц'=>'C','Ч'=>'Ch','Ð'=>'Dj','Đ'=>'Dj',
+ 'Ď'=>'Dj','Д'=>'Dj','É'=>'E','Ę'=>'E','Ё'=>'E','Ė'=>'E',
+ 'Ê'=>'E','Ě'=>'E','Ē'=>'E','È'=>'E','Е'=>'E','Э'=>'E',
+ 'Ë'=>'E','Ĕ'=>'E','Ф'=>'F','Г'=>'G','Ģ'=>'G','Ġ'=>'G',
+ 'Ĝ'=>'G','Ğ'=>'G','Х'=>'H','Ĥ'=>'H','Ħ'=>'H','Ï'=>'I',
+ 'Ĭ'=>'I','İ'=>'I','Į'=>'I','Ī'=>'I','Í'=>'I','Ì'=>'I',
+ 'И'=>'I','Ǐ'=>'I','Ĩ'=>'I','Î'=>'I','IJ'=>'IJ','Ĵ'=>'J',
+ 'Й'=>'J','Я'=>'Ja','Ю'=>'Ju','К'=>'K','Ķ'=>'K','Ĺ'=>'L',
+ 'Л'=>'L','Ł'=>'L','Ŀ'=>'L','Ļ'=>'L','Ľ'=>'L','М'=>'M',
+ 'Н'=>'N','Ń'=>'N','Ñ'=>'N','Ņ'=>'N','Ň'=>'N','Ō'=>'O',
+ 'О'=>'O','Ǿ'=>'O','Ǒ'=>'O','Ơ'=>'O','Ŏ'=>'O','Ő'=>'O',
+ 'Ø'=>'O','Ö'=>'Oe','Õ'=>'O','Ó'=>'O','Ò'=>'O','Ô'=>'O',
+ 'Œ'=>'OE','П'=>'P','Ŗ'=>'R','Р'=>'R','Ř'=>'R','Ŕ'=>'R',
+ 'Ŝ'=>'S','Ş'=>'S','Š'=>'S','Ș'=>'S','Ś'=>'S','С'=>'S',
+ 'Ш'=>'Sh','Щ'=>'Shch','Ť'=>'T','Ŧ'=>'T','Ţ'=>'T','Ț'=>'T',
+ 'Т'=>'T','Ů'=>'U','Ű'=>'U','Ŭ'=>'U','Ũ'=>'U','Ų'=>'U',
+ 'Ū'=>'U','Ǜ'=>'U','Ǚ'=>'U','Ù'=>'U','Ú'=>'U','Ü'=>'Ue',
+ 'Ǘ'=>'U','Ǖ'=>'U','У'=>'U','Ư'=>'U','Ǔ'=>'U','Û'=>'U',
+ 'В'=>'V','Ŵ'=>'W','Ы'=>'Y','Ŷ'=>'Y','Ý'=>'Y','Ÿ'=>'Y',
+ 'Ź'=>'Z','З'=>'Z','Ż'=>'Z','Ž'=>'Z','Ж'=>'Zh','á'=>'a',
+ 'ă'=>'a','â'=>'a','à'=>'a','ā'=>'a','ǻ'=>'a','å'=>'a',
+ 'ä'=>'ae','ą'=>'a','ǎ'=>'a','ã'=>'a','а'=>'a','ª'=>'a',
+ 'æ'=>'ae','ǽ'=>'ae','б'=>'b','č'=>'c','ç'=>'c','ц'=>'c',
+ 'ċ'=>'c','ĉ'=>'c','ć'=>'c','ч'=>'ch','ð'=>'dj','ď'=>'dj',
+ 'д'=>'dj','đ'=>'dj','э'=>'e','é'=>'e','ё'=>'e','ë'=>'e',
+ 'ê'=>'e','е'=>'e','ĕ'=>'e','è'=>'e','ę'=>'e','ě'=>'e',
+ 'ė'=>'e','ē'=>'e','ƒ'=>'f','ф'=>'f','ġ'=>'g','ĝ'=>'g',
+ 'ğ'=>'g','г'=>'g','ģ'=>'g','х'=>'h','ĥ'=>'h','ħ'=>'h',
+ 'ǐ'=>'i','ĭ'=>'i','и'=>'i','ī'=>'i','ĩ'=>'i','į'=>'i',
+ 'ı'=>'i','ì'=>'i','î'=>'i','í'=>'i','ï'=>'i','ij'=>'ij',
+ 'ĵ'=>'j','й'=>'j','я'=>'ja','ю'=>'ju','ķ'=>'k','к'=>'k',
+ 'ľ'=>'l','ł'=>'l','ŀ'=>'l','ĺ'=>'l','ļ'=>'l','л'=>'l',
+ 'м'=>'m','ņ'=>'n','ñ'=>'n','ń'=>'n','н'=>'n','ň'=>'n',
+ 'ʼn'=>'n','ó'=>'o','ò'=>'o','ǒ'=>'o','ő'=>'o','о'=>'o',
+ 'ō'=>'o','º'=>'o','ơ'=>'o','ŏ'=>'o','ô'=>'o','ö'=>'oe',
+ 'õ'=>'o','ø'=>'o','ǿ'=>'o','œ'=>'oe','п'=>'p','р'=>'r',
+ 'ř'=>'r','ŕ'=>'r','ŗ'=>'r','ſ'=>'s','ŝ'=>'s','ș'=>'s',
+ 'š'=>'s','ś'=>'s','с'=>'s','ş'=>'s','ш'=>'sh','щ'=>'shch',
+ 'ß'=>'ss','ţ'=>'t','т'=>'t','ŧ'=>'t','ť'=>'t','ț'=>'t',
+ 'у'=>'u','ǘ'=>'u','ŭ'=>'u','û'=>'u','ú'=>'u','ų'=>'u',
+ 'ù'=>'u','ű'=>'u','ů'=>'u','ư'=>'u','ū'=>'u','ǚ'=>'u',
+ 'ǜ'=>'u','ǔ'=>'u','ǖ'=>'u','ũ'=>'u','ü'=>'ue','в'=>'v',
+ 'ŵ'=>'w','ы'=>'y','ÿ'=>'y','ý'=>'y','ŷ'=>'y','ź'=>'z',
+ 'ž'=>'z','з'=>'z','ż'=>'z','ж'=>'zh'
+ )+Base::instance()->get('DIACRITICS'))))),'-');
+ }
+
+ /**
+ * Return chunk of text from standard Lorem Ipsum passage
+ * @return string
+ * @param $count int
+ * @param $max int
+ * @param $std bool
+ **/
+ function filler($count=1,$max=20,$std=TRUE) {
+ $out='';
+ if ($std)
+ $out='Lorem ipsum dolor sit amet, consectetur adipisicing elit, '.
+ 'sed do eiusmod tempor incididunt ut labore et dolore magna '.
+ 'aliqua.';
+ $rnd=explode(' ',
+ 'a ab ad accusamus adipisci alias aliquam amet animi aperiam '.
+ 'architecto asperiores aspernatur assumenda at atque aut beatae '.
+ 'blanditiis cillum commodi consequatur corporis corrupti culpa '.
+ 'cum cupiditate debitis delectus deleniti deserunt dicta '.
+ 'dignissimos distinctio dolor ducimus duis ea eaque earum eius '.
+ 'eligendi enim eos error esse est eum eveniet ex excepteur '.
+ 'exercitationem expedita explicabo facere facilis fugiat harum '.
+ 'hic id illum impedit in incidunt ipsa iste itaque iure iusto '.
+ 'laborum laudantium libero magnam maiores maxime minim minus '.
+ 'modi molestiae mollitia nam natus necessitatibus nemo neque '.
+ 'nesciunt nihil nisi nobis non nostrum nulla numquam occaecati '.
+ 'odio officia omnis optio pariatur perferendis perspiciatis '.
+ 'placeat porro possimus praesentium proident quae quia quibus '.
+ 'quo ratione recusandae reiciendis rem repellat reprehenderit '.
+ 'repudiandae rerum saepe sapiente sequi similique sint soluta '.
+ 'suscipit tempora tenetur totam ut ullam unde vel veniam vero '.
+ 'vitae voluptas');
+ for ($i=0,$add=$count-(int)$std;$i<$add;$i++) {
+ shuffle($rnd);
+ $words=array_slice($rnd,0,mt_rand(3,$max));
+ $out.=' '.ucfirst(implode(' ',$words)).'.';
+ }
+ return $out;
+ }
+
+}
+
+if (!function_exists('gzdecode')) {
+
+ /**
+ * Decode gzip-compressed string
+ * @param $str string
+ **/
+ function gzdecode($str) {
+ $fw=Base::instance();
+ if (!is_dir($tmp=$fw->get('TEMP')))
+ mkdir($tmp,Base::MODE,TRUE);
+ file_put_contents($file=$tmp.'/'.
+ $fw->hash($fw->get('ROOT').$fw->get('BASE')).'.'.
+ $fw->hash(uniqid(NULL,TRUE)).'.gz',$str,LOCK_EX);
+ ob_start();
+ readgzfile($file);
+ $out=ob_get_clean();
+ @unlink($file);
+ return $out;
+ }
+
+}
diff --git a/management-interface/lib/web/geo.php b/management-interface/lib/web/geo.php
new file mode 100644
index 0000000..c1b915e
--- /dev/null
+++ b/management-interface/lib/web/geo.php
@@ -0,0 +1,101 @@
+getLocation();
+ $trn=$ref->getTransitions($now=time(),$now);
+ $out=array(
+ 'offset'=>$ref->
+ getOffset(new \DateTime('now',new \DateTimeZone('GMT')))/3600,
+ 'country'=>$loc['country_code'],
+ 'latitude'=>$loc['latitude'],
+ 'longitude'=>$loc['longitude'],
+ 'dst'=>$trn[0]['isdst']
+ );
+ unset($ref);
+ return $out;
+ }
+
+ /**
+ * Return geolocation data based on specified/auto-detected IP address
+ * @return array|FALSE
+ * @param $ip string
+ **/
+ function location($ip=NULL) {
+ $fw=\Base::instance();
+ $web=\Web::instance();
+ if (!$ip)
+ $ip=$fw->get('IP');
+ $public=filter_var($ip,FILTER_VALIDATE_IP,
+ FILTER_FLAG_IPV4|FILTER_FLAG_IPV6|
+ FILTER_FLAG_NO_RES_RANGE|FILTER_FLAG_NO_PRIV_RANGE);
+ if (function_exists('geoip_db_avail') &&
+ geoip_db_avail(GEOIP_CITY_EDITION_REV1) &&
+ $out=@geoip_record_by_name($ip)) {
+ $out['request']=$ip;
+ $out['region_code']=$out['region'];
+ $out['region_name']=geoip_region_name_by_code(
+ $out['country_code'],$out['region']);
+ unset($out['country_code3'],$out['region'],$out['postal_code']);
+ return $out;
+ }
+ if (($req=$web->request('http://www.geoplugin.net/json.gp'.
+ ($public?('?ip='.$ip):''))) &&
+ $data=json_decode($req['body'],TRUE)) {
+ $out=array();
+ foreach ($data as $key=>$val)
+ if (!strpos($key,'currency') && $key!=='geoplugin_status'
+ && $key!=='geoplugin_region')
+ $out[$fw->snakecase(substr($key, 10))]=$val;
+ return $out;
+ }
+ return FALSE;
+ }
+
+ /**
+ * Return weather data based on specified latitude/longitude
+ * @return array|FALSE
+ * @param $latitude float
+ * @param $longitude float
+ **/
+ function weather($latitude,$longitude) {
+ $fw=\Base::instance();
+ $web=\Web::instance();
+ $query=array(
+ 'lat'=>$latitude,
+ 'lng'=>$longitude,
+ 'username'=>$fw->hash($fw->get('IP'))
+ );
+ return ($req=$web->request(
+ 'http://ws.geonames.org/findNearByWeatherJSON?'.
+ http_build_query($query))) &&
+ ($data=json_decode($req['body'],TRUE)) &&
+ isset($data['weatherObservation'])?
+ $data['weatherObservation']:
+ FALSE;
+ }
+
+}
diff --git a/management-interface/lib/web/google/staticmap.php b/management-interface/lib/web/google/staticmap.php
new file mode 100644
index 0000000..8d8a5fc
--- /dev/null
+++ b/management-interface/lib/web/google/staticmap.php
@@ -0,0 +1,58 @@
+query[]=array($func,$args[0]);
+ return $this;
+ }
+
+ /**
+ * Generate map
+ * @return string
+ **/
+ function dump() {
+ $fw=\Base::instance();
+ $web=\Web::instance();
+ $out='';
+ return ($req=$web->request(
+ self::URL_Static.'?'.array_reduce(
+ $this->query,
+ function($out,$item) {
+ return ($out.=($out?'&':'').
+ urlencode($item[0]).'='.urlencode($item[1]));
+ }
+ ))) && $req['body']?$req['body']:FALSE;
+ }
+
+}
diff --git a/management-interface/lib/web/openid.php b/management-interface/lib/web/openid.php
new file mode 100644
index 0000000..61ce575
--- /dev/null
+++ b/management-interface/lib/web/openid.php
@@ -0,0 +1,237 @@
+args['identity']))
+ $this->args['identity']='http://'.$this->args['identity'];
+ $url=parse_url($this->args['identity']);
+ // Remove fragment; reconnect parts
+ $this->args['identity']=$url['scheme'].'://'.
+ (isset($url['user'])?
+ ($url['user'].
+ (isset($url['pass'])?(':'.$url['pass']):'').'@'):'').
+ strtolower($url['host']).(isset($url['path'])?$url['path']:'/').
+ (isset($url['query'])?('?'.$url['query']):'');
+ // HTML-based discovery of OpenID provider
+ $req=\Web::instance()->
+ request($this->args['identity'],array('proxy'=>$proxy));
+ if (!$req)
+ return FALSE;
+ $type=array_values(preg_grep('/Content-Type:/',$req['headers']));
+ if ($type &&
+ preg_match('/application\/xrds\+xml|text\/xml/',$type[0]) &&
+ ($sxml=simplexml_load_string($req['body'])) &&
+ ($xrds=json_decode(json_encode($sxml),TRUE)) &&
+ isset($xrds['XRD'])) {
+ // XRDS document
+ $svc=$xrds['XRD']['Service'];
+ if (isset($svc[0]))
+ $svc=$svc[0];
+ if (preg_grep('/http:\/\/specs\.openid\.net\/auth\/2.0\/'.
+ '(?:server|signon)/',$svc['Type'])) {
+ $this->args['provider']=$svc['URI'];
+ if (isset($svc['LocalID']))
+ $this->args['localidentity']=$svc['LocalID'];
+ elseif (isset($svc['CanonicalID']))
+ $this->args['localidentity']=$svc['CanonicalID'];
+ }
+ $this->args['server']=$svc['URI'];
+ if (isset($svc['Delegate']))
+ $this->args['delegate']=$svc['Delegate'];
+ }
+ else {
+ $len=strlen($req['body']);
+ $ptr=0;
+ // Parse document
+ while ($ptr<$len)
+ if (preg_match(
+ '/^/is',
+ substr($req['body'],$ptr),$parts)) {
+ if ($parts[1] &&
+ // Process attributes
+ preg_match_all('/\b(rel|href)\h*=\h*'.
+ '(?:"(.+?)"|\'(.+?)\')/s',$parts[1],$attr,
+ PREG_SET_ORDER)) {
+ $node=array();
+ foreach ($attr as $kv)
+ $node[$kv[1]]=isset($kv[2])?$kv[2]:$kv[3];
+ if (isset($node['rel']) &&
+ preg_match('/openid2?\.(\w+)/',
+ $node['rel'],$var) &&
+ isset($node['href']))
+ $this->args[$var[1]]=$node['href'];
+
+ }
+ $ptr+=strlen($parts[0]);
+ }
+ else
+ $ptr++;
+ }
+ // Get OpenID provider's endpoint URL
+ if (isset($this->args['provider'])) {
+ // OpenID 2.0
+ $this->args['ns']='http://specs.openid.net/auth/2.0';
+ if (isset($this->args['localidentity']))
+ $this->args['identity']=$this->args['localidentity'];
+ if (isset($this->args['trust_root']))
+ $this->args['realm']=$this->args['trust_root'];
+ }
+ elseif (isset($this->args['server'])) {
+ // OpenID 1.1
+ $this->args['ns']='http://openid.net/signon/1.1';
+ if (isset($this->args['delegate']))
+ $this->args['identity']=$this->args['delegate'];
+ }
+ if (isset($this->args['provider'])) {
+ // OpenID 2.0
+ if (empty($this->args['claimed_id']))
+ $this->args['claimed_id']=$this->args['identity'];
+ return $this->args['provider'];
+ }
+ elseif (isset($this->args['server']))
+ // OpenID 1.1
+ return $this->args['server'];
+ else
+ return FALSE;
+ }
+
+ /**
+ * Initiate OpenID authentication sequence; Return FALSE on failure
+ * or redirect to OpenID provider URL
+ * @return bool
+ * @param $proxy string
+ * @param $attr array
+ * @param $reqd string|array
+ **/
+ function auth($proxy=NULL,$attr=array(),array $reqd=NULL) {
+ $fw=\Base::instance();
+ $root=$fw->get('SCHEME').'://'.$fw->get('HOST');
+ if (empty($this->args['trust_root']))
+ $this->args['trust_root']=$root.$fw->get('BASE').'/';
+ if (empty($this->args['return_to']))
+ $this->args['return_to']=$root.$_SERVER['REQUEST_URI'];
+ $this->args['mode']='checkid_setup';
+ if ($this->url=$this->discover($proxy)) {
+ if ($attr) {
+ $this->args['ns.ax']='http://openid.net/srv/ax/1.0';
+ $this->args['ax.mode']='fetch_request';
+ foreach ($attr as $key=>$val)
+ $this->args['ax.type.'.$key]=$val;
+ $this->args['ax.required']=is_string($reqd)?
+ $reqd:implode(',',$reqd);
+ }
+ $var=array();
+ foreach ($this->args as $key=>$val)
+ $var['openid.'.$key]=$val;
+ $fw->reroute($this->url.'?'.http_build_query($var));
+ }
+ return FALSE;
+ }
+
+ /**
+ * Return TRUE if OpenID verification was successful
+ * @return bool
+ * @param $proxy string
+ **/
+ function verified($proxy=NULL) {
+ preg_match_all('/(?<=^|&)openid\.([^=]+)=([^&]+)/',
+ $_SERVER['QUERY_STRING'],$matches,PREG_SET_ORDER);
+ foreach ($matches as $match)
+ $this->args[$match[1]]=urldecode($match[2]);
+ if (isset($this->args['mode']) &&
+ $this->args['mode']!='error' &&
+ $this->url=$this->discover($proxy)) {
+ $this->args['mode']='check_authentication';
+ $var=array();
+ foreach ($this->args as $key=>$val)
+ $var['openid.'.$key]=$val;
+ $req=\Web::instance()->request(
+ $this->url,
+ array(
+ 'method'=>'POST',
+ 'content'=>http_build_query($var),
+ 'proxy'=>$proxy
+ )
+ );
+ return (bool)preg_match('/is_valid:true/i',$req['body']);
+ }
+ return FALSE;
+ }
+
+ /**
+ * Return OpenID response fields
+ * @return array
+ **/
+ function response() {
+ return $this->args;
+ }
+
+ /**
+ * Return TRUE if OpenID request parameter exists
+ * @return bool
+ * @param $key string
+ **/
+ function exists($key) {
+ return isset($this->args[$key]);
+ }
+
+ /**
+ * Bind value to OpenID request parameter
+ * @return string
+ * @param $key string
+ * @param $val string
+ **/
+ function set($key,$val) {
+ return $this->args[$key]=$val;
+ }
+
+ /**
+ * Return value of OpenID request parameter
+ * @return mixed
+ * @param $key string
+ **/
+ function get($key) {
+ return isset($this->args[$key])?$this->args[$key]:NULL;
+ }
+
+ /**
+ * Remove OpenID request parameter
+ * @return NULL
+ * @param $key
+ **/
+ function clear($key) {
+ unset($this->args[$key]);
+ }
+
+}
+
diff --git a/management-interface/lib/web/pingback.php b/management-interface/lib/web/pingback.php
new file mode 100644
index 0000000..897ed67
--- /dev/null
+++ b/management-interface/lib/web/pingback.php
@@ -0,0 +1,170 @@
+request($url);
+ $found=FALSE;
+ if ($req && $req['body']) {
+ // Look for pingback header
+ foreach ($req['headers'] as $header)
+ if (preg_match('/^X-Pingback:\h*(.+)/',$header,$href)) {
+ $found=$href[1];
+ break;
+ }
+ if (!$found &&
+ // Scan page for pingback link tag
+ preg_match('//i',$req['body'],$parts) &&
+ preg_match('/rel\h*=\h*"pingback"/i',$parts[1]) &&
+ preg_match('/href\h*=\h*"\h*(.+?)\h*"/i',$parts[1],$href))
+ $found=$href[1];
+ }
+ return $found;
+ }
+
+ /**
+ * Load local page contents, parse HTML anchor tags, find permalinks,
+ * and send XML-RPC calls to corresponding pingback servers
+ * @return NULL
+ * @param $source string
+ **/
+ function inspect($source) {
+ $fw=\Base::instance();
+ $web=\Web::instance();
+ $parts=parse_url($source);
+ if (empty($parts['scheme']) || empty($parts['host']) ||
+ $parts['host']==$fw->get('HOST')) {
+ $req=$web->request($source);
+ $doc=new \DOMDocument('1.0',$fw->get('ENCODING'));
+ $doc->stricterrorchecking=FALSE;
+ $doc->recover=TRUE;
+ if ($req && @$doc->loadhtml($req['body'])) {
+ // Parse anchor tags
+ $links=$doc->getelementsbytagname('a');
+ foreach ($links as $link) {
+ $permalink=$link->getattribute('href');
+ // Find pingback-enabled resources
+ if ($permalink && $found=$this->enabled($permalink)) {
+ $req=$web->request($found,
+ array(
+ 'method'=>'POST',
+ 'header'=>'Content-Type: application/xml',
+ 'content'=>xmlrpc_encode_request(
+ 'pingback.ping',
+ array($source,$permalink),
+ array('encoding'=>$fw->get('ENCODING'))
+ )
+ )
+ );
+ if ($req && $req['body'])
+ $this->log.=date('r').' '.
+ $permalink.' [permalink:'.$found.']'.PHP_EOL.
+ $req['body'].PHP_EOL;
+ }
+ }
+ }
+ unset($doc);
+ }
+ }
+
+ /**
+ * Receive ping, check if local page is pingback-enabled, verify
+ * source contents, and return XML-RPC response
+ * @return string
+ * @param $func callback
+ * @param $path string
+ **/
+ function listen($func,$path=NULL) {
+ $fw=\Base::instance();
+ if (PHP_SAPI!='cli') {
+ header('X-Powered-By: '.$fw->get('PACKAGE'));
+ header('Content-Type: application/xml; '.
+ 'charset='.$charset=$fw->get('ENCODING'));
+ }
+ if (!$path)
+ $path=$fw->get('BASE');
+ $web=\Web::instance();
+ $args=xmlrpc_decode_request($fw->get('BODY'),$method,$charset);
+ $options=array('encoding'=>$charset);
+ if ($method=='pingback.ping' && isset($args[0],$args[1])) {
+ list($source,$permalink)=$args;
+ $doc=new \DOMDocument('1.0',$fw->get('ENCODING'));
+ // Check local page if pingback-enabled
+ $parts=parse_url($permalink);
+ if ((empty($parts['scheme']) ||
+ $parts['host']==$fw->get('HOST')) &&
+ preg_match('/^'.preg_quote($path,'/').'/'.
+ ($fw->get('CASELESS')?'i':''),$parts['path']) &&
+ $this->enabled($permalink)) {
+ // Check source
+ $parts=parse_url($source);
+ if ((empty($parts['scheme']) ||
+ $parts['host']==$fw->get('HOST')) &&
+ ($req=$web->request($source)) &&
+ $doc->loadhtml($req['body'])) {
+ $links=$doc->getelementsbytagname('a');
+ foreach ($links as $link) {
+ if ($link->getattribute('href')==$permalink) {
+ call_user_func_array($func,
+ array($source,$req['body']));
+ // Success
+ die(xmlrpc_encode_request(NULL,$source,$options));
+ }
+ }
+ // No link to local page
+ die(xmlrpc_encode_request(NULL,0x11,$options));
+ }
+ // Source failure
+ die(xmlrpc_encode_request(NULL,0x10,$options));
+ }
+ // Doesn't exist (or not pingback-enabled)
+ die(xmlrpc_encode_request(NULL,0x21,$options));
+ }
+ // Access denied
+ die(xmlrpc_encode_request(NULL,0x31,$options));
+ }
+
+ /**
+ * Return transaction history
+ * @return string
+ **/
+ function log() {
+ return $this->log;
+ }
+
+ /**
+ * Instantiate class
+ * @return object
+ **/
+ function __construct() {
+ // Suppress errors caused by invalid HTML structures
+ libxml_use_internal_errors(TRUE);
+ }
+
+}
diff --git a/management-interface/template/footer.php b/management-interface/template/footer.php
index 68f8351..bfae99f 100644
--- a/management-interface/template/footer.php
+++ b/management-interface/template/footer.php
@@ -1,3 +1,4 @@
+
diff --git a/management-interface/template/message.php b/management-interface/template/message.php
index 105345d..b018b16 100644
--- a/management-interface/template/message.php
+++ b/management-interface/template/message.php
@@ -1,5 +1 @@
-
+
diff --git a/management-interface/template/requestdump.php b/management-interface/template/requestdump.php
new file mode 100644
index 0000000..1ed225f
--- /dev/null
+++ b/management-interface/template/requestdump.php
@@ -0,0 +1,5 @@
+
+
+
diff --git a/management-interface/views/about.htm b/management-interface/views/about.htm
index ed15306..e90cdd2 100644
--- a/management-interface/views/about.htm
+++ b/management-interface/views/about.htm
@@ -1,8 +1,8 @@
-
-
-
-
{{ strtoupper(@_module) }}
-
-
-
-
+
+
This is the webinterface for the masterserver.
+
+ This is the public certificate for the FTPS connection: download
+ This is the tool to base64 the certificate.cer: download
+
+
diff --git a/management-interface/views/home.htm b/management-interface/views/home.htm
index f2cadd0..a6d5443 100644
--- a/management-interface/views/home.htm
+++ b/management-interface/views/home.htm
@@ -1,10 +1,6 @@
-
-
Hello {{ @username }}!
Status of server is: online offline
-
-
diff --git a/management-interface/views/login.htm b/management-interface/views/login.htm
index d283f45..bfcb593 100644
--- a/management-interface/views/login.htm
+++ b/management-interface/views/login.htm
@@ -1,4 +1,8 @@
-
+
+
+
@@ -17,4 +21,3 @@
-
diff --git a/management-interface/views/menu.php b/management-interface/views/menu.php
deleted file mode 100644
index d010119..0000000
--- a/management-interface/views/menu.php
+++ /dev/null
@@ -1,43 +0,0 @@
-
-
-
-
-
-
-
- ';
- echo 'Login ';
- } else {
- echo '';
- echo 'Logout ';
- }
- ?>
-
-
-
-
diff --git a/management-interface/views/satellites.htm b/management-interface/views/satellites.htm
index 24adba1..2d151f7 100644
--- a/management-interface/views/satellites.htm
+++ b/management-interface/views/satellites.htm
@@ -1,44 +1,138 @@
-
+
+
+
-
-
- List of all satellite public keys
-
+ Edit
+
+
+
+
+
+
+
+
List of all satellite public keys
+
+
+ Action:
+ delete
+
+ Go
-
+
+ Please login
+
+
+
diff --git a/management-interface/views/users.htm b/management-interface/views/users.htm
index c461072..703f009 100644
--- a/management-interface/views/users.htm
+++ b/management-interface/views/users.htm
@@ -1,18 +1,17 @@
-
List of all users
-
+
- ID
- Username
- Organization
- First name
- Last name
- Email
- Last login
+ #
+ Username
+ Organization
+ First name
+ Last name
+ Email
+ Last login
@@ -29,10 +28,15 @@
+
- Please login
+ Please login
-
--
cgit v1.2.3-55-g7522
DB
Mapper
Inheritance diagram for Audit:
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
+
+ 
