db/unattached-media: refactor queries, DRY

src/db/unattached-media.ts

@@ -10,6 +10,7 @@ interface UnattachedMedia {
   uploaded_at: Date;
 }
 
+/** Add unattached media into the database. */
 async function insertUnattachedMedia(media: Omit<UnattachedMedia, 'id' | 'uploaded_at'>) {
   const result = {
     id: uuid62.v4(),
@@ -24,8 +25,8 @@ async function insertUnattachedMedia(media: Omit<UnattachedMedia, 'id' | 'upload
   return result;
 }
 
-/** Find attachments that exist but aren't attached to any events. */
+/** Select query for unattached media. */
-function getUnattachedMedia(until: Date) {
+function selectUnattachedMediaQuery() {
   return db.selectFrom('unattached_media')
     .select([
       'unattached_media.id',
@@ -33,27 +34,27 @@ function getUnattachedMedia(until: Date) {
       'unattached_media.url',
       'unattached_media.data',
       'unattached_media.uploaded_at',
-    ])
+    ]);
+}
+
+/** Find attachments that exist but aren't attached to any events. */
+function getUnattachedMedia(until: Date) {
+  return selectUnattachedMediaQuery()
     .leftJoin('tags', 'unattached_media.url', 'tags.value')
     .where('uploaded_at', '<', until)
     .execute();
 }
 
+/** Delete unattached media by URL. */
 function deleteUnattachedMediaByUrl(url: string) {
   return db.deleteFrom('unattached_media')
     .where('url', '=', url)
     .execute();
 }
 
+/** Get unattached media by IDs. */
 function getUnattachedMediaByIds(ids: string[]) {
-  return db.selectFrom('unattached_media')
+  return selectUnattachedMediaQuery()
-    .select([
-      'unattached_media.id',
-      'unattached_media.pubkey',
-      'unattached_media.url',
-      'unattached_media.data',
-      'unattached_media.uploaded_at',
-    ])
     .where('id', 'in', ids)
     .execute();
 }