DukeInc/TimeChain
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Compare commits

base: DukeInc:54f16d0ac262e588410f6c50b667e6eea626442f
Branches Tags
DukeInc:master
DukeInc:feature_db_location
...
compare: DukeInc:7c9a29b16c99cb21cc27c60a4e6321f8f814d5cb
Branches Tags
DukeInc:feature_db_location
DukeInc:master

2 Commits
54f16d0ac2 ... 7c9a29b16c

Author SHA1 Message Date
Jason Tudisco
7c9a29b16c Before experimenting with the GUI, I'm writing tests to ensure that my data layer functions correctly. 2022-01-30 19:59:07 -06:00
Jason Tudisco
a88d85d3bc Moving some UI files and create no UI elements. Also updates to sqlite plugin. 2022-01-29 01:26:33 -06:00
17 changed files with 5763 additions and 515 deletions
Show Stats Expand all files Collapse all files

80
.gitignore vendored
View File

@ -1,40 +1,40 @@
# Logs
logs
*.log
npm-debug.log*
yarn-debug.log*
yarn-error.log*
lerna-debug.log*
.pnpm-debug.log*
.npm
# yarn v2
.yarn/cache
.yarn/unplugged
.yarn/build-state.yml
.yarn/install-state.gz
.pnp.*
# Dependency directories
node_modules/
jspm_packages/
# dotenv environment variable files
.env
.env.development.local
.env.test.local
.env.production.local
.env.local
# IDEs
.vscode
.idea
# parcel-bundler cache (https://parceljs.org/)
.cache
.parcel-cache
# build directory
dist/
# Logs
logs
*.log
npm-debug.log*
yarn-debug.log*
yarn-error.log*
lerna-debug.log*
.pnpm-debug.log*
.npm
# yarn v2
.yarn/cache
.yarn/unplugged
.yarn/build-state.yml
.yarn/install-state.gz
.pnp.*
# Dependency directories
node_modules/
jspm_packages/
# dotenv environment variable files
.env
.env.development.local
.env.test.local
.env.production.local
.env.local
# IDEs
.vscode
.idea
# parcel-bundler cache (https://parceljs.org/)
.cache
.parcel-cache
# build directory
dist/

10
.parcelrc
View File

@ -1,6 +1,6 @@
{
"extends": "@parcel/config-default",
"transformers": {
"*.riot": ["@riotjs/parcel-transformer-riot"]
}
{
"extends": "@parcel/config-default",
"transformers": {
"*.riot": ["@riotjs/parcel-transformer-riot"]
}
}

17
README.md Normal file
View File

@ -0,0 +1,17 @@
# TimeChain
A straightforward program for pasting text, HTML, photos, or anything else. The FILO interface is straightforward: tag it, timestamp it, then view it.
# Build
```
npm run build
```
# Tests
Type the following commands to run tests:
```
npx jest
```

40
index.html
View File

@ -1,21 +1,21 @@
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<meta http-equiv="Content-Security-Policy" content="default-src 'self'; script-src 'self'">
<meta http-equiv="X-Content-Security-Policy" content="default-src 'self'; script-src 'self'">
<title>Time Chain</title>
<link rel="stylesheet" href="src/css/main.css">
</head>
<body>
<div class="loading" >
<h1>Time Chain!</h1>
<p>Time traveling your data! Comming soon...</p>
<p id="timestamp"></p>
<img src="src/img/chain2.svg" class="rotate">
</div>
<script type="module" src="src/dist/start.js"></script>
</body>
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<meta http-equiv="Content-Security-Policy" content="default-src 'self'; script-src 'self'">
<meta http-equiv="X-Content-Security-Policy" content="default-src 'self'; script-src 'self'">
<title>Time Chain</title>
<link rel="stylesheet" href="src/css/main.css">
</head>
<body>
<div class="loading" >
<h1>Time Chain!</h1>
<p>Time traveling your data! Comming soon...</p>
<p id="timestamp"></p>
<img src="src/img/chain2.svg" class="rotate">
</div>
<script type="module" src="src/dist/start.js"></script>
</body>
</html>

5035
package-lock.json generated
View File

File diff suppressed because it is too large Load Diff

4
package.json
View File

@ -13,7 +13,7 @@
},
"scripts": {
"start": "electron .",
"compile": "parcel build --dist-dir ./src/dist --target \"jason\" start.js"
"build": "parcel build --dist-dir ./src/dist --target \"jason\" start.js"
},
"browserslist": "> 0.5%, last 2 versions, not dead",
"targets": {
@ -25,12 +25,14 @@
"@riotjs/compiler": "^6.1.3",
"@riotjs/parcel-transformer-riot": "^7.0.3",
"electron": "^16.0.7",
"jest": "^27.4.7",
"parcel": "^2.2.1"
},
"dependencies": {
"better-sqlite3": "^7.5.0",
"dayjs": "^1.10.7",
"es6-interface": "^3.2.1",
"nanoid": "^3.2.0",
"pubsub-js": "^1.9.4",
"riot": "^6.1.2"
}

