Add functions for compression

Author: siara-in

src/esp32.cpp

@@ -17,6 +17,8 @@
 #include <esp_spi_flash.h>
 #include <sys/stat.h>
 
+#include "shox96_0_2_0.h"
+
 #undef dbg_printf
 //#define dbg_printf(...) Serial.printf(__VA_ARGS__)
 #define dbg_printf(...) 0
@@ -620,8 +622,57 @@ int esp32_CurrentTime( sqlite3_vfs * vfs, double * result )
 	return SQLITE_OK;
 }
 
+static void shox96_0_2c(sqlite3_context *context, int argc, sqlite3_value **argv) {
+  int nIn, nOut;
+  long int nOut2;
+  const unsigned char *inBuf;
+  unsigned char *outBuf;
+  assert( argc==1 );
+  nIn = sqlite3_value_bytes(argv[0]);
+  inBuf = (unsigned char *) sqlite3_value_blob(argv[0]);
+  nOut = 13 + nIn + (nIn+999)/1000;
+  outBuf = (unsigned char *) malloc( nOut+4 );
+  outBuf[0] = nIn>>24 & 0xff;
+  outBuf[1] = nIn>>16 & 0xff;
+  outBuf[2] = nIn>>8 & 0xff;
+  outBuf[3] = nIn & 0xff;
+  //nOut2 = (long int)nOut;
+  nOut2 = shox96_0_2_0_compress((const char *) inBuf, nIn, (char *) &outBuf[4], NULL);
+  sqlite3_result_blob(context, outBuf, nOut2+4, free);
+}
+
+static void shox96_0_2d(sqlite3_context *context, int argc, sqlite3_value **argv) {
+  unsigned int nIn, nOut, rc;
+  const unsigned char *inBuf;
+  unsigned char *outBuf;
+  long int nOut2;
+  
+  assert( argc==1 );
+  nIn = sqlite3_value_bytes(argv[0]);
+  if( nIn<=4 ){
+    return;
+  }
+  inBuf = (unsigned char *) sqlite3_value_blob(argv[0]);
+  nOut = (inBuf[0]<<24) + (inBuf[1]<<16) + (inBuf[2]<<8) + inBuf[3];
+  outBuf = (unsigned char *) malloc( nOut );
+  //nOut2 = (long int)nOut;
+  nOut2 = shox96_0_2_0_decompress((const char *) &inBuf[4], nIn - 4, (char *) outBuf, NULL);
+  //if( rc!=Z_OK ){
+  //  free(outBuf);
+  //}else{
+    sqlite3_result_blob(context, outBuf, nOut2, free);
+  //}
+} 
+
+int registerShox96_0_2(sqlite3 *db, const char **pzErrMsg, const struct sqlite3_api_routines *pThunk) {
+  sqlite3_create_function(db, "shox96_0_2c", 1, SQLITE_UTF8, 0, shox96_0_2c, 0, 0);
+  sqlite3_create_function(db, "shox96_0_2d", 1, SQLITE_UTF8, 0, shox96_0_2d, 0, 0);
+  return SQLITE_OK;
+}
+
 int sqlite3_os_init(void){
   sqlite3_vfs_register(&esp32Vfs, 1);
+  sqlite3_auto_extension((void (*)())registerShox96_0_2);
   return SQLITE_OK;
 }