Local Model Download mirrors (#457)

* Local Model Download mirrors

* Update versions

* Fix Unit tests

Author: ShiftHackZ

core/localization/src/main/res/values/strings.xml

@@ -186,6 +186,7 @@
     <string name="title_txt_inversion">Textual Inversion</string>
     <string name="title_txt_inversion_short">Inversion</string>
     <string name="title_tag_edit">Edit tag</string>
+    <string name="title_select_download_source">Select source</string>
 
     <string name="gallery_media_store_banner">You have %1$s photos saved in Download/SDAI</string>
     <string name="gallery_info_field_date">Created</string>

data/src/main/java/com/shifthackz/aisdv1/data/repository/DownloadableModelRepositoryImpl.kt

@@ -13,11 +13,7 @@ internal class DownloadableModelRepositoryImpl(
     private val buildInfoProvider: BuildInfoProvider,
 ) : DownloadableModelRepository {
 
-    override fun download(id: String) = localDataSource
-        .getById(id)
-        .flatMapObservable { model ->
-            remoteDataSource.download(id, model.sources.firstOrNull() ?: "")
-        }
+    override fun download(id: String, url: String) = remoteDataSource.download(id, url)
 
     override fun delete(id: String) = localDataSource.delete(id)
 

data/src/test/java/com/shifthackz/aisdv1/data/repository/DownloadableModelRepositoryImplTest.kt

@@ -219,29 +219,14 @@ class DownloadableModelRepositoryImplTest {
             .assertNotComplete()
     }
 
-    @Test
-    fun `given attempt to download model, local data source has no such model, expected error value`() {
-        every {
-            stubLocalDataSource.getById(any())
-        } returns Single.error(stubException)
-
-        repository
-            .download("5598")
-            .test()
-            .assertNoValues()
-            .assertError(stubException)
-            .await()
-            .assertNotComplete()
-    }
-
     @Test
     fun `given attempt to download model, local data source has such model, download succeeds, expected unknown, downloading, complete values`() {
         every {
             stubLocalDataSource.getById(any())
         } returns Single.just(mockLocalAiModel)
 
         val stubObserver = repository
-            .download("5598")
+            .download("5598", "https://moroz.cc/stub.zip")
             .test()
 
         stubDownloadState.onNext(DownloadState.Unknown)
@@ -276,7 +261,7 @@ class DownloadableModelRepositoryImplTest {
         } returns Single.just(mockLocalAiModel)
 
         val stubObserver = repository
-            .download("5598")
+            .download("5598", "https://moroz.cc/stub.zip")
             .test()
 
         stubDownloadState.onNext(DownloadState.Unknown)
@@ -309,7 +294,7 @@ class DownloadableModelRepositoryImplTest {
         } returns Observable.error(stubException)
 
         repository
-            .download("5598")
+            .download("5598", "https://moroz.cc/stub.zip")
             .test()
             .assertError(stubException)
             .assertNoValues()

domain/src/main/java/com/shifthackz/aisdv1/domain/di/DomainModule.kt

@@ -38,6 +38,8 @@ import com.shifthackz.aisdv1.domain.usecase.downloadable.DownloadModelUseCase
 import com.shifthackz.aisdv1.domain.usecase.downloadable.DownloadModelUseCaseImpl
 import com.shifthackz.aisdv1.domain.usecase.downloadable.GetLocalMediaPipeModelsUseCase
 import com.shifthackz.aisdv1.domain.usecase.downloadable.GetLocalMediaPipeModelsUseCaseImpl
+import com.shifthackz.aisdv1.domain.usecase.downloadable.GetLocalModelUseCase
+import com.shifthackz.aisdv1.domain.usecase.downloadable.GetLocalModelUseCaseImpl
 import com.shifthackz.aisdv1.domain.usecase.downloadable.GetLocalOnnxModelsUseCase
 import com.shifthackz.aisdv1.domain.usecase.downloadable.GetLocalOnnxModelsUseCaseImpl
 import com.shifthackz.aisdv1.domain.usecase.downloadable.ObserveLocalOnnxModelsUseCase
@@ -185,6 +187,7 @@ internal val useCasesModule = module {
     factoryOf(::FetchAndGetStabilityAiEnginesUseCaseImpl) bind FetchAndGetStabilityAiEnginesUseCase::class
     factoryOf(::FetchAndGetSupportersUseCaseImpl) bind FetchAndGetSupportersUseCase::class
     factoryOf(::SendReportUseCaseImpl) bind SendReportUseCase::class
+    factoryOf(::GetLocalModelUseCaseImpl) bind GetLocalModelUseCase::class
 }
 
 internal val interActorsModule = module {

domain/src/main/java/com/shifthackz/aisdv1/domain/repository/DownloadableModelRepository.kt

@@ -8,7 +8,7 @@ import io.reactivex.rxjava3.core.Observable
 import io.reactivex.rxjava3.core.Single
 
 interface DownloadableModelRepository {
-    fun download(id: String): Observable<DownloadState>
+    fun download(id: String, url: String): Observable<DownloadState>
     fun delete(id: String): Completable
     fun getAllOnnx(): Single<List<LocalAiModel>>
     fun getAllMediaPipe(): Single<List<LocalAiModel>>

domain/src/main/java/com/shifthackz/aisdv1/domain/usecase/downloadable/DownloadModelUseCase.kt

@@ -4,5 +4,5 @@ import com.shifthackz.aisdv1.domain.entity.DownloadState
 import io.reactivex.rxjava3.core.Observable
 
 interface DownloadModelUseCase {
-    operator fun invoke(id: String): Observable<DownloadState>
+    operator fun invoke(id: String, url: String): Observable<DownloadState>
 }

domain/src/main/java/com/shifthackz/aisdv1/domain/usecase/downloadable/DownloadModelUseCaseImpl.kt

@@ -6,5 +6,5 @@ internal class DownloadModelUseCaseImpl(
     private val downloadableModelRepository: DownloadableModelRepository,
 ) : DownloadModelUseCase {
 
-    override fun invoke(id: String) = downloadableModelRepository.download(id)
+    override fun invoke(id: String, url: String) = downloadableModelRepository.download(id, url)
 }

domain/src/main/java/com/shifthackz/aisdv1/domain/usecase/downloadable/GetLocalModelUseCase.kt

@@ -0,0 +1,8 @@
+package com.shifthackz.aisdv1.domain.usecase.downloadable
+
+import com.shifthackz.aisdv1.domain.entity.LocalAiModel
+import io.reactivex.rxjava3.core.Single
+
+interface GetLocalModelUseCase {
+    operator fun invoke(id: String): Single<LocalAiModel>
+}

domain/src/main/java/com/shifthackz/aisdv1/domain/usecase/downloadable/GetLocalModelUseCaseImpl.kt

@@ -0,0 +1,12 @@
+package com.shifthackz.aisdv1.domain.usecase.downloadable
+
+import com.shifthackz.aisdv1.domain.datasource.DownloadableModelDataSource
+import com.shifthackz.aisdv1.domain.entity.LocalAiModel
+import io.reactivex.rxjava3.core.Single
+
+internal class GetLocalModelUseCaseImpl(
+    private val localDataSource: DownloadableModelDataSource.Local,
+) : GetLocalModelUseCase {
+
+    override fun invoke(id: String): Single<LocalAiModel> = localDataSource.getById(id)
+}

domain/src/test/java/com/shifthackz/aisdv1/domain/usecase/downloadable/DownloadModelUseCaseImplTest.kt

@@ -23,13 +23,13 @@ class DownloadModelUseCaseImplTest {
 
     @Before
     fun initialize() {
-        whenever(stubRepository.download(any()))
+        whenever(stubRepository.download(any(), any()))
             .thenReturn(stubDownloadStatus)
     }
 
     @Test
     fun `given download running, then finishes successfully, expected final state is Complete`() {
-        val stubObserver = useCase("5598").test()
+        val stubObserver = useCase("5598", "https://moroz.cc/stub.zip").test()
 
         stubDownloadStatus.onNext(DownloadState.Unknown)
 
@@ -58,7 +58,7 @@ class DownloadModelUseCaseImplTest {
 
     @Test
     fun `given download running, then fails, expected final state is Error`() {
-        val stubObserver = useCase("5598").test()
+        val stubObserver = useCase("5598", "https://moroz.cc/stub.zip").test()
 
         stubDownloadStatus.onNext(DownloadState.Unknown)
 
@@ -87,7 +87,7 @@ class DownloadModelUseCaseImplTest {
 
     @Test
     fun `given download running, then fails, then user restarts download, then completes, expected state Error on 1st try, final state is Complete`() {
-        val stubObserver = useCase("5598").test()
+        val stubObserver = useCase("5598", "https://moroz.cc/stub.zip").test()
 
         stubDownloadStatus.onNext(DownloadState.Unknown)
 
@@ -140,10 +140,10 @@ class DownloadModelUseCaseImplTest {
 
     @Test
     fun `given observable terminated with unexpected error, expected error value`() {
-        whenever(stubRepository.download(any()))
+        whenever(stubRepository.download(any(), any()))
             .thenReturn(Observable.error(stubTerminateException))
 
-        useCase("5598")
+        useCase("5598", "https://moroz.cc/stub.zip")
             .test()
             .assertError(stubTerminateException)
             .await()