chartdbs.cpp

Go to the documentation of this file.

/**************************************************************************
 *   Copyright (C) 2010 by David S. Register                               *
 *   Copyright (C) 2010 by Mark A Sikes                                    *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, see <https://www.gnu.org/licenses/>. *
 **************************************************************************/
 
#include "gl_headers.h"
 
#include <wx/wxprec.h>
 
#ifndef WX_PRECOMP
#include <wx/wx.h>
#endif
 
#include <wx/arrimpl.cpp>
#include <wx/dir.h>
#include <wx/encconv.h>
#include <wx/progdlg.h>
#include <wx/regex.h>
#include <wx/tokenzr.h>
#include <wx/evtloop.h>
 
#include "model/gui_events.h"
 
#include "chartbase.h"
#include "chartdbs.h"
#include "flex_hash.h"
#include "LOD_reduce.h"
#include "mbtiles.h"
#include "navutil.h"
#include "pluginmanager.h"
#include "shapefile_basemap.h"
#include "chartdb_thread.h"
 
#ifndef UINT32
#define UINT32 unsigned int
#endif
 
#ifdef __ANDROID__
#include "androidUTIL.h"
#endif
 
ChartGroupArray *g_pGroupArray;
 
static int s_dbVersion;  //    Database version currently in use at runtime
                         //  Needed for ChartTableEntry::GetChartType() only
                         //  TODO This can go away at opencpn Version 1.3.8 and
                         //  above....
 
static ChartFamilyEnum GetChartFamily(int charttype) {
  ChartFamilyEnum cf;
 
  switch (charttype) {
    case CHART_TYPE_KAP:
      cf = CHART_FAMILY_RASTER;
      break;
    case CHART_TYPE_GEO:
      cf = CHART_FAMILY_RASTER;
      break;
    case CHART_TYPE_S57:
      cf = CHART_FAMILY_VECTOR;
      break;
    case CHART_TYPE_CM93:
      cf = CHART_FAMILY_VECTOR;
      break;
    case CHART_TYPE_CM93COMP:
      cf = CHART_FAMILY_VECTOR;
      break;
    case CHART_TYPE_DUMMY:
      cf = CHART_FAMILY_RASTER;
      break;
    case CHART_TYPE_UNKNOWN:
      cf = CHART_FAMILY_UNKNOWN;
      break;
    default:
      cf = CHART_FAMILY_UNKNOWN;
      break;
  }
  return cf;
}
 
// ChartTableHeader
 
void ChartTableHeader::Read(wxInputStream &is) {
  is.Read(this, sizeof(ChartTableHeader));
}
 
void ChartTableHeader::Write(wxOutputStream &os) {
  char vb[5];
  sprintf(vb, "V%03d", DB_VERSION_CURRENT);
 
  memcpy(dbVersion, vb, 4);
  os.Write(this, sizeof(ChartTableHeader));
}
 
bool ChartTableHeader::CheckValid() {
  char vb[5];
  sprintf(vb, "V%03d", DB_VERSION_CURRENT);
  if (strncmp(vb, dbVersion, sizeof(dbVersion))) {
    wxString msg;
    char vbo[5];
    memcpy(vbo, dbVersion, 4);
    vbo[4] = 0;
    msg.Append(wxString(vbo, wxConvUTF8));
    msg.Prepend("   Warning: found incorrect chart db version: ");
    wxLogMessage(msg);
 
    //          return false;       // no match....
 
    // Try previous version....
    sprintf(vb, "V%03d", DB_VERSION_PREVIOUS);
    if (strncmp(vb, dbVersion, sizeof(dbVersion)))
      return false;
    else {
      wxLogMessage(
          "   Scheduling db upgrade to current db version on "
          "Options->Charts page visit...");
      return true;
    }
 
  } else {
    wxString msg;
    char vbo[5];
    memcpy(vbo, dbVersion, 4);
    vbo[4] = 0;
    msg.Append(wxString(vbo, wxConvUTF8));
    msg.Prepend("Loading chart db version: ");
    wxLogMessage(msg);
  }
 
  return true;
}
 
// ChartTableEntry
 
void ChartTableEntry::SetScale(int scale) {
  Scale = scale;
  rounding = 0;
  // XXX find the right rounding
  if (Scale >= 1000) rounding = 5 * pow(10, log10(Scale) - 2);
}
 
ChartTableEntry::ChartTableEntry(ChartBase &theChart, wxString &utf8Path) {
  Clear();
 
  char *pt = (char *)malloc(strlen(utf8Path.mb_str(wxConvUTF8)) + 1);
  strcpy(pt, utf8Path.mb_str(wxConvUTF8));
  pFullPath = pt;
 
  SetScale(theChart.GetNativeScale());
 
  ChartType = theChart.GetChartType();
  ChartFamily = theChart.GetChartFamily();
 
  Skew = theChart.GetChartSkew();
  ProjectionType = theChart.GetChartProjectionType();
 
  wxDateTime ed = theChart.GetEditionDate();
  if (theChart.GetEditionDate().IsValid())
    edition_date = theChart.GetEditionDate().GetTicks();
 
  wxFileName fn(theChart.GetFullPath());
  if (fn.GetModificationTime().IsValid())
    file_date = fn.GetModificationTime().GetTicks();
 
  m_pfilename = new wxString;  // create and populate helper members
  *m_pfilename = fn.GetFullName();
  m_psFullPath = new wxString;
  *m_psFullPath = utf8Path;
  m_fullSystemPath = utf8Path;
  m_FullPath = std::string(pFullPath);
 
#ifdef __ANDROID__
  m_fullSystemPath = wxString(utf8Path.mb_str(wxConvUTF8));
#endif
 
  Extent ext;
  theChart.GetChartExtent(&ext);
  LatMax = ext.NLAT;
  LatMin = ext.SLAT;
  LonMin = ext.WLON;
  LonMax = ext.ELON;
 
  m_bbox.Set(LatMin, LonMin, LatMax, LonMax);
 
  // Fill in the PLY information
  //  LOD calculation
  int LOD_pixels = 1;
  double scale_max_zoom = Scale / 4;
 
  double display_ppm = 1 / .00025;  // nominal for most LCD displays
  double meters_per_pixel_max_scale = scale_max_zoom / display_ppm;
  double LOD_meters = meters_per_pixel_max_scale * LOD_pixels;
 
  //    double LOD_meters = 5;
 
  // If  COVR table has only one entry, us it for the primary Ply Table
  if (theChart.GetCOVREntries() == 1) {
    nPlyEntries = theChart.GetCOVRTablePoints(0);
 
    if (nPlyEntries > 5 && (LOD_meters > .01)) {
      std::vector<int> index_keep{0, nPlyEntries - 1, 1, nPlyEntries - 2};
 
      double *DPbuffer = (double *)malloc(2 * nPlyEntries * sizeof(double));
 
      double *pfed = DPbuffer;
      Plypoint *ppp = (Plypoint *)theChart.GetCOVRTableHead(0);
 
      for (int i = 0; i < nPlyEntries; i++) {
        *pfed++ = ppp->ltp;
        *pfed++ = ppp->lnp;
        ppp++;
      }
 
      DouglasPeucker(DPbuffer, 1, nPlyEntries - 2, LOD_meters / (1852 * 60),
                     &index_keep);
      //              printf("DB DP Reduction: %d/%d\n", index_keep.size(),
      //              nPlyEntries);
 
      // Mark the keepers by adding a simple constant to ltp
      for (unsigned int i = 0; i < index_keep.size(); i++) {
        DPbuffer[2 * index_keep[i]] += 2000.;
      }
 
      float *pf = (float *)malloc(2 * index_keep.size() * sizeof(float));
      float *pfe = pf;
 
      for (int i = 0; i < nPlyEntries; i++) {
        if (DPbuffer[2 * i] > 1000.) {
          *pfe++ = DPbuffer[2 * i] - 2000.;
          *pfe++ = DPbuffer[(2 * i) + 1];
        }
      }
 
      pPlyTable = pf;
      nPlyEntries = index_keep.size();
      free(DPbuffer);
    } else {
      float *pf = (float *)malloc(2 * nPlyEntries * sizeof(float));
      pPlyTable = pf;
      float *pfe = pf;
      Plypoint *ppp = (Plypoint *)theChart.GetCOVRTableHead(0);
 
      for (int i = 0; i < nPlyEntries; i++) {
        *pfe++ = ppp->ltp;
        *pfe++ = ppp->lnp;
        ppp++;
      }
    }
  }
  // Else create a rectangular primary Ply Table from the chart extents
  // and create AuxPly table from the COVR tables
  else {
    // Create new artificial Ply table from chart extents
    nPlyEntries = 4;
    float *pf1 = (float *)malloc(2 * 4 * sizeof(float));
    pPlyTable = pf1;
    float *pfe = pf1;
    Extent fext;
    theChart.GetChartExtent(&fext);
 
    *pfe++ = fext.NLAT;  // LatMax;
    *pfe++ = fext.WLON;  // LonMin;
 
    *pfe++ = fext.NLAT;  // LatMax;
    *pfe++ = fext.ELON;  // LonMax;
 
    *pfe++ = fext.SLAT;  // LatMin;
    *pfe++ = fext.ELON;  // LonMax;
 
    *pfe++ = fext.SLAT;  // LatMin;
    *pfe++ = fext.WLON;  // LonMin;
 
    // Fill in the structure for pAuxPlyTable
 
    nAuxPlyEntries = theChart.GetCOVREntries();
    wxASSERT(nAuxPlyEntries);
    float **pfp = (float **)malloc(nAuxPlyEntries * sizeof(float *));
    float **pft0 = pfp;
    int *pip = (int *)malloc(nAuxPlyEntries * sizeof(int));
 
    for (int j = 0; j < nAuxPlyEntries; j++) {
      int nPE = theChart.GetCOVRTablePoints(j);
 
      if (nPE > 5 && (LOD_meters > .01)) {
        std::vector<int> index_keep{0, nPE - 1, 1, nPE - 2};
 
        double *DPbuffer = (double *)malloc(2 * nPE * sizeof(double));
 
        double *pfed = DPbuffer;
        Plypoint *ppp = (Plypoint *)theChart.GetCOVRTableHead(j);
 
        for (int i = 0; i < nPE; i++) {
          *pfed++ = ppp->ltp;
          *pfed++ = ppp->lnp;
          ppp++;
        }
 
        DouglasPeucker(DPbuffer, 1, nPE - 2, LOD_meters / (1852 * 60),
                       &index_keep);
        //                 printf("DBa DP Reduction: %d/%d\n",
        //                 index_keep.size(), nPE);
 
        // Mark the keepers by adding a simple constant to ltp
        for (unsigned int i = 0; i < index_keep.size(); i++) {
          DPbuffer[2 * index_keep[i]] += 2000.;
        }
 
        float *pf = (float *)malloc(2 * index_keep.size() * sizeof(float));
        float *pfe1 = pf;
 
        for (int i = 0; i < nPE; i++) {
          if (DPbuffer[2 * i] > 1000.) {
            *pfe1++ = DPbuffer[2 * i] - 2000.;
            *pfe1++ = DPbuffer[(2 * i) + 1];
          }
        }
 
        pft0[j] = pf;
        pip[j] = index_keep.size();
        free(DPbuffer);
      } else {
        float *pf_entry =
            (float *)malloc(theChart.GetCOVRTablePoints(j) * 2 * sizeof(float));
        memcpy(pf_entry, theChart.GetCOVRTableHead(j),
               theChart.GetCOVRTablePoints(j) * 2 * sizeof(float));
        pft0[j] = pf_entry;
        pip[j] = theChart.GetCOVRTablePoints(j);
      }
    }
 
    pAuxPlyTable = pfp;
    pAuxCntTable = pip;
  }
 
  //  Get and populate the NoCovr tables
 
  nNoCovrPlyEntries = theChart.GetNoCOVREntries();
  if (nNoCovrPlyEntries == 0) return;
 
  float **pfpnc = (float **)malloc(nNoCovrPlyEntries * sizeof(float *));
  float **pft0nc = pfpnc;
  int *pipnc = (int *)malloc(nNoCovrPlyEntries * sizeof(int));
 
  for (int j = 0; j < nNoCovrPlyEntries; j++) {
    float *pf_entry =
        (float *)malloc(theChart.GetNoCOVRTablePoints(j) * 2 * sizeof(float));
    memcpy(pf_entry, theChart.GetNoCOVRTableHead(j),
           theChart.GetNoCOVRTablePoints(j) * 2 * sizeof(float));
    pft0nc[j] = pf_entry;
    pipnc[j] = theChart.GetNoCOVRTablePoints(j);
  }
 
  pNoCovrPlyTable = pfpnc;
  pNoCovrCntTable = pipnc;
}
 
 
ChartTableEntry::~ChartTableEntry() {
  // free(pFullPath);
  free(pPlyTable);
 
  for (int i = 0; i < nAuxPlyEntries; i++) free(pAuxPlyTable[i]);
  free(pAuxPlyTable);
  free(pAuxCntTable);
 
  if (nNoCovrPlyEntries) {
    for (int i = 0; i < nNoCovrPlyEntries; i++) free(pNoCovrPlyTable[i]);
    free(pNoCovrPlyTable);
    free(pNoCovrCntTable);
  }
 
  delete m_pfilename;
  delete m_psFullPath;
}
 
 
 
