Feat: update list_unarchived_links_by_index

cesium · Sep 18, 2024 · 96d8f72 · 96d8f72
1 parent c1a317b
commit 96d8f72
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 2 deletions.
diff --git a/lib/cesium_link/links.ex b/lib/cesium_link/links.ex
@@ -64,7 +64,11 @@ defmodule CesiumLink.Links do
 
   """
   def list_unarchived_links_by_index do
-    Repo.all(from l in Link, where: l.archived == false, order_by: [asc: l.index])
+    Link
+    |> where([l], fragment("? > now()", l.publish_at))
+    |> where([l], l.archived == false )
+    |> order_by([l], asc: l.index)
+    |> Repo.all()
   end
 
   @doc """

diff --git a/lib/cesium_link/links/link.ex b/lib/cesium_link/links/link.ex
@@ -5,7 +5,7 @@ defmodule CesiumLink.Links.Link do
   use CesiumLink.Schema
 
   @required_fields ~w(name emoji url attention edited_at)a
-  @optional_fields ~w(index archived visits)a
+  @optional_fields ~w(index archived visits publish_at)a
 
   schema "links" do
     field :archived, :boolean, default: false
@@ -16,6 +16,7 @@ defmodule CesiumLink.Links.Link do
     field :url, :string
     field :visits, :integer, default: 0
     field :edited_at, :utc_datetime
+    field :publish_at, :utc_datetime
 
     timestamps(type: :utc_datetime)
   end

diff --git a/priv/repo/migrations/20240918181533_add_link_scheduling.exs b/priv/repo/migrations/20240918181533_add_link_scheduling.exs
@@ -0,0 +1,9 @@
+defmodule CesiumLink.Repo.Migrations.AddLinkScheduling do
+  use Ecto.Migration
+
+  def change do
+    alter table(:links) do
+      add :publish_at, :utc_datetime
+    end
+  end
+end