Class Hydro

lib/hydro.js:47–197

}

export default class Hydro {
  constructor({ secret, endpoint, forceDisableMock } = {}) {
    // When mocking, the secret isn't important because nothing's actually
    // password protected in terms of HTTP authorization. But, the
    // secret is used for creating an HMAC payload so it has to be
    // a string.
    this.secret = secret || process.env.HYDRO_SECRET || (MOCK_HYDRO_POST && '')
    this.endpoint = endpoint || process.env.HYDRO_ENDPOINT
    // This class is involved in 2 types of jest tests:
    //  1. end-to-end tests where jest talks to localhost:4000 (with NODE_ENV===test)
    //  2. literal unit tests that might mock the socket stuff
    // Because `MOCK_HYDRO_POST = process.env.NODE_ENV === 'test'` gets set
    // for either type of jest tests, this additional setting makes it
    // possible to override `process.env.NODE_ENV === 'test'` from
    // mocking the HTTP calls.
    this.forceDisableMock = forceDisableMock
  }

  /**
   * Can check if it can actually send to Hydro
   */
  maySend() {
    return Boolean(this.secret && this.endpoint) || MOCK_HYDRO_POST
  }

  /**
   * Generate a SHA256 hash of the payload using the secret
   * to authenticate with Hydro
   * @param {string} body
   */
  generatePayloadHmac(body) {
    return crypto.createHmac('sha256', this.secret).update(body).digest('hex')
  }

  /**
   * Publish a single event to Hydro
   * @param {string} schema
   * @param {any} value
   */
  async publish(schema, value) {
    const body = JSON.stringify({
      events: [
        {
          schema,
          value: JSON.stringify(value), // We must double-encode the value property
          cluster: 'potomac', // We only have ability to publish externally to potomac cluster
        },
      ],
    })
    const token = this.generatePayloadHmac(body)

    const agent = getHttpsAgent()

    const doPost = async () => {
      // We *could* exit early on this whole `publish()` method if we know
      // we're going to "mock" Hydro anyway, but injecting here, before
      // the actual network operation, we make most of this method's code
      // execute without actually depending on real network. This is