TTS Kernel Control

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_177":178,"_179":180},"routes/_app.x.$handle.$name",{"_106":105,"_38":50,"_114":96,"_33":60,"_13":14,"_115":-5,"_11":116,"_117":118,"_119":120,"_121":122,"_123":124,"_26":-5,"_125":-5,"_126":-5,"_127":31,"_128":129,"_130":31,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_48":49,"_38":50,"_43":51,"_52":-5,"_53":31,"_54":55,"_56":55,"_57":58,"_59":60,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":77,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":89,"_90":91,"_92":93,"_94":31},"version",11,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","e1c78555-49d5-4866-a2b0-f0307bd4e4b7","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":26,"_40":42,"_43":44,"_45":14,"_46":47,"_30":31},"previous",{"_36":37,"_38":34,"_39":26,"_40":41},"deleted",false,"deletedHere","path","gui_app.py","latestPath","fileId","06eae464-1f8b-11f1-a108-42dde27851f2","name","fileType","content","import webbrowser\nimport json\nimport os\nimport datetime\nimport logging\nimport queue\nimport tkinter as tk\nfrom tkinter import ttk, scrolledtext\nimport threading\nimport sys\nfrom browser_manager import BrowserManager\nfrom tiktok_shop_automator import KERNEL_API_KEY\n\nclass QueueHandler(logging.Handler):\n def __init__(self, log_queue):\n super().__init__()\n self.log_queue = log_queue\n\n def emit(self, record):\n self.log_queue.put(record)\n\nclass MiniGUI:\n def __init__(self, root):\n self.root = root\n self.root.title(\"TTS Auto\")\n self.root.geometry(\"300x500\") # Tăng chiều cao một chút để chứa tab\n self.root.attributes('-topmost', True) # Always on top\n self.root.configure(bg='#1e1e1e') # Dark mode\n\n self.log_queue = queue.Queue()\n queue_handler = QueueHandler(self.log_queue)\n logging.getLogger().addHandler(queue_handler)\n\n # Tabs\n self.notebook = ttk.Notebook(root)\n self.notebook.pack(fill=tk.BOTH, expand=True)\n\n # Style for Notebook\n style = ttk.Style()\n style.theme_use('clam')\n style.configure(\"TNotebook\", background=\"#1e1e1e\", borderwidth=0)\n style.configure(\"TNotebook.Tab\", background=\"#333\", foreground=\"#aaa\", font=(\"Consolas\", 8), padding=[10, 2], borderwidth=0)\n style.map(\"TNotebook.Tab\", background=[(\"selected\", \"#1e1e1e\")], foreground=[(\"selected\", \"#00ff00\")])\n\n # --- Tab 1: Control ---\n self.tab_control = tk.Frame(self.notebook, bg='#1e1e1e')\n self.notebook.add(self.tab_control, text=\"CONTROL\")\n self.setup_control_tab()\n\n # --- Tab 2: Profiles ---\n self.tab_profiles = tk.Frame(self.notebook, bg='#1e1e1e')\n self.notebook.add(self.tab_profiles, text=\"PROFILES\")\n self.setup_profiles_tab()\n\n self.running = False\n self.root.after(100, self.process_logs)\n\n def setup_control_tab(self):\n # Proxy Config\n tk.Label(self.tab_control, text=\"[PROXY CONFIG]\", bg='#1e1e1e', fg='#00ff00', font=(\"Consolas\", 8, \"bold\")).pack(anchor=\"w\", padx=5, pady=5)\n \n input_frame = tk.Frame(self.tab_control, bg='#1e1e1e')\n input_frame.pack(fill=tk.X, padx=5, pady=2)\n \n tk.Label(input_frame, text=\"Region:\", bg='#1e1e1e', fg='#aaa', font=(\"Consolas\", 8)).grid(row=0, column=0, sticky=\"w\")\n self.region_var = tk.StringVar()\n tk.Entry(input_frame, textvariable=self.region_var, bg='#333', fg='#fff', font=(\"Consolas\", 8), width=10, relief=\"flat\", insertbackground='white').grid(row=0, column=1, padx=5)\n\n tk.Label(input_frame, text=\"City:\", bg='#1e1e1e', fg='#aaa', font=(\"Consolas\", 8)).grid(row=1, column=0, sticky=\"w\")\n self.city_var = tk.StringVar()\n tk.Entry(input_frame, textvariable=self.city_var, bg='#333', fg='#fff', font=(\"Consolas\", 8), width=10, relief=\"flat\", insertbackground='white').grid(row=1, column=1, padx=5)\n\n # Actions\n btn_frame = tk.Frame(self.tab_control, bg='#1e1e1e')\n btn_frame.pack(fill=tk.X, padx=5, pady=10)\n\n self.btn_start = tk.Button(btn_frame, text=\"> START SYSTEM\", command=self.start_thread, bg='#004400', fg='#00ff00', font=(\"Consolas\", 9, \"bold\"), relief=\"flat\", activebackground=\"#006600\")\n self.btn_start.pack(fill=tk.X, pady=2)\n\n self.btn_stop = tk.Button(btn_frame, text=\"x STOP\", command=self.stop_system, bg='#440000', fg='#ff0000', font=(\"Consolas\", 8), relief=\"flat\", activebackground=\"#660000\")\n self.btn_stop.pack(fill=tk.X, pady=2)\n\n # Log Console\n tk.Label(self.tab_control, text=\"[LOGS]\", bg='#1e1e1e', fg='#aaa', font=(\"Consolas\", 8)).pack(anchor=\"w\", padx=5, pady=(5,0))\n self.log_area = scrolledtext.ScrolledText(self.tab_control, height=15, bg='#000', fg='#00ff00', font=(\"Consolas\", 7), state='disabled', relief=\"flat\")\n self.log_area.pack(fill=tk.BOTH, expand=True, padx=5, pady=5)\n\n # Status Bar\n self.status_var = tk.StringVar()\n self.status_var.set(\"IDLE\")\n tk.Label(self.tab_control, textvariable=self.status_var, bg='#1e1e1e', fg='#ffff00', font=(\"Consolas\", 7)).pack(anchor=\"e\", padx=5)\n\n def setup_profiles_tab(self):\n # Toolbar\n toolbar = tk.Frame(self.tab_profiles, bg='#1e1e1e')\n toolbar.pack(fill=tk.X, padx=5, pady=5)\n \n tk.Button(toolbar, text=\"REFRESH\", command=self.load_profiles, bg='#333', fg='#fff', font=(\"Consolas\", 7), relief=\"flat\").pack(side=tk.LEFT, padx=2)\n tk.Button(toolbar, text=\"OPEN\", command=self.open_selected_profile, bg='#004400', fg='#00ff00', font=(\"Consolas\", 7, \"bold\"), relief=\"flat\").pack(side=tk.LEFT, padx=2)\n tk.Button(toolbar, text=\"DELETE\", command=self.delete_selected_profile, bg='#440000', fg='#ff0000', font=(\"Consolas\", 7), relief=\"flat\").pack(side=tk.RIGHT, padx=2)\n\n # Listbox\n self.profile_list = tk.Listbox(self.tab_profiles, bg='#000', fg='#00ff00', font=(\"Consolas\", 8), relief=\"flat\", selectbackground=\"#333\", selectforeground=\"#fff\", borderwidth=0)\n self.profile_list.pack(fill=tk.BOTH, expand=True, padx=5, pady=5)\n self.profile_list.bind('', lambda e: self.open_selected_profile())\n \n self.load_profiles()\n\n def load_profiles(self):\n self.profile_list.delete(0, tk.END)\n self.profiles = []\n try:\n if os.path.exists(\"profiles.json\"):\n with open(\"profiles.json\", \"r\") as f:\n self.profiles = json.load(f)\n # Sort by timestamp desc\n self.profiles.sort(key=lambda x: x.get('timestamp', 0), reverse=True)\n \n for p in self.profiles:\n display_text = f\"{p.get('time_str', '?')} - {p.get('proxy_id', 'N/A')[:8]}...\"\n self.profile_list.insert(tk.END, display_text)\n except Exception as e:\n print(f\"Error loading profiles: {e}\")\n\n def save_profile(self, proxy_id, cdp_url, live_url):\n new_profile = {\n \"proxy_id\": proxy_id,\n \"cdp_url\": cdp_url,\n \"live_url\": live_url,\n \"timestamp\": datetime.datetime.now().timestamp(),\n \"time_str\": datetime.datetime.now().strftime(\"%H:%M:%S\")\n }\n \n current_profiles = []\n if os.path.exists(\"profiles.json\"):\n try:\n with open(\"profiles.json\", \"r\") as f:\n current_profiles = json.load(f)\n except: pass\n \n current_profiles.append(new_profile)\n with open(\"profiles.json\", \"w\") as f:\n json.dump(current_profiles, f, indent=2)\n \n self.root.after(0, self.load_profiles)\n\n def open_selected_profile(self):\n selection = self.profile_list.curselection()\n if selection:\n index = selection[0]\n profile = self.profiles[index]\n live_url = profile.get('live_url')\n if live_url:\n webbrowser.open(live_url)\n\n def delete_selected_profile(self):\n selection = self.profile_list.curselection()\n if selection:\n index = selection[0]\n del self.profiles[index]\n with open(\"profiles.json\", \"w\") as f:\n json.dump(self.profiles, f, indent=2)\n self.load_profiles()\n\n\n def log(self, message):\n self.log_area.configure(state='normal')\n self.log_area.insert(tk.END, message + \"\\n\")\n self.log_area.see(tk.END)\n self.log_area.configure(state='disabled')\n\n def process_logs(self):\n while not self.log_queue.empty():\n record = self.log_queue.get()\n msg = f\"[{record.levelname[0]}] {record.getMessage()}\"\n self.log(msg)\n self.root.after(100, self.process_logs)\n\n def start_thread(self):\n if self.running: return\n self.running = True\n self.btn_start.config(state=\"disabled\")\n self.status_var.set(\"RUNNING...\")\n threading.Thread(target=self.run_automation, daemon=True).start()\n\n def run_automation(self):\n try:\n region = self.region_var.get().strip() or None\n city = self.city_var.get().strip() or None\n \n logging.info(\"Init Browser Manager...\")\n browser_manager = BrowserManager(KERNEL_API_KEY)\n \n logging.info(f\"Creating Proxy (US, {region}, {city})...\")\n proxy_id = browser_manager.create_proxy(country=\"US\", region=region, city=city)\n \n if proxy_id:\n logging.info(\"Creating Browser...\")\n cdp, live_url = browser_manager.create_browser_session(proxy_id)\n \n if cdp:\n # Save profile\n self.save_profile(proxy_id, cdp, live_url)\n logging.info(f\"Profile saved. Live View: {live_url}\")\n \n logging.info(\"Opening Live View in Default Browser...\")\n if live_url:\n webbrowser.open(live_url)\n \n logging.info(\"Done. Session is running.\")\n else:\n logging.error(\"Failed to create browser.\")\n else:\n logging.error(\"Failed to create proxy.\")\n \n except Exception as e:\n logging.error(f\"Error: {e}\")\n finally:\n self.running = False\n # Use root.after to safely update UI from thread\n self.root.after(0, lambda: self.btn_start.config(state=\"normal\"))\n self.root.after(0, lambda: self.status_var.set(\"IDLE\"))\n\n def stop_system(self):\n # Placeholder for stop logic (requires more complex thread management to truly kill)\n logging.info(\"Stop signal sent (soft)...\")\n self.running = False\n self.status_var.set(\"STOPPING...\")\n\nif __name__ == \"__main__\":\n root = tk.Tk()\n app = MiniGUI(root)\n root.mainloop()","export default async function(req: Request): Promise {\n const method = req.method;\n const url = new URL(req.url);\n const path = url.pathname;\n\n // API Routes\n if (path === \"/api/create-proxy\" && method === \"POST\") {\n const body = await req.json();\n const { country = \"US\", region, city } = body;\n\n try {\n // Placeholder - replace with actual Kernel API call\n const proxyId = `proxy_${Date.now()}`;\n return Response.json({ success: true, proxyId, message: `Proxy created: ${proxyId}` });\n } catch (error) {\n return Response.json({ success: false, error: (error as Error).message }, { status: 500 });\n }\n }\n\n if (path === \"/api/create-browser\" && method === \"POST\") {\n const body = await req.json();\n const { proxyId } = body;\n\n try {\n // Placeholder - replace with actual Kernel API call\n const cdpUrl = `wss://cdp.example.com/${proxyId}`;\n const liveUrl = `https://live.example.com/${proxyId}`;\n return Response.json({ success: true, cdpUrl, liveUrl });\n } catch (error) {\n return Response.json({ success: false, error: (error as Error).message }, { status: 500 });\n }\n }\n\n if (path === \"/api/profiles\" && method === \"GET\") {\n // Placeholder - return sample profiles\n return Response.json({\n profiles: [\n { id: 1, proxyId: \"proxy_123...\", time: \"10:30:45\", liveUrl: \"https://example.com\" },\n { id: 2, proxyId: \"proxy_456...\", time: \"10:15:22\", liveUrl: \"https://example.com\" },\n ]\n });\n }\n\n // Main HTML Page\n const html = \\`\n\n\n \n \n TTS Kernel Control\n \n\n\n

\n \n\n

\n \n \n

\n\n

\n \n

⚙️ PROXY CONFIG

\n \n

\n Region (optional)\n \n

\n\n

\n City (optional)\n \n

\n\n

\n \n \n

\n\n

IDLE

\n\n

📋 LOGS

\n\n \n

\n \n

\n\n

\n\n \n\n\\`;\n\n return new Response(html, {\n headers: { \"Content-Type\": \"text/html; charset=utf-8\" },\n });\n}\n","createdAt",["D",1773481897785],"branchVersion","branchId","defea1e8-1f8a-11f1-9dea-42dde27851f2","id","defde8f2-1f8a-11f1-9dea-42dde27851f2","kernel",["D",1773481673231],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Kernel Control Panel - Web UI for proxy & browser management","imageUrl","","019ceb5c-6caf-756b-adbd-4861b5ab6dee","pinnedFileId","7388d0b8-1f8b-11f1-9f3b-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019ceb5c-6caf-756b-adbd-4c6cbb08afaf","tursoName","defde8f21f8a11f19dea42dde27851f2","tursoHostname","defde8f21f8a11f19dea42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789528252206],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_106":105,"_113":109},"org",{"_106":105,"_107":-5,"_108":109,"_19":61,"_110":111,"_112":31},"branch",{"_13":95,"_38":96,"_48":47,"_97":49,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":50,"_104":105},"isOwned",22,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","buonhayvui1404","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNBdlp1NXpMS3Zra3JwR0lZQkRoTlpNNUw2USJ9","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_48":49,"_38":50,"_43":172,"_52":-5,"_53":31,"_54":55,"_56":55,"_57":58,"_59":60,"_19":61,"_62":63,"_64":65,"_66":-5,"_67":-5,"_68":69,"_70":71,"_72":73,"_74":75,"_76":173,"_78":-5,"_79":80,"_81":80,"_82":83,"_84":83,"_85":83,"_86":80,"_87":80,"_88":174,"_90":175,"_92":176,"_94":31},"tree",[163,164],"files",[163,164],"counts",{"_152":69,"_153":154,"_155":69,"_156":157,"_158":159},"contents",[135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_48":144,"_38":145,"_36":146,"_138":-5,"_46":47,"_45":147,"_139":65,"_43":148,"_13":149,"_39":26,"_40":150,"_30":31,"_142":-5,"_33":151},{"_48":137,"_38":34,"_36":37,"_138":-5,"_46":47,"_45":14,"_139":65,"_43":140,"_13":141,"_39":26,"_40":42,"_30":31,"_142":-5,"_33":143},"64d7d3ca-1f8b-11f1-a9a6-42dde27851f2","parentId","latest",["D",1773481897785],4,"label",[34],"fdb7bf8e-1f8a-11f1-a35a-42dde27851f2","browser_manager.py","f0fdf916-1f8a-11f1-9dea-42dde27851f2",5,["D",1773481724769],3,"import logging\nimport time\nfrom kernel import Kernel\n\nlogger = logging.getLogger(__name__)\n\nclass BrowserManager:\n def __init__(self, api_key):\n self.client = Kernel(api_key=api_key)\n\n def create_proxy(self, country=\"US\", region=None, city=None):\n \"\"\"Creates a residential proxy with specific location.\"\"\"\n location_info = f\"{country}\"\n if region: location_info += f\", {region}\"\n if city: location_info += f\", {city}\"\n \n logger.info(f\"Creating Residential Proxy ({location_info})...\")\n try:\n config = {\"country\": country}\n if region:\n config[\"region\"] = region\n if city:\n config[\"city\"] = city\n \n proxy = self.client.proxies.create(\n type=\"residential\",\n name=f\"tiktok_auto_proxy_{int(time.time())}\",\n config=config\n )\n logger.info(f\"Proxy Created Successfully: {proxy.id} ({location_info})\")\n return proxy.id\n except Exception as e:\n logger.error(f\"Error creating proxy: {e}\")\n raise\n\n def create_browser_session(self, proxy_id):\n \"\"\"Creates a browser session using the specified proxy.\"\"\"\n logger.info(f\"Creating Browser Session with Proxy ID: {proxy_id}...\")\n try:\n browser = self.client.browsers.create(\n proxy_id=proxy_id,\n headless=False,\n stealth=True, # Enable Stealth Mode to avoid detection\n timeout_seconds=3600\n )\n logger.info(f\"Browser Created. CDP URL: {browser.cdp_ws_url}\")\n \n if hasattr(browser, 'browser_live_view_url'):\n logger.info(f\"Live View: {browser.browser_live_view_url}\")\n # Optional: Automatically open live view for debugging\n # import webbrowser\n # webbrowser.open(browser.browser_live_view_url)\n return browser.cdp_ws_url, browser.browser_live_view_url\n \n return browser.cdp_ws_url, None\n except Exception as e:\n logger.error(f\"Error creating browser session: {e}\")\n raise",[145],"pulls","branches",1,"forks","envVars",{"_160":154,"_162":69},"connections",{"_160":69,"_161":69},"count","unfilledCount","emptyCount",{"_48":144,"_38":145,"_36":146,"_138":-5,"_46":47,"_45":147,"_139":65,"_43":169,"_13":149,"_39":26,"_40":150,"_30":31,"_142":-5,"_166":170,"_33":171},{"_48":137,"_38":34,"_36":37,"_138":-5,"_46":47,"_45":14,"_139":65,"_43":165,"_13":141,"_39":26,"_40":42,"_30":31,"_142":-5,"_166":167,"_33":168},["D",1773481897785],"children",[],[34],["D",1773481724769],[],[145],["D",1773481673231],["D",1789528252206],{"_106":105,"_113":109},{"_106":105,"_107":-5,"_108":109,"_19":61,"_110":111,"_112":31},{"_13":95,"_38":96,"_48":47,"_97":49,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":-5,"_103":50,"_104":105},"ctx",{"_88":-5,"_132":210,"_211":212,"_213":214,"_215":31,"_216":31,"_217":31,"_218":65,"_219":-5,"_220":-7,"_221":-7,"_222":69,"_223":31,"_224":31,"_225":-5,"_226":31,"_227":31,"_228":31,"_229":-5},"ENV",{"_181":182,"_183":184,"_185":96,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v11