# -*- coding: utf-8 -*-

# 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, either version 3 of the License, or

# (at your option) any later version.

#

# 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/>.

"""

kallithea.bin.ldap_sync

~~~~~~~~~~~~~~~~~~~~~~~

LDAP sync script

This file was forked by the Kallithea project in July 2014.

Original author and date, and relevant copyright and licensing information is below:

:created_on: Mar 06, 2013

:author: marcink

:copyright: (c) 2013 RhodeCode GmbH, and others.

:license: GPLv3, see LICENSE.md for more details.

"""

from __future__ import print_function

import urllib2

import uuid

from ConfigParser import ConfigParser

import ldap

from kallithea.lib.compat import json

config = ConfigParser()

config.read('ldap_sync.conf')

class InvalidResponseIDError(Exception):

    """ Request and response don't have the same UUID. """

class ResponseError(Exception):

    """ Response has an error, something went wrong with request execution. """

class UserAlreadyInGroupError(Exception):

    """ User is already a member of the target group. """

class UserNotInGroupError(Exception):

    """ User is not a member of the target group. """

class API(object):

    def __init__(self, url, key):

        self.url = url

        self.key = key

    def get_api_data(self, uid, method, args):

        """Prepare dict for API post."""

        return {

            "id": uid,

            "api_key": self.key,

            "method": method,

            "args": args

        }

    def post(self, method, args):

        """Send a generic API post to Kallithea.

        This will generate the UUID for validation check after the

        response is returned. Handle errors and get the result back.

        """

        uid = str(uuid.uuid1())

        data = self.get_api_data(uid, method, args)

        data = json.dumps(data)

        headers = {'content-type': 'text/plain'}

        req = urllib2.Request(self.url, data, headers)

        response = urllib2.urlopen(req)

        response = json.load(response)

        if uid != response["id"]:

            raise InvalidResponseIDError("UUID does not match.")

        if response["error"] is not None:

            raise ResponseError(response["error"])

        return response["result"]

    def create_group(self, name, active=True):

        """Create the Kallithea user group."""

        args = {

            "group_name": name,

            "active": str(active)

        }

        self.post("create_user_group", args)

    def add_membership(self, group, username):

        """Add specific user to a group."""

        args = {

            "usersgroupid": group,

            "userid": username

        }

        result = self.post("add_user_to_user_group", args)

        if not result["success"]:

            raise UserAlreadyInGroupError("User %s already in group %s." %

                                          (username, group))

    def remove_membership(self, group, username):

        """Remove specific user from a group."""

        args = {

            "usersgroupid": group,

            "userid": username

        }

        result = self.post("remove_user_from_user_group", args)

        if not result["success"]:

            raise UserNotInGroupError("User %s not in group %s." %

                                      (username, group))

    def get_group_members(self, name):

        """Get the list of member usernames from a user group."""

        args = {"usersgroupid": name}

        members = self.post("get_user_group", args)['members']

        member_list = []

        for member in members:

            member_list.append(member["username"])

        return member_list

    def get_group(self, name):

        """Return group info."""

        args = {"usersgroupid": name}

        return self.post("get_user_group", args)

    def get_user(self, username):

        """Return user info."""

        args = {"userid": username}

        return self.post("get_user", args)

class LdapClient(object):

    def __init__(self, uri, user, key, base_dn):

        self.client = ldap.initialize(uri, trace_level=0)

        self.client.set_option(ldap.OPT_REFERRALS, 0)

        self.client.simple_bind(user, key)

        self.base_dn = base_dn

    def close(self):

        self.client.unbind()

    def get_groups(self):

        """Get all the groups in form of dict {group_name: group_info,...}."""

        searchFilter = "objectClass=groupOfUniqueNames"

        result = self.client.search_s(self.base_dn, ldap.SCOPE_SUBTREE,

                                      searchFilter)

        groups = {}

        for group in result:

            groups[group[1]['cn'][0]] = group[1]

        return groups

    def get_group_users(self, groups, group):

        """Returns all the users belonging to a single group.

        Based on the list of groups and memberships, returns all the

        users belonging to a single group, searching recursively.

        """

        users = []

        for member in groups[group]["uniqueMember"]:

            member = self.parse_member_string(member)

            if member[0] == "uid":

                users.append(member[1])

            elif member[0] == "cn":

                users += self.get_group_users(groups, member[1])

        return users

    def parse_member_string(self, member):

        """Parses the member string and returns a touple of type and name.

        Unique member can be either user or group. Users will have 'uid' as

        prefix while groups will have 'cn'.

        """

        member = member.split(",")[0]

        return member.split('=')

