Add test for page that shows bookmarked posts
[Sone.git] / src / test / java / net / pterodactylus / sone / core / WebOfTrustUpdaterTest.java
1 package net.pterodactylus.sone.core;
2
3 import static java.lang.Thread.sleep;
4 import static java.util.concurrent.TimeUnit.SECONDS;
5 import static org.hamcrest.MatcherAssert.assertThat;
6 import static org.hamcrest.Matchers.containsString;
7 import static org.hamcrest.Matchers.is;
8 import static org.hamcrest.Matchers.not;
9 import static org.mockito.ArgumentMatchers.eq;
10 import static org.mockito.Mockito.doAnswer;
11 import static org.mockito.Mockito.doThrow;
12 import static org.mockito.Mockito.mock;
13 import static org.mockito.Mockito.never;
14 import static org.mockito.Mockito.verify;
15 import static org.mockito.Mockito.when;
16
17 import java.util.concurrent.CountDownLatch;
18
19 import net.pterodactylus.sone.core.WebOfTrustUpdaterImpl.AddContextJob;
20 import net.pterodactylus.sone.core.WebOfTrustUpdaterImpl.RemoveContextJob;
21 import net.pterodactylus.sone.core.WebOfTrustUpdaterImpl.SetPropertyJob;
22 import net.pterodactylus.sone.core.WebOfTrustUpdaterImpl.SetTrustJob;
23 import net.pterodactylus.sone.core.WebOfTrustUpdaterImpl.WebOfTrustContextUpdateJob;
24 import net.pterodactylus.sone.core.WebOfTrustUpdaterImpl.WebOfTrustUpdateJob;
25 import net.pterodactylus.sone.freenet.plugin.PluginException;
26 import net.pterodactylus.sone.freenet.wot.Identity;
27 import net.pterodactylus.sone.freenet.wot.OwnIdentity;
28 import net.pterodactylus.sone.freenet.wot.Trust;
29 import net.pterodactylus.sone.freenet.wot.WebOfTrustConnector;
30 import net.pterodactylus.sone.freenet.wot.WebOfTrustException;
31
32 import org.junit.Test;
33 import org.mockito.invocation.InvocationOnMock;
34 import org.mockito.stubbing.Answer;
35
36 /**
37  * Unit test for {@link WebOfTrustUpdaterImpl} and its subclasses.
38  *
39  * @author <a href="mailto:bombe@pterodactylus.net">David ‘Bombe’ Roden</a>
40  */
41 public class WebOfTrustUpdaterTest {
42
43         private static final String CONTEXT = "test-context";
44         private static final Integer SCORE = 50;
45         private static final Integer OTHER_SCORE = 25;
46         private static final String TRUST_COMMENT = "set in a test";
47         private static final String PROPERTY_NAME = "test-property";
48         private final WebOfTrustConnector webOfTrustConnector = mock(WebOfTrustConnector.class);
49         private final WebOfTrustUpdaterImpl webOfTrustUpdater = new WebOfTrustUpdaterImpl(webOfTrustConnector);
50         private final OwnIdentity ownIdentity = when(mock(OwnIdentity.class).getId()).thenReturn("own-identity-id").getMock();
51         private final WebOfTrustUpdateJob successfulWebOfTrustUpdateJob = createWebOfTrustUpdateJob(true);
52         private final WebOfTrustUpdateJob failingWebOfTrustUpdateJob = createWebOfTrustUpdateJob(false);
53         private final WebOfTrustContextUpdateJob contextUpdateJob = webOfTrustUpdater.new WebOfTrustContextUpdateJob(ownIdentity, CONTEXT);
54         private final AddContextJob addContextJob = webOfTrustUpdater.new AddContextJob(ownIdentity, CONTEXT);
55         private final RemoveContextJob removeContextJob = webOfTrustUpdater.new RemoveContextJob(ownIdentity, CONTEXT);
56         private final Identity trustee = when(mock(Identity.class).getId()).thenReturn("trustee-id").getMock();
57
58         private WebOfTrustUpdateJob createWebOfTrustUpdateJob(final boolean success) {
59                 return webOfTrustUpdater.new WebOfTrustUpdateJob() {
60                         @Override
61                         public void run() {
62                                 super.run();
63                                 try {
64                                         sleep(100);
65                                 } catch (InterruptedException ie1) {
66                                         throw new RuntimeException(ie1);
67                                 }
68                                 finish(success);
69                         }
70                 };
71         }
72
73         @Test
74         public void webOfTrustUpdateJobWaitsUntilFinishedHasBeenCalledAndReturnsSuccess() throws InterruptedException {
75                 new Thread(successfulWebOfTrustUpdateJob).start();
76                 assertThat(successfulWebOfTrustUpdateJob.waitForCompletion(), is(true));
77         }
78
79         @Test
80         public void webOfTrustUpdateJobWaitsUntilFinishedHasBeenCalledAndReturnsFailure() throws InterruptedException {
81                 new Thread(failingWebOfTrustUpdateJob).start();
82                 assertThat(failingWebOfTrustUpdateJob.waitForCompletion(), is(false));
83         }
84
85         @Test
86         public void webOfTrustContextUpdateJobsAreEqualIfTheirClassOwnIdentityAndContextAreEqual() {
87                 WebOfTrustContextUpdateJob secondContextUpdateJob = webOfTrustUpdater.new WebOfTrustContextUpdateJob(ownIdentity, CONTEXT);
88                 assertThat(contextUpdateJob.equals(secondContextUpdateJob), is(true));
89                 assertThat(secondContextUpdateJob.equals(contextUpdateJob), is(true));
90                 assertThat(contextUpdateJob.hashCode(), is(secondContextUpdateJob.hashCode()));
91         }
92
93         @Test
94         public void webOfTrustContextUpdatesJobsAreNotEqualIfTheirClassDiffers() {
95                 assertThat(contextUpdateJob.equals(addContextJob), is(false));
96         }
97
98         @Test
99         public void webOfTrustContextUpdateJobToStringContainsIdentityAndContext() {
100                 assertThat(contextUpdateJob.toString(), containsString(ownIdentity.toString()));
101                 assertThat(contextUpdateJob.toString(), containsString(CONTEXT));
102         }
103
104         @Test
105         public void webOfTrustContextUpdateJobsAreNotEqualIfTheIdentitiesDiffer() {
106                 OwnIdentity ownIdentity = mock(OwnIdentity.class);
107                 WebOfTrustContextUpdateJob secondContextUpdateJob = webOfTrustUpdater.new WebOfTrustContextUpdateJob(ownIdentity, CONTEXT);
108                 assertThat(contextUpdateJob.equals(secondContextUpdateJob), is(false));
109                 assertThat(secondContextUpdateJob.equals(contextUpdateJob), is(false));
110         }
111
112         @Test
113         public void webOfTrustContextUpdateJobsAreNotEqualIfTheirContextsDiffer() {
114                 WebOfTrustContextUpdateJob secondContextUpdateJob = webOfTrustUpdater.new WebOfTrustContextUpdateJob(ownIdentity, CONTEXT + CONTEXT);
115                 assertThat(contextUpdateJob.equals(secondContextUpdateJob), is(false));
116                 assertThat(secondContextUpdateJob.equals(contextUpdateJob), is(false));
117         }
118
119         @Test
120         public void webOfTrustContextUpdateJobsAreNotEqualToNull() {
121                 assertThat(contextUpdateJob.equals(null), is(false));
122         }
123
124         @Test
125         public void addContextJobAddsTheContext() throws PluginException {
126                 addContextJob.run();
127                 verify(webOfTrustConnector).addContext(eq(ownIdentity), eq(CONTEXT));
128                 verify(ownIdentity).addContext(eq(CONTEXT));
129                 assertThat(addContextJob.waitForCompletion(), is(true));
130         }
131
132         @Test
133         public void exceptionWhileAddingAContextIsExposed() throws PluginException {
134                 doThrow(PluginException.class).when(webOfTrustConnector).addContext(eq(ownIdentity), eq(CONTEXT));
135                 addContextJob.run();
136                 verify(webOfTrustConnector).addContext(eq(ownIdentity), eq(CONTEXT));
137                 verify(ownIdentity, never()).addContext(eq(CONTEXT));
138                 assertThat(addContextJob.waitForCompletion(), is(false));
139         }
140
141         @Test
142         public void removeContextJobRemovesTheContext() throws PluginException {
143                 removeContextJob.run();
144                 verify(webOfTrustConnector).removeContext(eq(ownIdentity), eq(CONTEXT));
145                 verify(ownIdentity).removeContext(eq(CONTEXT));
146                 assertThat(removeContextJob.waitForCompletion(), is(true));
147         }
148
149         @Test
150         public void exceptionWhileRemovingAContextIsExposed() throws PluginException {
151                 doThrow(PluginException.class).when(webOfTrustConnector).removeContext(eq(ownIdentity), eq(CONTEXT));
152                 removeContextJob.run();
153                 verify(webOfTrustConnector).removeContext(eq(ownIdentity), eq(CONTEXT));
154                 verify(ownIdentity, never()).removeContext(eq(CONTEXT));
155                 assertThat(removeContextJob.waitForCompletion(), is(false));
156         }
157
158         @Test
159         public void settingAPropertySetsTheProperty() throws PluginException {
160                 String propertyName = "property-name";
161                 String propertyValue = "property-value";
162                 SetPropertyJob setPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue);
163                 setPropertyJob.run();
164                 verify(webOfTrustConnector).setProperty(eq(ownIdentity), eq(propertyName), eq(propertyValue));
165                 verify(ownIdentity).setProperty(eq(propertyName), eq(propertyValue));
166                 assertThat(setPropertyJob.waitForCompletion(), is(true));
167         }
168
169         @Test
170         public void settingAPropertyToNullRemovesTheProperty() throws PluginException {
171                 String propertyName = "property-name";
172                 SetPropertyJob setPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, null);
173                 setPropertyJob.run();
174                 verify(webOfTrustConnector).removeProperty(eq(ownIdentity), eq(propertyName));
175                 verify(ownIdentity).removeProperty(eq(propertyName));
176                 assertThat(setPropertyJob.waitForCompletion(), is(true));
177         }
178
179         @Test
180         public void pluginExceptionWhileSettingAPropertyIsHandled() throws PluginException {
181                 String propertyName = "property-name";
182                 String propertyValue = "property-value";
183                 doThrow(PluginException.class).when(webOfTrustConnector).setProperty(eq(ownIdentity), eq(propertyName), eq(propertyValue));
184                 SetPropertyJob setPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue);
185                 setPropertyJob.run();
186                 verify(webOfTrustConnector).setProperty(eq(ownIdentity), eq(propertyName), eq(propertyValue));
187                 verify(ownIdentity, never()).setProperty(eq(propertyName), eq(propertyValue));
188                 assertThat(setPropertyJob.waitForCompletion(), is(false));
189         }
190
191         @Test
192         public void setPropertyJobsWithSameClassPropertyAndValueAreEqual() {
193                 String propertyName = "property-name";
194                 String propertyValue = "property-value";
195                 SetPropertyJob firstSetPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue);
196                 SetPropertyJob secondSetPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue);
197                 assertThat(firstSetPropertyJob, is(secondSetPropertyJob));
198                 assertThat(secondSetPropertyJob, is(firstSetPropertyJob));
199                 assertThat(firstSetPropertyJob.hashCode(), is(secondSetPropertyJob.hashCode()));
200         }
201
202         @Test
203         public void setPropertyJobsWithDifferentClassesAreNotEqual() {
204                 String propertyName = "property-name";
205                 String propertyValue = "property-value";
206                 SetPropertyJob firstSetPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue);
207                 SetPropertyJob secondSetPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue) {
208                 };
209                 assertThat(firstSetPropertyJob, not(is(secondSetPropertyJob)));
210         }
211
212         @Test
213         public void nullIsNotASetProjectJobEither() {
214                 String propertyName = "property-name";
215                 String propertyValue = "property-value";
216                 SetPropertyJob setPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue);
217                 assertThat(setPropertyJob, not(is((Object) null)));
218         }
219
220         @Test
221         public void setPropertyJobsWithDifferentPropertiesAreNotEqual() {
222                 String propertyName = "property-name";
223                 String propertyValue = "property-value";
224                 SetPropertyJob firstSetPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue);
225                 SetPropertyJob secondSetPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName + "2", propertyValue);
226                 assertThat(firstSetPropertyJob, not(is(secondSetPropertyJob)));
227         }
228
229         @Test
230         public void setPropertyJobsWithDifferentOwnIdentitiesAreNotEqual() {
231                 OwnIdentity otherOwnIdentity = mock(OwnIdentity.class);
232                 String propertyName = "property-name";
233                 String propertyValue = "property-value";
234                 SetPropertyJob firstSetPropertyJob = webOfTrustUpdater.new SetPropertyJob(ownIdentity, propertyName, propertyValue);
235                 SetPropertyJob secondSetPropertyJob = webOfTrustUpdater.new SetPropertyJob(otherOwnIdentity, propertyName, propertyValue);
236                 assertThat(firstSetPropertyJob, not(is(secondSetPropertyJob)));
237         }
238
239         @Test
240         public void setTrustJobSetsTrust() throws PluginException {
241                 SetTrustJob setTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT);
242                 setTrustJob.run();
243                 verify(webOfTrustConnector).setTrust(eq(ownIdentity), eq(trustee), eq(SCORE), eq(TRUST_COMMENT));
244                 verify(trustee).setTrust(eq(ownIdentity), eq(new Trust(SCORE, null, 0)));
245                 assertThat(setTrustJob.waitForCompletion(), is(true));
246         }
247
248         @Test
249         public void settingNullTrustRemovesTrust() throws WebOfTrustException {
250                 SetTrustJob setTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, null, TRUST_COMMENT);
251                 setTrustJob.run();
252                 verify(webOfTrustConnector).removeTrust(eq(ownIdentity), eq(trustee));
253                 verify(trustee).removeTrust(eq(ownIdentity));
254                 assertThat(setTrustJob.waitForCompletion(), is(true));
255         }
256
257         @Test
258         public void exceptionWhileSettingTrustIsCaught() throws PluginException {
259                 doThrow(PluginException.class).when(webOfTrustConnector).setTrust(eq(ownIdentity), eq(trustee), eq(SCORE), eq(TRUST_COMMENT));
260                 SetTrustJob setTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT);
261                 setTrustJob.run();
262                 verify(webOfTrustConnector).setTrust(eq(ownIdentity), eq(trustee), eq(SCORE), eq(TRUST_COMMENT));
263                 verify(trustee, never()).setTrust(eq(ownIdentity), eq(new Trust(SCORE, null, 0)));
264                 assertThat(setTrustJob.waitForCompletion(), is(false));
265         }
266
267         @Test
268         public void setTrustJobsWithDifferentClassesAreNotEqual() {
269                 SetTrustJob firstSetTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT);
270                 SetTrustJob secondSetTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT) {
271                 };
272                 assertThat(firstSetTrustJob, not(is(secondSetTrustJob)));
273                 assertThat(secondSetTrustJob, not(is(firstSetTrustJob)));
274         }
275
276         @Test
277         public void setTrustJobsWithDifferentTrustersAreNotEqual() {
278                 SetTrustJob firstSetTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT);
279                 SetTrustJob secondSetTrustJob = webOfTrustUpdater.new SetTrustJob(mock(OwnIdentity.class), trustee, SCORE, TRUST_COMMENT);
280                 assertThat(firstSetTrustJob, not(is(secondSetTrustJob)));
281                 assertThat(secondSetTrustJob, not(is(firstSetTrustJob)));
282         }
283
284         @Test
285         public void setTrustJobsWithDifferentTrusteesAreNotEqual() {
286                 SetTrustJob firstSetTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT);
287                 SetTrustJob secondSetTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, mock(Identity.class), SCORE, TRUST_COMMENT);
288                 assertThat(firstSetTrustJob, not(is(secondSetTrustJob)));
289                 assertThat(secondSetTrustJob, not(is(firstSetTrustJob)));
290         }
291
292         @Test
293         public void setTrustJobsWithDifferentScoreAreEqual() {
294                 SetTrustJob firstSetTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT);
295                 SetTrustJob secondSetTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, OTHER_SCORE, TRUST_COMMENT);
296                 assertThat(firstSetTrustJob, is(secondSetTrustJob));
297                 assertThat(secondSetTrustJob, is(firstSetTrustJob));
298                 assertThat(firstSetTrustJob.hashCode(), is(secondSetTrustJob.hashCode()));
299         }
300
301         @Test
302         public void setTrustJobDoesNotEqualNull() {
303                 SetTrustJob setTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT);
304                 assertThat(setTrustJob, not(is((Object) null)));
305         }
306
307         @Test
308         public void toStringOfSetTrustJobContainsIdsOfTrusterAndTrustee() {
309                 SetTrustJob setTrustJob = webOfTrustUpdater.new SetTrustJob(ownIdentity, trustee, SCORE, TRUST_COMMENT);
310                 assertThat(setTrustJob.toString(), containsString(ownIdentity.getId()));
311                 assertThat(setTrustJob.toString(), containsString(trustee.getId()));
312         }
313
314         @Test
315         public void webOfTrustUpdaterStopsWhenItShould() {
316                 webOfTrustUpdater.stop();
317                 webOfTrustUpdater.serviceRun();
318         }
319
320         @Test
321         public void webOfTrustUpdaterStopsAfterItWasStarted() {
322                 webOfTrustUpdater.start();
323                 webOfTrustUpdater.stop();
324         }
325
326         @Test
327         public void removePropertyRemovesProperty() throws InterruptedException, PluginException {
328                 final CountDownLatch wotCallTriggered = new CountDownLatch(1);
329                 doAnswer(new Answer<Void>() {
330                         @Override
331                         public Void answer(InvocationOnMock invocation) throws Throwable {
332                                 wotCallTriggered.countDown();
333                                 return null;
334                         }
335                 }).when(webOfTrustConnector).removeProperty(eq(ownIdentity), eq(PROPERTY_NAME));
336                 webOfTrustUpdater.removeProperty(ownIdentity, PROPERTY_NAME);
337                 webOfTrustUpdater.start();
338                 assertThat(wotCallTriggered.await(1, SECONDS), is(true));
339         }
340
341         @Test
342         public void multipleCallsToSetPropertyAreCollapsed() throws InterruptedException, PluginException {
343                 final CountDownLatch wotCallTriggered = new CountDownLatch(1);
344                 doAnswer(new Answer<Void>() {
345                         @Override
346                         public Void answer(InvocationOnMock invocation) throws Throwable {
347                                 wotCallTriggered.countDown();
348                                 return null;
349                         }
350                 }).when(webOfTrustConnector).removeProperty(eq(ownIdentity), eq(PROPERTY_NAME));
351                 webOfTrustUpdater.removeProperty(ownIdentity, PROPERTY_NAME);
352                 webOfTrustUpdater.removeProperty(ownIdentity, PROPERTY_NAME);
353                 webOfTrustUpdater.start();
354                 assertThat(wotCallTriggered.await(1, SECONDS), is(true));
355                 verify(webOfTrustConnector).removeProperty(eq(ownIdentity), eq(PROPERTY_NAME));
356         }
357
358         @Test
359         public void addContextWaitWaitsForTheContextToBeAdded() {
360                 webOfTrustUpdater.start();
361                 assertThat(webOfTrustUpdater.addContextWait(ownIdentity, CONTEXT), is(true));
362                 verify(ownIdentity).addContext(eq(CONTEXT));
363         }
364
365         @Test
366         public void removeContextRemovesAContext() throws InterruptedException, PluginException {
367                 webOfTrustUpdater.start();
368                 final CountDownLatch removeContextTrigger = new CountDownLatch(1);
369                 doAnswer(new Answer<Void>() {
370                         @Override
371                         public Void answer(InvocationOnMock invocation) throws Throwable {
372                                 removeContextTrigger.countDown();
373                                 return null;
374                         }
375                 }).when(ownIdentity).removeContext(eq(CONTEXT));
376                 webOfTrustUpdater.removeContext(ownIdentity, CONTEXT);
377                 removeContextTrigger.await(1, SECONDS);
378                 verify(webOfTrustConnector).removeContext(eq(ownIdentity), eq(CONTEXT));
379                 verify(ownIdentity).removeContext(eq(CONTEXT));
380         }
381
382         @Test
383         public void removeContextRequestsAreCoalesced() throws InterruptedException, PluginException {
384                 final CountDownLatch contextRemovedTrigger = new CountDownLatch(1);
385                 doAnswer(new Answer<Void>() {
386                         @Override
387                         public Void answer(InvocationOnMock invocation) throws Throwable {
388                                 contextRemovedTrigger.countDown();
389                                 return null;
390                         }
391                 }).when(ownIdentity).removeContext(eq(CONTEXT));
392                 for (int i = 1; i <= 2; i++) {
393                         /* this is so fucking volatile. */
394                         if (i > 1) {
395                                 sleep(200);
396                         }
397                         new Thread(new Runnable() {
398                                 public void run() {
399                                         webOfTrustUpdater.removeContext(ownIdentity, CONTEXT);
400                                 }
401                         }).start();
402                 }
403                 webOfTrustUpdater.start();
404                 assertThat(contextRemovedTrigger.await(1, SECONDS), is(true));
405                 verify(webOfTrustConnector).removeContext(eq(ownIdentity), eq(CONTEXT));
406                 verify(ownIdentity).removeContext(eq(CONTEXT));
407         }
408
409         @Test
410         public void setTrustSetsTrust() throws InterruptedException, PluginException {
411                 final CountDownLatch trustSetTrigger = new CountDownLatch(1);
412                 doAnswer(new Answer<Void>() {
413                         @Override
414                         public Void answer(InvocationOnMock invocation) throws Throwable {
415                                 trustSetTrigger.countDown();
416                                 return null;
417                         }
418                 }).when(trustee).setTrust(eq(ownIdentity), eq(new Trust(SCORE, null, 0)));
419                 webOfTrustUpdater.start();
420                 webOfTrustUpdater.setTrust(ownIdentity, trustee, SCORE, TRUST_COMMENT);
421                 assertThat(trustSetTrigger.await(1, SECONDS), is(true));
422                 verify(trustee).setTrust(eq(ownIdentity), eq(new Trust(SCORE, null, 0)));
423                 verify(webOfTrustConnector).setTrust(eq(ownIdentity), eq(trustee), eq(SCORE), eq(TRUST_COMMENT));
424         }
425
426         @Test
427         public void setTrustRequestsAreCoalesced() throws InterruptedException, PluginException {
428                 final CountDownLatch trustSetTrigger = new CountDownLatch(1);
429                 doAnswer(new Answer<Void>() {
430                         @Override
431                         public Void answer(InvocationOnMock invocation) throws Throwable {
432                                 trustSetTrigger.countDown();
433                                 return null;
434                         }
435                 }).when(trustee).setTrust(eq(ownIdentity), eq(new Trust(SCORE, null, 0)));
436                 for (int i = 1; i <= 2; i++) {
437                         /* this is so fucking volatile. */
438                         if (i > 1) {
439                                 sleep(200);
440                         }
441                         new Thread(new Runnable() {
442                                 public void run() {
443                                         webOfTrustUpdater.setTrust(ownIdentity, trustee, SCORE, TRUST_COMMENT);
444                                 }
445                         }).start();
446                 }
447                 webOfTrustUpdater.start();
448                 assertThat(trustSetTrigger.await(1, SECONDS), is(true));
449                 verify(trustee).setTrust(eq(ownIdentity), eq(new Trust(SCORE, null, 0)));
450                 verify(webOfTrustConnector).setTrust(eq(ownIdentity), eq(trustee), eq(SCORE), eq(TRUST_COMMENT));
451         }
452
453 }