bool ChartTableEntry::IsEarlierThan(const ChartTableEntry &cte) const {
  wxDateTime mine(edition_date);
  wxDateTime theirs(cte.edition_date);
 
  if (!mine.IsValid() || !theirs.IsValid())
    return false;  // will have the effect of keeping all questionable charts
 
  return (mine.IsEarlierThan(theirs));
}
 
bool ChartTableEntry::IsEqualTo(const ChartTableEntry &cte) const {
  wxDateTime mine(edition_date);
  wxDateTime theirs(cte.edition_date);
 
  if (!mine.IsValid() || !theirs.IsValid())
    return true;  // will have the effect of keeping all questionable charts
 
  return (mine.IsEqualTo(theirs));
}
 
 
static int convertChartType(int charttype) {
  //    Hackeroo here....
  //    dB version 14 had different ChartType Enum, patch it here
  if (s_dbVersion == 14) {
    switch (charttype) {
      case 0:
        return CHART_TYPE_KAP;
      case 1:
        return CHART_TYPE_GEO;
      case 2:
        return CHART_TYPE_S57;
      case 3:
        return CHART_TYPE_CM93;
      case 4:
        return CHART_TYPE_CM93COMP;
      case 5:
        return CHART_TYPE_UNKNOWN;
      case 6:
        return CHART_TYPE_DONTCARE;
      case 7:
        return CHART_TYPE_DUMMY;
      default:
        return CHART_TYPE_UNKNOWN;
    }
  }
  return charttype;
}
 
static int convertChartFamily(int charttype, int chartfamily) {
  if (s_dbVersion < 18) {
    switch (charttype) {
      case CHART_TYPE_KAP:
      case CHART_TYPE_GEO:
        return CHART_FAMILY_RASTER;
 
      case CHART_TYPE_S57:
      case CHART_TYPE_CM93:
      case CHART_TYPE_CM93COMP:
        return CHART_FAMILY_VECTOR;
 
      default:
        return CHART_FAMILY_UNKNOWN;
    }
  }
  return chartfamily;
}
 
bool ChartTableEntry::Read(const ChartDatabase *pDb, wxInputStream &is) {
  char path[4096], *cp;
 
  Clear();
 
  //      Allow reading of current db format, and maybe others
  ChartDatabase *pD = (ChartDatabase *)pDb;
  int db_version = pD->GetVersion();
 
  if (db_version == 18) {
    // Read the path first
    for (cp = path; (*cp = (char)is.GetC()) != 0; cp++);
    pFullPath = (char *)malloc(cp - path + 1);
    strncpy(pFullPath, path, cp - path + 1);
    wxLogVerbose("  Chart %s", pFullPath);
 
    //  Create and populate the helper members
    m_pfilename = new wxString;
    wxString fullfilename(pFullPath, wxConvUTF8);
    wxFileName fn(fullfilename);
    *m_pfilename = fn.GetFullName();
    m_psFullPath = new wxString;
    *m_psFullPath = fullfilename;
    m_fullSystemPath = fullfilename;
    m_FullPath = std::string(pFullPath);
 
#ifdef __ANDROID__
    m_fullSystemPath = wxString(fullfilename.mb_str(wxConvUTF8));
#endif
    // Read the table entry
    ChartTableEntry_onDisk_18 cte;
    is.Read(&cte, sizeof(ChartTableEntry_onDisk_18));
 
    //    Transcribe the elements....
    EntryOffset = cte.EntryOffset;
    ChartType = cte.ChartType;
    ChartFamily = cte.ChartFamily;
    LatMax = cte.LatMax;
    LatMin = cte.LatMin;
    LonMax = cte.LonMax;
    LonMin = cte.LonMin;
 
    m_bbox.Set(LatMin, LonMin, LatMax, LonMax);
 
    Skew = cte.skew;
    ProjectionType = cte.ProjectionType;
 
    SetScale(cte.Scale);
    edition_date = cte.edition_date;
    file_date = cte.file_date;
 
    nPlyEntries = cte.nPlyEntries;
    nAuxPlyEntries = cte.nAuxPlyEntries;
 
    nNoCovrPlyEntries = cte.nNoCovrPlyEntries;
 
    bValid = cte.bValid;
 
    if (nPlyEntries) {
      int npeSize = nPlyEntries * 2 * sizeof(float);
      pPlyTable = (float *)malloc(npeSize);
      is.Read(pPlyTable, npeSize);
    }
 
    if (nAuxPlyEntries) {
      int napeSize = nAuxPlyEntries * sizeof(int);
      pAuxPlyTable = (float **)malloc(nAuxPlyEntries * sizeof(float *));
      pAuxCntTable = (int *)malloc(napeSize);
      is.Read(pAuxCntTable, napeSize);
 
      for (int nAuxPlyEntry = 0; nAuxPlyEntry < nAuxPlyEntries;
           nAuxPlyEntry++) {
        int nfSize = pAuxCntTable[nAuxPlyEntry] * 2 * sizeof(float);
        pAuxPlyTable[nAuxPlyEntry] = (float *)malloc(nfSize);
        is.Read(pAuxPlyTable[nAuxPlyEntry], nfSize);
      }
    }
 
    if (nNoCovrPlyEntries) {
      int napeSize = nNoCovrPlyEntries * sizeof(int);
      pNoCovrCntTable = (int *)malloc(napeSize);
      is.Read(pNoCovrCntTable, napeSize);
 
      pNoCovrPlyTable = (float **)malloc(nNoCovrPlyEntries * sizeof(float *));
      for (int i = 0; i < nNoCovrPlyEntries; i++) {
        int nfSize = pNoCovrCntTable[i] * 2 * sizeof(float);
        pNoCovrPlyTable[i] = (float *)malloc(nfSize);
        is.Read(pNoCovrPlyTable[i], nfSize);
      }
    }
  }
 
  else if (db_version == 17) {
    // Read the path first
    for (cp = path; (*cp = (char)is.GetC()) != 0; cp++);
    pFullPath = (char *)malloc(cp - path + 1);
    strncpy(pFullPath, path, cp - path + 1);
    wxLogVerbose("  Chart %s", pFullPath);
 
    //  Create and populate the helper members
    m_pfilename = new wxString;
    wxString fullfilename(pFullPath, wxConvUTF8);
    wxFileName fn(fullfilename);
    *m_pfilename = fn.GetFullName();
    m_psFullPath = new wxString;
    *m_psFullPath = fullfilename;
    m_FullPath = std::string(pFullPath);
 
    // Read the table entry
    ChartTableEntry_onDisk_17 cte;
    is.Read(&cte, sizeof(ChartTableEntry_onDisk_17));
 
    //    Transcribe the elements....
    EntryOffset = cte.EntryOffset;
    ChartType = cte.ChartType;
    LatMax = cte.LatMax;
    LatMin = cte.LatMin;
    LonMax = cte.LonMax;
    LonMin = cte.LonMin;
 
    m_bbox.Set(LatMin, LatMax, LonMin, LonMax);
 
    Skew = cte.skew;
    ProjectionType = cte.ProjectionType;
 
    SetScale(cte.Scale);
    edition_date = cte.edition_date;
    file_date = cte.file_date;
 
    nPlyEntries = cte.nPlyEntries;
    nAuxPlyEntries = cte.nAuxPlyEntries;
 
    nNoCovrPlyEntries = cte.nNoCovrPlyEntries;
 
    bValid = cte.bValid;
 
    if (nPlyEntries) {
      int npeSize = nPlyEntries * 2 * sizeof(float);
      pPlyTable = (float *)malloc(npeSize);
      is.Read(pPlyTable, npeSize);
    }
 
    if (nAuxPlyEntries) {
      int napeSize = nAuxPlyEntries * sizeof(int);
      pAuxPlyTable = (float **)malloc(nAuxPlyEntries * sizeof(float *));
      pAuxCntTable = (int *)malloc(napeSize);
      is.Read(pAuxCntTable, napeSize);
 
      for (int nAuxPlyEntry = 0; nAuxPlyEntry < nAuxPlyEntries;
           nAuxPlyEntry++) {
        int nfSize = pAuxCntTable[nAuxPlyEntry] * 2 * sizeof(float);
        pAuxPlyTable[nAuxPlyEntry] = (float *)malloc(nfSize);
        is.Read(pAuxPlyTable[nAuxPlyEntry], nfSize);
      }
    }
 
    if (nNoCovrPlyEntries) {
      int napeSize = nNoCovrPlyEntries * sizeof(int);
      pNoCovrCntTable = (int *)malloc(napeSize);
      is.Read(pNoCovrCntTable, napeSize);
 
      pNoCovrPlyTable = (float **)malloc(nNoCovrPlyEntries * sizeof(float *));
      for (int i = 0; i < nNoCovrPlyEntries; i++) {
        int nfSize = pNoCovrCntTable[i] * 2 * sizeof(float);
        pNoCovrPlyTable[i] = (float *)malloc(nfSize);
        is.Read(pNoCovrPlyTable[i], nfSize);
      }
    }
  }
 
  else if (db_version == 16) {
    // Read the path first
    for (cp = path; (*cp = (char)is.GetC()) != 0; cp++);
    // TODO: optimize prepended dir
    pFullPath = (char *)malloc(cp - path + 1);
    strncpy(pFullPath, path, cp - path + 1);
    wxLogVerbose("  Chart %s", pFullPath);
 
    //  Create and populate the helper members
    m_pfilename = new wxString;
    wxString fullfilename(pFullPath, wxConvUTF8);
    wxFileName fn(fullfilename);
    *m_pfilename = fn.GetFullName();
    m_psFullPath = new wxString;
    *m_psFullPath = fullfilename;
    m_FullPath = std::string(pFullPath);
 
    // Read the table entry
    ChartTableEntry_onDisk_16 cte;
    is.Read(&cte, sizeof(ChartTableEntry_onDisk_16));
 
    //    Transcribe the elements....
    EntryOffset = cte.EntryOffset;
    ChartType = cte.ChartType;
    LatMax = cte.LatMax;
    LatMin = cte.LatMin;
    LonMax = cte.LonMax;
    LonMin = cte.LonMin;
 
    m_bbox.Set(LatMin, LatMax, LonMin, LonMax);
 
    Skew = cte.skew;
    ProjectionType = cte.ProjectionType;
 
    SetScale(cte.Scale);
    edition_date = cte.edition_date;
    file_date = cte.file_date;
 
    nPlyEntries = cte.nPlyEntries;
    nAuxPlyEntries = cte.nAuxPlyEntries;
 
    bValid = cte.bValid;
 
    if (nPlyEntries) {
      int npeSize = nPlyEntries * 2 * sizeof(float);
      pPlyTable = (float *)malloc(npeSize);
      is.Read(pPlyTable, npeSize);
    }
 
    if (nAuxPlyEntries) {
      int napeSize = nAuxPlyEntries * sizeof(int);
      pAuxPlyTable = (float **)malloc(nAuxPlyEntries * sizeof(float *));
      pAuxCntTable = (int *)malloc(napeSize);
      is.Read(pAuxCntTable, napeSize);
 
      for (int nAuxPlyEntry = 0; nAuxPlyEntry < nAuxPlyEntries;
           nAuxPlyEntry++) {
        int nfSize = pAuxCntTable[nAuxPlyEntry] * 2 * sizeof(float);
        pAuxPlyTable[nAuxPlyEntry] = (float *)malloc(nfSize);
        is.Read(pAuxPlyTable[nAuxPlyEntry], nfSize);
      }
    }
  }
 
  else if (db_version == 15) {
    // Read the path first
    for (cp = path; (*cp = (char)is.GetC()) != 0; cp++);
    // TODO: optimize prepended dir
    pFullPath = (char *)malloc(cp - path + 1);
    strncpy(pFullPath, path, cp - path + 1);
    wxLogVerbose("  Chart %s", pFullPath);
 
    // Read the table entry
    ChartTableEntry_onDisk_15 cte;
    is.Read(&cte, sizeof(ChartTableEntry_onDisk_15));
 
    //    Transcribe the elements....
    EntryOffset = cte.EntryOffset;
    ChartType = cte.ChartType;
    LatMax = cte.LatMax;
    LatMin = cte.LatMin;
    LonMax = cte.LonMax;
    LonMin = cte.LonMin;
 
    m_bbox.Set(LatMin, LatMax, LonMin, LonMax);
 
    SetScale(cte.Scale);
    edition_date = cte.edition_date;
    file_date = cte.file_date;
 
    nPlyEntries = cte.nPlyEntries;
    nAuxPlyEntries = cte.nAuxPlyEntries;
 
    bValid = cte.bValid;
 
    if (nPlyEntries) {
      int npeSize = nPlyEntries * 2 * sizeof(float);
      pPlyTable = (float *)malloc(npeSize);
      is.Read(pPlyTable, npeSize);
    }
 
    if (nAuxPlyEntries) {
      int napeSize = nAuxPlyEntries * sizeof(int);
      pAuxPlyTable = (float **)malloc(nAuxPlyEntries * sizeof(float *));
      pAuxCntTable = (int *)malloc(napeSize);
      is.Read(pAuxCntTable, napeSize);
 
      for (int nAuxPlyEntry = 0; nAuxPlyEntry < nAuxPlyEntries;
           nAuxPlyEntry++) {
        int nfSize = pAuxCntTable[nAuxPlyEntry] * 2 * sizeof(float);
        pAuxPlyTable[nAuxPlyEntry] = (float *)malloc(nfSize);
        is.Read(pAuxPlyTable[nAuxPlyEntry], nfSize);
      }
    }
  } else if (db_version == 14) {
    // Read the path first
    for (cp = path; (*cp = (char)is.GetC()) != 0; cp++);
    pFullPath = (char *)malloc(cp - path + 1);
    strncpy(pFullPath, path, cp - path + 1);
    wxLogVerbose("  Chart %s", pFullPath);
 
    // Read the table entry
    ChartTableEntry_onDisk_14 cte;
    is.Read(&cte, sizeof(ChartTableEntry_onDisk_14));
 
    //    Transcribe the elements....
    EntryOffset = cte.EntryOffset;
    ChartType = cte.ChartType;
    LatMax = cte.LatMax;
    LatMin = cte.LatMin;
    LonMax = cte.LonMax;
    LonMin = cte.LonMin;
 
    m_bbox.Set(LatMin, LatMax, LonMin, LonMax);
 
    SetScale(cte.Scale);
    edition_date = cte.edition_date;
    file_date = 0;  //  file_date does not exist in V14;
    nPlyEntries = cte.nPlyEntries;
    nAuxPlyEntries = cte.nAuxPlyEntries;
    bValid = cte.bValid;
 
    if (nPlyEntries) {
      int npeSize = nPlyEntries * 2 * sizeof(float);
      pPlyTable = (float *)malloc(npeSize);
      is.Read(pPlyTable, npeSize);
    }
 
    if (nAuxPlyEntries) {
      int napeSize = nAuxPlyEntries * sizeof(int);
      pAuxPlyTable = (float **)malloc(nAuxPlyEntries * sizeof(float *));
      pAuxCntTable = (int *)malloc(napeSize);
      is.Read(pAuxCntTable, napeSize);
 
      for (int nAuxPlyEntry = 0; nAuxPlyEntry < nAuxPlyEntries;
           nAuxPlyEntry++) {
        int nfSize = pAuxCntTable[nAuxPlyEntry] * 2 * sizeof(float);
        pAuxPlyTable[nAuxPlyEntry] = (float *)malloc(nfSize);
        is.Read(pAuxPlyTable[nAuxPlyEntry], nfSize);
      }
    }
  }
  ChartFamily = convertChartFamily(ChartType, ChartFamily);
  ChartType = convertChartType(ChartType);
 
  return true;
}
 
 
bool ChartTableEntry::Write(const ChartDatabase *pDb, wxOutputStream &os) {
  os.Write(pFullPath, strlen(pFullPath) + 1);
 
  //      Write the current version type only
  //      Create an on_disk table entry
  ChartTableEntry_onDisk_18 cte;
 
  //    Transcribe the elements....
  cte.EntryOffset = EntryOffset;
  cte.ChartType = ChartType;
  cte.ChartFamily = ChartFamily;
  cte.LatMax = LatMax;
  cte.LatMin = LatMin;
  cte.LonMax = LonMax;
  cte.LonMin = LonMin;
 
  cte.Scale = Scale;
  cte.edition_date = edition_date;
  cte.file_date = file_date;
 
  cte.nPlyEntries = nPlyEntries;
  cte.nAuxPlyEntries = nAuxPlyEntries;
 
  cte.skew = Skew;
  cte.ProjectionType = ProjectionType;
 
  cte.bValid = bValid;
 
  cte.nNoCovrPlyEntries = nNoCovrPlyEntries;
 
  os.Write(&cte, sizeof(ChartTableEntry_onDisk_18));
  wxLogVerbose("  Wrote Chart %s", pFullPath);
 
  //      Write out the tables
  if (nPlyEntries) {
    int npeSize = nPlyEntries * 2 * sizeof(float);
    os.Write(pPlyTable, npeSize);
  }
 
  if (nAuxPlyEntries) {
    int napeSize = nAuxPlyEntries * sizeof(int);
    os.Write(pAuxCntTable, napeSize);
 
    for (int nAuxPlyEntry = 0; nAuxPlyEntry < nAuxPlyEntries; nAuxPlyEntry++) {
      int nfSize = pAuxCntTable[nAuxPlyEntry] * 2 * sizeof(float);
      os.Write(pAuxPlyTable[nAuxPlyEntry], nfSize);
    }
  }
 
  if (nNoCovrPlyEntries) {
    int ncSize = nNoCovrPlyEntries * sizeof(int);
    os.Write(pNoCovrCntTable, ncSize);
 
    for (int i = 0; i < nNoCovrPlyEntries; i++) {
      int nctSize = pNoCovrCntTable[i] * 2 * sizeof(float);
      os.Write(pNoCovrPlyTable[i], nctSize);
    }
  }
 
  return true;
}
 
 
void ChartTableEntry::Clear() {
  pFullPath = NULL;
  pPlyTable = NULL;
  pAuxPlyTable = NULL;
  pAuxCntTable = NULL;
  bValid = false;
  ;
  pNoCovrCntTable = NULL;
  pNoCovrPlyTable = NULL;
 
  nNoCovrPlyEntries = 0;
  nAuxPlyEntries = 0;
 
  m_pfilename = NULL;  // a helper member, not on disk
  m_psFullPath = NULL;
  Scale = 1e8;  // Very small scale
}
 
 
void ChartTableEntry::Disable() {
  // Mark this chart in the database, so that it will not be seen during this
  // run How?  By setting the chart bounding box to an absurd value
  // TODO... Fix this heinous hack
  LatMax += (float)1000.;
  LatMin += (float)1000.;
}
 
