class Multiwoven::Integrations::Source::AmazonS3::Client

def list_files_in_folder(bucket_name, folder_path)
  folder_path = folder_path.end_with?("/") ? folder_path : "#{folder_path}/"
  bucket = @s3_resource.bucket(bucket_name)
  bucket.objects(prefix: folder_path).reject { |object| object.key == folder_path }.map do |object|
    RecordMessage.new(
      data: {
        file_name: File.basename(object.key),
        file_path: object.key,
        size: object.content_length,
        file_type: File.extname(object.key).sub(".", ""),
        created_date: object.last_modified.to_s,
        modified_date: object.last_modified.to_s
      },
      emitted_at: Time.now.to_i
    ).to_multiwoven_message
  end
end