Fix scrolling bug, enforce 3 level nesting in sheaf replies

lib/vyasa/sangh.ex

@@ -6,9 +6,12 @@ defmodule Vyasa.Sangh do
   import Ecto.Query, warn: false
   import EctoLtree.Functions, only: [nlevel: 1]
   alias Vyasa.Repo
+  alias EctoLtree.LabelTree, as: Ltree
   # alias Vyasa.Draft
   alias Vyasa.Sangh.{Sheaf}
 
+  @max_sheaf_depth 3
+
   @doc """
   Returns a list of sheafs associated with a specific session.
 
@@ -403,11 +406,117 @@ defmodule Vyasa.Sangh do
 
   #   """
   def update_sheaf(%Sheaf{} = sheaf, attrs) do
+    IO.puts("CHECKPOINT: update_sheaf")
+
     sheaf
     |> Sheaf.mutate_changeset(attrs)
     |> Repo.update()
   end
 
+  @doc """
+  Given a sheaf that is ready to be published as a reply, ensures that the
+  replies adhere to the 3-level nesting limit.
+
+  There are 3 ways that the reply to context is determined:
+  1. if the attrs contain :parent, then use that sheaf. This is more of an override-case,
+     for example, in the context of quick replies
+  2. if the attrs don't contain parent, but the draft sheaf already has an associated parent,
+     then that's the reply to context
+  3. there are no parents associated -- so the reply's parent is nil and there's no :parent in the attrs
+
+  Suppose the reply to context is already at depth = 3 (zero-indexed, then level = 2) then we need to reconcile this.
+  To reconcile, we shall update the attrs payload such that:
+  1. the parent of the reply sheaf ends up being the grandparent instead
+  2. the reply sheaf's path gets updated, is now encoded as though its the child of its grandparent
+  """
+  # way number 1 -- using parent in attr
+  def make_reply(
+        %Sheaf{
+          id: id
+        } = reply,
+        %{
+          parent:
+            %Sheaf{
+              parent_id: grandparent_id,
+              path: %Ltree{
+                labels: parent_path_labels
+              }
+            } = _injected_parent
+        } = attrs
+      ) do
+    IO.puts("CHECKPOINT Make Reply way 1 -- use injected parent in attr")
+
+    reconciled_attrs =
+      case parent_path_labels |> Enum.count() do
+        # need to reassign both path and parent:
+        @max_sheaf_depth ->
+          attrs |> reconcile_payload_using_grandparent(grandparent_id, id)
+
+        # keep as is
+        _ ->
+          attrs
+      end
+
+    reply |> update_sheaf(reconciled_attrs)
+  end
+
+  # way number 2 -- if not in attr, then use pre-existing associated parent to the reply sheaf
+  def make_reply(
+        %Sheaf{
+          id: id,
+          parent: %Sheaf{
+            parent_id: grandparent_id,
+            path: %Ltree{
+              labels: parent_path_labels
+            }
+          }
+        } = reply,
+        attrs
+      ) do
+    IO.puts("CHECKPOINT Make Reply way 2 -- use pre-associated parent")
+
+    reconciled_attrs =
+      case parent_path_labels |> Enum.count() do
+        # need to reassign both path and parent:
+        @max_sheaf_depth ->
+          attrs |> reconcile_payload_using_grandparent(grandparent_id, id)
+
+        _ ->
+          attrs
+      end
+
+    reply |> update_sheaf(reconciled_attrs)
+  end
+
+  # way number 3 -- no assoced parent, nothing to reconcile
+  def make_reply(
+        %Sheaf{
+          parent: nil
+        } = reply,
+        attrs
+      ) do
+    IO.puts("CHECKPOINT Make Reply way 3 -- no parent to associate to")
+    reply |> update_sheaf(attrs)
+  end
+
+  # To reconcile, we shall update the attrs payload such that:
+  # 1. the parent of the reply sheaf ends up being the grandparent instead
+  # 2. the reply sheaf's path gets updated, is now encoded as though its the child of its grandparent
+  defp reconcile_payload_using_grandparent(%{} = attrs, grandparent_id, child_id)
+       when is_binary(grandparent_id) do
+    %Sheaf{path: %Ltree{} = grandparent_path} = grandparent = get_sheaf!(grandparent_id)
+
+    IO.puts(
+      "CHECKPOINT -- turns out we need to reconcile this sheaf and assoc to its grandparent instead"
+    )
+
+    attrs
+    |> Map.merge(%{
+      parent: grandparent,
+      path: child_id |> Sheaf.encode_path(grandparent_path)
+    })
+  end
+
   #   @doc """
   #   Updates a sheaf.
 
