'use strict';

// @ts-ignore
import Converter from './src/utils/Converter';
const jsonMerger = require("json-merger");  //https://github.com/boschni/json-merger
const Graph = require("./utils/graph-data-structure");
const _ = require('underscore');

export default class OracleSchemaGraph {

    //Get the array of same table names (edges) from two nodes
    getEdges = (node1, node2) => {
        let edgeNames = node1.filter(function (val) {
            return node2.indexOf(val) != -1;
        });

        return edgeNames;
    }

    //Get unique edges names
    //Purpose: so one edge as the key can have nested target and source
    getUniqueEdgeNames = (edgesAndNodesCombined: Array<any>) => {
        let edgeNames = [];
        for(let i=0; i<edgesAndNodesCombined.length; i++) {
            edgeNames.push(edgesAndNodesCombined[i][0]);
            //console.log(edgesAndNodesCombined[i][0]);
        }
        return _.uniq(edgeNames);
    }

    //Get the array of the same edges found from two nodes
    //return the array of edges as well as the two nodes
    getEdgesAndNodes = (referencedTables) => {

        //console.log(tableWithColObject);

        let edgesAndNodes = [];
        let edgesAndNodesCombined = [];

        let edgeName:string; //foreign key column name
        let sourceNode:string; //foreign key table name
        let targetNode:string;  //primary key table name

        for(let i=0; i<referencedTables.length; i++){
                edgeName = referencedTables[i]['COLUMN_NAME'];      //foreign key
                sourceNode = referencedTables[i]['TABLE_NAME'];     //table that has the foreign key
                targetNode = referencedTables[i]['R_TABLE_NAME'];   //table that has the primary key

                //adds edges and nodes to an array
                edgesAndNodes.push(edgeName);   //add edge name
                edgesAndNodes.push(sourceNode);
                edgesAndNodes.push(targetNode);
                edgesAndNodesCombined.push(edgesAndNodes);
                edgesAndNodes = [];
        }
        
        return edgesAndNodesCombined;
    }

    //Get edges with source node and target node in Json
    getEdgesGraph = (uniqueEdgeNames:Array<any>, edgesAndNodesCombined: Array<any>) => {

        let serializedLinks;
        let edgesJson = {edges: {}};
        let sourceNode;
        let targetNode;
        let edgeName:string = '';

        let graph = new Graph();

        for (let i=0; i<uniqueEdgeNames.length; i++) {
            for(let j=0; j<edgesAndNodesCombined.length; j++) {
                if(edgesAndNodesCombined[j][0].includes(uniqueEdgeNames[i])) {
                    edgeName = uniqueEdgeNames[i];
                    sourceNode = edgesAndNodesCombined[j][1];
                    targetNode = edgesAndNodesCombined[j][2];

                    graph.addNode(sourceNode);
                    graph.addNode(targetNode);
                    graph.addEdge(sourceNode, targetNode);
                    //console.log(uniqueEdgeNames[i] + "\t" + edgesAndNodesCombined[j] )
                }
            }
            serializedLinks = graph.serializeLinks(edgeName);
            edgesJson.edges[edgeName] = serializedLinks[edgeName];
            graph = new Graph();

        }

        return edgesJson;
    }
}

