Update spectrogram creation to skip ones already created for an overlapping range

server/lib/orcasite/radio/audio_image.ex

@@ -79,6 +79,9 @@ defmodule Orcasite.Radio.AudioImage do
  defaults [:read, :destroy, create: :*, update: :*]
 
  create :for_feed_segment do
+ upsert? true
+ upsert_identity :unique_audio_image
+
  argument :feed_segment_id, :string, allow_nil?: false
 
  argument :image_type, Orcasite.Types.ImageType do

server/lib/orcasite/radio/audio_image_feed_segment.ex

@@ -15,6 +15,10 @@ defmodule Orcasite.Radio.AudioImageFeedSegment do
  end
  end
 
+ identities do
+ identity :unique_audio_image, [:feed_segment_id, :audio_image_id]
+ end
+
  attributes do
  uuid_primary_key :id
 
@@ -27,7 +31,14 @@ defmodule Orcasite.Radio.AudioImageFeedSegment do
  end
 
  actions do
- defaults [:read, :destroy, create: :*, update: :*]
+ defaults [:read, :destroy, update: :*]
+
+ create :create do
+ primary? true
+ accept :*
+ upsert? true
+ upsert_identity :unique_audio_image
+ end
  end
 
  graphql do

server/lib/orcasite/radio/feed.ex

@@ -204,6 +204,7 @@ defmodule Orcasite.Radio.Feed do
 
  change
  |> Ash.Changeset.manage_relationship(:audio_images, audio_image_inputs,
+ on_lookup: :ignore,
  on_no_match: {:create, :for_feed_segment},
  on_match: :ignore
  )

server/priv/repo/migrations/20240910222932_update_audio_image_feed_segment_join_table_unique.exs

@@ -0,0 +1,21 @@
+defmodule Orcasite.Repo.Migrations.UpdateAudioImageFeedSegmentJoinTableUnique do
+ @moduledoc """
+ Updates resources based on their most recent snapshots.
+
+ This file was autogenerated with `mix ash_postgres.generate_migrations`
+ """
+
+ use Ecto.Migration
+
+ def up do
+ create unique_index(:audio_image_feed_segments, [:feed_segment_id, :audio_image_id],
+ name: "audio_image_feed_segments_unique_audio_image_index"
+ )
+ end
+
+ def down do
+ drop_if_exists unique_index(:audio_image_feed_segments, [:feed_segment_id, :audio_image_id],
+ name: "audio_image_feed_segments_unique_audio_image_index"
+ )
+ end
+end

server/priv/resource_snapshots/repo/audio_image_feed_segments/20240910222932.json

@@ -0,0 +1,171 @@
+{
+ "attributes": [
+ {
+ "allow_nil?": false,
+ "default": "fragment(\"gen_random_uuid()\")",
+ "generated?": false,
+ "primary_key?": true,
+ "references": null,
+ "size": null,
+ "source": "id",
+ "type": "uuid"
+ },
+ {
+ "allow_nil?": false,
+ "default": "fragment(\"(now() AT TIME ZONE 'utc')\")",
+ "generated?": false,
+ "primary_key?": false,
+ "references": null,
+ "size": null,
+ "source": "inserted_at",
+ "type": "utc_datetime_usec"
+ },
+ {
+ "allow_nil?": false,
+ "default": "fragment(\"(now() AT TIME ZONE 'utc')\")",
+ "generated?": false,
+ "primary_key?": false,
+ "references": null,
+ "size": null,
+ "source": "updated_at",
+ "type": "utc_datetime_usec"
+ },
+ {
+ "allow_nil?": true,
+ "default": "nil",
+ "generated?": false,
+ "primary_key?": false,
+ "references": {
+ "deferrable": false,
+ "destination_attribute": "id",
+ "destination_attribute_default": null,
+ "destination_attribute_generated": null,
+ "index?": false,
+ "match_type": null,
+ "match_with": null,
+ "multitenancy": {
+ "attribute": null,
+ "global": null,
+ "strategy": null
+ },
+ "name": "audio_image_feed_segments_feed_segment_id_fkey",
+ "on_delete": null,
+ "on_update": null,
+ "primary_key?": true,
+ "schema": null,
+ "table": "feed_segments"
+ },
+ "size": null,
+ "source": "feed_segment_id",
+ "type": "uuid"
+ },
+ {
+ "allow_nil?": true,
+ "default": "nil",
+ "generated?": false,
+ "primary_key?": false,
+ "references": {
+ "deferrable": false,
+ "destination_attribute": "id",
+ "destination_attribute_default": null,
+ "destination_attribute_generated": null,
+ "index?": false,
+ "match_type": null,
+ "match_with": null,
+ "multitenancy": {
+ "attribute": null,
+ "global": null,
+ "strategy": null
+ },
+ "name": "audio_image_feed_segments_audio_image_id_fkey",
+ "on_delete": null,
+ "on_update": null,
+ "primary_key?": true,
+ "schema": null,
+ "table": "audio_images"
+ },
+ "size": null,
+ "source": "audio_image_id",
+ "type": "uuid"
+ }
+ ],
+ "base_filter": null,
+ "check_constraints": [],
+ "custom_indexes": [
+ {
+ "all_tenants?": false,
+ "concurrently": false,
+ "error_fields": [
+ "feed_segment_id"
+ ],
+ "fields": [
+ {
+ "type": "atom",
+ "value": "feed_segment_id"
+ }
+ ],
+ "include": null,
+ "message": null,
+ "name": null,
+ "nulls_distinct": true,
+ "prefix": null,
+ "table": null,
+ "unique": false,
+ "using": null,
+ "where": null
+ },
+ {
+ "all_tenants?": false,
+ "concurrently": false,
+ "error_fields": [
+ "audio_image_id"
+ ],
+ "fields": [
+ {
+ "type": "atom",
+ "value": "audio_image_id"
+ }
+ ],
+ "include": null,
+ "message": null,
+ "name": null,
+ "nulls_distinct": true,
+ "prefix": null,
+ "table": null,
+ "unique": false,
+ "using": null,
+ "where": null
+ }
+ ],
+ "custom_statements": [],
+ "has_create_action": true,
+ "hash": "D8A1FF82B91190958A59F7146B9D440787938C57346C22CB8B90BF3DF6A76D5A",
+ "identities": [
+ {
+ "all_tenants?": false,
+ "base_filter": null,
+ "index_name": "audio_image_feed_segments_unique_audio_image_index",
+ "keys": [
+ {
+ "type": "atom",
+ "value": "feed_segment_id"
+ },
+ {
+ "type": "atom",
+ "value": "audio_image_id"
+ }
+ ],
+ "name": "unique_audio_image",
+ "nils_distinct?": true,
+ "where": null
+ }
+ ],
+ "multitenancy": {
+ "attribute": null,
+ "global": null,
+ "strategy": null
+ },
+ "repo": "Elixir.Orcasite.Repo",
+ "schema": null,
+ "table": "audio_image_feed_segments"
+}