/* Copyright 2017 The Cobalt Authors. All Rights Reserved.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "cobalt/web/message_event.h"

#include <string>
#include <utility>

#include "base/basictypes.h"
#include "cobalt/base/polymorphic_downcast.h"
#include "cobalt/script/v8c/conversion_helpers.h"
#include "cobalt/script/v8c/entry_scope.h"
#include "cobalt/script/v8c/v8c_exception_state.h"
#include "cobalt/web/context.h"
#include "cobalt/web/environment_settings.h"
#include "cobalt/web/environment_settings_helper.h"
#include "starboard/common/string.h"
#include "starboard/memory.h"
#include "v8/include/v8.h"

namespace cobalt {
namespace web {

namespace {
const char* const kResponseTypes[] = {"text", "blob", "arraybuffer", "any"};

COMPILE_ASSERT(arraysize(kResponseTypes) == MessageEvent::kResponseTypeMax,
               enum_and_array_size_mismatch);

}  // namespace

MessageEvent::MessageEvent(const std::string& type,
                           const MessageEventInit& init_dict)
    : Event(type, init_dict), response_type_(kAny) {
  if (init_dict.has_data() && init_dict.data()) {
    structured_clone_ =
        std::make_unique<script::StructuredClone>(*(init_dict.data()));
  }
  if (init_dict.has_origin()) {
    origin_ = init_dict.origin();
  }
  if (init_dict.has_last_event_id()) {
    last_event_id_ = init_dict.last_event_id();
  }
  if (init_dict.has_source()) {
    source_ = init_dict.source();
  }
  if (init_dict.has_ports()) {
    ports_ = init_dict.ports();
  }
}

// static
std::string MessageEvent::GetResponseTypeAsString(
    const MessageEvent::ResponseType response_type) {
  DCHECK_GE(response_type, kText);
  DCHECK_LT(response_type, kResponseTypeMax);
  return kResponseTypes[response_type];
}

// static
MessageEvent::ResponseType MessageEvent::GetResponseType(
    base::StringPiece to_match) {
  for (std::size_t i = 0; i != arraysize(kResponseTypes); ++i) {
    if (strncmp(kResponseTypes[i], to_match.data(), to_match.size()) == 0) {
      return MessageEvent::ResponseType(i);
    }
  }
  return kResponseTypeMax;
}

MessageEvent::Response MessageEvent::data(
    script::EnvironmentSettings* settings) {
  switch (response_type_) {
    case kText: {
      if (!data_io_buffer_) {
        return Response(script::Handle<script::ValueHandle>());
      }
      // TODO: Find a way to remove two copies of data here.
      std::string string_response(data_io_buffer_->data(),
                                  data_io_buffer_->size());
      return Response(string_response);
    }
    case kBlob:
    case kArrayBuffer: {
      auto* global_environment = web::get_global_environment(settings);
      if (!data_io_buffer_ || !global_environment) {
        return Response(script::Handle<script::ValueHandle>());
      }
      auto buffer_copy = script::ArrayBuffer::New(
          global_environment, data_io_buffer_->data(), data_io_buffer_->size());
      script::Handle<script::ArrayBuffer> response_buffer =
          std::move(buffer_copy);
      if (response_type_ == kBlob) {
        DCHECK(settings);
        scoped_refptr<Blob> blob = new Blob(settings, response_buffer);
        return Response(blob);
      }
      return Response(response_buffer);
    }
    case kAny: {
      if (!structured_clone_) {
        return Response(script::Handle<script::ValueHandle>());
      }
      auto* isolate = web::get_isolate(settings);
      script::v8c::EntryScope entry_scope(isolate);
      return Response(structured_clone_->Deserialize(isolate));
    }
    default:
      NOTREACHED() << "Invalid response type.";
      return Response(script::Handle<script::ValueHandle>());
  }
}

}  // namespace web
}  // namespace cobalt