class LdapSync(object):

    def __init__(self):

        self.ldap_client = LdapClient(config.get("default", "ldap_uri"),

                                      config.get("default", "ldap_user"),

                                      config.get("default", "ldap_key"),

                                      config.get("default", "base_dn"))

        self.kallithea_api = API(config.get("default", "api_url"),

                                 config.get("default", "api_key"))

    def update_groups_from_ldap(self):

        """Add all the groups from LDAP to Kallithea."""

        added = existing = 0

        groups = self.ldap_client.get_groups()

        for group in groups:

            try:

                self.kallithea_api.create_group(group)

                added += 1

            except Exception:

                existing += 1

        return added, existing

    def update_memberships_from_ldap(self, group):

        """Update memberships based on the LDAP groups."""

        groups = self.ldap_client.get_groups()

        group_users = self.ldap_client.get_group_users(groups, group)

        # Delete memberships first from each group which are not part

        # of the group any more.

        members = self.kallithea_api.get_group_members(group)

        for member in members:

            if member not in group_users:

                try:

                    self.kallithea_api.remove_membership(group,

                                                         member)

                except UserNotInGroupError:

                    pass

        # Add memberships.

        for member in group_users:

            try:

                self.kallithea_api.add_membership(group, member)

            except UserAlreadyInGroupError:

                # TODO: handle somehow maybe..

                pass

    def close(self):

        self.ldap_client.close()

if __name__ == '__main__':

    sync = LdapSync()

    print(sync.update_groups_from_ldap())

    for gr in sync.ldap_client.get_groups():

        # TODO: exception when user does not exist during add membership...

        # How should we handle this.. Either sync users as well at this step,

        # or just ignore those who don't exist. If we want the second case,

        # we need to find a way to recognize the right exception (we always get

        # ResponseError with no error code so maybe by return msg (?)

        sync.update_memberships_from_ldap(gr)

    sync.close()

# Copyright (C) 2014 RhodeCode GmbH, and others.

# This file is distributed under the same license as the Kallithea project.

msgid ""

msgstr ""

"Report-Msgid-Bugs-To: translations@kallithea-scm.org\n"

"Language: ru\n"

"MIME-Version: 1.0\n"

"Content-Type: text/plain; charset=UTF-8\n"

"Content-Transfer-Encoding: 8bit\n"

"Plural-Forms: nplurals=3; plural=n%10==1 && n%100!=11 ? 0 : n%10>=2 && n"

"%10<=4 && (n%100<10 || n%100>=20) ? 1 : 2;\n"

msgid "There are no changesets yet"

msgstr "Ещё не было изменений"

msgid "None"

msgstr "Ничего"

msgid "(closed)"

msgstr "(закрыто)"

msgid "Show whitespace"

msgstr "Отображать пробелы"

msgid "Ignore whitespace"

msgstr "Игнорировать пробелы"

msgid "Increase diff context to %(num)s lines"

msgstr "Увеличить контекст до %(num)s строк"

msgid "Such revision does not exist for this repository"

msgstr "Нет такой ревизии в этом репозитории"

msgid "Cannot compare repositories without using common ancestor"

msgstr "Невозможно сравнивать репозитории без общего предка"

msgid "No response"

msgstr "Нет ответа"

msgid "Unknown error"

msgstr "Неизвестная ошибка"

msgid ""

"The request could not be understood by the server due to malformed syntax."

msgstr "Запрос не распознан сервером из-за неправильного синтаксиса."