void ChartTableEntry::ReEnable() {
  if (LatMax > 90.) {
    LatMax -= (float)1000.;
    LatMin -= (float)1000.;
  }
}
bool ChartTableEntry::IsBasemap() const {
  wxFileName fn(GetFullPath());
  return (fn.GetPath().Lower().Contains("basemap"));
}
 
std::vector<float> ChartTableEntry::GetReducedPlyPoints() {
  if (m_reducedPlyPoints.size()) return m_reducedPlyPoints;
 
  //  Reduce the LOD of the chart outline PlyPoints
  float LOD_meters = 1;
 
  float plylat, plylon;
  const int nPoints = GetnPlyEntries();
 
  float *fpo = GetpPlyTable();
 
  double *ppd = new double[nPoints * 2];
  double *ppsm = new double[nPoints * 2];
  double *npr = ppd;
  double *npsm = ppsm;
  for (int i = 0; i < nPoints; i++) {
    plylat = fpo[i * 2];
    plylon = fpo[i * 2 + 1];
 
    double x, y;
    toSM(plylat, plylon, fpo[0], fpo[1], &x, &y);
 
    *npr++ = plylon;
    *npr++ = plylat;
    *npsm++ = x;
    *npsm++ = y;
  }
 
  std::vector<int> index_keep;
  if (nPoints > 10) {
    index_keep.push_back(0);
    index_keep.push_back(nPoints - 1);
    index_keep.push_back(1);
    index_keep.push_back(nPoints - 2);
 
    DouglasPeuckerM(ppsm, 1, nPoints - 2, LOD_meters, &index_keep);
 
  } else {
    index_keep.resize(nPoints);
    for (int i = 0; i < nPoints; i++) index_keep[i] = i;
  }
 
  double *ppr = ppd;
  for (int ip = 0; ip < nPoints; ip++) {
    double x = *ppr++;
    double y = *ppr++;
 
    for (unsigned int j = 0; j < index_keep.size(); j++) {
      if (index_keep[j] == ip) {
        m_reducedPlyPoints.push_back(x);
        m_reducedPlyPoints.push_back(y);
        break;
      }
    }
  }
 
  delete[] ppd;
  delete[] ppsm;
 
  int nprr = m_reducedPlyPoints.size() / 2;
 
  return m_reducedPlyPoints;
}
 
std::vector<float> ChartTableEntry::GetReducedAuxPlyPoints(int iTable) {
  //  Maybe need to initialize the vector
  if (!m_reducedAuxPlyPointsVector.size()) {
    std::vector<float> vec;
    for (int i = 0; i < GetnAuxPlyEntries(); i++) {
      m_reducedAuxPlyPointsVector.push_back(vec);
    }
  }
 
  std::vector<float> vec;
 
  //  Invalid parameter
  if ((unsigned int)iTable >= m_reducedAuxPlyPointsVector.size()) return vec;
 
  if (m_reducedAuxPlyPointsVector.at(iTable).size())
    return m_reducedAuxPlyPointsVector.at(iTable);
 
  //  Reduce the LOD of the chart outline PlyPoints
  float LOD_meters = 1.0;
 
  const int nPoints = GetAuxCntTableEntry(iTable);
  float *fpo = GetpAuxPlyTableEntry(iTable);
 
  double *ppd = new double[nPoints * 2];
  double *ppsm = new double[nPoints * 2];
  double *npr = ppd;
  double *npsm = ppsm;
  float plylat, plylon;
 
  for (int i = 0; i < nPoints; i++) {
    plylat = fpo[i * 2];
    plylon = fpo[i * 2 + 1];
 
    double x, y;
    toSM(plylat, plylon, fpo[0], fpo[1], &x, &y);
 
    *npr++ = plylon;
    *npr++ = plylat;
    *npsm++ = x;
    *npsm++ = y;
  }
 
  std::vector<int> index_keep;
  if (nPoints > 10) {
    index_keep.push_back(0);
    index_keep.push_back(nPoints - 1);
    index_keep.push_back(1);
    index_keep.push_back(nPoints - 2);
 
    DouglasPeuckerM(ppsm, 1, nPoints - 2, LOD_meters, &index_keep);
 
  } else {
    index_keep.resize(nPoints);
    for (int i = 0; i < nPoints; i++) index_keep[i] = i;
  }
 
  int nnn = index_keep.size();
 
  double *ppr = ppd;
  for (int ip = 0; ip < nPoints; ip++) {
    double x = *ppr++;
    double y = *ppr++;
 
    for (unsigned int j = 0; j < index_keep.size(); j++) {
      if (index_keep[j] == ip) {
        vec.push_back(x);
        vec.push_back(y);
        break;
      }
    }
  }
 
  delete[] ppd;
  delete[] ppsm;
 
  m_reducedAuxPlyPointsVector[iTable] = vec;
 
  int nprr = vec.size() / 2;
 
  return vec;
}
 
// ChartDatabase
const int ID_DBS_PROGRESS_UPDATE = wxNewId();
 
WX_DEFINE_OBJARRAY(ChartTable);
 
ChartDatabase::ChartDatabase() {
  bValid = false;
  SetBusy(false);
 
  m_ChartTableEntryDummy.Clear();
 
  Bind(wxEVT_OCPN_CHARTTABLEENTRYTHREAD, &ChartDatabase::OnEvtThread, this);
  Bind(wxEVT_COMMAND_MENU_SELECTED, &ChartDatabase::OnDBSProgressUpdate, this,
       ID_DBS_PROGRESS_UPDATE);
 
  m_progress_timer.SetOwner(this, ID_TIMER_UPDATE_PROGRESS);
  Bind(wxEVT_TIMER, &ChartDatabase::OnProgessTimer, this,
       ID_TIMER_UPDATE_PROGRESS);
 
  m_update_competion_timer.SetOwner(this, ID_TIMER_UPDATE_COMPLETE);
  Bind(wxEVT_TIMER, &ChartDatabase::OnUpdateComplete, this,
       ID_TIMER_UPDATE_COMPLETE);
 
  UpdateChartClassDescriptorArray();
}
 
void ChartDatabase::OnDBSProgressUpdate(wxCommandEvent &evt) {}
 
void ChartDatabase::OnUpdateComplete(wxTimerEvent &event) {
  ProcessThreadQueueEmpty();
}
 
void ChartDatabase::OnProgessTimer(wxTimerEvent &event) {
  if (m_pprog && m_progress_timer.IsRunning() && (m_jobsRemaining > 1)) {
    if (m_progress_dirty.exchange(false)) {
#ifdef __ANDROID__
      qDebug() << "   ***Update()" << m_jobsRemaining;
#endif
      m_pprog->Update(m_progress_value, m_progress_message);
#ifdef __ANDROID__
      qDebug() << "   ---Update() out" << m_jobsRemaining;
#endif
    }
  }
}
 
void ChartDatabase::ProcessThreadQueueEmpty() {
#ifdef __ANDROID__
  qDebug() << "ProcessThreadQueueEmpty";
#endif
  if (m_deferred_ticket_vector.size()) {
    // Process the deferred charts in a single thread pool
    // load the thread pool from the prepared array
    // Enqueue jobs
    for (auto &ticket_d : m_deferred_ticket_vector) {
      ticket_d->m_ticket_type = 0;
      m_pool_deferred.Push(ticket_d);
      m_jobsRemaining++;
    }
    m_deferred_ticket_vector.clear();
 
    // Initialize progress dialog
    m_progcount = 0;
    m_progint = 0;
    m_ticketcount = m_jobsRemaining;
    m_nFileProgressQuantum = 1;  // wxMax(m_ticketcount / 10, 2);
    m_progress_message = _("Processing charts");
    m_progress_timer.Start(50, wxTIMER_CONTINUOUS);
 
    // Start up the queued thread, if necessary
    if (m_jobsRemaining) {
      const int workerCount = 1;
      if (m_pool_deferred.GetWorkerCount() < workerCount) {
        int threads_needed = workerCount - m_pool_deferred.GetWorkerCount();
        for (int i = 0; i < threads_needed; ++i) {
          (new PoolWorkerThread(m_pool_deferred, this))->Run();
          m_pool_deferred.AddWorker();
        }
      }
    }
    return;  // Let the thread run
  }
 
  m_progress_timer.Stop();
  if (m_pprog) m_pprog->Hide();
 
  // Now m_ticket_vector is populated with verified tickets
  // for all specified directories.
 
  // Add the CTEs from the tickets to the active table
  // NB: The active_chartTable was cleared by the Update() method
  // before this point
 
  for (auto &ticket_valid : m_ticket_vector) {
    if (ticket_valid->m_chart_table_entry)
      active_chartTable.push_back(ticket_valid->m_chart_table_entry);
  }
 
  // Release references to tickets
  m_ticket_vector.clear();
 
#ifdef __ANDROID__
  qDebug() << "FinalizeChartUpdate";
#endif
 
  FinalizeChartUpdate();
}
 
