Publish

1 files changed, 124 insertions, 0 deletions

diff --git a/documentapi/src/tests/messages/error_codes_test.cpp b/documentapi/src/tests/messages/error_codes_test.cpp
new file mode 100644
index 00000000000..1714fb70a04
--- /dev/null
+++ b/documentapi/src/tests/messages/error_codes_test.cpp
@@ -0,0 +1,124 @@
+// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+// Copyright 2015 Yahoo Technologies Norway AS
+#include <vespa/vespalib/testkit/testapp.h>
+#include <vespa/documentapi/messagebus/documentprotocol.h>
+#include <iostream>
+#include <fstream>
+#include <sstream>
+#include <string>
+#include <exception>
+#include <map>
+
+using NamedErrorCodes = std::map<std::string, uint32_t>;
+
+// DocumentAPI C++ module uses Ye Olde Test Framework.
+class ErrorCodesTest : public vespalib::TestApp {
+    int Main() override;
+    void error_codes_match_java_definitions();
+    NamedErrorCodes all_document_protocol_error_codes();
+};
+
+TEST_APPHOOK(ErrorCodesTest);
+
+// ERROR_CODE_KV(FOO) -> {"FOO", DocumentProtocol::FOO}
+#define ERROR_CODE_KV(code_name) \
+    {#code_name, DocumentProtocol::code_name}
+
+NamedErrorCodes
+ErrorCodesTest::all_document_protocol_error_codes()
+{
+    using documentapi::DocumentProtocol;
+    return {
+        ERROR_CODE_KV(ERROR_MESSAGE_IGNORED),
+        ERROR_CODE_KV(ERROR_POLICY_FAILURE),
+        ERROR_CODE_KV(ERROR_DOCUMENT_NOT_FOUND),
+        // Error code not consistently named between languages!
+        // Java: ERROR_DOCUMENT_EXISTS, C++: ERROR_EXISTS
+        // Names must be consistent in test or checking will fail.
+        {"ERROR_DOCUMENT_EXISTS", DocumentProtocol::ERROR_EXISTS},
+        ERROR_CODE_KV(ERROR_REJECTED),
+        ERROR_CODE_KV(ERROR_NOT_IMPLEMENTED),
+        ERROR_CODE_KV(ERROR_ILLEGAL_PARAMETERS),
+        ERROR_CODE_KV(ERROR_UNKNOWN_COMMAND),
+        ERROR_CODE_KV(ERROR_NO_SPACE),
+        ERROR_CODE_KV(ERROR_IGNORED),
+        ERROR_CODE_KV(ERROR_INTERNAL_FAILURE),
+        ERROR_CODE_KV(ERROR_TEST_AND_SET_CONDITION_FAILED),
+        ERROR_CODE_KV(ERROR_PROCESSING_FAILURE),
+        ERROR_CODE_KV(ERROR_TIMESTAMP_EXIST),
+        ERROR_CODE_KV(ERROR_NODE_NOT_READY),
+        ERROR_CODE_KV(ERROR_WRONG_DISTRIBUTION),
+        ERROR_CODE_KV(ERROR_ABORTED),
+        ERROR_CODE_KV(ERROR_BUSY),
+        ERROR_CODE_KV(ERROR_NOT_CONNECTED),
+        ERROR_CODE_KV(ERROR_DISK_FAILURE),
+        ERROR_CODE_KV(ERROR_IO_FAILURE),
+        ERROR_CODE_KV(ERROR_BUCKET_NOT_FOUND),
+        ERROR_CODE_KV(ERROR_BUCKET_DELETED),
+        ERROR_CODE_KV(ERROR_STALE_TIMESTAMP),
+        ERROR_CODE_KV(ERROR_SUSPENDED)
+    };
+}
+
+#undef ERROR_CODE_KV
+
+namespace {
+
+std::string read_file(const std::string& file_name) {
+    std::ifstream ifs(file_name);
+    if (!ifs.is_open()) {
+        throw std::runtime_error("file '" + file_name + "' does not exist");
+    }
+    std::ostringstream oss;
+    oss << ifs.rdbuf();
+    return oss.str();
+}
+
+void write_file(const std::string& file_name,
+                const std::string& content)
+{
+    std::ofstream ofs(file_name, std::ios_base::trunc);
+    ofs << content;
+}
+
+std::string to_sorted_key_value_string(const NamedErrorCodes& codes) {
+    std::ostringstream os;
+    bool emit_newline = false;
+    for (auto& kv : codes) {
+        if (emit_newline) {
+            os << '\n';
+        }
+        os << kv.first << ' ' << kv.second;
+        emit_newline = true;
+    }
+    return os.str();
+}
+
+std::string path_prefixed(const std::string& file_name) {
+    return "../../../test/crosslanguagefiles/" + file_name;
+}
+
+} // anon ns
+
+void
+ErrorCodesTest::error_codes_match_java_definitions()
+{
+    NamedErrorCodes codes(all_document_protocol_error_codes());
+    auto cpp_golden_file = path_prefixed("HEAD-cpp-golden-error-codes.txt");
+    auto cpp_golden_data = to_sorted_key_value_string(codes);
+    write_file(cpp_golden_file, cpp_golden_data);
+
+    auto java_golden_file = path_prefixed("HEAD-java-golden-error-codes.txt");
+    auto java_golden_data = read_file(java_golden_file);
+    EXPECT_EQUAL(cpp_golden_data, java_golden_data);
+}
+
+int
+ErrorCodesTest::Main()
+{
+    TEST_INIT("error_codes_test");
+    error_codes_match_java_definitions();
+    TEST_FLUSH();
+    TEST_DONE();
+}
+