pagan
/
traqtor
forked from 2pm.tech/traqtor
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Clean up. Removed pre-aio projects.

Browse Source
sidewalk-01
Edward M. Kagan 5 years ago
parent 0b67b20009
commit e22677e4e8
87 changed files with 8 additions and 3704 deletions
Show Stats Download Patch File Download Diff File

13
traqtor-framework/src/main/java/link/pagan/traqtor/framework/logic/Service.java → traqtor-aio/src/main/java/link/pagan/traqtor/Filed.java
Unescape Escape View File

@ -3,12 +3,13 @@
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.framework.logic;
package link.pagan.traqtor;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class Service {
import java.io.File;
/** @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >} */
public interface Filed {
public File file ();
}

17
traqtor-aio/src/main/java/link/pagan/traqtor/Traqtor.java
Unescape Escape View File

@ -1,17 +0,0 @@
package link.pagan.traqtor;
import link.pagan.traqtor.deck.IoMaster;
import link.pagan.traqtor.deck.JsonMaster;
/** @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >} */
public abstract class Traqtor {
public static JsonMaster json () {
return JsonMaster.instance();
}
public static IoMaster io () {
return IoMaster.instance();
}
}

112
traqtor-aio/src/main/java/link/pagan/traqtor/deck/IoMaster.java
Unescape Escape View File

@ -1,112 +0,0 @@
package link.pagan.traqtor.deck;
import java.io.File;
import link.pagan.traqtor.Traqtor;
import link.pagan.traqtor.deck.op.OperationResult;
import link.pagan.traqtor.Workspace;
/** @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >} */
public class IoMaster {
private static final IoMaster INSTANCE = new IoMaster();
private IoMaster () {}
public static IoMaster instance () {
return INSTANCE;
}
public OperationResult saveAs (Workspace workspace, File parent) {
return saveAs(workspace, parent, OperationResult.start());
}
public OperationResult saveAs (Workspace workspace, File parent, OperationResult result) {
if (parent == null) {
return result
.info("Target directory must be set, are you OK?")
.fail("Failed to save workspace, no new root directory was passed");
}
if (!parent.exists()) {
return result
.info("Directory " + parent.getAbsolutePath() + " does not exist, deleted/moved/unmounted?")
.fail("Failed to save workspace, due non existent parent direcory for new workspace");
}
if (workspace.name() == null) {
return result
.info("Workspace does not contain name - how did you even achieve that?")
.fail("Failed to save workspace, due unknown name of it, huh...");
}
File root = new File(parent, workspace.name().asTiled());
if (!root.exists()) {
result.info("Creating new root direcory at " + root.getAbsolutePath());
if (!root.mkdirs()) {
return result
.info("Unable to create directory " + root.getAbsolutePath() + " - permission problem?")
.fail("Failed to save workspace, can not create new root directory");
}
}
if (root.listFiles().length > 0) {
return result
.info("Directory " + root.getAbsolutePath() + " is not empty, not safe to save?")
.fail("Failed to save workspace, due to polluted new root direcory");
}
File oldRoot = workspace.root();
workspace.root(root);
result.info("Setting workspace root to " + root.getAbsolutePath());
save(workspace, result.startSubresult());
if (!result.ok()) {
result.info("Reverting workspace root to " + oldRoot.getAbsolutePath());
workspace.root(oldRoot);
}
return result;
}
public OperationResult save (Workspace workspace) {
return save(workspace, OperationResult.start());
}
public OperationResult save (Workspace workspace, OperationResult result) {
result.info("Saving workspace " + workspace.name().asTiled() + " ...");
if (workspace.root() == null) {
return result
.info("Workspace root is not set - is this a new workspace?")
.fail("Failed to save workspace, due to unknown root directory");
}
if (!workspace.root().exists()) {
return result
.info("Directory " + workspace.root().getAbsolutePath() +
" does not exist, deleted/moved/unmounted?")
.fail("Failed to save workspace, due non existent root direcory");
}
if (!workspace.root().canRead()) {
return result
.info("Unable to read " + workspace.root().getAbsolutePath() + " - permission problem?")
.fail("Failed to save workspace, due unreadable root direcory");
}
if (!workspace.root().canWrite()) {
return result
.info("Unable to write " + workspace.root().getAbsolutePath() + " - permission problem?")
.fail("Failed to save workspace, due write restriction on root direcory");
}
result.addSubresult(Traqtor.json().save(workspace));
if (result.ok()) { workspace.dirty(false); }
return result;
}
}

66
traqtor-aio/src/main/java/link/pagan/traqtor/deck/JsonMaster.java
Unescape Escape View File

@ -1,66 +0,0 @@
package link.pagan.traqtor.deck;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.databind.module.SimpleModule;
import java.io.File;
import java.io.IOException;
import java.util.logging.Level;
import java.util.logging.Logger;
import link.pagan.traqtor.Workspace;
import link.pagan.traqtor.WorkspaceSerializer;
import link.pagan.traqtor.deck.op.OperationResult;
import link.pagan.traqtor.project.universe.UniverseProject;
import link.pagan.traqtor.project.universe.UniverseProjectSerializer;
import link.pagan.traqtor.project.universe.element.Element;
import link.pagan.traqtor.project.universe.element.ElementSerializer;
import link.pagan.traqtor.project.universe.element.Particle;
import link.pagan.traqtor.project.universe.element.PaticleInfoSerializer;
import link.pagan.traqtor.project.universe.link.Link;
import link.pagan.traqtor.project.universe.link.LinkSerializer;
import link.pagan.traqtor.project.universe.schema.Constraint;
import link.pagan.traqtor.project.universe.schema.ConstraintInfoSerializer;
import link.pagan.traqtor.util.Name;
import link.pagan.traqtor.util.NameSerializer;
/** @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >} */
public class JsonMaster {
private static final JsonMaster INSTANCE = new JsonMaster();
private final ObjectMapper mapper;
public JsonMaster () {
this.mapper = new ObjectMapper()
.enable(SerializationFeature.INDENT_OUTPUT)
.registerModule(new SimpleModule()
.addSerializer(Name.class, new NameSerializer())
.addSerializer(UniverseProject.class, new UniverseProjectSerializer())
.addSerializer(Element.class, new ElementSerializer())
.addSerializer(Particle.class, new PaticleInfoSerializer())
.addSerializer(Constraint.class, new ConstraintInfoSerializer())
.addSerializer(Link.class, new LinkSerializer())
.addSerializer(Workspace.class, new WorkspaceSerializer()));
}
public static JsonMaster instance () {
return INSTANCE;
}
public OperationResult save (Workspace workspace) {
OperationResult result = OperationResult.start();
File workspaceDesciptorFile = new File(workspace.root(), "workspace.json");
result.info("Writing workspace descriptor file to " + workspaceDesciptorFile.getAbsolutePath() + " ...");
try {
mapper.writeValue(workspaceDesciptorFile, workspace);
} catch (IOException ex) {
Logger.getLogger(IoMaster.class.getName()).log(Level.SEVERE, null, ex);
result.fail("Failed to write file " + workspaceDesciptorFile.getAbsolutePath() + " - IO exception");
result.fail(ex);
}
return result;
}
}

22
traqtor-aio/src/main/java/link/pagan/traqtor/project/database/Database.java
Unescape Escape View File

@ -1,22 +0,0 @@
package link.pagan.traqtor.project.database;
/** @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >} */
public class Database {
public static DatabaseProject project () {
return new DatabaseProject();
}
public static DatabaseSchema schema () {
return new DatabaseSchema();
}
public static DatabaseTable table () {
return new DatabaseTable();
}
public static DatabaseColumn column () {
return new DatabaseColumn();
}
}

180
traqtor-aio/src/test/java/link/pagan/traqtor/EndToEndTest.java
Unescape Escape View File

@ -1,180 +0,0 @@
package link.pagan.traqtor;
import com.fasterxml.jackson.core.JsonProcessingException;
import link.pagan.traqtor.project.universe.UniverseProject;
import link.pagan.traqtor.project.universe.Universe;
import link.pagan.traqtor.project.universe.element.Element;
import link.pagan.traqtor.project.universe.element.Particle;
import link.pagan.traqtor.project.universe.schema.DatatypeSchema;
import link.pagan.traqtor.project.universe.schema.impl.LiteralDataTypeSchema;
import link.pagan.traqtor.project.universe.schema.impl.LogicDatatypeSchema;
import link.pagan.traqtor.project.universe.schema.impl.NumericDatatypeSchema;
import link.pagan.traqtor.project.universe.schema.impl.TemporalDatatypeSchema;
import link.pagan.traqtor.project.universe.schema.impl.data.literal.StringDataType;
import link.pagan.traqtor.project.universe.schema.impl.data.numeric.integer.IntDataType;
import link.pagan.traqtor.project.universe.schema.impl.data.numeric.real.DoubleDataType;
import link.pagan.traqtor.project.universe.schema.impl.data.numeric.real.FloatDataType;
import link.pagan.traqtor.util.RegExpHelper;
import org.junit.jupiter.api.Test;
public class EndToEndTest {
@Test
void endToEndTest () throws JsonProcessingException {
DatatypeSchema LITERAL = LiteralDataTypeSchema.instance();
DatatypeSchema LOGIC = LogicDatatypeSchema.instance();
DatatypeSchema NUMERIC = NumericDatatypeSchema.instance();
DatatypeSchema TEMPORAL = TemporalDatatypeSchema.instance();
StringDataType STRING = LiteralDataTypeSchema.instance().STRING;
// LogicDataType BOOLEAN = LOGIC.BOOLEAN;
// IntegerDataType BYTE = NUMERIC.BYTE;
// IntegerDataType SHORT = NUMERIC.SHORT;
IntDataType INTEGER = NumericDatatypeSchema.instance().INTEGER;
// IntegerDataType LONG = NUMERIC.LONG;
FloatDataType FLOAT = NumericDatatypeSchema.instance().FLOAT;
DoubleDataType DOUBLE = NumericDatatypeSchema.instance().DOUBLE;
// TemporalDataType DATE = TEMPORAL.DATE;
// TemporalDataType TIME = TEMPORAL.TIME;
// TemporalDataType TIMESTAMP = TEMPORAL.TIMESTAMP;
Particle<StringDataType> email = STRING.particle()
.name("email")
.description("email as main identifier for an account")
.constraints(STRING.min(4), STRING.max(512), STRING.regExp(RegExpHelper.EMAIL));
Particle<StringDataType> phone = STRING.particle()
.name("phone")
.description("alternative identifier for an account")
.optional()
.constraints(STRING.min(10), STRING.max(32), STRING.regExp(RegExpHelper.PHONE));
Particle<StringDataType> password = STRING.particle()
.name("phone")
.description("account password")
.constraints(STRING.min(8), STRING.max(32));
Element account = Universe.atom()
.name("account")
.particles(email, phone, password);
Particle<StringDataType> lastName = STRING.particle()
.name("last", "name")
.description("last name of user")
.constraints(STRING.max(64), STRING.min(1));
Particle<StringDataType> firstName = STRING.particle()
.name("first", "name")
.description("first name of user")
.optional()
.constraints(STRING.max(64), STRING.min(1));
Particle<IntDataType> age = INTEGER.particle()
.name("age")
.description("age of user owning an account")
.constraints(INTEGER.min(18), INTEGER.max(65));
Element accountDetails = Universe.atom()
.name("account", "details")
.particles(lastName, firstName, age);
Particle<DoubleDataType> length = DOUBLE.particle()
.name("length")
.description("penis length")
.constraints(DOUBLE.min(0), DOUBLE.max(40));
Element male = Universe.isotope()
.base(account)
.name("male")
.particles(length);
Particle<FloatDataType> depth = FLOAT.particle()
.name("depth")
.description("vagina depth")
.constraints(DOUBLE.min(0), DOUBLE.max(40));
Element female = Universe.isotope()
.base(account)
.name("female")
.particles(depth);
Particle<StringDataType> positionName = STRING.particle()
.name("title")
.description("position name")
.constraints(STRING.max(255), STRING.min(3));
Element position = Universe.atom()
.name("position")
.particles(positionName);
Particle<StringDataType> idNumber = STRING.particle()
.name("number")
.description("military id number")
.constraints(STRING.max(11), STRING.min(11));
Element militaryId = Universe.atom()
.name("military", "id")
.particles(idNumber);
Element profile = Universe.atom()
.name(("profile"));
UniverseProject baseUniverse = Universe.project()
.name("base")
.schemas(LITERAL, LOGIC, NUMERIC, TEMPORAL)
.elements(account, accountDetails, male, female, position, militaryId, profile)
.links(Universe.linkOneToOne()
.from(account)
.fromName("details")
.to(accountDetails)
.toName("account")
.mandatory(), Universe.linkOneToMany()
.from(account)
.fromName("profiles")
.to(profile)
.toName("account")
.more(0), Universe.linkManyToMany()
.from(profile)
.fromName("positions")
.to(position)
.toName("profiles"), Universe.linkOneToOne()
.from(male)
.fromName("military", "id")
.to(militaryId)
.toName("account"));
Particle<StringDataType> organizationName = STRING.particle()
.name("name")
.description("full name of an organization")
.constraints(STRING.max(255), STRING.min(3));
Element organization = Universe.atom();
organization.name("organization");
organization.particles(organizationName);
UniverseProject dataUniverse = Universe.project()
.name("data")
.schemas(LITERAL)
.elements(organization);
// try {
//
// String writeValueAsString = mapper.writeValueAsString(dataUniverse);
// // DatabaseProject mainDatabase = Database.project()
// // .name("primary")
// // .universes(baseUniverse, dataUniverse)
// // .addSchema(Database.schema()
// // .name("public")
// // .tables(Database.table()
// // .columns()));
Workspace workspace = new Workspace()
.name("link", "pagan")
.projects(baseUniverse, dataUniverse);
// } catch (JsonProcessingException ex) {
// Logger.getLogger(EndToEndTest.class.getName()).log(Level.SEVERE, null, ex);
// }
Traqtor.io().save(workspace);
// System.out.println(Traqtor.io().toFileHandle(baseUniverse).content());
// System.out.println(Traqtor.io().toFileHandle(dataUniverse).content());
}
}

35
traqtor-aio/src/test/java/link/pagan/traqtor/WorkspaceTest.java
Unescape Escape View File

@ -1,35 +0,0 @@
package link.pagan.traqtor;
import java.io.IOException;
import link.pagan.traqtor.test.TestUtils;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
/** @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >} */
public class WorkspaceTest {
@BeforeEach
public void cleanTestDir () throws IOException {
TestUtils.rebuildTestRoot();
}
@AfterEach
public void killCore () throws IOException {
TestUtils.deleteTestRoot();
}
@Test
@DisplayName("Workspace save")
void workspaceSave () throws IOException {
Workspace workspace = new Workspace().name("traqtor", "demo", "workspace");
Assertions.assertTrue(!Traqtor.io().save(workspace).ok());
TestUtils.deleteTestRoot();
Assertions.assertTrue(!Traqtor.io().save(workspace.root(TestUtils.testRoot())).ok());
TestUtils.rebuildTestRoot();
Assertions.assertTrue(Traqtor.io().saveAs(workspace, TestUtils.testRoot()).ok());
}
}

75
traqtor-api/pom.xml
Unescape Escape View File

@ -1,75 +0,0 @@
<?xml version="1.0"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor-api</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>TraQtor / API </name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.junit</groupId>
<artifactId>junit-bom</artifactId>
<version>5.7.1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>traqtor-schema</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>traqtor-schema-ref</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>traqtor-generator</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>traqtor-framework</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.12.1</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
</plugin>
<plugin>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.22.2</version>
</plugin>
</plugins>
</build>
</project>

24
traqtor-api/src/main/java/link/pagan/traqtor/_api/BinaryCommand.java
Unescape Escape View File

@ -1,24 +0,0 @@
// package link.pagan.traqtor._api;
// import link.pagan.traqtor._api.result.CommandExecResult;
// /**
// *
// * @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
// */
// public abstract class BinaryCommand<T extends Commanded, R extends Commanded> extends UnaryCommand<T> {
// protected R arg2;
// public CommandExecResult subexec(BinaryCommand<T, R> subcommand) {
// subcommand.setResultHolder(result);
// subcommand.setArg(arg);
// subcommand.setArg2(arg2);
// return subcommand.exec();
// }
// public void setArg2(R arg2) {
// this.arg2 = arg2;
// }
// }

9
traqtor-api/src/main/java/link/pagan/traqtor/_api/Commanded.java
Unescape Escape View File

@ -1,9 +0,0 @@
package link.pagan.traqtor._api;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public interface Commanded {
}

31
traqtor-api/src/main/java/link/pagan/traqtor/_api/Executor.java
Unescape Escape View File

@ -1,31 +0,0 @@
//package link.pagan.traqtor._api;
//
//import link.pagan.traqtor._api.result.CommandExecResult;
//import link.pagan.traqtor._api.result.CommandExecResultStatus;
//
///**
// *
// * @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
// */
//public abstract class Executor<T extends Executor<T>> extends Commanded<T> {
//
//
//
// @SuppressWarnings("unchecked")
// public CommandExecResult execute(Command<T> command) {
// CommandExecResult result = new CommandExecResult();
// command.setResultHolder(result);
// command.exec((T) this);
// if (!mute) {
// if (paranoindLoggin) {
// result.print();
// } else {
// if (result.getStatus() != CommandExecResultStatus.DONE) {
// result.print();
// }
// }
// }
// return result;
// }
//
//}

77
traqtor-api/src/main/java/link/pagan/traqtor/_api/UnaryCommand.java
Unescape Escape View File

@ -1,77 +0,0 @@
package link.pagan.traqtor._api;
import link.pagan.traqtor._api.result.CommandExecResult;
import link.pagan.traqtor._api.result.message.CommandExecMessage;
import link.pagan.traqtor._api.result.message.CommandExecMessageStatus;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public abstract class UnaryCommand<T extends Commanded> {
private static boolean paranoindLoggin = false;
private static boolean mute = true;
public static void enableParanoindLoggin() {
enableLog();
paranoindLoggin = true;
}
public static void enableLog() {
mute = false;
}
protected CommandExecResult result;
protected T arg;
public abstract CommandExecResult exec();
public CommandExecResult subexec(UnaryCommand<T> subcommand) {
subcommand.setResultHolder(result);
subcommand.setArg(arg);
return subcommand.exec();
}
protected CommandExecResult fail(String message) {
result.add(new CommandExecMessage(CommandExecMessageStatus.FAIL, message));
return result;
}
protected CommandExecResult info(String message) {
result.add(new CommandExecMessage(CommandExecMessageStatus.INFO, message));
return result;
}
protected CommandExecResult warn(String message) {
result.add(new CommandExecMessage(CommandExecMessageStatus.WARN, message));
return result;
}
protected CommandExecResult done(String message) {
result.add(new CommandExecMessage(CommandExecMessageStatus.DONE, message));
return result;
}
protected CommandExecResult done() {
result.add(new CommandExecMessage(CommandExecMessageStatus.DONE, "OK"));
return result;
}
public void setResultHolder(CommandExecResult result) {
this.result = result;
}
public void setArg(T arg) {
this.arg = arg;
}
public static boolean paranoidLoggingEnabled() {
return paranoindLoggin;
}
public static boolean mute() {
return mute;
}
}

42
traqtor-api/src/main/java/link/pagan/traqtor/_api/result/CommandExecResult.java
Unescape Escape View File

@ -1,42 +0,0 @@
package link.pagan.traqtor._api.result;
import java.util.ArrayList;
import link.pagan.traqtor._api.result.message.CommandExecMessage;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class CommandExecResult {
final ArrayList<CommandExecMessage> messages;
public CommandExecResult() {
this.messages = new ArrayList<CommandExecMessage>();
}
public void add(CommandExecMessage message) {
this.messages.add(message);
}
public boolean OK () {
return this.getStatus() != CommandExecResultStatus.FAIL;
}
public CommandExecResultStatus getStatus() {
int status = 100;
for (CommandExecMessage message : messages) {
if (status > message.getStatus().getCode()) {
status = message.getStatus().getCode();
}
}
return CommandExecResultStatus.ofCode(status);
}
public void print() {
for (CommandExecMessage message : messages) {
message.print();
}
}
}

27
traqtor-api/src/main/java/link/pagan/traqtor/_api/result/CommandExecResultStatus.java
Unescape Escape View File

@ -1,27 +0,0 @@
package link.pagan.traqtor._api.result;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public enum CommandExecResultStatus {
DONE(0),
WARN(-1),
FAIL(-2);
int code;
private CommandExecResultStatus(int code) {
this.code = code;
}
public int getCode() {
return code;
}
public static CommandExecResultStatus ofCode (int code) {
if (code < -1) return FAIL;
if (code == -1) return WARN;
return DONE;
}
}

33
traqtor-api/src/main/java/link/pagan/traqtor/_api/result/message/CommandExecMessage.java
Unescape Escape View File

@ -1,33 +0,0 @@
package link.pagan.traqtor._api.result.message;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class CommandExecMessage {
final CommandExecMessageStatus status;
final String message;
public CommandExecMessage(CommandExecMessageStatus status, String message) {
this.status = status;
this.message = message;
}
public CommandExecMessageStatus getStatus() {
return status;
}
public String getMessage() {
return message;
}
public void print() {
// if (status.getCode() < 0) {
System.out.println(status.toString() + " : " + message);
// } else {
// System.out.println(status.toString() + " : " + message);
// }
}
}

28
traqtor-api/src/main/java/link/pagan/traqtor/_api/result/message/CommandExecMessageStatus.java
Unescape Escape View File

@ -1,28 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor._api.result.message;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public enum CommandExecMessageStatus {
INFO(1),
DONE(0),
WARN(-1),
FAIL(-2);
int code;
private CommandExecMessageStatus(int code) {
this.code = code;
}
public int getCode() {
return code;
}
}

298
traqtor-api/src/main/java/link/pagan/traqtor/api/API.java
Unescape Escape View File

@ -1,298 +0,0 @@
package link.pagan.traqtor.api;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.module.SimpleModule;
import java.io.File;
import java.io.IOException;
import java.util.HashMap;
import link.pagan.traqtor._api.UnaryCommand;
import link.pagan.traqtor._api.result.CommandExecResult;
import link.pagan.traqtor._api.result.message.CommandExecMessage;
import link.pagan.traqtor._api.result.message.CommandExecMessageStatus;
import link.pagan.traqtor.api.project.Project;
import link.pagan.traqtor.api.project.universe.UniverseProject;
import link.pagan.traqtor.api.workspace.Workspace;
import link.pagan.traqtor.schema.data.DataTypeSchema;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class API {
private static boolean workspaceExists (CommandExecResult result, Traqtor traqtor) {
if (traqtor.workspace() == null) {
result.add(new CommandExecMessage(CommandExecMessageStatus.FAIL, "No workspace initialized"));
return false;
}
return true;
}
public static class CreateWorkspace extends UnaryCommand<Traqtor> {
private final Name name;
private final String path;
public CreateWorkspace() {
this(Workspace.DEFAULT_WORKSPACE_NAME);
}
public CreateWorkspace(Name name) {
this(name, null);
}
public CreateWorkspace(Name name, String path) {
this.name = name;
this.path = path;
}
@Override
public CommandExecResult exec() {
if (arg.workspace() != null) {
return fail("There is an open workspace - please close this first, before creating new one");
}
arg.workspace(new Workspace());
arg.workspace().name(name);
subexec(new API.WorkspaceLoadDataTypeSchema(Name.of("traqtor", "basic")));
if (!result.OK()) {
arg.workspace(null);
return result;
}
if (path != null) {
subexec(new SaveAsWorkspace(path));
if (!result.OK()) {
arg.workspace(null);
return result;
}
}
return done();
}
}
public static class SaveAsWorkspace extends UnaryCommand<Traqtor> {
private final String workspacePath;
public SaveAsWorkspace(String workspacePath) {
this.workspacePath = workspacePath;
}
@Override
public CommandExecResult exec() {
File workspaceDir = new File(workspacePath);
if (!workspaceDir.exists()) {
if (!workspaceDir.mkdir()) {
return fail("Failed to create workspace root directory at " + workspacePath);
} else {
info("Workspace root directory created at " + workspacePath);
}
} else {
if (workspaceDir.listFiles().length > 0) {
return fail("Root directory is not empty, failed to assing " + workspacePath + " as root for workspace");
}
}
File workspaceFile = new File(workspacePath, Workspace.JSON_FILENAME + ".json");
if (!workspaceFile.exists()) {
try {
if (!workspaceFile.createNewFile()) {
return fail("Failed to create " + Workspace.JSON_FILENAME + ".json in workspace root directory");
}
} catch (IOException ex) {
return fail("IO erorr while creating " + Workspace.JSON_FILENAME + ".json in workspace root directory");
}
}
String hold = arg.workspace().root();
arg.workspace().root(workspacePath);
subexec(new SaveWorkspace());
if (!result.OK()) {
arg.workspace().root(hold);
return result;
}
return done();
}
}
public static class SaveWorkspace extends UnaryCommand<Traqtor> {
@Override
public CommandExecResult exec() {
String workspacePath = arg.workspace().root();
if (arg.workspace().root() == null) {
return fail("Workspace was not saved before - use \"save as\" command for the first save");
}
File workspaceFile = new File(workspacePath, Workspace.JSON_FILENAME + ".json");
if (!workspaceFile.exists()) {
return fail("Failed to save, " + Workspace.JSON_FILENAME + ".json does not exist, workspace corrupted?");
}
if (!workspaceFile.canWrite()) {
return fail("Can not write " + Workspace.JSON_FILENAME + ".json - permission denied");
}
try {
arg.workspace().mapper().writeValue(workspaceFile, arg.workspace());
} catch (IOException ex) {
System.err.println(ex);
return fail("Failed to write " + Workspace.JSON_FILENAME + ".json");
}
arg.workspace().dirty(false);
return done();
}
}
public static class LoadWorkspace extends UnaryCommand<Traqtor> {
private final String workspacePath;
public LoadWorkspace(String workspacePath) {
this.workspacePath = workspacePath;
}
@Override
public CommandExecResult exec() {
File workspaceFile = new File(workspacePath, Workspace.JSON_FILENAME + ".json");
if (!workspaceFile.exists()) {
return fail("No " + Workspace.JSON_FILENAME + ".json file found in selected directory, missed?");
}
ObjectMapper mapper = new ObjectMapper();
SimpleModule module = new SimpleModule();
module.addDeserializer(Workspace.class, new Workspace.WorkspaceDeserializer());
mapper.registerModule(module);
Workspace workspace = null;
try {
workspace = mapper.readValue(workspaceFile, Workspace.class);
} catch (IOException ex) {
System.err.println(ex);
return fail("Failed to read " + workspaceFile.getAbsolutePath());
}
workspace.root(workspacePath);
HashMap<Name, DataTypeSchema> schemas = workspace.dataTypeSchemas();
for (Name name : schemas.keySet()) {
if (schemas.get(name) == null) {
DataTypeSchema loaded = arg.dataTypeSchemas.get(name);
if (loaded == null) {
warn("Shema with name " + name.asDotted() + " was not found in system. Preload or give up");
} else {
schemas.put(name, loaded);
info("Shema " + name.asDotted() + " was found and loaded into workspace on load");
}
}
}
arg.workspace(workspace);
return done();
}
}
public static class WorkspaceLoadDataTypeSchema extends UnaryCommand<Traqtor> {
private final Name name;
public WorkspaceLoadDataTypeSchema(Name name) {
this.name = name;
}
@Override
public CommandExecResult exec() {
if (!workspaceExists(result, arg)) {
return result;
}
DataTypeSchema schema = arg.dataTypeSchemas.get(this.name);
if (schema == null) {
return fail("Unable to load data type schema by name " + name.asDotted());
}
arg.workspace().dataTypeSchemas().put(schema.getName(), schema);
return done();
}
}
public static class WorkspaceCreateUniverseProject extends UnaryCommand<Traqtor> {
private final Name name;
private final Name schema;
public WorkspaceCreateUniverseProject(Name name, Name schema) {
this.name = name;
this.schema = schema;
}
@Override
public CommandExecResult exec() {
if (!workspaceExists(result, arg)) {
return result;
}
Workspace workspace = arg.workspace();
DataTypeSchema dataTypeSchema = workspace.dataTypeSchemas().get(schema);
if (dataTypeSchema == null) {
return fail("Data type schema with name " + schema.asDotted() + " was not found");
}
if (workspace.projects().containsKey(this.name)) {
return fail("Project with name " + this.name + " already exists");
}
Project project = new UniverseProject(name, dataTypeSchema);
workspace.projects().put(project.name(), project);
workspace.dirty(true);
CommandExecResult saveResult = arg.execute(new API.SaveWorkspace());
if (!saveResult.OK()) {
return fail("Failed to save workspace, after project addition");
}
return done();
}
}
public static class ProjectSave extends UnaryCommand<Traqtor> {
private final Name name;
private final Name schema;
public ProjectSave(Name name, Name schema) {
this.name = name;
this.schema = schema;
}
@Override
public CommandExecResult exec() {
if (!workspaceExists(result, arg)) {
return result;
}
Workspace workspace = arg.workspace();
DataTypeSchema dataTypeSchema = workspace.dataTypeSchemas().get(schema);
if (dataTypeSchema == null) {
return fail("Data type schema with name " + schema.asDotted() + " was not found");
}
if (workspace.projects().containsKey(this.name)) {
return fail("Project with name " + this.name + " already exists");
}
Project project = new UniverseProject(name, dataTypeSchema);
workspace.projects().put(project.name(), project);
workspace.dirty(true);
CommandExecResult saveResult = arg.execute(new API.SaveWorkspace());
if (!saveResult.OK()) {
return fail("Failed to save workspace, after project addition");
}
return done();
}
}
}

63
traqtor-api/src/main/java/link/pagan/traqtor/api/Traqtor.java
Unescape Escape View File

@ -1,63 +0,0 @@
package link.pagan.traqtor.api;
import java.util.HashMap;
import java.util.Map;
import link.pagan.traqtor._api.UnaryCommand;
import link.pagan.traqtor._api.Commanded;
import link.pagan.traqtor._api.result.CommandExecResult;
import link.pagan.traqtor._api.result.CommandExecResultStatus;
import link.pagan.traqtor.api.workspace.Workspace;
import link.pagan.traqtor.schema.basic.data.DataTypeSchemaReferenceImplementation;
import link.pagan.traqtor.schema.data.DataTypeSchema;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class Traqtor implements Commanded {
private Workspace workspace;
Map<Name, DataTypeSchema> dataTypeSchemas;
public static Traqtor init() {
Traqtor traqtor = new Traqtor();
traqtor.registerDataTypeSchema(new DataTypeSchemaReferenceImplementation());
return traqtor;
}
private void registerDataTypeSchema(DataTypeSchema schema) {
this.dataTypeSchemas.put(schema.getName(), schema);
}
private Traqtor() {
this.dataTypeSchemas = new HashMap<>();
}
public Workspace workspace() {
return workspace;
}
public void workspace(Workspace workspace) {
this.workspace = workspace;
}
public CommandExecResult execute(UnaryCommand<Traqtor> command) {
CommandExecResult result = new CommandExecResult();
command.setResultHolder(result);
command.setArg(this);
command.exec();
if (!UnaryCommand.mute()) {
if (UnaryCommand.paranoidLoggingEnabled()) {
result.print();
} else {
if (result.getStatus() != CommandExecResultStatus.DONE) {
result.print();
}
}
}
return result;
}
}

42
traqtor-api/src/main/java/link/pagan/traqtor/api/project/Project.java
Unescape Escape View File

@ -1,42 +0,0 @@
package link.pagan.traqtor.api.project;
import link.pagan.traqtor._api.Commanded;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public abstract class Project implements Commanded {
private final ProjectType type;
private Name name;
private boolean dirty;
public Project(ProjectType type, Name name) {
this.type = type;
this.name = name;
this.dirty = true;
}
public ProjectType type() {
return type;
}
public Name name() {
return name;
}
public void name(Name name) {
this.name = name;
}
public boolean dirty() {
return dirty;
}
public void dirty(boolean dirty) {
this.dirty = dirty;
}
}

74
traqtor-api/src/main/java/link/pagan/traqtor/api/project/ProjectType.java
Unescape Escape View File

@ -1,74 +0,0 @@
package link.pagan.traqtor.api.project;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.deser.std.StdDeserializer;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import java.io.IOException;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public enum ProjectType {
UNIVERSE("universe"),
DATABASE("database"),
FRONTEND("frontend"),
BACKEND("backend");
String jsonValue;
private ProjectType(String jsonValue) {
this.jsonValue = jsonValue;
}
public static final class ProjectTypeSerializer extends StdSerializer<ProjectType> {
private static final long serialVersionUID = 1L;
public ProjectTypeSerializer() {
this(null);
}
public ProjectTypeSerializer(Class<ProjectType> t) {
super(t);
}
@Override
public void serialize(ProjectType value, JsonGenerator gen, SerializerProvider provider) throws IOException {
gen.writeString(value.jsonValue);
}
}
public static final class ProjectTypeDeserializer extends StdDeserializer<ProjectType> {
private static final long serialVersionUID = 1L;
public ProjectTypeDeserializer() {
this(null);
}
public ProjectTypeDeserializer(Class<ProjectType> t) {
super(t);
}
@Override
public ProjectType deserialize(JsonParser parser, DeserializationContext ctxt) throws IOException, JsonProcessingException {
JsonNode stringType = parser.getCodec().readTree(parser);
String type = stringType.asText();
for (ProjectType pt : values()) {
if (pt.jsonValue.equals(type)) {
return pt;
}
}
return null;
}
}
}

22
traqtor-api/src/main/java/link/pagan/traqtor/api/project/backend/BackendProject.java
Unescape Escape View File

@ -1,22 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.api.project.backend;
import link.pagan.traqtor.api.project.Project;
import link.pagan.traqtor.api.project.ProjectType;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class BackendProject extends Project {
public BackendProject(Name name) {
super(ProjectType.BACKEND, name);
}
}

22
traqtor-api/src/main/java/link/pagan/traqtor/api/project/database/DatabaseProject.java
Unescape Escape View File

@ -1,22 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.api.project.database;
import link.pagan.traqtor.api.project.Project;
import link.pagan.traqtor.api.project.ProjectType;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class DatabaseProject extends Project {
public DatabaseProject(Name name) {
super(ProjectType.DATABASE, name);
}
}

22
traqtor-api/src/main/java/link/pagan/traqtor/api/project/frontend/FrontendProject.java
Unescape Escape View File

@ -1,22 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.api.project.frontend;
import link.pagan.traqtor.api.project.Project;
import link.pagan.traqtor.api.project.ProjectType;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class FrontendProject extends Project {
public FrontendProject(Name name) {
super(ProjectType.FRONTEND, name);
}
}

22
traqtor-api/src/main/java/link/pagan/traqtor/api/project/universe/UniverseProject.java
Unescape Escape View File

@ -1,22 +0,0 @@
package link.pagan.traqtor.api.project.universe;
import link.pagan.traqtor.api.project.Project;
import link.pagan.traqtor.api.project.ProjectType;
import link.pagan.traqtor.schema.data.DataTypeSchema;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class UniverseProject extends Project {
DataTypeSchema dataTypeSchema;
public UniverseProject(Name name, DataTypeSchema dataTypeSchema) {
super(ProjectType.UNIVERSE, name);
this.dataTypeSchema = dataTypeSchema;
}
}

188
traqtor-api/src/main/java/link/pagan/traqtor/api/workspace/Workspace.java
Unescape Escape View File

@ -1,188 +0,0 @@
package link.pagan.traqtor.api.workspace;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.SerializationFeature;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.deser.std.StdDeserializer;
import com.fasterxml.jackson.databind.module.SimpleModule;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import link.pagan.traqtor._api.Commanded;
import link.pagan.traqtor.api.project.Project;
import link.pagan.traqtor.generator.blueprint.universe.AtomBlueprint;
import link.pagan.traqtor.generator.blueprint.universe.LinkBlueprint;
import link.pagan.traqtor.generator.blueprint.universe.LinkType;
import link.pagan.traqtor.generator.blueprint.universe.ParticleBlueprint;
import link.pagan.traqtor.generator.blueprint.universe.UniverseBlueprint;
import link.pagan.traqtor.schema.data.DataTypeSchema;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class Workspace implements Commanded {
public static final String JSON_FILENAME = "workspace";
public static final Name DEFAULT_WORKSPACE_NAME = Name.of("workspace");
private final ObjectMapper mapper;
private boolean dirty;
private String root;
private Name name;
private HashMap<Name, DataTypeSchema> schemas;
private HashMap<Name, Project> projects;
public Workspace() {
this.mapper = new ObjectMapper().enable(SerializationFeature.INDENT_OUTPUT);
SimpleModule module = new SimpleModule();
module.addSerializer(Workspace.class, new Workspace.WorkspaceSerializer());
module.addSerializer(UniverseBlueprint.class, new UniverseBlueprint.UniverseBlueprintSerializer());
module.addSerializer(Name.class, new Name.NameSerializer());
module.addDeserializer(Name.class, new Name.NameDeserializer());
module.addSerializer(ParticleBlueprint.class, new ParticleBlueprint.ParticleBlueprintSerializer());
module.addSerializer(AtomBlueprint.class, new AtomBlueprint.AtomBlueprintSerializer());
module.addSerializer(LinkBlueprint.class, new LinkBlueprint.LinkBlueprintSerializer());
module.addSerializer(LinkType.class, new LinkType.LinkTypeSerializer());
mapper.registerModule(module);
this.dirty = true;
this.projects = new HashMap<>();
this.schemas = new HashMap<>();
}
public Name name() {
return name;
}
public String root() {
return root;
}
public void root(String root) {
this.root = root;
}
public void name(Name name) {
this.name = name;
}
public ObjectMapper mapper() {
return mapper;
}
public boolean dirty() {
return dirty;
}
public void dirty(boolean dirty) {
this.dirty = dirty;
}
public HashMap<Name, DataTypeSchema> dataTypeSchemas() {
return schemas;
}
public HashMap<Name, Project> projects() {
return projects;
}
public static final class WorkspaceSerializer extends StdSerializer<Workspace> {
private static final long serialVersionUID = 1L;
public WorkspaceSerializer() {
this(null);
}
public WorkspaceSerializer(Class<Workspace> t) {
super(t);
}
@Override
public void serialize(Workspace value, JsonGenerator gen, SerializerProvider provider) throws IOException {
gen.writeStartObject();
gen.writeObjectField("name", value.name);
gen.writeBooleanField("pretty", value.mapper.isEnabled(SerializationFeature.INDENT_OUTPUT));
gen.writeArrayFieldStart("schemas");
ArrayList<Name> schemaNames = new ArrayList<>();
for (Name schemaName : value.schemas.keySet()) {
schemaNames.add(schemaName);
}
schemaNames.sort(Name.COMPARATOR);
for (Name name : schemaNames) {
gen.writeObject(name);
}
gen.writeEndArray();
gen.writeArrayFieldStart("projects");
ArrayList<Name> projectNames = new ArrayList<>();
for (Name projectName : value.projects.keySet()) {
projectNames.add(projectName);
}
projectNames.sort(Name.COMPARATOR);
for (Name name : projectNames) {
gen.writeObject(name);
}
gen.writeEndArray();
gen.writeEndObject();
}
}
public static final class WorkspaceDeserializer extends StdDeserializer<Workspace> {
private static final long serialVersionUID = 1L;
public WorkspaceDeserializer() {
this(null);
}
public WorkspaceDeserializer(Class<Workspace> t) {
super(t);
}
@Override
public Workspace deserialize(JsonParser parser, DeserializationContext context) throws IOException, JsonProcessingException {
Workspace workspace = new Workspace();
JsonNode node = parser.getCodec().readTree(parser);
boolean pretty = node.get("pretty").asBoolean(false);
if (pretty) {
workspace.mapper.enable(SerializationFeature.INDENT_OUTPUT);
} else {
workspace.mapper.disable(SerializationFeature.INDENT_OUTPUT);
}
Name name = workspace.mapper.treeToValue(node.get("name"), Name.class);
workspace.name(name);
for (JsonNode schema : node.get("schemas")) {
Name readValue = workspace.mapper.readValue(schema.toString(), Name.class);
workspace.schemas.put(readValue, null);
}
for (JsonNode project : node.get("projects")) {
workspace.projects.put(workspace.mapper.readValue(project.asText(), Name.class), null);
}
workspace.dirty = false;
return workspace;
}
}
}

29
traqtor-api/src/test/java/link/pagan/traqtor/_api/TraqtorApiTestUtils.java
Unescape Escape View File

@ -1,29 +0,0 @@
package link.pagan.traqtor._api;
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.util.Comparator;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class TraqtorApiTestUtils {
public static final String TEST_WORKSPACE_ROOT = new File(new File("").getAbsoluteFile().getParentFile(), "traqtor-demo-workspace").getAbsolutePath();
public static final Name TEST_WORKSPACE_NAME = Name.of("traqtor", "demo", "workspace");
public static final void killTestRoot() throws IOException {
File root = new File(TEST_WORKSPACE_ROOT);
if (root.exists()) {
Files.walk(new File(TEST_WORKSPACE_ROOT).toPath())
.sorted(Comparator.reverseOrder())
.map(Path::toFile)
.forEach(File::delete);
}
}
}

59
traqtor-api/src/test/java/link/pagan/traqtor/api/TraqtorTest.java
Unescape Escape View File

@ -1,59 +0,0 @@
package link.pagan.traqtor.api;
import java.io.IOException;
import link.pagan.traqtor._api.TraqtorApiTestUtils;
import link.pagan.traqtor._api.result.CommandExecResult;
import static link.pagan.traqtor._api.result.CommandExecResultStatus.DONE;
import static link.pagan.traqtor._api.result.CommandExecResultStatus.FAIL;
import static org.junit.jupiter.api.Assertions.assertEquals;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class TraqtorTest {
CommandExecResult result;
@BeforeEach
public void cleanTestDir() throws IOException {
TraqtorApiTestUtils.killTestRoot();
// Executor.enableParanoindLoggin();
}
@Test
@DisplayName("New workspace creation")
void newWorkspaceSave() {
Traqtor traqtor = Traqtor.init();
result = traqtor.execute(new API.CreateWorkspace());
assertEquals(DONE, result.getStatus());
assertEquals(traqtor.workspace().dirty(), true);
result = traqtor.execute(new API.SaveWorkspace());
assertEquals(FAIL, result.getStatus());
assertEquals(traqtor.workspace().dirty(), true);
result = traqtor.execute(new API.SaveAsWorkspace(TraqtorApiTestUtils.TEST_WORKSPACE_ROOT));
assertEquals(DONE, result.getStatus());
assertEquals(traqtor.workspace().dirty(), false);
}
@Test
@DisplayName("Workspace load")
void newSaveLoad() {
Traqtor traqtor = Traqtor.init();
result = traqtor.execute(new API.CreateWorkspace(TraqtorApiTestUtils.TEST_WORKSPACE_NAME, TraqtorApiTestUtils.TEST_WORKSPACE_ROOT));
assertEquals(DONE, result.getStatus());
assertEquals(traqtor.workspace().dirty(), false);
traqtor = Traqtor.init();
result = traqtor.execute(new API.LoadWorkspace(TraqtorApiTestUtils.TEST_WORKSPACE_ROOT));
assertEquals(DONE, result.getStatus());
assertEquals(traqtor.workspace().dirty(), false);
assertEquals(traqtor.workspace().dataTypeSchemas().size(), 1);
result = traqtor.execute(new API.SaveWorkspace());
assertEquals(DONE, result.getStatus());
assertEquals(traqtor.workspace().dirty(), false);
}
}

35
traqtor-api/src/test/java/link/pagan/traqtor/api/workspace/WorkspaceTest.java
Unescape Escape View File

@ -1,35 +0,0 @@
package link.pagan.traqtor.api.workspace;
import java.io.IOException;
import link.pagan.traqtor._api.TraqtorApiTestUtils;
import link.pagan.traqtor._api.result.CommandExecResult;
import static link.pagan.traqtor._api.result.CommandExecResultStatus.DONE;
import link.pagan.traqtor.api.API;
import link.pagan.traqtor.api.Traqtor;
import link.pagan.traqtor.util.Name;
import static org.junit.jupiter.api.Assertions.assertEquals;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
public class WorkspaceTest {
CommandExecResult result;
@BeforeEach
public void cleanTestDir() throws IOException {
TraqtorApiTestUtils.killTestRoot();
// Executor.enableParanoindLoggin();
}
@Test
@DisplayName("Create project")
void newSaveLoad() {
Traqtor traqtor = Traqtor.init();
result = traqtor.execute(new API.CreateWorkspace(TraqtorApiTestUtils.TEST_WORKSPACE_NAME, TraqtorApiTestUtils.TEST_WORKSPACE_ROOT));
assertEquals(DONE, result.getStatus());
assertEquals(traqtor.workspace().dirty(), false);
traqtor.execute(new API.WorkspaceCreateUniverseProject(Name.of("universe"), Name.of("traqtor", "basic")));
}
}

90
traqtor-api/src/test/java/link/pagan/traqtor/generator/UniverseBlueprintTest.java
Unescape Escape View File

@ -1,90 +0,0 @@
package link.pagan.traqtor.generator;
import com.fasterxml.jackson.core.JsonProcessingException;
import link.pagan.traqtor._api.result.CommandExecResult;
import static link.pagan.traqtor._api.result.CommandExecResultStatus.DONE;
import link.pagan.traqtor.api.API;
import link.pagan.traqtor.api.Traqtor;
import link.pagan.traqtor.generator.blueprint.universe.LinkType;
import link.pagan.traqtor.generator.blueprint.universe.build.LinkBlueprintBuilder;
import link.pagan.traqtor.generator.blueprint.universe.build.AtomBlueprintBuilder;
import link.pagan.traqtor.generator.blueprint.universe.build.ParticleBlueprintBuilder;
import link.pagan.traqtor.generator.blueprint.universe.build.UniverseBlueprintBuilder;
import link.pagan.traqtor.generator.blueprint.universe.UniverseBlueprint;
import link.pagan.traqtor.util.Name;
import link.pagan.traqtor.schema.basic.data.DataTypeSchemaReferenceImplementation;
import static org.junit.jupiter.api.Assertions.assertEquals;
import org.junit.jupiter.api.Test;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class UniverseBlueprintTest {
@Test
void programmaticBuild() throws JsonProcessingException {
UniverseBlueprintBuilder builder = new UniverseBlueprintBuilder(new DataTypeSchemaReferenceImplementation());
builder
.addAtom(new AtomBlueprintBuilder()
.name(Name.of("account"))
.description("Base user atom")
.addParticle(new ParticleBlueprintBuilder()
.name(Name.of("nickname"))
.description("User nickname, just in case")
.type("string")
)
.addParticle(new ParticleBlueprintBuilder()
.name(Name.of("email"))
.description("Main auth facility for user")
.type("string")
)
.addParticle(new ParticleBlueprintBuilder()
.name(Name.of("phone"))
.description("Alternative user authentification facility")
.type("string")
)
.addParticle(new ParticleBlueprintBuilder()
.name(Name.of("password"))
.description("User password")
.type("string")
)
)
.addAtom(new AtomBlueprintBuilder()
.name(Name.of("account", "details"))
.description("User info atom")
.addParticle(new ParticleBlueprintBuilder()
.name(Name.of("first", "name"))
.description("First name of a user")
.type("string")
)
.addParticle(new ParticleBlueprintBuilder()
.name(Name.of("last", "name"))
.description("Last name of a user")
.type("string")
)
.addParticle(new ParticleBlueprintBuilder()
.name(Name.of("middle", "names"))
.description("Middle names of a user")
.type("string")
)
)
.addLink(new LinkBlueprintBuilder()
.from(Name.of("account"))
.to(Name.of("account", "details"))
.type(LinkType.ONE_TO_ONE)
);
UniverseBlueprint build = builder.build();
Traqtor traqtor = Traqtor.init();
CommandExecResult result = traqtor.execute(new API.CreateWorkspace());
assertEquals(result.getStatus(), DONE);
assertEquals(traqtor.workspace().dirty(), true);
String serialized = traqtor.workspace().mapper().writeValueAsString(build);
System.out.println(serialized);
}
}

34
traqtor-framework/pom.xml
Unescape Escape View File

@ -1,34 +0,0 @@
<?xml version="1.0"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor-framework</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>TraQtor / Framework </name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>org.hibernate.validator</groupId>
<artifactId>hibernate-validator</artifactId>
<version>6.2.0.Final</version>
</dependency>
<dependency>
<groupId>org.glassfish</groupId>
<artifactId>jakarta.el</artifactId>
<version>3.0.3</version>
</dependency>
<dependency>
<groupId>org.apache.cayenne</groupId>
<artifactId>cayenne-server</artifactId>
<version>4.1</version>
</dependency>
</dependencies>
</project>

13
traqtor-framework/src/main/java/link/pagan/traqtor/framework/data/DatabaseDataObject.java
Unescape Escape View File

@ -1,13 +0,0 @@
package link.pagan.traqtor.framework.data;
import org.apache.cayenne.BaseDataObject;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class DatabaseDataObject extends BaseDataObject {
private static final long serialVersionUID = 1448137394405559485L;
}

14
traqtor-framework/src/main/java/link/pagan/traqtor/framework/logic/Registry.java
Unescape Escape View File

@ -1,14 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.framework.logic;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class Registry {
}

14
traqtor-framework/src/main/java/link/pagan/traqtor/framework/logic/Resource.java
Unescape Escape View File

@ -1,14 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.framework.logic;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class Resource {
}

31
traqtor-generator/pom.xml
Unescape Escape View File

@ -1,31 +0,0 @@
<?xml version="1.0"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor-generator</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>TraQtor / Source generator </name>
<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>traqtor-schema</artifactId>
<version>${project.version}</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.12.1</version>
</dependency>
</dependencies>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
</project>

30
traqtor-generator/src/main/java/link/pagan/traqtor/generator/R.java
Unescape Escape View File

@ -1,30 +0,0 @@
package link.pagan.traqtor.generator;
import link.pagan.traqtor.generator.blueprint.database.builder.ColumnBlueprintBuilder;
import link.pagan.traqtor.generator.blueprint.database.builder.DatabaseBlueprintBuilder;
import link.pagan.traqtor.generator.blueprint.database.builder.SchemeBlueprintBuilder;
import link.pagan.traqtor.generator.blueprint.database.builder.TableBlueprintBuilder;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class R {
public static DatabaseBlueprintBuilder database() {
return new DatabaseBlueprintBuilder();
}
public static SchemeBlueprintBuilder schema() {
return new SchemeBlueprintBuilder();
}
public static TableBlueprintBuilder table() {
return new TableBlueprintBuilder();
}
public static ColumnBlueprintBuilder column() {
return new ColumnBlueprintBuilder();
}
}

20
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/ProjectBlueprint.java
Unescape Escape View File

@ -1,20 +0,0 @@
package link.pagan.traqtor.generator.blueprint;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public abstract class ProjectBlueprint {
// String name;
// Name rootPackage;
// String description;
//
// public void assemble() {
//
// }
//
}

14
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/backend/BackendBlueprint.java
Unescape Escape View File

@ -1,14 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.backend;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class BackendBlueprint {
}

27
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/database/ColumnBlueprint.java
Unescape Escape View File

@ -1,27 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.database;
import link.pagan.traqtor.util.Name;
import link.pagan.traqtor.schema.data.DataType;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class ColumnBlueprint {
Name name;
DataType dataType;
public ColumnBlueprint(Name name) {
this.name = name;
}
}

19
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/database/DatabaseBlueprint.java
Unescape Escape View File

@ -1,19 +0,0 @@
package link.pagan.traqtor.generator.blueprint.database;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class DatabaseBlueprint {
String name;
// private List<SchemeBlueprint> schemas;
// private DatabaseAdapter databaseAdapter;
public DatabaseBlueprint(String name) {
this.name = name;
}
}

14
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/database/SchemeBlueprint.java
Unescape Escape View File

@ -1,14 +0,0 @@
package link.pagan.traqtor.generator.blueprint.database;
import java.util.ArrayList;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class SchemeBlueprint {
String name;
ArrayList<TableBlueprint> tables;
}

19
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/database/TableBlueprint.java
Unescape Escape View File

@ -1,19 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.database;
import java.util.ArrayList;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class TableBlueprint {
String name;
ArrayList<ColumnBlueprint> columns;
}

55
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/database/builder/ColumnBlueprintBuilder.java
Unescape Escape View File

@ -1,55 +0,0 @@
package link.pagan.traqtor.generator.blueprint.database.builder;
import link.pagan.traqtor.generator.blueprint.database.ColumnBlueprint;
import link.pagan.traqtor.util.Name;
import link.pagan.traqtor.schema.data.DataType;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class ColumnBlueprintBuilder {
private Name name;
private boolean pk;
private DataType dataType;
public ColumnBlueprintBuilder() {
this.pk = false;
}
public boolean pk() {
return this.pk;
}
public ColumnBlueprintBuilder pk(boolean pk) {
this.pk = pk;
return this;
}
public ColumnBlueprintBuilder name(Name name) {
this.name = name;
return this;
}
public Name name() {
return name;
}
public DataType dataType() {
return dataType;
}
public ColumnBlueprintBuilder dataType(DataType dataType) {
this.dataType = dataType;
return this;
}
public ColumnBlueprint build() {
return new ColumnBlueprint(name);
}
}

57
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/database/builder/DatabaseBlueprintBuilder.java
Unescape Escape View File

@ -1,57 +0,0 @@
package link.pagan.traqtor.generator.blueprint.database.builder;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import link.pagan.traqtor.util.Name;
import link.pagan.traqtor.schema.data.mapping.database.DatabaseAdapter;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class DatabaseBlueprintBuilder {
private Name name;
private DatabaseAdapter adapter;
private final List<SchemeBlueprintBuilder> schemas;
public DatabaseBlueprintBuilder() {
this.schemas = new ArrayList<SchemeBlueprintBuilder>();
}
public Name name() {
return name;
}
public DatabaseBlueprintBuilder name(Name name) {
this.name = name;
return this;
}
public DatabaseAdapter adapter() {
return adapter;
}
public DatabaseBlueprintBuilder adapter(DatabaseAdapter adapter) {
this.adapter = adapter;
return this;
}
public DatabaseBlueprintBuilder schemas(SchemeBlueprintBuilder... schemas) {
if (schemas != null) {
Collections.addAll(this.schemas, schemas);
}
return this;
}
public SchemeBlueprintBuilder scheme(Name name) {
for (SchemeBlueprintBuilder sbb : schemas) {
if (sbb.name().equals(name)) {
return sbb;
}
}
return null;
}
}

46
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/database/builder/SchemeBlueprintBuilder.java
Unescape Escape View File

@ -1,46 +0,0 @@
package link.pagan.traqtor.generator.blueprint.database.builder;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class SchemeBlueprintBuilder {
private Name name;
private final List<TableBlueprintBuilder> tables;
public SchemeBlueprintBuilder() {
this.tables = new ArrayList<TableBlueprintBuilder>();
}
public Name name() {
return name;
}
public SchemeBlueprintBuilder name(Name name) {
this.name = name;
return this;
}
public SchemeBlueprintBuilder tables(TableBlueprintBuilder... tables) {
if (tables != null) {
Collections.addAll(this.tables, tables);
}
return this;
}
public TableBlueprintBuilder table(Name name) {
for (TableBlueprintBuilder tbb : tables) {
if (tbb.name().equals(name)) {
return tbb;
}
}
return null;
}
}

46
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/database/builder/TableBlueprintBuilder.java
Unescape Escape View File

@ -1,46 +0,0 @@
package link.pagan.traqtor.generator.blueprint.database.builder;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class TableBlueprintBuilder {
private Name name;
private final List<ColumnBlueprintBuilder> columns;
public TableBlueprintBuilder() {
this.columns = new ArrayList<ColumnBlueprintBuilder>();
}
public Name name() {
return name;
}
public TableBlueprintBuilder name(Name name) {
this.name = name;
return this;
}
public TableBlueprintBuilder columns(ColumnBlueprintBuilder... columns) {
if (columns != null) {
Collections.addAll(this.columns, columns);
}
return this;
}
public ColumnBlueprintBuilder column(Name name) {
for (ColumnBlueprintBuilder cbb : columns) {
if (cbb.name().equals(name)) {
return cbb;
}
}
return null;
}
}

14
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/frontend/FrontendBlueprint.java
Unescape Escape View File

@ -1,14 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.frontend;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class FrontendBlueprint {
}

20
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/mdl/logic/EndpointBlueprint.java
Unescape Escape View File

@ -1,20 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.mdl.logic;
import java.util.ArrayList;
import link.pagan.traqtor.generator.blueprint.mdl.security.permission.PermissionBlueprint;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class EndpointBlueprint {
ArrayList<PermissionBlueprint> permissions;
String name;
}

18
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/mdl/logic/RegistryBlueprint.java
Unescape Escape View File

@ -1,18 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.mdl.logic;
import java.util.ArrayList;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class RegistryBlueprint {
ArrayList<EndpointBlueprint> endpoints;
}

19
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/mdl/logic/ResourceBlueprint.java
Unescape Escape View File

@ -1,19 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.mdl.logic;
import java.util.ArrayList;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class ResourceBlueprint {
String name;
ArrayList<EndpointBlueprint> endpoints;
}

14
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/mdl/logic/ServiceBlueprint.java
Unescape Escape View File

@ -1,14 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.mdl.logic;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class ServiceBlueprint {
}

16
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/mdl/security/permission/PermissionBlueprint.java
Unescape Escape View File

@ -1,16 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.mdl.security.permission;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class PermissionBlueprint {
String name;
}

20
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/mdl/security/permission/PermissionDomainBlueprint.java
Unescape Escape View File

@ -1,20 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.mdl.security.permission;
import java.util.ArrayList;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class PermissionDomainBlueprint {
String name;
ArrayList<PermissionBlueprint> permissions;
ArrayList<PermissionDomainBlueprint> subdomains;
}

14
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/mdl/security/role/RoleBlueprint.java
Unescape Escape View File

@ -1,14 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.generator.blueprint.mdl.security.role;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class RoleBlueprint {
}

57
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/AtomBlueprint.java
Unescape Escape View File

@ -1,57 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import java.io.IOException;
import java.util.List;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class AtomBlueprint {
Name name;
String description;
List<ParticleBlueprint> particles;
public AtomBlueprint(Name name, String description, List<ParticleBlueprint> particles) {
this.name = name;
this.description = description;
this.particles = particles;
}
public Name name() {
return name;
}
public static final class AtomBlueprintSerializer extends StdSerializer<AtomBlueprint> {
private static final long serialVersionUID = 1L;
public AtomBlueprintSerializer() {
this(null);
}
public AtomBlueprintSerializer(Class<AtomBlueprint> t) {
super(t);
}
@Override
public void serialize(AtomBlueprint value, JsonGenerator gen, SerializerProvider provider) throws IOException {
gen.writeStartObject();
gen.writeObjectField("name", value.name);
gen.writeStringField("description", value.description);
gen.writeArrayFieldStart("particles");
for (ParticleBlueprint ab : value.particles) {
gen.writeObject(ab);
}
gen.writeEndArray();
gen.writeEndObject();
}
}
}

54
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/LinkBlueprint.java
Unescape Escape View File

@ -1,54 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import java.io.IOException;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class LinkBlueprint {
AtomBlueprint from;
AtomBlueprint to;
LinkType type;
public LinkBlueprint(AtomBlueprint from, AtomBlueprint to, LinkType type) {
this.from = from;
this.to = to;
this.type = type;
}
public AtomBlueprint from() {
return from;
}
public AtomBlueprint to() {
return to;
}
public static final class LinkBlueprintSerializer extends StdSerializer<LinkBlueprint> {
private static final long serialVersionUID = 1L;
public LinkBlueprintSerializer() {
this(null);
}
public LinkBlueprintSerializer(Class<LinkBlueprint> t) {
super(t);
}
@Override
public void serialize(LinkBlueprint value, JsonGenerator gen, SerializerProvider provider) throws IOException {
gen.writeStartObject();
gen.writeObjectField("name", value.from.name);
gen.writeObjectField("to", value.to.name);
gen.writeObjectField("type", value.type);
gen.writeEndObject();
}
}
}

41
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/LinkType.java
Unescape Escape View File

@ -1,41 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import java.io.IOException;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public enum LinkType {
MANY_TO_MANY,
ONE_TO_MANY,
ONE_TO_ONE;
public static final class LinkTypeSerializer extends StdSerializer<LinkType> {
private static final long serialVersionUID = 1L;
public LinkTypeSerializer() {
this(null);
}
public LinkTypeSerializer(Class<LinkType> t) {
super(t);
}
@Override
public void serialize(LinkType value, JsonGenerator gen, SerializerProvider provider) throws IOException {
if (value.equals(MANY_TO_MANY)) {
gen.writeString("MANY_TO_MANY");
} else if (value.equals(ONE_TO_MANY)) {
gen.writeString("ONE_TO_MANY");
} else {
gen.writeString("ONE_TO_ONE");
}
}
}
}

53
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/ParticleBlueprint.java
Unescape Escape View File

@ -1,53 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import java.io.IOException;
import link.pagan.traqtor.util.Name;
import link.pagan.traqtor.schema.data.DataType;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class ParticleBlueprint {
Name name;
String description;
DataType type;
public ParticleBlueprint(Name name, String description, DataType type) {
this.name = name;
this.description = description;
this.type = type;
}
public Name name() {
return name;
}
public static final class ParticleBlueprintSerializer extends StdSerializer<ParticleBlueprint> {
private static final long serialVersionUID = 1L;
public ParticleBlueprintSerializer() {
this(null);
}
public ParticleBlueprintSerializer(Class<ParticleBlueprint> t) {
super(t);
}
@Override
public void serialize(ParticleBlueprint value, JsonGenerator gen, SerializerProvider provider) throws IOException {
gen.writeStartObject();
gen.writeObjectField("name", value.name);
gen.writeStringField("description", value.description);
gen.writeStringField("type", value.type.getName());
gen.writeEndObject();
}
}
}

57
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/UniverseBlueprint.java
Unescape Escape View File

@ -1,57 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import java.io.IOException;
import java.util.List;
import link.pagan.traqtor.generator.blueprint.ProjectBlueprint;
import link.pagan.traqtor.schema.data.DataTypeSchema;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class UniverseBlueprint extends ProjectBlueprint {
List<AtomBlueprint> atoms;
List<LinkBlueprint> links;
DataTypeSchema dataTypeSchema;
public UniverseBlueprint(List<AtomBlueprint> atoms, List<LinkBlueprint> links, DataTypeSchema dataTypeSchema) {
this.atoms = atoms;
this.links = links;
this.dataTypeSchema = dataTypeSchema;
}
public static final class UniverseBlueprintSerializer extends StdSerializer<UniverseBlueprint> {
private static final long serialVersionUID = 1L;
public UniverseBlueprintSerializer() {
this(null);
}
public UniverseBlueprintSerializer(Class<UniverseBlueprint> t) {
super(t);
}
@Override
public void serialize(UniverseBlueprint value, JsonGenerator gen, SerializerProvider provider) throws IOException {
gen.writeStartObject();
gen.writeObjectField("schema", value.dataTypeSchema.getName());
gen.writeArrayFieldStart("atoms");
for (AtomBlueprint ab : value.atoms) {
gen.writeObject(ab);
}
gen.writeEndArray();
gen.writeArrayFieldStart("links");
for (LinkBlueprint lb : value.links) {
gen.writeObject(lb);
}
gen.writeEndArray();
gen.writeEndObject();
}
}
}

57
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/build/AtomBlueprintBuilder.java
Unescape Escape View File

@ -1,57 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe.build;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import link.pagan.traqtor.generator.blueprint.universe.AtomBlueprint;
import link.pagan.traqtor.generator.blueprint.universe.ParticleBlueprint;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class AtomBlueprintBuilder {
Name name;
String description;
List<ParticleBlueprintBuilder> particleBuilders;
public AtomBlueprintBuilder() {
this.particleBuilders = new ArrayList<>();
}
public AtomBlueprint build(UniverseBlueprintBuilder builder) {
List<ParticleBlueprint> particles = new ArrayList<>();
for (ParticleBlueprintBuilder pb : particleBuilders) {
particles.add(pb.build(builder));
}
particles.sort(new Comparator<ParticleBlueprint>() {
@Override
public int compare(ParticleBlueprint a, ParticleBlueprint b) {
return a.name().asDotted().compareTo(b.name().asDotted());
}
});
return new AtomBlueprint(name, description, particles);
}
public Name name() {
return name;
}
public AtomBlueprintBuilder name(Name name) {
this.name = name;
return this;
}
public AtomBlueprintBuilder description(String description) {
this.description = description;
return this;
}
public AtomBlueprintBuilder addParticle(ParticleBlueprintBuilder particle) {
this.particleBuilders.add(particle);
return this;
}
}

55
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/build/LinkBlueprintBuilder.java
Unescape Escape View File

@ -1,55 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe.build;
import java.util.ArrayList;
import link.pagan.traqtor.generator.blueprint.universe.AtomBlueprint;
import link.pagan.traqtor.generator.blueprint.universe.LinkBlueprint;
import link.pagan.traqtor.generator.blueprint.universe.LinkType;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class LinkBlueprintBuilder {
Name from;
Name to;
LinkType type;
public LinkBlueprint build(UniverseBlueprintBuilder builder, ArrayList<AtomBlueprint> atoms) {
AtomBlueprint fromAtom = getAtom(from, atoms);
if (fromAtom == null) {
throw new RuntimeException("Link from atom can not be null");
}
AtomBlueprint toAtom = getAtom(to, atoms);
if (toAtom == null) {
throw new RuntimeException("Link to atom can not be null");
}
return new LinkBlueprint(fromAtom, toAtom, type);
}
public LinkBlueprintBuilder from(Name from) {
this.from = from;
return this;
}
public LinkBlueprintBuilder to(Name to) {
this.to = to;
return this;
}
public LinkBlueprintBuilder type(LinkType type) {
this.type = type;
return this;
}
private static AtomBlueprint getAtom(Name name, ArrayList<AtomBlueprint> atoms) {
for (AtomBlueprint ab : atoms) {
if (ab.name().equals(name)) {
return ab;
}
}
return null;
}
}

40
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/build/ParticleBlueprintBuilder.java
Unescape Escape View File

@ -1,40 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe.build;
import link.pagan.traqtor.generator.blueprint.universe.ParticleBlueprint;
import link.pagan.traqtor.util.Name;
import link.pagan.traqtor.schema.data.DataType;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class ParticleBlueprintBuilder {
Name name;
String description;
String type;
public ParticleBlueprint build(UniverseBlueprintBuilder builder) {
DataType dataType = builder.getType(type);
if (dataType == null) {
throw new RuntimeException("Particle type was not found on build");
}
return new ParticleBlueprint(name, description, dataType);
}
public ParticleBlueprintBuilder name(Name name) {
this.name = name;
return this;
}
public ParticleBlueprintBuilder description(String description) {
this.description = description;
return this;
}
public ParticleBlueprintBuilder type(String type) {
this.type = type;
return this;
}
}

73
traqtor-generator/src/main/java/link/pagan/traqtor/generator/blueprint/universe/build/UniverseBlueprintBuilder.java
Unescape Escape View File

@ -1,73 +0,0 @@
package link.pagan.traqtor.generator.blueprint.universe.build;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.List;
import link.pagan.traqtor.generator.blueprint.universe.UniverseBlueprint;
import link.pagan.traqtor.generator.blueprint.universe.AtomBlueprint;
import link.pagan.traqtor.generator.blueprint.universe.LinkBlueprint;
import link.pagan.traqtor.schema.data.DataType;
import link.pagan.traqtor.schema.data.DataTypeSchema;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class UniverseBlueprintBuilder {
List<AtomBlueprintBuilder> atomBuilders;
List<LinkBlueprintBuilder> linkBuilder;
DataTypeSchema dataTypeSchema;
public UniverseBlueprintBuilder(DataTypeSchema dataTypeSchema) {
this.atomBuilders = new ArrayList<>();
this.linkBuilder = new ArrayList<>();
this.dataTypeSchema = dataTypeSchema;
}
public UniverseBlueprintBuilder addAtom(AtomBlueprintBuilder atom) {
this.atomBuilders.add(atom);
return this;
}
public UniverseBlueprintBuilder addLink(LinkBlueprintBuilder link) {
this.linkBuilder.add(link);
return this;
}
public UniverseBlueprint build() {
ArrayList<AtomBlueprint> atoms = new ArrayList<>();
for (AtomBlueprintBuilder ab : atomBuilders) {
atoms.add(ab.build(this));
}
atoms.sort(new Comparator<AtomBlueprint>() {
@Override
public int compare(AtomBlueprint a, AtomBlueprint b) {
return a.name().asDotted().compareTo(b.name().asDotted());
}
});
ArrayList<LinkBlueprint> links = new ArrayList<>();
for (LinkBlueprintBuilder lb : linkBuilder) {
links.add(lb.build(this, atoms));
}
links.sort(new Comparator<LinkBlueprint>() {
@Override
public int compare(LinkBlueprint a, LinkBlueprint b) {
return (a.from().name().asDotted() + "->" + a.to().name().asDotted()).compareTo(
(b.from().name().asDotted() + "->" + b.to().name().asDotted()));
}
});
return new UniverseBlueprint(atoms, links, dataTypeSchema);
}
DataType getType(String type) {
for (DataType dt : this.dataTypeSchema.getDataTypes()) {
if (dt.getName().equals(type)) {
return dt;
}
}
return null;
}
}

59
traqtor-json/pom.xml
Unescape Escape View File

@ -1,59 +0,0 @@
<?xml version="1.0"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor-json</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>TraQtor / JSON </name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.junit</groupId>
<artifactId>junit-bom</artifactId>
<version>5.7.1</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<dependencies>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.12.1</version>
</dependency>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>traqtor-aio</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.8.1</version>
</plugin>
<plugin>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.22.2</version>
</plugin>
</plugins>
</build>
</project>

26
traqtor-schema-ref/pom.xml
Unescape Escape View File

@ -1,26 +0,0 @@
<?xml version="1.0"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor-schema-ref</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>TraQtor / Scheme / Reference implementation</name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>traqtor-schema</artifactId>
<version>${project.version}</version>
</dependency>
</dependencies>
</project>

25
traqtor-schema-ref/src/main/java/link/pagan/traqtor/schema/basic/EndpointSchemaImpl.java
Unescape Escape View File

@ -1,25 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.schema.basic;
import java.util.List;
import link.pagan.traqtor.schema.logic.EndpointSchema;
import link.pagan.traqtor.schema.logic.EndpointTemplate;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class EndpointSchemaImpl implements EndpointSchema {
@Override
public List<EndpointTemplate> getPatterns() {
throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
}
}

79
traqtor-schema-ref/src/main/java/link/pagan/traqtor/schema/basic/data/DataTypeSchemaReferenceImplementation.java
Unescape Escape View File

@ -1,79 +0,0 @@
package link.pagan.traqtor.schema.basic.data;
import java.util.List;
import link.pagan.traqtor.schema.basic.data.mapping.MappingSchemaImpl;
import link.pagan.traqtor.schema.data.DataType;
import link.pagan.traqtor.schema.data.DataTypeSchema;
import link.pagan.traqtor.schema.data.mapping.MappingSchema;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class DataTypeSchemaReferenceImplementation implements DataTypeSchema {
private static final Name name = Name.of("traqtor", "basic");
// ARRAY(""),
// LIST(""),
// SET(""),
// MAP(""),
public static final DataType BOOLEAN = new DataType("boolean");
public static final DataType BYTE = new DataType("byte");
public static final DataType SHORT = new DataType("short");
public static final DataType INTEGER = new DataType("int");
public static final DataType LONG = new DataType("long");
public static final DataType FLOAT = new DataType("float");
public static final DataType DOUBLE = new DataType("double");
public static final DataType STRING = new DataType("string");
public static final DataType DATE = new DataType("date");
public static final DataType TIME = new DataType("time");
public static final DataType TIMESTAMP = new DataType("timestamp");
public static final DataType ID = new DataType("id");
public static final DataType UUID = new DataType("uuid");
private static final List<DataType> dataTypes = List.of(BOOLEAN, BYTE, SHORT, INTEGER, LONG, FLOAT, DOUBLE, STRING,
DATE, TIME, TIMESTAMP, ID, UUID);
private static final List<MappingSchema> mappingSchemas = List.of(new MappingSchemaImpl());
@Override
public List<DataType> getDataTypes() {
return dataTypes;
}
@Override
public Name getName() {
return name;
}
@Override
public List<MappingSchema> getMappingSchema() {
return mappingSchemas;
}
// @Override
// public Map<String, DataType> register() {
// return new HashMap<String, DataType>(){
// private static final long serialVersionUID = 1L;
// {
// put(BOOLEAN.getName(), BOOLEAN);
// put(BYTE.getName(), BYTE);
// put(SHORT.getName(), SHORT);
// put(INTEGER.getName(), INTEGER);
// put(LONG.getName(), LONG);
// put(FLOAT.getName(), FLOAT);
// put(DOUBLE.getName(), DOUBLE);
// put(STRING.getName(), STRING);
// put(BOOLEAN.getName(), BOOLEAN);
// put(DATE.getName(), DATE);
// put(TIME.getName(), TIME);
// put(TIMESTAMP.getName(), TIMESTAMP);
// put(ID.getName(), ID);
// put(UUID.getName(), UUID);
// }};
// }
}

59
traqtor-schema-ref/src/main/java/link/pagan/traqtor/schema/basic/data/mapping/MappingSchemaImpl.java
Unescape Escape View File

@ -1,59 +0,0 @@
package link.pagan.traqtor.schema.basic.data.mapping;
import java.util.List;
import link.pagan.traqtor.schema.basic.data.DataTypeSchemaReferenceImplementation;
import link.pagan.traqtor.schema.data.mapping.MappingEntry;
import link.pagan.traqtor.schema.data.mapping.MappingSchema;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class MappingSchemaImpl implements MappingSchema {
private static final Name name = Name.of("traqtor", "basic", "default");
public static final MappingEntry NULLABLE_BOOLEAN = new MappingEntry(DataTypeSchemaReferenceImplementation.BOOLEAN , true , false );
public static final MappingEntry BOOLEAN = new MappingEntry(DataTypeSchemaReferenceImplementation.BOOLEAN , false , true );
public static final MappingEntry NULLABLE_BYTE = new MappingEntry(DataTypeSchemaReferenceImplementation.BYTE , true , false );
public static final MappingEntry BYTE = new MappingEntry(DataTypeSchemaReferenceImplementation.BYTE , false , true );
public static final MappingEntry NULLABLE_SHORT = new MappingEntry(DataTypeSchemaReferenceImplementation.SHORT , true , false );
public static final MappingEntry SHORT = new MappingEntry(DataTypeSchemaReferenceImplementation.SHORT , false , true );
public static final MappingEntry NULLABLE_INTEGER = new MappingEntry(DataTypeSchemaReferenceImplementation.INTEGER , true , false );
public static final MappingEntry INTEGER = new MappingEntry(DataTypeSchemaReferenceImplementation.INTEGER , false , true );
public static final MappingEntry NULLABLE_LONG = new MappingEntry(DataTypeSchemaReferenceImplementation.LONG , true , false );
public static final MappingEntry LONG = new MappingEntry(DataTypeSchemaReferenceImplementation.LONG , false , true );
public static final MappingEntry NULLABLE_FLOAT = new MappingEntry(DataTypeSchemaReferenceImplementation.FLOAT , true , false );
public static final MappingEntry FLOAT = new MappingEntry(DataTypeSchemaReferenceImplementation.FLOAT , false , false );
public static final MappingEntry NULLABLE_DOUBLE = new MappingEntry(DataTypeSchemaReferenceImplementation.DOUBLE , true , false );
public static final MappingEntry DOUBLE = new MappingEntry(DataTypeSchemaReferenceImplementation.DOUBLE , false , false );
public static final MappingEntry STRING = new MappingEntry(DataTypeSchemaReferenceImplementation.STRING , true , false );
public static final MappingEntry DATE = new MappingEntry(DataTypeSchemaReferenceImplementation.DATE , true , false );
public static final MappingEntry TIME = new MappingEntry(DataTypeSchemaReferenceImplementation.TIME , true , false );
public static final MappingEntry TIMESTAMP = new MappingEntry(DataTypeSchemaReferenceImplementation.TIMESTAMP , true , false );
public static final MappingEntry ID = new MappingEntry(DataTypeSchemaReferenceImplementation.ID , true , true );
public static final MappingEntry UUID = new MappingEntry(DataTypeSchemaReferenceImplementation.UUID , true , true );
private static final List<MappingEntry> mappings = List.of(NULLABLE_BOOLEAN, BOOLEAN,
NULLABLE_BYTE, BYTE,
NULLABLE_SHORT, SHORT,
NULLABLE_INTEGER, INTEGER,
NULLABLE_LONG, LONG,
NULLABLE_FLOAT, FLOAT,
NULLABLE_DOUBLE, DOUBLE,
STRING,
DATE, TIME, TIMESTAMP,
ID, UUID);
@Override
public List<MappingEntry> getMappings() {
return mappings;
}
@Override
public Name getName() {
return name;
}
}

48
traqtor-schema-ref/src/main/java/link/pagan/traqtor/schema/basic/data/mapping/backend/JavaBackendMapping.java
Unescape Escape View File

@ -1,48 +0,0 @@
package link.pagan.traqtor.schema.basic.data.mapping.backend;
import java.util.HashMap;
import link.pagan.traqtor.schema.basic.data.mapping.MappingSchemaImpl;
import link.pagan.traqtor.schema.data.mapping.backend.BackendMapping;
import link.pagan.traqtor.schema.data.mapping.MappingEntry;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class JavaBackendMapping extends BackendMapping {
public JavaBackendMapping() {
super("Java", new HashMap<MappingEntry, String>() {
private static final long serialVersionUID = 1L;
{
put(MappingSchemaImpl.NULLABLE_BOOLEAN, "Boolean");
put(MappingSchemaImpl.NULLABLE_BYTE, "Byte");
put(MappingSchemaImpl.NULLABLE_SHORT, "Short");
put(MappingSchemaImpl.NULLABLE_INTEGER, "Integer");
put(MappingSchemaImpl.NULLABLE_LONG, "Long");
put(MappingSchemaImpl.BOOLEAN, "boolean");
put(MappingSchemaImpl.BYTE, "byte");
put(MappingSchemaImpl.SHORT, "short");
put(MappingSchemaImpl.INTEGER, "integer");
put(MappingSchemaImpl.LONG, "long");
put(MappingSchemaImpl.NULLABLE_DOUBLE, "Double");
put(MappingSchemaImpl.NULLABLE_FLOAT, "Float");
put(MappingSchemaImpl.DOUBLE, "double");
put(MappingSchemaImpl.FLOAT, "float");
put(MappingSchemaImpl.ID, "long");
put(MappingSchemaImpl.UUID, "String");
put(MappingSchemaImpl.STRING, "String");
put(MappingSchemaImpl.DATE, "Date");
put(MappingSchemaImpl.TIME, "Time");
put(MappingSchemaImpl.TIMESTAMP, "Timestamp");
}
});
}
}

37
traqtor-schema-ref/src/main/java/link/pagan/traqtor/schema/basic/data/mapping/database/PostgresDatabaseAdapter.java
Unescape Escape View File

@ -1,37 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.schema.basic.data.mapping.database;
import link.pagan.traqtor.schema.data.mapping.database.DatabaseAdapter;
import link.pagan.traqtor.util.Name;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class PostgresDatabaseAdapter extends DatabaseAdapter {
private static final Name NAME = Name.of("traqtor", "basic", "db", "postgres");
public PostgresDatabaseAdapter() {
super(NAME);
}
// @Override
// public Map<String, DatabaseAdapter> register() {
// return new HashMap<String, DatabaseAdapter>(){
// private static final long serialVersionUID = 1L;
// {
// put(NAME, new PostgresDatabaseAdapter());
// }};
// }
@Override
public Name getName() {
return NAME;
}
}

47
traqtor-schema-ref/src/main/java/link/pagan/traqtor/schema/basic/data/mapping/database/PostgresDatabaseMapping.java
Unescape Escape View File

@ -1,47 +0,0 @@
package link.pagan.traqtor.schema.basic.data.mapping.database;
import java.util.HashMap;
import link.pagan.traqtor.schema.basic.data.mapping.MappingSchemaImpl;
import link.pagan.traqtor.schema.data.mapping.database.DatabaseMapping;
import link.pagan.traqtor.schema.data.mapping.MappingEntry;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class PostgresDatabaseMapping extends DatabaseMapping {
public PostgresDatabaseMapping() {
super("PostgreSQL", new HashMap<MappingEntry, String>() {
private static final long serialVersionUID = 1L;
{
put(MappingSchemaImpl.NULLABLE_BOOLEAN, "boolean");
put(MappingSchemaImpl.NULLABLE_BYTE, "smallint");
put(MappingSchemaImpl.NULLABLE_SHORT, "smallint");
put(MappingSchemaImpl.NULLABLE_INTEGER, "integer");
put(MappingSchemaImpl.NULLABLE_LONG, "bigint");
put(MappingSchemaImpl.BOOLEAN, "boolean");
put(MappingSchemaImpl.BYTE, "smallint");
put(MappingSchemaImpl.SHORT, "smallint");
put(MappingSchemaImpl.INTEGER, "integer");
put(MappingSchemaImpl.LONG, "bigint");
put(MappingSchemaImpl.NULLABLE_DOUBLE, "double precision");
put(MappingSchemaImpl.NULLABLE_FLOAT, "real");
put(MappingSchemaImpl.DOUBLE, "double precision");
put(MappingSchemaImpl.FLOAT, "real");
put(MappingSchemaImpl.ID, "bigserial");
put(MappingSchemaImpl.UUID, "uuid");
put(MappingSchemaImpl.STRING, "String");
put(MappingSchemaImpl.DATE, "date");
put(MappingSchemaImpl.TIME, "time");
put(MappingSchemaImpl.TIMESTAMP, "timestamp");
}
});
}
}

47
traqtor-schema-ref/src/main/java/link/pagan/traqtor/schema/basic/data/mapping/frontend/JavaScriptFrontendMapping.java
Unescape Escape View File

@ -1,47 +0,0 @@
package link.pagan.traqtor.schema.basic.data.mapping.frontend;
import java.util.HashMap;
import link.pagan.traqtor.schema.basic.data.mapping.MappingSchemaImpl;
import link.pagan.traqtor.schema.data.mapping.frontend.FrontendMapping;
import link.pagan.traqtor.schema.data.mapping.MappingEntry;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class JavaScriptFrontendMapping extends FrontendMapping {
public JavaScriptFrontendMapping() {
super("JavaScript", new HashMap<MappingEntry, String>() {
private static final long serialVersionUID = 1L;
{
put(MappingSchemaImpl.NULLABLE_BOOLEAN, "Boolean");
put(MappingSchemaImpl.NULLABLE_BYTE, "Number");
put(MappingSchemaImpl.NULLABLE_SHORT, "Number");
put(MappingSchemaImpl.NULLABLE_INTEGER, "Number");
put(MappingSchemaImpl.NULLABLE_LONG, "BigInt");
put(MappingSchemaImpl.BOOLEAN, "Boolean");
put(MappingSchemaImpl.BYTE, "Number");
put(MappingSchemaImpl.SHORT, "Number");
put(MappingSchemaImpl.INTEGER, "Number");
put(MappingSchemaImpl.LONG, "BigInt");
put(MappingSchemaImpl.NULLABLE_DOUBLE, "Number");
put(MappingSchemaImpl.NULLABLE_FLOAT, "Number");
put(MappingSchemaImpl.DOUBLE, "Number");
put(MappingSchemaImpl.FLOAT, "Number");
put(MappingSchemaImpl.ID, "BigInt");
put(MappingSchemaImpl.UUID, "String");
put(MappingSchemaImpl.STRING, "String");
put(MappingSchemaImpl.DATE, "Date");
put(MappingSchemaImpl.TIME, "Date");
put(MappingSchemaImpl.TIMESTAMP, "Date");
}
});
}
}

59
traqtor-schema/pom.xml
Unescape Escape View File

@ -1,59 +0,0 @@
<?xml version="1.0"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor</artifactId>
<version>0.0.1-SNAPSHOT</version>
</parent>
<groupId>link.pagan</groupId>
<artifactId>traqtor-schema</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>TraQtor / Scheme </name>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
<dependencies>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.12.1</version>
</dependency>
</dependencies>
</project>
<!--<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.mgpu.mesh.loader</groupId>
<artifactId>traqtor-mdl</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>jar</packaging>
<dependencies>
<dependency>
<groupId>org.hibernate.validator</groupId>
<artifactId>hibernate-validator</artifactId>
<version>6.2.0.Final</version>
</dependency>
<dependency>
<groupId>org.glassfish</groupId>
<artifactId>jakarta.el</artifactId>
<version>3.0.3</version>
</dependency>
<dependency>
<groupId>org.apache.cayenne</groupId>
<artifactId>cayenne-server</artifactId>
<version>4.1</version>
</dependency>
</dependencies>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>11</maven.compiler.source>
<maven.compiler.target>11</maven.compiler.target>
</properties>
</project>-->

19
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/DataType.java
Unescape Escape View File

@ -1,19 +0,0 @@
package link.pagan.traqtor.schema.data;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class DataType {
private final String name;
public DataType(String name) {
this.name = name;
}
public String getName() {
return name;
}
}

17
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/DataTypeSchema.java
Unescape Escape View File

@ -1,17 +0,0 @@
package link.pagan.traqtor.schema.data;
import link.pagan.traqtor.schema.data.mapping.MappingSchema;
import link.pagan.traqtor.util.Named;
import java.util.List;
import link.pagan.traqtor.util.Registrable;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public interface DataTypeSchema extends Named, Registrable<DataType> {
public List<DataType> getDataTypes();
public List<MappingSchema> getMappingSchema();
}

27
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/mapping/Mapping.java
Unescape Escape View File

@ -1,27 +0,0 @@
package link.pagan.traqtor.schema.data.mapping;
import java.util.HashMap;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public abstract class Mapping {
private final String name;
private final HashMap<MappingEntry, String> mapping;
protected Mapping(String name, HashMap<MappingEntry, String> mapping) {
this.mapping = mapping;
this.name = name;
}
public String getName() {
return name;
}
public HashMap<MappingEntry, String> getMapping() {
return mapping;
}
}

35
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/mapping/MappingEntry.java
Unescape Escape View File

@ -1,35 +0,0 @@
package link.pagan.traqtor.schema.data.mapping;
import link.pagan.traqtor.schema.data.DataType;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class MappingEntry {
private final DataType dataType;
private final boolean nullable;
private final boolean keyable;
public MappingEntry(DataType dataType, boolean nullable, boolean keyable) {
this.dataType = dataType;
this.nullable = nullable;
this.keyable = keyable;
}
public DataType getDataType() {
return dataType;
}
public boolean isNullable() {
return nullable;
}
public boolean isKeyable() {
return keyable;
}
}

14
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/mapping/MappingSchema.java
Unescape Escape View File

@ -1,14 +0,0 @@
package link.pagan.traqtor.schema.data.mapping;
import link.pagan.traqtor.util.Named;
import java.util.List;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public interface MappingSchema extends Named {
public List<MappingEntry> getMappings ();
}

17
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/mapping/backend/BackendMapping.java
Unescape Escape View File

@ -1,17 +0,0 @@
package link.pagan.traqtor.schema.data.mapping.backend;
import java.util.HashMap;
import link.pagan.traqtor.schema.data.mapping.Mapping;
import link.pagan.traqtor.schema.data.mapping.MappingEntry;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class BackendMapping extends Mapping {
public BackendMapping(String name, HashMap<MappingEntry, String> mapping) {
super(name, mapping);
}
}

24
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/mapping/database/DatabaseAdapter.java
Unescape Escape View File

@ -1,24 +0,0 @@
package link.pagan.traqtor.schema.data.mapping.database;
import link.pagan.traqtor.util.Name;
import link.pagan.traqtor.util.Named;
import link.pagan.traqtor.util.Registrable;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public abstract class DatabaseAdapter implements Named, Registrable<DatabaseAdapter> {
private final Name name;
protected DatabaseAdapter(Name name) {
this.name = name;
}
@Override
public Name getName() {
return name;
}
}

17
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/mapping/database/DatabaseMapping.java
Unescape Escape View File

@ -1,17 +0,0 @@
package link.pagan.traqtor.schema.data.mapping.database;
import java.util.HashMap;
import link.pagan.traqtor.schema.data.mapping.Mapping;
import link.pagan.traqtor.schema.data.mapping.MappingEntry;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class DatabaseMapping extends Mapping {
public DatabaseMapping(String name, HashMap<MappingEntry, String> mapping) {
super(name, mapping);
}
}

14
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/mapping/database/DatabaseNamingScheme.java
Unescape Escape View File

@ -1,14 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.schema.data.mapping.database;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public interface DatabaseNamingScheme {
}

17
traqtor-schema/src/main/java/link/pagan/traqtor/schema/data/mapping/frontend/FrontendMapping.java
Unescape Escape View File

@ -1,17 +0,0 @@
package link.pagan.traqtor.schema.data.mapping.frontend;
import java.util.HashMap;
import link.pagan.traqtor.schema.data.mapping.Mapping;
import link.pagan.traqtor.schema.data.mapping.MappingEntry;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class FrontendMapping extends Mapping {
public FrontendMapping(String name, HashMap<MappingEntry, String> mapping) {
super(name, mapping);
}
}

18
traqtor-schema/src/main/java/link/pagan/traqtor/schema/logic/EndpointSchema.java
Unescape Escape View File

@ -1,18 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.schema.logic;
import java.util.List;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public interface EndpointSchema {
public List<EndpointTemplate> getPatterns();
}

16
traqtor-schema/src/main/java/link/pagan/traqtor/schema/logic/EndpointTemplate.java
Unescape Escape View File

@ -1,16 +0,0 @@
/*
* To change this license header, choose License Headers in Project Properties.
* To change this template file, choose Tools | Templates
* and open the template in the editor.
*/
package link.pagan.traqtor.schema.logic;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class EndpointTemplate {
}

135
traqtor-schema/src/main/java/link/pagan/traqtor/util/Name.java
Unescape Escape View File

@ -1,135 +0,0 @@
package link.pagan.traqtor.util;
import com.fasterxml.jackson.core.JsonGenerator;
import com.fasterxml.jackson.core.JsonParser;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationContext;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.SerializerProvider;
import com.fasterxml.jackson.databind.deser.std.StdDeserializer;
import com.fasterxml.jackson.databind.ser.std.StdSerializer;
import java.io.IOException;
import java.util.Arrays;
import java.util.Comparator;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public class Name {
public static final Comparator<Name> COMPARATOR = new Comparator<Name>() {
@Override
public int compare(Name a, Name b) {
return a.asDotted().compareTo(b.asDotted());
}
};
String[] parts;
public Name(String[] parts) {
this.parts = parts;
}
public static Name of(String... parts) {
if (parts == null) {
throw new NullPointerException("name can not be null");
}
if (parts.length < 1) {
throw new IllegalArgumentException("name can not be empty");
}
return new Name(parts);
}
public String asDotted() {
StringBuilder sb = new StringBuilder();
for (int i = 0; i < this.parts.length; i++) {
sb.append(parts[i]);
if (i != this.parts.length - 1) {
sb.append('.');
}
}
return sb.toString();
}
@Override
public boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null) {
return false;
}
if (getClass() != o.getClass()) {
return false;
}
Name name = (Name) o;
if (name.parts == null) {
return false;
}
if (name.parts.length != this.parts.length) {
return false;
}
for (int i = 0; i < this.parts.length; i++) {
if (!this.parts[i].equals(name.parts[i])) {
return false;
}
}
return true;
}
@Override
public int hashCode() {
int hash = 7;
hash = 43 * hash + Arrays.deepHashCode(this.parts);
return hash;
}
public static final class NameSerializer extends StdSerializer<Name> {
private static final long serialVersionUID = 1L;
public NameSerializer() {
this(null);
}
public NameSerializer(Class<Name> t) {
super(t);
}
@Override
public void serialize(Name value, JsonGenerator gen, SerializerProvider provider) throws IOException {
gen.writeArray(value.parts, 0, value.parts.length);
}
}
public static final class NameDeserializer extends StdDeserializer<Name> {
private static final long serialVersionUID = 1L;
public NameDeserializer() {
this(null);
}
public NameDeserializer(Class<Name> t) {
super(t);
}
@Override
public Name deserialize(JsonParser parser, DeserializationContext context) throws IOException, JsonProcessingException {
JsonNode partArray = parser.getCodec().readTree(parser);
String[] parts = new String[partArray.size()];
int i = 0;
for (final JsonNode part : partArray) {
parts[i] = part.asText();
i++;
}
return new Name(parts);
}
}
}

11
traqtor-schema/src/main/java/link/pagan/traqtor/util/Named.java
Unescape Escape View File

@ -1,11 +0,0 @@
package link.pagan.traqtor.util;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public interface Named {
public Name getName();
}

11
traqtor-schema/src/main/java/link/pagan/traqtor/util/Registrable.java
Unescape Escape View File

@ -1,11 +0,0 @@
package link.pagan.traqtor.util;
/**
*
* @author Edward M. Kagan {@literal <}kaganem{@literal @}2pm.tech{@literal >}
*/
public interface Registrable<T> {
// public Map<String, T> register();
}
Write Preview
Loading…
Cancel
Save