@AllArgsConstructor
public class EchoFlow extends FlowDefiner {
    private final Integer listenPort;
    @Override
    public Flow define() {
        return new Flow("Echo")
                .next(new TcpIn(listenPort, STRING))
                .next(new TcpOut());
    }
    public static void main(String[] args) {
        new EchoFlow(8080).deploy();
    }
}

@AllArgsConstructor
public class PrintTimeFlow extends FlowDefiner {
    private final Integer listenPort;
    @Override
    public Flow define() {
        return new Flow("PrintTime")
                .next(new TcpIn(listenPort, STRING))
                .next(msg -> msg.payload(ZonedDateTime.now()))
                .next(new TcpOut());
    }
    public static void main(String[] args) {
        new PrintTimeFlow(8080).deploy();
    }
}

@AllArgsConstructor
public class RequestFlow extends FlowDefiner {
    private final String host;
    private final Integer port;
    @Override
    public Flow define() {
        return new Flow("Request")
                .next(new TcpRequest(host, port))
                .next(msg -> msg);
    }
    public static void main(String[] args) {
        Flow flow = new RequestFlow("localhost", 8080).deploy();
        flow.invoke(new Msg().payload("hello"));
    }
}

@AllArgsConstructor
public class EchoFlow extends FlowDefiner {
    private final Integer listenPort;
    private final HttpMethod method;
    private final String url;
    @Override
    public Flow define() {
        return new Flow("Echo")
                .next(new HttpIn(listenPort, method, url))
                .next(new HttpOut());
    }
    public static void main(String[] args) {
        new EchoFlow(8080, HttpMethod.post, "/echo").deploy();
    }
}

@AllArgsConstructor
public class PrintTimeFlow extends FlowDefiner {
    private final Integer listenPort;
    private final HttpMethod method;
    private final String url;
    @Override
    public Flow define() {
        return new Flow("PrintTime")
                .next(new HttpIn(listenPort, method, url))
                .next(msg -> msg.payload(ZonedDateTime.now()))
                .next(new HttpOut());
    }
    public static void main(String[] args) {
        new PrintTimeFlow(8080, HttpMethod.get, "/time").deploy();
    }
}

@AllArgsConstructor
public class RequestFlow extends FlowDefiner {
    @Override
    public Flow define() {
        return new Flow("Request")
                .next(msg -> {
                    msg.put(HttpRequest.Fields.method, "POST");
                    msg.put(HttpRequest.Fields.url, "https://localhost:8080/echo");
                    return msg;
                })
                .next(new HttpRequest())
                .next(msg -> msg);
    }
    public static void main(String[] args) {
        Flow flow = new RequestFlow().deploy();
        flow.invoke(new Msg().payload("hello"));
    }
}