@@ -401,6 +422,14 @@ var I18N = {
add_manual:'✎ ساخت دستی',rescan:'بررسی مجدد',
new_messages:'پیام جدید',missed_messages:'{n} پیام از دست رفته یا حذف شده',
clear_cache:'پاک کردن کش',cache_cleared:'کش پاک شد!',
+ saved_resolvers_title:'شروع سریع',
+ saved_resolvers_msg:'آخرین اسکن ({t}) نتیجه داد: {n} سرور DNS سالم پیدا شد. همینها را استفاده کنیم یا دوباره اسکن کنیم؟',
+ saved_resolvers_use:'استفاده کن (بدون اسکن)',
+ saved_resolvers_rescan:'اسکن مجدد',
+ saved_resolvers_skip:'بعداً',
+ saved_resolvers_applied:'سرورهای DNS ذخیرهشده اعمال شدند',
+ minutes_ago:'دقیقه پیش',
+ hours_ago:'ساعت پیش',
},
en: {
search:'Search...',settings:'Settings',profiles:'Profiles',
@@ -435,6 +464,14 @@ var I18N = {
add_manual:'✎ Create Manually',rescan:'Rescan',
new_messages:'New messages',missed_messages:'{n} messages missed or deleted',
clear_cache:'Clear Cache',cache_cleared:'Cache cleared!',
+ saved_resolvers_title:'Quick Start',
+ saved_resolvers_msg:'Last scan ({t}) found {n} healthy DNS servers. Use them now (no scan needed), or scan again to re-verify.',
+ saved_resolvers_use:'Use Now (skip scan)',
+ saved_resolvers_rescan:'Scan Again',
+ saved_resolvers_skip:'Later',
+ saved_resolvers_applied:'Saved DNS servers applied!',
+ minutes_ago:'min ago',
+ hours_ago:'hr ago',
}
};
var lang = localStorage.getItem('thefeed_lang') || 'fa';
@@ -476,6 +513,7 @@ async function init(){
var r=await fetch('/api/status');var st=await r.json();
await loadProfiles();
if(!st.configured){openProfiles();return}
+ checkAndShowSavedResolversPrompt(st);
telegramLoggedIn=!!st.telegramLoggedIn;
serverNextFetch=st.nextFetch||0;
updateNextFetchDisplay();
@@ -514,6 +552,35 @@ async function clearCache(){
try{var r=await fetch('/api/cache/clear',{method:'POST'});var j=await r.json();if(j.ok){alert(t('cache_cleared'))}}catch(e){}
}
+// ===== SAVED RESOLVERS PROMPT =====
+function checkAndShowSavedResolversPrompt(status){
+ if(sessionStorage.getItem('thefeed_scan_prompt_shown'))return;
+ if(!status.lastScan||!status.lastScan.count)return;
+ var ls=status.lastScan;
+ var ageSec=Math.floor(Date.now()/1000)-ls.scannedAt;
+ var ageStr;
+ if(ageSec<3600)ageStr=Math.max(1,Math.round(ageSec/60))+' '+t('minutes_ago');
+ else ageStr=Math.round(ageSec/3600)+' '+t('hours_ago');
+ var msg=t('saved_resolvers_msg').replace('{n}',ls.count).replace('{t}',ageStr);
+ document.getElementById('savedResolversMsg').textContent=msg;
+ document.getElementById('savedResolversModal').classList.add('active');
+}
+function savedResolversSkip(){
+ // "Later" — just close, server already applied saved resolvers and refresh is underway
+ document.getElementById('savedResolversModal').classList.remove('active');
+ sessionStorage.setItem('thefeed_scan_prompt_shown','1');
+}
+function savedResolversUseNow(){
+ // Server already applied saved resolvers at startup; just close the popup
+ savedResolversSkip();
+ showToast(t('saved_resolvers_applied'));
+}
+async function savedResolversRescan(){
+ savedResolversSkip();
+ try{await fetch('/api/rescan',{method:'POST'})}catch(e){}
+ showToast(t('rescan_started'));
+}
+
// ===== SSE =====
function connectSSE(){
if(eventSource)eventSource.close();
@@ -902,6 +969,7 @@ async function selectChannel(num){
document.getElementById('chatName').textContent=name;
renderChannels();updateSendPanel();
document.getElementById('messages').innerHTML='
';
+ document.getElementById('scrollDownBtn').classList.remove('visible');
// Show immediate feedback progress bar
showChannelFetchProgress(num,name);
await loadMessages(num);
@@ -1017,7 +1085,7 @@ function renderMessages(msgs){
html+='
'+mediaHtml+textHtml+'
#'+id+''+timeStr+'
';
}
el.innerHTML=html;
- if(isFirstRender||wasAtBottom)el.scrollTop=el.scrollHeight;
+ if(isFirstRender||wasAtBottom){el.scrollTop=el.scrollHeight;document.getElementById('scrollDownBtn').classList.remove('visible');}
}
// ===== LOG =====
@@ -1270,6 +1338,25 @@ function copyMsg(idx){
navigator.clipboard.writeText(text).then(function(){showToast(t('msg_copied'))}).catch(function(){});
}
+// ===== SCROLL TO BOTTOM =====
+(function(){
+ var messagesEl=null;
+ function initScrollBtn(){
+ messagesEl=document.getElementById('messages');
+ if(!messagesEl)return;
+ messagesEl.addEventListener('scroll',function(){
+ var atBottom=messagesEl.scrollHeight-messagesEl.scrollTop-messagesEl.clientHeight<150;
+ document.getElementById('scrollDownBtn').classList.toggle('visible',!atBottom);
+ });
+ }
+ // Init after DOM is ready
+ document.addEventListener('DOMContentLoaded',initScrollBtn,{once:true});
+})();
+function scrollToBottom(){
+ var el=document.getElementById('messages');
+ if(el)el.scrollTop=el.scrollHeight;
+}
+
// ===== TOAST =====
function showToast(msg){
var el=document.getElementById('toast');el.textContent=msg;el.classList.add('show');
diff --git a/internal/web/web.go b/internal/web/web.go
index 8893046..0badc93 100644
--- a/internal/web/web.go
+++ b/internal/web/web.go
@@ -10,6 +10,7 @@ import (
"fmt"
"io/fs"
"log"
+ mrand "math/rand/v2"
"net/http"
"os"
"path/filepath"
@@ -57,6 +58,12 @@ type ProfileList struct {
Debug bool `json:"debug,omitempty"`
}
+// lastScanData is the on-disk structure for last_scan.json.
+type lastScanData struct {
+ Resolvers []string `json:"resolvers"`
+ ScannedAt int64 `json:"scannedAt"`
+}
+
// Server is the web UI server for thefeed client.
type Server struct {
dataDir string
@@ -165,6 +172,7 @@ func (s *Server) Run() error {
mux.HandleFunc("/api/profiles/switch", s.handleProfileSwitch)
mux.HandleFunc("/api/settings", s.handleSettings)
mux.HandleFunc("/api/cache/clear", s.handleClearCache)
+ mux.HandleFunc("/api/resolvers/apply-saved", s.handleApplySavedResolvers)
mux.HandleFunc("/", s.handleIndex)
addr := fmt.Sprintf("127.0.0.1:%d", s.port)
@@ -172,7 +180,16 @@ func (s *Server) Run() error {
fmt.Printf("\n Open in browser: http://%s\n\n", addr)
if s.fetcher != nil {
- s.startCheckerThenRefresh()
+ if ls := s.loadLastScan(); ls != nil {
+ // Fast path: apply saved healthy resolvers immediately and skip the
+ // initial full scan. Only the periodic 30-min checker starts.
+ // This gives the UI near-instant channel data on app open.
+ s.fetcher.SetActiveResolvers(ls.Resolvers)
+ s.checker.StartPeriodic(s.fetcherCtx)
+ go s.refreshMetadataOnly()
+ } else {
+ s.startCheckerThenRefresh()
+ }
}
var handler http.Handler = mux
@@ -227,6 +244,14 @@ func (s *Server) handleStatus(w http.ResponseWriter, r *http.Request) {
status["channels"] = s.channels
status["telegramLoggedIn"] = s.telegramLoggedIn
status["nextFetch"] = s.nextFetch
+ // Include last resolver scan if recent (<24 h) so the frontend can offer a quick-start.
+ if ls := s.loadLastScan(); ls != nil {
+ status["lastScan"] = map[string]any{
+ "resolvers": ls.Resolvers,
+ "scannedAt": ls.ScannedAt,
+ "count": len(ls.Resolvers),
+ }
+ }
}
writeJSON(w, status)
}
@@ -344,7 +369,24 @@ func (s *Server) handleRescan(w http.ResponseWriter, r *http.Request) {
return
}
go func() {
+ // Cancel any in-progress metadata refresh so it doesn't race with the
+ // scan — we want fresh resolver data before we hit DNS again.
+ s.refreshMu.Lock()
+ if s.refreshCancel != nil {
+ s.refreshCancel()
+ s.refreshCancel = nil
+ }
+ s.refreshMu.Unlock()
+
if checker.CheckNow(baseCtx) {
+ // Cool-down: give resolvers time to recover from the scan's DNS
+ // queries before we immediately hit them again with a fetch.
+ sleep := 3*time.Second + time.Duration(mrand.IntN(13))*time.Second // 3–15 s
+ select {
+ case <-baseCtx.Done():
+ return
+ case <-time.After(sleep):
+ }
s.refreshMetadataOnly()
}
}()
@@ -610,6 +652,11 @@ func (s *Server) initFetcher() error {
checker.SetLogFunc(func(msg string) {
s.addLog(msg)
})
+ checker.SetOnScanDone(func(healthy []string) {
+ if len(healthy) > 0 {
+ s.saveLastScan(healthy)
+ }
+ })
s.checker = checker
s.fetcher = fetcher
@@ -727,7 +774,7 @@ func (s *Server) refreshMetadataOnly() {
s.refreshMu.Unlock()
}()
- s.addLog("Fetching metadata...")
+ s.addLog(fmt.Sprintf("Fetching metadata... (%d active resolvers)", len(fetcher.Resolvers())))
// If the server's next Telegram fetch is imminent (within 5 s), wait for it first.
if dl := s.nextFetchDeadline(); !dl.IsZero() && time.Until(dl) < 5*time.Second {
@@ -961,6 +1008,57 @@ func (s *Server) loadConfig() (*Config, error) {
return &cfg, nil
}
+// saveLastScan persists the healthy resolver list from the most recent scan.
+func (s *Server) saveLastScan(resolvers []string) {
+ d := lastScanData{Resolvers: resolvers, ScannedAt: time.Now().Unix()}
+ b, err := json.MarshalIndent(d, "", " ")
+ if err != nil {
+ return
+ }
+ _ = os.WriteFile(filepath.Join(s.dataDir, "last_scan.json"), b, 0600)
+}
+
+// loadLastScan reads the most recent resolver scan result.
+// Returns nil when the file doesn't exist or is older than 24 hours.
+func (s *Server) loadLastScan() *lastScanData {
+ b, err := os.ReadFile(filepath.Join(s.dataDir, "last_scan.json"))
+ if err != nil {
+ return nil
+ }
+ var d lastScanData
+ if err := json.Unmarshal(b, &d); err != nil {
+ return nil
+ }
+ if len(d.Resolvers) == 0 || time.Since(time.Unix(d.ScannedAt, 0)) > 24*time.Hour {
+ return nil
+ }
+ return &d
+}
+
+// handleApplySavedResolvers immediately activates the resolvers from the last
+// scan file, letting the UI skip the current scan and start fetching channels.
+func (s *Server) handleApplySavedResolvers(w http.ResponseWriter, r *http.Request) {
+ if r.Method != http.MethodPost {
+ http.Error(w, "method not allowed", 405)
+ return
+ }
+ ls := s.loadLastScan()
+ if ls == nil {
+ http.Error(w, "no saved scan", 400)
+ return
+ }
+ s.mu.RLock()
+ fetcher := s.fetcher
+ s.mu.RUnlock()
+ if fetcher == nil {
+ http.Error(w, "not configured", 400)
+ return
+ }
+ fetcher.SetActiveResolvers(ls.Resolvers)
+ go s.refreshMetadataOnly()
+ writeJSON(w, map[string]any{"ok": true, "count": len(ls.Resolvers)})
+}
+
func (s *Server) saveConfig(cfg *Config) error {
path := filepath.Join(s.dataDir, "config.json")
data, err := json.MarshalIndent(cfg, "", " ")