refactor(main): expose IO modules

package.json

@@ -23,7 +23,7 @@
   "engines": {
     "node": ">= 5.0.0"
   },
-  "main": ".dist/index.js",
+  "main": ".dist/Main.js",
   "dependencies": {
     "graceful-fs": "^4.1.3",
     "humanize-plus": "^1.8.1",

src/IO.js

@@ -0,0 +1,40 @@
+'use strict'
+
+import {Observable as O} from 'rx'
+import * as Rx from './RxFP'
+import {demux} from 'muxer'
+import R from 'ramda'
+import {Request} from './Request'
+
+export const fromCB = R.compose(R.apply, O.fromNodeCallback)
+export const toOB = cb => R.compose(
+  Rx.shareReplay(1),
+  Rx.flatMap(fromCB(cb))
+)
+export const FILE = R.curry((fs) => {
+  return {
+    // New Methods
+    open: toOB(fs.open),
+    fstat: toOB(fs.fstat),
+    read: toOB(fs.read),
+    write: toOB(fs.write),
+    close: toOB(fs.close),
+    truncate: toOB(fs.truncate),
+    rename: toOB(fs.rename)
+  }
+})
+
+export const HTTP = R.curry((_request) => {
+  const request = Request(_request)
+  const requestHead = (params) => {
+    const [{response$}] = demux(request(params), 'response$')
+    return response$.first().tap(x => x.destroy()).share()
+  }
+
+  const select = R.curry((event, request$) => request$.filter(x => x.event === event).pluck('message'))
+  return {
+    requestHead,
+    select,
+    request
+  }
+})

src/index.js → src/Main.js

@@ -7,13 +7,14 @@ import fs from 'graceful-fs'
 import {Observable as O} from 'rx'
 import R from 'ramda'
 import * as U from './Utils'
-import * as T from './Transformers'
+import * as T from './IO'
 import {mux, demux} from 'muxer'
 
-export const Utils = U
+export const UTILS = U
 export const createDownload = (_options) => {
-  const [HTTP] = T.HTTP(request)
-  const [FILE] = T.FILE(fs)
+
+  const HTTP = T.HTTP(request)
+  const FILE = T.FILE(fs)
   const options = U.MergeDefaultOptions(_options)
 
   /**
@@ -36,7 +37,11 @@ export const createDownload = (_options) => {
    * Finalize Downloaded FILE
    */
   const finalizeDownload$ = downloadFromMTDFile$.last()
-    .withLatestFrom(fdR$, meta$, (_, fd, meta) => ({FILE, fd$: O.just(fd), meta$: O.just(meta)}))
+    .withLatestFrom(fdR$, meta$, (_, fd, meta) => ({
+      FILE,
+      fd$: O.just(fd),
+      meta$: O.just(meta)
+    }))
     .flatMap(U.FinalizeDownload)
     .share()
     .last()
@@ -48,9 +53,5 @@ export const createDownload = (_options) => {
     .map(R.tail)
     .flatMap(R.map(R.of))
   const closed$ = FILE.close(fd$)
-
-  /**
-   * Create Sink
-   */
-  return mux({response$, meta$, closed$})
+  return [mux({response$, meta$, closed$}), {FILE, HTTP, UTILS}]
 }

src/bin/mtd.js

@@ -11,7 +11,7 @@ import meow from 'meow'
 import humanize from 'humanize-plus'
 import newDownload from './NewDownload'
 import resumeDownload from './ResumeDownload'
-import {createDownload} from '../index'
+import {createDownload} from '../Main'
 import ProgressBar from 'progress'
 
 const flags = meow(`		

test/integration/test.observable.js → test/integration/test.IO.js

@@ -6,10 +6,10 @@
 import request from 'request'
 import {server} from '../../perf/server'
 import test from 'ava'
-import {HTTP} from '../../src/Transformers'
+import {HTTP} from '../../src/IO'
 import {demux} from 'muxer'
 
-const http = HTTP(request)[0]
+const http = HTTP(request)
 let closeHttp
 /*eslint-disable */
 test.before(async function () {

test/integration/test.mtd.js

@@ -6,7 +6,7 @@
 import Path from 'path'
 import test from 'ava'
 import {removeFile, createFileDigest} from '../../perf/TestHelpers'
-import {createDownload} from '../../src/index'
+import {createDownload} from '../../src/Main'
 import {server} from '../../perf/server'
 
 const pathFactory = () => {
@@ -35,7 +35,7 @@ test.after(async function () {
 })
 
 test('http', async function (t) {
-  await createDownload({url: 'http://localhost:3200/files/pug.jpg', path: path1}).toPromise()
+  await createDownload({url: 'http://localhost:3200/files/pug.jpg', path: path1})[0].toPromise()
   const digest = await createFileDigest(path1)
   t.deepEqual(digest, '25FD4542D7FFFB3AEC9EF0D25A533DDE4803B9C1')
 })
@@ -45,7 +45,7 @@ test('https', async function (t) {
     url: 'https://localhost:3201/files/pug.jpg',
     path: path2,
     strictSSL: false
-  }).toPromise()
+  })[0].toPromise()
   const digest = await createFileDigest(path2)
   t.deepEqual(digest, '25FD4542D7FFFB3AEC9EF0D25A533DDE4803B9C1')
 })
@@ -54,7 +54,7 @@ test('http(2)', async function (t) {
   await createDownload({
     url: 'http://localhost:3200/files/in.txt',
     path: path3
-  }).toPromise()
+  })[0].toPromise()
   const digest = await createFileDigest(path3)
   t.deepEqual(digest, 'A9070D71168B5135910A04F0650A91541B72762E')
 })