@@ -421,6 +530,8 @@ defmodule Vyasa.Sangh do
   #   """
 
   def update_sheaf!(%Sheaf{} = sheaf, attrs) do
+    IO.puts("CHECKPOINT: update_sheaf!")
+
     sheaf
     |> Sheaf.mutate_changeset(attrs)
     |> Repo.update!()

lib/vyasa/sangh/sheaf.ex

@@ -67,13 +67,19 @@ defmodule Vyasa.Sangh.Sheaf do
   end
 
   def mutate_changeset(%Sheaf{} = sheaf, attrs) do
-    sheaf
-    |> Vyasa.Repo.preload([:marks])
-    |> cast(attrs, [:id, :body, :active, :signature, :traits])
-    |> cast_path(attrs)
-    |> assoc_marks(attrs)
-    |> Map.put(:repo_opts, on_conflict: {:replace_all_except, [:id]}, conflict_target: :id)
-    |> validate_include_subset(:traits, ["personal", "draft", "published"])
+    IO.inspect(%{sheaf: sheaf, attrs: attrs}, label: "CHECKPOINT: mutate_changeset")
+
+    cs =
+      sheaf
+      |> Vyasa.Repo.preload([:marks])
+      |> cast(attrs, [:id, :body, :active, :signature, :traits, :updated_at, :inserted_at])
+      |> cast_path(attrs)
+      |> assoc_marks(attrs)
+      |> Map.put(:repo_opts, on_conflict: {:replace_all_except, [:id]}, conflict_target: :id)
+      |> validate_include_subset(:traits, ["personal", "draft", "published"])
+
+    IO.inspect(cs, label: "CHECKPOINT: mutate changeset outcome changeset:")
+    cs
   end
 
   defp assoc_marks(sheaf, %{marks: [%Mark{} | _] = marks}) do
@@ -87,17 +93,25 @@ defmodule Vyasa.Sangh.Sheaf do
   end
 
   defp cast_path(%{changes: %{id: sheaf_id}} = sheaf, %{
-         parent: %Sheaf{id: p_sheaf_id, path: lpath}
+         parent: %Sheaf{id: p_sheaf_id, path: lpath} = parent
        }) do
+    IO.inspect(parent, label: "SEE ME : cast_path, parent:")
+
     sheaf
     |> cast(%{parent_id: p_sheaf_id, path: encode_path(sheaf_id, lpath)}, [:parent_id, :path])
   end
 
   defp cast_path(%{changes: %{id: sheaf_id}} = sheaf, _) do
+    IO.inspect(sheaf, label: "SEE ME : cast_path, sheaf:")
+
     sheaf
     |> cast(%{path: encode_path(sheaf_id)}, [:path])
   end
 
+  defp cast_path(%{data: %{id: sheaf_id}} = sheaf, %{parent: %Sheaf{id: p_sheaf_id, path: lpath}}) do
+    cast(sheaf, %{parent_id: p_sheaf_id, path: encode_path(sheaf_id, lpath)}, [:parent_id, :path])
+  end
+
   defp cast_path(sheaf, _) do
     sheaf
   end
@@ -204,4 +218,18 @@ defmodule Vyasa.Sangh.Sheaf do
       ) do
     labels
   end
+
+  @doc """
+  For sorting sheafs, we should just default to only caring about their insertion time,
+  ignoring the update time.
+
+  TODO: update clauses once we are supporting other kinds of ordering
+  """
+  def sort_sheafs_chrono([%Sheaf{} | _] = sheafs) do
+    Enum.sort_by(sheafs, &elem(&1, 1).inserted_at, :desc)
+  end
+
+  def sort_sheaf_chrono(sheafs) do
+    sheafs
+  end
 end

lib/vyasa/sangh/sheaf_lattice.ex

@@ -323,6 +323,8 @@ defmodule Vyasa.Sangh.SheafLattice do
     sheaf_lattice
     |> read_sheaf_lattice(level, match)
     |> Enum.reject(fn %Sheaf{traits: traits} -> "draft" in traits end)
+    # TODO: to verify this, may not be correct
+    |> sort_sheaf_lattice_entries_chrono()
   end
 
   # fetches all sheafs in level 0:
@@ -449,4 +451,12 @@ defmodule Vyasa.Sangh.SheafLattice do
 
     lattice |> update_sheaf_in_lattice(lattice_key, %Sheaf{old_sheaf | marks: updated_marks})
   end
+
+  def sort_sheaf_lattice_entries_chrono([{label, %Sheaf{}} | _] = entries) when is_list(label) do
+    entries |> Enum.sort_by(fn {_, %Sheaf{} = sheaf} -> sheaf.inserted_at end, :desc)
+  end
+
+  def sort_sheaf_lattice_entries_chrono(entries) do
+    entries
+  end
 end

lib/vyasa_web/components/contexts/components.ex

@@ -4,6 +4,7 @@ defmodule VyasaWeb.Context.Components do
   """
   use VyasaWeb, :html
   alias Vyasa.Sangh.{Sheaf}
+  alias VyasaWeb.CoreComponents
   alias VyasaWeb.Context.Components.UiState.Mark, as: MarkUiState
   alias VyasaWeb.Context.Components.UiState.Sheaf, as: SheafUiState
 
@@ -323,7 +324,7 @@ defmodule VyasaWeb.Context.Components do
     <div id="sheaf-creator-container" class="flex flex-col">
       <.form
         for={%{}}
-        phx-submit={JS.push("sheaf::publish")}
+        phx-submit={CoreComponents.hide_modal(JS.push("sheaf::publish"), @id)}
         phx-target={@event_target}
         class="flex items-center"
       >
@@ -377,7 +378,7 @@ defmodule VyasaWeb.Context.Components do
           <div class="flex justify-between space-x-2">
             <button
               type="button"
-              phx-click={@on_cancel_callback}
+              phx-click={CoreComponents.hide_modal(@on_cancel_callback, @id)}
               class="w-2/5 text-bold mt-4 flex items-center justify-center p-3 rounded-full border-2 border-brand text-grey-800 bg-brand-dark hover:bg-brand-light transition-colors duration-200 shadow-lg hover:shadow-xl focus:outline-none focus:ring-2 focus:ring-brand focus:ring-opacity-50"
               phx-target={@event_target}
             >
@@ -564,18 +565,27 @@ defmodule VyasaWeb.Context.Components do
   attr :time_class, :string, default: "text-sm italic"
 
   def sheaf_signature_display(assigns) do
+    assigns =
+      assigns
+      |> assign(
+        edited_suffix:
+          cond do
+            assigns.sheaf.inserted_at < assigns.sheaf.updated_at ->
+              "(edited)"
+
+            true ->
+              ""
+          end
+      )
+
     ~H"""
     <div class="w-auto flex mt-2 text-sm text-gray-600">
       <div class="mx-1 text-gray-800 font-semibold">
         <p><%= @sheaf.signature %></p>
       </div>
       <!-- Time Display -->
       <div class="mx-1 text-gray-500 italic">
-        <%= if is_nil(@sheaf.updated_at) do %>
-          <%= (@sheaf.inserted_at |> Utils.Formatters.Time.friendly()).formatted_time %>
-        <% else %>
-          <%= (@sheaf.updated_at |> Utils.Formatters.Time.friendly()).formatted_time %> (edited)
-        <% end %>
+        <%= (@sheaf.inserted_at |> Utils.Formatters.Time.friendly()).formatted_time <> @edited_suffix %>
       </div>
     </div>
     """

lib/vyasa_web/components/contexts/discuss.ex

@@ -105,6 +105,21 @@ defmodule VyasaWeb.Context.Discuss do
     )
   end
 
+  @doc """
+  For a particular sheaf, re-registers it by deleting its old entry in the lattice and inserting the new entry.
+  This is useful for manipulating the lattices in events such as promoting a sheaf from draft to published.
+  """
+  def reregister_sheaf(
+        %Socket{} = socket,
+        %Sheaf{id: old_id} = old_sheaf,
+        %Sheaf{id: new_id} = new_sheaf
+      )
+      when old_id == new_id do
+    socket
+    |> deregister_sheaf(old_sheaf)
+    |> register_sheaf(new_sheaf)
+  end
+
   def deregister_sheaf(
         %Socket{
           assigns: %{
@@ -490,7 +505,7 @@ defmodule VyasaWeb.Context.Discuss do
      • we don’t want to persist the reply_to in the db (by updating the
        current active draft sheaf).
      • we won’t do an update query on the draft_sheaf form the
-       sheaf::quick_reply
+       sheaf::toggle_quick_reply
      • we will only change the reply_to_path that is kept in state
        within the discuss context
      • the user should expect that since this is a quick reply, this
@@ -501,7 +516,7 @@ defmodule VyasaWeb.Context.Discuss do
        depth, and desires to go and gather marks (e.g. by clicking some
        kind of “nav to read mode”), then this transient case will change
        to case 2, permanent.
-       ^ this event is will be different from the sheaf::quick_reply event though
+       ^ this event is will be different from the sheaf::toggle_quick_reply event though
 
   2. if “permanent/intentional”
      • we update both the reply_to_path in the local socket state as
@@ -511,7 +526,7 @@ defmodule VyasaWeb.Context.Discuss do
   1.1 Conclusions:
   ────────────────
 
-  1. `sheaf::quick_reply' will not do any db write to the current draft
+  1. `sheaf::toggle_quick_reply' will not do any db write to the current draft
      sheaf’s parent field. Will only update the local state (for
      `reply_to_path')
   2. `sheaf::publish' will be updated so that regardless of the upstream
@@ -520,7 +535,7 @@ defmodule VyasaWeb.Context.Discuss do
      current draft sheaf no matter what.
   """
   def handle_event(
-        "sheaf::quick_reply",
+        "sheaf::toggle_quick_reply",
         %{
           "sheaf_path_labels" => immediate_reply_to_sheaf_labels
         } = _params,
@@ -584,6 +599,7 @@ defmodule VyasaWeb.Context.Discuss do
     reply_to_lattice_key = Jason.decode!(new_reply_to_target)
     reply_to_sheaf = sheaf_lattice |> SheafLattice.get_sheaf_from_lattice(reply_to_lattice_key)
     draft_sheaf = sheaf_lattice |> SheafLattice.get_sheaf_from_lattice(draft_sheaf_lattice_key)
+    # why not  sheaf_lattice["reply_to_path"] -> quite explicit
 
     new_reply_to_path =
       case reply_to_sheaf do
@@ -597,8 +613,13 @@ defmodule VyasaWeb.Context.Discuss do
       end
 
     # FIXME: @ks0m1c this update function should be updating the parent for the current draft sheaf, but it doesn't seem to be
-    # doing so right now, can I leave this to you to check why the update isn't happening?
-    # else i'll eventually come back to it.
+    # doing so right now
+    # what it needs to do:
+    # 1. remove assoc b/w old parent and this sheaf
+    # 2. create new assoc b/w new parent and this sheaf:
+    #     - updates path of child
+    IO.puts("CHECKPOINT: before updating sheaf")
+
     updated_draft_sheaf =
       draft_sheaf
       |> Sangh.update_sheaf!(%{
@@ -674,6 +695,73 @@ defmodule VyasaWeb.Context.Discuss do
     }
   end
 
+  def handle_event(
+        "sheaf::publish",
+        %{
+          "body" => body,
+          "is_private" => _is_private
+        } = _params,
+        %Socket{
+          assigns: %{
+            session: %VyasaWeb.Session{
+              name: username,
+              sangh: %Vyasa.Sangh.Session{
+                id: sangh_id
+              }
+            },
+            draft_reflector_path: %Ltree{
+              labels: draft_sheaf_lattice_key
+            },
+            reply_to_path: %Ltree{
+              labels: reply_to_lattice_key
+            },
+            sheaf_lattice: %{} = sheaf_lattice,
+            sheaf_ui_lattice: %{} = sheaf_ui_lattice
+          }
+        } = socket
+      )
+      when is_binary(body) do
+    # TODO: the reply_to_lattice_key might be nil, that case of "create new thread" is not handled right now by discuss
+    reply_to_sheaf = sheaf_lattice[reply_to_lattice_key]
+    draft_sheaf = sheaf_lattice[draft_sheaf_lattice_key]
+
+    payload_precursor = %{
+      body: body,
+      traits: ["published"],
+      signature: username,
+      inserted_at: Utils.Time.get_utc_now()
+    }
+
+    update_payload =
+      case(is_nil(reply_to_sheaf)) do
+        true ->
+          payload_precursor
+
+        false ->
+          Map.put(payload_precursor, :parent, reply_to_sheaf)
+      end
+
+    {:ok, updated_sheaf} = draft_sheaf |> Vyasa.Sangh.make_reply(update_payload)
+
+    %Sheaf{
+      path: %Ltree{} = new_draft_reflector_path
+    } = new_draft_reflector = Sheaf.draft!(sangh_id)
+
+    {
+      :noreply,
+      socket
+      |> assign(
+        sheaf_ui_lattice:
+          sheaf_ui_lattice |> SheafLattice.toggle_show_sheaf_modal?(draft_sheaf_lattice_key)
+      )
+      |> reregister_sheaf(draft_sheaf, updated_sheaf)
+      |> assign(draft_reflector_path: new_draft_reflector_path)
+      |> assign(reply_to_path: nil)
+      |> register_sheaf(new_draft_reflector)
+      |> maybe_prepend_draft_mark_in_reflector()
+    }
+  end
+
   @impl true
   # TODO @ks0m1c this is an example of what binding/permalinking should handle
   # we need to do a push-patch direction from this function
@@ -861,7 +949,7 @@ defmodule VyasaWeb.Context.Discuss do
               sheaf_lattice={@sheaf_lattice}
               sheaf_ui_lattice={@sheaf_ui_lattice}
               on_replies_click={JS.push("ui::toggle_sheaf_is_expanded?", target: "#content-display")}
-              on_quick_reply={JS.push("sheaf::quick_reply", target: "#content-display")}
+              on_quick_reply={JS.push("sheaf::toggle_quick_reply", target: "#content-display")}
               on_set_reply_to={JS.push("sheaf::set_reply_to_context", target: "#content-display")}
             />
             <!-- <.sheaf_summary sheaf={root_sheaf} /> -->

lib/vyasa_web/components/contexts/discuss/sheaf_tree.ex

@@ -148,7 +148,12 @@ defmodule VyasaWeb.Context.Discuss.SheafTree do
       class={["border-l-2 border-gray-200", @container_class]}
       id={"collapsible-sheaf-container-" <> @id}
     >
-      <!-- <.debug_dump label="collapsible sheaf container" reply_to={@reply_to} /> -->
+      <!-- <.debug_dump
+        label="collapsible sheaf container"
+        id={@id}
+        level={@level}
+        num_children={@sheafs |> Enum.count()}
+      /> -->
       <!-- Non-Collapsible View -->
       <%= if is_nil(@sheafs) or !@sheafs or Enum.empty?(@sheafs) do %>
         <p class="text-gray-500">No child sheafs available.</p>
@@ -169,8 +174,8 @@ defmodule VyasaWeb.Context.Discuss.SheafTree do
             children={
               SheafLattice.read_published_from_sheaf_lattice(
                 @sheaf_lattice,
-                @level,
-                @sheaf.path.labels ++ [nil]
+                @level + 2,
+                child.path.labels ++ [nil]
               )
             }
           />
@@ -252,11 +257,11 @@ defmodule VyasaWeb.Context.Discuss.SheafTree do
       class="flex flex-col"
     >
       <!-- <.debug_dump
-        label={"LEVEL "<> to_string(@level) <>  " sheaf component id=" <> @id}
-        reply_to={@reply_to}
-        is_reply_to={@is_reply_to}
-        level={@level}
+        id={@id}
+        label="Sheaf Component"
         sheaf_path={@sheaf.path}
+        level={@level}
+        num_children={@children |> Enum.count()}
       /> -->
       <.sheaf_summary
         id={"sheaf-tree-node-sheaf-summary-"<> @id}
@@ -291,7 +296,7 @@ defmodule VyasaWeb.Context.Discuss.SheafTree do
           sheafs={@children}
           sheaf_lattice={@sheaf_lattice}
           sheaf_ui_lattice={@sheaf_ui_lattice}
-          level={@level + 1}
+          level={@level}
           on_replies_click={@on_replies_click}
           on_set_reply_to={@on_set_reply_to}
           on_quick_reply={@on_quick_reply}

lib/vyasa_web/components/contexts/read.ex

@@ -311,8 +311,6 @@ defmodule VyasaWeb.Context.Read do
       when is_binary(parent_id) do
     socket
     |> assign(reply_to: Sangh.get_sheaf(parent_id))
-
-    # |> assign(reply_to: Sangh.get_sheaf("4ce67b86-f7db-48e4-8834-c03f6fec69fa"))
   end
 
   def init_reply_to_context(%Socket{} = socket) do
@@ -352,10 +350,18 @@ defmodule VyasaWeb.Context.Read do
         } = socket
       )
       when not is_nil(sangh_id) do
