Method getUdt

lib/metadata/schema-parser.js:209–248

* @param {String} keyspaceName * @param {String} name * @param {Object} cache * @returns {Promise }

(keyspaceName, name, cache)

   * @returns {Promise<Object|null>}
   */
  async getUdt(keyspaceName, name, cache) {
    let udtInfo = cache && cache[name];
    if (!udtInfo) {
      udtInfo = new events.EventEmitter();
      if (cache) {
        cache[name] = udtInfo;
      }
      udtInfo.setMaxListeners(0);
      udtInfo.loading = false;
      udtInfo.name = name;
      udtInfo.keyspace = keyspaceName;
      udtInfo.fields = null;
    }
    if (udtInfo.fields) {
      return udtInfo;
    }
    if (udtInfo.loading) {
      return promiseUtils.fromEvent(udtInfo, 'load');
    }
    udtInfo.loading = true;
    const query = format(this.selectUdt, keyspaceName, name);
    try {
      const row = await this._getFirstRow(query);
      if (!row) {
        udtInfo.loading = false;
        udtInfo.emit('load', null, null);
        return null;
      }
      await this._parseUdt(udtInfo, row);
      udtInfo.emit('load', null, udtInfo);
      return udtInfo;
    }
    catch (err) {
      udtInfo.emit('load', err);
      throw err;
    }
    finally {
      udtInfo.loading = false;
    }
  }

  /**
   * Parses the udt information from the row