from __future__ import absolute_import, division, print_function
import os
from spotfinder.servers.multipart_encoder import post_multipart

def get_spotfinder_url(filename,host,port):
  if filename.find("EXIT")>=0:
    kill_server(host,port)
    return
  testurl = "%s:%d"%(host,port)
  selector = "/spotfinder"
  query_object = [
    ("filename",filename),
    ("bin",1),
  ]

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

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

def kill_server(host,port):
  from socket import error as socketerror
  try:
    while 1:
      testurl = "%s:%d"%(host,port)
      selector = "/spotfinder"
      query_object = [
      ("filename","EXIT"),
      ("bin",1),
      ]

      Response = post_multipart(host=testurl, selector=selector,
      fields = query_object, files = [])
      Response.getresponse()
      Response.close()
  except socketerror as e:
    pass

def do_main(filepath, host, port):
  absfile = os.path.abspath(filepath)
  get_spotfinder_url(absfile,host,port)

def do_main_apache(filepath, host, port):
  absfile = os.path.abspath(filepath)
  from six.moves import urllib
  Response = urllib.request.urlopen(
   "http://%s:%d/spotfinder/distl.signal_strength?filename=%s"%(
   host,port,absfile))
  print(Response.read())
  Response.close()


if __name__=="__main__":
  "Client is intended to be used with [mp_]spotfinder_server_read_file.py"
  import sys
  try:
    filepath, host, port = sys.argv[1:4]
    port = int(port)
  except Exception:
    print("""
Usage:
libtbx.python thin_client.py <filepath> <host> <port>
Three mandatory arguments:
  filepath: absolute or relative path name of the ADSC test image to be analyzed
  host: usually "localhost";
  port: port number of image analyzer http service
""")
  do_main(filepath, host, port)