Skip to content

Add --lino-output option to write LiNo output to file #54

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
konard wants to merge 3 commits into
base: main
Choose a base branch
from
Open

Add --lino-output option to write LiNo output to file #54

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
88b380d
Initial commit with task details for issue #8
konard Sep 10, 2025
30725a6
Remove CLAUDE.md - PR created successfully
konard Sep 10, 2025
36b7d30
Add --lino-output option to write LiNo output to file
konard Sep 10, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
164 changes: 125 additions & 39 deletions Foundation.Data.Doublets.Cli/Program.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
ο»Ώusing System.CommandLine;
using System.CommandLine.Invocation;
using Platform.Data;
using Platform.Data.Doublets;
using Platform.Data.Doublets.Memory.United.Generic;
Expand Down Expand Up @@ -70,6 +71,11 @@
afterOption.AddAlias("--links");
afterOption.AddAlias("-a");

var linoOutputOption = new Option<string?>(
name: "--lino-output",
description: "Path to write LiNo output to file instead of console"
);

var rootCommand = new RootCommand("LiNo CLI Tool for managing links data store")
{
dbOption,
Expand All @@ -79,75 +85,116 @@
structureOption,
beforeOption,
changesOption,
afterOption
afterOption,
linoOutputOption
};

rootCommand.SetHandler(
(string db, string queryOptionValue, string queryArgumentValue, bool trace, uint? structure, bool before, bool changes, bool after) =>
(InvocationContext context) =>
{
var db = context.ParseResult.GetValueForOption(dbOption)!;
var queryOptionValue = context.ParseResult.GetValueForOption(queryOption) ?? "";
var queryArgumentValue = context.ParseResult.GetValueForArgument(queryArgument) ?? "";
var trace = context.ParseResult.GetValueForOption(traceOption);
var structure = context.ParseResult.GetValueForOption(structureOption);
var before = context.ParseResult.GetValueForOption(beforeOption);
var changes = context.ParseResult.GetValueForOption(changesOption);
var after = context.ParseResult.GetValueForOption(afterOption);
var linoOutput = context.ParseResult.GetValueForOption(linoOutputOption);

var decoratedLinks = new NamedLinksDecorator<uint>(db, trace);

// If --structure is provided, handle it separately
if (structure.HasValue)
// Set up file writer if --lino-output is provided
StreamWriter? fileWriter = null;
if (!string.IsNullOrEmpty(linoOutput))
{
var linkId = structure.Value;
try
{
var structureFormatted = decoratedLinks.FormatStructure(linkId, link => decoratedLinks.IsFullPoint(linkId), true, true);
Console.WriteLine(Namify(decoratedLinks, structureFormatted));
fileWriter = new StreamWriter(linoOutput);
}
catch (Exception ex)
{
Console.Error.WriteLine($"Error formatting structure for link ID {linkId}: {ex.Message}");
Console.Error.WriteLine($"Error opening output file '{linoOutput}': {ex.Message}");
Environment.Exit(1);
}
return; // Exit after handling --structure
}

if (before)
try
{
PrintAllLinks(decoratedLinks);
}
// If --structure is provided, handle it separately
if (structure.HasValue)
{
var linkId = structure.Value;
try
{
var structureFormatted = decoratedLinks.FormatStructure(linkId, link => decoratedLinks.IsFullPoint(linkId), true, true);
var output = Namify(decoratedLinks, structureFormatted);

if (fileWriter != null)
{
fileWriter.WriteLine(output);
}
else
{
Console.WriteLine(output);
}
}
catch (Exception ex)
{
Console.Error.WriteLine($"Error formatting structure for link ID {linkId}: {ex.Message}");
Environment.Exit(1);
}
return; // Exit after handling --structure
}

var effectiveQuery = !string.IsNullOrWhiteSpace(queryOptionValue) ? queryOptionValue : queryArgumentValue;
if (before)
{
PrintAllLinksToFile(decoratedLinks, fileWriter);
}

var changesList = new List<(DoubletLink Before, DoubletLink After)>();
var effectiveQuery = !string.IsNullOrWhiteSpace(queryOptionValue) ? queryOptionValue : queryArgumentValue;

if (!string.IsNullOrWhiteSpace(effectiveQuery))
{
var options = new QueryProcessor.Options
var changesList = new List<(DoubletLink Before, DoubletLink After)>();

if (!string.IsNullOrWhiteSpace(effectiveQuery))
{
Query = effectiveQuery,
Trace = trace,
ChangesHandler = (beforeLink, afterLink) =>
var options = new QueryProcessor.Options
{
changesList.Add((new DoubletLink(beforeLink), new DoubletLink(afterLink)));
return decoratedLinks.Constants.Continue;
}
};
Query = effectiveQuery,
Trace = trace,
ChangesHandler = (beforeLink, afterLink) =>
{
changesList.Add((new DoubletLink(beforeLink), new DoubletLink(afterLink)));
return decoratedLinks.Constants.Continue;
}
};

QueryProcessor.ProcessQuery(decoratedLinks, options);
}
QueryProcessor.ProcessQuery(decoratedLinks, options);
}

