immich/server/src/dtos/duplicate.dto.ts

import { IsNotEmpty } from 'class-validator';
import { groupBy } from 'lodash';
import { AssetResponseDto } from 'src/dtos/asset-response.dto';
import { ValidateUUID } from 'src/validation';

export class DuplicateResponseDto {
  duplicateId!: string;
  assets!: AssetResponseDto[];
}

export class ResolveDuplicatesDto {
  @IsNotEmpty()
  @ValidateUUID({ each: true })
  assetIds!: string[];
}

export function mapDuplicateResponse(assets: AssetResponseDto[]): DuplicateResponseDto[] {
  const result = [];

  const grouped = groupBy(assets, (a) => a.duplicateId);

  for (const [duplicateId, assets] of Object.entries(grouped)) {
    result.push({ duplicateId, assets });
  }

  return result;
}