async create()

in src/database-controller/src/common/framework.js [436:502]
67 lines of code
21 McCabe index (conditional complexity)

  async create() {
    if (this._configSecretDef) {
      try {
        await k8s.createSecret(this._configSecretDef);
      } catch (err) {
        if (err.response && err.response.statusCode === 409) {
          logger.warn(
            `Secret ${this._configSecretDef.metadata.name} already exists.`,
          );
        } else {
          throw err;
        }
      }
    }
    if (this._userExtensionSecretDef) {
      try {
        await k8s.createSecret(this._userExtensionSecretDef);
      } catch (err) {
        if (err.response && err.response.statusCode === 409) {
          logger.warn(
            `Secret ${this._userExtensionSecretDef.metadata.name} already exists.`,
          );
        } else {
          throw err;
        }
      }
    }
    if (this._priorityClassDef) {
      try {
        await k8s.createPriorityClass(this._priorityClassDef);
      } catch (err) {
        if (err.response && err.response.statusCode === 409) {
          logger.warn(
            `PriorityClass ${this._priorityClassDef.metadata.name} already exists.`,
          );
        } else {
          throw err;
        }
      }
    }
    if (this._dockerSecretDef) {
      try {
        await k8s.createSecret(this._dockerSecretDef);
      } catch (err) {
        if (err.response && err.response.statusCode === 409) {
          logger.warn(
            `Secret ${this._dockerSecretDef.metadata.name} already exists.`,
          );
        } else {
          throw err;
        }
      }
    }
    if (this._tokenSecretDef) {
      try {
        await k8s.createSecret(this._tokenSecretDef);
      } catch (err) {
        if (err.response && err.response.statusCode === 409) {
          logger.warn(
            `Secret ${this._tokenSecretDef.metadata.name} already exists.`,
          );
        } else {
          throw err;
        }
      }
    }
  }