spray - 带有哈希函数的乐观锁

Question

下面的代码似乎没有错误地完成，但是在堆栈 spray.can.server.HttpServerConnection 的下方希望“If-Match”标头具有特定格式。
我觉得我可能缺少拒绝处理程序？还是我必须关闭某些东西？

有任何想法吗？

api 22:29:56.251 | WARN  | root-actor-system-akka.actor.default-dispatcher-4 | akka://root-actor-system/user/IO-HTTP/listener-0/2 | spray.can.server.HttpServerConnection | Illegal request header: Illegal 'If-Match' header: Invalid input 's', expected $timesIf$minusMatch (line 1, pos 1): somehashfunctionvalue

路线：

override def putObjectRoute = (path("api" / "models" / Segment / "objects") & authenticatedJsonRoute) {
    (modeledSystemName, tenantName, authInfo) =>
      put {
        entity(as[ModeledObject]) { obje =>
          etag(obje, hashfunction) {
            onComplete(service.updateObject(modeledSystemName, tenantName, obje)) {
              case Success(_) => complete(NoContent)
              case Failure(ex) =>
                log.error(ex.getMessage)
                complete(InternalServerError, s"An error occurred: ${ex.getMessage}")
            }
          }
        }

指示：

trait OCCETag {

  def etag[T](entity: T, f: (String, T) => Boolean): Directive0 = optionalHeaderValueByName("If-Match").flatMap {
    case Some(etag) => mapInnerRoute { route =>
      val e = entity
      ctx => {
        def complete304() = ctx.complete(HttpResponse(NotModified))
        def complete412() = ctx.complete(PreconditionFailed)
        if (f(etag, e)) pass else complete412()
      }
    }
    case None => reject(MissingHeaderRejection("If-Match"))
  }
}

Answer 1

我找到了解决方案。我将通行证更改为阅读器路线（ctx）。基本上，通行证不会将上下文彻底交给指令。