/*
 * Copyright (c) 2016 CA. All rights reserved.
 *
 * This software may be modified and distributed under the terms
 * of the MIT license.  See the LICENSE file for details.
 *
 */

package com.ca.mas;

import android.net.Uri;
import android.util.Base64;

import com.ca.mas.core.http.ContentType;
import com.ca.mas.core.io.IoUtils;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.nio.Buffer;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.UUID;

import okhttp3.mockwebserver.Dispatcher;
import okhttp3.mockwebserver.MockResponse;
import okhttp3.mockwebserver.QueueDispatcher;
import okhttp3.mockwebserver.RecordedRequest;
import okio.BufferedSource;
import okio.Okio;
import okio.Source;
import sun.security.pkcs.PKCS10;

public class GatewayDefaultDispatcher extends QueueDispatcher {

    //Endpoints
    public static final String CONNECT_DEVICE_CONFIG = "/connect/device/config";
    public static final String CONNECT_DEVICE_EXPIRED_CONFIG = "/connect/device/expiredConfig";
    public static final String CONNECT_DEVICE_REGISTER = "/connect/device/register";
    public static final String CONNECT_CLIENT_INITIALIZE = "/connect/client/initialize";
    public static final String AUTH_OAUTH_V2_TOKEN = "/auth/oauth/v2/token";
    public static final String AUTH_OAUTH_V2_REVOKE = "/auth/oauth/v2/token/revoke";
    public static final String PROTECTED_RESOURCE_SLOW = "/protected/resource/slow";
    public static final String PROTECTED_RESOURCE_PRODUCTS_AS_ARRAY = "/protected/resource/productsAsArray";
    public static final String PROTECTED_RESOURCE_PRODUCTS = "/protected/resource/products";
    public static final String DEVICEMETADATA_ENDPOINT = "/connect/device/metadata";
    public static final String TEST_NO_CONTENT = "/testNoContent";
    public static final String AUTH_OAUTH_V2_AUTHORIZE = "/auth/oauth/v2/authorize";
    public static final String CONNECT_DEVICE_REGISTER_CLIENT = "/connect/device/register/client";
    public static final String CONNECT_DEVICE_RENEW = "/connect/device/renew";
    public static final String CONNECT_DEVICE_REMOVE = "/connect/device/remove";
    public static final String CONNECT_SESSION_LOGOUT = "/connect/session/logout";
    public static final String OTP_PROTECTED_URL = "/otpProtected";
    public static final String AUTH_OTP = "/auth/generateOTP";
    public static final String USER_INFO = "/openid/connect/v1/userinfo";
    public static final String ECHO = "/echo";
    public static final String MULTIFACTOR_ENDPOINT = "/multifactor";
    public static final String WELL_KNOW_URI = "/.well-known/openid-configuration";
    public static final String JWKS_URI = "/openid/connect/jwks.json";
    public static final String UPLOAD = "/test/multipart";
    public static final String DOWNLOAD = "/test/download";

    public static final String OTHER = "other";

    public static final String ENTERPRISE_BROWSER = "/connect/enterprise/browser";
    public static final String ENTERPRISE_BROWSER_APPC = "/connect/enterprise/browser/websso/authorize/appc";

    public static final String ID_TOKEN = "dummy-idToken";
    public static final String ID_TOKEN_TYPE = "dummy-idTokenType";

    public static String TARGET_RESPONSE = "{ \"products\": [\n" +
            "    {\"id\": 1, \"name\": \"Red Stapler\", \"price\": \"54.44\"},\n" +
            "    {\"id\": 2, \"name\": \"Chewing Gum Wrapper\", \"price\": \"0.25\"},\n" +
            "    {\"id\": 3, \"name\": \"Microsoft Mouse\", \"price\": \"15.00\"},\n" +
            "    {\"id\": 4, \"name\": \"Mapple Smartphone\", \"price\": \"750.00\"},\n" +
            "    {\"id\": 5, \"name\": \"Can of Cola\", \"price\": \"1.25\"},\n" +
            "    {\"id\": 6, \"name\": \"Backpack\", \"price\": \"32.50\"}\n" +
            "  ],\n" +
            "  \"device_geo\": \"\",\n" +
            "  \"clientCert.subject\": \"CN=admin, OU=000000000000000, DC=sdk, O=Exampletronics Ltd\"\n" +
            "}\n";

