-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Created Datasource for the filesystem access. Makes things more testable.
- Loading branch information
1 parent
7091c4a
commit 48fc4cf
Showing
10 changed files
with
331 additions
and
182 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
17 changes: 17 additions & 0 deletions
17
server/src/main/kotlin/com/darkrockstudios/apps/hammer/projects/ProjectsDatasource.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,17 @@ | ||
| package com.darkrockstudios.apps.hammer.projects | ||
|
|
||
| import com.darkrockstudios.apps.hammer.project.ProjectDefinition | ||
| import com.darkrockstudios.apps.hammer.project.ProjectsSyncData | ||
|
|
||
| interface ProjectsDatasource { | ||
| fun saveSyncData(userId: Long, data: ProjectsSyncData) | ||
| fun getProjects(userId: Long): Set<ProjectDefinition> | ||
| fun loadSyncData(userId: Long): ProjectsSyncData | ||
| fun createUserData(userId: Long) | ||
| fun updateSyncData( | ||
| userId: Long, | ||
| action: (ProjectsSyncData) -> ProjectsSyncData | ||
| ): ProjectsSyncData | ||
|
|
||
| fun deleteProject(userId: Long, projectName: String): Result<Unit> | ||
| } |
121 changes: 121 additions & 0 deletions
121
.../src/main/kotlin/com/darkrockstudios/apps/hammer/projects/ProjectsFileSystemDatasource.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,121 @@ | ||
| package com.darkrockstudios.apps.hammer.projects | ||
|
|
||
| import com.darkrockstudios.apps.hammer.project.ProjectDefinition | ||
| import com.darkrockstudios.apps.hammer.project.ProjectRepository | ||
| import com.darkrockstudios.apps.hammer.project.ProjectsSyncData | ||
| import com.darkrockstudios.apps.hammer.projects.ProjectsRepository.Companion.defaultData | ||
| import com.darkrockstudios.apps.hammer.utilities.getRootDataDirectory | ||
| import kotlinx.serialization.encodeToString | ||
| import kotlinx.serialization.json.Json | ||
| import okio.FileSystem | ||
| import okio.Path | ||
|
|
||
| class ProjectsFileSystemDatasource( | ||
| private val fileSystem: FileSystem, | ||
| private val json: Json, | ||
| ) : ProjectsDatasource { | ||
|
|
||
| private fun getUserDirectory(userId: Long): Path { | ||
| return getUserDirectory(userId, fileSystem) | ||
| } | ||
|
|
||
| private fun getSyncDataPath(userId: Long): Path = getUserDirectory(userId) / DATA_FILE | ||
|
|
||
| override fun createUserData(userId: Long) { | ||
| val userDir = getUserDirectory(userId) | ||
|
|
||
| fileSystem.createDirectories(userDir) | ||
|
|
||
| val dataFile = userDir / DATA_FILE | ||
| val data = defaultData(userId) | ||
| val dataJson = json.encodeToString(data) | ||
| fileSystem.write(dataFile) { | ||
| writeUtf8(dataJson) | ||
| } | ||
|
|
||
| /* | ||
| val projectsFile = userDir / PROJECT_FILE | ||
| // Create the zip file with a place holder entry | ||
| //val zipFs = fileSystem.openZip(projectsFile) | ||
| val zipFile = File(projectsFile.toString()) | ||
| val out = ZipOutputStream(FileOutputStream(zipFile)) | ||
| val e = ZipEntry(".") | ||
| out.putNextEntry(e) | ||
| val placeHolderData = "\n".toByteArray() | ||
| out.write(placeHolderData, 0, placeHolderData.size) | ||
| out.closeEntry() | ||
| out.close() | ||
| */ | ||
| } | ||
|
|
||
| override fun deleteProject(userId: Long, projectName: String): Result<Unit> { | ||
| val projectDef = ProjectDefinition(projectName) | ||
| val projectDir = ProjectRepository.getProjectDirectory(userId, projectDef, fileSystem) | ||
| fileSystem.deleteRecursively(projectDir) | ||
|
|
||
| updateSyncData(userId) { data -> | ||
| data.copy( | ||
| deletedProjects = data.deletedProjects + projectName | ||
| ) | ||
| } | ||
|
|
||
| return Result.success(Unit) | ||
| } | ||
|
|
||
| override fun updateSyncData( | ||
| userId: Long, | ||
| action: (ProjectsSyncData) -> ProjectsSyncData | ||
| ): ProjectsSyncData { | ||
| val data = loadSyncData(userId) | ||
| val update = action(data) | ||
| saveSyncData(userId, update) | ||
| return update | ||
| } | ||
|
|
||
| override fun saveSyncData(userId: Long, data: ProjectsSyncData) { | ||
| val path = getSyncDataPath(userId) | ||
| fileSystem.write(path) { | ||
| val syncDataJson = json.encodeToString(data) | ||
| writeUtf8(syncDataJson) | ||
| } | ||
| } | ||
|
|
||
| override fun getProjects(userId: Long): Set<ProjectDefinition> { | ||
| val projectsDir = getUserDirectory(userId) | ||
| return fileSystem.list(projectsDir) | ||
| .filter { fileSystem.metadata(it).isDirectory } | ||
| .filter { it.name.startsWith('.').not() } | ||
| .map { path -> ProjectDefinition(path.name) } | ||
| .toSet() | ||
| } | ||
|
|
||
| override fun loadSyncData(userId: Long): ProjectsSyncData { | ||
| val path = getSyncDataPath(userId) | ||
| return if (fileSystem.exists(path)) { | ||
| fileSystem.read(path) { | ||
| val syncDataJson = readUtf8() | ||
| json.decodeFromString(syncDataJson) | ||
| } | ||
| } else { | ||
| val data = defaultData(userId) | ||
| saveSyncData(userId, data) | ||
| data | ||
| } | ||
| } | ||
|
|
||
| companion object { | ||
| private const val DATA_DIRECTORY = "user_data" | ||
| private const val DATA_FILE = "syncData.json" | ||
|
|
||
| fun getRootDirectory(fileSystem: FileSystem): Path = | ||
| getRootDataDirectory(fileSystem) / DATA_DIRECTORY | ||
|
|
||
| fun getUserDirectory(userId: Long, fileSystem: FileSystem): Path { | ||
| val dir = getRootDirectory(fileSystem) | ||
| return dir / userId.toString() | ||
| } | ||
|
|
||
| fun getSyncDataPath(userId: Long, fileSystem: FileSystem): Path = | ||
| getUserDirectory(userId, fileSystem) / DATA_FILE | ||
| } | ||
| } |
Oops, something went wrong.