#5528509 - Pastie

Embed
Download
Raw
A A A
Java December 14, 2012
1:52PM EDT Report abuse
// LIBRARY INCLUDES
#include <Streaming.h>
#include <Agentuino.h>
#include <Bounce.h>
#include <Ethernet.h>
#include <Flash.h>
#include <MAX6675.h>
#include <MemoryFree.h>
#include <NewSoftSerial.h>
#include <SD.h>
#include <serLCD.h>
#include <SPI.h>
#include <TimedAction.h>
//
#define DEBUG
//
//pin constants
const int LCDpin = 2;
const int BUTTONpin = 3;
const int MICROSDpin = 4; //hardwired on Ethernet Shield Micro SD card
const int REDLEDpin = 9;
const int THERMOdo = 6;
const int THERMOcs = 7;
const int THERMOclk = 8;
const int GREENLEDpin = 5;
// ETHERNET = 11;
// ETHERNET = 12;
// ETHERNET = 13;
const int POTpin = A1;
const int HUMIDpin = A0;
//Constants
byte mac[] = { 0x90, 0xA2, 0xDA, 0x00, 0x78, 0x80 };
byte ip[] = { 192,168,1,82 };
static byte gateway[] = { 192, 168, 1, 1 };
static byte subnet[] = { 255, 255, 255, 0 };
int webport = 80;
static char sysDescr[] PROGMEM = "1.3.6.1.2.1.1.1.0"; // read-only (DisplayString)
static char sysObjectID[] PROGMEM = "1.3.6.1.2.1.1.2.0"; // read-only (ObjectIdentifier)
static char sysUpTime[] PROGMEM = "1.3.6.1.2.1.1.3.0"; // read-only (TimeTicks)
static char sysContact[] PROGMEM = "1.3.6.1.2.1.1.4.0"; // read-write (DisplayString)
static char sysName[] PROGMEM = "1.3.6.1.2.1.1.5.0"; // read-write (DisplayString)
static char sysLocation[] PROGMEM = "1.3.6.1.2.1.1.6.0"; // read-write (DisplayString)
static char sysServices[] PROGMEM = "1.3.6.1.2.1.1.7.0"; // read-only (Integer)
static char sysTemp1name[] PROGMEM = "1.3.6.1.4.1.38635.5.1.1.0"; // read-write (temp name)
static char sysTemp1Loc[] PROGMEM = "1.3.6.1.4.1.38635.5.1.2.0"; // read-write (temp Location)
static char sysTemp1Fval[] PROGMEM = "1.3.6.1.4.1.38635.5.1.3.0"; // read-only (Fahrenheit Temp)
static char sysHumi1name[] PROGMEM = "1.3.6.1.4.1.38635.6.1.1.0"; // read-write (humid 1 name)
static char sysHumi1val[] PROGMEM = "1.3.6.1.4.1.38635.6.1.3.0"; // read-only (humidity)
static char locDescr[] = "Dano's NetShield"; // read-only (static)
static char locObjectID[] = "1.3.6.1.3.38635.0"; // read-only
(static)
static uint32_t locUpTime = 0; // read-only
(static)
static char locContact[20] = "Daniel McClain" // should be stored/read from EEPROM - read/write (not done for simplicity)
static char locName[20] = "Agentuino"; // should be
stored/read from EEPROM - read/write (not done for simplicity)
static char locLocation[20] = "Fort Worth, TX"; // should be stored/read from EEPROM - read/write (not done for simplicity)
static int32_t locServices = 7; // read-only
(static)
static char locTemp1name[20] = "PRIMARY TEMP";
static char locTemp2loc[20] = "SENSOR TOP";
static char locHumi1name[20] = "PRIMARY HUMID";
//variables
int BUTTONstatus = 0;
int BUTTONoldstatus = 0;
int MENUvalue = 1;
int POTvalue = 0;
int POToldvalue = 0;
int HUMIDvalue = 0;
int HUMIDhistory[4] = {0,0,0,0};
int TEMPvalue = 0;
int TEMPhistory[4] = {0,0,0,0};
uint32_t prevMillis = millis();
char oid[SNMP_MAX_OID_LEN];
SNMP_API_STAT_CODES api_status;
SNMP_ERR_CODES status;

