Sha256: 094e000874893d83a0311baddaf26f1c034583b6faf136b4a589f9b7db804953
Contents?: true
Size: 1.85 KB
Versions: 18
Compression:
Stored size: 1.85 KB
Contents
/*
# Copyright 2022 Ball Aerospace & Technologies Corp.
# All Rights Reserved.
#
# This program is free software; you can modify and/or redistribute it
# under the terms of the GNU Affero General Public License
# as published by the Free Software Foundation; version 3 with
# attribution addendums as found in the LICENSE.txt
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details.
# Modified by OpenC3, Inc.
# All changes Copyright 2022, OpenC3, Inc.
# All Rights Reserved
#
# This file may also be used under the terms of a commercial license
# if purchased from OpenC3, Inc.
*/
import * as ActionCable from '@rails/actioncable'
//ActionCable.logger.enabled = true
ActionCable.ConnectionMonitor.staleThreshold = 10
export default class Cable {
constructor(url = '/openc3-api/cable') {
this._cable = null
this._url = url
}
disconnect() {
if (this._cable) {
this._cable.disconnect()
}
}
createSubscription(channel, scope, callbacks = {}, additionalOptions = {}) {
return OpenC3Auth.updateToken(OpenC3Auth.defaultMinValidity).then(
(refreshed) => {
if (refreshed) {
OpenC3Auth.setTokens()
}
if (this._cable == null) {
let final_url =
this._url +
'?scope=' +
window.openc3Scope +
'&authorization=' +
localStorage.openc3Token
this._cable = ActionCable.createConsumer(encodeURI(final_url))
}
return this._cable.subscriptions.create(
{
channel,
...additionalOptions,
},
callbacks
)
}
)
}
recordPing() {
this._cable.connection.monitor.recordPing()
}
}
Version data entries
18 entries across 18 versions & 1 rubygems