Skip to content

Commit

Permalink
feat: New search system
Browse files Browse the repository at this point in the history
  • Loading branch information
@dogukanoksuz
dogukanoksuz committed Oct 23, 2024
1 parent a3e7855 commit b1b2c14
Showing 1 changed file with 125 additions and 84 deletions.
209 changes: 125 additions & 84 deletions app/Http/Controllers/API/SearchController.php
View file
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@
use App\Models\Server;
use Illuminate\Http\JsonResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\Cache;

/**
* Search Controller
Expand All @@ -24,114 +25,154 @@ class SearchController extends Controller
public function search(Request $request)
{
$searchable = [];
$searchQuery = strtolower($request->input('query'));

// Get constant searchables
if (user()->isAdmin()) {
foreach (config('liman.search.admin') as $constant) {
if (isset($constant['children'])) {
foreach ($constant['children'] as $child) {
if (! isset($searchable[$constant['name']])) {
$searchable[$constant['name']] = [];
}
$child['name'] = __($child['name']);
$searchable[$constant['name']][] = $child;
}
} else {
if (! isset($searchable['Yönetim'])) {
$searchable['Yönetim'] = [];
}
$constant['name'] = __($constant['name']);
$searchable['Yönetim'][] = $constant;
}
$results = Cache::remember(auth('api')->user()->id . '_searchable_' . $searchQuery, now()->addHour(), function () use ($searchable, $searchQuery) {
$configs = [
'user' => 'Kullanıcı',
'common' => 'Genel'
];

if (auth('api')->user()->isAdmin()) {
$configs['admin'] = 'Yönetici';
}
}

foreach (config('liman.search.user') as $constant) {
if (isset($constant['children'])) {
foreach ($constant['children'] as $child) {
if (! isset($searchable[$constant['name']])) {
$searchable[$constant['name']] = [];
}
$child['name'] = __($child['name']);
$searchable[$constant['name']][] = $child;
}
} else {
if (! isset($searchable['Kullanıcı'])) {
$searchable['Kullanıcı'] = [];
}
$constant['name'] = __($constant['name']);
$searchable['Kullanıcı'][] = $constant;
}
}

foreach (config('liman.search.common') as $constant) {
if (isset($constant['children'])) {
foreach ($constant['children'] as $child) {
if (! isset($searchable[$constant['name']])) {
$searchable[$constant['name']] = [];
foreach ($configs as $configKey => $defaultCategory) {
foreach (config("liman.search.$configKey") as $constant) {
$category = $constant['name'] ?? $defaultCategory;
if (isset($constant['children'])) {
foreach ($constant['children'] as $child) {
$child['name'] = __($child['name']);
$searchable[$category][] = $child;
}
} else {
$constant['name'] = __($constant['name']);
$searchable[$defaultCategory][] = $constant;
}
$child['name'] = __($child['name']);
$searchable[$constant['name']][] = $child;
}
} else {
if (! isset($searchable['Genel'])) {
$searchable['Genel'] = [];
}
$constant['name'] = __($constant['name']);
$searchable['Genel'][] = $constant;
}
}

// Server searching
$servers = Server::select('id', 'name')->get()
->filter(function ($server) {
return Permission::can(user()->id, 'server', 'id', $server->id);
});
$servers = Server::select('id', 'name')
->get()
->filter(function ($server) {
return Permission::can(user()->id, 'server', 'id', $server->id);
});

$searchable['Sunucular'] = [];
foreach ($servers as $server) {
if (Permission::can(user()->id, 'liman', 'id', 'server_details')) {
foreach ($servers as $server) {
$searchable['Sunucular'][] = [
'name' => $server->name,
'url' => "/servers/$server->id",
];
}

$extensions = $server->extensions();
foreach ($extensions as $extension) {
if (! isset($searchable[$server->name])) {
$searchable[$server->name] = [];
}

if (! empty($extension->display_name)) {
foreach ($server->extensions() as $extension) {
$searchable[$server->name][] = [
'name' => $extension->display_name,
'name' => $extension->display_name ?: $extension->name,
'url' => "/servers/$server->id/extensions/$extension->id",
];

continue;
$searchSettings = getExtensionJson($extension->name)["search"] ?? [];
foreach ($searchSettings as $search) {
$searchable[$server->name] = [
...$searchable[$server->name],
...$this->searchFromExtensions($server, $extension, $search, $searchQuery)
];
}
}
$searchable[$server->name][] = [
'name' => $extension->name,
'url' => "/servers/$server->id/extensions/$extension->id",
];
}
}

$results = [];
$searchQuery = $request->input('query');

foreach ($searchable as $category => $items) {
foreach ($items as $item) {
if (str_contains(strtolower($item['name']), strtolower($searchQuery))) {
if (! isset($results[$category])) {
$results[$category] = [];
$results = [];
foreach ($searchable as $category => $items) {
foreach ($items as $item) {
if (str_contains(strtolower($item['name']), $searchQuery)) {
$results[$category][] = $item;
}
$results[$category][] = $item;
}
}

return json_encode($results);
});

return $results;
}

/**
* Search from microservices
*/
private function searchFromExtensions($server, $extension, $settings, $searchQuery) {
// Check if permission exists
if (! Permission::can(auth('api')->user()->id, 'function', 'name', $extension->name, $settings['permission']))
return [];

if (strlen($searchQuery) < 2)
return [];

if (is_array($settings['search']['query_parameters']))
$settings['search']['query_parameters'] = json_encode($settings['search']['query_parameters']);

$settings['search']['query_parameters'] = str_replace(
sprintf("%%%%%s%%%%", $settings['search']['key']),
$searchQuery,
$settings['search']['query_parameters']
);

$settings['request'][$settings['search']['append_to']] .=
sprintf("?%s=%s", $settings['search']['query_key'], $settings['search']['query_parameters']);

$extensionCall = Cache::remember(
sprintf(
"%s_search_%s_%s_%s_%s",
auth('api')->user()->id,
$server->id,
$extension->id,
$searchQuery,
json_encode($settings['request'])
),
$settings['metadata']['cache_enabled'] ? now()->addHours(2) : now()->addSeconds(15),
function () use ($server, $extension, $settings) {
return callExtensionFunction(
$extension,
$server,
$settings['request'],
$settings['function'],
($settings['metadata']['timeout_ms'] / 1000) ?: 5
);
},
);

$records = [];
if (is_array($extensionCall)) {
$records = empty($settings['result']['take_from']) ? $extensionCall : ($extensionCall[$settings['result']['take_from']] ?? []);
} elseif (is_object($extensionCall)) {
$records = empty($settings['result']['take_from']) ? (array) $extensionCall : ((array) $extensionCall->{$settings['result']['take_from']} ?? []);
}

$results = [];
preg_match_all("/%%(.*?)%%/", $settings['result']['format'], $resultKeys);
preg_match_all("/%%(.*?)%%/", $settings['metadata']['url_format'], $urlKeys);
foreach ($records as $record) {
$record = (array) $record;
$results[] = [
'name' => (function () use ($resultKeys, $record, $settings) {
$name = $settings['result']['format'];
foreach ($resultKeys[1] as $key) {
$name = str_replace("%%$key%%", $record[$key] ?? '', $name);
}
return $name;
})(),
'url' => (function () use ($urlKeys, $record, $settings, $server, $extension) {
$url = $settings['metadata']['url_format'];
foreach ($urlKeys[1] as $key) {
$url = str_replace("%%$key%%", $record[$key] ?? '', $url);
}
return sprintf(
"/servers/%s/extensions/%s",
$server->id,
$extension->id
) . $url;
})(),
];
}

return response()->json((object) $results);
return $results;
}
}

0 comments on commit b1b2c14

Please sign in to comment.