/*********************************** Main Entry Point ************************************************/
/*
const extractedSchema = {
    "REGIONS": [
    {
        "name": "REGION_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": false,
        "precision": 0,
        "scale": -127
    },
    {
        "name": "REGION_NAME",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": true,
        "byteSize": 25
    }
    ],
    "LOCATIONS": [
    {
        "name": "LOCATION_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": false,
        "precision": 4,
        "scale": 0
    },
    {
        "name": "STREET_ADDRESS",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": true,
        "byteSize": 40
    },
    {
        "name": "POSTAL_CODE",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": true,
        "byteSize": 12
    },
    {
        "name": "CITY",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": false,
        "byteSize": 30
    },
    {
        "name": "STATE_PROVINCE",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": true,
        "byteSize": 25
    },
    {
        "name": "COUNTRY_ID",
        "fetchType": 2001,
        "dbType": 2003,
        "dbTypeName": "CHAR",
        "nullable": true,
        "byteSize": 2
    }
],
    "DEPARTMENTS": [
    {
        "name": "DEPARTMENT_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": false,
        "precision": 4,
        "scale": 0
    },
    {
        "name": "DEPARTMENT_NAME",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": false,
        "byteSize": 30
    },
    {
        "name": "MANAGER_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 6,
        "scale": 0
    },
    {
        "name": "LOCATION_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 4,
        "scale": 0
    }
],
    "JOBS": [
    {
        "name": "JOB_ID",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": false,
        "byteSize": 10
    },
    {
        "name": "JOB_TITLE",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": false,
        "byteSize": 35
    },
    {
        "name": "MIN_SALARY",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 6,
        "scale": 0
    },
    {
        "name": "MAX_SALARY",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 6,
        "scale": 0
    }
],
    "EMPLOYEES": [
    {
        "name": "EMPLOYEE_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": false,
        "precision": 6,
        "scale": 0
    },
    {
        "name": "FIRST_NAME",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": true,
        "byteSize": 20
    },
    {
        "name": "LAST_NAME",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": false,
        "byteSize": 25
    },
    {
        "name": "EMAIL",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": false,
        "byteSize": 25
    },
    {
        "name": "PHONE_NUMBER",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": true,
        "byteSize": 20
    },
    {
        "name": "HIRE_DATE",
        "fetchType": 2014,
        "dbType": 2011,
        "dbTypeName": "DATE",
        "nullable": false
    },
    {
        "name": "JOB_ID",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": false,
        "byteSize": 10
    },
    {
        "name": "SALARY",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 8,
        "scale": 2
    },
    {
        "name": "COMMISSION_PCT",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 2,
        "scale": 2
    },
    {
        "name": "MANAGER_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 6,
        "scale": 0
    },
    {
        "name": "DEPARTMENT_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 4,
        "scale": 0
    }
],
    "JOB_HISTORY": [
    {
        "name": "EMPLOYEE_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": false,
        "precision": 6,
        "scale": 0
    },
    {
        "name": "START_DATE",
        "fetchType": 2014,
        "dbType": 2011,
        "dbTypeName": "DATE",
        "nullable": false
    },
    {
        "name": "END_DATE",
        "fetchType": 2014,
        "dbType": 2011,
        "dbTypeName": "DATE",
        "nullable": false
    },
    {
        "name": "JOB_ID",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": false,
        "byteSize": 10
    },
    {
        "name": "DEPARTMENT_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 4,
        "scale": 0
    }
],
    "COUNTRIES": [
    {
        "name": "COUNTRY_ID",
        "fetchType": 2001,
        "dbType": 2003,
        "dbTypeName": "CHAR",
        "nullable": false,
        "byteSize": 2
    },
    {
        "name": "COUNTRY_NAME",
        "fetchType": 2001,
        "dbType": 2001,
        "dbTypeName": "VARCHAR2",
        "nullable": true,
        "byteSize": 40
    },
    {
        "name": "REGION_ID",
        "fetchType": 2010,
        "dbType": 2010,
        "dbTypeName": "NUMBER",
        "nullable": true,
        "precision": 0,
        "scale": -127
    }
    ]
}

const foreignKeyReferences = {
    metaData: [
        { name: 'CONSTRAINT_NAME' },
        { name: 'TABLE_NAME' },
        { name: 'COLUMN_NAME' },
        { name: 'R_CONSTRAINT_NAME' },
        { name: 'R_TABLE_NAME' },
        { name: 'R_COLUMN_NAME' }
    ],
    rows: [
        {
            CONSTRAINT_NAME: 'COUNTR_REG_FK',
            TABLE_NAME: 'COUNTRIES',
            COLUMN_NAME: 'REGION_ID',
            R_CONSTRAINT_NAME: 'REG_ID_PK',
            R_TABLE_NAME: 'REGIONS',
            R_COLUMN_NAME: 'REGION_ID'
        },
        {
            CONSTRAINT_NAME: 'DEPT_LOC_FK',
            TABLE_NAME: 'DEPARTMENTS',
            COLUMN_NAME: 'LOCATION_ID',
            R_CONSTRAINT_NAME: 'LOC_ID_PK',
            R_TABLE_NAME: 'LOCATIONS',
            R_COLUMN_NAME: 'LOCATION_ID'
        },
        {
            CONSTRAINT_NAME: 'DEPT_MGR_FK',
            TABLE_NAME: 'DEPARTMENTS',
            COLUMN_NAME: 'MANAGER_ID',
            R_CONSTRAINT_NAME: 'EMP_EMP_ID_PK',
            R_TABLE_NAME: 'EMPLOYEES',
            R_COLUMN_NAME: 'EMPLOYEE_ID'
        },
        {
            CONSTRAINT_NAME: 'EMP_DEPT_FK',
            TABLE_NAME: 'EMPLOYEES',
            COLUMN_NAME: 'DEPARTMENT_ID',
            R_CONSTRAINT_NAME: 'DEPT_ID_PK',
            R_TABLE_NAME: 'DEPARTMENTS',
            R_COLUMN_NAME: 'DEPARTMENT_ID'
        },
        {
            CONSTRAINT_NAME: 'EMP_JOB_FK',
            TABLE_NAME: 'EMPLOYEES',
            COLUMN_NAME: 'JOB_ID',
            R_CONSTRAINT_NAME: 'JOB_ID_PK',
            R_TABLE_NAME: 'JOBS',
            R_COLUMN_NAME: 'JOB_ID'
        },
        {
            CONSTRAINT_NAME: 'EMP_MANAGER_FK',
            TABLE_NAME: 'EMPLOYEES',
            COLUMN_NAME: 'MANAGER_ID',
            R_CONSTRAINT_NAME: 'EMP_EMP_ID_PK',
            R_TABLE_NAME: 'EMPLOYEES',
            R_COLUMN_NAME: 'EMPLOYEE_ID'
        },
        {
            CONSTRAINT_NAME: 'JHIST_DEPT_FK',
            TABLE_NAME: 'JOB_HISTORY',
            COLUMN_NAME: 'DEPARTMENT_ID',
            R_CONSTRAINT_NAME: 'DEPT_ID_PK',
            R_TABLE_NAME: 'DEPARTMENTS',
            R_COLUMN_NAME: 'DEPARTMENT_ID'
        },
        {
            CONSTRAINT_NAME: 'JHIST_EMP_FK',
            TABLE_NAME: 'JOB_HISTORY',
            COLUMN_NAME: 'EMPLOYEE_ID',
            R_CONSTRAINT_NAME: 'EMP_EMP_ID_PK',
            R_TABLE_NAME: 'EMPLOYEES',
            R_COLUMN_NAME: 'EMPLOYEE_ID'
        },
        {
            CONSTRAINT_NAME: 'JHIST_JOB_FK',
            TABLE_NAME: 'JOB_HISTORY',
            COLUMN_NAME: 'JOB_ID',
            R_CONSTRAINT_NAME: 'JOB_ID_PK',
            R_TABLE_NAME: 'JOBS',
            R_COLUMN_NAME: 'JOB_ID'
        },
        {
            CONSTRAINT_NAME: 'LOC_C_ID_FK',
            TABLE_NAME: 'LOCATIONS',
            COLUMN_NAME: 'COUNTRY_ID',
            R_CONSTRAINT_NAME: 'COUNTRY_C_ID_PK',
            R_TABLE_NAME: 'COUNTRIES',
            R_COLUMN_NAME: 'COUNTRY_ID'
        }
    ]

}

//NOTE: if we want the inserted schema, please make sure inserted staticly to the extracted schema
const oracleSchemaGraph = new OracleSchemaGraph();

//refer to oracleSchemaGraph->getForeignKeyReferences
let edgesAndNodesCombined = oracleSchemaGraph.getEdgesAndNodes(foreignKeyReferences['rows']);
//console.log(edgesAndNodesCombined);

let uniqueEdgeNames = oracleSchemaGraph.getUniqueEdgeNames(edgesAndNodesCombined);
//console.log(uniqueEdgeNames);

let nodesGraph = { nodes: { } };
nodesGraph.nodes = extractedSchema;
//console.log(nodesGraph);

let edgesJson = oracleSchemaGraph.getEdgesGraph(uniqueEdgeNames,edgesAndNodesCombined);
//console.log(JSON.stringify(edgesJson,null,4));

let schemaGraph = jsonMerger.mergeObjects([nodesGraph, edgesJson]);
//console.log(JSON.stringify(schemaGraph,null,4));


//get the Ed version of the edge graph
const converter = new Converter();
let edEdgesGraph = converter.convertToEdEdgesGraph(uniqueEdgeNames, edgesJson);
//console.log(JSON.stringify(edEdgesGraph,null,4));

//to comply with Ed Schema Graph
let schemaEdGraph = jsonMerger.mergeObjects([nodesGraph, edEdgesGraph]);
console.log(JSON.stringify(schemaEdGraph,null,4));

*/