feat/enhanced-follow-list

src/platforms/kick/kick.constants.ts

@@ -12,5 +12,7 @@ export const KICK_DEFAULT_SETTINGS: KickSettings = {
 	streamLatencyEnabled: true,
 	realVideoTimeEnabled: true,
 	realVideoTimeFormat12h: false,
+	shareFollowsToOtherPlatforms: false,
+	showFollowsFromOtherPlatforms: true,
 	channelSection: true,
 };

src/platforms/kick/kick.module.ts

@@ -2,6 +2,7 @@ import type KickApi from "$kick/apis/kick.api.ts";
 import type KickUtils from "$kick/kick.utils.ts";
 import type EnhancerApi from "$shared/apis/enhancer.api.ts";
 import Module from "$shared/module/module.ts";
+import type CommonDataService from "$shared/settings/common.service.ts";
 import type SettingsService from "$shared/settings/settings.service.ts";
 import type StorageRepository from "$shared/storage/storage-repository.ts";
 import type UtilsRepository from "$shared/utils/utils.repository.ts";
@@ -16,13 +17,14 @@ export default abstract class KickModule extends Module<KickEvents, KickStorage,
 		emitter: Emitter<KickEvents>,
 		storageRepository: StorageRepository<KickStorage>,
 		settingsService: SettingsService<KickSettings>,
+		commonDataService: CommonDataService,
 		utilsRepository: UtilsRepository,
 		enhancerApi: EnhancerApi,
 		workerApi: WorkerService,
 		private readonly _kickUtils: KickUtils,
 		private readonly _kickApi: KickApi,
 	) {
-		super(emitter, storageRepository, settingsService, utilsRepository, enhancerApi, workerApi);
+		super(emitter, storageRepository, settingsService, commonDataService, utilsRepository, enhancerApi, workerApi);
 	}
 
 	protected kickUtils() {

src/platforms/kick/kick.platform.ts

@@ -7,15 +7,14 @@ import ChatAttachmentsModule from "$kick/modules/chat-attachments/chat-attachmen
 import ChatBadgesModule from "$kick/modules/chat-badges/chat-badges.module.tsx";
 import ChatFixAutoScrollModule from "$kick/modules/chat-fix-auto-scroll/chat-fix-auto-scroll.module.tsx";
 import ChatHighlightUserModule from "$kick/modules/chat-highlight-user/chat-highlight-user.module.tsx";
-import ChatMessageMenuModule from "$kick/modules/chat-message-menu/chat-message-menu.module.tsx";
-import MessageMenuModule from "$kick/modules/chat-message-menu/message-menu.module.tsx";
 import ChatMessagePopupModule from "$kick/modules/chat-message-popup/chat-message-popup.module.tsx";
 import ChatNicknameCustomizationModule from "$kick/modules/chat-nickname-customization/chat-nickname-customization.module.ts";
 import ChatModule from "$kick/modules/chat/chat.module.ts";
 import LocalWatchtimeCounterModule from "$kick/modules/local-watchtime-counter/local-watchtime-counter.module.tsx";
 import RealVideoTimeModule from "$kick/modules/real-video-time/real-video-time.module.tsx";
 import SettingsButtonModule from "$kick/modules/settings-button/settings-button.module.tsx";
 import SettingsModule from "$kick/modules/settings/settings.module.tsx";
+import SharedFollowsModule from "$kick/modules/shared-follows/shared-follows.module.tsx";
 import StreamLatencyModule from "$kick/modules/stream-latency/stream-latency.module.tsx";
 import Platform from "$shared/platform/platform.ts";
 import type { KickEvents } from "$types/platforms/kick/kick.events.types.ts";
@@ -35,6 +34,7 @@ export default class KickPlatform extends Platform<KickModule, KickEvents, KickS
 			this.emitter,
 			this.storageRepository,
 			this.settingsService,
+			this.commonDataService,
 			this.utilsRepository,
 			this.enhancerApi,
 			this.workerApi,
@@ -58,6 +58,7 @@ export default class KickPlatform extends Platform<KickModule, KickEvents, KickS
 			// new ChatMessageMenuModule(...dependencies),
 			new AdditionalFontsModule(...dependencies),
 			new ChatFixAutoScrollModule(...dependencies),
+			new SharedFollowsModule(...dependencies),
 		];
 	}
 

src/platforms/kick/modules/settings/settings.module.tsx

