# Download Yocto Image
wget https://downloadmirror.intel.com/25028/eng/iot-devkit-prof-dev-image-galileo-20160606.direct.xz

# Flash to SD Card (Linux)
sudo dd if=iot-devkit-prof-dev-image-galileo-20160606.direct of=/dev/sdX bs=4M status=progress

# First Boot Configuration
systemctl enable ssh
systemctl start ssh

# Install Arduino Development Tools
opkg update
opkg install arduino-dev-tools

# Configure WiFi
wpa_passphrase "YourSSID" "YourPassword" >> /etc/wpa_supplicant/wpa_supplicant.conf
systemctl enable wpa_supplicant
systemctl start wpa_supplicant

// ArduinoX86 Industrial Control System
#include <WiFi.h>
#include <WebSocketsServer.h>
#include <ArduinoJson.h>
#include <ModbusMaster.h>

// Network Configuration
const char* ssid = "Factory_WiFi";
const char* password = "your_password";

// Modbus Configuration
ModbusMaster node;
WebSocketsServer webSocket = WebSocketsServer(81);

// System State
struct MachineState {
  float temperature;
  float pressure;
  int motorSpeed;
  bool isRunning;
  bool emergencyStop;
} machines[4];

void setup() {
  Serial.begin(115200);
  
  // Initialize Modbus
  Serial1.begin(9600);
  node.begin(1, Serial1);
  
  // Connect to WiFi
  WiFi.begin(ssid, password);
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.println("Connecting to WiFi...");
  }
  
  Serial.println("WiFi connected!");
  Serial.print("IP address: ");
  Serial.println(WiFi.localIP());
  
  // Start WebSocket server
  webSocket.begin();
  webSocket.onEvent(webSocketEvent);
  
  // Initialize GPIO for emergency stop
  pinMode(2, INPUT_PULLUP); // Emergency stop button
  
  Serial.println("Industrial Control System Ready");
}

void loop() {
  webSocket.loop();
  
  // Read machine data every 100ms
  static unsigned long lastRead = 0;
  if (millis() - lastRead > 100) {
    readMachineData();
    checkSafety();
    lastRead = millis();
  }
  
  // Send data to clients every 1 second
  static unsigned long lastSend = 0;
  if (millis() - lastSend > 1000) {
    sendMachineData();
    lastSend = millis();
  }
}

void readMachineData() {
  for (int i = 0; i < 4; i++) {
    // Read temperature (Holding Register 0)
    uint8_t result = node.readHoldingRegisters(i * 10, 4);
    
    if (result == node.ku8MBSuccess) {
      machines[i].temperature = node.getResponseBuffer(0) / 10.0;
      machines[i].pressure = node.getResponseBuffer(1) / 100.0;
      machines[i].motorSpeed = node.getResponseBuffer(2);
      machines[i].isRunning = node.getResponseBuffer(3) > 0;
    }
  }
}

void checkSafety() {
  // Check emergency stop
  if (digitalRead(2) == LOW) {
    for (int i = 0; i < 4; i++) {
      machines[i].emergencyStop = true;
      stopMachine(i);
    }
  }
  
  // Check temperature limits
  for (int i = 0; i < 4; i++) {
    if (machines[i].temperature > 85.0) {
      Serial.printf("Machine %d overheating: %.1f°C\n", i, machines[i].temperature);
      stopMachine(i);
    }
  }
}

void stopMachine(int machineId) {
  // Send stop command via Modbus
  node.writeSingleRegister(machineId * 10 + 10, 0);
  machines[machineId].isRunning = false;
}

void sendMachineData() {
  DynamicJsonDocument doc(1024);
  JsonArray machineArray = doc.createNestedArray("machines");
  
  for (int i = 0; i < 4; i++) {
    JsonObject machine = machineArray.createNestedObject();
    machine["id"] = i;
    machine["temperature"] = machines[i].temperature;
    machine["pressure"] = machines[i].pressure;
    machine["motorSpeed"] = machines[i].motorSpeed;
    machine["isRunning"] = machines[i].isRunning;
    machine["emergencyStop"] = machines[i].emergencyStop;
  }
  
  String jsonString;
  serializeJson(doc, jsonString);
  webSocket.broadcastTXT(jsonString);
}

void webSocketEvent(uint8_t num, WStype_t type, uint8_t * payload, size_t length) {
  switch(type) {
    case WStype_CONNECTED:
      Serial.printf("Client %u connected\n", num);
      break;
      
    case WStype_TEXT:
      handleWebSocketMessage(num, (char*)payload);
      break;
      
    case WStype_DISCONNECTED:
      Serial.printf("Client %u disconnected\n", num);
      break;
  }
}

void handleWebSocketMessage(uint8_t clientNum, char* message) {
  DynamicJsonDocument doc(512);
  deserializeJson(doc, message);
  
  String command = doc["command"];
  int machineId = doc["machineId"];
  
  if (command == "start" && !machines[machineId].emergencyStop) {
    node.writeSingleRegister(machineId * 10 + 10, 1);
    Serial.printf("Starting machine %d\n", machineId);
  }
  else if (command == "stop") {
    stopMachine(machineId);
    Serial.printf("Stopping machine %d\n", machineId);
  }
  else if (command == "setSpeed") {
    int speed = doc["speed"];
    node.writeSingleRegister(machineId * 10 + 11, speed);
    Serial.printf("Setting machine %d speed to %d\n", machineId, speed);
  }
}