{

	"hosts": ["127.0.0.1"],

	"port": 9901,

}

	#

	# Requests nodes in order of a batch DFS. Needs stack of size O(treeDepth*batchSize). Nodes in each tree level are accessed in order.

	def negotiate(self):

		localTree=self._tree

		blocksToTransfer=[]

		nodeStack=collections.deque([0]) # root

		# determine which blocks to send

		print(datetime.now(), "negotiating:")

		progress=Progress(localTree.leafCount)

		while len(nodeStack)>0:

			indices=[]

				indices.append(nodeStack.pop())

				if len(nodeStack)==0: break

			self._outcoming.writeMsg({"command":"req", "index":indices, "dataType":"hash"})

			jsonData,binData=self._incoming.readMsg()

			assert jsonData["index"]==indices

			assert jsonData["dataType"]=="hash"

			stats.logExchangedNode(len(indices))

			frontier=[]

			for (j,i) in enumerate(indices):

				(j1,j2)=[HashTree.HASH_LEN*ji for ji in (j,j+1)]

		print(datetime.now(), "{0} to transfer".format(size))

		return blocksToTransfer

	def sendData(self,blocksToTransfer):

		log.info(blocksToTransfer)

		dataFile=open(self._filename, mode="rb")

		i1=-1

		print(datetime.now(), "sending data:")

		progress=Progress(len(blocksToTransfer))

			indices=[]

			blocks=[]

				if k+j>=len(blocksToTransfer): break

				i2=blocksToTransfer[k+j]

				if i1+1!=i2:

					dataFile.seek(i2*HashTree.BLOCK_SIZE)

				block=dataFile.read(HashTree.BLOCK_SIZE)

				indices.append(i2)

				blocks.append(block)

				log.info("block #{0}: {1}...{2}".format(i2,block[:5],block[-5:]))

				i1=i2

				progress.p(k+j)

		if not ignoreLock:

			try:

				self._lock()

			except LockedException:

				print("The file is locked. Either (a) there's another pull going on (then wait or kill it), or (b) a previous pull ended prematurely and the file is probably corrupt (then repeat pull with -f for force).")

				return

		log.info(blocksToTransfer)

		dataFile=DataFile.open(self._filename, mode="rb+")

		print(datetime.now(), "receiving data:")

		progress=Progress(len(blocksToTransfer))

			self._outcoming.writeMsg({"command":"req", "index":indices, "dataType":"data"})

			jsonData,binData=self._incoming.readMsg()

			assert jsonData["command"]=="send" and jsonData["index"]==indices and jsonData["dataType"]=="data", jsonData

			for (j,i) in enumerate(indices):

				block=binData[j*HashTree.BLOCK_SIZE:(j+1)*HashTree.BLOCK_SIZE]

				dataFile.writeAt(i,block)

				if self._treeFile:

					self._newLeaves[i+self._tree.leafStart]=hashBlock(block)

				log.info("block #{0}: {1}...{2}".format(i,block[:5],block[-5:]))

configFile=os.path.join(directory,"config.json")

conf=dict()

if os.path.isfile(configFile):

	with open(configFile) as f: conf=json.load(f)

version=[0,1,0]

lowestCompatible=[0,1,0] # tuple is more fitting but json conversion transforms it into a list anyway

hosts=conf.get("hosts",["127.0.0.1"])

port=conf.get("port",9901)

import config

from hashtree import HashTree

from client import Client, Connection as ClientConnection, DeniedConnection

from server import Miniserver

from . import RedirectedOutput

config.logger.removeHandler(config.handler)

handler=FileHandler("/tmp/morevna.log")

handler.setFormatter(config.formatter)

config.logger.addHandler(handler)

dataDir=os.path.join(config.directory,"src/tests/data")

filename=os.path.join(dataDir,"test.img")

def compareFiles(f1,f2):

	with open(f1,mode="rb") as f:

		h2=hashlib.sha256(f.read()).hexdigest()

	with open(f2,mode="rb") as f:

		h=hashlib.sha256(f.read()).hexdigest()

	return (h,h2)