|
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216 |
- var path = require( 'path' );
-
- module.exports = {
- createFromFile: function ( filePath ) {
- var fname = path.basename( filePath );
- var dir = path.dirname( filePath );
- return this.create( fname, dir );
- },
-
- create: function ( cacheId, _path ) {
- var fs = require( 'fs' );
- var flatCache = require( 'flat-cache' );
- var cache = flatCache.load( cacheId, _path );
- var assign = require( 'object-assign' );
- var normalizedEntries = { };
-
- var removeNotFoundFiles = function removeNotFoundFiles() {
- const cachedEntries = cache.keys();
-
- cachedEntries.forEach( function remover( fPath ) {
- try {
- fs.statSync( fPath );
- } catch (err) {
- if ( err.code === 'ENOENT' ) {
- cache.removeKey( fPath );
- }
- }
- } );
- };
-
- removeNotFoundFiles();
-
- return {
-
-
- cache: cache,
-
-
- hasFileChanged: function ( file ) {
- return this.getFileDescriptor( file ).changed;
- },
-
-
-
- analyzeFiles: function ( files ) {
- var me = this;
- files = files || [ ];
-
- var res = {
- changedFiles: [],
- notFoundFiles: [],
- notChangedFiles: []
- };
-
- me.normalizeEntries( files ).forEach( function ( entry ) {
- if ( entry.changed ) {
- res.changedFiles.push( entry.key );
- return;
- }
- if ( entry.notFound ) {
- res.notFoundFiles.push( entry.key );
- return;
- }
- res.notChangedFiles.push( entry.key );
- } );
- return res;
- },
-
- getFileDescriptor: function ( file ) {
- var meta = cache.getKey( file );
- var cacheExists = !!meta;
- var fstat;
- var me = this;
-
- try {
- fstat = fs.statSync( file );
- } catch (ex) {
- me.removeEntry( file );
- return { key: file, notFound: true, err: ex };
- }
-
- var cSize = fstat.size;
- var cTime = fstat.mtime.getTime();
-
- if ( !meta ) {
- meta = { size: cSize, mtime: cTime };
- } else {
- var isDifferentDate = cTime !== meta.mtime;
- var isDifferentSize = cSize !== meta.size;
- }
-
- var nEntry = normalizedEntries[ file ] = {
- key: file,
- changed: !cacheExists || isDifferentDate || isDifferentSize,
- meta: meta
- };
-
- return nEntry;
- },
-
-
-
- getUpdatedFiles: function ( files ) {
- var me = this;
- files = files || [ ];
-
- return me.normalizeEntries( files ).filter( function ( entry ) {
- return entry.changed;
- } ).map( function ( entry ) {
- return entry.key;
- } );
- },
-
-
-
- normalizeEntries: function ( files ) {
- files = files || [ ];
-
- var me = this;
- var nEntries = files.map( function ( file ) {
- return me.getFileDescriptor( file );
- } );
-
-
- return nEntries;
- },
-
-
-
- removeEntry: function ( entryName ) {
- delete normalizedEntries[ entryName ];
- cache.removeKey( entryName );
- },
-
-
-
- deleteCacheFile: function () {
- cache.removeCacheFile();
- },
-
-
-
- destroy: function () {
- normalizedEntries = { };
- cache.destroy();
- },
-
-
- reconcile: function () {
- removeNotFoundFiles();
-
- var entries = normalizedEntries;
- var keys = Object.keys( entries );
-
- if ( keys.length === 0 ) {
- return;
- }
-
- keys.forEach( function ( entryName ) {
- var cacheEntry = entries[ entryName ];
-
- try {
- var stat = fs.statSync( cacheEntry.key );
- var meta = assign( cacheEntry.meta, {
- size: stat.size,
- mtime: stat.mtime.getTime()
- } );
-
- cache.setKey( entryName, meta );
- } catch (err) {
-
-
- if ( err.code !== 'ENOENT' ) {
- throw err;
- }
- }
- } );
-
- cache.save( true );
- }
- };
- }
- };
|