Skip to content

Commit

Permalink
chore: better organize new files
Browse files Browse the repository at this point in the history
  • Loading branch information
wellwelwel committed Nov 12, 2024
1 parent b765a02 commit 623e8c9
Show file tree
Hide file tree
Showing 13 changed files with 25 additions and 25 deletions.
10 changes: 5 additions & 5 deletions lib/base_connection.js → lib/base/connection.js
Original file line number Diff line number Diff line change
Expand Up @@ -23,11 +23,11 @@ const Readable = require('stream').Readable;
const Queue = require('denque');
const SqlString = require('sqlstring');
const { createLRU } = require('lru.min');
const PacketParser = require('./packet_parser.js');
const Packets = require('./packets/index.js');
const Commands = require('./commands/index.js');
const ConnectionConfig = require('./connection_config.js');
const CharsetToEncoding = require('./constants/charset_encodings.js');
const PacketParser = require('../packet_parser.js');
const Packets = require('../packets/index.js');
const Commands = require('../commands/index.js');
const ConnectionConfig = require('../connection_config.js');
const CharsetToEncoding = require('../constants/charset_encodings.js');

let _connectionId = 0;

Expand Down
4 changes: 2 additions & 2 deletions lib/base_pool.js → lib/base/pool.js
Original file line number Diff line number Diff line change
Expand Up @@ -3,9 +3,9 @@
const process = require('process');
const SqlString = require('sqlstring');
const EventEmitter = require('events').EventEmitter;
const PoolConnection = require('./pool_connection.js');
const PoolConnection = require('../pool_connection.js');
const Queue = require('denque');
const BaseConnection = require('./base_connection.js');
const BaseConnection = require('./connection.js');

function spliceConnection(queue, connection) {
const len = queue.length;
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
'use strict';

const BaseConnection = require('./base_connection.js');
const BaseConnection = require('./connection.js');

class BasePoolConnection extends BaseConnection {
constructor(pool, options) {
Expand Down
4 changes: 2 additions & 2 deletions lib/connection.js
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
'use strict';

const BaseConnection = require('./base_connection.js');
const BaseConnection = require('./base/connection.js');

class Connection extends BaseConnection {
promise(promiseImpl) {
const PromiseConnection = require('./promise_connection.js');
const PromiseConnection = require('./promise/connection.js');
return new PromiseConnection(this, promiseImpl);
}
}
Expand Down
4 changes: 2 additions & 2 deletions lib/pool.js
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
'use strict';

const BasePool = require('./base_pool.js');
const BasePool = require('./base/pool.js');

class Pool extends BasePool {
promise(promiseImpl) {
const PromisePool = require('./promise_pool.js');
const PromisePool = require('./promise/pool.js');
return new PromisePool(this, promiseImpl);
}
}
Expand Down
4 changes: 2 additions & 2 deletions lib/pool_connection.js
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
'use strict';

const BasePoolConnection = require('./base_pool_connection.js');
const BasePoolConnection = require('./base/pool_connection.js');

class PoolConnection extends BasePoolConnection {
promise(promiseImpl) {
const PromisePoolConnection = require('./promise_pool_connection.js');
const PromisePoolConnection = require('./promise/pool_connection.js');

Check warning on line 7 in lib/pool_connection.js

View check run for this annotation

Codecov / codecov/patch

lib/pool_connection.js#L7

Added line #L7 was not covered by tests
return new PromisePoolConnection(this, promiseImpl);
}
}
Expand Down
4 changes: 2 additions & 2 deletions lib/promise_connection.js → lib/promise/connection.js
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
'use strict';

const EventEmitter = require('events').EventEmitter;
const PromisePreparedStatementInfo = require('./promise_prepared_statement_info.js');
const PromisePreparedStatementInfo = require('./prepared_statement_info.js');
const makeDoneCb = require('./make_done_cb.js');
const inheritEvents = require('./inherit_events.js');
const BaseConnection = require('./base_connection.js');
const BaseConnection = require('../base/connection.js');

class PromiseConnection extends EventEmitter {
constructor(connection, promiseImpl) {
Expand Down
File renamed without changes.
File renamed without changes.
4 changes: 2 additions & 2 deletions lib/promise_pool.js → lib/promise/pool.js
Original file line number Diff line number Diff line change
Expand Up @@ -2,9 +2,9 @@

const EventEmitter = require('events').EventEmitter;
const makeDoneCb = require('./make_done_cb.js');
const PromisePoolConnection = require('./promise_pool_connection.js');
const PromisePoolConnection = require('./pool_connection.js');
const inheritEvents = require('./inherit_events.js');
const BasePool = require('./base_pool.js');
const BasePool = require('../base/pool.js');

class PromisePool extends EventEmitter {
constructor(pool, thePromise) {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
'use strict';

const PromiseConnection = require('./promise_connection.js');
const BasePoolConnection = require('./base_pool_connection.js');
const PromiseConnection = require('./connection.js');
const BasePoolConnection = require('../base/pool_connection.js');

class PromisePoolConnection extends PromiseConnection {
constructor(connection, promiseImpl) {
Expand Down
File renamed without changes.
10 changes: 5 additions & 5 deletions promise.js
Original file line number Diff line number Diff line change
Expand Up @@ -7,11 +7,11 @@ const PoolCluster = require('./lib/pool_cluster.js');
const createConnection = require('./lib/create_connection.js');
const createPool = require('./lib/create_pool.js');
const createPoolCluster = require('./lib/create_pool_cluster.js');
const PromiseConnection = require('./lib/promise_connection.js');
const PromisePool = require('./lib/promise_pool.js');
const makeDoneCb = require('./lib/make_done_cb.js');
const PromisePoolConnection = require('./lib/promise_pool_connection.js');
const inheritEvents = require('./lib/inherit_events.js');
const PromiseConnection = require('./lib/promise/connection.js');
const PromisePool = require('./lib/promise/pool.js');
const makeDoneCb = require('./lib/promise/make_done_cb.js');
const PromisePoolConnection = require('./lib/promise/pool_connection.js');
const inheritEvents = require('./lib/promise/inherit_events.js');

function createConnectionPromise(opts) {
const coreConnection = createConnection(opts);
Expand Down

0 comments on commit 623e8c9

Please sign in to comment.