- Timestamp:
- 07/06/13 03:51:11 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/test/java/com/framsticks/hosting/ServerTest.java
r96 r97 4 4 import org.testng.annotations.Test; 5 5 6 import com.framsticks.core.ObjectInstance; 6 import com.framsticks.core.Mode; 7 import com.framsticks.core.ObjectTree; 7 8 import com.framsticks.core.Path; 8 9 import com.framsticks.core.XmlBasedTest; 9 import com.framsticks.remote.Remote Instance;10 import com.framsticks.remote.RemoteTree; 10 11 11 12 import com.framsticks.test.TestClass; 12 import com.framsticks.core. Instance;13 import com.framsticks.core.Tree; 13 14 import com.framsticks.params.FramsClass; 14 import com.framsticks.util.AbstractStateFunctor;15 15 import com.framsticks.util.dispatching.Dispatching; 16 16 import com.framsticks.params.AccessInterface; 17 import com.framsticks.params.PrimitiveParam; 17 18 import com.framsticks.params.PropertiesAccess; 18 import com.framsticks.params.ValueParam;19 19 import com.framsticks.params.types.ProcedureParam; 20 20 import com.framsticks.util.dispatching.Dispatching.Waiter; 21 import com.framsticks.util.dispatching.Future ;21 import com.framsticks.util.dispatching.FutureHandler; 22 22 import com.framsticks.util.dispatching.RunAt; 23 23 24 import static com.framsticks.core. InstanceUtils.*;24 import static com.framsticks.core.TreeOperations.*; 25 25 26 26 import static org.fest.assertions.Assertions.*; … … 29 29 public class ServerTest extends XmlBasedTest { 30 30 31 protected Remote Instance remote;31 protected RemoteTree remote; 32 32 protected FramsClass remoteTestFramsClass; 33 33 protected Path remotePath; 34 34 35 35 protected Server server; 36 protected Object Instance hosted;36 protected ObjectTree hosted; 37 37 protected TestClass hostedObject; 38 38 … … 46 46 assertThat(framsticks.size()).isEqualTo(2); 47 47 assertThat(framsticks.get("test")).isInstanceOf(Server.class); 48 assertThat(framsticks.get("remote")).isInstanceOf(Remote Instance.class);48 assertThat(framsticks.get("remote")).isInstanceOf(RemoteTree.class); 49 49 50 50 server = (Server) framsticks.get("test"); 51 remote = (Remote Instance) framsticks.get("remote");52 assertThat(server.getHosted()).isInstanceOf(Object Instance.class);53 hosted = (Object Instance) server.getHosted();51 remote = (RemoteTree) framsticks.get("remote"); 52 assertThat(server.getHosted()).isInstanceOf(ObjectTree.class); 53 hosted = (ObjectTree) server.getHosted(); 54 54 assertThat(hosted.getRootObject()).isInstanceOf(TestClass.class); 55 55 hostedObject = hosted.getRootObject(TestClass.class); … … 58 58 @Test(dependsOnMethods = "runServer") 59 59 public void fetchInfo() { 60 remote.dispatch(new RunAt< Instance>() {60 remote.dispatch(new RunAt<Tree>(failOnException) { 61 61 @Override 62 p ublic void run() {63 remote. fetchInfo(Path.to(remote, "/"), new Future<FramsClass>(failOnException()) {62 protected void runAt() { 63 remote.info(Path.to(remote, "/"), new FutureHandler<FramsClass>(failOnException) { 64 64 @Override 65 65 protected void result(FramsClass result) { … … 78 78 final Waiter waiter = produceWaiter(1.0); 79 79 80 remote.dispatch(new RunAt< Instance>() {80 remote.dispatch(new RunAt<Tree>(failOnException) { 81 81 @Override 82 p ublic void run() {82 protected void runAt() { 83 83 final Path path = Path.to(remote, "/"); 84 84 assertThat(path.isResolved()).isFalse(); 85 85 86 remote.resolve(path, new Future <Path>(failOnException()) {86 remote.resolve(path, new FutureHandler<Path>(failOnException) { 87 87 @Override 88 88 protected void result(final Path result) { 89 89 assertThat(result.isResolved()).isTrue(); 90 90 remotePath = result; 91 remote. fetchValues(result, new AbstractStateFunctor(failOnException()) {91 remote.get(result, Mode.FETCH, new FutureHandler<Object>(failOnException) { 92 92 @Override 93 p ublic void call() {93 protected void result(Object object) { 94 94 AccessInterface access = bindAccess(result); 95 95 assertThat(access).isInstanceOf(PropertiesAccess.class); … … 108 108 final Waiter waiter = produceWaiter(2.0); 109 109 110 s toreValue(remotePath, remoteTestFramsClass.getParamEntry("name", ValueParam.class), "new name", new AbstractStateFunctor(failOnException()) {110 set(remotePath, remoteTestFramsClass.getParamEntry("name", PrimitiveParam.class), "new name", new FutureHandler<Integer>(failOnException) { 111 111 @Override 112 public void call() { 112 protected void result(Integer flags) { 113 // assertThat(flags).isEqualTo(0); 113 114 /** And now check directly whether it was really set. */ 114 hosted.dispatch(new RunAt< Instance>() {115 hosted.dispatch(new RunAt<Tree>(failOnException) { 115 116 @Override 116 p ublic void run() {117 protected void runAt() { 117 118 assertThat(hostedObject.getName()).isEqualTo("new name"); 118 119 waiter.pass(); … … 128 129 final Waiter waiter = produceWaiter(2.0); 129 130 130 call(remotePath, remoteTestFramsClass.getParamEntry("resetHistory", ProcedureParam.class), new Object[] {}, new Future <Object>(failOnException()) {131 call(remotePath, remoteTestFramsClass.getParamEntry("resetHistory", ProcedureParam.class), new Object[] {}, new FutureHandler<Object>(failOnException) { 131 132 @Override 132 133 protected void result(Object result) { … … 135 136 }); 136 137 137 call(remotePath, remoteTestFramsClass.getParamEntry("appendHistory", ProcedureParam.class), new Object[] {"next word"}, new Future <Object>(failOnException()) {138 call(remotePath, remoteTestFramsClass.getParamEntry("appendHistory", ProcedureParam.class), new Object[] {"next word"}, new FutureHandler<Object>(failOnException) { 138 139 @Override 139 140 protected void result(Object result) { 140 hosted.dispatch(new RunAt< Instance>() {141 hosted.dispatch(new RunAt<Tree>(failOnException) { 141 142 @Override 142 p ublic void run() {143 protected void runAt() { 143 144 assertThat(hostedObject.getHistory()).isEqualTo("next word|"); 144 145 waiter.pass();
Note: See TracChangeset
for help on using the changeset viewer.