TestConnector.js

const path = require("path");
const fs   = require("fs");
const md5  = require("md5");
const cp   = require('child_process');

var TestConnector = function()
{
    this.fetch = function(url,options)
    {

        try
        {
            if(TestConnector.test_base_dir == "")
                throw "You need to set TestConnector.test_base_dir to __dirname from inside your test script";

            var fixture_path = TestConnector.fixturePath(TestConnector.test_base_dir,url,options);
            var output = "";

            if(TestConnector.nocache)
                throw new Error("Force load");

            var output = fs.readFileSync(fixture_path).toString();
        }
        
        catch(e)
        {
            var live_url = url.replace("key=dummy&token=dummy","key="+TestConnector.live_key+"&token="+TestConnector.live_token);
            var header_string = "";
            var std_data = true;
            
            if(options.headers)
            {
                header_string = '--header "'+new IterableCollection(options.headers).implodeValues('" --header "',function(elem,key)
                {
                    return key+": "+elem;
                })+'" ';
            }

            if(options.payload)
            {
                if(options.headers)
                {
                    if(options.headers["content-type"] == "application/json")
                    {
                        std_data = false;
                        
                        try
                        {
                            options.payload = JSON.parse(options.payload);
                        }
                        
                        catch(e)
                        {
                        }

                        var data_string = JSON.stringify(new IterableCollection(options.payload).find(function(elem,key)
                        {   
                            if(key == "key")
                                return TestConnector.live_key;
                            else if(key == "token")
                                return TestConnector.live_token;
                            else
                                return elem;
                        }).obj);
                    }
                }
                
                if(std_data)
                {
                    var data_string = new IterableCollection(options.payload).implode("&",function(elem,key)
                    {
                        if(key == "key")
                            return TestConnector.live_key;
                        else if(key == "token")
                            return TestConnector.live_token;
                        else
                            return encodeURIComponent(elem);
                    });
                }
                
                var cmd = 'curl '+header_string+'--data "'+data_string.split('"').join('\\"')+'" --request '+options.method.toUpperCase()+" --url \""+live_url+'\"';
            }
            
            else
                var cmd = "curl "+header_string+"--request "+options.method.toUpperCase()+" --url \""+live_url+'\"';

            var stdout = cp.execSync(cmd,{ stdio: ['pipe', 'pipe', 'ignore']});
            
            if(stdout)
            {
                if((TestConnector.test_base_dir != "") && (!TestConnector.nocache))
                {
                    fs.writeFileSync(fixture_path,stdout);
                    var output = fs.readFileSync(fixture_path).toString();
                }
                
                else
                    var output = stdout.toString();

                try
                {
                    JSON.parse(stdout);
                }
                
                catch(e)
                {
                    throw new InvalidRequestException(stdout);
                }

            }
        }

        if(!output)
        {
            console.log("No test return content for: "+fixture_path);
            console.log(JSON.stringify(options));
            console.log(url);
            console.log("Output: "+output);
        }

        return output;
    }
}

TestConnector.sequencer = 0;
TestConnector.use_sequencer = false;
TestConnector.test_base_dir = "";
TestConnector.live_key      = process.argv[2];
TestConnector.live_token    = process.argv[3];
TestConnector.prefix        = "";
TestConnector.nocache       = false;

TestConnector.fixturePath = function(base_dir,url,options)
{
    var signature =  md5(url+JSON.stringify(options));
    
    if(TestConnector.use_sequencer)
    {
        signature = signature+TestConnector.sequencer.toString();
        TestConnector.sequencer++;
    }

    var api_cache_dir = path.resolve(base_dir,"./trello_api_fixtures/").toString();
    !fs.existsSync(api_cache_dir) && fs.mkdirSync(api_cache_dir);
    var fixture_dir = path.resolve(base_dir,"./trello_api_fixtures/"+path.basename(process.argv[1])).toString();
    !fs.existsSync(fixture_dir) && fs.mkdirSync(fixture_dir);
    var fixture_path = fixture_dir+"/"+TestConnector.prefix+signature;
    return fixture_path;
}

function writeInfo_(msg)
{
    console.log(msg);
}