← Back to the worked exampleOne request.
RECORDED AUTHORING SESSION
One request.
A reviewable record.
The visible conversation and completed command actions are shown in their recorded order. The resulting application was generated, run and checked against the stated requirements.
Configured model: gpt-6.1-sol · Reasoning effort: low
1 user prompt · 1 completed CLI turn · 3 visible assistant messages · 8 command actions
A CLI turn includes the tool loop; it is not a single inference. Requirements, generic SDK notes and a local compiler helper were prepared before this session.
Actual visible messages and completed command actions, in their original order. No private reasoning, session identifiers or credentials included. Local paths and the expanded cached compiler classpath are replaced by documented placeholders. Commands are the recorded transcript, not portable installation instructions.
Command action 1 · exit 0
Recorded command
/bin/zsh -lc "pwd; rg --files -g '"'!evidence/**'"' -g '"'!target/**'"' -g '"'!build/**'"'"
Observed output
$WORKSPACE SDK-NOTES.md local-build.sh REQUIREMENTS.md
Command action 2 · exit 0
Recorded command
/bin/zsh -lc 'cat SDK-NOTES.md local-build.sh REQUIREMENTS.md'
Observed output
# Supplied Fluxtion environment
These generic integration notes and the offline build helper are prepared before the trial; they are not model-authored output. The test is authoring the application's components, graph definition and tests from REQUIREMENTS.md.
Pinned local compiler: 1.0.83. Runtime: 1.1.3. JDK: Corretto21.0.9. No hosted-generation request or compiler credentials are needed. This provisioned local compiler is an environment assumption, not a claim that local generation is available to every free-tier user.
Use package demo.authoring for handwritten code. Put a public GenerateApplication class with main(String[] args) there; args[0] is the generated output directory. Generated package must be demo.authoring.generated, class OrderProcessor. Put an executable verification main in demo.authoring.VerifyApplication; args[0] is the evidence output directory.
API patterns:
- `com.telamin.fluxtion.runtime.annotations.OnEventHandler`: public boolean handler(Event e) on an event-input component; true propagates changes.
- `com.telamin.fluxtion.runtime.annotations.OnTrigger`: public boolean callback() on a dependent component. Hold dependency components in final fields, constructor-injected.
- `com.telamin.fluxtion.runtime.node.SingleNamedNode` is an audit-enabled base class; call super("nodeName") in the constructor. Its protected auditLog supports `.info("field", value)` chaining. Inspect cached API classes with javap if needed.
- `com.telamin.fluxtion.Fluxtion.compile(application -> { application.addNode(root, "decision"); application.addEventAudit(LogLevel.INFO); }, output -> { output.setPackageName("demo.authoring.generated"); output.setClassName("OrderProcessor"); output.setSourceWriter(sourceWriter); output.setGraphmlWriter(graphWriter); output.setFormatSource(false); });`
- LogLevel is `com.telamin.fluxtion.runtime.audit.EventLogControlEvent.LogLevel`.
- Use StringWriter to collect generated Java/GraphML, then write OrderProcessor.java and OrderProcessor.graphml to args[0].
- Generated processors have init(), start(), onEvent(event), stop(), tearDown(), getNodeById(String), setClockStrategy(...). Set an explicit application clock for test events. They expose eventLogger: configure setLogSink and tracingOn(LogLevel.INFO) before init. Append a YAML `---` separator between sink records. Initial lifecycle wall-clock records can precede clock setup; disclose that.
Use ./local-build.sh generate to compile handwritten components + generator (excluding VerifyApplication.java) and generate source. Use ./local-build.sh verify to compile all handwritten files except GenerateApplication.java plus generated Java against runtime-only, then run VerifyApplication. Source discovery is recursive under src/. Results are under evidence/.
The cached compiler's raw generated notice may be restrictive and contain legacy private contact details. Preserve those raw bytes locally. Do not publish or remove notices in this trial. The supervising owner has separately approved Apache 2.0 for demo code; later integration will make only the authorized notice change and rerun tests.
Do not use network commands, hosted generation, tools outside this workspace, secrets or existing solution files. You may read the cached JARs named by local-build.sh solely to inspect public API signatures. Do not read other projects or user configuration. Do not create subagents.
#!/bin/bash
set -euo pipefail
cd "$(dirname "$0")"
JAVA='$JAVA_HOME/bin'
CP_FILE='$LOCAL_COMPILER_CLASSPATH_FILE'
GEN_CP=$(cat "$CP_FILE")
RUNTIME='$MAVEN_CACHE/repository/com/telamin/fluxtion/fluxtion-runtime/1.1.3/fluxtion-runtime-1.1.3.jar'
mkdir -p build/generator build/runtime generated evidence home
if [[ "${1:-}" == generate ]]; then
files=()
while IFS= read -r f; do files+=("$f"); done < <(find src -name '*.java' ! -name 'VerifyApplication.java' | sort)
"$JAVA/javac" -proc:none -cp "$GEN_CP" -d build/generator "${files[@]}"
"$JAVA/java" -Duser.home="$PWD/home" -Dfluxtion.sourceGeneratorId=local -cp "build/generator:$GEN_CP" demo.authoring.GenerateApplication "$PWD/generated"
elif [[ "${1:-}" == verify ]]; then
files=()
while IFS= read -r f; do files+=("$f"); done < <(find src -name '*.java' ! -name 'GenerateApplication.java' | sort)
"$JAVA/javac" --release 8 -proc:none -cp "$RUNTIME" -d build/runtime "${files[@]}" generated/OrderProcessor.java
"$JAVA/java" -cp "build/runtime:$RUNTIME" demo.authoring.VerifyApplication "$PWD/evidence"
else
echo 'Usage: ./local-build.sh generate|verify' >&2
exit 2
fi
# Order control requirements
Create a fresh Java order-control application using Fluxtion's generated coordination.
- Input: quantity (positive int), unit price (non-negative long integer pence), limit (non-negative long integer pence).
- Calculate value = quantity * unit price using checked arithmetic.
- Accept a valid order if value <= limit; reject it if value > limit.
- Refuse zero/negative quantity, negative price/limit and multiplication overflow before dispatch.
- Separate calculation, limit comparison and result publication into graph-connected components; retain the decision as an observable node.
- A generated processor must run independently with the runtime JAR, without the compiler on its production classpath.
- Capture genuine audit records including the order's quantity, price, value, limit and decision; use YAML document separators between records so the Analyser can open it.
- Emit generated Java and GraphML from your application definition using the supplied offline local compiler helper.
- Execute and assert at least these cases in sequence: (10,1200,10000)->REJECTED twice; (10,1200,15000)->ACCEPTED; (10,1200,12000)->ACCEPTED; (10,1200,11999)->REJECTED; (1,0,0)->ACCEPTED; (1,Long.MAX_VALUE,Long.MAX_VALUE)->ACCEPTED.
- Execute four invalid constructions: (0,1,1), (1,-1,1), (1,1,-1), (2,Long.MAX_VALUE,1). Each must be refused.
- Tests must assert explicit expected outcomes, not derive the expected answer from the implementation under test.
Write source from these requirements. No existing order-control implementation is supplied. This is an authoring demonstration, not a blind fault-finding exercise and not a claim of correctness beyond tested requirements.
Command action 3 · exit 0
Recorded command
/bin/zsh -lc 'ls -la; cat $LOCAL_COMPILER_CLASSPATH_FILE'
Observed output
total 24 drwxr-xr-x@ 5 greg wheel 160 Nov 1 14:21 . drwxr-xr-x@ 5 greg wheel 160 Nov 1 14:24 .. -rw-r--r--@ 1 greg wheel 1706 Nov 1 14:21 REQUIREMENTS.md -rw-r--r--@ 1 greg wheel 3409 Nov 1 14:21 SDK-NOTES.md -rwxr-xr-x@ 1 greg wheel 1231 Nov 1 14:21 local-build.sh $LOCAL_GENERATOR_CLASSPATH
Command action 4 · exit 0
Recorded command
/bin/zsh -lc '$JAVA_HOME/bin/javap -classpath $MAVEN_CACHE/repository/com/telamin/fluxtion/fluxtion-runtime/1.1.3/fluxtion-runtime-1.1.3.jar com.telamin.fluxtion.runtime.audit.EventLogManager com.telamin.fluxtion.runtime.audit.LogRecord com.telamin.fluxtion.runtime.time.Clock'
Observed output
Compiled from "EventLogManager.java"
public class com.telamin.fluxtion.runtime.audit.EventLogManager implements com.telamin.fluxtion.runtime.audit.Auditor {
public static final java.lang.String NODE_NAME;
public boolean trace;
public boolean printEventToString;
public boolean printThreadName;
public com.telamin.fluxtion.runtime.audit.EventLogControlEvent$LogLevel traceLevel;
public com.telamin.fluxtion.runtime.time.Clock clock;
public boolean binaryRecord;
public boolean recordEndTime;
public com.telamin.fluxtion.runtime.audit.EventLogManager();
public com.telamin.fluxtion.runtime.audit.EventLogManager(com.telamin.fluxtion.runtime.audit.LogRecordListener);
public com.telamin.fluxtion.runtime.audit.EventLogManager tracingOff();
public com.telamin.fluxtion.runtime.audit.EventLogManager tracingOn(com.telamin.fluxtion.runtime.audit.EventLogControlEvent$LogLevel);
public com.telamin.fluxtion.runtime.audit.EventLogManager logLevel(com.telamin.fluxtion.runtime.audit.EventLogControlEvent$LogLevel);
public com.telamin.fluxtion.runtime.audit.EventLogManager printEventToString(boolean);
public com.telamin.fluxtion.runtime.audit.EventLogManager printThreadName(boolean);
public void nodeRegistered(java.lang.Object, java.lang.String);
public boolean auditInvocations();
public void nodeInvoked(java.lang.Object, java.lang.String, java.lang.String, java.lang.Object);
public void nodeInvoked(java.lang.Object, java.lang.String, java.lang.String, java.lang.String, java.lang.Object);
public void calculationLogConfig(com.telamin.fluxtion.runtime.audit.EventLogControlEvent);
public boolean lastRecordIsBinaryForTest();
public void setLogSink(com.telamin.fluxtion.runtime.audit.LogRecordListener);
public void setLogGroupId(java.lang.String);
public void setClearAfterPublish(boolean);
public void publishLastRecord();
public java.lang.String lastRecordAsString();
public void processingComplete();
public com.telamin.fluxtion.runtime.audit.EventLogManager binaryRecord(boolean);
public com.telamin.fluxtion.runtime.audit.EventLogManager recordEndTime(boolean);
public void init();
public void eventReceived(com.telamin.fluxtion.runtime.event.Event);
public void eventReceived(java.lang.Object);
static {};
}
Compiled from "LogRecord.java"
public class com.telamin.fluxtion.runtime.audit.LogRecord {
public java.lang.String groupingId;
protected final java.lang.StringBuilder sb;
protected java.lang.String sourceId;
protected boolean firstProp;
protected boolean recordEndTime;
protected com.telamin.fluxtion.runtime.time.Clock clock;
protected boolean printEventToString;
protected boolean printThreadName;
protected java.util.function.ObjLongConsumer<java.lang.StringBuilder> timeFormatter;
public static final int NO_ID;
public void encodeTo(java.io.OutputStream) throws java.io.IOException;
public com.telamin.fluxtion.runtime.audit.LogRecord(com.telamin.fluxtion.runtime.time.Clock);
public com.telamin.fluxtion.runtime.audit.LogRecord(com.telamin.fluxtion.runtime.time.Clock, com.telamin.fluxtion.runtime.audit.EventLogControlEvent$LogLevel);
public void updateLogLevel(com.telamin.fluxtion.runtime.audit.EventLogControlEvent$LogLevel);
public void setRecordEndTime(boolean);
public boolean isRecordEndTime();
public void replaceBuffer(java.lang.CharSequence);
public int internName(java.lang.String);
public void addRecord(int, int, double);
public void addRecord(int, int, long);
public void addRecord(int, int, int);
public void addRecord(int, int, boolean);
public void addRecord(int, int, char);
public void addRecord(java.lang.String, java.lang.String, double);
public void addRecord(java.lang.String, java.lang.String, long);
public void addRecord(java.lang.String, java.lang.String, int);
public void addRecord(java.lang.String, java.lang.String, char);
public void addRecord(java.lang.String, java.lang.String, java.lang.CharSequence);
public void addRecord(java.lang.String, java.lang.String, java.lang.Object);
public void addRecord(java.lang.String, java.lang.String, boolean);
public void addTrace(java.lang.String);
public void printEventToString(boolean);
protected void addSourceId(java.lang.String, java.lang.String);
protected long logTime();
public void clear();
public java.lang.CharSequence asCharSequence();
public void triggerEvent(com.telamin.fluxtion.runtime.event.Event);
public void triggerObject(java.lang.Object);
public boolean terminateRecord();
public java.lang.String toString();
protected boolean loggingEnabled();
public com.telamin.fluxtion.runtime.audit.EventLogControlEvent$LogLevel getLogLevel();
public void setClock(com.telamin.fluxtion.runtime.time.Clock);
public void setPrintThreadName(boolean);
public void setTimeFormatter(java.util.function.ObjLongConsumer<java.lang.StringBuilder>);
}
Compiled from "Clock.java"
public class com.telamin.fluxtion.runtime.time.Clock implements com.telamin.fluxtion.runtime.audit.Auditor,com.telamin.fluxtion.runtime.audit.Auditor$FirstAfterEvent {
public static final com.telamin.fluxtion.runtime.time.Clock DEFAULT_CLOCK;
public com.telamin.fluxtion.runtime.time.Clock();
public boolean shareReading(boolean);
public void eventReceived(com.telamin.fluxtion.runtime.event.Event);
public void eventReceived(java.lang.Object);
public void nodeRegistered(java.lang.Object, java.lang.String);
public void setClockStrategy(com.telamin.fluxtion.runtime.time.ClockStrategy$ClockStrategyEvent);
public long getProcessTime();
public long getEventTime();
public long getWallClockTime();
public void init();
static {};
}
Command action 5 · exit 0
Recorded command
/bin/zsh -lc "mkdir -p src/demo/authoring evidence
cat > src/demo/authoring/Order.java <<'EOF'
package demo.authoring;
/** Immutable input; all validation occurs before it can be dispatched. */
public final class Order {
public final int quantity;
public final long price;
public final long limit;
public Order(int quantity, long price, long limit) {
if (quantity <= 0 || price < 0 || limit < 0) {
throw new IllegalArgumentException(\"quantity must be positive; price and limit must be non-negative\");
}
Math.multiplyExact((long) quantity, price);
this.quantity = quantity;
this.price = price;
this.limit = limit;
}
}
EOF
cat > src/demo/authoring/OrderInput.java <<'EOF'
package demo.authoring;
import com.telamin.fluxtion.runtime.annotations.OnEventHandler;
import com.telamin.fluxtion.runtime.node.SingleNamedNode;
public class OrderInput extends SingleNamedNode {
public Order order;
public long count;
public OrderInput() { super(\"input\"); }
@OnEventHandler public boolean onOrder(Order order) {
this.order = order;
count++;
auditLog.info(\"quantity\", order.quantity).info(\"price\", order.price).info(\"limit\", order.limit);
return true;
}
}
EOF
cat > src/demo/authoring/Calculation.java <<'EOF'
package demo.authoring;
import com.telamin.fluxtion.runtime.annotations.OnTrigger;
import com.telamin.fluxtion.runtime.node.SingleNamedNode;
public class Calculation extends SingleNamedNode {
public final OrderInput input;
public long value;
public Calculation(OrderInput input) { super(\"calculation\"); this.input = input; }
@OnTrigger public boolean calculate() {
value = Math.multiplyExact((long) input.order.quantity, input.order.price);
auditLog.info(\"value\", value);
return true;
}
}
EOF
cat > src/demo/authoring/LimitComparison.java <<'EOF'
package demo.authoring;
import com.telamin.fluxtion.runtime.annotations.OnTrigger;
import com.telamin.fluxtion.runtime.node.SingleNamedNode;
public class LimitComparison extends SingleNamedNode {
public final Calculation calculation;
public boolean accepted;
public LimitComparison(Calculation calculation) { super(\"limit\"); this.calculation = calculation; }
@OnTrigger public boolean compare() {
accepted = calculation.value <= calculation.input.order.limit;
auditLog.info(\"accepted\", accepted);
return true;
}
}
EOF
cat > src/demo/authoring/Decision.java <<'EOF'
package demo.authoring;
import com.telamin.fluxtion.runtime.annotations.OnTrigger;
import com.telamin.fluxtion.runtime.node.SingleNamedNode;
public class Decision extends SingleNamedNode {
public final LimitComparison comparison;
public String result;
public long publications;
public Decision(LimitComparison comparison) { super(\"decision\"); this.comparison = comparison; }
@OnTrigger public boolean publish() {
result = comparison.accepted ? \"ACCEPTED\" : \"REJECTED\";
publications++;
auditLog.info(\"decision\", result);
return true;
}
}
EOF
cat > src/demo/authoring/GenerateApplication.java <<'EOF'
package demo.authoring;
import java.io.StringWriter;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import com.telamin.fluxtion.Fluxtion;
import com.telamin.fluxtion.runtime.audit.EventLogControlEvent.LogLevel;
public class GenerateApplication {
public static void main(String[] args) throws Exception {
Path output = Paths.get(args[0]);
Files.createDirectories(output);
StringWriter source = new StringWriter();
StringWriter graph = new StringWriter();
Decision root = new Decision(new LimitComparison(new Calculation(new OrderInput())));
Fluxtion.compile(application -> {
application.addNode(root, \"decision\");
application.addEventAudit(LogLevel.INFO);
}, config -> {
config.setPackageName(\"demo.authoring.generated\");
config.setClassName(\"OrderProcessor\");
config.setSourceWriter(source);
config.setGraphmlWriter(graph);
config.setFormatSource(false);
});
Files.write(output.resolve(\"OrderProcessor.java\"), source.toString().getBytes(StandardCharsets.UTF_8));
Files.write(output.resolve(\"OrderProcessor.graphml\"), graph.toString().getBytes(StandardCharsets.UTF_8));
System.out.println(\"Generated OrderProcessor.java and OrderProcessor.graphml\");
}
}
EOF
./local-build.sh generate > evidence/generate-attempt-1.log 2>&1
result="'$?
cat evidence/generate-attempt-1.log
exit $result'Observed output
------------------------------------------------------------------------ Fluxtion API key is not configured. Config file: $WORKSPACE/home/.fluxtion/fluxtion.apiKeyFile Current placeholder value: apiKey=MISSING_KEY Get an API key (on RapidAPI subscribe to "Fluxtion Source Generator" (host fluxtion-source-gen.p.rapidapi.com)): https://telaminai.github.io/fluxtion/home/quickstart-aot/#1-getting-an-api-key Then replace the placeholder value in the config file. Why a key: generation sends the graph model to the hosted generator; see "Cloud generation and your API key" in the Fluxtion README (https://github.com/telaminai/fluxtion#cloud-generation-and-your-api-key). ------------------------------------------------------------------------ ------------------------------------------------------------------------ Fluxtion API key is not configured. Config file: $WORKSPACE/home/.fluxtion/fluxtion.apiKeyFile Current placeholder value: apiKey=MISSING_KEY Get an API key (on RapidAPI subscribe to "Fluxtion Source Generator" (host fluxtion-source-gen.p.rapidapi.com)): https://telaminai.github.io/fluxtion/home/quickstart-aot/#1-getting-an-api-key Then replace the placeholder value in the config file. Why a key: generation sends the graph model to the hosted generator; see "Cloud generation and your API key" in the Fluxtion README (https://github.com/telaminai/fluxtion#cloud-generation-and-your-api-key). ------------------------------------------------------------------------ Nov 01, 2026 2:25:13 PM com.telamin.fluxtion.builder.generation.classcompiler.StringCompilation resolveStrategy INFO: Using compiler strategy: javac Generated OrderProcessor.java and OrderProcessor.graphml
Command action 6 · exit 0
Recorded command
/bin/zsh -lc "rg -n 'setClockStrategy|eventLogger|public final|public .*decision' generated/OrderProcessor.java; $JAVA_HOME/bin/javap -classpath $MAVEN_CACHE/repository/com/telamin/fluxtion/fluxtion-runtime/1.1.3/fluxtion-runtime-1.1.3.jar com.telamin.fluxtion.runtime.audit.LogRecordListener com.telamin.fluxtion.runtime.time.ClockStrategy"
Observed output
76: public transient final EventLogManager eventLogger = new EventLogManager();
83: public transient final Decision decision = new demo.authoring.Decision(limit);;
129: eventLogger.setClearAfterPublish(false);
130: eventLogger.trace = true;
131: eventLogger.printEventToString = true;
132: eventLogger.printThreadName = true;
133: eventLogger.traceLevel = LogLevel.INFO;
134: eventLogger.clock = clock;
135: eventLogger.binaryRecord = false;
136: eventLogger.recordEndTime = true;
149: initialiseAuditor(eventLogger);
238: eventLogger.tearDown();
343: auditInvocation(eventLogger, "eventLogger", "calculationLogConfig", "OnEventHandler", typedEvent);
344: eventLogger.calculationLogConfig(typedEvent);
351: auditInvocation(clock, "clock", "setClockStrategy", "OnEventHandler", typedEvent);
352: clock.setClockStrategy(typedEvent);
417: auditInvocation(eventLogger, "eventLogger", "calculationLogConfig", "OnEventHandler", typedEvent);
418: eventLogger.calculationLogConfig(typedEvent);
423: auditInvocation(clock, "clock", "setClockStrategy", "OnEventHandler", typedEvent);
424: clock.setClockStrategy(typedEvent);
466: eventLogger.eventReceived(typedEvent);
470: eventLogger.eventReceived(typedEvent);
473: eventLogger.nodeInvoked(node, nodeName, methodName, annotation, typedEvent);
559: eventLogger.processingComplete();
579: eventLogger.processingComplete();
656: case "eventLogger": return (T) eventLogger;
675: if (node == eventLogger) { return "eventLogger"; }
714: case "eventLogger": return (A) eventLogger;
Compiled from "LogRecordListener.java"
public interface com.telamin.fluxtion.runtime.audit.LogRecordListener {
public abstract void processLogRecord(com.telamin.fluxtion.runtime.audit.LogRecord);
public default void processLogRecord(com.telamin.fluxtion.runtime.audit.LogRecord, java.io.OutputStream) throws java.io.IOException;
}
Compiled from "ClockStrategy.java"
public interface com.telamin.fluxtion.runtime.time.ClockStrategy {
public abstract long getWallClockTime();
public static com.telamin.fluxtion.runtime.time.ClockStrategy$ClockStrategyEvent registerClockEvent(com.telamin.fluxtion.runtime.time.ClockStrategy);
public static com.telamin.fluxtion.runtime.time.ClockStrategy fastEpochMillisClock();
public static com.telamin.fluxtion.runtime.time.ClockStrategy nanoEpochClock();
}
Command action 7 · exit 0
Recorded command
/bin/zsh -lc "cat > src/demo/authoring/VerifyApplication.java <<'EOF'
package demo.authoring;
import demo.authoring.generated.OrderProcessor;
import com.telamin.fluxtion.runtime.audit.EventLogControlEvent.LogLevel;
import java.io.PrintWriter;
import java.nio.charset.StandardCharsets;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
/** Explicit requirement examples, executed against generated coordination. */
public class VerifyApplication {
private static void require(boolean value, String message) {
if ("'!value) throw new AssertionError(message);
}
public static void main(String[] args) throws Exception {
Path dir = Paths.get(args[0]);
Files.createDirectories(dir);
try (PrintWriter audit = new PrintWriter(Files.newBufferedWriter(dir.resolve("events.yaml"), StandardCharsets.UTF_8));
PrintWriter csv = new PrintWriter(Files.newBufferedWriter(dir.resolve("decisions.csv"), StandardCharsets.UTF_8));
PrintWriter summary = new PrintWriter(Files.newBufferedWriter(dir.resolve("summary.txt"), StandardCharsets.UTF_8))) {
OrderProcessor processor = new OrderProcessor();
processor.eventLogger.setLogSink(record -> {
audit.println("---");
audit.println(record.toString());
audit.flush();
});
processor.eventLogger.tracingOn(LogLevel.INFO);
processor.init();
final long[] now = {1700000000000L};
processor.setClockStrategy(() -> now[0]);
processor.start();
Decision decision = processor.getNodeById("decision");
require(decision == processor.decision, "observable decision identity");
int[] quantities = {10, 10, 10, 10, 10, 1, 1};
long[] prices = {1200, 1200, 1200, 1200, 1200, 0, Long.MAX_VALUE};
long[] limits = {10000, 10000, 15000, 12000, 11999, 0, Long.MAX_VALUE};
long[] values = {12000, 12000, 12000, 12000, 12000, 0, Long.MAX_VALUE};
String[] expected = {"REJECTED", "REJECTED", "ACCEPTED", "ACCEPTED", "REJECTED", "ACCEPTED", "ACCEPTED"};
csv.println("case,quantity,unit_price_pence,limit_pence,expected_value,observed_value,expected,observed");
for (int i = 0; i < expected.length; i++) {
now[0]++;
processor.onEvent(new Order(quantities[i], prices[i], limits[i]));
csv.println((i + 1) + "," + quantities[i] + "," + prices[i] + "," + limits[i] + "," + values[i] + "," + decision.comparison.calculation.value + "," + expected[i] + "," + decision.result);
csv.flush();
require(expected[i].equals(decision.result), "decision case " + (i + 1));
require(values[i] == decision.comparison.calculation.value, "value case " + (i + 1));
require(decision.publications == i + 1, "each event publishes, including repeated rejection");
require(decision.comparison.calculation.input.count == i + 1, "each event reaches input");
summary.println("PASS valid case " + (i + 1) + ": " + expected[i]);
}
int[] invalidQuantity = {0, 1, 1, 2};
long[] invalidPrice = {1, -1, 1, Long.MAX_VALUE};
long[] invalidLimit = {1, 1, -1, 1};
for (int i = 0; i < 4; i++) {
boolean refused = false;
try {
Order invalid = new Order(invalidQuantity[i], invalidPrice[i], invalidLimit[i]);
processor.onEvent(invalid);
} catch (IllegalArgumentException e) {
require(i < 3, "overflow must use checked arithmetic");
refused = true;
} catch (ArithmeticException e) {
require(i == 3, "unexpected overflow");
refused = true;
}
require(refused, "invalid construction " + (i + 1) + " refused");
require(decision.publications == 7 && decision.comparison.calculation.input.count == 7,
"invalid input must not be dispatched");
summary.println("PASS invalid construction (" + invalidQuantity[i] + "," + invalidPrice[i] + "," + invalidLimit[i] + "): refused before dispatch; input/publication counts remain 7");
summary.flush();
}
processor.stop();
processor.tearDown();
require(!audit.checkError() && !csv.checkError(), "evidence writes");
summary.println("PASS runtime-only verification: seven explicit decisions and four invalid constructions.");
summary.println("Audit records are genuine configured EventLogManager sink output, separated as YAML documents.");
summary.println("Application clock starts at 1700000000000 milliseconds; initial lifecycle/clock-setup records can use wall-clock time.");
summary.println("Scope: tested requirements only; no human approval or broader correctness claim.");
System.out.println("PASS: seven decisions, four invalid constructions, runtime-only processor; evidence written.");
}
}
}
EOF
./local-build.sh verify > evidence/verify-attempt-1.log 2>&1
result=$?
cat evidence/verify-attempt-1.log
exit $result'Observed output
warning: [options] source value 8 is obsolete and will be removed in a future release warning: [options] target value 8 is obsolete and will be removed in a future release warning: [options] To suppress warnings about obsolete options, use -Xlint:-options. 3 warnings PASS: seven decisions, four invalid constructions, runtime-only processor; evidence written.
Command action 8 · exit 0
Recorded command
/bin/zsh -lc "cat evidence/decisions.csv evidence/summary.txt; head -100 evidence/events.yaml; rg --files generated evidence src; rg -n 'quantity|price|value|limit|decision|170000000000' evidence/events.yaml"
Observed output
case,quantity,unit_price_pence,limit_pence,expected_value,observed_value,expected,observed
1,10,1200,10000,12000,12000,REJECTED,REJECTED
2,10,1200,10000,12000,12000,REJECTED,REJECTED
3,10,1200,15000,12000,12000,ACCEPTED,ACCEPTED
4,10,1200,12000,12000,12000,ACCEPTED,ACCEPTED
5,10,1200,11999,12000,12000,REJECTED,REJECTED
6,1,0,0,0,0,ACCEPTED,ACCEPTED
7,1,9223372036854775807,9223372036854775807,9223372036854775807,9223372036854775807,ACCEPTED,ACCEPTED
PASS valid case 1: REJECTED
PASS valid case 2: REJECTED
PASS valid case 3: ACCEPTED
PASS valid case 4: ACCEPTED
PASS valid case 5: REJECTED
PASS valid case 6: ACCEPTED
PASS valid case 7: ACCEPTED
PASS invalid construction (0,1,1): refused before dispatch; input/publication counts remain 7
PASS invalid construction (1,-1,1): refused before dispatch; input/publication counts remain 7
PASS invalid construction (1,1,-1): refused before dispatch; input/publication counts remain 7
PASS invalid construction (2,9223372036854775807,1): refused before dispatch; input/publication counts remain 7
PASS runtime-only verification: seven explicit decisions and four invalid constructions.
Audit records are genuine configured EventLogManager sink output, separated as YAML documents.
Application clock starts at 1700000000000 milliseconds; initial lifecycle/clock-setup records can use wall-clock time.
Scope: tested requirements only; no human approval or broader correctness claim.
---
eventLogRecord:
eventTime: 1793543142006
logTime: 1793543142006
groupingId: null
event: LifecycleEvent
eventToString: Init
thread: main
nodeLogs:
endTime: 1793543142007
---
eventLogRecord:
eventTime: 1793543142008
logTime: 1793543142008
groupingId: null
event: ClockStrategyEvent
eventToString: com.telamin.fluxtion.runtime.time.ClockStrategy$ClockStrategyEvent@59f95c5d
thread: main
nodeLogs:
endTime: 1700000000000
---
eventLogRecord:
eventTime: 1700000000000
logTime: 1700000000000
groupingId: null
event: LifecycleEvent
eventToString: Start
thread: main
nodeLogs:
endTime: 1700000000000
---
eventLogRecord:
eventTime: 1700000000001
logTime: 1700000000001
groupingId: null
event: Order
eventToString: demo.authoring.Order@7960847b
thread: main
nodeLogs:
- input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 10000}
- calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
- limit: { thread: main, method: compare, annotation: OnTrigger, accepted: false}
- decision: { thread: main, method: publish, annotation: OnTrigger, decision: REJECTED}
endTime: 1700000000001
---
eventLogRecord:
eventTime: 1700000000002
logTime: 1700000000002
groupingId: null
event: Order
eventToString: demo.authoring.Order@6a6824be
thread: main
nodeLogs:
- input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 10000}
- calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
- limit: { thread: main, method: compare, annotation: OnTrigger, accepted: false}
- decision: { thread: main, method: publish, annotation: OnTrigger, decision: REJECTED}
endTime: 1700000000002
---
eventLogRecord:
eventTime: 1700000000003
logTime: 1700000000003
groupingId: null
event: Order
eventToString: demo.authoring.Order@5c8da962
thread: main
nodeLogs:
- input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 15000}
- calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
- limit: { thread: main, method: compare, annotation: OnTrigger, accepted: true}
- decision: { thread: main, method: publish, annotation: OnTrigger, decision: ACCEPTED}
endTime: 1700000000003
---
eventLogRecord:
eventTime: 1700000000004
logTime: 1700000000004
groupingId: null
event: Order
eventToString: demo.authoring.Order@512ddf17
thread: main
nodeLogs:
- input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 12000}
- calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
- limit: { thread: main, method: compare, annotation: OnTrigger, accepted: true}
- decision: { thread: main, method: publish, annotation: OnTrigger, decision: ACCEPTED}
endTime: 1700000000004
---
eventLogRecord:
eventTime: 1700000000005
logTime: 1700000000005
groupingId: null
event: Order
eventToString: demo.authoring.Order@2c13da15
thread: main
nodeLogs:
- input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 11999}
- calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
- limit: { thread: main, method: compare, annotation: OnTrigger, accepted: false}
- decision: { thread: main, method: publish, annotation: OnTrigger, decision: REJECTED}
endTime: 1700000000005
generated/OrderProcessor.java
evidence/verify-attempt-1.log
generated/OrderProcessor.graphml
evidence/decisions.csv
evidence/events.yaml
evidence/generate-attempt-1.log
evidence/summary.txt
src/demo/authoring/GenerateApplication.java
src/demo/authoring/VerifyApplication.java
src/demo/authoring/OrderInput.java
src/demo/authoring/Decision.java
src/demo/authoring/Order.java
src/demo/authoring/Calculation.java
src/demo/authoring/LimitComparison.java
20: endTime: 1700000000000
23: eventTime: 1700000000000
24: logTime: 1700000000000
30: endTime: 1700000000000
33: eventTime: 1700000000001
34: logTime: 1700000000001
40: - input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 10000}
41: - calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
42: - limit: { thread: main, method: compare, annotation: OnTrigger, accepted: false}
43: - decision: { thread: main, method: publish, annotation: OnTrigger, decision: REJECTED}
44: endTime: 1700000000001
47: eventTime: 1700000000002
48: logTime: 1700000000002
54: - input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 10000}
55: - calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
56: - limit: { thread: main, method: compare, annotation: OnTrigger, accepted: false}
57: - decision: { thread: main, method: publish, annotation: OnTrigger, decision: REJECTED}
58: endTime: 1700000000002
61: eventTime: 1700000000003
62: logTime: 1700000000003
68: - input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 15000}
69: - calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
70: - limit: { thread: main, method: compare, annotation: OnTrigger, accepted: true}
71: - decision: { thread: main, method: publish, annotation: OnTrigger, decision: ACCEPTED}
72: endTime: 1700000000003
75: eventTime: 1700000000004
76: logTime: 1700000000004
82: - input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 12000}
83: - calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
84: - limit: { thread: main, method: compare, annotation: OnTrigger, accepted: true}
85: - decision: { thread: main, method: publish, annotation: OnTrigger, decision: ACCEPTED}
86: endTime: 1700000000004
89: eventTime: 1700000000005
90: logTime: 1700000000005
96: - input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 10, price: 1200, limit: 11999}
97: - calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 12000}
98: - limit: { thread: main, method: compare, annotation: OnTrigger, accepted: false}
99: - decision: { thread: main, method: publish, annotation: OnTrigger, decision: REJECTED}
100: endTime: 1700000000005
103: eventTime: 1700000000006
104: logTime: 1700000000006
110: - input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 1, price: 0, limit: 0}
111: - calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 0}
112: - limit: { thread: main, method: compare, annotation: OnTrigger, accepted: true}
113: - decision: { thread: main, method: publish, annotation: OnTrigger, decision: ACCEPTED}
114: endTime: 1700000000006
117: eventTime: 1700000000007
118: logTime: 1700000000007
124: - input: { thread: main, method: onOrder, annotation: OnEventHandler, quantity: 1, price: 9223372036854775807, limit: 9223372036854775807}
125: - calculation: { thread: main, method: calculate, annotation: OnTrigger, value: 9223372036854775807}
126: - limit: { thread: main, method: compare, annotation: OnTrigger, accepted: true}
127: - decision: { thread: main, method: publish, annotation: OnTrigger, decision: ACCEPTED}
128: endTime: 1700000000007
131: eventTime: 1700000000007
132: logTime: 1700000000007
138: endTime: 1700000000007
141: eventTime: 1700000000007
142: logTime: 1700000000007
148: endTime: 1700000000007
Download the visible record as JSON · Inspect the session receipt