Method v1AuthAllowed

test/tsd/TestQueryRpc.java:738–760

()

  }

  @Test
  public void v1AuthAllowed() throws Exception {
    final TSDB tsdb = NettyMocks.getMockedHTTPTSDBWithAuthEnabled(AuthStatus.SUCCESS);
    when(tsdb.newQuery()).thenReturn(query_result);
    when(query_result.configureFromQuery((TSQuery)any(), anyInt()))
        .thenReturn(Deferred.fromResult(null));
    when(query_result.runAsync())
        .thenReturn(Deferred.fromResult(new DataPoints[0]));

    final DataPoints[] datapoints = new DataPoints[1];
    datapoints[0] = new MockDataPoints().getMock();
    when(query_result.runAsync()).thenReturn(Deferred.fromResult(datapoints));

    final HttpQuery query = NettyMocks.postQuery(tsdb,"/api/query",
            "{\"start\":\"1h-ago\",\"queries\":" +
                    "[{\"metric\":\"sys.cpu.user\",\"aggregator\":\"sum\"}]}");

    NettyMocks.mockChannelFuture(query);
    rpc.execute(tsdb, query);
    final String json = query.response().getContent().toString(Charset.forName("UTF-8"));
    assertTrue(json.contains("\"metric\":\"system.cpu.user\""));
    assertEquals(HttpResponseStatus.OK, query.response().getStatus());
  }

  @Test
  public void v1AuthUnauthorized() throws Exception {