fix: explicitly promisify fs methods

`promisifyAll` will throw if a method with the suffix `Async` already exists. Fixes: https://github.com/trs/ftp-srv/pull/159
feat: allow connecting from local
2019-08-22 14:57:40 -06:00 · 2019-08-22 14:57:40 -06:00 · 2019-08-22 14:57:40 -06:00 · 2019-08-22 14:57:40 -06:00 · 2019-08-22 14:57:40 -06:00 · 2019-08-22 14:57:40 -06:00
156 changed files with 16724 additions and 5356 deletions
--- a/.circleci/config.yml
+++ b/.circleci/config.yml
@@ -1,53 +1,78 @@
 version: 2
+
 jobs:
  build:
    docker:
-      - image: circleci/node:8
+      - image: &node-image circleci/node:lts
    steps:
      - checkout
+      - restore_cache:
+          keys:
+            - &npm-cache-key npm-cache-{{ .Branch }}-{{ .Revision }}
+            - npm-cache-{{ .Branch }}
+            - npm-cache
      - run:
-          name: Building...
-          command: npm install
-      - save_cache:
+          name: Install
+          command: npm ci
+      - persist_to_workspace:
+          root: .
          paths:
            - node_modules
-          key: node_modules_{{ checksum package.json }}
+      - save_cache:
+          key: *npm-cache-key
+          paths:
+            - ~/.npm/_cacache
+
  lint:
    docker:
-      - image: circleci/node:8
+      - image: *node-image
    steps:
      - checkout
-      - restore_cache:
-          key: node_modules_{{ checksum package.json }}
+      - attach_workspace:
+          at: .
      - run:
-          name: Linting...
-          command: npm run lint
+          name: Lint
+          command: npm run verify
+
  test:
    docker:
-      - image: circleci/node:8
+      - image: *node-image
    steps:
      - checkout
-      - restore_cache:
-          key: node_modules_{{ checksum package.json }}
-      - run:
-          name: Testing...
-          command: npm run test
-  publish:
-    branches:
-      only: master
+      - attach_workspace:
+          at: .
+      - deploy:
+          name: Test
+          command: |
+            npm run test
+
+  release_dry_run:
    docker:
-      - image: circleci/node:8
+      - image: *node-image
    steps:
      - checkout
-      - restore_cache:
-          key: node_modules_{{ checksum package.json }}
-      - run:
-          name: Publishing...
-          command: npx semantic-release
+      - attach_workspace:
+          at: .
+      - deploy:
+          name: Dry Release
+          command: |
+            npm run semantic-release -- --dry-run
+
+  release:
+    docker:
+      - image: *node-image
+    steps:
+      - checkout
+      - attach_workspace:
+          at: .
+      - deploy:
+          name: Release
+          command: |
+            npm run semantic-release

 workflows:
  version: 2
-  main:
+  publish:
    jobs:
      - build
      - lint:
@@ -55,7 +80,18 @@ workflows:
            - build
      - test:
          requires:
-            - lint
-      - publish:
+            - build
+      - release_dry_run:
+          filters:
+            branches:
+              only: master
          requires:
