Add monitor classes for pretest checklist sparodev#2 (sparodev#5)

* Add monitors for pretest checklist sparodev#2

* Update author in podspec sparodev#2

Author: mwahlig

.swift-version

@@ -1 +1 @@
-4
+4.0

Podfile

@@ -10,6 +10,7 @@ target 'WingKit' do
   pod 'AWSS3'
   pod 'AWSCognito'
   pod 'AWSCognitoIdentityProvider'
+  pod 'ReachabilitySwift'
 
   target 'WingKitTests' do
     inherit! :search_paths

Podfile.lock

@@ -6,19 +6,22 @@ PODS:
   - AWSCore (2.6.1)
   - AWSS3 (2.6.1):
     - AWSCore (= 2.6.1)
+  - ReachabilitySwift (3)
 
 DEPENDENCIES:
   - AWSCognito
   - AWSCognitoIdentityProvider
   - AWSCore
   - AWSS3
+  - ReachabilitySwift
 
 SPEC CHECKSUMS:
   AWSCognito: 9aad635e11de0febf026e8a8acbbd345b2016801
   AWSCognitoIdentityProvider: a335678a0024fa2b44213bc4e86b46b21773e567
   AWSCore: e7d37fa0715def975acf1b0d75556576780088b8
   AWSS3: 2e18ede28199a5530955dc1a65434da43dcc4d2c
+  ReachabilitySwift: f5b9bb30a0777fac8f09ce8b067e32faeb29bb64
 
-PODFILE CHECKSUM: c613f50bf91b8944df444eb843e3f53034dbbe6e
+PODFILE CHECKSUM: f4811200c8b1ca96836fae5982534dab84a4ad13
 
 COCOAPODS: 1.2.1

WingKit.podspec

@@ -25,7 +25,7 @@ Pod::Spec.new do |s|
   #   * Write the description between the DESC delimiters below.
   #   * Finally, don't worry about the indent, CocoaPods strips it!
   s.description  = <<-DESC
-                    Provides the ability for third party applications to integrate with the Wing REST API and perform lung function tests.
+  An SDK that allows third parties to interface with Wing API and perform lung function tests.
                    DESC
 
   s.homepage     = "https://github.com/sparodev/WingKit"
@@ -80,7 +80,7 @@ Pod::Spec.new do |s|
   #  Supports git, hg, bzr, svn and HTTP.
   #
 
-  s.source       = { :git => "https://github.com/sparodev/WingKit.git", :tag => "#{s.version}" }
+  s.source       = { :git => "git@github.com:mwahlig/WingKit.git", :tag => "#{s.version}" }
 
 
   # ――― Source Code ―――――――――――――――――――――――――――――――――――――――――――――――――――――――――――――― #
@@ -91,7 +91,7 @@ Pod::Spec.new do |s|
   #  Not including the public_header_files will make all headers public.
   #
 
-  s.source_files  = "Classes", "WingKit/Classes/**/*.swift"
+  s.source_files  = "WingKit/Classes", "WingKit/Classes/**/*.swift"
   s.exclude_files = "Classes/Exclude"
 
   # s.public_header_files = "Classes/**/*.h"

WingKit.xcodeproj/project.pbxproj

@@ -68,6 +68,9 @@
 		6CE17A741F74D88800789D00 /* Date+ISO8601.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = "Date+ISO8601.swift"; sourceTree = "<group>"; };
 		6CE17A771F75965B00789D00 /* TestSessionTest.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = TestSessionTest.swift; sourceTree = "<group>"; };
 		6CE17A791F75966D00789D00 /* TestTest.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = TestTest.swift; sourceTree = "<group>"; };
+		6CF1C1721F855FC900C4F952 /* SensorMonitor.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = SensorMonitor.swift; sourceTree = "<group>"; };
+		6CF1C1731F855FC900C4F952 /* AmbientNoiseMonitor.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = AmbientNoiseMonitor.swift; sourceTree = "<group>"; };
+		6CF1C1741F855FC900C4F952 /* ReachabilityMonitor.swift */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.swift; path = ReachabilityMonitor.swift; sourceTree = "<group>"; };
 		846069578BD4FDF47618DFE6 /* Pods_WingKitTests.framework */ = {isa = PBXFileReference; explicitFileType = wrapper.framework; includeInIndex = 0; path = Pods_WingKitTests.framework; sourceTree = BUILT_PRODUCTS_DIR; };
 		8EDA753260E429AB8E829D6B /* Pods_WingKit.framework */ = {isa = PBXFileReference; explicitFileType = wrapper.framework; includeInIndex = 0; path = Pods_WingKit.framework; sourceTree = BUILT_PRODUCTS_DIR; };
 		9DA5ECD775C30D4D089E9857 /* Pods-WingKitTests.debug.xcconfig */ = {isa = PBXFileReference; includeInIndex = 1; lastKnownFileType = text.xcconfig; name = "Pods-WingKitTests.debug.xcconfig"; path = "Pods/Target Support Files/Pods-WingKitTests/Pods-WingKitTests.debug.xcconfig"; sourceTree = "<group>"; };
