ÿØÿà JFIF    ÿÛ „  ( %!1"%)+...383-7(-.+  -%%--------+------------/----------------------------ÿÀ  ¶" ÿÄ     ÿÄ @    !1AQaq‘¡"±ÁÑð2’BRráS‚ñ3b¢CT²Ò #cÿÄ    ÿÄ '   1!AQ2a"‘±#ÿÚ   ? ò(/p‘—–¢·,M|¯G»R£üešT. ôŸEoCFñ‡ 4ÔkåóxR|µÁ¨ÓDà!Ç´µ˜‡p ÍQ‹§!þž^õWsŒy  åÁ§$á«%ºq˜™JyyË0y«^Ϗ -3ÃÏËÈ£Æ\P’ä„s&•‹Üs üô'àWt¹pñCp$bÚF`·7.^)¾!)ÒÙ˜–ÅÏš^h¾ø³·ìe±ŒaeÖ—Í,e=B}Jéߦ$$½—šÙÜCC¯¶è8β–Åkèwx LÉngT±æ¹£Ócœ¿Í/©Éÿ ‰ÚCÒ­mq;Tt¶–}0"zÖPcd1š­¤tˆ„ÐÓâqú[™öUCŠ2޿د­É(¸ßúçšmW,Ò ºf‹Ån™ÄLêÁ8üÁkÁ€L¥ÍuJ1œôrÂSŒÓöt!7EUíïb)AËi¬â-ÙHk8òÁiXYwÅ)O^"ÇØriÛô{»wRUKÙÏÚlÓ¬€‚’שT ] ªb—ÊîKC^×M“xùäñz¬zJ× {4[¹M'IÆeH1LCWÕ]œûº WDæà°OÅ‚¹c²ÞuA–rL`HšpCez‡V’— Ž‚Ë„–ñ­'µR0ÕÖ=À:±G»C\nÆÉ5*¢ †3šhQ4ýÒi$Õ1"Ü]¢p-q3zcQ$ªö¨¥æf›‘»´ÝÚHá„e²JÇ–iÊ:·à¬Øc5Åk»Laª*wi [0Ówk ¦a¦0Õ²ÅÅ‚T¸’³q:Æ<¹ú Ò˜Æ}2VE•Ð€p¡Ô3Úº …h³^LJºçì¥Ánó|˜ÖˆÎˆ+« ¦dø‘Mº–d\ªDðÛ„Ì×LÝ——Ð9Ç|•FèçVm™¨€™3õS–9Äå¢<̉Ìm¢±`·º˜&Z²ž Ë®D«¶»6™‰©­HÈ Àá«h­i³04æ’hxœi3ï¨(ÓL·†‹¶ËpŒ ƒÜÒ? :õdsÀ –3æÓ·Üjâ¬9—]8n¼&]I F£¼…ì–—Œ0v°LǐÅfÛ2TÖ’aµ˜N@ÖBSÏ^à´4-±°b×nÈÈœÆD=KdŒø…ÄÈK,›ÖR§fjü$^ÔÎ!„6^ s:Üun\ôkCÞò÷<—Lúl Í›G¹ÀPá¼Nc¡šÒ…ÙWͳœ±vÊáЄ×9‹P‰cEØ‘™›µŸP<×g1 º©Ø¬wiÁ^l5× I/';Ë+´Z‡ÓÄFÕp[Èð’ HÄ ó 9¬Dl4“é±Ï”V=^Hð;žLädÉa‚°Ë,#/Ž~²BÔÛ QãñQtIeórVB,ÏÂf‹4#Îœc‹É3ZIÖ Œ¢¥·üxa‡Ãçè„jŠ[5 Ä!U?,3žÎ×…ðdÓ÷háŠA‰ìÄ4÷ÃÜZÃE{‰®+W\ZÍE[‰»µk»MÝ­`¢©†˜ÃV‹-f¢¡†¢a«eŠ%«Y¨©q%jâd,Ôq`) ¤¦…šˆ ¦E>0Ùb²t–Ÿ  ÷jsÏ‚Ò’KÈcø(é›;k(’#ôŒQ ™C> õ³M9óºÆµ¤çâ;uÀ)5>RÔ¸fÓ~Ȧ—’-$fe«"FâUˆÊwµPÏu w+"åÉó¨6s™Û9(À¨ù©hE°½†n`m~“@©›p!Vkhµ Á1šbEqqÊ@ºèl›2 –Yã%‘‚hÛ{a¶‡ÅÞM²¬çL34®Çl]®‹ŽØŒm'RÜe35æöˆ­Á­ cP9šeÁköo´L³Ì=p8]”‡B¶,šº|ɏdzXˆØk*ÇÚ{#ñ‰pã(€¶‡9ý'šÜ³½¯kƒ†Â’ëSOƒ•Å®H6+a¢µˆ‹Y¨b˜b+XˆÖ!°u!¢"µˆˆn2ˆ Å0Ä`Å Ô®c(ÓÜGº•Ä»Œ âWî%q.áÐÄ÷î%umÍ£+ÜQ,Vn¦-GphU¸¢X­&,Gt ·K¢ÅÅ·¥RÄÊÉbKn N­R2g$VµÕó Qr#–ÓZUÏð0ÎtÙÀœz ëöo“Îk¯n„T°"SÞ+³/…€½"ižãO%Í%&Δâ‘ËØ´IˆÓ°Ë‰ÞM3.™yçÁzit›`4C`k¢¼á!álÄï sÂ[×!¤l¾æo"ƒIÔ'@ªu)3›ô®“@Z à¾] üœ'‡4¸PÞkÁ-qÄH‰ÓÍBd´ÿ —¹°ÄA&ÊUC„öz‚‚RæŠtf¬>˜ÑidšEçÑL÷áý¡V±h§­c¿¥¨ƒ@g¼…Ýö^ÞËc.ž„æ“I[ ª+·zÐÒÚ,½Ð»¶€C›7jk$๖€Ž¾ÅÙpp¶ÍþéΤ ½ØÎŒq ñpæžÅ¥#Øâ49ÃÂK^MYV“,¶Éz_òæ:…;Õ«¦I3âJ£¤û5$7Èxün\â]Êe¯(Ÿ&Ž‹¶2<6Ćf× æ¢ƱqWı[(ÙÂŽç‚T7¨@ÈÉÍß‚ïÙ"&3TYlGŽ†)†#5ŠA©^T2ÆÁ†)©†©†¤yGXÁ†©"†)©¼ÅV WS†#©]R–r‹q5ÕbâWþBh¯u+ªÅÄ×ü„nÑ^êkªÁj‰jeœWˆÕÕ`µDµ2Ì+Ä µDµµ5Ô{¤Þ0RF’H÷AÛ<ÊÁ§ ƈæ0Ñ£ê4 öÚµ[¬/1²€â<-¬šö²r×0o×w ´xÐÒË„ g01¬„åEM蛇Ã\6µE›‘fÙO k÷CºnÓ1`iîÒ² áÂ!ÑLÄÿ ³¬\õ*:M=Ç»c‹2[‰ØsÕLò\ŒK L^™üÄN\¶#» Ç\……ßïIœÉ$¸ÎñÍ®ÔHÇ Ûí/´>Li”„†g^$ 7NÍÑÑ2M2ªNg=k½Ð}Ÿl6‡ —JWˆ”ÞéT·+µ¦üÂFè¢Vs6ýÆ4»2+2IÝ9ô9®ÇGÙÇ1+Ä8;*Õ§ž½D*îÑWÚçá3Ma¤·ˆ¥t}š²Ü…Q+Æüµ8HíS”üxGéÁˆ¦Ël„éÈ 5 µÄƒ6äÜ(kIš¯S†fÖ&¸®×v|Äyˆ*禌Éù@7-®Ä[]ÎÖ¿ê`º…=:…žJVnݳvðÖKE¼‚ »mà ÷f®:Ë ™–4rð¡4` ܹçž~‹C=œ…¾Ïj|VDtK.ƒ"9 Ï ­–éXá³6WÒïIL-Ї Ç lms.smk-almanshuriyah.sch.id/lib/aws-sdk/src/ClientSideMonitoring/AbstractMonitoringMiddleware.php000064400000021145152267527010034133 0ustar00home/smkb8269/public_htmlgetResponse(); if ($response !== null) { $header = $response->getHeader($headerName); if (!empty($header[0])) { return $header[0]; } } return null; } protected static function getResultHeader(ResultInterface $result, $headerName) { if (isset($result['@metadata']['headers'][$headerName])) { return $result['@metadata']['headers'][$headerName]; } return null; } protected static function getExceptionHeader(\Exception $e, $headerName) { if ($e instanceof ResponseContainerInterface) { $response = $e->getResponse(); if ($response instanceof ResponseInterface) { $header = $response->getHeader($headerName); if (!empty($header[0])) { return $header[0]; } } } return null; } /** * Constructor stores the passed in handler and options. * * @param callable $handler * @param callable $credentialProvider * @param $options * @param $region * @param $service */ public function __construct( callable $handler, callable $credentialProvider, $options, $region, $service ) { $this->nextHandler = $handler; $this->credentialProvider = $credentialProvider; $this->options = $options; $this->region = $region; $this->service = $service; } /** * Standard invoke pattern for middleware execution to be implemented by * child classes. * * @param CommandInterface $cmd * @param RequestInterface $request * @return Promise\PromiseInterface */ public function __invoke(CommandInterface $cmd, RequestInterface $request) { $handler = $this->nextHandler; $eventData = null; $enabled = $this->isEnabled(); if ($enabled) { $cmd['@http']['collect_stats'] = true; $eventData = $this->populateRequestEventData( $cmd, $request, $this->getNewEvent($cmd, $request) ); } $g = function ($value) use ($eventData, $enabled) { if ($enabled) { $eventData = $this->populateResultEventData( $value, $eventData ); $this->sendEventData($eventData); if ($value instanceof MonitoringEventsInterface) { $value->appendMonitoringEvent($eventData); } } if ($value instanceof \Exception || $value instanceof \Throwable) { return Promise\Create::rejectionFor($value); } return $value; }; return Promise\Create::promiseFor($handler($cmd, $request))->then($g, $g); } private function getClientId() { return $this->unwrappedOptions()->getClientId(); } private function getNewEvent( CommandInterface $cmd, RequestInterface $request ) { $event = [ 'Api' => $cmd->getName(), 'ClientId' => $this->getClientId(), 'Region' => $this->getRegion(), 'Service' => $this->getService(), 'Timestamp' => (int) floor(microtime(true) * 1000), 'UserAgent' => substr( $request->getHeaderLine('User-Agent') . ' ' . \Aws\default_user_agent(), 0, 256 ), 'Version' => 1 ]; return $event; } private function getHost() { return $this->unwrappedOptions()->getHost(); } private function getPort() { return $this->unwrappedOptions()->getPort(); } private function getRegion() { return $this->region; } private function getService() { return $this->service; } /** * Returns enabled flag from options, unwrapping options if necessary. * * @return bool */ private function isEnabled() { return $this->unwrappedOptions()->isEnabled(); } /** * Returns $eventData array with information from the request and command. * * @param CommandInterface $cmd * @param RequestInterface $request * @param array $event * @return array */ protected function populateRequestEventData( CommandInterface $cmd, RequestInterface $request, array $event ) { $dataFormat = static::getRequestData($request); foreach ($dataFormat as $eventKey => $value) { if ($value !== null) { $event[$eventKey] = $value; } } return $event; } /** * Returns $eventData array with information from the response, including * the calculation for attempt latency. * * @param ResultInterface|\Exception $result * @param array $event * @return array */ protected function populateResultEventData( $result, array $event ) { $dataFormat = static::getResponseData($result); foreach ($dataFormat as $eventKey => $value) { if ($value !== null) { $event[$eventKey] = $value; } } return $event; } /** * Checks if the socket is created. If PHP version is greater or equals to 8 then, * it will check if the var is instance of \Socket otherwise it will check if is * a resource. * * @return bool Returns true if the socket is created, false otherwise. */ private function isSocketCreated(): bool { // Before version 8, sockets are resources // After version 8, sockets are instances of Socket if (PHP_MAJOR_VERSION >= 8) { $socketClass = '\Socket'; return self::$socket instanceof $socketClass; } else { return is_resource(self::$socket); } } /** * Creates a UDP socket resource and stores it with the class, or retrieves * it if already instantiated and connected. Handles error-checking and * re-connecting if necessary. If $forceNewConnection is set to true, a new * socket will be created. * * @param bool $forceNewConnection * @return Resource */ private function prepareSocket($forceNewConnection = false) { if (!$this->isSocketCreated() || $forceNewConnection || socket_last_error(self::$socket) ) { self::$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP); socket_clear_error(self::$socket); socket_connect(self::$socket, $this->getHost(), $this->getPort()); } return self::$socket; } /** * Sends formatted monitoring event data via the UDP socket connection to * the CSM agent endpoint. * * @param array $eventData * @return int */ private function sendEventData(array $eventData) { $socket = $this->prepareSocket(); $datagram = json_encode($eventData); $result = socket_write($socket, $datagram, strlen($datagram)); if ($result === false) { $this->prepareSocket(true); } return $result; } /** * Unwraps options, if needed, and returns them. * * @return ConfigurationInterface */ private function unwrappedOptions() { if (!($this->options instanceof ConfigurationInterface)) { try { $this->options = ConfigurationProvider::unwrap($this->options); } catch (\Exception $e) { // Errors unwrapping CSM config defaults to disabling it $this->options = new Configuration( false, ConfigurationProvider::DEFAULT_HOST, ConfigurationProvider::DEFAULT_PORT ); } } return $this->options; } }