msgid "Unauthorized access to resource"

msgstr "Несанкционированный доступ к ресурсу"

msgid "You don't have permission to view this page"

msgstr "У вас нет прав для просмотра этой страницы"

msgid "The resource could not be found"

msgstr "Ресурс не найден"

msgid ""

"The server encountered an unexpected condition which prevented it from "

"fulfilling the request."

msgstr ""

"Сервер не может выполнить запрос из-за неправильного условия в запросе."

msgid "%s committed on %s"

msgstr "%s выполнил коммит в %s"

msgid "Changeset was too big and was cut off..."

msgstr "Изменения оказались слишком большими и были вырезаны..."

msgid "%s %s feed"

msgstr "Лента новостей %s %s"

msgid "Changes on %s repository"

msgstr "Изменения в репозитории %s"

msgid "Click here to add new file"

msgstr "Нажмите чтобы добавить новый файл"

msgid "%s at %s"

msgstr "%s (%s)"

msgid "You can only delete files with revision being a valid branch"

msgstr ""

msgid "Deleted file %s via Kallithea"

msgstr "Файл %s удалён с помощью Kallithea"

msgid "Successfully deleted file %s"

msgstr "Файл %s удалён"

msgid "Error occurred during commit"

msgstr "Во время коммита произошла ошибка"

msgid "You can only edit files with revision being a valid branch"

msgstr ""

"Вы можете редактировать файлы только в ревизии, связанной с существующей "

msgid "Edited file %s via Kallithea"

msgstr "Файл %s отредактирован с помощью Kallithea"

msgid "No changes"

msgstr "Без изменений"

msgid "Successfully committed to %s"

msgstr "Изменения применены в %s"

msgid "Added file via Kallithea"

msgstr "Файл добавлен с помощью Kallithea"

msgid "No content"

msgstr "Пусто"

msgid "No filename"

msgstr "Безымянный"

msgid "Location must be relative path and must not contain .. in path"

msgstr ""

"Расположение должно быть относительным путем, и не должно содержать \".."

"\" в пути"

msgid "Downloads disabled"

msgstr "Возможность скачивать отключена"

msgid "Unknown revision %s"

msgstr "Неизвестная ревизия %s"

msgid "Empty repository"

msgstr "Пустой репозиторий"

msgid "Unknown archive type"

msgstr "Неизвестный тип архива"

msgid "Changesets"

msgstr "Набор изменений"

msgid "Branches"

msgstr "Ветки"

msgid "Tags"

msgstr "Метки"

msgid "An error occurred during repository forking %s"

msgstr "Произошла ошибка во время создания форка репозитория %s"

msgid "Groups"

msgstr "Группы"

msgid "Repositories"

msgstr "Репозитории"

msgid "Branch"

msgstr "Ветка"

msgid "Closed Branches"

msgstr "Закрытые ветки"

msgid "Tag"

msgstr "Тэги"

msgid "Bookmark"

msgstr "Закладки"

msgid "Public Journal"

msgstr "Публичный журнал"

msgid "Journal"

msgstr "Журнал"

msgid "Bad captcha"

msgstr "Неверная капча"

msgid "You have successfully registered with %s"

msgstr "Регистрация в %s прошла успешно"

msgid "A password reset confirmation code has been sent"

msgstr "Код для сброса пароля отправлена"

msgid "Invalid password reset token"

msgstr "Неверный код сброса пароля"

msgid "Successfully updated password"

msgstr "Пароль обновлён"

msgid "%s (closed)"

msgstr "%s (закрыта)"

msgid "Changeset"

msgstr "Изменения"

msgid "Special"

msgstr "Специальный"

msgid "Peer branches"

msgstr "Ветки участника"

msgid "Bookmarks"

msgstr "Закладки"

msgid "Error creating pull request: %s"

msgstr "Ошибка при создании pull-запроса: %s"

msgid "Error occurred while creating pull request"

msgstr "Произошла ошибка при создании pull-запроса"

msgid "Successfully opened new pull request"

msgstr "Pull-запрос создан успешно"

