624 bypass caching

eo-maven-plugin/src/main/java/org/eolang/maven/PullMojo.java

@@ -33,16 +33,14 @@
 import org.apache.maven.plugins.annotations.LifecyclePhase;
 import org.apache.maven.plugins.annotations.Mojo;
 import org.apache.maven.plugins.annotations.Parameter;
+import org.cactoos.Input;
+import org.cactoos.scalar.Sticky;
+import org.cactoos.scalar.Unchecked;
 
 /**
  * Pull EO XML files from Objectionary and parse them into XML.
  *
  * @since 0.1
- * @todo #561:30min Add a parameter to bypass/overwrite cache
- *  for combination of Local and Caching and Remote.
- *  It was suggested by @yegor256 to rely on -U parameter of Maven
- *  (https://github.com/objectionary/eo/issues/561#issuecomment-1007128430).
- *  If it is possible to access it from the plugin.
  */
 @Mojo(
     name = "pull",
@@ -95,7 +93,7 @@ public void exec() throws IOException {
         if (this.objectionary == null) {
             final String full = new HashOfTag(this.hash).hash();
             final String small = full.substring(0, 7);
-            this.objectionary = new OyFallback(
+            this.objectionary = new PullMojo.FallbackSwapOy(
                 new OyHome(
                     small,
                     this.outputPath
@@ -104,7 +102,8 @@ public void exec() throws IOException {
                     small,
                     this.outputPath,
                     new OyRemote(full)
-                )
+                ),
+                this.forceUpdate()
             );
         }
         if (!tojos.isEmpty()) {
@@ -121,6 +120,14 @@ public void exec() throws IOException {
         }
     }
 
+    /**
+     * Is force update option enabled.
+     * @return True if option enabled and false otherwise
+     */
+    private boolean forceUpdate() {
+        return this.session.getRequest().isUpdateSnapshots();
+    }
+
     /**
      * Pull one object.
      *
@@ -150,4 +157,57 @@ private Path pull(final String name) throws IOException {
         return src;
     }
 
+    /**
+     * Fallback which can swap primary/secondary repos.
+     * @since 1.0
+     */
+    public static final class FallbackSwapOy implements Objectionary {
+        /**
+         * Swapped Oy.
+         */
+        private final Unchecked<Objectionary> swapped;
+
+        /**
+         * Ctor.
+         *
+         * @param first Initial primary
+         * @param second Initial secondary
+         * @param swap Whether to swap
+         */
+        public FallbackSwapOy(
+            final Objectionary first,
+            final Objectionary second,
+            final boolean swap
+        ) {
+            this.swapped = new Unchecked<>(
+                new Sticky<>(
+                    () -> {
+                        final Objectionary result;
+                        if (swap) {
+                            result = new OyFallback(
+                                second,
+                                first
+                            );
+                        } else {
+                            result = new OyFallback(
+                                first,
+                                second
+                            );
+                        }
+                        return result;
+                    }
+                )
+            );
+        }
+
+        @Override
+        public Input get(final String name) throws IOException {
+            return this.swapped.value().get(name);
+        }
+
+        @Override
+        public String toString() {
+            return this.swapped.value().toString();
+        }
+    }
 }

eo-maven-plugin/src/test/java/org/eolang/maven/PullMojoTest.java

@@ -25,9 +25,11 @@
 
 import com.yegor256.tojos.Json;
 import com.yegor256.tojos.MonoTojos;
+import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
 import org.cactoos.io.InputOf;
+import org.cactoos.text.TextOf;
 import org.hamcrest.MatcherAssert;
 import org.hamcrest.Matchers;
 import org.junit.jupiter.api.Test;
@@ -70,4 +72,47 @@ public void testSimplePull(@TempDir final Path temp) {
         );
     }
 
+    @Test
+    public void testFallbackNoSwapOy() throws Exception {
+        MatcherAssert.assertThat(
+            new TextOf(
+                new PullMojo.FallbackSwapOy(
+                    s -> new InputOf("[] > local\n"),
+                    s -> new InputOf("[] > remote\n"),
+                    false
+                ).get("")
+            ).asString(),
+            Matchers.containsString("local")
+        );
+    }
+
+    @Test
+    public void testFallbackSwapOyFail() throws Exception {
+        MatcherAssert.assertThat(
+            new TextOf(
+                new PullMojo.FallbackSwapOy(
+                    s -> new InputOf("[] > local\n"),
+                    s -> {
+                        throw new IOException("Can't get object");
+                    },
+                    false
+                ).get("")
+            ).asString(),
+            Matchers.containsString("local")
+        );
+    }
+
+    @Test
+    public void testFallbackSwapOy() throws Exception {
+        MatcherAssert.assertThat(
+            new TextOf(
+                new PullMojo.FallbackSwapOy(
+                    s -> new InputOf("[] > local\n"),
+                    s -> new InputOf("[] > remote\n"),
+                    true
+                ).get("")
+            ).asString(),
+            Matchers.containsString("remote")
+        );
+    }
 }