60
src/css/main.css
View File

@ -1,31 +1,31 @@
body {
background-color: #333;
color: whitesmoke;
}
.loading {
text-align: center;
padding: 5em;
}
.loading img {
width: 30%;
}
.loading p {
font-weight: 700;
font-size: 1.2em;
}
.rotate {
animation: rotation 2s infinite linear;
}
@keyframes rotation {
from {
transform: rotate(0deg);
}
to {
transform: rotate(359deg);
}
body {
background-color: #333;
color: whitesmoke;
}
.loading {
text-align: center;
padding: 5em;
}
.loading img {
width: 30%;
}
.loading p {
font-weight: 700;
font-size: 1.2em;
}
.rotate {
animation: rotation 2s infinite linear;
}
@keyframes rotation {
from {
transform: rotate(0deg);
}
to {
transform: rotate(359deg);
}
}

68
src/data/interfaces.js
View File

@ -1,35 +1,35 @@
const InterfaceRecord = {
find(search,limit,offset){},
get(uuid){},
add(uuid,timestamp,content,mime,hash){},
update(uuid,timestamp,content,mime,hash){},
delete(uuid){},
}
const InterfaceFile = {
add(uuid_record,uuid,timestamp,content,mime,hash){},
getByRecord(uuid_record){},
get(uuid){},
delete(uuid){},
deleteRecord(uuid_record){},
update(uuid,timestamp,content,mime,hash){}
}
const InterfaceTag = {
add(uuid,word){},
delete(uuid){}
}
const InterfaceTagLink = {
add(uuid_record,uuid_tag){},
delete(uuid_record,uuid_tag){},
deleteTag(uuid){},
deleteRecord(uuid){}
}
module.exports = {
InterfaceTagLink,
InterfaceTag,
InterfaceFile,
InterfaceRecord
const InterfaceRecord = {
find(search,sort,limit,offset){},
get(uuid){},
add(uuid,timestamp,content,mime,hash){},
update(uuid,content,mime,hash){},
delete(uuid){},
}
const InterfaceFile = {
add(uuid_record,uuid,timestamp,content,mime,hash){},
getByRecord(uuid_record){},
get(uuid){},
delete(uuid){},
deleteRecord(uuid_record){},
update(uuid,timestamp,content,mime,hash){}
}
const InterfaceTag = {
add(tag){},
delete(tag){}
}
const InterfaceTagLink = {
add(uuid,tag){},
delete(uuid,tag){},
deleteTag(tag){},
deleteRecord(uuid){}
}
module.exports = {
InterfaceTagLink,
InterfaceTag,
InterfaceFile,
InterfaceRecord
}

150
src/data/sqlite-electron-ipc.js
View File

@ -1,76 +1,76 @@
const { ipcMain } = require('electron');
const {app} = require('electron');
const config = app.getPath('userData');
const Conf = require('conf');
const config = new Conf();
// ** Extra Data
ipcMain.on('timechain-config-dir', (event,arg) => {
const configDir = app.getPath('userData');
event.reply('timechain-config-dir-reply', configDir);
});
// ** RECORD **
ipcMain.on('timechain-record-add', (event, arg) => {
event.reply('timechain-record-add-reply', 'pong')
});
ipcMain.on('timechain-record-delete', (event, arg) => {
event.reply('timechain-record-delete-reply', 'pong')
});
ipcMain.on('timechain-record-update', (event, arg) => {
event.reply('timechain-record-update-reply', 'pong')
});
ipcMain.on('timechain-record-find', (event, arg) => {
event.reply('timechain-record-find-reply', 'pong')
});
// ** FILE **
ipcMain.on('timechain-file-find', (event, arg) => {
event.reply('timechain-file-find-reply', 'pong')
});
ipcMain.on('timechain-file-add', (event, arg) => {
event.reply('timechain-file-add-reply', 'pong')
});
ipcMain.on('timechain-file-update', (event, arg) => {
event.reply('timechain-file-update-reply', 'pong')
});
ipcMain.on('timechain-file-delete', (event, arg) => {
event.reply('timechain-file-delete-reply', 'pong')
});
// ** TAG **
ipcMain.on('timechain-tag-add', (event, arg) => {
event.reply('timechain-tag-add-reply', 'pong')
});
ipcMain.on('timechain-tag-delete', (event, arg) => {
event.reply('timechain-tag-delete-reply', 'pong')
});
// ** TAG LINK **
ipcMain.on('timechain-taglink-add', (event, arg) => {
event.reply('timechain-taglink-add-reply', 'pong')
});
ipcMain.on('timechain-taglink-delete', (event, arg) => {
event.reply('timechain-taglink-delete-reply', 'pong')
});
ipcMain.on('timechain-taglink-deleteTag', (event, arg) => {
event.reply('timechain-taglink-deleteTag-reply', 'pong')
});
ipcMain.on('timechain-taglink-deleteRecord', (event, arg) => {
event.reply('timechain-taglink-deleteRecord-reply', 'pong')
const { ipcMain } = require('electron');
const {app} = require('electron');
const config = app.getPath('userData');
const Conf = require('conf');
const config = new Conf();
// ** Extra Data
ipcMain.on('timechain-config-dir', (event,arg) => {
const configDir = app.getPath('userData');
event.reply('timechain-config-dir-reply', configDir);
});
// ** RECORD **
ipcMain.on('timechain-record-add', (event, arg) => {
event.reply('timechain-record-add-reply', 'pong')
});
ipcMain.on('timechain-record-delete', (event, arg) => {
event.reply('timechain-record-delete-reply', 'pong')
});
ipcMain.on('timechain-record-update', (event, arg) => {
event.reply('timechain-record-update-reply', 'pong')
});
ipcMain.on('timechain-record-find', (event, arg) => {
event.reply('timechain-record-find-reply', 'pong')
});
// ** FILE **
ipcMain.on('timechain-file-find', (event, arg) => {
event.reply('timechain-file-find-reply', 'pong')
});
ipcMain.on('timechain-file-add', (event, arg) => {
event.reply('timechain-file-add-reply', 'pong')
});
ipcMain.on('timechain-file-update', (event, arg) => {
event.reply('timechain-file-update-reply', 'pong')
});
ipcMain.on('timechain-file-delete', (event, arg) => {
event.reply('timechain-file-delete-reply', 'pong')
});
// ** TAG **
ipcMain.on('timechain-tag-add', (event, arg) => {
event.reply('timechain-tag-add-reply', 'pong')
});
ipcMain.on('timechain-tag-delete', (event, arg) => {
event.reply('timechain-tag-delete-reply', 'pong')
});
// ** TAG LINK **
ipcMain.on('timechain-taglink-add', (event, arg) => {
event.reply('timechain-taglink-add-reply', 'pong')
});
ipcMain.on('timechain-taglink-delete', (event, arg) => {
event.reply('timechain-taglink-delete-reply', 'pong')
});
ipcMain.on('timechain-taglink-deleteTag', (event, arg) => {
event.reply('timechain-taglink-deleteTag-reply', 'pong')
});
ipcMain.on('timechain-taglink-deleteRecord', (event, arg) => {
event.reply('timechain-taglink-deleteRecord-reply', 'pong')
});

656
src/data/sqlite.js
View File

@ -1,264 +1,392 @@
const Interface = require("es6-interface");
const {InterfaceRecord,InterfaceFile,InterfaceTag,InterfaceTagLink} = require("./interfaces");
let db = null;
const connectToDatabase = (path)=>{
db = require('better-sqlite3')(path, {});
}
class TimeChainDataSqliteTag extends Interface(InterfaceTag) {
constructor(){
}
add(uuid,word){
}
delete(uuid){
}
}
class TimeChainDataSqliteTagLink extends Interface(InterfaceTagLink) {
constructor(){
}
}
class TimeChainDataSqliteFile extends Interface(InterfaceFile) {
constructor(){
const table = `CREATE TABLE IF NOT EXISTS "files" (
"uuid" TEXT UNIQUE,
"uuid_record" TEXT NOT NULL,
"timestamp" INTEGER NOT NULL,
"content" BLOB NOT NULL,
"mime" TEXT NOT NULL,
"hash" TEXT,
"created_at" INTEGER NOT NULL,
"updated_at" INTEGER NOT NULL,
PRIMARY KEY("uuid")
);`;
const table_idx = `
CREATE INDEX IF NOT EXISTS "files_idx_record" ON "files" (
"uuid_record"
);
CREATE INDEX IF NOT EXISTS "files_idx_time" ON "files" (
"timestamp" DESC
);`;
if(!db){
throw new Error("Database is not connected");
}
db.exec(table + "\n" + table_idx);
this.db = db;
}
get table_insert() {
if(!this._table_insert){
this._table_insert = db.prepare(`INSERT INTO files (uuid,uuid_record,timestamp,content,mime,hash,created_at,updated_at) VALUES (?,?,?,?,?,?,?,?)`);
}
return this._table_insert;
}
get table_update() {
if(!this._table_update){
this._table_update = db.prepare(`UPDATE files SET timestamp = ?, content = ?, mime = ? hash = ?, updated_at = ? WHERE uuid = ?`);
}
return this._table_update;
}
get table_delete() {
if(!this._table_delete){
this._table_delete = db.prepare(`DELETE FROM files WHERE uuid = ?`);
}
return this._table_delete;
}
get table_delete_record() {
if(!this._table_delete_record){
this._table_delete_record = db.prepare(`DELETE FROM files WHERE uuid_record = ?`);
}
return this._table_delete_record;
}
get table_find_one() {
if(!this._table_find_one){
this._table_find_one = db.prepare(`SELECT * FROM files WHERE uuid = ?`);
}
return this._table_find_one;
}
get table_find_record(){
if(!this._table_find_record){
this._table_find_record = db.prepare(`SELECT * FROM files WHERE uuid_record = ?`);
}
return this._table_find_record;
}
add(uuid_record,uuid,timestamp,content,mime,hash){
return new Promise(resolve=>{
const dt = Math.floor(Date.now());
const res = this.table_insert.exec(uuid,uuid_record,timestamp,content,mime,hash,dt,dt);
return resolve(res?.changes);
});
}
getByRecord(uuid_record){
return new Promise(resolve => {
const res = this.table_find_record.get(uuid_record);
return resolve(res);
});
}
get(uuid){
return new Promise(resolve => {
const res = this.table_fine_one.get(uuid);
return resolve(res);
});
}
delete(uuid){
return new Promise(resolve=>{
const res = this.table_delete.exec(uuid);
return resolve(res?.changes);
})
}
deleteRecord(){
return new Promise(resolve=>{
const res = this.table_delete_record.exec(uuid_record);
return resolve(res?.changes);
})
}
update(uuid,timestamp,content,mime,hash){
return new Promise(resolve=>{
const res = this.table_update.exec(timestamp,content,mime,hash,uuid);
return resolve(res?.changes);
})
}
}
class TimeChainDataSqliteRecord extends Interface(InterfaceRecord) {
constructor(){
//TODO: Create Tables Here if not exist
const table = `CREATE TABLE IF NOT EXISTS "records" (
"uuid" TEXT NOT NULL UNIQUE,
"timestamp" INTEGER NOT NULL,
"content" TEXT NOT NULL,
"mime" TEXT NOT NULL,
"hash" TEXT,
"created_at" INTEGER NOT NULL,
"updated_at" INTEGER NOT NULL,
PRIMARY KEY("uuid")
);`;
const table_idx = `CREATE INDEX IF NOT EXISTS "records_idx_timestamp" ON "records" (
"timestamp" DESC
);`
if(!db){
throw new Error("Database is not connected");
}
db.exec(table + "\n" + table_idx);
this.db = db;
}
get table_insert() {
if(!this._table_insert){
this._table_insert = db.prepare(`INSERT INTO records (uuid,timestamp,content,mime,hash,created_at,updated_at) VALUES (?,?,?,?,?,?,?)`);
}
return this._table_insert;
}
get table_update(){
if(!this._table_update){
this._table_update = db.prepare(`UPDATE records SET timestamp = ?, content = ?, mime = ?, hash = ? updated_at = ? WHERE uuid = ?`);
}
return this._table_update;
}
get table_delete(){
if(!this._table_delete){
this._table_delete = db.prepare(`DELETE FROM records WHERE uuid = ?`);
}
return this._table_delete;
}
get table_fine_one(){
if(!this._table_fine_one){
this._table_fine_one = db.prepare(`SELECT * FROM records WHERE uuid = ?`);
}
return this._table_fine_one;
}
add(uuid,timestamp,content,mime,hash){
return new Promise(resolve=>{
const dt = Math.floor(Date.now());
const res = this.table_insert.run(uuid,timestamp,content,mime,hash,dt,dt);
return resolve(res?.changes);
});
}
get(uuid){
return new Promise(resolve=>{
const rec = this.table_fine_one.get(uuid);
return resolve(rec);
});
}
find(search,sort=null,limit=undefined,offset=0){
//TODO: add logic for seach and sort (Currently does nothing)
return new Promise(resolve=>{
const rescount = this.db.prepare("SELECT count(*) as cnt FROM records").get();
if(limit){
const res = this.db.prepare("SELECT * FROM records ORDER BY timestamp DESC LIMIT ? OFFSET ?").all(limit,offset);
}else{
const res = this.db.prepare("SELECT * FROM records ORDER BY timestamp DESC").all();
}
return resolve({
data: res,
count: rescount?.cnt,
limit: limit,
offset: offset
});
})
}
delete(uuid){
return new Promise(resolve=>{
const res = this.table_delete.exec(uuid);
return resolve(res?.changes);
});
}
update(uuid,content,mime,hash){
return new Promise(resolve=>{
const dt = Math.floor(Date.now());
const res = this.table_update.exec(content,mime,hash,dt,uuid);
return resolve(res?.changes);
})
}
}
class TimeChainDataSqlite {
}
const Interface = require("es6-interface");
const {InterfaceRecord,InterfaceFile,InterfaceTag,InterfaceTagLink} = require("./interfaces");
let db = null;
const ConnectToDatabase = (path)=>{
db = require('better-sqlite3')(path, {});
return db;
}
class TimeChainDataSqliteTag extends Interface(InterfaceTag) {
constructor(){
super();
const table = `CREATE TABLE IF NOT EXISTS "tags" (
"tag" TEXT UNIQUE,
"created_at" INTEGER NOT NULL,
"updated_at" INTEGER NOT NULL,
PRIMARY KEY("tag")
);`;
const table_idx = ``;
if(!db){
throw new Error("Database is not connected");
}
db.exec(table + "\n" + table_idx);
this.db = db;
}
get table_add(){
if(!this._table_add){
this._table_add = db.prepare("INSERT INTO tags (tag,created_at,updated_at) VALUES (?,?,?)");
}
return this.table_add;
}
get table_delete(){
if(!this._table_delete){
this._table_delete = db.prepare("DELETE FROM tags WHERE tag = ?");
}
return this._table_delete;
}
add(tag){
return new Promise(resolve=>{
const dt = Math.floor(Date.now());
const res = this.table_add.run(tag,dt,dt);
return resolve(res?.changes);
});
}
delete(tag){
return new Promise(resolve=>{
const dt = Math.floor(Date.now());
const res = this.table_delete.run(tag);
return resolve(res?.changes);
});
}
}
class TimeChainDataSqliteTagLink extends Interface(InterfaceTagLink) {
constructor(){
super();
this.table = `CREATE TABLE IF NOT EXISTS "taglink" (
"uuid" TEXT NOT NULL,
"tag" TEXT NOT NULL,
"created_at" INTEGER NOT NULL
);`;
this.table_idx = `
CREATE INDEX IF NOT EXISTS "uuid_idx" ON "taglink" (
"uuid"
);
CREATE INDEX IF NOT EXISTS "tag_idx" ON "taglink" (
"tag"
);
`;
db.exec(this.table + "\n" + this.table_idx);
this.db = db;
}
get table_add(){
if(!_table_add){
this._table_add = db.prepare('INSERT INTO taglink (uuid,tag,created_at) VALUES (?,?,?)');
}
return this._table_add;
}
get table_delete(){
if(!this._table_delete){
this._table_delete = db.prepare('DELETE FROM taglink WHERE uuid=? AND tag=?');
}
return this._table_delete;
}
get table_delete_tag(){
if(!this._table_delete_tag){
this._table_delete_tag = db.prepare('DELETE FROM taglink WHERE tag=?');
}
return this._table_delete_tag;
}
get table_delete_record(){
if(!this._table_delete_record){
this._table_delete_record = db.prepare('DELETE FROM taglink WHERE uuid=?');
}
}
add(uuid,tag){
return new Promise(resolve=>{
const prepare = this.table_add;
const dt = Math.floor(Date.now());
const res = prepare.run(uuid,tag,dt);
return resolve(res?.changes);
});
}
delete(uuid,tag){
return new Promise(resolve=>{
const prepare = this.table_delete;
const res = prepare.run(uuid,tag);
return resolve(res?.changes);
});
}
deleteTag(tag){
return new Promise(resolve=>{
const prepare = this.table_delete_tag;
const res = prepare.run(tag);
return resolve(res?.changes);
});
}
deleteRecord(uuid){
return new Promise(resolve=>{
const prepare = this.table_delete_record;
const res = prepare.run(uuid);
return resolve(res?.changes);
});
}
}
class TimeChainDataSqliteFile extends Interface(InterfaceFile) {
constructor(){
super();
const table = `CREATE TABLE IF NOT EXISTS "files" (
"uuid" TEXT UNIQUE,
"uuid_record" TEXT NOT NULL,
"timestamp" INTEGER NOT NULL,
"content" BLOB NOT NULL,
"mime" TEXT NOT NULL,
"hash" TEXT,
"created_at" INTEGER NOT NULL,
"updated_at" INTEGER NOT NULL,
PRIMARY KEY("uuid")
);`;
const table_idx = `
CREATE INDEX IF NOT EXISTS "files_idx_record" ON "files" (
"uuid_record"
);
CREATE INDEX IF NOT EXISTS "files_idx_time" ON "files" (
"timestamp" DESC
);`;
if(!db){
throw new Error("Database is not connected");
}
db.exec(table + "\n" + table_idx);
this.db = db;
}
get table_insert() {
if(!this._table_insert){
this._table_insert = db.prepare(`INSERT INTO files (uuid,uuid_record,timestamp,content,mime,hash,created_at,updated_at) VALUES (?,?,?,?,?,?,?,?)`);
}
return this._table_insert;
}
get table_update() {
if(!this._table_update){
this._table_update = db.prepare(`UPDATE files SET timestamp = ?, content = ?, mime = ? hash = ?, updated_at = ? WHERE uuid = ?`);
}
return this._table_update;
}
get table_delete() {
if(!this._table_delete){
this._table_delete = db.prepare(`DELETE FROM files WHERE uuid = ?`);
}
return this._table_delete;
}
get table_delete_record() {
if(!this._table_delete_record){
this._table_delete_record = db.prepare(`DELETE FROM files WHERE uuid_record = ?`);
}
return this._table_delete_record;
}
get table_find_one() {
if(!this._table_find_one){
this._table_find_one = db.prepare(`SELECT * FROM files WHERE uuid = ?`);
}
return this._table_find_one;
}
get table_find_record(){
if(!this._table_find_record){
this._table_find_record = db.prepare(`SELECT * FROM files WHERE uuid_record = ?`);
}
return this._table_find_record;
}
add(uuid_record,uuid,timestamp,content,mime,hash){
return new Promise(resolve=>{
const dt = Math.floor(Date.now());
const res = this.table_insert.run(uuid,uuid_record,timestamp,content,mime,hash,dt,dt);
return resolve(res?.changes);
});
}
getByRecord(uuid_record){
return new Promise(resolve => {
const res = this.table_find_record.get(uuid_record);
return resolve(res);
});
}
get(uuid){
return new Promise(resolve => {
const res = this.table_fine_one.get(uuid);
return resolve(res);
});
}
delete(uuid){
return new Promise(resolve=>{
const prepare = this.table_delete;
const res = prepare.exec(uuid);
return resolve(res?.changes);
})
}
deleteRecord(uuid_record){
return new Promise(resolve=>{
const res = this.table_delete_record.run(uuid_record);
return resolve(res?.changes);
})
}
update(uuid,timestamp,content,mime,hash){
return new Promise(resolve=>{
const res = this.table_update.run(timestamp,content,mime,hash,uuid);
return resolve(res?.changes);
})
}
}
class TimeChainDataSqliteRecord extends Interface(InterfaceRecord) {
constructor(){
super();
//TODO: Create Tables Here if not exist
const table = `CREATE TABLE IF NOT EXISTS "records" (
"uuid" TEXT NOT NULL UNIQUE,
"timestamp" INTEGER NOT NULL,
"content" TEXT NOT NULL,
"mime" TEXT NOT NULL,
"hash" TEXT,
"created_at" INTEGER NOT NULL,
"updated_at" INTEGER NOT NULL,
PRIMARY KEY("uuid")
);`;
const table_idx = `CREATE INDEX IF NOT EXISTS "records_idx_timestamp" ON "records" (
"timestamp" DESC
);`
if(!db){
throw new Error("Database is not connected");
}
db.exec(table + "\n" + table_idx);
this.db = db;
}
get table_insert() {
if(!this._table_insert){
this._table_insert = db.prepare(`INSERT INTO records (uuid,timestamp,content,mime,hash,created_at,updated_at) VALUES (?,?,?,?,?,?,?)`);
}
return this._table_insert;
}
get table_update(){
if(!this._table_update){
this._table_update = db.prepare(`UPDATE records SET timestamp = ?, content = ?, mime = ?, hash = ? updated_at = ? WHERE uuid = ?`);
}
return this._table_update;
}
get table_delete(){
if(!this._table_delete){
this._table_delete = db.prepare(`DELETE FROM records WHERE uuid = ?`);
}
return this._table_delete;
}
get table_fine_one(){
if(!this._table_fine_one){
this._table_fine_one = db.prepare(`SELECT * FROM records WHERE uuid = ?`);
}
return this._table_fine_one;
}
add(uuid,timestamp,content,mime,hash){
return new Promise(resolve=>{
const dt = Math.floor(Date.now());
const res = this.table_insert.run(uuid,timestamp,content,mime,hash,dt,dt);
return resolve(res?.changes);
});
}
get(uuid){
return new Promise(resolve=>{
const rec = this.table_fine_one.get(uuid);
return resolve(rec);
});
}
find(search,sort=null,limit=undefined,offset=0){
//TODO: add logic for seach and sort (Currently does nothing)
return new Promise(resolve=>{
const rescount = this.db.prepare("SELECT count(*) as cnt FROM records").get();
if(limit){
const res = this.db.prepare("SELECT * FROM records ORDER BY timestamp DESC LIMIT ? OFFSET ?").all(limit,offset);
}else{
const res = this.db.prepare("SELECT * FROM records ORDER BY timestamp DESC").all();
}
return resolve({
data: res,
count: rescount?.cnt,
limit: limit,
offset: offset
});
})
}
delete(uuid){
return new Promise(resolve=>{
const prepare = this.table_delete;
const res = prepare.run(uuid);
return resolve(res?.changes);
});
}
update(uuid,content,mime,hash){
return new Promise(resolve=>{
const dt = Math.floor(Date.now());
const res = this.table_update.run(content,mime,hash,dt,uuid);
return resolve(res?.changes);
})
}
}
class TimeChainDataSqlite {
}
module.exports = {
ConnectToDatabase,
TimeChainDataSqlite,
TimeChainDataSqliteRecord,
TimeChainDataSqliteFile,
TimeChainDataSqliteTagLink,
TimeChainDataSqliteTag
}

3
src/ui/app.riot Normal file
View File

@ -0,0 +1,3 @@
<app>
</app>

0
src/ui/timechain-input.riot Normal file
View File

0
src/ui/timer-ctrl.riot Normal file
View File

66
timestamp.riot → src/ui/timestamp.riot
View File

@ -1,34 +1,34 @@
<timestamp>
<div class="timestamp">
<div class="timestamp-icon">
<div class="timestamp-text">{ state.time_text }</div>
</div>
<script>
const pubsub = require('pubsub-js');
const dayjs = require('dayjs');
export default {
state: {
time_text: "",
format: "long"
},
onMounted(){
this.start();
},
start(){
setTimeout(()=>{
this.makeString();
this.start();
},200);
},
makeString(){
if(this.state.format=="long"){
this.update({time_text:dayjs().format("MMMM D, YYYY h:mm:ss A")});
}
}
};
</script>
<timestamp>
<div class="timestamp">
<div class="timestamp-icon">
<div class="timestamp-text">{ state.time_text }</div>
</div>
<script>
const pubsub = require('pubsub-js');
const dayjs = require('dayjs');
export default {
state: {
time_text: "",
format: "long"
},
onMounted(){
this.start();
},
start(){
setTimeout(()=>{
this.makeString();
this.start();
},200);
},
makeString(){
if(this.state.format=="long"){
this.update({time_text:dayjs().format("MMMM D, YYYY h:mm:ss A")});
}
}
};
</script>
</timestamp>

12
start.js
View File

@ -1,7 +1,7 @@
import Timestamp from './timestamp.riot'
import { component } from 'riot'
component(Timestamp)(document.getElementById('timestamp'))
import Timestamp from './src/ui/timestamp.riot'
import { component } from 'riot'
component(Timestamp)(document.getElementById('timestamp'))
console.log("yes!");

77
test/sqlite.test.js Normal file
View File

@ -0,0 +1,77 @@
const {TimeChainDataSqliteRecord,ConnectToDatabase, TimeChainDataSqliteFile, TimeChainDataSqliteTag, TimeChainDataSqliteTagLink} = require('../src/data/sqlite');
const { nanoid } = require('nanoid');
const { unsubscribe } = require('pubsub-js');
let db = null;
beforeAll(() => {
db = ConnectToDatabase(__dirname + "/test.db");
});
afterAll(()=>{
db.close();
})
test("Should create a records table", ()=>{
const rec = new TimeChainDataSqliteRecord();
const st = db.prepare("SELECT name FROM sqlite_master WHERE type='table' AND name=?");
const res = st.get('records');
expect(res).not.toBeNull();
expect(res.name).toEqual('records');
});
test("Should create a files table", ()=>{
const file = new TimeChainDataSqliteFile();
const st = db.prepare("SELECT name FROM sqlite_master WHERE type='table' AND name=?");
const res = st.get('files');
expect(res).not.toBeNull();
expect(res.name).toEqual('files');
});
test("Should create a tags table", ()=>{
const tags = new TimeChainDataSqliteTag();
const st = db.prepare("SELECT name FROM sqlite_master WHERE type='table' AND name=?");
const res = st.get('tags');
expect(res).not.toBeNull();
expect(res.name).toEqual('tags');
});
test("Should create a tags link table", ()=>{
const links = new TimeChainDataSqliteTagLink();
const st = db.prepare("SELECT name FROM sqlite_master WHERE type='table' AND name=?");
const res = st.get('taglink');
expect(res).not.toBeNull();
expect(res.name).toEqual('taglink');
});
test("Should create a record in the database and then remove it",async ()=>{
const rec = new TimeChainDataSqliteRecord();
const id = nanoid();
const hash = "fakehash";
const content = "This is a test";
const mime = "text/plain";
const ts = Math.floor(Date.now());
return rec.add(id,ts,content,mime,hash).then(res=>{
expect(res).toEqual(1);
return rec.get(id).then(res=>{
expect(res.uuid).toEqual(id);
expect(res.timestamp).toEqual(ts);
expect(res.mime).toEqual(mime);
expect(res.content).toEqual(content);
expect(res.hash).toEqual(hash);
return rec.delete(id);
})
})
})

BIN
test/test.db Normal file
View File

Binary file not shown.