@@ -3,13 +3,34 @@

 #include <EthernetENC.h>

 #include <PubSubClient.h>

+

+int motorSpeedPin =   6;

+int motorUpPin =      2;

+int motorDownPin =    3;

+int motorLeftPin =    4;

+int motorRightPin =   5;

+int posTilt =         A0;

+int posPan =          A1;

+int motorSpeedStat =   0;

+

 // Update these with values suitable for your network.

 byte mac[]    = {  0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED };

 IPAddress ip(10, 13, 37, 165); 

 byte server[] = {10, 13, 37, 101};

 void callback(char* topic, byte* payload, unsigned int length) {

-  // handle message arrived

+

+  Serial.print("Message arrived [");

+  Serial.print(topic);

+  Serial.print("] ");

+  for (int i = 0; i < length; i++) {

+    Serial.print((char)payload[i]);

+  }

+  Serial.println("");

+

+

+

+  

 }

 EthernetClient ethClient;

@@ -17,6 +38,16 @@ PubSubClient client(server, 1883, callback, ethClient);

 void setup()

 {

+

+  pinMode(motorSpeedPin, OUTPUT);

+  pinMode(motorUpPin, OUTPUT);

+  pinMode(motorDownPin, OUTPUT);

+  pinMode(motorLeftPin, OUTPUT);

+  pinMode(motorRightPin, OUTPUT);

+

+  pinMode(posTilt, INPUT);

+  pinMode(posPan, INPUT);

+

   Serial.begin(9600);

   Ethernet.begin(mac, ip);

   client.setBufferSize(255);

@@ -30,10 +61,14 @@ void reconnect() {

     // Attempt to connect

     if (client.connect("connectionName", "[[USER]]", "[[PASS]]")) {

       Serial.println("connected");

-      // Once connected, publish an announcement...

-      client.publish("outTopic","hello world");

-      // ... and resubscribe

-      client.subscribe("inTopic");

+      client.publish("hamradio/rotator/status","READY");

+      client.subscribe("hamradio/rotator/#");

+        

+  client.publish("hamradio/rotator/motor/speed", "100");

+  client.publish("hamradio/rotator/pos/pan", "180");

+  client.publish("hamradio/rotator/pos/tilt", "60");

+  client.publish("hamradio/rotator/goto/pan", "180");

+  client.publish("hamradio/rotator/goto/tilt", "60");

     } else {

       Serial.print("failed, rc=");

       Serial.print(client.state());

@@ -50,4 +85,8 @@ void loop()

     reconnect();

   }

   client.loop();

+

+

+

+  

 }