Compare commits
9
Commits
e203c61279
..
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9ea9a4291c | ||
|
|
41325ba574 | ||
|
|
6d3c17d19d | ||
|
|
ae0d5d813f | ||
|
|
ffdc0fd9e8 | ||
|
|
05a3bc7471 | ||
|
|
b19b9c71d1 | ||
|
|
49dd2101e0 | ||
|
|
d7eb0a3abf |
No files matched your search
@@ -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())
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -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
|
||||||
|
}
|
||||||
@@ -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 {
|
||||||
|
|||||||
@@ -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)
|
||||||
|
|||||||
@@ -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)
|
|
||||||
}
|
|
||||||
@@ -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 '';
|
||||||
@@ -626,9 +626,10 @@ func (db *DB) TickersWithForeign() (map[string]bool, error) {
|
|||||||
// SaveUniverse inserts the full ticker universe from the close sweep.
|
// SaveUniverse inserts the full ticker universe from the close sweep.
|
||||||
// UniverseRow mirrors the CloseRow shape without importing sectors (cycle).
|
// UniverseRow mirrors the CloseRow shape without importing sectors (cycle).
|
||||||
type UniverseRow struct {
|
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(?,?,?)
|
||||||
|
|||||||
@@ -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")
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -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">
|
||||||
<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 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>
|
||||||
|
</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">
|
||||||
<div class="max-h-64 space-y-2 overflow-y-auto">
|
<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>}>
|
||||||
<For each={log()}>
|
<div class="max-h-64 space-y-2 overflow-y-auto">
|
||||||
{(m) => <div class="text-sm"><p><strong>You:</strong> {m.q}</p><p class="text-muted-foreground">{m.a.slice(0, 500)}</p></div>}
|
<For each={log()}>
|
||||||
</For>
|
{(m) => (
|
||||||
</div>
|
<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>
|
||||||
|
</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>
|
||||||
@@ -74,4 +83,4 @@ export function ChatSidebar() {
|
|||||||
</CardContent>
|
</CardContent>
|
||||||
</Card>
|
</Card>
|
||||||
);
|
);
|
||||||
}
|
}
|
||||||
+32
-14
@@ -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">
|
||||||
Flow<span class="text-primary">Sight</span>
|
<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>
|
||||||
|
</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>
|
||||||
|
|||||||
@@ -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>
|
||||||
|
|||||||
@@ -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">
|
||||||
<CardTitle class="text-xl font-bold">
|
<div>
|
||||||
{s.row.symbol}
|
<CardTitle class="text-xl font-bold">
|
||||||
<Show when={cx?.close}><span class="ml-2 font-mono text-sm font-normal text-muted-foreground">{fmtHarga(cx.close)}</span></Show>
|
{s.row.symbol}
|
||||||
</CardTitle>
|
<Show when={cx?.close}><span class="ml-2 font-mono text-sm font-normal text-muted-foreground">{fmtHarga(cx.close)}</span></Show>
|
||||||
|
</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">
|
||||||
|
|||||||
@@ -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">
|
||||||
|
|||||||
@@ -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>
|
||||||
|
|||||||
@@ -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">
|
||||||
<CardTitle class="text-xl font-bold">{s.row.symbol}</CardTitle>
|
<div>
|
||||||
|
<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">
|
||||||
|
|||||||
Reference in new issue
Block a user