716 lines
22 KiB
Elixir
716 lines
22 KiB
Elixir
defmodule BDS.MaintenanceTest do
|
|
use ExUnit.Case, async: false
|
|
|
|
import Ecto.Query
|
|
|
|
alias BDS.Repo
|
|
|
|
setup do
|
|
:ok = Ecto.Adapters.SQL.Sandbox.checkout(BDS.Repo)
|
|
|
|
temp_dir =
|
|
Path.join(System.tmp_dir!(), "bds-maintenance-#{System.unique_integer([:positive])}")
|
|
|
|
File.mkdir_p!(temp_dir)
|
|
on_exit(fn -> File.rm_rf(temp_dir) end)
|
|
|
|
{:ok, project} = BDS.Projects.create_project(%{name: "Maintenance", data_path: temp_dir})
|
|
%{project: project, temp_dir: temp_dir}
|
|
end
|
|
|
|
test "rebuild_from_filesystem dispatches to posts, media, scripts, and templates rebuilders", %{
|
|
project: project,
|
|
temp_dir: temp_dir
|
|
} do
|
|
assert {:ok, _metadata} =
|
|
BDS.Metadata.update_project_metadata(project.id, %{semantic_similarity_enabled: true})
|
|
|
|
posts_dir = Path.join([temp_dir, "posts", "2026", "04"])
|
|
File.mkdir_p!(posts_dir)
|
|
|
|
File.write!(
|
|
Path.join(posts_dir, "dispatch-post.md"),
|
|
[
|
|
"---",
|
|
"id: dispatch-post",
|
|
"title: Dispatch Post",
|
|
"slug: dispatch-post",
|
|
"status: published",
|
|
"createdAt: 1711843200",
|
|
"updatedAt: 1711929600",
|
|
"publishedAt: 1712016000",
|
|
"tags:",
|
|
"categories:",
|
|
"---",
|
|
"Body",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
media_dir = Path.join([temp_dir, "media", "2026", "04"])
|
|
File.mkdir_p!(media_dir)
|
|
|
|
File.write!(Path.join(media_dir, "asset.txt"), "hello media")
|
|
|
|
File.write!(
|
|
Path.join(media_dir, "asset.txt.meta"),
|
|
[
|
|
"id: dispatch-media",
|
|
"originalName: original.txt",
|
|
"mimeType: text/plain",
|
|
"size: 11",
|
|
"createdAt: 1711843200",
|
|
"updatedAt: 1711929600",
|
|
"tags:",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
template_dir = Path.join(temp_dir, "templates")
|
|
File.mkdir_p!(template_dir)
|
|
|
|
File.write!(
|
|
Path.join(template_dir, "dispatch-view.liquid"),
|
|
[
|
|
"---",
|
|
"id: dispatch-template",
|
|
"slug: dispatch-view",
|
|
"title: Dispatch View",
|
|
"kind: list",
|
|
"enabled: true",
|
|
"version: 1",
|
|
"createdAt: 101",
|
|
"updatedAt: 202",
|
|
"---",
|
|
"<section>Template</section>",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
script_dir = Path.join(temp_dir, "scripts")
|
|
File.mkdir_p!(script_dir)
|
|
|
|
File.write!(
|
|
Path.join(script_dir, "dispatch.lua"),
|
|
[
|
|
"---",
|
|
"id: dispatch-script",
|
|
"slug: dispatch",
|
|
"title: Dispatch Script",
|
|
"kind: utility",
|
|
"entrypoint: main",
|
|
"enabled: true",
|
|
"version: 1",
|
|
"createdAt: 301",
|
|
"updatedAt: 404",
|
|
"---",
|
|
"function main() return true end",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
assert {:ok, posts} = BDS.Maintenance.rebuild_from_filesystem(project.id, "post")
|
|
assert length(posts) == 1
|
|
assert Repo.get_by(BDS.Embeddings.Key, project_id: project.id, post_id: "dispatch-post") != nil
|
|
|
|
assert {:ok, media_items} = BDS.Maintenance.rebuild_from_filesystem(project.id, "media")
|
|
assert length(media_items) == 1
|
|
|
|
assert {:ok, scripts} = BDS.Maintenance.rebuild_from_filesystem(project.id, "script")
|
|
assert length(scripts) == 1
|
|
|
|
assert {:ok, templates} = BDS.Maintenance.rebuild_from_filesystem(project.id, "template")
|
|
assert length(templates) == 1
|
|
|
|
assert Repo.get(BDS.Posts.Post, "dispatch-post") != nil
|
|
assert Repo.get(BDS.Media.Media, "dispatch-media") != nil
|
|
assert Repo.get(BDS.Scripts.Script, "dispatch-script") != nil
|
|
assert Repo.get(BDS.Templates.Template, "dispatch-template") != nil
|
|
end
|
|
|
|
test "rebuild_from_filesystem rejects unsupported entity types", %{project: project} do
|
|
assert {:error, :unsupported_entity_type} =
|
|
BDS.Maintenance.rebuild_from_filesystem(project.id, "unknown")
|
|
end
|
|
|
|
test "rebuild_from_filesystem reports incremental progress for file-backed rebuilders", %{
|
|
project: project,
|
|
temp_dir: temp_dir
|
|
} do
|
|
parent = self()
|
|
on_progress = fn value, message -> send(parent, {:rebuild_progress, value, message}) end
|
|
|
|
posts_dir = Path.join([temp_dir, "posts", "2026", "04"])
|
|
File.mkdir_p!(posts_dir)
|
|
|
|
File.write!(
|
|
Path.join(posts_dir, "first-post.md"),
|
|
[
|
|
"---",
|
|
"id: first-post",
|
|
"title: First Post",
|
|
"slug: first-post",
|
|
"status: published",
|
|
"createdAt: 1711843200",
|
|
"updatedAt: 1711929600",
|
|
"publishedAt: 1712016000",
|
|
"tags:",
|
|
"categories:",
|
|
"---",
|
|
"Body one",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
File.write!(
|
|
Path.join(posts_dir, "second-post.md"),
|
|
[
|
|
"---",
|
|
"id: second-post",
|
|
"title: Second Post",
|
|
"slug: second-post",
|
|
"status: published",
|
|
"createdAt: 1711843200",
|
|
"updatedAt: 1711929600",
|
|
"publishedAt: 1712016000",
|
|
"tags:",
|
|
"categories:",
|
|
"---",
|
|
"Body two",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
media_dir = Path.join([temp_dir, "media", "2026", "04"])
|
|
File.mkdir_p!(media_dir)
|
|
|
|
File.write!(Path.join(media_dir, "first.txt"), "first media")
|
|
File.write!(Path.join(media_dir, "second.txt"), "second media")
|
|
|
|
File.write!(
|
|
Path.join(media_dir, "first.txt.meta"),
|
|
[
|
|
"id: first-media",
|
|
"originalName: first.txt",
|
|
"mimeType: text/plain",
|
|
"size: 11",
|
|
"createdAt: 1711843200",
|
|
"updatedAt: 1711929600",
|
|
"tags:",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
File.write!(
|
|
Path.join(media_dir, "second.txt.meta"),
|
|
[
|
|
"id: second-media",
|
|
"originalName: second.txt",
|
|
"mimeType: text/plain",
|
|
"size: 12",
|
|
"createdAt: 1711843200",
|
|
"updatedAt: 1711929600",
|
|
"tags:",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
template_dir = Path.join(temp_dir, "templates")
|
|
File.mkdir_p!(template_dir)
|
|
|
|
File.write!(
|
|
Path.join(template_dir, "first-template.liquid"),
|
|
[
|
|
"---",
|
|
"id: first-template",
|
|
"slug: first-template",
|
|
"title: First Template",
|
|
"kind: list",
|
|
"enabled: true",
|
|
"version: 1",
|
|
"createdAt: 101",
|
|
"updatedAt: 202",
|
|
"---",
|
|
"<section>First</section>",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
File.write!(
|
|
Path.join(template_dir, "second-template.liquid"),
|
|
[
|
|
"---",
|
|
"id: second-template",
|
|
"slug: second-template",
|
|
"title: Second Template",
|
|
"kind: post",
|
|
"enabled: true",
|
|
"version: 1",
|
|
"createdAt: 303",
|
|
"updatedAt: 404",
|
|
"---",
|
|
"<section>Second</section>",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
script_dir = Path.join(temp_dir, "scripts")
|
|
File.mkdir_p!(script_dir)
|
|
|
|
File.write!(
|
|
Path.join(script_dir, "first-script.lua"),
|
|
[
|
|
"---",
|
|
"id: first-script",
|
|
"slug: first-script",
|
|
"title: First Script",
|
|
"kind: utility",
|
|
"entrypoint: main",
|
|
"enabled: true",
|
|
"version: 1",
|
|
"createdAt: 505",
|
|
"updatedAt: 606",
|
|
"---",
|
|
"function main() return true end",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
File.write!(
|
|
Path.join(script_dir, "second-script.lua"),
|
|
[
|
|
"---",
|
|
"id: second-script",
|
|
"slug: second-script",
|
|
"title: Second Script",
|
|
"kind: transform",
|
|
"entrypoint: main",
|
|
"enabled: true",
|
|
"version: 1",
|
|
"createdAt: 707",
|
|
"updatedAt: 808",
|
|
"---",
|
|
"function main() return true end",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
assert {:ok, _posts} =
|
|
BDS.Maintenance.rebuild_from_filesystem(project.id, "post", on_progress: on_progress)
|
|
|
|
assert_incremental_progress(collect_progress_events())
|
|
|
|
assert {:ok, _media} =
|
|
BDS.Maintenance.rebuild_from_filesystem(project.id, "media", on_progress: on_progress)
|
|
|
|
assert_incremental_progress(collect_progress_events())
|
|
|
|
assert {:ok, _scripts} =
|
|
BDS.Maintenance.rebuild_from_filesystem(project.id, "script", on_progress: on_progress)
|
|
|
|
assert_incremental_progress(collect_progress_events())
|
|
|
|
assert {:ok, _templates} =
|
|
BDS.Maintenance.rebuild_from_filesystem(project.id, "template", on_progress: on_progress)
|
|
|
|
assert_incremental_progress(collect_progress_events())
|
|
end
|
|
|
|
test "maintenance rebuilds and diffs embedding state explicitly", %{project: project} do
|
|
assert {:ok, _metadata} =
|
|
BDS.Metadata.update_project_metadata(project.id, %{semantic_similarity_enabled: true})
|
|
|
|
assert {:ok, post} =
|
|
BDS.Posts.create_post(%{
|
|
project_id: project.id,
|
|
title: "Embedding Drift",
|
|
content: "space rocket orbit mission galaxy",
|
|
language: "en"
|
|
})
|
|
|
|
assert {:ok, post} = BDS.Posts.publish_post(post.id)
|
|
assert {:ok, _indexed} = BDS.Embeddings.index_unindexed(project.id)
|
|
|
|
index_path = BDS.Embeddings.index_path(project.id)
|
|
assert File.exists?(index_path)
|
|
|
|
Repo.delete_all(from key in BDS.Embeddings.Key, where: key.project_id == ^project.id)
|
|
File.rm!(index_path)
|
|
|
|
assert {:ok, %{diff_reports: diff_reports}} = BDS.Maintenance.metadata_diff(project.id)
|
|
|
|
assert Enum.any?(diff_reports, fn report ->
|
|
report.entity_type == "embedding" and report.entity_id == post.id
|
|
end)
|
|
|
|
assert {:ok, rebuilt_post_ids} = BDS.Maintenance.rebuild_from_filesystem(project.id, "embedding")
|
|
assert post.id in rebuilt_post_ids
|
|
assert Repo.get_by(BDS.Embeddings.Key, project_id: project.id, post_id: post.id) != nil
|
|
assert File.exists?(index_path)
|
|
end
|
|
|
|
test "metadata_diff reports field differences and orphan files across managed entities", %{
|
|
project: project,
|
|
temp_dir: temp_dir
|
|
} do
|
|
source_path = Path.join(temp_dir, "sample.txt")
|
|
File.write!(source_path, "hello media")
|
|
|
|
assert {:ok, post} =
|
|
BDS.Posts.create_post(%{
|
|
project_id: project.id,
|
|
title: "Original Post",
|
|
content: "Original body",
|
|
excerpt: "Original summary",
|
|
author: "Writer",
|
|
language: "en",
|
|
tags: ["alpha"],
|
|
categories: ["notes"]
|
|
})
|
|
|
|
assert {:ok, published_post} = BDS.Posts.publish_post(post.id)
|
|
|
|
assert {:ok, post_translation} =
|
|
BDS.Posts.upsert_post_translation(published_post.id, "de", %{
|
|
title: "Ursprunglicher Beitrag",
|
|
excerpt: "Zusammenfassung",
|
|
content: "Ubersetzter Inhalt"
|
|
})
|
|
|
|
assert {:ok, _republished_post} = BDS.Posts.publish_post(published_post.id)
|
|
published_post_translation = Repo.get!(BDS.Posts.Translation, post_translation.id)
|
|
|
|
assert {:ok, media} =
|
|
BDS.Media.import_media(%{
|
|
project_id: project.id,
|
|
source_path: source_path,
|
|
title: "Original media title",
|
|
alt: "Original alt",
|
|
caption: "Original caption",
|
|
author: "Photographer",
|
|
language: "en",
|
|
tags: ["alpha"]
|
|
})
|
|
|
|
assert {:ok, media_translation} =
|
|
BDS.Media.upsert_media_translation(media.id, "de", %{
|
|
title: "Ubersetzter Medientitel",
|
|
alt: "Ubersetzter Alt-Text",
|
|
caption: "Ubersetzte Beschriftung"
|
|
})
|
|
|
|
assert {:ok, script} =
|
|
BDS.Scripts.create_script(%{
|
|
project_id: project.id,
|
|
title: "Original Script",
|
|
kind: :utility,
|
|
entrypoint: "main",
|
|
content: "function main() return true end"
|
|
})
|
|
|
|
assert {:ok, published_script} = BDS.Scripts.publish_script(script.id)
|
|
|
|
assert {:ok, template} =
|
|
BDS.Templates.create_template(%{
|
|
project_id: project.id,
|
|
title: "Original Template",
|
|
kind: :list,
|
|
content: "<section>Original</section>"
|
|
})
|
|
|
|
assert {:ok, published_template} = BDS.Templates.publish_template(template.id)
|
|
|
|
post_path = Path.join(temp_dir, published_post.file_path)
|
|
|
|
File.write!(
|
|
post_path,
|
|
[
|
|
"---",
|
|
"id: #{published_post.id}",
|
|
"title: Edited Post",
|
|
"slug: #{published_post.slug}",
|
|
"excerpt: Edited summary",
|
|
"status: published",
|
|
"author: Editor",
|
|
"language: de",
|
|
"doNotTranslate: false",
|
|
"templateSlug: ",
|
|
"createdAt: #{published_post.created_at + 10}",
|
|
"updatedAt: #{published_post.updated_at + 20}",
|
|
"publishedAt: #{published_post.published_at + 30}",
|
|
"tags:",
|
|
" - beta",
|
|
"categories:",
|
|
" - article",
|
|
"---",
|
|
"Changed body",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
post_translation_path = Path.join(temp_dir, published_post_translation.file_path)
|
|
|
|
File.write!(
|
|
post_translation_path,
|
|
[
|
|
"---",
|
|
"id: #{published_post_translation.id}",
|
|
"translationFor: #{published_post_translation.translation_for}",
|
|
"language: #{published_post_translation.language}",
|
|
"title: Bearbeiteter Beitrag",
|
|
"excerpt: Bearbeitete Zusammenfassung",
|
|
"status: published",
|
|
"createdAt: #{published_post_translation.created_at}",
|
|
"updatedAt: #{published_post_translation.updated_at}",
|
|
"publishedAt: #{published_post_translation.published_at}",
|
|
"---",
|
|
"Bearbeiteter Inhalt",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
media_sidecar_path = Path.join(temp_dir, media.sidecar_path)
|
|
|
|
File.write!(
|
|
media_sidecar_path,
|
|
[
|
|
"id: #{media.id}",
|
|
"originalName: #{media.original_name}",
|
|
"mimeType: #{media.mime_type}",
|
|
"size: #{media.size}",
|
|
"title: Edited media title",
|
|
"alt: Edited alt",
|
|
"caption: Edited caption",
|
|
"author: Editor",
|
|
"language: de",
|
|
"createdAt: #{media.created_at}",
|
|
"updatedAt: #{media.updated_at}",
|
|
"tags:",
|
|
" - beta",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
media_translation_sidecar_path =
|
|
Path.join(temp_dir, "#{media.file_path}.#{media_translation.language}.meta")
|
|
|
|
File.write!(
|
|
media_translation_sidecar_path,
|
|
[
|
|
"translationFor: #{media.id}",
|
|
"language: #{media_translation.language}",
|
|
"title: Bearbeiteter Medientitel",
|
|
"alt: Bearbeiteter Alt-Text",
|
|
"caption: Bearbeitete Beschriftung",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
script_path = Path.join(temp_dir, published_script.file_path)
|
|
|
|
File.write!(
|
|
script_path,
|
|
[
|
|
"---",
|
|
"id: #{published_script.id}",
|
|
"projectId: #{project.id}",
|
|
"slug: #{published_script.slug}",
|
|
"title: Edited Script",
|
|
"kind: utility",
|
|
"entrypoint: run",
|
|
"enabled: false",
|
|
"version: #{published_script.version}",
|
|
"createdAt: #{published_script.created_at}",
|
|
"updatedAt: #{published_script.updated_at}",
|
|
"---",
|
|
"function run() return false end",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
template_path = Path.join(temp_dir, published_template.file_path)
|
|
|
|
File.write!(
|
|
template_path,
|
|
[
|
|
"---",
|
|
"id: #{published_template.id}",
|
|
"projectId: #{project.id}",
|
|
"slug: #{published_template.slug}",
|
|
"title: Edited Template",
|
|
"kind: list",
|
|
"enabled: false",
|
|
"version: #{published_template.version}",
|
|
"createdAt: #{published_template.created_at}",
|
|
"updatedAt: #{published_template.updated_at}",
|
|
"---",
|
|
"<section>Edited</section>",
|
|
""
|
|
]
|
|
|> Enum.join("\n")
|
|
)
|
|
|
|
File.write!(
|
|
Path.join([temp_dir, "posts", "2026", "04", "orphan-post.md"]),
|
|
"---\nid: orphan\ntitle: Orphan\nslug: orphan\nstatus: published\ncreatedAt: 1\nupdatedAt: 1\npublishedAt: 1\ntags:\ncategories:\n---\nBody\n"
|
|
)
|
|
|
|
File.write!(
|
|
Path.join([temp_dir, "posts", "2026", "04", "orphan-post.es.md"]),
|
|
"---\nid: orphan-post-translation\ntranslationFor: orphan\nlanguage: es\ntitle: Huerfano\nstatus: published\ncreatedAt: 1\nupdatedAt: 1\npublishedAt: 1\n---\nCuerpo\n"
|
|
)
|
|
|
|
File.write!(Path.join([temp_dir, "media", "2026", "04", "orphan.txt"]), "orphan")
|
|
|
|
File.write!(
|
|
Path.join([temp_dir, "media", "2026", "04", "orphan.txt.meta"]),
|
|
"id: orphan-media\noriginalName: orphan.txt\nmimeType: text/plain\nsize: 6\ncreatedAt: 1\nupdatedAt: 1\ntags:\n"
|
|
)
|
|
|
|
File.write!(
|
|
Path.join([temp_dir, "media", "2026", "04", "orphan.txt.es.meta"]),
|
|
"translationFor: orphan-media\nlanguage: es\ntitle: Huerfano\nalt: Texto\ncaption: Leyenda\n"
|
|
)
|
|
|
|
File.write!(
|
|
Path.join([temp_dir, "scripts", "orphan.lua"]),
|
|
"---\nid: orphan-script\nprojectId: #{project.id}\nslug: orphan-script\ntitle: Orphan Script\nkind: utility\nentrypoint: main\nenabled: true\nversion: 1\ncreatedAt: 1\nupdatedAt: 1\n---\nfunction main() return true end\n"
|
|
)
|
|
|
|
File.write!(
|
|
Path.join([temp_dir, "templates", "orphan-view.liquid"]),
|
|
"---\nid: orphan-template\nprojectId: #{project.id}\nslug: orphan-view\ntitle: Orphan View\nkind: list\nenabled: true\nversion: 1\ncreatedAt: 1\nupdatedAt: 1\n---\n<section>Orphan</section>\n"
|
|
)
|
|
|
|
assert {:ok, %{diff_reports: diff_reports, orphan_reports: orphan_reports}} =
|
|
BDS.Maintenance.metadata_diff(project.id)
|
|
|
|
assert Enum.any?(diff_reports, fn report ->
|
|
report.entity_type == "post" and report.entity_id == published_post.id and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "title" and &1.db_value == "Original Post" and
|
|
&1.file_value == "Edited Post")
|
|
) and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "excerpt" and &1.db_value == "Original summary" and
|
|
&1.file_value == "Edited summary")
|
|
) and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "created_at" and
|
|
&1.file_value == Integer.to_string(published_post.created_at + 10))
|
|
) and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "updated_at" and
|
|
&1.file_value == Integer.to_string(published_post.updated_at + 20))
|
|
) and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "published_at" and
|
|
&1.file_value == Integer.to_string(published_post.published_at + 30))
|
|
)
|
|
end)
|
|
|
|
assert Enum.any?(diff_reports, fn report ->
|
|
report.entity_type == "media" and report.entity_id == media.id and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "title" and &1.file_value == "Edited media title")
|
|
) and
|
|
Enum.any?(report.differences, &(&1.name == "language" and &1.file_value == "de"))
|
|
end)
|
|
|
|
assert Enum.any?(diff_reports, fn report ->
|
|
report.entity_type == "script" and report.entity_id == published_script.id and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "title" and &1.file_value == "Edited Script")
|
|
) and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "entrypoint" and &1.file_value == "run")
|
|
)
|
|
end)
|
|
|
|
assert Enum.any?(diff_reports, fn report ->
|
|
report.entity_type == "template" and report.entity_id == published_template.id and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "title" and &1.file_value == "Edited Template")
|
|
) and
|
|
Enum.any?(report.differences, &(&1.name == "enabled" and &1.file_value == "false"))
|
|
end)
|
|
|
|
assert Enum.any?(diff_reports, fn report ->
|
|
report.entity_type == "post_translation" and
|
|
report.entity_id == published_post_translation.id and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "title" and &1.db_value == "Ursprunglicher Beitrag" and
|
|
&1.file_value == "Bearbeiteter Beitrag")
|
|
) and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "excerpt" and &1.db_value == "Zusammenfassung" and
|
|
&1.file_value == "Bearbeitete Zusammenfassung")
|
|
)
|
|
end)
|
|
|
|
assert Enum.any?(diff_reports, fn report ->
|
|
report.entity_type == "media_translation" and
|
|
report.entity_id == media_translation.id and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "title" and &1.db_value == "Ubersetzter Medientitel" and
|
|
&1.file_value == "Bearbeiteter Medientitel")
|
|
) and
|
|
Enum.any?(
|
|
report.differences,
|
|
&(&1.name == "alt" and &1.db_value == "Ubersetzter Alt-Text" and
|
|
&1.file_value == "Bearbeiteter Alt-Text")
|
|
)
|
|
end)
|
|
|
|
orphan_paths = Enum.map(orphan_reports, & &1.file_path)
|
|
assert "posts/2026/04/orphan-post.md" in orphan_paths
|
|
assert "posts/2026/04/orphan-post.es.md" in orphan_paths
|
|
assert "media/2026/04/orphan.txt.meta" in orphan_paths
|
|
assert "media/2026/04/orphan.txt.es.meta" in orphan_paths
|
|
assert "scripts/orphan.lua" in orphan_paths
|
|
assert "templates/orphan-view.liquid" in orphan_paths
|
|
end
|
|
|
|
defp collect_progress_events(acc \\ []) do
|
|
receive do
|
|
{:rebuild_progress, value, message} -> collect_progress_events([{value, message} | acc])
|
|
after
|
|
0 -> Enum.reverse(acc)
|
|
end
|
|
end
|
|
|
|
defp assert_incremental_progress(events) do
|
|
assert Enum.any?(events, fn {value, _message} -> value > 0.0 and value < 1.0 end)
|
|
assert Enum.any?(events, fn {value, _message} -> value == 1.0 end)
|
|
end
|
|
end
|