Move line parsing and to Buffer.cc directly

7 files changed, 89 insertions, 104 deletions

diff --git a/src/buffer.cc b/src/buffer.cc
index 02f076d0..8ca9aae8 100644
--- a/src/buffer.cc
+++ b/src/buffer.cc
@@ -17,7 +17,46 @@
 namespace Kakoune
 {
 
-Buffer::Buffer(String name, Flags flags, BufferLines lines,
+struct ParsedLines { BufferLines lines; bool bom, crlf; };
+
+static ParsedLines parse_lines(StringView data)
+{
+    bool bom = false, crlf = false;
+    const char* pos = data.begin();
+    if (data.substr(0, 3_byte) == "\xEF\xBB\xBF")
+    {
+        bom = true;
+        pos = data.begin() + 3;
+    }
+
+    BufferLines lines;
+    while (pos < data.end())
+    {
+        const char* line_end = pos;
+        while (line_end < data.end() and *line_end != '\r' and *line_end != '\n')
+             ++line_end;
+
+        lines.emplace_back(StringData::create({pos, line_end}, '\n'));
+
+        if (line_end+1 != data.end() and *line_end == '\r' and *(line_end+1) == '\n')
+        {
+            crlf = true;
+            pos = line_end + 2;
+        }
+        else
+            pos = line_end + 1;
+    }
+
+    return { std::move(lines), bom, crlf };
+}
+
+static void apply_options(OptionManager& options, const ParsedLines& parsed_lines)
+{
+    options.get_local_option("eolformat").set<String>(parsed_lines.crlf ? "crlf" : "lf");
+    options.get_local_option("BOM").set<String>(parsed_lines.bom ? "utf-8" : "no");
+}
+
+Buffer::Buffer(String name, Flags flags, StringView data,
                timespec fs_timestamp)
     : Scope(GlobalScope::instance()),
       m_name((flags & Flags::File) ? real_path(parse_filename(name)) : std::move(name)),
@@ -30,18 +69,22 @@ Buffer::Buffer(String name, Flags flags, BufferLines lines,
     BufferManager::instance().register_buffer(*this);
     options().register_watcher(*this);
 
-    if (lines.empty())
-        lines.emplace_back(StringData::create("\n"));
+    ParsedLines parsed_lines = parse_lines(data);
+
+    if (parsed_lines.lines.empty())
+        parsed_lines.lines.emplace_back(StringData::create("\n"));
 
     #ifdef KAK_DEBUG
-    for (auto& line : lines)
+    for (auto& line : parsed_lines.lines)
         kak_assert(not (line->length == 0) and
                    line->data()[line->length-1] == '\n');
     #endif
-    static_cast<BufferLines&>(m_lines) = std::move(lines);
+    static_cast<BufferLines&>(m_lines) = std::move(parsed_lines.lines);
 
     m_changes.push_back({ Change::Insert, true, {0,0}, line_count() });
 
+    apply_options(options(), parsed_lines);
+
     if (flags & Flags::File)
     {
         if (flags & Flags::New)
@@ -160,10 +203,12 @@ struct Buffer::Modification
     }
 };
 
-void Buffer::reload(BufferLines lines, timespec fs_timestamp)
+void Buffer::reload(StringView data, timespec fs_timestamp)
 {
-    if (lines.empty())
-        lines.emplace_back(StringData::create("\n"));
+    ParsedLines parsed_lines = parse_lines(data);
+
+    if (parsed_lines.lines.empty())
+        parsed_lines.lines.emplace_back(StringData::create("\n"));
 
     const bool record_undo = not (m_flags & Flags::NoUndo);
 
@@ -173,14 +218,14 @@ void Buffer::reload(BufferLines lines, timespec fs_timestamp)
     {
         m_changes.push_back({ Change::Erase, true, {0,0}, line_count() });
 
-        static_cast<BufferLines&>(m_lines) = std::move(lines);
+        static_cast<BufferLines&>(m_lines) = std::move(parsed_lines.lines);
 
         m_changes.push_back({ Change::Insert, true, {0,0}, line_count() });
     }
     else
     {
         auto diff = find_diff(m_lines.begin(), m_lines.size(),
-                              lines.begin(), (int)lines.size(),
+                              parsed_lines.lines.begin(), (int)parsed_lines.lines.size(),
                               [](const StringDataPtr& lhs, const StringDataPtr& rhs)
                               { return lhs->hash == rhs->hash and lhs->strview() == rhs->strview(); });
 
@@ -196,10 +241,10 @@ void Buffer::reload(BufferLines lines, timespec fs_timestamp)
                 for (LineCount line = 0; line < d.len; ++line)
                     m_current_undo_group.emplace_back(
                         Modification::Insert, cur_line + line,
-                        SharedString{lines[(int)(d.posB + line)]});
+                        SharedString{parsed_lines.lines[(int)(d.posB + line)]});
 
                 m_changes.push_back({ Change::Insert, it == m_lines.end(), cur_line, cur_line + d.len });
-                m_lines.insert(it, &lines[d.posB], &lines[d.posB + d.len]);
+                m_lines.insert(it, &parsed_lines.lines[d.posB], &parsed_lines.lines[d.posB + d.len]);
                 it = m_lines.begin() + (int)(cur_line + d.len);
             }
             else if (d.mode == Diff::Remove)
@@ -219,6 +264,8 @@ void Buffer::reload(BufferLines lines, timespec fs_timestamp)
 
     commit_undo_group();
 
+    apply_options(options(), parsed_lines);
+
     m_last_save_undo_index = m_history_cursor - m_history.begin();
     m_fs_timestamp = fs_timestamp;
 }
@@ -586,7 +633,7 @@ UnitTest test_buffer{[]()
 {
     Buffer empty_buffer("empty", Buffer::Flags::None, {});
 
-    Buffer buffer("test", Buffer::Flags::None, { "allo ?\n"_ss, "mais que fais la police\n"_ss,  " hein ?\n"_ss, " youpi\n"_ss });
+    Buffer buffer("test", Buffer::Flags::None, "allo ?\nmais que fais la police\n hein ?\n youpi\n");
     kak_assert(buffer.line_count() == 4);
 
     BufferIterator pos = buffer.begin();
@@ -629,8 +676,7 @@ UnitTest test_buffer{[]()
 
 UnitTest test_undo{[]()
 {
-    BufferLines lines = { "allo ?\n"_ss, "mais que fais la police\n"_ss,  " hein ?\n"_ss, " youpi\n"_ss };
-    Buffer buffer("test", Buffer::Flags::None, lines);
+    Buffer buffer("test", Buffer::Flags::None, "allo ?\nmais que fais la police\n hein ?\n youpi\n");
     auto pos = buffer.insert(buffer.end(), "kanaky\n");
     buffer.erase(pos, buffer.end());
     buffer.insert(buffer.iterator_at(2_line), "tchou\n");
@@ -642,9 +688,11 @@ UnitTest test_undo{[]()
     buffer.redo();
     buffer.undo();
 
-    kak_assert((int)buffer.line_count() == lines.size());
-    for (size_t i = 0; i < lines.size(); ++i)
-        kak_assert(SharedString{lines[i]} == buffer[LineCount((int)i)]);
+    kak_assert((int)buffer.line_count() == 4);
+    kak_assert(buffer[0_line] == "allo ?\n");
+    kak_assert(buffer[1_line] == "mais que fais la police\n");
+    kak_assert(buffer[2_line] == " hein ?\n");
+    kak_assert(buffer[3_line] == " youpi\n");
 }};
 
 }
diff --git a/src/buffer.hh b/src/buffer.hh
index 5342dd83..581321bc 100644
--- a/src/buffer.hh
+++ b/src/buffer.hh
@@ -78,7 +78,7 @@ public:
         NoUndo = 8,
     };
 
-    Buffer(String name, Flags flags, BufferLines lines = {},
+    Buffer(String name, Flags flags, StringView data = {},
            timespec fs_timestamp = InvalidTime);
     Buffer(const Buffer&) = delete;
     Buffer& operator= (const Buffer&) = delete;
@@ -152,7 +152,7 @@ public:
 
     void run_hook_in_own_context(StringView hook_name, StringView param);
 
-    void reload(BufferLines lines, timespec fs_timestamp = InvalidTime);
+    void reload(StringView data, timespec fs_timestamp = InvalidTime);
 
     void check_invariant() const;
 
diff --git a/src/buffer_utils.cc b/src/buffer_utils.cc
index e2fdbfcb..045e4364 100644
--- a/src/buffer_utils.cc
+++ b/src/buffer_utils.cc
@@ -47,53 +47,12 @@ ByteCount get_byte_to_column(const Buffer& buffer, CharCount tabstop, CharCoord
     return (int)(it - line.begin());
 }
 
-struct BufferData
-{
-    BufferLines lines;
-    bool bom = false;
-    bool crlf = false;
-
-    BufferData(StringView data)
-    {
-        const char* pos = data.begin();
-        if (data.length() >= 3 and
-           data[0_byte] == '\xEF' and data[1_byte] == '\xBB' and data[2_byte] == '\xBF')
-        {
-            bom = true;
-            pos = data.begin() + 3;
-        }
-
-        while (pos < data.end())
-        {
-            const char* line_end = pos;
-            while (line_end < data.end() and *line_end != '\r' and *line_end != '\n')
-                 ++line_end;
-
-            lines.emplace_back(StringData::create({pos, line_end}, '\n'));
-
-            if (line_end+1 != data.end() and *line_end == '\r' and *(line_end+1) == '\n')
-            {
-                crlf = true;
-                pos = line_end + 2;
-            }
-            else
-                pos = line_end + 1;
-        }
-    }
-
-    void apply_options(Buffer& buffer) const
-    {
-        OptionManager& options = buffer.options();
-        options.get_local_option("eolformat").set<String>(crlf ? "crlf" : "lf");
-        options.get_local_option("BOM").set<String>(bom ? "utf-8" : "no");
-    }
-};
-
 Buffer* create_file_buffer(StringView filename)
 {
     if (MappedFile file_data{filename})
-        return create_buffer({ file_data.data, (int)file_data.st.st_size }, filename,
-                             Buffer::Flags::File, file_data.st.st_mtim);
+        return new Buffer(filename.str(), Buffer::Flags::File,
+                          { file_data.data, (int)file_data.st.st_size },
+                          file_data.st.st_mtim);
     return nullptr;
 }
 
@@ -102,28 +61,12 @@ bool reload_file_buffer(Buffer& buffer)
     kak_assert(buffer.flags() & Buffer::Flags::File);
     if (MappedFile file_data{buffer.name()})
     {
-        reload_buffer(buffer,  { file_data.data, (int)file_data.st.st_size }, file_data.st.st_mtim);
+        buffer.reload({ file_data.data, (int)file_data.st.st_size }, file_data.st.st_mtim);
         return true;
     }
     return false;
 }
 
-Buffer* create_buffer(StringView data, StringView name, Buffer::Flags flags,
-                      timespec fs_timestamp)
-{
-    BufferData buf_data(data);
-    Buffer* buffer = new Buffer{name.str(), flags, std::move(buf_data.lines), fs_timestamp};
-    buf_data.apply_options(*buffer);
-    return buffer;
-}
-
-void reload_buffer(Buffer& buffer, StringView data, timespec fs_timestamp)
-{
-    BufferData buf_data(data);
-    buffer.reload(std::move(buf_data.lines), fs_timestamp);
-    buf_data.apply_options(buffer);
-}
-
 Buffer* create_fifo_buffer(String name, int fd, bool scroll)
 {
     static ValueId s_fifo_watcher_id = ValueId::get_free_id();
@@ -132,7 +75,7 @@ Buffer* create_fifo_buffer(String name, int fd, bool scroll)
     if (buffer)
     {
         buffer->flags() |= Buffer::Flags::NoUndo;
-        buffer->reload({"\n"_ss}, InvalidTime);
+        buffer->reload({}, InvalidTime);
     }
     else
         buffer = new Buffer(std::move(name), Buffer::Flags::Fifo | Buffer::Flags::NoUndo);
@@ -213,13 +156,13 @@ void write_to_debug_buffer(StringView str)
         return;
     }
 
-    const StringView debug_buffer_name = "*debug*";
+    constexpr StringView debug_buffer_name = "*debug*";
     if (Buffer* buffer = BufferManager::instance().get_buffer_ifp(debug_buffer_name))
         buffer->insert(buffer->end(), str);
     else
     {
         String line = str + ((str.empty() or str.back() != '\n') ? "\n" : "");
-        create_buffer(line, debug_buffer_name, Buffer::Flags::NoUndo, InvalidTime);
+        new Buffer(debug_buffer_name.str(), Buffer::Flags::NoUndo, line, InvalidTime);
     }
 }
 
diff --git a/src/buffer_utils.hh b/src/buffer_utils.hh
index e9262c06..baf47890 100644
--- a/src/buffer_utils.hh
+++ b/src/buffer_utils.hh
@@ -30,10 +30,6 @@ CharCount get_column(const Buffer& buffer,
 ByteCount get_byte_to_column(const Buffer& buffer, CharCount tabstop,
                              CharCoord coord);
 
-Buffer* create_buffer(StringView data, StringView name,
-                      Buffer::Flags flags, timespec fs_timestamp);
-void reload_buffer(Buffer& buffer, StringView data, timespec fs_timestamp);
-
 Buffer* create_fifo_buffer(String name, int fd, bool scroll = false);
 Buffer* create_file_buffer(StringView filename);
 bool reload_file_buffer(Buffer& buffer);
diff --git a/src/line_modification.cc b/src/line_modification.cc
index d9a89cef..ac2bd487 100644
--- a/src/line_modification.cc
+++ b/src/line_modification.cc
@@ -105,7 +105,7 @@ bool operator==(const LineModification& lhs, const LineModification& rhs)
 UnitTest test_line_modifications{[]()
 {
     {
-        Buffer buffer("test", Buffer::Flags::None, { "line 1\n"_ss, "line 2\n"_ss });
+        Buffer buffer("test", Buffer::Flags::None, "line 1\nline 2\n");
         auto ts = buffer.timestamp();
         buffer.erase(buffer.iterator_at({1, 0}), buffer.iterator_at({2, 0}));
 
@@ -114,7 +114,7 @@ UnitTest test_line_modifications{[]()
     }
 
     {
-        Buffer buffer("test", Buffer::Flags::None, { "line 1\n"_ss, "line 2\n"_ss });
+        Buffer buffer("test", Buffer::Flags::None, "line 1\nline 2\n");
         auto ts = buffer.timestamp();
         buffer.insert(buffer.iterator_at({1, 7}), "line 3");
 
@@ -123,8 +123,7 @@ UnitTest test_line_modifications{[]()
     }
 
     {
-        Buffer buffer("test", Buffer::Flags::None,
-                      { "line 1\n"_ss, "line 2\n"_ss, "line 3\n"_ss });
+        Buffer buffer("test", Buffer::Flags::None, "line 1\nline 2\nline 3\n");
 
         auto ts = buffer.timestamp();
         buffer.insert(buffer.iterator_at({1, 4}), "hoho\nhehe");
@@ -135,8 +134,7 @@ UnitTest test_line_modifications{[]()
     }
 
     {
-        Buffer buffer("test", Buffer::Flags::None,
-                      { "line 1\n"_ss, "line 2\n"_ss, "line 3\n"_ss, "line 4\n"_ss });
+        Buffer buffer("test", Buffer::Flags::None, "line 1\nline 2\nline 3\nline 4\n");
 
         auto ts = buffer.timestamp();
         buffer.erase(buffer.iterator_at({0,0}), buffer.iterator_at({3,0}));
@@ -155,7 +153,7 @@ UnitTest test_line_modifications{[]()
     }
 
     {
-        Buffer buffer("test", Buffer::Flags::None, { "line 1\n"_ss });
+        Buffer buffer("test", Buffer::Flags::None, "line 1\n");
         auto ts = buffer.timestamp();
         buffer.insert(buffer.iterator_at({0,0}), "n");
         buffer.insert(buffer.iterator_at({0,1}), "e");
diff --git a/src/main.cc b/src/main.cc
index 8c003522..63ddd53d 100644
--- a/src/main.cc
+++ b/src/main.cc
@@ -457,14 +457,14 @@ int run_server(StringView session, StringView init_command,
     FaceRegistry        face_registry;
     ClientManager       client_manager;
 
-    UnitTest::run_all_tests();
-
     register_options();
     register_env_vars();
     register_registers();
     register_commands();
     register_highlighters();
 
+    UnitTest::run_all_tests();
+
     write_to_debug_buffer("*** This is the debug buffer, where debug info will be written ***");
 
     Server server(session.empty() ? to_string(getpid()) : session.str());
@@ -601,8 +601,8 @@ int run_filter(StringView keystr, ConstArrayView<StringView> files, bool quiet)
         }
         if (not isatty(0))
         {
-            Buffer* buffer = create_buffer(read_fd(0), "*stdin*",
-                                           Buffer::Flags::None, InvalidTime);
+            Buffer* buffer = new Buffer("*stdin*", Buffer::Flags::None,
+                                        read_fd(0), InvalidTime);
             apply_keys_to_buffer(*buffer);
             write_buffer_to_fd(*buffer, 1);
             buffer_manager.delete_buffer(*buffer);
diff --git a/src/word_db.cc b/src/word_db.cc
index 4ef5a912..f15ea380 100644
--- a/src/word_db.cc
+++ b/src/word_db.cc
@@ -139,11 +139,11 @@ int WordDB::get_word_occurences(StringView word) const
 UnitTest test_word_db{[]()
 {
     Buffer buffer("test", Buffer::Flags::None,
-                  { "tchou mutch\n"_ss,
-                    "tchou kanaky tchou\n"_ss,
-                    "\n"_ss,
-                    "tchaa tchaa\n"_ss,
-                    "allo\n"_ss});
+                  "tchou mutch\n"
+                  "tchou kanaky tchou\n"
+                  "\n"
+                  "tchaa tchaa\n"
+                  "allo\n");
     WordDB word_db(buffer);
     auto res = word_db.find_matching("", prefix_match);
     std::sort(res.begin(), res.end());