immich/mobile/lib/infrastructure/entities/merged_asset.drift

import 'remote_asset.entity.dart';
import 'local_asset.entity.dart';
import 'stack.entity.dart';

mergedAsset: SELECT * FROM
(
	SELECT
		rae.id as remote_id,
		lae.id as local_id,
		rae.name,
		rae."type",
		rae.created_at,
		rae.updated_at,
		rae.width,
		rae.height,
		rae.duration_in_seconds,
		rae.is_favorite,
		rae.thumb_hash,
		rae.checksum,
		rae.owner_id,
		rae.live_photo_video_id,
		0 as orientation,
		rae.stack_id,
		COALESCE(stack_count.total_count, 0) AS stack_count
	FROM
		remote_asset_entity rae
	LEFT JOIN
		local_asset_entity lae ON rae.checksum  = lae.checksum
	LEFT JOIN
        stack_entity se ON rae.stack_id = se.id
	LEFT JOIN
        (SELECT 
            stack_id,
            COUNT(*) AS total_count
         FROM remote_asset_entity 
         WHERE deleted_at IS NULL 
           AND visibility = 0
           AND stack_id IS NOT NULL
         GROUP BY stack_id
        ) AS stack_count ON rae.stack_id = stack_count.stack_id
	WHERE
		rae.deleted_at IS NULL
		AND rae.visibility = 0
		AND rae.owner_id in ?
		AND (
			rae.stack_id IS NULL
			OR rae.id = se.primary_asset_id
		)
	UNION ALL
	SELECT
		NULL as remote_id,
		lae.id as local_id,
		lae.name,
		lae."type",
		lae.created_at,
		lae.updated_at,
		lae.width,
		lae.height,
		lae.duration_in_seconds,
		lae.is_favorite,
		NULL as thumb_hash,
		lae.checksum,
		NULL as owner_id,
		NULL as live_photo_video_id,
		lae.orientation,
		NULL as stack_id,
		0 AS stack_count
	FROM
		local_asset_entity lae
	LEFT JOIN
		remote_asset_entity rae ON rae.checksum = lae.checksum
	WHERE
		rae.id IS NULL
)
ORDER BY created_at DESC
LIMIT $limit;

mergedBucket(:group_by AS INTEGER):
SELECT
	COUNT(*) as asset_count,
	 CASE
        WHEN :group_by = 0 THEN STRFTIME('%Y-%m-%d', created_at, 'localtime') -- day
        WHEN :group_by = 1 THEN STRFTIME('%Y-%m', created_at, 'localtime') -- month
    END AS bucket_date
FROM
(
	SELECT
		rae.name,
		rae.created_at
	FROM
		remote_asset_entity rae
	LEFT JOIN
		local_asset_entity lae  ON rae.checksum  = lae.checksum
	LEFT JOIN
        stack_entity se ON rae.stack_id = se.id
	WHERE
		rae.deleted_at IS NULL
		AND rae.visibility = 0
		AND rae.owner_id in ?
		AND (
			rae.stack_id IS NULL
			OR rae.id = se.primary_asset_id
		)
	UNION ALL
	SELECT
		lae.name,
		lae.created_at
	FROM
		local_asset_entity lae
	LEFT JOIN
		remote_asset_entity rae ON rae.checksum = lae.checksum
	WHERE
		rae.id IS NULL
)
GROUP BY bucket_date
ORDER BY bucket_date DESC;