/src/gdal/ogr/ogrsf_frmts/wfs/ogrwfsdatasource.cpp

Source
/******************************************************************************
 *
 * Project:  WFS Translator
 * Purpose:  Implements OGRWFSDataSource class
 * Author:   Even Rouault, even dot rouault at spatialys.com
 *
 ******************************************************************************
 * Copyright (c) 2010-2013, Even Rouault <even dot rouault at spatialys.com>
 *
 * SPDX-License-Identifier: MIT
 ****************************************************************************/

#include "cpl_port.h"
#include "ogr_wfs.h"
#include "ogr_api.h"
#include "cpl_minixml.h"
#include "cpl_http.h"
#include "gmlutils.h"
#include "parsexsd.h"
#include "ogr_swq.h"
#include "ogr_p.h"
#include "ogrwfsfilter.h"
#include "memdataset.h"

#include <algorithm>

typedef struct
{
    const char *pszPath;
    const char *pszMDI;
} MetadataItem;

static const MetadataItem asMetadata[] = {
    {"Service.Title", "TITLE"},                        /*1.0 */
    {"ServiceIdentification.Title", "TITLE"},          /* 1.1 or 2.0 */
    {"Service.Abstract", "ABSTRACT"},                  /* 1.0 */
    {"ServiceIdentification.Abstract", "ABSTRACT"},    /* 1.1 or 2.0 */
    {"ServiceProvider.ProviderName", "PROVIDER_NAME"}, /* 1.1 or 2.0 */
};

/************************************************************************/
/*                            WFSFindNode()                             */
/************************************************************************/

const CPLXMLNode *WFSFindNode(const CPLXMLNode *psXML, const char *pszRootName)
{
    const CPLXMLNode *psIter = psXML;
    do
    {
        if (psIter->eType == CXT_Element)
        {
            const char *pszNodeName = psIter->pszValue;
            const char *pszSep = strchr(pszNodeName, ':');
            if (pszSep)
                pszNodeName = pszSep + 1;
            if (EQUAL(pszNodeName, pszRootName))
            {
                return psIter;
            }
        }
        psIter = psIter->psNext;
    } while (psIter);

    psIter = psXML->psChild;
    while (psIter)
    {
        if (psIter->eType == CXT_Element)
        {
            const char *pszNodeName = psIter->pszValue;
            const char *pszSep = strchr(pszNodeName, ':');
            if (pszSep)
                pszNodeName = pszSep + 1;
            if (EQUAL(pszNodeName, pszRootName))
            {
                return psIter;
            }
        }
        psIter = psIter->psNext;
    }
    return nullptr;
}

/************************************************************************/
/*                       OGRWFSWrappedResultLayer                       */
/************************************************************************/

class OGRWFSWrappedResultLayer final : public OGRLayer
{
    std::unique_ptr<GDALDataset> poDS{};
    OGRLayer *poLayer = nullptr;

    CPL_DISALLOW_COPY_ASSIGN(OGRWFSWrappedResultLayer)

  public:
    OGRWFSWrappedResultLayer(GDALDataset *poDSIn, OGRLayer *poLayerIn)
        : poDS(poDSIn), poLayer(poLayerIn)
    {
    }

    void ResetReading() override;

    OGRFeature *GetNextFeature() override
    {
        return poLayer->GetNextFeature();
    }

    OGRErr SetNextByIndex(GIntBig nIndex) override
    {
        return poLayer->SetNextByIndex(nIndex);
    }

    OGRFeature *GetFeature(GIntBig nFID) override
    {
        return poLayer->GetFeature(nFID);
    }

    const OGRFeatureDefn *GetLayerDefn() const override
    {
        return poLayer->GetLayerDefn();
    }

    GIntBig GetFeatureCount(int bForce = TRUE) override
    {
        return poLayer->GetFeatureCount(bForce);
    }

    bool TestCapability(const char *pszCap) const override
    {
        return poLayer->TestCapability(pszCap);
    }
};

void OGRWFSWrappedResultLayer::ResetReading()
{
    poLayer->ResetReading();
}

/************************************************************************/
/*                          OGRWFSDataSource()                          */
/************************************************************************/

OGRWFSDataSource::OGRWFSDataSource()
    : bPagingAllowed(
          CPLTestBool(CPLGetConfigOption("OGR_WFS_PAGING_ALLOWED", "OFF"))),
      bLoadMultipleLayerDefn(CPLTestBool(
          CPLGetConfigOption("OGR_WFS_LOAD_MULTIPLE_LAYER_DEFN", "TRUE")))
{
    if (bPagingAllowed)
    {
        const char *pszOption =
            CPLGetConfigOption("OGR_WFS_PAGE_SIZE", nullptr);
        if (pszOption != nullptr)
        {
            nPageSize = atoi(pszOption);
            if (nPageSize <= 0)
                nPageSize = DEFAULT_PAGE_SIZE;
        }

        pszOption = CPLGetConfigOption("OGR_WFS_BASE_START_INDEX", nullptr);
        if (pszOption != nullptr)
            nBaseStartIndex = atoi(pszOption);
    }
}

/************************************************************************/
/*                         ~OGRWFSDataSource()                          */
/************************************************************************/

OGRWFSDataSource::~OGRWFSDataSource()

{
    if (psFileXML)
    {
        if (bRewriteFile)
        {
            CPLSerializeXMLTreeToFile(psFileXML, GetDescription());
        }

        CPLDestroyXMLNode(psFileXML);
    }

    for (int i = 0; i < nLayers; i++)
        delete papoLayers[i];
    CPLFree(papoLayers);

    if (!osLayerMetadataTmpFileName.empty())
        VSIUnlink(osLayerMetadataTmpFileName);
    delete poLayerMetadataDS;
    delete poLayerGetCapabilitiesDS;

    CSLDestroy(papszIdGenMethods);
    CSLDestroy(papszHttpOptions);
}

/************************************************************************/
/*                              GetLayer()                              */
/************************************************************************/

const OGRLayer *OGRWFSDataSource::GetLayer(int iLayer) const

{
    if (iLayer < 0 || iLayer >= nLayers)
        return nullptr;
    else
        return papoLayers[iLayer];
}

/************************************************************************/
/*                           GetLayerByName()                           */
/************************************************************************/

OGRLayer *OGRWFSDataSource::GetLayerByName(const char *pszNameIn)
{
    if (!pszNameIn)
        return nullptr;

    if (EQUAL(pszNameIn, "WFSLayerMetadata"))
    {
        if (!osLayerMetadataTmpFileName.empty())
            return poLayerMetadataLayer;

        osLayerMetadataTmpFileName =
            VSIMemGenerateHiddenFilename("WFSLayerMetadata.csv");
        osLayerMetadataCSV = "layer_name,title,abstract\n" + osLayerMetadataCSV;

        VSIFCloseL(VSIFileFromMemBuffer(
            osLayerMetadataTmpFileName,
            reinterpret_cast<GByte *>(osLayerMetadataCSV.data()),
            osLayerMetadataCSV.size(), FALSE));
        poLayerMetadataDS =
            GDALDataset::Open(osLayerMetadataTmpFileName, GDAL_OF_VECTOR,
                              nullptr, nullptr, nullptr);
        if (poLayerMetadataDS)
            poLayerMetadataLayer = poLayerMetadataDS->GetLayer(0);
        return poLayerMetadataLayer;
    }
    else if (EQUAL(pszNameIn, "WFSGetCapabilities"))
    {
        if (poLayerGetCapabilitiesLayer != nullptr)
            return poLayerGetCapabilitiesLayer;

        poLayerGetCapabilitiesDS = MEMDataset::Create(
            "WFSGetCapabilities", 0, 0, 0, GDT_Unknown, nullptr);
        poLayerGetCapabilitiesLayer = poLayerGetCapabilitiesDS->CreateLayer(
            "WFSGetCapabilities", nullptr, wkbNone, nullptr);
        OGRFieldDefn oFDefn("content", OFTString);
        CPL_IGNORE_RET_VAL(poLayerGetCapabilitiesLayer->CreateField(&oFDefn));
        OGRFeature *poFeature =
            new OGRFeature(poLayerGetCapabilitiesLayer->GetLayerDefn());
        poFeature->SetField(0, osGetCapabilities);
        CPL_IGNORE_RET_VAL(
            poLayerGetCapabilitiesLayer->CreateFeature(poFeature));
        delete poFeature;

        return poLayerGetCapabilitiesLayer;
    }

    int nIndex = GetLayerIndex(pszNameIn);
    if (nIndex < 0)
        return nullptr;
    else
        return papoLayers[nIndex];
}

/************************************************************************/
/*                       GetMetadataDomainList()                        */
/************************************************************************/

char **OGRWFSDataSource::GetMetadataDomainList()
{
    return BuildMetadataDomainList(GDALDataset::GetMetadataDomainList(), TRUE,
                                   "", "xml:capabilities", nullptr);
}

/************************************************************************/
/*                            GetMetadata()                             */
/************************************************************************/

CSLConstList OGRWFSDataSource::GetMetadata(const char *pszDomain)
{
    if (pszDomain != nullptr && EQUAL(pszDomain, "xml:capabilities"))
    {
        apszGetCapabilities[0] = osGetCapabilities.c_str();
        apszGetCapabilities[1] = nullptr;
        return const_cast<char **>(apszGetCapabilities);
    }
    return GDALDataset::GetMetadata(pszDomain);
}

/************************************************************************/
/*                           GetLayerIndex()                            */
/************************************************************************/

int OGRWFSDataSource::GetLayerIndex(const char *pszNameIn)
{
    bool bHasFoundLayerWithColon = false;

    /* first a case sensitive check */
    for (int i = 0; i < nLayers; i++)
    {
        OGRWFSLayer *poLayer = papoLayers[i];

        if (strcmp(pszNameIn, poLayer->GetName()) == 0)
            return i;

        bHasFoundLayerWithColon |= strchr(poLayer->GetName(), ':') != nullptr;
    }

    /* then case insensitive */
    for (int i = 0; i < nLayers; i++)
    {
        OGRWFSLayer *poLayer = papoLayers[i];

        if (EQUAL(pszNameIn, poLayer->GetName()))
            return i;
    }

    /* now try looking after the colon character */
    if (!bKeepLayerNamePrefix && bHasFoundLayerWithColon &&
        strchr(pszNameIn, ':') == nullptr)
    {
        for (int i = 0; i < nLayers; i++)
        {
            OGRWFSLayer *poLayer = papoLayers[i];

            const char *pszAfterColon = strchr(poLayer->GetName(), ':');
            if (pszAfterColon && EQUAL(pszNameIn, pszAfterColon + 1))
                return i;
        }
    }

    return -1;
}

/************************************************************************/
/*                      FindSubStringInsensitive()                      */
/************************************************************************/

const char *FindSubStringInsensitive(const char *pszStr, const char *pszSubStr)
{
    size_t nSubStrPos = CPLString(pszStr).ifind(pszSubStr);
    if (nSubStrPos == std::string::npos)
        return nullptr;
    return pszStr + nSubStrPos;
}

/************************************************************************/
/*                   DetectIfGetFeatureSupportHits()                    */
/************************************************************************/