msgid "No description"

msgstr "Нет описания"

msgid "Pull request updated"

msgstr "Pull-запрос обновлён"

msgid "Successfully deleted pull request"

msgstr "Pull-запрос успешно удалён"

msgid "This pull request has already been merged to %s."

msgstr "Этот pull-запрос уже принят на ветку %s."

msgid "This pull request has been closed and can not be updated."

msgstr "Этот pull-запрос был закрыт и не может быть обновлён."

msgid "Note: Branch %s has another head: %s."

msgstr "Внимание: Ветка %s имеет ещё одну верхушку: %s."

msgid "Invalid search query. Try quoting it."

msgstr "Недопустимый поисковый запрос. Попробуйте заключить его в кавычки."

msgid "An error occurred during search operation."

msgstr "Произошла ошибка при выполнении этого поиска."

msgid "No data ready yet"

msgstr "Нет данных"

msgid "Statistics are disabled for this repository"

msgstr "Статистические данные отключены для этого репозитария"

msgid "Auth settings updated successfully"

msgstr "Настройки авторизации успешно обновлены"

msgid "error occurred during update of auth settings"

msgstr "произошла ошибка при обновлении настроек авторизации"

msgid "Default settings updated successfully"

msgstr "Стандартные настройки успешно обновлены"

msgid "Error occurred during update of defaults"

msgstr "Произошла ошибка при обновлении стандартных настроек"

msgid "5 minutes"

msgstr "5 минут"

msgid "1 hour"

msgstr "1 час"

msgid "1 day"

msgstr "1 день"

msgid "1 month"

msgstr "1 месяц"

msgid "Lifetime"

msgstr "Срок"

msgid "Error occurred during gist creation"

msgstr "Произошла ошибка во время создания gist-записи"

msgid "Deleted gist %s"

msgstr "Gist-запись %s удалена"

msgid "Unmodified"

msgstr "Неизменный"

msgid "Successfully updated gist data"

msgstr "Данные gist-записи обновлены"

msgid "Error occurred during update of gist %s"

msgstr "Произошла ошибка при обновлении gist-записи %s"

msgid "You can't edit this user since it's crucial for entire application"

msgstr ""

"Вы не можете изменить данные этого пользователя, поскольку он важен для "

"работы всего приложения"

msgid "Your account was updated successfully"

msgstr "Ваша учетная запись успешно обновлена"

msgid "Error occurred during update of user %s"

msgstr "Произошла ошибка при обновлении пользователя %s"

msgid "Error occurred during update of user password"

msgstr "Ошибка при обновлении пароля"

msgid "Added email %s to user"

msgstr "Пользователю добавлен e-mail %s"

msgid "An error occurred during email saving"

msgstr "Произошла ошибка при сохранении e-mail"

msgid "Removed email from user"

msgstr "E-mail пользователя удалён"

msgid "API key successfully created"

msgstr "API-ключ успешно создан"

msgid "API key successfully reset"

msgstr "API-ключ успешно сброшен"

msgid "API key successfully deleted"

msgstr "API-ключ успешно удалён"

msgid "Read"

msgstr "Чтение"

msgid "Write"

msgstr "Запись"

msgid "Admin"

msgstr "Администратор"

msgid "Disabled"

msgstr "Отключено"

msgid "Allowed with manual account activation"

msgstr "Разрешена, с ручной активацией учётной записи"

msgid "Allowed with automatic account activation"

msgstr "Разрешена, с автоматической активацией учётной записи"

msgid "Manual activation of external account"

msgstr "Ручная активация внешней учетной записи"

msgid "Automatic activation of external account"

msgstr "Автоматическая активация внешней учетной записи"

msgid "Enabled"

msgstr "Включено"

msgid "Global permissions updated successfully"

msgstr "Глобальные привилегии успешно обновлены"

msgid "Error occurred during update of permissions"

msgstr "Произошла ошибка во время обновления привилегий"

msgid "Error occurred during creation of repository group %s"

msgstr "Произошла ошибка при создании группы репозиториев %s"

