Changes

Extracted interfaces for `WebsocketRoute` and `SseThingsRoute` to make
it possible to provide custom implementations. Moved `SseThingsRoute` to
package `things` as it belongs the things route.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Fixed compilation error because of type mismatch.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Adds static method to DittoRuntimeException to build a
DittoRuntimeException from Throwable.
* This is introduced because there were multiple places where such logic
 was implemented
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>

Refactoring of `ThingsSseRoute` and `WebsocketRoute`: * `ThingsSseRoute`
no longer extends `AbstractRoute` to get rid of actually unused fields
and complexity. * Adjusted code formatting and extracted methods of
`ThingsSseRoute` to improve readability. * Renamed `WebsocketRoute` to
`WebSocketRoute` to comply to the correct notation for 'WebSocket'. *
Renamed `WebsocketRouteBuilder` to `WebSocketRouteBuilder` to comply to
the correct notation for 'WebSocket'. * Introduced static factory
methods for `ThingsSseRoute` and `WebSocketRoute`. * Introduced
`WebSocketAuthorizationEnforcer` to optionally enforce authorization
before establishing a WebSocket connection.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Adjusted code formatting of `StopStreaming` and added null checks for
constructor arguments. Added unit tests for `StopStreaming`.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Made it possible to close an existing WebSocketConnection: * Made
`WebSocketRoute` truly a builder. * Added `CloseWebSocket` command. *
Made `EventAndResponsePublisher` to handle `CloseWebSocket` command. *
Added `WebSocketSupervisor` to provide a means for interfering in an
existing WebSocket connection.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Added possible exception to Javadoc comment of `supervise` method.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Use parameter of withIncommingEventSniffer and withOutgoingEventSniffer
* small bugfix because previously just the same value was assigned to
itself.
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>

Set log level of tick-related events to "trace" to reduce number of log
messages on debug level; had to use another logger as Akka's
LoggingAdapter does not support log level "trace".
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

NormalizedMessageMapper: Fix compile errors.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Disable mapping validation for now.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Optionally check authorization before opening SSE connections. * Renamed
`ThingsSseRoute` to `ThingsSseRouteBuilder` and made it a mutable
builder. * Introduced `SseAuthorizationEnforcer` to optionally enforce
authorization before establishing a SSE connection.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Handle invalid URI format of href in DittoRuntimeException
* This exception is ignored in multiple places so we could provide
 this handling in DittoRuntimeException itself
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>

Set bind-timeout to 6s so it's less possible to have a timeout when
starting the cluster locally in debug mode.
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>

Add "reply-target" to source and Ditto headers; remove unused timers.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Fixed parameter name of `WebSocketSupervisor.supervise` method.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Renamed `CloseWebSocket` to `CloseStreamExceptionally` to make it
re-usable for other streaming connections.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Made it possible to close an existing SSE connection: Added
`SseConnectionSupervisor` to provide a means for interfering in an
existing SSE connection.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Implement & test reply-target evaluation; stabilize tests.
Some connectivity unit tests have their actor system restarted each test 
to prevent interference from other tests.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

review: moved "credentials" and "replies" package contents of
model-connectivity into base package
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

#537 removed all code and configuration for suffixed collections in
thins and policies
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>

Placeholder pipeline: Replace Option<String> by dedicated
PipelineElement.
Reason: To add another pipeline function fn:delete that should delete
the entire string containing the pipeline, which is not evaluated yet.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

#537 fixed test
Signed-off-by: krj1imb <johannes.schneider@bosch-si.com>

Implement fn:delete.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Relax strictness of target address placeholder replacement; fix tests.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Remove duplicate substitution function in the class Placeholders.
Use ExpressionResolver.substitute instead; it is faster.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Fix TODO in AmqpConsumerActor; add "to" AMQP property.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Test and fix execution of pipelines starting with a function.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Resolve single pipeline expressions into pipeline elements.
- Maintained tests. Unresolvable arguments of fn:default throw
exceptions instead
 of being retained literally.
- Restructured placeholder evaluation: Each placeholder resolver is
tried for each
 pipeline expression, instead of all pipeline stages evaluated for each
resolver.
 This was the reason that repeated evaluations were necessary.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Disambiguate between AMQP properties and application properties.
All properties are read from and written to headers. Ambiguous
application properties are prefixed. Tests pending.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Fix pipeline expression validation.
- Tolerate unresolved values: They are always possible due to unknown
 parameter values for functions such as fn:substring-after.
- Do not tolerate unsupported placeholders in any situation:
 They will always result in error.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Test JMSPropertyMapper.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Connectivity: Fix non-forwarding of internal headers from consumers;
prettify JMSPropertyMapper.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