static bool DetectIfGetFeatureSupportHits(const CPLXMLNode *psRoot)
{
    const CPLXMLNode *psOperationsMetadata =
        CPLGetXMLNode(psRoot, "OperationsMetadata");
    if (!psOperationsMetadata)
    {
        CPLDebug("WFS", "Could not find <OperationsMetadata>");
        return false;
    }

    const CPLXMLNode *psChild = psOperationsMetadata->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Operation") == 0 &&
            strcmp(CPLGetXMLValue(psChild, "name", ""), "GetFeature") == 0)
        {
            break;
        }
        psChild = psChild->psNext;
    }
    if (!psChild)
    {
        CPLDebug("WFS", "Could not find <Operation name=\"GetFeature\">");
        return false;
    }

    psChild = psChild->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Parameter") == 0 &&
            strcmp(CPLGetXMLValue(psChild, "name", ""), "resultType") == 0)
        {
            break;
        }
        psChild = psChild->psNext;
    }
    if (!psChild)
    {
        CPLDebug("WFS", "Could not find <Parameter name=\"resultType\">");
        return false;
    }

    psChild = psChild->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Value") == 0)
        {
            CPLXMLNode *psChild2 = psChild->psChild;
            while (psChild2)
            {
                if (psChild2->eType == CXT_Text &&
                    strcmp(psChild2->pszValue, "hits") == 0)
                {
                    CPLDebug("WFS", "GetFeature operation supports hits");
                    return true;
                }
                psChild2 = psChild2->psNext;
            }
        }
        psChild = psChild->psNext;
    }

    return false;
}

/************************************************************************/
/*                DetectRequiresEnvelopeSpatialFilter()                 */
/************************************************************************/

bool OGRWFSDataSource::DetectRequiresEnvelopeSpatialFilter(
    const CPLXMLNode *psRoot)
{
    // This is a heuristic to detect Deegree 3 servers, such as
    // http://deegree3-demo.deegree.org:80/deegree-utah-demo/services that are
    // very GML3 strict, and don't like <gml:Box> in a <Filter><BBOX> request,
    // but requires instead <gml:Envelope>, but some servers (such as MapServer)
    // don't like <gml:Envelope> so we are obliged to detect the kind of server.

    const CPLXMLNode *psGeometryOperands = CPLGetXMLNode(
        psRoot, "Filter_Capabilities.Spatial_Capabilities.GeometryOperands");
    if (!psGeometryOperands)
    {
        return false;
    }

    int nCount = 0;
    const CPLXMLNode *psChild = psGeometryOperands->psChild;
    while (psChild)
    {
        nCount++;
        psChild = psChild->psNext;
    }
    // Magic number... Might be fragile.
    return nCount == 19;
}

/************************************************************************/
/*                       GetPostTransactionURL()                        */
/************************************************************************/

CPLString OGRWFSDataSource::GetPostTransactionURL()
{
    if (!osPostTransactionURL.empty())
        return osPostTransactionURL;

    osPostTransactionURL = osBaseURL;
    const char *pszPostTransactionURL = osPostTransactionURL.c_str();
    const char *pszEsperluet = strchr(pszPostTransactionURL, '?');
    if (pszEsperluet)
        osPostTransactionURL.resize(pszEsperluet - pszPostTransactionURL);

    return osPostTransactionURL;
}

/************************************************************************/
/*                      DetectTransactionSupport()                      */
/************************************************************************/

bool OGRWFSDataSource::DetectTransactionSupport(const CPLXMLNode *psRoot)
{
    const CPLXMLNode *psTransactionWFS100 =
        CPLGetXMLNode(psRoot, "Capability.Request.Transaction");
    if (psTransactionWFS100)
    {
        const CPLXMLNode *psPostURL =
            CPLGetXMLNode(psTransactionWFS100, "DCPType.HTTP.Post");
        if (psPostURL)
        {
            const char *pszPOSTURL =
                CPLGetXMLValue(psPostURL, "onlineResource", nullptr);
            if (pszPOSTURL)
            {
                osPostTransactionURL = pszPOSTURL;
            }
        }

        bTransactionSupport = true;
        return true;
    }

    const CPLXMLNode *psOperationsMetadata =
        CPLGetXMLNode(psRoot, "OperationsMetadata");
    if (!psOperationsMetadata)
    {
        return false;
    }

    const CPLXMLNode *psChild = psOperationsMetadata->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Operation") == 0 &&
            strcmp(CPLGetXMLValue(psChild, "name", ""), "Transaction") == 0)
        {
            break;
        }
        psChild = psChild->psNext;
    }
    if (!psChild)
    {
        CPLDebug("WFS", "No transaction support");
        return false;
    }

    bTransactionSupport = true;
    CPLDebug("WFS", "Transaction support !");

    const CPLXMLNode *psPostURL = CPLGetXMLNode(psChild, "DCP.HTTP.Post");
    if (psPostURL)
    {
        const char *pszPOSTURL = CPLGetXMLValue(psPostURL, "href", nullptr);
        if (pszPOSTURL)
            osPostTransactionURL = pszPOSTURL;
    }

    psChild = psChild->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Parameter") == 0 &&
            strcmp(CPLGetXMLValue(psChild, "name", ""), "idgen") == 0)
        {
            break;
        }
        psChild = psChild->psNext;
    }
    if (!psChild)
    {
        papszIdGenMethods = CSLAddString(nullptr, "GenerateNew");
        return true;
    }

    psChild = psChild->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Value") == 0)
        {
            const CPLXMLNode *psChild2 = psChild->psChild;
            while (psChild2)
            {
                if (psChild2->eType == CXT_Text)
                {
                    papszIdGenMethods =
                        CSLAddString(papszIdGenMethods, psChild2->pszValue);
                }
                psChild2 = psChild2->psNext;
            }
        }
        psChild = psChild->psNext;
    }

    return true;
}

/************************************************************************/
/*                      DetectSupportPagingWFS2()                       */
/************************************************************************/

bool OGRWFSDataSource::DetectSupportPagingWFS2(
    const CPLXMLNode *psGetCapabilitiesResponse,
    const CPLXMLNode *psConfigurationRoot)
{
    const char *pszPagingAllowed = CPLGetConfigOption(
        "OGR_WFS_PAGING_ALLOWED",
        CPLGetXMLValue(psConfigurationRoot, "PagingAllowed", nullptr));
    if (pszPagingAllowed != nullptr && !CPLTestBool(pszPagingAllowed))
        return false;

    const CPLXMLNode *psOperationsMetadata =
        CPLGetXMLNode(psGetCapabilitiesResponse, "OperationsMetadata");
    if (!psOperationsMetadata)
    {
        return false;
    }

    const CPLXMLNode *psChild = psOperationsMetadata->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Constraint") == 0 &&
            strcmp(CPLGetXMLValue(psChild, "name", ""),
                   "ImplementsResultPaging") == 0)
        {
            if (!EQUAL(CPLGetXMLValue(psChild, "DefaultValue", ""), "TRUE"))
            {
                psChild = nullptr;
                break;
            }
            break;
        }
        psChild = psChild->psNext;
    }
    if (!psChild)
    {
        CPLDebug("WFS", "No paging support");
        return false;
    }

    psChild = psOperationsMetadata->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Operation") == 0 &&
            strcmp(CPLGetXMLValue(psChild, "name", ""), "GetFeature") == 0)
        {
            break;
        }
        psChild = psChild->psNext;
    }

    const char *pszPageSize = CPLGetConfigOption(
        "OGR_WFS_PAGE_SIZE",
        CPLGetXMLValue(psConfigurationRoot, "PageSize", nullptr));
    if (psChild && pszPageSize == nullptr)
    {
        psChild = psChild->psChild;
        while (psChild)
        {
            if (psChild->eType == CXT_Element &&
                strcmp(psChild->pszValue, "Constraint") == 0 &&
                strcmp(CPLGetXMLValue(psChild, "name", ""), "CountDefault") ==
                    0)
            {
                int nVal = atoi(CPLGetXMLValue(psChild, "DefaultValue", "0"));
                if (nVal > 0)
                {
                    nPageSize = nVal;
                    const int nPageSizeURL =
                        atoi(CPLURLGetValue(osBaseURL, "COUNT"));
                    if (nPageSizeURL > 0 && nPageSizeURL < nPageSize)
                    {
                        nPageSize = nPageSizeURL;
                    }
                }

                break;
            }
            psChild = psChild->psNext;
        }
    }
    if (pszPageSize != nullptr)
    {
        nPageSize = atoi(pszPageSize);
        if (nPageSize <= 0)
            nPageSize = DEFAULT_PAGE_SIZE;
    }

    CPLDebug("WFS", "Paging support with page size %d", nPageSize);
    bPagingAllowed = true;

    return true;
}

/************************************************************************/
/*                   DetectSupportStandardJoinsWFS2()                   */
/************************************************************************/

bool OGRWFSDataSource::DetectSupportStandardJoinsWFS2(const CPLXMLNode *psRoot)
{
    const CPLXMLNode *psOperationsMetadata =
        CPLGetXMLNode(psRoot, "OperationsMetadata");
    if (!psOperationsMetadata)
    {
        return false;
    }

    const CPLXMLNode *psChild = psOperationsMetadata->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "Constraint") == 0 &&
            strcmp(CPLGetXMLValue(psChild, "name", ""),
                   "ImplementsStandardJoins") == 0)
        {
            if (!EQUAL(CPLGetXMLValue(psChild, "DefaultValue", ""), "TRUE"))
            {
                psChild = nullptr;
                break;
            }
            break;
        }
        psChild = psChild->psNext;
    }
    if (!psChild)
    {
        CPLDebug("WFS", "No ImplementsStandardJoins support");
        return false;
    }
    bStandardJoinsWFS2 = true;
    return true;
}

/************************************************************************/
/*                       FindComparisonOperator()                       */
/************************************************************************/

static bool FindComparisonOperator(const CPLXMLNode *psNode, const char *pszVal)
{
    const CPLXMLNode *psChild = psNode->psChild;
    while (psChild)
    {
        if (psChild->eType == CXT_Element &&
            strcmp(psChild->pszValue, "ComparisonOperator") == 0)
        {
            if (strcmp(CPLGetXMLValue(psChild, nullptr, ""), pszVal) == 0)
                return true;

            /* For WFS 2.0.0 */
            const char *pszName = CPLGetXMLValue(psChild, "name", nullptr);
            if (pszName != nullptr && STARTS_WITH(pszName, "PropertyIs") &&
                strcmp(pszName + 10, pszVal) == 0)
                return true;
        }
        psChild = psChild->psNext;
    }
    return false;
}

/************************************************************************/
/*                            LoadFromFile()                            */
/************************************************************************/

CPLXMLNode *OGRWFSDataSource::LoadFromFile(const char *pszFilename)
{
    VSIStatBufL sStatBuf;
    if (VSIStatExL(pszFilename, &sStatBuf,
                   VSI_STAT_EXISTS_FLAG | VSI_STAT_NATURE_FLAG) != 0 ||
        VSI_ISDIR(sStatBuf.st_mode))
        return nullptr;

    VSILFILE *fp = VSIFOpenL(pszFilename, "rb");

    if (fp == nullptr)
        return nullptr;

    /* -------------------------------------------------------------------- */
    /*      It is the right file, now load the full XML definition.         */
    /* -------------------------------------------------------------------- */
    VSIFSeekL(fp, 0, SEEK_END);
    const auto nLenLarge = VSIFTellL(fp);
    VSIFSeekL(fp, 0, SEEK_SET);
    if (nLenLarge > 100 * 1024 * 1024)
    {
        VSIFCloseL(fp);
        return nullptr;
    }
    const int nLen = static_cast<int>(nLenLarge);

    char *pszXML = static_cast<char *>(VSI_MALLOC_VERBOSE(nLen + 1));
    if (pszXML == nullptr)
    {
        VSIFCloseL(fp);
        return nullptr;
    }
    pszXML[nLen] = '\0';
    if (static_cast<int>(VSIFReadL(pszXML, 1, nLen, fp)) != nLen)
    {
        CPLFree(pszXML);
        VSIFCloseL(fp);

        return nullptr;
    }
    VSIFCloseL(fp);

    if (!STARTS_WITH_CI(pszXML, "<OGRWFSDataSource>") &&
        strstr(pszXML, "<WFS_Capabilities") == nullptr &&
        strstr(pszXML, "<wfs:WFS_Capabilities") == nullptr)
    {
        return nullptr;
    }

    if (strstr(pszXML, "CubeWerx"))
    {
        /* At least true for CubeWerx Suite 4.15.1 */
        bUseFeatureId = true;
    }
    else if (strstr(pszXML, "deegree"))
    {
        bGmlObjectIdNeedsGMLPrefix = true;
    }

    CPLXMLNode *psXML = CPLParseXMLString(pszXML);
    CPLFree(pszXML);

    return psXML;
}

/************************************************************************/
/*                        SendGetCapabilities()                         */
/************************************************************************/

CPLHTTPResult *OGRWFSDataSource::SendGetCapabilities(const char *pszBaseURL,
                                                     CPLString &osTypeName)
{
    CPLString osURL(pszBaseURL);

    osURL = CPLURLAddKVP(osURL, "SERVICE", "WFS");
    osURL = CPLURLAddKVP(osURL, "REQUEST", "GetCapabilities");
    osTypeName = CPLURLGetValue(osURL, "TYPENAME");
    if (osTypeName.empty())
        osTypeName = CPLURLGetValue(osURL, "TYPENAMES");
    osURL = CPLURLAddKVP(osURL, "TYPENAME", nullptr);
    osURL = CPLURLAddKVP(osURL, "TYPENAMES", nullptr);
    osURL = CPLURLAddKVP(osURL, "FILTER", nullptr);
    osURL = CPLURLAddKVP(osURL, "PROPERTYNAME", nullptr);
    osURL = CPLURLAddKVP(osURL, "MAXFEATURES", nullptr);
    osURL = CPLURLAddKVP(osURL, "OUTPUTFORMAT", nullptr);

    CPLDebug("WFS", "%s", osURL.c_str());

    CPLHTTPResult *psResult = HTTPFetch(osURL, nullptr);
    if (psResult == nullptr)
    {
        return nullptr;
    }

    if (strstr(reinterpret_cast<const char *>(psResult->pabyData),
               "<ServiceExceptionReport") != nullptr ||
        strstr(reinterpret_cast<const char *>(psResult->pabyData),
               "<ows:ExceptionReport") != nullptr ||
        strstr(reinterpret_cast<const char *>(psResult->pabyData),
               "<ExceptionReport") != nullptr)
    {
        CPLError(CE_Failure, CPLE_AppDefined, "Error returned by server : %s",
                 psResult->pabyData);
        CPLHTTPDestroyResult(psResult);
        return nullptr;
    }

    return psResult;
}

/************************************************************************/
/*                                Open()                                */
/************************************************************************/

int OGRWFSDataSource::Open(const char *pszFilename, int bUpdateIn,
                           CSLConstList papszOpenOptionsIn)

{
    bUpdate = CPL_TO_BOOL(bUpdateIn);

    const CPLXMLNode *psWFSCapabilities = nullptr;
    CPLXMLNode *psXML = nullptr;
    if (!STARTS_WITH(pszFilename, "http://") &&
        !STARTS_WITH(pszFilename, "https://"))
    {
        psXML = LoadFromFile(pszFilename);
    }
    CPLString osTypeName;
    const char *pszBaseURL = nullptr;

    bEmptyAsNull = CPLFetchBool(papszOpenOptionsIn, "EMPTY_AS_NULL", true);

    const CPLXMLNode *psConfigurationRoot = nullptr;

    if (psXML == nullptr)
    {
        if (!STARTS_WITH_CI(pszFilename, "WFS:") &&
            !STARTS_WITH(pszFilename, "http://") &&
            !STARTS_WITH(pszFilename, "https://") &&
            FindSubStringInsensitive(pszFilename, "SERVICE=WFS") == nullptr)
        {
            return FALSE;
        }

        pszBaseURL = CSLFetchNameValue(papszOpenOptionsIn, "URL");
        if (pszBaseURL == nullptr)
        {
            pszBaseURL = pszFilename;
            if (STARTS_WITH_CI(pszFilename, "WFS:"))
                pszBaseURL += strlen("WFS:");
        }

        osBaseURL = pszBaseURL;

        if (!STARTS_WITH(pszBaseURL, "http://") &&
            !STARTS_WITH(pszBaseURL, "https://") &&
            !STARTS_WITH(pszBaseURL, "/vsimem/"))
            return FALSE;

        CPLString strOriginalTypeName = "";
        CPLHTTPResult *psResult =
            SendGetCapabilities(pszBaseURL, strOriginalTypeName);
        osTypeName = WFS_DecodeURL(strOriginalTypeName);
        if (psResult == nullptr)
        {
            return FALSE;
        }

        if (strstr(reinterpret_cast<const char *>(psResult->pabyData),
                   "CubeWerx"))
        {
            /* At least true for CubeWerx Suite 4.15.1 */
            bUseFeatureId = true;
        }
        else if (strstr(reinterpret_cast<const char *>(psResult->pabyData),
                        "deegree"))
        {
            bGmlObjectIdNeedsGMLPrefix = true;
        }

        psXML = CPLParseXMLString(
            reinterpret_cast<const char *>(psResult->pabyData));
        if (psXML == nullptr)
        {
            CPLError(CE_Failure, CPLE_AppDefined, "Invalid XML content : %s",
                     psResult->pabyData);
            CPLHTTPDestroyResult(psResult);
            return FALSE;
        }
        osGetCapabilities = reinterpret_cast<const char *>(psResult->pabyData);

        CPLHTTPDestroyResult(psResult);
    }
    else if (WFSFindNode(psXML, "OGRWFSDataSource") == nullptr &&
             WFSFindNode(psXML, "WFS_Capabilities") != nullptr)
    {
        /* This is directly the Capabilities document */
        char *pszXML =
            CPLSerializeXMLTree(WFSFindNode(psXML, "WFS_Capabilities"));
        osGetCapabilities = pszXML;
        CPLFree(pszXML);
    }
    else
    {
        psConfigurationRoot = WFSFindNode(psXML, "OGRWFSDataSource");
        if (psConfigurationRoot == nullptr)
        {
            CPLError(CE_Failure, CPLE_AppDefined,
                     "Cannot find <OGRWFSDataSource>");
            CPLDestroyXMLNode(psXML);
            return FALSE;
        }

        pszBaseURL = CPLGetXMLValue(psConfigurationRoot, "URL", nullptr);
        if (pszBaseURL == nullptr)
        {
            CPLError(CE_Failure, CPLE_AppDefined, "Cannot find <URL>");
            CPLDestroyXMLNode(psXML);
            return FALSE;
        }
        osBaseURL = pszBaseURL;

        /* --------------------------------------------------------------------
         */
        /*      Capture other parameters. */
        /* --------------------------------------------------------------------
         */
        const char *pszParam =
            CPLGetXMLValue(psConfigurationRoot, "Timeout", nullptr);
        if (pszParam)
            papszHttpOptions =
                CSLSetNameValue(papszHttpOptions, "TIMEOUT", pszParam);

        pszParam = CPLGetXMLValue(psConfigurationRoot, "HTTPAUTH", nullptr);
        if (pszParam)
            papszHttpOptions =
                CSLSetNameValue(papszHttpOptions, "HTTPAUTH", pszParam);

        pszParam = CPLGetXMLValue(psConfigurationRoot, "USERPWD", nullptr);
        if (pszParam)
            papszHttpOptions =
                CSLSetNameValue(papszHttpOptions, "USERPWD", pszParam);

        pszParam = CPLGetXMLValue(psConfigurationRoot, "COOKIE", nullptr);
        if (pszParam)
            papszHttpOptions =
                CSLSetNameValue(papszHttpOptions, "COOKIE", pszParam);

        pszParam = CPLGetXMLValue(psConfigurationRoot, "Version", nullptr);
        if (pszParam)
            osVersion = pszParam;

        pszParam =
            CPLGetXMLValue(psConfigurationRoot, "BaseStartIndex", nullptr);
        if (pszParam)
            nBaseStartIndex = atoi(pszParam);

        CPLString strOriginalTypeName = CPLURLGetValue(pszBaseURL, "TYPENAME");
        if (strOriginalTypeName.empty())
            strOriginalTypeName = CPLURLGetValue(pszBaseURL, "TYPENAMES");
        osTypeName = WFS_DecodeURL(strOriginalTypeName);

        psWFSCapabilities =
            WFSFindNode(psConfigurationRoot, "WFS_Capabilities");
        if (psWFSCapabilities == nullptr)
        {
            CPLHTTPResult *psResult =
                SendGetCapabilities(pszBaseURL, strOriginalTypeName);
            if (psResult == nullptr)
            {
                CPLDestroyXMLNode(psXML);
                return FALSE;
            }

            CPLXMLNode *psXML2 = CPLParseXMLString(
                reinterpret_cast<const char *>(psResult->pabyData));
            if (psXML2 == nullptr)
            {
                CPLError(CE_Failure, CPLE_AppDefined,
                         "Invalid XML content : %s", psResult->pabyData);
                CPLHTTPDestroyResult(psResult);
                CPLDestroyXMLNode(psXML);
                return FALSE;
            }

            CPLHTTPDestroyResult(psResult);

            psWFSCapabilities = WFSFindNode(psXML2, "WFS_Capabilities");
            if (psWFSCapabilities == nullptr)
            {
                CPLError(CE_Failure, CPLE_AppDefined,
                         "Cannot find <WFS_Capabilities>");
                CPLDestroyXMLNode(psXML);
                CPLDestroyXMLNode(psXML2);
                return FALSE;
            }

            CPLAddXMLChild(psXML, CPLCloneXMLTree(psWFSCapabilities));

            const bool bOK =
                CPL_TO_BOOL(CPLSerializeXMLTreeToFile(psXML, pszFilename));

            CPLDestroyXMLNode(psXML);
            CPLDestroyXMLNode(psXML2);

            if (bOK)
                return Open(pszFilename, bUpdate, papszOpenOptionsIn);

            return FALSE;
        }
        else
        {
            psFileXML = psXML;

            /* To avoid to have nodes after WFSCapabilities */
            CPLXMLNode *psAfterWFSCapabilities = psWFSCapabilities->psNext;
            const_cast<CPLXMLNode *>(psWFSCapabilities)->psNext = nullptr;
            char *pszXML = CPLSerializeXMLTree(psWFSCapabilities);
            const_cast<CPLXMLNode *>(psWFSCapabilities)->psNext =
                psAfterWFSCapabilities;
            osGetCapabilities = pszXML;
            CPLFree(pszXML);
        }
    }

    bInvertAxisOrderIfLatLong = CPLTestBool(CSLFetchNameValueDef(
        papszOpenOptionsIn, "INVERT_AXIS_ORDER_IF_LAT_LONG",
        CPLGetConfigOption("GML_INVERT_AXIS_ORDER_IF_LAT_LONG", "YES")));
    osConsiderEPSGAsURN = CSLFetchNameValueDef(
        papszOpenOptionsIn, "CONSIDER_EPSG_AS_URN",
        CPLGetConfigOption("GML_CONSIDER_EPSG_AS_URN", "AUTO"));
    bExposeGMLId = CPLTestBool(
        CSLFetchNameValueDef(papszOpenOptionsIn, "EXPOSE_GML_ID",
                             CPLGetConfigOption("GML_EXPOSE_GML_ID", "YES")));

    CPLXMLNode *psStrippedXML = CPLCloneXMLTree(psXML);
    CPLStripXMLNamespace(psStrippedXML, nullptr, TRUE);
    psWFSCapabilities = CPLGetXMLNode(psStrippedXML, "=WFS_Capabilities");
    if (psWFSCapabilities == nullptr)
    {
        psWFSCapabilities =
            CPLGetXMLNode(psStrippedXML, "=OGRWFSDataSource.WFS_Capabilities");
    }
    if (psWFSCapabilities == nullptr)
    {
        CPLError(CE_Failure, CPLE_AppDefined, "Cannot find <WFS_Capabilities>");
        if (!psFileXML)
            CPLDestroyXMLNode(psXML);
        CPLDestroyXMLNode(psStrippedXML);
        return FALSE;
    }

    if (pszBaseURL == nullptr)
    {
        /* This is directly the Capabilities document */
        pszBaseURL = CPLGetXMLValue(
            psWFSCapabilities, "OperationsMetadata.Operation.DCP.HTTP.Get.href",
            nullptr);
        if (pszBaseURL == nullptr) /* WFS 1.0.0 variant */
            pszBaseURL = CPLGetXMLValue(psWFSCapabilities,
                                        "Capability.Request.GetCapabilities."
                                        "DCPType.HTTP.Get.onlineResource",
                                        nullptr);

        if (pszBaseURL == nullptr)
        {
            CPLError(CE_Failure, CPLE_AppDefined, "Cannot find base URL");
            if (!psFileXML)
                CPLDestroyXMLNode(psXML);
            CPLDestroyXMLNode(psStrippedXML);
            return FALSE;
        }

        osBaseURL = pszBaseURL;
    }

    pszBaseURL = nullptr;

    for (const auto &sMetadata : asMetadata)
    {
        const char *pszVal =
            CPLGetXMLValue(psWFSCapabilities, sMetadata.pszPath, nullptr);
        if (pszVal)
            SetMetadataItem(sMetadata.pszMDI, pszVal);
    }

    if (osVersion.empty())
        osVersion = CPLGetXMLValue(psWFSCapabilities, "version", "1.0.0");
    if (strcmp(osVersion.c_str(), "1.0.0") == 0)
    {
        bUseFeatureId = true;
    }
    else
    {
        /* Some servers happen to support RESULTTYPE=hits in 1.0.0, but there */
        /* is no way to advertises this */
        if (atoi(osVersion) >= 2)
            bGetFeatureSupportHits = true; /* WFS >= 2.0.0 supports hits */
        else
            bGetFeatureSupportHits =
                DetectIfGetFeatureSupportHits(psWFSCapabilities);
        bRequiresEnvelopeSpatialFilter =
            DetectRequiresEnvelopeSpatialFilter(psWFSCapabilities);
    }

    bool bRequestJSON = false;

    if (atoi(osVersion) >= 2)
    {
        CPLString osMaxFeatures = CPLURLGetValue(osBaseURL, "COUNT");
        /* Ok, people are used to MAXFEATURES, so be nice to recognize it if it
         * is used for WFS 2.0 ... */
        if (osMaxFeatures.empty())
        {
            osMaxFeatures = CPLURLGetValue(osBaseURL, "MAXFEATURES");
            if (!osMaxFeatures.empty() &&
                CPLTestBool(
                    CPLGetConfigOption("OGR_WFS_FIX_MAXFEATURES", "YES")))
            {
                CPLDebug("WFS", "MAXFEATURES wrongly used for WFS 2.0. Using "
                                "COUNT instead");
                osBaseURL = CPLURLAddKVP(osBaseURL, "MAXFEATURES", nullptr);
                osBaseURL = CPLURLAddKVP(osBaseURL, "COUNT", osMaxFeatures);
            }
        }

        DetectSupportPagingWFS2(psWFSCapabilities, psConfigurationRoot);
        DetectSupportStandardJoinsWFS2(psWFSCapabilities);

        const CPLXMLNode *psOperationsMetadata =
            CPLGetXMLNode(psWFSCapabilities, "OperationsMetadata");
        auto poGMLDriver = GDALDriver::FromHandle(GDALGetDriverByName("GML"));
        if (psOperationsMetadata && !(poGMLDriver && poGMLDriver->pfnOpen) &&
            CPLURLGetValue(osBaseURL, "OUTPUTFORMAT").empty())
        {
            const CPLXMLNode *psChild = psOperationsMetadata->psChild;
            while (psChild)
            {
                if (psChild->eType == CXT_Element &&
                    strcmp(psChild->pszValue, "Operation") == 0 &&
                    strcmp(CPLGetXMLValue(psChild, "name", ""), "GetFeature") ==
                        0)
                {
                    break;
                }
                psChild = psChild->psNext;
            }
            if (psChild)
            {
                psChild = psChild->psChild;
                while (psChild)
                {
                    if (psChild->eType == CXT_Element &&
                        strcmp(psChild->pszValue, "Parameter") == 0 &&
                        strcmp(CPLGetXMLValue(psChild, "name", ""),
                               "outputFormat") == 0)
                    {
                        break;
                    }
                    psChild = psChild->psNext;
                }
                if (psChild)
                {
                    const CPLXMLNode *psAllowedValues =
                        CPLGetXMLNode(psChild, "AllowedValues");
                    if (psAllowedValues)
                    {
                        psChild = psAllowedValues->psChild;
                        while (psChild)
                        {
                            if (psChild->eType == CXT_Element &&
                                strcmp(psChild->pszValue, "Value") == 0 &&
                                psChild->psChild &&
                                psChild->psChild->eType == CXT_Text)
                            {
                                CPLDebug("WFS", "Available output format: %s",
                                         psChild->psChild->pszValue);
                                if (strcmp(psChild->psChild->pszValue,
                                           "json") == 0)
                                {
                                    bRequestJSON = true;
                                }
                            }
                            psChild = psChild->psNext;
                        }
                    }
                }
            }
        }
    }

    DetectTransactionSupport(psWFSCapabilities);

    if (bUpdate && !bTransactionSupport)
    {
        CPLError(CE_Failure, CPLE_AppDefined,
                 "Server is read-only WFS; no WFS-T feature advertized");
        if (!psFileXML)
            CPLDestroyXMLNode(psXML);
        CPLDestroyXMLNode(psStrippedXML);
        return FALSE;
    }

    const CPLXMLNode *psFilterCap = CPLGetXMLNode(
        psWFSCapabilities, "Filter_Capabilities.Scalar_Capabilities");
    if (psFilterCap)
    {
        bHasMinOperators =
            CPLGetXMLNode(psFilterCap, "LogicalOperators") != nullptr ||
            CPLGetXMLNode(psFilterCap, "Logical_Operators") != nullptr;
        if (CPLGetXMLNode(psFilterCap, "ComparisonOperators"))
            psFilterCap = CPLGetXMLNode(psFilterCap, "ComparisonOperators");
        else if (CPLGetXMLNode(psFilterCap, "Comparison_Operators"))
            psFilterCap = CPLGetXMLNode(psFilterCap, "Comparison_Operators");
        else
            psFilterCap = nullptr;
        if (psFilterCap)
        {
            if (CPLGetXMLNode(psFilterCap, "Simple_Comparisons") == nullptr)
            {
                bHasMinOperators &=
                    FindComparisonOperator(psFilterCap, "LessThan");
                bHasMinOperators &=
                    FindComparisonOperator(psFilterCap, "GreaterThan");
                if (atoi(osVersion) >= 2)
                {
                    bHasMinOperators &= FindComparisonOperator(
                        psFilterCap, "LessThanOrEqualTo");
                    bHasMinOperators &= FindComparisonOperator(
                        psFilterCap, "GreaterThanOrEqualTo");
                }
                else
                {
                    bHasMinOperators &=
                        FindComparisonOperator(psFilterCap, "LessThanEqualTo");
                    bHasMinOperators &= FindComparisonOperator(
                        psFilterCap, "GreaterThanEqualTo");
                }
                bHasMinOperators &=
                    FindComparisonOperator(psFilterCap, "EqualTo");
                bHasMinOperators &=
                    FindComparisonOperator(psFilterCap, "NotEqualTo");
                bHasMinOperators &= FindComparisonOperator(psFilterCap, "Like");
            }
            else
            {
                bHasMinOperators &=
                    CPLGetXMLNode(psFilterCap, "Simple_Comparisons") !=
                        nullptr &&
                    CPLGetXMLNode(psFilterCap, "Like") != nullptr;
            }
            bHasNullCheck =
                FindComparisonOperator(psFilterCap, "NullCheck") ||
                FindComparisonOperator(psFilterCap, "Null") || /* WFS 2.0.0 */
                CPLGetXMLNode(psFilterCap, "NullCheck") != nullptr;
        }
        else
        {
            bHasMinOperators = false;
        }
    }

    const CPLXMLNode *psChild =
        CPLGetXMLNode(psWFSCapabilities, "FeatureTypeList");
    if (psChild == nullptr)
    {
        CPLError(CE_Failure, CPLE_AppDefined, "Cannot find <FeatureTypeList>");
        if (!psFileXML)
            CPLDestroyXMLNode(psXML);
        CPLDestroyXMLNode(psStrippedXML);
        return FALSE;
    }

    /* Check if there are layer names whose identical except their prefix */
    std::set<CPLString> aosSetLayerNames;
    for (CPLXMLNode *psChildIter = psChild->psChild; psChildIter != nullptr;
         psChildIter = psChildIter->psNext)
    {
        if (psChildIter->eType == CXT_Element &&
            strcmp(psChildIter->pszValue, "FeatureType") == 0)
        {
            const char *l_pszName =
                CPLGetXMLValue(psChildIter, "Name", nullptr);
            if (l_pszName != nullptr)
            {
                const char *pszShortName = strchr(l_pszName, ':');
                if (pszShortName)
                    l_pszName = pszShortName + 1;
                if (aosSetLayerNames.find(l_pszName) != aosSetLayerNames.end())
                {
                    bKeepLayerNamePrefix = true;
                    CPLDebug("WFS",
                             "At least 2 layers have names that are only "
                             "distinguishable by keeping the prefix");
                    break;
                }
                aosSetLayerNames.insert(l_pszName);
            }
        }
    }

    char **papszTypenames = nullptr;
    if (!osTypeName.empty())
        papszTypenames =
            CSLTokenizeStringComplex(osTypeName, ",", FALSE, FALSE);

    for (CPLXMLNode *psChildIter = psChild->psChild; psChildIter != nullptr;
         psChildIter = psChildIter->psNext)
    {
        if (psChildIter->eType == CXT_Element &&
            strcmp(psChildIter->pszValue, "FeatureType") == 0)
        {
            const char *pszNS = nullptr;
            const char *pszNSVal = nullptr;
            CPLXMLNode *psFeatureTypeIter = psChildIter->psChild;
            while (psFeatureTypeIter != nullptr)
            {
                if (psFeatureTypeIter->eType == CXT_Attribute)
                {
                    pszNS = psFeatureTypeIter->pszValue;
                    pszNSVal = psFeatureTypeIter->psChild->pszValue;
                }
                psFeatureTypeIter = psFeatureTypeIter->psNext;
            }

            const char *l_pszName =
                CPLGetXMLValue(psChildIter, "Name", nullptr);
            const char *pszTitle =
                CPLGetXMLValue(psChildIter, "Title", nullptr);
            const char *pszAbstract =
                CPLGetXMLValue(psChildIter, "Abstract", nullptr);
            if (l_pszName != nullptr &&
                (papszTypenames == nullptr ||
                 CSLFindString(papszTypenames, l_pszName) != -1))
            {
                const char *pszDefaultSRS =
                    CPLGetXMLValue(psChildIter, "DefaultSRS", nullptr);
                if (pszDefaultSRS == nullptr)
                    pszDefaultSRS = CPLGetXMLValue(psChildIter, "SRS", nullptr);
                if (pszDefaultSRS == nullptr)
                    pszDefaultSRS = CPLGetXMLValue(psChildIter, "DefaultCRS",
                                                   nullptr); /* WFS 2.0.0 */

                const CPLXMLNode *psOtherSRS =
                    CPLGetXMLNode(psChildIter, "OtherSRS");  // WFS 1.1
                if (psOtherSRS == nullptr)
                    psOtherSRS =
                        CPLGetXMLNode(psChildIter, "OtherCRS");  // WFS 2.0

                const auto IsValidCRSName = [](const char *pszStr)
                {
                    // EPSG:404000 is a GeoServer joke to indicate an unknown SRS
                    // https://osgeo-org.atlassian.net/browse/GEOS-8993
                    return !EQUAL(pszStr, "EPSG:404000") &&
                           !EQUAL(pszStr, "urn:ogc:def:crs:EPSG::404000");
                };

                if (pszDefaultSRS && !IsValidCRSName(pszDefaultSRS))
                    pszDefaultSRS = nullptr;

                std::vector<std::string> aosSupportedCRSList{};
                OGRLayer::GetSupportedSRSListRetType apoSupportedCRSList;
                if (psOtherSRS)
                {
                    if (pszDefaultSRS)
                    {
                        auto poSRS =
                            OGRSpatialReferenceRefCountedPtr::makeInstance();
                        if (poSRS->SetFromUserInput(
                                pszDefaultSRS,
                                OGRSpatialReference::
                                    SET_FROM_USER_INPUT_LIMITATIONS_get()) ==
                            OGRERR_NONE)
                        {
                            aosSupportedCRSList.emplace_back(pszDefaultSRS);
                            apoSupportedCRSList.emplace_back(std::move(poSRS));
                        }
                    }

                    CPLErrorStateBackuper oErrorStateBackuper(
                        CPLQuietErrorHandler);
                    for (const CPLXMLNode *psIter = psOtherSRS; psIter;
                         psIter = psIter->psNext)
                    {
                        if (psIter->eType == CXT_Element)
                        {
                            const char *pszSRS =
                                CPLGetXMLValue(psIter, "", nullptr);
                            if (pszSRS && IsValidCRSName(pszSRS))
                            {
                                auto poSRS = OGRSpatialReferenceRefCountedPtr::
                                    makeInstance();
                                if (poSRS->SetFromUserInput(
                                        EQUAL(pszSRS, "CRS:84") ? "OGC:CRS84"
                                                                : pszSRS,
                                        OGRSpatialReference::
                                            SET_FROM_USER_INPUT_LIMITATIONS_get()) ==
                                    OGRERR_NONE)
                                {
                                    aosSupportedCRSList.emplace_back(pszSRS);
                                    apoSupportedCRSList.emplace_back(
                                        std::move(poSRS));
                                }
                                else
                                {
                                    CPLDebug("WFS", "Invalid CRS %s", pszSRS);
                                }
                            }
                        }
                    }
                }

                CPLXMLNode *psOutputFormats =
                    CPLGetXMLNode(psChildIter, "OutputFormats");
                CPLString osOutputFormat;
                if (psOutputFormats)
                {
                    std::vector<CPLString> osFormats;
                    CPLXMLNode *psOutputFormatIter = psOutputFormats->psChild;
                    while (psOutputFormatIter)
                    {
                        if (psOutputFormatIter->eType == CXT_Element &&
                            EQUAL(psOutputFormatIter->pszValue, "Format") &&
                            psOutputFormatIter->psChild != nullptr &&
                            psOutputFormatIter->psChild->eType == CXT_Text)
                        {
                            osFormats.push_back(
                                psOutputFormatIter->psChild->pszValue);
                        }
                        psOutputFormatIter = psOutputFormatIter->psNext;
                    }

                    if (strcmp(osVersion.c_str(), "1.1.0") == 0 &&
                        !osFormats.empty())
                    {
                        bool bFoundGML31 = false;
                        for (size_t i = 0; i < osFormats.size(); i++)
                        {
                            if (strstr(osFormats[i].c_str(), "3.1") != nullptr)
                            {
                                bFoundGML31 = true;
                                break;
                            }
                        }

                        /* If we didn't find any mention to GML 3.1, then
                         * arbitrarily */
                        /* use the first output format */
                        if (!bFoundGML31)
                            osOutputFormat = osFormats[0].c_str();
                    }
                }
                if (osOutputFormat.empty() && bRequestJSON)
                    osOutputFormat = "json";

                OGRSpatialReference *poSRS = nullptr;
                bool bAxisOrderAlreadyInverted = false;

                /* If a SRSNAME parameter has been encoded in the URL, use it as
                 * the SRS */
                CPLString osSRSName = CPLURLGetValue(osBaseURL, "SRSNAME");
                if (!osSRSName.empty())
                {
                    pszDefaultSRS = osSRSName.c_str();
                }

                if (pszDefaultSRS)
                {
                    OGRSpatialReference oSRS;
                    if (oSRS.SetFromUserInput(
                            pszDefaultSRS,
                            OGRSpatialReference::
                                SET_FROM_USER_INPUT_LIMITATIONS_get()) ==
                        OGRERR_NONE)
                    {
                        poSRS = oSRS.Clone();
                        poSRS->SetAxisMappingStrategy(
                            bInvertAxisOrderIfLatLong
                                ? OAMS_TRADITIONAL_GIS_ORDER
                                : OAMS_AUTHORITY_COMPLIANT);
                        if (GML_IsSRSLatLongOrder(pszDefaultSRS) &&
                            bInvertAxisOrderIfLatLong)
                        {
                            bAxisOrderAlreadyInverted = true;
                        }
                    }
                }

                CPLXMLNode *psBBox = nullptr;
                CPLXMLNode *psLatLongBBox = nullptr;
                /* bool bFoundBBox = false; */
                double dfMinX = 0.0;
                double dfMinY = 0.0;
                double dfMaxX = 0.0;
                double dfMaxY = 0.0;
                if ((psBBox = CPLGetXMLNode(psChildIter, "WGS84BoundingBox")) !=
                    nullptr)
                {
                    const char *pszLC =
                        CPLGetXMLValue(psBBox, "LowerCorner", nullptr);
                    const char *pszUC =
                        CPLGetXMLValue(psBBox, "UpperCorner", nullptr);
                    if (pszLC != nullptr && pszUC != nullptr)
                    {
                        CPLString osConcat(pszLC);
                        osConcat += " ";
                        osConcat += pszUC;
                        char **papszTokens = CSLTokenizeStringComplex(
                            osConcat, " ,", FALSE, FALSE);
                        if (CSLCount(papszTokens) == 4)
                        {
                            // bFoundBBox = true;
                            dfMinX = CPLAtof(papszTokens[0]);
                            dfMinY = CPLAtof(papszTokens[1]);
                            dfMaxX = CPLAtof(papszTokens[2]);
                            dfMaxY = CPLAtof(papszTokens[3]);
                        }
                        CSLDestroy(papszTokens);
                    }
                }
                else if ((psLatLongBBox = CPLGetXMLNode(
                              psChildIter, "LatLongBoundingBox")) != nullptr)
                {
                    const char *pszMinX =
                        CPLGetXMLValue(psLatLongBBox, "minx", nullptr);
                    const char *pszMinY =
                        CPLGetXMLValue(psLatLongBBox, "miny", nullptr);
                    const char *pszMaxX =
                        CPLGetXMLValue(psLatLongBBox, "maxx", nullptr);
                    const char *pszMaxY =
                        CPLGetXMLValue(psLatLongBBox, "maxy", nullptr);
                    if (pszMinX != nullptr && pszMinY != nullptr &&
                        pszMaxX != nullptr && pszMaxY != nullptr)
                    {
                        // bFoundBBox = true;
                        dfMinX = CPLAtof(pszMinX);
                        dfMinY = CPLAtof(pszMinY);
                        dfMaxX = CPLAtof(pszMaxX);
                        dfMaxY = CPLAtof(pszMaxY);
                    }
                }

                char *pszCSVEscaped = CPLEscapeString(l_pszName, -1, CPLES_CSV);
                osLayerMetadataCSV += pszCSVEscaped;
                CPLFree(pszCSVEscaped);

                osLayerMetadataCSV += ",";
                if (pszTitle)
                {
                    pszCSVEscaped = CPLEscapeString(pszTitle, -1, CPLES_CSV);
                    osLayerMetadataCSV += pszCSVEscaped;
                    CPLFree(pszCSVEscaped);
                }
                osLayerMetadataCSV += ",";
                if (pszAbstract)
                {
                    pszCSVEscaped = CPLEscapeString(pszAbstract, -1, CPLES_CSV);
                    osLayerMetadataCSV += pszCSVEscaped;
                    CPLFree(pszCSVEscaped);
                }
                osLayerMetadataCSV += "\n";

                OGRWFSLayer *poLayer =
                    new OGRWFSLayer(this, poSRS, bAxisOrderAlreadyInverted,
                                    osBaseURL, l_pszName, pszNS, pszNSVal);
                if (!osOutputFormat.empty())
                    poLayer->SetRequiredOutputFormat(osOutputFormat);

                if (pszTitle)
                    poLayer->SetMetadataItem("TITLE", pszTitle);
                if (pszAbstract)
                    poLayer->SetMetadataItem("ABSTRACT", pszAbstract);
                CPLXMLNode *psKeywords = CPLGetXMLNode(psChildIter, "Keywords");
                if (psKeywords)
                {
                    int nKeywordCounter = 1;
                    for (CPLXMLNode *psKeyword = psKeywords->psChild;
                         psKeyword != nullptr; psKeyword = psKeyword->psNext)
                    {
                        if (psKeyword->eType == CXT_Element &&
                            psKeyword->psChild != nullptr)
                        {
                            poLayer->SetMetadataItem(
                                CPLSPrintf("KEYWORD_%d", nKeywordCounter),
                                psKeyword->psChild->pszValue);
                            nKeywordCounter++;
                        }
                        else if (psKeyword->eType == CXT_Text)
                        {
                            poLayer->SetMetadataItem("KEYWORDS",
                                                     psKeyword->pszValue);
                        }
                    }
                }

                if (poSRS)
                {
                    char *pszProj4 = nullptr;
                    if (poSRS->exportToProj4(&pszProj4) == OGRERR_NONE)
                    {
                        /* See http://trac.osgeo.org/gdal/ticket/4041 */
                        const bool bTrustBounds = CPLFetchBool(
                            papszOpenOptionsIn, "TRUST_CAPABILITIES_BOUNDS",
                            CPLTestBool(CPLGetConfigOption(
                                "OGR_WFS_TRUST_CAPABILITIES_BOUNDS", "FALSE")));

                        if (((bTrustBounds ||
                              (dfMinX == -180 && dfMinY == -90 &&
                               dfMaxX == 180 && dfMaxY == 90)) &&
                             strcmp(pszProj4,
                                    "+proj=longlat +datum=WGS84 +no_defs") ==
                                 0) ||
                            strcmp(pszDefaultSRS,
                                   "urn:ogc:def:crs:OGC:1.3:CRS84") == 0)
                        {
                            poLayer->SetWGS84Extents(dfMinX, dfMinY, dfMaxX,
                                                     dfMaxY);
                            poLayer->SetExtents(dfMinX, dfMinY, dfMaxX, dfMaxY);
                        }

                        else if (bTrustBounds)
                        {
                            OGRSpatialReference oWGS84;
                            oWGS84.SetWellKnownGeogCS("WGS84");
                            oWGS84.SetAxisMappingStrategy(
                                OAMS_TRADITIONAL_GIS_ORDER);
                            CPLPushErrorHandler(CPLQuietErrorHandler);
                            auto poCT =
                                std::unique_ptr<OGRCoordinateTransformation>(
                                    OGRCreateCoordinateTransformation(&oWGS84,
                                                                      poSRS));
                            if (poCT)
                            {
                                poLayer->SetWGS84Extents(dfMinX, dfMinY, dfMaxX,
                                                         dfMaxY);
                                poCT->TransformBounds(dfMinX, dfMinY, dfMaxX,
                                                      dfMaxY, &dfMinX, &dfMinY,
                                                      &dfMaxX, &dfMaxY, 20);
                                poLayer->SetExtents(dfMinX, dfMinY, dfMaxX,
                                                    dfMaxY);
                            }
                            CPLPopErrorHandler();
                            CPLErrorReset();
                        }
                    }
                    CPLFree(pszProj4);
                }
                poLayer->SetSupportedSRSList(std::move(aosSupportedCRSList),
                                             std::move(apoSupportedCRSList));

                papoLayers = static_cast<OGRWFSLayer **>(CPLRealloc(
                    papoLayers, sizeof(OGRWFSLayer *) * (nLayers + 1)));
                papoLayers[nLayers++] = poLayer;

                if (psFileXML != nullptr)
                {
                    CPLXMLNode *psIter = psXML->psChild;
                    while (psIter)
                    {
                        if (psIter->eType == CXT_Element && psIter->psChild &&
                            EQUAL(psIter->pszValue, "OGRWFSLayer") &&
                            strcmp(CPLGetXMLValue(psIter, "name", ""),
                                   l_pszName) == 0)
                        {
                            const CPLXMLNode *psSchema =
                                WFSFindNode(psIter->psChild, "schema");
                            if (psSchema)
                            {
                                OGRFeatureDefn *poSrcFDefn =
                                    poLayer->ParseSchema(psSchema);
                                if (poSrcFDefn)
                                    poLayer->BuildLayerDefn(poSrcFDefn);
                            }
                            break;
                        }
                        psIter = psIter->psNext;
                    }
                }
            }
        }
    }

    CSLDestroy(papszTypenames);

    if (!psFileXML)
        CPLDestroyXMLNode(psXML);
    CPLDestroyXMLNode(psStrippedXML);

    return TRUE;
}

/************************************************************************/
/*                       LoadMultipleLayerDefn()                        */
/************************************************************************/

/* TinyOWS doesn't support POST, but MapServer, GeoServer and Deegree do */
#define USE_GET_FOR_DESCRIBE_FEATURE_TYPE 1

void OGRWFSDataSource::LoadMultipleLayerDefn(const char *pszLayerName,
                                             char *pszNS, char *pszNSVal)
{
    if (!bLoadMultipleLayerDefn)
        return;

    if (aoSetAlreadyTriedLayers.find(pszLayerName) !=
        aoSetAlreadyTriedLayers.end())
        return;

    std::string osPrefix(pszLayerName);
    const auto nColumnPos = osPrefix.find(':');
    if (nColumnPos == std::string::npos)
        osPrefix.clear();
    else
        osPrefix.resize(nColumnPos);

    OGRWFSLayer *poRefLayer =
        dynamic_cast<OGRWFSLayer *>(GetLayerByName(pszLayerName));
    if (poRefLayer == nullptr)
        return;

    const char *pszRequiredOutputFormat = poRefLayer->GetRequiredOutputFormat();

#if USE_GET_FOR_DESCRIBE_FEATURE_TYPE == 1
    CPLString osLayerToFetch(pszLayerName);
#else
    CPLString osTypeNameToPost;
    osTypeNameToPost += "  <TypeName>";
    osTypeNameToPost += pszLayerName;
    osTypeNameToPost += "</TypeName>\n";
#endif

    int nLayersToFetch = 1;
    aoSetAlreadyTriedLayers.insert(pszLayerName);

    for (int i = 0; i < nLayers; i++)
    {
        if (!papoLayers[i]->HasLayerDefn())
        {
            /* We must be careful to requests only layers with the same
             * prefix/namespace */
            const char *l_pszName = papoLayers[i]->GetName();
            if (((osPrefix.empty() && strchr(l_pszName, ':') == nullptr) ||
                 (!osPrefix.empty() &&
                  strncmp(l_pszName, osPrefix.c_str(), osPrefix.size()) == 0 &&
                  l_pszName[osPrefix.size()] == ':')) &&
                ((pszRequiredOutputFormat == nullptr &&
                  papoLayers[i]->GetRequiredOutputFormat() == nullptr) ||
                 (pszRequiredOutputFormat != nullptr &&
                  papoLayers[i]->GetRequiredOutputFormat() != nullptr &&
                  strcmp(pszRequiredOutputFormat,
                         papoLayers[i]->GetRequiredOutputFormat()) == 0)))
            {
                if (aoSetAlreadyTriedLayers.find(l_pszName) !=
                    aoSetAlreadyTriedLayers.end())
                    continue;
                aoSetAlreadyTriedLayers.insert(l_pszName);

#if USE_GET_FOR_DESCRIBE_FEATURE_TYPE == 1
                if (nLayersToFetch > 0)
                    osLayerToFetch += ",";
                osLayerToFetch += papoLayers[i]->GetName();
#else
                osTypeNameToPost += "  <TypeName>";
                osTypeNameToPost += l_pszName;
                osTypeNameToPost += "</TypeName>\n";
#endif
                nLayersToFetch++;

                /* Avoid fetching to many layer definition at a time */
                if (nLayersToFetch >= 50)
                    break;
            }
        }
    }

#if USE_GET_FOR_DESCRIBE_FEATURE_TYPE == 1
    CPLString osURL(osBaseURL);
    osURL = CPLURLAddKVP(osURL, "SERVICE", "WFS");
    osURL = CPLURLAddKVP(osURL, "VERSION", GetVersion());
    osURL = CPLURLAddKVP(osURL, "REQUEST", "DescribeFeatureType");
    osURL = CPLURLAddKVP(osURL, "TYPENAME", WFS_EscapeURL(osLayerToFetch));
    osURL = CPLURLAddKVP(osURL, "PROPERTYNAME", nullptr);
    osURL = CPLURLAddKVP(osURL, "MAXFEATURES", nullptr);
    osURL = CPLURLAddKVP(osURL, "FILTER", nullptr);
    osURL = CPLURLAddKVP(osURL, "OUTPUTFORMAT",
                         pszRequiredOutputFormat
                             ? WFS_EscapeURL(pszRequiredOutputFormat).c_str()
                             : nullptr);

    if (pszNS && GetNeedNAMESPACE())
    {
        /* Older Deegree version require NAMESPACE */
        /* This has been now corrected */
        CPLString osValue("xmlns(");
        osValue += pszNS;
        osValue += "=";
        osValue += pszNSVal;
        osValue += ")";
        osURL = CPLURLAddKVP(osURL, "NAMESPACE", WFS_EscapeURL(osValue));
    }

    CPLHTTPResult *psResult = HTTPFetch(osURL, nullptr);
#else
    CPLString osPost;
    osPost += "<?xml version=\"1.0\"?>\n";
    osPost +=
        "<wfs:DescribeFeatureType xmlns:wfs=\"http://www.opengis.net/wfs\"\n";
    osPost += "                 "
              "xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"\n";
    osPost += "                 service=\"WFS\" version=\"";
    osPost += GetVersion();
    osPost += "\"\n";
    osPost += "                 xmlns:gml=\"http://www.opengis.net/gml\"\n";
    osPost += "                 xmlns:ogc=\"http://www.opengis.net/ogc\"\n";
    if (pszNS && pszNSVal)
    {
        osPost += "                 xmlns:";
        osPost += pszNS;
        osPost += "=\"";
        osPost += pszNSVal;
        osPost += "\"\n";
    }
    osPost +=
        "                 xsi:schemaLocation=\"http://www.opengis.net/wfs "
        "http://schemas.opengis.net/wfs/";
    osPost += GetVersion();
    osPost += "/wfs.xsd\"";
    const char *pszRequiredOutputFormat = poRefLayer->GetRequiredOutputFormat();
    if (pszRequiredOutputFormat)
    {
        osPost += "\n";
        osPost += "                 outputFormat=\"";
        osPost += pszRequiredOutputFormat;
        osPost += "\"";
    }
    osPost += ">\n";
    osPost += osTypeNameToPost;
    osPost += "</wfs:DescribeFeatureType>\n";

    // CPLDebug("WFS", "%s", osPost.c_str());

    CSLConstList papszOptions = NULL;
    papszOptions = CSLAddNameValue(papszOptions, "POSTFIELDS", osPost.c_str());
    papszOptions =
        CSLAddNameValue(papszOptions, "HEADERS",
                        "Content-Type: application/xml; charset=UTF-8");

    CPLHTTPResult *psResult = HTTPFetch(GetPostTransactionURL(), papszOptions);
    CSLDestroy(papszOptions);
#endif

    if (psResult == nullptr)
    {
        bLoadMultipleLayerDefn = false;
        return;
    }

    const char *pszResponse =
        reinterpret_cast<const char *>(psResult->pabyData);
    if (STARTS_WITH(pszResponse, "<html"))
    {
        // WFS:https://www.statistik.at/gs-open/GEODATA/ows returns a HTML error
        // (with code 200) when requesting all feature types...
        CPLDebug("WFS", "Response to multi-layer DescribeFeatureType: %s",
                 pszResponse);
        CPLHTTPDestroyResult(psResult);
        bLoadMultipleLayerDefn = false;
        return;
    }

    if (strstr(pszResponse, "<ServiceExceptionReport") != nullptr)
    {
        if (IsOldDeegree(pszResponse))
        {
            /* just silently forgive */
        }
        else
        {
            CPLError(CE_Failure, CPLE_AppDefined,
                     "Error returned by server : %s", pszResponse);
        }
        CPLHTTPDestroyResult(psResult);
        bLoadMultipleLayerDefn = false;
        return;
    }

    CPLXMLNode *psXML = CPLParseXMLString(pszResponse);
    if (psXML == nullptr)
    {
        CPLError(CE_Failure, CPLE_AppDefined, "Invalid XML content : %s",
                 pszResponse);
        CPLHTTPDestroyResult(psResult);
        bLoadMultipleLayerDefn = false;
        return;
    }
    CPLHTTPDestroyResult(psResult);

    const CPLXMLNode *psSchema = WFSFindNode(psXML, "schema");
    if (psSchema == nullptr)
    {
        CPLError(CE_Failure, CPLE_AppDefined, "Cannot find <Schema>");
        CPLDestroyXMLNode(psXML);
        bLoadMultipleLayerDefn = false;
        return;
    }

    const CPLString osTmpFileName = VSIMemGenerateHiddenFilename("file.xsd");
    CPLSerializeXMLTreeToFile(psSchema, osTmpFileName);

    std::vector<GMLFeatureClass *> aosClasses;
    bool bFullyUnderstood = false;
    bool bUseSchemaImports = false;
    GMLParseXSD(osTmpFileName, bUseSchemaImports, aosClasses, bFullyUnderstood);

    int nLayersFound = 0;
    if (!aosClasses.empty())
    {
        std::vector<GMLFeatureClass *>::const_iterator oIter =
            aosClasses.begin();
        std::vector<GMLFeatureClass *>::const_iterator oEndIter =
            aosClasses.end();
        while (oIter != oEndIter)
        {
            GMLFeatureClass *poClass = *oIter;
            ++oIter;

            OGRWFSLayer *poLayer = nullptr;

            if (bKeepLayerNamePrefix && pszNS != nullptr &&
                strchr(poClass->GetName(), ':') == nullptr)
            {
                CPLString osWithPrefix(pszNS);
                osWithPrefix += ":";
                osWithPrefix += poClass->GetName();
                poLayer =
                    dynamic_cast<OGRWFSLayer *>(GetLayerByName(osWithPrefix));
            }
            else
                poLayer = dynamic_cast<OGRWFSLayer *>(
                    GetLayerByName(poClass->GetName()));

            if (poLayer)
            {
                if (!poLayer->HasLayerDefn())
                {
                    nLayersFound++;

                    CPLXMLNode *psSchemaForLayer = CPLCloneXMLTree(psSchema);
                    CPLStripXMLNamespace(psSchemaForLayer, nullptr, TRUE);
                    CPLXMLNode *psIter = psSchemaForLayer->psChild;
                    bool bHasAlreadyImportedGML = false;
                    bool bFoundComplexType = false;
                    bool bFoundElement = false;
                    while (psIter != nullptr)
                    {
                        CPLXMLNode *psIterNext = psIter->psNext;
                        if (psIter->eType == CXT_Element &&
                            strcmp(psIter->pszValue, "complexType") == 0)
                        {
                            const char *l_pszName =
                                CPLGetXMLValue(psIter, "name", "");
                            CPLString osExpectedName(poLayer->GetShortName());
                            osExpectedName += "Type";
                            CPLString osExpectedName2(poLayer->GetShortName());
                            osExpectedName2 += "_Type";
                            if (strcmp(l_pszName, osExpectedName) == 0 ||
                                strcmp(l_pszName, osExpectedName2) == 0 ||
                                strcmp(l_pszName, poLayer->GetShortName()) == 0)
                            {
                                bFoundComplexType = true;
                            }
                            else
                            {
                                CPLRemoveXMLChild(psSchemaForLayer, psIter);
                                CPLDestroyXMLNode(psIter);
                            }
                        }
                        else if (psIter->eType == CXT_Element &&
                                 strcmp(psIter->pszValue, "element") == 0)
                        {
                            const char *l_pszName =
                                CPLGetXMLValue(psIter, "name", "");
                            CPLString osExpectedName(poLayer->GetShortName());
                            osExpectedName += "Type";
                            CPLString osExpectedName2(poLayer->GetShortName());
                            osExpectedName2 += "_Type";

                            const char *pszType =
                                CPLGetXMLValue(psIter, "type", "");
                            CPLString osExpectedType(poLayer->GetName());
                            osExpectedType += "Type";
                            CPLString osExpectedType2(poLayer->GetName());
                            osExpectedType2 += "_Type";
                            if (strcmp(pszType, osExpectedType) == 0 ||
                                strcmp(pszType, osExpectedType2) == 0 ||
                                strcmp(pszType, poLayer->GetName()) == 0 ||
                                (strchr(pszType, ':') &&
                                 (strcmp(strchr(pszType, ':') + 1,
                                         osExpectedType) == 0 ||
                                  strcmp(strchr(pszType, ':') + 1,
                                         osExpectedType2) == 0)))
                            {
                                bFoundElement = true;
                            }
                            else if (*pszType == '\0' &&
                                     CPLGetXMLNode(psIter, "complexType") !=
                                         nullptr &&
                                     (strcmp(l_pszName, osExpectedName) == 0 ||
                                      strcmp(l_pszName, osExpectedName2) == 0 ||
                                      strcmp(l_pszName,
                                             poLayer->GetShortName()) == 0))
                            {
                                bFoundElement = true;
                                bFoundComplexType = true;
                            }
                            else
                            {
                                CPLRemoveXMLChild(psSchemaForLayer, psIter);
                                CPLDestroyXMLNode(psIter);
                            }
                        }
                        else if (psIter->eType == CXT_Element &&
                                 strcmp(psIter->pszValue, "import") == 0 &&
                                 strcmp(CPLGetXMLValue(psIter, "namespace", ""),
                                        "http://www.opengis.net/gml") == 0)
                        {
                            if (bHasAlreadyImportedGML)
                            {
                                CPLRemoveXMLChild(psSchemaForLayer, psIter);
                                CPLDestroyXMLNode(psIter);
                            }
                            else
                            {
                                bHasAlreadyImportedGML = true;
                            }
                        }
                        psIter = psIterNext;
                    }

                    if (bFoundComplexType && bFoundElement)
                    {
                        OGRFeatureDefn *poSrcFDefn =
                            poLayer->ParseSchema(psSchemaForLayer);
                        if (poSrcFDefn)
                        {
                            poLayer->BuildLayerDefn(poSrcFDefn);
                            SaveLayerSchema(poLayer->GetName(),
                                            psSchemaForLayer);
                        }
                    }

                    CPLDestroyXMLNode(psSchemaForLayer);
                }
                else
                {
                    CPLDebug("WFS",
                             "Found several time schema for layer %s in "
                             "server response. Should not happen",
                             poClass->GetName());
                }
            }
            delete poClass;
        }
    }

    if (nLayersFound != nLayersToFetch)
    {
        CPLDebug("WFS", "Turn off loading of multiple layer definitions at a "
                        "single time");
        bLoadMultipleLayerDefn = false;
    }

    VSIUnlink(osTmpFileName);

    CPLDestroyXMLNode(psXML);
}

/************************************************************************/
/*                          SaveLayerSchema()                           */
/************************************************************************/

void OGRWFSDataSource::SaveLayerSchema(const char *pszLayerName,
                                       const CPLXMLNode *psSchema)
{
    if (psFileXML != nullptr)
    {
        bRewriteFile = true;
        CPLXMLNode *psLayerNode =
            CPLCreateXMLNode(nullptr, CXT_Element, "OGRWFSLayer");
        CPLSetXMLValue(psLayerNode, "#name", pszLayerName);
        CPLAddXMLChild(psLayerNode, CPLCloneXMLTree(psSchema));
        CPLAddXMLChild(psFileXML, psLayerNode);
    }
}

/************************************************************************/
/*                            IsOldDeegree()                            */
/************************************************************************/

bool OGRWFSDataSource::IsOldDeegree(const char *pszErrorString)
{
    if (!bNeedNAMESPACE &&
        strstr(pszErrorString, "Invalid \"TYPENAME\" parameter. "
                               "No binding for prefix") != nullptr)
    {
        bNeedNAMESPACE = true;
        return true;
    }
    return false;
}

/************************************************************************/
/*                           WFS_EscapeURL()                            */
/************************************************************************/

CPLString WFS_EscapeURL(const char *pszURL)
{
    CPLString osEscapedURL;

    /* Difference with CPLEscapeString(, CPLES_URL) : we do not escape */
    /* colon (:) or comma (,). Causes problems with servers such as
     * http://www.mapinfo.com/miwfs? */

    for (int i = 0; pszURL[i] != '\0'; i++)
    {
        char ch = pszURL[i];
        if ((ch >= 'a' && ch <= 'z') || (ch >= 'A' && ch <= 'Z') ||
            (ch >= '0' && ch <= '9') || ch == '_' || ch == '.' || ch == ':' ||
            ch == ',')
        {
            osEscapedURL += ch;
        }
        else
        {
            char szPercentEncoded[10];
            snprintf(szPercentEncoded, sizeof(szPercentEncoded), "%%%02X",
                     reinterpret_cast<const unsigned char *>(pszURL)[i]);
            osEscapedURL += szPercentEncoded;
        }
    }

    return osEscapedURL;
}

/************************************************************************/
/*                           WFS_DecodeURL()                            */
/************************************************************************/

CPLString WFS_DecodeURL(const CPLString &osSrc)
{
    CPLString ret;
    for (size_t i = 0; i < osSrc.length(); i++)
    {
        if (osSrc[i] == '%' && i + 2 < osSrc.length())
        {
            unsigned int ii = 0;
            sscanf(osSrc.substr(i + 1, 2).c_str(), "%x", &ii);
            char ch = static_cast<char>(ii);
            ret += ch;
            i = i + 2;
        }
        else
        {
            ret += osSrc[i];
        }
    }
    return ret;
}

/************************************************************************/
/*                             HTTPFetch()                              */
/************************************************************************/

CPLHTTPResult *OGRWFSDataSource::HTTPFetch(const char *pszURL,
                                           CSLConstList papszOptions)
{
    char **papszNewOptions = CSLDuplicate(papszOptions);
    if (bUseHttp10)
        papszNewOptions =
            CSLAddNameValue(papszNewOptions, "HTTP_VERSION", "1.0");
    if (papszHttpOptions)
        papszNewOptions = CSLMerge(papszNewOptions, papszHttpOptions);
    CPLHTTPResult *psResult = CPLHTTPFetch(pszURL, papszNewOptions);
    CSLDestroy(papszNewOptions);

    if (psResult == nullptr)
    {
        return nullptr;
    }
    if (psResult->nStatus != 0 || psResult->pszErrBuf != nullptr)
    {
        // A few buggy servers return chunked data with erroneous
        // remaining bytes value curl does not like this. Retry with
        // HTTP 1.0 protocol instead that does not support chunked
        // data.
        if (psResult->pszErrBuf &&
            strstr(psResult->pszErrBuf,
                   "transfer closed with outstanding read data remaining") &&
            !bUseHttp10)
        {
            CPLDebug("WFS", "Probably buggy remote server. Retrying with HTTP "
                            "1.0 protocol");
            bUseHttp10 = true;
            CPLHTTPDestroyResult(psResult);
            return HTTPFetch(pszURL, papszOptions);
        }

        CPLError(CE_Failure, CPLE_AppDefined,
                 "Error returned by server : %s (%d)",
                 (psResult->pszErrBuf) ? psResult->pszErrBuf : "unknown",
                 psResult->nStatus);
        CPLHTTPDestroyResult(psResult);
        return nullptr;
    }
    if (psResult->pabyData == nullptr)
    {
        CPLError(CE_Failure, CPLE_AppDefined,
                 "Empty content returned by server");
        CPLHTTPDestroyResult(psResult);
        return nullptr;
    }
    return psResult;
}

