import { PhoenixLoader } from './phoenix-loader';
import { Vector3, QuadraticBezierCurve3 } from 'three';
import { CMSObjects } from './objects/cms-objects';
import JSZip from 'jszip';

/**
 * PhoenixLoader for processing and loading a CMS event.
 */
export class CMSLoader extends PhoenixLoader {
  /** Event data to be processed. */
  private data: any;
  /** Scale factor for resizing geometry to fit Phoenix event display. */
  private geometryScale: number = 1000;

  /**
   * Constructor for the CMS loader.
   */
  constructor() {
    super();
    this.data = {};
  }

  /**
   * Loads all the object types and collections of event data.
   * Overridden from {@link PhoenixLoader}.
   * @param eventData Event data of a CMS event containing all collections.
   */
  protected loadObjectTypes(eventData: any) {
    super.loadObjectTypes(eventData);
    if (eventData.MuonChambers) {
      this.addObjectType(
        eventData.MuonChambers,
        CMSObjects.getMuonChamber,
        'MuonChambers',
      );
    }
  }

  /**
   * Read an ".ig" archive file and access the event data through a callback.
   * @param file Path to the ".ig" file or an object of type `File`.
   * @param onFileRead Callback called with an array of event data when the file is read.
   * @param eventPathName Complete event path or event number as in the ".ig" archive.
   */
  public readIgArchive(
    file: string | File,
    onFileRead: (allEvents: any[]) => void,
    eventPathName?: string,
  ) {
    this.loadingManager.addLoadableItem('ig_archive');
    const igArchive = new JSZip();
    const eventsDataInIg: any[] = [];
    const readArchive = (res: File | ArrayBuffer) => {
      igArchive.loadAsync(res).then(() => {
        let allFilesPath = Object.keys(igArchive.files);
        // If the event path or name is given then filter all data to get the required events
        if (eventPathName) {
          allFilesPath = allFilesPath.filter((filePath) =>
            filePath.includes(eventPathName),
          );
        }
        let i = 1;
        for (const filePathInIg of allFilesPath) {
          // If the files are in the "Events" folder then process them.
          if (filePathInIg.toLowerCase().startsWith('events')) {
            igArchive
              ?.file(filePathInIg)!
              .async('string')
              .then((singleEvent: string) => {
                // The data has some inconsistencies which need to be removed to properly parse JSON
                singleEvent = singleEvent
                  .replace(/'/g, '"')
                  .replace(/\(/g, '[')
                  .replace(/\)/g, ']')
                  .replace(/nan/g, '0');
                const eventJSON = JSON.parse(singleEvent);
                eventJSON.eventPath = filePathInIg;
                eventsDataInIg.push(eventJSON);
                if (i === allFilesPath.length) {
                  onFileRead(eventsDataInIg);
                  this.loadingManager.itemLoaded('ig_archive');
                }
                i++;
              });
          } else {
            if (i === allFilesPath.length) {
              onFileRead(eventsDataInIg);
              this.loadingManager.itemLoaded('ig_archive');
            }
            i++;
          }
        }
      });
    };

    if (file instanceof File) {
      readArchive(file);
    } else {
      fetch(file)
        .then((res) => res.arrayBuffer())
        .then((res) => {
          readArchive(res);
        });
    }
  }

  /**
   * Load event data from an ".ig" archive.
   * @param filePath Path to the ".ig" archive file.
   * @param eventPathName Complete event path or event number as in the ".ig" archive.
   * @param onEventRead Callback called when the event data is read.
   */
  public loadEventDataFromIg(
    filePath: string,
    eventPathName: string,
    onEventRead: (eventData: any) => void,
  ) {
    this.readIgArchive(
      filePath,
      (allEvents: any[]) => {
        onEventRead(allEvents[0]);
      },
      eventPathName,
    );
  }

  /**
   * Get all event data.
   * @returns Event data with Hits, Tracks, Jets and CaloClusters.
   */
  public getEventData(): any {
    const eventInfo = this.data?.['Collections']?.['Event_V2']?.[0];
    const eventData: {
      runNumber: any;
      eventNumber: any;
      ls: any;
      time: any;
      Hits: any;
      Tracks: any;
      Jets: any;
      CaloClusters: any;
      MuonChambers: any;
      [key: string]: any; // Add index signature
    } = {
      runNumber: eventInfo?.[0],
      eventNumber: eventInfo?.[1],
      ls: eventInfo?.[2],
      time: eventInfo?.[5],
      Hits: {},
      Tracks: {},
      Jets: {},
      CaloClusters: {},
      MuonChambers: {},
    };

    // Getting Hits
    eventData.Hits = this.getTrackingClusters(eventData.Hits);
    // Getting Tracks
    eventData.Tracks = this.getTracks();
    // Getting Jets
    eventData.Jets = this.getJets();
    // Getting CaloClusters
    eventData.CaloClusters = this.getCaloClusters();
    // Getting MuonChambers
    eventData.MuonChambers = this.getMuonChambers();

    // Undefining object types if there is no event data
    for (const objectType of [
      'Hits',
      'Tracks',
      'Jets',
      'CaloClusters',
      'MuonChambers',
    ]) {
      if (Object.keys(eventData[objectType]).length === 0) {
        eventData[objectType] = undefined;
      }
    }

    return eventData;
  }

  /**
   * Get event data of all events.
   * @param allEventsDataFromIg An array containing data of all events from ".ig" file.
   * @returns An object containing event data for all events.
   */
  public getAllEventsData(allEventsDataFromIg: any[]): any {
    const allEventsData: { [key: string]: any } = {};
    for (const eventData of allEventsDataFromIg) {
      this.data = eventData;
      allEventsData[eventData.eventPath] = this.getEventData();
    }
    return allEventsData;
  }

  /**
   * Get all tracking clusters from the event data.
   * @param Hits Hits object in which all cluster collections are to be put.
   * @returns Hits object containing all Cluster collections.
   */
  private getTrackingClusters(Hits: any): any {
    // These are the collections with point cloud geometries
    const clusterCollections = [
      'TrackingRecHits_V1',
      'SiStripClusters_V1',
      'SiPixelClusters_V1',
      'CSCLCTDigis_V1',
    ];
    const newHits = this.getObjectCollections(
      clusterCollections,
      (objectParams) => {
        if (objectParams['pos']) {
          // Increasing the scale to fit Phoenix's event display
          objectParams['pos'] = objectParams['pos'].map(
            (point: number) => point * this.geometryScale,
          );
        }
      },
    );

    Object.assign(Hits, newHits);

    return Hits;
  }

  /**
   * Get all CaloClusters from the event data.
   * @returns CaloClusters object containing all CaloClusters collections.
   */
  private getCaloClusters(): any {
    const caloClustersCollections = ['SuperClusters_V1'];
    const CaloClusters = this.getObjectCollections(
      caloClustersCollections,
      (objectParams) => {
        if (objectParams['energy']) {
          // If the attribute of Calo Cluster is energy then scale it to a higher value
          objectParams['energy'] *= this.geometryScale;
        }
      },
    );

    //! TO BE REVIEWED - Not using extras and assocs - output might be different
    // let ri = 0;
    // for (let i = 0; i < assocs.length; i++) {
    //     ri = assocs[ri][1][1];
    //     CaloClusters[caloClusterCollection].push(extras[ri]);
    // }

    return CaloClusters;
  }

  /**
   * Get all Jets from the event data.
   * @returns Jets object containing all Jets collections.
   */
  private getJets(): any {
    let Jets = {};

    // Filtering collections to get all Jets collections
    const jetsCollections = Object.keys(this.data['Collections']).filter(
      (key) => key.toLowerCase().includes('jets'),
    );
    const cuts = [
      { attribute: 'et', min: 10 },
      { attribute: 'energy', min: 10 },
    ];

    Jets = this.getObjectCollections(
      jetsCollections,
      (objectParams) => {
        for (const energyAttribute of ['et', 'energy']) {
          if (objectParams[energyAttribute]) {
            objectParams[energyAttribute] *= this.geometryScale;
            break;
          }
        }
      },
      cuts,
    );

    return Jets;
  }

  /**
   * Get all Muon Chambers from the event data.
   * @returns MuonChambers object containing all Muon Chambers collections.
   */
  private getMuonChambers(): any {
    const muonChambersCollections = ['MatchingCSCs_V1', 'MuonChambers_V1'];
    const MuonChambers = this.getObjectCollections(
      muonChambersCollections,
      (muonChamberParams) => {
        for (const muonChamberParam of Object.keys(muonChamberParams)) {
          if (
            muonChamberParam.startsWith('front') ||
            muonChamberParam.startsWith('back')
          ) {
            muonChamberParams[muonChamberParam] = muonChamberParams[
              muonChamberParam
            ].map((val: number) => val * this.geometryScale);
          }
        }
      },
    );
    return MuonChambers;
  }

  /**
   * Common function for linearly getting event data of collections of an object type.
   * @param collections Keys for collections to be iterated.
   * @param processObject Callback for applying a custom logic to object params.
   * @param cuts Cuts for defining a minimum and maximum value of an attribute.
   * @returns An object containing all event data from the given collections.
   */
  private getObjectCollections(
    collections: string[],
    processObject?: (objectParams: any) => void,
    cuts?: { attribute: string; min?: number; max?: number }[],
  ): any {
    const ObjectType: { [key: string]: any[] } = {};

    // Filter to check if the provided collections are indeed inside the data
    collections = collections.filter((key) => this.data['Collections'][key]);

    // Iterating all collections
    for (const collection of collections) {
      ObjectType[collection] = [];
      const objectAttributes = this.data['Types'][collection];
      // Iterating a single object collection to process all objects
      for (const physicsObject of this.data['Collections'][collection]) {
        const objectParams: { [key: string]: number } = {};

        // Filling object params using the given types
        objectAttributes.forEach(
          (attribute: (string | number)[], attributeIndex: string | number) => {
            objectParams[attribute[0]] = physicsObject[attributeIndex];
          },
        );

        // Applying cuts to object (if any)
        if (cuts) {
          let maxPass = true;
          let minPass = true;
          for (const cut of cuts) {
            // Check if the attribute actually exists
            if (objectParams[cut.attribute]) {
              if (cut.max && objectParams[cut.attribute] > cut.max) {
                maxPass = false;
                break;
              }
              if (cut.min && objectParams[cut.attribute] < cut.min) {
                minPass = false;
                break;
              }
            }
          }
          if (maxPass && minPass) {
            // Custom processing of object (if any)
            processObject?.(objectParams);
            ObjectType[collection].push(objectParams);
          }
        } else {
          // Custom processing of object (if any)
          processObject?.(objectParams);
          ObjectType[collection].push(objectParams);
        }
      }
      // If the object collection has no data then remove it
      if (ObjectType[collection].length === 0) {
        delete ObjectType[collection];
      }
    }
    return ObjectType;
  }

  /**
   * Get all Tracks from the event data.
   * @returns Tracks object containing all Tracks collections.
   */
  private getTracks(): any {
    const Tracks: { [key: string]: any[] } = {};

    // All collections with tracks
    let tracksCollections = [
      {
        collection: 'Tracks_V1',
        extras: 'Extras_V1',
        assocs: 'TrackExtras_V1',
        color: '0xff0000',
        min_pt: 1,
      },
      {
        collection: 'Tracks_V2',
        extras: 'Extras_V1',
        assocs: 'TrackExtras_V1',
        color: '0xff0000',
        min_pt: 1,
      },
      {
        collection: 'Tracks_V3',
        extras: 'Extras_V1',
        assocs: 'TrackExtras_V1',
        color: '0xff0000',
        min_pt: 1,
      },
      {
        collection: 'StandaloneMuons_V2',
        extras: 'Extras_V1',
        assocs: 'MuonTrackExtras_V1',
        color: '0xf57842',
        min_pt: 1,
      },
      {
        collection: 'PATStandaloneMuons_V1',
        extras: 'Extras_V1',
        assocs: 'PATMuonTrackExtras_V1',
        color: '0xf5aa42',
        min_pt: 1,
      },
      {
        collection: 'TrackerMuons_V2',
        extras: 'Extras_V1',
        assocs: 'MuonTrackerExtras_V1',
        color: '0xe8d546',
        min_pt: 2,
      },
      {
        collection: 'GsfElectrons_V1',
        extras: 'Extras_V1',
        assocs: 'GsfElectronExtras_V1',
        color: '0x1CFF1A',
        min_pt: 10,
      },
      {
        collection: 'GsfElectrons_V2',
        extras: 'Extras_V1',
        assocs: 'GsfElectronExtras_V1',
        color: '0x1bcf9f',
        min_pt: 10,
      },
      {
        collection: 'GsfElectrons_V3',
        extras: 'Extras_V1',
        assocs: 'GsfElectronExtras_V1',
        color: '0x1ad9ff',
        min_pt: 10,
      },
      {
        collection: 'PATElectrons_V1',
        extras: 'Extras_V1',
        assocs: 'PATElectronExtras_V1',
        color: '0x1a40ff',
        min_pt: 1,
      },
    ];
    // Filtering to check if data actually exists in collections
    tracksCollections = tracksCollections.filter(
      (obj) => this.data['Collections'][obj.collection],
    );

    for (const tracksCollection of tracksCollections) {
      Tracks[tracksCollection.collection] = [];

      // Processing tracks using associations and extras
      const tracks = this.data['Collections'][tracksCollection.collection];
      const extras = this.data['Collections'][tracksCollection.extras];
      const assocs = this.data['Associations'][tracksCollection.assocs];
      // Properties/attributes of tracks
      const trackTypes = this.data['Types'][tracksCollection.collection];

      // Variables to be used inside the loop
      let ti,
        ei,
        p1,
        d1,
        p2,
        d2,
        distance,
        scale,
        cp1,
        cp2,
        curve,
        trackParams: { [x: string]: any; pt?: any; color?: any; pos?: any };

      for (let i = 0; i < assocs.length; i++) {
        // Current track info
        trackParams = {};

        // Set properties/attributes of track
        trackTypes.forEach(
          (attribute: (string | number)[], attributeIndex: string | number) => {
            trackParams[attribute[0]] = tracks[i][attributeIndex];
          },
        );

        // SKIPPING TRACKS WITH pt < min_pt
        if (trackParams.pt < tracksCollection.min_pt) {
          continue;
        }

        trackParams.color = tracksCollection.color;

        // Track i - location in assocs
        ti = assocs[i][0][1];
        // Extras i - location in assocs
        ei = assocs[i][1][1];

        // Position 1 of current track
        p1 = new Vector3(extras[ei][0][0], extras[ei][0][1], extras[ei][0][2]);
        // Direction of position 1 of current track
        d1 = new Vector3(extras[ei][1][0], extras[ei][1][1], extras[ei][1][2]);
        d1.normalize();

        // Position 2 of current track
        p2 = new Vector3(extras[ei][2][0], extras[ei][2][1], extras[ei][2][2]);
        // Direction of position 2 of current track
        d2 = new Vector3(extras[ei][3][0], extras[ei][3][1], extras[ei][3][2]);
        d2.normalize();

        // Calculate the distance from position 1 to position 2
        distance = p1.distanceTo(p2);
        scale = distance * 0.25;

        // Calculating the control points to generate a bezier curve
        cp1 = new Vector3(
          p1.x + scale * d1.x,
          p1.y + scale * d1.y,
          p1.z + scale * d1.z,
        );
        cp2 = new Vector3(
          p2.x + scale * d2.x,
          p2.y + scale * d2.y,
          p2.z + scale * d2.z,
        );

        // Create the track curve
        curve = new QuadraticBezierCurve3(p1, cp1, p2);

        const positions = [];
        // Divide the curve into points to put into positions array
        for (const position of curve.getPoints(24)) {
          // Increasing the scale to fit Phoenix's event display
          position.multiplyScalar(this.geometryScale);
          positions.push([position.x, position.y, position.z]);
        }

        trackParams.pos = positions;
        Tracks[tracksCollection.collection].push(trackParams);
      }

      if (Tracks[tracksCollection.collection].length === 0) {
        delete Tracks[tracksCollection.collection];
      }
    }

    return Tracks;
  }

  /**
   * Get CMS specific metadata associated to the event.
   * @returns Metadata of the event.
   */
  getEventMetadata(): any[] {
    const metadata = super.getEventMetadata();
    const eventInfo = this.data?.['Collections']?.['Event_V2']?.[0];
    if (eventInfo?.[3]) {
      metadata.push({
        label: 'Orbit',
        value: eventInfo[3],
      });
    }
    return metadata;
  }
}