AmqpPublisherActor: Workaround Qpid client's spec breakage.
Circumvent application property "validity" check when setting them.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Move Qpid workarounds under org.eclipse.ditto; remove support for
content-encoding.
Reason: Classes outside the org.eclipse.ditto package can't be signed.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

fixed npe in StreamingSessionActor
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

BasePublisherActor: Stop retaining all headers in the absence of header
mapper.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Retain all headers in outbound signals to a reply-to address.
Reason: Backward-compatibility.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

#537 added migration script
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

Enable legacy header mapper by default and disable it in
HttpPublisherActor.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Review: Use typed EntityId; remove unnecessary enumeration of
collections.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

fixes https://github.com/eclipse/ditto-clients/issues/30
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

Remove legacy default header mapping and reply-to address for responses.
Responses and errors are now only published at reply-targets.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Cache "reply-target" header for live responses.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Fix that reply-target was not copied to builder.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

review: minor changes of removing non-used constants, methods,
missing/obsolete "finals" * allowed RabbitMQTargets to define an empty
exchange name
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

moved connectivity related placeholder classes out of placeholders model
module
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

fixed PlaceholderExceptions to be of common exception interface type
with common prefix
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

updated akka versions
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

review: fixed javadoc + added a simple test case for fn:delete()
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

review: removed non-used method, added 2 amqp property mappings to jms
methods to testcase
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

Remove implicit header mapping in WrappingMessageMapper.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

by default make unresolved placeholder in scope of applyWithDeletion()
return optional instead of the unresolved placeholder
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

Add live migration of existing connections so that they behave as
before.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

ExpressionResolver: Remove "allowUnresolved" behavior.
The unresolved pipeline element is now treated the same as the deleted
pipeline element at the end of expression resolution. They are still
treated differently during the evaluation of a single pipeline
expression.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

created initial Docker Action for a Maven build

PolicyTrie: Do not build JSON view using definition in field.
Reason: Definition may have a nested pointer as path.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

also run GitHub Actions for PRs

added information about community call

added ics for community call

fixed zoom link

Removed unused `getSelectedFields` method and appendage.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Migrate targets without header mapping on the fly
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Improve response dropped log message; do not attach defualt header
mapping for HTTP connections.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Added convenience method for setting an automatically generated
correlation ID to `DittoHeaders`'s builder.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

Removed unused import and adjusted formatting of equals method.
Signed-off-by: Juergen Fickel <juergen.fickel@bosch-si.com>

fixed message formatting
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

Do not migrate valid reply-target without "enabled=true".
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Remove ReplyTarget.fromJsonOptional.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

don't add all externalMessage headers in DittoMessageMapper * this must
be done explicitly in header mapping of connection sources
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

Fix unit tests, add TODO about "source" header.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

changed workflow name to "build"

replaced Travis build badge with GH Actions

stop building with Travis
use GitHub Actions as replacement

changed order of sourceId enforcement and incoming header mapping in
order to have mapped headers available
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

review: extracted constants; added javadoc
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

[WIP] Add request:subjectId to connectivity header mapping and make the
latter rigorous.
- For incoming messages: Header mapping injects Ditto headers from
external
 message headers.
- For outgoing messages: Header mapping creates external message headers
from
 Ditto headers.
- Headers not named in header mappings are never set in any externally
visible
 manner.
TODO: Map between adaptable (!) headers, not the signal headers!
     This way no special reservation for "ditto-" header prefix is
needed
     And all internal headers are automatically filtered out.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Map headers between adaptable and external messages.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Rename builder function in SseRouteBuilder to better reflect the
argument it expects
Signed-off-by: Klem Yannic (INST/ECS1) <yannic.klem@bosch-si.com>

Retain all headers from payload mapper.
It is now safe to do so as DittoMapper no longer copies all headers from
the input Adaptable.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Fix a NullPointerException in header mapping; rename method.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Replace static array Resolvers.PLACEHOLDERS by unmodifiable list for
security.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Prefix internal headers by 'ditto-'.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

updated akka and hivemq client dependency

reverted change
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

Document reply-target and header mapping.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

reverted change
Signed-off-by: Johannes Schneider <johannes.schneider@bosch-si.com>

review: removed getSource() and all "source" related stuff from
DittoHeaders
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

Total Helm chart rework
Signed-off-by: Axel Köhler <axel.koehler@kiwigrid.com>

Add hint how to limit resoucre usage
Signed-off-by: Axel Köhler <axel.koehler@kiwigrid.com>

added max-width for adopter logos

Remove duplicate log message.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

use "/sbin/tini" as start command wrapping invocation of "java"
execution
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>

Remove a concurrency issue in AmqpClientActorTest.
Signed-off-by: Yufei Cai <yufei.cai@bosch-si.com>

Revert useing "/sbin/tini" as start command wrapping invocation of
"java" execution - use entrypoint in Dockerfile instead
Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>