Skip to content

Commit 1eaf68d

Browse files
committed
Fix formatting
1 parent 70b9121 commit 1eaf68d

File tree

3 files changed

+84
-84
lines changed

3 files changed

+84
-84
lines changed

Sources/PackageCollections/Model/TargetListResult.swift

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -54,9 +54,9 @@ extension PackageCollectionsModel.TargetListResult {
5454

5555
/// Package name
5656
public let packageName: String
57-
57+
5858
public static func < (lhs: PackageVersion, rhs: PackageVersion) -> Bool {
59-
lhs.version < rhs.version
60-
}
59+
lhs.version < rhs.version
60+
}
6161
}
6262
}

Sources/PackageCollections/Storage/SQLitePackageCollectionsStorage.swift

Lines changed: 39 additions & 39 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ import TSCUtility
2020

2121
final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable {
2222
static let batchSize = 100
23-
23+
2424
private static let packageCollectionsTableName = "package_collections"
2525
private static let packagesFTSName = "fts_packages"
2626
private static let targetsFTSName = "fts_targets"
@@ -40,7 +40,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
4040

4141
private let cache = ThreadSafeKeyValueStore<Model.CollectionIdentifier, Model.Collection>()
4242
private let cacheLock = Lock()
43-
43+
4444
// Lock helps prevent concurrency errors with transaction statements during e.g. `refreshCollections`,
4545
// since only one transaction is allowed per SQLite connection. We need transactions to speed up bulk updates.
4646
// TODO: we could potentially optimize this with db connection pool
@@ -61,7 +61,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
6161
self.diagnosticsEngine = diagnosticsEngine
6262
self.encoder = JSONEncoder.makeWithDefaults()
6363
self.decoder = JSONDecoder.makeWithDefaults()
64-
64+
6565
self.populateTargetTrie()
6666
}
6767

@@ -100,22 +100,22 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
100100
try statement.bind(bindings)
101101
try statement.step()
102102
}
103-
103+
104104
try self.ftsLock.withLock {
105105
// Update search indices
106106
try self.withDB { db in
107107
try db.exec(query: "BEGIN TRANSACTION;")
108-
108+
109109
// First delete existing data
110110
try self.removeFromSearchIndices(identifier: collection.identifier)
111-
111+
112112
let packagesStatement = try db.prepare(query: "INSERT INTO \(Self.packagesFTSName) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?);")
113113
let targetsStatement = try db.prepare(query: "INSERT INTO \(Self.targetsFTSName) VALUES (?, ?, ?);")
114-
114+
115115
// Then insert new data
116116
try collection.packages.forEach { package in
117117
var targets = Set<String>()
118-
118+
119119
try package.versions.forEach { version in
120120
// Packages FTS
121121
let packagesBindings: [SQLite.SQLiteValue] = [
@@ -134,20 +134,20 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
134134

135135
try packagesStatement.clearBindings()
136136
try packagesStatement.reset()
137-
137+
138138
version.targets.forEach { targets.insert($0.name) }
139139
}
140-
140+
141141
let collectionPackage = CollectionPackage(collection: collection.identifier, package: package.reference.identity)
142142
try targets.forEach { target in
143143
// Targets in-memory trie
144144
self.targetTrie.insert(word: target.lowercased(), foundIn: collectionPackage)
145-
145+
146146
// Targets FTS
147147
let targetsBindings: [SQLite.SQLiteValue] = [
148148
.string(try self.encoder.encode(collection.identifier).base64EncodedString()),
149149
.string(package.repository.url),
150-
.string(target)
150+
.string(target),
151151
]
152152
try targetsStatement.bind(targetsBindings)
153153
try targetsStatement.step()
@@ -156,9 +156,9 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
156156
try targetsStatement.reset()
157157
}
158158
}
159-
159+
160160
try db.exec(query: "COMMIT;")
161-
161+
162162
try packagesStatement.finalize()
163163
try targetsStatement.finalize()
164164
}
@@ -172,24 +172,24 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
172172
}
173173
}
174174
}
175-
175+
176176
private func removeFromSearchIndices(identifier: Model.CollectionIdentifier) throws {
177177
let identifierBase64 = try self.encoder.encode(identifier.databaseKey()).base64EncodedString()
178-
178+
179179
let packagesQuery = "DELETE FROM \(Self.packagesFTSName) WHERE collection_id_blob_base64 = ?;"
180180
try self.executeStatement(packagesQuery) { statement -> Void in
181181
let bindings: [SQLite.SQLiteValue] = [.string(identifierBase64)]
182182
try statement.bind(bindings)
183183
try statement.step()
184184
}
185-
185+
186186
let targetsQuery = "DELETE FROM \(Self.targetsFTSName) WHERE collection_id_blob_base64 = ?;"
187187
try self.executeStatement(targetsQuery) { statement -> Void in
188188
let bindings: [SQLite.SQLiteValue] = [.string(identifierBase64)]
189189
try statement.bind(bindings)
190190
try statement.step()
191191
}
192-
192+
193193
self.targetTrie.remove { $0.collection == identifier }
194194
}
195195