void ChartDatabase::OnEvtThread(OCPN_ChartTableEntryThreadEvent &event) {
#ifdef __ANDROID__
  qDebug() << "Remaining: " << m_jobsRemaining;
#endif
  // Capture the completed job tickets
  auto ticket = event.GetTicket();
  if (!ticket) {
    return;
  }
 
  // Update progress dialog, if present
  if (m_pprog && (m_jobsRemaining > 1)) {
    m_progcount++;
    double ratio = 100. * (double)m_progcount / m_ticketcount;
    int val = ratio;
    if (((m_progcount % m_nFileProgressQuantum) == 0)) {
      if (val != m_progint) {
        m_progint = val;
        m_progress_value = val;
        m_progress_dirty = true;
      }
    }
  }
 
  if (!ticket->m_ticket_type) {  // TICKET_TYPE_NORMAL
    bool collision_found = false;
    if (ticket->b_thread_safe) {
      wxFileName fn(ticket->m_ChartPath);
      ChartCollisionsHashMap::iterator it;
      for (it = m_full_collision_map.begin(); it != m_full_collision_map.end();
           ++it) {
        if (it->first.IsSameAs(fn.GetFullName())) {
          // Two files found with identical file name
          // For now, just drop this ticket
          // TODO Make an (expensive) test on file modification times
          collision_found = true;
          break;
        }
      }
      if (!collision_found) {
        m_full_collision_map[fn.GetFullName()] = 1;
      }
      //  Consider TODO #1 here:  Looking for more duolicates acress directories
    }
 
    m_ticket_vector.push_back(ticket);
  }
 
  int remaining = --m_jobsRemaining;
 
  // Update throttle.
  m_pool.pending_events--;
  m_pool_deferred.pending_events--;
 
  if (remaining == 0) {
    m_pool.Shutdown();
    m_pool_deferred.Shutdown();
    m_progress_timer.Stop();
 
#ifdef __ANDROID__
    qDebug() << "Fire completion Oneshot";
#endif
    m_update_competion_timer.Start(100, wxTIMER_ONE_SHOT);
  }
}
 
void ChartDatabase::FinalizeChartUpdate() {
  // Scrub CTE list, remove any invalid entries,
  //  as tagged by directory removal
  active_chartTable.erase(
      std::remove_if(active_chartTable.begin(), active_chartTable.end(),
                     [](const auto &cte) { return !cte->GetbValid(); }),
      active_chartTable.end());
 
  size_t d = active_chartTable.size();
 
  //    And once more, setting the Entry index field
  active_chartTable_pathindex.clear();
  int i = 0;
  for (auto cte : active_chartTable) {
    active_chartTable_pathindex[cte->GetFullSystemPath()] = i;
    cte->SetEntryOffset(i);
    i++;
  }
 
  m_nentries = active_chartTable.size();
  bValid = true;
  SetBusy(false);
  ChartData->SetBusy(false);
 
  // Finalize the dB on disk
  ChartData->SaveBinary(ChartListFileName);
  wxLogMessage("Finished chart database Update");
  wxLogMessage("   ");
 
  if (m_pprog) m_pprog->Destroy();
  m_pprog = nullptr;
 
  // The Update() function may set gWorldMapLocation if at least one of the
  // directories contains GSHHS files.  Make sure GSHHS is still accessible
  if (gWorldMapLocation.empty()) {  // Last resort. User might have deleted all
                                    // GSHHG data, but we still might have the
                                    // default dataset distributed with OpenCPN
                                    // or from the package repository...
    gWorldMapLocation = gDefaultWorldMapLocation;
    m_gshhg_chart_loc = wxEmptyString;
  }
 
  // Update canvas and "Crossesland" machinery
  if (gWorldMapLocation != m_gshhg_chart_loc) {
    // ..For each canvas...
    // TODO Move this where?
    // for (unsigned int i = 0; i < g_canvasArray.GetCount(); i++) {
    //  ChartCanvas *cc = g_canvasArray.Item(i);
    //  if (cc) cc->ResetWorldBackgroundChart();
    // }
 
    // Reset the GSHHS singleton which is used to detect land crossing.
    gshhsCrossesLandReset();
  }
 
  // Purge all charts from cache, and delete.
  ChartData->PurgeCache();
 
  //  Signal Options dialog that update is finished
  GuiEvents::GetInstance().options_on_finalize_chartdbs.Notify();
 
  // Signal a full chart reload
  GuiEvents::GetInstance().on_finalize_chartdbs.Notify();
}
 
bool ChartDatabase::ScrubGroupArray() {
  //    For each group,
  //    make sure that each group element (dir or chart) references at least
  //    oneitem in the database. If not, remove the element.
 
  bool b_change = false;
  unsigned int igroup = 0;
  while (igroup < g_pGroupArray->GetCount()) {
    bool b_chart_in_element = false;
    ChartGroup *pGroup = g_pGroupArray->Item(igroup);
 
    for (unsigned int j = 0; j < pGroup->m_element_array.size(); j++) {
      const wxString &element_root = pGroup->m_element_array[j].m_element_name;
 
      for (unsigned int ic = 0;
           ic < (unsigned int)ChartData->GetChartTableEntries(); ic++) {
        auto &cte = ChartData->GetChartTableEntry(ic);
        wxString chart_full_path = cte.GetFullSystemPath();
 
        if (chart_full_path.StartsWith(element_root)) {
          b_chart_in_element = true;
          break;
        }
      }
 
      // Explicit check to avoid removing a group containing only GSHHS
      if (!b_chart_in_element) {
        wxString test_string = "GSHH";
        if (element_root.Upper().Contains(test_string))
          b_chart_in_element = true;
      }
 
      if (!b_chart_in_element)  // delete the element
      {
        pGroup->m_element_array.erase(pGroup->m_element_array.begin() + j);
        j--;
        b_change = true;
      }
    }
 
    igroup++;  // next group
  }
 
  return b_change;
}
 
void ChartDatabase::UpdateChartClassDescriptorArray() {
  if (m_ChartClassDescriptorArray.empty()) {
    m_ChartClassDescriptorArray.push_back(
        ChartClassDescriptor("ChartKAP", "*.kap", nullptr, BUILTIN_DESCRIPTOR));
    m_ChartClassDescriptorArray.push_back(
        ChartClassDescriptor("ChartGEO", "*.geo", nullptr, BUILTIN_DESCRIPTOR));
    m_ChartClassDescriptorArray.push_back(
        ChartClassDescriptor("s57chart", "*.000", nullptr, BUILTIN_DESCRIPTOR));
    m_ChartClassDescriptorArray.push_back(
        ChartClassDescriptor("s57chart", "*.s57", nullptr, BUILTIN_DESCRIPTOR));
    m_ChartClassDescriptorArray.push_back(ChartClassDescriptor(
        "cm93compchart", "00300000.a", nullptr, BUILTIN_DESCRIPTOR));
    m_ChartClassDescriptorArray.push_back(ChartClassDescriptor(
        "ChartMbTiles", "*.mbtiles", nullptr, BUILTIN_DESCRIPTOR));
  }
  //    If the PlugIn Manager exists, get the array of dynamically loadable
  //    chart class names
  if (g_pi_manager) {
    m_ChartClassDescriptorArray.erase(
        std::remove_if(m_ChartClassDescriptorArray.begin(),
                       m_ChartClassDescriptorArray.end(),
                       [](const ChartClassDescriptor &cd) {
                         return cd.m_descriptor_type == PLUGIN_DESCRIPTOR;
                       }),
        m_ChartClassDescriptorArray.end());
 
    wxArrayString array = g_pi_manager->GetPlugInChartClassNameArray();
    for (unsigned int j = 0; j < array.GetCount(); j++) {
      //    Instantiate a blank chart to retrieve the directory search mask for
      //    this chart type
      wxString class_name = array[j];
      ChartPlugInWrapper *cpiw = new ChartPlugInWrapper(class_name);
      if (cpiw) {
        wxString mask = cpiw->GetFileSearchMask();
 
        // Get the plugin (ptr) that provides this chart class
        auto plugin_t = g_pi_manager->GetProvidingPlugin(class_name);
        opencpn_plugin *plugin = dynamic_cast<opencpn_plugin *>(plugin_t);
        // Create a new descriptor and add it to the database
        m_ChartClassDescriptorArray.push_back(
            ChartClassDescriptor(class_name, mask, plugin, PLUGIN_DESCRIPTOR));
        delete cpiw;
      }
    }
  }
}
 
ChartTableEntry &ChartDatabase::GetChartTableEntry(int index) {
  if (index < GetChartTableEntries())
    return *active_chartTable[index];
  else
    return m_ChartTableEntryDummy;
}
 
bool ChartDatabase::CompareChartDirArray(ArrayOfCDI &test_array) {
  //  Compare the parameter "test_array" with this.m_dir_array
  //    Return true if functionally identical (order does not signify).
 
  if (test_array.GetCount() != m_dir_array.GetCount()) return false;
 
  bool bfound_inner;
  unsigned int nfound_outer = 0;
 
  for (unsigned int i = 0; i < test_array.GetCount(); i++) {
    ChartDirInfo p = test_array[i];
    bfound_inner = false;
    for (unsigned int j = 0; j < m_dir_array.GetCount(); j++) {
      ChartDirInfo q = m_dir_array[j];
 
      if (p.fullpath.IsSameAs(q.fullpath)) {
        bfound_inner = true;
        break;
      }
    }
    if (bfound_inner) nfound_outer++;
  }
 
  return (nfound_outer == test_array.GetCount());
}
 
wxString ChartDatabase::GetMagicNumberCached(wxString dir) {
  for (unsigned int j = 0; j < m_dir_array.GetCount(); j++) {
    ChartDirInfo q = m_dir_array[j];
    if (dir.IsSameAs(q.fullpath)) return q.magic_number;
  }
 
  return "";
}
 
bool ChartDatabase::Read(const wxString &filePath) {
  ChartTableEntry entry;
  int entries;
 
  bValid = false;
 
  wxFileName file(filePath);
  if (!file.FileExists()) return false;
 
  m_DBFileName = filePath;
 
  wxFFileInputStream ifs(filePath);
  if (!ifs.Ok()) return false;
 
  ChartTableHeader cth;
  cth.Read(ifs);
  if (!cth.CheckValid()) return false;
 
  //      Capture the version number
  char vbo[5];
  memcpy(vbo, cth.GetDBVersionString(), 4);
  vbo[4] = 0;
  m_dbversion = atoi(&vbo[1]);
  s_dbVersion = m_dbversion;  // save the static copy
 
  wxLogVerbose("Chartdb:Reading %d directory entries, %d table entries",
               cth.GetDirEntries(), cth.GetTableEntries());
  wxLogMessage("Chartdb: Chart directory list follows");
  if (0 == cth.GetDirEntries()) wxLogMessage("  Nil");
 
  int ind = 0;
  for (int iDir = 0; iDir < cth.GetDirEntries(); iDir++) {
    wxString dir;
    int dirlen;
    ifs.Read(&dirlen, sizeof(int));
    while (dirlen > 0) {
      char dirbuf[1024];
      int alen = dirlen > 1023 ? 1023 : dirlen;
      if (ifs.Read(&dirbuf, alen).Eof()) goto read_error;
      dirbuf[alen] = 0;
      dirlen -= alen;
      dir.Append(wxString(dirbuf, wxConvUTF8));
    }
    wxString msg;
    msg.Printf("  Chart directory #%d: ", iDir);
    msg.Append(dir);
    wxLogMessage(msg);
    m_chartDirs.Add(dir);
  }
 
  entries = cth.GetTableEntries();
  // active_chartTable.Alloc(entries);
  active_chartTable_pathindex.clear();
  while (entries-- && entry.Read(this, ifs)) {
    active_chartTable_pathindex[entry.GetFullSystemPath()] = ind++;
    auto sharedPtr = std::make_shared<ChartTableEntry>(entry);
    active_chartTable.push_back(sharedPtr);
  }
 
  entry.Clear();
  bValid = true;
  entry.SetAvailable(true);
 
  m_nentries = active_chartTable.size();
  return true;
 
read_error:
  bValid = false;
  m_nentries = active_chartTable.size();
  return false;
}
 
 
bool ChartDatabase::Write(const wxString &filePath) {
  wxFileName file(filePath);
  wxFileName dir(
      file.GetPath(wxPATH_GET_SEPARATOR | wxPATH_GET_VOLUME, wxPATH_NATIVE));
 
  if (!dir.DirExists() && !dir.Mkdir()) return false;
 
  wxFFileOutputStream ofs(filePath);
  if (!ofs.Ok()) return false;
 
  ChartTableHeader cth(m_chartDirs.GetCount(), active_chartTable.size());
  cth.Write(ofs);
 
  for (int iDir = 0; iDir < cth.GetDirEntries(); iDir++) {
    wxString dir1 = m_chartDirs[iDir];
    int dirlen = dir1.length();
    char s[200];
    strncpy(s, dir1.mb_str(wxConvUTF8), 199);
    s[199] = 0;
    dirlen = strlen(s);
    ofs.Write(&dirlen, sizeof(int));
    //        ofs.Write(dir.fn_str(), dirlen);
    ofs.Write(s, dirlen);
  }
 
  for (UINT32 iTable = 0; iTable < active_chartTable.size(); iTable++) {
    auto &cte = GetChartTableEntry(iTable);
    cte.Write(this, ofs);
  }
 
  //      Explicitly set the version
  m_dbversion = DB_VERSION_CURRENT;
 
  return true;
}
 
