X-Git-Url: https://git.pterodactylus.net/?p=Sone.git;a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fnet%2Fpterodactylus%2Fsone%2Fcore%2FUpdateCheckerTest.java;h=44819ee4bf7f66d3a1172bc30f2c3b2ca9c93adf;hp=fd7a02ad78d249451c3df00add8719c6f7295859;hb=00a353b7c10c9511fb69cb1120580e4ff95e9c0e;hpb=11bcfe02cef90ea88c19b30cd796d563c4567a96

diff --git a/src/test/java/net/pterodactylus/sone/core/UpdateCheckerTest.java b/src/test/java/net/pterodactylus/sone/core/UpdateCheckerTest.java
index fd7a02a..44819ee 100644
--- a/src/test/java/net/pterodactylus/sone/core/UpdateCheckerTest.java
+++ b/src/test/java/net/pterodactylus/sone/core/UpdateCheckerTest.java
@@ -1,7 +1,6 @@
 package net.pterodactylus.sone.core;
 
 import static java.lang.Long.MAX_VALUE;
-import static net.pterodactylus.sone.main.SonePlugin.VERSION;
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.instanceOf;
 import static org.hamcrest.Matchers.is;
@@ -88,23 +87,33 @@ public class UpdateCheckerTest {
 		setupFetchResult(createFutureFetchResult());
 		setupCallbackWithEdition(MAX_VALUE, true, false);
 		verifyAFreenetUriIsFetched();
-		ArgumentCaptor<UpdateFoundEvent> updateFoundEvent = forClass(UpdateFoundEvent.class);
-		verify(eventBus, times(1)).post(updateFoundEvent.capture());
-		assertThat(updateFoundEvent.getValue().version(), is(new Version(99, 0, 0)));
-		assertThat(updateFoundEvent.getValue().releaseTime(), is(11865368297000L));
-		assertThat(updateChecker.getLatestVersion(), is(new Version(99, 0, 0)));
-		assertThat(updateChecker.getLatestVersionDate(), is(11865368297000L));
-		assertThat(updateChecker.hasLatestVersion(), is(true));
+		verifyEventIsFired(new Version(99, 0, 0), 11865368297000L, false);
+		verifyThatUpdateCheckerKnowsLatestVersion(new Version(99, 0, 0), 11865368297000L);
 	}
 
 	private FetchResult createFutureFetchResult() {
 		ClientMetadata clientMetadata = new ClientMetadata("application/xml");
 		Bucket fetched = new ArrayBucket(("# MapConfigurationBackendVersion=1\n" +
 				"CurrentVersion/Version: 99.0.0\n" +
-				"CurrentVersion/ReleaseTime: 11865368297000").getBytes());
+				"CurrentVersion/ReleaseTime: 11865368297000\n" +
+				"DisruptiveVersion/0.1.2: true").getBytes());
 		return new FetchResult(clientMetadata, fetched);
 	}
 
+	private void verifyEventIsFired(Version version, long releaseTime, boolean disruptive) {
+		ArgumentCaptor<UpdateFoundEvent> updateFoundEvent = forClass(UpdateFoundEvent.class);
+		verify(eventBus, times(1)).post(updateFoundEvent.capture());
+		assertThat(updateFoundEvent.getValue().version(), is(version));
+		assertThat(updateFoundEvent.getValue().releaseTime(), is(releaseTime));
+		assertThat(updateFoundEvent.getValue().disruptive(), is(disruptive));
+	}
+
+	private void verifyThatUpdateCheckerKnowsLatestVersion(Version version, long releaseTime) {
+		assertThat(updateChecker.getLatestVersion(), is(version));
+		assertThat(updateChecker.getLatestVersionDate(), is(releaseTime));
+		assertThat(updateChecker.hasLatestVersion(), is(true));
+	}
+
 	@Test
 	public void callbackDoesNotStartIfNoNewEditionIsFound() {
 		setupFetchResult(createPastFetchResult());
@@ -231,4 +240,22 @@ public class UpdateCheckerTest {
 		return new FetchResult(clientMetadata, fetched);
 	}
 
+	@Test
+	public void disruptiveVersionGetsNotification() {
+		setupFetchResult(createDisruptiveVersionFetchResult());
+		setupCallbackWithEdition(MAX_VALUE, true, false);
+		verifyAFreenetUriIsFetched();
+		verifyEventIsFired(new Version(1, 2, 3), 1289417883000L, true);
+		verifyThatUpdateCheckerKnowsLatestVersion(new Version(1, 2, 3), 1289417883000L);
+	}
+
+	private FetchResult createDisruptiveVersionFetchResult() {
+		ClientMetadata clientMetadata = new ClientMetadata("application/xml");
+		Bucket fetched = new ArrayBucket(("# MapConfigurationBackendVersion=1\n" +
+				"CurrentVersion/Version: 1.2.3\n" +
+				"CurrentVersion/ReleaseTime: 1289417883000\n" +
+				"DisruptiveVersion/1.2.3: true").getBytes());
+		return new FetchResult(clientMetadata, fetched);
+	}
+
 }