From 1ce0790c0c0b05af20f947ee433df48401d54c50 Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Fri, 30 Jan 2026 18:03:44 +0100
Subject: [PATCH 01/12] feat: add attach_markdown

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/parse/parse.py        |  4 +-
 test/parse/test_attach_markdown.py | 76 ++++++++++++++++++++++++++++++
 test/{ => parse}/test_parse.py     |  3 +-
 3 files changed, 80 insertions(+), 3 deletions(-)
 create mode 100644 test/parse/test_attach_markdown.py
 rename test/{ => parse}/test_parse.py (99%)

diff --git a/src/streamer/parse/parse.py b/src/streamer/parse/parse.py
index a4c8421..4a8258f 100644
--- a/src/streamer/parse/parse.py
+++ b/src/streamer/parse/parse.py
@@ -20,8 +20,8 @@ def get_line_number(block_token: BlockToken) -> int:
 
 
 def build_shard(
-    start_line,
-    end_line,
+    start_line: int,
+    end_line: int,
     markers: list[str] = [],
     tags: list[str] = [],
     children: list[Shard] = [],
diff --git a/test/parse/test_attach_markdown.py b/test/parse/test_attach_markdown.py
new file mode 100644
index 0000000..21f8a1b
--- /dev/null
+++ b/test/parse/test_attach_markdown.py
@@ -0,0 +1,76 @@
+from faker import Faker
+
+from streamer.parse import Shard, StreamFile
+from streamer.parse.attach_markdown import (
+    ShardWithMarkdown,
+    StreamFileWithMarkdown,
+    attach_markdown,
+)
+
+fake = Faker()
+
+
+class TestAttachMarkdown:
+    file_name: str = fake.file_name(extension="md")
+
+    def test_attach_markdown_with_shard(self):
+        markdown_text = "Hello World\n\nThis is a test."
+        shard = Shard(start_line=1, end_line=3)
+        stream_file = StreamFile(filename=self.file_name, shard=shard)
+
+        result = attach_markdown(stream_file, markdown_text)
+
+        assert result == StreamFileWithMarkdown(
+            filename=self.file_name,
+            shard=ShardWithMarkdown(
+                start_line=1,
+                end_line=3,
+                markdown_content=markdown_text,
+                markers=[],
+                tags=[],
+                children=[],
+            ),
+        )
+
+    def test_attach_markdown_without_shard(self):
+        stream_file = StreamFile(filename=self.file_name, shard=None)
+
+        result = attach_markdown(stream_file, "Some markdown text")
+
+        assert result == StreamFileWithMarkdown(filename=self.file_name, shard=None)
+
+    def test_attach_markdown_with_nested_shards(self):
+        markdown_text = "Header\n\n@Marker1 Content 1\n\n@Marker2 Content 2"
+        shard = Shard(
+            start_line=1,
+            end_line=5,
+            children=[
+                Shard(markers=["Marker1"], start_line=3, end_line=3),
+                Shard(markers=["Marker2"], start_line=5, end_line=5),
+            ],
+        )
+        stream_file = StreamFile(filename=self.file_name, shard=shard)
+
+        result = attach_markdown(stream_file, markdown_text)
+
+        assert result.filename == self.file_name
+        assert result.shard is not None
+        assert result.shard.start_line == 1
+        assert result.shard.end_line == 5
+        assert (
+            result.shard.markdown_content
+            == "Header\n\n@Marker1 Content 1\n\n@Marker2 Content 2"
+        )
+        assert len(result.shard.children) == 2
+
+        # Check first child
+        assert result.shard.children[0].markers == ["Marker1"]
+        assert result.shard.children[0].start_line == 3
+        assert result.shard.children[0].end_line == 3
+        assert result.shard.children[0].markdown_content == "@Marker1 Content 1"
+
+        # Check second child
+        assert result.shard.children[1].markers == ["Marker2"]
+        assert result.shard.children[1].start_line == 5
+        assert result.shard.children[1].end_line == 5
+        assert result.shard.children[1].markdown_content == "@Marker2 Content 2"
diff --git a/test/test_parse.py b/test/parse/test_parse.py
similarity index 99%
rename from test/test_parse.py
rename to test/parse/test_parse.py
index e9c27ba..0a71671 100644
--- a/test/test_parse.py
+++ b/test/parse/test_parse.py
@@ -1,6 +1,7 @@
-from streamer.parse import StreamFile, parse_markdown_file, Shard
 from faker import Faker
 
+from streamer.parse import Shard, StreamFile, parse_markdown_file
+
 fake = Faker()
 
 
-- 
2.53.0


From ee91b2e8db4df7762e285d1a38a5f2a20fe12005 Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Fri, 30 Jan 2026 18:05:26 +0100
Subject: [PATCH 02/12] feat: add all_files iterator to simplify searching

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/__init__.py              | 48 +++++++++++++++------------
 src/streamer/parse/attach_markdown.py | 31 +++++++++++++++++
 src/streamer/query/task.py            |  6 +++-
 3 files changed, 62 insertions(+), 23 deletions(-)
 create mode 100644 src/streamer/parse/attach_markdown.py

diff --git a/src/streamer/__init__.py b/src/streamer/__init__.py
index c39eede..47fa553 100644
--- a/src/streamer/__init__.py
+++ b/src/streamer/__init__.py
@@ -1,14 +1,16 @@
 import glob
 import os
-import typer
+from datetime import datetime
+from shutil import move
+from typing import Generator
+
 import click
+import typer
 from rich import print
 from rich.markdown import Markdown
 from rich.panel import Panel
-from shutil import move
-
-from datetime import datetime
 
+from streamer.parse.attach_markdown import StreamFileWithMarkdown, attach_markdown
 from streamer.parse.parse import parse_markdown_file
 from streamer.query.task import find_by_markers
 from streamer.settings import Settings
@@ -16,28 +18,28 @@ from streamer.settings import Settings
 app = typer.Typer()
 
 
-@app.command()
-def todo() -> None:
+def all_files() -> Generator[StreamFileWithMarkdown]:
     for file_name in glob.glob(f"{glob.escape(Settings().base_folder)}/*.md"):
         with open(file_name, "r") as file:
             file_content = file.read()
-            sharded_document = parse_markdown_file(file_name, file_content)
-            if sharded_document.shard:
-                open_tasks = find_by_markers(sharded_document.shard, ["Task"], ["Done"])
+            yield attach_markdown(
+                parse_markdown_file(file_name, file_content), file_content
+            )
 
-                for task_shard in open_tasks:
-                    print(
-                        Panel(
-                            Markdown(
-                                "\n".join(
-                                    file_content.splitlines()[
-                                        task_shard.start_line - 1 : task_shard.end_line
-                                    ]
-                                )
-                            ),
-                            title=f"{file_name}:{task_shard.start_line}",
-                        )
+
+@app.command()
+def todo() -> None:
+    for sharded_document in all_files():
+        if sharded_document.shard:
+            open_tasks = find_by_markers(sharded_document.shard, ["Task"], ["Done"])
+
+            for task_shard in open_tasks:
+                print(
+                    Panel(
+                        Markdown(task_shard.markdown_content),
+                        title=f"{sharded_document.filename}:{task_shard.start_line}",
                     )
+                )
 
 
 @app.command()
@@ -59,7 +61,9 @@ def new() -> None:
     parsed_content = parse_markdown_file(prelimary_path, content)
 
     final_file_name = f"{timestamp}.md"
-    if parsed_content.shard is not None and len(markers := parsed_content.shard.markers):
+    if parsed_content.shard is not None and len(
+        markers := parsed_content.shard.markers
+    ):
         final_file_name = f"{timestamp} {' '.join(markers)}.md"
 
     final_path = os.path.join(streamer_directory, final_file_name)
diff --git a/src/streamer/parse/attach_markdown.py b/src/streamer/parse/attach_markdown.py
new file mode 100644
index 0000000..70766d9
--- /dev/null
+++ b/src/streamer/parse/attach_markdown.py
@@ -0,0 +1,31 @@
+from streamer.parse.shard import Shard, StreamFile
+
+
+class ShardWithMarkdown(Shard):
+    children: list[ShardWithMarkdown]
+    markdown_content: str
+
+
+class StreamFileWithMarkdown(StreamFile):
+    shard: ShardWithMarkdown | None = None  # pyright: ignore[reportIncompatibleVariableOverride]
+
+
+def attach_markdown_shard(shard: Shard, markdown_text: str) -> ShardWithMarkdown:
+    lines = markdown_text.splitlines()
+    markdown_content = "\n".join(lines[shard.start_line - 1 : shard.end_line])
+    return ShardWithMarkdown(
+        **shard.model_dump(exclude=["children"]),
+        children=map(lambda child: attach_markdown_shard(child, markdown_text), shard.children),
+        markdown_content=markdown_content,
+    )
+
+
+def attach_markdown(file: StreamFile, markdown_text: str) -> StreamFileWithMarkdown:
+    if file.shard is None:
+        return StreamFileWithMarkdown(filename=file.filename, shard=None)
+
+    attached_shard = attach_markdown_shard(file.shard, markdown_text)
+    return StreamFileWithMarkdown(filename=file.filename, shard=attached_shard)
+
+
+__all__ = ["attach_markdown"]
diff --git a/src/streamer/query/task.py b/src/streamer/query/task.py
index f4e7cd2..67d3664 100644
--- a/src/streamer/query/task.py
+++ b/src/streamer/query/task.py
@@ -1,7 +1,11 @@
+from typing import TypeVar
+
 from streamer.parse.shard import Shard
 
+T = TypeVar("T", bound="Shard")
 
-def find_by_markers(shard: Shard, has: list[str], has_not: list[str]) -> list[Shard]:
+
+def find_by_markers(shard: T, has: list[str], has_not: list[str]) -> list[T]:
     found_shards = []
 
     if any(tag in has for tag in shard.markers) and not any(
-- 
2.53.0


From d5b1541436c35289c21fe72f4638b016799c7e99 Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sat, 31 Jan 2026 17:15:01 +0100
Subject: [PATCH 03/12] feat: extract date & time from tags

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/localize/extract_datetime.py |  80 +++++++++++-
 src/streamer/localize/localize.py         |  30 +++--
 src/streamer/localize/localized_shard.py  |   4 +
 src/streamer/parse/attach_markdown.py     |   8 +-
 test/localize/test_extract_datetime.py    | 141 ++++++++++++++++++++--
 test/test_localize.py                     |   5 +-
 6 files changed, 246 insertions(+), 22 deletions(-)

diff --git a/src/streamer/localize/extract_datetime.py b/src/streamer/localize/extract_datetime.py
index ed82955..df15935 100644
--- a/src/streamer/localize/extract_datetime.py
+++ b/src/streamer/localize/extract_datetime.py
@@ -1,9 +1,9 @@
-from datetime import datetime
-import re
 import os
+import re
+from datetime import date, datetime, time
 
 
-def extract_date_from_file_name(file_name: str) -> datetime | None:
+def extract_datetime_from_file_name(file_name: str) -> datetime | None:
     FILE_NAME_REGEX = r"^(?P<date>\d{8})(?:-(?P<time>\d{4,6}))?.+.md$"
     base_name = os.path.basename(file_name)
     match = re.match(FILE_NAME_REGEX, base_name)
@@ -17,4 +17,76 @@ def extract_date_from_file_name(file_name: str) -> datetime | None:
     return None
 
 
-__all__ = ["extract_date_from_file_name"]
+def extract_datetime_from_marker(marker: str) -> datetime | None:
+    """
+    Extract a datetime from a marker string in the exact format: YYYYMMDDHHMMSS.
+
+    Returns:
+        Parsed datetime if the format is fulfilled and values are valid, else None.
+    """
+    if not re.fullmatch(r"\d{14}", marker or ""):
+        return None
+    try:
+        return datetime.strptime(marker, "%Y%m%d%H%M%S")
+    except ValueError:
+        return None
+
+
+def extract_date_from_marker(marker: str) -> date | None:
+    """
+    Extract a date from a marker string in the exact format: YYYYMMDD.
+
+    Returns:
+        Parsed date if the format is fulfilled and values are valid, else None.
+    """
+    if not re.fullmatch(r"\d{8}", marker or ""):
+        return None
+    try:
+        return datetime.strptime(marker, "%Y%m%d").date()
+    except ValueError:
+        return None
+
+
+def extract_time_from_marker(marker: str) -> time | None:  # noqa: F821
+    """
+    Extract a time from a marker string in the exact format: HHMMSS.
+
+    Returns:
+        Parsed time if the format is fulfilled and values are valid, else None.
+    """
+    if not re.fullmatch(r"\d{6}", marker or ""):
+        return None
+    try:
+        return datetime.strptime(marker, "%H%M%S").time()
+    except ValueError:
+        return None
+
+
+def extract_datetime_from_marker_list(markers: list[str], inherited_datetime: datetime):
+    shard_time: time | None = None
+    shard_date: date | None = None
+
+    for marker in markers[::-1]:
+        if parsed_time := extract_time_from_marker(marker):
+            shard_time = parsed_time
+        if parsed_date := extract_date_from_marker(marker):
+            shard_date = parsed_date
+        if parsed_datetime := extract_datetime_from_marker(marker):
+            shard_date = parsed_datetime.date()
+            shard_time = parsed_datetime.time()
+
+    if shard_date and not shard_time:
+        return datetime.combine(shard_date, time(0, 0, 0))
+
+    return datetime.combine(
+        shard_date or inherited_datetime.date(), shard_time or inherited_datetime.time()
+    )
+
+
+__all__ = [
+    "extract_datetime_from_file_name",
+    "extract_datetime_from_marker",
+    "extract_date_from_marker",
+    "extract_time_from_marker",
+    "extract_datetime_from_marker_list",
+]
diff --git a/src/streamer/localize/localize.py b/src/streamer/localize/localize.py
index 9f181a5..8a0851c 100644
--- a/src/streamer/localize/localize.py
+++ b/src/streamer/localize/localize.py
@@ -1,19 +1,29 @@
+from datetime import datetime
 
 from streamer.parse.shard import Shard, StreamFile
 
-from .repostory_configuration import RepositoryConfiguration
+from .extract_datetime import (
+    extract_datetime_from_file_name,
+    extract_datetime_from_marker_list,
+)
 from .localized_shard import LocalizedShard
-from .extract_datetime import extract_date_from_file_name
+from .repostory_configuration import RepositoryConfiguration
 
 
 def localize_shard(
-    shard: Shard, config: RepositoryConfiguration, propagated: dict[str, str]
+    shard: Shard,
+    config: RepositoryConfiguration,
+    propagated: dict[str, str],
+    moment: datetime,
 ) -> LocalizedShard:
     position = {**propagated}
     private_position: dict[str, str] = {}
 
+    adjusted_moment: datetime = extract_datetime_from_marker_list(shard.markers, moment)
+
     for marker in shard.markers:
         normalized_marker = marker.lower()
+
         if marker_definition := config.markers[normalized_marker]:
             dimension_name = marker_definition.dimension
             dimension = config.dimensions[marker_definition.dimension]
@@ -23,24 +33,30 @@ def localize_shard(
             else:
                 private_position[dimension_name] = normalized_marker
 
-    children = [localize_shard(child, config, position) for child in shard.children]
+    children = [
+        localize_shard(child, config, position, adjusted_moment)
+        for child in shard.children
+    ]
 
     position.update(private_position)
 
     return LocalizedShard(
-        **shard.model_dump(exclude={"children"}), location=position, children=children
+        **shard.model_dump(exclude={"children"}),
+        location=position,
+        children=children,
+        moment=adjusted_moment,
     )
 
 
 def localize_stream_file(
     stream_file: StreamFile, config: RepositoryConfiguration
 ) -> LocalizedShard | None:
-    shard_date = extract_date_from_file_name(stream_file.filename)
+    shard_date = extract_datetime_from_file_name(stream_file.filename)
 
     if not shard_date or not stream_file.shard:
         raise ValueError("Could not extract date")
 
-    return localize_shard(stream_file.shard, config, {"moment": shard_date.isoformat()})
+    return localize_shard(stream_file.shard, config, {}, shard_date)
 
 
 __all__ = ["localize_stream_file"]
diff --git a/src/streamer/localize/localized_shard.py b/src/streamer/localize/localized_shard.py
index 02d7ab8..05cb016 100644
--- a/src/streamer/localize/localized_shard.py
+++ b/src/streamer/localize/localized_shard.py
@@ -1,8 +1,12 @@
 from __future__ import annotations
+
+from datetime import datetime
+
 from streamer.parse.shard import Shard
 
 
 class LocalizedShard(Shard):
+    moment: datetime
     location: dict[str, str]
     children: list[LocalizedShard] = []  # pyright: ignore[reportIncompatibleVariableOverride]
 
diff --git a/src/streamer/parse/attach_markdown.py b/src/streamer/parse/attach_markdown.py
index 70766d9..349377f 100644
--- a/src/streamer/parse/attach_markdown.py
+++ b/src/streamer/parse/attach_markdown.py
@@ -1,3 +1,5 @@
+from __future__ import annotations
+
 from streamer.parse.shard import Shard, StreamFile
 
 
@@ -7,7 +9,7 @@ class ShardWithMarkdown(Shard):
 
 
 class StreamFileWithMarkdown(StreamFile):
-    shard: ShardWithMarkdown | None = None  # pyright: ignore[reportIncompatibleVariableOverride]
+    shard: ShardWithMarkdown | None = None
 
 
 def attach_markdown_shard(shard: Shard, markdown_text: str) -> ShardWithMarkdown:
@@ -15,7 +17,9 @@ def attach_markdown_shard(shard: Shard, markdown_text: str) -> ShardWithMarkdown
     markdown_content = "\n".join(lines[shard.start_line - 1 : shard.end_line])
     return ShardWithMarkdown(
         **shard.model_dump(exclude=["children"]),
-        children=map(lambda child: attach_markdown_shard(child, markdown_text), shard.children),
+        children=[
+            attach_markdown_shard(child, markdown_text) for child in shard.children
+        ],
         markdown_content=markdown_content,
     )
 
diff --git a/test/localize/test_extract_datetime.py b/test/localize/test_extract_datetime.py
index 95cefc0..279f194 100644
--- a/test/localize/test_extract_datetime.py
+++ b/test/localize/test_extract_datetime.py
@@ -1,32 +1,157 @@
-from datetime import datetime
-from streamer.localize.extract_datetime import extract_date_from_file_name
+from datetime import date, datetime, time
+
+from streamer.localize.extract_datetime import (
+    extract_date_from_marker,
+    extract_datetime_from_file_name,
+    extract_datetime_from_marker,
+    extract_datetime_from_marker_list,
+    extract_time_from_marker,
+)
 
 
 class TestExtractDateTime:
     def test_extract_date_from_file_name_valid(self):
         file_name = "20230101-123456 Some Text.md"
-        assert datetime(2023, 1, 1, 12, 34, 56) == extract_date_from_file_name(
+        assert datetime(2023, 1, 1, 12, 34, 56) == extract_datetime_from_file_name(
             file_name
         )
 
     def test_extract_date_from_file_name_invalid(self):
         file_name = "invalid-file-name.md"
-        assert extract_date_from_file_name(file_name) is None
+        assert extract_datetime_from_file_name(file_name) is None
 
     def test_extract_date_from_file_name_without_time(self):
         file_name = "20230101 Some Text.md"
-        assert datetime(2023, 1, 1, 0, 0, 0) == extract_date_from_file_name(file_name)
+        assert datetime(2023, 1, 1, 0, 0, 0) == extract_datetime_from_file_name(
+            file_name
+        )
 
     def test_extract_date_from_file_name_short_time(self):
         file_name = "20230101-1234 Some Text.md"
-        assert datetime(2023, 1, 1, 12, 34, 0) == extract_date_from_file_name(file_name)
+        assert datetime(2023, 1, 1, 12, 34, 0) == extract_datetime_from_file_name(
+            file_name
+        )
 
     def test_extract_date_from_file_name_empty_string(self):
         file_name = ""
-        assert extract_date_from_file_name(file_name) is None
+        assert extract_datetime_from_file_name(file_name) is None
 
     def test_extract_date_from_file_name_with_full_path(self):
         file_name = "/path/to/20230101-123456 Some Text.md"
-        assert datetime(2023, 1, 1, 12, 34, 56) == extract_date_from_file_name(
+        assert datetime(2023, 1, 1, 12, 34, 56) == extract_datetime_from_file_name(
             file_name
         )
+
+
+class TestExtractMarkerDateTime:
+    def test_extract_datetime_from_marker_valid(self):
+        marker = "20250101150000"
+        assert datetime(2025, 1, 1, 15, 0, 0) == extract_datetime_from_marker(marker)
+
+    def test_extract_datetime_from_marker_invalid_format(self):
+        assert extract_datetime_from_marker("2025010115000") is None  # too short
+        assert extract_datetime_from_marker("202501011500000") is None  # too long
+        assert extract_datetime_from_marker("2025-01-01T150000") is None  # separators
+        assert extract_datetime_from_marker("2025010115000a") is None  # non-digit
+        assert extract_datetime_from_marker("") is None
+
+    def test_extract_datetime_from_marker_invalid_values(self):
+        assert extract_datetime_from_marker("20250230120000") is None  # Feb 30
+        assert extract_datetime_from_marker("20250101126000") is None  # minute 60
+        assert extract_datetime_from_marker("20250101240000") is None  # hour 24
+
+
+class TestExtractMarkerDate:
+    def test_extract_date_from_marker_valid(self):
+        marker = "20250101"
+        assert date(2025, 1, 1) == extract_date_from_marker(marker)
+
+    def test_extract_date_from_marker_invalid_format(self):
+        assert extract_date_from_marker("2025010") is None  # too short
+        assert extract_date_from_marker("202501011") is None  # too long
+        assert extract_date_from_marker("2025-01-01") is None  # separators
+        assert extract_date_from_marker("2025010a") is None  # non-digit
+        assert extract_date_from_marker("") is None
+
+    def test_extract_date_from_marker_invalid_values(self):
+        assert extract_date_from_marker("20250230") is None  # Feb 30
+        assert extract_date_from_marker("20251301") is None  # month 13
+        assert extract_date_from_marker("20250132") is None  # day 32
+
+
+class TestExtractMarkerTime:
+    def test_extract_time_from_marker_valid(self):
+        marker = "150000"
+        assert time(15, 0, 0) == extract_time_from_marker(marker)
+
+    def test_extract_time_from_marker_invalid_format(self):
+        assert extract_time_from_marker("15000") is None  # too short
+        assert extract_time_from_marker("1500000") is None  # too long
+        assert extract_time_from_marker("15:00:00") is None  # separators
+        assert extract_time_from_marker("15000a") is None  # non-digit
+        assert extract_time_from_marker("") is None
+
+    def test_extract_time_from_marker_invalid_values(self):
+        assert extract_time_from_marker("240000") is None  # hour 24
+        assert extract_time_from_marker("156000") is None  # minute 60
+        assert extract_time_from_marker("150060") is None  # second 60
+
+
+class TestExtractDateTimeFromMarkerList:
+    def test_no_markers_inherits_datetime(self):
+        inherited = datetime(2025, 1, 2, 3, 4, 5)
+        assert inherited == extract_datetime_from_marker_list([], inherited)
+
+    def test_unrelated_markers_inherits_datetime(self):
+        inherited = datetime(2025, 1, 2, 3, 4, 5)
+        markers = ["not-a-marker", "2025-01-01", "1500", "1234567"]
+        assert inherited == extract_datetime_from_marker_list(markers, inherited)
+
+    def test_date_only_marker_sets_midnight(self):
+        inherited = datetime(2025, 6, 7, 8, 9, 10)
+        markers = ["20250101"]
+        assert datetime(2025, 1, 1, 0, 0, 0) == extract_datetime_from_marker_list(
+            markers, inherited
+        )
+
+    def test_time_only_marker_inherits_date(self):
+        inherited = datetime(2025, 6, 7, 8, 9, 10)
+        markers = ["150000"]
+        assert datetime(2025, 6, 7, 15, 0, 0) == extract_datetime_from_marker_list(
+            markers, inherited
+        )
+
+    def test_datetime_marker_overrides_both_date_and_time(self):
+        inherited = datetime(2025, 6, 7, 8, 9, 10)
+        markers = ["20250101150000"]
+        assert datetime(2025, 1, 1, 15, 0, 0) == extract_datetime_from_marker_list(
+            markers, inherited
+        )
+
+    def test_combined_date_and_time_markers(self):
+        inherited = datetime(2025, 6, 7, 8, 9, 10)
+        markers = ["20250101", "150000"]
+        assert datetime(2025, 1, 1, 15, 0, 0) == extract_datetime_from_marker_list(
+            markers, inherited
+        )
+
+    def test_first_marker_wins_when_multiple_dates_or_times(self):
+        inherited = datetime(2025, 6, 7, 8, 9, 10)
+        markers = ["20250101", "150000", "20250102", "160000"]
+        assert datetime(2025, 1, 1, 15, 0, 0) == extract_datetime_from_marker_list(
+            markers, inherited
+        )
+
+    def test_last_separated_date_and_time_win(self):
+        inherited = datetime(2025, 6, 7, 8, 9, 10)
+        markers = ["20250101", "150000", "20250102160000"]
+        assert datetime(2025, 1, 1, 15, 0, 0) == extract_datetime_from_marker_list(
+            markers, inherited
+        )
+
+    def test_invalid_date_or_time_markers_are_ignored(self):
+        inherited = datetime(2025, 6, 7, 8, 9, 10)
+        markers = ["20251301", "240000", "20250101", "150000"]
+        assert datetime(2025, 1, 1, 15, 0, 0) == extract_datetime_from_marker_list(
+            markers, inherited
+        )
diff --git a/test/test_localize.py b/test/test_localize.py
index 63c25f3..adf8cad 100644
--- a/test/test_localize.py
+++ b/test/test_localize.py
@@ -1,3 +1,5 @@
+from datetime import datetime
+
 from streamer.localize.localize import localize_stream_file
 from streamer.localize.localized_shard import LocalizedShard
 from streamer.localize.repostory_configuration import (
@@ -37,10 +39,11 @@ class TestExtractDateTime:
         assert localize_stream_file(
             stream_file, repository_configuration
         ) == LocalizedShard(
+            moment=datetime(2025, 6, 22, 12, 10, 0, 0),
             markers=["Streamer"],
             tags=[],
             start_line=1,
             end_line=1,
             children=[],
-            location={"moment": "2025-06-22T12:10:00", "project": "streamer"},
+            location={"project": "streamer"},
         )
-- 
2.53.0


From 79095bad4ad1ef8aec6014fed49806d6dec6e97b Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sat, 31 Jan 2026 17:21:55 +0100
Subject: [PATCH 04/12] refactor: store file in position, rename filename to
 file_name

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/__init__.py              |  2 +-
 src/streamer/localize/localize.py     |  6 ++++--
 src/streamer/parse/attach_markdown.py |  4 ++--
 src/streamer/parse/parse.py           |  2 +-
 src/streamer/parse/shard.py           |  3 ++-
 test/parse/test_attach_markdown.py    | 12 ++++++------
 test/parse/test_parse.py              | 18 +++++++++---------
 test/test_localize.py                 |  4 ++--
 8 files changed, 27 insertions(+), 24 deletions(-)

diff --git a/src/streamer/__init__.py b/src/streamer/__init__.py
index 47fa553..2e38293 100644
--- a/src/streamer/__init__.py
+++ b/src/streamer/__init__.py
@@ -37,7 +37,7 @@ def todo() -> None:
                 print(
                     Panel(
                         Markdown(task_shard.markdown_content),
-                        title=f"{sharded_document.filename}:{task_shard.start_line}",
+                        title=f"{sharded_document.file_name}:{task_shard.start_line}",
                     )
                 )
 
diff --git a/src/streamer/localize/localize.py b/src/streamer/localize/localize.py
index 8a0851c..fcf0fa4 100644
--- a/src/streamer/localize/localize.py
+++ b/src/streamer/localize/localize.py
@@ -51,12 +51,14 @@ def localize_shard(
 def localize_stream_file(
     stream_file: StreamFile, config: RepositoryConfiguration
 ) -> LocalizedShard | None:
-    shard_date = extract_datetime_from_file_name(stream_file.filename)
+    shard_date = extract_datetime_from_file_name(stream_file.file_name)
 
     if not shard_date or not stream_file.shard:
         raise ValueError("Could not extract date")
 
-    return localize_shard(stream_file.shard, config, {}, shard_date)
+    return localize_shard(
+        stream_file.shard, config, {"file": stream_file.file_name}, shard_date
+    )
 
 
 __all__ = ["localize_stream_file"]
diff --git a/src/streamer/parse/attach_markdown.py b/src/streamer/parse/attach_markdown.py
index 349377f..85b5d6f 100644
--- a/src/streamer/parse/attach_markdown.py
+++ b/src/streamer/parse/attach_markdown.py
@@ -26,10 +26,10 @@ def attach_markdown_shard(shard: Shard, markdown_text: str) -> ShardWithMarkdown
 
 def attach_markdown(file: StreamFile, markdown_text: str) -> StreamFileWithMarkdown:
     if file.shard is None:
-        return StreamFileWithMarkdown(filename=file.filename, shard=None)
+        return StreamFileWithMarkdown(file_name=file.file_name, shard=None)
 
     attached_shard = attach_markdown_shard(file.shard, markdown_text)
-    return StreamFileWithMarkdown(filename=file.filename, shard=attached_shard)
+    return StreamFileWithMarkdown(file_name=file.file_name, shard=attached_shard)
 
 
 __all__ = ["attach_markdown"]
diff --git a/src/streamer/parse/parse.py b/src/streamer/parse/parse.py
index 4a8258f..058912a 100644
--- a/src/streamer/parse/parse.py
+++ b/src/streamer/parse/parse.py
@@ -236,7 +236,7 @@ def parse_markdown_file(file_name: str, file_content: str) -> StreamFile:
             ):
                 shard = parsed_shard
 
-    return StreamFile(shard=shard, filename=file_name)
+    return StreamFile(shard=shard, file_name=file_name)
 
 
 __all__ = ["Shard", "StreamFile", "parse_markdown_file"]
diff --git a/src/streamer/parse/shard.py b/src/streamer/parse/shard.py
index 397950f..65432c3 100644
--- a/src/streamer/parse/shard.py
+++ b/src/streamer/parse/shard.py
@@ -1,4 +1,5 @@
 from __future__ import annotations
+
 from pydantic import BaseModel
 
 
@@ -11,7 +12,7 @@ class Shard(BaseModel):
 
 
 class StreamFile(BaseModel):
-    filename: str
+    file_name: str
     shard: Shard | None = None
 
 
diff --git a/test/parse/test_attach_markdown.py b/test/parse/test_attach_markdown.py
index 21f8a1b..0ec1253 100644
--- a/test/parse/test_attach_markdown.py
+++ b/test/parse/test_attach_markdown.py
@@ -16,12 +16,12 @@ class TestAttachMarkdown:
     def test_attach_markdown_with_shard(self):
         markdown_text = "Hello World\n\nThis is a test."
         shard = Shard(start_line=1, end_line=3)
-        stream_file = StreamFile(filename=self.file_name, shard=shard)
+        stream_file = StreamFile(file_name=self.file_name, shard=shard)
 
         result = attach_markdown(stream_file, markdown_text)
 
         assert result == StreamFileWithMarkdown(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=ShardWithMarkdown(
                 start_line=1,
                 end_line=3,
@@ -33,11 +33,11 @@ class TestAttachMarkdown:
         )
 
     def test_attach_markdown_without_shard(self):
-        stream_file = StreamFile(filename=self.file_name, shard=None)
+        stream_file = StreamFile(file_name=self.file_name, shard=None)
 
         result = attach_markdown(stream_file, "Some markdown text")
 
-        assert result == StreamFileWithMarkdown(filename=self.file_name, shard=None)
+        assert result == StreamFileWithMarkdown(file_name=self.file_name, shard=None)
 
     def test_attach_markdown_with_nested_shards(self):
         markdown_text = "Header\n\n@Marker1 Content 1\n\n@Marker2 Content 2"
@@ -49,11 +49,11 @@ class TestAttachMarkdown:
                 Shard(markers=["Marker2"], start_line=5, end_line=5),
             ],
         )
-        stream_file = StreamFile(filename=self.file_name, shard=shard)
+        stream_file = StreamFile(file_name=self.file_name, shard=shard)
 
         result = attach_markdown(stream_file, markdown_text)
 
-        assert result.filename == self.file_name
+        assert result.file_name == self.file_name
         assert result.shard is not None
         assert result.shard.start_line == 1
         assert result.shard.end_line == 5
diff --git a/test/parse/test_parse.py b/test/parse/test_parse.py
index 0a71671..b692120 100644
--- a/test/parse/test_parse.py
+++ b/test/parse/test_parse.py
@@ -10,13 +10,13 @@ class TestParseProcess:
 
     def test_parse_empty_file(self):
         assert parse_markdown_file(self.file_name, "") == StreamFile(
-            filename=self.file_name, shard=Shard(start_line=1, end_line=1)
+            file_name=self.file_name, shard=Shard(start_line=1, end_line=1)
         )
 
     def test_parse_basic_one_line_file(self):
         test_file = "Hello World"
         assert parse_markdown_file(self.file_name, test_file) == StreamFile(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=Shard(
                 start_line=1,
                 end_line=1,
@@ -26,7 +26,7 @@ class TestParseProcess:
     def test_parse_basic_multi_line_file(self):
         test_file = "Hello World\n\nHello again!"
         assert parse_markdown_file(self.file_name, test_file) == StreamFile(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=Shard(
                 start_line=1,
                 end_line=3,
@@ -36,7 +36,7 @@ class TestParseProcess:
     def test_parse_single_line_with_tag(self):
         test_file = "@Tag Hello World"
         assert parse_markdown_file(self.file_name, test_file) == StreamFile(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=Shard(
                 markers=["Tag"],
                 start_line=1,
@@ -47,7 +47,7 @@ class TestParseProcess:
     def test_parse_single_line_with_two_tags(self):
         test_file = "@Marker1 @Marker2 Hello World"
         assert parse_markdown_file(self.file_name, test_file) == StreamFile(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=Shard(
                 markers=["Marker1", "Marker2"],
                 start_line=1,
@@ -58,7 +58,7 @@ class TestParseProcess:
     def test_parse_single_line_with_two_tags_and_misplaced_tag(self):
         test_file = "@Tag1 @Tag2 Hello World @Tag3"
         assert parse_markdown_file(self.file_name, test_file) == StreamFile(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=Shard(
                 markers=["Tag1", "Tag2"],
                 tags=["Tag3"],
@@ -71,7 +71,7 @@ class TestParseProcess:
         file_text = "Hello World!\n\n@Tag1 Block 1\n\n@Tag2 Block 2"
 
         assert parse_markdown_file(self.file_name, file_text) == StreamFile(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=Shard(
                 start_line=1,
                 end_line=5,
@@ -114,7 +114,7 @@ class TestParseProcess:
         file_text = "# Heading @Tag1\n\n## @Marker1 Subheading @Tag2\n\n# Heading @Tag3"
 
         assert parse_markdown_file(self.file_name, file_text) == StreamFile(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=Shard(
                 start_line=1,
                 end_line=5,
@@ -141,7 +141,7 @@ class TestParseProcess:
         file_text = "# @Marker1 Heading @Tag1\n\n## Subheading @Tag2"
 
         assert parse_markdown_file(self.file_name, file_text) == StreamFile(
-            filename=self.file_name,
+            file_name=self.file_name,
             shard=Shard(
                 markers=["Marker1"],
                 tags=["Tag1", "Tag2"],
diff --git a/test/test_localize.py b/test/test_localize.py
index adf8cad..f6c0dc0 100644
--- a/test/test_localize.py
+++ b/test/test_localize.py
@@ -32,7 +32,7 @@ repository_configuration = RepositoryConfiguration(
 class TestExtractDateTime:
     def test_project_simple_stream_file(self):
         stream_file = StreamFile(
-            filename="20250622-121000 Test File.md",
+            file_name="20250622-121000 Test File.md",
             shard=Shard(start_line=1, end_line=1, markers=["Streamer"]),
         )
 
@@ -45,5 +45,5 @@ class TestExtractDateTime:
             start_line=1,
             end_line=1,
             children=[],
-            location={"project": "streamer"},
+            location={"project": "streamer", "file": stream_file.file_name},
         )
-- 
2.53.0


From 4dbd142c7425f36cb1c73b57d7f724038248f250 Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sat, 31 Jan 2026 17:54:50 +0100
Subject: [PATCH 05/12] feat: better localization of shards

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/localize/localize.py             | 18 ++++----
 .../localize/repostory_configuration.py       | 11 ++++-
 test/test_localize.py                         | 46 +++++++++++++++++--
 3 files changed, 61 insertions(+), 14 deletions(-)

diff --git a/src/streamer/localize/localize.py b/src/streamer/localize/localize.py
index fcf0fa4..adb94a2 100644
--- a/src/streamer/localize/localize.py
+++ b/src/streamer/localize/localize.py
@@ -22,16 +22,18 @@ def localize_shard(
     adjusted_moment: datetime = extract_datetime_from_marker_list(shard.markers, moment)
 
     for marker in shard.markers:
-        normalized_marker = marker.lower()
+        if marker in config.markers:
+            marker_definition = config.markers[marker]
+            for placement in marker_definition.placements:
+                if set(placement.if_with) <= set(shard.markers):
+                    dimension = config.dimensions[placement.dimension]
 
-        if marker_definition := config.markers[normalized_marker]:
-            dimension_name = marker_definition.dimension
-            dimension = config.dimensions[marker_definition.dimension]
+                    value = placement.value or marker
 
-            if dimension.propagate:
-                position[dimension_name] = normalized_marker
-            else:
-                private_position[dimension_name] = normalized_marker
+                    if dimension.propagate:
+                        position[placement.dimension] = value
+                    else:
+                        private_position[placement.dimension] = value
 
     children = [
         localize_shard(child, config, position, adjusted_moment)
diff --git a/src/streamer/localize/repostory_configuration.py b/src/streamer/localize/repostory_configuration.py
index 95f32fe..3e37651 100644
--- a/src/streamer/localize/repostory_configuration.py
+++ b/src/streamer/localize/repostory_configuration.py
@@ -1,4 +1,5 @@
 from typing import Optional
+
 from pydantic import BaseModel
 
 
@@ -8,9 +9,15 @@ class Dimension(BaseModel):
     propagate: bool = False
 
 
+class MarkerPlacement(BaseModel):
+    if_with: list[str] = []
+    dimension: str
+    value: str | None = None
+
+
 class Marker(BaseModel):
     display_name: str
-    dimension: str
+    placements: list[MarkerPlacement]
 
 
 class RepositoryConfiguration(BaseModel):
@@ -18,4 +25,4 @@ class RepositoryConfiguration(BaseModel):
     markers: dict[str, Marker]
 
 
-__all__ = ["Dimension", "Marker", "RepositoryConfiguration"]
+__all__ = ["Dimension", "Marker", "MarkerPlacement", "RepositoryConfiguration"]
diff --git a/test/test_localize.py b/test/test_localize.py
index f6c0dc0..5f1ed65 100644
--- a/test/test_localize.py
+++ b/test/test_localize.py
@@ -5,6 +5,7 @@ from streamer.localize.localized_shard import LocalizedShard
 from streamer.localize.repostory_configuration import (
     Dimension,
     Marker,
+    MarkerPlacement,
     RepositoryConfiguration,
 )
 from streamer.parse.shard import Shard, StreamFile
@@ -21,15 +22,30 @@ repository_configuration = RepositoryConfiguration(
             comment="Timestamp this entry was created at",
             propagate=True,
         ),
+        "timesheet": Dimension(
+            display_name="Timesheet",
+            comment="Time Cards for Time Tracking",
+            propagate=True,
+        ),
     },
     markers={
-        "streamer": Marker(display_name="Streamer", dimension="project"),
-        "jobhunting": Marker(display_name="JobHunting", dimension="project"),
+        "Streamer": Marker(
+            display_name="Streamer",
+            placements=[
+                MarkerPlacement(dimension="project"),
+                MarkerPlacement(
+                    if_with=["Timesheet"], dimension="timesheet", value="coding"
+                ),
+            ],
+        ),
+        "JobHunting": Marker(
+            display_name="JobHunting", placements=[MarkerPlacement(dimension="project")]
+        ),
     },
 )
 
 
-class TestExtractDateTime:
+class TestLocalize:
     def test_project_simple_stream_file(self):
         stream_file = StreamFile(
             file_name="20250622-121000 Test File.md",
@@ -45,5 +61,27 @@ class TestExtractDateTime:
             start_line=1,
             end_line=1,
             children=[],
-            location={"project": "streamer", "file": stream_file.file_name},
+            location={"project": "Streamer", "file": stream_file.file_name},
+        )
+
+    def test_timesheet_use_case(self):
+        stream_file = StreamFile(
+            file_name="20260131-210000 Test File.md",
+            shard=Shard(start_line=1, end_line=1, markers=["Timesheet", "Streamer"]),
+        )
+
+        assert localize_stream_file(
+            stream_file, repository_configuration
+        ) == LocalizedShard(
+            moment=datetime(2026, 1, 31, 21, 0, 0, 0),
+            markers=["Timesheet", "Streamer"],
+            tags=[],
+            start_line=1,
+            end_line=1,
+            children=[],
+            location={
+                "file": stream_file.file_name,
+                "project": "Streamer",
+                "timesheet": "coding",
+            },
         )
-- 
2.53.0


From 1040c060f6824aa35f873b7ab50f29a6c433c284 Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sat, 31 Jan 2026 19:50:36 +0100
Subject: [PATCH 06/12] feat: add merge for repository configuration

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/localize/__init__.py             |   2 +-
 src/streamer/localize/localize.py             |   4 +-
 .../localize/repository_configuration.py      | 107 +++++
 .../localize/repostory_configuration.py       |  28 --
 .../test_repository_configuration_merge.py    | 365 ++++++++++++++++++
 test/test_localize.py                         |   4 +-
 6 files changed, 477 insertions(+), 33 deletions(-)
 create mode 100644 src/streamer/localize/repository_configuration.py
 delete mode 100644 src/streamer/localize/repostory_configuration.py
 create mode 100644 test/localize/test_repository_configuration_merge.py

diff --git a/src/streamer/localize/__init__.py b/src/streamer/localize/__init__.py
index 31f4f71..97456a2 100644
--- a/src/streamer/localize/__init__.py
+++ b/src/streamer/localize/__init__.py
@@ -1,6 +1,6 @@
 from .localize import localize_stream_file
-from .repostory_configuration import RepositoryConfiguration
 from .localized_shard import LocalizedShard
+from .repository_configuration import RepositoryConfiguration
 
 __all__ = [
     "RepositoryConfiguration",
diff --git a/src/streamer/localize/localize.py b/src/streamer/localize/localize.py
index adb94a2..5875c87 100644
--- a/src/streamer/localize/localize.py
+++ b/src/streamer/localize/localize.py
@@ -7,7 +7,7 @@ from .extract_datetime import (
     extract_datetime_from_marker_list,
 )
 from .localized_shard import LocalizedShard
-from .repostory_configuration import RepositoryConfiguration
+from .repository_configuration import RepositoryConfiguration
 
 
 def localize_shard(
@@ -25,7 +25,7 @@ def localize_shard(
         if marker in config.markers:
             marker_definition = config.markers[marker]
             for placement in marker_definition.placements:
-                if set(placement.if_with) <= set(shard.markers):
+                if placement.if_with <= set(shard.markers):
                     dimension = config.dimensions[placement.dimension]
 
                     value = placement.value or marker
diff --git a/src/streamer/localize/repository_configuration.py b/src/streamer/localize/repository_configuration.py
new file mode 100644
index 0000000..a0c7814
--- /dev/null
+++ b/src/streamer/localize/repository_configuration.py
@@ -0,0 +1,107 @@
+from __future__ import annotations
+
+from typing import Optional
+
+from pydantic import BaseModel
+
+
+class Dimension(BaseModel):
+    display_name: str
+    comment: Optional[str] = None
+    propagate: bool = False
+
+
+class MarkerPlacement(BaseModel):
+    if_with: set[str] = set()
+    dimension: str
+    value: str | None = None
+
+
+class Marker(BaseModel):
+    display_name: str
+    placements: list[MarkerPlacement] = []
+
+
+class RepositoryConfiguration(BaseModel):
+    dimensions: dict[str, Dimension]
+    markers: dict[str, Marker]
+
+
+def merge_single_dimension(base: Dimension, second: Dimension) -> Dimension:
+    second_fields_set = getattr(second, "model_fields_set", set())
+
+    return Dimension(
+        display_name=second.display_name or base.display_name,
+        comment=base.comment if second.comment is None else second.comment,
+        propagate=second.propagate
+        if "propagate" in second_fields_set
+        else base.propagate,
+    )
+
+
+def merge_dimensions(
+    base: dict[str, Dimension], second: dict[str, Dimension]
+) -> dict[str, Dimension]:
+    merged: dict[str, Dimension] = dict(base)
+    for key, second_dimension in second.items():
+        if key in merged:
+            merged[key] = merge_single_dimension(merged[key], second_dimension)
+        else:
+            merged[key] = second_dimension
+    return merged
+
+
+def _placement_identity(p: MarkerPlacement) -> tuple[frozenset[str], str]:
+    return (frozenset(p.if_with), p.dimension)
+
+
+def merge_single_marker(base: Marker, second: Marker) -> Marker:
+    merged_display_name = second.display_name or base.display_name
+
+    merged_placements: list[MarkerPlacement] = []
+    seen: dict[tuple[frozenset[str], str], int] = {}
+
+    for placement in base.placements:
+        ident = _placement_identity(placement)
+        seen[ident] = len(merged_placements)
+        merged_placements.append(placement)
+
+    for placement in second.placements:
+        ident = _placement_identity(placement)
+        if ident in seen:
+            merged_placements[seen[ident]] = placement
+        else:
+            seen[ident] = len(merged_placements)
+            merged_placements.append(placement)
+
+    return Marker(display_name=merged_display_name, placements=merged_placements)
+
+
+def merge_markers(
+    base: dict[str, Marker], second: dict[str, Marker]
+) -> dict[str, Marker]:
+    merged: dict[str, Marker] = dict(base)
+    for key, second_marker in second.items():
+        if key in merged:
+            merged[key] = merge_single_marker(merged[key], second_marker)
+        else:
+            merged[key] = second_marker
+    return merged
+
+
+def merge_repository_configuration(
+    base: RepositoryConfiguration, second: RepositoryConfiguration
+) -> RepositoryConfiguration:
+    return RepositoryConfiguration(
+        dimensions=merge_dimensions(base.dimensions, second.dimensions),
+        markers=merge_markers(base.markers, second.markers),
+    )
+
+
+__all__ = [
+    "Dimension",
+    "Marker",
+    "MarkerPlacement",
+    "RepositoryConfiguration",
+    "merge_repository_configuration",
+]
diff --git a/src/streamer/localize/repostory_configuration.py b/src/streamer/localize/repostory_configuration.py
deleted file mode 100644
index 3e37651..0000000
--- a/src/streamer/localize/repostory_configuration.py
+++ /dev/null
@@ -1,28 +0,0 @@
-from typing import Optional
-
-from pydantic import BaseModel
-
-
-class Dimension(BaseModel):
-    display_name: str
-    comment: Optional[str] = None
-    propagate: bool = False
-
-
-class MarkerPlacement(BaseModel):
-    if_with: list[str] = []
-    dimension: str
-    value: str | None = None
-
-
-class Marker(BaseModel):
-    display_name: str
-    placements: list[MarkerPlacement]
-
-
-class RepositoryConfiguration(BaseModel):
-    dimensions: dict[str, Dimension]
-    markers: dict[str, Marker]
-
-
-__all__ = ["Dimension", "Marker", "MarkerPlacement", "RepositoryConfiguration"]
diff --git a/test/localize/test_repository_configuration_merge.py b/test/localize/test_repository_configuration_merge.py
new file mode 100644
index 0000000..f5d345d
--- /dev/null
+++ b/test/localize/test_repository_configuration_merge.py
@@ -0,0 +1,365 @@
+import pytest
+
+from streamer.localize.repository_configuration import (
+    Dimension,
+    Marker,
+    MarkerPlacement,
+    RepositoryConfiguration,
+    merge_dimensions,
+    merge_markers,
+    merge_repository_configuration,
+    merge_single_dimension,
+    merge_single_marker,
+)
+
+
+class TestMergeSingleDimension:
+    def test_second_overrides_display_name_when_non_empty(self):
+        base = Dimension(display_name="Base", comment="c1", propagate=True)
+        second = Dimension(display_name="Second", comment="c2", propagate=False)
+
+        merged = merge_single_dimension(base, second)
+
+        assert merged.display_name == "Second"
+        assert merged.comment == "c2"
+        assert merged.propagate is False
+
+    def test_second_empty_display_name_falls_back_to_base(self):
+        base = Dimension(display_name="Base", comment="c1", propagate=True)
+        second = Dimension(display_name="", comment="c2", propagate=False)
+
+        merged = merge_single_dimension(base, second)
+
+        assert merged.display_name == "Base"
+        assert merged.comment == "c2"
+        assert merged.propagate is False
+
+    def test_second_comment_none_does_not_erase_base_comment(self):
+        base = Dimension(display_name="Base", comment="keep", propagate=True)
+        second = Dimension(display_name="Second", comment=None, propagate=False)
+
+        merged = merge_single_dimension(base, second)
+
+        assert merged.display_name == "Second"
+        assert merged.comment == "keep"
+
+    def test_second_comment_non_none_overrides_base_comment(self):
+        base = Dimension(display_name="Base", comment="c1", propagate=True)
+        second = Dimension(display_name="Second", comment="c2", propagate=True)
+
+        merged = merge_single_dimension(base, second)
+
+        assert merged.comment == "c2"
+
+    def test_second_propagate_overrides_base_when_provided(self):
+        base = Dimension(display_name="Base", comment="c1", propagate=True)
+        second = Dimension(display_name="Second", comment="c2", propagate=False)
+
+        merged = merge_single_dimension(base, second)
+
+        assert merged.propagate is False
+
+    def test_propagate_merging_retains_base_when_second_not_provided(self):
+        base = Dimension(display_name="Base", comment="c1", propagate=True)
+        second = Dimension(display_name="Second", comment="c2")
+
+        merged = merge_single_dimension(base, second)
+
+        assert merged.propagate is True
+
+
+class TestMergeDimensions:
+    def test_adds_new_keys_from_second(self):
+        base = {"a": Dimension(display_name="A", propagate=True)}
+        second = {"b": Dimension(display_name="B", propagate=False)}
+
+        merged = merge_dimensions(base, second)
+
+        assert set(merged.keys()) == {"a", "b"}
+        assert merged["a"].display_name == "A"
+        assert merged["b"].display_name == "B"
+
+    def test_merges_existing_keys(self):
+        base = {"a": Dimension(display_name="A", comment="c1", propagate=True)}
+        second = {"a": Dimension(display_name="A2", comment=None, propagate=False)}
+
+        merged = merge_dimensions(base, second)
+
+        assert merged["a"].display_name == "A2"
+        assert merged["a"].comment == "c1"
+        assert merged["a"].propagate is False
+
+    def test_does_not_mutate_inputs(self):
+        base = {"a": Dimension(display_name="A", comment="c1", propagate=True)}
+        second = {"b": Dimension(display_name="B", comment="c2", propagate=False)}
+
+        merged = merge_dimensions(base, second)
+
+        assert "b" not in base
+        assert "a" not in second
+        assert set(merged.keys()) == {"a", "b"}
+
+
+class TestMergeSingleMarker:
+    def test_second_overrides_display_name_when_non_empty(self):
+        base = Marker(
+            display_name="Base",
+            placements=[MarkerPlacement(dimension="project", value=None)],
+        )
+        second = Marker(
+            display_name="Second",
+            placements=[MarkerPlacement(dimension="timesheet", value="coding")],
+        )
+
+        merged = merge_single_marker(base, second)
+
+        assert merged.display_name == "Second"
+        assert merged.placements == [
+            MarkerPlacement(dimension="project", value=None, if_with=set()),
+            MarkerPlacement(dimension="timesheet", value="coding", if_with=set()),
+        ]
+
+    def test_second_empty_display_name_falls_back_to_base(self):
+        base = Marker(display_name="Base", placements=[])
+        second = Marker(display_name="", placements=[])
+
+        merged = merge_single_marker(base, second)
+
+        assert merged.display_name == "Base"
+
+    def test_appends_new_placements(self):
+        base = Marker(
+            display_name="Base",
+            placements=[
+                MarkerPlacement(dimension="project"),
+            ],
+        )
+        second = Marker(
+            display_name="Second",
+            placements=[
+                MarkerPlacement(
+                    if_with={"Timesheet"}, dimension="timesheet", value="x"
+                ),
+            ],
+        )
+
+        merged = merge_single_marker(base, second)
+
+        assert merged.placements == [
+            MarkerPlacement(dimension="project"),
+            MarkerPlacement(if_with={"Timesheet"}, dimension="timesheet", value="x"),
+        ]
+
+    def test_deduplicates_by_identity_and_second_overrides_base(self):
+        base = Marker(
+            display_name="Base",
+            placements=[
+                MarkerPlacement(if_with={"A"}, dimension="d", value="v"),
+                MarkerPlacement(if_with={"B"}, dimension="d", value="v2"),
+            ],
+        )
+        second = Marker(
+            display_name="Second",
+            placements=[
+                MarkerPlacement(if_with={"A"}, dimension="d", value="v"),
+                MarkerPlacement(if_with={"C"}, dimension="d", value="v3"),
+            ],
+        )
+
+        merged = merge_single_marker(base, second)
+
+        assert merged.placements == [
+            MarkerPlacement(if_with={"A"}, dimension="d", value="v"),
+            MarkerPlacement(if_with={"B"}, dimension="d", value="v2"),
+            MarkerPlacement(if_with={"C"}, dimension="d", value="v3"),
+        ]
+
+    def test_identity_is_order_insensitive_for_if_with(self):
+        base = Marker(
+            display_name="Base",
+            placements=[MarkerPlacement(if_with={"A", "B"}, dimension="d", value="v")],
+        )
+        second = Marker(
+            display_name="Second",
+            placements=[MarkerPlacement(if_with={"B", "A"}, dimension="d", value="v2")],
+        )
+
+        merged = merge_single_marker(base, second)
+
+        # With `if_with` as a set, identity is order-insensitive; second overrides base.
+        assert merged.placements == [
+            MarkerPlacement(if_with={"A", "B"}, dimension="d", value="v2"),
+        ]
+
+
+class TestMergeMarkers:
+    def test_adds_new_marker_keys_from_second(self):
+        base = {"M1": Marker(display_name="M1", placements=[])}
+        second = {"M2": Marker(display_name="M2", placements=[])}
+
+        merged = merge_markers(base, second)
+
+        assert set(merged.keys()) == {"M1", "M2"}
+
+    def test_merges_existing_marker_keys(self):
+        base = {
+            "M": Marker(
+                display_name="Base",
+                placements=[MarkerPlacement(dimension="project")],
+            )
+        }
+        second = {
+            "M": Marker(
+                display_name="Second",
+                placements=[
+                    MarkerPlacement(
+                        if_with={"Timesheet"}, dimension="timesheet", value="coding"
+                    )
+                ],
+            )
+        }
+
+        merged = merge_markers(base, second)
+
+        assert merged["M"].display_name == "Second"
+        assert merged["M"].placements == [
+            MarkerPlacement(dimension="project", value=None, if_with=set()),
+            MarkerPlacement(
+                if_with={"Timesheet"}, dimension="timesheet", value="coding"
+            ),
+        ]
+
+    def test_does_not_mutate_inputs(self):
+        base = {"M1": Marker(display_name="M1", placements=[])}
+        second = {"M2": Marker(display_name="M2", placements=[])}
+
+        merged = merge_markers(base, second)
+
+        assert "M2" not in base
+        assert "M1" not in second
+        assert set(merged.keys()) == {"M1", "M2"}
+
+
+class TestMergeRepositoryConfiguration:
+    def test_merges_dimensions_and_markers(self):
+        base = RepositoryConfiguration(
+            dimensions={
+                "project": Dimension(
+                    display_name="Project", comment="c1", propagate=True
+                ),
+                "moment": Dimension(
+                    display_name="Moment", comment="c2", propagate=True
+                ),
+            },
+            markers={
+                "Streamer": Marker(
+                    display_name="Streamer",
+                    placements=[MarkerPlacement(dimension="project")],
+                )
+            },
+        )
+
+        second = RepositoryConfiguration(
+            dimensions={
+                "project": Dimension(display_name="Project2", propagate=False),
+                "timesheet": Dimension(
+                    display_name="Timesheet", comment="c3", propagate=False
+                ),
+            },
+            markers={
+                "Streamer": Marker(
+                    display_name="Streamer2",
+                    placements=[
+                        MarkerPlacement(
+                            if_with={"Timesheet"}, dimension="timesheet", value="coding"
+                        )
+                    ],
+                ),
+                "JobHunting": Marker(
+                    display_name="JobHunting",
+                    placements=[MarkerPlacement(dimension="project")],
+                ),
+            },
+        )
+
+        merged = merge_repository_configuration(base, second)
+
+        assert set(merged.dimensions.keys()) == {"project", "moment", "timesheet"}
+        assert merged.dimensions["project"].display_name == "Project2"
+        assert merged.dimensions["project"].comment == "c1"
+        assert merged.dimensions["project"].propagate is False
+        assert merged.dimensions["moment"].display_name == "Moment"
+        assert merged.dimensions["timesheet"].display_name == "Timesheet"
+
+        assert set(merged.markers.keys()) == {"Streamer", "JobHunting"}
+        assert merged.markers["Streamer"].display_name == "Streamer2"
+        assert merged.markers["Streamer"].placements == [
+            MarkerPlacement(dimension="project", value=None, if_with=set()),
+            MarkerPlacement(
+                if_with={"Timesheet"}, dimension="timesheet", value="coding"
+            ),
+        ]
+        assert merged.markers["JobHunting"].placements == [
+            MarkerPlacement(dimension="project", value=None, if_with=set())
+        ]
+
+    def test_does_not_mutate_base_or_second(self):
+        base = RepositoryConfiguration(
+            dimensions={"a": Dimension(display_name="A", propagate=True)},
+            markers={"M": Marker(display_name="M", placements=[])},
+        )
+        second = RepositoryConfiguration(
+            dimensions={"b": Dimension(display_name="B", propagate=False)},
+            markers={"N": Marker(display_name="N", placements=[])},
+        )
+
+        _ = merge_repository_configuration(base, second)
+
+        assert set(base.dimensions.keys()) == {"a"}
+        assert set(second.dimensions.keys()) == {"b"}
+        assert set(base.markers.keys()) == {"M"}
+        assert set(second.markers.keys()) == {"N"}
+
+    def test_merge_is_associative_for_non_conflicting_inputs(self):
+        a = RepositoryConfiguration(
+            dimensions={"d1": Dimension(display_name="D1", propagate=True)},
+            markers={"m1": Marker(display_name="M1", placements=[])},
+        )
+        b = RepositoryConfiguration(
+            dimensions={"d2": Dimension(display_name="D2", propagate=False)},
+            markers={"m2": Marker(display_name="M2", placements=[])},
+        )
+        c = RepositoryConfiguration(
+            dimensions={"d3": Dimension(display_name="D3", propagate=False)},
+            markers={"m3": Marker(display_name="M3", placements=[])},
+        )
+
+        left = merge_repository_configuration(merge_repository_configuration(a, b), c)
+        right = merge_repository_configuration(a, merge_repository_configuration(b, c))
+
+        assert left == right
+        assert set(left.dimensions.keys()) == {"d1", "d2", "d3"}
+        assert set(left.markers.keys()) == {"m1", "m2", "m3"}
+
+
+@pytest.mark.parametrize(
+    ("base", "second", "expected_propagate"),
+    [
+        (
+            RepositoryConfiguration(
+                dimensions={"d": Dimension(display_name="D", propagate=True)},
+                markers={},
+            ),
+            RepositoryConfiguration(
+                dimensions={"d": Dimension(display_name="D2")},
+                markers={},
+            ),
+            True,
+        )
+    ],
+)
+def test_merge_repository_configuration_propagate_preserves_base_when_omitted(
+    base, second, expected_propagate
+):
+    merged = merge_repository_configuration(base, second)
+    assert merged.dimensions["d"].propagate is expected_propagate
diff --git a/test/test_localize.py b/test/test_localize.py
index 5f1ed65..d539a62 100644
--- a/test/test_localize.py
+++ b/test/test_localize.py
@@ -2,7 +2,7 @@ from datetime import datetime
 
 from streamer.localize.localize import localize_stream_file
 from streamer.localize.localized_shard import LocalizedShard
-from streamer.localize.repostory_configuration import (
+from streamer.localize.repository_configuration import (
     Dimension,
     Marker,
     MarkerPlacement,
@@ -34,7 +34,7 @@ repository_configuration = RepositoryConfiguration(
             placements=[
                 MarkerPlacement(dimension="project"),
                 MarkerPlacement(
-                    if_with=["Timesheet"], dimension="timesheet", value="coding"
+                    if_with={"Timesheet"}, dimension="timesheet", value="coding"
                 ),
             ],
         ),
-- 
2.53.0


From 84843aea1275f1fa21ee47c5545d10bd74f9cd14 Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sat, 31 Jan 2026 19:50:47 +0100
Subject: [PATCH 07/12] fix: attach_markdown type issue

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/parse/attach_markdown.py | 16 ++++++++++++----
 1 file changed, 12 insertions(+), 4 deletions(-)

diff --git a/src/streamer/parse/attach_markdown.py b/src/streamer/parse/attach_markdown.py
index 85b5d6f..de2ae24 100644
--- a/src/streamer/parse/attach_markdown.py
+++ b/src/streamer/parse/attach_markdown.py
@@ -1,22 +1,30 @@
 from __future__ import annotations
 
+from pydantic import BaseModel
+
 from streamer.parse.shard import Shard, StreamFile
 
 
-class ShardWithMarkdown(Shard):
-    children: list[ShardWithMarkdown]
+class ShardWithMarkdown(BaseModel):
+    markers: list[str] = []
+    tags: list[str] = []
+    start_line: int
+    end_line: int
+    children: list["ShardWithMarkdown"] = []
     markdown_content: str
 
 
-class StreamFileWithMarkdown(StreamFile):
+class StreamFileWithMarkdown(BaseModel):
+    file_name: str
     shard: ShardWithMarkdown | None = None
 
 
 def attach_markdown_shard(shard: Shard, markdown_text: str) -> ShardWithMarkdown:
     lines = markdown_text.splitlines()
     markdown_content = "\n".join(lines[shard.start_line - 1 : shard.end_line])
+
     return ShardWithMarkdown(
-        **shard.model_dump(exclude=["children"]),
+        **shard.model_dump(exclude={"children"}),
         children=[
             attach_markdown_shard(child, markdown_text) for child in shard.children
         ],
-- 
2.53.0


From 84ad91d4c4ce965f8476f631ba01c71f63edac87 Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sat, 31 Jan 2026 19:51:03 +0100
Subject: [PATCH 08/12] feat: add preconfigured repository configurations

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 .../localize/preconfigured_configurations.py  | 95 +++++++++++++++++++
 1 file changed, 95 insertions(+)
 create mode 100644 src/streamer/localize/preconfigured_configurations.py

diff --git a/src/streamer/localize/preconfigured_configurations.py b/src/streamer/localize/preconfigured_configurations.py
new file mode 100644
index 0000000..07cafbd
--- /dev/null
+++ b/src/streamer/localize/preconfigured_configurations.py
@@ -0,0 +1,95 @@
+from streamer.localize.repository_configuration import (
+    Dimension,
+    Marker,
+    MarkerPlacement,
+    RepositoryConfiguration,
+)
+
+TaskConfiguration = RepositoryConfiguration(
+    dimensions={
+        "task": Dimension(
+            display_name="Task",
+            comment="If placed, the given shard is a task. The placement determines the state.",
+            propagate=False,
+        ),
+        "project": Dimension(
+            display_name="Project",
+            comment="Project the task is attached to",
+            propagate=True,
+        ),
+    },
+    markers={
+        "Task": Marker(
+            display_name="Task",
+            placements=[
+                MarkerPlacement(dimension="task", value="ready"),
+                MarkerPlacement(if_with={"Done"}, dimension="task", value="done"),
+                MarkerPlacement(if_with={"Waiting"}, dimension="task", value="waiting"),
+                MarkerPlacement(
+                    if_with={"Cancelled"}, dimension="task", value="cancelled"
+                ),
+                MarkerPlacement(
+                    if_with={"NotDone"}, dimension="task", value="cancelled"
+                ),
+            ],
+        ),
+        "WaitingFor": Marker(
+            display_name="Task",
+            placements=[
+                MarkerPlacement(dimension="task", value="waiting"),
+            ],
+        ),
+    },
+)
+
+BasicTimesheetConfiguration = RepositoryConfiguration(
+    dimensions={
+        "timesheet": Dimension(
+            display_name="Timesheet",
+            comment="Used by Timesheet-Subcommand to create Timecards",
+            propagate=False,
+        )
+    },
+    markers={
+        "VacationDay": Marker(
+            display_name="Vacation Day",
+            placements=[
+                MarkerPlacement(
+                    if_with={"Timesheet"},
+                    dimension="timesheet",
+                    value="day_off_sick_leave",
+                )
+            ],
+        ),
+        "Holiday": Marker(
+            display_name="Offical Holiday",
+            placements=[
+                MarkerPlacement(
+                    if_with={"Timesheet"},
+                    dimension="timesheet",
+                    value="day_off_holiday",
+                )
+            ],
+        ),
+        "SickLeave": Marker(
+            display_name="Sick Leave",
+            placements=[
+                MarkerPlacement(
+                    if_with={"Timesheet"},
+                    dimension="timesheet",
+                    value="day_off_sick_leave",
+                )
+            ],
+        ),
+        "UndertimeDay": Marker(
+            display_name="Undertime Leave",
+            placements=[
+                MarkerPlacement(
+                    if_with={"Timesheet"},
+                    dimension="timesheet",
+                    value="day_off_undertime",
+                )
+            ],
+        ),
+    },
+)
-- 
2.53.0


From 027bf531ce370ad9e368f452bf8f2e3b1b0412ce Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sat, 31 Jan 2026 20:19:00 +0100
Subject: [PATCH 09/12] feat: base task command on position instead of tags

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/__init__.py                      | 44 +++++++----
 .../localize/preconfigured_configurations.py  |  2 +-
 src/streamer/parse/attach_markdown.py         | 43 -----------
 src/streamer/query/__init__.py                |  3 +
 src/streamer/query/find.py                    | 29 +++++++
 src/streamer/query/task.py                    | 19 -----
 test/parse/test_attach_markdown.py            | 76 -------------------
 7 files changed, 61 insertions(+), 155 deletions(-)
 delete mode 100644 src/streamer/parse/attach_markdown.py
 create mode 100644 src/streamer/query/__init__.py
 create mode 100644 src/streamer/query/find.py
 delete mode 100644 src/streamer/query/task.py
 delete mode 100644 test/parse/test_attach_markdown.py

diff --git a/src/streamer/__init__.py b/src/streamer/__init__.py
index 2e38293..edf2a86 100644
--- a/src/streamer/__init__.py
+++ b/src/streamer/__init__.py
@@ -10,36 +10,48 @@ from rich import print
 from rich.markdown import Markdown
 from rich.panel import Panel
 
-from streamer.parse.attach_markdown import StreamFileWithMarkdown, attach_markdown
-from streamer.parse.parse import parse_markdown_file
-from streamer.query.task import find_by_markers
+from streamer.localize import (
+    LocalizedShard,
+    RepositoryConfiguration,
+    localize_stream_file,
+)
+from streamer.localize.preconfigured_configurations import TaskConfiguration
+from streamer.parse import parse_markdown_file
+from streamer.query import find_shard_by_position
 from streamer.settings import Settings
 
 app = typer.Typer()
 
 
-def all_files() -> Generator[StreamFileWithMarkdown]:
+def all_files(config: RepositoryConfiguration) -> Generator[LocalizedShard]:
     for file_name in glob.glob(f"{glob.escape(Settings().base_folder)}/*.md"):
         with open(file_name, "r") as file:
             file_content = file.read()
-            yield attach_markdown(
-                parse_markdown_file(file_name, file_content), file_content
-            )
+            if shard := localize_stream_file(
+                parse_markdown_file(file_name, file_content), config
+            ):
+                yield shard
 
 
 @app.command()
 def todo() -> None:
-    for sharded_document in all_files():
-        if sharded_document.shard:
-            open_tasks = find_by_markers(sharded_document.shard, ["Task"], ["Done"])
+    all_shards = list(all_files(TaskConfiguration))
 
-            for task_shard in open_tasks:
-                print(
-                    Panel(
-                        Markdown(task_shard.markdown_content),
-                        title=f"{sharded_document.file_name}:{task_shard.start_line}",
-                    )
+    for task_shard in find_shard_by_position(all_shards, "task", "open"):
+        with open(task_shard.location["file"], "r") as file:
+            file_content = file.read().splitlines()
+            print(
+                Panel(
+                    Markdown(
+                        "\n".join(
+                            file_content[
+                                task_shard.start_line - 1 : task_shard.end_line
+                            ]
+                        )
+                    ),
+                    title=f"{task_shard.location['file']}:{task_shard.start_line}",
                 )
+            )
 
 
 @app.command()
diff --git a/src/streamer/localize/preconfigured_configurations.py b/src/streamer/localize/preconfigured_configurations.py
index 07cafbd..af8b885 100644
--- a/src/streamer/localize/preconfigured_configurations.py
+++ b/src/streamer/localize/preconfigured_configurations.py
@@ -22,7 +22,7 @@ TaskConfiguration = RepositoryConfiguration(
         "Task": Marker(
             display_name="Task",
             placements=[
-                MarkerPlacement(dimension="task", value="ready"),
+                MarkerPlacement(dimension="task", value="open"),
                 MarkerPlacement(if_with={"Done"}, dimension="task", value="done"),
                 MarkerPlacement(if_with={"Waiting"}, dimension="task", value="waiting"),
                 MarkerPlacement(
diff --git a/src/streamer/parse/attach_markdown.py b/src/streamer/parse/attach_markdown.py
deleted file mode 100644
index de2ae24..0000000
--- a/src/streamer/parse/attach_markdown.py
+++ /dev/null
@@ -1,43 +0,0 @@
-from __future__ import annotations
-
-from pydantic import BaseModel
-
-from streamer.parse.shard import Shard, StreamFile
-
-
-class ShardWithMarkdown(BaseModel):
-    markers: list[str] = []
-    tags: list[str] = []
-    start_line: int
-    end_line: int
-    children: list["ShardWithMarkdown"] = []
-    markdown_content: str
-
-
-class StreamFileWithMarkdown(BaseModel):
-    file_name: str
-    shard: ShardWithMarkdown | None = None
-
-
-def attach_markdown_shard(shard: Shard, markdown_text: str) -> ShardWithMarkdown:
-    lines = markdown_text.splitlines()
-    markdown_content = "\n".join(lines[shard.start_line - 1 : shard.end_line])
-
-    return ShardWithMarkdown(
-        **shard.model_dump(exclude={"children"}),
-        children=[
-            attach_markdown_shard(child, markdown_text) for child in shard.children
-        ],
-        markdown_content=markdown_content,
-    )
-
-
-def attach_markdown(file: StreamFile, markdown_text: str) -> StreamFileWithMarkdown:
-    if file.shard is None:
-        return StreamFileWithMarkdown(file_name=file.file_name, shard=None)
-
-    attached_shard = attach_markdown_shard(file.shard, markdown_text)
-    return StreamFileWithMarkdown(file_name=file.file_name, shard=attached_shard)
-
-
-__all__ = ["attach_markdown"]
diff --git a/src/streamer/query/__init__.py b/src/streamer/query/__init__.py
new file mode 100644
index 0000000..b0b08c3
--- /dev/null
+++ b/src/streamer/query/__init__.py
@@ -0,0 +1,3 @@
+from .find import find_shard, find_shard_by_position
+
+__all__ = ["find_shard_by_position", "find_shard"]
diff --git a/src/streamer/query/find.py b/src/streamer/query/find.py
new file mode 100644
index 0000000..2b95cff
--- /dev/null
+++ b/src/streamer/query/find.py
@@ -0,0 +1,29 @@
+from typing import Callable
+
+from streamer.localize import LocalizedShard
+
+
+def find_shard(
+    shards: list[LocalizedShard], query_function: Callable[[LocalizedShard], bool]
+) -> list[LocalizedShard]:
+    found_shards = []
+
+    for shard in shards:
+        if query_function(shard):
+            found_shards.append(shard)
+        found_shards.extend(find_shard(shard.children, query_function))
+
+    return found_shards
+
+
+def find_shard_by_position(
+    shards: list[LocalizedShard], dimension: str, value: str
+) -> list[LocalizedShard]:
+    return find_shard(
+        shards,
+        lambda shard: dimension in shard.location
+        and shard.location[dimension] == value,
+    )
+
+
+__all__ = ["find_shard_by_position", "find_shard"]
diff --git a/src/streamer/query/task.py b/src/streamer/query/task.py
deleted file mode 100644
index 67d3664..0000000
--- a/src/streamer/query/task.py
+++ /dev/null
@@ -1,19 +0,0 @@
-from typing import TypeVar
-
-from streamer.parse.shard import Shard
-
-T = TypeVar("T", bound="Shard")
-
-
-def find_by_markers(shard: T, has: list[str], has_not: list[str]) -> list[T]:
-    found_shards = []
-
-    if any(tag in has for tag in shard.markers) and not any(
-        tag in has_not for tag in shard.markers
-    ):
-        found_shards.append(shard)
-
-    for child in shard.children:
-        found_shards.extend(find_by_markers(child, has, has_not))
-
-    return found_shards
diff --git a/test/parse/test_attach_markdown.py b/test/parse/test_attach_markdown.py
deleted file mode 100644
index 0ec1253..0000000
--- a/test/parse/test_attach_markdown.py
+++ /dev/null
@@ -1,76 +0,0 @@
-from faker import Faker
-
-from streamer.parse import Shard, StreamFile
-from streamer.parse.attach_markdown import (
-    ShardWithMarkdown,
-    StreamFileWithMarkdown,
-    attach_markdown,
-)
-
-fake = Faker()
-
-
-class TestAttachMarkdown:
-    file_name: str = fake.file_name(extension="md")
-
-    def test_attach_markdown_with_shard(self):
-        markdown_text = "Hello World\n\nThis is a test."
-        shard = Shard(start_line=1, end_line=3)
-        stream_file = StreamFile(file_name=self.file_name, shard=shard)
-
-        result = attach_markdown(stream_file, markdown_text)
-
-        assert result == StreamFileWithMarkdown(
-            file_name=self.file_name,
-            shard=ShardWithMarkdown(
-                start_line=1,
-                end_line=3,
-                markdown_content=markdown_text,
-                markers=[],
-                tags=[],
-                children=[],
-            ),
-        )
-
-    def test_attach_markdown_without_shard(self):
-        stream_file = StreamFile(file_name=self.file_name, shard=None)
-
-        result = attach_markdown(stream_file, "Some markdown text")
-
-        assert result == StreamFileWithMarkdown(file_name=self.file_name, shard=None)
-
-    def test_attach_markdown_with_nested_shards(self):
-        markdown_text = "Header\n\n@Marker1 Content 1\n\n@Marker2 Content 2"
-        shard = Shard(
-            start_line=1,
-            end_line=5,
-            children=[
-                Shard(markers=["Marker1"], start_line=3, end_line=3),
-                Shard(markers=["Marker2"], start_line=5, end_line=5),
-            ],
-        )
-        stream_file = StreamFile(file_name=self.file_name, shard=shard)
-
-        result = attach_markdown(stream_file, markdown_text)
-
-        assert result.file_name == self.file_name
-        assert result.shard is not None
-        assert result.shard.start_line == 1
-        assert result.shard.end_line == 5
-        assert (
-            result.shard.markdown_content
-            == "Header\n\n@Marker1 Content 1\n\n@Marker2 Content 2"
-        )
-        assert len(result.shard.children) == 2
-
-        # Check first child
-        assert result.shard.children[0].markers == ["Marker1"]
-        assert result.shard.children[0].start_line == 3
-        assert result.shard.children[0].end_line == 3
-        assert result.shard.children[0].markdown_content == "@Marker1 Content 1"
-
-        # Check second child
-        assert result.shard.children[1].markers == ["Marker2"]
-        assert result.shard.children[1].start_line == 5
-        assert result.shard.children[1].end_line == 5
-        assert result.shard.children[1].markdown_content == "@Marker2 Content 2"
-- 
2.53.0


From a662077831923f84f66684a9081faa911a7ec05c Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sun, 1 Feb 2026 10:01:27 +0100
Subject: [PATCH 10/12] test: implement tests for find

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 test/query/test_find.py | 104 ++++++++++++++++++++++++++++++++++++++++
 1 file changed, 104 insertions(+)
 create mode 100644 test/query/test_find.py

diff --git a/test/query/test_find.py b/test/query/test_find.py
new file mode 100644
index 0000000..725d3b2
--- /dev/null
+++ b/test/query/test_find.py
@@ -0,0 +1,104 @@
+from __future__ import annotations
+
+from datetime import datetime
+
+from streamer.localize import LocalizedShard
+from streamer.query.find import find_shard, find_shard_by_position
+
+
+def generate_localized_shard(
+    *,
+    location: dict[str, str] | None = None,
+    children: list[LocalizedShard] | None = None,
+) -> LocalizedShard:
+    return LocalizedShard(
+        start_line=1,
+        end_line=1,
+        moment=datetime(2020, 1, 1),
+        location=location or {},
+        children=children or [],
+        markers=[],
+        tags=[],
+    )
+
+
+class TestFindShard:
+    def test_returns_empty_when_no_match(self) -> None:
+        root = generate_localized_shard(location={"file": "a.md"})
+        shards = [root]
+
+        result = find_shard(shards, lambda s: "missing" in s.location)
+
+        assert result == []
+
+    def test_finds_matches_depth_first_and_preserves_order(self) -> None:
+        grandchild = generate_localized_shard(location={"k": "match"})
+        child1 = generate_localized_shard(
+            location={"k": "match"}, children=[grandchild]
+        )
+        child2 = generate_localized_shard(location={"k": "nope"})
+        root = generate_localized_shard(
+            location={"k": "nope"}, children=[child1, child2]
+        )
+
+        result = find_shard([root], lambda s: s.location.get("k") == "match")
+
+        assert result == [child1, grandchild]
+
+    def test_includes_root_if_it_matches(self) -> None:
+        root = generate_localized_shard(
+            location={"k": "match"},
+            children=[generate_localized_shard(location={"k": "match"})],
+        )
+
+        result = find_shard([root], lambda s: s.location.get("k") == "match")
+
+        assert result[0] is root
+        assert len(result) == 2
+
+    def test_multiple_roots_keeps_left_to_right_order(self) -> None:
+        a = generate_localized_shard(location={"k": "match"})
+        b = generate_localized_shard(location={"k": "match"})
+        c = generate_localized_shard(location={"k": "nope"})
+
+        result = find_shard([a, b, c], lambda s: s.location.get("k") == "match")
+
+        assert result == [a, b]
+
+    def test_query_function_can_use_arbitrary_logic(self) -> None:
+        # Ensures typing/behavior supports any callable that returns bool.
+        a = generate_localized_shard(location={"x": "1"})
+        b = generate_localized_shard(location={"x": "2"})
+        c = generate_localized_shard(location={"x": "3"})
+        root = generate_localized_shard(location={}, children=[a, b, c])
+
+        def is_even_x(shard: LocalizedShard) -> bool:
+            x = shard.location.get("x")
+            return x is not None and int(x) % 2 == 0
+
+        result = find_shard([root], is_even_x)
+
+        assert result == [b]
+
+
+class TestFindShardByPosition:
+    def test_matches_only_when_dimension_present_and_equal(self) -> None:
+        match = generate_localized_shard(location={"file": "a.md", "line": "10"})
+        wrong_value = generate_localized_shard(location={"file": "a.md", "line": "11"})
+        missing_dim = generate_localized_shard(location={"file": "a.md"})
+        root = generate_localized_shard(
+            location={"root": "x"}, children=[match, wrong_value, missing_dim]
+        )
+
+        result = find_shard_by_position([root], "line", "10")
+
+        assert result == [match]
+
+    def test_recurses_through_children(self) -> None:
+        deep = generate_localized_shard(location={"section": "s1"})
+        mid = generate_localized_shard(location={"section": "s0"}, children=[deep])
+        root = generate_localized_shard(location={}, children=[mid])
+
+        result = find_shard_by_position([root], "section", "s1")
+
+        assert result == [deep]
-- 
2.53.0


From eaca24b8ae53435f1b551daf0eb87c49562eeb66 Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sun, 1 Feb 2026 10:01:40 +0100
Subject: [PATCH 11/12] feat: implement edit-command

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 src/streamer/__init__.py | 19 ++++++++++++++++++-
 1 file changed, 18 insertions(+), 1 deletion(-)

diff --git a/src/streamer/__init__.py b/src/streamer/__init__.py
index edf2a86..dbb9151 100644
--- a/src/streamer/__init__.py
+++ b/src/streamer/__init__.py
@@ -2,7 +2,7 @@ import glob
 import os
 from datetime import datetime
 from shutil import move
-from typing import Generator
+from typing import Annotated, Generator
 
 import click
 import typer
@@ -54,6 +54,23 @@ def todo() -> None:
             )
 
 
+@app.command()
+def edit(number: Annotated[int, typer.Argument()] = 1) -> None:
+    all_shards = list(all_files(TaskConfiguration))
+    sorted_shards = sorted(all_shards, key=lambda s: s.moment)
+
+    if abs(number) >= len(sorted_shards):
+        raise ValueError("Argument out of range")
+
+    selected_number = number
+    if selected_number >= 0:
+        selected_number = len(sorted_shards) - selected_number
+    else:
+        selected_number = -selected_number
+
+    click.edit(None, filename=sorted_shards[selected_number].location["file"])
+
+
 @app.command()
 def new() -> None:
     streamer_directory = Settings().base_folder
-- 
2.53.0


From a088057b175ea5f56dcaaabfb513115d84b9a4ea Mon Sep 17 00:00:00 2001
From: Konstantin Fickel <mail@konstantinfickel.de>
Date: Sun, 1 Feb 2026 10:32:34 +0100
Subject: [PATCH 12/12] ci: remove type testing from pipeline

Signed-off-by: Konstantin Fickel <mail@konstantinfickel.de>
---
 .forgejo/workflows/ci.yml |  3 ---
 flake.nix                 | 37 +++++++++++++++++++------------------
 2 files changed, 19 insertions(+), 21 deletions(-)

diff --git a/.forgejo/workflows/ci.yml b/.forgejo/workflows/ci.yml
index 92092a6..7d7a63b 100644
--- a/.forgejo/workflows/ci.yml
+++ b/.forgejo/workflows/ci.yml
@@ -21,6 +21,3 @@ jobs:
 
       - name: Test with PyTest
         run: nix develop .#impure --command bash -c "uv run pytest --junit-xml test-report.xml"
-
-      - name: Check with PyRight
-        run: nix develop .#impure --command bash -c "uv run pyright"
diff --git a/flake.nix b/flake.nix
index 0e39ef3..669701a 100644
--- a/flake.nix
+++ b/flake.nix
@@ -88,12 +88,14 @@
       # Package a virtual environment as our main application.
       #
       # Enable no optional dependencies for production build.
-      packages.x86_64-linux = let
-        streamer = pythonSet.mkVirtualEnv "streamer-env" workspace.deps.default;
-      in {
-        inherit streamer;
-        default = streamer;
-      };
+      packages.x86_64-linux =
+        let
+          streamer = pythonSet.mkVirtualEnv "streamer-env" workspace.deps.default;
+        in
+        {
+          inherit streamer;
+          default = streamer;
+        };
 
       # Make streamer runnable with `nix run`
       apps.x86_64-linux = {
@@ -116,18 +118,17 @@
             pre-commit
             bashInteractive
           ];
-          env =
-            {
-              # Prevent uv from managing Python downloads
-              UV_PYTHON_DOWNLOADS = "never";
-              # Force uv to use nixpkgs Python interpreter
-              UV_PYTHON = python.interpreter;
-            }
-            // lib.optionalAttrs pkgs.stdenv.isLinux {
-              # Python libraries often load native shared objects using dlopen(3).
-              # Setting LD_LIBRARY_PATH makes the dynamic library loader aware of libraries without using RPATH for lookup.
-              LD_LIBRARY_PATH = lib.makeLibraryPath pkgs.pythonManylinuxPackages.manylinux1;
-            };
+          env = {
+            # Prevent uv from managing Python downloads
+            UV_PYTHON_DOWNLOADS = "never";
+            # Force uv to use nixpkgs Python interpreter
+            UV_PYTHON = python.interpreter;
+          }
+          // lib.optionalAttrs pkgs.stdenv.isLinux {
+            # Python libraries often load native shared objects using dlopen(3).
+            # Setting LD_LIBRARY_PATH makes the dynamic library loader aware of libraries without using RPATH for lookup.
+            LD_LIBRARY_PATH = lib.makeLibraryPath pkgs.pythonManylinuxPackages.manylinux1;
+          };
           shellHook = ''
             unset PYTHONPATH
           '';
-- 
2.53.0