Skip to content

Commit

Permalink
#110 Fix label in job
Browse files Browse the repository at this point in the history
  • Loading branch information
To-om committed Jul 27, 2018
1 parent 019aea4 commit 0721afa
Show file tree
Hide file tree
Showing 4 changed files with 9 additions and 5 deletions.
2 changes: 2 additions & 0 deletions app/org/thp/cortex/models/Migration.scala
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,8 @@ class Migration @Inject() (
renameAttribute("job", "workerName", "analyzerName"),
addAttribute("job", "type" JsString(WorkerType.analyzer.toString)),

addAttribute("report", "operations" JsString("[]")),

renameEntity("analyzer", "worker"),
renameAttribute("worker", "workerDefinitionId", "analyzerDefinitionId"),
addAttribute("worker", "type" JsString(WorkerType.analyzer.toString)),
Expand Down
8 changes: 5 additions & 3 deletions app/org/thp/cortex/services/JobSrv.scala
Original file line number Diff line number Diff line change
Expand Up @@ -172,14 +172,15 @@ class JobSrv(
val tlp = (attributes \ "tlp").asOpt[Long].getOrElse(2L)
val message = (attributes \ "message").asOpt[String].getOrElse("")
val parameters = (attributes \ "parameters").asOpt[JsObject].getOrElse(JsObject.empty)
val label = (attributes \ "label").asOpt[String]
val force = fields.getBoolean("force").getOrElse(false)
withGood(dataType, dataFiv) {
case (dt, Right(fiv)) dt attachmentSrv.save(fiv).map(Right.apply)
case (dt, Left(data)) dt Future.successful(Left(data))
}
.fold(
typeDataAttachment typeDataAttachment._2.flatMap(
da create(worker, typeDataAttachment._1, da, tlp, message, parameters, force)),
da create(worker, typeDataAttachment._1, da, tlp, message, parameters, label, force)),
errors {
val attributeError = AttributeCheckingError("job", errors)
logger.error("legacy job create fails", attributeError)
Expand Down Expand Up @@ -243,13 +244,13 @@ class JobSrv(
case (dt, Left(data)) dt Future.successful(Left(data))
}
.fold(
typeDataAttachment typeDataAttachment._2.flatMap(da create(worker, typeDataAttachment._1, da, tlp, message, parameters, force)),
typeDataAttachment typeDataAttachment._2.flatMap(da create(worker, typeDataAttachment._1, da, tlp, message, parameters, fields.getString("label"), force)),
errors Future.failed(AttributeCheckingError("job", errors)))
}
}
}

def create(worker: Worker, dataType: String, dataAttachment: Either[String, Attachment], tlp: Long, message: String, parameters: JsObject, force: Boolean)(implicit authContext: AuthContext): Future[Job] = {
def create(worker: Worker, dataType: String, dataAttachment: Either[String, Attachment], tlp: Long, message: String, parameters: JsObject, label: Option[String], force: Boolean)(implicit authContext: AuthContext): Future[Job] = {
val previousJob = if (force) Future.successful(None)
else findSimilarJob(worker, dataType, dataAttachment, tlp, parameters)
previousJob.flatMap {
Expand All @@ -267,6 +268,7 @@ class JobSrv(
"message" message,
"parameters" parameters.toString,
"type" worker.tpe()))
.set("label", label.map(JsString.apply))
val fieldWithData = dataAttachment match {
case Left(data) fields.set("data", data)
case Right(attachment) fields.set("attachment", AttachmentInputValue(attachment))
Expand Down
2 changes: 1 addition & 1 deletion app/org/thp/cortex/services/MispSrv.scala
Original file line number Diff line number Diff line change
Expand Up @@ -63,7 +63,7 @@ class MispSrv @Inject() (

for {
analyzer workerSrv.get(module)
job jobSrv.create(analyzer, mispType2dataType(mispType), artifact, 0, "", JsObject.empty, force = false)
job jobSrv.create(analyzer, mispType2dataType(mispType), artifact, 0, "", JsObject.empty, None, force = false)
_ auditActor.ask(Register(job.id, duration))(Timeout(duration))
updatedJob jobSrv.getForUser(authContext.userId, job.id)
mispOutput toMispOutput(authContext.userId, updatedJob)
Expand Down
2 changes: 1 addition & 1 deletion www/src/app/pages/jobs/components/jobs.list.html
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@
<h4 class="media-heading text-primary">
<strong>[{{job.dataType}}]</strong>
<span ng-if="job.type !== 'responder'">{{(isFile ? job.attachment.name : job.data) | fang | limitTo:200}}</span>
<span ng-if="job.type === 'responder'">{{job.data.label || 'No Label'}}</span>
<span ng-if="job.type === 'responder'">{{job.label || 'No Label'}}</span>
</h4>
<div class="row mv-xs text-muted">
<div class="col-sm-4">
Expand Down

0 comments on commit 0721afa

Please sign in to comment.