if (changes && changesList.Any())
{
// Simplify the collected changes
var simplifiedChanges = SimplifyChanges(changesList);
if (changes && changesList.Any())
{
// Simplify the collected changes
var simplifiedChanges = SimplifyChanges(changesList);

// Print the simplified changes
foreach (var (linkBefore, linkAfter) in simplifiedChanges)
// Print the simplified changes
foreach (var (linkBefore, linkAfter) in simplifiedChanges)
{
PrintChangeToFile(decoratedLinks, linkBefore, linkAfter, fileWriter);
}
}

if (after)
{
PrintChange(decoratedLinks, linkBefore, linkAfter);
PrintAllLinksToFile(decoratedLinks, fileWriter);
}
}

if (after)
finally
{
PrintAllLinks(decoratedLinks);
fileWriter?.Close();
fileWriter?.Dispose();
}
},
// Explicitly specify the type parameters
dbOption, queryOption, queryArgument, traceOption, structureOption, beforeOption, changesOption, afterOption
}
);

await rootCommand.InvokeAsync(args);
Expand Down Expand Up @@ -183,10 +230,49 @@ static void PrintAllLinks(NamedLinksDecorator<uint> links)
});
}

static void PrintAllLinksToFile(NamedLinksDecorator<uint> links, StreamWriter? fileWriter)
{
var any = links.Constants.Any;
var query = new DoubletLink(index: any, source: any, target: any);

links.Each(query, link =>
{
var formattedLink = links.Format(link);
var output = Namify(links, formattedLink);

if (fileWriter != null)
{
fileWriter.WriteLine(output);
}
else
{
Console.WriteLine(output);
}
return links.Constants.Continue;
});
}

static void PrintChange(NamedLinksDecorator<uint> links, DoubletLink linkBefore, DoubletLink linkAfter)
{
var beforeText = linkBefore.IsNull() ? "" : links.Format(linkBefore);
var afterText = linkAfter.IsNull() ? "" : links.Format(linkAfter);
var formattedChange = $"({beforeText}) ({afterText})";
Console.WriteLine(Namify(links, formattedChange));
}

static void PrintChangeToFile(NamedLinksDecorator<uint> links, DoubletLink linkBefore, DoubletLink linkAfter, StreamWriter? fileWriter)
{
var beforeText = linkBefore.IsNull() ? "" : links.Format(linkBefore);
var afterText = linkAfter.IsNull() ? "" : links.Format(linkAfter);
var formattedChange = $"({beforeText}) ({afterText})";
var output = Namify(links, formattedChange);

if (fileWriter != null)
{
fileWriter.WriteLine(output);
}
else
{
Console.WriteLine(output);
}
}