Test of Mapillary oauth

index4.py

#!/usr/bin/env python

from wsgiref.simple_server import make_server
from cgi import parse_qs, escape

import sys
import json
import urllib
import httplib

try:
    import requests
except ImportError:
    print("requests not found - please run: pip install requests")
    sys.exit()

def application (environ, start_response):
    # Application named: Private
    client_id = 'Y0NtM3R4Zm52cTBOSUlrTFAwWFFFQTo3ZGMyNmUxYTIyOGQ4MmUy'
    client_secret = 'Y ... ='
    
    redirect_uri = 'http://localhost:7788/browser/api/index4.py'
    
    url = 'http://www.mapillary.com/connect?'+urllib.urlencode({'client_id':client_id, 'response_type':'token', 'scope':'user:read', 'state':'return', 'redirect_uri':redirect_uri})
    #http://www.mapillary.com/connect?scope=user%3Aread&state=return&redirect_uri=http%3A%2F%2Flocalhost%3A7788%2Ftest.py&response_type=token&client_id=Y0NtM3R4Zm52cTBOSUlrTFAwWFFFQTo5ODcxYTgzMTgzNzVhMTNi
    if len(environ['QUERY_STRING']) == 0:
        # No query string: Step 1: Redirect the user to Mapillary to get permission.
        response_headers = [
            ('Location', url)
        ]
        status = '302 Moved Temporary'
        start_response(status, response_headers)
        response_body = ''
        return [response_body]
    
    # Step 2: Send the access token to Mapillary to get an authorization token:
    
    # Returns a dictionary in which the values are lists
    query_params = parse_qs(environ['QUERY_STRING'])
    
    access_token = query_params['access_token'][0]
    # {'token_type': ['bearer'], 'access_token': ['ey ... Y'], 'expires_in': ['never']}
    
    payload = {'client_id': client_id, 'client_secret': client_secret, 'redirect_uri':redirect_uri, 'grant_type':'authorization_code', 'code':access_token}
    
    data = urllib.urlencode(payload)
    h = httplib.HTTPSConnection('a.mapillary.com')
    headers = {"Content-type": "application/x-www-form-urlencoded", "Accept": "text/plain"}
    h.request('POST', '/v2/oauth/token', data, headers)
    r = h.getresponse()
    resp = r.read()+"\n"+data
    
    status = '200 OK'
    # Use this response_body when it works.
    #response_body = environ['QUERY_STRING']
    response_body = str(resp)
    
    # Now content type is text/html
    response_headers = [
        ('Content-Type', 'text/plain'),
        ('Content-Length', str(len(response_body)))
    ]

    start_response(status, response_headers)
    return [response_body]