package org.jruby.ir.targets;

import com.headius.invokebinder.Binder;
import org.jruby.ir.runtime.IRRuntimeHelpers;
import org.jruby.runtime.Block;
import org.jruby.runtime.BlockBody;
import org.jruby.runtime.CompiledIRBlockBody;
import org.jruby.runtime.ThreadContext;
import org.jruby.runtime.builtin.IRubyObject;
import org.jruby.util.cli.Options;
import org.jruby.util.log.Logger;
import org.jruby.util.log.LoggerFactory;
import org.objectweb.asm.Handle;
import org.objectweb.asm.Opcodes;

import java.lang.invoke.CallSite;
import java.lang.invoke.MethodHandle;
import java.lang.invoke.MethodHandles;
import java.lang.invoke.MethodType;
import java.lang.invoke.MutableCallSite;

import static org.jruby.util.CodegenUtils.p;
import static org.jruby.util.CodegenUtils.sig;

Created by headius on 1/8/16.
/**
 * Created by headius on 1/8/16.
 */
public class YieldSite extends MutableCallSite {
    private final boolean unwrap;
    private int bindCount;

    private static final int MAX_REBIND = 2;

    private static final Logger LOG = LoggerFactory.getLogger(YieldSite.class);

    public YieldSite(MethodType type, boolean unwrap) {
        super(type);

        this.unwrap = unwrap;
    }

    public static final Handle BOOTSTRAP = new Handle(
            Opcodes.H_INVOKESTATIC,
            p(YieldSite.class),
            "bootstrap",
            sig(CallSite.class, MethodHandles.Lookup.class, String.class, MethodType.class, int.class),
            false);

    public static CallSite bootstrap(MethodHandles.Lookup lookup, String name, MethodType type, int unwrap) throws Throwable {
        YieldSite site = new YieldSite(type, unwrap == 1 ? true : false);

        MethodHandle handle;
        switch (name) {
            case "yield":
            case "yieldSpecific":
                handle = Binder.from(type)
                        .prepend(YieldSite.class, site)
                        .invokeVirtual(lookup, name);
                break;
            case "yieldValues":
                handle = Binder.from(type)
                        .collect(2, IRubyObject[].class)
                        .prepend(YieldSite.class, site)
                        .invokeVirtual(lookup, name);
                break;
            default:
                throw new RuntimeException("invalid yield type: " + name);
        }

        site.setTarget(handle);

        return site;
    }

    public IRubyObject yield(ThreadContext context, Block block, IRubyObject arg) throws Throwable {
        if (Options.INVOKEDYNAMIC_YIELD.load()) {
            if (++bindCount >= MAX_REBIND) {
                if (Options.INVOKEDYNAMIC_LOG_BINDING.load()) {
                    LOG.info("yield \tdisabled due to polymorphism:" + Bootstrap.logBlock(block));
                }
            } else {
                BlockBody body = block.getBody();
                MethodHandle target;

                if (block.getBody() instanceof CompiledIRBlockBody) {
                    CompiledIRBlockBody compiledBody = (CompiledIRBlockBody) block.getBody();

                    if (Options.INVOKEDYNAMIC_LOG_BINDING.load()) {
                        LOG.info("yield \tbound directly as yield:" + Bootstrap.logBlock(block));
                    }

                    target = unwrap ? compiledBody.getNormalYieldUnwrapHandle() : compiledBody.getNormalYieldHandle();
                } else {
                    if (Options.INVOKEDYNAMIC_LOG_BINDING.load()) {
                        LOG.info("yield \tbound indirectly as yield:" + Bootstrap.logBlock(block));
                    }

                    target = Binder.from(type())
                            .append(unwrap)
                            .invokeStaticQuiet(MethodHandles.lookup(), IRRuntimeHelpers.class, "yield");
                }

                MethodHandle fallback = getTarget();
                MethodHandle test = body.getTestBlockBody();

                MethodHandle guard = MethodHandles.guardWithTest(test, target, fallback);

                setTarget(guard);

                return (IRubyObject) target.invokeExact(context, block, arg);
            }
        }

        return IRRuntimeHelpers.yield(context, block, arg, unwrap);
    }

    public IRubyObject yieldSpecific(ThreadContext context, Block block) throws Throwable {
        if (Options.INVOKEDYNAMIC_YIELD.load()) {
            if (++bindCount >= MAX_REBIND) {
                if (Options.INVOKEDYNAMIC_LOG_BINDING.load()) {
                    LOG.info("yield \tdisabled due to polymorphism:" + Bootstrap.logBlock(block));
                }
            } else {
                BlockBody body = block.getBody();
                MethodHandle target;

                if (block.getBody() instanceof CompiledIRBlockBody) {
                    CompiledIRBlockBody compiledBody = (CompiledIRBlockBody) block.getBody();

                    if (Options.INVOKEDYNAMIC_LOG_BINDING.load()) {
                        LOG.info("yield \tbound directly as yieldSpecific:" + Bootstrap.logBlock(block));
                    }

                    target = compiledBody.getNormalYieldSpecificHandle();
                } else {
                    if (Options.INVOKEDYNAMIC_LOG_BINDING.load()) {
                        LOG.info("yield \tbound indirectly as yieldSpecific:" + Bootstrap.logBlock(block));
                    }

                    target = Binder.from(type())
                            .permute(1, 0)
                            .invokeVirtualQuiet(MethodHandles.lookup(), "yieldSpecific");
                }

                MethodHandle fallback = getTarget();
                MethodHandle test = body.getTestBlockBody();

                MethodHandle guard = MethodHandles.guardWithTest(test, target, fallback);

                setTarget(guard);

                return (IRubyObject) target.invokeExact(context, block);
            }
        }

        return block.yieldSpecific(context);
    }

    public IRubyObject yieldValues(ThreadContext context, Block block, IRubyObject[] args) {
        if (Options.INVOKEDYNAMIC_YIELD.load()) {
            if (Options.INVOKEDYNAMIC_LOG_BINDING.load()) {
                LOG.info("yield \tbound indirectly as yieldValues:" + Bootstrap.logBlock(block));
            }
        }

        return block.yieldValues(context, args);
    }
}