chore: publish npm package

.gitignore

@@ -1,3 +1,4 @@
 .idea
 .code
-*.log
+*.log
+node_modules/

client-ts/dist/client-service.d.ts

@@ -0,0 +1,29 @@
+import * as github_com_foomo_busser_service from './vo-service';
+import * as github_com_foomo_busser_table from './vo-table';
+import * as github_com_foomo_busser_table_validation from './vo-validation';
+export declare class ServiceClient {
+    transport: <T>(method: string, data?: any[]) => Promise<T>;
+    static defaultEndpoint: string;
+    constructor(transport: <T>(method: string, data?: any[]) => Promise<T>);
+    commit(id: github_com_foomo_busser_table.ID, version: github_com_foomo_busser_table.Version): Promise<github_com_foomo_busser_service.ErrorCommit | null>;
+    delete(id: github_com_foomo_busser_table.ID, versions: Array<github_com_foomo_busser_table.Version> | null): Promise<github_com_foomo_busser_service.ErrorDelete | null>;
+    getCommitted(id: github_com_foomo_busser_table.ID): Promise<{
+        t: github_com_foomo_busser_table.Table | null;
+        vt: github_com_foomo_busser_table_validation.Table | null;
+        err: github_com_foomo_busser_service.ErrorGet | null;
+    }>;
+    getVersion(id: github_com_foomo_busser_table.ID, version: github_com_foomo_busser_table.Version): Promise<{
+        t: github_com_foomo_busser_table.Table | null;
+        vt: github_com_foomo_busser_table_validation.Table | null;
+        err: github_com_foomo_busser_service.ErrorGet | null;
+    }>;
+    list(): Promise<{
+        ret: github_com_foomo_busser_table.Map;
+        ret_1: github_com_foomo_busser_service.ErrorGet | null;
+    }>;
+    validate(id: github_com_foomo_busser_table.ID): Promise<{
+        t: github_com_foomo_busser_table.Table | null;
+        vt: github_com_foomo_busser_table_validation.Table | null;
+        err: github_com_foomo_busser_service.ErrorValidation | null;
+    }>;
+}

client-ts/dist/client-service.js

@@ -0,0 +1,119 @@
+"use strict";
+var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
+    function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
+    return new (P || (P = Promise))(function (resolve, reject) {
+        function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
+        function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
+        function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
+        step((generator = generator.apply(thisArg, _arguments || [])).next());
+    });
+};
+var __generator = (this && this.__generator) || function (thisArg, body) {
+    var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g;
+    return g = { next: verb(0), "throw": verb(1), "return": verb(2) }, typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
+    function verb(n) { return function (v) { return step([n, v]); }; }
+    function step(op) {
+        if (f) throw new TypeError("Generator is already executing.");
+        while (g && (g = 0, op[0] && (_ = 0)), _) try {
+            if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
+            if (y = 0, t) op = [op[0] & 2, t.value];
+            switch (op[0]) {
+                case 0: case 1: t = op; break;
+                case 4: _.label++; return { value: op[1], done: false };
+                case 5: _.label++; y = op[1]; op = [0]; continue;
+                case 7: op = _.ops.pop(); _.trys.pop(); continue;
+                default:
+                    if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
+                    if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
+                    if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
+                    if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
+                    if (t[2]) _.ops.pop();
+                    _.trys.pop(); continue;
+            }
+            op = body.call(thisArg, _);
+        } catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
+        if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
+    }
+};
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.ServiceClient = void 0;
+var ServiceClient = (function () {
+    function ServiceClient(transport) {
+        this.transport = transport;
+    }
+    ServiceClient.prototype.commit = function (id, version) {
+        return __awaiter(this, void 0, void 0, function () {
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4, this.transport("Commit", [id, version])];
+                    case 1: return [2, (_a.sent())[0]];
+                }
+            });
+        });
+    };
+    ServiceClient.prototype.delete = function (id, versions) {
+        return __awaiter(this, void 0, void 0, function () {
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4, this.transport("Delete", [id, versions])];
+                    case 1: return [2, (_a.sent())[0]];
+                }
+            });
+        });
+    };
+    ServiceClient.prototype.getCommitted = function (id) {
+        return __awaiter(this, void 0, void 0, function () {
+            var response;
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4, this.transport("GetCommitted", [id])];
+                    case 1:
+                        response = _a.sent();
+                        return [2, { t: response[0], vt: response[1], err: response[2] }];
+                }
+            });
+        });
+    };
+    ServiceClient.prototype.getVersion = function (id, version) {
+        return __awaiter(this, void 0, void 0, function () {
+            var response;
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4, this.transport("GetVersion", [id, version])];
+                    case 1:
+                        response = _a.sent();
+                        return [2, { t: response[0], vt: response[1], err: response[2] }];
+                }
+            });
+        });
+    };
+    ServiceClient.prototype.list = function () {
+        return __awaiter(this, void 0, void 0, function () {
+            var response;
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4, this.transport("List", [])];
+                    case 1:
+                        response = _a.sent();
+                        return [2, { ret: response[0], ret_1: response[1] }];
+                }
+            });
+        });
+    };
+    ServiceClient.prototype.validate = function (id) {
+        return __awaiter(this, void 0, void 0, function () {
+            var response;
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4, this.transport("Validate", [id])];
+                    case 1:
+                        response = _a.sent();
+                        return [2, { t: response[0], vt: response[1], err: response[2] }];
+                }
+            });
+        });
+    };
+    ServiceClient.defaultEndpoint = "/services/busser";
+    return ServiceClient;
+}());
+exports.ServiceClient = ServiceClient;

