Import third-party events

license-report.md

@@ -457,7 +457,7 @@
  The dependencies distributed under several licenses, are used according their commercial-use-friendly license.
 
 
-This report was generated on **Sun Sep 01 13:04:20 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
+This report was generated on **Wed Sep 04 11:10:23 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
 
 
 
@@ -865,7 +865,7 @@ This report was generated on **Sun Sep 01 13:04:20 EEST 2019** using [Gradle-Lic
  The dependencies distributed under several licenses, are used according their commercial-use-friendly license.
 
 
-This report was generated on **Sun Sep 01 13:04:20 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
+This report was generated on **Wed Sep 04 11:10:24 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
 
 
 
@@ -1321,7 +1321,7 @@ This report was generated on **Sun Sep 01 13:04:20 EEST 2019** using [Gradle-Lic
  The dependencies distributed under several licenses, are used according their commercial-use-friendly license.
 
 
-This report was generated on **Sun Sep 01 13:04:21 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
+This report was generated on **Wed Sep 04 11:10:25 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
 
 
 
@@ -1939,7 +1939,7 @@ This report was generated on **Sun Sep 01 13:04:21 EEST 2019** using [Gradle-Lic
  The dependencies distributed under several licenses, are used according their commercial-use-friendly license.
 
 
-This report was generated on **Sun Sep 01 13:04:22 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
+This report was generated on **Wed Sep 04 11:10:26 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
 
 
 
@@ -2461,7 +2461,7 @@ This report was generated on **Sun Sep 01 13:04:22 EEST 2019** using [Gradle-Lic
  The dependencies distributed under several licenses, are used according their commercial-use-friendly license.
 
 
-This report was generated on **Sun Sep 01 13:04:23 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
+This report was generated on **Wed Sep 04 11:10:27 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
 
 
 
@@ -2993,7 +2993,7 @@ This report was generated on **Sun Sep 01 13:04:23 EEST 2019** using [Gradle-Lic
  The dependencies distributed under several licenses, are used according their commercial-use-friendly license.
 
 
-This report was generated on **Sun Sep 01 13:04:23 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
+This report was generated on **Wed Sep 04 11:10:28 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
 
 
 
@@ -3533,7 +3533,7 @@ This report was generated on **Sun Sep 01 13:04:23 EEST 2019** using [Gradle-Lic
  The dependencies distributed under several licenses, are used according their commercial-use-friendly license.
 
 
-This report was generated on **Sun Sep 01 13:04:24 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
+This report was generated on **Wed Sep 04 11:10:28 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
 
 
 
@@ -4119,4 +4119,4 @@ This report was generated on **Sun Sep 01 13:04:24 EEST 2019** using [Gradle-Lic
  The dependencies distributed under several licenses, are used according their commercial-use-friendly license.
 
 
-This report was generated on **Sun Sep 01 13:04:25 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).
+This report was generated on **Wed Sep 04 11:10:29 EEST 2019** using [Gradle-License-Report plugin](https://github.com/jk1/Gradle-License-Report) by Evgeny Naumenko, licensed under [Apache 2.0 License](https://github.com/jk1/Gradle-License-Report/blob/master/LICENSE).

server/src/main/java/io/spine/server/BoundedContextBuilder.java

@@ -40,6 +40,7 @@
 import io.spine.server.event.EventDispatcher;
 import io.spine.server.event.EventEnricher;
 import io.spine.server.integration.IntegrationBus;
+import io.spine.server.security.Security;
 import io.spine.server.stand.Stand;
 import io.spine.server.tenant.TenantIndex;
 import io.spine.server.type.CommandEnvelope;
@@ -100,7 +101,7 @@ public final class BoundedContextBuilder implements Logging {
     private final Collection<Repository<?, ?>> repositories = new ArrayList<>();
 
     /**
-     * Prevents direct instantiation.
+     * Creates a new builder with the given spec.
      *
      * @param spec
      *         the context spec for the built context
@@ -112,10 +113,12 @@ public final class BoundedContextBuilder implements Logging {
     }
 
     /**
-     * Prevents direct instantiation.
+     * Creates a new builder with the given spec and system features.
      *
      * @param spec
      *         the context spec for the built context
+     * @param systemFeatures
+     *         system feature flags; can be changed later via {@link #systemFeatures()}
      * @see BoundedContext#singleTenant
      * @see BoundedContext#multitenant
      */
@@ -145,6 +148,29 @@ public static BoundedContextBuilder assumingTests() {
         return assumingTests(false);
     }
 
+    /**
+     * Creates a new builder for a Bounded Context which does not store its events.
+     *
+     * <p>Such a Bounded Context should not be used general case. This method throws
+     * a {@link SecurityException} if called outside the framework core. Please use static factory
+     * methods in {@link BoundedContext} to create an instance of builder.
+     */
+    @Internal
+    public static BoundedContextBuilder notStoringEvents(String name, boolean multitenant) {
+        checkNotNull(name);
+        Security.allowOnlyFrameworkServer();
+
+        ContextSpec spec = multitenant
+                           ? multitenant(name)
+                           : singleTenant(name);
+        BoundedContextBuilder builder = new BoundedContextBuilder(spec.notStoringEvents());
+        builder.systemFeatures()
+               .forgetEvents()
+               .disableAggregateQuerying()
+               .disableCommandLog();
+        return builder;
+    }
+
     /**
      * Obtains the context spec.
      */

server/src/main/java/io/spine/server/aggregate/Apply.java

@@ -60,4 +60,3 @@
      */
     boolean allowImport() default false;
 }
-

server/src/main/java/io/spine/server/aggregate/UnsupportedImportEventException.java

@@ -27,6 +27,7 @@
 import io.spine.server.type.EventEnvelope;
 import io.spine.type.TypeName;
 
+import static io.spine.core.EventValidationError.UNSUPPORTED_EVENT_VALUE;
 import static io.spine.server.event.EventException.eventTypeAttribute;
 import static java.lang.String.format;
 
@@ -71,7 +72,7 @@ private static Error unsupportedImportEvent(Message eventMessage, String errorMe
         Error result = Error
                 .newBuilder()
                 .setType(UnsupportedImportEventException.class.getName())
-                .setCode(-1)
+                .setCode(UNSUPPORTED_EVENT_VALUE)
                 .setMessage(errorMessage)
                 .putAllAttributes(eventTypeAttribute(eventMessage))
                 .build();

server/src/main/java/io/spine/server/entity/storage/EntityColumn.java

@@ -127,7 +127,7 @@
  *
  * <p>An entity column can be of any type. Most common types are already supported if an existing
  * implementation of the {@link io.spine.server.storage.Storage Spine Storage} is used.
- * However, their behavior can be overriden using {@link ColumnTypeRegistry}.
+ * However, their behavior can be overridden using {@link ColumnTypeRegistry}.
  *
  * <p>To handle column types not supported by default implement the {@link ColumnType}
  * interface, register it in a {@link ColumnTypeRegistry} and pass the instance of the registry

server/src/main/java/io/spine/server/event/EventBus.java

@@ -186,7 +186,8 @@ protected EventEnvelope toEnvelope(Event message) {
     public EventStore eventStore() {
         checkNotNull(
                 eventStore,
-                "`EventStore` is not initialized. Please call `EventBus.init(BoundedContext)`."
+                "`EventStore` is not initialized. " +
+                        "Please call `EventBus.registerWith(BoundedContext)`."
         );
         return eventStore;
     }

server/src/main/java/io/spine/server/event/EventFactory.java

@@ -25,6 +25,7 @@
 import com.google.protobuf.Timestamp;
 import io.spine.base.EventMessage;
 import io.spine.base.RejectionMessage;
+import io.spine.core.ActorContext;
 import io.spine.core.Event;
 import io.spine.core.EventContext;
 import io.spine.core.EventId;
@@ -73,6 +74,24 @@ public static EventFactory on(MessageEnvelope origin, Any producerId) {
         return new EventFactory(eventOrigin, producerId);
     }
 
+    /**
+     * Creates a new event factory for producing events to be imported into a Bounced Context.
+     *
+     * @param actorContext
+     *         the description of the actor who imports the events
+     * @param producerId
+     *         the ID of the system which produced the events
+     * @return new event factory
+     */
+    public static EventFactory forImport(ActorContext actorContext, Any producerId) {
+        checkNotNull(actorContext);
+        checkNotNull(producerId);
+        checkValid(actorContext);
+
+        EventOrigin origin = EventOrigin.forImport(actorContext);
+        return new EventFactory(origin, producerId);
+    }
+
     /**
      * Creates an event for the passed event message.
      *

server/src/main/java/io/spine/server/event/React.java

@@ -34,8 +34,8 @@
  * <ul>
  *     <li>be annotated with {@link React @React};
  *     <li>have package-private visibility;
- *     <li>accept an event message (derived from {@link io.spine.base.EventMessage
- *         EventMessage}) as the first parameter;
+ *     <li>accept an event message (derived from {@link io.spine.base.EventMessage EventMessage})
+ *         as the first parameter;
  *     <li>return an event message derived from {@link io.spine.base.EventMessage Message}
  *         <strong>or</strong> several event messages returned as an {@code Iterable}.
  * </ul>

server/src/main/java/io/spine/server/event/model/EventAcceptingSignature.java

@@ -38,7 +38,7 @@ abstract class EventAcceptingSignature<H extends HandlerMethod<?, ?, EventEnvelo
 
     /**
      * This field is also is used by {@link SubscriberSignature} to avoid repeated scanning in
-     * the overriden {@link #paramSpecs()}.
+     * the overridden {@link #paramSpecs()}.
      */
     static final ImmutableSet<EventAcceptingMethodParams>
             PARAM_SPEC = ImmutableSet.copyOf(EventAcceptingMethodParams.values());

server/src/main/java/io/spine/server/event/model/EventReactorSignature.java

@@ -21,6 +21,7 @@
 package io.spine.server.event.model;
 
 import com.google.common.collect.ImmutableSet;
+import io.spine.annotation.Internal;
 import io.spine.base.EventMessage;
 import io.spine.server.event.React;
 import io.spine.server.model.ParameterSpec;
@@ -32,12 +33,13 @@
 /**
  * The signature of {@link EventReactorMethod}.
  */
-final class EventReactorSignature extends EventAcceptingSignature<EventReactorMethod> {
+@Internal
+public final class EventReactorSignature extends EventAcceptingSignature<EventReactorMethod> {
 
     private static final ImmutableSet<Class<?>>
             RETURN_TYPES = ImmutableSet.of(EventMessage.class, Iterable.class, Optional.class);
 
-    EventReactorSignature() {
+    public EventReactorSignature() {
         super(React.class);
     }
 

server/src/main/java/io/spine/server/integration/ConfigurationChangeObserver.java

@@ -75,7 +75,7 @@ final class ConfigurationChangeObserver extends AbstractChannelObserver implemen
      * types.
      *
      * <p>If the request originates from a previously unknown Bounded Context,
-     * {@linkplain IntegrationBus#notifyOfCurrentNeeds() publishes} the needs of current context,
+     * {@linkplain IntegrationBus#introduceSelf() publishes} the needs of current context,
      * since they may be unknown to the new context.
      *
      * @param value {@link RequestForExternalMessages} form another Bounded Context
@@ -89,7 +89,7 @@ public void handle(ExternalMessage value) {
         clearStaleSubscriptions(request.getRequestedMessageTypeList(), origin);
         if (!knownContexts.contains(origin)) {
             knownContexts.add(origin);
-            integrationBus.notifyOfCurrentNeeds();
+            integrationBus.introduceSelf();
         }
     }
 

server/src/main/java/io/spine/server/integration/IntegrationBus.java

@@ -283,12 +283,13 @@ private void notifyOfUpdatedNeeds() {
     }
 
     /**
-     * Notifies other parts of the application about the types requested by this integration bus.
+     * Notifies other Bounded Contexts of the application about the types requested by this Context.
      *
-     * <p>Sends out an instance of {@linkplain RequestForExternalMessages
-     * request for external messages} for that purpose.
+     * <p>The {@code IntegrationBus} sends a {@link RequestForExternalMessages}. The request
+     * triggers other Contexts to send their requests. As the result, all the Contexts know about
+     * the needs of all the Contexts.
      */
-    void notifyOfCurrentNeeds() {
+    void introduceSelf() {
         configurationBroadcast.send();
     }