1 files changed, 9 insertions, 27 deletions
diff --git a/fabfile/__init__.py b/fabfile/__init__.py
index caf123f..d87fbdd 100644
--- a/fabfile/__init__.py
+++ b/fabfile/__init__.py
@@ -1,44 +1,23 @@
 from fabric.api import run,env
-from fabric.operations import get
+from fabric.operations import get,put
 import os
 import yaml
 import re
-
-def _all_hosts():
-   return filter(lambda fn: '.' in fn and not fn.startswith('.') and os.path.isdir(fn),os.listdir("."))
-
-def _roledefs():
-   rules = dict()
-
-   rules_file = "cosmos-rules.yaml";
-   if os.path.exists(rules_file):
-      with open(rules_file) as fd:
-         rules.update(yaml.load(fd))
-
-   roles = dict() 
-   for node_name in _all_hosts():
-      for reg,cls in rules.iteritems():
-         if re.search(reg,node_name):
-            for cls_name in cls.keys():
-               h = roles.get(cls_name,[])
-               h.append(node_name)
-               roles[cls_name] = h
-   return roles
+import sys
+from fabfile.db import cosmos_db
 
 env.user = 'root'
 env.timeout = 30
 env.connection_attempts = 3
 env.warn_only = True
 env.skip_bad_hosts = True
-env.roledefs = _roledefs()
-
-#print repr(env.roledefs)
+env.roledefs = cosmos_db()['members']
 
 def all():
-    env.hosts = _all_hosts()
+    env.hosts = cosmos_db()['members']['all']
 
 def cosmos():
-    run("cosmos update && cosmos apply");
+    run("cosmos update ; cosmos -v apply");
 
 def upgrade():
     run("apt-get -qq update && apt-get -y -q dist-upgrade");
@@ -51,3 +30,6 @@ def chassis():
 
 def newvm(fqdn,ip,domain):
     run("vmbuilder kvm ubuntu --domain %s --dest /var/lib/libvirt/images/%s.img --arch x86_64 --hostname %s --mem 512 --ip %s --addpkg openssh-server" % (domain,fqdn,fqdn,ip))
+
+def cp(local,remote):
+    put(local,remote)