This repository was archived by the owner on Aug 18, 2020. It is now read-only.
File tree 3 files changed +39
-1
lines changed
src/main/scala/org/codeoverflow/chatoverflow
3 files changed +39
-1
lines changed Original file line number Diff line number Diff line change @@ -59,7 +59,19 @@ class FileSystemActor extends Actor {
59
59
}
60
60
case CreateDirectory (folderName) =>
61
61
try {
62
- sender ! fixPath(folderName).mkdir()
62
+ sender ! fixPath(folderName).mkdirs()
63
+ } catch {
64
+ case _ : Exception => sender ! false
65
+ }
66
+ case Exists (pathInResources) =>
67
+ try {
68
+ sender ! fixPath(pathInResources).exists
69
+ } catch {
70
+ case _ : Exception => sender ! false
71
+ }
72
+ case Delete (pathInResources) =>
73
+ try {
74
+ sender ! fixPath(pathInResources).delete
63
75
} catch {
64
76
case _ : Exception => sender ! false
65
77
}
@@ -123,4 +135,18 @@ object FileSystemActor {
123
135
*/
124
136
case class CreateDirectory (folderName : String ) extends ActorMessage
125
137
138
+ /**
139
+ * Send a Exists-Object to the FileSystemActor to check if a file or folder exists
140
+ *
141
+ * @param pathInResources the relative Path in the resource folder
142
+ */
143
+ case class Exists (pathInResources : String ) extends ActorMessage
144
+
145
+ /**
146
+ * Send a Delete-Object to the FileSystemActor to remove a file or folder
147
+ *
148
+ * @param pathInResources the relative Path in the resource folder
149
+ */
150
+ case class Delete (pathInResources : String ) extends ActorMessage
151
+
126
152
}
Original file line number Diff line number Diff line change @@ -34,6 +34,10 @@ class FileConnector(override val sourceIdentifier: String) extends Connector(sou
34
34
35
35
def createDirectory (folderName : String ): Boolean = fileActor.?? [Boolean ](5 ){CreateDirectory (folderName)}.get
36
36
37
+ def exists (pathInResources : String ): Boolean = fileActor.?? [Boolean ](5 ){Exists (pathInResources)}.get
38
+
39
+ def delete (pathInResources : String ): Boolean = fileActor.?? [Boolean ](5 ){Delete (pathInResources)}.get
40
+
37
41
override def start (): Boolean = {
38
42
logger info s " Started file connector! Source identifier is: ' $sourceIdentifier'. "
39
43
true
Original file line number Diff line number Diff line change @@ -35,6 +35,14 @@ class FileOutputImpl extends OutputImpl[FileConnector] with FileOutput with With
35
35
sourceConnector.get.createDirectory(folderName)
36
36
}
37
37
38
+ override def exists (pathInResources : String ): Boolean = {
39
+ sourceConnector.get.exists(pathInResources)
40
+ }
41
+
42
+ override def delete (pathInResources : String ): Boolean = {
43
+ sourceConnector.get.delete(pathInResources)
44
+ }
45
+
38
46
override def start () = true
39
47
40
48
}
You can’t perform that action at this time.
0 commit comments