from fabric.api import *
from fabric.api import env
import time
import re


# env.hosts = ['10.200.20.146', '10.200.20.156', '10.200.20.168', '10.200.20.154']
env.hosts = ['10.200.20.158', '10.200.20.146', '10.200.20.156', '10.200.20.168', '10.200.20.154']

env.user = 'datastax'
env.password = 'datastax'

seed = '10.200.20.158'

@parallel
def clean_dse():
    # run("ps aux | grep cassandra")
    sudo("service dse stop")
    sudo("rm -rf /var/lib/cassandra/*/*")
    #run("ls -la")

@parallel
def boot_dse():
    sudo("service dse start")


@parallel
def update_seed():
    sudo("sed --follow-symlinks -i 's#         - seeds: .*#         - seeds: \"" + seed + "\"#g' /etc/dse/cassandra/cassandra.yaml")


def tail_log():
    sudo("tail -100 /var/log/cassandra/system.log")
    time.sleep(1)


def is_launched():
    output = run("nodetool status")
    if (re.search('127.0.0.1', output) > -1):
        print "this node is down"