wxString SplitPath(wxString s, wxString tkd, int nchar, int offset,
                   int *pn_split) {
  wxString r;
  int ncr = 0;
 
  int rlen = offset;
  wxStringTokenizer tkz(s, tkd);
  while (tkz.HasMoreTokens()) {
    wxString token = tkz.GetNextToken();
    if ((rlen + (int)token.Len() + 1) < nchar) {
      r += token;
      r += tkd[0];
      rlen += token.Len() + 1;
    } else {
      r += "\n";
      ncr++;
      for (int i = 0; i < offset; i++) {
        r += " ";
      }
      r += token;
      r += tkd[0];
      rlen = offset + token.Len() + 1;
    }
  }
 
  if (pn_split) *pn_split = ncr;
 
  return r.Mid(0, r.Len() - 1);  // strip the last separator char
}
 
wxString ChartDatabase::GetFullChartInfo(ChartBase *pc, int dbIndex,
                                         int *char_width, int *line_count) {
  wxString r;
  int lc = 0;
  unsigned int max_width = 0;
  int ncr;
  unsigned int target_width = 60;
 
  const ChartTableEntry &cte = GetChartTableEntry(dbIndex);
  wxString line;
  line.Empty();
  if (pc) {
    line = _(" Name:  ");
    wxString longline = pc->GetName();
 
    wxString tkz;
    if (longline.Find(' ') != wxNOT_FOUND)  // assume a proper name
      tkz = " ";
    else
      tkz = "/,\\";  // else a file name
 
    if (longline.Len() > target_width) {
      line += SplitPath(pc->GetName(), tkz, target_width, 12, &ncr);
      max_width = wxMax(max_width, target_width + 4);
      lc += ncr;
    } else {
      line += longline;
      max_width = wxMax(max_width, line.Len() + 4);
    }
  }
 
  line += "\n";
  r += line;
  lc++;
 
  if (pc)  // chart is loaded and available
    line.Printf(" %s:  1:%d", _("Scale"), pc->GetNativeScale());
  else
    line.Printf(" %s:  1:%d", _("Scale"), cte.GetScale());
 
  line += "\n";
  max_width = wxMax(max_width, line.Len());
  r += line;
  lc++;
  if (pc) {
    wxDateTime ed = pc->GetEditionDate();
    if (ed.IsValid()) {
      line = _(" Updated:  ") + ed.FormatISODate() + "\n";
      max_width = wxMax(max_width, line.Len());
      r += line;
    }
    lc++;
 
    line = _(" Source Edition:  ") + pc->GetSE() + "\n";
    max_width = wxMax(max_width, line.Len());
    r += line;
    lc++;
  }
 
  if (pc) {
    line = _(" Depth Units:  ") + pc->GetDepthUnits() + "\n";
    max_width = wxMax(max_width, line.Len());
    r += line;
    lc++;
 
    line = _(" Soundings:  ") + pc->GetSoundingsDatum() + "\n";
    max_width = wxMax(max_width, line.Len());
    r += line;
    lc++;
 
    line = _(" Datum:  ") + pc->GetDatumString() + "\n";
    max_width = wxMax(max_width, line.Len());
    r += line;
    lc++;
  }
 
  line = _(" Projection:  ");
  if (PROJECTION_UNKNOWN == cte.GetChartProjectionType())
    line += _("Unknown");
  else if (PROJECTION_MERCATOR == cte.GetChartProjectionType())
    line += _("Mercator");
  else if (PROJECTION_TRANSVERSE_MERCATOR == cte.GetChartProjectionType())
    line += _("Transverse Mercator");
  else if (PROJECTION_POLYCONIC == cte.GetChartProjectionType())
    line += _("Polyconic");
  else if (PROJECTION_WEB_MERCATOR == cte.GetChartProjectionType())
    line += _("Web Mercator (EPSG:3857)");
  line += "\n";
  max_width = wxMax(max_width, line.Len());
  r += line;
  lc++;
 
  line.Empty();
  if (pc) {
  }
 
  line.Empty();
  if (pc && pc->GetExtraInfo().Len()) {
    line += pc->GetExtraInfo();
    line += "\n";
    max_width = wxMax(max_width, line.Len());
    r += line;
    lc++;
  }
  if (pc) {
    line.Empty();
    line = _(" ID:  ");
    line += pc->GetID();
    line += "\n";
    max_width = wxMax(max_width, line.Len());
    r += line;
    lc++;
  }
 
  line = _(" ChartFile:  ");
  wxString longline = *(cte.GetpsFullPath());
  if (longline.Len() > target_width) {
    line += SplitPath(longline, "/,\\", target_width, 15, &ncr);
    max_width = wxMax(max_width, target_width + 4);
    lc += ncr;
  } else {
    line += longline;
    max_width = wxMax(max_width, line.Len() + 4);
  }
  r += line;
  r += "\n";
  lc++;
 
  if (line_count) *line_count = lc;
 
  if (char_width) *char_width = max_width;
 
  return r;
}
 
// ----------------------------------------------------------------------------
// Create Chart Table Database by directory search
//    resulting in valid pChartTable in (this)
// ----------------------------------------------------------------------------
bool ChartDatabase::Create(ArrayOfCDI &dir_array,
                           wxGenericProgressDialog *pprog) {
  m_dir_array = dir_array;
 
  bValid = false;
 
  m_chartDirs.Clear();
  active_chartTable.clear();
  active_chartTable_pathindex.clear();
 
  Update(dir_array, true, pprog);  // force the update the reload everything
 
  bValid = true;
 
  //      Explicitly set the version
  m_dbversion = DB_VERSION_CURRENT;
 
  return true;
}
 
/*
 * Traverse a directory recursively and find the GSHHG directory
 * that contains GSHHG data files.
 */
class GshhsTraverser : public wxDirTraverser {
public:
  GshhsTraverser() {}
  virtual wxDirTraverseResult OnFile(const wxString &filename) override {
    wxFileName fn(filename);
    wxFileName dir(fn.GetPath());
    if (fn.GetFullName().Matches("poly-*-1.dat") &&
        dir.GetFullName().IsSameAs("GSHHG", false)) {
      parent_dir = fn.GetPath(wxPATH_GET_VOLUME | wxPATH_GET_SEPARATOR);
      return wxDIR_STOP;
    }
    return wxDIR_CONTINUE;
  }
  virtual wxDirTraverseResult OnDir(const wxString &dirname) override {
    // Always recurse into directories.
    return wxDIR_CONTINUE;
  }
  wxString GetGshhsDir() const { return parent_dir; }
 
private:
  wxString parent_dir;
};
 
/*
 * Find and return the full path a of directory containing GSHHG data files.
 * Search recursively starting from directory.
 */
wxString findGshhgDirectory(const wxString &directory) {
  wxDir dir(directory);
  if (!dir.IsOpened()) {
    return wxEmptyString;
  }
  GshhsTraverser traverser;
  dir.Traverse(traverser, wxEmptyString, wxDIR_FILES | wxDIR_DIRS);
  return traverser.GetGshhsDir();
}
 
bool ChartDatabase::UpdateChartDatabaseInplace(ArrayOfCDI &DirArray,
                                               bool b_force,
                                               wxGenericProgressDialog *_prog) {
  // AbstractPlatform::ShowBusySpinner();
 
  m_pprog = _prog;
 
  wxLogMessage("   ");
  wxLogMessage("Starting chart database Update...");
 
  // The Update() function may set gWorldMapLocation if at least one of the
  // directories contains GSHHS files.  Save current situation...
  m_gshhg_chart_loc = gWorldMapLocation;
  gWorldMapLocation = wxEmptyString;
 
  Update(DirArray, b_force, m_pprog);
 
  // AbstractPlatform::HideBusySpinner();
  return true;
}
 
// ----------------------------------------------------------------------------
// Update existing ChartTable Database by directory search
//    resulting in valid pChartTable in (this)
// ----------------------------------------------------------------------------
bool ChartDatabase::Update(ArrayOfCDI &dir_array, bool bForce,
                           wxGenericProgressDialog *pprog) {
  m_pprog = pprog;
  m_ticket_vector.clear();
  m_full_collision_map.clear();
  m_jobsRemaining = 0;
  m_deferred_ticket_vector.clear();
  SetChartDirArray(dir_array);
 
  bValid = false;  // database is not useable right now...
  SetBusy(true);
  ChartData->SetBusy(true);
 
  //  Mark all charts provisionally invalid
  for (unsigned int i = 0; i < active_chartTable.size(); i++) {
    auto &cte = GetChartTableEntry(i);
    cte.SetValid(false);
  }
 
  m_chartDirs.Clear();
 
  if (bForce) active_chartTable.clear();
 
  bool lbForce = bForce;
 
  //    Do a dB Version upgrade if the current one is obsolete
  if (s_dbVersion != DB_VERSION_CURRENT) {
    active_chartTable.clear();
    lbForce = true;
    s_dbVersion = DB_VERSION_CURRENT;  // Update the static indicator
    m_dbversion = DB_VERSION_CURRENT;  // and the member
  }
 
  //  Get the new charts
 
  for (unsigned int j = 0; j < dir_array.GetCount(); j++) {
    ChartDirInfo dir_info = dir_array[j];
 
    // On Android, with SDK >= 30, traversal of a folder that is
    //  on within the "scoped storage" domain is very slow.
    //  Aviod it....
#ifdef __ANDROID__
    if (!androidIsDirWritable(dir_info.fullpath)) continue;
#endif
 
    wxString dir_magic;
    // Recursively search for a directory that contains GSHHG files starting
    // from dir_info.
    wxString gshhg_dir = findGshhgDirectory(dir_info.fullpath);
    if (!gshhg_dir.empty()) {
      // If some polygons exist in the directory, set it as the one to use for
      // GSHHG
      // TODO: We should probably compare the version and maybe resolutions
      // available with what is currently used...
      wxLogMessage("Updating GSHHG directory: %s", gshhg_dir.c_str());
      gWorldMapLocation = gshhg_dir;
    }
 
    // If the user has added a directory containig an extended OSMSHP basemap
    // then capture the location, and reset the basemap render amchine.
    if (dir_info.fullpath.Find("OSMSHP") != wxNOT_FOUND) {
      if (!wxDir::FindFirst(dir_info.fullpath, "basemap_*.shp").empty()) {
        wxLogMessage("Updating OSMSHP directory: %s", dir_info.fullpath);
        gWorldShapefileLocation =
            dir_info.fullpath + wxFileName::GetPathSeparator();
        gShapeBasemap.Reset();
      }
    }
 
    TraverseDirAndAddCharts(dir_info, pprog, dir_magic, lbForce);
 
    //  Update the dir_list entry, even if the magic values are the same
    dir_info.magic_number = dir_magic;
    dir_array.RemoveAt(j);
    dir_array.Insert(dir_info, j);
 
    m_chartDirs.Add(dir_info.fullpath);
  }  // for
 
  // Special case, if chart dir list is truly empty
  if (m_chartDirs.IsEmpty() || !m_jobsRemaining) {
    if (!m_deferred_ticket_vector.size()) {
      FinalizeChartUpdate();
      return true;
    } else {
      auto *evt =
          new OCPN_ChartTableEntryThreadEvent(wxEVT_OCPN_CHARTTABLEENTRYTHREAD);
      auto ticket_deferred = m_deferred_ticket_vector.back();
      ticket_deferred->m_ticket_type = 1;  // Mark as a dummy ticket.;
                                           // to trigger an event
      m_jobsRemaining = 1;
      evt->SetTicket(ticket_deferred);
      wxQueueEvent(this, evt);
    }
  }
 
  // Initialize progress dialog
  m_progcount = 0;
  m_progint = 0;
  m_ticketcount = m_jobsRemaining;
  m_nFileProgressQuantum = 1;  // wxMax(m_ticketcount / 10, 2);
  m_progress_message = _("Processing charts");
 
  m_progress_timer.Start(50, wxTIMER_CONTINUOUS);
 
  // Start up the queued threads, if necessary
  if (m_jobsRemaining) {
    int workerCount = 4;
#ifdef __ANDROID__
    workerCount = 1;  // A little less stress on busy phones.
#endif
    if (m_pool.GetWorkerCount() < workerCount) {
      int threads_needed = workerCount - m_pool.GetWorkerCount();
      for (int i = 0; i < threads_needed; ++i) {
        (new PoolWorkerThread(m_pool, this))->Run();
        m_pool.AddWorker();
      }
    }
  }
 
  return true;
}
 
//-------------------------------------------------------------------
//    Find Chart dbIndex
//-------------------------------------------------------------------
 
int ChartDatabase::FinddbIndex(wxString PathToFind) {
  if (active_chartTable_pathindex.find(PathToFind) !=
      active_chartTable_pathindex.end())
    return active_chartTable_pathindex[PathToFind];
 
  return -1;
}
 
//-------------------------------------------------------------------
//    Disable Chart
//-------------------------------------------------------------------
 
int ChartDatabase::DisableChart(wxString &PathToDisable) {
  int index = FinddbIndex(PathToDisable);
  if (index != -1) {
    auto &entry = GetChartTableEntry(index);
    entry.Disable();
    return 1;
  }
  return 0;
}
 
// ----------------------------------------------------------------------------
//  Traverse the given directory looking for charts
//  If bupdate is true, also search the existing database for a name match.
//  If target chart is already in database, mark the entry valid and skip
//  additional processing
// ----------------------------------------------------------------------------
 
int ChartDatabase::TraverseDirAndAddCharts(ChartDirInfo &dir_info,
                                           wxGenericProgressDialog *pprog,
                                           wxString &dir_magic, bool bForce) {
  //    Extract the true dir name and magic number from the compound string
  wxString dir_path = dir_info.fullpath;
#ifdef __ANDROID__
  dir_path = wxString(dir_info.fullpath.mb_str(wxConvUTF8));
#endif
 
  wxString old_magic = dir_info.magic_number;
  wxString new_magic = old_magic;
  dir_magic = old_magic;  // provisionally the same
 
  int nAdd = 0;
 
  bool b_skipDetectDirChange = false;
  bool b_dirchange = false;
 
  // Does this directory actually exist?
  if (!wxDir::Exists(dir_path)) return 0;
 
  // Check to see if this is a cm93 directory root
  // If so, skip the DetectDirChange since it may be very slow
  // and give no information
  // Assume a change has happened, and process accordingly
  bool b_cm93 = Check_CM93_Structure(dir_path);
  if (b_cm93) {
    b_skipDetectDirChange = true;
    b_dirchange = true;
  }
 
  //    Quick scan the directory to see if it has changed
  //    If not, there is no need to scan again.....
  if (!b_skipDetectDirChange)
    b_dirchange = DetectDirChange(dir_path, dir_info.fullpath, old_magic,
                                  new_magic, pprog);
 
  if (!bForce && !b_dirchange) {
    wxString msg("   No change detected on directory ");
    msg.Append(dir_path);
    wxLogMessage(msg);
 
    //    Traverse the database, and mark as valid all charts coming from this
    //    dir, or anywhere in its tree
 
    wxFileName fn_dir(dir_path, "stuff");
    unsigned int dir_path_count = fn_dir.GetDirCount();
 
    if (pprog) pprog->SetTitle(_("OpenCPN Chart Scan...."));
 
    int nEntries = active_chartTable.size();
 
    for (int ic = 0; ic < nEntries; ic++) {
      auto &cte = GetChartTableEntry(ic);
      wxFileName fn(cte.GetFullSystemPath());
 
      while (fn.GetDirCount() >= dir_path_count) {
        if (fn.GetPath() == dir_path) {
          auto &cte_a = GetChartTableEntry(ic);
          cte_a.SetValid(true);
          //                             if(pprog)
          //                                  pprog->Update((ic * 100)
          //                                  /nEntries, fn.GetFullPath());
 
          break;
        }
        fn.RemoveLastDir();
      }
    }
 
    return 0;
  }
 
  //    There presumably was a change in the directory contents.  Return the new
  //    magic number
  dir_magic = new_magic;
 
  //    Look for all possible defined chart classes
  for (auto &cd : m_ChartClassDescriptorArray) {
    nAdd += SearchDirAndAddCharts(dir_info.fullpath, cd, pprog);
  }
 
  return nAdd;
}
 
bool ChartDatabase::DetectDirChange(const wxString &dir_path,
                                    const wxString &prog_label,
                                    const wxString &magic, wxString &new_magic,
                                    wxGenericProgressDialog *pprog) {
  if (pprog) pprog->SetTitle(_("OpenCPN Directory Scan...."));
 
  //    parse the magic number
  long long unsigned int nmagic;
  wxULongLong nacc = 0;
 
  magic.ToULongLong(&nmagic, 10);
 
  //    Get an arraystring of all files
  wxArrayString FileList;
  wxDir dir(dir_path);
  int n_files = dir.GetAllFiles(dir_path, &FileList);
  FileList.Sort();  // Ensure persistent order of items being hashed.
 
  FlexHash hash(sizeof nacc);
  hash.Reset();
 
  if (pprog) pprog->Update(0, prog_label);
 
  // Traverse the list of files, getting their interesting stuff to add to
  // accumulator
  for (int ifile = 0; ifile < n_files; ifile++) {
    wxFileName file(FileList[ifile]);
 
    // NOTE. Do not ever try to optimize this code by combining `wxString`
    // calls. Otherwise `fileNameUTF8` will point to a stale buffer overwritten
    // by garbage.
    wxString fileNameNative = file.GetFullPath();
    wxScopedCharBuffer fileNameUTF8 = fileNameNative.ToUTF8();
    hash.Update(fileNameUTF8.data(), fileNameUTF8.length());
 
    //    File Size;
    wxULongLong size = file.GetSize();
    wxULongLong fileSize = ((size != wxInvalidSize) ? size : 0);
    hash.Update(&fileSize, (sizeof fileSize));
 
    //    Mod time, in ticks
    wxDateTime t = file.GetModificationTime();
    wxULongLong fileTime = t.GetTicks();
    hash.Update(&fileTime, (sizeof fileTime));
  }
 
  hash.Finish();
  hash.Receive(&nacc);
 
  //    Return the calculated magic number
  new_magic = nacc.ToString();
 
  //    And do the test
  if (new_magic != magic)
    return true;
  else
    return false;
}
 
bool ChartDatabase::IsChartDirUsed(const wxString &theDir) {
  wxString dir(theDir);
  if (dir.Last() == '/' || dir.Last() == wxFileName::GetPathSeparator())
    dir.RemoveLast();
 
  dir.Append("*");
  for (UINT32 i = 0; i < active_chartTable.size(); i++) {
    auto &cte_u = GetChartTableEntry(i);
    if (cte_u.GetpsFullPath()->Matches(dir)) return true;
  }
  return false;
}
 
//-----------------------------------------------------------------------------
// Validate a given directory as a cm93 root database
// If it appears to be a cm93 database, then return true
//-----------------------------------------------------------------------------
bool ChartDatabase::Check_CM93_Structure(wxString dir_name) {
  wxString filespec;
 
  wxRegEx test("[0-9]+");
 
  wxDir dirt(dir_name);
  wxString candidate;
 
  if (dirt.IsOpened())
    wxLogMessage("check_cm93 opened dir OK:  " + dir_name);
  else {
    wxLogMessage("check_cm93 NOT OPENED OK:  " + dir_name);
    wxLogMessage("check_cm93 returns false." + dir_name);
    return false;
  }
 
  bool b_maybe_found_cm93 = false;
  bool b_cont = dirt.GetFirst(&candidate);
 
  while (b_cont) {
    if (test.Matches(candidate) && (candidate.Len() == 8)) {
      b_maybe_found_cm93 = true;
      break;
    }
 
    b_cont = dirt.GetNext(&candidate);
  }
 
  if (b_maybe_found_cm93) {
    wxString dir_next = dir_name;
    dir_next += "/";
    dir_next += candidate;
    if (wxDir::Exists(dir_next)) {
      wxDir dir_n(dir_next);
      if (dirt.IsOpened()) {
        wxString candidate_n;
 
        wxRegEx test_n("^[A-Ga-g]");
        bool b_probably_found_cm93 = false;
        bool b_cont_n = dir_n.IsOpened() && dir_n.GetFirst(&candidate_n);
        while (b_cont_n) {
          if (test_n.Matches(candidate_n) && (candidate_n.Len() == 1)) {
            b_probably_found_cm93 = true;
            break;
          }
          b_cont_n = dir_n.GetNext(&candidate_n);
        }
 
        if (b_probably_found_cm93)  // found a directory that looks
                                    // like {dir_name}/12345678/A
                                    // probably cm93
        {
          // make sure the dir exists
          wxString dir_luk = dir_next;
          dir_luk += "/";
          dir_luk += candidate_n;
          if (wxDir::Exists(dir_luk)) return true;
        }
      }
    }
  }
 
  return false;
}
 
/*
//-----------------------------------------------------------------------------
// Validate a given directory as a cm93 root database
// If it appears to be a cm93 database, then return the name of an existing cell
file
// File name will be unique with respect to member element m_cm93_filename_array
// If not cm93, return empty string
//-----------------------------------------------------------------------------
wxString ChartDatabase::Get_CM93_FileName(wxString dir_name)
{
      wxString filespec;
 
      wxRegEx test("[0-9]+");
 
      wxDir dirt(dir_name);
      wxString candidate;
 
      bool b_maybe_found_cm93 = false;
      bool b_cont = dirt.GetFirst(&candidate);
 
      while(b_cont)
      {
            if(test.Matches(candidate)&& (candidate.Len() == 8))
            {
                  b_maybe_found_cm93 = true;
                  break;
            }
 
            b_cont = dirt.GetNext(&candidate);
 
      }
 
      if(b_maybe_found_cm93)
      {
            wxString dir_next = dir_name;
            dir_next += "/";
            dir_next += candidate;
            if(wxDir::Exists(dir_next))
            {
                  wxDir dir_n(dir_next);
                  wxString candidate_n;
 
                  wxRegEx test_n("^[A-Ga-g]");
                  bool b_probably_found_cm93 = false;
                  bool b_cont_n = dir_n.GetFirst(&candidate_n);
                  while(b_cont_n)
                  {
                        if(test_n.Matches(candidate_n) && (candidate_n.Len() ==
1))
                        {
                              b_probably_found_cm93 = true;
                              break;
                        }
                        b_cont_n = dir_n.GetNext(&candidate_n);
                  }
 
                  if(b_probably_found_cm93)           // found a directory that
looks like {dir_name}/12345678/A   probably cm93 { // and we want to try and
shorten the recursive search
                        // make sure the dir exists
                        wxString dir_luk = dir_next;
                        dir_luk += "/";
                        dir_luk += candidate_n;
                        if(wxDir::Exists(dir_luk))
                        {
                              wxString msg("Found probable CM93 database in
"); msg += dir_name; wxLogMessage(msg);
 
                              wxString dir_name_plus = dir_luk; // be very
specific about the dir_name,
 
                              wxDir dir_get(dir_name_plus);
                              wxString one_file;
                              dir_get.GetFirst(&one_file);
 
                              //    We must return a unique file name, i.e. one
that has not bee seen
                              //    before in this invocation of chart dir
scans. bool find_unique = false; while(!find_unique)
                              {
                                    find_unique = true;
                                    for(unsigned int ifile=0; ifile <
m_cm93_filename_array.GetCount(); ifile++)
                                    {
                                          if(m_cm93_filename_array[ifile] ==
one_file) find_unique = false;
                                    }
                                    if(!find_unique)
                                          dir_get.GetNext(&one_file);
                              }
 
                              m_cm93_filename_array.Add(one_file);
 
                              filespec = one_file;
                        }
 
                  }
            }
      }
 
      return filespec;
}
*/
 