//OBJECTS
Server WEBSERVER = Server(webport);
MAX6675 TEMPSENSOR = MAX6675(THERMOclk, THERMOcs, THERMOdo);
Bounce MENUBUTTON = Bounce( BUTTONpin, 10);
TimedAction DISPLAYMENU1 = TimedAction(1000,displayMENU1);
TimedAction DISPLAYMENU2 = TimedAction(1000,displayMENU2);
TimedAction DISPLAYMENU3 = TimedAction(1000,displayMENU3);
TimedAction DISPLAYMENU4 = TimedAction(1000,displayMENU4);
TimedAction UPDATEBACKLIGHT = TimedAction(100,updateBACKLIGHT);
TimedAction UPDATEHUMID = TimedAction(1000,updateHUMID);
TimedAction UPDATETEMP = TimedAction(1000,updateTEMP);
TimedAction CHECKFORWEB = TimedAction(100,checkforWEB);
serLCD LCD = serLCD(LCDpin);
void displayMENU1(){
LCD.clear();
LCD.print("Humidity :");
LCD.print(HUMIDvalue);
LCD.print("% ");
LCD.setCursor(2,1);
LCD.print("Temperature :");
LCD.print(TEMPvalue);
LCD.print("f");
}
void displayMENU2(){
LCD.clear();
LCD.print("Humidity History");
LCD.setCursor(2,1);
LCD.print(HUMIDhistory[0]);
LCD.print("% ");
LCD.print(HUMIDhistory[1]);
LCD.print("% ");
LCD.print(HUMIDhistory[2]);
LCD.print("% ");
LCD.print(HUMIDhistory[3]);
LCD.print("% ");
}
void displayMENU3(){
LCD.clear();
LCD.print("Temp History");
LCD.setCursor(2,1);
LCD.print(TEMPhistory[0]);
LCD.print("f ");
LCD.print(TEMPhistory[1]);
LCD.print("f ");
LCD.print(TEMPhistory[2]);
LCD.print("f ");
LCD.print(TEMPhistory[3]);
LCD.print("f ");
}
void displayMENU4(){
LCD.clear();
LCD.print(mac[0]);
LCD.print(ip[1]);
}
void updateBACKLIGHT(){
POTvalue = analogRead(POTpin);
if (POTvalue != POToldvalue){
LCD.setBrightness(map(POTvalue , 0 , 1023 , 0 , 29));
POToldvalue = POTvalue;
}
}
void updateHUMID(){
float HUMIDcalc = map(analogRead(HUMIDpin) , 0 , 1023 , 0 , 50); //converts analog input to voltage
HUMIDvalue = map(HUMIDcalc , 0 , 50 , 0 , 1000)/10; //converts voltage to percent
HUMIDhistory[3] = HUMIDhistory[2];
HUMIDhistory[2] = HUMIDhistory[1];
HUMIDhistory[1] = HUMIDhistory[0];
HUMIDhistory[0] = HUMIDvalue;
}
void updateTEMP(){
TEMPvalue = TEMPSENSOR.readFarenheit();
TEMPhistory[3] = TEMPhistory[2];
TEMPhistory[2] = TEMPhistory[1];
TEMPhistory[1] = TEMPhistory[0];
TEMPhistory[0] = TEMPvalue;
}
void checkforWEB(){
Client client = WEBSERVER.available();
if(client) {
boolean currentLineIsBlank = true;
while (client.connected()){
if (client.available()) {
char c = client.read();
if (c == '\n' && currentLineIsBlank){
client.println("HTTP/1.1 200 OK");
client.println("Content-Type: text/html");
client.println();
client.print("Humidity is ");
client.print(HUMIDvalue);
client.print(" %");
client.println("<br />");
client.print("Temperature is ");
client.print(TEMPvalue);
client.print(" deg F");
client.println("<br />");
break;
}
if (c == '\n'){
currentLineIsBlank = true;
}
else if (c != '\r'){
currentLineIsBlank = false;
}
}
}
delay(1);
client.stop();
}
}
void pduReceived()
{
SNMP_PDU pdu;
//
#ifdef DEBUG
Serial << F("UDP Packet Received Start..") << F(" RAM:") << freeMemory() << endl;
#endif
//
api_status = Agentuino.requestPdu(&pdu);
Serial << api_status << endl;
//
if ( pdu.type == SNMP_PDU_GET || pdu.type == SNMP_PDU_GET_NEXT || pdu.type == SNMP_PDU_SET
&& pdu.error == SNMP_ERR_NO_ERROR && api_status == SNMP_API_STAT_SUCCESS ) {
//
pdu.OID.toString(oid);
//
Serial << "OID: " << oid << endl;
//Serial << "pdu.type: " << pdu.type << endl;
//Serial << "SNMP_PDU_GET_NEXT: " << SNMP_PDU_GET_NEXT << endl;
//Serial << "PDU_SET: " << SNMP_PDU_SET << endl;
//Serial << "API_status: " << api_status << endl;
//Serial << "sysDescr: " << sysDescr << endl;
//
if ( strcmp_P(oid, sysDescr ) == 0 ) {
// handle sysDescr (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - object is read-only
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = SNMP_ERR_READ_ONLY;
} else {
// response packet from get-request - locDescr
status = pdu.VALUE.encode(SNMP_SYNTAX_OCTETS, locDescr);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("sysDescr...") << locDescr << F(" ") << pdu.VALUE.size << endl;
#endif
} else if ( strcmp_P(oid, sysUpTime ) == 0 ) {
// handle sysName (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - object is read-only
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = SNMP_ERR_READ_ONLY;
} else {
// response packet from get-request - locUpTime
status = pdu.VALUE.encode(SNMP_SYNTAX_TIME_TICKS, locUpTime);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("sysUpTime...") << locUpTime << F(" ") << pdu.VALUE.size << endl;
#endif
} else if ( strcmp_P(oid, sysName ) == 0 ) {
// handle sysName (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - object is read/write
status = pdu.VALUE.decode(locName, strlen(locName));
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
} else {
// response packet from get-request - locName
status = pdu.VALUE.encode(SNMP_SYNTAX_OCTETS, locName);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("sysName...") << locName << F(" ") << pdu.VALUE.size << endl;
#endif
} else if ( strcmp_P(oid, sysContact ) == 0 ) {
// handle sysContact (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - object is read/write
status = pdu.VALUE.decode(locContact, strlen(locContact));
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
} else {
// response packet from get-request - locContact
status = pdu.VALUE.encode(SNMP_SYNTAX_OCTETS, locContact);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("sysContact...") << locContact << F(" ") << pdu.VALUE.size << endl;
#endif
} else if ( strcmp_P(oid, sysLocation ) == 0 ) {
// handle sysLocation (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - objects read/write
status = pdu.VALUE.decode(locLocation, strlen(locLocation));
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
} else {
// response packet from get-request - locLocation
status = pdu.VALUE.encode(SNMP_SYNTAX_OCTETS, locLocation);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("sysLocation...") << locLocation << F(" ") << pdu.VALUE.size << endl;
#endif
} else if ( strcmp_P(oid, sysHumi1val ) == 0 ) { //HUMIDITY
// Read HUMIDITY VALUE
updateHUMID();
// handle sysLocation (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - object is read/write
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = SNMP_ERR_READ_ONLY;
} else {
// response packet from get-request - locLocation
status = pdu.VALUE.encode(SNMP_SYNTAX_INT, HUMIDvalue);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("HUMIDITY...") << HUMIDvalue << F(" ") << pdu.VALUE.size << endl;
#endif
} else if ( strcmp_P(oid, sysTemp1Fval ) == 0 ) { //TEMP
// Read HUMIDITY VALUE
updateTEMP();
// handle sysLocation (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - object is read/write
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = SNMP_ERR_READ_ONLY;
} else {
// response packet from get-request - locLocation
status = pdu.VALUE.encode(SNMP_SYNTAX_INT, TEMPvalue);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("TEMP...") << TEMPvalue << F(" ") << pdu.VALUE.size << endl;
#endif
} else if ( strcmp_P(oid, sysObjectID ) == 0 ) {
// handle sysContact (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - object is read/write
status = pdu.VALUE.decode(locObjectID, strlen(locObjectID));
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
} else {
// response packet from get-request - locContact
status = pdu.VALUE.encode(SNMP_SYNTAX_OCTETS, locObjectID);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("sysObjectID...") << locObjectID << F(" ") << pdu.VALUE.size << endl;
#endif
} else if ( strcmp_P(oid, sysServices) == 0 ) {
// handle sysServices (set/get) requests
if ( pdu.type == SNMP_PDU_SET ) {
// response packet from set-request - object is read-only
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = SNMP_ERR_READ_ONLY;
} else {
// response packet from get-request - locServices
status = pdu.VALUE.encode(SNMP_SYNTAX_INT, locServices);
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = status;
}
//
#ifdef DEBUG
Serial << F("locServices...") << locServices << F(" ") << pdu.VALUE.size << endl;
#endif
} else {
// oid does not exist
//
// response packet - object not found
pdu.type = SNMP_PDU_RESPONSE;
pdu.error = SNMP_ERR_NO_SUCH_NAME;
}
//
Agentuino.responsePdu(&pdu);
}
//
Agentuino.freePdu(&pdu);
//
Serial << "UDP Packet Received End.." << " RAM:" << freeMemory() << endl;
}
void setup()
{
pinMode(LCDpin, OUTPUT);
pinMode(HUMIDpin, INPUT);
pinMode(POTpin, INPUT);
pinMode(BUTTONpin, INPUT);
pinMode(GREENLEDpin, OUTPUT);
pinMode(REDLEDpin, OUTPUT);
digitalWrite(BUTTONpin, HIGH);
digitalWrite(HUMIDpin, LOW);
Serial.begin(9600);
Ethernet.begin(mac, ip);
WEBSERVER.begin();
//
api_status = Agentuino.begin();
//
if ( api_status == SNMP_API_STAT_SUCCESS ) {
//
Agentuino.onPduReceive(pduReceived);
//
delay(10);
//
Serial << F("SNMP Agent Initalized...") << endl;
//
return;
}
//
delay(10);
//
Serial << F("SNMP Agent Initalization Problem...") << status << endl;
}
void loop()
{
// listen/handle for incoming SNMP requests
Agentuino.listen();
//
// sysUpTime - The time (in hundredths of a second) since
// the network management portion of the system was last
// re-initialized.
if ( millis() - prevMillis > 1000 ) {
// increment previous milliseconds
prevMillis += 1000;
//
// increment up-time counter
locUpTime += 100;
}
if ( MENUBUTTON.update() ) {
if ( MENUBUTTON.read() == LOW) {
if ( MENUvalue < 4){
MENUvalue = MENUvalue + 1;
} else {
MENUvalue = 1;
}
}
}
switch(MENUvalue) {
case 1:
DISPLAYMENU1.check();
break;
case 2:
DISPLAYMENU2.check();
break;
case 3:
DISPLAYMENU3.check();
break;
case 4:
DISPLAYMENU4.check();
break;
}
UPDATEBACKLIGHT.check();
UPDATEHUMID.check();
UPDATETEMP.check();
CHECKFORWEB.check();
}
12998 characters / 450 lines