V0.6.0 Apalone

Sources/IoT-Simulator-Core/Classes/Devices/EdgeDevice.swift

@@ -1,73 +1,90 @@
-public class EdgeDevice : EdgeDeviceP {
-    
+import Crypto
+import DataAcquisition
+import Foundation
+
+public class EdgeDevice: EdgeDeviceP {
+
     public let deviceID: String
     public let deviceType: DeviceType
     public let dataType: DataType
     public var disconnected: Bool
     public var compromised: Bool
+    public var location: Location3D
     public var dutyCicle: UInt
     public var sensors: [Int: Sensor]
-    public var privateKey: [UInt8]
+    public var privateKey: P521.Signing.PrivateKey
 
     private var numberOfSensors: Int {
-        get{
-            return sensors.count
-        }
+        return sensors.count
     }
 
     public init(
         deviceID: String,
         dataType: DataType,
         disconnected: Bool,
+        location: Location3D,
         dutyCicle: UInt,
-        sensors: [Int: Sensor]
+        sensors: [Int: Sensor],
+        privateKey: P521.Signing.PrivateKey
     ) {
         self.deviceID = deviceID
         self.deviceType = DeviceType.EdgeDevice
         self.dataType = dataType
         self.disconnected = disconnected
         self.compromised = false
+        self.location = location
         self.dutyCicle = dutyCicle
         self.sensors = sensors
+        self.privateKey = privateKey
     }
 
     public func addSensor(sensor: Sensor) {
-        self.sensors[numberOfSensors +  1] = sensor
+        self.sensors[numberOfSensors + 1] = sensor
     }
 
     public func removeSensor(id: Int) {
         self.sensors.removeValue(forKey: id)
     }
 
-    public func work(envrionment: PhysicalEnvironment)  {
+    public func work(envrionment: PhysicalEnvironment) -> Message {
 
-        // UGLY: In case I have some optimization problems, fix here
-        var values: [Float] = []
+        // UGLY: Declaring here some variables manually, remove them if you want to offere flexibility
+        let numberOfSamples: Int = 10
 
-        for sensor in sensors {
-            values.append(
-                sensor.value.read(envrionment).value
-            )
-        }
+        let rowPointer =
+            UnsafeMutablePointer<UnsafeMutablePointer<Float>?>.allocate(capacity: numberOfSamples)
 
-        // Todo: START Remove this and Add Vincenzo's implementation
-        let avg : Float = meanValue(values: values)
-        let std_dev : Float = standardDeviation(values: values)
-
-        // Todo: END Add Vincenzo's implementation
-        return Message(
-            msgType: MessageType.Data, 
-            timestamp: , 
-            deviceID: String, 
-            location: Location3D, 
-            fields: [Field], 
-            signature: [UInt8]
+        rowPointer.initialize(
+            repeating: UnsafeMutablePointer<Float>
+                .allocate(capacity: self.sensors.count),
+            count: numberOfSamples
         )
 
+        for rowI in 0..<numberOfSamples {
+            for colI in 0..<self.sensors.count {
+                rowPointer[rowI]![colI] = self.sensors[colI]!.read(envrionment).value
+            }
+        }
+
+        let metrics: Metrics = getMetrics(
+            rowPointer, Int32(self.sensors.count), Int32(numberOfSamples))
+
+        // Todo: END Add Vincenzo's implementation
+        let msg: Message = Message(
+            msgType: MessageType.Data,
+            timestamp: Date(),
+            deviceID: self.deviceID,
+            location: self.location,
+            fields: [
+                Field(key: "data_type", value: "\(self.dataType)"),
+                Field(key: "mean_value", value: "\(metrics.mean)"),
+                Field(key: "std_value", value: "\(metrics.standardDeviation)"),
+            ]
+        )
+
+        msg.signMessage(key: self.privateKey)
+
+        return msg
     }
 
-
-
-    
-
-} 
+}

Sources/IoT-Simulator-Core/Classes/Devices/Sensors.swift

@@ -1,3 +1,5 @@
+import RandomCpp
+
 public class Sensor {
 
     public let sensorID: Int
@@ -20,7 +22,7 @@ public class Sensor {
 
         let datum = self._read(environment)
 
-        return self.faulty ? datum : datum + Float.random(in: 1E2...1E10)
+        return !self.faulty ? datum : datum + Float.random(in: 1E2...1E10)
 
     }
 
@@ -60,7 +62,7 @@ public class RealSensor: Sensor {
     private var _stdNoise: Float
     private let _quantizationBits: Int
     // TODO: add a generator of GaussianRNG 
-    //private var gaussianNoise: 
+    private var _gaussianNoise: GaussianRNG
 
     public init(
         sensorID: Int,
@@ -73,26 +75,30 @@ public class RealSensor: Sensor {
         self._meanNoise = meanNoise
         self._stdNoise = stdNoise
         self._quantizationBits = quantizationBits
+        self._gaussianNoise = GaussianRNG(self._meanNoise, self._stdNoise)
         super.init(id: sensorID, sensorType: sensorType, faulty: faulty)
     }
 
-    public init(
+    convenience public init(
         sensorID: Int,
         sensorType: DataType,
         meanNoise: Float,
         stdNoise: Float,
         quantizationBits: Int 
     ) {
-        self._meanNoise = meanNoise
-        self._stdNoise = stdNoise
-        self._quantizationBits = quantizationBits
-        super.init(id: sensorID, sensorType: sensorType)
+        self.init(
+            sensorID: sensorID, 
+            sensorType: sensorType, 
+            faulty: false, 
+            meanNoise: meanNoise, 
+            stdNoise: stdNoise, 
+            quantizationBits: quantizationBits
+        )
     }
 
     override public func read(_ environment: PhysicalEnvironment) -> PhysicalData {
         let value: PhysicalData = super.read(environment)
-        // TODO Add gaussian error here
-        return value 
+        return value + self._gaussianNoise.generate()
     }
 
 }

Sources/IoT-Simulator-Core/Classes/Utils/Field.swift

@@ -8,5 +8,9 @@ public class Field {
         self.key = key
         self.value = value
     }
+
+    public var description: String {
+        return "\(self.key): \t\(self.value)"
+    }
     
 }

Sources/IoT-Simulator-Core/Classes/Utils/Location3D.swift

@@ -9,4 +9,8 @@ public class Location3D {
         self.y = y 
         self.z = z
     }
+
+    public var description: String {
+        return "X: \(self.x)\tY: \(self.y)\tZ: \(self.z)"
+    }
 }

Sources/IoT-Simulator-Core/Classes/Utils/Message.swift

@@ -9,9 +9,7 @@ public class Message {
     public let location: Location3D
     public let fields: [Field]
     public var signature: String {
-        get{
-            return self._signature != nil ? self._signature! : "##INVALID"
-        }
+        return self._signature != nil ? self._signature! : "##INVALID"
     }
     private var _signature: String? = nil
 
@@ -30,22 +28,41 @@ public class Message {
 
     }
 
-    public func toData() -> Data {
-        var string: String = "" + "\(messageType)" + "\(timestamp)" + "\(deviceID)" + "\(location)"
+    public func toDataCompatibleString() -> String {
+        var string: String = "\(self.messageType)" 
+        string += "\(self.timestamp)" 
+        string += "\(self.deviceID)" 
+        string += "\(self.location.x)"
+        string += "\(self.location.y)"
+        string += "\(self.location.z)"
 
         for field in self.fields {
-            string += "\(field)"
+            string += "\(field.key)\(field.value)"
         }
 
-        return Data(string.utf8)
+        return string
     }
 
     public func signMessage(key: P521.Signing.PrivateKey) {
         do {
-            self._signature = try sign(object: self.toData(), key: key) 
+            self._signature = try sign(string: self.toDataCompatibleString(), key: key)
         } catch {
             // Do nothing
         }
     }
 
+    public var description: String {
+
+        var string: String = "MessageType: \t\(self.messageType)\n" 
+        string += "Timestamp: \t\(self.timestamp)\n" 
+        string += "DeviceID: \t\(self.deviceID)\n" 
+        string += "Location: \t\(self.location.description)\n"
+
+        for field in self.fields {
+            string += "\(field.description)\n"
+        }
+
+        return string
+    }
+
 }

Sources/IoT-Simulator-Core/Classes/Utils/WorkerTask.swift

@@ -0,0 +1,55 @@
+/* import Foundation
+
+public class WorkerTask {
+
+    public let env: PhysicalEnvironment
+    public let device: EdgeDeviceP
+    public let success: (_ msg: Message) throws -> Void
+    public let failure: () -> Void
+    private var task : Task<(), Never>?
+
+    public init(
+        env: PhysicalEnvironment,
+        dev: EdgeDeviceP,
+        success: @escaping (_ msg: Message) throws -> Void,
+        failure: @escaping () -> Void
+    ) {
+        self.env = env
+        self.device = dev
+        self.success = success
+        self.failure = failure
+        self.task = nil
+    }
+
+    public func work()  {
+
+        task = Task{
+            
+            while true {
+
+                let message = device.work(envrionment: env)
+                do {
+                    try success(message)
+                } catch{
+                    failure()
+                }
+                usleep(__useconds_t(device.dutyCicle))
+            }
+        }
+
+    }
+
+    public func cancel() {
+        if self.task == nil {
+            return 
+        }
+
+        self.task!.cancel()
+        self.task = nil
+    }
+    
+
+    
+
+}
+ */

Sources/IoT-Simulator-Core/Enums/DataType.swift

@@ -1,4 +1,4 @@
-public enum DataType {
+public enum DataType : Sendable{
     case Temperature
     case Humidity
     case Scan

Sources/IoT-Simulator-Core/Enums/DeviceType.swift

@@ -1,4 +1,4 @@
-public enum DeviceType {
+public enum DeviceType : Sendable{
     case AsyncEdgeDevice
     case EdgeDevice
 }

Sources/IoT-Simulator-Core/Errors/CoreErrors.swift

@@ -1,3 +1,4 @@
 public enum CoreError : Error {
     case NoPhysicalDataAvailable( dataType: String)
+    case NoEnvironment
 }

Sources/IoT-Simulator-Core/IoT_Simulator_Core.swift

@@ -1,2 +1,73 @@
 // The Swift Programming Language
 // https://docs.swift.org/swift-book
+
+import Foundation
+
+public actor IoTSimulatorCore {
+
+    private static var enviroments: [String: PhysicalEnvironment] = Dictionary()
+    private static var devices: [String: EdgeDeviceP] = Dictionary()
+    private static var env_dev: [String: Set<String>] = Dictionary()
+    private static var dev_tasks: [String: Task<(), Never>] = Dictionary()
+
+    public static func addEnv(environment: PhysicalEnvironment) {
+        IoTSimulatorCore.enviroments[environment.location] = environment
+    }
+
+    public static func addDevice(location: String, device: EdgeDeviceP) throws {
+        if let environment = IoTSimulatorCore.enviroments[location] {
+            IoTSimulatorCore.devices[device.deviceID] = device
+
+            if IoTSimulatorCore.env_dev[location] == nil {
+                IoTSimulatorCore.env_dev[location] = Set()
+            }
+
+            IoTSimulatorCore.env_dev[location]!.insert(device.deviceID)
+
+            // schedule work
+            let task = IoTSimulatorCore.schedule(envID: environment.location, deviceID: device.deviceID) { msg in
+                print("\(msg.description)\n\n")
+            } failure: {
+                print("Something is wrong")
+            }
+
+            IoTSimulatorCore.dev_tasks[device.deviceID] = task
+
+        } else {
+            throw CoreError.NoEnvironment
+        }
+
+    }
+
+    public static func getEnv(name: String) -> PhysicalEnvironment? {
+        return IoTSimulatorCore.enviroments[name]
+    }
+
+    public static func getDev(devID: String) -> EdgeDeviceP? {
+        return IoTSimulatorCore.devices[devID]
+    }
+
+    private static func schedule(
+        envID: sending String,
+        deviceID: sending String,
+        success: sending @escaping (_ msg: Message) throws -> Void,
+        failure: sending @escaping () -> Void
+    )  -> Task<(), Never> {
+        return Task {
+
+            while true {
+                let dev = IoTSimulatorCore.getDev(devID: deviceID)!
+                let env = IoTSimulatorCore.getEnv(name: envID)!
+
+                let message = dev.work(envrionment: env)
+                do {
+                    try success(message)
+                } catch {
+                    failure()
+                }
+                usleep(__useconds_t(dev.dutyCicle * 1000))
+            }
+        }
+    }
+
+}

Sources/IoT-Simulator-Core/Protocols/EdgeDeviceProtocol.swift

@@ -1,12 +1,15 @@
+import Crypto
+
 public protocol EdgeDeviceP {
 
     var deviceID : String {get}
     var deviceType : DeviceType {get}
     var dataType : DataType {get}
+    var location: Location3D {get set}
     var disconnected : Bool {get set}
     var compromised : Bool {get set}
     var dutyCicle : UInt {get set}
-    var privateKey: [UInt8] {get}
+    var privateKey: P521.Signing.PrivateKey {get}
 
     func work(envrionment: PhysicalEnvironment) ->  Message
 

Sources/IoT-Simulator-Core/Utils/Security.swift

@@ -16,6 +16,13 @@ public func sign(object: Data, key: P521.Signing.PrivateKey)throws -> String {
     return try key.signature<Data>(for: object).rawRepresentation.base64EncodedString()
 
 }
+/* 
+public func sign<T>(object: T, key: P521.Signing.PrivateKey) throws -> String {
+
+    var _object = object
+    let data: Data = Data(bytes: &_object, count: MemoryLayout<T>.stride)
+
+} */