http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/framing/Http2FrameParsing.scala (6 lines): - line 56: // TODO: add @switch? seems non-trivial for now - line 106: SettingsAckFrame(Nil) // TODO if we were to send out settings, here would be the spot to include the acks for the ones we've sent out - line 115: // TODO: check frame size - line 116: // TODO: check flags - line 160: case tpe => // TODO: remove once all stream types are defined - line 197: // TODO: assert that reserved bit is 0 by checking if streamId > 0 http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/Http2StreamHandling.scala (4 lines): - line 544: // FIXME: DRY with below - line 581: // FIXME: do we need to adjust connection level window here as described in https://httpwg.org/specs/rfc7540.html#StreamStates: - line 604: // FIXME: go through state machine and don't manipulate vars directly here - line 792: // TODO: Check that buffer is not too much over the limit (which we might warn the user about) http/src/main/scala/org/apache/pekko/http/javadsl/server/directives/HeaderDirectives.scala (4 lines): - line 45: // TODO When breaking binary compatibility this should become HttpOriginRange.Default, see https://github.com/akka/akka/pull/20776/files#r70049845 - line 154: * FIXME: WARNING: Custom headers don't work yet with this directive! - line 159: // TODO custom headers don't work yet - line 160: // TODO needs instance of check if it's a modeled header and then magically locate companion http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/Http2Blueprint.scala (4 lines): - line 124: val masterHttpHeaderParser = HttpHeaderParser(settings.parserSettings, log) // FIXME: reuse for framing - line 247: * TODO: introduce another FrameEvent type that exclude HeadersFrame and ContinuationFrame from - line 258: * and handles priorization (TODO: later) - line 266: * and handles priorization (TODO: later) http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/Http2.scala (3 lines): - line 68: // FIXME: won't having the same package as top-level break osgi? - line 77: // TODO: split up similarly to what `Http` does into `serverLayer`, `bindAndHandle`, etc. - line 244: // TODO FIXME configure hostname verification for this case http-core/src/main/scala/org/apache/pekko/http/impl/engine/parsing/BodyPartParser.scala (3 lines): - line 57: // TODO: prevent re-priming header parser from scratch - line 67: private var output = collection.immutable.Queue.empty[Output] // FIXME this probably is too wasteful - line 333: // TODO: evaluate whether an upgrade to the more efficient FJS is worth the implementation cost http-marshallers-scala/http-spray-json/src/main/scala/org/apache/pekko/http/scaladsl/marshallers/sprayjson/SprayJsonSupport.scala (2 lines): - line 51: // TODO we could optimise ByteStrings to better handle linear access like this (or provide ByteStrings.linearAccessOptimised) - line 52: // TODO IF it's worth it. http-core/src/main/scala/org/apache/pekko/http/impl/engine/client/pool/SlotState.scala (2 lines): - line 244: // TODO: register failed connection attempt to be able to backoff (see https://github.com/akka/akka-http/issues/1391) - line 338: ctx.warning(msg) // FIXME: should still warn here? http-core/src/main/scala/org/apache/pekko/http/impl/engine/client/pool/NewHostConnectionPool.scala (2 lines): - line 503: withSlot(_.debug("Received response")) // FIXME: add abbreviated info - line 558: // FIXME: after moving to Akka 2.6.x only, we can use cancelation cause propagation which would probably also report http-core/src/main/scala/org/apache/pekko/http/impl/engine/parsing/HttpHeaderParser.scala (2 lines): - line 94: // TODO: evaluate whether switching to a value-class-based approach allows us to improve code readability without sacrificing performance - line 566: // TODO: optimize by running the header value parser directly on the input ByteString (rather than an extracted String); seems done? http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/Http2Demux.scala (2 lines): - line 323: // FIXME: handle the connection closing according to the specification - line 428: // FIXME: What if user handler doesn't pull in new substreams? Should we reject them http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/HttpEntity.scala (2 lines): - line 355: // TODO: re-establish serializability - line 356: // TODO: equal/hashcode ? http/src/main/scala/org/apache/pekko/http/javadsl/server/directives/SecurityDirectives.scala (2 lines): - line 68: inner.apply(cred.map(_.asJava).toJava).delegate // TODO attempt to not need map() - line 277: _.left.map(_.asScala)) // TODO make sure cast is safe http/src/main/scala/org/apache/pekko/http/javadsl/marshalling/Marshaller.scala (2 lines): - line 78: // TODO make sure these are actually usable in a sane way - line 211: // TODO would be nice to not need this special case http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/hpack/HeaderDecompression.scala (2 lines): - line 97: decoder.endHeaderBlock() // TODO: do we have to check the result here? - line 119: // FIXME: handle SETTINGS frames that change decompression parameters http/src/main/scala/org/apache/pekko/http/scaladsl/server/Rejection.scala (2 lines): - line 139: scala.collection.mutable.Set(supported.map(_.asJava).toVector: _*).asJava // TODO optimise - line 341: transformed.asJava // TODO "asJavaDeep" and optimise? http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/hpack/Http2HeaderParsing.scala (1 line): - line 52: Uri.parseHttp2AuthorityPseudoHeader(value /*FIXME: , mode = serverSettings.parserSettings.uriParsingMode*/ ) http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/headers/HttpChallenge.scala (1 line): - line 49: // FIXME: AbstractFunction3 required for bin compat. remove in Akka 10.0 and change realm in case class to option #20786 http/src/main/scala/org/apache/pekko/http/javadsl/unmarshalling/Unmarshaller.scala (1 line): - line 215: // TODO not exposed for Java yet http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/headers/HttpCookie.scala (1 line): - line 157: // TODO: suppress running these requires for cookies created from our header parser http-core/src/main/scala/org/apache/pekko/http/impl/model/parser/LinkHeader.scala (1 line): - line 46: // TODO: support `link-extension` http-core/src/main/scala/org/apache/pekko/http/impl/util/StageLoggingWithOverride.scala (1 line): - line 25: // TODO Try to reconcile with what Pekko provides in StageLogging. http/src/main/scala/org/apache/pekko/http/scaladsl/server/directives/HeaderDirectives.scala (1 line): - line 224: // TODO DRY? http-core/src/main/scala/org/apache/pekko/http/scaladsl/ClientTransport.scala (1 line): - line 150: // TODO: replace with lazyFutureFlow when support for Akka 2.5.x is dropped http/src/main/scala/org/apache/pekko/http/javadsl/server/RoutingJavaMapping.scala (1 line): - line 56: // TODO make it inherit http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/RequestParsing.scala (1 line): - line 204: // FIXME: later modify by adding HttpHeaderParser.parseHttp2Header that would use (name, value) pair directly http/src/main/scala/org/apache/pekko/http/scaladsl/server/package.scala (1 line): - line 28: def FIXME = throw new RuntimeException("Not yet implemented") http-core/src/main/scala/org/apache/pekko/http/impl/engine/ws/FrameOutHandler.scala (1 line): - line 55: // let user complete it, FIXME: maybe make configurable? immediately, or timeout http/src/main/scala/org/apache/pekko/http/javadsl/server/directives/RouteDirectives.scala (1 line): - line 336: // TODO: This might need to be raised as an issue to scala-java8-compat instead. http-core/src/main/scala/org/apache/pekko/http/impl/engine/ws/WebSocket.scala (1 line): - line 50: closeTimeout: FiniteDuration = 3.seconds, // TODO put close timeout into the settings? parsing/src/main/scala-3/org/apache/pekko/http/ccompat/pre213macro.scala (1 line): - line 18: // FIXME: need to implement or we will resurrect some ugly things (or remove 2.12 support) http/src/main/scala/org/apache/pekko/http/scaladsl/common/StrictForm.scala (1 line): - line 55: // TODO: make timeout configurable http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/client/PersistentConnection.scala (1 line): - line 211: override def onUpstreamFailure(ex: Throwable): Unit = onDisconnected() // FIXME: log error http-core/src/main/scala/org/apache/pekko/http/impl/model/parser/UriParser.scala (1 line): - line 352: ) // TODO: asterisk-form http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/FrameEvent.scala (1 line): - line 56: def sizeInWindow: Int = payload.size // FIXME: take padding size into account, #1313 http-core/src/main/scala/org/apache/pekko/http/scaladsl/Http.scala (1 line): - line 832: // FIXME: that statement is wrong since this method is used for the superPool as well which can comprise any number of target host pools. http/src/main/scala/org/apache/pekko/http/javadsl/server/directives/BasicDirectives.scala (1 line): - line 83: } // TODO try to remove map() http-core/src/main/scala/org/apache/pekko/http/javadsl/ConnectHttp.scala (1 line): - line 45: // TODO may be optimised a bit to avoid parsing the Uri entirely for the known port cases http-core/src/main/scala/org/apache/pekko/http/impl/engine/server/HttpServerBluePrint.scala (1 line): - line 326: // TODO: provide and use default impl for simply connecting an input and an output port as we do here http/src/main/scala/org/apache/pekko/http/scaladsl/marshalling/Marshaller.scala (1 line): - line 23: // TODO make it extend JavaDSL http/src/main/scala/org/apache/pekko/http/scaladsl/server/Directive.scala (1 line): - line 221: * TODO: remove with next binary incompatible release bump http/src/main/scala/org/apache/pekko/http/scaladsl/client/RequestBuilding.scala (1 line): - line 75: // TODO: reactivate after HTTP message encoding has been ported http-core/src/main/scala/org/apache/pekko/http/impl/engine/client/PoolMasterActor.scala (1 line): - line 207: // FIXME: shutdown pools directly without going through message, https://github.com/akka/akka-http/issues/3184 http/src/main/scala/org/apache/pekko/http/scaladsl/server/directives/CacheConditionDirectives.scala (1 line): - line 95: // TODO: also handle Cache-Control and Vary http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/framing/FrameRenderer.scala (1 line): - line 46: // TODO: should padding be emitted? In which cases? http/src/main/scala/org/apache/pekko/http/javadsl/server/Rejections.scala (1 line): - line 464: s.TransformationRejection(rejections => f.apply(rejections.map(_.asJava).asJava).asScala.toVector.map(_.asScala)) // TODO this is maddness http-core/src/main/scala/org/apache/pekko/http/impl/engine/ws/Handshake.scala (1 line): - line 95: // TODO See #18709 Extension support is optional in WS and currently unsupported. http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/hpack/ByteStringInputStream.scala (1 line): - line 30: // TODO optimise, ByteString needs to expose InputStream (esp if array backed, nice!) http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/PriorityTree.scala (1 line): - line 102: this // FIXME: actually implement moving nodes down in a dependency chain http-core/src/main/scala/org/apache/pekko/http/impl/engine/ws/MessageToFrameRenderer.scala (1 line): - line 35: // FIXME: fragment? project/Doc.scala (1 line): - line 160: // FIXME: see https://github.com/akka/akka-http/issues/230 project/ValidatePullRequest.scala (1 line): - line 553: // TODO - Line wrapping an other magikz http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/Uri.scala (1 line): - line 439: // FIXME: add test for this method http-core/src/main/scala/org/apache/pekko/http/impl/util/Rendering.scala (1 line): - line 472: // TODO: optimize by adding another `putByteArrayUnsafe` overload taking an byte array slice http/src/main/scala/org/apache/pekko/http/scaladsl/server/directives/RangeDirectives.scala (1 line): - line 154: ctx.reject(UnsatisfiableRangeRejection(ranges, -1)) // FIXME: provide better error http-scalafix/scalafix-rules/src/main/scala/org/apache/pekko/http/fix/MigrateToServerBuilder.scala (1 line): - line 105: // FIXME: warn about parallelism if it exists http-core/src/main/scala/org/apache/pekko/http/javadsl/ServerBinding.scala (1 line): - line 116: * TODO: This feature request is tracked by: https://github.com/akka/akka-http/issues/1210 http/src/main/scala/org/apache/pekko/http/scaladsl/marshalling/PredefinedToResponseMarshallers.scala (1 line): - line 120: // TODO we could either special case for certain known types, http-core/src/main/scala/org/apache/pekko/http/impl/engine/http2/HttpMessageRendering.scala (1 line): - line 37: // TODO: optionally a less drastic measure would be only resetting all the active substreams http-core/src/main/scala/org/apache/pekko/http/scaladsl/model/Multipart.scala (1 line): - line 372: // FIXME: SI-2991 workaround - two functions below. Remove when (hopefully) this issue is fixed http/src/main/scala/org/apache/pekko/http/javadsl/server/directives/FutureDirectives.scala (1 line): - line 118: // TODO: This might need to be raised as an issue to scala-java8-compat instead. http-core/src/main/scala/org/apache/pekko/http/impl/util/JavaVersion.scala (1 line): - line 24: // FIXME replace with Runtime.version() when we no longer support Java 8