dynamoDBHelper.prototype.loadPois = function()

in source/resources/helper/lib/dynamodb-helper.js [50:94]
34 lines of code
3 McCabe index (conditional complexity)

    dynamoDBHelper.prototype.loadPois = function(ddbTable, cb) {

        let parser = csv.parse();
        let fileStream = fs.createReadStream('./marketing-pois.csv');
        fileStream
            .on('readable', function() {
                var data;
                while ((data = fileStream.read()) !== null) {
                    parser.write(data);
                }
            })
            .on('end', function() {
                parser.end();
            });

        parser
            .on('readable', function() {
                var data;
                while ((data = parser.read()) !== null) {
                    codes_info.push({
                        poi_id: data[0],
                        address: data[1],
                        city: data[2],
                        latitude: data[3],
                        longitude: data[4],
                        message: data[5],
                        poi: data[6],
                        radius: data[7],
                        state: data[8]
                    });
                }
            })
            .on('end', function() {
                console.log('Attempting to load POIs to marketing table.');
                loadCodes(codes_info, 0, ddbTable, function(err, data) {
                    if (err) {
                        console.log('Error loading POI marketing table', err);
                    } else {
                        console.log('Successfully loaded POI marketing table.');
                    }
                    cb(null, 'success');
                });
            });

    };