{"version":3,"file":"rails.js","mappings":"2hBAAA,IAAAA,EAAA,CACAC,OAAA,oBAAAC,QAAAA,aAAAC,EACAC,UAAA,oBAAAA,UAAAA,eAAAD,GAGAF,EAAA,CACA,GAAAI,IAAAC,GACAC,KAAAC,UACAF,EAAAG,KAAAC,KAAAC,OACAX,EAAAC,OAAAI,IAAA,mBAAAC,GAEA,GAGA,MAAAK,EAAA,SAAAD,MAAAE,UAEAC,EAAAC,IAAAH,IAAAG,GAAA,IAEA,MAAAC,EACA,WAAAC,CAAAC,GACAV,KAAAW,oBAAAX,KAAAW,oBAAAC,KAAAZ,MACAA,KAAAU,WAAAA,EACAV,KAAAa,kBAAA,CACA,CACA,KAAAC,GACAd,KAAAe,cACAf,KAAAgB,UAAAZ,WACAJ,KAAAiB,UACAjB,KAAAkB,eACAC,iBAAA,mBAAAnB,KAAAW,qBACAjB,EAAAI,IAAA,gDAAiEE,KAAAS,YAAAW,oBAEjE,CACA,IAAAC,GACArB,KAAAe,cACAf,KAAAiB,UAAAb,IACAJ,KAAAsB,cACAC,oBAAA,mBAAAvB,KAAAW,qBACAjB,EAAAI,IAAA,6BAEA,CACA,SAAAiB,GACA,OAAAf,KAAAgB,YAAAhB,KAAAiB,SACA,CACA,aAAAO,GACAxB,KAAAyB,SAAArB,GACA,CACA,aAAAsB,GACA1B,KAAAa,kBAAA,SACAb,KAAA2B,eACAjC,EAAAI,IAAA,qCACA,CACA,gBAAA8B,GACA5B,KAAA2B,eAAAvB,IACAV,EAAAI,IAAA,wCACA,CACA,YAAAoB,GACAlB,KAAAsB,cACAtB,KAAA6B,MACA,CACA,WAAAP,GACAQ,aAAA9B,KAAA+B,YACA,CACA,IAAAF,GACA7B,KAAA+B,YAAAC,WAAA,KACAhC,KAAAiC,mBACAjC,KAAA6B,MACK,EAAA7B,KAAAkC,kBACL,CACA,eAAAA,GACA,MAAWd,eAAAA,EAAAe,wBAAAA,GAAkFnC,KAAAS,YAI7F,WAAAW,EAHAgB,KAAAC,IAAA,EAAAF,EAAAC,KAAAE,IAAAtC,KAAAa,kBAAA,MAGA,GAFA,IAAAb,KAAAa,kBAAA,EAAAsB,GACAC,KAAAG,SAEA,CACA,gBAAAN,GACAjC,KAAAwC,sBACA9C,EAAAI,IAAA,oEAAqFE,KAAAa,mCAAwCP,EAAAN,KAAAyC,qCAAuDzC,KAAAS,YAAAW,oBACpLpB,KAAAa,oBACAb,KAAA0C,uBACAhD,EAAAI,IAAA,+EAAkGQ,EAAAN,KAAA2B,sBAElGjC,EAAAI,IAAA,+BACAE,KAAAU,WAAAiC,UAGA,CACA,eAAAF,GACA,OAAAzC,KAAAyB,SAAAzB,KAAAyB,SAAAzB,KAAAgB,SACA,CACA,iBAAAwB,GACA,OAAAlC,EAAAN,KAAAyC,aAAAzC,KAAAS,YAAAW,cACA,CACA,oBAAAsB,GACA,OAAA1C,KAAA2B,gBAAArB,EAAAN,KAAA2B,gBAAA3B,KAAAS,YAAAW,cACA,CACA,mBAAAT,GACA,YAAAiC,SAAAC,iBACAb,WAAA,MACAhC,KAAAwC,qBAAAxC,KAAAU,WAAAoC,WACApD,EAAAI,IAAA,uFAA4G8C,SAAAC,mBAC5G7C,KAAAU,WAAAiC,SAEO,MAEP,EAGAnC,EAAAY,eAAA,EAEAZ,EAAA2B,wBAAA,IAEA,IAAAY,EAAA,CACAC,cAAA,CACAC,QAAA,UACAC,WAAA,aACAC,KAAA,OACAC,aAAA,uBACAC,UAAA,uBAEAC,mBAAA,CACAC,aAAA,eACAC,gBAAA,kBACAC,eAAA,iBACAC,OAAA,UAEAC,mBAAA,SACAC,UAAA,mDAGA,MAAOZ,cAAAA,EAAAY,UAAAA,GAAoDb,EAE3Dc,EAAAD,EAAAE,MAAA,EAAAF,EAAAG,OAAA,GAEAC,EAAA,GAAAA,QAEA,MAAAC,EACA,WAAAxD,CAAAyD,GACAlE,KAAAmE,KAAAnE,KAAAmE,KAAAvD,KAAAZ,MACAA,KAAAkE,SAAAA,EACAlE,KAAAoE,cAAApE,KAAAkE,SAAAE,cACApE,KAAAqE,QAAA,IAAA7D,EAAAR,MACAA,KAAAsE,cAAA,CACA,CACA,IAAAC,CAAAC,GACA,QAAAxE,KAAA8C,WACA9C,KAAAyE,UAAAF,KAAAG,KAAAC,UAAAH,KACA,EAIA,CACA,IAAAL,GACA,GAAAnE,KAAA4E,WAEA,OADAlF,EAAAI,IAAA,uDAAwEE,KAAA6E,eACxE,EACM,CACN,MAAAC,EAAA,IAAAlB,KAAA5D,KAAAkE,SAAAa,cAAA,IAQA,OAPArF,EAAAI,IAAA,uCAAwDE,KAAA6E,6BAAkCC,KAC1F9E,KAAAyE,WACAzE,KAAAgF,yBAEAhF,KAAAyE,UAAA,IAAAhF,EAAAI,UAAAG,KAAAkE,SAAAe,IAAAH,GACA9E,KAAAkF,uBACAlF,KAAAqE,QAAAvD,SACA,CACA,CACA,CACA,KAAAqE,EAASC,eAAAA,GAAgC,CACzCA,gBAAA,IAKA,GAHAA,GACApF,KAAAqE,QAAAhD,OAEArB,KAAA8C,SACA,OAAA9C,KAAAyE,UAAAU,OAEA,CACA,MAAAxC,GAEA,GADAjD,EAAAI,IAAA,yCAAwDE,KAAA6E,eACxD7E,KAAA4E,WAUA,OAAA5E,KAAAmE,OATA,IACA,OAAAnE,KAAAmF,OACA,CAAQ,MAAAE,GACR3F,EAAAI,IAAA,6BAAAuF,EACA,CAAQ,QACR3F,EAAAI,IAAA,0BAA6CE,KAAAS,YAAA6E,iBAC7CtD,WAAAhC,KAAAmE,KAAAnE,KAAAS,YAAA6E,YACA,CAIA,CACA,WAAAC,GACA,GAAAvF,KAAAyE,UACA,OAAAzE,KAAAyE,UAAAe,QAEA,CACA,MAAA1C,GACA,OAAA9C,KAAAyF,QAAA,OACA,CACA,QAAAb,GACA,OAAA5E,KAAAyF,QAAA,oBACA,CACA,gBAAAC,GACA,OAAA1F,KAAAqE,QAAAxD,kBAAA,CACA,CACA,mBAAA8E,GACA,OAAA3B,EAAA4B,KAAA/B,EAAA7D,KAAAuF,gBAAA,CACA,CACA,OAAAE,IAAAI,GACA,OAAA7B,EAAA4B,KAAAC,EAAA7F,KAAA6E,aAAA,CACA,CACA,QAAAA,GACA,GAAA7E,KAAAyE,UACA,QAAAqB,KAAArG,EAAAI,UACA,GAAAJ,EAAAI,UAAAiG,KAAA9F,KAAAyE,UAAAsB,WACA,OAAAD,EAAAE,cAIA,WACA,CACA,oBAAAd,GACA,QAAAe,KAAAjG,KAAAkG,OAAA,CACA,MAAAC,EAAAnG,KAAAkG,OAAAD,GAAArF,KAAAZ,MACAA,KAAAyE,UAAA,KAA0BwB,KAAUE,CACpC,CACA,CACA,sBAAAnB,GACA,QAAAiB,KAAAjG,KAAAkG,OACAlG,KAAAyE,UAAA,KAA0BwB,KAAU,YAEpC,EAGAhC,EAAAqB,YAAA,IAEArB,EAAAmC,UAAAF,OAAA,CACA,OAAAG,CAAAC,GACA,IAAAtG,KAAA2F,sBACA,OAEA,MAAWY,WAAAA,EAAAF,QAAAA,EAAAG,OAAAA,EAAAC,UAAAA,EAAAC,KAAAA,GAA4FhC,KAAAiC,MAAAL,EAAA9B,MAEvG,OADAxE,KAAAqE,QAAA7C,gBACAkF,GACA,KAAA1D,EAAAC,QAKA,OAJAjD,KAAA0F,qBACA1F,KAAA4G,oBAAA,GAEA5G,KAAAqE,QAAA3C,gBACA1B,KAAAoE,cAAAyC,SAEA,KAAA7D,EAAAE,WAEA,OADAxD,EAAAI,IAAA,0BAA2C0G,KAC3CxG,KAAAmF,MAAA,CACAC,eAAAqB,IAGA,KAAAzD,EAAAG,KACA,YAEA,KAAAH,EAAAI,aAEA,OADApD,KAAAoE,cAAA0C,oBAAAP,GACAvG,KAAA4G,oBACA5G,KAAA4G,oBAAA,EACA5G,KAAAoE,cAAA2C,OAAAR,EAAA,aACAS,aAAA,KAGAhH,KAAAoE,cAAA2C,OAAAR,EAAA,aACAS,aAAA,IAIA,KAAAhE,EAAAK,UACA,OAAArD,KAAAoE,cAAA6C,OAAAV,GAEA,QACA,OAAAvG,KAAAoE,cAAA2C,OAAAR,EAAA,WAAAF,GAEA,EACA,IAAAlC,GAGA,GAFAzE,EAAAI,IAAA,kCAAiDE,KAAAuF,8BACjDvF,KAAAsE,cAAA,GACAtE,KAAA2F,sBAEA,OADAjG,EAAAI,IAAA,gEACAE,KAAAmF,MAAA,CACAC,gBAAA,GAGA,EACA,KAAAD,CAAAmB,GAEA,GADA5G,EAAAI,IAAA,4BACAE,KAAAsE,aAKA,OAFAtE,KAAAsE,cAAA,EACAtE,KAAAqE,QAAAzC,mBACA5B,KAAAoE,cAAA8C,UAAA,gBACAC,qBAAAnH,KAAAqE,QAAAtD,aAEA,EACA,KAAAsE,GACA3F,EAAAI,IAAA,0BACA,GAaA,MAAAsH,EACA,WAAA3G,CAAAyD,EAAAmD,EAAA,GAAmCC,GACnCtH,KAAAkE,SAAAA,EACAlE,KAAAuG,WAAA7B,KAAAC,UAAA0C,GAbA,SAAAE,EAAAC,GACA,SAAAA,EACA,QAAAC,KAAAD,EAAA,CACA,MAAAE,EAAAF,EAAAC,GACAF,EAAAE,GAAAC,CACA,CAGA,CAMAC,CAAA3H,KAAAsH,EACA,CACA,OAAAM,CAAAC,EAAArD,EAAA,IAEA,OADAA,EAAAqD,OAAAA,EACA7H,KAAAuE,KAAAC,EACA,CACA,IAAAD,CAAAC,GACA,OAAAxE,KAAAkE,SAAAK,KAAA,CACAuD,QAAA,UACAvB,WAAAvG,KAAAuG,WACA/B,KAAAE,KAAAC,UAAAH,IAEA,CACA,WAAAuD,GACA,OAAA/H,KAAAkE,SAAAE,cAAA4D,OAAAhI,KACA,EAGA,MAAAiI,EACA,WAAAxH,CAAA2D,GACApE,KAAAoE,cAAAA,EACApE,KAAAkI,qBAAA,EACA,CACA,SAAAC,CAAAC,IACA,GAAApI,KAAAkI,qBAAAlE,QAAAoE,IACA1I,EAAAI,IAAA,sCAAuDsI,EAAA7B,cACvDvG,KAAAkI,qBAAAhI,KAAAkI,IAEA1I,EAAAI,IAAA,8CAA+DsI,EAAA7B,cAE/DvG,KAAAqI,mBACA,CACA,MAAAC,CAAAF,GACA1I,EAAAI,IAAA,oCAAmDsI,EAAA7B,cACnDvG,KAAAkI,qBAAAlI,KAAAkI,qBAAAK,OAAAC,GAAAA,IAAAJ,EACA,CACA,iBAAAC,GACArI,KAAAyI,mBACAzI,KAAA0I,kBACA,CACA,gBAAAD,GACA3G,aAAA9B,KAAA2I,aACA,CACA,gBAAAD,GACA1I,KAAA2I,aAAA3G,WAAA,KACAhC,KAAAoE,eAAA,mBAAApE,KAAAoE,cAAAwE,WACA5I,KAAAkI,qBAAAW,IAAAT,IACA1I,EAAAI,IAAA,uCAA4DsI,EAAA7B,cAC5DvG,KAAAoE,cAAAwE,UAAAR,EACS,EAEJ,MACL,EAGA,MAAAU,EACA,WAAArI,CAAAyD,GACAlE,KAAAkE,SAAAA,EACAlE,KAAA+I,UAAA,IAAAd,EAAAjI,MACAA,KAAAoE,cAAA,EACA,CACA,MAAA4E,CAAAC,EAAA3B,GACA,MACAD,EAAA,iBADA4B,IACA,CACAC,QAFAD,GAIAb,EAAA,IAAAhB,EAAApH,KAAAkE,SAAAmD,EAAAC,GACA,OAAAtH,KAAAmJ,IAAAf,EACA,CACA,GAAAe,CAAAf,GAKA,OAJApI,KAAAoE,cAAAlE,KAAAkI,GACApI,KAAAkE,SAAAkF,yBACApJ,KAAA+G,OAAAqB,EAAA,eACApI,KAAA4I,UAAAR,GACAA,CACA,CACA,MAAAJ,CAAAI,GAKA,OAJApI,KAAAsI,OAAAF,GACApI,KAAAqJ,QAAAjB,EAAA7B,YAAAxC,QACA/D,KAAAsJ,YAAAlB,EAAA,eAEAA,CACA,CACA,MAAAnB,CAAAV,GACA,OAAAvG,KAAAqJ,QAAA9C,GAAAsC,IAAAT,IACApI,KAAAsI,OAAAF,GACApI,KAAA+G,OAAAqB,EAAA,YACAA,GAEA,CACA,MAAAE,CAAAF,GAGA,OAFApI,KAAA+I,UAAAT,OAAAF,GACApI,KAAAoE,cAAApE,KAAAoE,cAAAmE,OAAAC,GAAAA,IAAAJ,GACAA,CACA,CACA,OAAAiB,CAAA9C,GACA,OAAAvG,KAAAoE,cAAAmE,OAAAC,GAAAA,EAAAjC,aAAAA,EACA,CACA,MAAAM,GACA,OAAA7G,KAAAoE,cAAAyE,IAAAT,GAAApI,KAAA4I,UAAAR,GACA,CACA,SAAAlB,CAAAqC,KAAAC,GACA,OAAAxJ,KAAAoE,cAAAyE,IAAAT,GAAApI,KAAA+G,OAAAqB,EAAAmB,KAAAC,GACA,CACA,MAAAzC,CAAAqB,EAAAmB,KAAAC,GACA,IAAApF,EAMA,OAJAA,EADA,iBAAAgE,EACApI,KAAAqJ,QAAAjB,GAEA,CAAAA,GAEAhE,EAAAyE,IAAAT,GAAA,mBAAAA,EAAAmB,GAAAnB,EAAAmB,MAAAC,QAAA5J,EACA,CACA,SAAAgJ,CAAAR,GACApI,KAAAsJ,YAAAlB,EAAA,cACApI,KAAA+I,UAAAZ,UAAAC,EAEA,CACA,mBAAAtB,CAAAP,GACA7G,EAAAI,IAAA,0BAAyCyG,KACzCvG,KAAAqJ,QAAA9C,GAAAsC,IAAAT,GAAApI,KAAA+I,UAAAT,OAAAF,GACA,CACA,WAAAkB,CAAAlB,EAAAN,GACA,MAAWvB,WAAAA,GAAwB6B,EACnC,OAAApI,KAAAkE,SAAAK,KAAA,CACAuD,QAAAA,EACAvB,WAAAA,GAEA,EAGA,MAAAkD,EACA,WAAAhJ,CAAAwE,GACAjF,KAAA0J,KAAAzE,EACAjF,KAAAoE,cAAA,IAAA0E,EAAA9I,MACAA,KAAAU,WAAA,IAAAuD,EAAAjE,MACAA,KAAA+E,aAAA,EACA,CACA,OAAAE,GACA,OAAA0E,EAAA3J,KAAA0J,KACA,CACA,IAAAnF,CAAAC,GACA,OAAAxE,KAAAU,WAAA6D,KAAAC,EACA,CACA,OAAAoF,GACA,OAAA5J,KAAAU,WAAAyD,MACA,CACA,UAAAjB,GACA,OAAAlD,KAAAU,WAAAyE,MAAA,CACAC,gBAAA,GAEA,CACA,sBAAAgE,GACA,IAAApJ,KAAAU,WAAAkE,WACA,OAAA5E,KAAAU,WAAAyD,MAEA,CACA,cAAA0F,CAAAC,GACA9J,KAAA+E,aAAA,IAAA/E,KAAA+E,aAAA+E,EACA,EAGA,SAAAH,EAAA1E,GAIA,GAHA,mBAAAA,IACAA,EAAAA,KAEAA,IAAA,UAAA8E,KAAA9E,GAAA,CACA,MAAA+E,EAAApH,SAAAqH,cAAA,KAIA,OAHAD,EAAAE,KAAAjF,EACA+E,EAAAE,KAAAF,EAAAE,KACAF,EAAAxE,SAAAwE,EAAAxE,SAAA2E,QAAA,aACAH,EAAAE,IACA,CACA,OAAAjF,CAEA,CAEA,SAAAmF,EAAAnF,EAAAoF,EAAA,QAAAtH,EAAAY,oBACA,WAAA8F,EAAAxE,EACA,CAEA,SAAAoF,EAAAC,GACA,MAAAC,EAAA3H,SAAA4H,KAAAC,cAAA,2BAAyEH,OACzE,GAAAC,EACA,OAAAA,EAAAG,aAAA,UAEA,CC3fAC,OAAOC,MAAQC,EACGjL,MAAd+K,OAAOG,MACTH,OAAOG,IAAM,CAAC,GAEhBA,IAAIC,MAAQX","sources":["./node_modules/@rails/actioncable/app/assets/javascripts/actioncable.esm.js","./app/assets/javascript/rails.js"],"sourcesContent":["var adapters = {\n  logger: typeof console !== \"undefined\" ? console : undefined,\n  WebSocket: typeof WebSocket !== \"undefined\" ? WebSocket : undefined\n};\n\nvar logger = {\n  log(...messages) {\n    if (this.enabled) {\n      messages.push(Date.now());\n      adapters.logger.log(\"[ActionCable]\", ...messages);\n    }\n  }\n};\n\nconst now = () => (new Date).getTime();\n\nconst secondsSince = time => (now() - time) / 1e3;\n\nclass ConnectionMonitor {\n  constructor(connection) {\n    this.visibilityDidChange = this.visibilityDidChange.bind(this);\n    this.connection = connection;\n    this.reconnectAttempts = 0;\n  }\n  start() {\n    if (!this.isRunning()) {\n      this.startedAt = now();\n      delete this.stoppedAt;\n      this.startPolling();\n      addEventListener(\"visibilitychange\", this.visibilityDidChange);\n      logger.log(`ConnectionMonitor started. stale threshold = ${this.constructor.staleThreshold} s`);\n    }\n  }\n  stop() {\n    if (this.isRunning()) {\n      this.stoppedAt = now();\n      this.stopPolling();\n      removeEventListener(\"visibilitychange\", this.visibilityDidChange);\n      logger.log(\"ConnectionMonitor stopped\");\n    }\n  }\n  isRunning() {\n    return this.startedAt && !this.stoppedAt;\n  }\n  recordMessage() {\n    this.pingedAt = now();\n  }\n  recordConnect() {\n    this.reconnectAttempts = 0;\n    delete this.disconnectedAt;\n    logger.log(\"ConnectionMonitor recorded connect\");\n  }\n  recordDisconnect() {\n    this.disconnectedAt = now();\n    logger.log(\"ConnectionMonitor recorded disconnect\");\n  }\n  startPolling() {\n    this.stopPolling();\n    this.poll();\n  }\n  stopPolling() {\n    clearTimeout(this.pollTimeout);\n  }\n  poll() {\n    this.pollTimeout = setTimeout((() => {\n      this.reconnectIfStale();\n      this.poll();\n    }), this.getPollInterval());\n  }\n  getPollInterval() {\n    const {staleThreshold: staleThreshold, reconnectionBackoffRate: reconnectionBackoffRate} = this.constructor;\n    const backoff = Math.pow(1 + reconnectionBackoffRate, Math.min(this.reconnectAttempts, 10));\n    const jitterMax = this.reconnectAttempts === 0 ? 1 : reconnectionBackoffRate;\n    const jitter = jitterMax * Math.random();\n    return staleThreshold * 1e3 * backoff * (1 + jitter);\n  }\n  reconnectIfStale() {\n    if (this.connectionIsStale()) {\n      logger.log(`ConnectionMonitor detected stale connection. reconnectAttempts = ${this.reconnectAttempts}, time stale = ${secondsSince(this.refreshedAt)} s, stale threshold = ${this.constructor.staleThreshold} s`);\n      this.reconnectAttempts++;\n      if (this.disconnectedRecently()) {\n        logger.log(`ConnectionMonitor skipping reopening recent disconnect. time disconnected = ${secondsSince(this.disconnectedAt)} s`);\n      } else {\n        logger.log(\"ConnectionMonitor reopening\");\n        this.connection.reopen();\n      }\n    }\n  }\n  get refreshedAt() {\n    return this.pingedAt ? this.pingedAt : this.startedAt;\n  }\n  connectionIsStale() {\n    return secondsSince(this.refreshedAt) > this.constructor.staleThreshold;\n  }\n  disconnectedRecently() {\n    return this.disconnectedAt && secondsSince(this.disconnectedAt) < this.constructor.staleThreshold;\n  }\n  visibilityDidChange() {\n    if (document.visibilityState === \"visible\") {\n      setTimeout((() => {\n        if (this.connectionIsStale() || !this.connection.isOpen()) {\n          logger.log(`ConnectionMonitor reopening stale connection on visibilitychange. visibilityState = ${document.visibilityState}`);\n          this.connection.reopen();\n        }\n      }), 200);\n    }\n  }\n}\n\nConnectionMonitor.staleThreshold = 6;\n\nConnectionMonitor.reconnectionBackoffRate = .15;\n\nvar INTERNAL = {\n  message_types: {\n    welcome: \"welcome\",\n    disconnect: \"disconnect\",\n    ping: \"ping\",\n    confirmation: \"confirm_subscription\",\n    rejection: \"reject_subscription\"\n  },\n  disconnect_reasons: {\n    unauthorized: \"unauthorized\",\n    invalid_request: \"invalid_request\",\n    server_restart: \"server_restart\",\n    remote: \"remote\"\n  },\n  default_mount_path: \"/cable\",\n  protocols: [ \"actioncable-v1-json\", \"actioncable-unsupported\" ]\n};\n\nconst {message_types: message_types, protocols: protocols} = INTERNAL;\n\nconst supportedProtocols = protocols.slice(0, protocols.length - 1);\n\nconst indexOf = [].indexOf;\n\nclass Connection {\n  constructor(consumer) {\n    this.open = this.open.bind(this);\n    this.consumer = consumer;\n    this.subscriptions = this.consumer.subscriptions;\n    this.monitor = new ConnectionMonitor(this);\n    this.disconnected = true;\n  }\n  send(data) {\n    if (this.isOpen()) {\n      this.webSocket.send(JSON.stringify(data));\n      return true;\n    } else {\n      return false;\n    }\n  }\n  open() {\n    if (this.isActive()) {\n      logger.log(`Attempted to open WebSocket, but existing socket is ${this.getState()}`);\n      return false;\n    } else {\n      const socketProtocols = [ ...protocols, ...this.consumer.subprotocols || [] ];\n      logger.log(`Opening WebSocket, current state is ${this.getState()}, subprotocols: ${socketProtocols}`);\n      if (this.webSocket) {\n        this.uninstallEventHandlers();\n      }\n      this.webSocket = new adapters.WebSocket(this.consumer.url, socketProtocols);\n      this.installEventHandlers();\n      this.monitor.start();\n      return true;\n    }\n  }\n  close({allowReconnect: allowReconnect} = {\n    allowReconnect: true\n  }) {\n    if (!allowReconnect) {\n      this.monitor.stop();\n    }\n    if (this.isOpen()) {\n      return this.webSocket.close();\n    }\n  }\n  reopen() {\n    logger.log(`Reopening WebSocket, current state is ${this.getState()}`);\n    if (this.isActive()) {\n      try {\n        return this.close();\n      } catch (error) {\n        logger.log(\"Failed to reopen WebSocket\", error);\n      } finally {\n        logger.log(`Reopening WebSocket in ${this.constructor.reopenDelay}ms`);\n        setTimeout(this.open, this.constructor.reopenDelay);\n      }\n    } else {\n      return this.open();\n    }\n  }\n  getProtocol() {\n    if (this.webSocket) {\n      return this.webSocket.protocol;\n    }\n  }\n  isOpen() {\n    return this.isState(\"open\");\n  }\n  isActive() {\n    return this.isState(\"open\", \"connecting\");\n  }\n  triedToReconnect() {\n    return this.monitor.reconnectAttempts > 0;\n  }\n  isProtocolSupported() {\n    return indexOf.call(supportedProtocols, this.getProtocol()) >= 0;\n  }\n  isState(...states) {\n    return indexOf.call(states, this.getState()) >= 0;\n  }\n  getState() {\n    if (this.webSocket) {\n      for (let state in adapters.WebSocket) {\n        if (adapters.WebSocket[state] === this.webSocket.readyState) {\n          return state.toLowerCase();\n        }\n      }\n    }\n    return null;\n  }\n  installEventHandlers() {\n    for (let eventName in this.events) {\n      const handler = this.events[eventName].bind(this);\n      this.webSocket[`on${eventName}`] = handler;\n    }\n  }\n  uninstallEventHandlers() {\n    for (let eventName in this.events) {\n      this.webSocket[`on${eventName}`] = function() {};\n    }\n  }\n}\n\nConnection.reopenDelay = 500;\n\nConnection.prototype.events = {\n  message(event) {\n    if (!this.isProtocolSupported()) {\n      return;\n    }\n    const {identifier: identifier, message: message, reason: reason, reconnect: reconnect, type: type} = JSON.parse(event.data);\n    this.monitor.recordMessage();\n    switch (type) {\n     case message_types.welcome:\n      if (this.triedToReconnect()) {\n        this.reconnectAttempted = true;\n      }\n      this.monitor.recordConnect();\n      return this.subscriptions.reload();\n\n     case message_types.disconnect:\n      logger.log(`Disconnecting. Reason: ${reason}`);\n      return this.close({\n        allowReconnect: reconnect\n      });\n\n     case message_types.ping:\n      return null;\n\n     case message_types.confirmation:\n      this.subscriptions.confirmSubscription(identifier);\n      if (this.reconnectAttempted) {\n        this.reconnectAttempted = false;\n        return this.subscriptions.notify(identifier, \"connected\", {\n          reconnected: true\n        });\n      } else {\n        return this.subscriptions.notify(identifier, \"connected\", {\n          reconnected: false\n        });\n      }\n\n     case message_types.rejection:\n      return this.subscriptions.reject(identifier);\n\n     default:\n      return this.subscriptions.notify(identifier, \"received\", message);\n    }\n  },\n  open() {\n    logger.log(`WebSocket onopen event, using '${this.getProtocol()}' subprotocol`);\n    this.disconnected = false;\n    if (!this.isProtocolSupported()) {\n      logger.log(\"Protocol is unsupported. Stopping monitor and disconnecting.\");\n      return this.close({\n        allowReconnect: false\n      });\n    }\n  },\n  close(event) {\n    logger.log(\"WebSocket onclose event\");\n    if (this.disconnected) {\n      return;\n    }\n    this.disconnected = true;\n    this.monitor.recordDisconnect();\n    return this.subscriptions.notifyAll(\"disconnected\", {\n      willAttemptReconnect: this.monitor.isRunning()\n    });\n  },\n  error() {\n    logger.log(\"WebSocket onerror event\");\n  }\n};\n\nconst extend = function(object, properties) {\n  if (properties != null) {\n    for (let key in properties) {\n      const value = properties[key];\n      object[key] = value;\n    }\n  }\n  return object;\n};\n\nclass Subscription {\n  constructor(consumer, params = {}, mixin) {\n    this.consumer = consumer;\n    this.identifier = JSON.stringify(params);\n    extend(this, mixin);\n  }\n  perform(action, data = {}) {\n    data.action = action;\n    return this.send(data);\n  }\n  send(data) {\n    return this.consumer.send({\n      command: \"message\",\n      identifier: this.identifier,\n      data: JSON.stringify(data)\n    });\n  }\n  unsubscribe() {\n    return this.consumer.subscriptions.remove(this);\n  }\n}\n\nclass SubscriptionGuarantor {\n  constructor(subscriptions) {\n    this.subscriptions = subscriptions;\n    this.pendingSubscriptions = [];\n  }\n  guarantee(subscription) {\n    if (this.pendingSubscriptions.indexOf(subscription) == -1) {\n      logger.log(`SubscriptionGuarantor guaranteeing ${subscription.identifier}`);\n      this.pendingSubscriptions.push(subscription);\n    } else {\n      logger.log(`SubscriptionGuarantor already guaranteeing ${subscription.identifier}`);\n    }\n    this.startGuaranteeing();\n  }\n  forget(subscription) {\n    logger.log(`SubscriptionGuarantor forgetting ${subscription.identifier}`);\n    this.pendingSubscriptions = this.pendingSubscriptions.filter((s => s !== subscription));\n  }\n  startGuaranteeing() {\n    this.stopGuaranteeing();\n    this.retrySubscribing();\n  }\n  stopGuaranteeing() {\n    clearTimeout(this.retryTimeout);\n  }\n  retrySubscribing() {\n    this.retryTimeout = setTimeout((() => {\n      if (this.subscriptions && typeof this.subscriptions.subscribe === \"function\") {\n        this.pendingSubscriptions.map((subscription => {\n          logger.log(`SubscriptionGuarantor resubscribing ${subscription.identifier}`);\n          this.subscriptions.subscribe(subscription);\n        }));\n      }\n    }), 500);\n  }\n}\n\nclass Subscriptions {\n  constructor(consumer) {\n    this.consumer = consumer;\n    this.guarantor = new SubscriptionGuarantor(this);\n    this.subscriptions = [];\n  }\n  create(channelName, mixin) {\n    const channel = channelName;\n    const params = typeof channel === \"object\" ? channel : {\n      channel: channel\n    };\n    const subscription = new Subscription(this.consumer, params, mixin);\n    return this.add(subscription);\n  }\n  add(subscription) {\n    this.subscriptions.push(subscription);\n    this.consumer.ensureActiveConnection();\n    this.notify(subscription, \"initialized\");\n    this.subscribe(subscription);\n    return subscription;\n  }\n  remove(subscription) {\n    this.forget(subscription);\n    if (!this.findAll(subscription.identifier).length) {\n      this.sendCommand(subscription, \"unsubscribe\");\n    }\n    return subscription;\n  }\n  reject(identifier) {\n    return this.findAll(identifier).map((subscription => {\n      this.forget(subscription);\n      this.notify(subscription, \"rejected\");\n      return subscription;\n    }));\n  }\n  forget(subscription) {\n    this.guarantor.forget(subscription);\n    this.subscriptions = this.subscriptions.filter((s => s !== subscription));\n    return subscription;\n  }\n  findAll(identifier) {\n    return this.subscriptions.filter((s => s.identifier === identifier));\n  }\n  reload() {\n    return this.subscriptions.map((subscription => this.subscribe(subscription)));\n  }\n  notifyAll(callbackName, ...args) {\n    return this.subscriptions.map((subscription => this.notify(subscription, callbackName, ...args)));\n  }\n  notify(subscription, callbackName, ...args) {\n    let subscriptions;\n    if (typeof subscription === \"string\") {\n      subscriptions = this.findAll(subscription);\n    } else {\n      subscriptions = [ subscription ];\n    }\n    return subscriptions.map((subscription => typeof subscription[callbackName] === \"function\" ? subscription[callbackName](...args) : undefined));\n  }\n  subscribe(subscription) {\n    if (this.sendCommand(subscription, \"subscribe\")) {\n      this.guarantor.guarantee(subscription);\n    }\n  }\n  confirmSubscription(identifier) {\n    logger.log(`Subscription confirmed ${identifier}`);\n    this.findAll(identifier).map((subscription => this.guarantor.forget(subscription)));\n  }\n  sendCommand(subscription, command) {\n    const {identifier: identifier} = subscription;\n    return this.consumer.send({\n      command: command,\n      identifier: identifier\n    });\n  }\n}\n\nclass Consumer {\n  constructor(url) {\n    this._url = url;\n    this.subscriptions = new Subscriptions(this);\n    this.connection = new Connection(this);\n    this.subprotocols = [];\n  }\n  get url() {\n    return createWebSocketURL(this._url);\n  }\n  send(data) {\n    return this.connection.send(data);\n  }\n  connect() {\n    return this.connection.open();\n  }\n  disconnect() {\n    return this.connection.close({\n      allowReconnect: false\n    });\n  }\n  ensureActiveConnection() {\n    if (!this.connection.isActive()) {\n      return this.connection.open();\n    }\n  }\n  addSubProtocol(subprotocol) {\n    this.subprotocols = [ ...this.subprotocols, subprotocol ];\n  }\n}\n\nfunction createWebSocketURL(url) {\n  if (typeof url === \"function\") {\n    url = url();\n  }\n  if (url && !/^wss?:/i.test(url)) {\n    const a = document.createElement(\"a\");\n    a.href = url;\n    a.href = a.href;\n    a.protocol = a.protocol.replace(\"http\", \"ws\");\n    return a.href;\n  } else {\n    return url;\n  }\n}\n\nfunction createConsumer(url = getConfig(\"url\") || INTERNAL.default_mount_path) {\n  return new Consumer(url);\n}\n\nfunction getConfig(name) {\n  const element = document.head.querySelector(`meta[name='action-cable-${name}']`);\n  if (element) {\n    return element.getAttribute(\"content\");\n  }\n}\n\nexport { Connection, ConnectionMonitor, Consumer, INTERNAL, Subscription, SubscriptionGuarantor, Subscriptions, adapters, createConsumer, createWebSocketURL, getConfig, logger };\n","import * as ActionCable from '@rails/actioncable';\n\nwindow.Cable = ActionCable;\nif (window.App == undefined) {\n  window.App = {};\n}\nApp.cable = ActionCable.createConsumer();\n"],"names":["adapters","logger","console","undefined","WebSocket","log","messages","this","enabled","push","Date","now","getTime","secondsSince","time","ConnectionMonitor","constructor","connection","visibilityDidChange","bind","reconnectAttempts","start","isRunning","startedAt","stoppedAt","startPolling","addEventListener","staleThreshold","stop","stopPolling","removeEventListener","recordMessage","pingedAt","recordConnect","disconnectedAt","recordDisconnect","poll","clearTimeout","pollTimeout","setTimeout","reconnectIfStale","getPollInterval","reconnectionBackoffRate","Math","pow","min","random","connectionIsStale","refreshedAt","disconnectedRecently","reopen","document","visibilityState","isOpen","INTERNAL","message_types","welcome","disconnect","ping","confirmation","rejection","disconnect_reasons","unauthorized","invalid_request","server_restart","remote","default_mount_path","protocols","supportedProtocols","slice","length","indexOf","Connection","consumer","open","subscriptions","monitor","disconnected","send","data","webSocket","JSON","stringify","isActive","getState","socketProtocols","subprotocols","uninstallEventHandlers","url","installEventHandlers","close","allowReconnect","error","reopenDelay","getProtocol","protocol","isState","triedToReconnect","isProtocolSupported","call","states","state","readyState","toLowerCase","eventName","events","handler","prototype","message","event","identifier","reason","reconnect","type","parse","reconnectAttempted","reload","confirmSubscription","notify","reconnected","reject","notifyAll","willAttemptReconnect","Subscription","params","mixin","object","properties","key","value","extend","perform","action","command","unsubscribe","remove","SubscriptionGuarantor","pendingSubscriptions","guarantee","subscription","startGuaranteeing","forget","filter","s","stopGuaranteeing","retrySubscribing","retryTimeout","subscribe","map","Subscriptions","guarantor","create","channelName","channel","add","ensureActiveConnection","findAll","sendCommand","callbackName","args","Consumer","_url","createWebSocketURL","connect","addSubProtocol","subprotocol","test","a","createElement","href","replace","createConsumer","getConfig","name","element","head","querySelector","getAttribute","window","Cable","actioncable_esm_namespaceObject","App","cable"],"sourceRoot":""}