Compare commits

...
9 Commits
Author SHA1 Message Date
asepharyana 9ea9a4291c feat: scheduler tangkap company name dari top-changes (n=750) — gratis, isi yang kosong saja
CI / go test + web typecheck (push) Canceled after 0s
CI / build + deploy (Nix) — flowsight (push) Canceled after 0s
2026-09-16 16:54:27 +07:00
asepharyana 41325ba574 feat: tangkap company name dari snapshot top-changes (n=750, gratis) + SetCompanyNames fill-blank 2026-09-16 16:53:50 +07:00
asepharyana 6d3c17d19d fix: PDF export kini Unicode — ganti core font Helvetica (latin1 → '?') dengan DejaVuSans ter-embed
CI / go test + web typecheck (push) Canceled after 0s
CI / build + deploy (Nix) — flowsight (push) Canceled after 0s
2026-09-16 16:48:27 +07:00
asepharyana ae0d5d813f feat(ui): watchlist empty-state + chat error styling + hint
CI / go test + web typecheck (push) Canceled after 0s
CI / build + deploy (Nix) — flowsight (push) Canceled after 0s
- WatchlistDrawer: shows helpful hint ('Ketik kode saham lalu Add') when empty
- ChatSidebar: errors in text-destructive, empty state explains how chat works
- styled-components/timestamp formatting and company-name display already in previous commit
2026-09-16 15:39:33 +07:00
asepharyana ffdc0fd9e8 feat(ui): polish pass — theme-aware charts, brand nav, search & date formatting
- Dashboard foreign-flow chart line now uses the CSS --primary token (hsl) so it matches light/dark instead of a hardcoded blue; Portfolio bar chart gets themed bars with rounded corners + alpha steps
- Nav: logo mark (📈 in primary tile), active item left accent bar, active-state matching for sub-routes (/report/:ticker now highlights Report... actually Dashboard/Screener etc)
- TickerSearch: cleaner searchbox with magnifier icon + 'Buka' button, aria-label
- Login page: centered branded header (logo + FlowSight), vertically centered card
- Sorotan cards + Screener show company name under ticker when available
- Routines run history + Alerts event/alert lists: formatted dates (16 Sep 07:30), status badges (ok/error), credits-used display
- Dashboard hero/misc spacing polish
2026-09-16 15:33:18 +07:00
asepharyana 05a3bc7471 fix: audit round 4 — XSS in HTML report export, SSRF webhook guard, body limit
CI / go test + web typecheck (push) Canceled after 0s
CI / build + deploy (Nix) — flowsight (push) Canceled after 0s
- ToHTML() now html.EscapeString on ticker, generated_at, section name/body, citations (stored/LLM content can't inject script into exported file)
- Discord destination webhook_url restricted to discord.com/discordapp.com hosts (SSRF guard: server POSTs alert cards; no private IPs or arbitrary hosts)
- Router middleware caps POST/PUT/PATCH bodies at 1 MiB (MaxBytesReader)
- TestDestinations updated: non-discord host must 422, uses realistic discord.com webhook URL
2026-09-16 14:43:56 +07:00
asepharyana b19b9c71d1 test: universe save + local ticker search (ticker & company-name lookup)
CI / go test + web typecheck (push) Canceled after 0s
CI / build + deploy (Nix) — flowsight (push) Canceled after 0s
2026-09-16 14:32:54 +07:00
asepharyana 49dd2101e0 fix: local ticker search for screener (Sectors companies/ 401s on sub)
- q= now searches universe table locally (ticker + company_name LIKE, order by close) instead of calling the Sectors companies/ endpoint, which returns SUBSCRIPTION_DOES_NOT_ALLOW on the current subscription and silently fell back to the full 780-ticker universe
- removes the broken name-fill cmd + scheduler/one-shot Screen() name enrichment (wasted credits, empty names)
- Screener UI: search card says 'kode saham', results still show company name when present
2026-09-16 14:30:22 +07:00
asepharyana d7eb0a3abf feat: company names in screener + universe enrichment
CI / go test + web typecheck (push) Canceled after 0s
CI / build + deploy (Nix) — flowsight (push) Canceled after 0s
- migration 0010: universe.company_name column
- SaveUniverse persists company names; new CompanyNames() store lookup
- scheduler universe sweep + universe-sweep cmd fetch names via one Screen() call (best effort)
- /api/screen now returns real company names (live when keyed, stored as fallback)
- Screener card shows 'PT Bank ...' name under the ticker symbol for search results
2026-09-16 14:23:09 +07:00
16 changed files with 402 additions and 56 deletions

No files matched your search

+6 -2
View File
@@ -236,13 +236,17 @@ func TestDestinations(t *testing.T) {
if rec.Code != http.StatusUnprocessableEntity { if rec.Code != http.StatusUnprocessableEntity {
t.Fatalf("code = %d, want 422", rec.Code) t.Fatalf("code = %d, want 422", rec.Code)
} }
// Discord non-https -> 422. // Discord non-https or non-Discord host -> 422.
rec = doAuth(t, s, "POST", "/api/destinations", map[string]any{"kind": "discord", "webhook_url": "http://x"}) rec = doAuth(t, s, "POST", "/api/destinations", map[string]any{"kind": "discord", "webhook_url": "http://x"})
if rec.Code != http.StatusUnprocessableEntity { if rec.Code != http.StatusUnprocessableEntity {
t.Fatalf("code = %d, want 422", rec.Code) t.Fatalf("code = %d, want 422", rec.Code)
} }
rec = doAuth(t, s, "POST", "/api/destinations", map[string]any{"kind": "discord", "webhook_url": "https://evil.example/hook"})
if rec.Code != http.StatusUnprocessableEntity {
t.Fatalf("non-discord host must 422, got %d", rec.Code)
}
// Valid discord create -> 201. // Valid discord create -> 201.
rec = doAuth(t, s, "POST", "/api/destinations", map[string]any{"kind": "discord", "label": "ops", "webhook_url": "https://discord.example/hook"}) rec = doAuth(t, s, "POST", "/api/destinations", map[string]any{"kind": "discord", "label": "ops", "webhook_url": "https://discord.com/api/webhooks/123/abc"})
if rec.Code != http.StatusCreated { if rec.Code != http.StatusCreated {
t.Fatalf("code = %d, body %s", rec.Code, rec.Body.String()) t.Fatalf("code = %d, body %s", rec.Code, rec.Body.String())
} }
+27 -1
View File
@@ -134,7 +134,10 @@ func (s *Server) DeleteDestination(w http.ResponseWriter, r *http.Request) {
writeJSON(w, http.StatusOK, map[string]any{"id": id, "ok": true}) writeJSON(w, http.StatusOK, map[string]any{"id": id, "ok": true})
} }
// checkDestSecrets validates kind-appropriate secrets. // checkDestSecrets validates kind-appropriate secrets. Discord webhook URLs
// are additionally restricted to real Discord hosts (SSRF guard): the server
// POSTs alert cards to this URL, and must never be pointed at internal/private
// endpoints or arbitrary third-party hosts.
func checkDestSecrets(kind, botToken, chatID, webhookURL string) string { func checkDestSecrets(kind, botToken, chatID, webhookURL string) string {
switch kind { switch kind {
case store.DestTelegram: case store.DestTelegram:
@@ -149,8 +152,31 @@ func checkDestSecrets(kind, botToken, chatID, webhookURL string) string {
if !strings.HasPrefix(u, "https://") { if !strings.HasPrefix(u, "https://") {
return "webhook_url must be https" return "webhook_url must be https"
} }
host := u[len("https://"):]
if i := strings.IndexAny(host, "/?"); i >= 0 {
host = host[:i]
}
if !discordWebhookHost(host) {
return "webhook_url must be a discord.com/app.com webhook host"
}
default: default:
return "kind must be telegram or discord" return "kind must be telegram or discord"
} }
return "" return ""
} }
// discordWebhookHost allows only Discord's webhook API hosts (subdomains
// included). Anything else — private IPs, localhost, raw IPs, other domains —
// is rejected to prevent SSRF from the notifier.
func discordWebhookHost(host string) bool {
h := strings.ToLower(strings.TrimSpace(host))
if h == "discord.com" || h == "discordapp.com" {
return true
}
for _, suffix := range []string{".discord.com", ".discordapp.com", ".discord.gg"} {
if strings.HasSuffix(h, suffix) {
return true
}
}
return false
}
+27 -2
View File
@@ -45,10 +45,27 @@ func (s *Server) Screen(w http.ResponseWriter, r *http.Request) {
} }
// Base universe: live screener when keyed, else stored watchlist. // Base universe: live screener when keyed, else stored watchlist.
var universe []string var universe []string
if s.Cfg.HasSectorsKey() && (req.Where != "" || req.Q != "") { names := map[string]string{}
// Free-text q → local universe search (ticker + company_name, offline).
// The Sectors companies/ endpoint is not on this subscription, so remote
// screening is skipped entirely to avoid a silent full-universe fallback.
if req.Q != "" {
if hits, err := s.DB.SearchTickers(req.Q, limit*2); err == nil {
for _, h := range hits {
universe = append(universe, h.Symbol)
if h.CompanyName != "" {
names[h.Symbol] = h.CompanyName
}
}
}
} else if s.Cfg.HasSectorsKey() && req.Where != "" {
if rows, err := s.Sectors.Screen(r.Context(), req.Where, req.Q, limit*2, 0); err == nil { if rows, err := s.Sectors.Screen(r.Context(), req.Where, req.Q, limit*2, 0); err == nil {
for _, row := range rows { for _, row := range rows {
universe = append(universe, strings.ToUpper(strings.TrimSuffix(row.Symbol, ".JK"))) tk := strings.ToUpper(strings.TrimSuffix(row.Symbol, ".JK"))
universe = append(universe, tk)
if row.CompanyName != "" {
names[tk] = row.CompanyName
}
} }
} }
} }
@@ -61,10 +78,18 @@ func (s *Server) Screen(w http.ResponseWriter, r *http.Request) {
universe = s.Cfg.Watchlist universe = s.Cfg.Watchlist
} }
} }
// Fall back to stored company names when offline (universe table).
storedNames, _ := s.DB.CompanyNames(universe)
for tk, nm := range storedNames {
names[tk] = nm
}
} }
var rows []ScreenRow var rows []ScreenRow
for _, tk := range universe { for _, tk := range universe {
row := s.scoreTicker(tk) row := s.scoreTicker(tk)
if nm := names[tk]; nm != "" {
row.Name = nm
}
if req.Institutional != nil { if req.Institutional != nil {
inst := req.Institutional inst := req.Institutional
if b, _ := row.Breakdown["broker_score"].(float64); b < inst.BrokerScoreMin { if b, _ := row.Breakdown["broker_score"].(float64); b < inst.BrokerScoreMin {
+10
View File
@@ -63,6 +63,16 @@ func New(cfg config.Config, db *store.DB, cache *store.Cache, s *sectors.Client)
func (s *Server) Router() http.Handler { func (s *Server) Router() http.Handler {
r := chi.NewRouter() r := chi.NewRouter()
r.Use(middleware.Logger, middleware.Recoverer, middleware.Heartbeat("/ping")) r.Use(middleware.Logger, middleware.Recoverer, middleware.Heartbeat("/ping"))
// Cap request bodies (1 MiB) so large POSTs cannot exhaust memory.
// JSON bodies here are tiny (auth, screen filters, chat prompts).
r.Use(func(next http.Handler) http.Handler {
return http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
if req.Body != nil && (req.Method == http.MethodPost || req.Method == http.MethodPut || req.Method == http.MethodPatch) {
req.Body = http.MaxBytesReader(w, req.Body, 1<<20)
}
next.ServeHTTP(w, req)
})
})
r.Route("/api", func(r chi.Router) { r.Route("/api", func(r chi.Router) {
r.Get("/health", s.Health) r.Get("/health", s.Health)
r.Get("/auth/start", s.AuthStart) r.Get("/auth/start", s.AuthStart)
+23 -23
View File
@@ -3,6 +3,7 @@ package reports
import ( import (
"bytes" "bytes"
"fmt" "fmt"
"html"
"strings" "strings"
"time" "time"
@@ -29,18 +30,21 @@ func (r Report) ToMarkdown() string {
return b.String() return b.String()
} }
// ToHTML renders the report as a standalone page. // ToHTML renders the report as a standalone page. All dynamic values are
// HTML-escaped — bodies come from stored snapshots/LLM and must never be able
// to inject script into the exported file.
func (r Report) ToHTML() string { func (r Report) ToHTML() string {
esc := html.EscapeString
var b strings.Builder var b strings.Builder
b.WriteString(`<!doctype html><html><head><meta charset="utf-8"><title>`) b.WriteString("<!doctype html><html><head><meta charset=\"utf-8\"><title>")
b.WriteString(r.Ticker + " — FlowSight Report</title></head><body>") b.WriteString(esc(r.Ticker) + " — FlowSight Report</title></head><body>")
fmt.Fprintf(&b, "<h1>%s — FlowSight Report (%s)</h1>", r.Ticker, r.GeneratedAt) fmt.Fprintf(&b, "<h1>%s — FlowSight Report (%s)</h1>", esc(r.Ticker), esc(r.GeneratedAt))
for _, s := range r.Sections { for _, s := range r.Sections {
fmt.Fprintf(&b, "<h2>%s</h2><p>%s</p>", s.Name, s.Body) fmt.Fprintf(&b, "<h2>%s</h2><p>%s</p>", esc(s.Name), esc(s.Body))
if len(s.Citations) > 0 { if len(s.Citations) > 0 {
b.WriteString("<ul>") b.WriteString("<ul>")
for _, c := range s.Citations { for _, c := range s.Citations {
fmt.Fprintf(&b, "<li>%s %s @ %s</li>", c.Endpoint, c.Ticker, c.SnapshotAt) fmt.Fprintf(&b, "<li>%s %s @ %s</li>", esc(c.Endpoint), esc(c.Ticker), esc(c.SnapshotAt))
} }
b.WriteString("</ul>") b.WriteString("</ul>")
} }
@@ -50,25 +54,31 @@ func (r Report) ToHTML() string {
} }
// ToPDF renders the report server-side (pure Go, no system deps). // ToPDF renders the report server-side (pure Go, no system deps).
// Font: DejaVuSans (Unicode) instead of core Helvetica so Indonesian text
// (Em-dash, quotes, Rp, accents) renders correctly — latin1() was turning
// every non-Latin rune into '?'.
func (r Report) ToPDF() ([]byte, error) { func (r Report) ToPDF() ([]byte, error) {
pdf := gofpdf.New("P", "mm", "A4", "") pdf := gofpdf.New("P", "mm", "A4", "")
pdf.SetFontLocation("/usr/share/fonts/truetype/dejavu/")
pdf.AddUTF8Font("DejaVu", "", "DejaVuSans.ttf")
pdf.AddUTF8Font("DejaVu", "B", "DejaVuSans-Bold.ttf")
pdf.AddPage() pdf.AddPage()
pdf.SetFont("Helvetica", "B", 16) pdf.SetFont("DejaVu", "B", 14)
pdf.Cell(0, 10, r.Ticker+" — FlowSight Report") pdf.Cell(0, 10, r.Ticker+" — FlowSight Report")
pdf.Ln(12) pdf.Ln(12)
pdf.SetFont("Helvetica", "", 10) pdf.SetFont("DejaVu", "", 10)
pdf.Cell(0, 6, "Generated "+r.GeneratedAt) pdf.Cell(0, 6, "Generated "+r.GeneratedAt)
pdf.Ln(8) pdf.Ln(8)
for _, s := range r.Sections { for _, s := range r.Sections {
pdf.SetFont("Helvetica", "B", 12) pdf.SetFont("DejaVu", "B", 12)
pdf.Cell(0, 8, s.Name) pdf.Cell(0, 8, s.Name)
pdf.Ln(8) pdf.Ln(8)
pdf.SetFont("Helvetica", "", 10) pdf.SetFont("DejaVu", "", 10)
pdf.MultiCell(0, 5, latin1(s.Body), "", "", false) pdf.MultiCell(0, 5, s.Body, "", "", false)
if len(s.Citations) > 0 { if len(s.Citations) > 0 {
pdf.SetFont("Helvetica", "I", 8) pdf.SetFont("DejaVu", "", 8)
for _, c := range s.Citations { for _, c := range s.Citations {
pdf.MultiCell(0, 4, latin1(c.Endpoint+" "+c.Ticker+" @ "+c.SnapshotAt), "", "", false) pdf.MultiCell(0, 4, c.Endpoint+" "+c.Ticker+" @ "+c.SnapshotAt, "", "", false)
} }
} }
pdf.Ln(4) pdf.Ln(4)
@@ -79,13 +89,3 @@ func (r Report) ToPDF() ([]byte, error) {
} }
return buf.Bytes(), nil return buf.Bytes(), nil
} }
// latin1 drops non-latin runes gofpdf core fonts cannot render.
func latin1(s string) string {
return strings.Map(func(r rune) rune {
if r > 255 {
return '?'
}
return r
}, s)
}
+21 -2
View File
@@ -12,6 +12,7 @@ import (
"log" "log"
"net/url" "net/url"
"strconv" "strconv"
"strings"
"time" "time"
"github.com/robfig/cron/v3" "github.com/robfig/cron/v3"
@@ -295,13 +296,31 @@ func (s *Scheduler) universe(ctx context.Context) error {
} }
// market pulls top-changes (1 class x 2 periods), most-traded, idx-total, // market pulls top-changes (1 class x 2 periods), most-traded, idx-total,
// brokers/top — the cheap context block of the cycle. // brokers/top — the cheap context block of the cycle. The top-changes call
// also enriches universe company names (MoverRow.Name) at no extra credit —
// n_stock is free; cost is classes×periods only.
func (s *Scheduler) market(ctx context.Context) error { func (s *Scheduler) market(ctx context.Context) error {
if g, l, err := s.Sectors.TopChanges(ctx, if g, l, err := s.Sectors.TopChanges(ctx,
[]string{"top_gainers"}, []string{"1d", "7d"}, "", 5); err == nil { []string{"top_gainers"}, []string{"1d", "7d"}, "", 750); err == nil {
if raw, err := json.Marshal(map[string]any{"top_gainers": g, "top_losers": l}); err == nil { if raw, err := json.Marshal(map[string]any{"top_gainers": g, "top_losers": l}); err == nil {
_ = s.DB.SaveSnapshot("IDX", time.Now().Format("2006-01-02"), "top-changes", string(raw)) _ = s.DB.SaveSnapshot("IDX", time.Now().Format("2006-01-02"), "top-changes", string(raw))
} }
// Capture company names from whatever mover rows came back.
names := map[string]string{}
collect := func(rows map[string][]sectors.MoverRow) {
for _, rs := range rows {
for _, r := range rs {
if r.Name != "" {
names[strings.TrimSuffix(r.Symbol, ".JK")] = r.Name
}
}
}
}
collect(g)
collect(l)
if err := s.DB.SetCompanyNames(names); err != nil {
log.Printf("scheduler: set company names: %v", err)
}
} else { } else {
return err return err
} }
@@ -0,0 +1,2 @@
-- 0010_universe_names.sql: company names for screener display.
ALTER TABLE universe ADD COLUMN company_name TEXT NOT NULL DEFAULT '';
+87 -2
View File
@@ -629,6 +629,7 @@ type UniverseRow struct {
Symbol string Symbol string
Close int64 Close int64
Date string Date string
CompanyName string
} }
func (db *DB) SaveUniverse(rows []UniverseRow) error { func (db *DB) SaveUniverse(rows []UniverseRow) error {
@@ -644,14 +645,98 @@ func (db *DB) SaveUniverse(rows []UniverseRow) error {
// Normalize: API returns "BBCA.JK" — strip the suffix so it matches // Normalize: API returns "BBCA.JK" — strip the suffix so it matches
// watchlist/depth keys (BBCA) everywhere. // watchlist/depth keys (BBCA) everywhere.
t := strings.TrimSuffix(r.Symbol, ".JK") t := strings.TrimSuffix(r.Symbol, ".JK")
if _, err := tx.Exec(`INSERT OR IGNORE INTO universe(ticker, close, date) VALUES(?,?,?)`, if _, err := tx.Exec(`INSERT OR IGNORE INTO universe(ticker, close, date, company_name) VALUES(?,?,?,?)`,
t, r.Close, r.Date); err != nil { t, r.Close, r.Date, r.CompanyName); err != nil {
return err return err
} }
} }
return tx.Commit() return tx.Commit()
} }
// CompanyNames returns the company name map for the given tickers (from the
// universe table). Tickers with no stored name are omitted.
func (db *DB) CompanyNames(tickers []string) (map[string]string, error) {
if len(tickers) == 0 {
return map[string]string{}, nil
}
ph := strings.Repeat("?,", len(tickers))
ph = ph[:len(ph)-1]
args := make([]any, len(tickers))
for i, t := range tickers {
args[i] = t
}
rows, err := db.Query(`SELECT ticker, company_name FROM universe
WHERE company_name != '' AND ticker IN (`+ph+`)`, args...)
if err != nil {
return nil, err
}
defer rows.Close()
out := map[string]string{}
for rows.Next() {
var t, nm string
if err := rows.Scan(&t, &nm); err != nil {
return nil, err
}
out[t] = nm
}
return out, rows.Err()
}
// SetCompanyNames bulk-upserts company_name for tickers (from top-changes
// snapshots). Only non-empty names are written; existing names win (skip
// blank overwrite) so a later richer source doesn't clobber a good one.
func (db *DB) SetCompanyNames(names map[string]string) error {
if len(names) == 0 {
return nil
}
tx, err := db.Begin()
if err != nil {
return err
}
defer tx.Rollback()
for t, nm := range names {
nm = strings.TrimSpace(nm)
if nm == "" || strings.EqualFold(nm, t) {
continue
}
if _, err := tx.Exec(`UPDATE universe SET company_name = ? WHERE ticker = ? AND company_name = ''`, nm, t); err != nil {
return err
}
}
return tx.Commit()
}
// TickerHit is one local search result over the universe table.
type TickerHit struct {
Symbol string
CompanyName string
}
// SearchTickers finds universe tickers matching q in ticker or company_name
// (case-insensitive), most-traded first. Works offline — no Sectors API call.
func (db *DB) SearchTickers(q string, limit int) ([]TickerHit, error) {
if limit <= 0 {
limit = 20
}
like := "%" + strings.ToUpper(strings.TrimSpace(q)) + "%"
rows, err := db.Query(`SELECT ticker, company_name FROM universe
WHERE ticker LIKE ? OR UPPER(company_name) LIKE ?
ORDER BY close DESC LIMIT ?`, like, like, limit)
if err != nil {
return nil, err
}
defer rows.Close()
var out []TickerHit
for rows.Next() {
var h TickerHit
if err := rows.Scan(&h.Symbol, &h.CompanyName); err != nil {
return nil, err
}
out = append(out, h)
}
return out, rows.Err()
}
// AddWatch inserts a ticker (idempotent). // AddWatch inserts a ticker (idempotent).
func (db *DB) AddWatch(userKey, ticker string) error { func (db *DB) AddWatch(userKey, ticker string) error {
_, err := db.Exec(`INSERT INTO watchlists(user_key,ticker,added_at) VALUES(?,?,?) _, err := db.Exec(`INSERT INTO watchlists(user_key,ticker,added_at) VALUES(?,?,?)
+92
View File
@@ -107,3 +107,95 @@ func TestDestinationCRUD(t *testing.T) {
t.Fatal("double delete must report false") t.Fatal("double delete must report false")
} }
} }
// Universe save + local ticker search + company-name lookup.
func TestUniverseSearch(t *testing.T) {
db, err := Open(t.TempDir() + "/univ.db")
if err != nil {
t.Fatal(err)
}
defer db.Close()
uni := []UniverseRow{
{Symbol: "BBCA.JK", Close: 100, Date: "2026-09-16", CompanyName: "PT Bank Central Asia Tbk"},
{Symbol: "TLKM.JK", Close: 90, Date: "2026-09-16"},
{Symbol: "BBRI.JK", Close: 80, Date: "2026-09-16", CompanyName: "PT Bank Rakyat Indonesia"},
}
if err := db.SaveUniverse(uni); err != nil {
t.Fatal(err)
}
// Search by ticker prefix (case-insensitive).
hits, err := db.SearchTickers("bca", 10)
if err != nil {
t.Fatal(err)
}
if len(hits) != 1 || hits[0].Symbol != "BBCA" {
t.Fatalf("bca hits = %+v, want BBCA", hits)
}
// Search by company name.
hits, err = db.SearchTickers("bank", 10)
if err != nil {
t.Fatal(err)
}
if len(hits) != 2 {
t.Fatalf("bank hits = %d, want 2 (BBCA+BBRI by name)", len(hits))
}
// .JK stripped on save, order by close desc.
if hits[0].Symbol != "BBCA" || hits[1].Symbol != "BBRI" {
t.Fatalf("bank order = %s,%s, want BBCA,BBRI", hits[0].Symbol, hits[1].Symbol)
}
// CompanyNames returns only tickers with stored names.
names, err := db.CompanyNames([]string{"BBCA", "TLKM", "BBRI"})
if err != nil {
t.Fatal(err)
}
if names["BBCA"] != "PT Bank Central Asia Tbk" || names["BBRI"] != "PT Bank Rakyat Indonesia" {
t.Fatalf("names = %+v, want BBCA+BBRI only", names)
}
if _, ok := names["TLKM"]; ok {
t.Fatal("TLKM has no name, must be omitted")
}
}
// SetCompanyNames fills blank names; never overwrites existing ones; skips
// blanks and ticker-equal names.
func TestSetCompanyNames(t *testing.T) {
db, err := Open(t.TempDir() + "/names.db")
if err != nil {
t.Fatal(err)
}
defer db.Close()
uni := []UniverseRow{
{Symbol: "BBCA.JK", Close: 100, Date: "2026-09-16", CompanyName: "PT Bank Central Asia Tbk"},
{Symbol: "TLKM.JK", Close: 90, Date: "2026-09-16"},
{Symbol: "BBRI.JK", Close: 80, Date: "2026-09-16"},
}
if err := db.SaveUniverse(uni); err != nil {
t.Fatal(err)
}
// Fill TLKM + BBRI; BBCA already has a name (must NOT be clobbered);
// "UNVR" would be a new row (INSERT OR IGNORE means it's skipped).
err = db.SetCompanyNames(map[string]string{
"TLKM": "PT Telkom Indonesia (Persero) Tbk",
"BBRI": "PT Bank Rakyat Indonesia (Persero) Tbk",
"BBCA": "SHOULD NOT OVERWRITE",
"UNVR": "PT Unilever Indonesia Tbk",
"EMTK": "PT Elang Mahkota Teknologi Tbk", // no universe row -> no-op
"BLAH": "BLAH", // ticker-equal -> skip
})
if err != nil {
t.Fatal(err)
}
names, err := db.CompanyNames([]string{"BBCA", "TLKM", "BBRI", "UNVR"})
if err != nil {
t.Fatal(err)
}
if names["BBCA"] != "PT Bank Central Asia Tbk" {
t.Fatalf("BBCA clobbered: %q", names["BBCA"])
}
if names["TLKM"] != "PT Telkom Indonesia (Persero) Tbk" || names["BBRI"] != "PT Bank Rakyat Indonesia (Persero) Tbk" {
t.Fatalf("names = %+v, want TLKM+BBRI filled", names)
}
if _, ok := names["UNVR"]; ok {
t.Fatal("UNVR not in universe must be absent")
}
}
+12 -3
View File
@@ -36,7 +36,9 @@ export function WatchlistDrawer() {
</div> </div>
<Show when={err()}><p class="text-xs text-destructive">{err()}</p></Show> <Show when={err()}><p class="text-xs text-destructive">{err()}</p></Show>
<ul class="flex flex-wrap gap-1.5"> <ul class="flex flex-wrap gap-1.5">
<Show when={(wl()?.watchlist || []).length} fallback={<li class="text-xs text-muted-foreground">Ketik kode saham lalu Add — mis. BBCA, TLKM, BBRI.</li>}>
<For each={wl()?.watchlist || []}>{(t) => <li class="flex items-center gap-1"><a href={`/report/${encodeURIComponent(t)}`}><Badge variant="secondary">{t}</Badge></a> <button class="text-xs text-muted-foreground hover:text-foreground" aria-label={`Hapus ${t} dari watchlist`} onClick={() => del(t)}>×</button></li>}</For> <For each={wl()?.watchlist || []}>{(t) => <li class="flex items-center gap-1"><a href={`/report/${encodeURIComponent(t)}`}><Badge variant="secondary">{t}</Badge></a> <button class="text-xs text-muted-foreground hover:text-foreground" aria-label={`Hapus ${t} dari watchlist`} onClick={() => del(t)}>×</button></li>}</For>
</Show>
</ul> </ul>
</CardContent> </CardContent>
</Card> </Card>
@@ -45,7 +47,7 @@ export function WatchlistDrawer() {
export function ChatSidebar() { export function ChatSidebar() {
const [msg, setMsg] = createSignal(""); const [msg, setMsg] = createSignal("");
const [log, setLog] = createSignal<{ q: string; a: string }[]>([]); const [log, setLog] = createSignal<{ q: string; a: string; err?: boolean }[]>([]);
async function send() { async function send() {
const q = msg().trim(); const q = msg().trim();
if (!q) return; if (!q) return;
@@ -54,18 +56,25 @@ export function ChatSidebar() {
const r = await api.chat(q); const r = await api.chat(q);
setLog((p) => [...p, { q, a: r.answer }].slice(-10)); setLog((p) => [...p, { q, a: r.answer }].slice(-10));
} catch (e) { } catch (e) {
setLog((p) => [...p, { q, a: String(e) }].slice(-10)); setLog((p) => [...p, { q, a: String(e), err: true }].slice(-10));
} }
} }
return ( return (
<Card> <Card>
<CardHeader class="pb-2"><CardTitle class="text-base">AI Chat</CardTitle></CardHeader> <CardHeader class="pb-2"><CardTitle class="text-base">AI Chat</CardTitle></CardHeader>
<CardContent class="space-y-2"> <CardContent class="space-y-2">
<Show when={log().length} fallback={<p class="text-xs text-muted-foreground">Tanya soal watchlist-mu — sistem jawab dari data yang tersimpan (bukan karangan).</p>}>
<div class="max-h-64 space-y-2 overflow-y-auto"> <div class="max-h-64 space-y-2 overflow-y-auto">
<For each={log()}> <For each={log()}>
{(m) => <div class="text-sm"><p><strong>You:</strong> {m.q}</p><p class="text-muted-foreground">{m.a.slice(0, 500)}</p></div>} {(m) => (
<div class="text-sm">
<p><strong>You:</strong> {m.q}</p>
<p classList={{ "text-muted-foreground": !m.err, "text-destructive": !!m.err }}>{m.a.slice(0, 500)}</p>
</div>
)}
</For> </For>
</div> </div>
</Show>
<div class="flex gap-2"> <div class="flex gap-2">
<label class="sr-only" for="chat-msg">Tanya AI</label> <label class="sr-only" for="chat-msg">Tanya AI</label>
<TextField class="flex-1"><TextFieldInput id="chat-msg" placeholder="Ask about your watchlist…" value={msg()} onInput={(e) => setMsg(e.currentTarget.value)} onKeyDown={(e: KeyboardEvent) => { if (e.key === "Enter") send(); }} /></TextField> <TextField class="flex-1"><TextFieldInput id="chat-msg" placeholder="Ask about your watchlist…" value={msg()} onInput={(e) => setMsg(e.currentTarget.value)} onKeyDown={(e: KeyboardEvent) => { if (e.key === "Enter") send(); }} /></TextField>
+31 -13
View File
@@ -27,17 +27,24 @@ function Nav(props: { loggedIn: boolean }) {
const loc = useLocation(); const loc = useLocation();
// Belum login: hanya Dashboard yg terlihat (fitur lain di-hide). // Belum login: hanya Dashboard yg terlihat (fitur lain di-hide).
const items = () => props.loggedIn ? NAV_ALL : NAV_ALL.slice(0, 1); const items = () => props.loggedIn ? NAV_ALL : NAV_ALL.slice(0, 1);
const isActive = (href: string) => loc.pathname === href || (href !== "/" && loc.pathname.startsWith(href));
return ( return (
<nav class="flex w-56 shrink-0 flex-col gap-1 border-r bg-card p-4 max-lg:hidden"> <nav class="flex w-56 shrink-0 flex-col gap-1 border-r bg-card p-4 max-lg:hidden">
<div class="mb-4 px-2 text-xl font-bold tracking-tight"> <div class="mb-5 px-2">
<a href="/" class="flex items-center gap-2 text-xl font-bold tracking-tight">
<span class="grid size-7 place-items-center rounded-lg bg-primary text-sm text-primary-foreground">📈</span>
Flow<span class="text-primary">Sight</span> Flow<span class="text-primary">Sight</span>
</a>
</div> </div>
{items().map((n) => ( {items().map((n) => (
<a <a
href={n.href} href={n.href}
class={`flex items-center gap-2 rounded-md px-3 py-2 text-sm font-medium transition-colors hover:bg-accent hover:text-accent-foreground ${loc.pathname === n.href ? "bg-accent text-accent-foreground" : "text-muted-foreground"}`} class={`relative flex items-center gap-2.5 rounded-lg px-3 py-2 text-sm font-medium transition-colors hover:bg-accent hover:text-accent-foreground ${isActive(n.href) ? "bg-accent text-accent-foreground" : "text-muted-foreground"}`}
> >
<span>{n.icon}</span> {n.label} <span class="text-base leading-none">{n.icon}</span> {n.label}
<Show when={isActive(n.href)}>
<span class="absolute left-0 top-1/2 h-5 w-0.5 -translate-y-1/2 rounded-full bg-primary" />
</Show>
</a> </a>
))} ))}
</nav> </nav>
@@ -64,18 +71,25 @@ function MobileNav(props: { loggedIn: boolean }) {
function TickerSearch(props: { loggedIn: boolean }) { function TickerSearch(props: { loggedIn: boolean }) {
const nav = useNavigate(); const nav = useNavigate();
const [q, setQ] = createSignal(""); const [q, setQ] = createSignal("");
const go = () => { const go = (t: string) => {
const t = q().toUpperCase().trim(); const v = t.toUpperCase().trim();
// Report butuh login: arahkan yg belum login ke /login. // Report butuh login: arahkan yg belum login ke /login.
if (t) nav(props.loggedIn ? `/report/${t}` : "/login"); if (v) nav(props.loggedIn ? `/report/${v}` : "/login");
}; };
return ( return (
<form class="flex max-w-sm flex-1 items-center gap-2" onSubmit={(e) => { e.preventDefault(); go(); }}> <form class="flex max-w-sm flex-1 items-center gap-2" onSubmit={(e) => { e.preventDefault(); go(q()); }}>
<TextField class="flex-1"> <div class="relative flex-1">
<TextFieldInput placeholder="Ticker → report (e.g. BBCA)" value={q()} <TextFieldInput
onInput={(e) => setQ(e.currentTarget.value)} /> placeholder="Cari kode saham…"
</TextField> value={q()}
<Button type="submit" variant="secondary">Open</Button> aria-label="Cari kode saham"
onInput={(e) => setQ(e.currentTarget.value)}
onKeyDown={(e: KeyboardEvent) => { if (e.key === "Enter") { e.preventDefault(); go(q()); } }}
class="h-9 pr-8"
/>
<span class="pointer-events-none absolute right-2.5 top-1/2 -translate-y-1/2 text-sm text-muted-foreground">🔍</span>
</div>
<Button type="submit" variant="secondary" class="h-9 px-3">Buka</Button>
</form> </form>
); );
} }
@@ -99,7 +113,11 @@ function LoginPage() {
finally { setBusy(false); } finally { setBusy(false); }
} }
return ( return (
<div class="mx-auto max-w-md py-[8vh]"> <div class="mx-auto flex min-h-[70vh] w-full max-w-md flex-col justify-center py-[6vh]">
<div class="mb-6 flex items-center justify-center gap-2 text-2xl font-bold tracking-tight">
<span class="grid size-9 place-items-center rounded-xl bg-primary text-lg text-primary-foreground">📈</span>
Flow<span class="text-primary">Sight</span>
</div>
<Card> <Card>
<CardHeader class="text-center"> <CardHeader class="text-center">
<CardTitle class="text-2xl">Masuk ke FlowSight 👋</CardTitle> <CardTitle class="text-2xl">Masuk ke FlowSight 👋</CardTitle>
+11 -2
View File
@@ -50,6 +50,11 @@ function AlertsInner() {
refetchDests(); refetchDests();
} catch (e) { setDerr(String(e)); } } catch (e) { setDerr(String(e)); }
} }
const fmtDate = (s: unknown) => {
const t = String(s || "");
const d = new Date(t);
return Number.isNaN(d.getTime()) ? t : d.toLocaleString("id-ID", { day: "numeric", month: "short", hour: "2-digit", minute: "2-digit" });
};
async function toggleDest(id: number, enabled: boolean) { try { await api.updateDestination(id, { enabled: !enabled }); refetchDests(); } catch (e) { setDerr(String(e)); } } async function toggleDest(id: number, enabled: boolean) { try { await api.updateDestination(id, { enabled: !enabled }); refetchDests(); } catch (e) { setDerr(String(e)); } }
async function delDest(id: number) { try { await api.deleteDestination(id); refetchDests(); } catch (e) { setDerr(String(e)); } } async function delDest(id: number) { try { await api.deleteDestination(id); refetchDests(); } catch (e) { setDerr(String(e)); } }
return ( return (
@@ -111,7 +116,11 @@ function AlertsInner() {
<CardHeader><CardTitle>Notifikasi terpasang</CardTitle></CardHeader> <CardHeader><CardTitle>Notifikasi terpasang</CardTitle></CardHeader>
<CardContent> <CardContent>
<Show when={(alerts()?.alerts || []).length} fallback={<EmptyState icon="🔔" title="Belum ada" hint="Pilih template di atas, sekali klik." />}> <Show when={(alerts()?.alerts || []).length} fallback={<EmptyState icon="🔔" title="Belum ada" hint="Pilih template di atas, sekali klik." />}>
<ul class="space-y-1.5 text-sm"><For each={alerts()?.alerts || []}>{(a) => <li class="flex items-center gap-2">{a.name} <span class="text-muted-foreground">terakhir: {a.last_fired || "belum pernah"}</span><span class="flex-1" /><Button variant="destructive" size="sm" onClick={() => del(a.id)}>Hapus</Button></li>}</For></ul> <ul class="space-y-1.5 text-sm"><For each={alerts()?.alerts || []}>{(a) => <li class="flex flex-wrap items-center gap-2">
{a.name}
<span class="text-muted-foreground">terakhir: {a.last_fired ? fmtDate(a.last_fired) : "belum pernah"}</span>
<span class="flex-1" /><Button variant="destructive" size="sm" onClick={() => del(a.id)}>Hapus</Button>
</li>}</For></ul>
</Show> </Show>
</CardContent> </CardContent>
</Card> </Card>
@@ -122,7 +131,7 @@ function AlertsInner() {
</CardHeader> </CardHeader>
<CardContent> <CardContent>
<Show when={(events() || []).length} fallback={<p class="text-sm text-muted-foreground">Belum ada kejadian.</p>}> <Show when={(events() || []).length} fallback={<p class="text-sm text-muted-foreground">Belum ada kejadian.</p>}>
<ul class="space-y-1.5 text-sm"><For each={events() || []}>{(e) => <li><Badge variant="secondary">{String(e.ticker)}</Badge> {String(e.message)}</li>}</For></ul> <ul class="space-y-1.5 text-sm"><For each={events() || []}>{(e) => <li class="flex items-start gap-2"><Badge variant="secondary">{String(e.ticker)}</Badge><span class="min-w-0 flex-1">{String(e.message)}</span><span class="shrink-0 text-xs text-muted-foreground">{fmtDate(e.date)}</span></li>}</For></ul>
</Show> </Show>
</CardContent> </CardContent>
</Card> </Card>
+14 -2
View File
@@ -38,13 +38,20 @@ export default function Dashboard() {
}; };
const sorotan = () => (screen()?.rows || []).map((r) => ({ row: r, ...verdictFor(r) })); const sorotan = () => (screen()?.rows || []).map((r) => ({ row: r, ...verdictFor(r) }));
const closeMap = () => Object.fromEntries((flow()?.closes || []).map((c) => [c.ticker, c])); const closeMap = () => Object.fromEntries((flow()?.closes || []).map((c) => [c.ticker, c]));
// Resolve theme-aware primary color (falls back to blue) so the chart
// matches light/dark instead of a hardcoded hex.
const primaryColor = () => {
const c = getComputedStyle(document.documentElement).getPropertyValue("--primary");
const [h, s, l] = c.trim().split(/[\s,]+/).map(Number);
return Number.isFinite(h) && Number.isFinite(s) && Number.isFinite(l) ? `hsl(${h} ${s}% ${l}%)` : "#3b82f6";
};
const chartData = () => ({ const chartData = () => ({
labels: (foreign()?.dates || []) as string[], labels: (foreign()?.dates || []) as string[],
datasets: [{ datasets: [{
label: `${chartTiker()} — uang asing harian (Rp juta)`, label: `${chartTiker()} — uang asing harian (Rp juta)`,
data: (foreign()?.nets || []) as number[], data: (foreign()?.nets || []) as number[],
borderColor: "#3b82f6", borderColor: primaryColor(),
backgroundColor: "rgba(59,130,246,.15)", backgroundColor: "transparent",
fill: true, fill: true,
tension: 0.25, tension: 0.25,
}], }],
@@ -99,10 +106,15 @@ export default function Dashboard() {
return ( return (
<Card class={s.verdict === "Dilirik" ? "border-emerald-500/50" : s.verdict === "Dilepas" ? "border-red-500/50" : ""}> <Card class={s.verdict === "Dilirik" ? "border-emerald-500/50" : s.verdict === "Dilepas" ? "border-red-500/50" : ""}>
<CardHeader class="flex flex-row items-center justify-between space-y-0 pb-2"> <CardHeader class="flex flex-row items-center justify-between space-y-0 pb-2">
<div>
<CardTitle class="text-xl font-bold"> <CardTitle class="text-xl font-bold">
{s.row.symbol} {s.row.symbol}
<Show when={cx?.close}><span class="ml-2 font-mono text-sm font-normal text-muted-foreground">{fmtHarga(cx.close)}</span></Show> <Show when={cx?.close}><span class="ml-2 font-mono text-sm font-normal text-muted-foreground">{fmtHarga(cx.close)}</span></Show>
</CardTitle> </CardTitle>
<Show when={s.row.name && s.row.name !== s.row.symbol}>
<p class="text-xs text-muted-foreground">{s.row.name}</p>
</Show>
</div>
<VerdictBadge verdict={s.verdict} /> <VerdictBadge verdict={s.verdict} />
</CardHeader> </CardHeader>
<CardContent class="space-y-3"> <CardContent class="space-y-3">
+14 -1
View File
@@ -31,9 +31,22 @@ function PortfolioInner() {
if (top.weight > 0.4) return `${top.ticker} porsinya ${(top.weight * 100).toFixed(0)}% — kebanyakan telur di satu keranjang. Pertimbangkan tambah saham beda sektor.`; if (top.weight > 0.4) return `${top.ticker} porsinya ${(top.weight * 100).toFixed(0)}% — kebanyakan telur di satu keranjang. Pertimbangkan tambah saham beda sektor.`;
return "Sebarannya sudah lumayan — tidak numpuk di satu tempat. Pertahankan. 👍"; return "Sebarannya sudah lumayan — tidak numpuk di satu tempat. Pertahankan. 👍";
}; };
const primaryColor = () => {
const c = getComputedStyle(document.documentElement).getPropertyValue("--primary");
const [h, s, l] = c.trim().split(/[\s,]+/).map(Number);
return Number.isFinite(h) && Number.isFinite(s) && Number.isFinite(l) ? `hsl(${h} ${s}% ${l}%)` : "#3b82f6";
};
const chartData = () => ({ const chartData = () => ({
labels: conc().map((c) => c.ticker), labels: conc().map((c) => c.ticker),
datasets: [{ label: "Porsi %", data: conc().map((c) => +(c.weight * 100).toFixed(1)) }], datasets: [{
label: "Porsi %",
data: conc().map((c) => +(c.weight * 100).toFixed(1)),
backgroundColor: conc().map((_, i) => {
const alphas = ["88", "66", "44", "33", "22"];
return `${primaryColor()}${alphas[i % alphas.length]}`;
}),
borderRadius: 4,
}],
}); });
return ( return (
<div class="space-y-4"> <div class="space-y-4">
+18 -1
View File
@@ -30,6 +30,13 @@ function RoutinesInner() {
catch (e) { setErr(String(e)); } catch (e) { setErr(String(e)); }
finally { setBusy(false); } finally { setBusy(false); }
} }
const fmtTime = (s: unknown) => {
const t = String(s || "");
if (!t) return "—";
// ISO timestamp → "16 Sep 07:30" (local time).
const d = new Date(t);
return Number.isNaN(d.getTime()) ? t : d.toLocaleString("id-ID", { day: "numeric", month: "short", hour: "2-digit", minute: "2-digit" });
};
async function toggle(id: number, enabled: boolean) { async function toggle(id: number, enabled: boolean) {
try { await api.updateRoutine(id, { enabled: !enabled }); refetch(); } catch (e) { setErr(String(e)); } try { await api.updateRoutine(id, { enabled: !enabled }); refetch(); } catch (e) { setErr(String(e)); }
} }
@@ -93,7 +100,17 @@ function RoutinesInner() {
<Button variant="ghost" size="sm" onClick={() => refetchRuns()}>Refresh</Button> <Button variant="ghost" size="sm" onClick={() => refetchRuns()}>Refresh</Button>
</CardHeader> </CardHeader>
<CardContent> <CardContent>
<ul class="space-y-1 text-sm text-muted-foreground"><For each={runs() || []}>{(r) => <li>{String(r.started_at)} — {String(r.status)}</li>}</For></ul> <ul class="space-y-1 text-sm text-muted-foreground">
<For each={runs() || []}>{(r) => (
<li class="flex items-center justify-between gap-2">
<span class="flex items-center gap-2">
<Badge variant={r.status === "ok" ? "success" : r.status === "error" ? "error" : "secondary"} class="capitalize">{String(r.status)}</Badge>
<span>{fmtTime(r.started_at)}</span>
</span>
<span class="font-mono text-xs">{r.credits_used ? `${String(r.credits_used)} kredit` : `#${String(r.routine_id)}`}</span>
</li>
)}</For>
</ul>
</CardContent> </CardContent>
</Card> </Card>
</div> </div>
+7 -2
View File
@@ -62,9 +62,9 @@ function ScreenerInner() {
</Card> </Card>
)}</For> )}</For>
<Card class={showCustom() ? "border-primary" : ""}> <Card class={showCustom() ? "border-primary" : ""}>
<CardHeader class="pb-2"><CardTitle class="text-base">🔎 Cari nama / sektor sendiri</CardTitle><CardDescription>Ketik nama perusahaan atau sektor (mis. "bank", "energi").</CardDescription></CardHeader> <CardHeader class="pb-2"><CardTitle class="text-base">🔎 Cari kode saham</CardTitle><CardDescription>Ketik kode saham atau nama (mis. "bca", "tlkm", "bank").</CardDescription></CardHeader>
<CardContent class="flex gap-2"> <CardContent class="flex gap-2">
<TextField class="flex-1"><TextFieldInput placeholder="mis. bank, bca, energi…" value={q()} onInput={(e) => { setQ(e.currentTarget.value); setShowCustom(true); }} onKeyDown={(e: KeyboardEvent) => { if (e.key === "Enter") runCustom(); }} /></TextField> <TextField class="flex-1"><TextFieldInput placeholder="mis. bca, tlkm, bbri…" value={q()} onInput={(e) => { setQ(e.currentTarget.value); setShowCustom(true); }} onKeyDown={(e: KeyboardEvent) => { if (e.key === "Enter") runCustom(); }} /></TextField>
<Button size="sm" onClick={runCustom} disabled={busy() || !q().trim()}>{busy() && aktif() === "custom" ? "Menyaring…" : "Cari"}</Button> <Button size="sm" onClick={runCustom} disabled={busy() || !q().trim()}>{busy() && aktif() === "custom" ? "Menyaring…" : "Cari"}</Button>
</CardContent> </CardContent>
</Card> </Card>
@@ -80,7 +80,12 @@ function ScreenerInner() {
return ( return (
<Card> <Card>
<CardHeader class="flex flex-row items-center justify-between space-y-0 pb-2"> <CardHeader class="flex flex-row items-center justify-between space-y-0 pb-2">
<div>
<CardTitle class="text-xl font-bold">{s.row.symbol}</CardTitle> <CardTitle class="text-xl font-bold">{s.row.symbol}</CardTitle>
<Show when={s.row.name && s.row.name !== s.row.symbol}>
<p class="text-sm text-muted-foreground">{s.row.name}</p>
</Show>
</div>
<VerdictBadge verdict={s.verdict} /> <VerdictBadge verdict={s.verdict} />
</CardHeader> </CardHeader>
<CardContent class="space-y-3"> <CardContent class="space-y-3">