# frozen_string_literal: true

module Aserto
  module Directory
    module V3
      module Importer
        #
        # Imports objects and relations
        #
        # @param Array[Hash] data to be imported
        #
        # op_code = {
        #   OPCODE_UNKNOWN                                              = ;
        #   OPCODE_SET                                                  = 1;
        #   OPCODE_DELETE                                               = 2;
        # }
        # @example
        #   directory.import(
        #     [
        #       { op_code: 1, object: { type: "user", id: "import-user" } },
        #       { op_code: 1, object: { type: "group", id: "import-group" } },
        #       {
        #         op_code: 1,
        #         relation: {
        #           object_type: "user",
        #           object_id: "import-user",
        #           relation: "member",
        #           subject_id: "import-group",
        #           subject_type: "group"
        #         }
        #       }
        #     ]
        #   )
        def import(data)
          data.map! do |value|
            if value.dig(:object, :properties)
              require "google/protobuf/well_known_types"

              value[:object][:properties] = Google::Protobuf::Struct.from_hash(
                value[:object][:properties].transform_keys(&:to_s)
              )
            end

            Aserto::Directory::Importer::V3::ImportRequest.new(value)
          end
          operation = importer.import(data, return_op: true)
          response = operation.execute
          response.each { |r| } # ensures that the server sends trailing data
          operation.wait
        end
      end
    end
  end
end