diff --git a/__install/migrations/004_add_analytics_system.sql b/__install/migrations/004_add_analytics_system.sql
new file mode 100644
index 0000000..eab275a
--- /dev/null
+++ b/__install/migrations/004_add_analytics_system.sql
@@ -0,0 +1,104 @@
+-- Migration: Add analytics and tracking system
+
+-- Video analytics (detailed metrics)
+CREATE TABLE IF NOT EXISTS db_video_analytics (
+ analytics_id BIGINT AUTO_INCREMENT PRIMARY KEY,
+ video_id INT NOT NULL,
+ usr_id INT,
+ event_type ENUM('view', 'like', 'comment', 'share', 'download', 'watch_time', 'completion') NOT NULL,
+ watch_duration INT DEFAULT 0,
+ completion_percentage DECIMAL(5,2) DEFAULT 0,
+ device_type ENUM('desktop', 'mobile', 'tablet', 'tv', 'other') DEFAULT 'desktop',
+ browser VARCHAR(50),
+ os VARCHAR(50),
+ country_code VARCHAR(2),
+ referrer VARCHAR(512),
+ ip_hash VARCHAR(64),
+ session_id VARCHAR(64),
+ created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+ INDEX idx_video_date (video_id, created_at),
+ INDEX idx_user (usr_id),
+ INDEX idx_event_type (event_type),
+ INDEX idx_session (session_id),
+ FOREIGN KEY (video_id) REFERENCES db_videofiles(video_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+-- Channel analytics summary (daily aggregates)
+CREATE TABLE IF NOT EXISTS db_channel_analytics_daily (
+ summary_id INT AUTO_INCREMENT PRIMARY KEY,
+ usr_id INT NOT NULL,
+ date DATE NOT NULL,
+ views INT DEFAULT 0,
+ watch_time_minutes INT DEFAULT 0,
+ likes INT DEFAULT 0,
+ comments INT DEFAULT 0,
+ shares INT DEFAULT 0,
+ subscribers_gained INT DEFAULT 0,
+ subscribers_lost INT DEFAULT 0,
+ unique_viewers INT DEFAULT 0,
+ avg_view_duration INT DEFAULT 0,
+ avg_completion_rate DECIMAL(5,2) DEFAULT 0,
+ created_at DATETIME DEFAULT CURRENT_TIMESTAMP,
+ updated_at DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+ UNIQUE KEY unique_user_date (usr_id, date),
+ INDEX idx_user_date (usr_id, date),
+ FOREIGN KEY (usr_id) REFERENCES db_accountuser(usr_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+-- Traffic sources tracking
+CREATE TABLE IF NOT EXISTS db_traffic_sources (
+ source_id INT AUTO_INCREMENT PRIMARY KEY,
+ video_id INT NOT NULL,
+ usr_id INT NOT NULL,
+ source_type ENUM('direct', 'search', 'external', 'suggested', 'playlist', 'notification', 'social', 'other') NOT NULL,
+ source_detail VARCHAR(255),
+ view_count INT DEFAULT 1,
+ date DATE NOT NULL,
+ UNIQUE KEY unique_video_source_date (video_id, source_type, source_detail, date),
+ INDEX idx_video_date (video_id, date),
+ INDEX idx_user_date (usr_id, date),
+ FOREIGN KEY (video_id) REFERENCES db_videofiles(video_id) ON DELETE CASCADE,
+ FOREIGN KEY (usr_id) REFERENCES db_accountuser(usr_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+-- Audience retention (minute-by-minute)
+CREATE TABLE IF NOT EXISTS db_audience_retention (
+ retention_id BIGINT AUTO_INCREMENT PRIMARY KEY,
+ video_id INT NOT NULL,
+ minute INT NOT NULL,
+ viewer_count INT DEFAULT 1,
+ date DATE NOT NULL,
+ INDEX idx_video_date (video_id, date),
+ INDEX idx_video_minute (video_id, minute),
+ FOREIGN KEY (video_id) REFERENCES db_videofiles(video_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+-- Demographics tracking
+CREATE TABLE IF NOT EXISTS db_audience_demographics (
+ demo_id INT AUTO_INCREMENT PRIMARY KEY,
+ usr_id INT NOT NULL,
+ date DATE NOT NULL,
+ country_code VARCHAR(2),
+ age_range ENUM('13-17', '18-24', '25-34', '35-44', '45-54', '55-64', '65+', 'unknown') DEFAULT 'unknown',
+ gender ENUM('male', 'female', 'other', 'unknown') DEFAULT 'unknown',
+ device_type ENUM('desktop', 'mobile', 'tablet', 'tv', 'other') DEFAULT 'desktop',
+ view_count INT DEFAULT 1,
+ watch_time_minutes INT DEFAULT 0,
+ UNIQUE KEY unique_user_date_demo (usr_id, date, country_code, age_range, gender, device_type),
+ INDEX idx_user_date (usr_id, date),
+ FOREIGN KEY (usr_id) REFERENCES db_accountuser(usr_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
+
+-- Real-time stats cache (for dashboard)
+CREATE TABLE IF NOT EXISTS db_realtime_stats (
+ stat_id INT AUTO_INCREMENT PRIMARY KEY,
+ usr_id INT NOT NULL UNIQUE,
+ live_viewers INT DEFAULT 0,
+ views_last_hour INT DEFAULT 0,
+ views_last_24h INT DEFAULT 0,
+ subscribers_last_24h INT DEFAULT 0,
+ revenue_last_24h DECIMAL(10,2) DEFAULT 0,
+ top_video_id INT,
+ updated_at DATETIME DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+ FOREIGN KEY (usr_id) REFERENCES db_accountuser(usr_id) ON DELETE CASCADE
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
diff --git a/api/analytics.php b/api/analytics.php
new file mode 100644
index 0000000..3ebb8e7
--- /dev/null
+++ b/api/analytics.php
@@ -0,0 +1,151 @@
+ false, 'error' => 'Method not allowed']);
+ exit;
+ }
+
+ $input = json_decode(file_get_contents('php://input'), true) ?: $_POST;
+
+ $video_id = $input['video_id'] ?? null;
+ $event_type = $input['event_type'] ?? 'view';
+
+ if (!$video_id) {
+ http_response_code(400);
+ echo json_encode(['success' => false, 'error' => 'Video ID required']);
+ exit;
+ }
+
+ $data = [
+ 'usr_id' => $current_user_id,
+ 'watch_duration' => $input['watch_duration'] ?? 0,
+ 'completion_percentage' => $input['completion_percentage'] ?? 0,
+ 'country_code' => $input['country_code'] ?? null
+ ];
+
+ $result = $analytics->trackEvent($video_id, $event_type, $data);
+
+ // Track retention if provided
+ if (isset($input['minute'])) {
+ $analytics->trackRetention($video_id, $input['minute']);
+ }
+
+ // Track traffic source if provided
+ if (isset($input['source_type'])) {
+ // Get video owner
+ global $class_database;
+ $sql = "SELECT usr_id FROM db_videofiles WHERE video_id = ?";
+ $res = $class_database->execute($sql, [$video_id]);
+ if ($res && $row = $class_database->fetch($res)) {
+ $analytics->trackTrafficSource(
+ $video_id,
+ $row['usr_id'],
+ $input['source_type'],
+ $input['source_detail'] ?? ''
+ );
+ }
+ }
+
+ echo json_encode(['success' => (bool)$result]);
+ exit;
+}
+
+// All other actions require authentication
+if (!$current_user_id) {
+ http_response_code(401);
+ echo json_encode(['success' => false, 'error' => 'Authentication required']);
+ exit;
+}
+
+// Handle analytics queries
+switch ($action) {
+ case 'overview':
+ $data = $analytics->getChannelOverview($current_user_id, $days);
+ echo json_encode(['success' => true, 'data' => $data]);
+ break;
+
+ case 'timeseries':
+ $metric = $_GET['metric'] ?? 'views';
+ $data = $analytics->getChannelTimeSeries($current_user_id, $days, $metric);
+ echo json_encode(['success' => true, 'data' => $data]);
+ break;
+
+ case 'top_videos':
+ $metric = $_GET['metric'] ?? 'views';
+ $limit = intval($_GET['limit'] ?? 10);
+ $data = $analytics->getTopVideos($current_user_id, $days, $metric, $limit);
+ echo json_encode(['success' => true, 'data' => $data]);
+ break;
+
+ case 'demographics':
+ $data = $analytics->getDemographics($current_user_id, $days);
+ echo json_encode(['success' => true, 'data' => $data]);
+ break;
+
+ case 'traffic_sources':
+ $data = $analytics->getTrafficSources($current_user_id, $days);
+ echo json_encode(['success' => true, 'data' => $data]);
+ break;
+
+ case 'retention':
+ $video_id = $_GET['video_id'] ?? null;
+
+ if (!$video_id) {
+ http_response_code(400);
+ echo json_encode(['success' => false, 'error' => 'Video ID required']);
+ exit;
+ }
+
+ // Verify ownership
+ global $class_database;
+ $sql = "SELECT usr_id FROM db_videofiles WHERE video_id = ?";
+ $result = $class_database->execute($sql, [$video_id]);
+
+ if (!$result || $class_database->rowCount($result) == 0) {
+ http_response_code(404);
+ echo json_encode(['success' => false, 'error' => 'Video not found']);
+ exit;
+ }
+
+ $row = $class_database->fetch($result);
+
+ if ($row['usr_id'] != $current_user_id) {
+ http_response_code(403);
+ echo json_encode(['success' => false, 'error' => 'Permission denied']);
+ exit;
+ }
+
+ $data = $analytics->getAudienceRetention($video_id, $days);
+ echo json_encode(['success' => true, 'data' => $data]);
+ break;
+
+ default:
+ http_response_code(400);
+ echo json_encode(['success' => false, 'error' => 'Invalid action']);
+}
diff --git a/app_scripts/cron/aggregate_analytics.php b/app_scripts/cron/aggregate_analytics.php
new file mode 100644
index 0000000..a49f0c1
--- /dev/null
+++ b/app_scripts/cron/aggregate_analytics.php
@@ -0,0 +1,32 @@
+info("Starting analytics aggregation for date: $date");
+
+try {
+ $result = $analytics->aggregateDailyStats($date);
+
+ if ($result) {
+ $logger->info("Analytics aggregation complete for $date");
+ } else {
+ $logger->error("Analytics aggregation failed for $date");
+ }
+} catch (Exception $e) {
+ $logger->error("Analytics aggregation error: " . $e->getMessage());
+}
+
+echo "Done. Aggregated stats for $date\n";
diff --git a/creator/dashboard.php b/creator/dashboard.php
new file mode 100644
index 0000000..1ed1d62
--- /dev/null
+++ b/creator/dashboard.php
@@ -0,0 +1,389 @@
+
+
+
+
+
+
+ Creator Dashboard - EasyStream
+
+
+
+
+
+
+
+
+
+
+
Views (Last 30 Days)
+
-
+
Loading...
+
+
+
+
Watch Time
+
-
+
Loading...
+
+
+
+
Subscribers
+
-
+
Loading...
+
+
+
+
Engagement Rate
+
-
+
Loading...
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
Top Performing Videos
+
+
+