PublicArchive/SpacetimeDB
2
0
Fork 0
mirror of https://github.com/clockworklabs/SpacetimeDB.git synced 2026-05-21 23:22:17 -04:00
Code Issues Packages Projects Releases Wiki Activity

Push

Browse Source
This commit is contained in:
Puru Vijay
2024-09-30 12:45:02 +05:30
parent 4ff51b500d
commit cb43f41fc7
7 changed files with 164 additions and 109 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sdks/typescript/examples/quickstart/src/module_bindings/index.ts
+31 -9
View File
@@ -6,26 +6,47 @@ import {
STDBEvent,
type CallbackInit,
} from '@clockworklabs/spacetimedb-sdk';
import { MessageTable } from './message.ts';
import { User } from './user.ts';
import { MessageTableHandle } from './message.ts';
import { SendMessageReducer } from './send_message_reducer.ts';
import { SetNameReducer } from './set_name_reducer.ts';
import { UserTableHandle } from './user.ts';
// AUTOGENERATED
class EventContext extends DbContext<RemoteTables, RemoteReducers> {
event: STDBEvent<ReducerEvent>;
event: STDBEvent<ReducerEvent<ReducerEnum>>;
constructor(
client: DBConnectionBase,
db: RemoteTables,
reducers: RemoteReducers,
event: STDBEvent<ReducerEvent>
event: STDBEvent<ReducerEvent<ReducerEnum>>
) {
super(client, db, reducers);
this.event = event;
}
}
// AUTOGENERATED
type ReducerEnum =
| {
tag: 'SendMessage';
value: SendMessageReducer<
EventContext,
RemoteTables,
RemoteReducers,
ReducerEnum
>;
}
| {
tag: 'SetName';
value: SetNameReducer<
EventContext,
RemoteTables,
RemoteReducers,
ReducerEnum
>;
};
class RemoteTables {
#client: DBConnectionBase;
@@ -34,11 +55,11 @@ class RemoteTables {
}
get user() {
return User;
return new UserTableHandle(this.#client);
}
get message() {
return new MessageTable(this.#client);
return new MessageTableHandle(this.#client);
}
}
@@ -47,7 +68,8 @@ class RemoteReducers {
#sendMessageReducer: SendMessageReducer<
EventContext,
RemoteTables,
RemoteReducers
RemoteReducers,
any
>;
constructor(client: DBConnectionBase) {
@@ -86,7 +108,7 @@ export class DbConnection {
static builder() {
const base = new DBConnectionBase();
const tables = new RemoteTables();
const tables = new RemoteTables(base);
const reducers = new RemoteReducers(base);
const builder = new DBConnectionBuilder(base, tables, reducers);
sdks/typescript/examples/quickstart/src/module_bindings/message.ts
+8 -8
View File
@@ -16,7 +16,7 @@ type Message = {
text: string;
};
export class MessageTable<
export class MessageTableHandle<
DbView,
ReducerView,
ReducerEnum,
@@ -31,14 +31,14 @@ export class MessageTable<
constructor(
client: DBConnectionBase<ReducerEnum, EventContext>,
sender: Identity,
sent: bigint,
text: string
sender?: Identity,
sent?: bigint,
text?: string
) {
this.#client = client;
this.sender = sender;
this.sent = sent;
this.text = text;
this.sender = sender!;
this.sent = sent!;
this.text = text!;
}
public static serialize(value: Message): object {
@@ -69,7 +69,7 @@ export class MessageTable<
>(
client: DBConnectionBase<ReducerEnum, EventContext>,
value: AlgebraicValue
): MessageTable<DbView, ReducerView, ReducerEnum, EventContext> {
): MessageTableHandle<DbView, ReducerView, ReducerEnum, EventContext> {
let productValue = value.asProductValue();
let __sender = productValue.elements[0].asIdentity();
let __sent = productValue.elements[1].asBigInt();
sdks/typescript/examples/quickstart/src/module_bindings/set_name_reducer.ts
+8 -2
View File
@@ -8,11 +8,17 @@ import {
ReducerArgsAdapter,
} from '@clockworklabs/spacetimedb-sdk';
export class SetNameReducer<EventContext, DBView, ReducerView> extends Reducer<
export class SetNameReducer<
EventContext,
DBView,
ReducerView,
ReducerEnum,
> extends Reducer<
[name: string],
DBView,
ReducerView,
EventContext
EventContext,
ReducerEnum
> {
constructor(client: DBConnectionBase) {
super(client, 'SetName');
sdks/typescript/examples/quickstart/src/module_bindings/user.ts
+100 -64
View File
@@ -2,81 +2,117 @@
// WILL NOT BE SAVED. MODIFY TABLES IN RUST INSTEAD.
// @ts-ignore
import { __SPACETIMEDB__, AlgebraicType, ProductType, ProductTypeElement, SumType, SumTypeVariant, DatabaseTable, AlgebraicValue, ReducerEvent, Identity, Address, ClientDB, SpacetimeDBClient } from "@clockworklabs/spacetimedb-sdk";
import {
AlgebraicType,
AlgebraicValue,
DBConnectionBase,
DbContext,
Identity,
ProductTypeElement,
SumTypeVariant,
} from '@clockworklabs/spacetimedb-sdk';
export class User extends DatabaseTable
{
public static db: ClientDB = __SPACETIMEDB__.clientDB;
public static tableName = "User";
public identity: Identity;
public name: string | null;
public online: boolean;
export type User = {
identity: Identity;
name: string | null;
online: boolean;
};
public static primaryKey: string | undefined = "identity";
export class UserTableHandle<
DbView,
ReducerView,
ReducerEnum,
EventContext extends DbContext<DbView, ReducerView>,
> {
#client: DBConnectionBase<ReducerEnum, EventContext>;
tableName = 'User';
constructor(identity: Identity, name: string | null, online: boolean) {
super();
this.identity = identity;
this.name = name;
this.online = online;
}
identity: Identity;
name: string | null;
online: boolean;
public static serialize(value: User): object {
return [
Array.from(value.identity.toUint8Array()), value.name ? { "some": value.name } : { "none": [] }, value.online
];
}
primaryKey?: string = 'identity';
public static getAlgebraicType(): AlgebraicType
{
return AlgebraicType.createProductType([
new ProductTypeElement("identity", AlgebraicType.createProductType([
new ProductTypeElement("__identity_bytes", AlgebraicType.createArrayType(AlgebraicType.createU8Type())),
])),
new ProductTypeElement("name", AlgebraicType.createSumType([
new SumTypeVariant("some", AlgebraicType.createStringType()),
new SumTypeVariant("none", AlgebraicType.createProductType([
])),
])),
new ProductTypeElement("online", AlgebraicType.createBoolType()),
]);
}
constructor(
client: DBConnectionBase,
identity?: Identity,
name?: string | null,
online?: boolean
) {
this.#client = client;
this.identity = identity!;
this.name = name!;
this.online = online!;
}
public static fromValue(value: AlgebraicValue): User
{
let productValue = value.asProductValue();
let __identity = productValue.elements[0].asIdentity();
let __name = productValue.elements[1].asSumValue().tag == 1 ? null : productValue.elements[1].asSumValue().value.asString();
let __online = productValue.elements[2].asBoolean();
return new this(__identity, __name, __online);
}
static serialize(value: User): object {
return [
Array.from(value.identity.toUint8Array()),
value.name ? { some: value.name } : { none: [] },
value.online,
];
}
public static *filterByIdentity(value: Identity): IterableIterator<User>
{
for (let instance of this.db.getTable("User").getInstances())
{
if (instance.identity.isEqual(value)) {
yield instance;
}
}
}
static getAlgebraicType(): AlgebraicType {
return AlgebraicType.createProductType([
new ProductTypeElement(
'identity',
AlgebraicType.createProductType([
new ProductTypeElement(
'__identity_bytes',
AlgebraicType.createArrayType(AlgebraicType.createU8Type())
),
])
),
new ProductTypeElement(
'name',
AlgebraicType.createSumType([
new SumTypeVariant('some', AlgebraicType.createStringType()),
new SumTypeVariant('none', AlgebraicType.createProductType([])),
])
),
new ProductTypeElement('online', AlgebraicType.createBoolType()),
]);
}
public static findByIdentity(value: Identity): User | undefined
{
return this.filterByIdentity(value).next().value;
}
static fromValue<
DbView,
ReducerView,
ReducerEnum,
EventContext extends DbContext<DbView, ReducerView>,
>(
client: DBConnectionBase<ReducerEnum, EventContext>,
value: AlgebraicValue
): UserTableHandle<DbView, ReducerView, ReducerEnum, EventContext> {
let productValue = value.asProductValue();
let __identity = productValue.elements[0].asIdentity();
let __name =
productValue.elements[1].asSumValue().tag == 1
? null
: productValue.elements[1].asSumValue().value.asString();
let __online = productValue.elements[2].asBoolean();
return new this(client, __identity, __name, __online);
}
public static *filterByOnline(value: boolean): IterableIterator<User>
{
for (let instance of this.db.getTable("User").getInstances())
{
if (instance.online === value) {
yield instance;
}
}
}
*filterByIdentity(value: Identity): IterableIterator<User> {
for (let instance of this.#client.db.getTable('User').getInstances()) {
if (instance.identity.isEqual(value)) {
yield instance;
}
}
}
findByIdentity(value: Identity): User | undefined {
return this.filterByIdentity(value).next().value;
}
*filterByOnline(value: boolean): IterableIterator<User> {
for (let instance of this.#client.db.getTable('User').getInstances()) {
if (instance.online === value) {
yield instance;
}
}
}
}
export default User;
sdks/typescript/packages/sdk/src/reducer_event.ts
+1 -1
View File
@@ -2,7 +2,7 @@ import { Address } from './address.ts';
import type { Timestamp, UpdateStatus } from './client_api.ts';
import { Identity } from './identity.ts';
export class ReducerEvent<ReducerEnum extends any = any> {
export class ReducerEvent<ReducerEnum = any> {
/**
* The time when the reducer started running.
*
sdks/typescript/packages/sdk/src/spacetimedb.ts
-6
View File
@@ -335,12 +335,6 @@ export class DBConnectionBuilder<
}
}
// class DBConnection extends DbConnectionBase {}
// const ctxz = new DbConnection()
// ctxz.
export class DBConnectionBase<
ReducerEnum = {},
EventContext extends DbContext<any, any> = any,
sdks/typescript/packages/sdk/src/table.ts
+16 -19
View File
@@ -3,20 +3,13 @@ import BinaryReader from './binary_reader.ts';
import { EventEmitter } from './event_emitter.ts';
import OperationsMap from './operations_map.ts';
import { ReducerEvent } from './reducer_event.ts';
import { AlgebraicValue, DbContext, type CallbackInit } from './spacetimedb.ts';
import { AlgebraicValue, type CallbackInit } from './spacetimedb.ts';
class DBOp {
type DBOp = {
type: 'insert' | 'delete';
instance: any;
rowPk: string;
constructor(type: 'insert' | 'delete', rowPk: string, instance: any) {
this.type = type;
this.rowPk = rowPk;
this.instance = instance;
}
}
row: any;
};
export class TableOperation {
/**
* The type of CRUD operation.
@@ -94,9 +87,13 @@ export class Table {
this.#entityClass.getAlgebraicType(),
adapter
);
const instance = this.#entityClass.fromValue(entry);
const row = this.#entityClass.fromValue(entry);
dbOps.push(new DBOp(operation.type, pk, instance));
dbOps.push({
type: operation.type,
rowPk: pk,
row: row,
});
}
if (this.#entityClass.primaryKey !== undefined) {
@@ -107,7 +104,7 @@ export class Table {
if (dbOp.type === 'insert') {
inserts.push(dbOp);
} else {
deleteMap.set(dbOp.instance[pkName], dbOp);
deleteMap.set(dbOp.row[pkName], dbOp);
}
}
for (const dbOp of inserts) {
@@ -140,21 +137,21 @@ export class Table {
oldDbOp: DBOp,
reducerEvent: ReducerEvent | undefined
): void => {
const newInstance = newDbOp.instance;
const oldInstance = oldDbOp.instance;
const newInstance = newDbOp.row;
const oldInstance = oldDbOp.row;
this.rows.delete(oldDbOp.rowPk);
this.rows.set(newDbOp.rowPk, newInstance);
this.emitter.emit('update', oldInstance, newInstance, reducerEvent);
};
insert = (dbOp: DBOp, reducerEvent: ReducerEvent | undefined): void => {
this.rows.set(dbOp.rowPk, dbOp.instance);
this.emitter.emit('insert', dbOp.instance, reducerEvent);
this.rows.set(dbOp.rowPk, dbOp.row);
this.emitter.emit('insert', dbOp.row, reducerEvent);
};
delete = (dbOp: DBOp, reducerEvent: ReducerEvent | undefined): void => {
this.rows.delete(dbOp.rowPk);
this.emitter.emit('delete', dbOp.instance, reducerEvent);
this.emitter.emit('delete', dbOp.row, reducerEvent);
};
/**