    private List<Dispatcher> dispatchers = new ArrayList<>();

    @Override
    public MockResponse dispatch(RecordedRequest request) throws InterruptedException {
        try {
            request.getBody();
            if (request.getPath().contains(CONNECT_DEVICE_CONFIG)) {
                return configDeviceResponse();
            } else if (request.getPath().contains(CONNECT_DEVICE_EXPIRED_CONFIG)) {
                return expiredConfigDeviceResponse();
            } else if (request.getPath().contains(CONNECT_DEVICE_REGISTER)) {
                return registerDeviceResponse(request);
            } else if (request.getPath().contains(CONNECT_CLIENT_INITIALIZE)) {
                return initializeResponse();
            } else if (request.getPath().contains(AUTH_OAUTH_V2_REVOKE)) {
                return revokeTokenResponse();
            } else if (request.getPath().contains(AUTH_OAUTH_V2_TOKEN)) {
                return retrieveTokenResponse();
            } else if (request.getPath().contains(PROTECTED_RESOURCE_PRODUCTS_AS_ARRAY)) {
                return secureServiceResponseAsArray();
            } else if (request.getPath().contains(PROTECTED_RESOURCE_PRODUCTS)) {
                return secureServiceResponse();
            } else if (request.getPath().contains(PROTECTED_RESOURCE_SLOW)) {
                Thread.sleep(1000);
                return secureServiceResponse();
            } else if (request.getPath().contains(TEST_NO_CONTENT)) {
                return secureServiceResponseWithNoContent();
            } else if (request.getPath().contains(WELL_KNOW_URI)) {
                return wellknowURIResponse(request);
            } else if (request.getPath().contains(JWKS_URI)) {
                return jwksURIResponse();
            } else if (request.getPath().contains(AUTH_OAUTH_V2_AUTHORIZE)) {
                return authorizeResponse(request);
            } else if (request.getPath().contains(CONNECT_DEVICE_REGISTER_CLIENT)) {
                return registerDeviceResponse(request);
            } else if (request.getPath().contains(CONNECT_DEVICE_RENEW)) {
                return renewDeviceResponse();
            } else if (request.getPath().contains(CONNECT_SESSION_LOGOUT)) {
                return logout();
            } else if (request.getPath().contains(CONNECT_DEVICE_REMOVE)) {
                return deRegister();
            } else if (request.getPath().contains(OTP_PROTECTED_URL)) {
                String xOtp = request.getHeader("X-OTP");
                if (xOtp == null) {
                    return otpMissingHeader();
                } else {
                    return otpProtectedResponse();
                }
            } else if (request.getPath().contains(AUTH_OTP)) {
                return generateOtp();
            } else if (request.getPath().contains(USER_INFO)) {
                return userInfo();
            } else if (request.getPath().contains(UPLOAD)) {
                return upload(request);
            } else if (request.getPath().contains(DOWNLOAD)) {
                return download(request);
            } else if (request.getPath().startsWith(ENTERPRISE_BROWSER)) {
                return enterpriseBrowser(request);
            } else if (request.getPath().contains(ECHO)) {
                return echo(request);
            } else if (request.getPath().contains(MULTIFACTOR_ENDPOINT)) {
                return multiFactor(request);
            } else if (request.getPath().contains(DEVICEMETADATA_ENDPOINT)) {
                return deviceMetadata();
            }

            for (Dispatcher d : dispatchers) {
                MockResponse response = d.dispatch(request);
                if (response != null) {
                    return response;
                }
            }
            return other();
        } catch (Exception e) {
            return new MockResponse().setResponseCode(HttpURLConnection.HTTP_INTERNAL_ERROR).
                    setBody(e.toString());
        }
    }

    private MockResponse download(RecordedRequest request) throws IOException {
    //TODO send file body
       return new MockResponse()
                .setResponseCode(200)
                .setHeader("Content-Type", "image/png");

    }

    protected MockResponse multiFactor(RecordedRequest request) {
        if (request.getHeader("multi-factor-value") != null) {
            return new MockResponse().setResponseCode(200).setBody("{\"test\":\"test value\"}");
        } else {
            return new MockResponse().setResponseCode(HttpURLConnection.HTTP_BAD_REQUEST).addHeader("x-Dummy-err", "1234");
        }
    }

