updates for database + api

1 files changed, 0 insertions, 141 deletions

diff --git a/module/plugins/AccountManager.py b/module/plugins/AccountManager.py
deleted file mode 100644
index c610d10e0..000000000
--- a/module/plugins/AccountManager.py
+++ /dev/null
@@ -1,141 +0,0 @@
-#!/usr/bin/env python
-# -*- 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/>.
-
-    @author: RaNaN
-"""
-
-from threading import Lock
-from random import choice
-
-from module.common.json_layer import json
-from module.utils import lock
-
-class AccountManager:
-    """manages all accounts"""
-
-    def __init__(self, core):
-        """Constructor"""
-
-        self.core = core
-        self.lock = Lock()
-
-        self.loadAccounts()
-
-    def loadAccounts(self):
-        """loads all accounts available"""
-
-        self.accounts = {}
-
-        for plugin, loginname, activated, password, options in self.core.db.loadAccounts():
-            # put into options as used in other context
-            options = json.loads(options) if options else {}
-            options["activated"] = activated
-
-            self.createAccount(plugin, loginname, password, options)
-
-        return
-
-    def iterAccounts(self):
-        """ yields login, account  for all accounts"""
-        for name, data in self.accounts.iteritems():
-            for login, account in data.iteritems():
-                yield login, account
-
-    def saveAccounts(self):
-        """save all account information"""
-
-        data = []
-        for name, plugin in self.accounts.iteritems():
-            data.extend([(name, acc.loginname, acc.activated, acc.password, json.dumps(acc.options)) for acc in
-                                                                                                     plugin.itervalues()])
-        self.core.db.saveAccounts(data)
-
-    def createAccount(self, plugin, loginname, password, options):
-        klass = self.core.pluginManager.loadClass("accounts", plugin)
-        if not klass:
-            self.core.log.warning(_("Unknown account plugin %s") % plugin)
-            return
-
-        if plugin not in self.accounts:
-            self.accounts[plugin] = {}
-
-        self.core.log.debug("Create account %s:%s" % (plugin, loginname))
-
-        self.accounts[plugin][loginname] = klass(self, loginname, password, options)
-
-
-    def getAccount(self, plugin, user):
-        return self.accounts[plugin].get(user, None)
-
-    @lock
-    def updateAccount(self, plugin, user, password=None, options={}):
-        """add or update account"""
-        if plugin in self.accounts and user in self.accounts[plugin]:
-            acc = self.accounts[plugin][user]
-            updated = acc.update(password, options)
-
-            self.saveAccounts()
-            if updated: acc.scheduleRefresh(force=True)
-        else:
-            self.createAccount(plugin, user, password, options)
-            self.saveAccounts()
-
-        self.sendChange(plugin, user)
-
-    @lock
-    def removeAccount(self, plugin, user):
-        """remove account"""
-        if plugin in self.accounts and user in self.accounts[plugin]:
-            del self.accounts[plugin][user]
-            self.core.db.removeAccount(plugin, user)
-            self.core.eventManager.dispatchEvent("accountDeleted", plugin, user)
-        else:
-            self.core.log.debug("Remove non existing account %s %s" % (plugin, user))
-
-
-    @lock
-    def getAccountForPlugin(self, plugin):
-        if plugin in self.accounts:
-            accs = [x for x in self.accounts[plugin].values() if x.isUsable()]
-            if accs: return choice(accs)
-
-        return None
-
-    @lock
-    def getAllAccounts(self, refresh=False):
-        """ Return account info, refresh afterwards if needed
-
-        :param refresh:
-        :return:
-        """
-        if refresh:
-            self.core.scheduler.addJob(0, self.core.accountManager.getAllAccounts)
-
-        # load unavailable account info
-        for p_dict in self.accounts.itervalues():
-            for acc in p_dict.itervalues():
-                acc.getAccountInfo()
-
-        return self.accounts
-
-    def refreshAllAccounts(self):
-        """ Force a refresh of every account """
-        for p in self.accounts.itervalues():
-            for acc in p.itervalues():
-                acc.getAccountInfo(True)
-
-    def sendChange(self, plugin, name):
-        self.core.eventManager.dispatchEvent("accountUpdated", plugin, name)
\ No newline at end of file