Copyx_caci_sg_meraki_merakidevices

Copy(function loadData(import_set_table) {

    // this tool will hash the incoming record and if it is a duplicate of a record that has already been
    // processed the new record will not be written to the import set table and processed
    //var inserter = new sn_cmdb_int_util.DuplicateRowProcessor("288088d680821010f8772cdfe9d5f8b5", import_set_table);

    var sg_util = new x_caci_sg_meraki.SGConnectorMerakiUtils();
    var orgStream = sn_fd.FlowAPI.executeDataStreamAction('x_caci_sg_meraki.merakiorganization');
    while (orgStream.hasNext()) {

        // Get a single item from the data stream.
        var org = orgStream.next();

        //networks
        var networksStreamInput = {};
        networksStreamInput['orgid'] = org.id;

        var networksStream = sn_fd.FlowAPI.executeDataStreamAction('x_caci_sg_meraki.sgmerakigetnetworks', networksStreamInput);
        var networks_array = [];
        while (networksStream.hasNext()) {
            var networks = networksStream.next();
            var network_obj = {};
            network_obj.id = networks['id'];
            network_obj.name = networks['name'];
            networks_array.push(network_obj);
        }
        //gs.info('networks_array' + networks_array.toString());




        //devicestatus
        var devicestatusStreamInput = {};
        devicestatusStreamInput['orgid'] = org.id;

        var devicestatusStream = sn_fd.FlowAPI.executeDataStreamAction('x_caci_sg_meraki.sgmerakigetdevicestatuses', devicestatusStreamInput);
        var devicestatus_array = [];
        while (devicestatusStream.hasNext()) {
            var devicestatus = devicestatusStream.next();
            var devicestatus_obj = {};
            devicestatus_obj.serial = devicestatus['serial'];
            devicestatus_obj.networkId = devicestatus['networkId'];
            devicestatus_obj.lastReportedAt = devicestatus['lastReportedAt'];
            devicestatus_obj.status = devicestatus['status'];

            devicestatus_array.push(devicestatus_obj);
        }
        //gs.info('devicestatus_array' + devicestatus_array.toString());


        // the only input to the second data stream is the id of the organization
        var deviceStreamInput = {};
        deviceStreamInput['orgid'] = org.id;

        var deviceStream = sn_fd.FlowAPI.executeDataStreamAction('x_caci_sg_meraki.sgmerakigetdevices', deviceStreamInput);
        while (deviceStream.hasNext()) {
            var device = deviceStream.next();
            device['organizationId'] = org.id;
            device['organization_name'] = org.name;
            device['organization_url'] = org.url;
            device['network_name'] = sg_util.searchArray(networks_array, 'id', device['networkId']).name;

            var devStatus = {};
            devStatus = sg_util.searchArray(devicestatus_array, 'serial', device['serial']);
            if (device['serial'] == devStatus.serial &&
                device['networkId'] == devStatus.networkId &&
                device['serial'] != null &&
                device['networkId'] != null) {
                device['device_status'] = devStatus.status;
                device['lastReportedAt'] = devStatus.lastReportedAt;
            }
            import_set_table.insert(device);
        }
        networksStream.close();

        deviceStream.close();
    }

    orgStream.close();

})(import_set_table);