# include "addstar.h"

int find_matches_closest_refstars (SkyRegion *region, Stars **stars, unsigned int NstarsIn, Catalog *catalog, AddstarClientOptions options) {

  off_t i, j, n, N, J, Jmin, status;
  double RADIUS, RADIUS2, Rmin;
  double *X1, *Y1, *X2, *Y2;
  double dX, dY, dR;
  off_t *N1, *N2, *next_meas;
  off_t Nave, NAVE, Nmeas, NMEAS, Nstars, Nmatch;
  unsigned int objID, catID;
  Coords tcoords;
  int Nsecfilt;

  if ((NREFSTAR_GROUP != 1) && (NREFSTAR_GROUP != 3)) {
    fprintf (stderr, "ERROR: NREFSTAR_GROUP NOT SET!\n");
    exit (1);
  }

  /* photcode data -- should not have to modify secfilt / average */
  Nsecfilt = GetPhotcodeNsecfilt ();

  /** allocate local arrays (stars) **/
  ALLOCATE (X1, double, NstarsIn);
  ALLOCATE (Y1, double, NstarsIn);
  ALLOCATE (N1, off_t,  NstarsIn);

  /** allocate local arrays (catalog) **/
  NAVE = Nave = catalog[0].Naverage;
  ALLOCATE (X2, double, NAVE);
  ALLOCATE (Y2, double, NAVE);
  ALLOCATE (N2, off_t,  NAVE);
  ALLOCATE (catalog[0].found_t, off_t, NAVE);
  /* for secfilt j and star i, secfilt[i*Nsecfilt+j] */

  /* internal counters */
  Nmatch = 0;
  NMEAS = Nmeas = catalog[0].Nmeasure;
  
  // current max obj ID for this catalog
  objID = catalog[0].objID;
  catID = catalog[0].catID;

  /* project onto rectilinear grid with 1 arcsec pixels. the choice of ARC projection has
   * the advantage that every point in R,D has a mapping to a unique X,Y.  However, note
   * that not all possible X,Y points map back to R,D and the local plate scale changes
   * far from the projection pole. We use the center of the region (catalog) for crval1,2.
   */
  tcoords.crval1 = 0.5*(region[0].Rmin + region[0].Rmax);
  if (region[0].Dmax < 90) {
    tcoords.crval2 = 0.5*(region[0].Dmin + region[0].Dmax);
  } else {
    tcoords.crval2 = 90.0;
  }
  tcoords.crpix1 = 0.0;
  tcoords.crpix2 = 0.0;
  tcoords.cdelt1 = tcoords.cdelt2 = 1.0 / 3600.0;
  tcoords.pc1_1 = tcoords.pc2_2 = 1.0;
  tcoords.pc1_2 = tcoords.pc2_1 = 0.0;
  tcoords.Npolyterms = 0;
  strcpy (tcoords.ctype, "DEC--ARC");
  
  /* build spatial index (RA sort) referencing input array sequence */
  Nstars = 0;
  for (i = 0; i < NstarsIn; i++) {
    status = RD_to_XY (&X1[Nstars], &Y1[Nstars], stars[i][0].average.R, stars[i][0].average.D, &tcoords);
    if (!status) continue;
    N1[Nstars] = i;
    Nstars ++;
  }
  if (Nstars < 1) {
    if (VERBOSE) fprintf (stderr, "skipping %s, no overlapping stars\n", catalog[0].filename);
    free (X1);
    free (Y1);
    free (N1);
    free (X2);
    free (Y2);
    free (N2);
    return (0);
  }
  if (Nstars > 1) sort_coords_index (X1, Y1, N1, Nstars);
  
  /* build spatial index (RA sort) */
  for (i = 0; i < Nave; i++) {
    RD_to_XY (&X2[i], &Y2[i], catalog[0].average[i].R, catalog[0].average[i].D, &tcoords);
    N2[i] = i;
    catalog[0].found_t[N2[i]] = -1;
  }
  if (Nave > 1) sort_coords_index (X2, Y2, N2, Nave);

  /* set up pointers for linked list of measure */
  if (catalog[0].sorted && (catalog[0].Nmeasure == catalog[0].Nmeas_disk)) {
    // this version is only valid if we have done a full catalog load, and if the catalog
    // is sorted while processed
    next_meas = init_measure_links (catalog[0].average, Nave, catalog[0].measure, Nmeas);
  } else {
    next_meas = build_measure_links (catalog[0].average, Nave, catalog[0].measure, Nmeas);
  }    

  /* choose a radius for matches */
  if (options.radius == 0) {
    RADIUS = 2.0; /* hardwired default for refstars */
  } else {
    RADIUS = options.radius; /* provided by config */
  }
  RADIUS2 = RADIUS*RADIUS;

  /** find matched stars **/
  // XXX could use NREFSTAR_GROUP to do this match more quicky
  for (i = j = 0; (i < Nstars) && (j < Nave); ) {
    if (!finite(X1[i]) || !finite(Y1[i])) { 
      i++; 
      continue;
    }
    if (!finite(X2[j]) || !finite(Y2[j])) { 
      j++; 
      continue;
    }
    
    /* negative dX: j is too large */
    dX = X1[i] - X2[j];
    if (dX <= -1.02*RADIUS) {
      i++;
      continue;
    }
    /* positive dX, i is too large */
    if (dX >= 1.02*RADIUS) {
      j++;
      continue;
    }

    /* within match range; look for matches */
    Jmin = -1;
    Rmin = RADIUS2;
    for (J = j; (dX > -1.02*RADIUS) && (J < Nave); J++) {
      /* find closest match for this detection */
      dX = X1[i] - X2[J];
      dY = Y1[i] - Y2[J];
      dR = dX*dX + dY*dY;
      if (dR > RADIUS2) continue;
      if (dR < Rmin) {
	Rmin = dR;
	Jmin  = J;
      }
    }

    /* no match, try next detection */ 
    if (Jmin == -1) {
      i++;
      continue;
    }

    /*** a match is found, add to average, measure ***/
    Nmatch ++;
    n = N2[Jmin];
    N = N1[i];

    /** in replace mode, search for entry and replace values M, dM, R, D */
    // XXX this fails for unsorted catalogs, right?
    if (options.replace && replace_match (&catalog[0].average[n], catalog[0].measure, stars[N])) {
	i++;
	continue;
    }

    /* make sure there is space for next entry */
    if (Nmeas >= NMEAS) {
      NMEAS = Nmeas + 1000;
      REALLOCATE (next_meas, off_t, NMEAS);
      REALLOCATE (catalog[0].measure, Measure, NMEAS);
    }

    /* add to end of measurement list */
    add_meas_link (&catalog[0].average[n], next_meas, Nmeas, NMEAS);
	
    /** add measurements for this star **/

    // set the new measurements
    catalog[0].measure[Nmeas]          = stars[N][0].measure;

    /** *** dR,dD now in arcsec *** **/
    catalog[0].measure[Nmeas].R        = stars[N][0].average.R;
    catalog[0].measure[Nmeas].D        = stars[N][0].average.D;
    catalog[0].measure[Nmeas].dbFlags  = 0;
    catalog[0].measure[Nmeas].averef   = n;
    catalog[0].measure[Nmeas].objID    = catalog[0].average[n].objID;
    catalog[0].measure[Nmeas].catID    = catalog[0].catID;

    float dRoff = dvoOffsetR(&catalog[0].measure[Nmeas], &catalog[0].average[n]);

    // rationalize dR:
    if (dRoff > +180.0*3600.0) {
      // average on high end of boundary, move star up
      catalog[0].measure[Nmeas].R += 360.0;
      dRoff -= 360.0*3600.0;
    }
    if (dRoff < -180.0*3600.0) {
      // average on low end of boundary, move star down
      catalog[0].measure[Nmeas].R -= 360.0;
      dRoff += 360.0*3600.0;
    }

    // the reference data may not have per-object time specified
    catalog[0].measure[Nmeas].t        = (TIMEREF == 0) ? stars[N][0].measure.t      : TIMEREF; /** careful : time_t vs e_time **/
    catalog[0].measure[Nmeas].t_msec   = (TIMEREF == 0) ? stars[N][0].measure.t_msec : TIMEREF; /** careful : time_t vs e_time **/

    // we can choose to accept the proper-motion and parallax from the reference catalog
    if (ACCEPT_MOTION) {
      catalog[0].average[n].uR         = stars[N][0].average.uR;
      catalog[0].average[n].uD         = stars[N][0].average.uD;
      catalog[0].average[n].duR        = stars[N][0].average.duR;
      catalog[0].average[n].duD        = stars[N][0].average.duD;
      catalog[0].average[n].P          = stars[N][0].average.P;
      catalog[0].average[n].dP         = stars[N][0].average.dP;
    }

    /** don't update average / secfilt values for REF photcodes **/

    /*** handle multiple stars */
    /* this catalog star matches more than one image star */
    // XXX should this be an average flag?
    if (catalog[0].found_t[n] > -1) {
      catalog[0].measure[catalog[0].found_t[n]].dbFlags |= ID_MEAS_BLEND_OBJ;
      catalog[0].measure[Nmeas].dbFlags |= ID_MEAS_BLEND_OBJ;
    } else {
      catalog[0].found_t[n] = Nmeas;
    }

    stars[N][0].found = Nmeas;
    catalog[0].average[n].Nmeasure ++;
    Nmeas ++;

    // make this optional:
    // update_coords (&catalog[0].average[n], &catalog[0].measure[0], next_meas);
    i++;
  }

  /* Incorporate unmatched refcat stars.  Skip this step if we want to
     require matches combined with -replace, this lets us keep the
     reference up-to-date with known stars only */

  for (i = 0; (i < Nstars) && !options.only_match; i+=NREFSTAR_GROUP) {
    /* make sure there is space for next entry */
    if (Nmeas >= NMEAS - NREFSTAR_GROUP) {
      NMEAS = Nmeas + 1000;
      REALLOCATE (next_meas, off_t, NMEAS);
      REALLOCATE (catalog[0].measure, Measure, NMEAS);
    }
    if (Nave >= NAVE) {
      NAVE = Nave + 1000;
      REALLOCATE (catalog[0].average, Average, NAVE);
      REALLOCATE (catalog[0].secfilt, SecFilt, NAVE*catalog[0].Nsecfilt);
    }

    N = N1[i];
    if (stars[N][0].found >= 0) continue;
    if (!IN_REGION (stars[N][0].average.R, stars[N][0].average.D)) continue;

    dvo_average_init (&catalog[0].average[Nave]);
    catalog[0].average[Nave].R         	   = stars[N][0].average.R;
    catalog[0].average[Nave].D         	   = stars[N][0].average.D;

    catalog[0].average[Nave].Nmeasure      = NREFSTAR_GROUP;
    catalog[0].average[Nave].measureOffset = Nmeas;
    catalog[0].average[Nave].objID     	   = objID;
    catalog[0].average[Nave].catID     	   = catID;

    if (PSPS_ID) {
        catalog[0].average[Nave].extID = CreatePSPSObjectID(catalog[0].average[Nave].R, catalog[0].average[Nave].D);
    }

    if (ACCEPT_MOTION) {
      catalog[0].average[Nave].dR    	   = stars[N][0].average.dR;
      catalog[0].average[Nave].dD    	   = stars[N][0].average.dD;
      catalog[0].average[Nave].uR    	   = stars[N][0].average.uR;
      catalog[0].average[Nave].uD    	   = stars[N][0].average.uD;
      catalog[0].average[Nave].duR   	   = stars[N][0].average.duR;
      catalog[0].average[Nave].duD   	   = stars[N][0].average.duD;
      catalog[0].average[Nave].P     	   = stars[N][0].average.P;
      catalog[0].average[Nave].dP    	   = stars[N][0].average.dP;
    }

    objID ++;

    for (j = 0; j < Nsecfilt; j++) {
      dvo_secfilt_init (&catalog[0].secfilt[Nave*Nsecfilt+j]);
    }

    for (j = 0; j < NREFSTAR_GROUP; j++) {
      N = N1[i + j];

      catalog[0].measure[Nmeas]          = stars[N][0].measure;

      catalog[0].measure[Nmeas].R       = catalog[0].average[Nave].R;
      catalog[0].measure[Nmeas].D       = catalog[0].average[Nave].D;
      catalog[0].measure[Nmeas].dbFlags  = 0;
      catalog[0].measure[Nmeas].averef   = Nave;
      catalog[0].measure[Nmeas].objID    = catalog[0].average[Nave].objID;
      catalog[0].measure[Nmeas].catID    = catalog[0].catID;

      catalog[0].measure[Nmeas].t        = (stars[N][0].measure.t == 0) ? TIMEREF : stars[N][0].measure.t;      /** careful : time_t vs e_time **/
      catalog[0].measure[Nmeas].t_msec   = (stars[N][0].measure.t == 0) ?       0 : stars[N][0].measure.t_msec; /** careful : time_t vs e_time **/

      stars[N][0].found = Nmeas;
      next_meas[Nmeas] = -1;
      Nmeas ++;
    }
    for (j = 0; j < NREFSTAR_GROUP - 1; j++) {
	next_meas[Nmeas - NREFSTAR_GROUP + j] = Nmeas - NREFSTAR_GROUP + j + 1;
    }
    Nave ++;
  }
      
  REALLOCATE (catalog[0].average, Average, Nave);
  REALLOCATE (catalog[0].measure, Measure, Nmeas);

  // XXX allow for unsorted output?
  catalog[0].measure = sort_measure (catalog[0].average, Nave, catalog[0].measure, Nmeas, next_meas);

  /* note stars which have been found in this catalog */
  for (i = 0; i < Nstars; i++) {
    if (stars[i][0].found > -1) {
      stars[i][0].found = -2;
    }
  }

  catalog[0].objID    = objID; // new max value, save on catalog close
  catalog[0].Naverage = Nave;
  catalog[0].Nmeasure = Nmeas;
  catalog[0].Nsecf_mem = Nave*Nsecfilt;
  if (VERBOSE) fprintf (stderr, "Nstars, Nave, Nmeas: "OFF_T_FMT" "OFF_T_FMT" "OFF_T_FMT", ("OFF_T_FMT" matches)\n",  Nstars,  Nave,  Nmeas,  Nmatch);

  free (X1);
  free (Y1);
  free (N1);
  free (N2);
  free (X2);
  free (Y2);
  free (next_meas);

  return (Nmatch);
}
