gistfile1.txt

#!/usr/bin/env python
"""
xsync.py by zjx20
http://github.com/zjx20/xsync/

This script will watch a local directory and on change will
sync to a remote directory. The script can be easily modified
to do whatever you want on a change event.

requires: pip install 'watchdog==0.8.3'

  about watchdog:
    # project site: http://github.com/gorakhargosh/watchdog
    # api document: https://pythonhosted.org/watchdog/index.html

TODO: enhance 'ignore list' feature
TODO: Chinese support
"""

import os, datetime, time
import sys, argparse, json
import watchdog.events, watchdog.observers
from watchdog.utils.dirsnapshot import DirectorySnapshot


class SkipSymlinksDirectorySnapshot(DirectorySnapshot):
    def __init__(self, *args, **kwargs):
        kwargs['listdir'] = self.__class__.my_listdir
        super(SkipSymlinksDirectorySnapshot, self).__init__(*args, **kwargs)

    @staticmethod
    def my_listdir(path):
        if os.path.islink(path):
            display("skipped symlink dir: " + path)
            return ()
        else:
            return os.listdir(path)


if 'FSEventsObserver' in watchdog.observers.Observer.__name__:
    import watchdog.observers.fsevents
    if 'DirectorySnapshot' in dir(watchdog.observers.fsevents):
        watchdog.observers.fsevents.DirectorySnapshot = SkipSymlinksDirectorySnapshot
    else:
        raise RuntimeError('unsupported watchdog version, should >= 0.8.3')


class SyncHandler(watchdog.events.FileSystemEventHandler):

    def __init__(self, conf, times=False):
        watchdog.events.FileSystemEventHandler.__init__(self)
        self.local_path = conf['local_path']
        self.remote_host = conf['remote_host']
        self.remote_path = conf['remote_path']
        self.ignore_list = []
        self.times = times
        if 'ignore_list' in conf:
            self.ignore_list = conf['ignore_list']
        self.ignore_list += ['.xsync']    # ignore .xsync by default

    def should_ignore(self, filename):
        for ig in self.ignore_list:
            if ig in filename:
                return True
        return False

    def on_created(self, event):
        filename = event.src_path
        if self.should_ignore(filename):
            return

        if event.is_directory:
            filename += '/'

        remote_file = filename.replace(self.local_path, '')
        remote_parent = "%s%s" % (self.remote_path, 
                                  os.path.dirname(remote_file))

        # escape spaces for sending the cmd via ssh
        remote_parent = remote_parent.replace(' ', '\\\\ ')

        # to make sure the remote parent dir exists
        cmd = " ssh %s '[ ! -d \"%s\" ] && mkdir -p \"%s\"'" % \
            (self.remote_host, remote_parent, remote_parent)
        os.system(cmd)

        # -lptgoD is almostly equal to -a except -r
        rsync_args = '-lpgoDzq' + ('t' if self.times else '')
        cmd = " rsync %s \"%s\" \"%s:%s/\" " % \
            (rsync_args, filename, self.remote_host, remote_parent)
        display("Syncing %s " % filename)
        os.system(cmd)

    def on_deleted(self, event):
        filename = event.src_path
        if self.should_ignore(filename):
            return

        local_parent = os.path.dirname(filename) + '/'
        if not os.path.isdir(local_parent):
            # the parent dir does not exists, skip
            return

        remote_file = filename.replace(self.local_path, '')

        cmd = " ssh %s 'rm -rf \"%s%s\"'" % \
            (self.remote_host, self.remote_path, remote_file)
        display("Syncing %s " % filename)
        os.system(cmd)

    def on_modified(self, event):
        if isinstance(event, watchdog.events.DirModifiedEvent):
            # ignore dir modified event
            return

        filename = event.src_path
        if self.should_ignore(filename):
            return

        remote_file = filename.replace(self.local_path, '')

        # -lptgoDr is equal to -a
        rsync_args = '-lpgoDrzq' + ('t' if self.times else '')
        cmd = " rsync %s --delete \"%s\" \"%s:%s%s\" " % \
            (rsync_args, filename, self.remote_host,
             self.remote_path.replace(' ', '\\\\ '),
             remote_file.replace(' ', '\\\\ '))
        display("Syncing %s " % filename)
        os.system(cmd)

    def on_moved(self, event):
        if event.is_directory:
            self.on_deleted(watchdog.events.DirDeletedEvent(event.src_path))
            self.on_created(watchdog.events.DirCreatedEvent(event.dest_path))
        else:
            self.on_deleted(watchdog.events.FileDeletedEvent(event.src_path))
            self.on_created(watchdog.events.FileCreatedEvent(event.dest_path))


