/* -*- mode: Java; c-basic-offset: 2; indent-tabs-mode: nil; coding: utf-8-unix -*-
 *
 * Copyright © 2025–2026 microBean™.
 *
 * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
 * the License. You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
 * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
 * specific language governing permissions and limitations under the License.
 */
package org.microbean.clientproxy.bytebuddy;

import java.lang.invoke.MethodHandles;
import java.lang.invoke.MethodHandles.Lookup;

import java.util.Map;
import java.util.Objects;

import java.util.concurrent.ConcurrentHashMap;

import java.util.function.Supplier;

import net.bytebuddy.dynamic.DynamicType;

import net.bytebuddy.dynamic.loading.ClassLoadingStrategy;

import net.bytebuddy.pool.TypePool;

import org.microbean.bean.Id;

import org.microbean.construct.Domain;

import org.microbean.proxy.AbstractToolkitProxier;
import org.microbean.proxy.Proxy;
import org.microbean.proxy.ProxySpecification;

import org.microbean.reference.ClientProxier;
import org.microbean.reference.ReferenceException;

import static java.lang.invoke.MethodType.methodType;

import static java.util.Objects.requireNonNull;

/**
 * An {@link AbstractToolkitProxier} and {@link ClientProxier} that uses <a href="https://bytebuddy.net/#/">Byte
 * Buddy</a> to {@linkplain #generate(ProxySpecification) generate} {@linkplain org.microbean.proxy.Proxy client
 * proxies}.
 *
 * @author <a href="https://about.me/lairdnelson" target="_top">Laird Nelson</a>
 *
 * @see BBClientProxyClassGenerator
 */
public final class BBClientProxier extends AbstractToolkitProxier<ProxySpecification, DynamicType.Unloaded<?>> implements ClientProxier {

  private static final Map<ProxySpecification, Object> clientProxyInstances = new ConcurrentHashMap<>();

  private final TypeDefinitions tds;

  private final BBClientProxyClassGenerator g;

  /**
   * Creates a new {@link BBClientProxier}.
   *
   * @param domain a non-{@code null} {@link Domain}
   *
   * @exception NullPointerException if any argument is {@code null}
   *
   * @see TypeElementTypePool#TypeElementTypePool(Domain)
   *
   * @see #BBClientProxier(Domain, TypePool)
   */
  public BBClientProxier(final Domain domain) {
    this(domain, new TypeElementTypePool(domain));
  }

  /**
   * Creates a new {@link BBClientProxier}.
   *
   * @param domain a non-{@code null} {@link Domain}
   *
   * @param typePool a non-{@code null} {@link TypePool}
   *
   * @exception NullPointerException if any argument is {@code null}
   *
   * @see TypeDefinitions#TypeDefinitions(TypePool)
   *
   * @see BBClientProxyClassGenerator#BBClientProxyClassGenerator(TypePool)
   *
   * @see #BBClientProxier(Domain, TypeDefinitions, BBClientProxyClassGenerator)
   */
  public BBClientProxier(final Domain domain,
                         final TypePool typePool) {
    this(domain, new TypeDefinitions(typePool), new BBClientProxyClassGenerator(typePool));
  }

  /**
   * Creates a new {@link BBClientProxier}.
   *
   * @param domain a non-{@code null} {@link Domain}; must not be {@code null}
   *
   * @param tds a non-{@code null} {@link TypeDefinitions}
   *
   * @param g a non-{@code nulll} {@link BBClientProxyClassGenerator}
   *
   * @exception NullPointerException if any argument is {@code null}
   */
  public BBClientProxier(final Domain domain,
                          final TypeDefinitions tds,
                          final BBClientProxyClassGenerator g) {
    super(domain, MethodHandles.lookup());
    this.tds = requireNonNull(tds, "tds");
    this.g = requireNonNull(g, "g");
  }

  @Override // ClientProxier
  public <R> R clientProxy(final Id id, final Supplier<? extends R> instanceSupplier) {
    return this.proxy(new ProxySpecification(this.domain(), id), instanceSupplier).$cast();
  }

  @Override // AbstractClientProxier<DynamicType.Unloaded<?>>
  protected final DynamicType.Unloaded<?> generate(final ProxySpecification ps) {
    return
      this.g.generate(ps.name(),
                      this.tds.typeDescription(ps.superclass()),
                      ps.interfaces().stream().map(this.tds::typeDescriptionGeneric).toList());
  }

  @Override // AbstractToolkitProxier<ProxySpecification, DynamicType.Unloaded<?>>
  @SuppressWarnings("unchecked")
  public final <R> Proxy<R> proxy(final ProxySpecification ps, final Supplier<? extends R> instanceSupplier) {
    return (Proxy<R>)clientProxyInstances.computeIfAbsent(ps, ps0 -> {
        try {
          final Class<?> proxyClass = this.proxyClass(ps);
          this.getClass().getModule().addReads(proxyClass.getModule());
          return
            this.lookup(proxyClass).findConstructor(proxyClass, methodType(void.class, Supplier.class))
            .asType(methodType(Object.class, Supplier.class))
            .invokeExact(instanceSupplier);
        } catch (final RuntimeException | Error e) {
          throw e;
        } catch (final Throwable e) {
          throw new ReferenceException(e.getMessage(), e);
        }
      });
  }

  @Override // AbstractClientProxier<DynamicType.Unloaded<?>>
  protected final Class<?> proxyClass(final DynamicType.Unloaded<?> dtu, final ClassLoader cl)
    throws ClassNotFoundException {
    // getTypeName() invoked on a TypeDescription will be its binary name (required by Class#forName(String)):
    // https://javadoc.io/static/net.bytebuddy/byte-buddy/1.17.3/net/bytebuddy/description/type/TypeDefinition.html#getTypeName--
    final String binaryName = dtu.getTypeDescription().getSuperClass().asErasure().getTypeName();
    final Class<?> superclass = Class.forName(binaryName, false, cl);
    return dtu.load(superclass.getClassLoader(), ClassLoadingStrategy.UsingLookup.of(lookup(superclass))).getLoaded();
  }

}