Skip to content

I
IPRSv2
Commit 3ef2ec07 authored by Michael Ngei's avatar Michael Ngei
Browse files
Options

Updates search quota plugin

parent 49f4c19d
Hide whitespace changes
Inline Side-by-side
Showing with 116 additions and 86 deletions
app/Http/Controllers/API/PaymentsAPI.php
View file @ 3ef2ec07
......@@ -30,72 +30,72 @@ class PaymentsAPI extends Controller
]);
}
// wOLD VERSION WITH NO TOKEN ADDED
/* public function store(StoreContractAPIRequest $request)
{
try {
$validated = $request->validated();
$contract= Contract::where('RID',$validated['contract_id'])->with('client')->first();
$consumer_name = str_replace( ' ', '_', strtoupper($contract->client->name_sh));
try {
$consumerKey = "search_quota:max:".$consumer_name;
$keyValue= null;
if($keyValue == null) {
//@TODO clean returned data api ContractCon
//$this->apiDetails = $this->apiContract($consumer_name, $validated['tokens'], $validated['contract_id']);
$api_res = $this->apiContractCon($consumer_name, $validated['tokens'], $validated['contract_id']);
if ($api_res['status'] === true) {
$data = $api_res['body'];
$data = json_decode($api_res['body'], true);
//$data = json_decode($api_res['body'], true);
$this->jsonData = $data;
//$this->jsonData = json_encode($data, JSON_PRETTY_PRINT);
//Redis::set($consumerKey, $validated['tokens']);
}else{
return response()->json([
'success' => false,
'message' => 'Failed to create payment',
'error' => "Error creating/updating consumer",
], 500);
}
}else{
//update
$value=$keyValue+$validated['tokens'];
//Redis::set($consumerKey, $value);
};
} catch (\Predis\Connection\ConnectionException $redisException) {
return response()->json([
'success' => false,
'message' => 'Failed to update search quota',
'error' => $redisException->getMessage(),
], 500);
}
// Attempt to insert the payment
$payment = Payments::create([
'PAYMENT_REF' => $validated['payment_ref'],
'PAYMENT_MODE' => $validated['payment_mode'],
'AMOUNT' => $validated['amount'],
'TOKENS' => $validated['tokens'],
'contract_id' => $validated['contract_id'],
'USER_ID' => $validated['user_id'],
]);
/* public function store(StoreContractAPIRequest $request)
{
try {
$validated = $request->validated();
$contract= Contract::where('RID',$validated['contract_id'])->with('client')->first();
$consumer_name = str_replace( ' ', '_', strtoupper($contract->client->name_sh));
// Return success JSON response
return response()->json([
'success' => true,
'message' => 'Payment created successfully',
$this->jsonData,
], 201);
try {
$consumerKey = "search_quota:max:".$consumer_name;
$keyValue= null;
if($keyValue == null) {
//@TODO clean returned data api ContractCon
//$this->apiDetails = $this->apiContract($consumer_name, $validated['tokens'], $validated['contract_id']);
$api_res = $this->apiContractCon($consumer_name, $validated['tokens'], $validated['contract_id']);
if ($api_res['status'] === true) {
$data = $api_res['body'];
$data = json_decode($api_res['body'], true);
//$data = json_decode($api_res['body'], true);
$this->jsonData = $data;
//$this->jsonData = json_encode($data, JSON_PRETTY_PRINT);
//Redis::set($consumerKey, $validated['tokens']);
}else{
return response()->json([
'success' => false,
'message' => 'Failed to create payment',
'error' => "Error creating/updating consumer",
], 500);
}
}else{
//update
$value=$keyValue+$validated['tokens'];
//Redis::set($consumerKey, $value);
};
} catch (\Predis\Connection\ConnectionException $redisException) {
return response()->json([
'success' => false,
'message' => 'Failed to update search quota',
'error' => $redisException->getMessage(),
], 500);
}
// Attempt to insert the payment
$payment = Payments::create([
'PAYMENT_REF' => $validated['payment_ref'],
'PAYMENT_MODE' => $validated['payment_mode'],
'AMOUNT' => $validated['amount'],
'TOKENS' => $validated['tokens'],
'contract_id' => $validated['contract_id'],
'USER_ID' => $validated['user_id'],
]);
} catch (\Exception $e) {
// Return failure JSON response
return response()->json([
'success' => false,
'message' => 'Failed to create payment',
'error' => $e->getMessage(),
], 500);
}
}*/
// Return success JSON response
return response()->json([
'success' => true,
'message' => 'Payment created successfully',
$this->jsonData,
], 201);
} catch (\Exception $e) {
// Return failure JSON response
return response()->json([
'success' => false,
'message' => 'Failed to create payment',
'error' => $e->getMessage(),
], 500);
}
}*/
public function store(StoreContractAPIRequest $request)
{
......@@ -104,15 +104,18 @@ class PaymentsAPI extends Controller
$consumer_name = str_replace( ' ', '_', strtoupper($contract->client->name_sh));
//$res=Redis::set('name', 'mikee');
//$checkKey = Redis::get('search_quota:countsse:user23');
try{
if (Redis::exists("search_quota:max:".$consumer_name)) {
$tokens = $validated['tokens'];
$maxToken = Redis::get("search_quota:max:".$consumer_name);
//$currentToken = Redis::get("search_quota:count:".$consumer_name);
// added tokens
$newMax = $tokens + $maxToken;
//set tokens
$tokenRes = Redis::set("search_quota:max:".$consumer_name, $newMax);
// Attempt to insert the payment
if($tokenRes){
$payment = Payments::create([
......@@ -132,7 +135,7 @@ class PaymentsAPI extends Controller
}
}else{
//create new
$this->apiContract($consumer_name, $validated['tokens'], $validated['contract_id']);
$res = $this->apiContract($consumer_name, $validated['tokens'], $validated['contract_id']);
$payment = Payments::create([
'PAYMENT_REF' => $validated['payment_ref'],
'PAYMENT_MODE' => $validated['payment_mode'],
......@@ -177,21 +180,21 @@ class PaymentsAPI extends Controller
"exp" => 172800
],
"limit-count" => [
"count" => $tokens,
"time_window"=> 30,
"rejected_code"=>503,
"key"=> base64_encode($consumerName),
"policy"=> "redis",
"redis_host"=> "redis",
"redis_password"=> env('REDIS_PASSWORD'),
"redis_port" => (int)env('REDIS_PORT'),
"redis_timeout" => 1000,
"rejected_msg" =>"You have reached your token limit.",
"show_limit_quota_header" => true
"count" => $tokens,
"time_window"=> 30,
"rejected_code"=>503,
"key"=> base64_encode($consumerName),
"policy"=> "redis",
"redis_host"=> "redis",
"redis_password"=> env('REDIS_PASSWORD'),
"redis_port" => (int)env('REDIS_PORT'),
"redis_timeout" => 1000,
"rejected_msg" =>"You have reached your token limit.",
"show_limit_quota_header" => true
]
]
]);
// var_dump($response->status(), $response->headers(), $response->body());
// var_dump($response->status(), $response->headers(), $response->body());
//var_dump($response->successful()); //return true or false
if ($response->successful()) {
//save it locally
......@@ -224,8 +227,8 @@ class PaymentsAPI extends Controller
],
"search-quota-redis" => [
"redis_host" => 'redis',
"redis_port" => (int)env('REDIS_PORT'),
"redis_password" => env('REDIS_PASSWORD'),
"redis_port" => 6379,
"redis_password" => 'password',
"default_max_queries" => $tokens
]
]
......
app/Http/Controllers/API/TokensAPI.php
View file @ 3ef2ec07
......@@ -3,8 +3,10 @@
namespace App\Http\Controllers\API;
use App\Http\Controllers\Controller;
use App\Models\Contract;
use App\Models\Tokens;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Redis;
class TokensAPI extends Controller
{
......@@ -13,14 +15,37 @@ class TokensAPI extends Controller
* Get tokens give a contract ID
*
* */
public function show ($contract_id)
public function show($contract_id)
{
// $token = Tokens::with('contract')->get();
$token = Tokens::where('contract_id', $contract_id)->with('contract')->get();
//$token = Tokens::where('contract_id', $contract_id)->with('contract')->get();
$consumer=Contract::where('rid',$contract_id)->with(['client:rid,name_sh,name_fl'])->select('rid','client_rid')->get();
$consumerName = $consumer[0]['client']['name_sh'];
$searchQuota = [];
$cursor = '0';
$pattern = 'search_quota:*:'.$consumerName;
//dd($pattern);
//dump("Keys from KEYS:", Redis::keys($pattern));
do {
$result = Redis::scan($cursor, 'MATCH', $pattern, 'COUNT', 10);
$cursor = $result[0]; // Update cursor for the next iteration
$keys = $result[1];
if (!empty($keys)) {
foreach ($keys as $key) {
$searchQuota[$key] = Redis::get($key);
}
}
} while ($cursor !== '0');
/*
* "search_quota:count:MIKELTD250" => "3"
"search_quota:max:MIKELTD250" => "6"
*/
// Return the data as a JSON response
return response()->json([
'status' => 'success',
'data' => $token,
'data' => $searchQuota,
], 200);
}
}
app/Http/Controllers/TokensController.php
View file @ 3ef2ec07
......@@ -15,7 +15,7 @@ class TokensController extends Controller
{
$searchQuotas = [];
$cursor = '0';
$pattern = 'search_quota:count:*';
$pattern = 'search_quota:*';
//dump("Keys from KEYS:", Redis::keys($pattern));
do {
$result = Redis::scan($cursor, 'MATCH', $pattern, 'COUNT', 10);
......@@ -28,7 +28,9 @@ class TokensController extends Controller
}
}
} while ($cursor !== '0');
dump("Keys from SCAN:", $searchQuotas);
dd($searchQuotas);
$tokens = Tokens::with('contract.client')->get();
return view('tokens.tokens', [
'tokens' => $tokens,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment