Scope semantic persistence by tenant

Author: nshkrdotcom

apps/host_surface/test/outer_brain/host_surface_test.exs

@@ -14,6 +14,7 @@ defmodule OuterBrain.HostSurfaceTest do
              HostSurface.open_session(
                "session_alpha",
                "console_host",
+               tenant_id: "tenant://host/a",
                now: DateTime.from_unix!(1_800_000_700),
                epoch: 1,
                ttl_seconds: 30,

core/memory_engine/test/outer_brain/memory_engine_test.exs

@@ -3,6 +3,8 @@ defmodule OuterBrain.MemoryEngineTest do
 
   alias OuterBrain.MemoryEngine
 
+  @moduletag :tenant_isolation
+
   test "memory writes return refs and evidence without raw bodies" do
     store = MemoryEngine.new()
 

core/outer_brain_persistence/lib/outer_brain/persistence/schemas/recovery_task.ex

@@ -8,6 +8,7 @@ defmodule OuterBrain.Persistence.Schemas.RecoveryTask do
   @primary_key {:task_id, :string, autogenerate: false}
 
   schema "recovery_tasks" do
+    field(:tenant_id, :string)
     field(:session_id, :string)
     field(:reason, :string)
     field(:status, Ecto.Enum, values: [:pending, :running, :done])
@@ -17,7 +18,7 @@ defmodule OuterBrain.Persistence.Schemas.RecoveryTask do
 
   def changeset(schema, attrs) do
     schema
-    |> cast(attrs, [:task_id, :session_id, :reason, :status])
-    |> validate_required([:task_id, :session_id, :reason, :status])
+    |> cast(attrs, [:task_id, :tenant_id, :session_id, :reason, :status])
+    |> validate_required([:task_id, :tenant_id, :session_id, :reason, :status])
   end
 end

core/outer_brain_persistence/lib/outer_brain/persistence/schemas/reply_publication.ex

@@ -8,6 +8,7 @@ defmodule OuterBrain.Persistence.Schemas.ReplyPublication do
   @primary_key {:publication_id, :string, autogenerate: false}
 
   schema "reply_publications" do
+    field(:tenant_id, :string)
     field(:causal_unit_id, :string)
     field(:phase, Ecto.Enum, values: [:provisional, :final])
     field(:state, Ecto.Enum, values: [:pending, :published, :suppressed])
@@ -22,6 +23,7 @@ defmodule OuterBrain.Persistence.Schemas.ReplyPublication do
     schema
     |> cast(attrs, [
       :publication_id,
+      :tenant_id,
       :causal_unit_id,
       :phase,
       :state,
@@ -31,13 +33,14 @@ defmodule OuterBrain.Persistence.Schemas.ReplyPublication do
     ])
     |> validate_required([
       :publication_id,
+      :tenant_id,
       :causal_unit_id,
       :phase,
       :state,
       :dedupe_key,
       :body,
       :body_ref
     ])
-    |> unique_constraint(:dedupe_key)
+    |> unique_constraint([:tenant_id, :dedupe_key])
   end
 end

core/outer_brain_persistence/lib/outer_brain/persistence/schemas/semantic_journal_entry.ex

@@ -8,6 +8,7 @@ defmodule OuterBrain.Persistence.Schemas.SemanticJournalEntry do
   @primary_key {:entry_id, :string, autogenerate: false}
 
   schema "semantic_journal_entries" do
+    field(:tenant_id, :string)
     field(:session_id, :string)
     field(:causal_unit_id, :string)
     field(:entry_type, :string)
@@ -19,9 +20,18 @@ defmodule OuterBrain.Persistence.Schemas.SemanticJournalEntry do
 
   def changeset(schema, attrs) do
     schema
-    |> cast(attrs, [:entry_id, :session_id, :causal_unit_id, :entry_type, :payload, :recorded_at])
+    |> cast(attrs, [
+      :entry_id,
+      :tenant_id,
+      :session_id,
+      :causal_unit_id,
+      :entry_type,
+      :payload,
+      :recorded_at
+    ])
     |> validate_required([
       :entry_id,
+      :tenant_id,
       :session_id,
       :causal_unit_id,
       :entry_type,

core/outer_brain_persistence/lib/outer_brain/persistence/schemas/semantic_session_lease.ex

@@ -8,6 +8,7 @@ defmodule OuterBrain.Persistence.Schemas.SemanticSessionLease do
   @primary_key {:row_id, :string, autogenerate: false}
 
   schema "semantic_session_leases" do
+    field(:tenant_id, :string)
     field(:session_id, :string)
     field(:holder, :string)
     field(:lease_id, :string)
@@ -19,8 +20,16 @@ defmodule OuterBrain.Persistence.Schemas.SemanticSessionLease do
 
   def changeset(schema, attrs) do
     schema
-    |> cast(attrs, [:row_id, :session_id, :holder, :lease_id, :epoch, :expires_at])
-    |> validate_required([:row_id, :session_id, :holder, :lease_id, :epoch, :expires_at])
-    |> unique_constraint(:session_id)
+    |> cast(attrs, [:row_id, :tenant_id, :session_id, :holder, :lease_id, :epoch, :expires_at])
+    |> validate_required([
+      :row_id,
+      :tenant_id,
+      :session_id,
+      :holder,
+      :lease_id,
+      :epoch,
+      :expires_at
+    ])
+    |> unique_constraint([:tenant_id, :session_id])
   end
 end