sapling/infinitepush/fileindexapi.py

53 lines
1.5 KiB
Python
Raw Normal View History

import os
from indexapi import (
indexapi,
indexexception,
)
class fileindexapi(indexapi):
def __init__(self, repo):
super(fileindexapi, self).__init__()
self._repo = repo
root = repo.ui.config('infinitepush', 'indexpath')
if not root:
root = os.path.join('scratchbranches', 'index')
self._nodemap = os.path.join(root, 'nodemap')
self._bookmarkmap = os.path.join(root, 'bookmarkmap')
def addbundle(self, bundleid, nodes):
for node in nodes:
nodepath = os.path.join(self._nodemap, node)
self._write(nodepath, bundleid)
def addbookmark(self, bookmark, node):
bookmarkpath = os.path.join(self._bookmarkmap, bookmark)
self._write(bookmarkpath, node)
def addbookmarkandbundle(self, bundleid, nodes, bookmark, bookmarknode):
self.addbookmark(bookmark, bookmarknode)
self.addbundle(bundleid, nodes)
def getbundle(self, node):
nodepath = os.path.join(self._nodemap, node)
return self._read(nodepath)
def getnode(self, bookmark):
bookmarkpath = os.path.join(self._bookmarkmap, bookmark)
return self._read(bookmarkpath)
def _write(self, path, value):
vfs = self._repo.vfs
dirname = vfs.dirname(path)
if not vfs.exists(dirname):
vfs.makedirs(dirname)
vfs.write(path, value)
def _read(self, path):
vfs = self._repo.vfs
if not vfs.exists(path):
return None
return vfs.read(path)