@@ -152,6 +155,7 @@
 		6CA9A0101F743B0B0085E247 /* Classes */ = {
 			isa = PBXGroup;
 			children = (
+				6CF1C1711F855FC900C4F952 /* Monitors */,
 				6CE17A721F74D7E500789D00 /* Extensions */,
 				6CE17A6F1F74D25E00789D00 /* Protocols */,
 				6CE17A6C1F74C9F000789D00 /* UploadTarget */,
@@ -230,6 +234,16 @@
 			path = Extensions;
 			sourceTree = "<group>";
 		};
+		6CF1C1711F855FC900C4F952 /* Monitors */ = {
+			isa = PBXGroup;
+			children = (
+				6CF1C1721F855FC900C4F952 /* SensorMonitor.swift */,
+				6CF1C1731F855FC900C4F952 /* AmbientNoiseMonitor.swift */,
+				6CF1C1741F855FC900C4F952 /* ReachabilityMonitor.swift */,
+			);
+			path = Monitors;
+			sourceTree = "<group>";
+		};
 		9345E7DAD294DB07AFEC62A7 /* Pods */ = {
 			isa = PBXGroup;
 			children = (

WingKit/Classes/Monitors/AmbientNoiseMonitor.swift

@@ -0,0 +1,155 @@
+//
+//  AmbientNoiseMonitor.swift
+//  AWSCognito
+//
+//  Created by Matt Wahlig on 10/4/17.
+//
+
+import Foundation
+import AVFoundation
+
+public protocol AmbientNoiseMonitorDelegate: class {
+    func ambientNoiseMonitorDidChangeState(_ monitor: AmbientNoiseMonitor)
+}
+
+public class AmbientNoiseMonitor {
+
+    public enum Error: Swift.Error {
+        case microphonePermissionDenied
+        case recorderConfigurationError
+    }
+
+    public weak var delegate: AmbientNoiseMonitorDelegate?
+
+    fileprivate(set) var isActive = false
+
+    fileprivate var recorder: AVAudioRecorder?
+    fileprivate var audioSession = AVAudioSession.sharedInstance()
+
+    public fileprivate(set) var isBelowThreshold: Bool = true
+
+    public var noiseThreshold: Float = -10.0
+    public var noiseCheckInterval: TimeInterval = 0.25
+
+    fileprivate var noiseCheckTimer: Timer?
+
+    public init() {}
+
+    public func start(completion: @escaping (Error?) -> Void) {
+
+        guard !isActive else { return }
+
+        configureAudioSession { error in
+
+            if let error = error {
+                completion(error)
+                return
+            }
+
+            self.isActive = true
+
+            self.startRecorder()
+            self.startTimer()
+
+            completion(nil)
+        }
+    }
+
+    public func stop() {
+
+        isActive = false
+
+        stopRecorder()
+        stopTimer()
+    }
+
+    fileprivate func configureAudioSession(completion: @escaping (Error?) -> Void) {
+
+        if recorder == nil {
+            audioSession.requestRecordPermission({ (granted) in
+
+                guard granted else {
+                    completion(Error.microphonePermissionDenied)
+                    return
+                }
+
+                do {
+                    try self.audioSession.setCategory(
+                        AVAudioSessionCategoryPlayAndRecord,
+                        with: .defaultToSpeaker)
+                    try self.audioSession.setActive(true)
+                } catch {
+                    completion(Error.recorderConfigurationError)
+                }
+
+                let manager = FileManager()
+                guard let cachesDirectoryURL = manager.urls(for: .cachesDirectory, in: .userDomainMask).first else {
+                    completion(Error.recorderConfigurationError)
+                    return
+                }
+
+                let recordingFileURL = cachesDirectoryURL.appendingPathComponent("recordTest.caf")
+                let recordSettings: [String : AnyObject] = [
+                    AVFormatIDKey: Int(kAudioFormatAppleIMA4) as AnyObject,
+                    AVSampleRateKey: 44100.0 as AnyObject,
+                    AVNumberOfChannelsKey: 1 as AnyObject,
+                    AVEncoderBitRateKey: 12800 as AnyObject,
+                    AVLinearPCMBitDepthKey: 16 as AnyObject,
+                    AVEncoderAudioQualityKey: AVAudioQuality.max.rawValue as AnyObject
+                ]
+
+                do {
+                    self.recorder = try AVAudioRecorder(url: recordingFileURL, settings: recordSettings)
+                } catch {
+                    completion(Error.recorderConfigurationError)
+                }
+
+                completion(nil)
+
+            })
+        }
+    }
+
+    // MARK: - Recorder
+
+    fileprivate func startRecorder() {
+        self.recorder?.prepareToRecord()
+        self.recorder?.isMeteringEnabled = true
+        self.recorder?.record()
+    }
+
+    fileprivate func stopRecorder() {
+        recorder?.stop()
+    }
+
+    // MARK: - Timer
+
+    fileprivate func startTimer() {
+        noiseCheckTimer = Timer.scheduledTimer(timeInterval: noiseCheckInterval,
+                                               target: self, selector: #selector(checkAmbientNoise),
+                                               userInfo: nil, repeats: true)
+    }
+
+    fileprivate func stopTimer() {
+        noiseCheckTimer?.invalidate()
+        noiseCheckTimer = nil
+    }
+
+    /**
+     Checks whether the ambient noise is above a threshold
+     */
+    @objc func checkAmbientNoise() {
+        recorder?.updateMeters()
+
+        let previousState = isBelowThreshold
+        if let averagePower = recorder?.averagePower(forChannel: 0) {
+            isBelowThreshold = !(averagePower > noiseThreshold)
+        } else {
+            isBelowThreshold = false
+        }
+
+        if previousState != isBelowThreshold {
+            delegate?.ambientNoiseMonitorDidChangeState(self)
+        }
+    }
+}

WingKit/Classes/Monitors/ReachabilityMonitor.swift

@@ -0,0 +1,93 @@
+//
+//  ReachabilityMonitor.swift
+//  AWSCognito
+//
+//  Created by Matt Wahlig on 10/4/17.
+//
+
+import Foundation
+import ReachabilitySwift
+
+enum ReachabilityMonitorError: Error {
+    case configurationError
+    case monitorUnavailable
+}
+
+public protocol ReachabilityMonitorDelegate: class {
+    func reachabilityMonitorDidChangeReachability(_ manager: ReachabilityMonitor)
+}
+
+public class ReachabilityMonitor {
+
+    public weak var delegate: ReachabilityMonitorDelegate?
+
+    fileprivate(set) var isActive = false
+
+    public var isConnectedToInternet: Bool {
+        return reachability?.isReachable ?? false
+    }
+
+    fileprivate let reachability = Reachability()
+
+    // MARK: - Init
+
+    public init() {
+        configure()
+    }
+
+    deinit {
+        NotificationCenter.default.removeObserver(self)
+    }
+
+    // MARK: - Start/Stop
+
+    public func start() throws {
+
+        guard !isActive else { return }
+
+        guard let reachability = reachability else {
+            throw ReachabilityMonitorError.configurationError
+        }
+
+        do {
+            try reachability.startNotifier()
+
+            self.isActive = true
+
+        } catch {
+            throw ReachabilityMonitorError.monitorUnavailable
+        }
+    }
+
+    public func stop() {
+        isActive = false
+
+        reachability?.stopNotifier()
+    }
+
+    // MARK: - Configure
+
+    fileprivate func configure() {
+        guard let reachability = reachability else {
+            return
+        }
+
+        NotificationCenter.default.addObserver(
+            self, selector: #selector(reachabilityChanged(_:)),
+            name: ReachabilityChangedNotification, object: reachability)
+    }
+
+    // MARK: - Reachability Changed Observer
+
+    /**
+     Triggered when the network reachability changes
+
+     - parameter notification:
+     */
+    @objc func reachabilityChanged(_ notification: Notification) {
+        DispatchQueue.main.async {
+            self.delegate?.reachabilityMonitorDidChangeReachability(self)
+        }
+    }
+}
+