Skip to main content
Explore
Sign in
Explore
Snippets Groups Projects
Commit a1b64049 authored by fazelginanda's avatar fazelginanda
Browse files

feat: add PHP component for connecting to SOAP

parent 89d07cf5
No related branches found
No related tags found
No related merge requests found
Show whitespace changes
Inline Side-by-side
Showing
with 731 additions and 0 deletions
src/app/baseclasses/BaseRepository.php 0 → 100644
+ 231
− 0
View file @ a1b64049
<?php
require_once SRC_ROOT_PATH . "/app/core/PDOHandler.php";
abstract class BaseRepository
{
protected static $instance;
protected $pdo;
protected $tableName = '';
protected function __construct()
{
$this->pdo = PDOInstance::getInstance()->getPDO();
}
public static function getInstance()
{
if (!isset(self::$instance)) {
self::$instance = new static();
}
return self::$instance;
}
public function getPDO()
{
return $this->pdo;
}
public function getAll()
{
$sql = "SELECT * FROM $this->tableName";
return $this->pdo->query($sql);
}
public function countRow($where = []) {
$sql = "SELECT COUNT(*) FROM $this->tableName";
if (count($where) > 0) {
$sql .= " WHERE ";
$sql .= implode(" AND ", array_map(function ($key, $value) {
if ($value[2] == 'LIKE') {
return "$key LIKE :$key";
}
return "$key = :$key";
}, array_keys($where), array_values($where)));
}
$stmt = $this->pdo->prepare($sql);
foreach ($where as $key => $value) {
$stmt->bindValue(":$key", $value[0], $value[1]);
if ($value[2] == 'LIKE') {
$stmt->bindValue(":$key", "%$value[0]%", $value[1]);
} else {
$stmt->bindValue(":$key", $value[0], $value[1]);
}
}
$stmt->execute();
return $stmt->fetchColumn();
}
public function findAll(
$where = [],
$order = null,
$pageNo = null,
$pageSize = null,
$isDesc = false,
) {
$sql = "SELECT * FROM $this->tableName ";
if (count($where) > 0) {
$sql .= "WHERE ";
$sql .= implode(" AND ", array_map(function ($key, $value) {
if ($key == "judul") {
return "(judul LIKE :$key OR penyanyi LIKE :$key OR YEAR(tanggal_terbit) LIKE :$key)";
}
if ($value[2] == 'LIKE') {
return "$key LIKE :$key";
}
return "$key = :$key";
}, array_keys($where), array_values($where)));
}
if ($order) {
$sql .= " ORDER BY $order";
}
if ($isDesc) {
$sql .= " DESC";
}
if ($pageSize && $pageNo) {
$sql .= " LIMIT :pageSize";
$sql .= " OFFSET :offset";
}
$stmt = $this->pdo->prepare($sql);
foreach ($where as $key => $value) {
if ($value[2] == 'LIKE') {
$stmt->bindValue(":$key", "%$value[0]%", $value[1]);
} else {
$stmt->bindValue(":$key", $value[0], $value[1]);
}
}
if ($pageSize && $pageNo) {
$offset = ($pageNo - 1) * $pageSize;
$stmt->bindValue(":pageSize", $pageSize, PDO::PARAM_INT);
$stmt->bindValue(":offset", $offset, PDO::PARAM_INT);
}
$stmt->execute();
return $stmt->fetchAll();
}
public function findOne($arrParams)
{
$sql = "SELECT * FROM $this->tableName WHERE ";
$i = 0;
foreach ($arrParams as $key => $value) {
$sql .= "$key = :$key";
if ($i < count($arrParams) - 1) {
$sql .= " AND ";
}
$i++;
}
$stmt = $this->pdo->prepare($sql);
foreach ($arrParams as $key => $value) {
$stmt->bindValue(":$key", $value[0], $value[1]);
}
$stmt->execute();
return $stmt->fetch();
}
public function insert($model, $arrParams)
{
$sql = "INSERT INTO $this->tableName (";
$i = 0;
foreach ($arrParams as $key => $value) {
$sql .= "$key";
if ($i < count($arrParams) - 1) {
$sql .= ", ";
}
$i++;
}
$sql .= ") VALUES (";
$i = 0;
foreach ($arrParams as $key => $value) {
$sql .= ":$key";
if ($i < count($arrParams) - 1) {
$sql .= ", ";
}
$i++;
}
$sql .= ")";
$stmt = $this->pdo->prepare($sql);
foreach ($arrParams as $key => $value) {
$stmt->bindValue(":$key", $model->get($key), $value);
}
$stmt->execute();
return $this->pdo->lastInsertId();
}
public function update($model, $arrParams)
{
$sql = "UPDATE $this->tableName SET ";
$i = 0;
foreach ($arrParams as $key => $value) {
$sql .= "$key = :$key";
if ($i < count($arrParams) - 1) {
$sql .= ", ";
}
$i++;
}
$primaryKey = $model->get('_primary_key');
$sql .= " WHERE $primaryKey = :primaryKey";
$stmt = $this->pdo->prepare($sql);
foreach ($arrParams as $key => $value) {
$stmt->bindValue(":$key", $model->get($key), $value);
}
$stmt->bindValue(":primaryKey", $model->get($primaryKey), PDO::PARAM_INT);
$stmt->execute();
return $stmt->rowCount();
}
public function delete($model)
{
$sql = "DELETE FROM $this->tableName WHERE ";
$primaryKey = $model->get('_primary_key');
$sql .= "$primaryKey = :primaryKey";
$stmt = $this->pdo->prepare($sql);
$stmt->bindValue(":primaryKey", $model->get($primaryKey), PDO::PARAM_INT);
$stmt->execute();
return $stmt->rowCount();
}
public function getNLastRow($N)
{
$sql = "SELECT COUNT(*) FROM $this->tableName";
$stmt = $this->pdo->prepare($sql);
$stmt->execute();
$count = $stmt->fetchColumn();
if ($count < $N) {
$N = $count;
}
$offset = $count - $N;
$sql = "SELECT * FROM $this->tableName LIMIT :limit OFFSET :offset";
$stmt = $this->pdo->prepare($sql);
$stmt->bindValue(":limit", $N, PDO::PARAM_INT);
$stmt->bindValue(":offset", $offset, PDO::PARAM_INT);
$stmt->execute();
return $stmt->fetchAll();
}
}
\ No newline at end of file
src/app/baseclasses/BaseService.php 0 → 100644
+ 16
− 0
View file @ a1b64049
<?php
abstract class BaseService {
protected static $instance;
protected $repository;
protected function __construct() {
}
public static function getInstance() {
if (!isset(self::$instance)) {
self::$instance = new static();
}
return self::$instance;
}
}
\ No newline at end of file
src/app/clients/SocmedSoapClient.php 0 → 100644
+ 81
− 0
View file @ a1b64049
<?php
require_once SRC_ROOT_PATH . "/utils/SoapWrapper.php";
class SocmedSoapClient
{
private static $instance;
private $client;
private function __construct()
{
$opts = array(
'http' => array(
'header' => 'Authorization: ' . getenv("MONOLITHIC_SOAP_API_KEY"))
);
$params = array(
'encoding' => 'UTF-8',
'soap_version' => SOAP_1_2,
'trace' => 1,
'exceptions' => 1,
'connection_timeout' => 180,
'stream_context' => stream_context_create($opts),
);
$this->client = new SoapWrapper($_ENV['WSDL_URL'], $params);
}
public static function getInstance()
{
if (!isset(self::$instance)) {
self::$instance = new static();
}
return self::$instance;
}
public function requestUnlocking($socmed_id, $link_code)
{
$res = $this->client->call("requestUnlocking", array(
'arg0' => $socmed_id,
'arg1' => null,
'arg2' => $link_code,
));
return $res;
}
public function getUnlocking()
{
$res = $this->client->call("getUnlocking", null);
return $res;
}
public function getUnlockingBySocmedId($socmed_id)
{
$response = self::getInstance()->getUnlockingBySocmedId(
array(
"socmed_id" => $socmed_id,
)
);
return $response;
}
public function acceptUnlocking($socmed_id, $link_code)
{
$res = $this->client->call("acceptUnlocking", array(
'arg0' => $socmed_id,
'arg1' => null,
'arg2' => $link_code,
));
return $res;
}
public function rejectUnlocking($socmed_id, $link_code)
{
$res = $this->client->call("rejectUnlocking", array(
'arg0' => $socmed_id,
'arg1' => $link_code,
));
return $res;
}
}
src/app/controllers/Unlocking/UnlockingController.php 0 → 100644
+ 31
− 0
View file @ a1b64049
<?php
require_once SRC_ROOT_PATH . "/app/services/UnlockingService.php";
require_once SRC_ROOT_PATH . "/app/baseclasses/BaseController.php";
class UnlockingController extends BaseController {
protected static $instance;
private function __construct($srv)
{
parent::__construct($srv);
}
public static function getInstance()
{
if (!isset(self::$instance)) {
self::$instance = new static(
UnlockingService::getInstance()
);
}
return self::$instance;
}
public function post($urlParams) {
$socmed_id = $_SESSION['id'];
$link_code = $_SESSION['username'];
return $this->srv->requestUnlocking($socmed_id, $link_code);
}
}
src/app/models/UnlockingModel.php 0 → 100644
+ 33
− 0
View file @ a1b64049
<?php
require_once SRC_ROOT_PATH . "/baseclasses/BaseModel.php";
class SubscriptionModel extends BaseModel
{
public $socmed_id;
public $dashboard_id;
public $link_code;
public function __construct()
{
$this->_primary_key = ["socmed_id"];
return $this;
}
public function constructFromArray($array)
{
$this->socmed_id = $array["socmed_id"];
$this->dashboard_id = $array["dashboard_id"];
$this->link_code = ($array["link_code"]);
return $this;
}
public function toResponse()
{
return array(
"socmed_id" => $this->socmed_id,
"dashboard_id" => $this->dashboard_id,
"link_code" => $this->link_code,
);
}
}
src/app/repositories/UnlockingRespository.php 0 → 100644
+ 59
− 0
View file @ a1b64049
<?php
require_once SRC_ROOT_PATH . "/baseclasses/BaseRepository.php";
class UnlockingRepository extends BaseRepository{
protected static $instance;
private function __construct() {
parent::__construct();
}
public static function getInstance() {
if (!isset(self::$instance)) {
self::$instance = new static();
}
return self::$instance;
}
public function getAllUnlockings() {
$sql = "SELECT * FROM unlocking";
$stmt = $this->pdo->prepare($sql);
$stmt->execute();
return $stmt->fetchAll();
}
public function getUnlocking($socmed_id, $dashboard_id) {
$sql = "SELECT * FROM unlocking WHERE socmed_id = :socmed_id AND dashboard_id = :dashboard_id";
$stmt = $this->pdo->prepare($sql);
$stmt->bindParam(':socmed_id', $socmed_id, PDO::PARAM_INT);
$stmt->bindParam(':dashboard_id', $dashboard_id, PDO::PARAM_INT);
$stmt->execute();
return $stmt->fetchAll();
}
public function getAcceptedUnlockingBySocmedID($socmed_id) {
$sql = "SELECT * FROM unlocking WHERE socmed_id = :socmed_id and dashboard_id IS NOT NULL";
$stmt = $this->pdo->prepare($sql);
$stmt->bindParam(':socmed_id', $socmed_id, PDO::PARAM_INT);
$stmt->execute();
return $stmt->fetchAll();
}
public function insertUnlocking($socmed_id, $dashboard_id, $link_code) {
$sql = "INSERT INTO unlocking (socmed_id, dashboard_id, link_code) VALUES (:socmed_id, :subscriber_id, :link_code)";
$stmt = $this->pdo->prepare($sql);
$stmt->bindParam(':socmed_id', $socmed_id, PDO::PARAM_INT);
$stmt->bindParam(':dashboard_id', $dashboard_id, PDO::PARAM_INT);
$stmt->bindParam(':link_code', $link_code, PDO::PARAM_STR);
$stmt->execute();
return $stmt->rowCount();
}
}
src/app/services/UnlockingService.php 0 → 100644
+ 73
− 0
View file @ a1b64049
<?php
require_once PROJECT_ROOT_PATH . "/src/bases/BaseService.php";
require_once PROJECT_ROOT_PATH . "/src/utils/SoapWrapper.php";
require_once PROJECT_ROOT_PATH . "/src/clients/SocmedSoapClient.php";
require_once PROJECT_ROOT_PATH . "/src/models/UnlockingModel.php";
require_once PROJECT_ROOT_PATH . "/src/repositories/UnlockingRepository.php";
class UnlockingService extends BaseSrv {
protected static $instance;
private $client;
private function __construct($client) {
parent::__construct();
$this->client = $client;
}
public static function getInstance() {
if (!isset(self::$instance)) {
self::$instance = new static(
SocmedSoapClient::getInstance()
);
}
return self::$instance;
}
public function getAcceptedUnlockingBySocmedId($socmedId) {
$unlocksSQL = UnlockingRepository::getInstance()->getAcceptedUnlockingBySocmedId($socmedId);
$unlocks = [];
foreach ($unlocksSQL as $unlockSQL) {
$unlock = new UnlockingModel();
$unlocks[] = $unlock->constructFromArray($unlockSQL);
}
return $unlocks;
}
public function update($socmed_id, $dashboard_id, $link_code) {
return UnlockingnRepository::getInstance()
->updateUnlocking($socmed_id, $dashboard_id, $link_code);
}
public function requestUnlocking($socmed_id, $link_code) {
$resp = $this->client->requestUnlocking($socmed_id, $link_code);
UnlockingRepository::getInstance()->insertUnlocking($socmed_id, null, $link_code);
return $resp;
}
public function getSoapUnlocking() {
return $this->client->getUnlocking();
}
public function getUnlocking() {
$sqlRes = UnlockingRepository::getInstance()->getAllUnlockings();
$unlocks = [];
foreach ($sqlRes as $unlockSQL) {
$unlock = new UnlockingModel();
$unlocks[] = $unlock->constructFromArray($unlockSQL);
}
return $subs;
}
public function acceptUnlocking($socmed_id, $link_code) {
return $this->client->acceptUnlocking($socmed_id, $link_code);
}
public function rejectUnlocking($socmed_id, $link_code) {
return $this->client->rejectUnlocking($socmed_id, $link_code);
}
}
src/app/utils/Logger.php 0 → 100644
+ 174
− 0
View file @ a1b64049
<?php
class Logger
{
protected static $log_file;
protected static $file;
protected static $options = [
'dateFormat' => 'd-M-Y',
'logFormat' => 'H:i:s d-M-Y'
];
private static $instance;
private static $logdir = PROJECT_ROOT_PATH . '/logs';
public static function createLogFile()
{
$time = date(static::$options['dateFormat']);
static::$log_file = static::$logdir . "/log-{$time}.txt";
if (!file_exists(static::$logdir)) {
mkdir(static::$logdir, 0777, true);
}
if (!file_exists(static::$log_file)) {
fopen(static::$log_file, 'w') or exit("Can't create {static::log_file}!");
}
if (!is_writable(static::$log_file)) {
throw new Exception("ERROR: Unable to write to file!", 1);
}
}
public static function setOptions($options = [])
{
static::$options = array_merge(static::$options, $options);
}
public static function info($message, array $context = [])
{
$bt = debug_backtrace(DEBUG_BACKTRACE_PROVIDE_OBJECT, 1);
static::writeLog([
'message' => $message,
'bt' => $bt,
'severity' => 'INFO',
'context' => $context
]);
}
public static function notice($message, array $context = [])
{
$bt = debug_backtrace(DEBUG_BACKTRACE_PROVIDE_OBJECT, 1);
static::writeLog([
'message' => $message,
'bt' => $bt,
'severity' => 'NOTICE',
'context' => $context
]);
}
public static function debug($message, array $context = [])
{
$bt = debug_backtrace(DEBUG_BACKTRACE_PROVIDE_OBJECT, 1);
static::writeLog([
'message' => $message,
'bt' => $bt,
'severity' => 'DEBUG',
'context' => $context
]);
}
public static function warning($message, array $context = [])
{
$bt = debug_backtrace(DEBUG_BACKTRACE_PROVIDE_OBJECT, 1);
static::writeLog([
'message' => $message,
'bt' => $bt,
'severity' => 'WARNING',
'context' => $context
]);
}
public static function error($message, array $context = [])
{
$bt = debug_backtrace(DEBUG_BACKTRACE_PROVIDE_OBJECT, 1);
static::writeLog([
'message' => $message,
'bt' => $bt,
'severity' => 'ERROR',
'context' => $context
]);
}
public static function fatal($message, array $context = [])
{
$bt = debug_backtrace(DEBUG_BACKTRACE_PROVIDE_OBJECT, 1);
static::writeLog([
'message' => $message,
'bt' => $bt,
'severity' => 'FATAL',
'context' => $context
]);
}
public static function writeLog($args = [])
{
static::createLogFile();
if (!is_resource(static::$file)) {
static::openLog();
}
$time = date(static::$options['logFormat']);
$context = json_encode($args['context']);
$caller = array_shift($args['bt']);
$btLine = $caller['line'];
$btPath = $caller['file'];
$path = static::absToRelPath($btPath);
$timeLog = is_null($time) ? "[N/A] " : "[{$time}] ";
$pathLog = is_null($path) ? "[N/A] " : "[{$path}] ";
$lineLog = is_null($btLine) ? "[N/A] " : "[{$btLine}] ";
$severityLog = is_null($args['severity']) ? "[N/A]" : "[{$args['severity']}]";
$messageLog = is_null($args['message']) ? "N/A" : "{$args['message']}";
$contextLog = empty($args['context']) ? "" : "{$context}";
fwrite(static::$file, "{$timeLog}{$pathLog}{$lineLog}: {$severityLog} - {$messageLog} {$contextLog}" . PHP_EOL);
static::closeFile();
}
private static function openLog()
{
$openFile = static::$log_file;
static::$file = fopen($openFile, 'a') or exit("Can't open $openFile!");
}
public static function closeFile()
{
if (static::$file) {
fclose(static::$file);
}
}
public static function absToRelPath($pathToConvert)
{
$pathAbs = str_replace(['/', '\\'], '/', $pathToConvert);
$documentRoot = str_replace(['/', '\\'], '/', $_SERVER['DOCUMENT_ROOT']);
return $_SERVER['SERVER_NAME'] . str_replace($documentRoot, '', $pathAbs);
}
protected function __construct()
{
}
public static function getInstance()
{
if (is_null(self::$instance)) {
self::$instance = new self();
}
return self::$instance;
}
private function __destruct()
{
}
}
src/app/utils/SoapWrapper.php 0 → 100644
+ 33
− 0
View file @ a1b64049
<?php
class SoapWrapper {
public function __construct($wsdl) {
try {
$this->soapClient = new SoapClient($wsdl,array(
"exceptions" => 0,
"trace" => 1,
"encoding" => "UTF-8",
'stream_context' => stream_context_create(array(
'http' => array(
'header' => 'Authorization: Bearer ' . $_ENV['API_KEY'],
),
)),
));
} catch (Exception $e) {
Logger::error("SoapWrapper: Error while creating SoapClient: " . $e->getMessage());
$this->soapClient = null;
}
}
public function call($functionName, $params) {
$res = null;
if (!isset($params)) {
$res = $this->soapClient->$functionName();
} else {
$res = $this->soapClient->$functionName($params);
}
return json_encode($res);
}
}
\ No newline at end of file
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please to comment