lighthub/lighthub/flashstream.cpp

#include "flashstream.h"
#include "systemconfigdata.h"

#include <main.h>

#ifdef OTA
#include <WiFiOTA.h>
#endif


#if defined(ARDUINO_ARCH_AVR)
#include <EEPROM.h>
#endif

#if defined(ESP32) && !defined(FS_STORAGE)
#include <EEPROM.h>
#endif

#if defined(ARDUINO_ARCH_ESP8266) && !defined(FS_STORAGE)
#include <ESP_EEPROM.h>
#endif


#if defined(__SAM3X8E__)
#include <DueFlashStorage.h>
DueFlashStorage EEPROM;
 static char samBuffer[64];
 short samBufferPos = 0;
#endif

#ifdef NRF5
#include <NRFFlashStorage.h>   //STUB
NRFFlashStorage EEPROM;
#endif

#ifdef ARDUINO_ARCH_STM32
//NRFFlashStorage EEPROM;
#include <EEPROM.h>
#define DATA_LENGTH E2END
//FLASH_PAGE_SIZE = 0x400
#endif

#if defined(FS_STORAGE)


 int flashStream::open(String _filename, char mode) 
   {
                  char modestr[4];
                  int paramPos=-1;
                  //modestr[0]=mode; modestr[1]='b'; modestr[2]='+'; modestr[3]='\0';
                  modestr[0]=mode; modestr[1]='+'; modestr[2]='\0';
                  if (fs) fs.close();

                  if ((paramPos=_filename.indexOf('?'))>=0)
                     {
                        filename=_filename.substring(0,paramPos);
                     }
                  else filename=_filename;

                  if (fs =  SPIFFS.open(filename,modestr))
                     {
                        openedMode=mode;
                        streamSize = DEFAULT_FILESIZE_LIMIT;

                        if (filename.endsWith(".json")) {contentType=HTTP_TEXT_JSON;textMode=true;streamSize = MAX_JSON_CONF_SIZE; }
                           else if (filename.endsWith(".bin")) {contentType=HTTP_OCTET_STREAM;textMode=false;streamSize = SYSCONF_SIZE;  }
                                else if (filename.endsWith(".txt")) {contentType=HTTP_TEXT_PLAIN;textMode=true;}
                                     else if (filename.endsWith(".html")) {contentType=HTTP_TEXT_HTML;textMode=true;} 
                                          else if (filename.endsWith(".gif")) {contentType=HTTP_IMAGE_GIF;textMode=false;}
                                               else if (filename.endsWith(".jpg")) {contentType=HTTP_IMAGE_JPEG;textMode=false;}


                        debugSerial<<(F("Opened ("))<<modestr<<(F(")"))<<filename<<F(" Size:")<<streamSize<<endl;
                        return fs;
                     }
                  else 
                     {
                         openedMode='\0';  
                         debugSerial<<("Open error (")<<modestr<<(")")<<filename<<endl; 
                         return 0;
                     }   
   }; 
               
    int flashStream::available() 
                { 
                    if (!fs) return 0;
                    //if (textMode && (peek()==EOFchar)) {debugSerial<<"X";return 0;}  //Not working for esp8266
                    if (fs.position()>=streamSize) return 0;
                    return fs.available();  
                };
                
    int flashStream::read() {
       return fs.read();
       };

    int flashStream::peek() {
       return fs.peek();
       };

    unsigned int flashStream::seek  (unsigned int _pos)  
    {   
        debugSerial<<(F("Seek:"))<<_pos;
        if (_pos>streamSize) _pos=streamSize;
        unsigned int res = fs.seek(_pos,SeekSet);
        debugSerial<<(F(" Res:"))<<res<<endl;
        return res;
      };         
    void flashStream::close()  {fs.flush();fs.close(); debugSerial<<filename<<"  Closed\n";};
    void flashStream::flush()  {fs.flush(); debugSerial<<filename<<"  Flushed\n";};
    size_t flashStream::write(uint8_t ch) 
                {
                    return fs.write(ch);
                    };
   
 flashStream::~flashStream () {if (fs) fs.close();} ;


