# Copyright (C) 2012,2014-2015  Codethink Limited
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; version 2 of the License.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License along
# with this program.  If not, see <http://www.gnu.org/licenses/>.


import unittest
import os

import fs.tempfs

import morphlib


class LocalArtifactCacheTests(unittest.TestCase):

    def setUp(self):
        self.tempfs = fs.tempfs.TempFS()

        loader = morphlib.morphloader.MorphologyLoader()
        morph = loader.load_from_string(
            '''
            name: chunk
            kind: chunk
            products:
                - artifact: chunk-runtime
                  include:
                    - usr/bin
                    - usr/sbin
                    - usr/lib
                    - usr/libexec
                - artifact: chunk-devel
                  include:
                    - usr/include
            ''')
        sources = morphlib.source.make_sources('repo', 'ref',
                                               'chunk.morph', 'sha1',
                                               'tree', morph)
        self.source, = sources
        self.source.cache_key = '0'*64
        self.runtime_artifact = morphlib.artifact.Artifact(
            self.source, 'chunk-runtime')
        self.devel_artifact = morphlib.artifact.Artifact(
            self.source, 'chunk-devel')

    def test_artifact_filename(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)
        filename = cache.artifact_filename(self.devel_artifact)
        expected_name = self.tempfs.getsyspath(self.devel_artifact.basename())
        self.assertEqual(filename, expected_name)

    def test_get_source_metadata_filename(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)
        artifact = self.devel_artifact
        source = self.source
        name = 'foobar'

        filename = cache.get_source_metadata_filename(artifact.source,
                                                      source.cache_key, name)
        expected_name = self.tempfs.getsyspath('%s.%s' %
                                               (source.cache_key, name))
        self.assertEqual(filename, expected_name)

    def test_put_artifacts_and_check_whether_the_cache_has_them(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)

        handle = cache.put(self.runtime_artifact)
        handle.write('runtime')
        handle.close()

        self.assertTrue(cache.has(self.runtime_artifact))

        handle = cache.put(self.devel_artifact)
        handle.write('devel')
        handle.close()

        self.assertTrue(cache.has(self.runtime_artifact))
        self.assertTrue(cache.has(self.devel_artifact))

    def test_put_artifacts_and_get_them_afterwards(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)

        handle = cache.put(self.runtime_artifact)
        handle.write('runtime')
        handle.close()

        handle = cache.get(self.runtime_artifact)
        stored_data = handle.read()
        handle.close()

        self.assertEqual(stored_data, 'runtime')

        handle = cache.put(self.devel_artifact)
        handle.write('devel')
        handle.close()

        handle = cache.get(self.runtime_artifact)
        stored_data = handle.read()
        handle.close()

        self.assertEqual(stored_data, 'runtime')

        handle = cache.get(self.devel_artifact)
        stored_data = handle.read()
        handle.close()

        self.assertEqual(stored_data, 'devel')

    def test_put_check_and_get_artifact_metadata(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)

        handle = cache.put_artifact_metadata(self.runtime_artifact, 'log')
        handle.write('log line 1\nlog line 2\n')
        handle.close()

        self.assertTrue(cache.has_artifact_metadata(
            self.runtime_artifact, 'log'))

        handle = cache.get_artifact_metadata(self.runtime_artifact, 'log')
        stored_metadata = handle.read()
        handle.close()

        self.assertEqual(stored_metadata, 'log line 1\nlog line 2\n')

    def test_put_check_and_get_source_metadata(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)

        handle = cache.put_source_metadata(self.source, 'mycachekey', 'log')
        handle.write('source log line 1\nsource log line 2\n')
        handle.close()

        self.assertTrue(cache.has_source_metadata(
            self.source, 'mycachekey', 'log'))

        handle = cache.get_source_metadata(self.source, 'mycachekey', 'log')
        stored_metadata = handle.read()
        handle.close()

        self.assertEqual(stored_metadata,
                         'source log line 1\nsource log line 2\n')

    def test_clears_artifact_cache(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)

        handle = cache.put(self.runtime_artifact)
        handle.write('runtime')
        handle.close()

        self.assertTrue(cache.has(self.runtime_artifact))
        cache.clear()
        self.assertFalse(cache.has(self.runtime_artifact))

    def test_put_artifacts_and_list_them_afterwards(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)

        handle = cache.put(self.runtime_artifact)
        handle.write('runtime')
        handle.close()

        self.assertEqual(len(list(cache.list_contents())), 1)

        handle = cache.put(self.devel_artifact)
        handle.write('devel')
        handle.close()

        self.assertEqual(len(list(cache.list_contents())), 1)

    def test_put_artifacts_and_remove_them_afterwards(self):
        cache = morphlib.localartifactcache.LocalArtifactCache(self.tempfs)

        handle = cache.put(self.runtime_artifact)
        handle.write('runtime')
        handle.close()

        handle = cache.put(self.devel_artifact)
        handle.write('devel')
        handle.close()

        key = list(cache.list_contents())[0][0]
        cache.remove(key)

        self.assertEqual(len(list(cache.list_contents())), 0)