FM / commands

/var/www/qr4y.gr/server/delivery/node_modules/mysql2/lib/commands/

/var/www/qr4y.gr/server/delivery/node_modules/mysql2/lib/commands

Name	Size	Mode	Actions
auth_switch.js	3459	0644	edit dl rm
binlog_dump.js	2920	0644	edit dl rm
change_user.js	1761	0644	edit dl rm
client_handshake.js	6443	0644	edit dl rm
close_statement.js	361	0644	edit dl rm
command.js	1264	0644	edit dl rm
execute.js	3717	0644	edit dl rm
index.js	696	0644	edit dl rm
ping.js	817	0644	edit dl rm
prepare.js	3496	0644	edit dl rm
query.js	10074	0644	edit dl rm
quit.js	563	0644	edit dl rm
register_slave.js	592	0644	edit dl rm
server_handshake.js	5180	0644	edit dl rm

Edit: /var/www/qr4y.gr/server/delivery/node_modules/mysql2/lib/commands/command.js (1264B)

'use strict';

const EventEmitter = require('events').EventEmitter;
const Timers = require('timers');

class Command extends EventEmitter {
  constructor() {
    super();
    this.next = null;
  }

// slow. debug only
  stateName() {
    const state = this.next;
    for (const i in this) {
      if (this[i] === state && i !== 'next') {
        return i;
      }
    }
    return 'unknown name';
  }

execute(packet, connection) {
    if (!this.next) {
      this.next = this.start;
      connection._resetSequenceId();
    }
    if (packet && packet.isError()) {
      const err = packet.asError(connection.clientEncoding);
      err.sql = this.sql || this.query;
      if (this.queryTimeout) {
        Timers.clearTimeout(this.queryTimeout);
        this.queryTimeout = null;
      }
      if (this.onResult) {
        this.onResult(err);
        this.emit('end');
      } else {
        this.emit('error', err);
        this.emit('end');
      }
      return true;
    }
    // TODO: don't return anything from execute, it's ugly and error-prone. Listen for 'end' event in connection
    this.next = this.next(packet, connection);
    if (this.next) {
      return false;
    } 
    this.emit('end');
    return true;
    
  }
}

module.exports = Command;

'use strict'; const EventEmitter = require('events').EventEmitter; const Timers = require('timers'); class Command extends EventEmitter { constructor() { super(); this.next = null; } // slow. debug only stateName() { const state = this.next; for (const i in this) { if (this[i] === state && i !== 'next') { return i; } } return 'unknown name'; } execute(packet, connection) { if (!this.next) { this.next = this.start; connection._resetSequenceId(); } if (packet && packet.isError()) { const err = packet.asError(connection.clientEncoding); err.sql = this.sql || this.query; if (this.queryTimeout) { Timers.clearTimeout(this.queryTimeout); this.queryTimeout = null; } if (this.onResult) { this.onResult(err); this.emit('end'); } else { this.emit('error', err); this.emit('end'); } return true; } // TODO: don't return anything from execute, it's ugly and error-prone. Listen for 'end' event in connection this.next = this.next(packet, connection); if (this.next) { return false; } this.emit('end'); return true; } } module.exports = Command;