Move python bindings code into subvertpy directory.

1 files changed, 373 insertions, 0 deletions

diff --git a/subvertpy/repos.c b/subvertpy/repos.c
new file mode 100644
index 00000000..f2992136
--- /dev/null
+++ b/subvertpy/repos.c
@@ -0,0 +1,373 @@
+/*
+ * Copyright © 2008 Jelmer Vernooij <jelmer@samba.org>
+ * -*- coding: utf-8 -*-
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */
+#include <stdbool.h>
+#include <Python.h>
+#include <apr_general.h>
+#include <svn_fs.h>
+#include <svn_repos.h>
+
+#include "util.h"
+
+extern PyTypeObject Repository_Type;
+extern PyTypeObject FileSystem_Type;
+
+typedef struct { 
+	PyObject_HEAD
+    apr_pool_t *pool;
+    svn_repos_t *repos;
+} RepositoryObject;
+
+static PyObject *repos_create(PyObject *self, PyObject *args)
+{
+	char *path;
+	PyObject *config=Py_None, *fs_config=Py_None;
+    svn_repos_t *repos;
+    apr_pool_t *pool;
+    apr_hash_t *hash_config, *hash_fs_config;
+	RepositoryObject *ret;
+
+	if (!PyArg_ParseTuple(args, "s|OO", &path, &config, &fs_config))
+		return NULL;
+
+    pool = Pool(NULL);
+	if (pool == NULL)
+		return NULL;
+    hash_config = config_hash_from_object(config, pool);
+	if (hash_config == NULL)
+		return NULL;
+    hash_fs_config = apr_hash_make(pool); /* FIXME */
+	if (hash_fs_config == NULL) {
+		PyErr_SetString(PyExc_RuntimeError, "Unable to create fs config hash");
+		return NULL;
+	}
+    RUN_SVN_WITH_POOL(pool, svn_repos_create(&repos, path, NULL, NULL, 
+                hash_config, hash_fs_config, pool));
+
+	ret = PyObject_New(RepositoryObject, &Repository_Type);
+	if (ret == NULL)
+		return NULL;
+
+	ret->pool = pool;
+	ret->repos = repos;
+
+    return (PyObject *)ret;
+}
+
+static void repos_dealloc(PyObject *self)
+{
+	RepositoryObject *repos = (RepositoryObject *)self;
+
+	apr_pool_destroy(repos->pool);
+	PyObject_Del(repos);
+}
+
+static PyObject *repos_init(PyTypeObject *type, PyObject *args, PyObject *kwargs)
+{
+	char *path;
+	char *kwnames[] = { "path", NULL };
+	svn_error_t *err;
+	RepositoryObject *ret;
+
+	if (!PyArg_ParseTupleAndKeywords(args, kwargs, "s", kwnames, &path))
+		return NULL;
+
+	ret = PyObject_New(RepositoryObject, &Repository_Type);
+	if (ret == NULL)
+		return NULL;
+
+	ret->pool = Pool(NULL);
+	if (ret->pool == NULL)
+		return NULL;
+	Py_BEGIN_ALLOW_THREADS
+	err = svn_repos_open(&ret->repos, path, ret->pool);
+	Py_END_ALLOW_THREADS
+    if (!check_error(err)) {
+		Py_DECREF(ret);
+		return NULL;
+	}
+
+	return (PyObject *)ret;
+}
+
+typedef struct {
+	PyObject_HEAD
+	RepositoryObject *repos;
+	apr_pool_t *pool;
+	svn_fs_t *fs;
+} FileSystemObject;
+
+static PyObject *repos_fs(PyObject *self)
+{
+	RepositoryObject *reposobj = (RepositoryObject *)self;
+	FileSystemObject *ret;
+	svn_fs_t *fs;
+
+	fs = svn_repos_fs(reposobj->repos);
+
+	if (fs == NULL) {
+		PyErr_SetString(PyExc_RuntimeError, "Unable to obtain fs handle");
+		return NULL;
+	}
+
+	ret = PyObject_New(FileSystemObject, &FileSystem_Type);
+	if (ret == NULL)
+		return NULL;
+
+	ret->fs = fs;
+	ret->repos = reposobj;
+	ret->pool = reposobj->pool;
+	Py_INCREF(reposobj);
+
+	return (PyObject *)ret;
+}
+
+static PyObject *fs_get_uuid(PyObject *self)
+{
+	FileSystemObject *fsobj = (FileSystemObject *)self;
+	const char *uuid;
+	PyObject *ret;
+	apr_pool_t *temp_pool;
+
+	temp_pool = Pool(NULL);
+	if (temp_pool == NULL)
+		return NULL;
+	RUN_SVN_WITH_POOL(temp_pool, svn_fs_get_uuid(fsobj->fs, &uuid, temp_pool));
+	ret = PyString_FromString(uuid);
+	apr_pool_destroy(temp_pool);
+
+	return ret;
+}
+
+static PyMethodDef fs_methods[] = {
+	{ "get_uuid", (PyCFunction)fs_get_uuid, METH_NOARGS, NULL },
+	{ NULL, }
+};
+
+static void fs_dealloc(PyObject *self)
+{
+	FileSystemObject *fsobj = (FileSystemObject *)self;
+
+	Py_DECREF(fsobj->repos);
+	apr_pool_destroy(fsobj->pool);
+}
+
+PyTypeObject FileSystem_Type = {
+	PyObject_HEAD_INIT(NULL) 0,
+	"repos.FileSystem", /*	const char *tp_name;  For printing, in format "<module>.<name>" */
+	sizeof(FileSystemObject), 
+	0,/*	Py_ssize_t tp_basicsize, tp_itemsize;  For allocation */
+	
+	/* Methods to implement standard operations */
+	
+	fs_dealloc, /*	destructor tp_dealloc;	*/
+	NULL, /*	printfunc tp_print;	*/
+	NULL, /*	getattrfunc tp_getattr;	*/
+	NULL, /*	setattrfunc tp_setattr;	*/
+	NULL, /*	cmpfunc tp_compare;	*/
+	NULL, /*	reprfunc tp_repr;	*/
+	
+	/* Method suites for standard classes */
+	
+	NULL, /*	PyNumberMethods *tp_as_number;	*/
+	NULL, /*	PySequenceMethods *tp_as_sequence;	*/
+	NULL, /*	PyMappingMethods *tp_as_mapping;	*/
+	
+	/* More standard operations (here for binary compatibility) */
+	
+	NULL, /*	hashfunc tp_hash;	*/
+	NULL, /*	ternaryfunc tp_call;	*/
+	NULL, /*	reprfunc tp_str;	*/
+	NULL, /*	getattrofunc tp_getattro;	*/
+	NULL, /*	setattrofunc tp_setattro;	*/
+	
+	/* Functions to access object as input/output buffer */
+	NULL, /*	PyBufferProcs *tp_as_buffer;	*/
+	
+	/* Flags to define presence of optional/expanded features */
+	0, /*	long tp_flags;	*/
+	
+	NULL, /*	const char *tp_doc;  Documentation string */
+	
+	/* Assigned meaning in release 2.0 */
+	/* call function for all accessible objects */
+	NULL, /*	traverseproc tp_traverse;	*/
+	
+	/* delete references to contained objects */
+	NULL, /*	inquiry tp_clear;	*/
+	
+	/* Assigned meaning in release 2.1 */
+	/* rich comparisons */
+	NULL, /*	richcmpfunc tp_richcompare;	*/
+	
+	/* weak reference enabler */
+	0, /*	Py_ssize_t tp_weaklistoffset;	*/
+	
+	/* Added in release 2.2 */
+	/* Iterators */
+	NULL, /*	getiterfunc tp_iter;	*/
+	NULL, /*	iternextfunc tp_iternext;	*/
+	
+	/* Attribute descriptor and subclassing stuff */
+	fs_methods, /*	struct PyMethodDef *tp_methods;	*/
+
+};
+
+static PyObject *repos_load_fs(PyObject *self, PyObject *args, PyObject *kwargs)
+{
+	const char *parent_dir = "";
+	PyObject *dumpstream, *feedback_stream, *cancel_func = Py_None;
+	bool use_pre_commit_hook = false, use_post_commit_hook = false;
+	char *kwnames[] = { "dumpstream", "feedback_stream", "uuid_action",
+		                "parent_dir", "use_pre_commit_hook", 
+						"use_post_commit_hook", "cancel_func", NULL };
+	int uuid_action;
+	apr_pool_t *temp_pool;
+	RepositoryObject *reposobj = (RepositoryObject *)self;
+
+    if (!PyArg_ParseTupleAndKeywords(args, kwargs, "OOi|sbbO", kwnames,
+								&dumpstream, &feedback_stream, &uuid_action,
+								&parent_dir, &use_pre_commit_hook, 
+								&use_post_commit_hook,
+								&cancel_func))
+		return NULL;
+
+	temp_pool = Pool(NULL);
+	if (temp_pool == NULL)
+		return NULL;
+	RUN_SVN_WITH_POOL(temp_pool, svn_repos_load_fs2(reposobj->repos, 
+				new_py_stream(temp_pool, dumpstream), 
+				new_py_stream(temp_pool, feedback_stream),
+				uuid_action, parent_dir, use_pre_commit_hook, 
+				use_post_commit_hook, py_cancel_func, (void *)cancel_func,
+				reposobj->pool));
+	apr_pool_destroy(temp_pool);
+	Py_RETURN_NONE;
+}
+
+static PyMethodDef repos_module_methods[] = {
+	{ "create", repos_create, METH_VARARGS, NULL },
+	{ NULL, }
+};
+
+static PyMethodDef repos_methods[] = {
+	{ "load_fs", (PyCFunction)repos_load_fs, METH_VARARGS|METH_KEYWORDS, NULL },
+	{ "fs", (PyCFunction)repos_fs, METH_NOARGS, NULL },
+	{ NULL, }
+};
+
+PyTypeObject Repository_Type = {
+	PyObject_HEAD_INIT(NULL) 0,
+	"repos.Repository", /*	const char *tp_name;  For printing, in format "<module>.<name>" */
+	sizeof(RepositoryObject), 
+	0,/*	Py_ssize_t tp_basicsize, tp_itemsize;  For allocation */
+	
+	/* Methods to implement standard operations */
+	
+	repos_dealloc, /*	destructor tp_dealloc;	*/
+	NULL, /*	printfunc tp_print;	*/
+	NULL, /*	getattrfunc tp_getattr;	*/
+	NULL, /*	setattrfunc tp_setattr;	*/
+	NULL, /*	cmpfunc tp_compare;	*/
+	NULL, /*	reprfunc tp_repr;	*/
+	
+	/* Method suites for standard classes */
+	
+	NULL, /*	PyNumberMethods *tp_as_number;	*/
+	NULL, /*	PySequenceMethods *tp_as_sequence;	*/
+	NULL, /*	PyMappingMethods *tp_as_mapping;	*/
+	
+	/* More standard operations (here for binary compatibility) */
+	
+	NULL, /*	hashfunc tp_hash;	*/
+	NULL, /*	ternaryfunc tp_call;	*/
+	NULL, /*	reprfunc tp_str;	*/
+	NULL, /*	getattrofunc tp_getattro;	*/
+	NULL, /*	setattrofunc tp_setattro;	*/
+	
+	/* Functions to access object as input/output buffer */
+	NULL, /*	PyBufferProcs *tp_as_buffer;	*/
+	
+	/* Flags to define presence of optional/expanded features */
+	0, /*	long tp_flags;	*/
+	
+	NULL, /*	const char *tp_doc;  Documentation string */
+	
+	/* Assigned meaning in release 2.0 */
+	/* call function for all accessible objects */
+	NULL, /*	traverseproc tp_traverse;	*/
+	
+	/* delete references to contained objects */
+	NULL, /*	inquiry tp_clear;	*/
+	
+	/* Assigned meaning in release 2.1 */
+	/* rich comparisons */
+	NULL, /*	richcmpfunc tp_richcompare;	*/
+	
+	/* weak reference enabler */
+	0, /*	Py_ssize_t tp_weaklistoffset;	*/
+	
+	/* Added in release 2.2 */
+	/* Iterators */
+	NULL, /*	getiterfunc tp_iter;	*/
+	NULL, /*	iternextfunc tp_iternext;	*/
+	
+	/* Attribute descriptor and subclassing stuff */
+	repos_methods, /*	struct PyMethodDef *tp_methods;	*/
+	NULL, /*	struct PyMemberDef *tp_members;	*/
+	NULL, /*	struct PyGetSetDef *tp_getset;	*/
+	NULL, /*	struct _typeobject *tp_base;	*/
+	NULL, /*	PyObject *tp_dict;	*/
+	NULL, /*	descrgetfunc tp_descr_get;	*/
+	NULL, /*	descrsetfunc tp_descr_set;	*/
+	0, /*	Py_ssize_t tp_dictoffset;	*/
+	NULL, /*	initproc tp_init;	*/
+	NULL, /*	allocfunc tp_alloc;	*/
+	repos_init, /*	newfunc tp_new;	*/
+
+};
+
+void initrepos(void)
+{
+	static apr_pool_t *pool;
+	PyObject *mod;
+
+	if (PyType_Ready(&Repository_Type) < 0)
+		return;
+
+	if (PyType_Ready(&FileSystem_Type) < 0)
+		return;
+
+	apr_initialize();
+	pool = Pool(NULL);
+	if (pool == NULL)
+		return;
+
+	svn_fs_initialize(pool);
+
+	mod = Py_InitModule3("repos", repos_module_methods, "Local repository management");
+	if (mod == NULL)
+		return;
+
+	PyModule_AddObject(mod, "LOAD_UUID_DEFAULT", PyLong_FromLong(0));
+	PyModule_AddObject(mod, "LOAD_UUID_IGNORE", PyLong_FromLong(1));
+	PyModule_AddObject(mod, "LOAD_UUID_FORCE", PyLong_FromLong(2));
+
+	PyModule_AddObject(mod, "Repository", (PyObject *)&Repository_Type);
+	Py_INCREF(&Repository_Type);
+}