fix: set first artist listed as primary by default (#81)

db/queries/release.sql

@@ -74,8 +74,8 @@ JOIN artist_releases ar ON r.id = ar.release_id
 WHERE ar.artist_id = $1;
 
 -- name: AssociateArtistToRelease :exec
-INSERT INTO artist_releases (artist_id, release_id)
+INSERT INTO artist_releases (artist_id, release_id, is_primary)
-VALUES ($1, $2)
+VALUES ($1, $2, $3)
 ON CONFLICT DO NOTHING;
 
 -- name: GetReleasesWithoutImages :many

db/queries/track.sql

@@ -4,8 +4,8 @@ VALUES ($1, $2, $3)
 RETURNING *;
 
 -- name: AssociateArtistToTrack :exec
-INSERT INTO artist_tracks (artist_id, track_id)
+INSERT INTO artist_tracks (artist_id, track_id, is_primary)
-VALUES ($1, $2)
+VALUES ($1, $2, $3)
 ON CONFLICT DO NOTHING;
 
 -- name: GetTrack :one

internal/catalog/submit_listen_test.go

@@ -203,6 +203,22 @@ func TestSubmitListen_CreateAllNoMbzIDsNoArtistNamesNoReleaseTitle(t *testing.T)
     )`, "Madeline Kenney")
 	require.NoError(t, err)
 	assert.True(t, exists, "expected featured artist to be created")
+
+	// assert that Rat Tally is the primary artist
+	exists, err = store.RowExists(ctx, `
+    SELECT EXISTS (
+      SELECT 1 FROM artist_tracks
+      WHERE artist_id = $1 AND is_primary = $2
+    )`, 1, true)
+	require.NoError(t, err)
+	assert.True(t, exists, "expected primary artist to be marked as primary for track")
+	exists, err = store.RowExists(ctx, `
+    SELECT EXISTS (
+      SELECT 1 FROM artist_releases
+      WHERE artist_id = $1 AND is_primary = $2
+    )`, 1, true)
+	require.NoError(t, err)
+	assert.True(t, exists, "expected primary artist to be marked as primary for release")
 }
 
 func TestSubmitListen_MatchAllMbzIDs(t *testing.T) {

internal/db/psql/album.go

@@ -144,6 +144,7 @@ func (d *Psql) SaveAlbum(ctx context.Context, opts db.SaveAlbumOpts) (*models.Al
 		err = qtx.AssociateArtistToRelease(ctx, repository.AssociateArtistToReleaseParams{
 			ArtistID:  artistId,
 			ReleaseID: r.ID,
+			IsPrimary: opts.ArtistIDs[0] == artistId,
 		})
 		if err != nil {
 			return nil, fmt.Errorf("SaveAlbum: AssociateArtistToRelease: %w", err)

internal/db/psql/track.go

@@ -132,8 +132,9 @@ func (d *Psql) SaveTrack(ctx context.Context, opts db.SaveTrackOpts) (*models.Tr
 	// insert associated artists
 	for _, aid := range opts.ArtistIDs {
 		err = qtx.AssociateArtistToTrack(ctx, repository.AssociateArtistToTrackParams{
-			ArtistID: aid,
+			ArtistID:  aid,
-			TrackID:  trackRow.ID,
+			TrackID:   trackRow.ID,
+			IsPrimary: opts.ArtistIDs[0] == aid,
 		})
 		if err != nil {
 			return nil, fmt.Errorf("SaveTrack: AssociateArtistToTrack: %w", err)

internal/repository/alias.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: alias.sql
 
 package repository

internal/repository/artist.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: artist.sql
 
 package repository

internal/repository/db.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 
 package repository
 

internal/repository/etc.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: etc.sql
 
 package repository

internal/repository/listen.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: listen.sql
 
 package repository

internal/repository/models.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 
 package repository
 

internal/repository/release.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: release.sql
 
 package repository
@@ -14,18 +14,19 @@ import (
 )
 
 const associateArtistToRelease = `-- name: AssociateArtistToRelease :exec
-INSERT INTO artist_releases (artist_id, release_id)
+INSERT INTO artist_releases (artist_id, release_id, is_primary)
-VALUES ($1, $2)
+VALUES ($1, $2, $3)
 ON CONFLICT DO NOTHING
 `
 
 type AssociateArtistToReleaseParams struct {
 	ArtistID  int32
 	ReleaseID int32
+	IsPrimary bool
 }
 
 func (q *Queries) AssociateArtistToRelease(ctx context.Context, arg AssociateArtistToReleaseParams) error {
-	_, err := q.db.Exec(ctx, associateArtistToRelease, arg.ArtistID, arg.ReleaseID)
+	_, err := q.db.Exec(ctx, associateArtistToRelease, arg.ArtistID, arg.ReleaseID, arg.IsPrimary)
 	return err
 }
 

internal/repository/search.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: search.sql
 
 package repository

internal/repository/sessions.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: sessions.sql
 
 package repository

internal/repository/track.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: track.sql
 
 package repository
@@ -13,18 +13,19 @@ import (
 )
 
 const associateArtistToTrack = `-- name: AssociateArtistToTrack :exec
-INSERT INTO artist_tracks (artist_id, track_id)
+INSERT INTO artist_tracks (artist_id, track_id, is_primary)
-VALUES ($1, $2)
+VALUES ($1, $2, $3)
 ON CONFLICT DO NOTHING
 `
 
 type AssociateArtistToTrackParams struct {
-	ArtistID int32
+	ArtistID  int32
-	TrackID  int32
+	TrackID   int32
+	IsPrimary bool
 }
 
 func (q *Queries) AssociateArtistToTrack(ctx context.Context, arg AssociateArtistToTrackParams) error {
-	_, err := q.db.Exec(ctx, associateArtistToTrack, arg.ArtistID, arg.TrackID)
+	_, err := q.db.Exec(ctx, associateArtistToTrack, arg.ArtistID, arg.TrackID, arg.IsPrimary)
 	return err
 }
 

internal/repository/users.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: users.sql
 
 package repository

internal/repository/year.sql.go

@@ -1,6 +1,6 @@
 // Code generated by sqlc. DO NOT EDIT.
 // versions:
-//   sqlc v1.29.0
+//   sqlc v1.30.0
 // source: year.sql
 
 package repository