    private MockResponse echo(RecordedRequest request) {
        Uri uri = Uri.parse(request.getPath());
        return new MockResponse().setResponseCode(HttpURLConnection.HTTP_OK)
                .setBody(uri.getQueryParameter("name"))
                .addHeader("Content-type", ContentType.TEXT_PLAIN.toString());
    }

    protected MockResponse other() {
        return new MockResponse().setResponseCode(HttpURLConnection.HTTP_INTERNAL_ERROR);
    }

    protected MockResponse logout() {
        return new MockResponse().setResponseCode(200).setBody("{\"session_status\":\"logged out\"}");
    }

    protected MockResponse initializeResponse() {
        String result = "{\"client_id\":\"dummy\", \"client_secret\":\"dummy\", \"client_expiration\":" + new Date().getTime() + 36000 + "}";
        return new MockResponse().setResponseCode(200).setBody(result);
    }

    protected MockResponse authorizeResponse(RecordedRequest request) throws IOException, JSONException {
        Uri uri = Uri.parse(request.getPath());
        return new MockResponse()
                .setResponseCode(200)
                .setBody(TestUtils.getJSONObject(uri.getPath()).toString());
    }

    protected MockResponse deRegister() {
        return new MockResponse()
                .setResponseCode(200);
    }

    protected MockResponse configDeviceResponse() {
        byte[] bytes = new byte[0];
        try {
            bytes = IoUtils.slurpStream(getClass().getResourceAsStream("/msso_config.json"), 10485760);
            JSONObject jsonObject = new JSONObject(new String(bytes));
            return new MockResponse()
                    .setResponseCode(200)
                    .setBody(jsonObject.toString())
                    .addHeader("Content-type", ContentType.APPLICATION_JSON.toString());
        } catch (Exception e) {
            return new MockResponse().setResponseCode(HttpURLConnection.HTTP_INTERNAL_ERROR);
        }
    }

    protected MockResponse expiredConfigDeviceResponse() {
        try {
            JSONObject jsonObject = new JSONObject("{\n" +
                    "  \"error\": \"invalid_request\",\n" +
                    "  \"error_description\": \"The server configuration is invalid. Contact the administrator\"\n" +
                    "}");
            return new MockResponse()
                    .setResponseCode(400)
                    .setHeader("x-ca-err", "132")
                    .setBody(jsonObject.toString())
                    .addHeader("Content-type", ContentType.APPLICATION_JSON.toString());
        } catch (Exception e) {
            return new MockResponse().setResponseCode(HttpURLConnection.HTTP_INTERNAL_ERROR);
        }
    }


