@@ -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 |