Function _include

databases/mongo.js:47–184

(appId, include, docs)

  },

  _include(appId, include, docs) {
    // This function is for joins. :)
    const _self = obj;
    const join = [];
    const deferred = q.defer();
    try {
      // include and merge all the documents.
      const promises = [];
      include.sort();
      for (let i = 0; i < include.length; i++) {
        const [columnName] = include[i].split('.');
        join.push(columnName);
        for (let k = 1; k < include.length; k++) {
          if (columnName === include[k].split('.')[0]) {
            i += 1;
          } else {
            break;
          }
        }
        // include this column and merge.
        const idList = [];
        let collectionName = null;
        _.each(docs, (doc) => {
          if (doc[columnName] !== null) {
            // checks if the doc[columnName] is an list of relations or a relation
            if (Object.getPrototypeOf(doc[columnName]) === Object.prototype) {
              if (doc[columnName] && doc[columnName]._id) {
                if (doc[columnName]._type === 'file') {
                  collectionName = '_File';
                } else {
                  collectionName = doc[columnName]._tableName;
                }
                idList.push(doc[columnName]._id);
              }
            } else {
              for (let j = 0; j < doc[columnName].length; j++) {
                if (doc[columnName][j] && doc[columnName][j]._id) {
                  if (doc[columnName][j]._type === 'file') {
                    collectionName = '_File';
                  } else {
                    collectionName = doc[columnName][j]._tableName;
                  }
                  idList.push(doc[columnName][j]._id);
                }
              }
            }
          }
        }, null);

        // if(idList.length >0 && collectionName) {
        const qry = {};
        qry._id = {};
        qry._id.$in = idList;
        promises.push(_self.document.fetch_data(appId, collectionName, qry));
        // }
      }

      q.all(promises).then((arrayOfDocs) => {