msgid "Created repository group %s"

msgstr "Создана новая группа репозиториев %s"

msgid "Updated repository group %s"

msgstr "Группа репозиториев %s обновлена"

msgid "Error occurred during update of repository group %s"

msgstr "Произошла ошибка при обновлении группы репозиториев %s"

msgid "This group contains %s repositories and cannot be deleted"

msgstr "Данная группа содержит %s репозитариев и не может быть удалена"

msgid "This group contains %s subgroups and cannot be deleted"

msgstr "Группа содержит в себе %s подгрупп и не может быть удалён"

msgid "Removed repository group %s"

msgstr "Группа репозиториев %s удалена"

msgid "Error occurred during deletion of repository group %s"

msgstr "Произошла ошибка при удалении группы репозиториев %s"

msgid "Cannot revoke permission for yourself as admin"

msgstr "Администратор не может отозвать свои привелегии"

msgid "Repository group permissions updated"

msgstr "Привилегии группы репозиториев обновлены"

msgid "An error occurred during revoking of permission"

msgstr "Произошла ошибка при отзыве привелегии"

msgid "Error creating repository %s"

msgstr "Произошла ошибка при создании репозитория %s"

msgid "Created repository %s from %s"

msgstr "Репозиторий %s создан из %s"

msgid "Forked repository %s as %s"

msgstr "Сделан форк(копия) репозитория %s на %s"

msgid "Created repository %s"

msgstr "Репозиторий %s создан"

msgid "Repository %s updated successfully"

msgstr "Репозитарий %s успешно обновлён"

msgid "Error occurred during update of repository %s"

msgstr "Произошла ошибка во время обновления репозитория %s"

msgid "Detached %s forks"

msgstr "Форки %s отсоединены"

msgid "Deleted %s forks"

msgstr "Удалены форки репозитория %s"

msgid "Deleted repository %s"

msgstr "Репозиторий %s удалён"

msgid "Cannot delete repository %s which still has forks"

msgstr "Невозможно удалить %s, у него всё ещё есть форки"

msgid "An error occurred during deletion of %s"

msgstr "Произошла ошибка во время удаления %s"

msgid "Repository permissions updated"

msgstr "Привилегии репозитория обновлены"

msgid "An error occurred during removal of field"

msgstr "Произошла ошибка при удалении поля"

msgid "-- Not a fork --"

msgstr "-- Не форк --"

msgid "Updated repository visibility in public journal"

msgstr "Видимость репозитория в публичном журнале обновлена"

msgid "An error occurred during setting this repository in public journal"

msgstr "Произошла ошибка при установке репозитария в общедоступный журнал"

msgid "Nothing"

msgstr "Ничего"

msgid "Marked repository %s as fork of %s"

msgstr "Репозиторий %s отмечен как форк %s"

msgid "An error occurred during this operation"

msgstr "Произошла ошибка при выполнении операции"

msgid "Cache invalidation successful"

msgstr "Кэш сброшен"

msgid "An error occurred during cache invalidation"

msgstr "Произошла ошибка при очистке кэша"

msgid "Pulled from remote location"

msgstr "Внесены изменения из удалённого репозитория"

msgid "An error occurred during pull from remote location"

msgstr "Произошла ошибка при внесении изменений из удалённого репозитория"

msgid "An error occurred during deletion of repository stats"

msgstr "Произошла ошибка при удалении статистики репозитория"

msgid "Updated VCS settings"

msgstr "Обновлены настройки VCS"

msgid ""

"Unable to activate hgsubversion support. The \"hgsubversion\" library is "

"missing"

msgstr ""

"Невозможно включить поддержку hgsubversion. Библиотека «hgsubversion» "

"отсутствует"

msgid "Error occurred while updating application settings"

msgstr "Произошла ошибка при обновлении настроек приложения"

msgid "Repositories successfully rescanned. Added: %s. Removed: %s."

msgstr "Репозитории успешно пересканированы, добавлено: %s, удалено: %s."

msgid "Updated application settings"

msgstr "Обновленные параметры настройки приложения"

msgid "Updated visualisation settings"

msgstr "Настройки визуализации обновлены"

msgid "Error occurred during updating visualisation settings"

msgstr "Произошла ошибка при обновлении настроек визуализации"

msgid "Please enter email address"

msgstr "Пожалуйста, введите адрес электронной почты"

msgid "Send email task created"

msgstr "Задача отправки Email создана"

msgid "Added new hook"

msgstr "Добавлена новая ловушка"

msgid "Updated hooks"

msgstr "Обновлённые ловушки"

msgid "Error occurred during hook creation"

msgstr "произошла ошибка при создании хука"

msgid "Whoosh reindex task scheduled"

msgstr "Запланирована переиндексация базы Whoosh"

msgid "Created user group %s"

msgstr "Создана группа пользователей %s"

msgid "Error occurred during creation of user group %s"

msgstr "Произошла ошибка при создании группы пользователей %s"

msgid "Updated user group %s"

msgstr "Группа пользователей %s обновлена"

msgid "Error occurred during update of user group %s"

msgstr "Произошла ошибка при обновлении группы пользователей %s"

msgid "Successfully deleted user group"

msgstr "Группа пользователей успешно удалена"

msgid "An error occurred during deletion of user group"

msgstr "Произошла ошибка при удалении группы пользователей"

msgid "Target group cannot be the same"

msgstr "Целевая группа не может быть такой же"

msgid "User group permissions updated"

msgstr "Привилегии группы пользователей обновлены"

msgid "Updated permissions"

msgstr "Обновлены привилегии"

msgid "An error occurred during permissions saving"

msgstr "Произошла ошибка при сохранении привилегий"

msgid "Created user %s"

msgstr "Пользователь %s создан"

msgid "Error occurred during creation of user %s"

msgstr "Произошла ошибка при создании пользователя %s"

msgid "User updated successfully"

msgstr "Пользователь успешно обновлён"

msgid "Successfully deleted user"

msgstr "Пользователь успешно удалён"

msgid "An error occurred during deletion of user"

msgstr "Произошла ошибка при удалении пользователя"

msgid "Added IP address %s to user whitelist"

msgstr "Добавлен IP %s в белый список пользователя"

msgid "An error occurred while adding IP address"

msgstr "Произошла ошибка при сохранении IP"

msgid "Removed IP address from user whitelist"

msgstr "Удален IP %s из белого списка пользователя"

msgid "You need to be a registered user to perform this action"

msgstr ""

"Вы должны быть зарегистрированным пользователем, чтобы выполнить это "

"действие"

msgid "You need to be signed in to view this page"

msgstr "Страница доступна только авторизованным пользователям"

msgid "Repository not found in the filesystem"

msgstr "Репозиторий не найден на файловой системе"

msgid "Binary file"

msgstr "Двоичный файл"

msgid ""

"Changeset was too big and was cut off, use diff menu to display this diff"

msgstr ""

"Набор изменения оказался слишком большими и был урезан, используйте меню "

"сравнения для показа результата сравнения"

msgid "No changes detected"

msgstr "Изменений не обнаружено"

msgid "Deleted branch: %s"

msgstr "Удалена ветка: %s"

msgid "Created tag: %s"

msgstr "Создан тег: %s"

msgid "Show all combined changesets %s->%s"

msgstr "Показать отличия вместе %s->%s"

msgid "and"

msgstr "и"

msgid "%s more"

msgstr "на %s больше"

msgid "revisions"

msgstr "версии"

msgid "Pull request %s"

msgstr "Pull-запрос %s"

msgid "[deleted] repository"

msgstr "[удален] репозиторий"

msgid "[created] repository"

msgstr "[создан] репозиторий"

msgid "[created] repository as fork"

msgstr "[создан] репозиторий как форк"

msgid "[forked] repository"

msgstr "[форкнут] репозиторий"

msgid "[updated] repository"

msgstr "[обновлён] репозиторий"

msgid "[downloaded] archive from repository"

msgstr "[загружен] архив из репозитория"