Managed Deployments: Groups and Releases

lib/nerves_hub/accounts/remove_account.ex

@@ -5,7 +5,7 @@ defmodule NervesHub.Accounts.RemoveAccount do
   alias NervesHub.{
     Accounts,
     Firmwares,
-    Deployments.Deployment,
+    ManagedDeployments.DeploymentGroup,
     Products,
     Repo,
     OrgKey,
@@ -25,7 +25,7 @@ defmodule NervesHub.Accounts.RemoveAccount do
     |> Multi.delete_all(:invites, &query_by_org_id(Invite, &1))
     |> Multi.delete_all(:device_certificates, &query_by_org_id(DeviceCertificate, &1))
     |> Multi.delete_all(:ca_certificates, &query_by_org_id(CACertificate, &1))
-    |> Multi.delete_all(:deployments, &query_by_org_id(Deployment, &1))
+    |> Multi.delete_all(:deployment_groups, &query_by_org_id(DeploymentGroup, &1))
     |> Multi.delete_all(:firmware_deltas, &query_firmware_deltas/1)
     |> Multi.delete_all(:firmware_transfers, &query_by_org_id(FirmwareTransfer, &1))
     |> Multi.merge(&delete_firmwares/1)

lib/nerves_hub/application.ex

@@ -76,7 +76,7 @@ defmodule NervesHub.Application do
   defp deployments_supervisor("test"), do: []
 
   defp deployments_supervisor(_) do
-    [NervesHub.Deployments.Supervisor]
+    [NervesHub.ManagedDeployments.Supervisor]
   end
 
   defp endpoints("test") do

lib/nerves_hub/audit_logs.ex

@@ -2,7 +2,7 @@ defmodule NervesHub.AuditLogs do
   import Ecto.Query
 
   alias NervesHub.AuditLogs.AuditLog
-  alias NervesHub.Deployments.Deployment
+  alias NervesHub.ManagedDeployments.DeploymentGroup
   alias NervesHub.Repo
   alias NimbleCSV.RFC4180, as: CSV
 
@@ -58,8 +58,8 @@ defmodule NervesHub.AuditLogs do
     |> Flop.run(flop)
   end
 
-  defp query_for_feed(%Deployment{id: id}) do
-    resource_type = to_string(Deployment)
+  defp query_for_feed(%DeploymentGroup{id: id}) do
+    resource_type = to_string(DeploymentGroup)
 
     from(al in AuditLog, where: [resource_type: ^resource_type, resource_id: ^id])
     |> order_by(desc: :inserted_at)

lib/nerves_hub/audit_logs/templates.ex

@@ -6,7 +6,7 @@ defmodule NervesHub.AuditLogs.Templates do
   def audit_resolve_changed_deployment(device, reference_id) do
     description =
       if device.deployment_id do
-        "device #{device.identifier} reloaded deployment and is attached to deployment #{device.deployment.name}"
+        "device #{device.identifier} reloaded deployment and is attached to deployment #{device.deployment_group.name}"
       else
         "device #{device.identifier} reloaded deployment and is no longer attached to a deployment"
       end
@@ -15,18 +15,18 @@ defmodule NervesHub.AuditLogs.Templates do
   end
 
   def audit_device_deployment_update_triggered(device, reference_id) do
-    deployment = device.deployment
-    firmware = deployment.firmware
+    deployment_group = device.deployment_group
+    firmware = deployment_group.firmware
 
     description =
-      "deployment #{deployment.name} update triggered device #{device.identifier} to update firmware #{firmware.uuid}"
+      "deployment #{deployment_group.name} update triggered device #{device.identifier} to update firmware #{firmware.uuid}"
 
-    AuditLogs.audit_with_ref!(deployment, device, description, reference_id)
+    AuditLogs.audit_with_ref!(deployment_group, device, description, reference_id)
   end
 
   def audit_device_assigned(device, reference_id) do
     description =
-      "device #{device.identifier} reloaded deployment and is attached to deployment #{device.deployment.name}"
+      "device #{device.identifier} reloaded deployment and is attached to deployment #{device.deployment_group.name}"
 
     AuditLogs.audit_with_ref!(device, device, description, reference_id)
   end

lib/nerves_hub/devices.ex

@@ -9,8 +9,8 @@ defmodule NervesHub.Devices do
   alias NervesHub.Accounts.User
   alias NervesHub.AuditLogs
   alias NervesHub.Certificate
-  alias NervesHub.Deployments.Deployment
-  alias NervesHub.Deployments.Orchestrator
+  alias NervesHub.ManagedDeployments.DeploymentGroup
+  alias NervesHub.ManagedDeployments.Orchestrator
   alias NervesHub.Devices.CACertificate
   alias NervesHub.Devices.Alarms
   alias NervesHub.Devices.Connections
@@ -86,12 +86,12 @@ defmodule NervesHub.Devices do
     |> where([d], d.product_id == ^product_id)
     |> join(:left, [d], o in assoc(d, :org))
     |> join(:left, [d, o], p in assoc(d, :product))
-    |> join(:left, [d, o, p], dp in assoc(d, :deployment))
+    |> join(:left, [d, o, p], dp in assoc(d, :deployment_group))
     |> join(:left, [d, o, p, dp], f in assoc(dp, :firmware))
     |> Repo.exclude_deleted()
     |> order_by(^sort_devices(sorting))
     |> filtering(filters)
-    |> preload([d, o, p, dp, f], org: o, product: p, deployment: {dp, firmware: f})
+    |> preload([d, o, p, dp, f], org: o, product: p, deployment_group: {dp, firmware: f})
     |> Connections.preload_latest_connection()
     |> Flop.run(flop)
   end
@@ -365,7 +365,7 @@ defmodule NervesHub.Devices do
         {:error, :not_found}
 
       device ->
-        {:ok, Repo.preload(device, [:org, :product, deployment: [:firmware]])}
+        {:ok, Repo.preload(device, [:org, :product, deployment_group: [:firmware]])}
     end
   end
 
@@ -392,9 +392,9 @@ defmodule NervesHub.Devices do
     |> where(identifier: ^identifier)
     |> where(org_id: ^org_id)
     |> join(:left, [d], o in assoc(d, :org))
-    |> join(:left, [d], dp in assoc(d, :deployment))
+    |> join(:left, [d], dp in assoc(d, :deployment_group))
     |> join_and_preload(preload_assoc)
-    |> preload([d, o, dp], org: o, deployment: dp)
+    |> preload([d, o, dp], org: o, deployment_group: dp)
   end
 
   defp join_and_preload(query, nil), do: query
@@ -466,7 +466,7 @@ defmodule NervesHub.Devices do
 
   def get_eligible_deployments(%Device{firmware_metadata: meta} = device) do
     from(
-      d in Deployment,
+      d in DeploymentGroup,
       join: p in assoc(d, :product),
       on: [org_id: ^device.org_id, name: ^meta.product],
       join: f in assoc(d, :firmware),
@@ -736,7 +736,7 @@ defmodule NervesHub.Devices do
   @spec get_device_firmware_for_delta_generation_by_product(binary()) ::
           list({source_firmware_id(), target_firmware_id()})
   def get_device_firmware_for_delta_generation_by_product(product_id) do
-    Deployment
+    DeploymentGroup
     |> where([dep], dep.product_id == ^product_id)
     |> join(:inner, [dep], dev in Device, on: dev.deployment_id == dep.id)
     |> join(:inner, [dep, dev], f in Firmware,
@@ -751,7 +751,7 @@ defmodule NervesHub.Devices do
   @spec get_device_firmware_for_delta_generation_by_deployment(binary()) ::
           list({source_firmware_id(), target_firmware_id()})
   def get_device_firmware_for_delta_generation_by_deployment(deployment_id) do
-    Deployment
+    DeploymentGroup
     |> where([dep], dep.id == ^deployment_id)
     |> join(:inner, [dep], dev in Device, on: dev.deployment_id == dep.id)
     |> join(:inner, [dep, dev], f in Firmware,
@@ -817,7 +817,7 @@ defmodule NervesHub.Devices do
   end
 
   def resolve_update(device) do
-    deployment = Repo.preload(device.deployment, [:firmware])
+    deployment = Repo.preload(device.deployment_group, [:firmware])
 
     case verify_update_eligibility(device, deployment) do
       {:ok, _device} ->
@@ -828,7 +828,7 @@ defmodule NervesHub.Devices do
           update_available: true,
           firmware_url: url,
           firmware_meta: meta,
-          deployment: deployment,
+          deployment_group: deployment,
           deployment_id: deployment.id
         }
 
@@ -860,7 +860,7 @@ defmodule NervesHub.Devices do
   """
   def matches_deployment?(
         %Device{tags: tags, firmware_metadata: %FirmwareMetadata{version: version}},
-        %Deployment{conditions: %{"version" => requirement, "tags" => dep_tags}}
+        %DeploymentGroup{conditions: %{"version" => requirement, "tags" => dep_tags}}
       ) do
     if version_match?(version, requirement) and tags_match?(tags, dep_tags) do
       true
@@ -871,29 +871,21 @@ defmodule NervesHub.Devices do
 
   def matches_deployment?(_, _), do: false
 
-  @spec update_deployment(Device.t(), Deployment.t()) :: Device.t()
+  @spec update_deployment(Device.t(), DeploymentGroup.t()) :: Device.t()
   def update_deployment(device, deployment) do
     device
     |> Ecto.Changeset.change()
     |> Ecto.Changeset.put_change(:deployment_id, deployment.id)
     |> Repo.update!()
   end
 
-  @spec clear_deployment(Device.t()) :: Device.t()
-  def clear_deployment(device) do
-    device
-    |> Ecto.Changeset.change()
-    |> Ecto.Changeset.put_change(:deployment_id, nil)
-    |> Repo.update!()
-  end
-
-  @spec failure_threshold_met?(Device.t(), Deployment.t()) :: boolean()
-  def failure_threshold_met?(%Device{} = device, %Deployment{} = deployment) do
+  @spec failure_threshold_met?(Device.t(), DeploymentGroup.t()) :: boolean()
+  def failure_threshold_met?(%Device{} = device, %DeploymentGroup{} = deployment) do
     Enum.count(device.update_attempts) >= deployment.device_failure_threshold
   end
 
-  @spec failure_rate_met?(Device.t(), Deployment.t()) :: boolean()
-  def failure_rate_met?(%Device{} = device, %Deployment{} = deployment) do
+  @spec failure_rate_met?(Device.t(), DeploymentGroup.t()) :: boolean()
+  def failure_rate_met?(%Device{} = device, %DeploymentGroup{} = deployment) do
     seconds_ago =
       Timex.shift(DateTime.utc_now(), seconds: -deployment.device_failure_rate_seconds)
 
@@ -1021,7 +1013,7 @@ defmodule NervesHub.Devices do
     if inflight_update != nil do
       Orchestrator.device_updated(inflight_update.deployment_id)
 
-      Deployment
+      DeploymentGroup
       |> where([d], d.id == ^inflight_update.deployment_id)
       |> Repo.update_all(inc: [current_updated_devices: 1])
 
@@ -1086,7 +1078,7 @@ defmodule NervesHub.Devices do
     |> Repo.transaction()
     |> case do
       {:ok, %{move: updated}} ->
-        _ = broadcast(updated, "moved")
+        # Deployments.set_deployment(updated)
         {:ok, updated}
 
       err ->
@@ -1387,14 +1379,14 @@ defmodule NervesHub.Devices do
     |> Repo.update!()
   end
 
-  def inflight_updates_for(%Deployment{} = deployment) do
+  def inflight_updates_for(%DeploymentGroup{} = deployment) do
     InflightUpdate
     |> where([iu], iu.deployment_id == ^deployment.id)
     |> preload([:device])
     |> Repo.all()
   end
 
-  def count_inflight_updates_for(%Deployment{} = deployment) do
+  def count_inflight_updates_for(%DeploymentGroup{} = deployment) do
     InflightUpdate
     |> select([iu], count(iu))
     |> where([iu], iu.deployment_id == ^deployment.id)

lib/nerves_hub/devices/device.ex

@@ -7,8 +7,8 @@ defmodule NervesHub.Devices.Device do
   alias NervesHub.Devices.DeviceCertificate
   alias NervesHub.Devices.DeviceConnection
   alias NervesHub.Devices.DeviceMetric
-  alias NervesHub.Deployments.Deployment
-  alias NervesHub.Extensions.DeviceExtensionsSetting
+  alias NervesHub.Extensions.ExtensionsSetting
+  alias NervesHub.ManagedDeployments.DeploymentGroup
   alias NervesHub.Firmwares.FirmwareMetadata
   alias NervesHub.Products.Product
 
@@ -40,7 +40,7 @@ defmodule NervesHub.Devices.Device do
   schema "devices" do
     belongs_to(:org, Org, where: [deleted_at: nil])
     belongs_to(:product, Product, where: [deleted_at: nil])
-    belongs_to(:deployment, Deployment)
+    belongs_to(:deployment_group, DeploymentGroup, foreign_key: :deployment_id)
     embeds_one(:firmware_metadata, FirmwareMetadata, on_replace: :update)
     has_many(:device_certificates, DeviceCertificate, on_delete: :delete_all)
     has_many(:device_connections, DeviceConnection, on_delete: :delete_all)
@@ -65,6 +65,10 @@ defmodule NervesHub.Devices.Device do
     field(:connecting_code, :string)
     field(:connection_metadata, :map, default: %{})
 
+    field(:deployment_conflict, Ecto.Enum,
+      values: [:bad_architecture, :bad_platform, :bad_architecture_and_platform]
+    )
+
     timestamps()
 
     # Deprecated fields, replaced with device_connections table.

lib/nerves_hub/devices/inflight_update.ex

@@ -5,14 +5,14 @@ defmodule NervesHub.Devices.InflightUpdate do
 
   alias NervesHub.Devices.Device
   alias NervesHub.Devices.InflightUpdate
-  alias NervesHub.Deployments.Deployment
+  alias NervesHub.ManagedDeployments.DeploymentGroup
   alias NervesHub.Firmwares.Firmware
 
   @required_params [:device_id, :deployment_id, :firmware_id, :firmware_uuid, :expires_at]
 
   schema "inflight_updates" do
     belongs_to(:device, Device)
-    belongs_to(:deployment, Deployment)
+    belongs_to(:deployment_group, DeploymentGroup, foreign_key: :deployment_id)
     belongs_to(:firmware, Firmware)
 
     field(:firmware_uuid, Ecto.UUID)

lib/nerves_hub/devices/update_payload.ex

@@ -4,7 +4,7 @@ defmodule NervesHub.Devices.UpdatePayload do
   """
 
   alias NervesHub.Firmwares.FirmwareMetadata
-  alias NervesHub.Deployments.Deployment
+  alias NervesHub.ManagedDeployments.DeploymentGroup
 
   @derive {Jason.Encoder,
            only: [
@@ -17,22 +17,22 @@ defmodule NervesHub.Devices.UpdatePayload do
   defstruct update_available: false,
             firmware_url: nil,
             firmware_meta: nil,
-            deployment: nil,
+            deployment_group: nil,
             deployment_id: nil
 
   @type t ::
           %__MODULE__{
             update_available: false,
             firmware_meta: nil,
             firmware_url: nil,
-            deployment: nil,
+            deployment_group: nil,
             deployment_id: nil
           }
           | %__MODULE__{
               update_available: true,
               firmware_meta: FirmwareMetadata.t(),
               firmware_url: String.t(),
-              deployment: Deployment.t(),
+              deployment_group: DeploymentGroup.t(),
               deployment_id: non_neg_integer()
             }
 end