import {expect} from "chai";
import {ForkName} from "@lodestar/params";
import {GossipType, GossipEncoding, GossipTopicMap} from "../../../../src/network/gossip/index.js";
import {parseGossipTopic, stringifyGossipTopic} from "../../../../src/network/gossip/topic.js";
import {config} from "../../../utils/config.js";

describe("network / gossip / topic", function () {
  const encoding = GossipEncoding.ssz_snappy;

  // Enforce with Typescript that we test all GossipType
  const testCases: {[K in GossipType]: {topic: GossipTopicMap[K]; topicStr: string}[]} = {
    [GossipType.beacon_block]: [
      {
        topic: {type: GossipType.beacon_block, fork: ForkName.phase0, encoding},
        topicStr: "/eth2/18ae4ccb/beacon_block/ssz_snappy",
      },
    ],
    [GossipType.beacon_block_and_blobs_sidecar]: [
      {
        topic: {type: GossipType.beacon_block_and_blobs_sidecar, fork: ForkName.eip4844, encoding},
        topicStr: "/eth2/46acb19a/beacon_block_and_blobs_sidecar/ssz_snappy",
      },
    ],
    [GossipType.beacon_aggregate_and_proof]: [
      {
        topic: {type: GossipType.beacon_aggregate_and_proof, fork: ForkName.phase0, encoding},
        topicStr: "/eth2/18ae4ccb/beacon_aggregate_and_proof/ssz_snappy",
      },
    ],
    [GossipType.beacon_attestation]: [
      {
        topic: {type: GossipType.beacon_attestation, fork: ForkName.phase0, subnet: 5, encoding},
        topicStr: "/eth2/18ae4ccb/beacon_attestation_5/ssz_snappy",
      },
    ],
    [GossipType.voluntary_exit]: [
      {
        topic: {type: GossipType.voluntary_exit, fork: ForkName.phase0, encoding},
        topicStr: "/eth2/18ae4ccb/voluntary_exit/ssz_snappy",
      },
    ],
    [GossipType.bls_to_execution_change]: [
      {
        topic: {type: GossipType.bls_to_execution_change, fork: ForkName.capella, encoding},
        topicStr: "/eth2/63f1741c/bls_to_execution_change/ssz_snappy",
      },
    ],
    [GossipType.proposer_slashing]: [
      {
        topic: {type: GossipType.proposer_slashing, fork: ForkName.phase0, encoding},
        topicStr: "/eth2/18ae4ccb/proposer_slashing/ssz_snappy",
      },
    ],
    [GossipType.attester_slashing]: [
      {
        topic: {type: GossipType.attester_slashing, fork: ForkName.phase0, encoding},
        topicStr: "/eth2/18ae4ccb/attester_slashing/ssz_snappy",
      },
    ],
    [GossipType.sync_committee_contribution_and_proof]: [
      {
        topic: {type: GossipType.sync_committee_contribution_and_proof, fork: ForkName.altair, encoding},
        topicStr: "/eth2/8e04f66f/sync_committee_contribution_and_proof/ssz_snappy",
      },
    ],
    [GossipType.sync_committee]: [
      {
        topic: {type: GossipType.sync_committee, fork: ForkName.altair, subnet: 5, encoding},
        topicStr: "/eth2/8e04f66f/sync_committee_5/ssz_snappy",
      },
    ],
    [GossipType.light_client_finality_update]: [
      {
        topic: {type: GossipType.light_client_finality_update, fork: ForkName.altair, encoding},
        topicStr: "/eth2/8e04f66f/light_client_finality_update/ssz_snappy",
      },
    ],
    [GossipType.light_client_optimistic_update]: [
      {
        topic: {type: GossipType.light_client_optimistic_update, fork: ForkName.altair, encoding},
        topicStr: "/eth2/8e04f66f/light_client_optimistic_update/ssz_snappy",
      },
    ],
  };

  for (const topics of Object.values(testCases)) {
    if (topics.length === 0) throw Error("Must have a least 1 testCase for each GossipType");

    for (const {topic, topicStr} of topics) {
      it(`should encode gossip topic ${topic.type} ${topic.fork} ${topic.encoding}`, async () => {
        const topicStrRes = stringifyGossipTopic(config, topic);
        expect(topicStrRes).to.equal(topicStr);
      });

      it(`should decode gossip topic ${topicStr}`, async () => {
        const outputTopic = parseGossipTopic(config, topicStr);
        expect(outputTopic).to.deep.equal(topic);
      });
    }
  }

  const badTopicStrings: string[] = [
    // completely invalid
    "/different/protocol/entirely",
    // invalid fork digest
    "/eth2/ffffffff/beacon_attestation_5/ssz_snappy",
    // invalid gossip type
    "/eth2/18ae4ccb/beacon_attestation_foo/ssz_snappy",
    // invalid gossip type
    "/eth2/18ae4ccb/something_different/ssz_snappy",
    "/eth2/18ae4ccb/beacon_attestation/ssz_snappy",
    "/eth2/18ae4ccb/beacon_attestation_/ssz_snappy",
    "/eth2/18ae4ccb/beacon_attestation_PP/ssz_snappy",
    // invalid encoding
    "/eth2/18ae4ccb/beacon_attestation_5/ssz_supersnappy",
  ];
  for (const topicStr of badTopicStrings) {
    it(`should fail to decode invalid gossip topic string ${topicStr}`, async () => {
      expect(() => parseGossipTopic(config, topicStr), topicStr).to.throw();
    });
  }
});