Ark/deluge-streaming
1
0
Fork 0
mirror of https://github.com/JohnDoee/deluge-streaming/ synced 2026-07-01 07:31:17 -07:00
Code Issues Packages Projects Releases Wiki Activity

added reverse proxy mode

Browse Source
This commit is contained in:
Anders Jensen
2018-08-24 21:20:53 +02:00
parent 37753a23e4
commit 7aed811b78
5 changed files with 117 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
README.md
View File

@@ -47,7 +47,7 @@ The _allow remote_ option is to allow remote add and stream of torrents.
* [x] Add RAR streaming support * [x] Add RAR streaming support
* [ ] Better feedback in interface about streams * [ ] Better feedback in interface about streams
* [ ] Better feedback when using API * [ ] Better feedback when using API
* [ ] Reverse proxy improvement (e.g. port different than bind port) * [x] Reverse proxy improvement (e.g. port different than bind port)
# Version Info # Version Info
@@ -55,6 +55,7 @@ The _allow remote_ option is to allow remote add and stream of torrents.
* Rewrote large parts of the code * Rewrote large parts of the code
* Now using [thomas](https://github.com/JohnDoee/thomas) as file-reading core - this adds support for multi-rar streaming. * Now using [thomas](https://github.com/JohnDoee/thomas) as file-reading core - this adds support for multi-rar streaming.
* Faster streaming by reading directly from disk * Faster streaming by reading directly from disk
* Reverse proxy mode
## Version 0.9.0 ## Version 0.9.0
* Few bugfixes * Few bugfixes

7
streaming/core.py
View File

@@ -81,6 +81,8 @@ DEFAULT_PREFS = {
'use_ssl': False, 'use_ssl': False,
'remote_username': 'stream', 'remote_username': 'stream',
'remote_password': ''.join(random.choice(string.ascii_letters + string.digits) for _ in range(16)), 'remote_password': ''.join(random.choice(string.ascii_letters + string.digits) for _ in range(16)),
'reverse_proxy_enabled': False,
'reverse_proxy_base_url': '',
'serve_method': 'standalone', 'serve_method': 'standalone',
'ssl_source': 'daemon', 'ssl_source': 'daemon',
'ssl_priv_key_path': '', 'ssl_priv_key_path': '',
@@ -675,12 +677,17 @@ class Core(CorePluginBase):
else: else:
raise NotImplementedError() raise NotImplementedError()
if self.config['reverse_proxy_enabled'] and self.config['reverse_proxy_base_url']:
self.base_url = self.config['reverse_proxy_base_url']
else:
self.base_url += '://' self.base_url += '://'
if ':' in ip: if ':' in ip:
self.base_url += ip self.base_url += ip
else: else:
self.base_url += '%s:%s' % (ip, port) self.base_url += '%s:%s' % (ip, port)
self.base_url = self.base_url.rstrip('/')
@defer.inlineCallbacks @defer.inlineCallbacks
def disable(self): def disable(self):
self.site.stopFactory() self.site.stopFactory()

66
streaming/data/config.glade
View File

@@ -166,6 +166,70 @@
<property name="position">1</property> <property name="position">1</property>
</packing> </packing>
</child> </child>
<child>
<widget class="GtkHBox" id="hbox54">
<property name="visible">True</property>
<property name="can_focus">False</property>
<child>
<widget class="GtkCheckButton" id="input_reverse_proxy_enabled">
<property name="label" translatable="yes">Enable Reverse Proxy</property>
<property name="visible">True</property>
<property name="can_focus">True</property>
<property name="receives_default">False</property>
<property name="use_action_appearance">False</property>
<property name="draw_indicator">True</property>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
<property name="position">0</property>
</packing>
</child>
</widget>
<packing>
<property name="expand">True</property>
<property name="fill">True</property>
<property name="position">2</property>
</packing>
</child>
<child>
<widget class="GtkHBox" id="hbox55">
<property name="visible">True</property>
<property name="can_focus">False</property>
<child>
<widget class="GtkLabel" id="reverse_proxy_base_url_label">
<property name="visible">True</property>
<property name="can_focus">False</property>
<property name="label" translatable="yes">Reverse Proxy Base Url: </property>
</widget>
<packing>
<property name="expand">False</property>
<property name="fill">False</property>
<property name="position">0</property>
</packing>
</child>
<child>
<widget class="GtkEntry" id="input_reverse_proxy_base_url">
<property name="visible">True</property>
<property name="can_focus">True</property>
<property name="primary_icon_activatable">False</property>
<property name="secondary_icon_activatable">False</property>
<property name="primary_icon_sensitive">True</property>
<property name="secondary_icon_sensitive">True</property>
</widget>
<packing>
<property name="expand">True</property>
<property name="fill">True</property>
<property name="position">1</property>
</packing>
</child>
</widget>
<packing>
<property name="expand">True</property>
<property name="fill">True</property>
<property name="position">3</property>
</packing>
</child>
<!-- <child> <!-- <child>
<widget class="GtkRadioButton" id="input_serve_webui"> <widget class="GtkRadioButton" id="input_serve_webui">
<property name="label" translatable="yes">Serve files via WebUI</property> <property name="label" translatable="yes">Serve files via WebUI</property>
@@ -371,7 +435,7 @@
<packing> <packing>
<property name="expand">False</property> <property name="expand">False</property>
<property name="fill">False</property> <property name="fill">False</property>
<property name="position">3</property> <property name="position">5</property>
</packing> </packing>
</child> </child>
</widget> </widget>

49
streaming/data/streaming.js
View File

@@ -35,7 +35,10 @@ PreferencePage = Ext.extend(Ext.Panel, {
title: 'Streaming', title: 'Streaming',
border: false, border: false,
layout: 'form', layout: 'form',
header: false,
autoScroll: true, autoScroll: true,
autoHeight: true,
width: 320,
_fields: {}, _fields: {},
initComponent: function() { initComponent: function() {
@@ -50,10 +53,12 @@ PreferencePage = Ext.extend(Ext.Panel, {
title: 'Settings', title: 'Settings',
style: 'margin-bottom: 0px; padding-bottom: 0px; padding-top: 5px', style: 'margin-bottom: 0px; padding-bottom: 0px; padding-top: 5px',
autoHeight: true, autoHeight: true,
labelWidth: 1, labelAlign: 'top',
labelWidth: 150,
width: 300,
defaultType: 'textfield', defaultType: 'textfield',
defaults: { defaults: {
width: 180, width: 280,
} }
}); });
@@ -69,10 +74,12 @@ PreferencePage = Ext.extend(Ext.Panel, {
title: 'File Serving Settings', title: 'File Serving Settings',
style: 'margin-bottom: 0px; padding-bottom: 0px; padding-top: 5px', style: 'margin-bottom: 0px; padding-bottom: 0px; padding-top: 5px',
autoHeight: true, autoHeight: true,
labelWidth: 110, labelAlign: 'top',
labelWidth: 150,
width: 280,
defaultType: 'textfield', defaultType: 'textfield',
defaults: { defaults: {
width: 180, width: 260,
} }
}); });
@@ -89,13 +96,22 @@ PreferencePage = Ext.extend(Ext.Panel, {
maxValue: 99999, maxValue: 99999,
})); }));
var field = fieldset.add({
xtype: 'togglefield',
name: 'reverse_proxy_base_url',
fieldLabel: 'Reverse Proxy Config',
});
om.bind('reverse_proxy_enabled', field.toggle);
om.bind('reverse_proxy_base_url', field.input);
fieldset = this.add({ fieldset = this.add({
xtype: 'fieldset', xtype: 'fieldset',
border: false, border: false,
autoHeight: true, autoHeight: true,
defaultType: 'radio', defaultType: 'radio',
style: 'margin-bottom: 5px; margin-top: 0; padding-bottom: 5px; padding-top: 0;', style: 'margin-bottom: 5px; margin-top: 0; padding-bottom: 5px; padding-top: 0;',
width: 240, width: 280,
labelWidth: 1 labelWidth: 1
}); });
@@ -130,7 +146,7 @@ PreferencePage = Ext.extend(Ext.Panel, {
autoHeight: true, autoHeight: true,
defaultType: 'radio', defaultType: 'radio',
style: 'margin-left: 24px; margin-bottom: 5px; margin-top: 0; padding-bottom: 5px; padding-top: 0;', style: 'margin-left: 24px; margin-bottom: 5px; margin-top: 0; padding-bottom: 5px; padding-top: 0;',
width: 240, width: 280,
labelWidth: 1 labelWidth: 1
}); });
@@ -164,12 +180,12 @@ PreferencePage = Ext.extend(Ext.Panel, {
om.bind('ssl_priv_key_path', fieldset.add({ om.bind('ssl_priv_key_path', fieldset.add({
name: 'ssl_priv_key_path', name: 'ssl_priv_key_path',
fieldLabel: 'Private key file path' fieldLabel: 'Private key file path',
})); }));
om.bind('ssl_cert_path', fieldset.add({ om.bind('ssl_cert_path', fieldset.add({
name: 'ssl_cert_path', name: 'ssl_cert_path',
fieldLabel: 'Certificate and chains file path' fieldLabel: 'Certificate and chains file path',
})); }));
fieldset = this.add({ fieldset = this.add({
@@ -178,10 +194,12 @@ PreferencePage = Ext.extend(Ext.Panel, {
title: 'Advanced settings', title: 'Advanced settings',
style: 'margin-bottom: 0px; padding-bottom: 0px; padding-top: 5px', style: 'margin-bottom: 0px; padding-bottom: 0px; padding-top: 5px',
autoHeight: true, autoHeight: true,
labelWidth: 1, labelAlign: 'top',
labelWidth: 150,
width: 280,
defaultType: 'textfield', defaultType: 'textfield',
defaults: { defaults: {
width: 180, width: 260,
} }
}); });
@@ -189,7 +207,8 @@ PreferencePage = Ext.extend(Ext.Panel, {
xtype: 'checkbox', xtype: 'checkbox',
name: 'allow_remote', name: 'allow_remote',
boxLabel: 'Allow remote control', boxLabel: 'Allow remote control',
style: 'margin-left: 12px;' style: 'margin-left: 12px;',
width: 150
})); }));
fieldset = this.add({ fieldset = this.add({
@@ -197,10 +216,12 @@ PreferencePage = Ext.extend(Ext.Panel, {
border: false, border: false,
style: 'margin-bottom: 0px; padding-bottom: 0px; padding-top: 5px', style: 'margin-bottom: 0px; padding-bottom: 0px; padding-top: 5px',
autoHeight: true, autoHeight: true,
labelWidth: 110, labelAlign: 'top',
labelWidth: 150,
width: 260,
defaultType: 'textfield', defaultType: 'textfield',
defaults: { defaults: {
width: 180, width: 240,
} }
}); });
@@ -232,7 +253,7 @@ PreferencePage = Ext.extend(Ext.Panel, {
labelWidth: 1, labelWidth: 1,
defaultType: 'textfield', defaultType: 'textfield',
defaults: { defaults: {
width: 180, width: 200,
} }
}); });

