Synnefo

    def node_accounts(self, accounts=()):

        s = select([self.nodes.c.path, self.nodes.c.node])

        s = s.where(and_(self.nodes.c.node != 0,

                         self.nodes.c.parent == 0))

        if accounts:

            s = s.where(self.nodes.c.path.in_(accounts))

        r = self.conn.execute(s)

        rows = r.fetchall()

        r.close()

        return rows

    def node_account_usage(self, account_node, cluster):

        select_children = select(

            [self.nodes.c.node]).where(self.nodes.c.parent == account_node)

        select_descendants = select([self.nodes.c.node]).where(

            or_(self.nodes.c.parent.in_(select_children),

                self.nodes.c.node.in_(select_children)))

        s = select([func.sum(self.versions.c.size)])

        s = s.group_by(self.versions.c.cluster)

        s = s.where(self.nodes.c.node == self.versions.c.node)

        s = s.where(self.nodes.c.node.in_(select_descendants))

        s = s.where(self.versions.c.cluster == cluster)

        r = self.conn.execute(s)

        usage = r.fetchone()[0]

        r.close()

        return usage