int ChartDatabase::SearchDirAndAddCharts(wxString &dir_name_base,
                                         ChartClassDescriptor &chart_desc,
                                         wxGenericProgressDialog *pprog) {
  wxString msg("Searching directory: ");
  msg += dir_name_base;
  msg += " for ";
  msg += chart_desc.m_search_mask;
  wxLogMessage(msg);
 
  wxString dir_name = dir_name_base;
 
#ifdef __ANDROID__
  dir_name = wxString(dir_name_base.mb_str(wxConvUTF8));  // android
#endif
 
  if (!wxDir::Exists(dir_name)) return 0;
 
  wxString filespec = chart_desc.m_search_mask.Upper();
  wxString lowerFileSpec = chart_desc.m_search_mask.Lower();
  wxString filespecXZ = filespec + ".xz";
  wxString lowerFileSpecXZ = lowerFileSpec + ".xz";
  wxString filename;
 
  //    Count the files
  wxArrayString FileList;
  int gaf_flags = wxDIR_DEFAULT;  // as default, recurse into subdirs
 
  //    Here is an optimization for MSW/cm93 especially
  //    If this directory seems to be a cm93, and we are not explicitely looking
  //    for cm93, then abort Otherwise, we will be looking thru entire cm93 tree
  //    for non-existent .KAP files, etc.
 
  bool b_found_cm93 = false;
  bool b_cm93 = Check_CM93_Structure(dir_name);
  if (b_cm93) {
    if (filespec != "00300000.A")
      return false;
    else {
      filespec = dir_name;
      b_found_cm93 = true;
    }
  }
 
  if (!b_found_cm93) {
    wxDir dir(dir_name);
    dir.GetAllFiles(dir_name, &FileList, filespec, gaf_flags);
 
#ifdef __ANDROID__
    if (!FileList.GetCount()) {
      wxArrayString afl = androidTraverseDir(dir_name, filespec);
      for (wxArrayString::const_iterator item = afl.begin(); item != afl.end();
           item++)
        FileList.Add(*item);
    }
#endif
 
#ifndef __WXMSW__
    if (filespec != lowerFileSpec) {
      // add lowercase filespec files too
      wxArrayString lowerFileList;
      dir.GetAllFiles(dir_name, &lowerFileList, lowerFileSpec, gaf_flags);
 
#ifdef __ANDROID__
      if (!lowerFileList.GetCount()) {
        wxArrayString afl = androidTraverseDir(dir_name, lowerFileSpec);
        for (wxArrayString::const_iterator item = afl.begin();
             item != afl.end(); item++)
          lowerFileList.Add(*item);
      }
#endif
 
      for (wxArrayString::const_iterator item = lowerFileList.begin();
           item != lowerFileList.end(); item++)
        FileList.Add(*item);
    }
#endif
 
#ifdef OCPN_USE_LZMA
    // add xz compressed files;
    dir.GetAllFiles(dir_name, &FileList, filespecXZ, gaf_flags);
    dir.GetAllFiles(dir_name, &FileList, lowerFileSpecXZ, gaf_flags);
#endif
 
    FileList.Sort();  // Sorted processing order makes the progress bar more
                      // meaningful to the user.
  } else {            // This is a cm93 dataset, specified as yada/yada/cm93
    wxString dir_plus = dir_name;
    dir_plus += wxFileName::GetPathSeparator();
    FileList.Add(dir_plus);
  }
 
  int nFile = FileList.GetCount();
 
  if (!nFile) return false;
 
  int nDirEntry = 0;
 
  //    Check to see if there are any charts in the DB which refer to this
  //    directory If none at all, there is no need to scan the DB for fullpath
  //    match of each potential addition and bthis_dir_in_dB is false.
  // bool bthis_dir_in_dB = IsChartDirUsed(dir_name);
 
  if (pprog) pprog->SetTitle(_("OpenCPN Chart Add...."));
 
  // build a hash table based on filename (without directory prefix) of
  // the chart to fast detect identical charts
  ChartCollisionsHashMap collision_map;
  //  int nEntry = active_chartTable.GetCount();
  //  for (int i = 0; i < nEntry; i++) {
  //    wxString table_file_name = active_chartTable[i].GetFullSystemPath();
  //    wxFileName table_file(table_file_name);
  //    collision_map[table_file.GetFullName()] = i;
  //  }
 
  // Capture a vector of pending thread tickets for this directory
  std::vector<std::shared_ptr<ChartTableEntryJobTicket>> ticket_vector;
 
  for (int ifile = 0; ifile < nFile; ifile++) {
    wxFileName file(FileList[ifile]);
    wxString full_path = file.GetFullPath();
    wxString file_name = file.GetFullName();
    wxString utf8_path = full_path;
 
#ifdef __ANDROID__
    // The full path (full_name) is the broken Android files system
    // interpretation, which does not display well onscreen. So, here we
    // reconstruct a full path spec in UTF-8 encoding for later use in string
    // displays. This utf-8 string will be used to construct the chart database
    // entry if required.
    wxFileName fnbase(dir_name_base);
    int nDirs = fnbase.GetDirCount();
 
    wxFileName file_target(FileList[ifile]);
 
    for (int i = 0; i < nDirs + 1;
         i++)  // strip off the erroneous intial directories
      file_target.RemoveDir(0);
 
    wxString leftover_path = file_target.GetFullPath();
    utf8_path =
        dir_name_base + leftover_path;  // reconstruct a fully utf-8 version
#endif
 
    //    Validate the file name again, considering MSW's semi-random treatment
    //    of case....
    // TODO...something fishy here - may need to normalize saved name?
    if (!file_name.Matches(lowerFileSpec) && !file_name.Matches(filespec) &&
        !file_name.Matches(lowerFileSpecXZ) && !file_name.Matches(filespecXZ) &&
        !b_found_cm93) {
      // wxLogMessage("FileSpec test failed for:" + file_name);
      continue;
    }
 
    ChartTableEntry *pnewChart = NULL;
    bool bAddFinal = true;
    int b_add_msg = 0;
 
#if 0  // TODO  Fix?
    // Check the collisions map looking for duplicates in directories already
    // processed, and choosing the right one.
//    ChartCollisionsHashMap::const_iterator collision_ptr =
//        collision_map.find(file_name);
//    bool collision = (collision_ptr != collision_map.end());
//    bool file_path_is_same = false;
//    bool file_time_is_same = false;
//    ChartTableEntry *pEntry = NULL;
//    wxString table_file_name;
 
 
    //  Allow multiple cm93 chart sets #4217
    if (b_found_cm93) collision = false;
 
    if (collision) {
      pEntry = &active_chartTable[collision_ptr->second];
      table_file_name = pEntry->GetFullSystemPath();
      file_path_is_same =
          bthis_dir_in_dB && full_name.IsSameAs(table_file_name);
 
      // If the chart full file paths are exactly the same, select the newer
      // one.
      if (file_path_is_same) {
        b_add_msg++;
 
        //    Check the file modification time
        time_t t_oldFile = pEntry->GetFileTime();
        time_t t_newFile = file.GetModificationTime().GetTicks();
 
        if (t_newFile <= t_oldFile) {
          file_time_is_same = true;
          bAddFinal = false;
          pEntry->SetValid(true);
        } else {
          bAddFinal = true;
          pEntry->SetValid(false);
        }
      }
    }
#endif
 
    //  Check for duplicates within this directory
    bool collision_found = false;
    ChartCollisionsHashMap::iterator it;
    for (it = collision_map.begin(); it != collision_map.end(); ++it) {
      if (it->first.IsSameAs(file_name)) {
        // Two files found with identical file name
        // For now, just drop this ticket
        // TODO Make an (expensive) test on file modification times
        collision_found = true;
        break;
      }
    }
 
    if (!collision_found) {
      // Create a ticket for this chart
      auto ticket = std::make_shared<ChartTableEntryJobTicket>();
      ticket->m_ChartPath = full_path;
      ticket->m_ChartPathUTF8 = full_path;
      ticket->chart_desc = chart_desc;
 
      ticket_vector.push_back(ticket);
      collision_map[file_name] = ifile;
    }
 
  }  // the big loop
 
  // Built-in chart types are all thread-safe
  // Check plugin charts
  bool is_kap = false;  // chart_desc.m_class_name.IsSameAs("ChartKAP");
  if (chart_desc.m_descriptor_type == PLUGIN_DESCRIPTOR || is_kap) {
    // Check plugin charts API.  API >- 118 are known to be thread-safe
    opencpn_plugin *plugin = chart_desc.m_plugin;
    opencpn_plugin_118 *provider_plugin118 = dynamic_cast<opencpn_plugin_118 *>(
        dynamic_cast<opencpn_plugin *>(plugin));
 
    if (!provider_plugin118 || is_kap) {
      // old plugin, charts not thread-safe
      // So arrange to process the tickets in the main app thread,
      // during the event handler, at the end of the queue processing
      for (auto &ticket : ticket_vector) {
        ticket->b_thread_safe = false;
        ticket->m_provider_type = 1;
        ticket->provider_class_name = chart_desc.m_class_name;
        m_deferred_ticket_vector.push_back(ticket);
      }
      return nDirEntry;
    }
  }
 
  // Chart directory is known thread-safe
  // load the thread pool from the prepared array
  // Enqueue jobs
  for (auto &ticket : ticket_vector) {
    m_pool.Push(ticket);
    m_jobsRemaining++;
  }
 
  // Tickets queued, wait for completion events
  return nDirEntry;
}
 
bool ChartDatabase::AddChart(wxString &chartfilename,
                             ChartClassDescriptor &chart_desc,
                             wxGenericProgressDialog *pprog, int isearch,
                             bool bthis_dir_in_dB) {
  bool rv = false;
  wxFileName file(chartfilename);
  wxString full_name = file.GetFullPath();
  wxString file_name = file.GetFullName();
 
  //    Validate the file name again, considering MSW's semi-random treatment of
  //    case....
  // TODO...something fishy here - may need to normalize saved name?
  //    if(!file_name.Matches(lowerFileSpec) && !file_name.Matches(filespec) &&
  //    !b_found_cm93)
  //        continue;
 
  if (pprog)
    pprog->Update(wxMin((m_pdifile * 100) / m_pdnFile, 100), full_name);
 
  ChartTableEntry *pnewChart = NULL;
  bool bAddFinal = true;
  int b_add_msg = 0;
  wxString msg_fn(full_name);
  msg_fn.Replace("%", "%%");
 
  pnewChart = CreateChartTableEntry(full_name, full_name, chart_desc);
  if (!pnewChart) {
    bAddFinal = false;
    wxLogMessage(wxString::Format(
        "   CreateChartTableEntry() failed for file: %s", msg_fn.c_str()));
    return false;
  } else  // traverse the existing database looking for duplicates, and choosing
          // the right one
  {
    int nEntry = active_chartTable.size();
    for (int i = 0; i < nEntry; i++) {
      auto &cte_a = GetChartTableEntry(i);
      wxString *ptable_file_name = cte_a.GetpsFullPath();
 
      //    If the chart full file paths are exactly the same, select the newer
      //    one
      if (bthis_dir_in_dB && full_name.IsSameAs(*ptable_file_name)) {
        b_add_msg++;
 
        //    Check the file modification time
        auto &cte_search = GetChartTableEntry(isearch);
        time_t t_oldFile = cte_search.GetFileTime();
        time_t t_newFile = file.GetModificationTime().GetTicks();
 
        if (t_newFile <= t_oldFile) {
          bAddFinal = false;
          cte_search.SetValid(true);
        } else {
          bAddFinal = true;
          cte_search.SetValid(false);
          wxLogMessage(
              wxString::Format("   Replacing older chart file of same path: %s",
                               msg_fn.c_str()));
        }
 
        break;
      }
 
      //  Look at the chart file name (without directory prefix) for a further
      //  check for duplicates This catches the case in which the "same" chart
      //  is in different locations, and one may be newer than the other.
      wxFileName table_file(*ptable_file_name);
 
      if (table_file.GetFullName() == file_name) {
        b_add_msg++;
 
        // TODO fix this...
#if 0
        if (pnewChart->IsEarlierThan(active_chartTable[isearch])) {
          //    Make sure the compare file actually exists
          if (table_file.IsFileReadable()) {
            active_chartTable[isearch].SetValid(true);
            bAddFinal = false;
            wxLogMessage(wxString::Format(
                "   Retaining newer chart file of same name: %s",
                msg_fn.c_str()));
          }
        } else if (pnewChart->IsEqualTo(active_chartTable[isearch])) {
          //    The file names (without dir prefix) are identical,
          //    and the mod times are identical
          //    Prsume that this is intentional, in order to facilitate
          //    having the same chart in multiple groups.
          //    So, add this chart.
          bAddFinal = true;
        }
 
        else {
          active_chartTable[isearch].SetValid(false);
          bAddFinal = true;
          wxLogMessage(
              wxString::Format("   Replacing older chart file of same name: %s",
                               msg_fn.c_str()));
        }
#endif
        break;
      }
 
      // TODO    Look at the chart ID as a further check against duplicates
 
      isearch++;
      if (nEntry == isearch) isearch = 0;
    }  // for
  }
 
  if (bAddFinal) {
    if (0 == b_add_msg) {
      wxLogMessage(
          wxString::Format("   Adding chart file: %s", msg_fn.c_str()));
    }
    std::shared_ptr<ChartTableEntry> sharedPtr(pnewChart);
    active_chartTable.push_back(sharedPtr);
    rv = true;
  } else {
    delete pnewChart;
    //                  wxLogMessage(wxString::Format("   Not adding chart
    //                  file: %s", msg_fn.c_str()));
    rv = false;
  }
 
  m_nentries = active_chartTable.size();
 
  return rv;
}
 
