/*
 *
 * A test that verifies that our results are identical to proto2 for a
 * given proto type and input protobuf.
 */

#define __STDC_LIMIT_MACROS  // So we get UINT32_MAX
#include <assert.h>
#include <google/protobuf/descriptor.h>
#include <google/protobuf/dynamic_message.h>
#include <google/protobuf/message.h>
#include <google/protobuf/text_format.h>
#include <google/protobuf/wire_format_lite.h>
#include <inttypes.h>
#include <stdint.h>
#include <stdio.h>
#include <stdlib.h>
#include "tests/google_messages.pb.h"
#include "tests/upb_test.h"
#include "upb/bindings/googlepb/bridge.h"
#include "upb/def.h"
#include "upb/handlers.h"
#include "upb/pb/decoder.h"
#include "upb/pb/glue.h"
#include "upb/pb/varint.int.h"

// Pull in string data from tests/google_message{1,2}.dat
// (the .h files are generated with xxd).
const unsigned char message1_data[] = {
#include "tests/google_message1.h"
};

const unsigned char message2_data[] = {
#include "tests/google_message2.h"
};

void compare_metadata(const google::protobuf::Descriptor* d,
                      const upb::MessageDef *upb_md) {
  ASSERT(d->field_count() == upb_md->field_count());
  for (upb::MessageDef::const_field_iterator i = upb_md->field_begin();
       i != upb_md->field_end(); ++i) {
    const upb::FieldDef* upb_f = *i;
    const google::protobuf::FieldDescriptor *proto2_f =
        d->FindFieldByNumber(upb_f->number());
    ASSERT(upb_f);
    ASSERT(proto2_f);
    ASSERT(upb_f->number() == (uint32_t)proto2_f->number());
    ASSERT(std::string(upb_f->name()) == proto2_f->name());
    ASSERT(upb_f->descriptor_type() ==
           static_cast<upb::FieldDef::DescriptorType>(proto2_f->type()));
    ASSERT(upb_f->IsSequence() == proto2_f->is_repeated());
  }
}

void print_diff(const google::protobuf::Message& msg1,
                const google::protobuf::Message& msg2) {
  std::string text_str1;
  std::string text_str2;
  google::protobuf::TextFormat::PrintToString(msg1, &text_str1);
  google::protobuf::TextFormat::PrintToString(msg2, &text_str2);
  fprintf(stderr, "str1: %s, str2: %s\n", text_str1.c_str(), text_str2.c_str());
}

void parse_and_compare(google::protobuf::Message *msg1,
                       google::protobuf::Message *msg2,
                       const upb::Handlers *protomsg_handlers,
                       const char *str, size_t len, bool allow_jit) {
  // Parse to both proto2 and upb.
  ASSERT(msg1->ParseFromArray(str, len));

  upb::pb::CodeCache cache;
  ASSERT(cache.set_allow_jit(allow_jit));
  upb::reffed_ptr<const upb::pb::DecoderMethod> decoder_method(
      cache.GetDecoderMethod(upb::pb::DecoderMethodOptions(protomsg_handlers)));

  upb::Status status;
  upb::Environment env;
  env.ReportErrorsTo(&status);
  upb::Sink protomsg_sink(protomsg_handlers, msg2);
  upb::pb::Decoder* decoder =
      upb::pb::Decoder::Create(&env, decoder_method.get(), &protomsg_sink);

  msg2->Clear();
  bool ok = upb::BufferSource::PutBuffer(str, len, decoder->input());
  if (!ok) {
    fprintf(stderr, "error parsing: %s\n", status.error_message());
    print_diff(*msg1, *msg2);
  }
  ASSERT(ok);
  ASSERT(status.ok());

  // Would like to just compare the message objects themselves,  but
  // unfortunately MessageDifferencer is not part of the open-source release of
  // proto2, so we compare their serialized strings, which we expect will be
  // equivalent.
  std::string str1;
  std::string str2;
  msg1->SerializeToString(&str1);
  msg2->SerializeToString(&str2);
  if (str1 != str2) {
    print_diff(*msg1, *msg2);
  }
  ASSERT(str1 == str2);
  ASSERT(std::string(str, len) == str2);
}

void test_zig_zag() {
  for (uint64_t num = 5; num * 1.5 < UINT64_MAX; num *= 1.5) {
    ASSERT(upb_zzenc_64(num) ==
           google::protobuf::internal::WireFormatLite::ZigZagEncode64(num));
    if (num < UINT32_MAX) {
      ASSERT(upb_zzenc_32(num) ==
             google::protobuf::internal::WireFormatLite::ZigZagEncode32(num));
    }
  }

}

extern "C" {

int run_tests(int argc, char *argv[]) {
  UPB_UNUSED(argc);
  UPB_UNUSED(argv);
  UPB_UNUSED(message1_data);
  UPB_UNUSED(message2_data);
  size_t len = sizeof(MESSAGE_DATA_IDENT);
  const char *str = (const char*)MESSAGE_DATA_IDENT;

  MESSAGE_CIDENT msg1;
  MESSAGE_CIDENT msg2;

  upb::reffed_ptr<const upb::Handlers> h(
      upb::googlepb::WriteHandlers::New(msg1));

  compare_metadata(msg1.GetDescriptor(), h->message_def());

  // Run twice to test proper object reuse.
  parse_and_compare(&msg1, &msg2, h.get(), str, len, false);
  parse_and_compare(&msg1, &msg2, h.get(), str, len, true);
  parse_and_compare(&msg1, &msg2, h.get(), str, len, false);
  parse_and_compare(&msg1, &msg2, h.get(), str, len, true);

  // Test with DynamicMessage.
  google::protobuf::DynamicMessageFactory* factory =
      new google::protobuf::DynamicMessageFactory;
  const google::protobuf::Message* prototype =
      factory->GetPrototype(msg1.descriptor());
  google::protobuf::Message* dyn_msg1 = prototype->New();
  google::protobuf::Message* dyn_msg2 = prototype->New();
  h = upb::googlepb::WriteHandlers::New(*dyn_msg1);
  parse_and_compare(dyn_msg1, dyn_msg2, h.get(), str, len, false);
  parse_and_compare(dyn_msg1, dyn_msg2, h.get(), str, len, true);
  delete dyn_msg1;
  delete dyn_msg2;
  delete factory;

  test_zig_zag();

  printf("All tests passed, %d assertions.\n", num_assertions);

  google::protobuf::ShutdownProtobufLibrary();
  return 0;
}

}