    protected MockResponse registerDeviceResponse(RecordedRequest request) {

        String magIdentifier = UUID.randomUUID().toString();

        PKCS10 pkcs10 = null;
        try {
            pkcs10 = new PKCS10(Base64.decode(request.getBody().readByteArray(), Base64.NO_WRAP | Base64.NO_PADDING | Base64.URL_SAFE));
        } catch (Exception e) {
            return new MockResponse().setResponseCode(HttpURLConnection.HTTP_INTERNAL_ERROR);
        }
        DataSource.getInstance().storeDevice(magIdentifier, new DataSource.Device(pkcs10.getSubjectPublicKeyInfo()));

        //Mock response for device registration
        String cert = "-----BEGIN CERTIFICATE-----\n" +
                "MIIDGDCCAgCgAwIBAgIIaJHtKa4XQj4wDQYJKoZIhvcNAQEMBQAwKjEoMCYGA1UEAxMfbW9iaWxl\n" +
                "LXN0YWdpbmctbXlzcWwubDd0ZWNoLmNvbTAeFw0xNzAxMDQxNzI2MzlaFw0yNzAxMDIxNzI2Mzla\n" +
                "MCoxKDAmBgNVBAMTH21vYmlsZS1zdGFnaW5nLW15c3FsLmw3dGVjaC5jb20wggEiMA0GCSqGSIb3\n" +
                "DQEBAQUAA4IBDwAwggEKAoIBAQDsr6QwY8DL7J4aa1MWt+qmJKDGk/4M7Cx7sSUiMvuc9S3cGddQ\n" +
                "lYOaQsg1a6H8DzsCE7WkX/CcYvJSQ/V26pQfbuwp39C7kTofo5OXZNbQX0EYJjUDfJsZ0lo1GUkn\n" +
                "dCX0ugR1/NXAzmZYcTGIFVi/y2mMynZHLeEZUKL/O3vS3uniEw4qcxQ2Jz1qT4gGJJNcHHM+4SqV\n" +
                "17yXm5trvr1aHey3G3KgQWVo0OQ/vZoiRSURADUvWRsym+6CALp73KS1wtbsopE2VtSLrm4ztBbH\n" +
                "EfH/mp4PkZjpNisoaJwyqCCP+f7ITYSXnjuiGrC/z1KrENGCzXSJl3lHjUFOiZYnAgMBAAGjQjBA\n" +
                "MB0GA1UdDgQWBBRF0EYejzI/wOSIrB+kz+FgATJdcDAfBgNVHSMEGDAWgBRF0EYejzI/wOSIrB+k\n" +
                "z+FgATJdcDANBgkqhkiG9w0BAQwFAAOCAQEAOKKUsR3RsYCtiJ+3omovqDFmexlWlW02we0ELwia\n" +
                "312ATazQPFTxjiHnOyhG+K67ItqTbz3X7vQP8yvQ91JWTHesebnYSxJEAqTEiBC2uLPP7XqUWnJa\n" +
                "J/XGMAhRVIbkaHfzleWl+BtG++B4tclHqhRWrPfP5S1Ys3SCvmhte09XAmuuPYnuzsoZwJVpx/UJ\n" +
                "lYxOuSIkYxUOCzGVp7qUYBVzMVW2MEKOiJvAuXM0aeY5+D5Z6uMs+F58W5nbYCgjLTVXRAm46ntG\n" +
                "NP9R2i3LWnjHhdN+WLtSsmj6dFtzjQbrS9LXa8bR4GRncA34UdW/LMsyiJzd2Iy8mfe2sQu3Zg==\n" +
                "-----END CERTIFICATE-----";
        return new MockResponse()
                .setResponseCode(200)
                .setHeader("device-status", "activated")
                .setHeader("mag-identifier", magIdentifier)
                .setHeader("id-token", ID_TOKEN)
                .setHeader("id-token-type", ID_TOKEN_TYPE)
                .setBody(cert);

    }

    protected MockResponse renewDeviceResponse() {
        String newCert = "-----BEGIN CERTIFICATE-----\n" +
                "MIIDGDCCAgCgAwIBAgIIaJHtKa4XQj4wDQYJKoZIhvcNAQEMBQAwKjEoMCYGA1UEAxMfbW9iaWxl\n" +
                "LXN0YWdpbmctbXlzcWwubDd0ZWNoLmNvbTAeFw0xNzAxMDQxNzI2MzlaFw0yNzAxMDIxNzI2Mzla\n" +
                "MCoxKDAmBgNVBAMTH21vYmlsZS1zdGFnaW5nLW15c3FsLmw3dGVjaC5jb20wggEiMA0GCSqGSIb3\n" +
                "DQEBAQUAA4IBDwAwggEKAoIBAQDsr6QwY8DL7J4aa1MWt+qmJKDGk/4M7Cx7sSUiMvuc9S3cGddQ\n" +
                "lYOaQsg1a6H8DzsCE7WkX/CcYvJSQ/V26pQfbuwp39C7kTofo5OXZNbQX0EYJjUDfJsZ0lo1GUkn\n" +
                "dCX0ugR1/NXAzmZYcTGIFVi/y2mMynZHLeEZUKL/O3vS3uniEw4qcxQ2Jz1qT4gGJJNcHHM+4SqV\n" +
                "17yXm5trvr1aHey3G3KgQWVo0OQ/vZoiRSURADUvWRsym+6CALp73KS1wtbsopE2VtSLrm4ztBbH\n" +
                "EfH/mp4PkZjpNisoaJwyqCCP+f7ITYSXnjuiGrC/z1KrENGCzXSJl3lHjUFOiZYnAgMBAAGjQjBA\n" +
                "MB0GA1UdDgQWBBRF0EYejzI/wOSIrB+kz+FgATJdcDAfBgNVHSMEGDAWgBRF0EYejzI/wOSIrB+k\n" +
                "z+FgATJdcDANBgkqhkiG9w0BAQwFAAOCAQEAOKKUsR3RsYCtiJ+3omovqDFmexlWlW02we0ELwia\n" +
                "312ATazQPFTxjiHnOyhG+K67ItqTbz3X7vQP8yvQ91JWTHesebnYSxJEAqTEiBC2uLPP7XqUWnJa\n" +
                "J/XGMAhRVIbkaHfzleWl+BtG++B4tclHqhRWrPfP5S1Ys3SCvmhte09XAmuuPYnuzsoZwJVpx/UJ\n" +
                "lYxOuSIkYxUOCzGVp7qUYBVzMVW2MEKOiJvAuXM0aeY5+D5Z6uMs+F58W5nbYCgjLTVXRAm46ntG\n" +
                "NP9R2i3LWnjHhdN+WLtSsmj6dFtzjQbrS9LXa8bR4GRncA34UdW/LMsyiJzd2Iy8mfe2sQu3Zg==\n" +
                "-----END CERTIFICATE-----";
        //Mock response for device renew
        return new MockResponse()
                .setResponseCode(200)
                .setBody(newCert)
                .setHeader("mag-identifier", "test-device");

    }


