X-Git-Url: http://git.pjr.cc/?p=random_node_code.git;a=blobdiff_plain;f=tftp%2Fnode_modules%2Ftftp-client%2Flib%2Ftftp.js;fp=tftp%2Fnode_modules%2Ftftp-client%2Flib%2Ftftp.js;h=0000000000000000000000000000000000000000;hp=4029627c6560f3fd49f9f6edfe2d4a5e7fec4706;hb=58109845ae41cbdea4483ad2b875808f0347fd0c;hpb=942600847463141c96126666cedec70403a32819

diff --git a/tftp/node_modules/tftp-client/lib/tftp.js b/tftp/node_modules/tftp-client/lib/tftp.js
deleted file mode 100644
index 4029627..0000000
--- a/tftp/node_modules/tftp-client/lib/tftp.js
+++ /dev/null
@@ -1,457 +0,0 @@
-var dgram = require('dgram');	// UDP (datagram)
-
-// Timeout for ack/data packet
-var TIMEOUT = 5000; // 5 seconds
-// Max retransmits if timeout
-var MAX_RETRANSMITS = 3;
-
-// type: Opcode
-var types = {
-	'rrq': 1, // Read ReQuest
-	'wrq': 2, // Write ReQuest
-	'data':3,
-	'ack': 4,
-	'err': 5,
-
-	// aliases:
-	'read':1,
-	'write':2
-}
-
-// Error strings ([errorCode] = errorString)
-var errors = [
-	'Not defined, see error message (if any).',
-	'File not found.',
-	'Access violation.',
-	'Disk full or allocation exceeded.',
-	'Illegal TFTP operation.',
-	'Unknown transfer ID.',
-	'File already exists.',
-	'No such user.'
-];
-
-/**
- * Constructor
- * @param  {Number} port Port the tftp server is listening to
- * @param  {String} ip   Ip or hostname of the tftp server
- */
-var TFTP = module.exports = function(port, ip) {
-	this.ip = ip || '127.0.0.1';
-	this.port = port || 69;
-
-	// Hold the current operation
-	this.current = false;
-	// Holds the queue of the next operations
-	this.queue = [];
-
-	// Client will be created when needed
-	this.client = null;
-
-	// Display debug messages?
-	this.debug = false;
-}
-
-TFTP.prototype.createClient = function() {
-	if (this.client !== null)
-		return;
-
-	// We need this inside onMessage...
-	var self = this;
-	
-	// Called when getting an message from the server
-	var onMessage = function(msg, rinfo) {
-
-		// Type of message (see `types` above)
-		var type  = msg.readUInt16BE(0);
-
-		switch (type) {
-			// Data - Respond with Ack
-			case types.data:
-				var block = msg.readUInt16BE(2);
-				var data = msg.slice(4); // From byte 4 is data
-
-				if (self.debug) {
-					console.log('> Received data. Block#: %d Bytes: %d', block, data.length);
-					console.log('< Sending ACK. Block#: %d', block);
-				}
-
-				// Concat the two buffers
-				self.current.data = Buffer.concat([self.current.data, data]);
-
-				// Create and send ACK packet
-				var ack = createAck(block);
-				self.send(ack);
-
-				// If less than 512 bytes were received, it's the end...
-				if (data.length < 512) {
-					// Send the data to the callback
-					self.current.callback(null, self.current.data);
-
-					// Go to next operation in queue
-					self.next();
-				}
-				break;
-			// Ack - Respond with Data
-			case types.ack:
-				var block = msg.readUInt16BE(2);
-
-				if (self.debug)
-					console.log('> Received ACK. Block#: %d', block);
-
-				// If this is the ack for the last block
-				if (block == self.current.blocks) {
-					// Send callback
-					self.current.callback(null, self.current.data.length);
-
-					// Go to next operation in queue
-					self.next();
-
-					// Break out of switch
-					break;
-				}
-
-				if (self.debug)
-					console.log('< Sending data. Block#: %d', block + 1);
-
-				// Create the data packet for the next block of data
-				var start = 512 * block;
-				// End is `start + 512`, or end of data, whichever comes first
-				var end   = Math.min(start + 512, self.current.data.length);
-				var data = self.current.data.slice(start, end);
-
-				var packet = createData(block+1, data);
-
-				// Send data block
-				self.send(packet);
-				break;
-			// Error
-			case types.err:
-				// Create new Error(), and send callback
-				var errorCode = msg.readUInt16BE(2);
-				var errMsg = msg.toString('ascii', 4, msg.length - 1);
-				// @TODO: Take errMsg from `errors`, unless code == 0?
-				var err = new Error(errMsg);
-					err.code = errorCode;
-
-				if (self.debug)
-					console.log('> Received Error. code: %d - msg: %s', errorCode, ErrMsg);
-
-				// Callback
-				self.current.callback(err);
-
-				// Go to next operation in queue
-				self.next();
-				break;
-		}
-	}
-
-	// Create socket, and listen to messages
-	this.client = dgram.createSocket("udp4", onMessage);
-};
-
-/**
- * Shortcut for sending packet to server
- * @param  {Buffer}   buff The buffer to send
- * @param  {Function} cb   Callback - (err, bytes)
- */
-TFTP.prototype.send = function(buff, cb) {
-	if (typeof cb !== 'function') cb = function() {};
-
-	// We need this later
-	var self = this;
-	
-	// Create function of sending this packet so that we can call it again on timeout
-	var send = function() {
-		self.client.send(buff, 0, buff.length, self.port, self.ip, cb);
-	};
-	// Send the packet already
-	send();
-
-	var onTimeout = function() {
-		// If we have retransmitted less than MAX_RETRANSMITS
-		if (MAX_RETRANSMITS > ++self.current.timeout.retransmits) {
-
-			if (self.debug)
-				console.log('! Timeout - Retransmitting (%d bytes)', buff.length);
-
-			// Send the packet again
-			send();
-
-			// Set a new timeout for the packet we just sent
-			self.current.timeout.id = setTimeout(onTimeout, TIMEOUT);
-		}
-
-		// If we sent too many retransmitts, the remote server did not respond...
-		else {
-			if (self.debug)
-				console.log('! Timeout - End');
-
-			// Create error
-			var err = new Error("Timeout");
-			err.code = 0;
-
-			self.current.callback(err);
-			// Reset current, and check queue - (no answer from server)
-			self.next();
-		}
-	}
-
-	// If there is a timeout, clear the timeout
-	if (this.current.timeout)
-		clearTimeout(this.current.timeout.id);
-
-	// Create a timeout object where we store information about this timeout
-	this.current.timeout = {
-		id: setTimeout(onTimeout, TIMEOUT),
-		retransmits: 0
-	}
-};
-
-/**
- * Goes to next item in queue (if any). Same as `check()`, but clears current first
- */
-TFTP.prototype.next = function() {
-	// Has to clear any timeout
-	if (this.current && this.current.timeout)
-		clearTimeout(this.current.timeout.id);
-
-	// Reset current, and check queue
-	this.current = false;
-	this.check();
-};
-
-/**
- * Checks the Queue.
- * If no operation is currently active, go to the next item in the queue (if any).
- */
-TFTP.prototype.check = function() {
-	// If there currently is an active operation
-	// Or if the queue is empty, just return
-	if (this.current !== false)
-		return;
-
-	// If there is nothing running, and the queue is empty
-	if (this.queue.length == 0) {
-		// Close client
-		this.client.close();
-		return;
-	} else {
-		// Create client
-		this.createClient();
-	}
-
-	// Take the first item in queue
-	this.current = this.queue.shift();
-
-	// We need this later
-	var self = this;
-
-
-	if (self.debug)
-		console.log('< Sending request');
-
-	// Create the request...
-	var buff = createRequest(this.current.type, this.current.filename);
-	// Send the request
-	this.send(buff, function(err, bytes) {
-		// If there was an error sending the packet
-		if (err) {
-			// Create Error message
-			var err = new Error(['Error when sending ',
-								self.current.type,
-								' request for ',
-								self.current.filename].join());
-
-			// Send error to the callback of the current operation
-			self.current.callback(err);
-
-			// Reset current
-			self.current = false;
-
-			// Then check queue
-			self.check();
-		}
-	});
-};
-
-/**
- * Sends a file to the server
- * @param  {String}   filename File to send
- * @param  {Buffer}   data     The data to write/send to the server
- * @param  {Function} cb       Callback - (err)
- */
-TFTP.prototype.write = function(filename, data, cb) {
-	if (typeof cb !== 'function') cb = function() {}; // Default cb to an empty function
-	if (!Buffer.isBuffer(data)) data = new Buffer(data); // If data is not a Buffer, make it a buffer
-
-	// Item to put into the queue
-	var queueItem = {
-		type: 'write',
-		filename: filename,
-		callback: cb,
-		data: data,
-		blocks: Math.ceil(data.length / 512) // Number of blocks to transfer data.
-		                                     // When we receive an ACK with this number, the transfer is finished
-	};
-
-	// Push the queueItem to the end of the queue.
-	this.queue.push(queueItem);
-
-	// Check the queue...
-	this.check();
-};
-
-/**
- * Reads a file off the server
- * @param  {String}   filename File to read from server
- * @param  {Function} cb       Callback - (err, data)
- */
-TFTP.prototype.read = function(filename, cb) {
-	if (typeof cb !== 'function') cb = function() {}; // Default cb to an empty function
-
-	// Item to put into the queue
-	var queueItem = {
-		type: 'read',
-		filename: filename,
-		callback: cb,
-		data: new Buffer(0) // Buffer of size 0 which will be filled up by onMessage
-	};
-
-	// Push the queueItem to the end of the queue.
-	this.queue.push(queueItem);
-
-	// Check the queue...
-	this.check();
-};
-
-/**
- * Creates a buffer for a request.
-
-   2 bytes     string    1 byte     string   1 byte
-   ------------------------------------------------
-  | Opcode |  Filename  |   0  |    Mode    |   0  |
-   ------------------------------------------------
-
- * @param  {String|Number} type     Int Opcode, or String (read|write|rrq|wrq)
- * @param  {String} filename        Filename to add in the request
- * @param  {String} mode            optional Mode (netascii|octet|email) - Defaults to octet
- * @return {Buffer}                 The Buffer
- */
-function createRequest(type, filename, mode) {
-	// Figure out the opcode for the type
-	if (typeof type === 'string') {
-		type = type.toLowerCase();
-
-		// If it exists in the types object, we found it
-		if (types.hasOwnProperty(type))
-			type = types[type];
-		// If not, we dno what type
-		else
-			throw 'Unknown type (' + type + ')';
-	}
-	// Not a string, nor a number, then we dno what type of request it is...
-	else if (typeof type !== 'number')
-		throw 'Unknown type (' + type + ')';
-
-	// Default mode to 'octet'
-	mode = mode || 'octet';
-
-	// Calculate the length of the buffer
-	// mode (2 byte opcode) + length of filename + 1 null byte + length of mode + 1 null byte.
-	var buffLen = 4 + filename.length + mode.length;
-
-	// Create the buffer
-	var buff = new Buffer(buffLen);
-	// Write mode (as unsigned 16 bit integer) on offset 0
-	buff.writeUInt16BE(type, 0);
-	// Write filename as ascii on offset 2
-	buff.write(filename, 2, 'ascii');
-	// Write mode as ascii on offset filename.length + 3 (type + filename null termination)
-	buff.write(mode, 2 + filename.length + 1, 'ascii');
-
-	// Make sure the ends of the strings are null
-	buff[2 + filename.length] = buff[buffLen - 1] = 0;
-
-	// Return the new buffer
-	return buff;
-}
-
-/**
- * Creates a buffer for a data packet
-
-   2 bytes     2 bytes      n bytes
-   ----------------------------------
-  | Opcode |   Block #  |   Data     |
-   ----------------------------------
-
- * @param  {Number} blockNumber Which block of the transaction it is
- * @param  {String} data        The data to send
- * @return {Buffer}             The Buffer
- */
-function createData(blockNumber, data) {
-	var type = types['data'];
-
-	// Type + blocknumber + length of data(max 512)
-	var dataLen = Math.min(data.length, 512);
-	var buffLen = 4 + dataLen;
-
-	var buff = new Buffer(buffLen);
-
-	buff.writeUInt16BE(type, 0); // Type as UInt16BE on offset: 0
-	buff.writeUInt16BE(blockNumber, 2); // BlockNumber as UInt16BE on offset: 2
-	// Copy `data` into buff on offset 4. bytes 0 to 512 from `data`.
-	data.copy(buff, 4, 0, dataLen); // targetBuffer, targetStart, sourceStart, sourceEnd
-
-	return buff;
-}
-
-/**
- * Creates a buffer for a ACK packet
-
-   2 bytes     2 bytes
-   ---------------------
-  | Opcode |   Block #  |
-   ---------------------
-
- * @param  {Number} blockNumber Which block to ack
- * @return {Buffer}             The Buffer
- */
-function createAck(blockNumber) {
-	var type = types['ack'];
-
-	var buff = new Buffer(4);
-	buff.writeUInt16BE(type, 0); // Type as UInt16BE on offset: 0
-	buff.writeUInt16BE(blockNumber, 2); // BlockNumber as UInt16BE on offset: 2
-
-	return buff;
-}
-
-/**
- * Creates a buffer for an ERROR packet
-
-   2 bytes     2 bytes      string    1 byte
-   -----------------------------------------
-  | Opcode |  ErrorCode |   ErrMsg   |   0  |
-   -----------------------------------------
-
- * @param  {Number} code ErrorCode
- * @param  {String} msg  Optional message - defaults to the message of the error code
- * @return {Buffer}      The Buffer
- */
-function createError(code, msg) {
-	// Default error message to the error message for the code (defined on top)
-	msg = msg || errors[code];
-	if (typeof msg !== 'string') msg = '';
-
-	var type = types['error'];
-
-	var buffLen = 4 + msg.length + 1;
-
-	var buff = new Buffer(buffLen);
-	buff.writeUInt16BE(type, 0); // Type as UInt16BE on offset: 0
-	buff.writeUInt16BE(code, 2); // ErrorCode as UInt16BE on offset: 2
-	buff.write(msg, 4, 'ascii'); // ErrMsg as ascii string on offset: 4
-	buff[buffLen - 1] = 0; // Last byte is 0
-
-	return buff;
-}