UnitFramework

microservice framework guided by DDD

This is microservice framework.

To test his functionality take next steps: 1.npm install 2.yarn dev ( to run server ) 3. node node client-test.js ( script to test end-point )

/==============================================================/ If you wish to use and test this framework, next snippet will give you introduction on how to use framework.

var UnitLib = require('@abukodonosor/unit');

const config = {
    // service information
    service_info: {
        name: "Unit",
        communication_type: "http",
        appType: "microservice",
        port: 3000,
    },
    //mysql db config
    db: {
        ip: "local",
        port: 3000,
        db_name: "db_name",
        db_user: "unit",
        db_password: "unit",
    },
    registry: {
        registry_ip: "192.168.2.1",
        registry_port: 9000,
        registry_token: "hw$xxg93`_sXXX09!2_pPq"
    },
    redis_cache: {
        cache_ip: "local",
        cache_port: 6770,
    },
};

const UnitLibFactory = UnitLib.UnitLib(config);
const unitService1 = UnitLibFactory.newService;

unitService1
    .setDomains([
    {
        type: 'airplane',
        definition: "Airplane"
    },
    {
        type: 'boat',
        definition: "Boat"
    }]);

unitService1.implementDomain("Airplane",//setDomainModules
[
    'authMiddleware', 
    'serviceAvailabilityMiddleware'
], function( AirplaneRouter, AirplaneRouterGet ) {

    AirplaneRouter('/by/card',{
        userId: 'number',
        places: 'array',
        priceRange: 'string',
        filterSchema: 'object'
    }, RentActionController );
});

unitService1.Run();

async function RentActionController( request, response, userId, places, priceRange, filterSchema) {
    console.log("Controller action");
    let expiredTickets = await Ticket.getAllExpiredTickets();
    console.log("Get all expired tickets: " + expiredTickets);
    let nonExpiredTickets = await Ticket.getNonExpiredTickets();
    console.log("All Non-Expired tickets: " + nonExpiredTickets);
    const newTicket = "success";
    response.send(newTicket);
}

//Example how to inherit class from this package
class Ticket extends UnitLibFactory.classTemplate {

    constructor(){
        super();
        this.name = 3;
    }

    static getAllExpiredTickets(){
        return new Promise((resolve,reject)=>{
            this.dbConnection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
                if (error) throw error;
                console.log('The solution is: ', results[0].solution);
                resolve(results[0].solution)
            });
        })
    }
    // promise wrapper around query lib
    static getNonExpiredTickets() {
        return this.dbConnection.queryPromise("SELECT 1 + 1 AS solution",[]);
    }
}