from __future__ import absolute_import, division, print_function
from six.moves import range
import os
from spotfinder.diffraction.imagefiles import quick_image
from spotfinder.servers.multipart_encoder import post_multipart

def get_spotfinder_url(file_object,host,port):
  testurl = "%s:%d"%(host,port)
  selector = "/spotfinder"
  start_index=0
  stop_index = file_object.linearintdata.size()
  raw_string=file_object.linearintdata.slice_to_byte_str(start_index,stop_index)
  query_object = [
    ("moduleindex",file_object.__dict__.get("moduleindex",-1)),
    ("filename",file_object.filename),
    ("bin",1),
    ("vendortype",file_object.vendortype),
    ("beam_center_reference_frame",file_object.beam_center_reference_frame),
    ("beam_center_convention",file_object.beam_center_convention),
    ("header",file_object.header),
    ("headerlines",""),
  ]
  for item in ['DISTANCE', 'PHI', 'WAVELENGTH',
    'TWOTHETA', 'OSC_RANGE',
    'CCD_IMAGE_SATURATION', 'OSC_START', 'DETECTOR_SN', 'PIXEL_SIZE',
    'SIZE1','SIZE2','BEAM_CENTER_X','BEAM_CENTER_Y'
    ]:
    if type(file_object.parameters[item])==type(1.0):
      query_object.append((item,"%.6f"%file_object.parameters[item]))
    else:
      query_object.append((item,file_object.parameters[item]))

  files = [
    ("adsc_data",file_object.filename,raw_string)
  ]

  print("length of data in ints",stop_index)
  print("length of data in bytes",len(raw_string))
  assert len(raw_string)/4==stop_index

  Response = post_multipart(host=testurl, selector=selector,
    fields = query_object, files = files)

  print(Response.getresponse().read())

def get_labelit_image_object(file,convention):
  Q = quick_image(file)
  Q.set_beam_center_convention(convention)
  Q.read()

  return Q

def do_main(filepath, force_binning, convention, host, port):
  absfile = os.path.abspath(filepath)
  Q = get_labelit_image_object(absfile, convention)
  if force_binning:
    Q.setBin(2)
    Q.show_header()
  get_spotfinder_url(Q,host,port)

  from iotbx.detectors import image_divider
  number_of_modules = image_divider(
                        Q.linearintdata,
                        Q.vendor_specific_null_value
                      ).module_count()

  for x in range(number_of_modules):
    file = "file://%s?slice=%d"%(absfile,x)
    Q = get_labelit_image_object(file, convention)
    if force_binning:
      Q.setBin(2)
      Q.show_header()
    get_spotfinder_url(Q,host,port)

if __name__=="__main__":
  import sys
  try:
    filepath, force_binning, convention, host, port = sys.argv[1:6]
    force_binning = bool(force_binning)
    port = int(port)
    convention = int(convention)
  except Exception:
    print("""
Usage:
libtbx.python adsc_client.py <filepath> <force_binning> <convention> <host> <port>
Four mandatory arguments:
  filepath: absolute or relative path name of the ADSC test image to be analyzed
  force_binning: True (client-side 2x2-pixel software binning; sometimes the best
                       choice if raw data is not hardware-binned) or False
  convention: beam_center_convention as defined on the spotfinder servers wiki
  host: usually "localhost"; in any case, must be machine with same endianness
  port: port number of image analyzer http service
""")
  do_main(filepath, force_binning, convention, host, port)