-            - test
+            - test
+            - lint
+      - hold_release:
+          type: approval
+          requires:
+            - release_dry_run
+      - release:
+          requires:
+            - hold_release
--- a/.config/.eslintignore
+++ b/.config/.eslintignore
@@ -1,2 +0,0 @@
-node_modules/*
-config/*
--- a/.config/.eslintrc.json
+++ b/.config/.eslintrc.json
@@ -1,15 +0,0 @@
-{
-  "extends": "eslint:recommended",
-  "env": {
-    "node": true,
-    "es6": true,
-    "jest": true
-  },
-  "parserOptions": {
-    "ecmaVersion": 8,
-    "sourceType": "module",
-    "ecmaFeatures": {
-      "impliedStrict": true
-    }
-  }
-}
--- a/.editorconfig
+++ b/.editorconfig
@@ -1,3 +1,6 @@
+# Editor Config - generated by Confit. This file will NOT be re-overwritten by Confit
+# Feel free to customise it further.
+# http://editorconfig.org
 root = true

 [*]
--- a/.eslintignore
+++ b/.eslintignore
@@ -0,0 +1,2 @@
+node_modules/*
+bower_components/*
--- a/.gitattributes
+++ b/.gitattributes
@@ -0,0 +1 @@
+package-lock.json binary
--- a/.github/.gitattributes
+++ b/.github/.gitattributes
@@ -1 +0,0 @@
-yarn.lock binary
--- a/.github/.gitignore
+++ b/.github/.gitignore
@@ -1,2 +0,0 @@
-node_modules/
-.vscode
--- a/.github/CONTRIBUTING.md
+++ b/.github/CONTRIBUTING.md
@@ -1,211 +0,0 @@
-<!--[CN_HEADING]-->
-# Contributing
-
-Welcome! This document explains how you can contribute to making **ftp-srv** even better.
-
-
-<!--[]-->
-
-<!--[CN_GETTING_STARTED]-->
-# Getting Started
-
-## Installation
-
-```
-git clone <this repo>
-npm install -g commitizen
-npm install -g semantic-release-cli
-npm install
-```
-
-
-<!--[]-->
-
-<!--[RM_DIR_STRUCTURE]-->
-## Directory Structure
-
-Code is organised into modules which contain one-or-more components. This a great way to ensure maintainable code by encapsulation of behavior logic. A component is basically a self contained app usually in a single file or a folder with each concern as a file: style, template, specs, e2e, and component class. Here's how it looks:
-```
-ftp-srv/
- ├──config/                       * configuration files live here (e.g. eslint, verify, testUnit)
- │
- ├──src/                          * source code files should be here
- │
- ├──dist/                         * production-build code should live here
- │
- ├──reports/                      * test reports appear here
- │
- ├──test/                         * unit test specifications live here
- │
- ├──confit.yml                    * the project config file generated by 'yo confit'
- ├──CONTRIBUTING.md               * how to contribute to the project
- ├──README.md                     * this file
- └──package.json                  * NPM package description file
-```
-
-
-<!--[]-->
-
-<!--[CN_GITFLOW_PROCESS]-->
-# GitFlow Development Process
-
-This project uses the [GitHub Flow](https://guides.github.com/introduction/flow/index.html) workflow.
-
-## Create a branch
-When you're working on a project, you're going to have a bunch of different features or ideas in progress at any given time – some of which are ready to go, and others which are not. Branching exists to help you manage this workflow.
-
-When you create a branch in your project, you're creating an environment where you can try out new ideas. Changes you make on a branch don't affect the `master` branch, so you're free to experiment and commit changes, safe in the knowledge that your branch won't be merged until it's ready to be reviewed by someone you're collaborating with.
-
-###ProTip
-
-Branching is a core concept in Git, and the entire GitHub Flow is based upon it. There's only one rule: anything in the `master` branch is always deployable.
-
-Because of this, it's extremely important that your new branch is created off of `master` when working on a feature or a fix. Your branch name should be descriptive (e.g., `refactor-authentication`, `user-content-cache-key`, `make-retina-avatars`), so that others can see what is being worked on.
-
-## Add commits
-Once your branch has been created, it's time to start making changes. Whenever you add, edit, or delete a file, you're making a commit, and adding them to your branch. This process of adding commits keeps track of your progress as you work on a feature branch.
-
-Commits also create a transparent history of your work that others can follow to understand what you've done and why. Each commit has an associated commit message, which is a description explaining why a particular change was made. Furthermore, each commit is considered a separate unit of change. This lets you roll back changes if a bug is found, or if you decide to head in a different direction.
-
-###ProTip
-
-Commit messages are important, especially since Git tracks your changes and then displays them as commits once they're pushed to the server. By writing clear commit messages, you can make it easier for other people to follow along and provide feedback.
-
-## Open a pull request
-
-Pull Requests initiate discussion about your commits. Because they're tightly integrated with the underlying Git repository, anyone can see exactly what changes would be merged if they accept your request.
-
-You can open a Pull Request at any point during the development process: when you have little or no code but want to share some screenshots or general ideas, when you're stuck and need help or advice, or when you're ready for someone to review your work. By using GitHub's @mention system in your Pull Request message, you can ask for feedback from specific people or teams, whether they're down the hall or ten time zones away.
-
-###ProTip
-
-Pull Requests are useful for contributing to open source projects and for managing changes to shared repositories. If you're using a Fork & Pull Model, Pull Requests provide a way to notify project maintainers about the changes you'd like them to consider. If you're using a Shared Repository Model, Pull Requests help start code review and conversation about proposed changes before they're merged into the `master` branch.
-
-## Discuss and review your code
-Once a Pull Request has been opened, the person or team reviewing your changes may have questions or comments. Perhaps the coding style doesn't match project guidelines, the change is missing unit tests, or maybe everything looks great and props are in order. Pull Requests are designed to encourage and capture this type of conversation.
-
-You can also continue to push to your branch in light of discussion and feedback about your commits. If someone comments that you forgot to do something or if there is a bug in the code, you can fix it in your branch and push up the change. GitHub will show your new commits and any additional feedback you may receive in the unified Pull Request view.
-
-###ProTip
-
-Pull Request comments are written in Markdown, so you can embed images and emoji, use pre-formatted text blocks, and other lightweight formatting.
-
-## Merge to `master`
-
-Once your PR has passed any the integration tests and received approval to merge, it is time to merge your code into the `master` branch.
-
-Once merged, Pull Requests preserve a record of the historical changes to your code. Because they're searchable, they let anyone go back in time to understand why and how a decision was made.
-
-###ProTip
-
-By incorporating certain keywords into the text of your Pull Request, you can associate issues with code. When your Pull Request is merged, the related issues are also closed. For example, entering the phrase Closes #32 would close issue number 32 in the repository. For more information, check out our help article.
-
-
-<!--[]-->
-
-<!--[CN_BUILD_TASKS]-->
-## Build Tasks
-
-Command | Description
-:------ | :----------
-<pre>npm run build</pre> | Generate production build into [dist/](dist/) folder
-<pre>npm run dev</pre> | Run project in development mode (verify code, and re-verify when code is changed)
-<pre>npm start</pre> | Alias for `npm run dev` task
-
-
-
-<!--[]-->
-
-<!--[CN_TEST_TASKS]-->
-## Test Tasks
-
-Command | Description
-:------ | :----------
-<pre>npm test</pre> | Alias for `npm run test:unit` task
-<pre>npm run test:coverage</pre> | Run instrumented unit tests then verify coverage meets defined thresholds<ul><li>Returns non-zero exit code when coverage does not meet thresholds (as defined in istanbul.js)</li></ul>
-<pre>npm run test:unit</pre> | Run unit tests whenever JS source or tests change<ul><li>Uses Mocha</li><li>Code coverage</li><li>Runs continuously (best to run in a separate window)</li></ul>
-<pre>npm run test:unit:once</pre> | Run unit tests once<ul><li>Uses Mocha</li><li>Code coverage</li></ul>
-
-
-
-<!--[]-->
-
-<!--[CN_VERIFY_TASKS]-->
-## Verification (Linting) Tasks
-
-Command | Description
-:------ | :----------
-<pre>npm run verify</pre> | Verify code style and syntax<ul><li>Verifies source *and test code* aginst customisable rules (unlike Webpack loaders)</li></ul>
-<pre>npm run verify:js</pre> | Verify Javascript code style and syntax
-<pre>npm run verify:js:fix</pre> | Verify Javascript code style and syntax and fix any errors that can be fixed automatically
-<pre>npm run verify:js:watch</pre> | Verify Javascript code style and syntax and watch files for changes
-<pre>npm run verify:watch</pre> | Runs verify task whenever JS or CSS code is changed
-
-
-
-<!--[]-->
-
-<!--[CN_COMMIT_TASKS]-->
-## Commit Tasks
-
-Command | Description
-:------ | :----------
-<pre>git status</pre> | Lists the current branch and the status of changed files
-<pre>git log</pre> | Displays the commit log (press Q to quit viewing)
-<pre>git add .</pre> | Stages all modified & untracked files, ready to be committed
-<pre>git cz</pre> | Commit changes to local repository using Commitizen.<ul><li>Asks questions about the change to generate a valid conventional commit message</li><li>Can be customised by modifying [config/release/commitMessageConfig.js](config/release/commitMessageConfig.js)</li></ul>
-<pre>git push</pre> | Push local repository changes to remote repository
-
-
-<!--[]-->
-
-<!--[CN_DOCUMENTATION_TASKS]-->
-
-
-
-<!--[]-->
-
-<!--[CN_RELEASE_TASKS]-->
-## Release Tasks
-
-Command | Description
-:------ | :----------
-<pre>npm run commitmsg</pre> | Git commit message hook that validates the commit message conforms to your commit message conventions.
-<pre>npm run pre-release</pre> | Verify code, run unit tests, check test coverage, build software. This task is designed to be run before
-the `semantic-release` task.
-<ul><li>Run `semantic-release-cli setup` once you have a remote repository. See https://github.com/semantic-release/cli for details.</li><li>Semantic-release integrates with Travis CI (or similar tools) to generate release notes
-for each release (which appears in the "Releases" section in GitHub) and
-publishes the package to NPM (when all the tests are successful) with a semantic version number.
-</li></ul>
-<pre>npm run prepush</pre> | Git pre-push hook that verifies code and checks unit test coverage meet minimum thresholds.
-<pre>npm run upload-coverage</pre> | Uploads code-coverage metrics to Coveralls.io<ul><li>Setup - https://coveralls.zendesk.com/hc/en-us/articles/201347419-Coveralls-currently-supports</li><li>Define an environment variable called COVERALLS_REPO_TOKEN in your build environment with the repo token from https://coveralls.io/github/<repo-name>/settings</li><li>In your CI configuration (e.g. `travis.yml`), call `npm run upload-coverage` if the build is successful.</li></ul>
-
-
-
-<!--[]-->
-
-
-<!--[CN_CHANGING_BUILD_TOOL_CONFIG]-->
-## Changing build-tool configuration
-
-There are 3 ways you can change the build-tool configuration for this project:
-
-1. BEST: Modify the Confit configuration file ([confit.yml](confit.yml)) by hand, then re-run `yo confit` and tell it to use the existing configuration.
-1. OK: Re-run `yo confit` and provide new answers to the questions. **Confit will attempt to overwrite your existing configuration (it will prompt for confirmation), so make sure you have committed your code to a source control (e.g. git) first**.
-  There are certain configuration settings which can **only** be specified by hand, in which case the first approach is still best.
-1. RISKY: Modify the generated build-tool config by hand. Be aware that if you re-run `yo confit` it will attempt to overwrite your changes. So commit your changes to source control first.
-
-Additionally, the **currently-generated** configuration can be extended in the following ways:
-
- The task configuration is defined in [package.json](package.json). It is possible to change the task definitions to add your own sub-tasks.
-You can also use the `pre...` and `post...` script-name prefixes to run commands before (pre) and after (post) the generated commands.
-
- The `entryPoint.entryPoints` string in [confit.yml](confit.yml) is designed to be edited manually. It represents the starting-point(s) of the application (like a `main()` function). A NodeJS application has one entry point. E.g. `src/index.js`
-
-
-
-
-<!--[]-->
-
-
-
--- a/.gitignore
+++ b/.gitignore
@@ -0,0 +1,6 @@
+test_tmp/
+
+node_modules/
+
+dist/
+npm-debug.log
--- a/CONTRIBUTING.md
+++ b/CONTRIBUTING.md
@@ -0,0 +1,25 @@
+<p align="center">
+  <a href="https://github.com/trs/ftp-srv">
+    <img alt="ftp-srv" src="logo.png" width="400px"  />
+  </a>
+</p>
+
+<h1 align="center">
+  Contributing Guide
+</h1>
+
+## Welcome
+
+- Thank you for your eagerness to contribute, pull requests are encouraged!
+
+## Guidelines
+
+- Any new fixes are features should include new or updated [tests](/test).
+- Commits follow the [AngularJS Git Commit Message Conventions](https://docs.google.com/document/d/1QrDFcIiPjSLDn3EL15IJygNPiHORgU1_OOAqWjiDU5Y/edit), please review and commit accordingly
+- Submit your pull requests to the `master` branch, these will normally be merged into a separate branch for any finally changes before being merged into `master`.
+- Submit any bugs or requests to the issues page in Github.
+
+## Setup
+
+- Clone the repository `git clone`
+- Install dependencies `npm install`
--- a/2
+++ b/2
@@ -1,6 +1,6 @@
 MIT License

-Copyright (c) 2018 Tyler Stewart
+Copyright (c) 2019 Tyler Stewart

 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal
--- a/README.md
+++ b/README.md
@@ -14,22 +14,345 @@
    <img alt="npm" src="https://img.shields.io/npm/dm/ftp-srv.svg?style=for-the-badge" />
  </a>

-  <a href="https://circleci.com/gh/trs/ftp-srv">
-    <img alt="circleci" src="https://img.shields.io/circleci/project/github/trs/ftp-srv.svg?style=for-the-badge" />
-  </a>
-
-  <a href="https://coveralls.io/github/trs/ftp-srv?branch=master">
-    <img alt="coveralls" src="https://img.shields.io/coveralls/github/trs/ftp-srv.svg?style=for-the-badge" />
+  <a href="https://circleci.com/gh/trs/workflows/ftp-srv/tree/master">
+    <img alt="circleci" src="https://img.shields.io/circleci/project/github/trs/ftp-srv/master.svg?style=for-the-badge" />
  </a>
 </p>

 ---

-> Looking for v2? Check the [v2](#v2) branch.
+- [Overview](#overview)
+- [Features](#features)
+- [Install](#install)
+- [Usage](#usage)
+  - [API](#api)
+  - [CLI](#cli)
+  - [Events](#events)
+  - [Supported Commands](#supported-commands)
+  - [File System](#file-system)
+- [Contributing](#contributing)
+- [License](#license)

-# Installation
+## Overview
+`ftp-srv` is a modern and extensible FTP server designed to be simple yet configurable.

-```
-$ yarn install
+## Features
+- Extensible [file systems](#file-system) per connection
+- Passive and active transfers
+- [Explicit](https://en.wikipedia.org/wiki/FTPS#Explicit) & [Implicit](https://en.wikipedia.org/wiki/FTPS#Implicit) TLS connections
+- Promise based API
+
+## Install
+`npm install ftp-srv --save`
+
+## Usage
+
+```js
+// Quick start
+
+const FtpSrv = require('ftp-srv');
+const ftpServer = new FtpSrv({ options ... });
+
+ftpServer.on('login', (data, resolve, reject) => { ... });
+...
+
+ftpServer.listen()
+.then(() => { ... });
 ```

+## API
+
+### `new FtpSrv({options})`
+#### url
+[URL string](https://nodejs.org/api/url.html#url_url_strings_and_url_objects) indicating the protocol, hostname, and port to listen on for connections.
+Supported protocols:
+- `ftp` Plain FTP
+- `ftps` Implicit FTP over TLS
+
+_Note:_ The hostname must be the external IP address to accept external connections. `0.0.0.0` will listen on any available hosts for server and passive connections.  
+__Default:__ `"ftp://127.0.0.1:21"`
+
+#### `pasv_url`
+The hostname to provide a client when attempting a passive connection (`PASV`). This defaults to the provided `url` hostname.
+
+_Note:_ If set to `0.0.0.0`, this will automatically resolve to the external IP of the box.  
+__Default:__ `"127.0.0.1"`
+
+#### `pasv_min`
+Tne starting port to accept passive connections.  
+__Default:__ `1024`
+
+#### `pasv_max`
+The ending port to accept passive connections.  
+The range is then queried for an available port to use when required.  
+__Default:__ `65535`
+
+#### `greeting`
+A human readable array of lines or string to send when a client connects.  
+__Default:__ `null`
+
+#### `tls`
+Node [TLS secure context object](https://nodejs.org/api/tls.html#tls_tls_createsecurecontext_options) used for implicit (`ftps` protocol) or explicit (`AUTH TLS`) connections.  
+__Default:__ `false`
+
+#### `anonymous`
+If true, will allow clients to authenticate using the username `anonymous`, not requiring a password from the user.  
+Can also set as a string which allows users to authenticate using the username provided.  
+The `login` event is then sent with the provided username and `@anonymous` as the password.  
+__Default:__ `false`
+
+#### `blacklist`
+Array of commands that are not allowed.  
+Response code `502` is sent to clients sending one of these commands.  
+__Example:__ `['RMD', 'RNFR', 'RNTO']` will not allow users to delete directories or rename any files.  
+__Default:__ `[]`
+
+#### `whitelist`
+Array of commands that are only allowed.  
+Response code `502` is sent to clients sending any other command.  
+__Default:__ `[]`
+
+#### `file_format`
+Sets the format to use for file stat queries such as `LIST`.  
+__Default:__ `"ls"`  
+__Allowable values:__
+  - `ls` [bin/ls format](https://cr.yp.to/ftp/list/binls.html)
+  - `ep` [Easily Parsed LIST format](https://cr.yp.to/ftp/list/eplf.html)
+  - `function () {}` A custom function returning a format or promise for one.
+    - Only one argument is passed in: a node [file stat](https://nodejs.org/api/fs.html#fs_class_fs_stats) object with additional file `name` parameter
+
+#### `log`
+A [bunyan logger](https://github.com/trentm/node-bunyan) instance. Created by default.
+
+#### `timeout`
+Sets the timeout (in ms) after that an idle connection is closed by the server  
+__Default:__ `0`
+
+## CLI
+
+`ftp-srv` also comes with a builtin CLI.
+
+```bash
+$ ftp-srv [url] [options]
+```
+
+```bash
+$ ftp-srv ftp://0.0.0.0:9876 --root ~/Documents
+```
+
+#### `url`
+
+Set the listening URL.
+
+Defaults to `ftp://127.0.0.1:21`
+
+#### `--root` / `-r`
+
+Set the default root directory for users.
+
+Defaults to the current directory.
+
+#### `--credentials` / `-c`
+
+Set the path to a json credentials file.
+
+Format:
+
+```js
+[
+  {
+    "username": "...",
+    "password": "...",
+    "root": "..." // Root directory
+  },
+  ...
+]
+```
+
+#### `--username`
+
+Set the username for the only user. Do not provide an argument to allow anonymous login.
+
+#### `--password`
+
+Set the password for the given `username`.
+
+## Events
+
+The `FtpSrv` class extends the [node net.Server](https://nodejs.org/api/net.html#net_class_net_server). Some custom events can be resolved or rejected, such as `login`.
+
+### `login`
+```js
+ftpServer.on('login', ({connection, username, password}, resolve, reject) => { ... });
+```
+
+Occurs when a client is attempting to login. Here you can resolve the login request by username and password.
+
+`connection` [client class object](src/connection.js)  
+`username` string of username from `USER` command  
+`password` string of password from `PASS` command  
+`resolve` takes an object of arguments:  
+- `fs`
+  - Set a custom file system class for this connection to use.
+  - See [File System](#file-system) for implementation details.
+- `root`
+  - If `fs` is not provided, this will set the root directory for the connection.
+  - The user cannot traverse lower than this directory.
+- `cwd`
+  - If `fs` is not provided, will set the starting directory for the connection
+  - This is relative to the `root` directory.
+- `blacklist`
+  - Commands that are forbidden for only this connection
+- `whitelist`
+  - If set, this connection will only be able to use the provided commands
+
+`reject` takes an error object
+
+### `client-error`
+```js
+ftpServer.on('client-error', ({connection, context, error}) => { ... });
+```
+
+Occurs when an error arises in the client connection.
+
+`connection` [client class object](src/connection.js)  
+`context` string of where the error occurred  
+`error` error object
+
+### `RETR`
+```js
+connection.on('RETR', (error, filePath) => { ... });
+```
+
+Occurs when a file is downloaded.
+
+`error` if successful, will be `null`  
+`filePath` location to which file was downloaded
+
+### `STOR`
+```js
+connection.on('STOR', (error, fileName) => { ... });
+```
+
+Occurs when a file is uploaded.
+
+`error` if successful, will be `null`  
+`fileName` name of the file that was uploaded
+
+### `RNTO`
+```js
+connection.on('RNTO', (error, fileName) => { ... });
+```
+
+Occurs when a file is renamed.
+
+`error` if successful, will be `null`  
+`fileName` name of the file that was renamed
+
+## Supported Commands
+
+See the [command registry](src/commands/registration) for a list of all implemented FTP commands.
+
+## File System
+The default [file system](src/fs.js) can be overwritten to use your own implementation.  
+This can allow for virtual file systems, and more.  
+Each connection can set it's own file system based on the user.  
+
+The default file system is exported and can be extended as needed:  
+```js
+const {FtpSrv, FileSystem} = require('ftp-srv');
+
+class MyFileSystem extends FileSystem {
+  constructor() {
+    super(...arguments);
+  }
+
+  get(fileName) {
+    ...
+  }
+}
+```
+
+Custom file systems can implement the following variables depending on the developers needs:
+
+### Methods
+#### [`currentDirectory()`](src/fs.js#L40)
+Returns a string of the current working directory  
+__Used in:__ `PWD`
+
+#### [`get(fileName)`](src/fs.js#L44)
+Returns a file stat object of file or directory  
+__Used in:__ `LIST`, `NLST`, `STAT`, `SIZE`, `RNFR`, `MDTM`
+
+#### [`list(path)`](src/fs.js#L50)
+Returns array of file and directory stat objects  
+__Used in:__ `LIST`, `NLST`, `STAT`
+
+#### [`chdir(path)`](src/fs.js#L67)
+Returns new directory relative to current directory  
+__Used in:__ `CWD`, `CDUP`
+
+#### [`mkdir(path)`](src/fs.js#L114)
+Returns a path to a newly created directory  
+__Used in:__ `MKD`
+
+#### [`write(fileName, {append, start})`](src/fs.js#L79)
+Returns a writable stream  
+Options:  
+ `append` if true, append to existing file  
+ `start` if set, specifies the byte offset to write to  
+__Used in:__ `STOR`, `APPE`
+
+#### [`read(fileName, {start})`](src/fs.js#L90)
+Returns a readable stream  
+Options:  
+ `start` if set, specifies the byte offset to read from  
+__Used in:__ `RETR`
+
+#### [`delete(path)`](src/fs.js#L105)
+Delete a file or directory  
+__Used in:__ `DELE`
+
+#### [`rename(from, to)`](src/fs.js#L120)
+Renames a file or directory  
+__Used in:__ `RNFR`, `RNTO`
+
+#### [`chmod(path)`](src/fs.js#L126)
+Modifies a file or directory's permissions  
+__Used in:__ `SITE CHMOD`
+
+#### [`getUniqueName()`](src/fs.js#L131)
+Returns a unique file name to write to  
+__Used in:__ `STOU`
+
+## Contributing
+
+See [CONTRIBUTING.md](CONTRIBUTING.md).
+
+## Contributors
+
+- [OzairP](https://github.com/OzairP)
+- [TimLuq](https://github.com/TimLuq)
+- [crabl](https://github.com/crabl)
+- [hirviid](https://github.com/hirviid)
+- [DiegoRBaquero](https://github.com/DiegoRBaquero)
+- [edin-m](https://github.com/edin-m)
+- [voxsoftware](https://github.com/voxsoftware)
+- [jorinvo](https://github.com/jorinvo)
+- [Johnnyrook777](https://github.com/Johnnyrook777)
+- [qchar](https://github.com/qchar)
+- [mikejestes](https://github.com/mikejestes)
+- [pkeuter](https://github.com/pkeuter)
+- [qiansc](https://github.com/qiansc)
+- [broofa](https://github.com/broofa)
+- [lafin](https://github.com/lafin)
+- [alancnet](https://github.com/alancnet)
+- [zgwit](https://github.com/zgwit)
+
+## License
+
+This software is licensed under the MIT Licence. See [LICENSE](LICENSE).
+
+## References
+
+- [https://cr.yp.to/ftp.html](https://cr.yp.to/ftp.html)
--- a/bin/index.js
+++ b/bin/index.js
@@ -0,0 +1,141 @@
+#!/usr/bin/env node
+
+const yargs = require('yargs');
+const path = require('path');
+
+const FtpSrv = require('../src');
+const errors = require('../src/errors');
+
+const args = setupYargs();
+const state = setupState(args);
+startFtpServer(state);
+
+function setupYargs() {
+  return yargs
+    .option('credentials', {
+      alias: 'c',
+      describe: 'Load user & pass from json file',
+      normalize: true
+    })
+    .option('username', {
+      describe: 'Blank for anonymous',
+      type: 'string',
+      default: ''
+    })
+    .option('password', {
+      describe: 'Password for given username',
+      type: 'string'
+    })
+    .option('root', {
+      alias: 'r',
+      describe: 'Default root directory for users',
+      type: 'string',
+      normalize: true
+    })
+    .option('read-only', {
+      describe: 'Disable write actions such as upload, delete, etc',
+      boolean: true,
+      default: false
+    })
+    .option('pasv_url', {
+      describe: 'URL to provide for passive connections',
+      type: 'string'
+    })
+    .option('pasv_min', {
+      describe: 'Starting point to use when creating passive connections',
+      type: 'number',
+      default: 1024
+    })
+    .option('pasv_max', {
+      describe: 'Ending port to use when creating passive connections',
+      type: 'number',
+      default: 65535
+    })
+    .parse();
+}
+
+function setupState(_args) {
+  const _state = {};
+
+  function setupOptions() {
+    if (_args._ && _args._.length > 0) {
+      _state.url = _args._[0];
+    }
+    _state.pasv_url = _args.pasv_url;
+    _state.pasv_min = _args.pasv_min;
+    _state.pasv_max = _args.pasv_max;
+    _state.anonymous = _args.username === '';
+  }
+
+  function setupRoot() {
+    const dirPath = _args.root;
+    if (dirPath) {
+      _state.root = dirPath;
+    } else {
+      _state.root = process.cwd();
+    }
+  }
+
+  function setupCredentials() {
+    _state.credentials = {};
+
+    const setCredentials = (username, password, root = null) => {
+      _state.credentials[username] = {
+        password,
+        root
+      };
+    };
+
+    if (_args.credentials) {
+      const credentialsFile = path.resolve(_args.credentials);
+      const credentials = require(credentialsFile);
+
+      for (const cred of credentials) {
+        setCredentials(cred.username, cred.password, cred.root);
+      }
+    } else if (_args.username) {
+      setCredentials(_args.username, _args.password);
+    }
+  }
+
+  function setupCommandBlacklist() {
+    if (_args.readOnly) {
+      _state.blacklist = ['ALLO', 'APPE', 'DELE', 'MKD', 'RMD', 'RNRF', 'RNTO', 'STOR', 'STRU'];
+    }
+  }
+
+  setupOptions();
+  setupRoot();
+  setupCredentials();
+  setupCommandBlacklist();
+
+  return _state;
+}
+
+function startFtpServer(_state) {
+  // Remove null/undefined options so they get set to defaults, below
+  for (const key in _state) {
+    if (_state[key] === undefined) delete _state[key];
+  }
+
+  function checkLogin(data, resolve, reject) {
+    const user = _state.credentials[data.username];
+    if (_state.anonymous || user && user.password === data.password) {
+      return resolve({root: user && user.root || _state.root});
+    }
+
+    return reject(new errors.GeneralError('Invalid username or password', 401));
+  }
+
+  const ftpServer = new FtpSrv({
+    url: _state.url,
+    pasv_url: _state.pasv_url,
+    pasv_min: _state.pasv_min,
+    pasv_max: _state.pasv_max,
+    anonymous: _state.anonymous,
+    blacklist: _state.blacklist
+  });
+
+  ftpServer.on('login', checkLogin);
+  ftpServer.listen();
+}
--- a/changelog/v2_to_v3_migation.md
+++ b/changelog/v2_to_v3_migation.md
@@ -0,0 +1,44 @@
+# Migration Guide - v2 to v3
+
+The `FtpServer` constructor has been changed to only take one object option. Combining the two just made sense.
+
+### From:
+
+```js
+const server = new FtpServer('ftp://0.0.0.0:21');
+```
+
+### To:
+
+```js
+const server = new FtpServer({
+  url: 'ftp://0.0.0.0:21'
+});
+```
+
+----
+
+The `pasv_range` option has been changed to separate integer variables: `pasv_min`, `pasv_max`.
+
+### From:
+
+```js
+const server = new FtpServer(..., {
+  pasv_range: '1000-2000'
+});
+```
+
+### To:
+
+```js
+const server = new FtpServer({
+  pasv_min: 1000,
+  pasv_max: 2000
+})
+```
+
+----
+
+The default passive port range has been changed to `1024` - `65535`
+
+----
--- a/examples/basic.js
+++ b/examples/basic.js
@@ -1,11 +0,0 @@
-/* eslint no-console: 0 */
-const FtpSrv = require('../src');
-
-const server = new FtpSrv();
-server.listen(8880)
-.then(() => {
-  console.log('listening');
-})
-.catch(err => {
-  console.log('err', err)
-})
--- a/ftp-srv.d.ts
+++ b/ftp-srv.d.ts
@@ -0,0 +1,127 @@
+import * as tls from 'tls'
+import { Stats } from 'fs'
+import { EventEmitter } from 'events';
+
+export class FileSystem {
+
+	readonly connection: FtpConnection;
+	readonly root: string;
+	readonly cwd: string;
+
+    constructor(connection: FtpConnection, {root, cwd}?: {
+        root: any;
+        cwd: any;
+    });
+
+    currentDirectory(): string;
+
+    get(fileName: string): Promise<any>;
+
+    list(path?: string): Promise<any>;
+
+    chdir(path?: string): Promise<string>;
+
+    write(fileName: string, {append, start}?: {
+        append?: boolean;
+        start?: any;
+    }): any;
+
+    read(fileName: string, {start}?: {
+        start?: any;
+    }): Promise<any>;
+
+    delete(path: string): Promise<any>;
+
+    mkdir(path: string): Promise<any>;
+
+    rename(from: string, to: string): Promise<any>;
+
+    chmod(path: string, mode: string): Promise<any>;
+
+    getUniqueName(): string;
+}
+
+export class FtpConnection extends EventEmitter {
+	server: FtpServer;
+	id: string;
+	log: any;
+	transferType: string;
+	encoding: string;
+	bufferSize: boolean;
+	readonly ip: string;
+	restByteCount: number | undefined;
+	secure: boolean
+
+	close (code: number, message: number): Promise<any>
+	login (username: string, password: string): Promise<any>
+	reply (options: number | Object, ...letters: Array<any>): Promise<any>
+
+}
+
+export interface FtpServerOptions {
+    url?: string,
+    pasv_min?: number,
+    pasv_max?: number,
+    pasv_url?: string,
+    greeting?: string | string[],
+    tls?: tls.SecureContextOptions | false,
+    anonymous?: boolean,
+    blacklist?: Array<string>,
+    whitelist?: Array<string>,
+    file_format?: (stat: Stats) => string | Promise<string> | "ls" | "ep",
+	log?: any,
+	timeout?: number
+}
+
+export class FtpServer extends EventEmitter {
+    constructor(options?: FtpServerOptions);
+
+    readonly isTLS: boolean;
+
+    listen(): any;
+
+    emitPromise(action: any, ...data: any[]): Promise<any>;
+
+    // emit is exported from super class
+
+    setupTLS(_tls: boolean): boolean | {
+      cert: string;
+      key: string;
+      ca: string
+    };
+
+    setupGreeting(greet: string): string[];
+
+    setupFeaturesMessage(): string;
+
+    disconnectClient(id: string): Promise<any>;
+
+    close(): any;
+
+	on(event: "login", listener: (
+		data: {
+			connection: FtpConnection,
+			username: string,
+			password: string
+		},
+		resolve: (config: {
+            fs?: FileSystem,
+            root?: string,
+            cwd?: string,
+            blacklist?: Array<string>,
+            whitelist?: Array<string>
+        }) => void,
+		reject: (err?: Error) => void
+	) => void): this;
+
+	on(event: "client-error", listener: (
+		data: {
+			connection: FtpConnection,
+			context: string,
+			error: Error,
+		}
+	) => void): this;
+}
+
+export {FtpServer as FtpSrv};
+export default FtpServer;
--- a/ftp-srv.js
+++ b/ftp-srv.js
@@ -0,0 +1,8 @@
+const FtpSrv = require('./src');
+const FileSystem = require('./src/fs');
+const errors = require('./src/errors');
+
+module.exports = FtpSrv;
+module.exports.FtpSrv = FtpSrv;
+module.exports.FileSystem = FileSystem;
+module.exports.ftpErrors = errors;
--- a/logo/generate.js
+++ b/logo/generate.js
@@ -1,19 +0,0 @@
-const puppeteer = require('puppeteer');
-
-(async function () {
-  const logoPath = `file://${process.cwd()}/logo/logo.html`;
-
-  const browser = await puppeteer.launch();
-  const page = await browser.newPage();
-  await page.goto(logoPath);
-  await page.setViewport({
-    width: 600,
-    height: 250,
-    deviceScaleFactor: 2
-  });
-  await page.screenshot({
-    path: 'logo.png',
-    omitBackground: true
-  });
-  await browser.close();
-})();
--- a/meta/contributors/contributors.js
+++ b/meta/contributors/contributors.js
@@ -0,0 +1,27 @@
+const {get} = require('https');
+
+get('https://api.github.com/repos/trs/ftp-srv/contributors', {
+  headers: {
+    'User-Agent': 'Chrome'
+  }
+}, (res) => {
+  let response = '';
+  res.on('data', (data) => {
+    response += data;
+  });
+  res.on('end', () => {
+    const contributors = JSON.parse(response)
+      .filter((contributor) => contributor.type === 'User');
+
+    for (const contributor of contributors) {
+      const url = contributor.html_url;
+      const username = contributor.login;
+
+      const markdown = `- [${username}](${url})\n`;
+
+      process.stdout.write(markdown);
+    }
+  });
+}).on('error', (err) => {
+  process.stderr.write(err);
+});
--- a/meta/logo/generate.js
+++ b/meta/logo/generate.js
@@ -0,0 +1,23 @@
+const puppeteer = require('puppeteer');
+const logoPath = `file://${process.cwd()}/logo/logo.html`;
+
+puppeteer.launch()
+.then(browser => {
+  return browser.newPage()
+  .then(page => {
+    return page.goto(logoPath)
+    .then(() => page);
+  })
+  .then(page => {
+    return page.setViewport({
+      width: 600,
+      height: 250,
+      deviceScaleFactor: 2
+    })
+    .then(() => page.screenshot({
+      path: 'logo.png',
+      omitBackground: true
+    }));
+  })
+  .then(() => browser.close());
+});
--- a/meta/logo/logo.html
+++ b/meta/logo/logo.html
--- a/package-lock.json
+++ b/package-lock.json
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
  "name": "ftp-srv",
