functionalmongo.js

/*
// Ideia de uso:

const fmongo = FunctionalMongo('mongodb://0.0.0.0:27017/yhub')
    .collect('User')
    .byId({ id })

*/

import { curry, objOf } from 'ramda'
import { MongoClient } from 'mongodb'

const _connect = curry((uri, options = { useNewUrlParser: true }) => MongoClient.connect(uri, options))

const _collection = curry((connection, collectionName) => connection.collection(collectionName))

const _FunctionalMongo = async (uri, options) => {
    const client = await _connect(uri, options);
    const connection = client.db();
    
    return objOf(
        'collect',
        (collectionName) => {
            const collection = await _collection(connection, collectionName)
            return objOf(
                'byId',
                (identifier) => collection.find(identifier)
            )
        }
    )
}

export default curry(_FunctionalMongo)