Created
August 14, 2012 15:42
-
-
Save ianonavy/3350393 to your computer and use it in GitHub Desktop.
Simple daemon that waits for a screenshot to be saved into a folder and automatically uploads it to a remote server. When that's done, it copies the URL into the user's clipboard. Very similar to CloudApp and Droplr, but it runs on Linux.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python | |
import sys, os, time, atexit | |
from signal import SIGTERM | |
class Daemon: | |
""" | |
A generic daemon class. | |
Usage: subclass the Daemon class and override the run() method | |
""" | |
def __init__(self, pidfile, stdin='/dev/null', stdout='/dev/null', stderr='/dev/null'): | |
self.stdin = stdin | |
self.stdout = stdout | |
self.stderr = stderr | |
self.pidfile = pidfile | |
def daemonize(self): | |
""" | |
do the UNIX double-fork magic, see Stevens' "Advanced | |
Programming in the UNIX Environment" for details (ISBN 0201563177) | |
http://www.erlenstar.demon.co.uk/unix/faq_2.html#SEC16 | |
""" | |
try: | |
pid = os.fork() | |
if pid > 0: | |
# exit first parent | |
sys.exit(0) | |
except OSError, e: | |
sys.stderr.write("fork #1 failed: %d (%s)\n" % (e.errno, e.strerror)) | |
sys.exit(1) | |
# decouple from parent environment | |
os.chdir("/") | |
os.setsid() | |
os.umask(0) | |
# do second fork | |
try: | |
pid = os.fork() | |
if pid > 0: | |
# exit from second parent | |
sys.exit(0) | |
except OSError, e: | |
sys.stderr.write("fork #2 failed: %d (%s)\n" % (e.errno, e.strerror)) | |
sys.exit(1) | |
# redirect standard file descriptors | |
sys.stdout.flush() | |
sys.stderr.flush() | |
si = file(self.stdin, 'r') | |
so = file(self.stdout, 'a+') | |
se = file(self.stderr, 'a+', 0) | |
os.dup2(si.fileno(), sys.stdin.fileno()) | |
os.dup2(so.fileno(), sys.stdout.fileno()) | |
os.dup2(se.fileno(), sys.stderr.fileno()) | |
# write pidfile | |
atexit.register(self.delpid) | |
pid = str(os.getpid()) | |
file(self.pidfile,'w+').write("%s\n" % pid) | |
def delpid(self): | |
os.remove(self.pidfile) | |
def start(self): | |
""" | |
Start the daemon | |
""" | |
# Check for a pidfile to see if the daemon already runs | |
try: | |
pf = file(self.pidfile,'r') | |
pid = int(pf.read().strip()) | |
pf.close() | |
except IOError: | |
pid = None | |
if pid: | |
message = "pidfile %s already exist. Daemon already running?\n" | |
sys.stderr.write(message % self.pidfile) | |
sys.exit(1) | |
# Start the daemon | |
self.daemonize() | |
self.run() | |
def stop(self): | |
""" | |
Stop the daemon | |
""" | |
# Get the pid from the pidfile | |
try: | |
pf = file(self.pidfile,'r') | |
pid = int(pf.read().strip()) | |
pf.close() | |
except IOError: | |
pid = None | |
if not pid: | |
message = "pidfile %s does not exist. Daemon not running?\n" | |
sys.stderr.write(message % self.pidfile) | |
return # not an error in a restart | |
# Try killing the daemon process | |
try: | |
while 1: | |
os.kill(pid, SIGTERM) | |
time.sleep(0.1) | |
except OSError, err: | |
err = str(err) | |
if err.find("No such process") > 0: | |
if os.path.exists(self.pidfile): | |
os.remove(self.pidfile) | |
else: | |
print str(err) | |
sys.exit(1) | |
def restart(self): | |
""" | |
Restart the daemon | |
""" | |
self.stop() | |
self.start() | |
def run(self): | |
""" | |
You should override this method when you subclass Daemon. It will be called after the process has been | |
daemonized by start() or restart(). | |
""" |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
#!/usr/bin/env python | |
import gtk | |
import pygtk | |
import time | |
import sys | |
from os import listdir as ls, rename | |
from os.path import exists, isfile, join, splitext | |
from random import choice | |
from string import ascii_letters, digits | |
from subprocess import call | |
from daemon import Daemon | |
pygtk.require('2.0') | |
# Config | |
SSH_PORT = 22 | |
PATH = "/path/to/screenshot/folder" | |
BASE_URL = "http://files.example.com/" | |
SCP_PATH = "files.example.com:sites/filesd/files" | |
WAIT_INTERVAL = 1 | |
class FilesDaemon(Daemon): | |
def run(self): | |
""" | |
Constantly loops checking for a new file. It's not very efficient, but | |
it gets the job done. | |
""" | |
print "Loading list of all files..." | |
# Get list of all files. | |
files = [f for f in ls(PATH) if isfile(join(PATH, f))] | |
print "Done! Waiting for some new files." | |
while 1: | |
for f in ls(PATH): | |
filename = join(PATH, f) # Get the full file path. | |
if isfile(filename): | |
if f not in files: | |
#print f, files | |
base, extension = splitext(f) | |
new_filename = self.random_filename(extension=extension) | |
rename(filename, join(PATH, new_filename)) | |
files.append(new_filename) | |
self.upload(join(PATH, new_filename)) | |
image_url = "%s%s" % (BASE_URL, new_filename) | |
self.copy_to_clipboard(image_url) | |
time.sleep(WAIT_INTERVAL) | |
def upload(self, filename): | |
""" Uploads a file to the remote host. """ | |
print "scp -P %d %s %s" % (SSH_PORT, filename, SCP_PATH) | |
call("scp -P %d %s %s" % (SSH_PORT, filename, SCP_PATH), shell=True) | |
def copy_to_clipboard(self, text): | |
""" Copies the passed argument to the clipboard. """ | |
clipboard = gtk.clipboard_get() | |
clipboard.set_text(text) | |
clipboard.store() # Let other programs use it. | |
def random_filename(self, length=4, extension='', attempts=10): | |
""" Generates a random filename and verifies that it doesn't exist. """ | |
chars = ''.join([ascii_letters, digits]) | |
for attempt in range(attempts): | |
filename = ''.join([choice(chars) for i in range(length)]) | |
filename = filename + extension | |
if not exists(filename): | |
return filename | |
if __name__ == "__main__": | |
daemon = FilesDaemon('/tmp/filesd.pid') | |
if len(sys.argv) == 2: | |
if 'start' == sys.argv[1]: | |
daemon.start() | |
elif 'stop' == sys.argv[1]: | |
daemon.stop() | |
elif 'restart' == sys.argv[1]: | |
daemon.restart() | |
else: | |
print "Unknown command" | |
sys.exit(2) | |
sys.exit(0) | |
else: | |
print "usage: %s {start|stop|restart}" % sys.argv[0] | |
sys.exit(2) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment