Added API-level support for cached artifacts

3 files changed, 82 insertions, 8 deletions

diff --git a/src/shared/java/com/amadornes/artifactural/base/artifact/ArtifactBase.java b/src/shared/java/com/amadornes/artifactural/base/artifact/ArtifactBase.java
index 4656285..e7dd0c2 100644
--- a/src/shared/java/com/amadornes/artifactural/base/artifact/ArtifactBase.java
+++ b/src/shared/java/com/amadornes/artifactural/base/artifact/ArtifactBase.java
@@ -13,7 +13,7 @@ public abstract class ArtifactBase implements Artifact {
     private final ArtifactType type;
     private final ArtifactMetadata metadata;
 
-    ArtifactBase(ArtifactIdentifier identifier, ArtifactType type, ArtifactMetadata metadata) {
+    public ArtifactBase(ArtifactIdentifier identifier, ArtifactType type, ArtifactMetadata metadata) {
         this.identifier = identifier;
         this.type = type;
         this.metadata = metadata;
@@ -41,7 +41,7 @@ public abstract class ArtifactBase implements Artifact {
     }
 
     @Override
-    public Artifact cache(ArtifactCache cache, String specifier) {
+    public Artifact.Cached cache(ArtifactCache cache, String specifier) {
         return cache.store(this, specifier);
     }
 
diff --git a/src/shared/java/com/amadornes/artifactural/base/cache/ArtifactCacheBase.java b/src/shared/java/com/amadornes/artifactural/base/cache/ArtifactCacheBase.java
index 5f1c240..93ca358 100644
--- a/src/shared/java/com/amadornes/artifactural/base/cache/ArtifactCacheBase.java
+++ b/src/shared/java/com/amadornes/artifactural/base/cache/ArtifactCacheBase.java
@@ -1,16 +1,31 @@
 package com.amadornes.artifactural.base.cache;
 
 import com.amadornes.artifactural.api.artifact.Artifact;
+import com.amadornes.artifactural.api.artifact.ArtifactIdentifier;
+import com.amadornes.artifactural.api.artifact.ArtifactMetadata;
+import com.amadornes.artifactural.api.artifact.ArtifactType;
+import com.amadornes.artifactural.api.artifact.MissingArtifactException;
 import com.amadornes.artifactural.api.cache.ArtifactCache;
+import com.amadornes.artifactural.api.transform.ArtifactTransformer;
 import com.amadornes.artifactural.base.artifact.StreamableArtifact;
 
-import java.io.*;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
 
-abstract class ArtifactCacheBase implements ArtifactCache {
+public abstract class ArtifactCacheBase implements ArtifactCache {
 
-    Artifact doStore(File path, Artifact artifact) {
-        return StreamableArtifact.ofStreamable(artifact.getIdentifier(), artifact.getType(), () -> stream(path, artifact))
-                .withMetadata(artifact.getMetadata());
+    Artifact.Cached doStore(File path, Artifact artifact) {
+        return wrap(
+                StreamableArtifact.ofStreamable(
+                        artifact.getIdentifier(),
+                        artifact.getType(),
+                        () -> stream(path, artifact)
+                ).withMetadata(artifact.getMetadata()),
+                path
+        );
     }
 
     private InputStream stream(File path, Artifact artifact) throws IOException {
@@ -30,4 +45,63 @@ abstract class ArtifactCacheBase implements ArtifactCache {
         return new FileInputStream(path);
     }
 
+    public static Artifact.Cached wrap(Artifact artifact, File file) {
+        return new Artifact.Cached() {
+
+            @Override
+            public ArtifactIdentifier getIdentifier() {
+                return artifact.getIdentifier();
+            }
+
+            @Override
+            public ArtifactMetadata getMetadata() {
+                return artifact.getMetadata();
+            }
+
+            @Override
+            public ArtifactType getType() {
+                return artifact.getType();
+            }
+
+            @Override
+            public Artifact withMetadata(ArtifactMetadata metadata) {
+                return artifact.withMetadata(metadata);
+            }
+
+            @Override
+            public Artifact apply(ArtifactTransformer transformer) {
+                return artifact.apply(transformer);
+            }
+
+            @Override
+            public Artifact.Cached cache(ArtifactCache cache, String specifier) {
+                return artifact.cache(cache, specifier);
+            }
+
+            @Override
+            public boolean isPresent() {
+                return artifact.isPresent();
+            }
+
+            @Override
+            public InputStream openStream() throws IOException, MissingArtifactException {
+                return artifact.openStream();
+            }
+
+            @Override
+            public File asFile() throws IOException, MissingArtifactException {
+                if(!file.exists()) {
+                    artifact.openStream().close();
+                }
+                return file;
+            }
+
+            @Override
+            public File getFileLocation() throws MissingArtifactException {
+                return file;
+            }
+
+        };
+    }
+
 }
diff --git a/src/shared/java/com/amadornes/artifactural/base/cache/LocatedArtifactCache.java b/src/shared/java/com/amadornes/artifactural/base/cache/LocatedArtifactCache.java
index caa5de7..2afbff8 100644
--- a/src/shared/java/com/amadornes/artifactural/base/cache/LocatedArtifactCache.java
+++ b/src/shared/java/com/amadornes/artifactural/base/cache/LocatedArtifactCache.java
@@ -14,7 +14,7 @@ public class LocatedArtifactCache extends ArtifactCacheBase {
     }
 
     @Override
-    public Artifact store(Artifact artifact, String specifier) {
+    public Artifact.Cached store(Artifact artifact, String specifier) {
         ArtifactIdentifier identifier = artifact.getIdentifier();
         File cachePath = new File(path.getAbsolutePath()
                 .replace("${GROUP}", identifier.getGroup())