(function() {
    'use strict';
    
    var DIR         = '../../../',
        DIR_SERVER  = DIR + 'server/',
        
        path        = require('path'),
        fs          = require('fs'),
        
        CloudFunc   = require(DIR + 'cloudfunc'),
        Util        = require(DIR + 'util'),
        
        flop        = require(DIR_SERVER + 'flop'),
        pack        = require(DIR_SERVER + 'pack'),
        pipe        = require(DIR_SERVER + 'pipe'),
        patch       = require(DIR_SERVER + 'patch');
        
    module.exports  = function(query, name, readStream, callback) {
        var baseName    = path.basename(name),
            onDone      = function(msg, error) {
                if (!error)
                    msg     = CloudFunc.formatMsg(msg, baseName);
                
                callback(error, msg); 
            },
            onSave      = Util.exec.with(onDone, 'save'),
            OnMakeDir   = Util.exec.with(onDone, 'make dir');
        
        Util.checkArgs(arguments, ['query', 'name', 'readStream', 'callback']);
        
        switch(query) {
        default:
            pipe.create(readStream, name, onSave);
            break;
        
        case 'dir':
            flop.create(name, 'dir', OnMakeDir);
            break;
        
        case 'file':
            fs.writeFile(name, '', callback);
            break;
        
        case 'unzip':
            pack.gunzip(readStream, name, onSave);
            break;
        
        case 'patch':
            pipe.getBody(readStream, function(error, data) {
                var options = {
                    size: CloudFunc.MAX_FILE_SIZE
                };
                
                patch(name, data, options, function(error) {
                    var msg;
                    
                    if (!error)
                        msg = CloudFunc.formatMsg('patch', baseName);
                    
                    callback(error, msg);
                });
            });
            break;
        }
    };
})();