    protected MockResponse registerDeviceClientResponse() {

        //Mock response for device registration
        String cert = "-----BEGIN CERTIFICATE-----\n" +
                "MIIDGDCCAgCgAwIBAgIIaJHtKa4XQj4wDQYJKoZIhvcNAQEMBQAwKjEoMCYGA1UEAxMfbW9iaWxl\n" +
                "LXN0YWdpbmctbXlzcWwubDd0ZWNoLmNvbTAeFw0xNzAxMDQxNzI2MzlaFw0yNzAxMDIxNzI2Mzla\n" +
                "MCoxKDAmBgNVBAMTH21vYmlsZS1zdGFnaW5nLW15c3FsLmw3dGVjaC5jb20wggEiMA0GCSqGSIb3\n" +
                "DQEBAQUAA4IBDwAwggEKAoIBAQDsr6QwY8DL7J4aa1MWt+qmJKDGk/4M7Cx7sSUiMvuc9S3cGddQ\n" +
                "lYOaQsg1a6H8DzsCE7WkX/CcYvJSQ/V26pQfbuwp39C7kTofo5OXZNbQX0EYJjUDfJsZ0lo1GUkn\n" +
                "dCX0ugR1/NXAzmZYcTGIFVi/y2mMynZHLeEZUKL/O3vS3uniEw4qcxQ2Jz1qT4gGJJNcHHM+4SqV\n" +
                "17yXm5trvr1aHey3G3KgQWVo0OQ/vZoiRSURADUvWRsym+6CALp73KS1wtbsopE2VtSLrm4ztBbH\n" +
                "EfH/mp4PkZjpNisoaJwyqCCP+f7ITYSXnjuiGrC/z1KrENGCzXSJl3lHjUFOiZYnAgMBAAGjQjBA\n" +
                "MB0GA1UdDgQWBBRF0EYejzI/wOSIrB+kz+FgATJdcDAfBgNVHSMEGDAWgBRF0EYejzI/wOSIrB+k\n" +
                "z+FgATJdcDANBgkqhkiG9w0BAQwFAAOCAQEAOKKUsR3RsYCtiJ+3omovqDFmexlWlW02we0ELwia\n" +
                "312ATazQPFTxjiHnOyhG+K67ItqTbz3X7vQP8yvQ91JWTHesebnYSxJEAqTEiBC2uLPP7XqUWnJa\n" +
                "J/XGMAhRVIbkaHfzleWl+BtG++B4tclHqhRWrPfP5S1Ys3SCvmhte09XAmuuPYnuzsoZwJVpx/UJ\n" +
                "lYxOuSIkYxUOCzGVp7qUYBVzMVW2MEKOiJvAuXM0aeY5+D5Z6uMs+F58W5nbYCgjLTVXRAm46ntG\n" +
                "NP9R2i3LWnjHhdN+WLtSsmj6dFtzjQbrS9LXa8bR4GRncA34UdW/LMsyiJzd2Iy8mfe2sQu3Zg==\n" +
                "-----END CERTIFICATE-----";
        return new MockResponse()
                .setResponseCode(200)
                .setHeader("device-status", "activated")
                .setHeader("mag-identifier", "test-device")
                .setBody(cert);
    }


    protected MockResponse retrieveTokenResponse() {
        //Mock response for retrieve token
        String token = "{\n" +
                "  \"access_token\":\"caa5871c-7c0f-44c7-b03b-1783609170e4\",\n" +
                "  \"token_type\":\"Bearer\",\n" +
                "  \"expires_in\":" + 3600 + ",\n" +
                "  \"refresh_token\":\"19785fca-4b86-4f8e-a73c-7de1d420f88d\",\n" +
                "  \"scope\":\"openid msso phone profile address email msso_register msso_client_register mas_messaging mas_storage mas_identity mas_identity_retrieve_users mas_identity_create_users mas_identity_update_users mas_identity_delete_users mas_identity_retrieve_groups mas_identity_create_groups mas_identity_update_groups mas_identity_delete_groups\"\n" +
                "}";
        return new MockResponse().setResponseCode(200).setBody(token);

    }

    protected MockResponse revokeTokenResponse() {
        //Mock response for retrieve token
        String token = "{\n" +
                "  \"result\":\"revoked\"\n" +
                "}";
        return new MockResponse().setResponseCode(200).setBody(token);

    }

    protected MockResponse retrieveTokenResponseWithIdToken() {
        //Mock response for retrieve token
        String token = "{\n" +
                "  \"access_token\":\"caa5871c-7c0f-44c7-b03b-1783609170e4\",\n" +
                "  \"token_type\":\"Bearer\",\n" +
                "  \"expires_in\":3600,\n" +
                "  \"refresh_token\":\"19785fca-4b86-4f8e-a73c-7de1d420f88d\",\n" +
                "  \"scope\":\"openid msso phone profile address email msso_register msso_client_register mas_messaging mas_storage mas_identity mas_identity_retrieve_users mas_identity_create_users mas_identity_update_users mas_identity_delete_users mas_identity_retrieve_groups mas_identity_create_groups mas_identity_update_groups mas_identity_delete_groups\",\n" +
                "  \"id-token\":\"dummy-idToken\",\n" +
                "  \"id-token-type\":\"dummy-idTokenType\"\n" +
                "}";
        return new MockResponse().setResponseCode(200).setBody(token);
    }

    protected MockResponse secureServiceResponse() {
        //Mock response for the secure service
        return new MockResponse().setResponseCode(200)
                .setBody(TARGET_RESPONSE)
                .addHeader("Content-type", ContentType.APPLICATION_JSON.toString());
    }

    protected MockResponse secureServiceResponseWithNoContent() {
        return new MockResponse().setResponseCode(HttpURLConnection.HTTP_NO_CONTENT);
    }

    protected MockResponse secureServiceResponseAsArray() {
        //Mock response for the secure service
        try {
            JSONArray jsonArray = new JSONArray("[\n" +
                    "  \"test1\",\n" +
                    "  \"test2\",\n" +
                    "  \"test3\"\n" +
                    "]");
            return new MockResponse().setResponseCode(200)
                    .setBody(jsonArray.toString())
                    .addHeader("Content-type", ContentType.APPLICATION_JSON.toString());

        } catch (JSONException e) {
            return new MockResponse().setResponseCode(HttpURLConnection.HTTP_INTERNAL_ERROR);
        }


    }

    protected MockResponse otpProtectedResponse() {
        return new MockResponse().setResponseCode(200)
                .addHeader("Content-type", ContentType.TEXT_PLAIN);
    }

    protected MockResponse otpMissingHeader() {
        return new MockResponse().setResponseCode(401)
                .setHeader("WWW-Authenticate", "Basic realm=\"fake\"")
                .setHeader("X-OTP", "required")
                .setHeader("X-OTP-CHANNEL", "EMAIL,SMS,QRCODE")
                .setHeader("x-ca-err", "8000140")
                .setBody("{\n" +
                        "error\":\"otp_select_channel\",\n" +
                        "\"error_description\":\"This page is OTP protected. Please select the channel for OTP delivery.\"\n" +
                        "}\n");
    }

    protected MockResponse generateOtp() {
        return new MockResponse().setResponseCode(200)
                .setHeader("X-OTP", "generated");
    }

    protected MockResponse deviceMetadataErrorOverflow() throws JSONException {
        return new MockResponse().setResponseCode(400)
                .setHeader("Content-type", ContentType.APPLICATION_JSON)
                .setHeader("x-ca-err", "1016155");
    }

    protected MockResponse deviceMetadata() throws JSONException {
        JSONObject data = new JSONObject();
        data.put("name", "attr");
        data.put("value", "attrVAlue");
        return new MockResponse().setResponseCode(200)
                .setHeader("Content-type", ContentType.APPLICATION_JSON)
                .setBody(data.toString());
    }

    protected MockResponse userInfo() {
        return new MockResponse().setResponseCode(200)
                .setHeader("Content-type", ContentType.APPLICATION_JSON)
                .setBody("{\n" +
                        "  \"sub\": \"6vKMGM8Xsw6o54D-FurMX1zXDhYLrf9fBBPFr-HwWXY\",\n" +
                        "  \"given_name\": \"Admin\",\n" +
                        "  \"family_name\": \"Admin\",\n" +
                        "  \"preferred_username\": \"admin\",\n" +
                        "  \"picture\": \"https://photos.example.com/profilephoto/72930000000Ccne/F\",\n" +
                        "  \"email\": \"sarek@layer7tech.com\",\n" +
                        "  \"phone_number\": \"555-555-5555\",\n" +
                        "  \"address\": {\n" +
                        "    \"street_address\": \"100 Universal City Plaza\",\n" +
                        "    \"locality\": \"Hollywood\",\n" +
                        "    \"region\": \"CA\",\n" +
                        "    \"postal_code\": \"91608\",\n" +
                        "    \"country\": \"USA\"\n" +
                        "  }\n" +
                        "}");
    }

    protected MockResponse enterpriseBrowser(RecordedRequest request) throws IOException, JSONException {
        return new MockResponse().setResponseCode(200)
                .setHeader("Content-type", ContentType.APPLICATION_JSON)
                .setBody(TestUtils.getJSONObject(request.getPath()).toString());

    }

    public void addDispatcher(Dispatcher queueDispatcher) {
        this.dispatchers.add(queueDispatcher);
    }


    private MockResponse wellknowURIResponse(RecordedRequest request) {

        String result = "{\"issuer\":\"https://localhost:41979\",\"authorization_endpoint\":\"https://localhost:41979/auth/oauth/v2/authorize\",\"token_endpoint\":\"https://localhost:41979/auth/oauth/v2/token\",\"jwks_uri\":\"https://localhost:41979/openid/connect/jwks.json\",\"response_types_supported\":[\"code\", \"token id_token\", \"token\", \"code id_token\", \"id_token\", \"code token\", \"code id_token token\"],\"subject_types_supported\":[\"pairwise\"],\"id_token_signing_alg_values_supported\":[\"RS256\", \"HS256\"],\"userinfo_endpoint\":\"https://localhost:41979/openid/connect/v1/userinfo\",\"registration_endpoint\":\"https://localhost:41979/openid/connect/register\",\"scopes_supported\":[\"openid\", \"email\", \"profile\", \"openid_client_registration\"],\"claims_supported\":[\"sub\", \"iss\", \"auth_time\", \"acr\", \"aud\", \"azp\", \"exp\", \"c_hash\", \"at_hash\", \"nonce\"],\"grant_types_supported\":[\"authorization_code\", \"implicit\", \"refresh_token\"],\"acr_values_supported\":[\"0\"],\"token_endpoint_auth_methods_supported\":[\"client_secret_basic\", \"client_secret_post\", \"client_secret_jwt\", \"private_key_jwt\"],\"token_endpoint_auth_signing_alg_values_supported\":[\"RS256\", \"HS256\"],\"display_values_supported\":[\"page\"],\"claim_types_supported\":[\"normal\"],\"service_documentation\":\"https://localhost:41979/apidocs/auth/oauth/v2/swagger\",\"ui_locales_supported\":[\"en-US\"],\"response_modes_supported\":[\"query\", \"fragment\", \"form_post\"],\"userinfo_signing_alg_values_supported\":[\"RS256\", \"HS256\"]}";

        return new MockResponse().setResponseCode(200).setBody(result);
    }

