o.js

var loopWhile = require('deasync').loopWhile;

function block() {
  var done = false;
  this.start = function() {
    done = false;
  };
  this.wait = function() {
    loopWhile(() => !done);
  };
  this.done = function() {
    done = true;
  };
}

var _revoke_all = args => args.map(a => (a && ['object', 'function'].includes(typeof a) && a.__PROXY_TARGET__) || a);

function syncCallback(f) {
  var b = new block();
  return function(...args) {
    if (args.length >= f.length) {
      return f(...args);
    }
    var result;
    var error;
    args[f.length - 1] = function(err, res) {
      b.done();
      err ? (error = err) : (result = res);
    };
    b.start();
    f.apply(this, args);
    b.wait();
    if (error) throw error;
    return result;
  };
}

function syncPromise(t) {
  if (typeof t === 'object' && t != null) {
    return new Proxy(t, {
      get: function(target, name) {
        if (name === '__PROXY_TARGET__') return t;
        if ((name !== 'o' && name !== 'oo') || !('then' in target) || name in target) {
          return syncPromise(target[name]);
        }
        var error, result;
        var b = new block();
        b.start();
        target
          .then(res => {
            result = res;
            b.done();
          })
          .catch(err => {
            error = err;
            b.done();
          });
        b.wait();
        if (error) {
          throw error;
        }
        return name==='oo'? result : syncPromise(result);
      },
    });
  }

  if (typeof t === 'function') {
    return new Proxy(
      function(...args) {
        var _t = (this && this.__PROXY_TARGET__) || this;
        var result = t.apply(_t, _revoke_all(args));
        return syncPromise(result);
      },
      {
        get: function(_, name) {
          if (name === '__PROXY_TARGET__') return t;
          if (name === 'call' || name === 'apply') {
            return function(...args) {
              return syncPromise(t[name](..._revoke_all(args)));
            };
          }
          return syncPromise(t[name]);
        },
      }
    );
  }

  return t;
}

module.exports = {
  syncCallback,
  syncPromise,
  sp: syncPromise,
  sc: syncCallback,
};