fix: OracleP*C* now provides subscribeEvents: true for post-connect narrate

Author: iridiankin

packages/prophet/AuthorityProphet/AuthorityNexus.js

@@ -120,7 +120,11 @@ export default class AuthorityNexus extends LogEventGenerator {
       if (!authorityConfig) {
         throw new Error(`No Valaa authority config found for "${String(authorityURI)}"`);
       }
-      return schemeModule.createAuthorityProphet({ authorityURI, authorityConfig, nexus: this });
+      return schemeModule.createAuthorityProphet({
+        authorityURI, authorityConfig, nexus: this,
+        verbosity: authorityConfig.hasOwnProperty("verbosity")
+            ? authorityConfig.verbosity : this.getVerbosity(),
+      });
     } catch (error) {
       throw this.wrapErrorEvent(error, `createAuthorityProphet("${String(authorityURI)}")`,
           "\n\tschemeModule:", schemeModule,

packages/prophet/Oracle/OraclePartitionConnection.js

@@ -40,14 +40,15 @@ export default class OraclePartitionConnection extends PartitionConnection {
     // logic (defined in PartitionConnection.js) and begin I/O bound(?)
     // scribe event log narration in parallel to the authority
     // proxy/connection creation.
+    const subscribeEvents = (options.subscribeEvents !== false);
     this.setUpstreamConnection(this._authorityProphet.acquirePartitionConnection(
         this.getPartitionURI(), {
           subscribeEvents: false, narrateOptions: false,
           receiveTruths: this.getReceiveTruths(options.receiveTruths),
         }));
     return thenChainEagerly(
         this._upstreamConnection.getActiveConnection(),
-        () => this.narrateEventLog(options.narrateOptions));
+        () => this.narrateEventLog({ subscribeEvents, ...options.narrateOptions }));
   }
 
   receiveTruths (truths: EventBase[], retrieveMediaBuffer: RetrieveMediaBuffer,

packages/prophet/api/types.js

@@ -44,6 +44,10 @@ export type NarrateOptions = {
   receiveCommands?: ReceiveEvents, // default: receiveTruths. Callback for re-narrated commands
   eventIdBegin?: number,
   eventIdEnd?: number,
+  subscribeEvents?: boolean        // if provided will enable or disable event subscriptions.
+                                   // TODO(iridian, 2019-01): This (c|sh)ould be extracted to its
+                                   // own separate function. Now this flag is awkwardly present
+                                   // both here and in ConnectOptions.
 };
 
 export type ChronicleOptions = NarrateOptions & {