#!/usr/bin/env python3

import argparse
import http.server
import json
import re
from socketserver import ThreadingMixIn
import sys
from pmtiles.reader import read


# https://docs.python.org/3/library/http.server.html
class ThreadingSimpleServer(ThreadingMixIn, http.server.HTTPServer):
    pass

parser = argparse.ArgumentParser(description='Convert between PMTiles and other archive formats.')
parser.add_argument('pmtiles_file',help='PMTiles archive to serve')
parser.add_argument('port',help='Port to bind to')
parser.add_argument('--bind', help='Address to bind server to: default localhost')
parser.add_argument('--cors-allow-all', help='Return Access-Control-Allow-Origin:* header',action='store_true')
args = parser.parse_args()

with read(args.pmtiles_file) as reader:
    fmt = reader.metadata['format']

    class Handler(http.server.SimpleHTTPRequestHandler):
        def do_GET(self):
            if self.path == "/metadata":
                self.send_response(200)
                if args.cors_allow_all:
                    self.send_header('Access-Control-Allow-Origin','*')
                self.end_headers()
                self.wfile.write(json.dumps(reader.metadata).encode('utf-8'))
                return
            match = re.match("/(\d+)/(\d+)/(\d+)." + fmt, self.path)
            if not match:
                self.send_response(400)
                self.end_headers()
                self.wfile.write("bad request".encode('utf-8'))
                return
            z = int(match.group(1))
            x = int(match.group(2))
            y = int(match.group(3))
            data = reader.get(z,x,y)
            if not data:
                self.send_response(404)
                self.end_headers()
                self.wfile.write("tile not found".encode('utf-8'))
                return
            self.send_response(200)
            if args.cors_allow_all:
                self.send_header('Access-Control-Allow-Origin','*')
            if fmt == 'pbf':
                self.send_header('Content-Type','application/x-protobuf')
            else:
                self.send_header('Content-Type','image/' + fmt)
            self.end_headers()
            self.wfile.write(data)

    bind = args.bind or 'localhost'
    print(f'serving {bind}:{args.port}/{{z}}/{{x}}/{{y}}.{fmt}, for development only')
    httpd = ThreadingSimpleServer((args.bind or '', int(args.port)), Handler)
    httpd.serve_forever()