Skip to content

Commit

Permalink
add publish index and publish assertion (#1996)
Browse files Browse the repository at this point in the history
* update publish request schema

* add publish index and publish assertion

* fix merge issues

* removed unused query

* update insert index and insert assertion

* remove unused dependencies and update logger

* initialize repositorymodulemanager

* remove unused file

* update package-lock and comunica dependency

* remove old dependency injection
  • Loading branch information
zeroxbt authored Aug 31, 2022
1 parent c415d75 commit b234ce4
Show file tree
Hide file tree
Showing 28 changed files with 1,019 additions and 1,139 deletions.
2 changes: 1 addition & 1 deletion config/config.json
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@
}
},
"minimumAckResponses": {
"publish": 5,
"publish": 2,
"get": 1
},
"commandExecutorVerboseLoggingEnabled": false,
Expand Down
7 changes: 3 additions & 4 deletions ot-node.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
const DeepExtend = require('deep-extend');
const rc = require('rc');
const fs = require('fs');
const queue = require('fastq');
const appRootPath = require('app-root-path');
const path = require('path');
const EventEmitter = require('events');
Expand Down Expand Up @@ -35,7 +34,9 @@ class OTNode {
this.logger.info(`Node is running in ${process.env.NODE_ENV} environment`);

this.initializeDependencyContainer();
this.logger.info(`dependency container initialized`);
this.initializeEventEmitter();
this.logger.info(` event emitter initialized`);

await this.initializeModules();
await this.saveNetworkModulePeerIdAndPrivKey();
Expand Down Expand Up @@ -86,9 +87,6 @@ class OTNode {
this.container = DependencyInjection.initialize();
DependencyInjection.registerValue(this.container, 'config', this.config);
DependencyInjection.registerValue(this.container, 'logger', this.logger);
DependencyInjection.registerValue(this.container, 'constants', constants);
DependencyInjection.registerValue(this.container, 'blockchainQueue', queue);
DependencyInjection.registerValue(this.container, 'tripleStoreQueue', queue);

this.logger.info('Dependency injection module is initialized');
}
Expand All @@ -97,6 +95,7 @@ class OTNode {
const initializationPromises = [];
for (const moduleName in this.config.modules) {
const moduleManagerName = `${moduleName}ModuleManager`;
this.logger.info(`schedulinginitializing ${moduleManagerName}`);

const moduleManager = this.container.resolve(moduleManagerName);
initializationPromises.push(moduleManager.initialize());
Expand Down
Loading

0 comments on commit b234ce4

Please sign in to comment.