#else
    void flashStream::setSize(unsigned int _size) {streamSize=_size;}; 
    int  flashStream::open(short fileNum, char mode) 
                {

                  #if  defined(__SAM3X8E__) //|| defined (ARDUINO_ARCH_STM32)
                  if (samBufferPos) flush();
                  samBufferPos = 0;
                  #endif 

                 #if  defined (ARDUINO_ARCH_STM32)    
                 eeprom_buffer_fill();
                 #endif

                 switch (fileNum) {
                   case FN_CONFIG_JSON:     
                        pos = 0;
                        streamSize = MAX_JSON_CONF_SIZE;  
                        startPos = EEPROM_offsetJSON;
                        textMode = true;
                        #ifdef OTA
                        contentType = HTTP_TEXT_JSON;
                        #endif
                        openmode = mode;
                        return 1;    
                    
                  case FN_CONFIG_BIN:                    
                        pos = 0;
                        startPos = SYSCONF_OFFSET;
                        streamSize = SYSCONF_SIZE;
                        textMode =false;
                        #ifdef OTA
                        contentType = HTTP_OCTET_STREAM;
                        #endif
                        openmode = mode;
                        return 1;

                   default:
                   return 0;
            }          
};


     int flashStream::open(String _filename, char mode) 
                {
                  
                  int paramPos;
                  if ((paramPos=_filename.indexOf('?'))>=0)
                     {
                        _filename=_filename.substring(0,paramPos);
                     }
                    
                  if (_filename == "/config.json") return open (FN_CONFIG_JSON,mode);
                  else if (_filename == "/config.bin")  return open (FN_CONFIG_BIN,mode);
                  else return 0;    
                };

     unsigned int flashStream::seek(unsigned int _pos) 
        {   
         
         #if  defined(__SAM3X8E__) //|| defined (ARDUINO_ARCH_STM32)
         if (samBufferPos) flush();
         #endif

         #if defined (ARDUINO_ARCH_STM32)
         //eeprom_buffer_flush();
         #endif

         pos=min(_pos, streamSize);         
            //Serial.print("StartPos=");Serial.println(startPos);
            //Serial.print("Pos=");Serial.println(pos);
            //Serial.print("streamSize=");Serial.println(streamSize);
            return pos;
        };

     int flashStream::available() 
        { 
            if (textMode && peek()==EOFchar) return 0; 
            return (pos<streamSize);
         };

     int flashStream::read() 
         {
            int ch = peek(); 
            pos++; 
            return ch;
         };

     int flashStream::peek() 
         {    
            if (pos<streamSize) 
               return EEPROM.read(startPos+pos);
            else return -1;    
            };

    
    void flashStream::flush() {
        #if defined(ESP8266) || defined(ESP32)
        if (EEPROM.commitReset())
                infoSerial<<"Commited to FLASH"<<endl;
        else    errorSerial<<"Commit error. len:"<<EEPROM.length()<<endl;       
        #elif  defined(__SAM3X8E__) //|| defined (ARDUINO_ARCH_STM32)
        if (samBufferPos)
             EEPROM.write(startPos+pos-samBufferPos,(byte*)samBuffer,samBufferPos);    
        samBufferPos=0;     
        #elif defined (ARDUINO_ARCH_STM32)
        eeprom_buffer_flush();
        #endif
   };
   

    size_t flashStream::write(uint8_t ch) 
            {
               #if defined(__AVR__)
                  EEPROM.update(startPos+pos++,(char)ch);
                  return 1;
               #elif  defined(__SAM3X8E__)// || defined (ARDUINO_ARCH_STM32)
      
               if (samBufferPos==sizeof(samBuffer))
                        {            
                           samBufferPos = 0;
                           EEPROM.write(startPos+pos-sizeof(samBuffer),(byte*)samBuffer,sizeof(samBuffer));     
                                         
                        }
           
               samBuffer[samBufferPos++]=ch;
               pos++;
               return 1;
                //  return EEPROM.write(startPos+pos++,(char)ch);

               #elif defined (ARDUINO_ARCH_STM32)
               if (startPos+pos<=DATA_LENGTH) 
                   {
                   eeprom_buffered_write_byte(startPos+pos++,(char)ch);  
                   return 1;
                   }
               else 
                     {
                     errorSerial<<F("Flash sector exceeded")<<endl;    
                     return 0;
                     }
               #else 
                  EEPROM.write(startPos+pos++,(char)ch);
                  return 1;  
               #endif                
            };
  /*  
   #if defined(__SAM3X8E__)
    size_t flashStream::write(const uint8_t *buffer, size_t size) 
            {     
                  EEPROM.write(startPos+pos,(byte*)buffer,size);
                  pos+=size;
                return size;          
            };
     
   #endif    
*/
    #if defined(ESP8266) || defined(ESP32)      
     void flashStream::putEOF()  
            {
                if (textMode) write (EOFchar);
                EEPROM.commit();
            };
    #endif        

 void flashStream::close()  
    {  
      if (openmode == 'w') 
                              {
                              putEOF();
                              debugSerial<<F("EOF")<<endl;
                              }
      #if  defined(__SAM3X8E__)
      if (samBufferPos) flush();
      #endif
    }    


#endif