-
Notifications
You must be signed in to change notification settings - Fork 0
/
aiko_pebble.ino
1225 lines (993 loc) · 32.4 KB
/
aiko_pebble.ino
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
433
434
435
436
437
438
439
440
441
442
443
444
445
446
447
448
449
450
451
452
453
454
455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
491
492
493
494
495
496
497
498
499
500
501
502
503
504
505
506
507
508
509
510
511
512
513
514
515
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
536
537
538
539
540
541
542
543
544
545
546
547
548
549
550
551
552
553
554
555
556
557
558
559
560
561
562
563
564
565
566
567
568
569
570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
634
635
636
637
638
639
640
641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690
691
692
693
694
695
696
697
698
699
700
701
702
703
704
705
706
707
708
709
710
711
712
713
714
715
716
717
718
719
720
721
722
723
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
749
750
751
752
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908
909
910
911
912
913
914
915
916
917
918
919
920
921
922
923
924
925
926
927
928
929
930
931
932
933
934
935
936
937
938
939
940
941
942
943
944
945
946
947
948
949
950
951
952
953
954
955
956
957
958
959
960
961
962
963
964
965
966
967
968
969
970
971
972
973
974
975
976
977
978
979
980
981
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
/* aiko_pebble.pde
* ~~~~~~~~~~~~~~~
* Please do not remove the following notices.
* Copyright (c) 2009 by Geekscape Pty. Ltd.
* Documentation: http://groups.google.com/group/aiko-platform
* Documentation: http://geekscape.org/static/arduino.html
* License: GPLv3. http://geekscape.org/static/arduino_license.html
* Version: 0.3
* ----------------------------------------------------------------------------
* See Google Docs: "Project: Aiko: Stream protocol specification"
* Currently requires an Aiko-Gateway.
* ----------------------------------------------------------------------------
*
* Third-Party libraries
* ~~~~~~~~~~~~~~~~~~~~~
* These libraries are not included in the Arduino IDE and
* need to be downloaded and installed separately.
*
* - LiquidCrystal (now included as part of Arduino 0017 onwards)
* http://arduino.cc/en/Reference/LiquidCrystal
*
* - One-Wire (look for "most recent version" text for download link)
* http://www.arduino.cc/playground/Learning/OneWire
*
* - NewSoftSerial (download is at the bottom of the web page)
* http://arduiniana.org/libraries/newsoftserial
*
* - PString
* http://arduiniana.org/libraries/pstring
*
* To Do
* ~~~~~
* - Put protocol version into boot message to Aiko-Gateway.
* - Verify protocol version in the Aiko-Gateway boot message.
* - Default baud rate 38,400 and auto-baud to 115,200.
* - Fix temperature data acquisition should work every time, not every second time !
* - Temperature sensor won't need 750 ms, if using permanent 5 VDC.
* - Handle "(node= name)", where "name" greater than 40 characters.
* - "name" parameter should be delimited by double-quotes.
* - Complete serialHandler() communications.
* - Think about what happens when reusing "SExpressionArray commandArray" ?
* - Implement: addCommandHandler() and removeCommandHandler().
* - This will be neater than the current ugly #ifdef / #endif arrangement.
* - Implement: (update_rate SECONDS UNIT)
* - Implement: (error on) (error off)
* - Implement: (display_title= STRING) --> LCD position (0,0)
* - Make full use of the 20 column by 4 row LCD screen
* - Implement: (device_update NAME VALUE UNIT) or (NAME= VALUE)
* - Implement: (profile)
* - Implement: (clock yyyy-mm-ddThh:mm:ss)
* - Improve error handling.
*/
//#define IS_GATEWAY
#define IS_PEBBLE
//#define IS_STONE
#ifdef IS_GATEWAY
#define DEFAULT_NODE_NAME "gateway_1"
#define DEFAULT_TRANSMIT_RATE 15 // seconds
#define HAS_LCD
#define HAS_SENSORS
#define HAS_SERIAL_MIRROR
#define HAS_TOUCHPANEL
#endif
#ifdef IS_PEBBLE
#define DEFAULT_NODE_NAME "pebble_1"
#define DEFAULT_TRANSMIT_RATE 1 // seconds
#define ENABLE_AIKO_DEVICE_BUTTON
#define HAS_LCD
#define LCD_4094 // Drive LCD wth 4094 8-bit shift register to save Arduino pins
//#define HAS_HP_LD220 // Hewlett-Packard Point-Of-Sale sign
#define ENABLE_AIKO_DEVICE_POTENTIOMETER
#define HAS_SENSORS
//#define HAS_SPEAKER
#endif
#ifdef IS_STONE
#define DEFAULT_NODE_NAME "stone_1"
#define DEFAULT_NODE_NAME "mdb_1" // (Whittlesea)
#define DEFAULT_TRANSMIT_RATE 30 // seconds
//#define STONE_DEBUG // Enable capture and dump of all sampled values
#endif
#define DEFAULT_BAUD_RATE 38400
// Digital Input/Output pins
#define PIN_SERIAL_RX 0
#define PIN_SERIAL_TX 1
#ifdef IS_GATEWAY
// Analogue Input pins
#define PIN_LIGHT_SENSOR 4
// Digital Input/Output pins
#define PIN_ONE_WIRE 10 // OneWire or CANBus
#define PIN_RELAY_1 11
#endif
#ifdef IS_PEBBLE
// Analogue Input pins
#define PIN_LIGHT_SENSOR 0
// Digital Input/Output pins
#define PIN_LCD_STROBE 2 // CD4094 8-bit shift/latch
#define PIN_LCD_DATA 3 // CD4094 8-bit shift/latch
#define PIN_LCD_CLOCK 4 // CD4094 8-bit shift/latch
#define PIN_ONE_WIRE 5 // OneWire or CANBus
#define PIN_RELAY_1 6 // PWM output (timer 2)
#define PIN_RELAY_2 7
#define PIN_CONTROL_BUTTON 8 // Used for LCD menu and command
#define PIN_SPEAKER 9 // Speaker output
#endif
#ifdef IS_STONE
// Analogue Input pins
#define PIN_CURRENT_SENSOR_1 0 // Electrical monitoring
// Digital Input/Output pins
#define PIN_RELAY_1 3
#endif
#include <PString.h>
#if defined (__AVR_ATmega8__) || (__AVR_ATmega168__)
#define BUFFER_SIZE 40
#else
#define BUFFER_SIZE 200
#endif
char globalBuffer[BUFFER_SIZE]; // Store dynamically constructed strings
PString globalString(globalBuffer, sizeof(globalBuffer));
#include <AikoCommands.h>
#include <AikoDevices.h>
#include <AikoEvents.h>
#include <AikoSExpression.h>
using namespace Aiko;
using namespace Command;
using namespace Device;
#include <AikoCommandsHack.h>
void setup() {
//analogReference(EXTERNAL);
Events.addHandler(serialHandler, 30); // Sufficient for 38,400 baud
Events.addHandler(blinkHandler, 500);
Events.addHandler(nodeHandler, 1000 * DEFAULT_TRANSMIT_RATE);
#ifdef ENABLE_AIKO_DEVICE_BUTTON
Events.addHandler(buttonHandler, 100);
#endif
#ifdef HAS_LCD
Events.addHandler(clockHandler, 1000);
Events.addHandler(lcdHandler, 1000);
#endif
#ifdef LCD_4094
Events.addHandler(pebbleLedHandler, 5000); //can't be faster than lcdHandler
#endif
#ifdef ENABLE_AIKO_DEVICE_POTENTIOMETER
Events.addHandler(potentiometerHandler, 100);
#endif
#ifdef HAS_SENSORS
Events.addHandler(lightSensorHandler, 1000 * DEFAULT_TRANSMIT_RATE);
Events.addHandler(temperatureSensorHandler, 1000 * DEFAULT_TRANSMIT_RATE);
#endif
#ifdef HAS_SERIAL_MIRROR
Events.addHandler(serialMirrorHandler, 30); // Sufficient for 38,400 baud
#endif
#ifdef HAS_TOUCHPANEL
Events.addHandler(touchPanelHandler, 50);
#endif
#ifdef IS_STONE
//Events.addHandler(currentSensorHandler, 1000 * DEFAULT_TRANSMIT_RATE);
Events.addHandler(currentClampHandler, 1);
Events.addHandler(powerOutputHandler, 1000 * DEFAULT_TRANSMIT_RATE);
#endif
//setup_mqtt();
}
void loop() {
Events.loop();
//loop_mqtt();
}
/* -------------------------------------------------------------------------- */
#ifdef HAS_SENSORS
int lightValue = 0;
void lightSensorHandler(void) {
lightValue = analogRead(PIN_LIGHT_SENSOR);
globalString.begin();
globalString = "(light_lux ";
globalString += lightValue;
globalString += " lux)";
sendMessage(globalString);
}
#endif
/* -------------------------------------------------------------------------- */
#ifdef HAS_SENSORS
#include <OneWire.h>
OneWire oneWire(PIN_ONE_WIRE); // Maxim DS18B20 temperature sensor
byte oneWireInitialized = false;
#define ONE_WIRE_COMMAND_READ_SCRATCHPAD 0xBE
#define ONE_WIRE_COMMAND_START_CONVERSION 0x44
#define ONE_WIRE_COMMAND_MATCH_ROM 0x55
#define ONE_WIRE_COMMAND_SKIP_ROM 0xCC
#define ONE_WIRE_DEVICE_18B20 0x28
#define ONE_WIRE_DEVICE_18S20 0x10
int temperature_whole = 0;
int temperature_fraction = 0;
/*
void processOneWireListDevices(void) {
byte address[8];
oneWire.reset_search();
while (oneWire.search(address)) {
if (OneWire::crc8(address, 7) == address[7]) {
if (address[0] == ONE_WIRE_DEVICE_18B20) {
// Display device details
}
}
}
}
*/
void temperatureSensorHandler(void) { // total time: 33 milliseconds
byte address[8];
byte data[12];
byte index;
if (! oneWire.search(address)) { // time: 14 milliseconds
// Serial.println("(error 'No more one-wire devices')");
oneWire.reset_search(); // time: <1 millisecond
return;
}
/*
Serial.print("OneWire device: ");
for (index = 0; index < 8; index ++) {
Serial.print(address[index], HEX);
Serial.print(" ");
}
Serial.println();
*/
if (OneWire::crc8(address, 7) != address[7]) {
// sendMessage("(error 'Address CRC is not valid')");
return;
}
if (address[0] != ONE_WIRE_DEVICE_18B20) {
// sendMessage("(error 'Device is not a DS18B20')");
return;
}
if (oneWireInitialized) {
byte present = oneWire.reset(); // time: 1 millisecond
oneWire.select(address); // time: 5 milliseconds
oneWire.write(ONE_WIRE_COMMAND_READ_SCRATCHPAD); // time: 1 millisecond
for (index = 0; index < 9; index++) { // time: 5 milliseconds
data[index] = oneWire.read();
}
/*
Serial.print("Scratchpad: ");
Serial.print(present, HEX);
Serial.print(" ");
for (index = 0; index < 9; index++) {
Serial.print(data[index], HEX);
Serial.print(" ");
}
Serial.println();
*/
if (OneWire::crc8(data, 8) != data[8]) {
// sendMessage("(error 'Data CRC is not valid')");
return;
}
int temperature = (data[1] << 8) + data[0];
int signBit = temperature & 0x8000;
if (signBit) temperature = (temperature ^ 0xffff) + 1; // 2's complement
int tc_100 = (6 * temperature) + temperature / 4; // multiply by 100 * 0.0625
temperature_whole = tc_100 / 100;
temperature_fraction = tc_100 % 100;
globalString.begin();
globalString = "(temperature ";
if (signBit) globalString += "-";
globalString += temperature_whole;
globalString += ".";
if (temperature_fraction < 10) globalString += "0";
globalString += temperature_fraction;
globalString += " C)";
sendMessage(globalString);
}
// Start temperature conversion with parasitic power
oneWire.reset(); // time: 1 millisecond
oneWire.select(address); // time: 5 milliseconds
oneWire.write(ONE_WIRE_COMMAND_START_CONVERSION, 1); // time: 1 millisecond
// Must wait at least 750 milliseconds for temperature conversion to complete
oneWireInitialized = true;
}
#endif
/* -------------------------------------------------------------------------- */
byte relayInitialized = false;
void relayInitialize(void) {
pinMode(PIN_RELAY_1, OUTPUT);
#ifdef PIN_RELAY_2
pinMode(PIN_RELAY_2, OUTPUT);
#endif
#ifdef HAS_SPEAKER
pinMode(PIN_SPEAKER_1, OUTPUT);
#endif
relayInitialized = true;
}
boolean relay_state = false;
void relayCommand(void) {
relayHandler(PIN_RELAY_1);
}
#ifdef PIN_RELAY_2
void relay2Command(void) {
relayHandler(PIN_RELAY_2);
}
#endif
void relayHandler(
int pinRelay) {
if (relayInitialized == false) relayInitialize();
if (parameter.isEqualTo("on")) {
relay_state = true;
digitalWrite(pinRelay, HIGH);
globalString.begin();
globalString = "(relay on)";
sendMessage(globalString);
#ifdef HAS_SPEAKER
playTune();
#endif
}
else if (parameter.isEqualTo("off")) {
relay_state = false;
digitalWrite(pinRelay, LOW);
globalString = "(relay off)";
sendMessage(globalString);
}
else {
// sendMessage("(error parameterInvalid)");
}
}
#ifdef HAS_SPEAKER
int length = 5; // the number of notes
char notes[] = "bCacd "; // a space represents a rest
int beats[] = { 1, 1, 1, 1, 2 };
int tempo = 300;
void playTune() {
for (int i = 0; i < length; i++) {
if (notes[i] == ' ') {
delay(beats[i] * tempo); // rest
}
else {
playNote(notes[i], beats[i] * tempo);
}
delay(tempo / 2); // pause between notes
}
}
void playNote(
char note,
int duration) {
char names[] = { 'c', 'd', 'e', 'f', 'g', 'a', 'b', 'C' };
int tones[] = { 1915, 1700, 1519, 1432, 1275, 1136, 1014, 956 };
// play the tone corresponding to the note name
for (int i = 0; i < 8; i++) {
if (names[i] == note) {
playTone(tones[i], duration);
}
}
}
void playTone(int tone, int duration) {
for (long i = 0; i < duration * 1000L; i += tone * 2) {
digitalWrite(PIN_SPEAKER, HIGH);
delayMicroseconds(tone);
digitalWrite(PIN_SPEAKER, LOW);
delayMicroseconds(tone);
}
}
#endif
/* -------------------------------------------------------------------------- */
/* LCD KS0066 4-bit data interface, 3 Arduino pins and MC14094 8-bit register
* http://www.datasheetsite.com/datasheet/KS0066
*
* MC14094 input: Arduino digital pin 2=Clock, pin 4=Data, pin 7=Strobe
* MC14094 output: Q8=DB4, Q7=DB5, Q6=DB6, Q5=DB7, Q4=E, Q3=RW, Q2=RS, Q1=None
* http://www.ee.mut.ac.th/datasheet/MC14094.pdf
*
* +--------------------------------------------+
* | Arduino (ATMega 168 or 328) |
* | D02 D03 D04 |
* +----+-------------+-------------+-----------+
* |4 |5 |6
* |1 |2 |3
* +----+-------------+-------------+-----------+
* | Strobe Data Clock |
* | MC14094 8-bit shift/latch register |
* | Q8 Q7 Q6 Q5 Q4 Q3 Q2 Q1 |
* +----+----+----+----+----+----+----+----+----+
* |11 |12 |13 |14 |7 |6 |5 |4
* |11 |12 |13 |14 |6 |5 |4
* +----+----+----+----+----+----+----+---------+
* | DB4 DB5 DB6 DB7 E RW RS |
* | LCD KS0066 |
* +--------------------------------------------+
*/
byte lcdInitialized = false;
void resetLcdCommand(void) {
lcdInitialized = false;
//sendMessage("resetLcdCommand()");
}
#ifdef LCD_4094
int pebbleLedStatus = true;
// LCD pin bit-patterns, output from MC14094 -> LCD KS0066 input
#define LCD_ENABLE_HIGH 0x10 // MC14094 Q4 -> LCD E
#define LCD_ENABLE_LOW 0xEF // Enable (high) / Disable (low)
#define LCD_RW_HIGH 0x20 // MC14094 Q3 -> LCD RW
#define LCD_RW_LOW 0xDF // Read (high) / Write (low)
#define LCD_RS_HIGH 0x40 // MC14094 Q2 -> LCD RS
#define LCD_RS_LOW 0xBF // Data (high) / Instruction (low) Select
// LCD Commands
#define LCD_COMMAND_CLEAR 0x01 // Clear display
#define LCD_COMMAND_HOME 0x02 // Set DD RAM address counter to (0, 0)
#define LCD_COMMAND_ENTRY_SET 0x06 // Entry mode set
#define LCD_COMMAND_DISPLAY_SET 0x0C // Display on/off control
#define LCD_COMMAND_FUNCTION_SET 0x28 // Function set
#define LCD_COMMAND_SET_DDRAM_ADDRESS 0x80 // Set DD RAM address counter (row, column)
#define LCD_SECOND_ROW 0x40 // Second row literal
byte lcdSetup[] = { // LCD command, delay time in milliseconds
LCD_COMMAND_HOME, 50, // wait for LCD controller to be initialized
LCD_COMMAND_HOME, 50, // ditto
LCD_COMMAND_FUNCTION_SET, 1, // 4-bit interface, 2 display lines, 5x8 font
LCD_COMMAND_DISPLAY_SET, 1, // turn display on, cursor off, blinking off
LCD_COMMAND_CLEAR, 2, // clear display
LCD_COMMAND_ENTRY_SET, 1 // increment mode, display shift off
};
void lcdInitialize(void) {
pinMode(PIN_LCD_CLOCK, OUTPUT);
pinMode(PIN_LCD_DATA, OUTPUT);
pinMode(PIN_LCD_STROBE, OUTPUT);
byte length = sizeof(lcdSetup) / sizeof(*lcdSetup);
byte index = 0;
while (index < length) {
lcdWrite(lcdSetup[index ++], false);
delay(lcdSetup[index ++]);
}
lcdInitialized = true;
}
void lcdWrite(
byte value,
byte dataFlag) {
digitalWrite(PIN_LCD_STROBE, LOW);
byte output = value >> 4; // Most Significant Nibble
if (dataFlag) output = (output | LCD_RS_HIGH) & LCD_RW_LOW; // Command or Data ?
for (byte loop1 = 0; loop1 < 2; loop1 ++) { // First MSN, then LSN
for (byte loop2 = 0; loop2 < 3; loop2 ++) { // LCD ENABLE LOW -> HIGH -> LOW
output = (loop2 == 1) ? (output | LCD_ENABLE_HIGH) : (output & LCD_ENABLE_LOW);
if (pebbleLedStatus) {
output = output | 0x80;
}
else {
output = output & 0x7F;
}
if (pebbleLedStatus) {
output = output | 0x80;
}
else {
output = output & 0x7F;
}
shiftOut(PIN_LCD_DATA, PIN_LCD_CLOCK, LSBFIRST, output);
digitalWrite(PIN_LCD_STROBE, HIGH);
delayMicroseconds(10);
digitalWrite(PIN_LCD_STROBE,LOW);
}
delay(1);
output = value & 0x0F; // Least Significant Nibble
if (dataFlag) output = (output | LCD_RS_HIGH) & LCD_RW_LOW; // Command or Data ?
}
}
void lcdClear(void) {
lcdWrite(LCD_COMMAND_CLEAR, false);
delay(2);
}
void lcdPosition(
byte row, // Must be either 0 (first row) or 1 (second row)
byte column) { // Must be between 0 and 15
if (row == 1) row = LCD_SECOND_ROW;
lcdWrite(LCD_COMMAND_SET_DDRAM_ADDRESS | row | column, false);
delayMicroseconds(40);
}
void lcdWriteString(
char message[]) {
while (*message) lcdWrite((*message ++), true);
}
void pebbleLedHandler(void) {
pebbleLedStatus = ! pebbleLedStatus;
}
#else
#include <LiquidCrystal.h>
LiquidCrystal lcd(4, 5, 6, 7, 8, 9);
void lcdInitialize(void) {
lcdInitialized = true;
pinMode(11, OUTPUT);
digitalWrite(11, HIGH);
lcd.begin(16, 2);
lcd.noCursor();
}
void lcdClear() {
lcd.clear();
}
void lcdPosition(
byte row, // Must be either 0 (first row) or 1 (second row)
byte column) { // Must be between 0 and 15
lcd.setCursor(column, row);
}
void lcdWrite(
byte value,
byte dataFlag) {
lcd.print(value);
}
void lcdWriteString(
char message[]) {
lcd.print(message);
}
#endif
// checks out how many digits there are in a number
int estimateDigits(int nr) {
int dec = 10;
int temp = 1;
int div = nr/dec;
while (div > 0) {
dec *= 10;
div = nr/dec;
temp++;
}
return temp;
}
// Raise number to power
int pow(int base, int expo) {
int temp = 1;
for (int c = 1; c <= expo; c++) {
temp *= base;
}
return temp;
}
// this function help us to write numbers
// with more than one digit
void lcdWriteNumber(int nr, int digits) {
for (int i = digits-1; i >= 0; i--) {
int dec = pow(10,i);
int div = nr/dec;
lcdWrite(div+48, true);
if (div > 0) {
nr -= div*dec;
}
}
}
void lcdWriteNumber(int nr) {
int value = nr;
if (value < 0) {
lcdWrite('-', true);
value = - nr;
}
int digits = estimateDigits(value);
lcdWriteNumber(value, digits);
}
void lcdHandler(void) {
if (lcdInitialized == false) {
lcdInitialize();
lcdClear();
lcdWriteString("Aiko");
}
lcdPosition(0, 8);
if (hour < 10) lcdWriteString("0");
lcdWriteNumber((int) hour);
lcdWriteString(":");
if (minute < 10) lcdWriteString("0");
lcdWriteNumber((int) minute);
lcdWriteString(":");
if (second < 10) lcdWriteString("0");
lcdWriteNumber((int) second);
#ifdef HAS_SENSORS
lcdPosition(1, 0);
lcdWriteString("Lux ");
lcdWriteNumber(lightValue);
lcdWriteString(" ");
lcdPosition(1, 9);
lcdWriteNumber(temperature_whole);
lcdWriteString(".");
if (temperature_fraction < 10) lcdWriteString("0");
lcdWriteNumber(temperature_fraction);
lcdWriteString(" C ");
#endif
lcdPosition(0, 39);
if (relay_state) {
lcdWriteString("A");
}
else {
lcdWriteString(" ");
}
#ifdef ENABLE_AIKO_DEVICE_BUTTON
lcdPosition(0,20);
lcdWriteString("But ");
lcdWriteNumber(buttonValue);
lcdWriteString(" ");
// FIXME: This doesn't work lcdWriteString wants a char* and the pstring is a const char *
// lcdWriteString(buttonState);
#endif
#ifdef ENABLE_AIKO_DEVICE_POTENTIOMETER
lcdPosition(0,29);
lcdWriteString("Pot ");
lcdWriteNumber(potentiometerValue);
lcdWriteString(" ");
#endif
}
/* -------------------------------------------------------------------------- */
void alertCommand(void) {
char* parameterString = parameter.head();
}
void displayCommand(void) {
char* parameterString = parameter.head();
}
/* -------------------------------------------------------------------------- */
int baudRate = DEFAULT_BAUD_RATE;
void baudRateCommand(void) {
char* parameterString = parameter.head();
}
/* -------------------------------------------------------------------------- */
int transmitRate = DEFAULT_TRANSMIT_RATE; // seconds
void transmitRateCommand(void) {
char* parameterString = parameter.head();
}
/* -------------------------------------------------------------------------- */
/*
* Arduino serial buffer is 128 characters.
* At 115,200 baud (11,520 cps) the buffer is filled 90 times per second.
* Need to run this handler every 10 milliseconds.
*
* At 38,400 baud (3,840 cps) the buffer is filled 30 times per second.
* Need to run this handler every 30 milliseconds.
*/
SExpressionArray commandArray;
byte serialHandlerInitialized = false;
void serialHandlerInitialize(void) {
Serial.begin(DEFAULT_BAUD_RATE);
serialHandlerInitialized = true;
}
void serialHandler(void) {
static char buffer[32];
static byte length = 0;
static long timeOut = 0;
if (serialHandlerInitialized == false) serialHandlerInitialize();
unsigned long timeNow = millis();
int count = Serial.available();
if (count == 0) {
if (length > 0) {
if (timeNow > timeOut) {
// sendMessage("(error timeout)");
length = 0;
}
}
}
else {
/* globalString.begin();
globalString = "(info readCount ";
globalString += count;
globalString += ")";
sendMessage(globalString);
*/
for (byte index = 0; index < count; index ++) {
char ch = Serial.read();
if (length >= (sizeof(buffer) / sizeof(*buffer))) {
// sendMessage("(error bufferOverflow)");
length = 0;
}
else if (ch == '\n' || ch == ';') {
buffer[length] = '\0'; // TODO: Check this working correctly, seems to be some problems when command is longer than buffer length ?!?
char* result = commandArray.parse(buffer); // TODO: Error handling when result == null
/*
for (int index = 0; index < commandArray.length(); index ++) { // TODO: Check failure cases
Serial.print(index);
Serial.print(": ");
Serial.println(commandArray[index].head());
}
*/
int commandIndex = 0;
while (commandIndex < commandCount) {
if (commandArray[0].isEqualTo(commands[commandIndex])) {
if (parameterCount[commandIndex] != (commandArray.length() - 1)) {
// sendMessage("(error parameterCount)");
}
else { // execute command
if (parameterCount[commandIndex] > 0) parameter = commandArray[1];
(commandHandlers[commandIndex])();
}
break;
}
commandIndex ++;
}
// if (commandIndex >= commandCount) sendMessage("(error unknownCommand)");
length = 0;
}
else {
buffer[length ++] = ch;
}
}
timeOut = timeNow + 5000;
}
}
/* -------------------------------------------------------------------------- */
#ifdef HAS_SERIAL_MIRROR
#include <SoftwareSerial.h>
#define SERIAL_MIRROR_RX_PIN 2
#define SERIAL_MIRROR_TX_PIN 3
byte serialMirrorInitialized = false;
SoftwareSerial serialMirror(SERIAL_MIRROR_RX_PIN, SERIAL_MIRROR_TX_PIN);
#define SERIAL_MIRROR_BUFFER_SIZE 128
void serialMirrorInitialize(void) {
serialMirror.begin(DEFAULT_BAUD_RATE);
serialMirrorInitialized = true;
}
void serialMirrorHandler(void) {
static char serialMirrorBuffer[SERIAL_MIRROR_BUFFER_SIZE];
static byte serialMirrorLength = 0;
static long serialMirrorTimeOut = 0;
if (serialMirrorInitialized == false) serialMirrorInitialize();
unsigned long timeNow = millis();
int count = serialMirror.available();
if (count == 0) {
if (serialMirrorLength > 0) {
if (timeNow > serialMirrorTimeOut) {
sendMessage("(error serialMirrorTimeout)");
serialMirrorLength = 0;
}
}
}
else {
/* globalString.begin();
globalString = "(info readCount ";
globalString += count;
globalString += ")";
sendMessage(globalString);
*/
for (byte index = 0; index < count; index ++) {
char ch = serialMirror.read();
if (ch == '\n') continue;
if (serialMirrorLength >= (sizeof(serialMirrorBuffer) / sizeof(*serialMirrorBuffer))) {
sendMessage("(error serialMirrorBufferOverflow)");
serialMirrorLength = 0;
}
else if (ch == '\r') {
serialMirrorBuffer[serialMirrorLength] = '\0'; // TODO: Check this working correctly, seems to be some problems when command is longer than buffer length ?!?
Serial.println(serialMirrorBuffer);
serialMirrorLength = 0;
}
else {
serialMirrorBuffer[serialMirrorLength ++] = ch;
}
}
serialMirrorTimeOut = timeNow + 5000;
}
}
#endif
/* -------------------------------------------------------------------------- */
#ifdef HAS_TOUCHPANEL
// Taken from http://kousaku-kousaku.blogspot.com/2008/08/arduino_24.html
#ifdef MEGA
#define ANALOG_OFFSET 54
#else
#define ANALOG_OFFSET 14
#endif
#define xLowAnalog 0
#define xLow (xLowAnalog + ANALOG_OFFSET)
#define xHigh (2 + ANALOG_OFFSET)
#define yLowAnalog 3
#define yLow (yLowAnalog + ANALOG_OFFSET)
#define yHigh (1 + ANALOG_OFFSET)
void touchPanelHandler() {
pinMode(xLow,OUTPUT);
pinMode(xHigh,OUTPUT);
digitalWrite(xLow,LOW);
digitalWrite(xHigh,HIGH);
digitalWrite(yLow,LOW);
digitalWrite(yHigh,LOW);
pinMode(yLow,INPUT);
pinMode(yHigh,INPUT);
//delay(10);
// xLow has analog port -14 !!
int x = analogRead(yLowAnalog);
pinMode(yLow,OUTPUT);
pinMode(yHigh,OUTPUT);
digitalWrite(yLow,LOW);
digitalWrite(yHigh,HIGH);
digitalWrite(xLow,LOW);
digitalWrite(xHigh,LOW);
pinMode(xLow,INPUT);
pinMode(xHigh,INPUT);
//delay(10);
// yLow has analog port -14 !!
int y = analogRead(xLowAnalog);
lcdPosition(1, 0);
if (x > 99 && y > 99) {
lcdWriteNumber(x);
lcdWriteString(",");
lcdWriteNumber(y);
lcdWriteString(" ");
if (touch(x, y, 160, 410, 815, 920)) lcdWriteString("Menu ");
else if (touch(x, y, 575, 825, 815, 920)) lcdWriteString("View ");
else if (touch(x, y, 160, 410, 590, 700)) lcdWriteString("Off ");
else if (touch(x, y, 575, 825, 590, 700)) lcdWriteString("On ");
else if (touch(x, y, 160, 299, 340, 470)) lcdWriteString("0 % ");
else if (touch(x, y, 685, 825, 340, 470)) lcdWriteString("100 % ");
else if (touch(x, y, 160, 410, 110, 240)) lcdWriteString("Cancel ");
else if (touch(x, y, 575, 825, 110, 240)) lcdWriteString("Enter ");
else if (touch(x, y, 300, 685, 340, 470)) {
lcdWriteNumber(((x - 300l) * 100l) / (685l - 300l));
lcdWriteString(" % ");
}
else lcdWriteString(" ");
}
}
int touch(
int x, int y, int xMin, int xMax, int yMin, int yMax) {
return(x >= xMin && x <= xMax && y >= yMin && y <= yMax);
}
#endif
/* -------------------------------------------------------------------------- */
#ifdef IS_STONE_DEPRECATED
byte currentSensorInitialized = false;
#define CURRENT_SIZE 10
#ifdef STONE_DEBUG
#define SAMPLE_SIZE 100
#else
#define SAMPLE_SIZE 5000
#endif
float current_average[CURRENT_SIZE];
int current_index = 0;
void currentSensorInitialize(void) {
//analogReference(INTERNAL);
currentSensorInitialized = true;
for (int index = 0; index < CURRENT_SIZE; index ++) {
current_average[index] = 0.0;
}