Migrated all resources into the resources' directory.
This commit is contained in:
didier amyot committed
1 parent
8449cf94ee
commit
eca4820fd2
16 files changed
+3
-7
No files matched your search
@@ -0,0 +1,183 @@
|
||||
import {Command} from "https://deno.land/x/cliffy@v0.25.7/command/mod.ts";
|
||||
import {concat, partial} from 'https://deno.land/x/lodash@4.17.15-es/lodash.js';
|
||||
import {dirname, join} from "https://deno.land/std@0.171.0/path/mod.ts";
|
||||
import avro from "npm:avro-js@1.11.1";
|
||||
|
||||
|
||||
enum AvroPrimitives {
|
||||
Null = "null",
|
||||
Boolean = "boolean",
|
||||
Int = "int",
|
||||
Long = "long",
|
||||
Float = "float",
|
||||
Double = "double",
|
||||
Bytes = "bytes",
|
||||
String = "string"
|
||||
}
|
||||
|
||||
interface AvroRecordField {
|
||||
name: string,
|
||||
doc?: string,
|
||||
default?: any,
|
||||
type: AvroTypes,
|
||||
}
|
||||
|
||||
interface AvroRecord {
|
||||
name: string,
|
||||
type: "record",
|
||||
namespace?: string,
|
||||
doc?: string,
|
||||
aliases?: string[]
|
||||
fields: AvroRecordField[]
|
||||
}
|
||||
|
||||
interface AvroEnum {
|
||||
name: string,
|
||||
namespace?: string,
|
||||
aliases?: string[],
|
||||
type: "enum",
|
||||
symbols: string[],
|
||||
}
|
||||
|
||||
type AvroUnion = AvroTypes[];
|
||||
|
||||
type AvroTypes = AvroPrimitives | AvroRecord | AvroUnion | AvroEnum;
|
||||
|
||||
const CacheChequeEvent: AvroRecord = {
|
||||
name: "CacheChequeEvent",
|
||||
type: "record",
|
||||
fields: [
|
||||
{name: "account", type: AvroPrimitives.Long},
|
||||
]
|
||||
}
|
||||
|
||||
const BogusEvent: AvroRecord = {
|
||||
name: "BogusEvent",
|
||||
type: "record",
|
||||
fields: [
|
||||
{name: "account", type: AvroPrimitives.Long},
|
||||
{name: "foo", type: AvroPrimitives.Long},
|
||||
]
|
||||
}
|
||||
|
||||
const allEvents: AvroRecord[] = [CacheChequeEvent, BogusEvent]
|
||||
|
||||
const eventTypes: AvroEnum = {
|
||||
type: "enum",
|
||||
name: "EventType",
|
||||
symbols: allEvents.map(x => x.name),
|
||||
}
|
||||
|
||||
const LedgerEventsSchema: AvroRecord = {
|
||||
name: "LedgerEvent",
|
||||
type: "record",
|
||||
fields: [
|
||||
{name: "event_type", type: eventTypes},
|
||||
{name: "event", type: allEvents},
|
||||
]
|
||||
};
|
||||
|
||||
interface CliOptions {
|
||||
dry: boolean,
|
||||
output: string,
|
||||
}
|
||||
|
||||
type Serializer = (rec: AvroRecord) => Promise<void>;
|
||||
|
||||
function getOutputFileName(outputDir: string, rec: AvroRecord): string {
|
||||
return join(outputDir, rec.name + '.json');
|
||||
}
|
||||
|
||||
async function drySerializer(outputDir: string, rec: AvroRecord): Promise<void> {
|
||||
console.log(getOutputFileName(outputDir, rec) + " : " + JSON.stringify(rec));
|
||||
}
|
||||
|
||||
async function fileSerializer(outputDir: string, rec: AvroRecord): Promise<void> {
|
||||
const outputFile = getOutputFileName(outputDir, rec);
|
||||
await Deno.mkdir(dirname(outputFile), { recursive: true });
|
||||
await Deno.writeTextFile(outputFile, JSON.stringify(rec, null, 4));
|
||||
|
||||
}
|
||||
|
||||
function getSerializer(dry: boolean, outputDir: string): Serializer {
|
||||
return dry ? partial(drySerializer, outputDir) : partial(fileSerializer, outputDir);
|
||||
}
|
||||
|
||||
async function buildSchemata(options: CliOptions): Promise<void> {
|
||||
const serializer = getSerializer(options.dry, options.output);
|
||||
for (const e of concat([], allEvents, LedgerEventsSchema, eventTypes)) {
|
||||
await serializer(e);
|
||||
}
|
||||
}
|
||||
|
||||
async function testShit(): Promise<void> {
|
||||
const type = avro.parse(CacheChequeEvent);
|
||||
const buff = await Deno.readFile("/tmp/foo.data");
|
||||
console.log(buff);
|
||||
console.log(type.fromBuffer(buff));
|
||||
}
|
||||
|
||||
async function createMockData(): Promise<void> {
|
||||
const type = avro.parse(
|
||||
{
|
||||
"name": "CacheChequeEvent",
|
||||
"type": "record",
|
||||
"fields": [
|
||||
{
|
||||
"name": "account",
|
||||
"type": "long"
|
||||
}
|
||||
]
|
||||
}
|
||||
|
||||
);
|
||||
const e = {
|
||||
account: 666
|
||||
// event_type: CacheChequeEvent.name,
|
||||
// event: {CacheChequeEvent: {account: 1788301184}}
|
||||
};
|
||||
const encoder = avro.createFileEncoder("/tmp/foo.data", type);
|
||||
encoder.write({account: 666});
|
||||
encoder.end();
|
||||
return;
|
||||
// const file = await Deno.open("/tmp/foo.data", {write: true, create: true});
|
||||
// for (let i = 0; i < 1; i++) {
|
||||
// await Deno.write(file.rid, type.toBuffer(e).buffer);
|
||||
// }
|
||||
}
|
||||
|
||||
function buildSchemataCommand() {
|
||||
return new Command()
|
||||
.description("Build the avro schemata")
|
||||
.option("--dry [value:boolean]", "Do not output any files", {
|
||||
default: false,
|
||||
})
|
||||
.option("--output [value:file]", "directory to output schemata", {
|
||||
default: '.',
|
||||
})
|
||||
.action(buildSchemata);
|
||||
}
|
||||
|
||||
function buildMockEventsCommand() {
|
||||
return new Command()
|
||||
.description("Generate mock data")
|
||||
.option("--output [value:file]", "output data file", {
|
||||
default: '.',
|
||||
})
|
||||
.action(createMockData);
|
||||
}
|
||||
|
||||
function buildTestingCommand() {
|
||||
return new Command()
|
||||
.description("Test mock data")
|
||||
.action(testShit);
|
||||
|
||||
}
|
||||
|
||||
await new Command()
|
||||
.name("ledger-avro-schemata-builder")
|
||||
.version("0.1.0")
|
||||
.command('build-schema', buildSchemataCommand())
|
||||
.command('create-mock-data', buildMockEventsCommand())
|
||||
.command('testing', buildTestingCommand())
|
||||
.parse(Deno.args);
|
||||
@@ -0,0 +1,94 @@
|
||||
CREATE TABLE IF NOT EXISTS users
|
||||
(
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
name TEXT NOT NULL,
|
||||
public_key TEXT NOT NULL,
|
||||
creation_time DATETIME DEFAULT CURRENT_TIMESTAMP
|
||||
);
|
||||
|
||||
CREATE TABLE IF NOT EXISTS security_types
|
||||
(
|
||||
name TEXT PRIMARY KEY
|
||||
) STRICT;
|
||||
|
||||
INSERT INTO security_types(name)
|
||||
VALUES ('currency'),
|
||||
('bond');
|
||||
|
||||
CREATE TABLE IF NOT EXISTS securities
|
||||
(
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
security_type TEXT NOT NULL,
|
||||
name TEXT NOT NULL UNIQUE,
|
||||
symbol TEXT NOT NULL UNIQUE,
|
||||
creation_time DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
FOREIGN KEY (security_type) REFERENCES security_types (name)
|
||||
);
|
||||
|
||||
CREATE TABLE IF NOT EXISTS account_types
|
||||
(
|
||||
name TEXT PRIMARY KEY
|
||||
) STRICT;
|
||||
|
||||
INSERT INTO account_types(name)
|
||||
VALUES ('checking'),
|
||||
('security_emitter');
|
||||
|
||||
CREATE TABLE IF NOT EXISTS accounts
|
||||
(
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
version INTEGER NOT NULL CHECK ( version >= 0 ),
|
||||
security INTEGER NOT NULL,
|
||||
account_type TEXT NOT NULL,
|
||||
|
||||
amount INTEGER NOT NULL,
|
||||
timestamp DATETIME NOT NULL,
|
||||
creation_time DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
|
||||
FOREIGN KEY (security) REFERENCES securities (id),
|
||||
FOREIGN KEY (account_type) REFERENCES account_types (name)
|
||||
);
|
||||
|
||||
CREATE TABLE IF NOT EXISTS accounts_history
|
||||
(
|
||||
account_id INTEGER NOT NULL,
|
||||
account_version INTEGER NOT NULL,
|
||||
amount INTEGER NOT NULL,
|
||||
timestamp DATETIME NOT NULL,
|
||||
FOREIGN KEY (account_id) REFERENCES accounts (id),
|
||||
PRIMARY KEY (account_id, account_version)
|
||||
);
|
||||
|
||||
CREATE TABLE IF NOT EXISTS account_user_permissions
|
||||
(
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
account_id INTEGER NOT NULL,
|
||||
user_id INTEGER NOT NULL,
|
||||
creation_time DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
|
||||
FOREIGN KEY (account_id) REFERENCES accounts (id),
|
||||
FOREIGN KEY (user_id) REFERENCES users (id)
|
||||
|
||||
);
|
||||
|
||||
CREATE TABLE IF NOT EXISTS cashed_cheques
|
||||
(
|
||||
id INTEGER PRIMARY KEY AUTOINCREMENT,
|
||||
drawer_user_id INTEGER NOT NULL,
|
||||
drawer_account_id INTEGER NOT NULL,
|
||||
drawer_account_version INTEGER NOT NULL,
|
||||
cheque_number INTEGER NOT NULL,
|
||||
amount INTEGER NOT NULL,
|
||||
underlying_security INTEGER NOT NULL,
|
||||
payee_user_id INTEGER NOT NULL,
|
||||
payee_account_id INTEGER NOT NULL,
|
||||
payee_account_version INTEGER NOT NULL,
|
||||
creation_time DATETIME DEFAULT CURRENT_TIMESTAMP,
|
||||
|
||||
FOREIGN KEY (underlying_security) REFERENCES securities (id),
|
||||
FOREIGN KEY (drawer_user_id) REFERENCES users (id),
|
||||
FOREIGN KEY (drawer_account_id) REFERENCES accounts (id),
|
||||
FOREIGN KEY (payee_user_id) REFERENCES users (id),
|
||||
FOREIGN KEY (payee_account_id) REFERENCES accounts (id),
|
||||
CONSTRAINT double_spending UNIQUE (drawer_user_id, cheque_number) -- no double spending
|
||||
);
|
||||
Reference in new issue
Block a user