Skip to content

Commit

Permalink
#2324 Remove observables with empty data
Browse files Browse the repository at this point in the history
  • Loading branch information
To-om committed Feb 7, 2022
1 parent e2734de commit af4ab42
Show file tree
Hide file tree
Showing 2 changed files with 28 additions and 4 deletions.
16 changes: 14 additions & 2 deletions thehive/app/org/thp/thehive/controllers/v0/ObservableCtrl.scala
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,13 @@ class ObservableCtrl @Inject() (
.flatMap(obs => obs.attachment.map(createAttachmentObservableInCase(case0, obs, _)))
else
inputAttachObs
.flatMap(obs => obs.data.map(createSimpleObservableInCase(case0, obs, _)))
.flatMap(obs =>
obs
.data
.filter(_.exists(_ != ' '))
.filterNot(_.isEmpty)
.map(createSimpleObservableInCase(case0, obs, _))
)
val (successes, failures) = successesAndFailures
.foldLeft[(Seq[JsValue], Seq[JsValue])]((Nil, Nil)) {
case ((s, f), Right(o)) => (s :+ o, f)
Expand Down Expand Up @@ -162,7 +168,13 @@ class ObservableCtrl @Inject() (
}
else
inputAttachObs
.flatMap(obs => obs.data.map(createSimpleObservableInAlert(alert, obs, _)))
.flatMap(obs =>
obs
.data
.filter(_.exists(_ != ' '))
.filterNot(_.isEmpty)
.map(createSimpleObservableInAlert(alert, obs, _))
)
val (successes, failures) = successesAndFailures
.foldLeft[(Seq[JsValue], Seq[JsValue])]((Nil, Nil)) {
case ((s, f), Right(o)) => (s :+ o, f)
Expand Down
16 changes: 14 additions & 2 deletions thehive/app/org/thp/thehive/controllers/v1/ObservableCtrl.scala
Original file line number Diff line number Diff line change
Expand Up @@ -138,7 +138,13 @@ class ObservableCtrl @Inject() (
.flatMap(obs => obs.attachment.map(createAttachmentObservableInCase(case0, obs, _)))
else
inputAttachObs
.flatMap(obs => obs.data.map(createSimpleObservableInCase(case0, obs, _)))
.flatMap(obs =>
obs
.data
.filter(_.exists(_ != ' '))
.filterNot(_.isEmpty)
.map(createSimpleObservableInCase(case0, obs, _))
)
val (successes, failures) = successesAndFailures
.foldLeft[(Seq[JsValue], Seq[JsValue])]((Nil, Nil)) {
case ((s, f), Right(o)) => (s :+ o, f)
Expand Down Expand Up @@ -219,7 +225,13 @@ class ObservableCtrl @Inject() (
}
else
inputAttachObs
.flatMap(obs => obs.data.map(createSimpleObservableInAlert(alert, obs, _)))
.flatMap(obs =>
obs
.data
.filter(_.exists(_ != ' '))
.filterNot(_.isEmpty)
.map(createSimpleObservableInAlert(alert, obs, _))
)
val (successes, failures) = successesAndFailures
.foldLeft[(Seq[JsValue], Seq[JsValue])]((Nil, Nil)) {
case ((s, f), Right(o)) => (s :+ o, f)
Expand Down

0 comments on commit af4ab42

Please sign in to comment.