5
5
// SPDX-License-Identifier: Apache-2.0
6
6
//
7
7
8
- import AWSPluginsCore
9
8
import Amplify
9
+ import AWSClientRuntime
10
+ import AWSCloudWatchLogs
11
+ import AWSPluginsCore
10
12
import Combine
11
13
import Foundation
12
- import AWSCloudWatchLogs
13
- import AWSClientRuntime
14
14
import Network
15
15
16
16
/// Concrete implementation of
@@ -57,7 +57,7 @@ final class AWSCloudWatchLoggingCategoryClient {
57
57
self . networkMonitor = networkMonitor
58
58
self . networkMonitor. startMonitoring ( using: DispatchQueue ( label: " com.amazonaws.awscloudwatchlogging.networkmonitor " ) )
59
59
self . automaticFlushLogMonitor = AWSCLoudWatchLoggingMonitor ( flushIntervalInSeconds: TimeInterval ( flushIntervalInSeconds) , eventDelegate: self )
60
- self . automaticFlushLogMonitor? . setAutomaticFlushIntervals ( )
60
+ automaticFlushLogMonitor? . setAutomaticFlushIntervals ( )
61
61
self . authSubscription = Amplify . Hub. publisher ( for: . auth) . sink { [ weak self] payload in
62
62
self ? . handle ( payload: payload)
63
63
}
@@ -92,8 +92,8 @@ final class AWSCloudWatchLoggingCategoryClient {
92
92
case HubPayload . EventName. Auth. signedIn, CognitoEventName . signInAPI. rawValue:
93
93
takeUserIdentifierFromCurrentUser ( )
94
94
case HubPayload . EventName. Auth. signedOut, CognitoEventName . signOutAPI. rawValue:
95
- self . userIdentifier = nil
96
- self . updateSessionControllers ( )
95
+ userIdentifier = nil
96
+ updateSessionControllers ( )
97
97
default :
98
98
break
99
99
}
@@ -135,7 +135,7 @@ extension AWSCloudWatchLoggingCategoryClient: LoggingCategoryClientBehavior {
135
135
}
136
136
137
137
var `default` : Logger {
138
- return self . logger ( forCategory: " Amplify " )
138
+ return logger ( forCategory: " Amplify " )
139
139
}
140
140
141
141
func logger( forCategory category: String , namespace: String ? , logLevel: Amplify . LogLevel ) -> Logger {
@@ -145,17 +145,19 @@ extension AWSCloudWatchLoggingCategoryClient: LoggingCategoryClientBehavior {
145
145
return existing
146
146
}
147
147
148
- let controller = AWSCloudWatchLoggingSessionController ( credentialsProvider: credentialsProvider,
149
- authentication: authentication,
150
- logFilter: self . logFilter,
151
- category: category,
152
- namespace: namespace,
153
- logLevel: logLevel,
154
- logGroupName: self . logGroupName,
155
- region: self . region,
156
- localStoreMaxSizeInMB: self . localStoreMaxSizeInMB,
157
- userIdentifier: self . userIdentifier,
158
- networkMonitor: self . networkMonitor)
148
+ let controller = AWSCloudWatchLoggingSessionController (
149
+ credentialsProvider: credentialsProvider,
150
+ authentication: authentication,
151
+ logFilter: self . logFilter,
152
+ category: category,
153
+ namespace: namespace,
154
+ logLevel: logLevel,
155
+ logGroupName: self . logGroupName,
156
+ region: self . region,
157
+ localStoreMaxSizeInMB: self . localStoreMaxSizeInMB,
158
+ userIdentifier: self . userIdentifier,
159
+ networkMonitor: self . networkMonitor
160
+ )
159
161
if enabled {
160
162
controller. enable ( )
161
163
}
@@ -165,21 +167,21 @@ extension AWSCloudWatchLoggingCategoryClient: LoggingCategoryClientBehavior {
165
167
}
166
168
167
169
func logger( forCategory category: String , logLevel: LogLevel ) -> Logger {
168
- return self . logger ( forCategory: category, namespace: nil , logLevel: logLevel)
170
+ return logger ( forCategory: category, namespace: nil , logLevel: logLevel)
169
171
}
170
172
171
173
func logger( forCategory category: String ) -> Logger {
172
- let defaultLogLevel = logFilter. getDefaultLogLevel ( forCategory: category, userIdentifier: self . userIdentifier)
173
- return self . logger ( forCategory: category, namespace: nil , logLevel: defaultLogLevel)
174
+ let defaultLogLevel = logFilter. getDefaultLogLevel ( forCategory: category, userIdentifier: userIdentifier)
175
+ return logger ( forCategory: category, namespace: nil , logLevel: defaultLogLevel)
174
176
}
175
177
176
178
func logger( forNamespace namespace: String ) -> Logger {
177
- self . logger ( forCategory: namespace)
179
+ logger ( forCategory: namespace)
178
180
}
179
181
180
182
func logger( forCategory category: String , forNamespace namespace: String ) -> Logger {
181
- let defaultLogLevel = logFilter. getDefaultLogLevel ( forCategory: category, userIdentifier: self . userIdentifier)
182
- return self . logger ( forCategory: category, namespace: namespace, logLevel: defaultLogLevel)
183
+ let defaultLogLevel = logFilter. getDefaultLogLevel ( forCategory: category, userIdentifier: userIdentifier)
184
+ return logger ( forCategory: category, namespace: namespace, logLevel: defaultLogLevel)
183
185
}
184
186
185
187
func getInternalClient( ) -> CloudWatchLogsClientProtocol {
0 commit comments