zckrs / gulp-css-base64 / 10

Build # 10

Build Type

push

travis-ci

Committed by Igor Dontsov

Commit Message

Fixed: A function with a name starting with an uppercase letter should only be used as a constructor

Run Details

47 of 50 branches covered (94.0%)

2 of 2 new or added lines in 1 file covered. (100.0%)

116 of 117 relevant lines covered (99.15%)

35.93 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

97.6

/src/index.js

'use strict';

// NodeJS library
var fs = require('fs');
var path = require('path');
var mime = require('mime');
var util = require('util');
var Stream = require('stream').Stream;

// NPM library
var Vinyl = require('vinyl');
var fancyLog = require('fancy-log');
var PluginError = require('plugin-error');
var through = require('through2');
var request = require('request');
var buffers = require('buffers');
var async = require('async');
var chalk = require('chalk');

var rImages = /url(?:\(['|"]?)(.*?)(?:['|"]?\))(?!.*\/\*base64:skip\*\/)/ig;

function gulpCssBase64(opts) {
  opts = JSON.parse(JSON.stringify(opts || {}));
  opts.maxWeightResource = opts.maxWeightResource || 32768;
  if (util.isArray(opts.extensionsAllowed)) {
    opts.extensionsAllowed = opts.extensionsAllowed;
  } else {
    opts.extensionsAllowed = [];
  }
  opts.extensionsAllowed = opts.extensionsAllowed || [];
  opts.baseDir = opts.baseDir || '';
  opts.verbose = process.argv.indexOf('--verbose') !== -1;

    // Creating a stream through which each file will pass
  var stream = through.obj(function (file, enc, callbackStream) {
    var currentStream = this;
    var cache = [];

    if (file.isNull()) {
            // Do nothing if no contents
      currentStream.push(file);

      return callbackStream();
    }

    if (file.isBuffer()) {
      var src = file.contents.toString();
      var result = [];

      async.whilst(
                function () {
                  result = rImages.exec(src);

                  return result !== null;
                },
                function (callback) {
                  if (cache[result[1]]) {
                    src = src.replace(result[1], cache[result[1]]);
                    callback();
                    return;
                  }

                  var pureUrl = result[1].split('?')[0].split('#')[0];
                  if (opts.extensionsAllowed.length !== 0 && opts.extensionsAllowed.indexOf(path.extname(pureUrl)) === -1) {
                    log('Ignores ' + chalk.yellow(result[1]) + ', extension not allowed ' + chalk.yellow(path.extname(result[1])), opts.verbose);
                    callback();
                    return;
                  }

                  encodeResource(result[1], file, opts, function (fileRes) {
                    if (undefined !== fileRes) {
                      if (fileRes.contents.length > opts.maxWeightResource) {
                        log('Ignores ' + chalk.yellow(result[1]) + ', file is too big ' + chalk.yellow(fileRes.contents.length + ' bytes'), opts.verbose);
                        callback();
                        return;
                      }

                      var strRes = 'data:' + mime.lookup(fileRes.path) + ';base64,' + fileRes.contents.toString('base64');
                      src = src.replace(result[1], strRes);

                            // Store in cache
                      cache[result[1]] = strRes;
                    }
                    callback();
                  });
                },
                function () {
                  file.contents = new Buffer(src);
                  currentStream.push(file);

                  return callbackStream();
                }
            );
    }

    if (file.isStream()) {
      this.emit('error', new PluginError('gulp-css-base64', 'Stream not supported!'));
    }
  });

    // returning the file stream
  return stream;
}

function encodeResource(img, file, opts, doneCallback) {
  var fileRes = new Vinyl();

  if (/^data:/.test(img)) {
    log('Ignores ' + chalk.yellow(img.substring(0, 30) + '...') + ', already encoded', opts.verbose);
    doneCallback();
    return;
  }

  if (img[0] === '#') {
    log('Ignores ' + chalk.yellow(img.substring(0, 30) + '...') + ', SVG mask', opts.verbose);
    doneCallback();
    return;
  }

  if (/^(http|https|\/\/)/.test(img)) {
    log('Fetch ' + chalk.yellow(img), opts.verbose);
        // different case for uri start '//'
    if (img[0] + img[1] === '//') {
      img = 'http:' + img;
    }

    fetchRemoteRessource(img, function (resultBuffer) {
      if (resultBuffer === null) {
        log('Error: ' + chalk.red(img) + ', unable to fetch', opts.verbose);
        doneCallback();
        return;
      }
      fileRes.path = img;
      fileRes.contents = resultBuffer;
      doneCallback(fileRes);
      return;
    });
  } else {
    var location = '';
    var binRes = '';

    location = img.charAt(0) === '/' ? (opts.baseDir || '') + img : path.join(path.dirname(file.path), (opts.baseDir || '') + '/' + img);
    location = location.replace(/([?#].*)$/, '');

    if (!fs.existsSync(location)) {
      log('Error: ' + chalk.red(location) + ', file not found', opts.verbose);
      doneCallback();
      return;
    }

    binRes = fs.readFileSync(location);

    fileRes.path = location;
    fileRes.contents = binRes;

    doneCallback(fileRes);
    return;
  }
}

function fetchRemoteRessource(url, callback) {
  var resultBuffer;
  var buffList = buffers();
  var imageStream = new Stream();

  imageStream.writable = true;
  imageStream.write = function (data) {
    buffList.push(new Buffer(data));
  };
  imageStream.end = function () {
    resultBuffer = buffList.toBuffer();
  };

  request(url, function (error, response) {
    if (error) {
      callback(null);
      return;
    }

        // Bail if we get anything other than 200
    if (response.statusCode !== 200) {
      callback(null);
      return;
    }

    callback(resultBuffer);
  }).pipe(imageStream);
}

function log(message, isVerbose) {
  if (isVerbose === true) {
    fancyLog(message);
  }
}

// Exporting the plugin main function
module.exports = gulpCssBase64;

1	'use strict';
2
3	// NodeJS library
4	var fs = require('fs');	4✔
5	var path = require('path');	4✔
6	var mime = require('mime');	4✔
7	var util = require('util');	4✔
8	var Stream = require('stream').Stream;	4✔
9
10	// NPM library
11	var Vinyl = require('vinyl');	4✔
12	var fancyLog = require('fancy-log');	4✔
13	var PluginError = require('plugin-error');	4✔
14	var through = require('through2');	4✔
15	var request = require('request');	4✔
16	var buffers = require('buffers');	4✔
17	var async = require('async');	4✔
18	var chalk = require('chalk');	4✔
19
20	var rImages = /url(?:\(['\|"]?)(.?)(?:['\|"]?\))(?!.\/\base64:skip\\/)/ig;	4✔
21
22	function gulpCssBase64(opts) {	4✔
23	opts = JSON.parse(JSON.stringify(opts \|\| {}));	96✔
24	opts.maxWeightResource = opts.maxWeightResource \|\| 32768;	96✔
25	if (util.isArray(opts.extensionsAllowed)) {	96✔
26	opts.extensionsAllowed = opts.extensionsAllowed;	12✔
27	} else {
28	opts.extensionsAllowed = [];	84✔
29	}
30	opts.extensionsAllowed = opts.extensionsAllowed \|\| [];	96!
31	opts.baseDir = opts.baseDir \|\| '';	96✔
32	opts.verbose = process.argv.indexOf('--verbose') !== -1;	96✔
33
34	// Creating a stream through which each file will pass
35	var stream = through.obj(function (file, enc, callbackStream) {	96✔
36	var currentStream = this;	92✔
37	var cache = [];	92✔
38
39	if (file.isNull()) {	92✔
40	// Do nothing if no contents
41	currentStream.push(file);	4✔
42
43	return callbackStream();	4✔
44	}
45
46	if (file.isBuffer()) {	88✔
47	var src = file.contents.toString();	84✔
48	var result = [];	84✔
49
50	async.whilst(	84✔
51	function () {
52	result = rImages.exec(src);	168✔
53
54	return result !== null;	168✔
55	},
56	function (callback) {
57	if (cache[result[1]]) {	84✔
58	src = src.replace(result[1], cache[result[1]]);	4✔
59	callback();	4✔
60	return;	4✔
61	}
62
63	var pureUrl = result[1].split('?')[0].split('#')[0];	80✔
64	if (opts.extensionsAllowed.length !== 0 && opts.extensionsAllowed.indexOf(path.extname(pureUrl)) === -1) {	80✔
65	log('Ignores ' + chalk.yellow(result[1]) + ', extension not allowed ' + chalk.yellow(path.extname(result[1])), opts.verbose);	4✔
66	callback();	4✔
67	return;	4✔
68	}
69
70	encodeResource(result[1], file, opts, function (fileRes) {	76✔
71	if (undefined !== fileRes) {	76✔
72	if (fileRes.contents.length > opts.maxWeightResource) {	56✔
73	log('Ignores ' + chalk.yellow(result[1]) + ', file is too big ' + chalk.yellow(fileRes.contents.length + ' bytes'), opts.verbose);	4✔
74	callback();	4✔
75	return;	4✔
76	}
77
78	var strRes = 'data:' + mime.lookup(fileRes.path) + ';base64,' + fileRes.contents.toString('base64');	52✔
79	src = src.replace(result[1], strRes);	52✔
80
81	// Store in cache
82	cache[result[1]] = strRes;	52✔
83	}
84	callback();	72✔
85	});
86	},
87	function () {
88	file.contents = new Buffer(src);	84✔
89	currentStream.push(file);	84✔
90
91	return callbackStream();	84✔
92	}
93	);
94	}
95
96	if (file.isStream()) {	88✔
97	this.emit('error', new PluginError('gulp-css-base64', 'Stream not supported!'));	4✔
98	}
99	});
100
101	// returning the file stream
102	return stream;	96✔
103	}
104
105	function encodeResource(img, file, opts, doneCallback) {	4✔
106	var fileRes = new Vinyl();	76✔
107
108	if (/^data:/.test(img)) {	76✔
109	log('Ignores ' + chalk.yellow(img.substring(0, 30) + '...') + ', already encoded', opts.verbose);	4✔
110	doneCallback();	4✔
111	return;	4✔
112	}
113
114	if (img[0] === '#') {	72✔
115	log('Ignores ' + chalk.yellow(img.substring(0, 30) + '...') + ', SVG mask', opts.verbose);	4✔
116	doneCallback();	4✔
117	return;	4✔
118	}
119
120	if (/^(http\|https\|\/\/)/.test(img)) {	68✔
121	log('Fetch ' + chalk.yellow(img), opts.verbose);	20✔
122	// different case for uri start '//'
123	if (img[0] + img[1] === '//') {	20✔
124	img = 'http:' + img;	4✔
125	}
126
127	fetchRemoteRessource(img, function (resultBuffer) {	20✔
128	if (resultBuffer === null) {	20✔
129	log('Error: ' + chalk.red(img) + ', unable to fetch', opts.verbose);	8✔
130	doneCallback();	8✔
131	return;	8✔
132	}
133	fileRes.path = img;	12✔
134	fileRes.contents = resultBuffer;	12✔
135	doneCallback(fileRes);	12✔
136	return;	12✔
137	});
138	} else {
139	var location = '';	48✔
140	var binRes = '';	48✔
141
142	location = img.charAt(0) === '/' ? (opts.baseDir \|\| '') + img : path.join(path.dirname(file.path), (opts.baseDir \|\| '') + '/' + img);	48!
143	location = location.replace(/([?#].*)$/, '');	48✔
144
145	if (!fs.existsSync(location)) {	48✔
146	log('Error: ' + chalk.red(location) + ', file not found', opts.verbose);	4✔
147	doneCallback();	4✔
148	return;	4✔
149	}
150
151	binRes = fs.readFileSync(location);	44✔
152
153	fileRes.path = location;	44✔
154	fileRes.contents = binRes;	44✔
155
156	doneCallback(fileRes);	44✔
157	return;	44✔
158	}
159	}
160
161	function fetchRemoteRessource(url, callback) {	4✔
162	var resultBuffer;	20✔
163	var buffList = buffers();	20✔
164	var imageStream = new Stream();	20✔
165
166	imageStream.writable = true;	20✔
167	imageStream.write = function (data) {	20✔
168	buffList.push(new Buffer(data));	32✔
169	};
170	imageStream.end = function () {	20✔
171	resultBuffer = buffList.toBuffer();	16✔
172	};
173
174	request(url, function (error, response) {	20✔
175	if (error) {	20✔
176	callback(null);	4✔
177	return;	4✔
178	}
179
180	// Bail if we get anything other than 200
181	if (response.statusCode !== 200) {	16✔
182	callback(null);	4✔
183	return;	4✔
184	}
185
186	callback(resultBuffer);	12✔
187	}).pipe(imageStream);
188	}
189
190	function log(message, isVerbose) {	4✔
191	if (isVerbose === true) {	48!
192	fancyLog(message);	×
193	}
194	}
195
196	// Exporting the plugin main function
197	module.exports = gulpCssBase64;	4✔

zckrs / gulp-css-base64 / 10

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous