SegmentFlow API Service

# ── Base de datos ─────────────────────────────────
driver=com.mysql.cj.jdbc.Driver
database.url=jdbc:mysql://localhost:3306/segmentflow?useSSL=false&serverTimezone=UTC
database.user=segmentflow_app
database.password=s3cr3t_segflow_2024

# ── Servidor HTTP ─────────────────────────────────
default.home.page=api/segments
server.port=8090
server.host=0.0.0.0

# ── App ────────────────────────────────────────────
default.language=es_ES
application.version=2.1.0
application.name=SegmentFlow API

# ── Sesiones (Redis en prod) ───────────────────────
# default.session.repository=org.tinystruct.http.RedisSessionRepository
# redis.host=redis.segmentflow.internal
# redis.port=6379

package com.segmentflow;

import org.tinystruct.AbstractApplication;
import org.tinystruct.ApplicationException;
import org.tinystruct.data.component.Builder;
import org.tinystruct.data.component.Builders;
import org.tinystruct.http.SSEPushManager;
import org.tinystruct.system.annotation.Action;
import org.tinystruct.system.annotation.Action.Mode;
import com.segmentflow.model.Segment;
import java.util.List;

public class SegmentService extends AbstractApplication {

    @Override
    public void init() {
        // API-only: sin plantillas .view
        this.setTemplateRequired(false);
    }

    @Override
    public String version() { return "2.1.0"; }

    // ── GET /api/segments  ─────────────────────────────────────
    // También: bin/dispatcher api/segments
    @Action("api/segments")
    public String listSegments() throws ApplicationException {
        Segment query = new Segment();
        List<Segment> segments = query.findAll();

        Builders list = new Builders();
        for (Segment s : segments) {
            Builder item = new Builder();
            item.put("id",        s.getId());
            item.put("name",      s.getName());
            item.put("filters",   s.getFilters());
            item.put("userCount", s.getUserCount());
            item.put("active",    s.isActive());
            list.add(item);
        }

        Builder response = new Builder();
        response.put("status", "ok");
        response.put("count",  segments.size());
        response.put("data",   list);
        return response.toString();
    }

    // ── POST /api/segments ─────────────────────────────────────
    @Action(value = "api/segments", mode = Mode.HTTP_POST)
    public String createSegment() throws ApplicationException {
        String name    = (String) getContext().getAttribute("name");
        String filters = (String) getContext().getAttribute("filters");

        if (name == null || name.isBlank()) {
            throw new ApplicationException("'name' is required");
        }

        Segment seg = new Segment();
        seg.setName(name);
        seg.setFilters(filters != null ? filters : "{}");
        seg.setActive(true);
        seg.setUserCount(0);
        seg.save();

        Builder res = new Builder();
        res.put("status", "created");
        res.put("id",     seg.getId());
        res.put("name",   seg.getName());
        return res.toString();
    }

    // ── GET /api/segments/{id}/stats ───────────────────────────
    // También: bin/dispatcher api/segments/42/stats
    @Action("api/segments/{id}/stats")
    public String segmentStats(int id) throws ApplicationException {
        Segment seg = new Segment();
        seg.findById(id);

        if (seg.getId() == 0) {
            Builder err = new Builder();
            err.put("status", "not_found");
            err.put("id",     id);
            return err.toString();
        }

        // Calcula métricas en tiempo real
        double convRate = seg.getConversions() * 100.0 / Math.max(1, seg.getUserCount());

        Builder stats = new Builder();
        stats.put("segmentId",      id);
        stats.put("name",           seg.getName());
        stats.put("totalUsers",     seg.getUserCount());
        stats.put("conversions",    seg.getConversions());
        stats.put("conversionRate", String.format("%.2f%%", convRate));
        stats.put("lastUpdated",    seg.getUpdatedAt());
        return stats.toString();
    }

    // ── CLI only: bin/dispatcher export-csv/42 ─────────────────
    @Action(value = "export-csv", mode = Mode.CLI)
    public String exportCsv(int id) throws ApplicationException {
        Segment seg = new Segment();
        seg.findById(id);

        StringBuilder csv = new StringBuilder("id,name,filters,user_count,conversion_rate\n");
        double rate = seg.getConversions() * 100.0 / Math.max(1, seg.getUserCount());
        csv.append(seg.getId()).append(",")
           .append(seg.getName()).append(",")
           .append(seg.getFilters().replace(",", ";")).append(",")
           .append(seg.getUserCount()).append(",")
           .append(String.format("%.2f", rate));

        // En CLI, stdout es el output natural
        System.out.println(csv);
        return "Exported segment " + id + " to stdout";
    }

