from __future__ import absolute_import, division, print_function
from BaseHTTPServer import BaseHTTPRequestHandler,HTTPServer
from scitbx.array_family import flex
from libtbx.development.timers import Timer
import cgi, sys
from six.moves import StringIO
from spotfinder.applications.stats_distl import optionally_add_saturation_webice,key_adaptor

from urlparse import urlparse
#backward compatibility with Python 2.5
try: from urlparse import parse_qs
except Exception: from cgi import parse_qs

def module_safe_items(image):
  return [
      ("%7d","Good Bragg Candidates",key_adaptor(image,'N_spots_inlier')),
      ("%7.0f","Total integrated signal, pixel-ADC units above local background",
                 key_adaptor(image,'ad_hoc_signal1')),
      ("%7d","Ice Rings",key_adaptor(image,'ice-ring_impact')),
      ("%7.1f","Resolution estimate",key_adaptor(image,'resolution')),
      ("%7.1f","Maximum unit cell",key_adaptor(image,'maxcel')),
  ]

def module_image_stats(S,key):
    # List of spots between specified high- and low-resolution limits
    image = S.images[key]
    spots = image.__getitem__('spots_inlier')

    integrated = 0.0

    for i,spot in enumerate(spots):
     integrated += flex.sum(spot.wts)
    image["ad_hoc_signal1"]=integrated

    canonical_info = []
    canonical_info.extend(module_safe_items(image))
    optionally_add_saturation_webice(canonical_info,image)

    for item in canonical_info:
      if item[2]==None:
        print("%63s : None"%item[1])
      else:
        print("%63s : %s"%(item[1],item[0]%item[2]))

class image_request_handler(BaseHTTPRequestHandler):

  def do_POST(self):
    T = Timer("do_POST")
    parsed = urlparse(self.path)
    qs = parse_qs(parsed.query)

    expect = self.headers.getheaders("Expect")
    if len(expect)>=1:
      if True in [item.find("100")>=0 for item in expect]:
        self.send_response(100) # untested; has no apparent affect on libcurl

    # Get arguments by reading body of request.
    # We read this in chunks to avoid straining
    # socket.read(); around the 10 or 15Mb mark, some platforms
    # begin to have problems (bug #792570).
    max_chunk_size = 10*1024*1024
    size_remaining = int(self.headers["content-length"])
    L = []
    while size_remaining:
        chunk_size = min(size_remaining, max_chunk_size)
        L.append(self.rfile.read(chunk_size))
        size_remaining -= len(L[-1])
    data = ''.join(L)
    post_data = StringIO(data)

    # Parse the multipart/form-data
    contentTypeHeader = self.headers.getheaders('content-type').pop()

    # Extract the boundary parameter in the content-type header
    headerParameters = contentTypeHeader.split(";")
    boundary = headerParameters[1].split("=")
    boundary = boundary[1].strip()

    parts = cgi.parse_multipart(post_data,
      {"boundary":boundary,
       "content-disposition":self.headers.getheaders('content-disposition')
      })
    print("*****************************")
    for item in parts.keys():
      if len(parts[item][0])< 1000:
        print(item, parts[item])
    print("*****************************")

    from iotbx.detectors.image_from_http_request import module_or_slice_from_http_request
    imgobj = module_or_slice_from_http_request(parts)
    imgobj.read()
    print("Final image object:")
    imgobj.show_header()

    from spotfinder.diffraction.imagefiles import image_files, file_names
    from spotfinder.diffraction.imagefiles import Spotspickle_argument_module

    from spotfinder.applications.overall_procedure import spotfinder_no_pickle

    class server_imagefiles(image_files):
      def __init__(self): pass

    Files = server_imagefiles()
    Files.filenames = file_names(Spotspickle_argument_module(imgobj.filename))
    Files.images = [imgobj]

    S = spotfinder_no_pickle(Files, s3_passthru = "-s3 4",
                             spot_convention = 0)

    frames = Files.frames()

    logfile = StringIO()
    sys.stdout = logfile

    from spotfinder.applications.stats_distl import pretty_image_stats,notes
    for frame in frames:
      #pretty_image_stats(S,frame)
      #notes(S,frames[0])
      module_image_stats(S,frame)

    sys.stdout = sys.__stdout__
    log = logfile.getvalue()
    print(log)

    ctype = 'text/plain'
    self.send_response(200)
    self.send_header("Content-type", ctype)
    self.send_header("Content-length",len(log))
    self.end_headers()
    self.wfile.write(log)
    self.opt_logging()

  def opt_logging(self):
    pass

if __name__=="__main__":
  import sys
  try:
    port = int(sys.argv[1])
  except Exception:
    print("""
Usage:  libtbx.python adsc_server.py <port number>
""")
  server_address = ('', port)

  image_request_handler.protocol_version = "HTTP/1.0"
  httpd = HTTPServer(server_address, image_request_handler)

  sa = httpd.socket.getsockname()
  print("Serving HTTP on", sa[0], "port", sa[1], "...")
  httpd.serve_forever()