-    socket
-    |> init_draft_reflector()
-    |> init_draft_reflector_ui()
-    |> maybe_prepend_draft_mark_in_reflector()
+    draft_sheafs = sangh_id |> Vyasa.Sangh.get_sheafs_by_session(%{traits: ["draft"]})
+
+    draft_sheaf =
+      case draft_sheafs do
+        [%Sheaf{} = draft_sheaf | _] ->
+          draft_sheaf
+
+        _ ->
+          Sheaf.draft!(sangh_id)
+      end
+
+    socket |> register_sheaf(draft_sheaf)
   end
 
   # fallthrough
@@ -365,6 +371,24 @@ defmodule VyasaWeb.Context.Read do
     |> assign(draft_reflector_ui: nil)
   end
 
+  @doc """
+  Registers a sheaf in drafting context by setting its state, the state for its ui
+  and also maybe prepends a draft mark in the draft sheaf.
+  """
+  def register_sheaf(
+        %Socket{
+          assigns: %{
+            session: %{sangh: %{id: _sangh_id}}
+          }
+        } = socket,
+        %Sheaf{} = sheaf
+      ) do
+    socket
+    |> assign(draft_reflector: sheaf)
+    |> assign(draft_reflector_ui: sheaf |> SheafUiState.get_initial_ui_state())
+    |> maybe_prepend_draft_mark_in_reflector()
+  end
+
   @doc """
   Only initialises a draft reflector in the socket state. If there's no existing
   draft reflector(s) in the db, then we shall create a new draft sheaf.
@@ -771,65 +795,6 @@ defmodule VyasaWeb.Context.Read do
     {:noreply, socket}
   end
 
-  @impl true
-  # TODO: @ks0m1c sheaf crud -- event handler [TODO testing needed by @rtshkmr if this works as required]
-  # This function handles the case where there's a parent sheaf in the reply_to context.
-  # What should happen:
-  # 1. since this is NOT a ROOT sheaf, the existing draft sheaf should be updated and promoted to a pulished sheaf AND it needs to be associated to the parent sheaf (in the reply to context).
-  #    => also, that should also be the new, active sheaf since it just got created (NOT SURE ABOUT THIS)
-  # 2. no need to add in a new draft sheaf because the init_reply_to_context() will handle it for us.
-  #
-  # Consider the current implementation of init_draft_reflector when writing this out. The draft sheaf used for the draft_reflector may
-  # be fetched from the DB (or may have been generated without being pushed in).
-  # If it was fetched from the DB, then this creation step needs to ensure that entry needs to be updated/delete.
-  #
-  # TODO: @ks0m1c [this can be done another time, or now]
-  # There's some more cases to handle:
-  # 1. if it's a private sheaf ==> needs to be associated with the user's private sangh session id
-  # 2. if it's a public sheaf ==> (no change) keep usingthe current sangh session id
-  #
-  def handle_event(
-        "sheaf::publish",
-        %{
-          "body" => body,
-          "is_private" => is_private
-        } = _params,
-        %Socket{
-          assigns: %{
-            marks_ui: %MarksUiState{} = ui_state,
-            reply_to: %Sheaf{} = parent_sheaf,
-            draft_reflector: %Sheaf{} = draft_sheaf,
-            session: %VyasaWeb.Session{
-              name: username,
-              sangh: %Vyasa.Sangh.Session{
-                id: sangh_id
-              }
-            }
-          }
-        } = socket
-      )
-      when not is_nil(parent_sheaf) do
-    IO.inspect(%{body: body, is_private: is_private},
-      label: "SHEAF CREATION"
-    )
-
-    Vyasa.Sangh.update_sheaf(
-      draft_sheaf,
-      %{
-        body: body,
-        traits: ["published"],
-        parent: parent_sheaf,
-        signature: username
-      }
-    )
-
-    {:noreply,
-     socket
-     |> assign(marks_ui: ui_state |> MarksUiState.toggle_show_sheaf_modal?())
-     |> assign(draft_reflector: Sheaf.draft!(sangh_id))
-     |> cascade_stream_change()}
-  end
-
   # TODO: @ks0m1c since this is a root sheaf, no parent to associate.
   # This function shall:
   # 1. update (promote) this current draft sheaf in the reflector to a published sheaf
@@ -848,6 +813,7 @@ defmodule VyasaWeb.Context.Read do
             draft_reflector_ui: %SheafUiState{
               marks_ui: %MarksUiState{} = _ui_state
             },
+            reply_to: reply_to_sheaf,
             session: %VyasaWeb.Session{
               name: username,
               sangh: %Vyasa.Sangh.Session{
@@ -861,21 +827,30 @@ defmodule VyasaWeb.Context.Read do
       label: "SHEAF CREATION without parent"
     )
 
-    # current_sheaf_id context is always inherited from the in-context window
-    Vyasa.Sangh.update_sheaf(
-      draft_sheaf,
-      %{
-        body: body,
-        traits: ["published"],
-        signature: username
-      }
-    )
+    payload_precursor = %{
+      body: body,
+      traits: ["published"],
+      signature: username,
+      inserted_at: Utils.Time.get_utc_now()
+    }
+
+    reply_payload =
+      cond do
+        %Sheaf{} = reply_to_sheaf ->
+          payload_precursor |> Map.put(:parent, reply_to_sheaf)
+
+        true ->
+          payload_precursor
+      end
+
+    draft_sheaf
+    |> Vyasa.Sangh.make_reply(reply_payload)
 
     {:noreply,
      socket
      |> ui_toggle_show_sheaf_modal?()
-     |> assign(draft_reflector: Sheaf.draft!(sangh_id))
-     |> maybe_prepend_draft_mark_in_reflector()
+     |> register_sheaf(Sheaf.draft!(sangh_id))
+     |> assign(reply_to: nil)
      |> cascade_stream_change()}
   end
 

mix.exs

@@ -47,6 +47,7 @@ defmodule Vyasa.MixProject do
       {:postgrex, ">= 0.0.0"},
       {:phoenix_html, "~> 4.0"},
       {:phoenix_live_reload, "~> 1.5", only: :dev},
+      # in order to get the correct patching behaviour, we needed a un-released commit on the main branch. Ref: https://github.com/phoenixframework/phoenix_live_view/commit/440fd0460405c57f61fcc7457ea9f80ff56f1135
       {:phoenix_live_view,
        github: "phoenixframework/phoenix_live_view", ref: "440fd04", override: true},
       {:floki, ">= 0.30.0"},