    // ── SSE: GET /sse/live-stats ────────────────────────────────
    @Action("sse/live-stats")
    public String connectLiveStats() {
        String sessionId = getContext().getId();
        return "{\"type\":\"connected\",\"session\":\"" + sessionId + "\"}";
    }

    /** Llamado internamente (cron/evento) para hacer broadcast de métricas **/
    public void broadcastStats(Segment seg) throws Exception {
        Builder msg = new Builder();
        msg.put("type",      "stats_update");
        msg.put("segmentId", seg.getId());
        msg.put("users",     seg.getUserCount());
        SSEPushManager.getInstance().broadcast(msg);
    }
}

package com.segmentflow.model;

import org.tinystruct.data.component.AbstractData;
import org.tinystruct.ApplicationException;
import java.time.LocalDateTime;
import java.util.List;

public class Segment extends AbstractData {

    private int           id;
    private String        name;
    private String        filters;       // JSON string
    private int           userCount;
    private int           conversions;
    private boolean       active;
    private LocalDateTime updatedAt;

    public Segment() {
        // AbstractData lee automáticamente config/Segment.xml
        super("Segment");
    }

    // ── Operaciones CRUD heredadas de AbstractData ─────────────
    public List<Segment> findAll() throws ApplicationException {
        return this.query("SELECT * FROM segments WHERE 1=1 ORDER BY id DESC", Segment.class);
    }

    public void findById(int segId) throws ApplicationException {
        this.id = segId;
        this.findOne(); // mapea columnas → campos via Segment.xml
    }

    // ── Getters / Setters ──────────────────────────────────────
    public int           getId()          { return id; }
    public String        getName()        { return name; }
    public String        getFilters()     { return filters; }
    public int           getUserCount()   { return userCount; }
    public int           getConversions() { return conversions; }
    public boolean       isActive()       { return active; }
    public LocalDateTime getUpdatedAt()   { return updatedAt; }

    public void setName(String v)      { this.name = v; }
    public void setFilters(String v)   { this.filters = v; }
    public void setUserCount(int v)    { this.userCount = v; }
    public void setActive(boolean v)  { this.active = v; }
}

<?xml version="1.0" encoding="UTF-8"?>
<mapping table="segments" class="com.segmentflow.model.Segment">
    <field column="id"           property="id"          type="int"     primary="true"/>
    <field column="name"         property="name"        type="String"/>
    <field column="filters"      property="filters"     type="String"/>
    <field column="user_count"   property="userCount"   type="int"/>
    <field column="conversions"  property="conversions" type="int"/>
    <field column="active"       property="active"      type="boolean"/>
    <field column="updated_at"   property="updatedAt"   type="LocalDateTime"/>
</mapping>

package com.segmentflow;

import org.tinystruct.mcp.MCPTool;
import org.tinystruct.mcp.MCPException;
import org.tinystruct.system.annotation.Action;
import org.tinystruct.system.annotation.Argument;
import com.segmentflow.model.Segment;

public class SegmentStatsTool extends MCPTool {

    public SegmentStatsTool() {
        super("segment_stats", "Get conversion stats for a SegmentFlow audience segment");
    }

    @Action(
        value = "segment_stats/get",
        description = "Returns user count and conversion rate for a segment",
        arguments = {
            @Argument(key = "segmentId", description = "Numeric segment ID",
                       type = "integer", optional = false)
        }
    )
    public String getStats(String segmentId) throws MCPException {
        // SECURITY: Validar antes de usar en la respuesta (Prompt Injection)
        if (segmentId == null || !segmentId.matches("\\d{1,9}")) {
            throw new MCPException("Invalid segmentId: must be a positive integer");
        }
        try {
            Segment seg = new Segment();
            seg.findById(Integer.parseInt(segmentId));
            double rate = seg.getConversions() * 100.0 / Math.max(1, seg.getUserCount());
            return "Segment '" + seg.getName() + "': "
                 + seg.getUserCount() + " users, "
                 + String.format("%.1f%%", rate) + " conversion";
        } catch (Exception e) {
            throw new MCPException("Failed to retrieve segment stats");
        }
    }
}