start of filesystem impl conversion to kotlin

filesystem/src/main/java/com/nytimes/android/external/fs3/FSAllEraser.kt

@@ -0,0 +1,15 @@
+package com.nytimes.android.external.fs3
+
+import com.nytimes.android.external.fs3.filesystem.FileSystem
+import com.nytimes.android.external.store3.base.DiskAllErase
+import io.reactivex.Observable
+
+
+class FSAllEraser(internal val fileSystem: FileSystem) : DiskAllErase {
+    override fun deleteAll(path: String): Observable<Boolean> {
+        return Observable.fromCallable {
+            fileSystem.deleteAll(path)
+            true
+        }
+    }
+}

filesystem/src/main/java/com/nytimes/android/external/fs3/FSWriter.kt

@@ -0,0 +1,23 @@
+package com.nytimes.android.external.fs3
+
+import com.nytimes.android.external.fs3.filesystem.FileSystem
+import com.nytimes.android.external.store3.base.DiskWrite
+
+import io.reactivex.Single
+import okio.BufferedSource
+
+/**
+ * FSReader is used when persisting to file system
+ * PathResolver will be used in creating file system paths based on cache keys.
+ * Make sure to have keys containing same data resolve to same "path"
+ * @param <T> key type
+</T> */
+open class FSWriter<T>(internal val fileSystem: FileSystem, internal val pathResolver: PathResolver<T>) : DiskWrite<BufferedSource, T> {
+
+    override fun write(key: T, data: BufferedSource): Single<Boolean> {
+        return Single.fromCallable {
+            fileSystem.write(pathResolver.resolve(key), data)
+            true
+        }
+    }
+}

filesystem/src/main/java/com/nytimes/android/external/fs3/RecordPersister.kt

@@ -0,0 +1,28 @@
+package com.nytimes.android.external.fs3
+
+import com.nytimes.android.external.fs3.filesystem.FileSystem
+import com.nytimes.android.external.store3.base.RecordProvider
+import com.nytimes.android.external.store3.base.RecordState
+import com.nytimes.android.external.store3.base.impl.BarCode
+
+import java.util.concurrent.TimeUnit
+import javax.inject.Inject
+
+class RecordPersister @Inject
+constructor(fileSystem: FileSystem,
+            private val expirationDuration: Long,
+            private val expirationUnit: TimeUnit) : SourcePersister(fileSystem), RecordProvider<BarCode> {
+
+    override fun getRecordState(barCode: BarCode): RecordState {
+        return sourceFileReader.getRecordState(barCode, expirationUnit, expirationDuration)
+    }
+
+    companion object {
+
+        fun create(fileSystem: FileSystem,
+                   expirationDuration: Long,
+                   expirationUnit: TimeUnit): RecordPersister {
+            return RecordPersister(fileSystem, expirationDuration, expirationUnit)
+        }
+    }
+}

filesystem/src/main/java/com/nytimes/android/external/fs3/SourceAllPersister.kt

@@ -0,0 +1,55 @@
+package com.nytimes.android.external.fs3
+
+
+import com.nytimes.android.external.fs3.filesystem.FileSystem
+import com.nytimes.android.external.store3.base.AllPersister
+import com.nytimes.android.external.store3.base.impl.BarCode
+
+import java.io.FileNotFoundException
+import javax.inject.Inject
+
+import io.reactivex.Maybe
+import io.reactivex.Observable
+import io.reactivex.Single
+import okio.BufferedSource
+
+class SourceAllPersister @Inject
+constructor(fileSystem: FileSystem) : AllPersister<BufferedSource, BarCode> {
+
+    internal val sourceFileAllReader: FSAllReader
+    internal val sourceFileAllEraser: FSAllEraser
+
+    internal val sourceFileReader: FSReader<BarCode>
+    internal val sourceFileWriter: FSWriter<BarCode>
+
+    init {
+        sourceFileAllReader = FSAllReader(fileSystem)
+        sourceFileAllEraser = FSAllEraser(fileSystem)
+        sourceFileReader = FSReader(fileSystem, BarCodeReadAllPathResolver())
+        sourceFileWriter = FSWriter(fileSystem, BarCodeReadAllPathResolver())
+    }
+
+    @Throws(FileNotFoundException::class)
+    override fun readAll(path: String): Observable<BufferedSource> {
+        return sourceFileAllReader.readAll(path)
+    }
+
+    override fun deleteAll(path: String): Observable<Boolean> {
+        return sourceFileAllEraser.deleteAll(path)
+    }
+
+    override fun read(barCode: BarCode): Maybe<BufferedSource> {
+        return sourceFileReader.read(barCode)
+    }
+
+    override fun write(barCode: BarCode, data: BufferedSource): Single<Boolean> {
+        return sourceFileWriter.write(barCode, data)
+    }
+
+    companion object {
+
+        fun create(fileSystem: FileSystem): SourceAllPersister {
+            return SourceAllPersister(fileSystem)
+        }
+    }
+}

filesystem/src/main/java/com/nytimes/android/external/fs3/SourceFileReader.kt

@@ -0,0 +1,17 @@
+package com.nytimes.android.external.fs3
+
+import com.nytimes.android.external.fs3.filesystem.FileSystem
+import com.nytimes.android.external.store3.base.DiskRead
+import com.nytimes.android.external.store3.base.RecordState
+import com.nytimes.android.external.store3.base.impl.BarCode
+import okio.BufferedSource
+import java.util.concurrent.TimeUnit
+
+class SourceFileReader @JvmOverloads constructor(fileSystem: FileSystem, pathResolver: PathResolver<BarCode> = BarCodePathResolver()) : FSReader<BarCode>(fileSystem, pathResolver), DiskRead<BufferedSource, BarCode> {
+
+    fun getRecordState(barCode: BarCode,
+                       expirationUnit: TimeUnit,
+                       expirationDuration: Long): RecordState {
+        return fileSystem.getRecordState(expirationUnit, expirationDuration, SourcePersister.pathForBarcode(barCode))
+    }
+}

filesystem/src/main/java/com/nytimes/android/external/fs3/SourceFileWriter.kt

@@ -0,0 +1,9 @@
+package com.nytimes.android.external.fs3
+
+import com.nytimes.android.external.fs3.filesystem.FileSystem
+import com.nytimes.android.external.store3.base.DiskWrite
+import com.nytimes.android.external.store3.base.impl.BarCode
+
+import okio.BufferedSource
+
+class SourceFileWriter @JvmOverloads constructor(fileSystem: FileSystem, pathResolver: PathResolver<BarCode> = BarCodePathResolver()) : FSWriter<BarCode>(fileSystem, pathResolver), DiskWrite<BufferedSource, BarCode>