-  "version": "0.0.0-development",
+  "version": "0.0.0",
  "description": "Modern, extensible FTP Server",
  "keywords": [
    "ftp",
@@ -12,25 +12,80 @@
    "server"
  ],
  "license": "MIT",
+  "files": [
+    "src",
+    "bin",
+    "ftp-srv.d.ts"
+  ],
+  "main": "ftp-srv.js",
+  "bin": "./bin/index.js",
+  "types": "./ftp-srv.d.ts",
  "repository": {
    "type": "git",
    "url": "https://github.com/trs/ftp-srv"
  },
  "scripts": {
-    "test": "jest ./src/**/*.test.js --verbose",
-    "lint": "eslint -c .config/.eslintrc.json \"src/**/*.js\" \"logo/**/*.js\"  \"examples/**/*.js\""
+    "pre-release": "npm run verify",
+    "semantic-release": "semantic-release",
+    "test": "mocha test/**/*.spec.js test/*.spec.js --ui bdd",
+    "verify": "eslint src/**/*.js test/**/*.js bin/**/*.js"
+  },
+  "release": {
+    "verifyConditions": "condition-circle"
+  },
+  "husky": {
+    "hooks": {
+      "pre-commit": "lint-staged",
+      "commit-msg": "commitlint -E HUSKY_GIT_PARAMS"
+    }
+  },
+  "lint-staged": {
+    "*.js": [
+      "eslint --fix",
+      "git add"
+    ]
+  },
+  "commitlint": {
+    "extends": [
+      "@commitlint/config-conventional"
+    ]
+  },
+  "eslintConfig": {
+    "extends": "eslint:recommended",
+    "env": {
+      "node": true,
+      "mocha": true,
+      "es6": true
+    },
+    "parserOptions": {
+      "ecmaVersion": 6,
+      "sourceType": "module"
+    }
  },
  "dependencies": {
-    "bee-queue": "^1.2.2",
-    "signale": "^1.1.0",
-    "z": "^1.0.8"
+    "bluebird": "^3.5.1",
+    "bunyan": "^1.8.12",
+    "ip": "^1.1.5",
+    "lodash": "^4.17.15",
+    "moment": "^2.22.1",
+    "uuid": "^3.2.1",
+    "yargs": "^11.0.0"
  },
  "devDependencies": {
-    "eslint": "^4.18.2",
-    "jest": "^22.4.2",
-    "semantic-release": "^15.0.2"
+    "@commitlint/cli": "^8.1.0",
+    "@commitlint/config-conventional": "^8.1.0",
+    "@icetee/ftp": "^1.0.2",
+    "chai": "^4.2.0",
+    "condition-circle": "^2.0.2",
+    "eslint": "^5.14.1",
+    "husky": "^1.3.1",
+    "lint-staged": "^8.1.4",
+    "mocha": "^5.2.0",
+    "rimraf": "^2.6.1",
+    "semantic-release": "^15.13.24",
+    "sinon": "^2.3.5"
  },
  "engines": {
-    "node": ">=8.x"
+    "node": ">=6.x"
  }
 }
