1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
//===----------------------------------------------------------------------===//
//
// This source file is part of the Swift open source project
//
// Copyright (c) 2021-2023 Apple Inc. and the Swift project authors
// Licensed under Apache License v2.0 with Runtime Library Exception
//
// See http://swift.org/LICENSE.txt for license information
// See http://swift.org/CONTRIBUTORS.txt for the list of Swift project authors
//
//===----------------------------------------------------------------------===//
import Basics
import Dispatch
import PackageModel
import struct TSCUtility.Version
public protocol PackageFingerprintStorage {
func get(
package: PackageIdentity,
version: Version,
observabilityScope: ObservabilityScope,
callbackQueue: DispatchQueue,
callback: @escaping (Result<[Fingerprint.Kind: [Fingerprint.ContentType: Fingerprint]], Error>) -> Void
)
func put(
package: PackageIdentity,
version: Version,
fingerprint: Fingerprint,
observabilityScope: ObservabilityScope,
callbackQueue: DispatchQueue,
callback: @escaping (Result<Void, Error>) -> Void
)
func get(
package: PackageReference,
version: Version,
observabilityScope: ObservabilityScope,
callbackQueue: DispatchQueue,
callback: @escaping (Result<[Fingerprint.Kind: [Fingerprint.ContentType: Fingerprint]], Error>) -> Void
)
func put(
package: PackageReference,
version: Version,
fingerprint: Fingerprint,
observabilityScope: ObservabilityScope,
callbackQueue: DispatchQueue,
callback: @escaping (Result<Void, Error>) -> Void
)
}
extension PackageFingerprintStorage {
public func get(
package: PackageIdentity,
version: Version,
kind: Fingerprint.Kind,
contentType: Fingerprint.ContentType,
observabilityScope: ObservabilityScope,
callbackQueue: DispatchQueue,
callback: @escaping (Result<Fingerprint, Error>) -> Void
) {
self.get(
package: package,
version: version,
observabilityScope: observabilityScope,
callbackQueue: callbackQueue
) { result in
self.get(kind: kind, contentType: contentType, result, callback: callback)
}
}
public func get(
package: PackageReference,
version: Version,
kind: Fingerprint.Kind,
contentType: Fingerprint.ContentType,
observabilityScope: ObservabilityScope,
callbackQueue: DispatchQueue,
callback: @escaping (Result<Fingerprint, Error>) -> Void
) {
self.get(
package: package,
version: version,
observabilityScope: observabilityScope,
callbackQueue: callbackQueue
) { result in
self.get(kind: kind, contentType: contentType, result, callback: callback)
}
}
private func get(
kind: Fingerprint.Kind,
contentType: Fingerprint.ContentType,
_ fingerprintsByKindResult: Result<[Fingerprint.Kind: [Fingerprint.ContentType: Fingerprint]], Error>,
callback: @escaping (Result<Fingerprint, Error>) -> Void
) {
callback(fingerprintsByKindResult.tryMap { fingerprintsByKind in
guard let fingerprintsByContentType = fingerprintsByKind[kind],
let fingerprint = fingerprintsByContentType[contentType]
else {
throw PackageFingerprintStorageError.notFound
}
return fingerprint
})
}
}
public enum PackageFingerprintStorageError: Error, Equatable, CustomStringConvertible {
case conflict(given: Fingerprint, existing: Fingerprint)
case notFound
public var description: String {
switch self {
case .conflict(let given, let existing):
return "fingerprint \(given) is different from previously recorded value \(existing)"
case .notFound:
return "not found"
}
}
}
|
