secubox-openwrt/luci-app-media-flow/htdocs/luci-static/resources/view/media-flow/history.js
CyberMind-FR 6200167434 feat: implement Media Flow streaming detection and monitoring module
Complete implementation of Media Flow module for real-time detection and
monitoring of streaming services with quality estimation and alerts.

Features:
---------

1. Streaming Service Detection
   - Video: Netflix, YouTube, Disney+, Prime Video, Twitch, HBO, Hulu, Vimeo
   - Audio: Spotify, Apple Music, Deezer, SoundCloud, Tidal, Pandora
   - Visio: Zoom, Teams, Google Meet, Discord, Skype, WebEx

2. Quality Estimation
   - SD (< 1 Mbps), HD (1-3 Mbps), FHD (3-8 Mbps), 4K (> 8 Mbps)
   - Based on real-time bandwidth analysis

3. Real-time Monitoring
   - Active streams dashboard with 5-second auto-refresh
   - Bandwidth consumption per stream
   - Client IP tracking
   - Service categorization (video/audio/visio)

4. Historical Data
   - Session history with timestamps
   - Usage statistics per service
   - Usage statistics per client
   - Configurable retention (last 1000 entries)

5. Configurable Alerts
   - Service-specific usage thresholds
   - Actions: notify, limit, block
   - UCI-based alert configuration

RPCD Backend:
-------------

Script: root/usr/libexec/rpcd/luci.media-flow

Methods implemented:
- status: Module status and netifyd integration check
- get_active_streams: Currently active streaming sessions
- get_stream_history: Historical sessions (configurable timeframe)
- get_stats_by_service: Aggregated stats per service
- get_stats_by_client: Aggregated stats per client IP
- get_service_details: Detailed info for specific service
- set_alert: Configure usage alerts
- list_alerts: List all configured alerts

Integration with netifyd DPI for application detection.

Views:
------

1. dashboard.js - Main overview with active streams and service stats
2. services.js - Detailed per-service statistics and details modal
3. clients.js - Per-client streaming activity
4. history.js - Chronological session list with filters
5. alerts.js - Alert configuration interface

All views follow naming conventions:
- Menu paths match view file locations (media-flow/*)
- RPC object: 'luci.media-flow' matches RPCD script name
- All views use 'use strict'
- All RPC methods exist in RPCD implementation

Files Structure:
----------------

✓ Makefile: Complete with all required fields
✓ RPCD: luci.media-flow (matches ubus object)
✓ ACL: All 8 RPCD methods covered (read/write separated)
✓ Menu: 5 views with correct paths
✓ Views: All menu paths have corresponding .js files
✓ UCI Config: media_flow with global settings and alerts
✓ README: Complete documentation with API reference

Validation:
-----------

✓ RPCD script name matches ubus object (luci.media-flow)
✓ Menu paths match view file locations
✓ ACL permissions cover all RPCD methods
✓ RPCD script is executable
✓ JSON files have valid syntax
✓ All views use strict mode
✓ RPC method calls match RPCD implementations

Dependencies:
-------------

- netifyd: Deep Packet Inspection for application detection
- luci-app-netifyd-dashboard: Integration with Netifyd dashboard
- jq: JSON processing for historical data aggregation

Usage:
------

# View status
ubus call luci.media-flow status

# Get active streaming sessions
ubus call luci.media-flow get_active_streams

# Get 24h history
ubus call luci.media-flow get_stream_history '{"hours": 24}'

# Set alert for Netflix
ubus call luci.media-flow set_alert '{"service": "Netflix", "threshold_hours": 4, "action": "notify"}'

Data Storage:
-------------

- History: /tmp/media-flow-history.json (last 1000 entries)
- Stats: /tmp/media-flow-stats/ (aggregated data)
- Alerts: /etc/config/media_flow (UCI persistence)

All data stored locally, no external telemetry.

🤖 Generated with [Claude Code](https://claude.com/claude-code)

Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
2025-12-24 10:20:28 +01:00

92 lines
2.5 KiB
JavaScript

'use strict';
'require view';
'require form';
'require media-flow/api as API';
return L.view.extend({
load: function() {
return Promise.all([
API.getStreamHistory(24)
]);
},
render: function(data) {
var history = data[0] || [];
var m = new form.Map('media_flow', _('Stream History'),
_('Historical record of detected streaming sessions'));
var s = m.section(form.NamedSection, '__history', 'history');
s.anonymous = true;
s.addremove = false;
// Filter options
var o = s.option(form.ListValue, 'timeframe', _('Time Period'));
o.value('1', _('Last 1 hour'));
o.value('6', _('Last 6 hours'));
o.value('24', _('Last 24 hours'));
o.value('168', _('Last 7 days'));
o.default = '24';
// Display history table
s.render = L.bind(function(view, section_id) {
return API.getStreamHistory(24).then(L.bind(function(history) {
var table = E('table', { 'class': 'table' }, [
E('tr', { 'class': 'tr table-titles' }, [
E('th', { 'class': 'th' }, _('Time')),
E('th', { 'class': 'th' }, _('Service')),
E('th', { 'class': 'th' }, _('Client')),
E('th', { 'class': 'th' }, _('Quality')),
E('th', { 'class': 'th' }, _('Duration'))
])
]);
if (history && history.length > 0) {
// Sort by timestamp descending
history.sort(function(a, b) {
return new Date(b.timestamp) - new Date(a.timestamp);
});
history.slice(0, 100).forEach(function(entry) {
var time = new Date(entry.timestamp).toLocaleString();
var duration = Math.floor(entry.duration_seconds / 60);
var qualityColor = {
'SD': '#999',
'HD': '#0088cc',
'FHD': '#00cc00',
'4K': '#cc0000'
}[entry.quality] || '#666';
table.appendChild(E('tr', { 'class': 'tr' }, [
E('td', { 'class': 'td' }, time),
E('td', { 'class': 'td' }, entry.application),
E('td', { 'class': 'td' }, entry.client),
E('td', { 'class': 'td' },
E('span', { 'style': 'color: ' + qualityColor }, entry.quality)
),
E('td', { 'class': 'td' }, duration + ' min')
]));
});
} else {
table.appendChild(E('tr', { 'class': 'tr' }, [
E('td', { 'class': 'td', 'colspan': '5', 'style': 'text-align: center; font-style: italic' },
_('No historical data available'))
]));
}
return E('div', { 'class': 'cbi-section' }, [
E('h3', {}, _('Recent Sessions')),
table
]);
}, this));
}, this, this);
return m.render();
},
handleSaveApply: null,
handleSave: null,
handleReset: null
});