SubscriberElement.js

define(["lib/react"], function (React) {
  return React.createClass({
    subscribe: function () {
      var streamlink;

      // >= StreamLinkTS 7.1.12
      if (window.caplin.streamlink.getVersion) {
        streamlink = caplin.streamlink;
        // <= StreamLinkJS 7.0.4
      } else {
        if (typeof damJSStreamLink === "undefined") {
          alert("Make a real subscription first!");
          return;
        }
        streamlink = window.damJSStreamLink;
      }
      streamlink.subscribe(this.state.subject, {
        onSubscriptionStatus: function (subscription, event) {
          console.log(
            subscription.getSubject() + " is now " + event.getStatus()
          );
        },

        onSubscriptionError: function (subscription, event) {
          console.log(
            "Error: Subject " +
              subscription.getSubject() +
              " is " +
              event.getError()
          );
        },

        onRecordUpdate: function (subscription, event) {
          console.log(
            event.getSubject(),
            JSON.parse(JSON.stringify(event.getFields()))
          );
        },
      });
    },
    getInitialState: function () {
      return { subject: "/FX/EURUSD/SPOT/EUR/100" };
    },
    setSubject: function (e) {
      this.setState({
        subject: e.target.value,
      });
    },
    render: function () {
      return React.DOM.div(
        {},
        React.DOM.button({ onClick: this.props.back }, "Back"),
        React.DOM.input({
          value: this.state.subject,
          onChange: this.setSubject,
        }),
        React.DOM.button({ onClick: this.subscribe }, "Subscribe")
      );
    },
  });
});