Merge pull request #1 from codefresh-io/endpoints-generation

endpoints generation

Author: yaroslav-codefresh

.eslintrc.js

@@ -1,6 +1,6 @@
 module.exports = {
     'plugins': [
-        'mocha'
+        'jest'
     ],
     'extends': 'airbnb-base',
     'rules': {
@@ -15,6 +15,6 @@ module.exports = {
         'class-methods-use-this': 0
     },
     'env': {
-        'mocha': true,
+        'jest': true,
     }
 };

__tests__/__app__/events-interface.js

@@ -0,0 +1,21 @@
+class EventsInterface {
+    constructor() {
+        this.callback = null;
+        this.subscribeCalls = 0;
+        this.publishCalls = 0;
+        this.subscribe = this.subscribe.bind(this);
+        this.publish = this.publish.bind(this);
+    }
+
+    subscribe(callback) {
+        this.subscribeCalls = this.subscribeCalls + 1;
+        this.callback = callback;
+    }
+
+    publish(data) {
+        this.publishCalls = this.publishCalls + 1;
+        return this.callback(data);
+    }
+}
+
+module.exports = new EventsInterface();

__tests__/__app__/index.js

@@ -0,0 +1,40 @@
+/* eslint-disable import/no-extraneous-dependencies */
+const express = require('express');
+const Promise = require('bluebird');
+
+const config = require('./service.config');
+const { openapi } = require('../../index');
+const globalMiddleware = require('./server/global.middleware');
+const eventsInterface = require('./events-interface');
+
+class App {
+    constructor() {
+        this.server = null;
+        this.port = null;
+        this.app = express();
+    }
+
+    async start() {
+        const deferred = Promise.defer();
+        openapi.init(config);
+        openapi.events().setSubscribeInterface(eventsInterface.subscribe);
+        openapi.events().setPublishInterface(eventsInterface.publish);
+        openapi.endpoints().addSpecMiddleware(globalMiddleware.specMiddleware);
+        openapi.endpoints().addDependenciesSpecMiddleware(globalMiddleware.dependenciesSpecMiddleware);
+        openapi.endpoints().register(this.app);
+        openapi.dependencies().fetch();
+        this.server = this.app.listen(0, () => {
+            openapi.events().subscribe();
+            openapi.events().publish();
+            deferred.resolve();
+        });
+        this.port = this.server.address().port;
+        return deferred.promise;
+    }
+
+    async stop() {
+        this.server.close();
+    }
+}
+
+module.exports = new App();