From 9fd8f8148ad08b868965b3dcfeca1e50d8146218 Mon Sep 17 00:00:00 2001
From: Andrew Welch <andrew@nystudio107.com>
Date: Sat, 24 Feb 2024 14:46:46 -0500
Subject: [PATCH] refactor: Working JSONB internal seach

---
 src/services/Assets.php | 16 +++++++++++-----
 1 file changed, 11 insertions(+), 5 deletions(-)

diff --git a/src/services/Assets.php b/src/services/Assets.php
index 60bfd6b..d9c5242 100644
--- a/src/services/Assets.php
+++ b/src/services/Assets.php
@@ -189,7 +189,7 @@ protected function updateContent(string $value, CantoFieldData $cantoFieldData,
                 // Get any existing Canto Assets fields that contain the asset ID we're updating
                 $cantoIdFieldName = ElementHelper::fieldColumnFromField($cantoDamAssetField, self::CONTENT_COLUMN_KEY_MAPPINGS['cantoId']);
                 $cantoAssetDataFieldName = ElementHelper::fieldColumnFromField($cantoDamAssetField, self::CONTENT_COLUMN_KEY_MAPPINGS['cantoAssetData']);
-                $jsonSearchNeedle = ['id' => $cantoFieldData->cantoId];
+                $jsonSearchNeedle[] = ['id' => $cantoFieldData->cantoId];
                 $jsonSearchSql = '';
                 if ($db->getIsMysql()) {
                     $jsonSearchSql = $this->mySqlJsonContains($cantoAssetDataFieldName, $jsonSearchNeedle);
@@ -201,12 +201,12 @@ protected function updateContent(string $value, CantoFieldData $cantoFieldData,
                     ->select(['id', $cantoAssetDataFieldName])
                     ->from([$table])
                     ->where([$cantoIdFieldName => 0])
-                    ->addParams([$jsonSearchSql])
+                    ->andWhere($jsonSearchSql)
                     ->all();
                 // Iterate through each row, the field data as appropriate
                 foreach ($rows as $row) {
-                    $rowCollection = new Collection($row[$cantoAssetDataFieldName]);
-                    $rowCollection->transform(function ($item) use ($cantoFieldData) {
+                    $rowCollection = new Collection(Json::decodeIfJson($row[$cantoAssetDataFieldName]));
+                    $rowCollection->transform(function($item) use ($cantoFieldData) {
                         if ($item['id'] === $cantoFieldData->cantoId) {
                             $item = $cantoFieldData->cantoAssetData[0];
                         }
@@ -231,7 +231,10 @@ protected function updateContent(string $value, CantoFieldData $cantoFieldData,
      */
     private function mySqlJsonContains(string $targetSql, mixed $value): string
     {
-        $value = Craft::$app->getDb()->quoteValue(Json::encode($value));
+        $db = Craft::$app->getDb();
+        $value = $db->quoteValue(Json::encode($value));
+        $targetSql = $db->quoteColumnName($targetSql);
+
         return "JSON_CONTAINS($targetSql, $value)";
     }
 
@@ -244,7 +247,10 @@ private function mySqlJsonContains(string $targetSql, mixed $value): string
      */
     private function pgSqlJsonContains(string $targetSql, mixed $value): string
     {
+        $db = Craft::$app->getDb();
         $value = Craft::$app->getDb()->quoteValue(Json::encode($value));
+        $targetSql = $db->quoteColumnName($targetSql);
+
         return "($targetSql @> $value::jsonb)";
     }