tarn.js: Operation timed out for an unknown reason

Hi, i’m facing the same issue,

Error: operation timed out for an unknown reason
at PendingOperation.promise.timeout.catch.err (/app/node_modules/tarn/lib/PendingOperation.js:16:27)
t propagateAslWrapper (/app/node_modules/async-listener/index.js:504:23)
at /app/node_modules/async-listener/glue.js:188:31
at /app/node_modules/async-listener/index.js:541:70
at /app/node_modules/async-listener/glue.js:188:31

this is only happening when Query is fired simultaneously and during this operation network connectivity is dropped, once network is back same error is keep on coming, until service restarted and new connection established.

to reproduce this following config :

const configDB = {
  user: config.sqlDbUsername,
  password: config.sqlDbPassword,
  port: config.sqlDbPort,
  server: config.sqlDbHost,
  database: config.sqlDbName,
  pool: {
    max: 1,
  },
};
let _connection: Promise<sql.ConnectionPool>;
export const setupDB = () => {
  try {
    const _pool = new sql.ConnectionPool(configDB);
    _connection = _pool.connect();
    logger.info('DB Connection is ready ...');
    _pool.on('error', error => {
      logger.error('DB Error handler :', error);
    });
  } catch (err) {
    logger.error('Failed to Initialize the socket:', err);
    throw err;
  }
};
export const getConnectionPool = () => {
  return _connection;
};

async function fetchData() {
  const _pool = await getConnectionPool();
  const _request = new PreparedStatement(_pool);
  await _request.prepare(query); // pass sample query
  const { recordsets } = await _request.execute(data);
  await _request.unprepare();
  return recordsets;
}

I’m executing parallel query using prepare statement, and with pool.max is 1

@laychopy I’ve handled this issue with different approach, i’ve listen for the error event (https://github.com/tediousjs/node-mssql#connect-callback) along with Error code ETIMEOUT, and again retry the connection within some interval, so every time if i’ll get operation timed out with error code, it will keep on retry connection until success ,

Here is the sample code

const handleDBError = (error: sql.ConnectionError) => {
  logger.error('DB Error handler: ', error);
  if (error.message.includes('operation timed out') || error.code === 'ETIMEOUT') {
    clearInterval(timer);
    timer = setInterval(() => {
      return void (async () => {
        try {
          logger.info(`Retrying connection ... `);
          await setupDB();
        } catch (error) {
          logger.error('Error connecting ...');
        }
      })();
    }, config.retryConnectionInterval);
  }
};

export const setupDB = async () => {
  try {
    _pool = new sql.ConnectionPool(configDB);
    await _pool.connect();
    clearInterval(timer); // clear the interval once the connection established
    logger.info('DB Connection successful ...');
    _pool.on('error', handleDBError);
  } catch (err) {
    logger.error('Failed to connect:', err);
    const _err = <sql.ConnectionError>err;
    if (_err.code === 'ETIMEOUT') handleDBError(err);
    throw err;
  }
};

Hope this helps you