commit.message = safe_str(message)

        # Compute date

        if date is None:

            date = time.time()

        elif isinstance(date, datetime.datetime):

            date = time.mktime(date.timetuple())

        author_time = kwargs.pop('author_time', date)

        commit.commit_time = int(date)

        commit.author_time = int(author_time)

        tz = time.timezone

        author_tz = kwargs.pop('author_timezone', tz)

        commit.commit_timezone = tz

        commit.author_timezone = author_tz

        object_store.add_object(commit)

        ref = 'refs/heads/%s' % branch

        repo.refs[ref] = commit.id

        repo.refs.set_symbolic_ref('HEAD', ref)

        # Update vcs repository object & recreate dulwich repo

        self.repository.revisions.append(commit.id)

        # invalidate parsed refs after commit

        self.repository._parsed_refs = self.repository._get_parsed_refs()

        tip = self.repository.get_changeset()

        self.reset()

        return tip

    def _get_missing_trees(self, path, root_tree):

        """

        Creates missing ``Tree`` objects for the given path.

        :param path: path given as a string. It may be a path to a file node

          (i.e. ``foo/bar/baz.txt``) or directory path - in that case it must

          end with slash (i.e. ``foo/bar/``).

        :param root_tree: ``dulwich.objects.Tree`` object from which we start

          traversing (should be commit's root tree)

        """

        dirpath = posixpath.split(path)[0]

        dirs = dirpath.split('/')

        if not dirs or dirs == ['']:

            return []

        def get_tree_for_dir(tree, dirname):

            for name, mode, id in tree.iteritems():

                if name == dirname:

                        '992f38217b979d0b0987d0bae3cc26dac85d9b19',

                        '78c3f0c23b7ee935ec276acb8b8212444c33c396',

                        '992f38217b979d0b0987d0bae3cc26dac85d9b19',

                        '992f38217b979d0b0987d0bae3cc26dac85d9b19',

                        '992f38217b979d0b0987d0bae3cc26dac85d9b19',

                        '16fba1ae9334d79b66d7afed2c2dfbfa2ae53647',

                        '16fba1ae9334d79b66d7afed2c2dfbfa2ae53647',

                        '16fba1ae9334d79b66d7afed2c2dfbfa2ae53647',

                        '16fba1ae9334d79b66d7afed2c2dfbfa2ae53647',

                        '992f38217b979d0b0987d0bae3cc26dac85d9b19',

                        '16fba1ae9334d79b66d7afed2c2dfbfa2ae53647',

                        '992f38217b979d0b0987d0bae3cc26dac85d9b19',

                        '992f38217b979d0b0987d0bae3cc26dac85d9b19',

                        '16fba1ae9334d79b66d7afed2c2dfbfa2ae53647',

                        '16fba1ae9334d79b66d7afed2c2dfbfa2ae53647',

                        '16fba1ae9334d79b66d7afed2c2dfbfa2ae53647',

                    ],

                },

            },

        }

        for fname, revision_dict in files.items():

            for rev, data in revision_dict.items():

                cs = self.repo.get_changeset(rev)

                l2 = files[fname][rev]['changesets']

                self.assertTrue(l1 == l2 , "The lists of revision for %s@rev %s"

                                "from annotation list should match each other, "

                                "got \n%s \nvs \n%s " % (fname, rev, l1, l2))

    def test_files_state(self):

        """

        Tests state of FileNodes.

        """

        node = self.repo\

            .get_changeset('e6ea6d16e2f26250124a1f4b4fe37a912f9d86a0')\

            .get_node('vcs/utils/diffs.py')

        self.assertTrue(node.state, NodeState.ADDED)

        self.assertTrue(node.added)

        self.assertFalse(node.changed)

        self.assertFalse(node.not_changed)

        self.assertFalse(node.removed)

        node = self.repo\

            .get_changeset('33fa3223355104431402a888fa77a4e9956feb3e')\

            .get_node('.hgignore')

        self.assertTrue(node.state, NodeState.CHANGED)

        self.assertFalse(node.added)

        self.assertTrue(node.changed)

                   20: {'lines_no': 1,

                        'changesets': [4]},

                   55: {'lines_no': 31,

                        'changesets': [32, 32, 45, 32, 32, 37, 32, 32, 32, 44,

                                       37, 37, 37, 37, 45, 37, 44, 37, 37, 37,

                                       32, 32, 32, 32, 37, 32, 37, 37, 32,

                                       32, 32]}},

                 'vcs/exceptions.py':

                 {89: {'lines_no': 18,

                       'changesets': [16, 16, 16, 16, 16, 16, 16, 16, 16, 16,

                                      16, 16, 17, 16, 16, 18, 18, 18]},

                  20: {'lines_no': 18,

                       'changesets': [16, 16, 16, 16, 16, 16, 16, 16, 16, 16,

                                      16, 16, 17, 16, 16, 18, 18, 18]},

                  55: {'lines_no': 18, 'changesets': [16, 16, 16, 16, 16, 16,

                                                      16, 16, 16, 16, 16, 16,

                                                      17, 16, 16, 18, 18, 18]}},

                 'MANIFEST.in': {89: {'lines_no': 5,

                                      'changesets': [7, 7, 7, 71, 71]},

                                 20: {'lines_no': 3,

                                      'changesets': [7, 7, 7]},

                                 55: {'lines_no': 3,

                                     'changesets': [7, 7, 7]}}}

        for fname, revision_dict in files.items():

            for rev, data in revision_dict.items():

                cs = self.repo.get_changeset(rev)

                l2 = files[fname][rev]['changesets']

                self.assertTrue(l1 == l2 , "The lists of revision for %s@rev%s"

                                "from annotation list should match each other,"

                                "got \n%s \nvs \n%s " % (fname, rev, l1, l2))

    def test_changeset_state(self):

        """

        Tests which files have been added/changed/removed at particular revision

        """

        # rev 46ad32a4f974:

        # hg st --rev 46ad32a4f974

        #    changed: 13

        #    added:   20

        #    removed: 1

        changed = set(['.hgignore'

            , 'README.rst' , 'docs/conf.py' , 'docs/index.rst' , 'setup.py'

            , 'tests/test_hg.py' , 'tests/test_nodes.py' , 'vcs/__init__.py'

            , 'vcs/backends/__init__.py' , 'vcs/backends/base.py'

            , 'vcs/backends/hg.py' , 'vcs/nodes.py' , 'vcs/utils/__init__.py'])

        added = set(['docs/api/backends/hg.rst'

            , 'docs/api/backends/index.rst' , 'docs/api/index.rst'

            , 'docs/api/nodes.rst' , 'docs/api/web/index.rst'