@@ -206,10 +206,10 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
206206
try statement.bind(bindings)
207207
try statement.step()
208208
}
209-
209+
210210
// remove from search indices
211211
try self.removeFromSearchIndices(identifier: identifier)
212-
212+
213213
// write to cache
214214
self.cache[identifier] = nil
215215
callback(.success(()))
@@ -327,10 +327,10 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
327327
let packageQuery = "SELECT collection_id_blob_base64, repository_url FROM \(Self.packagesFTSName) WHERE \(Self.packagesFTSName) MATCH ?;"
328328
try self.executeStatement(packageQuery) { statement in
329329
try statement.bind([.string(query)])
330-
330+
331331
while let row = try statement.step() {
332332
if let collectionData = Data(base64Encoded: row.string(at: 0)),
333-
let collection = try? self.decoder.decode(Model.CollectionIdentifier.self, from: collectionData) {
333+
let collection = try? self.decoder.decode(Model.CollectionIdentifier.self, from: collectionData) {
334334
matches.append((collection: collection, package: PackageIdentity(url: row.string(at: 1))))
335335
}
336336
}
@@ -342,7 +342,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
342342
let collectionDict = collections.reduce(into: [Model.CollectionIdentifier: Model.Collection]()) { result, collection in
343343
result[collection.identifier] = collection
344344
}
345-
345+
346346
// For each package, find the containing collections
347347
let packageCollections = matches.filter { collectionDict.keys.contains($0.collection) }
348348
.reduce(into: [PackageIdentity: (package: Model.Package, collections: Set<Model.CollectionIdentifier>)]()) { result, match in
@@ -383,10 +383,10 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
383383
let packageQuery = "SELECT collection_id_blob_base64, repository_url FROM \(Self.packagesFTSName) WHERE id = ?;"
384384
try self.executeStatement(packageQuery) { statement in
385385
try statement.bind([.string(identifier.description)])
386-
386+
387387
while let row = try statement.step() {
388388
if let collectionData = Data(base64Encoded: row.string(at: 0)),
389-
let collection = try? self.decoder.decode(Model.CollectionIdentifier.self, from: collectionData) {
389+
let collection = try? self.decoder.decode(Model.CollectionIdentifier.self, from: collectionData) {
390390
matches.append((collection: collection, package: PackageIdentity(url: row.string(at: 1))))
391391
}
392392
}
@@ -398,7 +398,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
398398
let collectionDict = collections.reduce(into: [Model.CollectionIdentifier: Model.Collection]()) { result, collection in
399399
result[collection.identifier] = collection
400400
}
401-
401+
402402
let collections = matches.filter { collectionDict.keys.contains($0.collection) }
403403
.compactMap { collectionDict[$0.collection] }
404404
// Sort collections by processing date so the latest metadata is first
@@ -407,7 +407,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
407407
guard let package = collections.compactMap({ $0.packages.first { $0.reference.identity == identifier } }).first else {
408408
return callback(.failure(NotFoundError("\(identifier)")))
409409
}
410-
410+
411411
callback(.success(.init(package: package, collections: collections.map { $0.identifier })))
412412
}
413413
}
@@ -458,7 +458,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
458458

459459
while let row = try statement.step() {
460460
if let collectionData = Data(base64Encoded: row.string(at: 0)),
461-
let collection = try? self.decoder.decode(Model.CollectionIdentifier.self, from: collectionData) {
461+
let collection = try? self.decoder.decode(Model.CollectionIdentifier.self, from: collectionData) {
462462
matches.append((
463463
collection: collection,
464464
package: PackageIdentity(url: row.string(at: 1)),
@@ -471,7 +471,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
471471
return callback(.failure(error))
472472
}
473473
}
474-
474+
475475
let collectionDict = collections.reduce(into: [Model.CollectionIdentifier: Model.Collection]()) { result, collection in
476476
result[collection.identifier] = collection
477477
}
@@ -480,7 +480,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
480480
var packageCollections = [PackageIdentity: (package: Model.Package, collections: Set<Model.CollectionIdentifier>)]()
481481
// For each matching target, find the containing package version(s)
482482
var targetPackageVersions = [Model.Target: [PackageIdentity: Set<Model.TargetListResult.PackageVersion>]]()
483-
483+
484484
matches.filter { collectionDict.keys.contains($0.collection) }.forEach { match in
485485
var packageEntry = packageCollections.removeValue(forKey: match.package)
486486
if packageEntry == nil {
@@ -495,7 +495,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
495495
if var packageEntry = packageEntry {
496496
packageEntry.collections.insert(match.collection)
497497
packageCollections[match.package] = packageEntry
498-
498+
499499
packageEntry.package.versions.forEach { version in
500500
let targets = version.targets.filter { $0.name.lowercased() == match.targetName.lowercased() }
501501
targets.forEach { target in
@@ -505,10 +505,10 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
505505
targetEntry[packageEntry.package.reference.identity] = targetPackageEntry
506506
targetPackageVersions[target] = targetEntry
507507
}
508-
}
508+
}
509509
}
510510
}
511-
511+
512512
let result = Model.TargetSearchResult(items: targetPackageVersions.map { target, packageVersions in
513513
let targetPackages: [Model.TargetListItem.Package] = packageVersions.compactMap { reference, versions in
514514
guard let packageEntry = packageCollections[reference] else {
@@ -543,7 +543,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
543543
);
544544
"""
545545
try db.exec(query: table)
546-
546+
547547
let ftsPackages = """
548548
CREATE VIRTUAL TABLE IF NOT EXISTS \(Self.packagesFTSName) USING fts4(
549549
collection_id_blob_base64, id, version, name, repository_url, summary, keywords, products, targets,
@@ -552,7 +552,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
552552
);
553553
"""
554554
try db.exec(query: ftsPackages)
555-
555+
556556
let ftsTargets = """
557557
CREATE VIRTUAL TABLE IF NOT EXISTS \(Self.targetsFTSName) USING fts4(
558558
collection_id_blob_base64, package_repository_url, name,
@@ -561,7 +561,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
561561
);
562562
"""
563563
try db.exec(query: ftsTargets)
564-
564+
565565
try db.exec(query: "PRAGMA journal_mode=WAL;")
566566
}
567567

@@ -625,7 +625,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
625625

626626
return try body(db)
627627
}
628-
628+
629629
func populateTargetTrie(callback: @escaping (Result<Void, Error>) -> Void = { _ in }) {
630630
self.queue.async {
631631
do {
@@ -636,7 +636,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
636636
let targetName = row.string(at: 2)
637637

638638
if let collectionData = Data(base64Encoded: row.string(at: 0)),
639-
let collection = try? self.decoder.decode(Model.CollectionIdentifier.self, from: collectionData) {
639+
let collection = try? self.decoder.decode(Model.CollectionIdentifier.self, from: collectionData) {
640640
let collectionPackage = CollectionPackage(collection: collection, package: PackageIdentity(url: row.string(at: 1)))
641641
self.targetTrie.insert(word: targetName.lowercased(), foundIn: collectionPackage)
642642
}
@@ -650,7 +650,7 @@ final class SQLitePackageCollectionsStorage: PackageCollectionsStorage, Closable
650650
}
651651
}
652652
}
653-
653+
654654
// For `Trie`
655655
private struct CollectionPackage: Hashable, CustomStringConvertible {
656656
let collection: Model.CollectionIdentifier

0 commit comments

Comments
 (0)