CCBC-1647: Handle server-side query timeout (status 1080)

Motivation
==========
The 1080 (timeout) query status is not being handled. This means that if the server times out before the client, we return LCB_SUCCESS with an incomplete set of rows instead of LCB_ERR_TIMEOUT. Typically the client will time out before the server, however, it's possible for the server to time out first if the query grace period is set to something high enough.

Changes
=======
Return LCB_ERR_TIMEOUT when query returns the 1080 status code in the response body

Results
=======
Test passes

Change-Id: I309198fb864c0eb8e3050ac64391b30833c85a5e
Reviewed-on: https://review.couchbase.org/c/libcouchbase/+/215620
Reviewed-by: Sergey Avseyev <[email protected]>
Tested-by: Build Bot <[email protected]>

Author: DemetrisChr

src/n1ql/query_handle.cc

@@ -122,6 +122,9 @@ bool lcb_QUERY_HANDLE_::parse_meta(const char *row, size_t row_len, lcb_STATUS &
         if (code.isNumeric()) {
             first_error.code = code.asUInt();
             switch (first_error.code) {
+                case 1080:
+                    rc = LCB_ERR_TIMEOUT;
+                    break;
                 case 3000:
                     rc = LCB_ERR_PARSING_FAILURE;
                     break;

tests/iotests/t_n1ql.cc

@@ -1162,3 +1162,32 @@ TEST_F(QueryUnitTest, testReadOnlyWithNoResults)
     ASSERT_STATUS_EQ(LCB_SUCCESS, res.rc);
     ASSERT_EQ(0, res.rows.size());
 }
+
+TEST_F(QueryUnitTest, testQueryServerTimeout)
+{
+    SKIP_IF_MOCK()
+    HandleWrap hw;
+    lcb_INSTANCE *instance;
+    createConnection(hw, &instance);
+
+    // Setting a very large grace period so the server-side timeout is returned before the client times out
+    lcb_cntl_setu32(instance, LCB_CNTL_QUERY_GRACE_PERIOD, 100000000);
+
+    N1QLResult res;
+    lcb_CMDQUERY *cmd;
+    lcb_cmdquery_create(&cmd);
+    string query = "WITH x AS (ARRAY_RANGE(0,100000)) SELECT * FROM x";
+    lcb_cmdquery_statement(cmd, query.c_str(), query.size());
+    lcb_cmdquery_timeout(cmd, 10000);
+    lcb_cmdquery_callback(cmd, rowcb);
+
+    lcb_QUERY_HANDLE *handle = nullptr;
+    lcb_cmdquery_handle(cmd, &handle);
+    lcb_STATUS rc = lcb_query(instance, &res, cmd);
+    lcb_cmdquery_destroy(cmd);
+    ASSERT_STATUS_EQ(LCB_SUCCESS, rc);
+    ASSERT_TRUE(handle != nullptr);
+    lcb_wait(instance, LCB_WAIT_DEFAULT);
+    ASSERT_TRUE(res.called);
+    ASSERT_STATUS_EQ(LCB_ERR_TIMEOUT, res.rc) << "http=" << res.htcode << ", meta=" << res.meta;
+}