@@ -74,6 +74,22 @@ export default class SettingsModule extends KickModule {
 			discord: await this.commonUtils().getAssetFile(this.workerService(), "brands/discord.svg"),
 		} as const;
 		this.SETTING_DEFINITIONS = [
+			{
+				id: "showFollowsFromOtherPlatforms",
+				title: "Enable follow list from other platforms",
+				description: "Shows your followed channels from other platforms in the follow list.",
+				type: "toggle",
+				tabIndex: 0,
+				requiresRefreshToDisable: true,
+			},
+			{
+				id: "shareFollowsToOtherPlatforms",
+				title: "Share followed channels",
+				description: "Expose your followed list to Enhancer so it can be used across platforms.",
+				type: "toggle",
+				tabIndex: 0,
+				requiresRefreshToDisable: false,
+			},
 			{
 				id: "streamLatencyEnabled",
 				title: "Enable Stream Latency",

src/platforms/kick/modules/shared-follows/kick.follow-syncer.ts

@@ -0,0 +1,79 @@
+import { HttpClient } from "$shared/http/http-client.ts";
+import FollowSyncer from "$shared/module/shared-follows/follow-syncer.ts";
+import type CommonDataService from "$shared/settings/common.service.ts";
+import type CommonUtils from "$shared/utils/common.utils.ts";
+import type { FollowedChannelsResponse } from "$types/platforms/kick/kick.api.types.ts";
+
+export default class KickFollowSyncer extends FollowSyncer {
+	private readonly http: HttpClient = new HttpClient(this.logger);
+	private syncInProgress = false;
+
+	constructor(
+		private readonly commonDataService: CommonDataService,
+		private readonly commonUtils: CommonUtils,
+	) {
+		super("kick");
+	}
+
+	async getFollows() {
+		if (this.syncInProgress) {
+			this.logger.warn("Sync already in progress, skipping new request");
+			return;
+		}
+		this.syncInProgress = true;
+		try {
+			const followed = await this.fetchAllFollowed();
+			await this.commonDataService.updateCommonNestedKey("sharedFollows", "kick", followed);
+			this.logger.info(`Synced ${followed.length} followed channels`);
+		} catch (err) {
+			this.logger.error("Failed to sync follows", err);
+		} finally {
+			this.syncInProgress = false;
+		}
+	}
+
+	async clearFollows() {
+		await this.commonDataService.updateCommonNestedKey("sharedFollows", "kick", []);
+	}
+
+	private async fetchAllFollowed(): Promise<string[]> {
+		const collected = new Set<string>();
+		await this.fetchFollowedRecursive(0, collected);
+		return Array.from(collected);
+	}
+
+	private async fetchFollowedRecursive(cursor: number, collected: Set<string>) {
+		const authorization = this.getAuthHeader();
+		if (!authorization) return;
+
+		try {
+			const url = new URL("https://kick.com/api/v2/channels/followed");
+			url.searchParams.set("cursor", String(cursor));
+
+			const { data } = await this.http.request<FollowedChannelsResponse>(url.href, {
+				method: "GET",
+				headers: { Authorization: authorization },
+			});
+
+			(data.channels ?? []).forEach((channel) => {
+				const name = (channel.channel_slug || channel.user_username || "").toString().trim();
+				if (name) {
+					collected.add(name.toLowerCase());
+				}
+			});
+
+			if (typeof data.nextCursor === "number") {
+				await this.fetchFollowedRecursive(data.nextCursor, collected);
+			}
+		} catch (error) {
+			this.logger.warn(`Failed to fetch followed channels at cursor ${cursor}`, error);
+			return;
+		}
+	}
+
+	private getAuthHeader(): string | undefined {
+		const token = this.commonUtils.getCookie("session_token");
+		if (!token) return;
+		return `Bearer ${token}`;
+	}
+}

src/platforms/kick/modules/shared-follows/shared-follows.module.tsx

@@ -0,0 +1,42 @@
+import KickModule from "$kick/kick.module.ts";
+import KickFollowSyncer from "$kick/modules/shared-follows/kick.follow-syncer.ts";
+import type { KickModuleConfig } from "$types/shared/module/module.types.ts";
+
+export default class SharedFollowsModule extends KickModule {
+	private readonly kickFollowsSyncer = new KickFollowSyncer(this.commonDataService(), this.commonUtils());
+
+	config: KickModuleConfig = {
+		name: "shared-follows",
+		appliers: [
+			{
+				type: "event",
+				event: "kick:settings:shareFollowsToOtherPlatforms",
+				callback: async (value) => {
+					if (value) await this.startSyncTimer();
+					else {
+						await this.kickFollowsSyncer.clearFollows();
+						this.stopSyncTimer();
+					}
+				},
+				key: "share-follows",
+			},
+		],
+	};
+
+	private syncFollowsTimer: NodeJS.Timeout | undefined;
+
+	async initialize(): Promise<void> {
+		const shareFollowsToOtherPlatforms = await this.settingsService().getSettingsKey("shareFollowsToOtherPlatforms");
+		if (shareFollowsToOtherPlatforms) await this.startSyncTimer();
+	}
+
+	private async startSyncTimer() {
+		this.stopSyncTimer();
+		this.syncFollowsTimer = setInterval(() => this.kickFollowsSyncer.getFollows(), 120000); // 2 mins
+		await this.kickFollowsSyncer.getFollows();
+	}
+
+	private stopSyncTimer() {
+		if (this.syncFollowsTimer) clearInterval(this.syncFollowsTimer);
+	}
+}