Skip to content

Commit

Permalink
#2336 Fix parsing for parentId query
Browse files Browse the repository at this point in the history
  • Loading branch information
To-om committed Feb 7, 2022
1 parent c0c2442 commit e2734de
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ class CortexQueryExecutor @Inject() (

override val customFilterQuery: FilterQuery = FilterQuery(publicProperties) { (tpe, globalParser) =>
FieldsParser("parentChildFilter") {
case (_, FObjOne("_parent", ParentIdFilter(_, parentId))) if parentTypes.isDefinedAt(tpe) =>
case (_, FObjOne("_parent", ParentIdFilter(parentId, _))) if parentTypes.isDefinedAt(tpe) =>
Good(new CortexParentIdInputFilter(parentId))
case (path, FObjOne("_parent", ParentQueryFilter(_, parentFilterField))) if parentTypes.isDefinedAt(tpe) =>
globalParser(parentTypes(tpe)).apply(path, parentFilterField).map(query => new CortexParentQueryInputFilter(query))
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ class TheHiveQueryExecutor @Inject() (
}
override val customFilterQuery: FilterQuery = FilterQuery(publicProperties) { (tpe, globalParser) =>
FieldsParser("parentChildFilter") {
case (_, FObjOne("_parent", ParentIdFilter(parentType, parentId))) if parentTypes.isDefinedAt((tpe, parentType)) =>
case (_, FObjOne("_parent", ParentIdFilter(parentId, parentType))) if parentTypes.isDefinedAt((tpe, parentType)) =>
Good(new ParentIdInputFilter(parentId))
case (path, FObjOne("_parent", ParentQueryFilter(parentType, parentFilterField))) if parentTypes.isDefinedAt((tpe, parentType)) =>
globalParser(parentTypes((tpe, parentType))).apply(path, parentFilterField).map(query => new ParentQueryInputFilter(parentType, query))
Expand Down Expand Up @@ -149,17 +149,17 @@ class ParentIdInputFilter(parentId: String) extends InputQuery[Traversal.Unk, Tr
case t if t <:< ru.typeOf[Task] =>
traversal
.asInstanceOf[Traversal.V[Task]]
.has(_.relatedId, EntityId(parentId))
.has(_.relatedId, EntityId.read(parentId))
.asInstanceOf[Traversal.Unk]
case t if t <:< ru.typeOf[Observable] =>
traversal
.asInstanceOf[Traversal.V[Observable]]
.has(_.relatedId, EntityId(parentId))
.has(_.relatedId, EntityId.read(parentId))
.asInstanceOf[Traversal.Unk]
case t if t <:< ru.typeOf[Log] =>
traversal
.asInstanceOf[Traversal.V[Log]]
.has(_.taskId, EntityId(parentId))
.has(_.taskId, EntityId.read(parentId))
.asInstanceOf[Traversal.Unk]
}
.getOrElse(throw BadRequestError(s"$traversalType hasn't parent"))
Expand Down

0 comments on commit e2734de

Please sign in to comment.