/************************************************************************/
/*                             ExecuteSQL()                             */
/************************************************************************/

OGRLayer *OGRWFSDataSource::ExecuteSQL(const char *pszSQLCommand,
                                       OGRGeometry *poSpatialFilter,
                                       const char *pszDialect)

{
    while (*pszSQLCommand &&
           isspace(static_cast<unsigned char>(*pszSQLCommand)))
        ++pszSQLCommand;

    swq_select_parse_options oParseOptions;
    oParseOptions.poCustomFuncRegistrar = WFSGetCustomFuncRegistrar();

    /* -------------------------------------------------------------------- */
    /*      Use generic implementation for recognized dialects              */
    /* -------------------------------------------------------------------- */
    if (IsGenericSQLDialect(pszDialect))
    {
        OGRLayer *poResLayer = GDALDataset::ExecuteSQL(
            pszSQLCommand, poSpatialFilter, pszDialect, &oParseOptions);
        oMap[poResLayer] = nullptr;
        return poResLayer;
    }

    /* -------------------------------------------------------------------- */
    /*      Deal with "SELECT _LAST_INSERTED_FIDS_ FROM layername" statement */
    /* -------------------------------------------------------------------- */
    if (STARTS_WITH_CI(pszSQLCommand, "SELECT _LAST_INSERTED_FIDS_ FROM "))
    {
        const char *pszIter = pszSQLCommand + 33;
        while (*pszIter && *pszIter != ' ')
            pszIter++;

        CPLString osName = pszSQLCommand + 33;
        osName.resize(pszIter - (pszSQLCommand + 33));
        OGRWFSLayer *poLayer =
            dynamic_cast<OGRWFSLayer *>(GetLayerByName(osName));
        if (poLayer == nullptr)
        {
            CPLError(CE_Failure, CPLE_AppDefined, "Unknown layer : %s",
                     osName.c_str());
            return nullptr;
        }

        auto poMEMDS = std::unique_ptr<MEMDataset>(
            MEMDataset::Create("dummy_name", 0, 0, 0, GDT_Unknown, nullptr));
        OGRLayer *poMEMLayer =
            poMEMDS->CreateLayer("FID_LIST", nullptr, wkbNone, nullptr);
        OGRFieldDefn oFDefn("gml_id", OFTString);
        CPL_IGNORE_RET_VAL(poMEMLayer->CreateField(&oFDefn));

        for (const auto &osFID : poLayer->GetLastInsertedFIDList())
        {
            OGRFeature oFeature(poMEMLayer->GetLayerDefn());
            oFeature.SetField(0, osFID);
            CPL_IGNORE_RET_VAL(poMEMLayer->CreateFeature(&oFeature));
        }

        OGRLayer *poResLayer =
            new OGRWFSWrappedResultLayer(poMEMDS.release(), poMEMLayer);
        oMap[poResLayer] = nullptr;
        return poResLayer;
    }

    /* -------------------------------------------------------------------- */
    /*      Deal with "DELETE FROM layer_name WHERE expression" statement   */
    /* -------------------------------------------------------------------- */
    if (STARTS_WITH_CI(pszSQLCommand, "DELETE FROM "))
    {
        const char *pszIter = pszSQLCommand + 12;
        while (*pszIter && *pszIter != ' ')
            pszIter++;
        if (*pszIter == 0)
        {
            CPLError(CE_Failure, CPLE_AppDefined, "Invalid statement");
            return nullptr;
        }

        CPLString osName = pszSQLCommand + 12;
        osName.resize(pszIter - (pszSQLCommand + 12));
        OGRWFSLayer *poLayer =
            dynamic_cast<OGRWFSLayer *>(GetLayerByName(osName));
        if (poLayer == nullptr)
        {
            CPLError(CE_Failure, CPLE_AppDefined, "Unknown layer : %s",
                     osName.c_str());
            return nullptr;
        }

        while (*pszIter == ' ')
            pszIter++;
        if (!STARTS_WITH_CI(pszIter, "WHERE "))
        {
            CPLError(CE_Failure, CPLE_AppDefined, "WHERE clause missing");
            return nullptr;
        }
        pszIter += 5;

        const char *pszQuery = pszIter;

        /* Check with the generic SQL engine that this is a valid WHERE clause
         */
        OGRFeatureQuery oQuery;
        OGRErr eErr = oQuery.Compile(poLayer->GetLayerDefn(), pszQuery);
        if (eErr != OGRERR_NONE)
        {
            return nullptr;
        }

        /* Now turn this into OGC Filter language if possible */
        int bNeedsNullCheck = FALSE;
        int nVersion = (strcmp(GetVersion(), "1.0.0") == 0) ? 100 : 110;
        swq_expr_node *poNode =
            static_cast<swq_expr_node *>(oQuery.GetSWQExpr());
        poNode->ReplaceBetweenByGEAndLERecurse();
        poNode->ReplaceInByOrRecurse();
        CPLString osOGCFilter = WFS_TurnSQLFilterToOGCFilter(
            poNode, nullptr, poLayer->GetLayerDefn(), nVersion,
            bPropertyIsNotEqualToSupported, bUseFeatureId,
            bGmlObjectIdNeedsGMLPrefix, "", &bNeedsNullCheck);
        if (bNeedsNullCheck && !HasNullCheck())
            osOGCFilter = "";

        if (osOGCFilter.empty())
        {
            CPLError(CE_Failure, CPLE_AppDefined,
                     "Cannot convert WHERE clause into a OGC filter");
            return nullptr;
        }

        poLayer->DeleteFromFilter(osOGCFilter);

        return nullptr;
    }

    /* -------------------------------------------------------------------- */
    /*      Deal with "SELECT xxxx ORDER BY" statement                      */
    /* -------------------------------------------------------------------- */
    if (STARTS_WITH_CI(pszSQLCommand, "SELECT"))
    {
        swq_select *psSelectInfo = new swq_select();
        if (psSelectInfo->preparse(pszSQLCommand, TRUE) != CE_None)
        {
            delete psSelectInfo;
            return nullptr;
        }
        int iLayer = 0;
        if (strcmp(GetVersion(), "1.0.0") != 0 &&
            psSelectInfo->table_count == 1 &&
            psSelectInfo->table_defs[0].data_source == nullptr &&
            (iLayer = GetLayerIndex(psSelectInfo->table_defs[0].table_name)) >=
                0 &&
            psSelectInfo->join_count == 0 && psSelectInfo->order_specs > 0 &&
            psSelectInfo->poOtherSelect == nullptr)
        {
            OGRWFSLayer *poSrcLayer = papoLayers[iLayer];
            std::vector<OGRWFSSortDesc> aoSortColumns;
            int i = 0;  // Used after for.
            for (; i < psSelectInfo->order_specs; i++)
            {
                int nFieldIndex = poSrcLayer->GetLayerDefn()->GetFieldIndex(
                    psSelectInfo->order_defs[i].field_name);
                if (poSrcLayer->HasGotApproximateLayerDefn() || nFieldIndex < 0)
                    break;

                /* Make sure to have the right case */
                const char *pszFieldName = poSrcLayer->GetLayerDefn()
                                               ->GetFieldDefn(nFieldIndex)
                                               ->GetNameRef();

                aoSortColumns.emplace_back(
                    pszFieldName, psSelectInfo->order_defs[i].ascending_flag);
            }

            if (i == psSelectInfo->order_specs)
            {
                OGRWFSLayer *poDupLayer = poSrcLayer->Clone();

                poDupLayer->SetOrderBy(aoSortColumns);
                int nBackup = psSelectInfo->order_specs;
                psSelectInfo->order_specs = 0;
                char *pszSQLWithoutOrderBy = psSelectInfo->Unparse();
                CPLDebug("WFS", "SQL without ORDER BY: %s",
                         pszSQLWithoutOrderBy);
                psSelectInfo->order_specs = nBackup;
                delete psSelectInfo;
                psSelectInfo = nullptr;

                /* Just set poDupLayer in the papoLayers for the time of the */
                /* base ExecuteSQL(), so that the OGRGenSQLResultsLayer
                 * references */
                /* that temporary layer */
                papoLayers[iLayer] = poDupLayer;

                OGRLayer *poResLayer = GDALDataset::ExecuteSQL(
                    pszSQLWithoutOrderBy, poSpatialFilter, pszDialect,
                    &oParseOptions);
                papoLayers[iLayer] = poSrcLayer;

                CPLFree(pszSQLWithoutOrderBy);

                if (poResLayer != nullptr)
                    oMap[poResLayer] = poDupLayer;
                else
                    delete poDupLayer;
                return poResLayer;
            }
        }
        else if (bStandardJoinsWFS2 && psSelectInfo->join_count > 0 &&
                 psSelectInfo->poOtherSelect == nullptr)
        {
            // Just to make sure everything is valid, but we won't use
            // that one as we want to run the join on server-side
            oParseOptions.bAllowFieldsInSecondaryTablesInWhere = TRUE;
            oParseOptions.bAddSecondaryTablesGeometryFields = TRUE;
            oParseOptions.bAlwaysPrefixWithTableName = TRUE;
            oParseOptions.bAllowDistinctOnGeometryField = TRUE;
            oParseOptions.bAllowDistinctOnMultipleFields = TRUE;
            GDALSQLParseInfo *psParseInfo =
                BuildParseInfo(psSelectInfo, &oParseOptions);
            oParseOptions.bAllowFieldsInSecondaryTablesInWhere = FALSE;
            oParseOptions.bAddSecondaryTablesGeometryFields = FALSE;
            oParseOptions.bAlwaysPrefixWithTableName = FALSE;
            oParseOptions.bAllowDistinctOnGeometryField = FALSE;
            oParseOptions.bAllowDistinctOnMultipleFields = FALSE;
            const bool bOK = psParseInfo != nullptr;
            DestroyParseInfo(psParseInfo);

            OGRLayer *poResLayer = nullptr;
            if (bOK)
            {
                poResLayer = OGRWFSJoinLayer::Build(this, psSelectInfo);
                oMap[poResLayer] = nullptr;
            }

            delete psSelectInfo;
            return poResLayer;
        }

        delete psSelectInfo;
    }

    OGRLayer *poResLayer = GDALDataset::ExecuteSQL(
        pszSQLCommand, poSpatialFilter, pszDialect, &oParseOptions);
    oMap[poResLayer] = nullptr;
    return poResLayer;
}

/************************************************************************/
/*                          ReleaseResultSet()                          */
/************************************************************************/

void OGRWFSDataSource::ReleaseResultSet(OGRLayer *poResultsSet)
{
    if (poResultsSet == nullptr)
        return;

    std::map<OGRLayer *, OGRLayer *>::iterator oIter = oMap.find(poResultsSet);
    if (oIter != oMap.end())
    {
        /* Destroy first the result layer, because it still references */
        /* the poDupLayer (oIter->second) */
        delete poResultsSet;

        delete oIter->second;
        oMap.erase(oIter);
    }
    else
    {
        CPLError(CE_Failure, CPLE_AppDefined,
                 "Trying to destroy an invalid result set !");
    }
}

Coverage Report

Created: 2026-11-12 08:28