4
streaming/gtkui.py
View File

@@ -142,9 +142,11 @@ class GtkUI(GtkPluginBase):
"auto_open_stream_urls": self.glade.get_widget("input_auto_open_stream_urls").get_active(), "auto_open_stream_urls": self.glade.get_widget("input_auto_open_stream_urls").get_active(),
"allow_remote": self.glade.get_widget("input_allow_remote").get_active(), "allow_remote": self.glade.get_widget("input_allow_remote").get_active(),
"download_only_streamed": self.glade.get_widget("input_download_only_streamed").get_active(), "download_only_streamed": self.glade.get_widget("input_download_only_streamed").get_active(),
"reverse_proxy_enabled": self.glade.get_widget("input_reverse_proxy_enabled").get_active(),
# "download_in_order": self.glade.get_widget("input_download_in_order").get_active(), # "download_in_order": self.glade.get_widget("input_download_in_order").get_active(),
"use_ssl": self.glade.get_widget("input_use_ssl").get_active(), "use_ssl": self.glade.get_widget("input_use_ssl").get_active(),
# "remote_username": self.glade.get_widget("input_remote_username").get_text(), # "remote_username": self.glade.get_widget("input_remote_username").get_text(),
"reverse_proxy_base_url": self.glade.get_widget("input_reverse_proxy_base_url").get_text(),
"remote_password": self.glade.get_widget("input_remote_password").get_text(), "remote_password": self.glade.get_widget("input_remote_password").get_text(),
"ssl_priv_key_path": self.glade.get_widget("input_ssl_priv_key_path").get_text(), "ssl_priv_key_path": self.glade.get_widget("input_ssl_priv_key_path").get_text(),
"ssl_cert_path": self.glade.get_widget("input_ssl_cert_path").get_text(), "ssl_cert_path": self.glade.get_widget("input_ssl_cert_path").get_text(),
@@ -175,9 +177,11 @@ class GtkUI(GtkPluginBase):
self.glade.get_widget("input_allow_remote").set_active(config["allow_remote"]) self.glade.get_widget("input_allow_remote").set_active(config["allow_remote"])
self.glade.get_widget("input_use_ssl").set_active(config["use_ssl"]) self.glade.get_widget("input_use_ssl").set_active(config["use_ssl"])
self.glade.get_widget("input_download_only_streamed").set_active(config["download_only_streamed"]) self.glade.get_widget("input_download_only_streamed").set_active(config["download_only_streamed"])
self.glade.get_widget("input_reverse_proxy_enabled").set_active(config["reverse_proxy_enabled"])
# self.glade.get_widget("input_download_in_order").set_active(config["download_in_order"]) # self.glade.get_widget("input_download_in_order").set_active(config["download_in_order"])
# self.glade.get_widget("input_download_everything").set_active(not config["download_in_order"] and not config["download_only_streamed"]) # self.glade.get_widget("input_download_everything").set_active(not config["download_in_order"] and not config["download_only_streamed"])
# self.glade.get_widget("input_remote_username").set_text(config["remote_username"]) # self.glade.get_widget("input_remote_username").set_text(config["remote_username"])
self.glade.get_widget("input_reverse_proxy_base_url").set_text(config["reverse_proxy_base_url"])
self.glade.get_widget("input_remote_password").set_text(config["remote_password"]) self.glade.get_widget("input_remote_password").set_text(config["remote_password"])
self.glade.get_widget("input_ssl_priv_key_path").set_text(config["ssl_priv_key_path"]) self.glade.get_widget("input_ssl_priv_key_path").set_text(config["ssl_priv_key_path"])
self.glade.get_widget("input_ssl_cert_path").set_text(config["ssl_cert_path"]) self.glade.get_widget("input_ssl_cert_path").set_text(config["ssl_cert_path"])