bool ChartDatabase::AddSingleChart(wxString &ChartFullPath,
                                   bool b_force_full_search) {
  //  Find a relevant chart class descriptor
  wxFileName fn(ChartFullPath);
  wxString ext = fn.GetExt();
  ext.Prepend("*.");
  wxString ext_upper = ext.MakeUpper();
  wxString ext_lower = ext.MakeLower();
  wxString dir_name = fn.GetPath();
 
  //    Search the array of chart class descriptors to find a match
  //    between the search mask and the chart file extension
 
  ChartClassDescriptor desc;
  for (auto &cd : m_ChartClassDescriptorArray) {
    if (cd.m_descriptor_type == PLUGIN_DESCRIPTOR) {
      if (cd.m_search_mask == ext_upper) {
        desc = cd;
        break;
      }
      if (cd.m_search_mask == ext_lower) {
        desc = cd;
        break;
      }
    }
  }
 
  //  If we know that we need to do a full recursive search of the db,
  //  then there is no need to verify it by doing a directory match
  bool b_recurse = true;
  if (!b_force_full_search) b_recurse = IsChartDirUsed(dir_name);
 
  bool rv = AddChart(ChartFullPath, desc, NULL, 0, b_recurse);
 
  //  remove duplicates marked in AddChart()
 
  for (unsigned int i = 0; i < active_chartTable.size(); i++) {
    auto &cte_r = GetChartTableEntry(i);
    if (!cte_r.GetbValid()) {
      // TODO fix this
      // active_chartTable.RemoveAt(i);
      i--;  // entry is gone, recheck this index for next entry
    }
  }
 
  //    Update the Entry index fields
  for (unsigned int i = 0; i < active_chartTable.size(); i++) {
    auto &cte_ef = GetChartTableEntry(i);
    cte_ef.SetEntryOffset(i);
  }
 
  //  Get a new magic number
  wxString new_magic;
  DetectDirChange(dir_name, "", "", new_magic, 0);
 
  //    Update (clone) the CDI array
  bool bcfound = false;
  ArrayOfCDI NewChartDirArray;
 
  ArrayOfCDI ChartDirArray = GetChartDirArray();
  for (unsigned int i = 0; i < ChartDirArray.GetCount(); i++) {
    ChartDirInfo cdi = ChartDirArray[i];
 
    ChartDirInfo newcdi = cdi;
 
    //      If entry is found that matches this cell, clear the magic number.
    if (newcdi.fullpath == dir_name) {
      newcdi.magic_number = new_magic;
      bcfound = true;
    }
 
    NewChartDirArray.Add(newcdi);
  }
 
  if (!bcfound) {
    ChartDirInfo cdi;
    cdi.fullpath = dir_name;
    cdi.magic_number = new_magic;
    NewChartDirArray.Add(cdi);
  }
 
  // Update the database master copy of the CDI array
  SetChartDirArray(NewChartDirArray);
 
  //  Update the list of chart dirs.
  m_chartDirs.Clear();
 
  for (unsigned int i = 0; i < GetChartDirArray().GetCount(); i++) {
    ChartDirInfo cdi = GetChartDirArray()[i];
    m_chartDirs.Add(cdi.fullpath);
  }
 
  m_nentries = active_chartTable.size();
 
  ChartData->UpdateChartDatabaseInplace(NewChartDirArray, false, nullptr);
  return rv;
}
 
bool ChartDatabase::RemoveSingleChart(wxString &ChartFullPath) {
  bool rv = false;
 
  //  Walk the chart table, looking for the target
  for (unsigned int i = 0; i < active_chartTable.size(); i++) {
    auto &cte = GetChartTableEntry(i);
    if (ChartFullPath.IsSameAs(cte.GetFullSystemPath())) {
      // Fast remove element, order not preserved
      std::swap(active_chartTable[i], active_chartTable.back());
      active_chartTable.pop_back();
      break;
    }
  }
 
  //    Update the EntryOffset fields for the array
  for (unsigned int i = 0; i < active_chartTable.size(); i++) {
    auto &pcte = GetChartTableEntry(i);
    pcte.SetEntryOffset(i);
  }
 
  //  Check and update the dir array
  wxFileName fn(ChartFullPath);
  wxString fd = fn.GetPath();
  if (!IsChartDirUsed(fd)) {
    //      Clone a new array, removing the unused directory,
    ArrayOfCDI NewChartDirArray;
 
    ArrayOfCDI ChartDirArray = GetChartDirArray();
    for (unsigned int i = 0; i < ChartDirArray.GetCount(); i++) {
      ChartDirInfo cdi = ChartDirArray[i];
 
      ChartDirInfo newcdi = cdi;
 
      if (newcdi.fullpath != fd) NewChartDirArray.Add(newcdi);
    }
 
    SetChartDirArray(NewChartDirArray);
  }
 
  //  Update the list of chart dirs.
  m_chartDirs.Clear();
  for (unsigned int i = 0; i < GetChartDirArray().GetCount(); i++) {
    ChartDirInfo cdi = GetChartDirArray()[i];
    m_chartDirs.Add(cdi.fullpath);
  }
 
  m_nentries = active_chartTable.size();
  ChartData->UpdateChartDatabaseInplace(m_dir_array, false, nullptr);
 
  return rv;
}
 
// Create a Chart object
 
ChartBase *ChartDatabase::GetChart(const wxChar *theFilePath,
                                   ChartClassDescriptor &chart_desc) const {
  // TODO: support non-UI chart factory
  return NULL;
}
 
// Create Chart Table entry by reading chart header info, etc.
 
ChartTableEntry *ChartDatabase::CreateChartTableEntry(
    const wxString &filePath, wxString &utf8Path,
    ChartClassDescriptor &chart_desc) {
  wxString msg_fn(filePath);
  msg_fn.Replace("%", "%%");
  wxLogMessage(wxString::Format("Loading chart data for %s", msg_fn.c_str()));
 
#ifdef __ANDROID__
  qDebug() << "   CCTE: " << filePath.ToStdString().c_str();
#endif
  ChartBase *pch = GetChart(filePath, chart_desc);
  if (pch == NULL) {
    wxLogMessage(
        wxString::Format("   ...creation failed for %s", msg_fn.c_str()));
    return NULL;
  }
 
  InitReturn rc = pch->Init(filePath, HEADER_ONLY);
  if (rc != INIT_OK) {
    delete pch;
    wxLogMessage(
        wxString::Format("   ...initialization failed for %s", msg_fn.c_str()));
    return NULL;
  }
 
  ChartTableEntry *ret_val = new ChartTableEntry(*pch, utf8Path);
  ret_val->SetValid(true);
 
  delete pch;
 
  return ret_val;
}
 
bool ChartDatabase::GetCentroidOfLargestScaleChart(double *clat, double *clon,
                                                   ChartFamilyEnum family) {
  int cur_max_i = -1;
  int cur_max_scale = 0;
 
  int nEntry = active_chartTable.size();
 
  for (int i = 0; i < nEntry; i++) {
    auto &cte_fam = GetChartTableEntry(i);
    if (GetChartFamily(cte_fam.GetChartType()) == family) {
      if (cte_fam.GetScale() > cur_max_scale) {
        cur_max_scale = cte_fam.GetScale();
        cur_max_i = i;
      }
    }
  }
 
  if (cur_max_i == -1)
    return false;  // nothing found
  else {
    auto &cte_sel = GetChartTableEntry(cur_max_i);
    *clat = (cte_sel.GetLatMax() + cte_sel.GetLatMin()) / 2.;
    *clon = (cte_sel.GetLonMin() + cte_sel.GetLonMax()) / 2.;
  }
  return true;
}
 
//-------------------------------------------------------------------
//    Get DBChart Projection
//-------------------------------------------------------------------
int ChartDatabase::GetDBChartProj(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &cte = GetChartTableEntry(dbIndex);
    return cte.GetChartProjectionType();
  } else
    return PROJECTION_UNKNOWN;
}
 
//-------------------------------------------------------------------
//    Get DBChart Family
//-------------------------------------------------------------------
int ChartDatabase::GetDBChartFamily(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &cte = GetChartTableEntry(dbIndex);
    return cte.GetChartFamily();
  } else
    return CHART_FAMILY_UNKNOWN;
}
 
//-------------------------------------------------------------------
//    Get DBChart FullFileName
//-------------------------------------------------------------------
wxString ChartDatabase::GetDBChartFileName(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &cte = GetChartTableEntry(dbIndex);
    return wxString(cte.GetFullSystemPath());
  } else
    return "";
}
 
//-------------------------------------------------------------------
//    Get DBChart Type
//-------------------------------------------------------------------
int ChartDatabase::GetDBChartType(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &cte = GetChartTableEntry(dbIndex);
    return cte.GetChartType();
  } else
    return 0;
}
 
//-------------------------------------------------------------------
//    Get DBChart Skew
//-------------------------------------------------------------------
float ChartDatabase::GetDBChartSkew(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &cte = GetChartTableEntry(dbIndex);
    return cte.GetChartSkew();
  } else
    return 0.;
}
 
//-------------------------------------------------------------------
//    Get DBChart Scale
//-------------------------------------------------------------------
int ChartDatabase::GetDBChartScale(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &cte = GetChartTableEntry(dbIndex);
    return cte.GetScale();
  } else
    return 1;
}
 
//-------------------------------------------------------------------
//    Get Lat/Lon Bounding Box from db
//-------------------------------------------------------------------
bool ChartDatabase::GetDBBoundingBox(int dbIndex, LLBBox &box) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &entry = GetChartTableEntry(dbIndex);
    box.Set(entry.GetLatMin(), entry.GetLonMin(), entry.GetLatMax(),
            entry.GetLonMax());
  }
 
  return true;
}
 
const LLBBox &ChartDatabase::GetDBBoundingBox(int dbIndex) {
  if ((bValid) && (dbIndex >= 0)) {
    auto &entry = GetChartTableEntry(dbIndex);
    return entry.GetBBox();
  } else {
    return m_dummy_bbox;
  }
}
 
//-------------------------------------------------------------------
//    Get PlyPoint from Database
//-------------------------------------------------------------------
int ChartDatabase::GetDBPlyPoint(int dbIndex, int plyindex, float *lat,
                                 float *lon) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    const ChartTableEntry &entry = GetChartTableEntry(dbIndex);
    if (entry.GetnPlyEntries()) {
      float *fp = entry.GetpPlyTable();
      fp += plyindex * 2;
      if (lat) *lat = *fp;
      fp++;
      if (lon) *lon = *fp;
    }
    return entry.GetnPlyEntries();
  } else
    return 0;
}
 
//-------------------------------------------------------------------
//    Get AuxPlyPoint from Database
//-------------------------------------------------------------------
int ChartDatabase::GetDBAuxPlyPoint(int dbIndex, int plyindex, int ply,
                                    float *lat, float *lon) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    const ChartTableEntry &entry = GetChartTableEntry(dbIndex);
    if (entry.GetnAuxPlyEntries()) {
      float *fp = entry.GetpAuxPlyTableEntry(ply);
 
      fp += plyindex * 2;
      if (lat) *lat = *fp;
      fp++;
      if (lon) *lon = *fp;
    }
 
    return entry.GetAuxCntTableEntry(ply);
  } else
    return 0;
}
 
int ChartDatabase::GetnAuxPlyEntries(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    const ChartTableEntry &entry = GetChartTableEntry(dbIndex);
    return entry.GetnAuxPlyEntries();
  } else
    return 0;
}
 
//-------------------------------------------------------------------
//      Get vector of reduced Plypoints
//-------------------------------------------------------------------
std::vector<float> ChartDatabase::GetReducedPlyPoints(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    ChartTableEntry &cte = GetChartTableEntry(dbIndex);
    return cte.GetReducedPlyPoints();
  }
 
  std::vector<float> dummy;
  return dummy;
}
 
//-------------------------------------------------------------------
//      Get vector of reduced AuxPlypoints
//-------------------------------------------------------------------
std::vector<float> ChartDatabase::GetReducedAuxPlyPoints(int dbIndex,
                                                         int iTable) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &cte = GetChartTableEntry(dbIndex);
    return cte.GetReducedAuxPlyPoints(iTable);
  }
 
  std::vector<float> dummy;
  return dummy;
}
 
bool ChartDatabase::IsChartAvailable(int dbIndex) {
  if ((bValid) && (dbIndex >= 0) && (dbIndex < (int)active_chartTable.size())) {
    auto &cte = GetChartTableEntry(dbIndex);
 
    //      If not PLugIn chart, assume always available
    if (cte.GetChartType() != CHART_TYPE_PLUGIN) return true;
 
    wxString *path = cte.GetpsFullPath();
    wxFileName fn(*path);
    wxString ext = fn.GetExt();
    ext.Prepend("*.");
    wxString ext_upper = ext.MakeUpper();
    wxString ext_lower = ext.MakeLower();
 
    //    Search the array of chart class descriptors to find a match
    //    between the search mask and the the chart file extension
 
    for (auto &cd : m_ChartClassDescriptorArray) {
      if (cd.m_descriptor_type == PLUGIN_DESCRIPTOR) {
        wxString search_mask = cd.m_search_mask;
 
        if (search_mask == ext_upper) {
          return true;
        }
        if (search_mask == ext_lower) {
          return true;
        }
        if (path->Matches(search_mask)) {
          return true;
        }
      }
    }
  }
 
  return false;
}
 
void ChartDatabase::ApplyGroupArray(ChartGroupArray *pGroupArray) {
  wxString separator(wxFileName::GetPathSeparator());
 
  for (unsigned int ic = 0; ic < active_chartTable.size(); ic++) {
    auto &cte = GetChartTableEntry(ic);
 
    cte.ClearGroupArray();
 
    wxString *chart_full_path = cte.GetpsFullPath();
 
    for (unsigned int igroup = 0; igroup < pGroupArray->GetCount(); igroup++) {
      ChartGroup *pGroup = pGroupArray->Item(igroup);
      for (const auto &elem : pGroup->m_element_array) {
        wxString element_root = elem.m_element_name;
 
        //  The element may be a full single chart name
        //  If so, add it
        //  Otherwise, append a sep character so that similar paths are
        //  distinguished. See FS#1060
        if (!chart_full_path->IsSameAs(element_root))
          element_root.Append(
              separator);  // Prevent comingling similar looking path names
        if (chart_full_path->StartsWith(element_root)) {
          bool b_add = true;
          for (unsigned int k = 0; k < elem.m_missing_name_array.size(); k++) {
            const wxString &missing_item = elem.m_missing_name_array[k];
            if (chart_full_path->StartsWith(missing_item)) {
              if (chart_full_path->IsSameAs(
                      missing_item))  // missing item is full chart name
              {
                b_add = false;
                break;
              } else {
                if (wxDir::Exists(missing_item))  // missing item is a dir
                {
                  b_add = false;
                  break;
                }
              }
            }
          }
 
          if (b_add) cte.AddIntToGroupArray(igroup + 1);
        }
      }
    }
  }
}