Fixing: Deprecate Using the yegor256/rultor Docker Image

src/test/java/com/rultor/agents/daemons/EndsDaemonITCase.java

@@ -39,7 +39,10 @@
 import org.apache.commons.io.FileUtils;
 import org.apache.commons.lang3.SystemUtils;
 import org.hamcrest.MatcherAssert;
+import org.hamcrest.core.StringContains;
+import org.hamcrest.core.StringEndsWith;
 import org.junit.Assume;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.TemporaryFolder;
@@ -102,6 +105,38 @@ public void readsExitCodeCorrectly() throws IOException {
         );
     }
 
+    /**
+     * EndsDaemon can deprecate default image.
+     * @throws IOException In case of error
+     */
+    @Test
+    @Ignore
+    public void deprecatesDefaultImage() throws IOException {
+        final Talk talk = new Talk.InFile();
+        FileUtils.write(
+            new File(this.start(talk, "").getAbsolutePath(), "testing"), "12"
+        );
+        new EndsDaemon().execute(talk);
+        for (final String path
+            : talk.read().xpath("/p/entry[@key='merge']/entry[@key='script']")
+        ) {
+            if ("yegor256/rultor".equals(path)) {
+                final String dir = talk.read()
+                    .xpath("/talk/daemon/dir/text()").get(0);
+                MatcherAssert.assertThat(
+                    dir,
+                    StringContains.containsString(
+                        "#### Deprecation Notice ####"
+                    )
+                );
+                MatcherAssert.assertThat(
+                    dir,
+                    StringEndsWith.endsWith("##############")
+                );
+            }
+        }
+    }
+
     /**
      * Start a talk.
      * @param talk Talk to start

src/test/java/com/rultor/agents/daemons/StartsDaemonITCase.java

@@ -33,6 +33,7 @@
 import com.jcabi.matchers.XhtmlMatchers;
 import com.jcabi.ssh.SSHD;
 import com.jcabi.ssh.Shell;
+import com.jcabi.xml.XML;
 import com.jcabi.xml.XMLDocument;
 import com.rultor.agents.shells.TalkShells;
 import com.rultor.spi.Agent;
@@ -41,14 +42,17 @@
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.File;
+import java.io.IOException;
 import java.io.InputStream;
 import java.util.concurrent.TimeUnit;
 import org.apache.commons.io.input.NullInputStream;
 import org.apache.commons.lang3.CharEncoding;
 import org.apache.commons.lang3.SystemUtils;
 import org.hamcrest.MatcherAssert;
 import org.hamcrest.Matchers;
+import org.hamcrest.core.StringStartsWith;
 import org.junit.Assume;
+import org.junit.Ignore;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.TemporaryFolder;
@@ -81,6 +85,73 @@ public final class StartsDaemonITCase {
     @Test
     public void startsDaemon() throws Exception {
         Assume.assumeFalse(SystemUtils.IS_OS_WINDOWS);
+        final Talk talk = this.talk();
+        MatcherAssert.assertThat(
+            talk.read(),
+            XhtmlMatchers.hasXPaths(
+                "/talk/daemon[started and dir]",
+                "/talk/daemon[ends-with(started,'Z')]"
+            )
+        );
+        final String dir = talk.read().xpath("/talk/daemon/dir/text()").get(0);
+        final ByteArrayOutputStream baos = new ByteArrayOutputStream();
+        TimeUnit.SECONDS.sleep(2L);
+        new Shell.Safe(new TalkShells(talk.read()).get()).exec(
+            String.format("cat %s/stdout", dir),
+            new NullInputStream(0L),
+            baos, baos
+        );
+        MatcherAssert.assertThat(
+            baos.toString(CharEncoding.UTF_8),
+            Matchers.allOf(
+                Matchers.containsString("+ set -o pipefail"),
+                Matchers.containsString("+ date"),
+                Matchers.containsString("+ ls -al"),
+                Matchers.containsString("182f61268e6e6e6cd1a547be31fd8583")
+            )
+        );
+        MatcherAssert.assertThat(
+            new File(dir, "status").exists(), Matchers.is(false)
+        );
+    }
+
+    /**
+     * StartsDaemon can deprecate default image.
+     * @throws IOException In case of error
+     * @todo #1018:30min Implement a deprecation message at the start and end
+     *  of the process if the project is using the default image
+     *  'yegor256/rultor'. Fix the issue using the xpath available in
+     *  com.rultor.agents.daemons.StartsDaemon and
+     *  com.rultor.agents.daemons.EndsDaemon.
+     * @todo #1018:30min This test should not check for start and end
+     *  deprecation messages if when the repo is the actual Rultor repo:
+     *  https://github.com/yegor256/rultor
+     */
+    @Test
+    @Ignore
+    public void deprecatesDefaultImage() throws IOException {
+        final Talk talk = this.talk();
+        final XML xml = talk.read();
+        for (final String path
+            : xml.xpath("/p/entry[@key='merge']/entry[@key='script']")
+             ) {
+            if ("yegor256/rultor".equals(path)) {
+                final String dir = talk.read()
+                    .xpath("/talk/daemon/dir/text()").get(0);
+                MatcherAssert.assertThat(
+                    dir,
+                    StringStartsWith.startsWith("#### Deprecation Notice ####")
+                );
+            }
+        }
+    }
+
+    /**
+     * Creates a Talk object with basic parameters.
+     * @return The basic Talk object for testing
+     * @throws IOException In case of error
+     */
+    private Talk talk() throws IOException {
         final SSHD sshd = new SSHD(this.temp.newFolder());
         final int port = sshd.port();
         final Talk talk = new Talk.InFile();
@@ -116,33 +187,6 @@ public void startsDaemon() throws Exception {
         ).when(profile).assets();
         final Agent agent = new StartsDaemon(profile);
         agent.execute(talk);
-        MatcherAssert.assertThat(
-            talk.read(),
-            XhtmlMatchers.hasXPaths(
-                "/talk/daemon[started and dir]",
-                "/talk/daemon[ends-with(started,'Z')]"
-            )
-        );
-        final String dir = talk.read().xpath("/talk/daemon/dir/text()").get(0);
-        final ByteArrayOutputStream baos = new ByteArrayOutputStream();
-        TimeUnit.SECONDS.sleep(2L);
-        new Shell.Safe(new TalkShells(talk.read()).get()).exec(
-            String.format("cat %s/stdout", dir),
-            new NullInputStream(0L),
-            baos, baos
-        );
-        MatcherAssert.assertThat(
-            baos.toString(CharEncoding.UTF_8),
-            Matchers.allOf(
-                Matchers.containsString("+ set -o pipefail"),
-                Matchers.containsString("+ date"),
-                Matchers.containsString("+ ls -al"),
-                Matchers.containsString("182f61268e6e6e6cd1a547be31fd8583")
-            )
-        );
-        MatcherAssert.assertThat(
-            new File(dir, "status").exists(), Matchers.is(false)
-        );
+        return talk;
     }
-
 }