Mirrors/chaosflix
2
0
Fork 0
mirror of https://github.com/NiciDieNase/chaosflix synced 2024-11-26 14:10:23 +00:00
Code Issues Projects Releases Packages Wiki Activity

implement deleting of offline items

Browse source
This commit is contained in:
Felix 2017-12-01 01:02:56 +01:00
parent ef0d61f437
commit 7aa77b5259
2 changed files with 53 additions and 36 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

81
touch/src/main/java/de/nicidienase/chaosflix/touch/browse/BrowseViewModel.kt
View file

@ -6,6 +6,7 @@ import android.arch.lifecycle.Observer
import android.arch.lifecycle.ViewModel
import android.content.Context
import android.databinding.ObservableField
import android.os.Environment
import de.nicidienase.chaosflix.common.entities.ChaosflixDatabase
import de.nicidienase.chaosflix.common.entities.download.OfflineEvent
import de.nicidienase.chaosflix.common.network.RecordingService
@ -14,6 +15,7 @@ import de.nicidienase.chaosflix.touch.ChaosflixApplication
import de.nicidienase.chaosflix.touch.sync.Downloader
import io.reactivex.Completable
import io.reactivex.schedulers.Schedulers
import java.io.File
class BrowseViewModel(
val database: ChaosflixDatabase,
@ -64,47 +66,47 @@ class BrowseViewModel(
init {
getOfflineEvents().observeForever(Observer {
val downloadRef = it?.map { it.downloadReference }?.map { downloadStatus.put(it,DownloadStatus()) }
val downloadRef = it?.map { it.downloadReference }?.map { downloadStatus.put(it, DownloadStatus()) }
})
}
fun updateDownloadStatus() {
Completable.fromAction {
getOfflineEvents().observeForever(Observer {
val downloadRef = it?.map { it.downloadReference }?.toTypedArray()?.toLongArray() ?: longArrayOf()
val cursor = downloadManager.query(DownloadManager.Query().setFilterById(*downloadRef))
if (it != null && it.size > 0) {
val downloadRef = it.map { it.downloadReference }.toTypedArray().toLongArray() ?: longArrayOf()
val cursor = downloadManager.query(DownloadManager.Query().setFilterById(*downloadRef))
if (cursor.moveToFirst()) {
do {
val columnId = cursor.getColumnIndex(DownloadManager.COLUMN_ID)
val id = cursor.getLong(columnId)
val columnIndex = cursor.getColumnIndex(DownloadManager.COLUMN_STATUS)
val status = cursor.getInt(columnIndex)
val bytesSoFarIndex = cursor.getColumnIndex(DownloadManager.COLUMN_BYTES_DOWNLOADED_SO_FAR)
val bytesSoFar = cursor.getInt(bytesSoFarIndex)
val bytesTotalIndex = cursor.getColumnIndex(DownloadManager.COLUMN_TOTAL_SIZE_BYTES)
val bytesTotal = cursor.getInt(bytesTotalIndex)
if (cursor.moveToFirst()) {
do {
val columnId = cursor.getColumnIndex(DownloadManager.COLUMN_ID)
val id = cursor.getLong(columnId)
val columnIndex = cursor.getColumnIndex(DownloadManager.COLUMN_STATUS)
val status = cursor.getInt(columnIndex)
val bytesSoFarIndex = cursor.getColumnIndex(DownloadManager.COLUMN_BYTES_DOWNLOADED_SO_FAR)
val bytesSoFar = cursor.getInt(bytesSoFarIndex)
val bytesTotalIndex = cursor.getColumnIndex(DownloadManager.COLUMN_TOTAL_SIZE_BYTES)
val bytesTotal = cursor.getInt(bytesTotalIndex)
val statusText: String =
when (status) {
DownloadManager.STATUS_RUNNING -> "Running"
DownloadManager.STATUS_FAILED -> "Failed"
DownloadManager.STATUS_PAUSED -> "Paused"
DownloadManager.STATUS_SUCCESSFUL -> "Successful"
DownloadManager.STATUS_PENDING -> "Pending"
else -> "UNKNOWN"
}
if (downloadStatus.containsKey(id)) {
val item = downloadStatus[id]
if (item != null) {
item.statusText.set(statusText)
item.currentBytes.set(bytesSoFar)
item.totalBytes.set(bytesTotal)
val statusText: String =
when (status) {
DownloadManager.STATUS_RUNNING -> "Running"
DownloadManager.STATUS_FAILED -> "Failed"
DownloadManager.STATUS_PAUSED -> "Paused"
DownloadManager.STATUS_SUCCESSFUL -> "Successful"
DownloadManager.STATUS_PENDING -> "Pending"
else -> "UNKNOWN"
}
if (downloadStatus.containsKey(id)) {
val item = downloadStatus[id]
item?.statusText?.set(statusText)
item?.currentBytes?.set(bytesSoFar)
item?.totalBytes?.set(bytesTotal)
} else {
downloadStatus.put(id, DownloadStatus(statusText, bytesSoFar, bytesTotal))
}
} else {
downloadStatus.put(id, DownloadStatus(statusText, bytesSoFar, bytesTotal))
}
} while (cursor.moveToNext())
} while (cursor.moveToNext())
}
}
})
}.subscribeOn(Schedulers.io()).subscribe()
@ -122,4 +124,19 @@ class BrowseViewModel(
}
}
fun getUriForEvent(item: OfflineEvent): String {
val directory = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_MOVIES)
val uri = "${directory.toURI()}chaosflix/${item.localPath}"
return uri
}
fun deleteOfflineItem(item: OfflineEvent) {
Completable.fromAction {
val directory = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_MOVIES)
val file = File("${directory.path}/chaosflix/${item.localPath}")
if (file.exists()) file.delete()
database.offlineEventDao().deleteById(item.id)
}.subscribeOn(Schedulers.io()).subscribe()
}
}

8
touch/src/main/java/de/nicidienase/chaosflix/touch/browse/download/OfflineEventAdapter.kt
View file

@ -57,13 +57,11 @@ class OfflineEventAdapter(var items: List<OfflineEvent>, val viewModel: BrowseVi
true
}
R.id.item_play -> {
val directory = Environment.getExternalStoragePublicDirectory(Environment.DIRECTORY_MOVIES)
val uri = "${directory.toURI()}chaosflix/${item.localPath}"
PlayerActivity.launch(view.context, item.event!!, uri)
PlayerActivity.launch(view.context, item.event!!, viewModel.getUriForEvent(item))
true
}
R.id.item_delete -> {
Snackbar.make(view, "Coming soon", Snackbar.LENGTH_SHORT).show()
viewModel.deleteOfflineItem(item)
true
}
else -> false
@ -75,6 +73,8 @@ class OfflineEventAdapter(var items: List<OfflineEvent>, val viewModel: BrowseVi
}
override fun getItemCount(): Int {
return items.size
}