    protected MockResponse jwksURIResponse() {

        String result = "{\n" +
                "  \"keys\" : [ {\n" +
                "    \"kty\" : \"RSA\",\n" +
                "    \"kid\" : \"default_ssl_key\",\n" +
                "    \"use\" : \"sig\",\n" +
                "    \"n\" : \"p3y7NtvnADvbPV-tQXjUjMcqbWrxwXrJaqUhs0KnIpLLrehgHZo-w7h7tNOqW4Av7wGUZ4j54zaHdqwuwGTMegeZHgrcEITxjsYAA5eRO2uo4Yiqr2hUjmpb04HgvEsoQE5Gr1wrBrw8M6pphvp92X5lGGtWgjo8ZZDQJyt6dhp5MoJdTYChcN8fEsF-ZckhmWklsYylI8VoQDpx7jj--w5g7TSIMiBsTICRnrE_oJfE0_LNxlOL9gyycNZl9Os60tYO9qIvYjsZrfTv9urcTAshbsS1W6JVCGGnA82WCEoEpxldTeombDYVNGXwkHOb7Aqk_6AgnrHp98ZXephO8w\",\n" +
                "    \"e\" : \"AQAB\",\n" +
                "    \"x5c\" : [ \"MIIC9zCCAd+gAwIBAgIJAKtskkc74amlMA0GCSqGSIb3DQEBDAUAMBkxFzAVBgNVBAMTDm1hZ2ZpZG8uY2EuY29tMB4XDTE3MDcxNDA4MjcwMVoXDTI3MDcxMjA4MjcwMVowGTEXMBUGA1UEAxMObWFnZmlkby5jYS5jb20wggEiMA0GCSqGSIb3DQEBAQUAA4IBDwAwggEKAoIBAQCnfLs22+cAO9s9X61BeNSMxyptavHBeslqpSGzQqciksut6GAdmj7DuHu006pbgC/vAZRniPnjNod2rC7AZMx6B5keCtwQhPGOxgADl5E7a6jhiKqvaFSOalvTgeC8SyhATkavXCsGvDwzqmmG+n3ZfmUYa1aCOjxlkNAnK3p2Gnkygl1NgKFw3x8SwX5lySGZaSWxjKUjxWhAOnHuOP77DmDtNIgyIGxMgJGesT+gl8TT8s3GU4v2DLJw1mX06zrS1g72oi9iOxmt9O/26txMCyFuxLVbolUIYacDzZYISgSnGV1N6iZsNhU0ZfCQc5vsCqT/oCCesen3xld6mE7zAgMBAAGjQjBAMB0GA1UdDgQWBBRtEbLFE1SiG8EXI+047xM+hhBOKzAfBgNVHSMEGDAWgBRtEbLFE1SiG8EXI+047xM+hhBOKzANBgkqhkiG9w0BAQwFAAOCAQEApENK8QSc2i/KHM7HtbG78v44lZletODNdjCVIUAMHIQb/zCoOgKSicMEfP4xa1QSOQb1qA5hv7WWEfPRop4/BY3p0sNNmEIfnCenG9sYwfB4Nx4UEmN7qQZvFzQGuLEvz1xP5k3uot51lLi6yUwtyNsC84tgaA1xbaap2dlxH7K/ILg05vZ2I9TE4wdZl33E2io72KaJFJBaWzJCTpa1R3q4EloaAeim/BSuZTXhLxelKgY9ozJmcFhnA2VtY2mjATjy+2QiLfALBnjq5FYjsmSAJslwvHgida2i9LBqlk70chZNRPNtOh9tx8hF/tdKmXodTvYP1PzAhuNKp6tgNw==\" ],\n" +
                "    \"x5t\" : \"zAVqfuMe21XaBOWNGvwdKmPzJNo=\"\n" +
                "  } ]\n" +
                "}";

        return new MockResponse().setResponseCode(200).setBody(result).addHeader("Content-type", ContentType.APPLICATION_JSON.toString());
    }

    protected MockResponse upload(RecordedRequest request) throws IOException, JSONException {

        String reqBody = request.getBody().readUtf8();
        return new MockResponse().setResponseCode(200)
                .setHeader("Content-type", ContentType.APPLICATION_JSON)
                .setBody(reqBody);

    }

}