Compare commits
2 commits
6ac181fca7
...
1a8ebaf88d
Author | SHA1 | Date | |
---|---|---|---|
|
1a8ebaf88d | ||
|
d5791bf5ed |
|
@ -214,7 +214,7 @@ function App({ ctx }) {
|
||||||
<>
|
<>
|
||||||
<section className="pt-8 container">
|
<section className="pt-8 container">
|
||||||
<Input type="text"
|
<Input type="text"
|
||||||
className="bg-background p-4"
|
className="bg-background"
|
||||||
placeholder="..."
|
placeholder="..."
|
||||||
value={newText}
|
value={newText}
|
||||||
onKeyUp={parseTodos}
|
onKeyUp={parseTodos}
|
||||||
|
|
|
@ -7,16 +7,53 @@ export interface InputProps
|
||||||
|
|
||||||
const Input = React.forwardRef<HTMLInputElement, InputProps>(
|
const Input = React.forwardRef<HTMLInputElement, InputProps>(
|
||||||
({ className, type, ...props }, ref) => {
|
({ className, type, ...props }, ref) => {
|
||||||
|
const [selectedIndex, setSelectedIndex] = React.useState(0)
|
||||||
|
const options = ["add", "done", "delete"]
|
||||||
|
|
||||||
|
const handleWheel = (event: React.WheelEvent) => {
|
||||||
|
event.preventDefault()
|
||||||
|
if (event.deltaY > 0) {
|
||||||
|
// Scroll down
|
||||||
|
setSelectedIndex((prev) => (prev + 1) % options.length)
|
||||||
|
} else {
|
||||||
|
// Scroll up
|
||||||
|
setSelectedIndex((prev) => (prev - 1 + options.length) % options.length)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return (
|
return (
|
||||||
<input
|
<div className="relative"
|
||||||
type={type}
|
onWheel={handleWheel}
|
||||||
className={cn(
|
>
|
||||||
"flex h-9 w-full rounded-md border border-input bg-transparent px-3 py-1 text-base shadow-sm transition-colors file:border-0 file:bg-transparent file:text-sm file:font-medium file:text-foreground placeholder:text-muted-foreground focus-visible:outline-none focus-visible:ring-1 focus-visible:ring-ring disabled:cursor-not-allowed disabled:opacity-50 md:text-sm",
|
<select
|
||||||
className
|
className={cn(
|
||||||
)}
|
"absolute top-0 left-0 h-9 rounded-l-md border-r border-input bg-transparent px-2 text-sm cursor-default",
|
||||||
ref={ref}
|
"shadow-sm transition-all duration-200 text-center appearance-none",
|
||||||
{...props}
|
)}
|
||||||
/>
|
value={options[selectedIndex]}
|
||||||
|
onChange={(e) => {
|
||||||
|
setSelectedIndex(options.indexOf(e.target.value))
|
||||||
|
}}
|
||||||
|
>
|
||||||
|
<option value="" disabled selected>
|
||||||
|
Actions
|
||||||
|
</option>
|
||||||
|
{options.map((option) => (
|
||||||
|
<option key={option} value={option}>
|
||||||
|
{option}
|
||||||
|
</option>
|
||||||
|
))}
|
||||||
|
</select>
|
||||||
|
<input
|
||||||
|
type={type}
|
||||||
|
className={cn(
|
||||||
|
"flex h-9 w-full rounded-md border border-input bg-background px-[90px] text-base shadow-sm transition-colors file:border-0 file:bg-transparent file:text-sm file:font-medium file:text-foreground placeholder:text-muted-foreground focus-visible:outline-none focus-visible:ring-1 focus-visible:ring-ring disabled:cursor-not-allowed disabled:opacity-50 md:text-sm",
|
||||||
|
className
|
||||||
|
)}
|
||||||
|
ref={ref}
|
||||||
|
{...props}
|
||||||
|
/>
|
||||||
|
</div>
|
||||||
)
|
)
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
|
@ -1,90 +1,31 @@
|
||||||
import { StrictMode } from 'react'
|
|
||||||
import { createRoot } from 'react-dom/client'
|
import { createRoot } from 'react-dom/client'
|
||||||
import './index.css'
|
import './index.css'
|
||||||
import App from "./App.tsx";
|
import App from "./App.tsx";
|
||||||
import Root from "./Root.tsx";
|
|
||||||
import { start } from "@vlcn.io/ws-client/worker.js";
|
|
||||||
import { createDbProvider } from "@vlcn.io/ws-browserdb";
|
|
||||||
|
|
||||||
import initWasm from '@vlcn.io/crsqlite-wasm';
|
import initWasm from '@vlcn.io/crsqlite-wasm';
|
||||||
import wasmUrl from '@vlcn.io/crsqlite-wasm/crsqlite.wasm?url';
|
import wasmUrl from '@vlcn.io/crsqlite-wasm/crsqlite.wasm?url';
|
||||||
import tblrx from '@vlcn.io/rx-tbl';
|
import tblrx from '@vlcn.io/rx-tbl';
|
||||||
|
|
||||||
async function initializeDatabase() {
|
const sqlite = await initWasm(() => wasmUrl);
|
||||||
const sqlite = await initWasm(() => wasmUrl);
|
|
||||||
const db = await sqlite.open("todo.db");
|
|
||||||
await db.exec(`
|
|
||||||
CREATE TABLE IF NOT EXISTS todos (
|
|
||||||
id BLOB PRIMARY KEY NOT NULL,
|
|
||||||
description TEXT,
|
|
||||||
project text,
|
|
||||||
tags text,
|
|
||||||
due text,
|
|
||||||
wait text,
|
|
||||||
priority text,
|
|
||||||
urgency real,
|
|
||||||
completed INTEGER NOT NULL DEFAULT 0
|
|
||||||
);
|
|
||||||
SELECT crsql_as_crr('todos');
|
|
||||||
`);
|
|
||||||
db.onUpdate(async () => {
|
|
||||||
const changes = await db.execA(`SELECT * FROM crsql_changes WHERE db_version > 0 AND site_id = crsql_site_id()`);
|
|
||||||
|
|
||||||
sendChangesToServer(changes);
|
const db = await sqlite.open("todo.db");
|
||||||
});
|
await db.exec(`
|
||||||
return db;
|
CREATE TABLE IF NOT EXISTS todos (
|
||||||
}
|
id BLOB PRIMARY KEY NOT NULL,
|
||||||
|
description TEXT,
|
||||||
|
project text,
|
||||||
|
tags text,
|
||||||
|
due text,
|
||||||
|
wait text,
|
||||||
|
priority text,
|
||||||
|
urgency real,
|
||||||
|
completed INTEGER NOT NULL DEFAULT 0
|
||||||
|
);
|
||||||
|
SELECT crsql_as_crr('todos');
|
||||||
|
`);
|
||||||
|
|
||||||
const config = {
|
const rx = tblrx(db);
|
||||||
dbProvider: createDbProvider(),
|
const ctx = { db, rx };
|
||||||
transportProvider: (dbName) => new WebSocket(`ws://localhost:8080/sync/${dbName}`),
|
|
||||||
};
|
|
||||||
|
|
||||||
start(config);
|
|
||||||
const ws = new WebSocket('ws://localhost:8080/sync');
|
|
||||||
|
|
||||||
ws.onmessage = async function(event) {
|
|
||||||
const { type, data } = JSON.parse(event.data);
|
|
||||||
if (type === 'changes') {
|
|
||||||
await applyChanges(data);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
function sendChangesToServer(changes) {
|
|
||||||
const formattedChanges = changes.map(change => ({
|
|
||||||
TableName: change[0],
|
|
||||||
PK: Array.isArray(change[1]) ? btoa(String.fromCharCode.apply(null, change[1])) : btoa(change[1]),
|
|
||||||
ColumnName: change[2],
|
|
||||||
Value: Array.isArray(change[3]) ? btoa(String.fromCharCode.apply(null, change[3])) : change[3],
|
|
||||||
ColVersion: Number(change[4]),
|
|
||||||
DBVersion: Number(change[5]),
|
|
||||||
SiteID: Array.isArray(change[6]) ? btoa(new TextDecoder('utf8').decode(change[6])) : btoa(change[6]),
|
|
||||||
CL: Number(change[7]),
|
|
||||||
Seq: Number(change[8])
|
|
||||||
}));
|
|
||||||
console.log(formattedChanges)
|
|
||||||
|
|
||||||
const message = {
|
|
||||||
type: "changes",
|
|
||||||
data: formattedChanges
|
|
||||||
};
|
|
||||||
|
|
||||||
ws.send(JSON.stringify(message));
|
|
||||||
}
|
|
||||||
|
|
||||||
async function applyChanges(changes) {
|
|
||||||
const db = initializeDatabase();
|
|
||||||
const rx = tblrx(db);
|
|
||||||
const ctx = { db, rx };
|
|
||||||
await db.tx(async (tx) => {
|
|
||||||
for (const change of changes) {
|
|
||||||
await tx.exec(
|
|
||||||
`INSERT INTO crsql_changes VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,
|
|
||||||
change
|
|
||||||
);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
document.getElementById("root")!.classList.add("dark");
|
document.getElementById("root")!.classList.add("dark");
|
||||||
|
|
||||||
|
@ -93,3 +34,4 @@ createRoot(document.getElementById("root") as HTMLElement).render(
|
||||||
<App ctx={ctx} />
|
<App ctx={ctx} />
|
||||||
</main>
|
</main>
|
||||||
);
|
);
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue