diff --git a/gpt4all-chat/CMakeLists.txt b/gpt4all-chat/CMakeLists.txt
index 2b41ff46..51b5b1bc 100644
--- a/gpt4all-chat/CMakeLists.txt
+++ b/gpt4all-chat/CMakeLists.txt
@@ -36,7 +36,7 @@ configure_file(
   "${CMAKE_CURRENT_BINARY_DIR}/config.h"
 )
 
-find_package(Qt6 6.5 COMPONENTS Core Quick QuickDialogs2 Svg HttpServer REQUIRED)
+find_package(Qt6 6.5 COMPONENTS Core Quick QuickDialogs2 Svg HttpServer Sql Pdf REQUIRED)
 
 # Get the Qt6Core target properties
 get_target_property(Qt6Core_INCLUDE_DIRS Qt6::Core INTERFACE_INCLUDE_DIRECTORIES)
@@ -64,6 +64,7 @@ qt_add_executable(chat
     chatgpt.h chatgpt.cpp
     download.h download.cpp
     network.h network.cpp
+    localdocs.h localdocs.cpp
     llm.h llm.cpp
     server.h server.cpp
     sysinfo.h
@@ -124,7 +125,7 @@ endif()
 target_compile_definitions(chat
     PRIVATE $<$<OR:$<CONFIG:Debug>,$<CONFIG:RelWithDebInfo>>:QT_QML_DEBUG>)
 target_link_libraries(chat
-    PRIVATE Qt6::Quick Qt6::Svg Qt6::HttpServer)
+    PRIVATE Qt6::Quick Qt6::Svg Qt6::HttpServer Qt6::Sql Qt6::Pdf)
 target_link_libraries(chat
     PRIVATE llmodel)
 
diff --git a/gpt4all-chat/chat.cpp b/gpt4all-chat/chat.cpp
index be80c3bc..ac714a7c 100644
--- a/gpt4all-chat/chat.cpp
+++ b/gpt4all-chat/chat.cpp
@@ -1,5 +1,6 @@
 #include "chat.h"
 #include "llm.h"
+#include "localdocs.h"
 #include "network.h"
 #include "download.h"
 
@@ -42,6 +43,7 @@ void Chat::connectLLM()
     // Should be in same thread
     connect(Download::globalInstance(), &Download::modelListChanged, this, &Chat::modelListChanged, Qt::DirectConnection);
     connect(this, &Chat::modelNameChanged, this, &Chat::modelListChanged, Qt::DirectConnection);
+    connect(LocalDocs::globalInstance(), &LocalDocs::receivedResult, this, &Chat::handleLocalDocsRetrieved, Qt::DirectConnection);
 
     // Should be in different threads
     connect(m_llmodel, &ChatLLM::isModelLoadedChanged, this, &Chat::isModelLoadedChanged, Qt::QueuedConnection);
@@ -97,8 +99,38 @@ void Chat::prompt(const QString &prompt, const QString &prompt_template, int32_t
     int32_t top_k, float top_p, float temp, int32_t n_batch, float repeat_penalty,
     int32_t repeat_penalty_tokens)
 {
-    emit promptRequested(prompt, prompt_template, n_predict, top_k, top_p, temp, n_batch,
-        repeat_penalty, repeat_penalty_tokens, LLM::globalInstance()->threadCount());
+    m_queuedPrompt.prompt = prompt;
+    m_queuedPrompt.prompt_template = prompt_template;
+    m_queuedPrompt.n_predict = n_predict;
+    m_queuedPrompt.top_k = top_k;
+    m_queuedPrompt.temp = temp;
+    m_queuedPrompt.n_batch = n_batch;
+    m_queuedPrompt.repeat_penalty = repeat_penalty;
+    m_queuedPrompt.repeat_penalty_tokens = repeat_penalty_tokens;
+    LocalDocs::globalInstance()->requestRetrieve(QList<QString>("localdocs"), prompt);
+}
+
+void Chat::handleLocalDocsRetrieved()
+{
+    QList<QString> augmentedTemplate;
+    QList<QString> results = LocalDocs::globalInstance()->result();
+    if (!results.isEmpty()) {
+        augmentedTemplate.append("### Context:");
+        augmentedTemplate.append(results);
+    }
+    augmentedTemplate.append(m_queuedPrompt.prompt_template);
+    emit promptRequested(
+        m_queuedPrompt.prompt,
+        augmentedTemplate.join("\n"),
+        m_queuedPrompt.n_predict,
+        m_queuedPrompt.top_k,
+        m_queuedPrompt.top_p,
+        m_queuedPrompt.temp,
+        m_queuedPrompt.n_batch,
+        m_queuedPrompt.repeat_penalty,
+        m_queuedPrompt.repeat_penalty_tokens,
+        LLM::globalInstance()->threadCount());
+    m_queuedPrompt = Prompt();
 }
 
 void Chat::regenerateResponse()
diff --git a/gpt4all-chat/chat.h b/gpt4all-chat/chat.h
index 974378bc..b4f30015 100644
--- a/gpt4all-chat/chat.h
+++ b/gpt4all-chat/chat.h
@@ -94,6 +94,7 @@ Q_SIGNALS:
     void isServerChanged();
 
 private Q_SLOTS:
+    void handleLocalDocsRetrieved();
     void handleResponseChanged();
     void handleModelLoadedChanged();
     void responseStarted();
@@ -103,6 +104,18 @@ private Q_SLOTS:
     void handleModelNameChanged();
 
 private:
+    struct Prompt {
+        QString prompt;
+        QString prompt_template;
+        int32_t n_predict;
+        int32_t top_k;
+        float top_p;
+        float temp;
+        int32_t n_batch;
+        float repeat_penalty;
+        int32_t repeat_penalty_tokens;
+    };
+
     QString m_id;
     QString m_name;
     QString m_userName;
@@ -113,6 +126,7 @@ private:
     ChatLLM *m_llmodel;
     bool m_isServer;
     bool m_shouldDeleteLater;
+    Prompt m_queuedPrompt;
 };
 
 #endif // CHAT_H
diff --git a/gpt4all-chat/chatllm.cpp b/gpt4all-chat/chatllm.cpp
index 481a2256..8291200d 100644
--- a/gpt4all-chat/chatllm.cpp
+++ b/gpt4all-chat/chatllm.cpp
@@ -421,15 +421,15 @@ bool ChatLLM::prompt(const QString &prompt, const QString &prompt_template, int3
     m_ctx.repeat_penalty = repeat_penalty;
     m_ctx.repeat_last_n = repeat_penalty_tokens;
     m_modelInfo.model->setThreadCount(n_threads);
-#if defined(DEBUG)
+//#if defined(DEBUG)
     printf("%s", qPrintable(instructPrompt));
     fflush(stdout);
-#endif
+//#endif
     m_modelInfo.model->prompt(instructPrompt.toStdString(), promptFunc, responseFunc, recalcFunc, m_ctx);
-#if defined(DEBUG)
+//#if defined(DEBUG)
     printf("\n");
     fflush(stdout);
-#endif
+//#endif
     m_responseLogits += m_ctx.logits.size() - logitsBefore;
     std::string trimmed = trim_whitespace(m_response);
     if (trimmed != m_response) {
diff --git a/gpt4all-chat/localdocs.cpp b/gpt4all-chat/localdocs.cpp
new file mode 100644
index 00000000..4d9b461a
--- /dev/null
+++ b/gpt4all-chat/localdocs.cpp
@@ -0,0 +1,751 @@
+#include "localdocs.h"
+#include "download.h"
+
+#include <QTimer>
+#include <QPdfDocument>
+
+#define DEBUG
+//#define DEBUG_EXAMPLE
+
+#define LOCALDOCS_VERSION 0
+
+const auto INSERT_CHUNK_SQL = QLatin1String(R"(
+    insert into chunks(document_id, chunk_id, chunk_text,
+        embedding_id, embedding_path) values(?, ?, ?, ?, ?);
+    )");
+
+const auto INSERT_CHUNK_FTS_SQL = QLatin1String(R"(
+    insert into chunks_fts(document_id, chunk_id, chunk_text,
+        embedding_id, embedding_path) values(?, ?, ?, ?, ?);
+    )");
+
+const auto DELETE_CHUNKS_SQL = QLatin1String(R"(
+    DELETE FROM chunks WHERE document_id = ?;
+    )");
+
+const auto DELETE_CHUNKS_FTS_SQL = QLatin1String(R"(
+    DELETE FROM chunks_fts WHERE document_id = ?;
+    )");
+
+const auto CHUNKS_SQL = QLatin1String(R"(
+    create table chunks(document_id integer, chunk_id integer, chunk_text varchar,
+        embedding_id integer, embedding_path varchar);
+    )");
+
+const auto FTS_CHUNKS_SQL = QLatin1String(R"(
+    create virtual table chunks_fts using fts5(document_id unindexed, chunk_id unindexed, chunk_text,
+        embedding_id unindexed, embedding_path unindexed, tokenize="trigram");
+    )");
+
+const auto SELECT_SQL = QLatin1String(R"(
+    select chunks_fts.rowid, chunks_fts.document_id, chunks_fts.chunk_text
+    from chunks_fts
+    join documents ON chunks_fts.document_id = documents.id
+    join folders ON documents.folder_id = folders.id
+    join collections ON folders.id = collections.folder_id
+    where chunks_fts match ? and collections.collection_name in (%1)
+    order by bm25(chunks_fts) desc
+    limit 3;
+    )");
+
+bool addChunk(QSqlQuery &q, int document_id, int chunk_id, const QString &chunk_text, int embedding_id,
+    const QString &embedding_path)
+{
+    {
+        if (!q.prepare(INSERT_CHUNK_SQL))
+            return false;
+        q.addBindValue(document_id);
+        q.addBindValue(chunk_id);
+        q.addBindValue(chunk_text);
+        q.addBindValue(embedding_id);
+        q.addBindValue(embedding_path);
+        if (!q.exec())
+            return false;
+    }
+    {
+        if (!q.prepare(INSERT_CHUNK_FTS_SQL))
+            return false;
+        q.addBindValue(document_id);
+        q.addBindValue(chunk_id);
+        q.addBindValue(chunk_text);
+        q.addBindValue(embedding_id);
+        q.addBindValue(embedding_path);
+        if (!q.exec())
+            return false;
+    }
+    return true;
+}
+
+bool deleteChunksByDocumentId(QSqlQuery &q, int document_id)
+{
+    {
+        if (!q.prepare(DELETE_CHUNKS_SQL))
+            return false;
+        q.addBindValue(document_id);
+        if (!q.exec())
+            return false;
+    }
+
+    {
+        if (!q.prepare(DELETE_CHUNKS_FTS_SQL))
+            return false;
+        q.addBindValue(document_id);
+        if (!q.exec())
+            return false;
+    }
+
+    return true;
+}
+
+QStringList generateGrams(const QString &input, int N)
+{
+    // Remove common English punctuation using QRegularExpression
+    QRegularExpression punctuation(R"([.,;:!?'"()\-])");
+    QString cleanedInput = input;
+    cleanedInput = cleanedInput.remove(punctuation);
+
+    // Split the cleaned input into words using whitespace
+    QStringList words = cleanedInput.split(QRegularExpression("\\s+"), Qt::SkipEmptyParts);
+    N = qMin(words.size(), N);
+
+    // Generate all possible N-grams
+    QStringList ngrams;
+    for (int i = 0; i < words.size() - (N - 1); ++i) {
+        QStringList currentNgram;
+        for (int j = 0; j < N; ++j) {
+            currentNgram.append(words[i + j]);
+        }
+        ngrams.append("\"" + currentNgram.join(" ") + "\"");
+    }
+    return ngrams;
+}
+
+bool selectChunk(QSqlQuery &q, const QList<QString> &collection_names, const QString &chunk_text)
+{
+    for (int N = 5; N > 1; N--) {
+        // first try trigrams
+        QList<QString> text = generateGrams(chunk_text, N);
+        QString orText = text.join(" OR ");
+        qDebug() << "before" << chunk_text << "after" << orText;
+        const QString collection_names_str = collection_names.join("', '");
+        const QString formatted_query = SELECT_SQL.arg("'" + collection_names_str + "'");
+        if (!q.prepare(formatted_query))
+            return false;
+        q.addBindValue(orText);
+        bool success = q.exec();
+        if (!success) return false;
+        if (q.next()) {
+            q.previous();
+            return true;
+        }
+    }
+    return true;
+}
+
+void printResults(QSqlQuery &q)
+{
+    while (q.next()) {
+        int rowid = q.value(0).toInt();
+        QString collection_name = q.value(1).toString();
+        QString chunk_text = q.value(2).toString();
+
+        qDebug() << "rowid:" << rowid
+                 << "collection_name:" << collection_name
+                 << "chunk_text:" << chunk_text;
+    }
+}
+
+const auto INSERT_COLLECTION_SQL = QLatin1String(R"(
+    insert into collections(collection_name, folder_id) values(?, ?);
+    )");
+
+const auto COLLECTIONS_SQL = QLatin1String(R"(
+    create table collections(collection_name varchar, folder_id integer, unique(collection_name, folder_id));
+    )");
+
+const auto SELECT_FOLDERS_FROM_COLLECTIONS_SQL = QLatin1String(R"(
+    select folder_id from collections where collection_name = ?;
+    )");
+
+bool addCollection(QSqlQuery &q, const QString &collection_name, int folder_id)
+{
+    if (!q.prepare(INSERT_COLLECTION_SQL))
+        return false;
+    q.addBindValue(collection_name);
+    q.addBindValue(folder_id);
+    return q.exec();
+}
+
+bool selectFoldersFromCollection(QSqlQuery &q, const QString &collection_name, QList<int> *folderIds) {
+    if (!q.prepare(SELECT_FOLDERS_FROM_COLLECTIONS_SQL))
+        return false;
+    q.addBindValue(collection_name);
+    if (!q.exec())
+        return false;
+    while (q.next())
+        folderIds->append(q.value(0).toInt());
+    return true;
+}
+
+const auto INSERT_FOLDERS_SQL = QLatin1String(R"(
+    insert into folders(folder_path) values(?);
+    )");
+
+const auto DELETE_FOLDERS_SQL = QLatin1String(R"(
+    delete from folders where folder_path = ?;
+    )");
+
+const auto SELECT_FOLDERS_SQL = QLatin1String(R"(
+    select id from folders where folder_path = ?;
+    )");
+
+const auto FOLDERS_SQL = QLatin1String(R"(
+    create table folders(id integer primary key, folder_path varchar unique);
+    )");
+
+bool addFolderToDB(QSqlQuery &q, const QString &folder_path, int *folder_id)
+{
+    if (!q.prepare(INSERT_FOLDERS_SQL))
+        return false;
+    q.addBindValue(folder_path);
+    if (!q.exec())
+        return false;
+    *folder_id = q.lastInsertId().toInt();
+    return true;
+}
+
+bool removeFolderFromDB(QSqlQuery &q, const QString &folder_path) {
+    if (!q.prepare(DELETE_FOLDERS_SQL))
+        return false;
+    q.addBindValue(folder_path);
+    return q.exec();
+}
+
+bool selectFolder(QSqlQuery &q, const QString &folder_path, int *id) {
+    if (!q.prepare(SELECT_FOLDERS_SQL))
+        return false;
+    q.addBindValue(folder_path);
+    if (!q.exec())
+        return false;
+    Q_ASSERT(q.size() < 2);
+    if (q.next())
+        *id = q.value(0).toInt();
+    return true;
+}
+
+const auto INSERT_DOCUMENTS_SQL = QLatin1String(R"(
+    insert into documents(folder_id, document_time, document_path) values(?, ?, ?);
+    )");
+
+const auto UPDATE_DOCUMENT_TIME_SQL = QLatin1String(R"(
+    update documents set document_time = ? where id = ?;
+    )");
+
+const auto DOCUMENTS_SQL = QLatin1String(R"(
+    create table documents(id integer primary key, folder_id integer, document_time integer, document_path varchar unique);
+    )");
+
+const auto SELECT_DOCUMENT_SQL = QLatin1String(R"(
+    select id, document_time from documents where document_path = ?;
+    )");
+
+bool addDocument(QSqlQuery &q, int folder_id, int document_time, const QString &document_path, int *document_id)
+{
+    if (!q.prepare(INSERT_DOCUMENTS_SQL))
+        return false;
+    q.addBindValue(folder_id);
+    q.addBindValue(document_time);
+    q.addBindValue(document_path);
+    if (!q.exec())
+        return false;
+    *document_id = q.lastInsertId().toInt();
+    return true;
+}
+
+bool updateDocument(QSqlQuery &q, int id, int document_time)
+{
+    if (!q.prepare(UPDATE_DOCUMENT_TIME_SQL))
+        return false;
+    q.addBindValue(id);
+    q.addBindValue(document_time);
+    return q.exec();
+}
+
+bool selectDocument(QSqlQuery &q, const QString &document_path, int *id, int *document_time) {
+    if (!q.prepare(SELECT_DOCUMENT_SQL))
+        return false;
+    q.addBindValue(document_path);
+    if (!q.exec())
+        return false;
+    Q_ASSERT(q.size() < 2);
+    if (q.next()) {
+        *id = q.value(0).toInt();
+        *document_time = q.value(1).toInt();
+    }
+    return true;
+}
+
+QSqlError initDb()
+{
+    QString dbPath = Download::globalInstance()->downloadLocalModelsPath()
+        + QString("localdocs_v%1.db").arg(LOCALDOCS_VERSION);
+    QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE");
+    db.setDatabaseName(dbPath);
+
+    if (!db.open())
+        return db.lastError();
+
+    QStringList tables = db.tables();
+    if (tables.contains("chunks", Qt::CaseInsensitive))
+        return QSqlError();
+
+    QSqlQuery q;
+    if (!q.exec(CHUNKS_SQL))
+        return q.lastError();
+
+    if (!q.exec(FTS_CHUNKS_SQL))
+        return q.lastError();
+
+    if (!q.exec(COLLECTIONS_SQL))
+        return q.lastError();
+
+    if (!q.exec(FOLDERS_SQL))
+        return q.lastError();
+
+    if (!q.exec(DOCUMENTS_SQL))
+        return q.lastError();
+
+#if defined(DEBUG_EXAMPLE)
+    // Add a folder
+    QString folder_path = "/example/folder";
+    int folder_id;
+    if (!addFolderToDB(q, folder_path, &folder_id)) {
+        qDebug() << "Error adding folder:" << q.lastError().text();
+        return q.lastError();
+    }
+
+    // Add a collection
+    QString collection_name = "Example Collection";
+    if (!addCollection(q, collection_name, folder_id)) {
+        qDebug() << "Error adding collection:" << q.lastError().text();
+        return q.lastError();
+    }
+
+    // Add a document
+    int document_time = 123456789;
+    int document_id;
+    QString document_path = "/example/folder/document1.txt";
+    if (!addDocument(q, folder_id, document_time, document_path, &document_id)) {
+        qDebug() << "Error adding document:" << q.lastError().text();
+        return q.lastError();
+    }
+
+    // Add chunks to the document
+    QString chunk_text1 = "This is an example chunk.";
+    QString chunk_text2 = "Another example chunk.";
+    QString embedding_path = "/example/embeddings/embedding1.bin";
+    int embedding_id = 1;
+
+    if (!addChunk(q, document_id, 1, chunk_text1, embedding_id, embedding_path) ||
+        !addChunk(q, document_id, 2, chunk_text2, embedding_id, embedding_path)) {
+        qDebug() << "Error adding chunks:" << q.lastError().text();
+        return q.lastError();
+    }
+
+    // Perform a search
+    QList<QString> collection_names = {collection_name};
+    QString search_text = "example";
+    if (!selectChunk(q, collection_names, search_text)) {
+        qDebug() << "Error selecting chunks:" << q.lastError().text();
+        return q.lastError();
+    }
+
+    // Print the results
+    printResults(q);
+#endif
+
+    return QSqlError();
+}
+
+Database::Database()
+    : QObject(nullptr)
+    , m_watcher(new QFileSystemWatcher(this))
+{
+    moveToThread(&m_dbThread);
+    connect(&m_dbThread, &QThread::started, this, &Database::start);
+    m_dbThread.setObjectName("database");
+    m_dbThread.start();
+}
+
+void Database::handleDocumentErrorAndScheduleNext(const QString &errorMessage,
+    int document_id, const QString &document_path, const QSqlError &error)
+{
+    qWarning() << errorMessage << document_id << document_path << error.text();
+    if (!m_docsToScan.isEmpty())
+        QTimer::singleShot(0, this, &Database::scanQueue);
+}
+
+void Database::chunkStream(QTextStream &stream, int document_id)
+{
+    QString text = stream.readAll();
+    int chunkSize = 256;
+    int overlap = 25;
+    int chunk_id = 0;
+
+    for (int i = 0; i + chunkSize < text.length(); i += (chunkSize - overlap)) {
+        QString chunk = text.mid(i, chunkSize);
+        QSqlQuery q;
+        if (!addChunk(q,
+            document_id,
+            ++chunk_id,
+            chunk,
+            0 /*embedding_id*/,
+            QString() /*embedding_path*/
+        )) {
+            qWarning() << "ERROR: Could not insert chunk into db" << q.lastError();
+        }
+    }
+}
+
+//void Database::chunkStream(QTextStream &stream, int document_id)
+//{
+//    QString line;
+//    int chunk_id = 0;
+//    while (stream.readLineInto(&line)) {
+//        int chunkSize = 256;
+//        for (int i = 0; i < line.length(); i += chunkSize) {
+//            QString chunk = line.mid(i, chunkSize);
+//            QSqlQuery q;
+//            if (!addChunk(q,
+//                document_id,
+//                ++chunk_id,
+//                chunk,
+//                0 /*embedding_id*/,
+//                QString() /*embedding_path*/
+//            )) {
+//                qWarning() << "ERROR: Could not insert chunk into db" << q.lastError();
+//            }
+//        }
+//    }
+//}
+
+void Database::scanQueue()
+{
+    if (m_docsToScan.isEmpty())
+        return;
+
+    const DocumentInfo info = m_docsToScan.dequeue();
+    const int folder_id = info.folder;
+    const qint64 document_time = info.doc.fileTime(QFile::FileModificationTime).toMSecsSinceEpoch();
+    const QString document_path = info.doc.canonicalFilePath();
+
+#if defined(DEBUG)
+    qDebug() << "scanDocument" << folder_id << document_time << document_path;
+#endif
+
+    // Check and see if we already have this document
+    QSqlQuery q;
+    int existing_id = -1;
+    int existing_time = -1;
+    if (!selectDocument(q, document_path, &existing_id, &existing_time)) {
+        return handleDocumentErrorAndScheduleNext("ERROR: Cannot select document",
+            existing_id, document_path, q.lastError());
+    }
+
+    // If we have the document, we need to compare the last modification time and if it is newer
+    // we must rescan the document, otherwise return
+    if (existing_id != -1) {
+        Q_ASSERT(existing_time != -1);
+        if (document_time == existing_time) {
+            return handleDocumentErrorAndScheduleNext("WARNING: No need to rescan",
+                existing_id, document_path, q.lastError());
+        } else {
+            if (!deleteChunksByDocumentId(q, existing_id)) {
+                return handleDocumentErrorAndScheduleNext("ERROR: Cannot delete chunks of document",
+                    existing_id, document_path, q.lastError());
+            }
+        }
+    }
+
+    QFile file(document_path);
+    if (!file.open( QIODevice::ReadOnly)) {
+        return handleDocumentErrorAndScheduleNext("ERROR: Cannot open file for scanning",
+            existing_id, document_path, q.lastError());
+    }
+
+    // Update the document_time for an existing document, or add it for the first time now
+    int document_id = existing_id;
+    if (document_id != -1) {
+        if (!updateDocument(q, document_id, document_time)) {
+            return handleDocumentErrorAndScheduleNext("ERROR: Could not update document_time",
+                document_id, document_path, q.lastError());
+        }
+    } else {
+        if (!addDocument(q, folder_id, document_time, document_path, &document_id)) {
+            return handleDocumentErrorAndScheduleNext("ERROR: Could not add document",
+                document_id, document_path, q.lastError());
+        }
+    }
+
+    QElapsedTimer timer;
+    timer.start();
+
+    QSqlDatabase::database().transaction();
+    Q_ASSERT(document_id != -1);
+    if (info.doc.suffix() == QLatin1String("pdf")) {
+        file.close();
+        QPdfDocument doc;
+        if (QPdfDocument::Error::None != doc.load(info.doc.canonicalFilePath())) {
+            return handleDocumentErrorAndScheduleNext("ERROR: Could not load pdf",
+                document_id, document_path, q.lastError());
+            return;
+        }
+        QString text;
+        for (int i = 0; i < doc.pageCount(); ++i) {
+            const QPdfSelection selection = doc.getAllText(i);
+            text.append(selection.text());
+        }
+        QTextStream stream(&text);
+        chunkStream(stream, document_id);
+    } else {
+        QTextStream stream(&file);
+        chunkStream(stream, document_id);
+        file.close();
+    }
+    QSqlDatabase::database().commit();
+
+#if defined(DEBUG)
+    qDebug() << "localdocs chunking" << document_path << "took" << timer.elapsed() << "milliseconds";
+#endif
+
+    if (!m_docsToScan.isEmpty()) QTimer::singleShot(0, this, &Database::scanQueue);
+}
+
+void Database::scanDocuments(int folder_id, const QString &folder_path)
+{
+#if defined(DEBUG)
+    qDebug() << "scanDocuments" << folder_id << folder_path;
+#endif
+
+    QDir dir(folder_path);
+    Q_ASSERT(dir.exists());
+    Q_ASSERT(dir.isReadable());
+    QDirIterator it(folder_path, QDir::Readable | QDir::Files, QDirIterator::Subdirectories);
+    while (it.hasNext()) {
+        it.next();
+        QFileInfo fileInfo = it.fileInfo();
+        fileInfo.setCaching(false);
+        if (fileInfo.isDir()) {
+            addFolderToWatch(fileInfo.canonicalFilePath());
+            continue;
+        }
+
+        if (fileInfo.suffix() != QLatin1String("pdf")
+            && fileInfo.suffix() != QLatin1String("txt")) {
+            continue;
+        }
+
+        DocumentInfo info;
+        info.folder = folder_id;
+        info.doc = fileInfo;
+        m_docsToScan.enqueue(info);
+    }
+    emit docsToScanChanged();
+}
+
+void Database::start()
+{
+    connect(m_watcher, &QFileSystemWatcher::directoryChanged, this, &Database::directoryChanged);
+    connect(m_watcher, &QFileSystemWatcher::fileChanged, this, &Database::fileChanged);
+    connect(this, &Database::docsToScanChanged, this, &Database::scanQueue);
+    if (!QSqlDatabase::drivers().contains("QSQLITE")) {
+        qWarning() << "ERROR: missing sqllite driver";
+    } else {
+        QSqlError err = initDb();
+        if (err.type() != QSqlError::NoError)
+            qWarning() << "ERROR: initializing db" << err.text();
+    }
+}
+
+void Database::addFolder(const QString &collection, const QString &path)
+{
+    QFileInfo info(path);
+    if (!info.exists() || !info.isReadable()) {
+        qWarning() << "ERROR: Cannot add folder that doesn't exist or not readable" << path;
+        return;
+    }
+
+    QSqlQuery q;
+    int folder_id = -1;
+
+    // See if the folder exists in the db
+    if (!selectFolder(q, path, &folder_id)) {
+        qWarning() << "ERROR: Cannot select folder from path" << path << q.lastError();
+        return;
+    }
+
+    // Add the folder
+    if (folder_id == -1 && !addFolderToDB(q, path, &folder_id)) {
+        qWarning() << "ERROR: Cannot add folder to db with path" << path << q.lastError();
+        return;
+    }
+
+    Q_ASSERT(folder_id != -1);
+
+    // See if the folder has already been added to the collection
+    QList<int> folders;
+    if (!selectFoldersFromCollection(q, collection, &folders)) {
+        qWarning() << "ERROR: Cannot select folders from collections" << collection << q.lastError();
+        return;
+    }
+
+    if (!folders.contains(folder_id) && !addCollection(q, collection, folder_id)) {
+        qWarning() << "ERROR: Cannot add folder to collection" << collection << path << q.lastError();
+        return;
+    }
+
+    if (!addFolderToWatch(path))
+        return;
+
+    scanDocuments(folder_id, path);
+}
+
+void Database::removeFolder(const QString &collection, const QString &path)
+{
+#if defined(DEBUG)
+    qDebug() << "removeFolder" << path;
+#endif
+
+    // FIXME: Determine if the folder is used by more than one collection
+
+    // FIXME: If not, then delete all chunks and documents associated with it
+
+    // FIXME: Remove it from the collections
+
+    removeFolderFromWatch(path);
+}
+
+bool Database::addFolderToWatch(const QString &path)
+{
+#if defined(DEBUG)
+    qDebug() << "addFolderToWatch" << path;
+#endif
+
+    if (!m_watcher->addPath(path)) {
+        qWarning() << "ERROR: Cannot add path to file watcher:" << path;
+        return false;
+    }
+    return true;
+}
+
+bool Database::removeFolderFromWatch(const QString &path)
+{
+#if defined(DEBUG)
+    qDebug() << "removeFolderFromWatch" << path;
+#endif
+    if (!m_watcher->removePath(path)) {
+        qWarning() << "ERROR: Cannot remove path from file watcher:" << path;
+        return false;
+    }
+    return true;
+}
+
+void Database::retrieveFromDB(const QList<QString> &collections, const QString &text)
+{
+#if defined(DEBUG)
+    qDebug() << "retrieveFromDB" << collections << text;
+#endif
+
+    QSqlQuery q;
+    if (!selectChunk(q, collections, text)) {
+        qDebug() << "ERROR: selecting chunks:" << q.lastError().text();
+        return;
+    }
+
+    QList<QString> results;
+    while (q.next()) {
+        int rowid = q.value(0).toInt();
+        QString collection_name = q.value(1).toString();
+        QString chunk_text = q.value(2).toString();
+        results.append(chunk_text);
+#if defined(DEBUG)
+        qDebug() << "retrieve rowid:" << rowid
+                 << "collection_name:" << collection_name
+                 << "chunk_text:" << chunk_text;
+#endif
+    }
+
+    emit retrieveResult(results);
+}
+
+void Database::directoryChanged(const QString &path)
+{
+#if defined(DEBUG)
+    qDebug() << "directoryChanged" << path;
+#endif
+
+    // FIXME: Get the folder id
+    // Re-scan documents associated with folder_id
+}
+
+void Database::fileChanged(const QString &path)
+{
+#if defined(DEBUG)
+    qDebug() << "fileChanged" << path;
+#endif
+    // FIXME: Get the folder id
+    // Re-scan documents associated with document_path
+}
+
+class MyLocalDocs: public LocalDocs { };
+Q_GLOBAL_STATIC(MyLocalDocs, localDocsInstance)
+LocalDocs *LocalDocs::globalInstance()
+{
+    return localDocsInstance();
+}
+
+LocalDocs::LocalDocs()
+    : QObject(nullptr)
+    , m_database(new Database)
+    , m_retrieveInProgress(false)
+{
+    connect(this, &LocalDocs::requestAddFolder, m_database,
+        &Database::addFolder, Qt::QueuedConnection);
+    connect(this, &LocalDocs::requestRemoveFolder, m_database,
+        &Database::removeFolder, Qt::QueuedConnection);
+    connect(this, &LocalDocs::requestRetrieveFromDB, m_database,
+        &Database::retrieveFromDB, Qt::QueuedConnection);
+    connect(m_database, &Database::retrieveResult, this,
+        &LocalDocs::retrieveResult, Qt::QueuedConnection);
+
+    addFolder("localdocs", "/home/atreat/dev/large_language_models/localdocs");
+}
+
+void LocalDocs::addFolder(const QString &collection, const QString &path)
+{
+    emit requestAddFolder(collection, path);
+}
+
+void LocalDocs::removeFolder(const QString &collection, const QString &path)
+{
+    emit requestRemoveFolder(collection, path);
+}
+
+void LocalDocs::requestRetrieve(const QList<QString> &collections, const QString &text)
+{
+    m_retrieveInProgress = true;
+    m_retrieveResult = QList<QString>();
+    emit retrieveInProgressChanged();
+    emit requestRetrieveFromDB(collections, text);
+}
+
+void LocalDocs::retrieveResult(const QList<QString> &result)
+{
+#if defined(DEBUG)
+    qDebug() << "local docs retrieve" << result;
+#endif
+    m_retrieveInProgress = false;
+    m_retrieveResult = result;
+    emit receivedResult();
+    emit retrieveInProgressChanged();
+}
diff --git a/gpt4all-chat/localdocs.h b/gpt4all-chat/localdocs.h
new file mode 100644
index 00000000..c86cc76b
--- /dev/null
+++ b/gpt4all-chat/localdocs.h
@@ -0,0 +1,89 @@
+#ifndef LOCALDOCS_H
+#define LOCALDOCS_H
+
+#include <QObject>
+#include <QtSql>
+#include <QQueue>
+#include <QFileInfo>
+#include <QThread>
+#include <QFileSystemWatcher>
+
+struct DocumentInfo
+{
+    int folder;
+    QFileInfo doc;
+};
+
+class Database : public QObject
+{
+    Q_OBJECT
+public:
+    Database();
+
+public Q_SLOTS:
+    void scanQueue();
+    void scanDocuments(int folder_id, const QString &folder_path);
+    void addFolder(const QString &collection, const QString &path);
+    void removeFolder(const QString &collection, const QString &path);
+    void retrieveFromDB(const QList<QString> &collections, const QString &text);
+
+Q_SIGNALS:
+    void docsToScanChanged();
+    void retrieveResult(const QList<QString> &result);
+
+private Q_SLOTS:
+    void start();
+    void directoryChanged(const QString &path);
+    void fileChanged(const QString &path);
+    bool addFolderToWatch(const QString &path);
+    bool removeFolderFromWatch(const QString &path);
+
+private:
+    void chunkStream(QTextStream &stream, int document_id);
+    void handleDocumentErrorAndScheduleNext(const QString &errorMessage,
+        int document_id, const QString &document_path, const QSqlError &error);
+
+private:
+    QQueue<DocumentInfo> m_docsToScan;
+    QList<QString> m_retrieve;
+    QThread m_dbThread;
+    QFileSystemWatcher *m_watcher;
+};
+
+class LocalDocs : public QObject
+{
+    Q_OBJECT
+    Q_PROPERTY(bool retrieveInProgress READ retrieveInProgress NOTIFY retrieveInProgressChanged)
+
+public:
+    static LocalDocs *globalInstance();
+
+    void addFolder(const QString &collection, const QString &path);
+    void removeFolder(const QString &collection, const QString &path);
+
+    QList<QString> result() const { return m_retrieveResult; }
+    void requestRetrieve(const QList<QString> &collections, const QString &text);
+    bool retrieveInProgress() const { return m_retrieveInProgress; }
+
+Q_SIGNALS:
+    void requestAddFolder(const QString &collection, const QString &path);
+    void requestRemoveFolder(const QString &collection, const QString &path);
+    void requestRetrieveFromDB(const QList<QString> &collections, const QString &text);
+    void receivedResult();
+    void retrieveInProgressChanged();
+
+private Q_SLOTS:
+    void retrieveResult(const QList<QString> &result);
+
+private:
+    Database *m_database;
+    QList<QString> m_retrieveResult;
+    bool m_retrieveInProgress;
+
+private:
+    explicit LocalDocs();
+    ~LocalDocs() {}
+    friend class MyLocalDocs;
+};
+
+#endif // LOCALDOCS_H
diff --git a/gpt4all-chat/main.cpp b/gpt4all-chat/main.cpp
index aece4026..621c3597 100644
--- a/gpt4all-chat/main.cpp
+++ b/gpt4all-chat/main.cpp
@@ -6,6 +6,7 @@
 #include <QSettings>
 
 #include "llm.h"
+#include "localdocs.h"
 #include "download.h"
 #include "network.h"
 #include "config.h"
@@ -23,6 +24,7 @@ int main(int argc, char *argv[])
     qmlRegisterSingletonInstance("llm", 1, 0, "LLM", LLM::globalInstance());
     qmlRegisterSingletonInstance("download", 1, 0, "Download", Download::globalInstance());
     qmlRegisterSingletonInstance("network", 1, 0, "Network", Network::globalInstance());
+    qmlRegisterSingletonInstance("localdocs", 1, 0, "LocalDocs", LocalDocs::globalInstance());
     const QUrl url(u"qrc:/gpt4all/main.qml"_qs);
 
     QObject::connect(&engine, &QQmlApplicationEngine::objectCreated,