client-ts/dist/vo-service.d.ts

@@ -0,0 +1,12 @@
+export declare enum ErrorCommit {
+    CouldNotCommit = "COULD_NOT_COMMIT"
+}
+export declare enum ErrorDelete {
+    CouldNotDeleteVersion = "COULD_NOT_DELETE_VERSION"
+}
+export declare enum ErrorGet {
+    CouldNotLoadTableFromStore = "COULD_NOT_LOAD_TABLE_FROM_STORE"
+}
+export declare enum ErrorValidation {
+    CouldNotValidate = "COULD_NOT_LOAD_TABLE_FROM_STORE"
+}

client-ts/dist/vo-service.js

@@ -0,0 +1,19 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.ErrorValidation = exports.ErrorGet = exports.ErrorDelete = exports.ErrorCommit = void 0;
+var ErrorCommit;
+(function (ErrorCommit) {
+    ErrorCommit["CouldNotCommit"] = "COULD_NOT_COMMIT";
+})(ErrorCommit = exports.ErrorCommit || (exports.ErrorCommit = {}));
+var ErrorDelete;
+(function (ErrorDelete) {
+    ErrorDelete["CouldNotDeleteVersion"] = "COULD_NOT_DELETE_VERSION";
+})(ErrorDelete = exports.ErrorDelete || (exports.ErrorDelete = {}));
+var ErrorGet;
+(function (ErrorGet) {
+    ErrorGet["CouldNotLoadTableFromStore"] = "COULD_NOT_LOAD_TABLE_FROM_STORE";
+})(ErrorGet = exports.ErrorGet || (exports.ErrorGet = {}));
+var ErrorValidation;
+(function (ErrorValidation) {
+    ErrorValidation["CouldNotValidate"] = "COULD_NOT_LOAD_TABLE_FROM_STORE";
+})(ErrorValidation = exports.ErrorValidation || (exports.ErrorValidation = {}));

client-ts/dist/vo-table.d.ts

@@ -0,0 +1,22 @@
+import * as github_com_foomo_busser_table from './vo-table';
+export type ColumnName = string;
+export type ID = string;
+export type List = Array<github_com_foomo_busser_table.TableSummary>;
+export type Map = Record<github_com_foomo_busser_table.ID, github_com_foomo_busser_table.List | null>;
+export type Row = Record<github_com_foomo_busser_table.ColumnName, string>;
+export type Rows = Array<github_com_foomo_busser_table.Row | null>;
+export interface Table {
+    id: github_com_foomo_busser_table.ID;
+    version: github_com_foomo_busser_table.Version;
+    timestamp: number;
+    rows: github_com_foomo_busser_table.Rows | null;
+    readErrors: Array<string> | null;
+}
+export interface TableSummary {
+    id: github_com_foomo_busser_table.ID;
+    timestamp: number;
+    version: github_com_foomo_busser_table.Version;
+    valid: boolean;
+    committed: boolean;
+}
+export type Version = string;

client-ts/dist/vo-table.js

@@ -0,0 +1,2 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });

client-ts/dist/vo-validation.d.ts

