First version

Author: amiika

.gitignore

@@ -0,0 +1,111 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+turtlegit.egg-info
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*.cover
+.hypothesis/
+.pytest_cache/
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+local_settings.py
+db.sqlite3
+
+# Flask stuff:
+instance/
+.webassets-cache
+
+# Scrapy stuff:
+.scrapy
+
+# Sphinx documentation
+docs/_build/
+
+# PyTest
+
+.pytest_cache
+.pydevproject
+.project
+
+# PyBuilder
+target/
+
+# Jupyter Notebook
+.ipynb_checkpoints
+
+# pyenv
+.python-version
+
+# celery beat schedule file
+celerybeat-schedule
+
+# SageMath parsed files
+*.sage.py
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+env.bak/
+venv.bak/
+
+# Spyder project settings
+.spyderproject
+.spyproject
+
+# Rope project settings
+.ropeproject
+
+# mkdocs documentation
+/site
+
+# mypy
+.mypy_cache/

settings.ini

@@ -0,0 +1,8 @@
+[DEFAULT]
+;Workspace = c:/some/path
+Domain = http://localhost:5000/
+AutoAdd = True
+AutoCommit = True
+
+[LOGGING]
+Level = DEBUG

setup.cfg

@@ -0,0 +1,2 @@
+[aliases]
+test=pytest

setup.py

@@ -0,0 +1,17 @@
+from setuptools import setup
+
+setup(
+    name='turtlegit',
+    packages=['turtlegit'],
+    include_package_data=True,
+    install_requires=[
+        'flask',
+        'rdflib'
+    ],
+    setup_requires=[
+        'pytest-runner',
+    ],
+    tests_require=[
+        'pytest',
+    ],
+)

turtlegit/__init__.py

@@ -0,0 +1,84 @@
+from subprocess import Popen, PIPE
+import logging as log
+import re
+
+def add(fileName, repoDir):
+    log.debug('Adding '+fileName+' to '+repoDir)
+    cmd = 'git add ' + fileName
+    if not pipeSuccess(cmd, repoDir):
+        log.warn('FAILED to add '+fileName+' to '+repoDir)
+        
+def commit(commitMessage, repoDir):
+    log.debug('Committing all to '+repoDir)
+    cmd = 'git commit -am "%s"'%commitMessage
+    if not pipeSuccess(cmd, repoDir):
+        log.warn('FAILED to commit all '+repoDir)
+    
+def push(repoDir):
+    cmd = 'git push '
+    if not pipeSuccess(cmd, repoDir):
+        log.warn('FAILED to push '+repoDir)
+        
+def status(repoDir):
+    cmd = 'git status '
+    return pipeSuccess(cmd, repoDir)
+
+def init(repoDir):
+    cmd ='git init '
+    return pipeSuccess(cmd, repoDir)
+
+def rmAll(repoDir):
+    cmd = 'git rm *'
+    return pipeSuccess(cmd,repoDir)
+
+def pipeSuccess(cmd, repoDir):
+    try:
+        pipe = Popen(cmd, shell=True, cwd=repoDir,stdout = PIPE,stderr = PIPE)
+        (output,error)= pipe.communicate()
+        if 'fatal' in error.decode('ascii'):
+            log.warn(error)
+        log.info(output)
+    except (OSError, NotADirectoryError) as exception:
+        log.warn('Exception: ' + str(exception))
+    else:
+        return pipe.wait() == 0
+
+def size(repoDir):
+    cmd = 'git count-objects -v -H '
+    p = Popen(cmd, shell=True, cwd=repoDir, stdout=PIPE)
+    output = p.communicate()[0].decode('ascii')
+    size_pack = re.search("(?<=size-pack: )\d+", output).group()
+    return size_pack
+
+def modified(repoDir):
+    cmd = 'git ls-files -m '
+    p = Popen(cmd, shell=True, cwd=repoDir, stdout=PIPE)
+    output = p.communicate()[0].decode('ascii')
+    return output
+
+def lsfiles(repoDir):
+    cmd = 'git ls-files '
+    p = Popen(cmd, shell=True, cwd=repoDir, stdout=PIPE)
+    output = p.communicate()[0].decode('ascii')
+    return output.splitlines()
+
+def loglast(repoDir):
+    cmd = 'git log -p -1 '
+    p = Popen(cmd, shell=True, cwd=repoDir, stdout=PIPE)
+    output = p.communicate()[0].decode('utf-8')
+    return output   
+
+def setHome():
+    cmd = 'set HOME='
+    p = Popen(cmd, shell=True, stdout=PIPE)
+    output = p.communicate()[0].decode('utf-8')
+    return output  
+
+def getHome():
+    cmd = 'set HOME'
+    p = Popen(cmd, shell=True, stdout=PIPE)
+    output = p.communicate()[0].decode('utf-8')
+    return output  
+    
+
+        

turtlegit/cmdgit.py

@@ -0,0 +1,10 @@
+from os import path
+
+class Config(object):
+    DOMAIN = 'http://localhost/'
+    AUTOADD = True
+    AUTOCOMMIT = True
+    ROOT_DIR = path.dirname(path.dirname(__file__)).replace('\\','/')
+    
+class Logging(object):
+    LEVEL = 'DEBUG'

turtlegit/default_settings.py

@@ -0,0 +1,53 @@
+from rdflib.graph import Graph
+from rdflib.namespace import Namespace
+from otsrdflib import OrderedTurtleSerializer
+from urllib.parse import quote_plus, unquote_plus
+import io
+import logging as log
+import posixpath
+from os import path
+
+class FileGraph:
+
+	g = None
+	repopath = None
+	reponame = None
+	domain = None
+	filename = None
+	filepath = None
+	
+	def __init__(self, iri, domain, repopath, reponame):
+		self.iri = iri
+		self.domain = domain
+		self.repopath = repopath
+		self.reponame = reponame
+		self.g = Graph()
+		
+		log.info("IRI: "+self.iri)
+		log.info("DOMAIN: "+domain)
+		if iri.startswith(domain):
+			self.filename = iri.rsplit('/', 1)[-1]
+			if not self.filename.endswith('.ttl'):
+				self.filename += '.ttl'
+		else:
+			self.filename = quote_plus(iri.replace(domain+self.reponame,''))+".ttl"
+			
+		self.filepath = posixpath.join(repopath,self.filename)
+
+	def doExists(self):
+		return path.isfile(self.filepath)
+
+	def parseFile(self, f):
+		self.g.parse(f, format='turtle')
+		
+	def parseString(self, modelString):
+		f = io.StringIO(modelString)
+		self.g.parse(f, format='turtle')
+		
+	def parsePath(self):
+		self.g.parse(self.filepath, format='turtle')
+		
+	def serialize(self):
+		serializer = OrderedTurtleSerializer(self.g)
+		with open(self.filepath, 'wb') as fp:
+			serializer.serialize(fp)