--- a/src-old/Client.js
+++ b/src-old/Client.js
@@ -1,84 +0,0 @@
-const net = require('net');
-
-const Queue = require('./Queue');
-const {getCommandHandler} = require('./commands');
-
-class Client extends net.Socket {
-  constructor(id, socket) {
-    super();
-    socket && Object.assign(this, socket);
-    this.id = id;
-    this.commandQueue = new Queue({
-      [Queue.QUEUE_TYPES.IN]: () => {},
-      [Queue.QUEUE_TYPES.OUT]: () => {}
-    });
-    this.dataQueue = new Queue();
-    this.resetSession();
-
-    super.on('data', data => this._onData(data));
-  }
-
-  resetSession() {
-    this.session = {
-      encoding: 'utf8',
-      transferType: 'binary'
-    };
-  }
-
-  setSession(key, value) {
-    this.session[key] = value;
-  }
-
-  getSession(key) {
-    return this.session[key];
-  }
-
-  send(message) {
-    // this.sendQueue.enqueue(message);
-  }
-
-  get closed() {
-    return this.closing || super.destroyed;
-  }
-
-  close() {
-    if (super.destroyed) return;
-    this.closing = true;
-    super.destroy();
-  }
-
-  _onData(data) {
-    if (this.closed) return;
-
-    const commands = data
-      .toString(this.getSession('encoding'))
-      .split('\r\n')
-      .map(command => command.trim())
-      .filter(command => !!command);
-
-    this.commandQueue.enqueue(Queue.QUEUE_TYPES.IN, ...commands);
-  }
-
-  // async _processCommand(command) {
-
-  //   this.emit('command', {command});
-
-  //   const commandHandler = getCommandHandler(this, command);
-  //   if (typeof commandHandler === 'string') {
-  //     return this.send(commandHandler);
-  //   }
-
-  //   await commandHandler(this, command);
-  // }
-
-  // async _processSend(message) {
-  //   await new Promise((resolve, reject) => {
-  //     super.write(`${message}\r\n`, err => {
-  //       if (err) reject(err);
-  //       else resolve();
-  //     });
-  //   });
-  // }
-}
-
-module.exports = Client;
--- a/src-old/ConnectionManager.js
+++ b/src-old/ConnectionManager.js
@@ -1,33 +0,0 @@
-class ConnectionManager {
-  constructor() {
-    this._connections = {};
-  }
-
-  add(id, client) {
-    this._connections[id] = client;
-    return true;
-  }
-
-  remove(id) {
-    if (!this._connections.hasOwnProperty(id)) return false;
-    delete this._connections[id];
-    return true;
-  }
-
-  invoke(method, ...args) {
-    const invokeResults = Object.values(this._connections).map(connection => {
-      if (typeof connection[method] !== 'function') return undefined;
-      return connection[method](...args);
-    });
-    return Promise.all(invokeResults);
-  }
-
-  iterate() {
-    console.log('iterate', iterate)
-    const connections = Object.entires(this._connections);
-    console.log('connections', connections)
-    return connections
-  }
-}
-
-module.exports = ConnectionManager;
--- a/src-old/Queue.js
+++ b/src-old/Queue.js
@@ -1,40 +0,0 @@
-
-const QUEUE_TYPES = {
-  IN: Symbol('in'),
-  OUT: Symbol('out')
-}
-
-class Queue {
-  constructor(handlers = {}) {
-    this.items = {};
-    this.handlers = {};
-    for (const type of Object.values(QUEUE_TYPES)) {
-      this.items[type] = [];
-      this.handlers[type] = handlers[type];
-    }
-  }
-
-  enqueue(type, ...items) {
-    if (!this.items[type]) return;
-
-    items = items.map(item => {
-      if (!Array.isArray(item)) return [item];
-      return item;
-    });
-
-    this.items[type].push(...items);
-  }
-
-  tryDequeue(type) {
-    if (!this.items[type]) return;
-    if (!this.items[type].length) return;
-    if (!this.handlers[type]) return;
-
-    const item = this.items[type].shift();
-    const method = this.handlers[type];
-    return method(...item);
-  }
-}
-
-Queue.QUEUE_TYPES = QUEUE_TYPES;
-module.exports = Queue;
--- a/src-old/Queue.test.js
+++ b/src-old/Queue.test.js
--- a/src-old/Server.js
+++ b/src-old/Server.js
@@ -1,75 +0,0 @@
-const net = require('net');
-const path = require('path');
-const {fork} = require('child_process');
-const Queue = require('bee-queue');
-
-const Client = require('./Client');
-const ConnectionManager = require('./ConnectionManager');
-const {idGenerator} = require('./utils/idGenerator');
-const message = require('./const/message');
-
-class Server extends net.Server {
-  constructor() {
-    super({pauseOnConnect: true});
-
-    this.connectionManager = new ConnectionManager();
-    this.clientIDGenerator = idGenerator(1);
-    this.receiveQueue = new Queue('receive');
-    this.sendQueue = new Queue('send');
-
-    this.on('connection', socket => this._onConnection(socket));
-  }
-
-  async send(client, data) {
-    const job = await this.sendQueue.createJob({
-      id: client.id,
-      data
-    })
-    .timeout(30000)
-    .save();
-  }
-
-  async close() {
-    await this.connectionManager.invoke('close');
-    await new Promise(resolve => super.close(() => resolve()));
-    return this;
-  }
-
-  async listen(port) {
-    // const processor = path.resolve(__dirname, './commands/processor.js');
-    // this.commandProcess = fork(processor, {
-    //   stdio: 'pipe'
-    // });
-    // this.commandProcess.on('message', (message) => {
-    //   console.log('got', message)
-    // });
-    // this.commandProcess.on('error', (err) => {
-    //   console.log('error', err)
-    // });
-    // this.commandProcess.once('exit', (code) => {
-    //   console.log('exit', code)
-    // });
-    // this.commandProcess.once('close', (code) => {
-    //   console.log('close', code)
-    // });
-    this.commandProcess.send('server', this);
-
-    await new Promise(resolve => super.listen(port, () => resolve()));
-    return this;
-  }
-
-  _onConnection(socket) {
-    const id = this.clientIDGenerator.next().value;
-    const client = new Client(id, socket);
-    client.once('close', () => this.connectionManager.remove(client.id));
-
-    this.connectionManager.add(id, client);
-    this.emit('client', client);
-
-    // client.send(message.GREETING)
-    // .then(() => client.resume())
-    // .catch(() => client.close());
-  }
-}
-
-module.exports = Server;
--- a/src-old/Server.test.js
+++ b/src-old/Server.test.js
@@ -1,41 +0,0 @@
-const net = require('net');
-
-const Server = require('./Server');
-const {getUsablePort} = require('./utils/getUsablePort');
-
-let PORT;
-
-beforeEach(async () => {
-  PORT = await getUsablePort(8000);
-});
-
-test('expects server to start listening', done => {
-  const server = new Server();
-  server.once('listening', () => server.close());
-  server.once('close', () => done());
-  server.listen(PORT);
-});
-
-test('expects server to accept a client', done => {
-  const server = new Server();
-  server.once('client', client => {
-    expect(client.id).toBeGreaterThan(0);
-    server.close();
-  });
-  server.once('close', () => done());
-  server.listen(PORT);
-
-  net.createConnection(PORT);
-});
-
-test('expects server to send greeting on client connection', done => {
-  const server = new Server();
-  server.once('client', client => {
-    expect(client.id).toBeGreaterThan(0);
-  });
-  server.once('close', () => done());
-  server.listen(PORT);
-
-  const connection = net.createConnection(PORT);
-  connection.once('data', () => server.close());
-});
--- a/src-old/commands/index.js
+++ b/src-old/commands/index.js
@@ -1,39 +0,0 @@
-const registry = require('./registry');
-const message = require('../const/message');
-
-function parseCommand(rawCommand) {
-  const strippedRawCommand = rawCommand.replace(/"/g, '');
-  const [directive, ...args] = strippedRawCommand.split(' ');
-  const params = args.reduce(({arg, flags}, param) => {
-    if (/^-{1,2}[a-zA-Z0-9_]+/.test(param)) flags.push(param);
-    else arg.push(param);
-    return {arg, flags};
-  }, {arg: [], flags: []});
-
-  const command = {
-    directive: String(directive).trim().toLocaleUpperCase(),
-    arg: params.arg.length ? params.arg.join(' ') : null,
-    flags: params.flags,
-    // raw: rawCommand
-  };
-  return command;
-}
-
-async function getCommandHandler(client, command) {
-  command = parseCommand(command);
-
-  if (!registry.hasOwnProperty(command.directive)) return message.UNSUPPORTED_COMMAND;
-
-  const commandRegister = registry[command.directive];
-  const commandFlags = commandRegister.flags ? commandRegister.flags : {};
-  if (!commandFlags.no_auth && !client.authenticated) {
-    return message.COMMAND_REQUIRES_AUTHENTICATION;
-  }
-
-  return commandRegister.handle;
-}
-
-module.exports = {
-  getCommandHandler,
-  parseCommand
-};
--- a/src-old/commands/processor.js
+++ b/src-old/commands/processor.js
@@ -1,23 +0,0 @@
-process.once('message', (initMsg, server) => {
-  if (initMsg !== 'server') {
-    return process.exit(-1);
-  }
-
-  process.on('message', (msg, ...args) => {
-
-  });
-
-  processQueues(server);
-});
-
-async function processQueues(server) {
-  process.send('processQueues');
-  const iterable = server.connectionManager.iterate();
-  process.send('interable');
-  for (const [id, client] of iterable) {
-    process.send('process', id);
-  }
-
-  process.send('/processQueues');
-  return processQueues(server);
-}
--- a/src-old/commands/registry/index.js
+++ b/src-old/commands/registry/index.js
@@ -1,4 +0,0 @@
-module.exports = {
-  USER: require('./user'),
-  PASS: require('./pass')
-};
--- a/src-old/commands/registry/pass.js
+++ b/src-old/commands/registry/pass.js
@@ -1,20 +0,0 @@
-const message = require('../../const/message');
-
-module.exports = {
-  directive: 'PASS',
-  handler: async function (client, command) {
-    if (!client.getSession('username')) return client.send(message.BAD_COMMAND_SEQUENCE);
-    if (client.authenticated) return client.send(message.SUPERFLUOUS_COMMAND);
-    if (!command.arg) return client.send(message.SYNTAX_ERROR_ARGS);
-    // TODO: 332 : require account name (ACCT)
-
-    // TODO: do login
-
-    await client.send(message.AUTHENTICATED);
-  },
-  args: ['<password>'],
-  description: 'Authenticate client session',
-  flags: {
-    no_auth: true
-  }
-};
--- a/src-old/commands/registry/user.js
+++ b/src-old/commands/registry/user.js
@@ -1,21 +0,0 @@
-const message = require('../../const/message');
-
-module.exports = {
-  directive: 'USER',
-  handler: async function (client, command) {
-    if (client.getSession('username')) return client.send(message.USERNAME_SET_ALREADY);
-    if (client.authenticated) return client.send(message.USER_AUTHENTICATED);
-    if (!client.arg) return client.send(message.SYNTAX_ERROR_ARGS);
-
-    this.setSession('username', command.arg);
-
-    // TODO: allow anonymous logins
-
-    await this.reply(message.AWAITING_PASSWORD);
-  },
-  args: ['<username>'],
-  description: 'Set client session username',
-  flags: {
-    no_auth: true
-  }
-};
--- a/src-old/const/message.js
+++ b/src-old/const/message.js
@@ -1,12 +0,0 @@
-module.exports = {
-  SUPERFLUOUS_COMMAND: '202 Superfluous command',
-  GREETING: '220 Greetings',
-  AUTHENTICATED: '230 User authenticated successfully',
-  AWAITING_PASSWORD: '331 Username okay, awaiting password',
-  SYNTAX_ERROR_ARGS: '501 Syntax error in arguments',
-  UNSUPPORTED_COMMAND: '502 Command not supported',
-  BAD_COMMAND_SEQUENCE: '503 Bad sequence of commands',
-  USERNAME_SET_ALREADY: '530 Username already set',
-  COMMAND_REQUIRES_AUTHENTICATION: '530 Username already set',
-  AUTHENTICATED_FAILED: '530 Authentication failed',
-};
--- a/src-old/index.js
+++ b/src-old/index.js
@@ -1,4 +0,0 @@
-const Server = require('./Server');
-
-module.exports = Server;
-module.exports.FtpSrv = Server;
--- a/src-old/utils/getUsablePort.js
+++ b/src-old/utils/getUsablePort.js
@@ -1,39 +0,0 @@
-const net = require('net');
-
-const PORT_MAX = 65535;
-
-function getUsablePort(portStart = 21, portStop = PORT_MAX) {
-  return new Promise((resolve, reject) => {
-    const server = net.createServer();
-    server.maxConnections = 0;
-
-    const cleanUpServer = () => {
-      server.removeAllListeners();
-      server.unref();
-    };
-
-    let currentPort = portStart;
-    server.on('error', err => {
-      if (currentPort < PORT_MAX && currentPort < portStop) {
-        server.listen(++currentPort);
-      } else {
-        server.close(() => {
-          cleanUpServer();
-          reject(err);
-        });
-      }
-    });
-    server.on('listening', () => {
-      const {port} = server.address();
-      server.close(() => {
-        cleanUpServer();
-        resolve(port);
-      })
-    });
-    server.listen(currentPort);
-  });
-}
-
-module.exports = {
-  getUsablePort
-};
--- a/src-old/utils/getUsablePort.test.js
+++ b/src-old/utils/getUsablePort.test.js
@@ -1,6 +0,0 @@
-const {getUsablePort} = require('./getUsablePort');
-
-test('expects an available port to be found', async () => {
-  const port = await getUsablePort();
-  expect(port).toBeGreaterThan(0);
-});
--- a/src-old/utils/idGenerator.js
+++ b/src-old/utils/idGenerator.js
@@ -1,6 +0,0 @@
-function* idGenerator(start) {
-  let i = start;
-  while (true) yield i++;
-}
-
-module.exports = {idGenerator};
--- a/src-old/utils/idGenerator.test.js
+++ b/src-old/utils/idGenerator.test.js
@@ -1,8 +0,0 @@
-const {idGenerator} = require('./idGenerator');
-
-test('expects ids to be generated', () => {
-  const id = idGenerator(1);
-  expect(id.next().value).toBe(1);
-  expect(id.next().value).toBe(2);
-  expect(id.next().value).toBe(3);
-});
--- a/src/client/index.js
+++ b/src/client/index.js
@@ -1,16 +0,0 @@
-const net = require('net');
-
-class Client extends net.Socket {
-  constructor() {
-    super();
-  }
-
-  send() {
-
-  }
-
-  close() {
-
-  }
-}
-module.exports = Client;
--- a/src/commands/index.js
+++ b/src/commands/index.js
@@ -0,0 +1,76 @@
+const _ = require('lodash');
+const Promise = require('bluebird');
+
+const REGISTRY = require('./registry');
+
+const CMD_FLAG_REGEX = new RegExp(/^-(\w{1})$/);
+
+class FtpCommands {
+  constructor(connection) {
+    this.connection = connection;
+    this.previousCommand = {};
+    this.blacklist = _.get(this.connection, 'server.options.blacklist', []).map((cmd) => _.upperCase(cmd));
+    this.whitelist = _.get(this.connection, 'server.options.whitelist', []).map((cmd) => _.upperCase(cmd));
+  }
+
+  parse(message) {
+    const strippedMessage = message.replace(/"/g, '');
+    let [directive, ...args] = strippedMessage.split(' ');
+    directive = _.chain(directive).trim().toUpper().value();
+
+    const parseCommandFlags = !['RETR', 'SIZE', 'STOR'].includes(directive);
+    const params = args.reduce(({arg, flags}, param) => {
+      if (parseCommandFlags && CMD_FLAG_REGEX.test(param)) flags.push(param);
+      else arg.push(param);
+      return {arg, flags};
+    }, {arg: [], flags: []});
+
+    const command = {
+      directive,
+      arg: params.arg.length ? params.arg.join(' ') : null,
+      flags: params.flags,
+      raw: message
+    };
+    return command;
+  }
+
+  handle(command) {
+    if (typeof command === 'string') command = this.parse(command);
+
+    // Obfuscate password from logs
+    const logCommand = _.clone(command);
+    if (logCommand.directive === 'PASS') logCommand.arg = '********';
+
+    const log = this.connection.log.child({directive: command.directive});
+    log.trace({command: logCommand}, 'Handle command');
+
+    if (!REGISTRY.hasOwnProperty(command.directive)) {
+      return this.connection.reply(402, 'Command not allowed');
+    }
+
+    if (_.includes(this.blacklist, command.directive)) {
+      return this.connection.reply(502, 'Command blacklisted');
+    }
+
+    if (this.whitelist.length > 0 && !_.includes(this.whitelist, command.directive)) {
+      return this.connection.reply(502, 'Command not whitelisted');
+    }
+
+    const commandRegister = REGISTRY[command.directive];
+    const commandFlags = _.get(commandRegister, 'flags', {});
+    if (!commandFlags.no_auth && !this.connection.authenticated) {
+      return this.connection.reply(530, 'Command requires authentication');
+    }
+
+    if (!commandRegister.handler) {
+      return this.connection.reply(502, 'Handler not set on command');
+    }
+
+    const handler = commandRegister.handler.bind(this.connection);
+    return Promise.resolve(handler({log, command, previous_command: this.previousCommand}))
+    .finally(() => {
+      this.previousCommand = _.clone(command);
+    });
+  }
+}
+module.exports = FtpCommands;
--- a/src/commands/registration/abor.js
+++ b/src/commands/registration/abor.js
@@ -0,0 +1,14 @@
+module.exports = {
+  directive: 'ABOR',
+  handler: function () {
+    return this.connector.waitForConnection()
+    .then((socket) => {
+      return this.reply(426, {socket})
+      .then(() => this.reply(226));
+    })
+    .catch(() => this.reply(225))
+    .finally(() => this.connector.end());
+  },
+  syntax: '{{cmd}}',
+  description: 'Abort an active file transfer'
+};
--- a/src/commands/registration/allo.js
+++ b/src/commands/registration/allo.js
@@ -0,0 +1,11 @@
+module.exports = {
+  directive: 'ALLO',
+  handler: function () {
+    return this.reply(202);
+  },
+  syntax: '{{cmd}}',
+  description: 'Allocate sufficient disk space to receive a file',
+  flags: {
+    obsolete: true
+  }
+};
--- a/src/commands/registration/appe.js
+++ b/src/commands/registration/appe.js
@@ -0,0 +1,10 @@
+const stor = require('./stor').handler;
+
+module.exports = {
+  directive: 'APPE',
+  handler: function (args) {
+    return stor.call(this, args);
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Append to a file'
+};
--- a/src/commands/registration/auth.js
+++ b/src/commands/registration/auth.js
@@ -0,0 +1,42 @@
+const _ = require('lodash');
+const tls = require('tls');
+
+module.exports = {
+  directive: 'AUTH',
+  handler: function ({command} = {}) {
+    const method = _.upperCase(command.arg);
+
+    switch (method) {
+      case 'TLS': return handleTLS.call(this);
+      default: return this.reply(504);
+    }
+  },
+  syntax: '{{cmd}} <type>',
+  description: 'Set authentication mechanism',
+  flags: {
+    no_auth: true,
+    feat: 'AUTH TLS'
+  }
+};
+
+function handleTLS() {
+  if (!this.server.options.tls) return this.reply(502);
+  if (this.secure) return this.reply(202);
+
+  return this.reply(234)
+  .then(() => {
+    const secureContext = tls.createSecureContext(this.server.options.tls);
+    const secureSocket = new tls.TLSSocket(this.commandSocket, {
+      isServer: true,
+      secureContext
+    });
+    ['data', 'timeout', 'end', 'close', 'drain', 'error'].forEach((event) => {
+      function forwardEvent() {
+        this.emit.apply(this, arguments);
+      }
+      secureSocket.on(event, forwardEvent.bind(this.commandSocket, event));
+    });
+    this.commandSocket = secureSocket;
+    this.secure = true;
+  });
+}
--- a/src/commands/registration/cdup.js
+++ b/src/commands/registration/cdup.js
@@ -0,0 +1,11 @@
+const cwd = require('./cwd').handler;
+
+module.exports = {
+  directive: ['CDUP', 'XCUP'],
+  handler: function (args) {
+    args.command.arg = '..';
+    return cwd.call(this, args);
+  },
+  syntax: '{{cmd}}',
+  description: 'Change to Parent Directory'
+};
--- a/src/commands/registration/cwd.js
+++ b/src/commands/registration/cwd.js
@@ -0,0 +1,22 @@
+const Promise = require('bluebird');
+const escapePath = require('../../helpers/escape-path');
+
+module.exports = {
+  directive: ['CWD', 'XCWD'],
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.chdir) return this.reply(402, 'Not supported by file system');
+
+    return Promise.try(() => this.fs.chdir(command.arg))
+    .then((cwd) => {
+      const path = cwd ? `"${escapePath(cwd)}"` : undefined;
+      return this.reply(250, path);
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(550, err.message);
+    });
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Change working directory'
+};
--- a/src/commands/registration/dele.js
+++ b/src/commands/registration/dele.js
@@ -0,0 +1,20 @@
+const Promise = require('bluebird');
+
+module.exports = {
+  directive: 'DELE',
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.delete) return this.reply(402, 'Not supported by file system');
+
+    return Promise.try(() => this.fs.delete(command.arg))
+    .then(() => {
+      return this.reply(250);
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(550, err.message);
+    });
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Delete file'
+};
--- a/src/commands/registration/eprt.js
+++ b/src/commands/registration/eprt.js
@@ -0,0 +1,22 @@
+const _ = require('lodash');
+const ActiveConnector = require('../../connector/active');
+
+const FAMILY = {
+  1: 4,
+  2: 6
+};
+
+module.exports = {
+  directive: 'EPRT',
+  handler: function ({command} = {}) {
+    const [, protocol, ip, port] = _.chain(command).get('arg', '').split('|').value();
+    const family = FAMILY[protocol];
+    if (!family) return this.reply(504, 'Unknown network protocol');
+
+    this.connector = new ActiveConnector(this);
+    return this.connector.setupConnection(ip, port, family)
+    .then(() => this.reply(200));
+  },
+  syntax: '{{cmd}} |<protocol>|<address>|<port>|',
+  description: 'Specifies an address and port to which the server should connect'
+};
--- a/src/commands/registration/epsv.js
+++ b/src/commands/registration/epsv.js
@@ -0,0 +1,16 @@
+const PassiveConnector = require('../../connector/passive');
+
+module.exports = {
+  directive: 'EPSV',
+  handler: function () {
+    this.connector = new PassiveConnector(this);
+    return this.connector.setupServer()
+    .then((server) => {
+      const {port} = server.address();
+
+      return this.reply(229, `EPSV OK (|||${port}|)`);
+    });
+  },
+  syntax: '{{cmd}} [<protocol>]',
+  description: 'Initiate passive mode'
+};
--- a/src/commands/registration/feat.js
+++ b/src/commands/registration/feat.js
@@ -0,0 +1,27 @@
+const _ = require('lodash');
+
+module.exports = {
+  directive: 'FEAT',
+  handler: function () {
+    const registry = require('../registry');
+    const features = Object.keys(registry)
+      .reduce((feats, cmd) => {
+        const feat = _.get(registry[cmd], 'flags.feat', null);
+        if (feat) return _.concat(feats, feat);
+        return feats;
+      }, ['UTF8'])
+      .sort()
+      .map((feat) => ({
+        message: ` ${feat}`,
+        raw: true
+      }));
+    return features.length
+      ? this.reply(211, 'Extensions supported', ...features, 'End')
+      : this.reply(211, 'No features');
+  },
+  syntax: '{{cmd}}',
+  description: 'Get the feature list implemented by the server',
+  flags: {
+    no_auth: true
+  }
+};
--- a/src/commands/registration/help.js
+++ b/src/commands/registration/help.js
@@ -0,0 +1,24 @@
+const _ = require('lodash');
+
+module.exports = {
+  directive: 'HELP',
+  handler: function ({command} = {}) {
+    const registry = require('../registry');
+    const directive = _.upperCase(command.arg);
+    if (directive) {
+      if (!registry.hasOwnProperty(directive)) return this.reply(502, `Unknown command ${directive}.`);
+
+      const {syntax, description} = registry[directive];
+      const reply = _.concat([syntax.replace('{{cmd}}', directive), description]);
+      return this.reply(214, ...reply);
+    } else {
+      const supportedCommands = _.chunk(Object.keys(registry), 5).map((chunk) => chunk.join('\t'));
+      return this.reply(211, 'Supported commands:', ...supportedCommands, 'Use "HELP [command]" for syntax help.');
+    }
+  },
+  syntax: '{{cmd}} [<command>]',
+  description: 'Returns usage documentation on a command if specified, else a general help document is returned',
+  flags: {
+    no_auth: true
+  }
+};
--- a/src/commands/registration/list.js
+++ b/src/commands/registration/list.js
@@ -0,0 +1,57 @@
+const _ = require('lodash');
+const Promise = require('bluebird');
+const getFileStat = require('../../helpers/file-stat');
+
+// http://cr.yp.to/ftp/list.html
+// http://cr.yp.to/ftp/list/eplf.html
+module.exports = {
+  directive: 'LIST',
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.get) return this.reply(402, 'Not supported by file system');
+    if (!this.fs.list) return this.reply(402, 'Not supported by file system');
+
+    const simple = command.directive === 'NLST';
+
+    const path = command.arg || '.';
+    return this.connector.waitForConnection()
+    .tap(() => this.commandSocket.pause())
+    .then(() => Promise.try(() => this.fs.get(path)))
+    .then((stat) => stat.isDirectory() ? Promise.try(() => this.fs.list(path)) : [stat])
+    .then((files) => {
+      const getFileMessage = (file) => {
+        if (simple) return file.name;
+        return getFileStat(file, _.get(this, 'server.options.file_format', 'ls'));
+      };
+
+      return Promise.try(() => files.map((file) => {
+        const message = getFileMessage(file);
+        return {
+          raw: true,
+          message,
+          socket: this.connector.socket
+        };
+      }));
+    })
+    .tap(() => this.reply(150))
+    .then((fileList) => {
+      if (fileList.length) return this.reply({}, ...fileList);
+      return this.reply({socket: this.connector.socket, useEmptyMessage: true});
+    })
+    .tap(() => this.reply(226))
+    .catch(Promise.TimeoutError, (err) => {
+      log.error(err);
+      return this.reply(425, 'No connection established');
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(451, err.message || 'No directory');
+    })
+    .finally(() => {
+      this.connector.end();
+      this.commandSocket.resume();
+    });
+  },
+  syntax: '{{cmd}} [<path>]',
+  description: 'Returns information of a file or directory if specified, else information of the current working directory is returned'
+};
--- a/src/commands/registration/mdtm.js
+++ b/src/commands/registration/mdtm.js
@@ -0,0 +1,25 @@
+const Promise = require('bluebird');
+const moment = require('moment');
+
+module.exports = {
+  directive: 'MDTM',
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.get) return this.reply(402, 'Not supported by file system');
+
+    return Promise.try(() => this.fs.get(command.arg))
+    .then((fileStat) => {
+      const modificationTime = moment.utc(fileStat.mtime).format('YYYYMMDDHHmmss.SSS');
+      return this.reply(213, modificationTime);
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(550, err.message);
+    });
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Return the last-modified time of a specified file',
+  flags: {
+    feat: 'MDTM'
+  }
+};
--- a/src/commands/registration/mkd.js
+++ b/src/commands/registration/mkd.js
@@ -0,0 +1,22 @@
+const Promise = require('bluebird');
+const escapePath = require('../../helpers/escape-path');
+
+module.exports = {
+  directive: ['MKD', 'XMKD'],
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.mkdir) return this.reply(402, 'Not supported by file system');
+
+    return Promise.try(() => this.fs.mkdir(command.arg))
+    .then((dir) => {
+      const path = dir ? `"${escapePath(dir)}"` : undefined;
+      return this.reply(257, path);
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(550, err.message);
+    });
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Make directory'
+};
--- a/src/commands/registration/mode.js
+++ b/src/commands/registration/mode.js
@@ -0,0 +1,11 @@
+module.exports = {
+  directive: 'MODE',
+  handler: function ({command} = {}) {
+    return this.reply(/^S$/i.test(command.arg) ? 200 : 504);
+  },
+  syntax: '{{cmd}} <mode>',
+  description: 'Sets the transfer mode (Stream, Block, or Compressed)',
+  flags: {
+    obsolete: true
+  }
+};
--- a/src/commands/registration/nlst.js
+++ b/src/commands/registration/nlst.js
@@ -0,0 +1,10 @@
+const list = require('./list').handler;
+
+module.exports = {
+  directive: 'NLST',
+  handler: function (args) {
+    return list.call(this, args);
+  },
+  syntax: '{{cmd}} [<path>]',
+  description: 'Returns a list of file names in a specified directory'
+};
--- a/src/commands/registration/noop.js
+++ b/src/commands/registration/noop.js
@@ -0,0 +1,11 @@
+module.exports = {
+  directive: 'NOOP',
+  handler: function () {
+    return this.reply(200);
+  },
+  syntax: '{{cmd}}',
+  description: 'No operation',
+  flags: {
+    no_auth: true
+  }
+};
--- a/src/commands/registration/opts.js
+++ b/src/commands/registration/opts.js
@@ -0,0 +1,38 @@
+const _ = require('lodash');
+
+const OPTIONS = {
+  UTF8: utf8,
+  'UTF-8': utf8
+};
+
+module.exports = {
+  directive: 'OPTS',
+  handler: function ({command} = {}) {
+    if (!_.has(command, 'arg')) return this.reply(501);
+
+    const [_option, ...args] = command.arg.split(' ');
+    const option = _.toUpper(_option);
+
+    if (!OPTIONS.hasOwnProperty(option)) return this.reply(500);
+    return OPTIONS[option].call(this, args);
+  },
+  syntax: '{{cmd}}',
+  description: 'Select options for a feature'
+};
+
+function utf8([setting] = []) {
+  const getEncoding = () => {
+    switch (_.toUpper(setting)) {
+      case 'ON': return 'utf8';
+      case 'OFF': return 'ascii';
+      default: return null;
+    }
+  };
+
+  const encoding = getEncoding();
+  if (!encoding) return this.reply(501, 'Unknown setting for option');
+
+  this.encoding = encoding;
+
+  return this.reply(200, `UTF8 encoding ${_.toLower(setting)}`);
+}
--- a/src/commands/registration/pass.js
+++ b/src/commands/registration/pass.js
@@ -0,0 +1,25 @@
+module.exports = {
+  directive: 'PASS',
+  handler: function ({log, command} = {}) {
+    if (!this.username) return this.reply(503);
+    if (this.authenticated) return this.reply(202);
+
+    // 332 : require account name (ACCT)
+
+    const password = command.arg;
+    if (!password) return this.reply(501, 'Must provide password');
+    return this.login(this.username, password)
+    .then(() => {
+      return this.reply(230);
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(530, err.message || 'Authentication failed');
+    });
+  },
+  syntax: '{{cmd}} <password>',
+  description: 'Authentication password',
+  flags: {
+    no_auth: true
+  }
+};
--- a/src/commands/registration/pasv.js
+++ b/src/commands/registration/pasv.js
@@ -0,0 +1,33 @@
+const PassiveConnector = require('../../connector/passive');
+const {isLocalIP} = require('../../helpers/is-local');
+
+module.exports = {
+  directive: 'PASV',
+  handler: function ({log} = {}) {
+    if (!this.server.options.pasv_url) {
+      return this.reply(502);
+    }
+
+    this.connector = new PassiveConnector(this);
+    return this.connector.setupServer()
+    .then((server) => {
+      let address = this.server.options.pasv_url;
+      // Allow connecting from local
+      if (isLocalIP(this.ip)) {
+        address = this.ip;
+      }
+      const {port} = server.address();
+      const host = address.replace(/\./g, ',');
+      const portByte1 = port / 256 | 0;
+      const portByte2 = port % 256;
+
+      return this.reply(227, `PASV OK (${host},${portByte1},${portByte2})`);
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(425);
+    });
+  },
+  syntax: '{{cmd}}',
+  description: 'Initiate passive mode'
+};
--- a/src/commands/registration/pbsz.js
+++ b/src/commands/registration/pbsz.js
@@ -0,0 +1,14 @@
+module.exports = {
+  directive: 'PBSZ',
+  handler: function ({command} = {}) {
+    if (!this.secure) return this.reply(202, 'Not suppored');
+    this.bufferSize = parseInt(command.arg, 10);
+    return this.reply(200, this.bufferSize === 0 ? 'OK' : 'Buffer too large: PBSZ=0');
+  },
+  syntax: '{{cmd}}',
+  description: 'Protection Buffer Size',
+  flags: {
+    no_auth: true,
+    feat: 'PBSZ'
+  }
+};
--- a/src/commands/registration/port.js
+++ b/src/commands/registration/port.js
@@ -0,0 +1,25 @@
+const _ = require('lodash');
+const ActiveConnector = require('../../connector/active');
+
+module.exports = {
+  directive: 'PORT',
+  handler: function ({log, command} = {}) {
+    this.connector = new ActiveConnector(this);
+
+    const rawConnection = _.get(command, 'arg', '').split(',');
+    if (rawConnection.length !== 6) return this.reply(425);
+
+    const ip = rawConnection.slice(0, 4).join('.');
+    const portBytes = rawConnection.slice(4).map((p) => parseInt(p));
+    const port = portBytes[0] * 256 + portBytes[1];
+
+    return this.connector.setupConnection(ip, port)
+    .then(() => this.reply(200))
+    .catch((err) => {
+      log.error(err);
+      return this.reply(425);
+    });
+  },
+  syntax: '{{cmd}} <x>,<x>,<x>,<x>,<y>,<y>',
+  description: 'Specifies an address and port to which the server should connect'
+};
--- a/src/commands/registration/prot.js
+++ b/src/commands/registration/prot.js
@@ -0,0 +1,23 @@
+const _ = require('lodash');
+
+module.exports = {
+  directive: 'PROT',
+  handler: function ({command} = {}) {
+    if (!this.secure) return this.reply(202, 'Not suppored');
+    if (!this.bufferSize && typeof this.bufferSize !== 'number') return this.reply(503);
+
+    switch (_.toUpper(command.arg)) {
+      case 'P': return this.reply(200, 'OK');
+      case 'C':
+      case 'S':
+      case 'E': return this.reply(536, 'Not supported');
+      default: return this.reply(504);
+    }
+  },
+  syntax: '{{cmd}}',
+  description: 'Data Channel Protection Level',
+  flags: {
+    no_auth: true,
+    feat: 'PROT'
+  }
+};
--- a/src/commands/registration/pwd.js
+++ b/src/commands/registration/pwd.js
@@ -0,0 +1,22 @@
+const Promise = require('bluebird');
+const escapePath = require('../../helpers/escape-path');
+
+module.exports = {
+  directive: ['PWD', 'XPWD'],
+  handler: function ({log} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.currentDirectory) return this.reply(402, 'Not supported by file system');
+
+    return Promise.try(() => this.fs.currentDirectory())
+    .then((cwd) => {
+      const path = cwd ? `"${escapePath(cwd)}"` : undefined;
+      return this.reply(257, path);
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(550, err.message);
+    });
+  },
+  syntax: '{{cmd}}',
+  description: 'Print current working directory'
+};
--- a/src/commands/registration/quit.js
+++ b/src/commands/registration/quit.js
@@ -0,0 +1,11 @@
+module.exports = {
+  directive: 'QUIT',
+  handler: function () {
+    return this.close(221, 'Client called QUIT');
+  },
+  syntax: '{{cmd}}',
+  description: 'Disconnect',
+  flags: {
+    no_auth: true
+  }
+};
--- a/src/commands/registration/rest.js
+++ b/src/commands/registration/rest.js
@@ -0,0 +1,16 @@
+const _ = require('lodash');
+
+module.exports = {
+  directive: 'REST',
+  handler: function ({command} = {}) {
+    const arg = _.get(command, 'arg');
+    const byteCount = parseInt(arg, 10);
+
+    if (isNaN(byteCount) || byteCount < 0) return this.reply(501, 'Byte count must be 0 or greater');
+
+    this.restByteCount = byteCount;
+    return this.reply(350, `Restarting next transfer at ${byteCount}`);
+  },
+  syntax: '{{cmd}} <byte-count>',
+  description: 'Restart transfer from the specified point. Resets after any STORE or RETRIEVE'
+};
--- a/src/commands/registration/retr.js
+++ b/src/commands/registration/retr.js
@@ -0,0 +1,64 @@
+const Promise = require('bluebird');
+
+module.exports = {
+  directive: 'RETR',
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.read) return this.reply(402, 'Not supported by file system');
+
+    const filePath = command.arg;
+
+    return this.connector.waitForConnection()
+    .tap(() => this.commandSocket.pause())
+    .then(() => Promise.try(() => this.fs.read(filePath, {start: this.restByteCount})))
+    .then((fsResponse) => {
+      let {stream, clientPath} = fsResponse;
+      if (!stream && !clientPath) {
+        stream = fsResponse;
+        clientPath = filePath;
+      }
+      const serverPath = stream.path || filePath;
+
+      const destroyConnection = (connection, reject) => (err) => {
+        if (connection) connection.destroy(err);
+        reject(err);
+      };
+
+      const eventsPromise = new Promise((resolve, reject) => {
+        stream.on('data', (data) => {
+          if (stream) stream.pause();
+          if (this.connector.socket) {
+            this.connector.socket.write(data, () => stream && stream.resume());
+          }
+        });
+        stream.once('end', () => resolve());
+        stream.once('error', destroyConnection(this.connector.socket, reject));
+
+        this.connector.socket.once('error', destroyConnection(stream, reject));
+      });
+
+      this.restByteCount = 0;
+
+      return this.reply(150).then(() => stream.resume() && this.connector.socket.resume())
+      .then(() => eventsPromise)
+      .tap(() => this.emit('RETR', null, serverPath))
+      .then(() => this.reply(226, clientPath))
+      .finally(() => stream.destroy && stream.destroy());
+    })
+    .catch(Promise.TimeoutError, (err) => {
+      log.error(err);
+      return this.reply(425, 'No connection established');
+    })
+    .catch((err) => {
+      log.error(err);
+      this.emit('RETR', err);
+      return this.reply(551, err.message);
+    })
+    .finally(() => {
+      this.connector.end();
+      this.commandSocket.resume();
+    });
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Retrieve a copy of the file'
+};
--- a/src/commands/registration/rmd.js
+++ b/src/commands/registration/rmd.js
@@ -0,0 +1,10 @@
+const {handler: dele} = require('./dele');
+
+module.exports = {
+  directive: ['RMD', 'XRMD'],
+  handler: function (args) {
+    return dele.call(this, args);
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Remove a directory'
+};
--- a/src/commands/registration/rnfr.js
+++ b/src/commands/registration/rnfr.js
@@ -0,0 +1,22 @@
+const Promise = require('bluebird');
+
+module.exports = {
+  directive: 'RNFR',
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.get) return this.reply(402, 'Not supported by file system');
+
+    const fileName = command.arg;
+    return Promise.try(() => this.fs.get(fileName))
+    .then(() => {
+      this.renameFrom = fileName;
+      return this.reply(350);
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(550, err.message);
+    });
+  },
+  syntax: '{{cmd}} <name>',
+  description: 'Rename from'
+};
--- a/src/commands/registration/rnto.js
+++ b/src/commands/registration/rnto.js
@@ -0,0 +1,30 @@
+const Promise = require('bluebird');
+
+module.exports = {
+  directive: 'RNTO',
+  handler: function ({log, command} = {}) {
+    if (!this.renameFrom) return this.reply(503);
+
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.rename) return this.reply(402, 'Not supported by file system');
+
+    const from = this.renameFrom;
+    const to = command.arg;
+
+    return Promise.try(() => this.fs.rename(from, to))
+    .then(() => {
+      return this.reply(250);
+    })
+    .tap(() => this.emit('RNTO', null, to))
+    .catch((err) => {
+      log.error(err);
+      this.emit('RNTO', err);
+      return this.reply(550, err.message);
+    })
+    .finally(() => {
+      delete this.renameFrom;
+    });
+  },
+  syntax: '{{cmd}} <name>',
+  description: 'Rename to'
+};
--- a/src/commands/registration/site/chmod.js
+++ b/src/commands/registration/site/chmod.js
@@ -0,0 +1,17 @@
+const Promise = require('bluebird');
+
+module.exports = function ({log, command} = {}) {
+  if (!this.fs) return this.reply(550, 'File system not instantiated');
+  if (!this.fs.chmod) return this.reply(402, 'Not supported by file system');
+
+  const [mode, ...fileNameParts] = command.arg.split(' ');
+  const fileName = fileNameParts.join(' ');
+  return Promise.try(() => this.fs.chmod(fileName, parseInt(mode, 8)))
+  .then(() => {
+    return this.reply(200);
+  })
+  .catch((err) => {
+    log.error(err);
+    return this.reply(500);
+  });
+};
--- a/src/commands/registration/site/index.js
+++ b/src/commands/registration/site/index.js
@@ -0,0 +1,20 @@
+const Promise = require('bluebird');
+const _ = require('lodash');
+
+const registry = require('./registry');
+
+module.exports = {
+  directive: 'SITE',
+  handler: function ({log, command} = {}) {
+    const rawSubCommand = _.get(command, 'arg', '');
+    const subCommand = this.commands.parse(rawSubCommand);
+    const subLog = log.child({subverb: subCommand.directive});
+
+    if (!registry.hasOwnProperty(subCommand.directive)) return this.reply(502);
+
+    const handler = registry[subCommand.directive].handler.bind(this);
+    return Promise.resolve(handler({log: subLog, command: subCommand}));
+  },
+  syntax: '{{cmd}} <subVerb> [...<subParams>]',
+  description: 'Sends site specific commands to remote server'
+};
--- a/src/commands/registration/site/registry.js
+++ b/src/commands/registration/site/registry.js
@@ -0,0 +1,5 @@
+module.exports = {
+  CHMOD: {
+    handler: require('./chmod')
+  }
+};
--- a/src/commands/registration/size.js
+++ b/src/commands/registration/size.js
@@ -0,0 +1,23 @@
+const Promise = require('bluebird');
+
+module.exports = {
+  directive: 'SIZE',
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.get) return this.reply(402, 'Not supported by file system');
+
+    return Promise.try(() => this.fs.get(command.arg))
+    .then((fileStat) => {
+      return this.reply(213, {message: fileStat.size});
+    })
+    .catch((err) => {
+      log.error(err);
+      return this.reply(550, err.message);
+    });
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Return the size of a file',
+  flags: {
+    feat: 'SIZE'
+  }
+};
--- a/src/commands/registration/stat.js
+++ b/src/commands/registration/stat.js
@@ -0,0 +1,45 @@
+const _ = require('lodash');
+const Promise = require('bluebird');
+const getFileStat = require('../../helpers/file-stat');
+
+module.exports = {
+  directive: 'STAT',
+  handler: function (args = {}) {
+    const {log, command} = args;
+    const path = _.get(command, 'arg');
+    if (path) {
+      if (!this.fs) return this.reply(550, 'File system not instantiated');
+      if (!this.fs.get) return this.reply(402, 'Not supported by file system');
+
+      return Promise.try(() => this.fs.get(path))
+      .then((stat) => {
+        if (stat.isDirectory()) {
+          if (!this.fs.list) return this.reply(402, 'Not supported by file system');
+
+          return Promise.try(() => this.fs.list(path))
+          .then((stats) => [213, stats]);
+        }
+        return [212, [stat]];
+      })
+      .then(([code, fileStats]) => {
+        return Promise.map(fileStats, (file) => {
+          const message = getFileStat(file, _.get(this, 'server.options.file_format', 'ls'));
+          return {
+            raw: true,
+            message
+          };
+        })
+        .then((messages) => [code, messages]);
+      })
+      .then(([code, messages]) => this.reply(code, 'Status begin', ...messages, 'Status end'))
+      .catch((err) => {
+        log.error(err);
+        return this.reply(450, err.message);
+      });
+    } else {
+      return this.reply(211, 'Status OK');
+    }
+  },
+  syntax: '{{cmd}} [<path>]',
+  description: 'Returns the current status'
+};
--- a/src/commands/registration/stor.js
+++ b/src/commands/registration/stor.js
@@ -0,0 +1,78 @@
+const Promise = require('bluebird');
+
+module.exports = {
+  directive: 'STOR',
+  handler: function ({log, command} = {}) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.write) return this.reply(402, 'Not supported by file system');
+
+    const append = command.directive === 'APPE';
+    const fileName = command.arg;
+
+    return this.connector.waitForConnection()
+    .tap(() => this.commandSocket.pause())
+    .then(() => Promise.try(() => this.fs.write(fileName, {append, start: this.restByteCount})))
+    .then((fsResponse) => {
+      let {stream, clientPath} = fsResponse;
+      if (!stream && !clientPath) {
+        stream = fsResponse;
+        clientPath = fileName;
+      }
+      const serverPath = stream.path || fileName;
+
+      const destroyConnection = (connection, reject) => (err) => {
+        try {
+          if (connection) {
+            if (connection.writable) connection.end();
+            connection.destroy(err);
+          }
+        } finally {
+          reject(err);
+        }
+      };
+
+      const streamPromise = new Promise((resolve, reject) => {
+        stream.once('error', destroyConnection(this.connector.socket, reject));
+        stream.once('finish', () => resolve());
+      });
+
+      const socketPromise = new Promise((resolve, reject) => {
+        this.connector.socket.on('data', (data) => {
+          if (this.connector.socket) this.connector.socket.pause();
+          if (stream && stream.writable) {
+            stream.write(data, () => this.connector.socket && this.connector.socket.resume());
+          }
+        });
+        this.connector.socket.once('end', () => {
+          if (stream.listenerCount('close')) stream.emit('close');
+          else stream.end();
+          resolve();
+        });
+        this.connector.socket.once('error', destroyConnection(stream, reject));
+      });
+
+      this.restByteCount = 0;
+
+      return this.reply(150).then(() => this.connector.socket.resume())
+      .then(() => Promise.all([streamPromise, socketPromise]))
+      .tap(() => this.emit('STOR', null, serverPath))
+      .then(() => this.reply(226, clientPath))
+      .finally(() => stream.destroy && stream.destroy());
+    })
+    .catch(Promise.TimeoutError, (err) => {
+      log.error(err);
+      return this.reply(425, 'No connection established');
+    })
+    .catch((err) => {
+      log.error(err);
+      this.emit('STOR', err);
+      return this.reply(550, err.message);
+    })
+    .finally(() => {
+      this.connector.end();
+      this.commandSocket.resume();
+    });
+  },
+  syntax: '{{cmd}} <path>',
+  description: 'Store data as a file at the server site'
+};
--- a/src/commands/registration/stou.js
+++ b/src/commands/registration/stou.js
@@ -0,0 +1,21 @@
+const Promise = require('bluebird');
+const {handler: stor} = require('./stor');
+
+module.exports = {
+  directive: 'STOU',
+  handler: function (args) {
+    if (!this.fs) return this.reply(550, 'File system not instantiated');
+    if (!this.fs.get || !this.fs.getUniqueName) return this.reply(402, 'Not supported by file system');
+
+    const fileName = args.command.arg;
+    return Promise.try(() => this.fs.get(fileName))
+    .then(() => Promise.try(() => this.fs.getUniqueName()))
+    .catch(() => fileName)
+    .then((name) => {
+      args.command.arg = name;
+      return stor.call(this, args);
+    });
+  },
+  syntax: '{{cmd}}',
+  description: 'Store file uniquely'
+};
--- a/src/commands/registration/stru.js
+++ b/src/commands/registration/stru.js
@@ -0,0 +1,11 @@
+module.exports = {
+  directive: 'STRU',
+  handler: function ({command} = {}) {
+    return this.reply(/^F$/i.test(command.arg) ? 200 : 504);
+  },
+  syntax: '{{cmd}} <structure>',
+  description: 'Set file transfer structure',
+  flags: {
+    obsolete: true
+  }
+};
--- a/src/commands/registration/syst.js
+++ b/src/commands/registration/syst.js
@@ -0,0 +1,11 @@
+module.exports = {
+  directive: 'SYST',
+  handler: function () {
+    return this.reply(215);
+  },
+  syntax: '{{cmd}}',
+  description: 'Return system type',
+  flags: {
+    no_auth: true
+  }
+};
--- a/src/commands/registration/type.js
+++ b/src/commands/registration/type.js
@@ -0,0 +1,18 @@
+module.exports = {
+  directive: 'TYPE',
+  handler: function ({command} = {}) {
+    if (/^A[0-9]?$/i.test(command.arg)) {
+      this.transferType = 'ascii';
+    } else if (/^L[0-9]?$/i.test(command.arg) || /^I$/i.test(command.arg)) {
+      this.transferType = 'binary';
+    } else {
+      return this.reply(501);
+    }
+    return this.reply(200, `Switch to "${this.transferType}" transfer mode.`);
+  },
+  syntax: '{{cmd}} <mode>',
+  description: 'Set the transfer mode, binary (I) or ascii (A)',
+  flags: {
+    feat: 'TYPE A,I,L'
+  }
+};
--- a/src/commands/registration/user.js
+++ b/src/commands/registration/user.js
@@ -0,0 +1,28 @@
+module.exports = {
+  directive: 'USER',
+  handler: function ({log, command} = {}) {
+    if (this.username) return this.reply(530, 'Username already set');
+    if (this.authenticated) return this.reply(230);
+
+    this.username = command.arg;
+    if (!this.username) return this.reply(501, 'Must provide username');
+
+    if (this.server.options.anonymous === true && this.username === 'anonymous' ||
+        this.username === this.server.options.anonymous) {
+      return this.login(this.username, '@anonymous')
+      .then(() => {
+        return this.reply(230);
+      })
+      .catch((err) => {
+        log.error(err);
+        return this.reply(530, err.message || 'Authentication failed');
+      });
+    }
+    return this.reply(331);
+  },
+  syntax: '{{cmd}} <username>',
+  description: 'Authentication username',
+  flags: {
+    no_auth: true
+  }
+};
--- a/src/commands/registry.js
+++ b/src/commands/registry.js
@@ -0,0 +1,50 @@
+/* eslint no-return-assign: 0 */
+const commands = [
+  require('./registration/abor'),
+  require('./registration/allo'),
+  require('./registration/appe'),
+  require('./registration/auth'),
+  require('./registration/cdup'),
+  require('./registration/cwd'),
+  require('./registration/dele'),
+  require('./registration/feat'),
+  require('./registration/help'),
+  require('./registration/list'),
+  require('./registration/mdtm'),
+  require('./registration/mkd'),
+  require('./registration/mode'),
+  require('./registration/nlst'),
+  require('./registration/noop'),
+  require('./registration/opts'),
+  require('./registration/pass'),
+  require('./registration/pasv'),
+  require('./registration/port'),
+  require('./registration/pwd'),
+  require('./registration/quit'),
+  require('./registration/rest'),
+  require('./registration/retr'),
+  require('./registration/rmd'),
+  require('./registration/rnfr'),
+  require('./registration/rnto'),
+  require('./registration/site'),
+  require('./registration/size'),
+  require('./registration/stat'),
+  require('./registration/stor'),
+  require('./registration/stou'),
+  require('./registration/stru'),
+  require('./registration/syst'),
+  require('./registration/type'),
+  require('./registration/user'),
+  require('./registration/pbsz'),
+  require('./registration/prot'),
+  require('./registration/eprt'),
+  require('./registration/epsv')
+];
+
+const registry = commands.reduce((result, cmd) => {
+  const aliases = Array.isArray(cmd.directive) ? cmd.directive : [cmd.directive];
+  aliases.forEach((alias) => result[alias] = cmd);
+  return result;
+}, {});
+
+module.exports = registry;
--- a/src/connection.js
+++ b/src/connection.js
@@ -0,0 +1,152 @@
+const _ = require('lodash');
+const uuid = require('uuid');
+const Promise = require('bluebird');
+const EventEmitter = require('events');
+
+const BaseConnector = require('./connector/base');
+const FileSystem = require('./fs');
+const Commands = require('./commands');
+const errors = require('./errors');
+const DEFAULT_MESSAGE = require('./messages');
+
+class FtpConnection extends EventEmitter {
+  constructor(server, options) {
+    super();
+    this.server = server;
+    this.id = uuid.v4();
+    this.log = options.log.child({id: this.id, ip: this.ip});
+    this.commands = new Commands(this);
+    this.transferType = 'binary';
+    this.encoding = 'utf8';
+    this.bufferSize = false;
+    this._restByteCount = 0;
+    this._secure = false;
+
+    this.connector = new BaseConnector(this);
+
+    this.commandSocket = options.socket;
+    this.commandSocket.on('error', (err) => {
+      this.log.error(err, 'Client error');
+      this.server.emit('client-error', {connection: this, context: 'commandSocket', error: err});
+    });
+    this.commandSocket.on('data', this._handleData.bind(this));
+    this.commandSocket.on('timeout', () => {
+      this.log.trace('Client timeout');
+      this.close().catch((e) => this.log.trace(e, 'Client close error'));
+    });
+    this.commandSocket.on('close', () => {
+      if (this.connector) this.connector.end();
+      if (this.commandSocket && !this.commandSocket.destroyed) this.commandSocket.destroy();
+      this.removeAllListeners();
+    });
+  }
+
+  _handleData(data) {
+    const messages = _.compact(data.toString(this.encoding).split('\r\n'));
+    this.log.trace(messages);
+    return Promise.mapSeries(messages, (message) => this.commands.handle(message));
+  }
+
+  get ip() {
+    try {
+      return this.commandSocket ? this.commandSocket.remoteAddress : undefined;
+    } catch (ex) {
+      return null;
+    }
+  }
+
+  get restByteCount() {
+    return this._restByteCount > 0 ? this._restByteCount : undefined;
+  }
+  set restByteCount(rbc) {
+    this._restByteCount = rbc;
+  }
+
+  get secure() {
+    return this.server.isTLS || this._secure;
+  }
+  set secure(sec) {
+    this._secure = sec;
+  }
+
+  close(code = 421, message = 'Closing connection') {
+    return Promise.resolve(code)
+      .then((_code) => _code && this.reply(_code, message))
+      .then(() => this.commandSocket && this.commandSocket.end());
+  }
+
+  login(username, password) {
+    return Promise.try(() => {
+      const loginListeners = this.server.listeners('login');
+      if (!loginListeners || !loginListeners.length) {
+        if (!this.server.options.anonymous) throw new errors.GeneralError('No "login" listener setup', 500);
+      } else {
+        return this.server.emitPromise('login', {connection: this, username, password});
+      }
+    })
+    .then(({root, cwd, fs, blacklist = [], whitelist = []} = {}) => {
+      this.authenticated = true;
+      this.commands.blacklist = _.concat(this.commands.blacklist, blacklist);
+      this.commands.whitelist = _.concat(this.commands.whitelist, whitelist);
+      this.fs = fs || new FileSystem(this, {root, cwd});
+    });
+  }
+
+  reply(options = {}, ...letters) {
+    const satisfyParameters = () => {
+      if (typeof options === 'number') options = {code: options}; // allow passing in code as first param
+      if (!Array.isArray(letters)) letters = [letters];
+      if (!letters.length) letters = [{}];
+      return Promise.map(letters, (promise, index) => {
+        return Promise.resolve(promise)
+        .then((letter) => {
+          if (!letter) letter = {};
+          else if (typeof letter === 'string') letter = {message: letter}; // allow passing in message as first param
+
+          if (!letter.socket) letter.socket = options.socket ? options.socket : this.commandSocket;
+          if (!options.useEmptyMessage) {
+            if (!letter.message) letter.message = DEFAULT_MESSAGE[options.code] || 'No information';
+            if (!letter.encoding) letter.encoding = this.encoding;
+          }
+          return Promise.resolve(letter.message) // allow passing in a promise as a message
+          .then((message) => {
+            if (!options.useEmptyMessage) {
+              const seperator = !options.hasOwnProperty('eol') ?
+                letters.length - 1 === index ? ' ' : '-' :
+                options.eol ? ' ' : '-';
+              message = !letter.raw ? _.compact([letter.code || options.code, message]).join(seperator) : message;
+              letter.message = message;
+            } else {
+              letter.message = '';
+            }
+            return letter;
+          });
+        });
+      });
+    };
+
+    const processLetter = (letter) => {
+      return new Promise((resolve, reject) => {
+        if (letter.socket && letter.socket.writable) {
+          this.log.trace({port: letter.socket.address().port, encoding: letter.encoding, message: letter.message}, 'Reply');
+          letter.socket.write(letter.message + '\r\n', letter.encoding, (err) => {
+            if (err) {
+              this.log.error(err);
+              return reject(err);
+            }
+            resolve();
+          });
+        } else reject(new errors.SocketError('Socket not writable'));
+      });
+    };
+
+    return satisfyParameters()
+    .then((satisfiedLetters) => Promise.mapSeries(satisfiedLetters, (letter, index) => {
+      return processLetter(letter, index);
+    }))
+    .catch((err) => {
+      this.log.error(err);
+    });
+  }
+}
+module.exports = FtpConnection;
--- a/src/connector/active.js
+++ b/src/connector/active.js
@@ -0,0 +1,48 @@
+const {Socket} = require('net');
+const tls = require('tls');
+const Promise = require('bluebird');
+const Connector = require('./base');
+
+class Active extends Connector {
+  constructor(connection) {
+    super(connection);
+    this.type = 'active';
+  }
+
+  waitForConnection({timeout = 5000, delay = 250} = {}) {
+    const checkSocket = () => {
+      if (this.dataSocket && this.dataSocket.connected) {
+        return Promise.resolve(this.dataSocket);
+      }
+      return Promise.resolve().delay(delay)
+      .then(() => checkSocket());
+    };
+
+    return checkSocket().timeout(timeout);
+  }
+
+  setupConnection(host, port, family = 4) {
+    const closeExistingServer = () => Promise.resolve(
+      this.dataSocket ? this.dataSocket.destroy() : undefined);
+
+    return closeExistingServer()
+    .then(() => {
+      this.dataSocket = new Socket();
+      this.dataSocket.on('error', (err) => this.server && this.server.emit('client-error', {connection: this.connection, context: 'dataSocket', error: err}));
+      this.dataSocket.connect({host, port, family}, () => {
+        this.dataSocket.pause();
+
+        if (this.connection.secure) {
+          const secureContext = tls.createSecureContext(this.server.options.tls);
+          const secureSocket = new tls.TLSSocket(this.dataSocket, {
+            isServer: true,
+            secureContext
+          });
+          this.dataSocket = secureSocket;
+        }
+        this.dataSocket.connected = true;
+      });
+    });
+  }
+}
+module.exports = Active;
--- a/src/connector/base.js
+++ b/src/connector/base.js
@@ -0,0 +1,53 @@
+const Promise = require('bluebird');
+const errors = require('../errors');
+
+class Connector {
+  constructor(connection) {
+    this.connection = connection;
+
+    this.dataSocket = null;
+    this.dataServer = null;
+    this.type = false;
+  }
+
+  get log() {
+    return this.connection.log;
+  }
+
+  get socket() {
+    return this.dataSocket;
+  }
+
+  get server() {
+    return this.connection.server;
+  }
+
+  waitForConnection() {
+    return Promise.reject(new errors.ConnectorError('No connector setup, send PASV or PORT'));
+  }
+
+  closeSocket() {
+    if (this.dataSocket) {
+      const socket = this.dataSocket;
+      this.dataSocket.end(() => socket.destroy());
+      this.dataSocket = null;
+    }
+  }
+
+  closeServer() {
+    if (this.dataServer) {
+      this.dataServer.close();
+      this.dataServer = null;
+    }
+  }
+
+
+  end() {
+    this.closeSocket();
+    this.closeServer();
+
+    this.type = false;
+    this.connection.connector = new Connector(this);
+  }
+}
+module.exports = Connector;
--- a/src/connector/passive.js
+++ b/src/connector/passive.js
@@ -0,0 +1,93 @@
+const net = require('net');
+const tls = require('tls');
+const ip = require('ip');
+const Promise = require('bluebird');
+
+const Connector = require('./base');
+const errors = require('../errors');
+
+const CONNECT_TIMEOUT = 30 * 1000;
+
+class Passive extends Connector {
+  constructor(connection) {
+    super(connection);
+    this.type = 'passive';
+  }
+
+  waitForConnection({timeout = 5000, delay = 50} = {}) {
+    if (!this.dataServer) return Promise.reject(new errors.ConnectorError('Passive server not setup'));
+
+    const checkSocket = () => {
+      if (this.dataServer && this.dataServer.listening && this.dataSocket && this.dataSocket.connected) {
+        return Promise.resolve(this.dataSocket);
+      }
+      return Promise.resolve().delay(delay)
+      .then(() => checkSocket());
+    };
+
+    return checkSocket().timeout(timeout);
+  }
+
+  setupServer() {
+    this.closeServer();
+    return this.server.getNextPasvPort()
+    .then((port) => {
+      this.dataSocket = null;
+      let idleServerTimeout;
+
+      const connectionHandler = (socket) => {
+        if (!ip.isEqual(this.connection.commandSocket.remoteAddress, socket.remoteAddress)) {
+          this.log.error({
+            pasv_connection: socket.remoteAddress,
+            cmd_connection: this.connection.commandSocket.remoteAddress
+          }, 'Connecting addresses do not match');
+
+          socket.destroy();
+          return this.connection.reply(550, 'Remote addresses do not match')
+          .finally(() => this.connection.close());
+        }
+        clearTimeout(idleServerTimeout);
+
+        this.log.trace({port, remoteAddress: socket.remoteAddress}, 'Passive connection fulfilled.');
+
+        this.dataSocket = socket;
+        this.dataSocket.on('error', (err) => this.server && this.server.emit('client-error', {connection: this.connection, context: 'dataSocket', error: err}));
+        this.dataSocket.once('close', () => this.closeServer());
+
+        if (!this.connection.secure) {
+          this.dataSocket.connected = true;
+        }
+      };
+
+      const serverOptions = Object.assign({}, this.connection.secure ? this.server.options.tls : {}, {pauseOnConnect: true});
+      this.dataServer = (this.connection.secure ? tls : net).createServer(serverOptions, connectionHandler);
+      this.dataServer.maxConnections = 1;
+
+      this.dataServer.on('error', (err) => this.server && this.server.emit('client-error', {connection: this.connection, context: 'dataServer', error: err}));
+      this.dataServer.once('close', () => {
+        this.log.trace('Passive server closed');
+        this.end();
+      });
+
+      if (this.connection.secure) {
+        this.dataServer.on('secureConnection', (socket) => {
+          socket.connected = true;
+        });
+      }
+
+      return new Promise((resolve, reject) => {
+        this.dataServer.listen(port, this.server.url.hostname, (err) => {
+          if (err) reject(err);
+          else {
+            idleServerTimeout = setTimeout(() => this.closeServer(), CONNECT_TIMEOUT);
+
+            this.log.debug({port}, 'Passive connection listening');
+            resolve(this.dataServer);
+          }
+        });
+      });
+    });
+  }
+
+}
+module.exports = Passive;
--- a/src/errors.js
+++ b/src/errors.js
@@ -0,0 +1,44 @@
+
+class GeneralError extends Error {
+  constructor(message, code = 400) {
+    super();
+    this.code = code;
+    this.name = 'GeneralError';
+    this.message = message;
+  }
+}
+
+class SocketError extends Error {
+  constructor(message, code = 500) {
+    super();
+    this.code = code;
+    this.name = 'SocketError';
+    this.message = message;
+  }
+}
+
+class FileSystemError extends Error {
+  constructor(message, code = 400) {
+    super();
+    this.code = code;
+    this.name = 'FileSystemError';
+    this.message = message;
+  }
+}
+
+class ConnectorError extends Error {
+  constructor(message, code = 400) {
+    super();
+    this.code = code;
+    this.name = 'ConnectorError';
+    this.message = message;
+  }
+}
+
+
+module.exports = {
+  SocketError,
+  FileSystemError,
+  ConnectorError,
+  GeneralError
+};
--- a/src/fs.js
+++ b/src/fs.js
@@ -0,0 +1,136 @@
+const _ = require('lodash');
+const nodePath = require('path');
+const uuid = require('uuid');
+const Promise = require('bluebird');
+const {createReadStream, createWriteStream, constants} = require('fs');
+const fsAsync = require('./helpers/fs-async');
+const errors = require('./errors');
+
+class FileSystem {
+  constructor(connection, {root, cwd} = {}) {
+    this.connection = connection;
+    this.cwd = nodePath.normalize(cwd ? nodePath.join(nodePath.sep, cwd) : nodePath.sep);
+    this._root = nodePath.resolve(root || process.cwd());
+  }
+
+  get root() {
+    return this._root;
+  }
+
+  _resolvePath(path = '.') {
+    const clientPath = (() => {
+      path = nodePath.normalize(path);
+      if (nodePath.isAbsolute(path)) {
+        return nodePath.join(path);
+      } else {
+        return nodePath.join(this.cwd, path);
+      }
+    })();
+
+    const fsPath = (() => {
+      const resolvedPath = nodePath.join(this.root, clientPath);
+      return nodePath.resolve(nodePath.normalize(nodePath.join(resolvedPath)));
+    })();
+
+    return {
+      clientPath,
+      fsPath
+    };
+  }
+
+  currentDirectory() {
+    return this.cwd;
+  }
+
+  get(fileName) {
+    const {fsPath} = this._resolvePath(fileName);
+    return fsAsync.stat(fsPath)
+    .then((stat) => _.set(stat, 'name', fileName));
+  }
+
+  list(path = '.') {
+    const {fsPath} = this._resolvePath(path);
+    return fsAsync.readdir(fsPath)
+    .then((fileNames) => {
+      return Promise.map(fileNames, (fileName) => {
+        const filePath = nodePath.join(fsPath, fileName);
+        return fsAsync.access(filePath, constants.F_OK)
+        .then(() => {
+          return fsAsync.stat(filePath)
+          .then((stat) => _.set(stat, 'name', fileName));
+        })
+        .catch(() => null);
+      });
+    })
+    .then(_.compact);
+  }
+
+  chdir(path = '.') {
+    const {fsPath, clientPath} = this._resolvePath(path);
+    return fsAsync.stat(fsPath)
+    .tap((stat) => {
+      if (!stat.isDirectory()) throw new errors.FileSystemError('Not a valid directory');
+    })
+    .then(() => {
+      this.cwd = clientPath;
+      return this.currentDirectory();
+    });
+  }
+
+  write(fileName, {append = false, start = undefined} = {}) {
+    const {fsPath, clientPath} = this._resolvePath(fileName);
+    const stream = createWriteStream(fsPath, {flags: !append ? 'w+' : 'a+', start});
+    stream.once('error', () => fsAsync.unlink(fsPath));
+    stream.once('close', () => stream.end());
+    return {
+      stream,
+      clientPath
+    };
+  }
+
+  read(fileName, {start = undefined} = {}) {
+    const {fsPath, clientPath} = this._resolvePath(fileName);
+    return fsAsync.stat(fsPath)
+    .tap((stat) => {
+      if (stat.isDirectory()) throw new errors.FileSystemError('Cannot read a directory');
+    })
+    .then(() => {
+      const stream = createReadStream(fsPath, {flags: 'r', start});
+      return {
+        stream,
+        clientPath
+      };
+    });
+  }
+
+  delete(path) {
+    const {fsPath} = this._resolvePath(path);
+    return fsAsync.stat(fsPath)
+    .then((stat) => {
+      if (stat.isDirectory()) return fsAsync.rmdir(fsPath);
+      else return fsAsync.unlink(fsPath);
+    });
+  }
+
+  mkdir(path) {
+    const {fsPath} = this._resolvePath(path);
+    return fsAsync.mkdir(fsPath)
+    .then(() => fsPath);
+  }
+
+  rename(from, to) {
+    const {fsPath: fromPath} = this._resolvePath(from);
+    const {fsPath: toPath} = this._resolvePath(to);
+    return fsAsync.rename(fromPath, toPath);
+  }
+
+  chmod(path, mode) {
+    const {fsPath} = this._resolvePath(path);
+    return fsAsync.chmod(fsPath, mode);
+  }
+
+  getUniqueName() {
+    return uuid.v4().replace(/\W/g, '');
+  }
+}
+module.exports = FileSystem;
--- a/src/helpers/escape-path.js
+++ b/src/helpers/escape-path.js
@@ -0,0 +1,4 @@
+module.exports = function (path) {
+  return path
+    .replace(/"/g, '""');
+};
--- a/src/helpers/file-stat.js
+++ b/src/helpers/file-stat.js
@@ -0,0 +1,55 @@
+const _ = require('lodash');
+const moment = require('moment');
+const errors = require('../errors');
+
+const FORMATS = {
+  ls,
+  ep
+};
+
+module.exports = function (fileStat, format = 'ls') {
+  if (typeof format === 'function') return format(fileStat);
+  if (!FORMATS.hasOwnProperty(format)) {
+    throw new errors.FileSystemError('Bad file stat formatter');
+  }
+  return FORMATS[format](fileStat);
+};
+
+function ls(fileStat) {
+  const now = moment.utc();
+  const mtime = moment.utc(new Date(fileStat.mtime));
+  const timeDiff = now.diff(mtime, 'months');
+  const dateFormat = timeDiff < 6 ? 'MMM DD HH:mm' : 'MMM DD  YYYY';
+
+  return [
+    fileStat.mode ? [
+      fileStat.isDirectory() ? 'd' : '-',
+      fileStat.mode & 256 ? 'r' : '-',
+      fileStat.mode & 128 ? 'w' : '-',
+      fileStat.mode & 64 ? 'x' : '-',
+      fileStat.mode & 32 ? 'r' : '-',
+      fileStat.mode & 16 ? 'w' : '-',
+      fileStat.mode & 8 ? 'x' : '-',
+      fileStat.mode & 4 ? 'r' : '-',
+      fileStat.mode & 2 ? 'w' : '-',
+      fileStat.mode & 1 ? 'x' : '-'
+    ].join('') : fileStat.isDirectory() ? 'drwxr-xr-x' : '-rwxr-xr-x',
+    '1',
+    fileStat.uid || 1,
+    fileStat.gid || 1,
+    _.padStart(fileStat.size, 12),
+    _.padStart(mtime.format(dateFormat), 12),
+    fileStat.name
+  ].join(' ');
+}
+
+function ep(fileStat) {
+  const facts = _.compact([
+    fileStat.dev && fileStat.ino ? `i${fileStat.dev.toString(16)}.${fileStat.ino.toString(16)}` : null,
+    fileStat.size ? `s${fileStat.size}` : null,
+    fileStat.mtime ? `m${moment.utc(new Date(fileStat.mtime)).format('X')}` : null,
+    fileStat.mode ? `up${(fileStat.mode & 4095).toString(8)}` : null,
+    fileStat.isDirectory() ? '/' : 'r'
+  ]).join(',');
+  return `+${facts}\t${fileStat.name}`;
+}
--- a/src/helpers/find-port.js
+++ b/src/helpers/find-port.js
@@ -0,0 +1,61 @@
+const net = require('net');
+const errors = require('../errors');
+
+const MAX_PORT = 65535;
+const MAX_PORT_CHECK_ATTEMPT = 5;
+
+function* portNumberGenerator(min, max = MAX_PORT) {
+  let current = min;
+  while (true) {
+    if (current > MAX_PORT || current > max) {
+      current = min;
+    }
+    yield current++;
+  }
+}
+
+function getNextPortFactory(host, portMin, portMax, maxAttempts = MAX_PORT_CHECK_ATTEMPT) {
+  const nextPortNumber = portNumberGenerator(portMin, portMax);
+
+  return () => new Promise((resolve, reject) => {
+    const portCheckServer = net.createServer();
+    portCheckServer.maxConnections = 0;
+
+    let attemptCount = 0;
+    const tryGetPort = () => {
+      attemptCount++;
+      if (attemptCount > maxAttempts) {
+        reject(new errors.ConnectorError('Unable to find valid port'));
+        return;
+      }
+
+      const {value: port} = nextPortNumber.next();
+
+      portCheckServer.removeAllListeners();
+      portCheckServer.once('error', (err) => {
+        if (['EADDRINUSE'].includes(err.code)) {
+          tryGetPort();
+        } else {
+          reject(err);
+        }
+      });
+      portCheckServer.once('listening', () => {
+        portCheckServer.removeAllListeners();
+        portCheckServer.close(() => resolve(port));
+      });
+
+      try {
+        portCheckServer.listen(port, host);
+      } catch (err) {
+        reject(err);
+      }
+    };
+
+    tryGetPort();
+  });
+}
+
+module.exports = {
+  getNextPortFactory,
+  portNumberGenerator
+};
--- a/src/helpers/fs-async.js
+++ b/src/helpers/fs-async.js
@@ -0,0 +1,18 @@
+const fs = require('fs');
+const {promisify} = require('bluebird');
+
+const methods = [
+  'stat',
+  'readdir',
+  'access',
+  'unlink',
+  'rmdir',
+  'mkdir',
+  'rename',
+  'chmod'
+];
+
+module.exports = methods.reduce((obj, method) => {
+  obj[method] = promisify(fs[method]);
+  return obj;
+}, {});
--- a/src/helpers/is-local.js
+++ b/src/helpers/is-local.js
@@ -0,0 +1,3 @@
+module.exports.isLocalIP = function(ip) {
+  return ip === '127.0.0.1' || ip == '::1';
+}
--- a/src/index.js
+++ b/src/index.js
@@ -0,0 +1,152 @@
+const _ = require('lodash');
+const Promise = require('bluebird');
+const nodeUrl = require('url');
+const buyan = require('bunyan');
+const net = require('net');
+const tls = require('tls');
+const EventEmitter = require('events');
+
+const Connection = require('./connection');
+const {getNextPortFactory} = require('./helpers/find-port');
+
+class FtpServer extends EventEmitter {
+  constructor(options = {}) {
+    super();
+    this.options = Object.assign({
+      log: buyan.createLogger({name: 'ftp-srv'}),
+      url: 'ftp://127.0.0.1:21',
+      pasv_min: 1024,
+      pasv_max: 65535,
+      pasv_url: null,
+      anonymous: false,
+      file_format: 'ls',
+      blacklist: [],
+      whitelist: [],
+      greeting: null,
+      tls: false,
+      timeout: 0
+    }, options);
+
+    this._greeting = this.setupGreeting(this.options.greeting);
+    this._features = this.setupFeaturesMessage();
+
+    delete this.options.greeting;
+
+    this.connections = {};
+    this.log = this.options.log;
+    this.url = nodeUrl.parse(this.options.url);
+    this.getNextPasvPort = getNextPortFactory(
+      _.get(this, 'url.hostname'),
+      _.get(this, 'options.pasv_min'),
+      _.get(this, 'options.pasv_max'));
+
+	const timeout = Number(this.options.timeout);
+	this.options.timeout = isNaN(timeout) ? 0 : Number(timeout);
+
+    const serverConnectionHandler = (socket) => {
+      socket.setTimeout(this.options.timeout);
+      let connection = new Connection(this, {log: this.log, socket});
+      this.connections[connection.id] = connection;
+
+      socket.on('close', () => this.disconnectClient(connection.id));
+
+      const greeting = this._greeting || [];
+      const features = this._features || 'Ready';
+      return connection.reply(220, ...greeting, features)
+      .finally(() => socket.resume());
+    };
+    const serverOptions = Object.assign({}, this.isTLS ? this.options.tls : {}, {pauseOnConnect: true});
+
+    this.server = (this.isTLS ? tls : net).createServer(serverOptions, serverConnectionHandler);
+    this.server.on('error', (err) => this.log.error(err, '[Event] error'));
+
+    const quit = _.debounce(this.quit.bind(this), 100);
+
+    process.on('SIGTERM', quit);
+    process.on('SIGINT', quit);
+    process.on('SIGQUIT', quit);
+  }
+
+  get isTLS() {
+    return this.url.protocol === 'ftps:' && this.options.tls;
+  }
+
+  listen() {
+    if (!this.options.pasv_url) {
+      this.log.warn('Passive URL not set. Passive connections not available.');
+    }
+
+    return new Promise((resolve, reject) => {
+      this.server.once('error', reject);
+      this.server.listen(this.url.port, this.url.hostname, (err) => {
+        this.server.removeListener('error', reject);
+        if (err) return reject(err);
+        this.log.info({
+          protocol: this.url.protocol.replace(/\W/g, ''),
+          ip: this.url.hostname,
+          port: this.url.port
+        }, 'Listening');
+        resolve('Listening');
+      });
+    });
+  }
+
+  emitPromise(action, ...data) {
+    return new Promise((resolve, reject) => {
+      const params = _.concat(data, [resolve, reject]);
+      this.emit.call(this, action, ...params);
+    });
+  }
+
+  setupGreeting(greet) {
+    if (!greet) return [];
+    const greeting = Array.isArray(greet) ? greet : greet.split('\n');
+    return greeting;
+  }
+
+  setupFeaturesMessage() {
+    let features = [];
+    if (this.options.anonymous) features.push('a');
+
+    if (features.length) {
+      features.unshift('Features:');
+      features.push('.');
+    }
+    return features.length ? features.join(' ') : 'Ready';
+  }
+
+  disconnectClient(id) {
+    return new Promise((resolve) => {
+      const client = this.connections[id];
+      if (!client) return resolve();
+      delete this.connections[id];
+      try {
+        client.close(0);
+      } catch (err) {
+        this.log.error(err, 'Error closing connection', {id});
+      } finally {
+        resolve('Disconnected');
+      }
+    });
+  }
+
+  quit() {
+    return this.close()
+    .finally(() => process.exit(0));
+  }
+
+  close() {
+    this.log.info('Server closing...');
+    this.server.maxConnections = 0;
+    return Promise.map(Object.keys(this.connections), (id) => Promise.try(this.disconnectClient.bind(this, id)))
+    .then(() => new Promise((resolve) => {
+      this.server.close((err) => {
+        if (err) this.log.error(err, 'Error closing server');
+        resolve('Closed');
+      });
+    }))
+    .then(() => this.removeAllListeners());
+  }
+
+}
+module.exports = FtpServer;
--- a/src/messages.js
+++ b/src/messages.js
@@ -0,0 +1,56 @@
+module.exports = {
+  // 100 - 199 :: Remarks
+  100: 'The requested action is being initiated',
+  110: 'Restart marker reply',
+  120: 'Service ready in %s minutes',
+  125: 'Data connection already open; transfer starting',
+  150: 'File status okay; about to open data connection',
+  // 200 - 399 :: Acceptance
+  /// 200 - 299 :: Positive Completion Replies
+  /// These type of replies indicate that the requested action was taken and that the server is awaiting another command.
+  200: 'The requested action has been successfully completed',
+  202: 'Superfluous command',
+  211: 'System status, or system help reply',
+  212: 'Directory status',
+  213: 'File status',
+  214: 'Help message', // On how to use the server or the meaning of a particular non-standard command. This reply is useful only to the human user.
+  215: 'UNIX Type: L8', // NAME system type. Where NAME is an official system name from the list in the Assigned Numbers document.
+  220: 'Service ready for new user',
+  221: 'Service closing control connection', // Logged out if appropriate.
+  225: 'Data connection open; no transfer in progress',
+  226: 'Closing data connection', // Requested file action successful (for example, file transfer or file abort).
+  227: 'Entering Passive Mode', // (h1,h2,h3,h4,p1,p2).
+  230: 'User logged in, proceed',
+  234: 'Honored',
+  250: 'Requested file action okay, completed',
+  257: '\'%s\' created',
+  /// 300 - 399 :: Positive Intermediate Replies
+  /// These types of replies indicate that the requested action was taken and that the server is awaiting further information to complete the request.
+  331: 'Username okay, awaiting password',
+  332: 'Need account for login',
+  350: 'Requested file action pending further information',
+  // 400 - 599 :: Rejection
+  /// 400 - 499 :: Transient Negative Completion Replies
+  /// These types of replies indicate that the command was not accepted; the requested action was not taken.
+  /// However, the error is temporary and the action may be requested again.
+  421: 'Service not available, closing control connection', // This may be a reply to any command if the service knows it must shut down.
+  425: 'Unable to open data connection',
+  426: 'Connection closed; transfer aborted',
+  450: 'Requested file action not taken', // File unavailable (e.g., file busy).
+  451: 'Requested action aborted. Local error in processing',
+  452: 'Requested action not taken. Insufficient storage',
+  /// 500 - 599 :: Permanent Negative Completion Replies
+  /// These types of replies indicate that the command was not accepted; the requested action was not taken.
+  /// The FTP client is "discouraged" from repeating the same exact request.
+  500: 'Syntax error', // Can close connection
+  501: 'Syntax error in parameters or arguments',
+  502: 'Command not supported',
+  503: 'Bad sequence of commands',
+  504: 'Command parameter not supported',
+  530: 'Not logged in', // Permission Denied, Can close connection
+  532: 'Need account for storing files',
+  550: 'Requested action not taken. File unavailable', // (e.g., file not found, no access).
+  551: 'Requested action aborted. Page type unknown',
+  552: 'Requested file action aborted. Exceeded storage allocation', // (for current directory or dataset).
+  553: 'Requested action not taken. File name not allowed'
+};
--- a/src/server/index.js
+++ b/src/server/index.js
@@ -1,90 +0,0 @@
-const net = require('net');
-const Queue = require('bee-queue');
-const {Signale} = require('signale');
-const {matches} = require('z');
-
-const KeyValueStore = require('../utils/keyValueStore');
-const {setAsyncTimeout} = require('../utils/setAsyncTimeout')
-const {setupWorkers} = require('../workers');
-
-const LISTEN_RETRY_MAX = 2;
-const LISTEN_RETRY_DELAY = 1500;
-
-class Server extends net.Server {
-  constructor({
-    host = '0.0.0.0',
-    port = 21,
-    log = {}
-  } = {}) {
-    super({
-      pauseOnConnect: true
-    });
-
-    this.log = new Signale(Object.assign({
-      scope: 'ftp-srv',
-    }, log));
-    this.debugLog = this.log.scope('debug');
-    this.debugLog.config({
-      displayTimestamp: true
-    })
-
-    this.receiveQueue = new Queue('receive');
-    this.sendQueue = new Queue('send');
-    this.workers = new KeyValueStore();
-    this.options = new KeyValueStore({
-      host,
-      port
-    });
-  }
-
-  async listen() {
-    const workers = await setupWorkers();
-    this.workers.sets(workers);
-
-    const port = this.options.get('port');
-    const host = this.options.get('host');
-
-    const tryListen = (retryCount = 1) =>
-      new Promise((resolve, reject) => {
-        super.once('error', reject);
-        super.once('listening', resolve);
-        super.listen(port, host);
-      })
-      .catch(err => matches(err)(
-        (e = {code: 'EADDRINUSE'}) => {
-          if (retryCount > LISTEN_RETRY_MAX) throw e;
-
-          this.log.error({
-            message: `Port (${port}) in use, retrying...`,
-            suffix: `${retryCount} / ${LISTEN_RETRY_MAX}`
-          });
-          return setAsyncTimeout(() => tryListen(++retryCount), LISTEN_RETRY_DELAY);
-        },
-        (e) => {
-          throw e;
-        }
-      ))
-      .catch(async e => {
-        await this.close();
-        throw e;
-      });
-
-    await tryListen();
-    return this;
-  }
-
-  async close() {
-    const tryClose = () => new Promise((resolve) => {
-      super.close(err => {
-        if (err) {
-          this.debugLog.error(err);
-        }
-        resolve();
-      });
-    });
-
-    await tryClose();
-  }
-}
-
-module.exports = Server;
--- a/src/server/index.test.js
+++ b/src/server/index.test.js
@@ -1,23 +0,0 @@
-
-const Server = require('./');
-
-describe('Server', function () {
-  let server;
-
-  beforeAll(function () {
-    server = new Server({
-      port: 8880
-    });
-  });
-
-  afterAll(async function () {
-    const value = await server.close();
-    console.log(value)
-  });
-
-  describe('.listen', function () {
-    it('# listens', async function () {
-      await server.listen();
-    });
-  });
-});
--- a/Show More
+++ b/Show More
Author	SHA1	Message	Date
Tyler Stewart	0b9167e1e4	fix: explicitly promisify fs methods `promisifyAll` will throw if a method with the suffix `Async` already exists. Fixes: https://github.com/trs/ftp-srv/pull/159	2019-08-22 14:57:40 -06:00
Tyler Stewart	484409d2eb	feat: allow connecting from local	2019-08-22 14:57:40 -06:00
Tyler Stewart	5ffcef3312	fix: dont format message is empty	2019-08-22 14:57:40 -06:00
Tibor Papp	290769a042	Possibility to send back empty message	2019-08-22 14:57:40 -06:00
Tibor Papp	a1c7f2ffda	Return response when folder is empty. If we do not send back a response, some FTP clients can fail, when they use encryption.	2019-08-22 14:57:40 -06:00
Tyler Stewart	7153ffab4d	chore: npm audit	2019-08-22 14:57:40 -06:00
Tyler Stewart	c0e132b70e	fix: ensure valid fs path resolution	2019-08-22 14:57:40 -06:00
Tyler Stewart	e661bd10e2	fix: remove socket encoding By setting the encoding, there becomes issues with binary transfers (such as photos).	2019-08-22 14:57:40 -06:00
Tyler Stewart	bece42a0c9	feat: close passive server when client disconnects Since a passive server is created for an individual client, when it disconnects from the server we can assume the server is done and should close it.	2019-08-22 14:57:40 -06:00
Tyler Stewart	b1fe56826c	feat: disconnect passive server after timeout If no client connects within 30 seconds of requesting, close the server. This prevents multiple servers from being created and never closing.	2019-08-22 14:57:40 -06:00
Tyler Stewart	16dbc7895c	chore: audit fix	2019-06-21 14:37:56 -06:00
Tyler Stewart	94f0b893e4	fix: enable better concurrent port search Creates a new instance of a server each time the port search is called. This ensures that concurrent calls to this function wont hang or produce `ERR_SERVER_ALREADY_LISTEN`	2019-06-21 14:37:56 -06:00
Tyler Stewart	79d7bd9062	chore: ensure correct test path	2019-06-21 14:37:56 -06:00
Tyler Stewart	44999c714d	fix(stor): ensure rejection after destroy	2019-06-21 14:37:56 -06:00
Tyler Stewart	0d9131c370	chore: simplify circle config	2019-03-08 11:14:42 -07:00
Tyler Stewart	eafaf6f642	chore: drop testing of node v6	2019-03-08 11:00:56 -07:00
Tyler Stewart	ea99e6ebbd	chore: fix circle ci node_modules persistance	2019-03-08 10:47:55 -07:00
Tyler Stewart	342911eb36	fix: dont specify host when port searching (#158 ) fix: handle errors on pasv/port commands	2019-03-08 17:40:48 +00:00
ls	0094614ee3	feat: socket timeout (#154 ) * feat: managed new param socketTimeout expressed in ms * feat: changed README.md * feat: changed README.md * feat: minor change * feat: pull request changes * feat: timeout value is set on 'options' object	2019-03-04 16:45:27 +00:00
Jean Gregory	0773967ba5	fix: find available port using hostname (#155 ) The passive url is passed to getNextPortFactory so in passive mode, the opening of a listening port fail when the passive url is not the ip of an interface on the ftp server host machine.	2019-03-02 22:56:09 +00:00
Tyler Stewart	e5820688c4	feat: remove pasv url resolution (#153 ) * fix: correctly try additional ports on EADDRINUSE * feat: remove passive url host resoltion See: https://github.com/trs/ftp-srv/issues/139 * feat: require pasv url to be specified * fix(pasv): check for set pasv url * chore: update scripts * fix(cli): remove undefined values * chore: add cli to eslint verify * chore: run eslint * chore: update scripts * feat: add maximum number of retries to port selection * chore: simplify eslint config * chore: simplify dev dependencies * chore: generate contributors * chore: update readme contributors * chore: add verify step to release BREAKING CHANGE: remove ipify.org automatic resolution of ip	2019-02-21 18:50:16 +00:00
Tyler Stewart	a3fa1a2f71	Merge pull request #152 from trs/revert-143-remove-pasv-url-resolution fix: revert "feat: remove host resolution"	2019-02-21 18:43:28 +00:00
Tyler Stewart	e540822d5b	Revert "feat: remove host resolution (#143 )" This reverts commit `36f331d15d`.	2019-02-21 11:42:32 -07:00
Tyler Stewart	36f331d15d	feat: remove host resolution (#143 ) * fix: correctly try additional ports on EADDRINUSE * feat: remove passive url host resoltion See: https://github.com/trs/ftp-srv/issues/139 * feat: require pasv url to be specified * fix(pasv): check for set pasv url * chore: update scripts * fix(cli): remove undefined values * chore: add cli to eslint verify * chore: run eslint * chore: update scripts * feat: add maximum number of retries to port selection * chore: simplify eslint config * chore: simplify dev dependencies * chore: generate contributors * chore: update readme contributors	2019-02-21 18:39:07 +00:00
Devonte	03ff982959	fix: correct writable checks (#147 ) fix: correct writable checks	2019-02-21 18:30:58 +00:00
Sergey Kuvakin	8c8f3922a3	feat: expose a RNTO event (#151 ) * feat(commands): expose a RNTO event, updated a readme file * feat(commands): fixed test for the RNTO * chore: fixed prepush errors * fix: turnback spaces into a README.md	2019-02-21 18:04:01 +00:00
zGwit	eca26ee86a	fix: close connection on timeout (#145 ) * Close connection when timeout * Add promise processing	2019-01-17 02:44:48 +00:00
David Van Gompel	811db7b1a7	fix: add correct typing for tls option (#141 )	2019-01-16 23:55:20 +00:00
Tyler Stewart	ab085a1bca	chore: remove npm-run-all Late to the party, but removes dev dependency `npm-run-all` to avoid malicious package	2018-12-21 15:49:38 -07:00
Robert Kieffer	a5f26480e5	fix(cli): correct --root flag logic (#135 ) Fixes #134	2018-12-21 22:44:13 +00:00
Mike Estes	e41b04be46	fix: add pasv_url to typescript definitions (#131 )	2018-11-19 09:49:43 -07:00
Tyler Stewart	7acf861a4d	fix(cli): correctly setup server, add pasv options (#130 )	2018-11-19 09:48:24 -07:00
Tyler Stewart	4801ecc0cc	fix: correct timeouts around TLS data connection (#128 ) * fix: timeouts when using tls * fix: correct tls connection * fix(connector): dont prematurely destroy socket * fix(passive): set connected if not tls * refactor: dont return promises on connector end Since we're not waiting, we don't need to return promises	2018-11-12 03:19:57 +00:00
Qian.Sicheng	8e34e4c71a	fix: correct type definitions (#125 ) * fix types of server options * fix usage of server options	2018-11-07 08:29:37 -07:00
Tyler Stewart	0afd578683	chore: update semantic-release (#124 )	2018-10-30 01:48:36 +00:00
Tyler Stewart	46b0d52ff2	fix: improve uploading of files	2018-10-30 01:38:59 +00:00
Tyler Stewart	185e473edc	chore: update test example	2018-10-30 01:38:59 +00:00
Tyler Stewart	92a323f3dd	chore: update fs method links	2018-10-30 01:38:59 +00:00
Tyler Stewart	f67e487306	test: update tests	2018-10-30 01:38:59 +00:00
Tyler Stewart	2716123da7	chore: add Johnnyrook777 to contributors	2018-10-30 01:38:59 +00:00
Tyler Stewart	ef207f60c1	feat: replace `tls` options with actual tls `SecureContext` https://github.com/trs/ftp-srv/pull/108 BREAKING CHANGE: tls options no longer assume file paths are passed for key, ca, and cert. Options are passed directly to `tls.createServer`. See: https://nodejs.org/api/tls.html#tls_tls_createsecurecontext_options	2018-10-30 01:38:59 +00:00
Tyler Stewart	4d8cf42ad0	chore: update readme with changed options	2018-10-30 01:38:59 +00:00
Tyler Stewart	50c6b92d12	fix: improve connection close events and handlers (#123 ) * (fix) base: set datasocket to null once destroyed (#119) Ensure new sockets get created when uploading files by setting the datasocket to null after its destroyed * fix(stor): use the close event (#118) The 'end' event is not called when using SSL. Should use the 'close' event * refactor(list): chained promises with less depth (#117) * Update list.js Tidy up of the List function. Makes the intent of the method clearer, as there are less nested promises * refactor(list): chained promises with less depth * refactor: fixup formatting * test: update test file config	2018-10-25 10:25:52 -06:00
Tyler Stewart	a2103e5a3c	fix: command parse ignores flags on RETR and SIZE (#122 ) * fix: command parse ignores flags on RETR and SIZE (#121) fixes #120 * refactor: upper directive before checking flag parse * test: add test for command option parse * feat: restrict command flags to single dash, single character Only parse `-x` style flags.	2018-10-25 10:25:32 -06:00
Mark Wheeldon	2302b749fa	fix(connector): gracefully end data socket (#116 ) Fixes GnuTLS error -110: The TLS connection was non-properly terminated issue	2018-09-21 13:54:59 -06:00
Tyler Stewart	27b43d702b	chore: update scripts	2018-09-02 16:20:48 +00:00
Tyler Stewart	fae003e644	test(passive): correctly close test connections	2018-09-02 16:20:48 +00:00
Tyler Stewart	a51678ae70	feat: start pasv port selection from last checked port (#111 ) * Update find-port.js Reuse the Port Number Generator * feat(passive): initialize port factory in server Ensures that each passive connection does not have to start from the beginning of the pasv port range https://github.com/trs/ftp-srv/pull/110 * fix(connector): ensure data socket is destroyed and resolved If there was a data socket, this would never resolve * test: use bluebird promises for tests, fix stubs * fix(commands): ensure connector is ended before resuming	2018-09-02 16:20:48 +00:00
Tyler Stewart	bc26886a0d	fix(fs): wrap fs methods in try This handles throwing better than `resolve`	2018-09-02 16:20:48 +00:00
Tyler Stewart	c9b4371579	feat: respond with full paths in STOR/RETR (#95 ) Emit and reply with the full paths to the files. BREAKING CHANGE: fs expects an object `{stream, clientPath}` in response to `.read()` and `.write()`. This is implemented in a backwards compatible way, and works with the old `fs` implementation. But since this may break builds in unintented ways.	2018-09-02 16:20:48 +00:00
Tyler Stewart	95471bdd15	test: update tests with refactors	2018-09-02 16:20:48 +00:00
Tyler Stewart	5a36a6685d	refactor(passive): increment passive connection ports Using a generator, will loop through min and max ports in order This should be faster and more efficient since it starts after the last valid port meaning it has a higher chance of being valid	2018-09-02 16:20:48 +00:00
Tyler Stewart	90a7419661	feat: change server options BREAKING CHANGE: some options have moved or been renamed	2018-09-02 16:20:48 +00:00
Tyler Stewart	29cb035f66	chore: migration guide v2 to v3	2018-09-02 16:20:48 +00:00
Tyler Stewart	66fc66ed80	fix(connector): build passive server correctly for tls (#106 ) * fix(connector): build passive server correctly for tls Fixes an issue where passive tls connections would never be fulfilled. This uses `tls` to create a server if the connection is secure, which allows an ftp client to connect correctly * test: stop skipping explicit tests	2018-08-08 19:07:06 -06:00
Tyler Stewart	c970a42132	chore(package): update package lock (#107 ) Fixes vulnerabilities in packages	2018-08-08 19:04:38 -06:00
Tim Lundqvist	30ae54a952	fix: better typings for EventEmitter inheritance (#105 )	2018-07-24 11:46:03 -06:00
Tyler Stewart	91be338ebd	fix: expose errors as export	2018-07-22 18:47:23 -06:00
Tyler Stewart	2a5013447c	fix: fix event emitter extension typing	2018-07-22 18:44:15 -06:00
alancnet	1f15af0fb6	fix(cli): resolve authentication bug (#94 ) cli would reject all logins with `530 Cannot destructure property `password` of 'undefined' or 'null'.` because the credentials object was being indexed with `[object Object]`. Even with that fixed, if the username was not found, it would produce that error.	2018-06-08 01:52:51 +00:00
Tyler Stewart	1cf1f750f4	chore(readme): update contributors	2018-06-02 18:51:27 +00:00
Diego Rodríguez Baquero	442490d713	chore(readme): correct word and improve events (#91 )	2018-06-02 18:51:27 +00:00
Tyler Stewart	58b9ba27d9	test(fs): add fs tests	2018-05-31 14:28:10 +00:00
Tyler Stewart	87a2138cb3	fix(fs): improve path resolution	2018-05-31 14:28:10 +00:00
Tyler Stewart	9fd423c745	docs: fix circle ci badge Links only to master branch	2018-05-25 17:34:25 -06:00
Tyler Stewart	363839ec8f	chore: fix markdown newlines	2018-05-25 22:50:01 +00:00
Tyler Stewart	d9fc0c9cac	feat: pasv_url option to send to client This has passive connections to listen on the same hostname as the server. But allows this to be customized via the `pasv_url` option. Hostnames are no longer resolved if given `0.0.0.0`, except when being given to the client via `PASV`	2018-05-25 22:50:01 +00:00
Tyler Stewart	b0463d65b6	fix(passive): listen on server hostname	2018-05-25 22:50:01 +00:00
Tyler Stewart	47b2cc0593	chore(readme): add cli documentation	2018-05-18 21:21:43 +00:00
Tyler Stewart	e5f24f991d	refactor(cli): update state management, call ftp methods	2018-05-18 21:21:43 +00:00
Edin Mujagic	87f3ae79a1	feat(cli): add cli support for ftp-srv	2018-05-18 21:21:43 +00:00
Tyler Stewart	3a7b3d4570	chore(circle): update circle config	2018-05-18 20:53:01 +00:00
Tyler Stewart	dc040eaabd	chore: remove unused dev packages/settings	2018-05-18 20:53:01 +00:00
Tyler Stewart	fecec961e1	docs(contributing): update contribution guide This was an auto generated document, actually make it	2018-05-18 20:53:01 +00:00
Tyler Stewart	5ff677ce42	fix(passive): improve remoteAddress comparisons Instead of a direct equal comparison, use the `ip` package	2018-05-18 20:53:01 +00:00
Tyler Stewart	cc0f2a5cd3	feat: set hostname to listen on By default, `net.Server` listens on `0.0.0.0`, which is any available address. This ensures that ftp-srv only listens on the set hostname.	2018-05-18 20:53:01 +00:00
Tim Lundqvist	414433a56e	fix: reject on server listen error See trs/ftp-srv#84	2018-05-18 20:53:01 +00:00
Tyler Stewart	a794f1e5b3	test: fix tests	2018-05-07 11:08:16 -06:00
Mateusz Kucharczyk	1b5d22a3ca	fix(typings): updated typescript typings to allow compiling with noImplicitAny option enabled	2018-05-07 10:07:31 -06:00
Jorin Vogel	4205caf7ac	fix(rest): small typo	2018-03-29 23:27:33 -06:00