# Copyright 2017 Google LLC
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.

import unittest

import mock

from google.cloud.datastore.client import _HAVE_GRPC


@unittest.skipUnless(_HAVE_GRPC, "No gRPC")
class Test_make_datastore_api(unittest.TestCase):
    def _call_fut(self, client):
        from google.cloud.datastore._gapic import make_datastore_api

        return make_datastore_api(client)

    @mock.patch(
        "google.cloud.datastore_v1.gapic.datastore_client.DatastoreClient",
        return_value=mock.sentinel.ds_client,
    )
    @mock.patch(
        "google.cloud.datastore._gapic.make_secure_channel",
        return_value=mock.sentinel.channel,
    )
    def test_live_api(self, make_chan, mock_klass):
        from google.cloud._http import DEFAULT_USER_AGENT

        base_url = "https://datastore.googleapis.com:443"
        client = mock.Mock(
            _base_url=base_url,
            _credentials=mock.sentinel.credentials,
            spec=["_base_url", "_credentials"],
        )
        ds_api = self._call_fut(client)
        self.assertIs(ds_api, mock.sentinel.ds_client)

        make_chan.assert_called_once_with(
            mock.sentinel.credentials,
            DEFAULT_USER_AGENT,
            "datastore.googleapis.com:443",
        )
        mock_klass.assert_called_once_with(
            channel=mock.sentinel.channel, client_info=mock.ANY
        )

    @mock.patch(
        "google.cloud.datastore_v1.gapic.datastore_client.DatastoreClient",
        return_value=mock.sentinel.ds_client,
    )
    @mock.patch(
        "google.cloud.datastore._gapic.insecure_channel",
        return_value=mock.sentinel.channel,
    )
    def test_emulator(self, make_chan, mock_klass):

        host = "localhost:8901"
        base_url = "http://" + host
        client = mock.Mock(
            _base_url=base_url,
            _credentials=mock.sentinel.credentials,
            spec=["_base_url", "_credentials"],
        )
        ds_api = self._call_fut(client)
        self.assertIs(ds_api, mock.sentinel.ds_client)

        make_chan.assert_called_once_with(host)
        mock_klass.assert_called_once_with(
            channel=mock.sentinel.channel, client_info=mock.ANY
        )
