Function pushRelationDocument

graphdb.js:841–935

(self, index, relation, documentindex, initializator, callback, between, recovered)

// Pushs "documentindex" to "index" document (document with all relations)
function pushRelationDocument(self, index, relation, documentindex, initializator, callback, between, recovered) {

	var offset = offsetDocument(self, index);
	var buf = U.createBufferSize(self.header.documentsize);

	Fs.read(self.fd, buf, 0, buf.length, offset, function() {

		// type (1b)              = from: 0
		// index (1b)             = from: 1
		// state (1b)             = from: 2
		// pageindex (4b)         = from: 3
		// relationindex (4b)     = from: 7  (it's for relations between two documents in TYPE_RELATION page)
		// parentindex (4b)       = from: 11
		// size/count (2b)        = from: 15
		// data                   = from: 17

		var count = buf.readUInt16LE(15);
		if (count + 1 > self.header.relationlimit) {
			findRelationDocument(self, buf.readUInt32LE(7), function(err, newindex) {

				// Is some relation document exist?
				if (newindex && !recovered) {
					pushRelationDocument(self, newindex, relation, documentindex, initializator, callback, between, true);
					return;
				}

				// meta.typeid (1 CLASS, 2 RELATION)
				// meta.type (link to type class/relation)
				// meta.state
				// meta.parentindex
				// meta.relationindex
				// meta.size
				// meta.buffer

				var meta = {};
				meta.typeid = relation.private ? TYPE_RELATION_DOCUMENT : TYPE_RELATION;
				meta.type = relation;
				meta.state = STATE_UNCOMPRESSED;
				meta.parentindex = 0;
				meta.relationindex = index;
				meta.size = 0;

				addNode(self, meta, function(err, docindex, pageindex) {
					relation.pageindex = pageindex;
					relation.documentindex = docindex;
					updDocumentRelation(self, relation.documentindex, index, function() {
						updDocumentParent(self, index, relation.documentindex, function() {
							pushRelationDocument(self, relation.documentindex, relation, documentindex, initializator, callback, between);
						});
					});
				});
			});

		} else {

			var buffer = U.createBufferSize(6);
			buffer.writeUInt8(relation.index, 0);
			buffer.writeUInt8(initializator ? 1 : 0, 1);