@@ -135,9 +135,9 @@ discard block |
||
| 135 | 135 | //retrive associated identifiers related to fetched event id |
| 136 | 136 | // Per le chiavi/tag associati non filtro per connection_name, potrebbero esserci associazioni anche in altri database |
| 137 | 137 | $associations = DB::table('cache_invalidation_event_associations') |
| 138 | - ->whereIn('event_id', $eventIds) |
|
| 139 | - ->get() |
|
| 140 | - ->groupBy('event_id') |
|
| 138 | + ->whereIn('event_id', $eventIds) |
|
| 139 | + ->get() |
|
| 140 | + ->groupBy('event_id') |
|
| 141 | 141 | ; |
| 142 | 142 | |
| 143 | 143 | // Prepare list of all identifiers to fetch last invalidation times |
@@ -321,10 +321,10 @@ discard block |
||
| 321 | 321 | foreach ($identifiers as $key) { |
| 322 | 322 | [$type, $identifier] = explode(':', $key, 2); |
| 323 | 323 | DB::table('cache_invalidation_timestamps') |
| 324 | - ->updateOrInsert( |
|
| 325 | - ['identifier_type' => $type, 'identifier' => $identifier], |
|
| 326 | - ['last_invalidated' => $now] |
|
| 327 | - ) |
|
| 324 | + ->updateOrInsert( |
|
| 325 | + ['identifier_type' => $type, 'identifier' => $identifier], |
|
| 326 | + ['last_invalidated' => $now] |
|
| 327 | + ) |
|
| 328 | 328 | ; |
| 329 | 329 | } |
| 330 | 330 | } |
@@ -391,8 +391,8 @@ discard block |
||
| 391 | 391 | |
| 392 | 392 | // Mark events as processed |
| 393 | 393 | DB::table('cache_invalidation_events') |
| 394 | - ->whereIn('id', $eventsToUpdate) |
|
| 395 | - ->update(['processed' => 1]) |
|
| 394 | + ->whereIn('id', $eventsToUpdate) |
|
| 395 | + ->update(['processed' => 1]) |
|
| 396 | 396 | ; |
| 397 | 397 | |
| 398 | 398 | // Commit transaction |