brennanMKE
commented
2 years ago @JyotsnaPiOSDEV
I see you are directly using a tokenValue which is what will expire. Once it expires this connection will no longer be valid since it is not being refreshed. What you can do is set up AWSIoTDataManager with an instance of AWSCredentialsProvider which will get a fresh credentials as needed.
We have a sample project which you can reference. First, see how the credentials provider is created. (code) It is passed into initializeControlPlane and initializeDataPlane.
Below is an example of sections you can define in awsconfiguration.json for IoT. The first 2 sections are for the control plane and the last one is for the data plane. Set the region as appropriate and replace "REPLACE" with the data URL for IoT.
"IoT": {
"Default": {
"Region": "us-east-1",
"Endpoint": "https://iot.us-east-1.amazonaws.com"
}
},
"IoTManager": {
"Default": {
"Region": "us-east-1",
"Endpoint": "https://iot.us-east-1.amazonaws.com"
}
},
"IoTDataManager": {
"Default": {
"Region": "us-east-1",
"Endpoint": "https://REPLACE-ats.iot.us-east-1.amazonaws.com"
}
},Below is some reference code you can use as well. It loads these sections from awsconfiguration.json so your code does not require any constants with these values. It sets up the control plane and data plane and confirms them with assertions at the end.
// MARK: - Control Plane setup
guard let iotServiceInfo = AWSInfo.default().serviceInfo("IoT", forKey: "Default"),
let iotManagerServiceInfo = AWSInfo.default().serviceInfo("IoTManager", forKey: "Default"),
let iotDataManagerServiceInfo = AWSInfo.default().serviceInfo("IoTDataManager", forKey: "Default") else {
fatalError("Failed to read in default service info for IoT")
}
let iot = AWSIoT.default()
guard let credentialsProvider = iot.configuration.credentialsProvider as? AWSCognitoCredentialsProvider else {
fatalError("App must be configured")
}
let region = iotServiceInfo.region
let controlPlaneServiceConfiguration = AWSServiceConfiguration(region:region, credentialsProvider:credentialsProvider)
AWSServiceManager.default().defaultServiceConfiguration = controlPlaneServiceConfiguration
iotManager = AWSIoTManager.default()
self.region = region
self.credentialsProvider = credentialsProvider
guard let iotDataManagerEndpoint = iotDataManagerServiceInfo.endpoint else {
fatalError("Failed to get Data Manager endpoint")
}
// MARK: - Data Plane setup
guard let dataConfiguration = AWSServiceConfiguration(region: iotDataManagerServiceInfo.region,
endpoint: iotDataManagerEndpoint,
credentialsProvider: credentialsProvider) else {
fatalError("Failed to create Data Configuration")
}
// Configure MQTT with Last Will & Testament (LWT)
let mqttConfiguration = AWSIoTMQTTConfiguration()
let message = "LWT-\(Date())"
mqttConfiguration.lastWillAndTestament.message = message
mqttConfiguration.lastWillAndTestament.topic = "lwt/disconnected"
mqttConfiguration.lastWillAndTestament.qos = .messageDeliveryAttemptedAtLeastOnce
mqttConfiguration.lastWillAndTestament.willRetain = true
AWSIoTDataManager.register(with: dataConfiguration, with: mqttConfiguration, forKey: Constants.dataManagerKey)
iotDataManager = AWSIoTDataManager(forKey: Constants.dataManagerKey)
// Control Plane
assertEqual(iotServiceInfo.infoDictionary["Endpoint"] as? String, iot.configuration.endpoint.url.absoluteString)
assertEqual(iotManagerServiceInfo.infoDictionary["Endpoint"] as? String, iotManager.configuration.endpoint.url.absoluteString)
// Data Plane
assertEqual(iotDataManagerServiceInfo.infoDictionary["Endpoint"] as? String, iotDataManager.configuration.endpoint.url.absoluteString)This code uses Cognito to support the credentials provider which may meet your needs with not additional requirements. Since you have a lambda doing this work you could create your own implementation of AWSCredentialsProvider because it is a protocol. See that we have an implementation called AWSStaticCredentialsProvider. You can see that you would need to implement the credentials function which returns AWSTask<AWSCredentials *> *. (code)
Your implementation will need to refresh the credentials before the current credentials expire so when they are requested they are always current. You could also refresh credentials on demand when they are expired. You will want to ensure this is done once when the token is expiring and make that process thread-safe.
JyotsnaPiOSDEV
harsh62
For connecting to MQTT channel of AWS IOT core we are using custom auth lambda for policy generation. In custom auth lambda we are using access token of AWS cognito to authenticate request. I want to reconnect on dissconect
Which AWS Services are you utilizing? AWSIoT
SDK Version: 2.270. Dependency Manager: Cocoapods
Device: Any device iOS Version: Any version
Please help how to reconnect and fix this disconnect issue