starred/newznab-tmux
1
0
Fork 0
mirror of https://github.com/NNTmux/newznab-tmux.git synced 2026-08-29 01:08:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix index columns changes

Browse Source
This commit is contained in:
DariusIII
2026-01-01 11:11:11 +01:00
parent 07d73dbac0
commit 51ba5b2141
1 changed files with 12 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files
app/Console/Commands/UpdateReleasesIndexSchema.php
+12 -28
View File
@@ -235,11 +235,10 @@ class UpdateReleasesIndexSchema extends Command
return Command::SUCCESS;
}
// Add each field using ALTER TABLE
// Add each field using the ManticoreSearch PHP client alter method
foreach ($fieldsToAdd as $field => $type) {
try {
$sql = "ALTER TABLE releases_rt ADD COLUMN {$field} {$type}";
$this->client->sql(['body' => ['query' => $sql]]);
$this->client->table('releases_rt')->alter('add', $field, $type);
$this->info("Added field: {$field}");
} catch (ResponseException $e) {
if (str_contains($e->getMessage(), 'already exists')) {
@@ -427,17 +426,14 @@ class UpdateReleasesIndexSchema extends Command
private function documentHasMediaIds(string $indexName, int $id): bool
{
try {
$result = $this->client->sql([
'body' => [
'query' => "SELECT imdbid, tmdbid, traktid, tvdb, tvmaze, tvrage FROM {$indexName} WHERE id = {$id}"
]
]);
$doc = $this->client->table($indexName)->getDocumentById($id);
$data = $result[0]['data'][0] ?? null;
if (!$data) {
if (!$doc) {
return false;
}
$data = $doc->getData();
// Check if any media ID is non-zero
return ($data['imdbid'] ?? 0) > 0
|| ($data['tmdbid'] ?? 0) > 0
@@ -462,15 +458,8 @@ class UpdateReleasesIndexSchema extends Command
foreach ($batch as $item) {
try {
// Use UPDATE to modify existing documents
$setClause = [];
foreach ($item['data'] as $field => $value) {
$setClause[] = "{$field} = {$value}";
}
$setStr = implode(', ', $setClause);
$sql = "UPDATE {$indexName} SET {$setStr} WHERE id = {$item['id']}";
$this->client->sql(['body' => ['query' => $sql]]);
// Use updateDocument to modify existing documents
$this->client->table($indexName)->updateDocument($item['data'], $item['id']);
$updated++;
} catch (\Throwable $e) {
// If update fails, try replace (document might not exist in index yet)
@@ -498,17 +487,12 @@ class UpdateReleasesIndexSchema extends Command
{
// First, try to get the existing document
try {
$result = $this->client->sql([
'body' => [
'query' => "SELECT * FROM {$indexName} WHERE id = {$id}"
]
]);
$doc = $this->client->table($indexName)->getDocumentById($id);
$existingDoc = $result[0]['data'][0] ?? null;
if ($existingDoc) {
if ($doc) {
// Merge existing data with new media data
$document = array_merge($existingDoc, $mediaData);
$existingData = $doc->getData();
$document = array_merge($existingData, $mediaData);
unset($document['id']); // ID is passed separately
$this->client->table($indexName)->replaceDocument($document, $id);