/* # Copyright (c) 2019 Frogmore42 Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the "Software"), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions: The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ #include #include #include #include #include #ifdef ESP8266 #define COMMAND_SCD30_CONTINUOUS_MEASUREMENT 0x0010 #define COMMAND_SCD30_MEASUREMENT_INTERVAL 0x4600 #define COMMAND_SCD30_GET_DATA_READY 0x0202 #define COMMAND_SCD30_READ_MEASUREMENT 0x0300 #define COMMAND_SCD30_CALIBRATION_TYPE 0x5306 #define COMMAND_SCD30_FORCED_RECALIBRATION_FACTOR 0x5204 #define COMMAND_SCD30_TEMPERATURE_OFFSET 0x5403 #define COMMAND_SCD30_ALTITUDE_COMPENSATION 0x5102 #define COMMAND_SCD30_SOFT_RESET 0xD304 #define COMMAND_SCD30_GET_FW_VERSION 0xD100 #define COMMAND_SCD30_STOP_MEASUREMENT 0x0104 #define SCD30_DATA_REGISTER_BYTES 2 #define SCD30_DATA_REGISTER_WITH_CRC 3 #define SCD30_MEAS_BYTES 18 #ifdef SCD30_DEBUG enum LoggingLevels {LOG_LEVEL_NONE, LOG_LEVEL_ERROR, LOG_LEVEL_INFO, LOG_LEVEL_DEBUG, LOG_LEVEL_DEBUG_MORE, LOG_LEVEL_ALL}; char scd30log_data[180]; #endif void FrogmoreScd30::begin(TwoWire *pWire, uint8_t i2cAddress) { this->i2cAddress = i2cAddress; if (pWire == NULL) { this->pWire = &Wire; } else { this->pWire = pWire; } co2NewDataLocation = -1; // indicates there is no data, so the 1st data point needs to fill up the median filter this->pWire->setClockStretchLimit(200000); this->ambientPressure = 0; } void FrogmoreScd30::begin(uint8_t i2cAddress) { begin(NULL, i2cAddress); } void FrogmoreScd30::begin(TwoWire *pWire) { begin(pWire, SCD30_ADDRESS); } void FrogmoreScd30::begin(void) { begin(NULL, SCD30_ADDRESS); } /*--------------------------------------------------------------------------- Function : opt_med5() In : pointer to array of 5 values Out : a uint16_t which is the middle value of the sorted array Job : optimized search of the median of 5 values Notice : found on sci.image.processing cannot go faster unless assumptions are made on the nature of the input signal. ---------------------------------------------------------------------------*/ #define PIX_SORT(a,b) { if ((a)>(b)) PIX_SWAP((a),(b)); } #define PIX_SWAP(a,b) { uint16_t temp=(a);(a)=(b);(b)=temp; } uint16_t opt_med5(uint16_t * p) { PIX_SORT(p[0], p[1]); PIX_SORT(p[3], p[4]); PIX_SORT(p[0], p[3]); PIX_SORT(p[1], p[4]); PIX_SORT(p[1], p[2]); PIX_SORT(p[2], p[3]); PIX_SORT(p[1], p[2]); return(p[2]); } // twi_status() attempts to read out any data left that is holding SDA low, so a new transaction can take place // something like (http://www.forward.com.au/pfod/ArduinoProgramming/I2C_ClearBus/index.html) int FrogmoreScd30::clearI2CBus(void) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "clearI2CBus"); AddLog(LOG_LEVEL_DEBUG_MORE); #endif return (twi_status()); } #ifdef SCD30_DEBUG void FrogmoreScd30::AddLog(uint8_t loglevel) { if (loglevel <= LOG_LEVEL_INFO) { Serial.printf("%s\r\n", scd30log_data); } } #endif uint8_t FrogmoreScd30::computeCRC8(uint8_t data[], uint8_t len) // Computes the CRC that the SCD30 uses { uint8_t crc = 0xFF; //Init with 0xFF for (uint8_t x = 0 ; x < len ; x++) { crc ^= data[x]; // XOR-in the next input byte for (uint8_t i = 0 ; i < 8 ; i++) { if ((crc & 0x80) != 0) crc = (uint8_t)((crc << 1) ^ 0x31); else crc <<= 1; } } return crc; //No output reflection } // Sends stream of bytes to device int FrogmoreScd30::sendBytes(void *pInput, uint8_t len) { uint8_t *pBytes = (uint8_t *) pInput; int result; uint8_t errorBytes = 0; // number of bytes that had an error in transmission #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30SendBytes: data: 0x %02X %02X %02X | 0x %02X %02X %02X | 0x %02X %02X %02X", pBytes[0], pBytes[1], pBytes[2], pBytes[3], pBytes[4], pBytes[5], pBytes[6], pBytes[7], pBytes[8]); AddLog(LOG_LEVEL_DEBUG_MORE); #endif pWire->beginTransmission(this->i2cAddress); errorBytes = len - (pWire->write(pBytes, len)); result = pWire->endTransmission(); if (errorBytes || result) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30SendBytes: errorBytes: %d | Wire.end: %d", errorBytes, result); AddLog(LOG_LEVEL_INFO); #endif } result <<= 8; // leave room for error bytes number result |= errorBytes; // low byte has number of bytes that were not written correctly return (result); } // Gets a number of bytes from device int FrogmoreScd30::getBytes(void *pOutput, uint8_t len) { uint8_t *pBytes = (uint8_t *) pOutput; uint8_t result; result = pWire->requestFrom(this->i2cAddress, len); if (len != result) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30GetBytes: wire request expected %d got: %d", len, result); AddLog(LOG_LEVEL_INFO); #endif return (ERROR_SCD30_NOT_ENOUGH_BYTES_ERROR); } if (pWire->available()) { for (int x = 0; x < len; x++) { pBytes[x] = pWire->read(); } #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30GetBytes: data: 0x %02X %02X %02X | 0x %02X %02X %02X | 0x %02X %02X %02X", pBytes[0], pBytes[1], pBytes[2], pBytes[3], pBytes[4], pBytes[5], pBytes[6], pBytes[7], pBytes[8]); AddLog(LOG_LEVEL_DEBUG_MORE); #endif return (ERROR_SCD30_NO_ERROR); } return (ERROR_SCD30_UNKNOWN_ERROR); } //Sends just a command, no arguments, no CRC int FrogmoreScd30::sendCommand(uint16_t command) { uint8_t data[2]; data[0] = command >> 8; data[1] = command & 0xFF; int error = sendBytes(data, sizeof(data)); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30SendCommand: Scd30SendBytes failed: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif } return (error); } //Sends a command along with arguments and CRC int FrogmoreScd30::sendCommandArguments(uint16_t command, uint16_t arguments) { uint8_t data[5]; data[0] = command >> 8; data[1] = command & 0xFF; data[2] = arguments >> 8; data[3] = arguments & 0xFF; data[4] = computeCRC8(&data[2], 2); //Calc CRC on the arguments only, not the command int error = sendBytes(data, sizeof(data)); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30SendCommandArguments: Scd30SendBytes failed: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif } return (error); } int FrogmoreScd30::get16BitRegCheckCRC(void* pInput, uint16_t *pData) { uint8_t *pBytes = (uint8_t *) pInput; uint8_t expectedCRC = computeCRC8(pBytes, SCD30_DATA_REGISTER_BYTES); if (expectedCRC != pBytes[SCD30_DATA_REGISTER_BYTES]) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30get16BitRegCheckCRC: expected: 0x%02X, but got: 0x%02X", expectedCRC, pBytes[SCD30_DATA_REGISTER_BYTES]); AddLog(LOG_LEVEL_INFO); snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30get16BitRegCheckCRC: data: 0x%02X, 0x%02X, 0x%02X", pBytes[0], pBytes[1], pBytes[2]); AddLog(LOG_LEVEL_INFO); #endif return (ERROR_SCD30_CRC_ERROR); } *pData = (uint16_t) pBytes[0] << 8 | pBytes[1]; // data from SCD30 is Big-Endian return (ERROR_SCD30_NO_ERROR); } // gets 32 bits, (2) 16-bit chunks, and validates the CRCs // int FrogmoreScd30::get32BitRegCheckCRC(void *pInput, float *pData) { uint16_t tempU16High; uint16_t tempU16Low; uint8_t *pBytes = (uint8_t *) pInput; uint32_t rawInt = 0; int error = get16BitRegCheckCRC(pBytes, &tempU16High); if (error) { return (error); } error = get16BitRegCheckCRC(pBytes + SCD30_DATA_REGISTER_WITH_CRC, &tempU16Low); if (error) { return (error); } // data from SCD is Big-Endian rawInt |= tempU16High; rawInt <<= 16; rawInt |= tempU16Low; *pData = * (float *) &rawInt; #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "get32BitRegCheckCRC: got: tempUs 0x%lX, %lX", tempU16High, tempU16Low); AddLog(LOG_LEVEL_DEBUG); #endif if (isnan(*pData) || isinf(*pData)) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "get32BitRegCheckCRC: not a floating point number: rawInt 0x%lX", rawInt); AddLog(LOG_LEVEL_INFO); #endif return (ERROR_SCD30_NOT_A_NUMBER_ERROR); } return (ERROR_SCD30_NO_ERROR); } //Gets two bytes (and check CRC) from SCD30 int FrogmoreScd30::readRegister(uint16_t registerAddress, uint16_t* pData) { int error = sendCommand(registerAddress); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadRegister: SendCommand error: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif return (error); } delay(1); // the SCD30 uses clock streching to give it time to prepare data, waiting here makes it work uint8_t data[SCD30_DATA_REGISTER_WITH_CRC]; error = getBytes(data, sizeof(data)); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadRegister: Scd30GetBytes error: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif return (error); } uint16 regValue; error = get16BitRegCheckCRC(data, ®Value); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadRegister: Scd30get16BitRegCheckCRC error: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif return (error); } *pData = regValue; return (ERROR_SCD30_NO_ERROR); } int FrogmoreScd30::softReset(void) { return (sendCommand(COMMAND_SCD30_SOFT_RESET)); } int FrogmoreScd30::getAltitudeCompensation(uint16_t *pHeight_meter) { return (readRegister(COMMAND_SCD30_ALTITUDE_COMPENSATION, pHeight_meter)); } int FrogmoreScd30::getAmbientPressure(uint16_t *pAirPressure_mbar) { *pAirPressure_mbar = ambientPressure; return (ERROR_SCD30_NO_ERROR); } int FrogmoreScd30::getCalibrationType(uint16_t *pIsAuto) { uint16_t value = 0; int error = readRegister(COMMAND_SCD30_CALIBRATION_TYPE, &value); if (!error) { *pIsAuto = value != 0; } return (error); } int FrogmoreScd30::getFirmwareVersion(uint8_t *pMajor, uint8_t *pMinor) { uint16_t value; int error = readRegister(COMMAND_SCD30_GET_FW_VERSION, &value); if (!error) { *pMajor = value >> 8; *pMinor = value & 0xFF; } return (error); } int FrogmoreScd30::getForcedRecalibrationFactor(uint16_t *pCo2_ppm) { return (readRegister(COMMAND_SCD30_FORCED_RECALIBRATION_FACTOR, pCo2_ppm)); } int FrogmoreScd30::getMeasurementInterval(uint16_t *pTime_sec) { return (readRegister(COMMAND_SCD30_MEASUREMENT_INTERVAL, pTime_sec)); } int FrogmoreScd30::getTemperatureOffset(float *pOffset_degC) { uint16_t value; int error = readRegister(COMMAND_SCD30_TEMPERATURE_OFFSET, &value); if (!error) { // result is in centi-degrees, need to convert to degrees *pOffset_degC = (float) value / 100.0; } return (error); } int FrogmoreScd30::getTemperatureOffset(uint16_t *pOffset_centiDegC) { uint16_t value; int error = readRegister(COMMAND_SCD30_TEMPERATURE_OFFSET, &value); if (!error) { // result is in centi-degrees, need to convert to degrees *pOffset_centiDegC = value; } return (error); } int FrogmoreScd30::setAltitudeCompensation(uint16_t height_meter) { return (sendCommandArguments(COMMAND_SCD30_ALTITUDE_COMPENSATION, height_meter)); } int FrogmoreScd30::setAmbientPressure(uint16_t airPressure_mbar) { ambientPressure = airPressure_mbar; return (beginMeasuring(ambientPressure)); } int FrogmoreScd30::setAutoSelfCalibration(void) { bool isAuto = true; return (setCalibrationType(isAuto)); } int FrogmoreScd30::setCalibrationType(bool isAuto) { bool value = !!isAuto; // using NOT operator twice makes sure value is 0 or 1 return (sendCommandArguments(COMMAND_SCD30_CALIBRATION_TYPE, value)); } int FrogmoreScd30::setForcedRecalibrationFactor(uint16_t co2_ppm) { return (sendCommandArguments(COMMAND_SCD30_FORCED_RECALIBRATION_FACTOR, co2_ppm)); } int FrogmoreScd30::setManualCalibration(void) { bool isAuto = false; return (setCalibrationType(isAuto)); } int FrogmoreScd30::setMeasurementInterval(uint16_t time_sec) { if (time_sec < 2) time_sec = 2; if (time_sec > 1800) time_sec = 1800; return (sendCommandArguments(COMMAND_SCD30_MEASUREMENT_INTERVAL, time_sec)); } int FrogmoreScd30::setTemperatureOffset(float offset_degC) { uint16_t offset_centiDegC; if (offset_degC >= 0) { offset_centiDegC = (uint16_t) offset_degC * 100; return (sendCommandArguments(COMMAND_SCD30_TEMPERATURE_OFFSET, offset_centiDegC)); } else { return (ERROR_SCD30_INVALID_VALUE); } } int FrogmoreScd30::setTemperatureOffset(uint16_t offset_centiDegC) { return (sendCommandArguments(COMMAND_SCD30_TEMPERATURE_OFFSET, offset_centiDegC)); } int FrogmoreScd30::beginMeasuring(void) { return (beginMeasuring(ambientPressure)); } int FrogmoreScd30::beginMeasuring(uint16_t airPressure_mbar) { ambientPressure = airPressure_mbar; return(sendCommandArguments(COMMAND_SCD30_CONTINUOUS_MEASUREMENT, ambientPressure)); } int FrogmoreScd30::isDataAvailable(bool *pIsAvailable) { uint16_t isDataAvailable = false; int error = readRegister(COMMAND_SCD30_GET_DATA_READY, &isDataAvailable); if (!error) { *pIsAvailable = isDataAvailable != 0; } return (error); } int FrogmoreScd30::readMeasurement( uint16 *pCO2_ppm, uint16 *pCO2EAvg_ppm, float *pTemperature, float *pHumidity ) { bool isAvailable = false; int error = 0; float tempCO2; float tempHumidity; float tempTemperature; error = isDataAvailable(&isAvailable); if (error) { return (error); } if (!isAvailable) { return (ERROR_SCD30_NO_DATA); } #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: have data"); AddLog(LOG_LEVEL_DEBUG_MORE); #endif error = sendCommand(COMMAND_SCD30_READ_MEASUREMENT); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: send command failed: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif return (error); } delay(1); // the SCD30 uses clock streching to give it time to prepare data, waiting here makes it work uint8_t bytes[SCD30_MEAS_BYTES]; // there are (6) 16-bit values, each with a CRC in the measurement data // the chip does not seem to like sending this data, except all at once error = getBytes(bytes, SCD30_MEAS_BYTES); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: Scd30GetBytes command failed: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif return (error); } #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: Scd30GetBytes data: 0x %02X %02X %02X | 0x %02X %02X %02X | 0x %02X %02X %02X", bytes[0], bytes[1], bytes[2], bytes[3], bytes[4], bytes[5], bytes[6], bytes[7], bytes[8]); AddLog(LOG_LEVEL_DEBUG_MORE); snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: Scd30GetBytes data: 0x %02X %02X %02X | 0x %02X %02X %02X | 0x %02X %02X %02X", bytes[9], bytes[10], bytes[11], bytes[12], bytes[13], bytes[14], bytes[15], bytes[16], bytes[17]); AddLog(LOG_LEVEL_DEBUG_MORE); #endif error = get32BitRegCheckCRC(&bytes[0], &tempCO2); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: Scd30Get32BitsCheckCRC 1st command failed: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif return (error); } error = get32BitRegCheckCRC(&bytes[6], &tempTemperature); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: Scd30Get32BitsCheckCRC 2nd command failed: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif return (error); } error = get32BitRegCheckCRC(&bytes[12], &tempHumidity); if (error) { #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: Scd30Get32BitsCheckCRC 3rd command failed: 0x%lX", error); AddLog(LOG_LEVEL_INFO); #endif return (error); } if (tempCO2 == 0) { return (ERROR_SCD30_CO2_ZERO); } if (co2NewDataLocation < 0) { co2EAverage = tempCO2; for (int x = 0; x < SCD30_MEDIAN_FILTER_SIZE; x++) { co2History[x] = tempCO2; co2NewDataLocation = 1; } } else { co2History[co2NewDataLocation++] = tempCO2; if (co2NewDataLocation >= SCD30_MEDIAN_FILTER_SIZE) { co2NewDataLocation = 0; } } #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: co2History: %ld, %ld, %ld, %ld, %ld", co2History[0], co2History[1], co2History[2], co2History[3], co2History[4]); AddLog(LOG_LEVEL_DEBUG_MORE); #endif // copy array since the median filter function will re-arrange it uint16_t temp[SCD30_MEDIAN_FILTER_SIZE]; for (int x = 0; x < SCD30_MEDIAN_FILTER_SIZE; x++) { temp[x] = co2History[x]; } #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: temp: %ld, %ld, %ld, %ld, %ld", temp[0], temp[1], temp[2], temp[3], temp[4]); AddLog(LOG_LEVEL_DEBUG_MORE); #endif *pCO2_ppm = opt_med5(temp); #ifdef SCD30_DEBUG snprintf_P(scd30log_data, sizeof(scd30log_data), "Scd30ReadMeasurement: CO2_ppm: %ld", *pCO2_ppm); AddLog(LOG_LEVEL_DEBUG_MORE); #endif if (pCO2EAvg_ppm) { int16_t delta = (int16_t) *pCO2_ppm - (int16_t) co2EAverage; int16_t change = delta / 32; co2EAverage += change; #if 0 uint16_t remain = co2EAverage % 5; uint16_t dividend = co2EAverage / 5; uint16_t co2EAReported = dividend * 5; if (remain > 2) { co2EAReported += 5; } *pCO2EAvg_ppm = co2EAReported; #else *pCO2EAvg_ppm = co2EAverage; #endif } *pTemperature = tempTemperature; *pHumidity = tempHumidity; return (ERROR_SCD30_NO_ERROR); } int FrogmoreScd30::stopMeasuring(void) { return (sendCommand(COMMAND_SCD30_STOP_MEASUREMENT)); } #endif // ESP8266