import path from 'node:path';
import type { GraphNode, GraphRelationship } from 'gitnexus-shared';
import { beforeAll, describe, expect, it } from 'vitest';
import { runPipelineFromRepo } from '../../src/core/ingestion/pipeline.js';
import type { PipelineResult } from '../../src/types/pipeline.js';

const FIXTURE = path.resolve(__dirname, '..', 'fixtures', 'spring-destination-app');

/**
 * End-to-end cover for the `springDestinations` phase: capture facts in,
 * `Destination` nodes and `CONSUMES_FROM` / `PUBLISHES_TO` edges out.
 *
 * The negative assertions carry as much weight here as the positive ones. The
 * whole feature turns on one rule — an address that did not resolve must not be
 * able to connect two services — and the test that proves it is the pair of
 * unrelated consumers that each write `${app.messaging.shared-topic}` and
 * nothing else. If those ever land on one node, every other assertion in this
 * file can pass while the graph reports a connection that does not exist.
 */
describe('Spring destination resolution', () => {
  let result: PipelineResult;
  let destinations: GraphNode[];
  let messagingEdges: GraphRelationship[];

  beforeAll(async () => {
    result = await runPipelineFromRepo(FIXTURE, () => {}, {});
    destinations = [...result.graph.iterNodes()].filter((node) => node.label === 'Destination');
    messagingEdges = [...result.graph.iterRelationships()].filter(
      (edge) => edge.type === 'CONSUMES_FROM' || edge.type === 'PUBLISHES_TO',
    );
  }, 120_000);

  const withAddress = (address: string): GraphNode[] =>
    destinations.filter((node) => node.properties.address === address);

  /**
   * Nodes at one address on ONE broker — the exact identity.
   *
   * `withAddress` alone stopped being a unique lookup once the broker joined
   * the key: `orders.v1` is a Kafka topic AND an unrelated Rabbit queue in this
   * fixture, so an assertion that means "the Kafka topic" has to say so.
   */
  const withBrokerAddress = (broker: string, address: string): GraphNode[] =>
    withAddress(address).filter((node) => node.properties.broker === broker);

  const edgesTo = (node: GraphNode): GraphRelationship[] =>
    messagingEdges.filter((edge) => edge.targetId === node.id);

  const sourceNames = (node: GraphNode): string[] =>
    edgesTo(node)
      .map((edge) => String(result.graph.getNode(edge.sourceId)?.properties.name ?? edge.sourceId))
      .sort();

  it('resolves a literal destination on both sides', () => {
    const nodes = withBrokerAddress('kafka', 'orders.v1');
    expect(nodes).toHaveLength(1);
    expect(nodes[0]?.properties.resolution).toBe('literal');
  });

  it('joins a publisher and a subscriber that name the same address', () => {
    // The reason the node is keyed by address: this connection is one hop.
    const [orders] = withBrokerAddress('kafka', 'orders.v1');
    expect(orders).toBeDefined();
    const names = sourceNames(orders as GraphNode);
    expect(names).toContain('publishLiteral');
    expect(names).toContain('consumeLiteral');
    const types = new Set(edgesTo(orders as GraphNode).map((edge) => edge.type));
    expect([...types].sort()).toEqual(['CONSUMES_FROM', 'PUBLISHES_TO']);
  });

  it('KEEPS that pair joined when a stranger names the same word on another broker', () => {
    // THE regression, end to end. `UnrelatedRabbitConsumer` listens on a Rabbit
    // queue it happened to call `orders.v1` and has nothing to do with the
    // Kafka pair above. While the address alone keyed the node, its mere
    // existence withdrew the address from all three sites and the pair — the
    // thing this feature exists to report — stopped being connected by a file
    // neither half of it knows about.
    const kafka = withBrokerAddress('kafka', 'orders.v1');
    const rabbit = withBrokerAddress('rabbit', 'orders.v1');
    expect(kafka).toHaveLength(1);
    expect(rabbit).toHaveLength(1);
    expect(kafka[0]?.id).not.toBe(rabbit[0]?.id);

    // The pair still meets on ONE node, from two files.
    const pairSources = sourceNames(kafka[0] as GraphNode);
    expect(pairSources).toContain('publishLiteral');
    expect(pairSources).toContain('consumeLiteral');

    // The stranger is on its own node, alone, and is NOT on the pair's.
    expect(sourceNames(rabbit[0] as GraphNode)).toEqual(['consume']);
    expect(pairSources).not.toContain('consume');
    expect(edgesTo(rabbit[0] as GraphNode).map((edge) => edge.type)).toEqual(['CONSUMES_FROM']);
  });

  it('resolves a constant reference and joins on it too', () => {
    const nodes = withAddress('shipments.v1');
    expect(nodes).toHaveLength(1);
    expect(nodes[0]?.properties.resolution).toBe('constant');
    expect(sourceNames(nodes[0] as GraphNode)).toEqual(
      expect.arrayContaining(['consumeConstant', 'publishConstant']),
    );
  });

  it('does NOT resolve a placeholder default, and keeps both key and default', () => {
    // The default is written in the source, so it is read — but it holds only
    // while the key is not overridden, and configuration VALUES are absent from
    // this graph by design, so it cannot be an identity.
    expect(withAddress('audit.v1')).toEqual([]);
    const nodes = destinations.filter(
      (node) => node.properties.configKey === 'app.messaging.audit-topic',
    );
    // One Java consumer, one Kotlin consumer — two files, two nodes.
    expect(nodes).toHaveLength(2);
    for (const node of nodes) {
      expect(node.properties.resolution).toBe('overridable-config-default');
      expect(node.properties.configDefault).toBe('audit.v1');
      expect(node.properties.address).toBeUndefined();
    }
  });

  it('does not merge two different keys that share a default', () => {
    // `${app.messaging.report-topic:events}` and
    // `${app.messaging.archive-topic:events}` collapsed onto one
    // `Destination:events` and reported a producer/consumer pair between two
    // services sharing nothing but a copy-pasted fallback.
    expect(withAddress('events')).toEqual([]);
    const shared = destinations.filter((node) => node.properties.configDefault === 'events');
    expect(shared).toHaveLength(2);
    expect(new Set(shared.map((node) => node.id)).size).toBe(2);
    expect(new Set(shared.map((node) => node.properties.configKey))).toEqual(
      new Set(['app.messaging.report-topic', 'app.messaging.archive-topic']),
    );
  });

  it('emits one edge per element of an array-valued topics argument', () => {
    // `topics = {"orders.v1", "returns.v1"}` really does subscribe to two
    // places, so each gets its own edge and "who reads returns.v1" is one hop.
    const returns = withAddress('returns.v1');
    expect(returns).toHaveLength(1);
    const consumers = sourceNames(returns[0] as GraphNode);
    expect(consumers).toContain('consumeMany');
    expect(sourceNames(withBrokerAddress('kafka', 'orders.v1')[0] as GraphNode)).toContain(
      'consumeMany',
    );
  });

  it('reads the Kotlin bracket and arrayOf spellings', () => {
    expect(sourceNames(withBrokerAddress('kafka', 'orders.v1')[0] as GraphNode)).toContain(
      'consumeArray',
    );
    expect(withAddress('kotlin.arrayof.v1')).toHaveLength(1);
  });

  it('folds a KOTLIN constant, not only a Java one', () => {
    // Two separate facts. Java's fold reaching this cascade says nothing about
    // Kotlin's: `makeConstantResolver` asks the OWNING provider for
    // `foldRoutePathOperands`, and the harvest behind it runs only for a
    // provider that declares `extractModuleConstants`. Kotlin declares both, so
    // `KotlinTopics.INVENTORY` resolves the same way `Topics.SHIPMENTS` does.
    const inventory = withAddress('kotlin.constant.v1');
    expect(inventory).toHaveLength(1);
    expect(inventory[0]?.properties.resolution).toBe('constant');
    expect(sourceNames(inventory[0] as GraphNode)).toContain('publishConstant');
  });

  it('resolves the other brokers', () => {
    expect(withAddress('orders.jms')[0]?.properties.broker).toBe('jms');
    expect(withAddress('orders-out-0')[0]?.properties.broker).toBe('stream');
    // Rabbit publishes name a routing key; the exchange rides on the edge.
    const routingKey = withAddress('orders.created');
    expect(routingKey).toHaveLength(1);
    expect(edgesTo(routingKey[0] as GraphNode)[0]?.reason).toContain('exchange=orders.exchange');
  });

  // ── The rule the whole feature turns on ─────────────────────────────────

  it('gives two files that write the SAME placeholder two distinct nodes', () => {
    const unresolved = destinations.filter(
      (node) => node.properties.configKey === 'app.messaging.shared-topic',
    );
    // Two Java consumers, one Kotlin consumer, one Java publisher.
    expect(unresolved.length).toBeGreaterThanOrEqual(3);
    expect(new Set(unresolved.map((node) => node.id)).size).toBe(unresolved.length);
    const files = new Set(unresolved.map((node) => String(node.properties.filePath)));
    expect(files.size).toBe(unresolved.length);
  });

  it('gives a RESOLVED destination no location, so an incremental delete cannot cut it', () => {
    // `deleteNodesForFiles` removes nodes with `n.filePath IN [changed files]`
    // and DETACH DELETEs their edges. A shared destination stamped with its
    // first-seen file would be collateral damage whenever that file changed,
    // taking edges from files outside the write set with it — a publisher and
    // a subscriber that agree on an address would silently stop being
    // connected. An unresolved destination belongs to one site and SHOULD be
    // deleted with its file.
    for (const node of destinations) {
      const isResolved = node.properties.address !== undefined;
      expect((node.properties.filePath ?? '') === '').toBe(isResolved);
    }
  });

  it('never gives an unresolved destination an address property', () => {
    // The join key. An absent property cannot match another absent property,
    // so the guarantee survives being read back out of the database.
    for (const node of destinations) {
      const resolved = node.properties.resolution;
      const hasAddress = node.properties.address !== undefined;
      expect(hasAddress).toBe(resolved === 'literal' || resolved === 'constant');
    }
  });

  it('gives two files that write the same SpEL expression two distinct nodes', () => {
    // A runtime bean expression is the archetypal unresolvable address. Filed
    // as a literal it produced ONE node with `address =
    // "#{@messagingProperties.ordersTopic}"` and a CONSUMES_FROM edge from each
    // of two unrelated services.
    const spel = destinations.filter((node) => node.properties.resolution === 'spel-expression');
    expect(spel).toHaveLength(2);
    expect(new Set(spel.map((node) => node.id)).size).toBe(2);
    for (const node of spel) expect(node.properties.address).toBeUndefined();
    expect(destinations.some((node) => String(node.properties.address ?? '').includes('#{'))).toBe(
      false,
    );
  });

  it('gives two Kotlin services writing the same string TEMPLATE two nodes', () => {
    // Kotlin interpolates; Java does not. `"orders-$env"` has no braces at all,
    // so the `${` test never saw it and both services shared the literal
    // address `orders-$env`.
    const templates = destinations.filter(
      (node) => node.properties.resolution === 'unescaped-interpolation',
    );
    // `"orders-$env"` in two files plus `"orders-${env}"` in one.
    expect(templates).toHaveLength(3);
    expect(new Set(templates.map((node) => node.id)).size).toBe(3);
    for (const node of templates) {
      expect(node.properties.address).toBeUndefined();
      // The braced form was read as a SPRING placeholder and invented
      // `configKey: "env"`, which the phase then linked to any Property of that
      // name — provenance with no source.
      expect(node.properties.configKey).toBeUndefined();
    }
    expect(destinations.some((node) => node.properties.address === 'orders-$env')).toBe(false);
  });

  it('still reads the ESCAPED Kotlin dollar as a real Spring placeholder', () => {
    // `"\${app.topic}"` is how a Spring placeholder has to be written in
    // Kotlin, and the interpolation rule must not swallow it.
    const escaped = destinations.filter(
      (node) =>
        String(node.properties.filePath).endsWith('KotlinOrderPublishers.kt') &&
        node.properties.resolution === 'unresolved-config-key',
    );
    expect(escaped).toHaveLength(1);
    expect(escaped[0]?.properties.configKey).toBe('app.messaging.shared-topic');
  });

  it('never publishes a Rabbit EXCHANGE as an address', () => {
    // `convertAndSend(Topics.ORDERS_EXCHANGE, routingKey, payload)` — an
    // ordinary publish whose routing key is a variable. Arity cannot tell it
    // from `(routingKey, message, postProcessor)`, and the discarded positional
    // fallback made the exchange the address, where it could join a listener on
    // a queue of that name.
    expect(withAddress('orders.exchange')).toEqual([]);
    expect(destinations.some((node) => String(node.properties.name) === 'orders.exchange')).toBe(
      false,
    );
    const sources = new Set(
      messagingEdges.map((edge) => result.graph.getNode(edge.sourceId)?.properties.name),
    );
    expect(sources.has('publishToExchangeWithVariableRoutingKey')).toBe(false);
  });

  it('emits nothing for the ambiguous rabbit overload, and still reads the decidable one', () => {
    // `convertAndSend("orders.rk", "body", correlationData)` is
    // `(exchange, routingKey, message)` OR
    // `(routingKey, message, correlationData)`, spelled identically. Reading
    // it either way publishes the other reading's payload as an address.
    expect(withAddress('body')).toEqual([]);
    expect(withAddress('orders.rk')).toEqual([]);
    const names = destinations.map((node) => String(node.properties.name));
    expect(names).not.toContain('body');
    expect(names).not.toContain('orders.rk');
    const sources = new Set(
      messagingEdges.map((edge) => result.graph.getNode(edge.sourceId)?.properties.name),
    );
    expect(sources.has('publishWithAmbiguousOverload')).toBe(false);

    // The other half, which matters as much: the SAME arity with a constant in
    // slot 1 is decidable and must still resolve. A refusal that took this
    // with it would look identical in the graph — an absent destination — so
    // only asserting both together catches an over-broad suppression.
    const routingKey = withAddress('orders.created');
    expect(routingKey).toHaveLength(1);
    expect(routingKey[0]?.properties.resolution).toBe('constant');
    expect(sources.has('publishToExchange')).toBe(true);
  });

  it('does not connect the two unrelated placeholder consumers', () => {
    const inventory = destinations.find((node) =>
      String(node.properties.filePath).endsWith('InventoryConsumer.java'),
    );
    const billing = destinations.find((node) =>
      String(node.properties.filePath).endsWith('BillingConsumer.java'),
    );
    expect(inventory).toBeDefined();
    expect(billing).toBeDefined();
    expect(inventory?.id).not.toBe(billing?.id);
    // Neither consumer appears on the other's destination, by any edge.
    const inventorySources = new Set(edgesTo(inventory as GraphNode).map((e) => e.sourceId));
    const billingSources = new Set(edgesTo(billing as GraphNode).map((e) => e.sourceId));
    expect([...inventorySources].filter((id) => billingSources.has(id))).toEqual([]);
  });

  it('does not connect a Rabbit queue and a JMS queue that share a name', () => {
    // `@RabbitListener(queues = "orders.queue")` and
    // `jmsTemplate.convertAndSend("orders.queue", payload)` name the same
    // string over two different brokers. Keyed on the address alone they were
    // one node, and the ordinary two-hop walk below reported a subscriber
    // reading what this publisher writes — which it does not.
    //
    // They are two nodes now because the BROKER is in the key, not because the
    // address was withdrawn from either of them: both resolve, both carry
    // `address`, and each is free to meet its own counterpart elsewhere. That
    // is the difference the assertions below are written to hold apart.
    const named = destinations.filter((node) => node.properties.name === 'orders.queue');
    expect(named).toHaveLength(2);
    expect(new Set(named.map((node) => node.id)).size).toBe(2);
    expect(withAddress('orders.queue')).toHaveLength(2);
    for (const node of named) {
      expect(node.properties.address).toBe('orders.queue');
      expect(node.properties.resolution).toBe('literal');
      // Connecting, so no location — the incremental-delete rule applies to
      // these exactly as it does to any other joinable destination.
      expect(node.properties.filePath).toBe('');
    }
    expect(new Set(named.map((node) => node.properties.broker))).toEqual(
      new Set(['jms', 'rabbit']),
    );

    // The walk itself, stated the way a report would ask it: the Rabbit
    // subscription and the JMS publish land on DIFFERENT nodes, so neither
    // reaches the other.
    const consumerTargets = named.flatMap((node) =>
      edgesTo(node)
        .filter((edge) => edge.type === 'CONSUMES_FROM')
        .map((edge) => edge.targetId),
    );
    const publisherTargets = named.flatMap((node) =>
      edgesTo(node)
        .filter((edge) => edge.type === 'PUBLISHES_TO')
        .map((edge) => edge.targetId),
    );
    expect(consumerTargets).toHaveLength(1);
    expect(publisherTargets).toHaveLength(1);
    expect(consumerTargets[0]).not.toBe(publisherTargets[0]);
  });

  it('keeps the placeholder text visible in name, and out of address', () => {
    const inventory = destinations.find((node) =>
      String(node.properties.filePath).endsWith('InventoryConsumer.java'),
    );
    // Unquoted, so an unresolved node's `name` is spelled the way a resolved
    // one's is rather than carrying the source's quotation marks.
    expect(inventory?.properties.name).toBe('${app.messaging.shared-topic}');
    expect(inventory?.properties.address).toBeUndefined();
    expect(inventory?.properties.resolution).toBe('unresolved-config-key');
  });

  it('links an unresolved key to every Property node for it, without resolving it', () => {
    // `spring-config.ts` keys a Property per FILE, so the key declared in both
    // application.yml and application-prod.yml is two nodes and both are
    // linked. Finding them does NOT upgrade the destination: the VALUE is
    // still not in the graph.
    const inventory = destinations.find((node) =>
      String(node.properties.filePath).endsWith('InventoryConsumer.java'),
    ) as GraphNode;
    const links = [...result.graph.iterRelationships()].filter(
      (edge) => edge.sourceId === inventory.id && edge.type === 'USES',
    );
    expect(links.length).toBe(2);
    for (const link of links) {
      expect(result.graph.getNode(link.targetId)?.label).toBe('Property');
    }
    expect(inventory.properties.address).toBeUndefined();
  });

  // ── Refusals ────────────────────────────────────────────────────────────

  it('does not treat a topic pattern as an address', () => {
    expect(withAddress('orders\\..*')).toEqual([]);
    expect(destinations.some((node) => String(node.properties.name).includes('orders\\..*'))).toBe(
      false,
    );
  });

  it('does not model a WebSocket/STOMP mapping as a broker destination', () => {
    expect(destinations.some((node) => String(node.properties.name).startsWith('/orders'))).toBe(
      false,
    );
  });

  it('emits nothing for a publish whose destination is inside an object', () => {
    // `kafkaTemplate.send(record)` and `rabbitTemplate.convertAndSend(payload)`
    // name no address anywhere in the source.
    const sources = new Set(
      messagingEdges.map((edge) => result.graph.getNode(edge.sourceId)?.properties.name),
    );
    expect(sources.has('publishRecord')).toBe(false);
    expect(sources.has('publishToDefaultExchange')).toBe(false);
  });

  it('leaves the refused sites out of the graph entirely', () => {
    // Refusals are counted on the phase's own output (asserted in
    // `spring-destinations-phase.test.ts`, which can see it — `PipelineResult`
    // does not carry phase outputs). What is observable HERE is that a refusal
    // adds nothing: no node, no edge, no partial address.
    const addresses = destinations.map((node) => node.properties.address).filter(Boolean);
    expect(addresses).not.toContain('');
    expect(addresses.some((address) => String(address).includes('${'))).toBe(false);
  });
});