From 51d18f37bf1c1ba513521b4f0310db8a317fbef0 Mon Sep 17 00:00:00 2001
From: Claudio Ortolina <cloud8421@gmail.com>
Date: Sat, 14 Sep 2024 14:20:43 +0100
Subject: [PATCH] First pass at seeding database

The task takes the Obsidian record folder as an argument.

It's not idempotent, so it will create duplicates if run multiple times.
---
 priv/repo/seeds.exs | 46 +++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 46 insertions(+)

diff --git a/priv/repo/seeds.exs b/priv/repo/seeds.exs
index 7fd82d8e..60276624 100644
--- a/priv/repo/seeds.exs
+++ b/priv/repo/seeds.exs
@@ -9,3 +9,49 @@
 #
 # We recommend using the bang functions (`insert!`, `update!`
 # and so on) as they will fail if something goes wrong.
+
+case System.argv() do
+  [] ->
+    IO.puts("Error: requires the path to the obsidian vault record folder")
+    System.halt(1)
+
+  [path] ->
+    # TODO: validate path
+    IO.puts("Seeding the database from #{path}")
+
+    %{valid: valid, errors: errors} =
+      Path.wildcard("#{path}/*.md")
+      |> Enum.reduce(%{valid: [], errors: []}, fn entry, acc ->
+        file_stat = File.stat!(entry)
+
+        case entry
+             |> File.read!()
+             |> MusicLibrary.Records.Parser.from_entry_contents() do
+          {:ok, parsed_entry} ->
+            inserted_at = file_stat.ctime
+              |> NaiveDateTime.from_erl!()
+              |> DateTime.from_naive!("Etc/UTC")
+            updated_at = file_stat.mtime
+              |> NaiveDateTime.from_erl!()
+              |> DateTime.from_naive!("Etc/UTC")
+            data =
+              parsed_entry
+              |> Map.put(:inserted_at, inserted_at)
+              |> Map.put(:updated_at, updated_at)
+
+            %{acc | valid: [data | acc.valid]}
+
+          {:error, error} ->
+            %{acc | errors: [{entry, error} | acc.errors]}
+        end
+      end)
+
+    IO.puts("Parsed #{length(valid)} entries")
+    IO.puts("Failed to parse #{length(errors)} entries")
+
+    MusicLibrary.Repo.insert_all(MusicLibrary.Records.Record, valid)
+
+  _other ->
+    IO.puts("Error: too many arguments")
+    System.halt(1)
+end