sjs/batteries
1
0
Fork 0
mirror of https://github.com/samsonjs/batteries.git synced 2026-04-27 15:07:42 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

move fs extensions into a subdir

Browse source
This commit is contained in:
Sami Samhuri 2011-06-05 18:06:27 -07:00
parent 2b7db269a3
commit 8e2ca7fec3
3 changed files with 6 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
lib/file-follower.js → lib/fs/file-follower.js
View file

@ -4,7 +4,7 @@
var fs = require('fs') var fs = require('fs')
, util = require('util') , util = require('util')
, EventEmitter = require('events').EventEmitter , EventEmitter = require('events').EventEmitter
, FileExt = require('./file') , batteries = require('./')
; ;
module.exports = FileFollower; module.exports = FileFollower;
@ -17,7 +17,7 @@ function FileFollower(file, options) {
this.currSize = fs.statSync(file).size; this.currSize = fs.statSync(file).size;
this.prevSize = this.currSize; this.prevSize = this.currSize;
this.interval = options.interval || 1000; this.interval = options.interval || 1000;
FileExt.eachLine(file, batteries.fs.eachLine(file,
{ line: function(line) { { line: function(line) {
self.emit('line', line); self.emit('line', line);
} }

9
lib/file.js → lib/fs/index.js
View file

@ -2,10 +2,9 @@
// Copyright 2010 - 2011 Sami Samhuri <sami@samhuri.net> // Copyright 2010 - 2011 Sami Samhuri <sami@samhuri.net>
var fs = require('fs') var fs = require('fs')
, ArrayExt = require('./array') , batteries = require('../')
, FileFollower = require('./file-follower') , FileFollower = require('./file-follower')
, LineEmitter = require('./line-emitter') , LineEmitter = require('./line-emitter')
, ObjectExt = require('./object')
, constants = require('constants') , constants = require('constants')
, FileExt , FileExt
; ;
@ -36,10 +35,10 @@ Object.keys(Object.getPrototypeOf(s)).forEach(function(k) {
}); });
exports.extendNative = function() { exports.extendNative = function() {
ObjectExt.extend(fs, FileExt); batteries.object.extend(fs, FileExt);
}; };
ObjectExt.extend(exports, FileExt); batteries.object.extend(exports, FileExt);
function eachLine(f, optionsOrLineFn, endFn) { function eachLine(f, optionsOrLineFn, endFn) {
var lineFn, hasLineFn, hasEndFn; var lineFn, hasLineFn, hasEndFn;
@ -81,7 +80,7 @@ function grep(regex, f, callback) {
var results = []; var results = [];
eachLine(f, eachLine(f,
{ line: function(line) { if (line.match(regex)) results.push(line); } { line: function(line) { if (line.match(regex)) results.push(line); }
, end: callback(results) , end: function() { callback(results); }
}); });
} }

0
lib/line-emitter.js → lib/fs/line-emitter.js
View file