buf.append(",\"labels\":[");
                    for (int i = 0; i < item.getTags().length; i++) {
                        if (i > 0) {
                            buf.append(',');
                        }
                        buf.append('\"').append(StringEscapeUtils.escapeJson(item.getTags()[i])).append('\"');
                    }
                    buf.append(']');

        assertEquals(origin, handler.getLastOrigin());
        assertSame(mockRequest, handler.getLastRequest());
        assertSame(mockResponse, handler.getLastResponse());
        assertEquals(0, mockResponse.getStatus()); // Status not set for non-OPTIONS
    }

    // Test with valid Origin and CorsHandler found (POST request)
    @Test
    public void test_doFilter_withCorsHandler_post() throws IOException, ServletException {

      boolean isDone() {
        return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0;
      }

      /** Checks if the state is {@link #CANCELLED} or {@link #INTERRUPTED}. */
      boolean isCancelled() {
        return (getState() & (CANCELLED | INTERRUPTED)) != 0;
      }

      /** Checks if the state is {@link #INTERRUPTED}. */

        mockRequest.setRequestURI("/search");

        testableFilter.doFilter(mockRequest, mockResponse, mockFilterChain);

        assertTrue(mockFilterChain.wasDoFilterCalled());
        assertEquals(0, mockResponse.getStatus());
    }

    @Test
    public void test_doFilter_apiDisabled() throws IOException, ServletException {
        setConfig(100, 100);
        testableFilter.setCpuPercent((short) 90);

      boolean isDone() {
        return (getState() & (COMPLETED | CANCELLED | INTERRUPTED)) != 0;
      }

      /** Checks if the state is {@link #CANCELLED} or {@link #INTERRUPTED}. */
      boolean isCancelled() {
        return (getState() & (CANCELLED | INTERRUPTED)) != 0;
      }

      /** Checks if the state is {@link #INTERRUPTED}. */

        indexUpdater.start();

        // Poll for thread to process exceptions
        for (int i = 0; i < 20; i++) {
            if (!indexUpdater.isAlive() || indexUpdater.getState() == Thread.State.WAITING
                    || indexUpdater.getState() == Thread.State.TIMED_WAITING) {
                break;
            }
            Thread.sleep(100);
        }

        // Clean up the thread

    while (!isThreadBlockedOnInstanceOf(t, blocker)) {
      if (t.getState() == Thread.State.TERMINATED) {
        throw new RuntimeException("Thread " + t + " exited unexpectedly");
      }
      Thread.sleep(1);
    }
  }

  private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) {
    return t.getState() == Thread.State.WAITING && blocker.isInstance(LockSupport.getBlocker(t));
  }

    while (!isThreadBlockedOnInstanceOf(t, blocker)) {
      if (t.getState() == Thread.State.TERMINATED) {
        throw new RuntimeException("Thread " + t + " exited unexpectedly");
      }
      Thread.sleep(1);
    }
  }

  private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) {
    return t.getState() == Thread.State.WAITING && blocker.isInstance(LockSupport.getBlocker(t));
  }

        manager.process(request, response, chain);
        assertEquals(404, response.getStatus());

        // Test with different status code
        manager = new StatusCodeWebApiManager(201);
        response = new TestHttpServletResponse();
        manager.process(request, response, chain);
        assertEquals(201, response.getStatus());
    }

    @Test

    }

    @Test
    public void test_user_state() {
        final User user = new User();
        assertNull(user.getState());

        user.setState("CA");
        assertEquals("CA", user.getState());
    }

    @Test
    public void test_user_street() {
        final User user = new User();
        assertNull(user.getStreet());