--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/foodtruck/scm/mercurial.py	Sat Jan 16 14:24:35 2016 -0800
@@ -0,0 +1,71 @@
+import os
+import logging
+import tempfile
+import subprocess
+from .base import SourceControl, RepoStatus
+
+
+logger = logging.getLogger(__name__)
+
+
+def _s(strs):
+    """ Convert a byte array to string using UTF8 encoding. """
+    if strs is None:
+        return None
+    assert isinstance(strs, bytes)
+    return strs.decode('utf8')
+
+
+class MercurialSourceControl(SourceControl):
+    def __init__(self, root_dir):
+        super(MercurialSourceControl, self).__init__(root_dir)
+        self.hg = 'hg'
+
+    def getStatus(self):
+        res = RepoStatus()
+        st_out = self._run('status')
+        for line in st_out.split('\n'):
+            if len(line) == 0:
+                continue
+            if line[0] == '?' or line[0] == 'A':
+                res.new_files.append(line[2:])
+            elif line[0] == 'M':
+                res.edited_files.append(line[2:])
+        return res
+
+    def commit(self, paths, author, message):
+        if not message:
+            raise ValueError("No commit message specified.")
+
+        # Check if any of those paths needs to be added.
+        st_out = self._run('status', *paths)
+        add_paths = []
+        for line in st_out.splitlines():
+            if line[0] == '?':
+                add_paths.append(line[2:])
+        if len(add_paths) > 0:
+            self._run('add', *paths)
+
+        # Create a temp file with the commit message.
+        f, temp = tempfile.mkstemp()
+        with os.fdopen(f, 'w') as fd:
+            fd.write(message)
+
+        # Commit and clean up the temp file.
+        try:
+            commit_args = list(paths) + ['-l', temp]
+            if author:
+                commit_args += ['-u', author]
+            self._run('commit', *commit_args)
+        finally:
+            os.remove(temp)
+
+    def _run(self, cmd, *args, **kwargs):
+        exe = [self.hg, '-R', self.root_dir]
+        exe.append(cmd)
+        exe += args
+        logger.debug("Running Mercurial: " + str(exe))
+        out = subprocess.check_output(exe)
+        encoded_out = _s(out)
+        return encoded_out
+