|
509 | 509 | if context == .preview { |
510 | 510 | previewTimerTask.withValue { |
511 | 511 | $0?.cancel() |
512 | | - $0 = Task { [weak self] in |
| 512 | + $0 = Task { @Sendable [weak self] in |
513 | 513 | await withErrorReporting { |
514 | 514 | while true { |
515 | 515 | guard let self else { break } |
|
1179 | 1179 | // NB: Fake 'sending' result. |
1180 | 1180 | nonisolated(unsafe) var result: T.QueryOutput? |
1181 | 1181 | try await userDatabase.read { db in |
1182 | | - result = try T |
| 1182 | + result = |
| 1183 | + try T |
1183 | 1184 | .where { |
1184 | 1185 | #sql("\($0.primaryKey) = \(bind: metadata.recordPrimaryKey)") |
1185 | 1186 | } |
|
1850 | 1851 | try await userDatabase.write { db in |
1851 | 1852 | try SyncMetadata |
1852 | 1853 | .find(rootRecordID) |
1853 | | - .update { $0.share = share } |
| 1854 | + .update { $0.share = #bind(share) } |
1854 | 1855 | .execute(db) |
1855 | 1856 | } |
1856 | 1857 | } |
|
1880 | 1881 | ) |
1881 | 1882 | .update { |
1882 | 1883 | $0.setLastKnownServerRecord(rootRecord) |
1883 | | - $0.share = nil |
| 1884 | + $0.share = #bind(nil) |
1884 | 1885 | } |
1885 | 1886 | .execute(db) |
1886 | 1887 | } |
|
2062 | 2063 | if data == nil { |
2063 | 2064 | reportIssue("Asset data not found on disk") |
2064 | 2065 | } |
2065 | | - return "\(quote: columnName) = \(data?.queryFragment ?? #""excluded".\#(quote: columnName)"#)" |
| 2066 | + return |
| 2067 | + "\(quote: columnName) = \(data?.queryFragment ?? #""excluded".\#(quote: columnName)"#)" |
2066 | 2068 | } else { |
2067 | 2069 | return """ |
2068 | 2070 | \(quote: columnName) = \ |
|
2330 | 2332 | for table in tables { |
2331 | 2333 | func open<T>(_: some SynchronizableTable<T>) throws { |
2332 | 2334 | let columnsWithUniqueConstraints = try PragmaIndexList<T> |
2333 | | - .where { $0.isUnique && $0.origin != "pk" } |
| 2335 | + .where { $0.isUnique && $0.origin.neq("pk") } |
2334 | 2336 | .select(\.name) |
2335 | 2337 | .fetchAll(db) |
2336 | 2338 | if !columnsWithUniqueConstraints.isEmpty { |
|
2442 | 2444 | mutating func setLastKnownServerRecord(_ lastKnownServerRecord: CKRecord?) { |
2443 | 2445 | self.zoneName = lastKnownServerRecord?.recordID.zoneID.zoneName ?? self.zoneName |
2444 | 2446 | self.ownerName = lastKnownServerRecord?.recordID.zoneID.ownerName ?? self.ownerName |
2445 | | - self.lastKnownServerRecord = lastKnownServerRecord |
2446 | | - self._lastKnownServerRecordAllFields = lastKnownServerRecord |
| 2447 | + self.lastKnownServerRecord = #bind(lastKnownServerRecord) |
| 2448 | + self._lastKnownServerRecordAllFields = #bind(lastKnownServerRecord) |
2447 | 2449 | if let lastKnownServerRecord { |
2448 | | - self.userModificationTime = #sql(""" |
| 2450 | + self.userModificationTime = #sql( |
| 2451 | + """ |
2449 | 2452 | max(\(self.userModificationTime), \(lastKnownServerRecord.userModificationTime)) |
2450 | | - """) |
| 2453 | + """ |
| 2454 | + ) |
2451 | 2455 | } |
2452 | 2456 | } |
2453 | 2457 | } |
|
0 commit comments