Initial commit

Not a lot of stuff, hard coded paths, tests against /usr/portage

12 files changed, 540 insertions, 0 deletions

diff --git a/src/Jamfile.jam b/src/Jamfile.jam
new file mode 100644
index 0000000..db6267c
--- /dev/null
+++ b/src/Jamfile.jam
@@ -0,0 +1,12 @@
+
+lib gitfs :
+	[ glob *.cpp ]
+	:
+	<library>..//adhocutil
+	<library>..//icetray
+	<library>..//git2
+	<library>..//netfs-api
+	: :
+	<library>..//netfs-api
+	;
+
diff --git a/src/blob.cpp b/src/blob.cpp
new file mode 100644
index 0000000..8fb0509
--- /dev/null
+++ b/src/blob.cpp
@@ -0,0 +1,49 @@
+#include <Ice/ObjectAdapter.h>
+#include "blob.h"
+
+GitFS::Blob::Blob(const GitFS::Git::RepositoryPtr & r, const GitFS::Git::TreeEntryPtr & te) :
+	blob(Git::BlobLookup(r, *git_tree_entry_id(te.get()))),
+	blobSize(git_blob_rawsize(blob.get())),
+	blobContent(static_cast<const char *>(git_blob_rawcontent(blob.get())))
+{
+}
+
+void
+GitFS::Blob::close(const ::Ice::Current& current)
+{
+	current.adapter->remove(current.id);
+}
+
+
+NetFS::Attr
+GitFS::Blob::fgetattr(ReqEnv, const ::Ice::Current&)
+{
+	return {};
+}
+
+
+NetFS::Buffer
+GitFS::Blob::read(long long int offset, long long int size, const ::Ice::Current&)
+{
+	if (offset > blobSize) {
+		return {};
+	}
+	auto len = std::min(blobSize - offset, size);
+	return NetFS::Buffer(blobContent + offset, blobContent + offset + len);
+}
+
+
+void
+GitFS::Blob::ftruncate(ReqEnv, long long int, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Blob::write(long long int, long long int, Buffer, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
diff --git a/src/blob.h b/src/blob.h
new file mode 100644
index 0000000..0a2a77d
--- /dev/null
+++ b/src/blob.h
@@ -0,0 +1,27 @@
+#ifndef GITFS_BLOB_H
+#define GITFS_BLOB_H
+
+#include <file.h>
+#include "git.h"
+
+namespace GitFS {
+	using namespace NetFS;
+	class Blob : public File {
+		public:
+			Blob(const GitFS::Git::RepositoryPtr & r, const Git::TreeEntryPtr &);
+
+			void close(const ::Ice::Current& current) override;
+			Attr fgetattr(ReqEnv env, const ::Ice::Current& current) override;
+			Buffer read(long long int offset, long long int size, const ::Ice::Current& current) override;
+			void ftruncate(ReqEnv env, long long int size, const ::Ice::Current& current) override;
+			void write(long long int offset, long long int size, Buffer data, const ::Ice::Current& current) override;
+
+		private:
+			Git::BlobPtr blob;
+			const decltype(git_blob_rawsize({})) blobSize;
+			const char * const blobContent;
+	};
+}
+
+#endif
+
diff --git a/src/dir.cpp b/src/dir.cpp
new file mode 100644
index 0000000..8a9fd86
--- /dev/null
+++ b/src/dir.cpp
@@ -0,0 +1,30 @@
+#include <Ice/ObjectAdapter.h>
+#include "dir.h"
+
+GitFS::Directory::Directory(const GitFS::Git::TreePtr & t, const std::string & p) :
+	tree(t),
+	path(p)
+{
+}
+
+void
+GitFS::Directory::close(const ::Ice::Current& current)
+{
+	current.adapter->remove(current.id);
+}
+
+
+NetFS::NameList
+GitFS::Directory::readdir(const ::Ice::Current&)
+{
+	return {};
+}
+
+
+NetFS::DirectoryContents
+GitFS::Directory::listdir(const ::Ice::Current&)
+{
+	return {};
+}
+
+
diff --git a/src/dir.h b/src/dir.h
new file mode 100644
index 0000000..74afde3
--- /dev/null
+++ b/src/dir.h
@@ -0,0 +1,24 @@
+#ifndef GITFS_DIRECTORY_H
+#define GITFS_DIRECTORY_H
+
+#include <directory.h>
+#include "git.h"
+
+namespace GitFS {
+	using namespace NetFS;
+	class Directory : public DirectoryV2 {
+		public:
+			Directory(const GitFS::Git::TreePtr & r, const std::string &);
+
+			void close(const ::Ice::Current& current) override;
+			NameList readdir(const ::Ice::Current& current) override;
+			DirectoryContents listdir(const ::Ice::Current& current) override;
+
+		private:
+			Git::TreePtr tree;
+			const std::string path;
+	};
+}
+
+#endif
+
diff --git a/src/git.cpp b/src/git.cpp
new file mode 100644
index 0000000..084e6ca
--- /dev/null
+++ b/src/git.cpp
@@ -0,0 +1,30 @@
+#include "git.h"
+#include <execinfo.h>
+#include <exceptions.h>
+
+namespace GitFS {
+	namespace Git {
+		void
+		throwError(int err)
+		{
+#if LIBGIT2_VER_MINOR >= 28
+			const git_error * e = git_error_last();
+#else
+			const git_error * e = giterr_last();
+#endif
+			throw Error { err, e->klass, e->message };
+		}
+	}
+}
+
+namespace std {
+	std::ostream &
+	operator<<(std::ostream & s, const git_oid & oid)
+	{
+		char str[GIT_OID_HEXSZ + 1];
+		git_oid_tostr(str, sizeof(str), &oid);
+		s.write(str, GIT_OID_HEXSZ);
+		return s;
+	}
+}
+
diff --git a/src/git.h b/src/git.h
new file mode 100644
index 0000000..c0ae4e3
--- /dev/null
+++ b/src/git.h
@@ -0,0 +1,91 @@
+#ifndef GITFS_GIT_H
+#define GITFS_GIT_H
+
+#include <memory>
+#include <git2.h>
+#include <ostream>
+
+namespace GitFS {
+	namespace Git {
+		struct Error {
+			int err;
+			int klass;
+			const char * message;
+		};
+		void throwError(int err);
+
+		template<typename ... P, typename ... A>
+		void
+		gitSafe(int (*func)(P...), A ... p)
+		{
+			if (int _giterror = func(p...); _giterror != 0) {
+				throwError(_giterror);
+			}
+		}
+
+		template<typename T>
+		using TPtr = std::shared_ptr<T>;
+
+		template<typename R, typename ... P, typename ... A>
+		auto
+		gitSafeGet(int(*get)(R**, P...), void(*release)(R*), A ... p)
+		{
+			R * r = nullptr;
+			gitSafe(get, &r, p...);
+			return TPtr<R>(r, release);
+		}
+
+		template<typename R, typename ... P, typename ... A>
+		auto
+		gitSafeGet(int(*get)(R**, P...), A ... p)
+		{
+			R * r = nullptr;
+			gitSafe(get, &r, p...);
+			return r;
+		}
+
+		inline auto OidParse(const std::string_view & str)
+		{
+			git_oid oid;
+			gitSafe(git_oid_fromstrn, &oid, str.data(), str.length());
+			return oid;
+		}
+
+		inline auto RepositoryOpenBare(const std::string & path)
+		{
+			return gitSafeGet(git_repository_open_bare, git_repository_free, path.c_str());
+		}
+		using RepositoryPtr = decltype(RepositoryOpenBare(""));
+
+		inline auto BlobLookup(const RepositoryPtr & repo, const git_oid & blob)
+		{
+			return gitSafeGet(git_blob_lookup, git_blob_free, repo.get(), &blob);
+		}
+		using BlobPtr = decltype(BlobLookup({}, {}));
+
+		inline auto CommitLookup(const RepositoryPtr & repo, const git_oid & commitId)
+		{
+			return gitSafeGet(git_commit_lookup, git_commit_free, repo.get(), &commitId);
+		}
+		using CommitPtr = decltype(CommitLookup({}, {}));
+
+		inline auto TreeLookup(const RepositoryPtr & repo, const git_oid & treeId)
+		{
+			return gitSafeGet(git_tree_lookup, git_tree_free, repo.get(), &treeId);
+		}
+		using TreePtr = decltype(TreeLookup({}, {}));
+
+		inline auto TreeEntryByPath(const TreePtr & tree, const std::string & path)
+		{
+			return gitSafeGet(git_tree_entry_bypath, git_tree_entry_free, tree.get(), path.c_str() + 1);
+		}
+		using TreeEntryPtr = decltype(TreeEntryByPath({}, {}));
+	}
+}
+
+namespace std {
+	std::ostream & operator<<(std::ostream &, const git_oid &);
+}
+
+#endif
+
diff --git a/src/main.cpp b/src/main.cpp
new file mode 100644
index 0000000..0666a3c
--- /dev/null
+++ b/src/main.cpp
@@ -0,0 +1,28 @@
+#include <icetrayService.h>
+#include <git2.h>
+#include <factory.h>
+#include <icecube.h>
+#include "repoList.h"
+
+namespace GitFS {
+	class Main : public IceTray::Service {
+		public:
+			Main()
+			{
+				git_libgit2_init();
+			}
+
+			~Main()
+			{
+				git_libgit2_shutdown();
+			}
+
+			void addObjects(const std::string &, const Ice::CommunicatorPtr & ic, const Ice::StringSeq &, const Ice::ObjectAdapterPtr & adp) override
+			{
+				IceTray::Cube::addObject<NetFS::Service, RepoList>(adp, "Service", ic->getProperties());
+			}
+	};
+
+	NAMEDFACTORY("default", Main, IceTray::ServiceFactory);
+}
+
diff --git a/src/repo.cpp b/src/repo.cpp
new file mode 100644
index 0000000..299f2ce
--- /dev/null
+++ b/src/repo.cpp
@@ -0,0 +1,174 @@
+#include <Ice/ObjectAdapter.h>
+#include <sys/stat.h>
+#include "repo.h"
+#include "blob.h"
+#include "dir.h"
+
+GitFS::Repo::Repo() :
+	repo(Git::RepositoryOpenBare("/usr/portage/.git")),
+	commit(Git::CommitLookup(repo, Git::OidParse("97a435f30472eb941f96234d274b3aeb492e2793"))),
+	tree(Git::TreeLookup(repo, *git_commit_tree_id(commit.get())))
+{
+}
+
+void
+GitFS::Repo::disconnect(const ::Ice::Current& current)
+{
+	current.adapter->remove(current.id);
+}
+
+
+NetFS::DirectoryPrxPtr
+GitFS::Repo::opendir(ReqEnv, ::std::string path, const ::Ice::Current& ice)
+{
+	return Ice::uncheckedCast<NetFS::DirectoryV2Prx>(ice.adapter->addWithUUID(
+				std::make_shared<Directory>(tree, path)));
+}
+
+
+NetFS::VFS
+GitFS::Repo::statfs(ReqEnv, ::std::string, const ::Ice::Current&)
+{
+	return {};
+}
+
+
+int
+GitFS::Repo::access(ReqEnv, ::std::string path, int mode, const ::Ice::Current&)
+{
+	if (mode & W_OK) return EACCES;
+	if (path.empty()) return EINVAL;
+	if (path == "/") return 0;
+
+	try {
+		auto e = Git::TreeEntryByPath(tree, path);
+		const auto emode = git_tree_entry_filemode(e.get());
+
+		if (S_ISDIR(emode)) return 0;
+		if (mode & R_OK && !(S_IRUSR & emode)) return EACCES;
+		if (mode & X_OK && !(S_IXUSR & emode)) return EACCES;
+
+		return 0;
+	}
+	catch (const Git::Error & e) {
+		if (e.err == GIT_ENOTFOUND) {
+			return ENOENT;
+		}
+		throw NetFS::SystemError(EIO);
+	}
+}
+
+
+NetFS::Attr
+GitFS::Repo::getattr(ReqEnv, ::std::string path, const ::Ice::Current&)
+{
+	NetFS::Attr a {};
+	(void)path;
+	a.ctime = a.atime = a.mtime = git_commit_time(commit.get());
+	return a;
+}
+
+
+::std::string
+GitFS::Repo::readlink(ReqEnv, ::std::string path, const ::Ice::Current&)
+{
+	auto e = Git::TreeEntryByPath(tree, path);
+	if (!e) throw NetFS::SystemError(ENOENT);
+	const auto emode = git_tree_entry_filemode(e.get());
+	if (!S_ISLNK(emode)) throw NetFS::SystemError(EINVAL);
+	return {};
+}
+
+
+NetFS::FilePrxPtr
+GitFS::Repo::open(ReqEnv, ::std::string path, int, const ::Ice::Current& ice)
+{
+	return Ice::uncheckedCast<NetFS::FilePrx>(ice.adapter->addWithUUID(
+				std::make_shared<Blob>(repo, Git::TreeEntryByPath(tree, path))));
+}
+
+
+NetFS::FilePrxPtr
+GitFS::Repo::create(ReqEnv, ::std::string, int, int, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::truncate(ReqEnv, ::std::string, long long int, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::unlink(ReqEnv, ::std::string, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::mkdir(ReqEnv, ::std::string, int, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::rmdir(ReqEnv, ::std::string, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::mknod(ReqEnv, ::std::string, int, int, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::symlink(ReqEnv, ::std::string, ::std::string, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::link(ReqEnv, ::std::string, ::std::string, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::rename(ReqEnv, ::std::string, ::std::string, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::chmod(ReqEnv, ::std::string, int, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::chown(ReqEnv, ::std::string, int, int, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
+void
+GitFS::Repo::utimens(ReqEnv, ::std::string, long long int, long long int, long long int, long long int, const ::Ice::Current&)
+{
+	throw NetFS::SystemError(EROFS);
+}
+
+
diff --git a/src/repo.h b/src/repo.h
new file mode 100644
index 0000000..e6f7d94
--- /dev/null
+++ b/src/repo.h
@@ -0,0 +1,42 @@
+#ifndef GITFS_REPO_H
+#define GITFS_REPO_H
+
+#include <volume.h>
+#include "git.h"
+
+namespace GitFS {
+	using namespace NetFS;
+	class Repo : public Volume {
+		public:
+			Repo();
+
+			void disconnect(const ::Ice::Current& current) override;
+			DirectoryPrxPtr opendir(ReqEnv env, ::std::string path, const ::Ice::Current& current) override;
+			VFS statfs(ReqEnv env, ::std::string path, const ::Ice::Current& current) override;
+			int access(ReqEnv env, ::std::string path, int mode, const ::Ice::Current& current) override;
+			Attr getattr(ReqEnv env, ::std::string path, const ::Ice::Current& current) override;
+			::std::string readlink(ReqEnv env, ::std::string path, const ::Ice::Current& current) override;
+			FilePrxPtr open(ReqEnv env, ::std::string path, int flags, const ::Ice::Current& current) override;
+			FilePrxPtr create(ReqEnv env, ::std::string path, int flags, int mode, const ::Ice::Current& current) override;
+			void truncate(ReqEnv env, ::std::string path, long long int size, const ::Ice::Current& current) override;
+			void unlink(ReqEnv env, ::std::string path, const ::Ice::Current& current) override;
+			void mkdir(ReqEnv env, ::std::string path, int mode, const ::Ice::Current& current) override;
+			void rmdir(ReqEnv env, ::std::string path, const ::Ice::Current& current) override;
+			void mknod(ReqEnv env, ::std::string path, int mode, int dev, const ::Ice::Current& current) override;
+			void symlink(ReqEnv env, ::std::string path1, ::std::string path2, const ::Ice::Current& current) override;
+			void link(ReqEnv env, ::std::string path1, ::std::string path2, const ::Ice::Current& current) override;
+			void rename(ReqEnv env, ::std::string from, ::std::string to, const ::Ice::Current& current) override;
+			void chmod(ReqEnv env, ::std::string path, int mode, const ::Ice::Current& current) override;
+			void chown(ReqEnv env, ::std::string path, int uid, int gid, const ::Ice::Current& current) override;
+			void utimens(ReqEnv env, ::std::string path, long long int atime, long long int atimens, long long int mtime, long long int mtimens, const ::Ice::Current& current) override;
+
+		private:
+			Git::RepositoryPtr repo;
+			Git::CommitPtr commit;
+			Git::TreePtr tree;
+	};
+}
+
+#endif
+
+
diff --git a/src/repoList.cpp b/src/repoList.cpp
new file mode 100644
index 0000000..0ee92c5
--- /dev/null
+++ b/src/repoList.cpp
@@ -0,0 +1,16 @@
+#include <Ice/ObjectAdapter.h>
+#include "repoList.h"
+#include "repo.h"
+
+GitFS::RepoList::RepoList(const Ice::PropertiesPtr &)
+{
+
+}
+
+NetFS::VolumePrxPtr 
+GitFS::RepoList::connect(const ::std::string, const ::std::string,
+		const ::Ice::Current & ice)
+{
+	return Ice::uncheckedCast<NetFS::VolumePrx>(ice.adapter->addWithUUID(std::make_shared<Repo>()));
+}
+
diff --git a/src/repoList.h b/src/repoList.h
new file mode 100644
index 0000000..ac8b885
--- /dev/null
+++ b/src/repoList.h
@@ -0,0 +1,17 @@
+#ifndef GITFS_REPOLIST_H
+#define GITFS_REPOLIST_H
+
+#include <service.h>
+#include <Ice/Properties.h>
+
+namespace GitFS {
+	class RepoList : public NetFS::Service {
+		public:
+			RepoList(const Ice::PropertiesPtr & ptr);
+
+  virtual NetFS::VolumePrxPtr connect(const ::std::string volume, const ::std::string auth, const ::Ice::Current& current) override;
+	};
+}
+
+#endif
+