discourse/app/assets/javascripts/admin/controllers/admin-web-hooks-show-events.js

import discourseComputed from "discourse-common/utils/decorators";
import { alias } from "@ember/object/computed";
import Controller from "@ember/controller";
import { ajax } from "discourse/lib/ajax";
import { popupAjaxError } from "discourse/lib/ajax-error";

export default Controller.extend({
  pingDisabled: false,
  incomingCount: alias("incomingEventIds.length"),

  init() {
    this._super(...arguments);

    this.incomingEventIds = [];
  },

  @discourseComputed("incomingCount")
  hasIncoming(incomingCount) {
    return incomingCount > 0;
  },

  subscribe() {
    this.messageBus.subscribe(
      `/web_hook_events/${this.get("model.extras.web_hook_id")}`,
      data => {
        if (data.event_type === "ping") {
          this.set("pingDisabled", false);
        }
        this._addIncoming(data.web_hook_event_id);
      }
    );
  },

  unsubscribe() {
    this.messageBus.unsubscribe("/web_hook_events/*");
  },

  _addIncoming(eventId) {
    const incomingEventIds = this.incomingEventIds;

    if (incomingEventIds.indexOf(eventId) === -1) {
      incomingEventIds.pushObject(eventId);
    }
  },

  actions: {
    loadMore() {
      this.model.loadMore();
    },

    ping() {
      this.set("pingDisabled", true);

      ajax(
        `/admin/api/web_hooks/${this.get("model.extras.web_hook_id")}/ping`,
        {
          type: "POST"
        }
      ).catch(error => {
        this.set("pingDisabled", false);
        popupAjaxError(error);
      });
    },

    showInserted() {
      const webHookId = this.get("model.extras.web_hook_id");

      ajax(`/admin/api/web_hooks/${webHookId}/events/bulk`, {
        type: "GET",
        data: { ids: this.incomingEventIds }
      }).then(data => {
        const objects = data.map(event =>
          this.store.createRecord("web-hook-event", event)
        );
        this.model.unshiftObjects(objects);
        this.set("incomingEventIds", []);
      });
    }
  }
});