@@ -0,0 +1,27 @@
+import * as github_com_foomo_busser_table from './vo-table';
+import * as github_com_foomo_busser_table_validation from './vo-validation';
+export interface Cell {
+    valid: boolean;
+    feedback: github_com_foomo_busser_table_validation.Feedback | null;
+}
+export type Feedback = Array<github_com_foomo_busser_table_validation.FeedbackEntry>;
+export interface FeedbackEntry {
+    level: github_com_foomo_busser_table_validation.FeedbackLevel;
+    msg: string;
+}
+export declare enum FeedbackLevel {
+    Error = "error",
+    Valid = "valid",
+    Warning = "warning"
+}
+export interface Row {
+    valid: boolean;
+    cells: Record<github_com_foomo_busser_table.ColumnName, github_com_foomo_busser_table_validation.Cell> | null;
+    feedback: github_com_foomo_busser_table_validation.Feedback | null;
+}
+export type Rows = Array<github_com_foomo_busser_table_validation.Row | null>;
+export interface Table {
+    valid: boolean;
+    rows: github_com_foomo_busser_table_validation.Rows | null;
+    feedback: github_com_foomo_busser_table_validation.Feedback | null;
+}

client-ts/dist/vo-validation.js

@@ -0,0 +1,9 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.FeedbackLevel = void 0;
+var FeedbackLevel;
+(function (FeedbackLevel) {
+    FeedbackLevel["Error"] = "error";
+    FeedbackLevel["Valid"] = "valid";
+    FeedbackLevel["Warning"] = "warning";
+})(FeedbackLevel = exports.FeedbackLevel || (exports.FeedbackLevel = {}));

package-lock.json

@@ -0,0 +1,37 @@
+{
+  "name": "@foomo/busser",
+  "version": "0.2.3",
+  "lockfileVersion": 2,
+  "requires": true,
+  "packages": {
+    "": {
+      "name": "@foomo/busser",
+      "version": "0.2.3",
+      "license": "MIT",
+      "devDependencies": {
+        "typescript": "^4.9.4"
+      }
+    },
+    "node_modules/typescript": {
+      "version": "4.9.4",
+      "resolved": "https://registry.npmjs.org/typescript/-/typescript-4.9.4.tgz",
+      "integrity": "sha512-Uz+dTXYzxXXbsFpM86Wh3dKCxrQqUcVMxwU54orwlJjOpO3ao8L7j5lH+dWfTwgCwIuM9GQ2kvVotzYJMXTBZg==",
+      "dev": true,
+      "bin": {
+        "tsc": "bin/tsc",
+        "tsserver": "bin/tsserver"
+      },
+      "engines": {
+        "node": ">=4.2.0"
+      }
+    }
+  },
+  "dependencies": {
+    "typescript": {
+      "version": "4.9.4",
+      "resolved": "https://registry.npmjs.org/typescript/-/typescript-4.9.4.tgz",
+      "integrity": "sha512-Uz+dTXYzxXXbsFpM86Wh3dKCxrQqUcVMxwU54orwlJjOpO3ao8L7j5lH+dWfTwgCwIuM9GQ2kvVotzYJMXTBZg==",
+      "dev": true
+    }
+  }
+}

package.json

@@ -0,0 +1,27 @@
+{
+  "name": "@foomo/busser",
+  "author": "foomo",
+  "license": "MIT",
+  "version": "0.2.4",
+  "description": "A program that runs on your server to validate and store table data",
+  "keywords": [],
+  "homepage": "https://github.com/foomo/busser#readme",
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/foomo/busser.git"
+  },
+  "bugs": {
+    "url": "https://github.com/foomo/busser/issues"
+  },
+  "main": "client-ts/dist/index.js",
+  "types": "client-ts/dist/index.d.ts",
+  "files": [
+    "client-ts/dist"
+  ],
+  "scripts": {
+    "build": "tsc -b -v ."
+  },
+  "devDependencies": {
+    "typescript": "^4.9.4"
+  }
+}

tsconfig.json

@@ -0,0 +1,23 @@
+{
+  "compilerOptions": {
+    "strict": true,
+    "forceConsistentCasingInFileNames": true,
+    "removeComments": true,
+    "target": "es5",
+    "lib": ["dom", "dom.iterable", "esnext"],
+    "allowJs": true,
+    "skipLibCheck": true,
+    "noEmit": false,
+    "esModuleInterop": true,
+    "module": "commonjs",
+    "moduleResolution": "node",
+    "resolveJsonModule": true,
+    "isolatedModules": true,
+    "jsx": "react",
+    "rootDir": "client-ts/src",
+    "outDir": "client-ts/dist",
+    "declaration": true
+  },
+  "exclude": ["node_modules"],
+  "include": ["client-ts/src"]
+}