// Copyright 2014 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
package org.chromium.mojo.bindings;
import androidx.test.filters.SmallTest;
import org.junit.After;
import org.junit.Assert;
import org.junit.Rule;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.chromium.base.test.BaseJUnit4ClassRunner;
import org.chromium.mojo.MojoTestRule;
import org.chromium.mojo.bindings.BindingsTestUtils.CapturingErrorHandler;
import org.chromium.mojo.bindings.test.mojom.imported.ImportedInterface;
import org.chromium.mojo.bindings.test.mojom.sample.Factory;
import org.chromium.mojo.bindings.test.mojom.sample.NamedObject;
import org.chromium.mojo.bindings.test.mojom.sample.NamedObject.GetName_Response;
import org.chromium.mojo.bindings.test.mojom.sample.Request;
import org.chromium.mojo.bindings.test.mojom.sample.Response;
import org.chromium.mojo.system.DataPipe.ConsumerHandle;
import org.chromium.mojo.system.MessagePipeHandle;
import org.chromium.mojo.system.Pair;
import org.chromium.mojo.system.impl.CoreImpl;
import java.io.Closeable;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
/** Tests for interfaces / proxies / stubs generated for sample_factory.mojom. */
@RunWith(BaseJUnit4ClassRunner.class)
public class InterfacesTest {
@Rule public MojoTestRule mTestRule = new MojoTestRule();
private static final String OBJECT_NAME = "hello world";
private final List<Closeable> mCloseablesToClose = new ArrayList<Closeable>();
/** Basic implementation of {@link NamedObject}. */
public static class MockNamedObjectImpl extends CapturingErrorHandler implements NamedObject {
private String mName = "";
/**
* @see org.chromium.mojo.bindings.Interface#close()
*/
@Override
public void close() {}
@Override
public void setName(String name) {
mName = name;
}
@Override
public void getName(GetName_Response callback) {
callback.call(mName);
}
public String getNameSynchronously() {
return mName;
}
}
/** Implementation of {@link GetNameResponse} keeping track of usage. */
public static class RecordingGetNameResponse implements GetName_Response {
private String mName;
private boolean mCalled;
public RecordingGetNameResponse() {
reset();
}
@Override
public void call(String name) {
mName = name;
mCalled = true;
}
public String getName() {
return mName;
}
public boolean wasCalled() {
return mCalled;
}
public void reset() {
mName = null;
mCalled = false;
}
}
/** Basic implementation of {@link Factory}. */
public class MockFactoryImpl extends CapturingErrorHandler implements Factory {
private boolean mClosed;
public boolean isClosed() {
return mClosed;
}
/**
* @see org.chromium.mojo.bindings.Interface#close()
*/
@Override
public void close() {
mClosed = true;
}
@Override
public void doStuff(Request request, MessagePipeHandle pipe, DoStuff_Response callback) {
if (pipe != null) {
pipe.close();
}
Response response = new Response();
response.x = 42;
callback.call(response, "Hello");
}
@Override
public void doStuff2(ConsumerHandle pipe, DoStuff2_Response callback) {
callback.call("World");
}
@Override
public void createNamedObject(InterfaceRequest<NamedObject> obj) {
NamedObject.MANAGER.bind(new MockNamedObjectImpl(), obj);
}
@Override
public void requestImportedInterface(
InterfaceRequest<ImportedInterface> obj,
RequestImportedInterface_Response callback) {
throw new UnsupportedOperationException("Not implemented.");
}
@Override
public void takeImportedInterface(
ImportedInterface obj, TakeImportedInterface_Response callback) {
throw new UnsupportedOperationException("Not implemented.");
}
}
/** Implementation of DoStuffResponse that keeps track of if the response is called. */
public static class DoStuffResponseImpl implements Factory.DoStuff_Response {
private boolean mResponseCalled;
public boolean wasResponseCalled() {
return mResponseCalled;
}
@Override
public void call(Response response, String string) {
mResponseCalled = true;
}
}
/**
* @see MojoTestCase#tearDown()
*/
@After
public void tearDown() throws Exception {
// Close the elements in the reverse order they were added. This is needed because it is an
// error to close the handle of a proxy without closing the proxy first.
Collections.reverse(mCloseablesToClose);
for (Closeable c : mCloseablesToClose) {
c.close();
}
}
/**
* Check that the given proxy receives the calls. If |impl| is not null, also check that the
* calls are forwared to |impl|.
*/
private void checkProxy(NamedObject.Proxy proxy, MockNamedObjectImpl impl) {
RecordingGetNameResponse callback = new RecordingGetNameResponse();
CapturingErrorHandler errorHandler = new CapturingErrorHandler();
proxy.getProxyHandler().setErrorHandler(errorHandler);
if (impl != null) {
Assert.assertNull(impl.getLastMojoException());
Assert.assertEquals("", impl.getNameSynchronously());
}
proxy.getName(callback);
mTestRule.runLoopUntilIdle();
Assert.assertNull(errorHandler.getLastMojoException());
Assert.assertTrue(callback.wasCalled());
Assert.assertEquals("", callback.getName());
callback.reset();
proxy.setName(OBJECT_NAME);
mTestRule.runLoopUntilIdle();
Assert.assertNull(errorHandler.getLastMojoException());
if (impl != null) {
Assert.assertNull(impl.getLastMojoException());
Assert.assertEquals(OBJECT_NAME, impl.getNameSynchronously());
}
proxy.getName(callback);
mTestRule.runLoopUntilIdle();
Assert.assertNull(errorHandler.getLastMojoException());
Assert.assertTrue(callback.wasCalled());
Assert.assertEquals(OBJECT_NAME, callback.getName());
}
@Test
@SmallTest
public void testName() {
Assert.assertEquals("sample.NamedObject", NamedObject.MANAGER.getName());
}
@Test
@SmallTest
public void testProxyAndStub() {
MockNamedObjectImpl impl = new MockNamedObjectImpl();
NamedObject.Proxy proxy =
NamedObject.MANAGER.buildProxy(null, NamedObject.MANAGER.buildStub(null, impl));
checkProxy(proxy, impl);
}
@Test
@SmallTest
public void testProxyAndStubOverPipe() {
MockNamedObjectImpl impl = new MockNamedObjectImpl();
NamedObject.Proxy proxy =
BindingsTestUtils.newProxyOverPipe(NamedObject.MANAGER, impl, mCloseablesToClose);
checkProxy(proxy, impl);
}
@Test
@SmallTest
public void testFactoryOverPipe() {
Factory.Proxy proxy =
BindingsTestUtils.newProxyOverPipe(
Factory.MANAGER, new MockFactoryImpl(), mCloseablesToClose);
Pair<NamedObject.Proxy, InterfaceRequest<NamedObject>> request =
NamedObject.MANAGER.getInterfaceRequest(CoreImpl.getInstance());
mCloseablesToClose.add(request.first);
proxy.createNamedObject(request.second);
checkProxy(request.first, null);
}
@Test
@SmallTest
public void testInterfaceClosing() {
MockFactoryImpl impl = new MockFactoryImpl();
Factory.Proxy proxy =
BindingsTestUtils.newProxyOverPipe(Factory.MANAGER, impl, mCloseablesToClose);
Assert.assertFalse(impl.isClosed());
proxy.close();
mTestRule.runLoopUntilIdle();
Assert.assertTrue(impl.isClosed());
}
@Test
@SmallTest
public void testResponse() {
MockFactoryImpl impl = new MockFactoryImpl();
Factory.Proxy proxy =
BindingsTestUtils.newProxyOverPipe(Factory.MANAGER, impl, mCloseablesToClose);
Request request = new Request();
request.x = 42;
Pair<MessagePipeHandle, MessagePipeHandle> handles =
CoreImpl.getInstance().createMessagePipe(null);
DoStuffResponseImpl response = new DoStuffResponseImpl();
proxy.doStuff(request, handles.first, response);
Assert.assertFalse(response.wasResponseCalled());
mTestRule.runLoopUntilIdle();
Assert.assertTrue(response.wasResponseCalled());
}
}
Codebase Browser
chromium