def display(str):
    now = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    print "[{0}] {1}".format(now, str)


def parse_opt():
    parser = argparse.ArgumentParser(prog='xsync',
            formatter_class=argparse.ArgumentDefaultsHelpFormatter)
    parser.add_argument('--setup', action='store_true',
            help='cp xsync to /usr/local/bin')
    parser.add_argument('--full', action='store_true',
            help='do full sync instead of starting a daemon')
    parser.add_argument('--conf', action='store',
            default=os.path.join(os.getcwd(), '.xsync'),
            help='config file path')
    parser.add_argument('--init', action='store_true',
            help='create .xsync file in current folder')
    parser.add_argument('--times', action='store_true',
            help='preserve modification times')
    args = parser.parse_args()
    return args


"""
Config sample:

  {
    "local_path": "/home/x/project1/",
    "remote_host": "[email protected]",
    "remote_path": "/home/dev/project1/",
    "ignore_list": [".git", ".svn", ".DS_Store"]
  }

  #
  # NOTICE:
  #
  #   it will use dirname of config file path as 'local_path' if
  #   the field does not exists.
  #
  #   if you are meeting a non-standard ssh port, try
  #   "--rsh='ssh -p2222' [email protected]" as 'remote_host'.
  #
  #   'ignore_list' is optional.
  #

  Or config blocks in an array

  [
    {
      "local_path": "/home/x/project1/",
      "remote_host": "[email protected]",
      "remote_path": "/home/dev/project1/",
      "ignore_list": [".git", ".svn", ".DS_Store"]
    },
    {
      ...
    },
  ]
"""
def parse_conf(filepath):
    if not os.path.isfile(filepath):
        print >> sys.stderr, '[WARNING] Config "' + filepath + '" not ' + \
            'exists! skipped.'
        return []

    conf = None
    with open(filepath) as f:
        try:
            conf = json.loads(f.read())
        except ValueError:
            print >> sys.stderr, '[WARNING] Couldn\'t parse config ' + \
                'from "%s"! skipped.' % filepath
            return []

    conf_list = conf
    if not isinstance(conf, list):
        conf_list = [conf]

    for conf in conf_list:
        if 'local_path' not in conf:
            conf['local_path'] = '%s/' % \
                os.path.dirname(os.path.abspath(filepath))
        if not conf['local_path'].endswith('/'):
            conf['local_path'] += '/'
        if not conf['remote_path'].endswith('/'):
            conf['remote_path'] += '/'

    return conf_list


def watch(conf_list, options):
    observer = watchdog.observers.Observer()

    for conf in conf_list:
        observer.schedule(SyncHandler(conf, times=options.times),
                          conf['local_path'], recursive=True)
        display('Watching for local path "%s", sync to "%s:%s".' %
                (conf['local_path'], conf['remote_host'], conf['remote_path']))

    observer.start()
    try:
        while True:
            time.sleep(1)
    except KeyboardInterrupt:
        observer.stop()
    observer.join()


def full_sync(conf_list):
    for conf in conf_list:
        display("Full sync from '%s' to %s:%s" % (conf['local_path'],
                conf['remote_host'], conf['remote_path']))
        cmd = " rsync -azq --delete %s %s:%s " % \
            (conf['local_path'], conf['remote_host'], conf['remote_path'])
        print cmd
        os.system(cmd)


def setup():
    script = os.path.abspath(sys.argv[0])
    dest = '/usr/local/bin/xsync'
    display('Link "%s" to %s' % (script, dest))
    cmd = 'chmod +x %s && sudo ln -s -f "%s" %s' % (script, script, dest)
    os.system(cmd)


def init():
    filepath = os.path.join(os.getcwd(), '.xsync')
    if not os.path.isfile(filepath):
        with open(filepath, 'w') as conf:
            conf.write("""\
{
  "local_path": "%s/",
  "remote_host": "USER@YOUHOST",
  "remote_path": "/home/USER/REMOTE_PATH/",
  "ignore_list": [".git", ".svn", ".DS_Store"]
}
""" % (os.getcwd()))

    os.system('vi %s' % filepath)


def main():
    args = parse_opt()

    if args.setup:
        setup()
        return

    if args.init:
        init()
        return

    conf_list = parse_conf(args.conf)

    if len(conf_list) == 0:
        return

    if args.full:
        full_sync(conf_list)
    else:
        watch(conf_list, args)


if __name__ == '__main__':
    main()