#include <iostream>

#include <iostream>

#include <list>

#include <list>

#include <map>

#include <map>

#include <algorithm>

#include <algorithm>

#include "pathut.h"

#include "pathut.h"

#include "conftree.h"

#include "conftree.h"

#include "rclconfig.h"

#include "rclconfig.h"

#include "fstreewalk.h"

#include "fstreewalk.h"

#include "rcldb.h"

#include "rcldb.h"

{

{

    if (!init())

    if (!init())

    return false;

    return false;

    for (list<string>::iterator it = files.begin(); it != files.end(); ) {

    for (list<string>::iterator it = files.begin(); it != files.end(); ) {

    string udi;

    string udi;

        // rcldb::purgefile returns true if the udi was either not

        // rcldb::purgefile returns true if the udi was either not

        // found or deleted, false only in case of actual error

        // found or deleted, false only in case of actual error

        bool existed;

        bool existed;

    if (!m_db->purgeFile(udi, &existed)) {

    if (!m_db->purgeFile(udi, &existed)) {

        LOGERR(("FsIndexer::purgeFiles: Database error\n"));

        LOGERR(("FsIndexer::purgeFiles: Database error\n"));

    // against the stored one). Changing the computation forces a full

    // against the stored one). Changing the computation forces a full

    // reindex of course.

    // reindex of course.

    string sig;

    string sig;

    makesig(stp, sig);

    makesig(stp, sig);

    string udi;

    string udi;

    if (!m_db->needUpdate(udi, sig)) {

    if (!m_db->needUpdate(udi, sig)) {

    LOGDEB0(("processone: up to date: %s\n", fn.c_str()));

    LOGDEB0(("processone: up to date: %s\n", fn.c_str()));

    if (m_updater) {

    if (m_updater) {

        // Status bar update, abort request etc.

        // Status bar update, abort request etc.

        m_updater->status.fn = fn;

        m_updater->status.fn = fn;

    LOGDEB2(("processone: fn transcoded from [%s] to [%s] (%s->%s)\n",

    LOGDEB2(("processone: fn transcoded from [%s] to [%s] (%s->%s)\n",

         path_getsimple(fn).c_str(), utf8fn.c_str(), charset.c_str(), 

         path_getsimple(fn).c_str(), utf8fn.c_str(), charset.c_str(), 

         "UTF-8"));

         "UTF-8"));

    string parent_udi;

    string parent_udi;

    Rcl::Doc doc;

    Rcl::Doc doc;

    char ascdate[30];

    char ascdate[30];

    sprintf(ascdate, "%ld", long(stp->st_mtime));

    sprintf(ascdate, "%ld", long(stp->st_mtime));

    FileInterner::Status fis = FileInterner::FIAgain;

    FileInterner::Status fis = FileInterner::FIAgain;

    bool hadNullIpath = false;

    bool hadNullIpath = false;

    // Set file name, mod time and url if not done by filter

    // Set file name, mod time and url if not done by filter

    if (doc.fmtime.empty())

    if (doc.fmtime.empty())

        doc.fmtime = ascdate;

        doc.fmtime = ascdate;

        if (doc.url.empty())

        if (doc.url.empty())

    if (doc.utf8fn.empty())

    if (doc.utf8fn.empty())

        doc.utf8fn = utf8fn;

        doc.utf8fn = utf8fn;

    char cbuf[100]; 

    char cbuf[100]; 

    sprintf(cbuf, OFFTPC, stp->st_size);

    sprintf(cbuf, OFFTPC, stp->st_size);

    // retried. This is for the once missing, later installed

    // retried. This is for the once missing, later installed

    // filter case. It can make indexing much slower (if there are

    // filter case. It can make indexing much slower (if there are

    // myriads of such files, the ext script is executed for them

    // myriads of such files, the ext script is executed for them

    // and fails every time)

    // and fails every time)

    if (fis == FileInterner::FIError) {

    if (fis == FileInterner::FIError) {

        doc.sig += plus;

    }

    }

        // Possibly add fields from local config

        // Possibly add fields from local config

        if (m_havelocalfields) 

        if (m_havelocalfields) 

            setlocalfields(doc);

            setlocalfields(doc);

    // Add document to database. If there is an ipath, add it as a children

    // Add document to database. If there is an ipath, add it as a children

    // of the file document.

    // of the file document.

    string udi;

    string udi;

    make_udi(fn, doc.ipath, udi);

    make_udi(fn, doc.ipath, udi);

        return FsTreeWalker::FtwError;

        return FsTreeWalker::FtwError;

    // Tell what we are doing and check for interrupt request

    // Tell what we are doing and check for interrupt request

    if (m_updater) {

    if (m_updater) {

        ++(m_updater->status.docsdone);

        ++(m_updater->status.docsdone);

    LOGDEB1(("Creating empty doc for file\n"));

    LOGDEB1(("Creating empty doc for file\n"));

    Rcl::Doc fileDoc;

    Rcl::Doc fileDoc;

    fileDoc.fmtime = ascdate;

    fileDoc.fmtime = ascdate;

    fileDoc.utf8fn = utf8fn;

    fileDoc.utf8fn = utf8fn;

    fileDoc.mimetype = interner.getMimetype();

    fileDoc.mimetype = interner.getMimetype();

    char cbuf[100]; 

    char cbuf[100]; 

    sprintf(cbuf, OFFTPC, stp->st_size);

    sprintf(cbuf, OFFTPC, stp->st_size);

    fileDoc.fbytes = cbuf;

    fileDoc.fbytes = cbuf;

    // Document signature for up to date checks.

    // Document signature for up to date checks.

    makesig(stp, fileDoc.sig);

    makesig(stp, fileDoc.sig);

        return FsTreeWalker::FtwError;

        return FsTreeWalker::FtwError;

    }

    }

    return FsTreeWalker::FtwOk;

    return FsTreeWalker::FtwOk;

}

}