-
-
Notifications
You must be signed in to change notification settings - Fork 642
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
0a83788
commit 97aabf0
Showing
31 changed files
with
43,536 additions
and
120 deletions.
There are no files selected for viewing
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -0,0 +1,116 @@ | ||
// Type definitions for dexie-observable v4.0.1-beta.13 | ||
// Project: https://github.com/dexie/Dexie.js/tree/master/addons/Dexie.Observable | ||
// Definitions by: David Fahlander <http://github.com/dfahlander> | ||
|
||
import Dexie, { DexieEventSet } from 'dexie'; | ||
import { IDatabaseChange } from '../api'; | ||
|
||
export interface SyncNodeConstructor { | ||
new() : SyncNode; | ||
} | ||
|
||
// | ||
// Interfaces of Dexie.Observable | ||
// | ||
|
||
|
||
/** | ||
* A SyncNode represents a local database instance that subscribes | ||
* to changes made on the database. | ||
* SyncNodes are stored in the _syncNodes table. | ||
* | ||
* Dexie.Syncable extends this interface and allows 'remote' nodes to be stored | ||
* as well. | ||
*/ | ||
export interface SyncNode { | ||
id?: number, | ||
myRevision: number, | ||
type: 'local' | 'remote', | ||
lastHeartBeat: number, | ||
deleteTimeStamp: number, // In case lastHeartBeat is too old, a value of now + HIBERNATE_GRACE_PERIOD will be set here. If reached before node wakes up, node will be deleted. | ||
isMaster: number // 1 if true. Not using Boolean because it's not possible to index Booleans. | ||
} | ||
|
||
export interface ObservableEventSet extends DexieEventSet { | ||
(eventName: 'latestRevisionIncremented', subscriber: (dbName: string, latestRevision: number) => void): void; | ||
(eventName: 'suicideNurseCall', subscriber: (dbName: string, nodeID: number) => void): void; | ||
(eventName: 'intercomm', subscriber: (dbName: string) => void): void; | ||
(eventName: 'beforeunload', subscriber: () => void): void; | ||
} | ||
|
||
// Object received by on('message') after sendMessage() or broadcastMessage() | ||
interface MessageEvent { | ||
id: number; | ||
type: string; | ||
message: any; | ||
destinationNode: number; | ||
wantReply?: boolean; | ||
resolve(result: any): void; | ||
reject(error: any): void; | ||
} | ||
|
||
// | ||
// Extend Dexie interface | ||
// | ||
declare module 'dexie' { | ||
// Extend methods on db (db.sendMessage(), ...) | ||
interface Dexie { | ||
// Placeholder where to access the SyncNode class constructor. | ||
// (makes it valid to do new db.observable.SyncNode()) | ||
observable: { | ||
version: string; | ||
SyncNode: SyncNodeConstructor; | ||
sendMessage( | ||
type: string, // Don't use 'response' as it is used internally by the framework | ||
message: any, // anything that can be saved by IndexedDB | ||
destinationNode: number, | ||
options: { | ||
wantReply?: boolean; | ||
} | ||
): Promise<any> | void; // When wantReply is undefined or false return is void | ||
|
||
broadcastMessage( | ||
type: string, | ||
message: any, // anything that can be saved by IndexedDB | ||
bIncludeSelf: boolean | ||
): void; | ||
} | ||
|
||
readonly _localSyncNode: SyncNode; | ||
|
||
_changes: Dexie.Table<IDatabaseChange & {rev: number}, number>; | ||
_syncNodes: Dexie.Table<SyncNode, number>; | ||
_intercomm: Dexie.Table<any, number>; | ||
} | ||
|
||
// Extended events db.on('changes', subscriber), ... | ||
interface DbEvents { | ||
(eventName: 'changes', subscriber: (changes: IDatabaseChange[], partial: boolean)=>void): void; | ||
(eventName: 'cleanup', subscriber: ()=>any): void; | ||
(eventName: 'message', subscriber: (msg: MessageEvent)=>any): void; | ||
} | ||
|
||
// Extended IndexSpec with uuid boolean for primary key. | ||
interface IndexSpec { | ||
uuid: boolean; | ||
} | ||
|
||
interface DexieConstructor { | ||
Observable: { | ||
(db: Dexie) : void; | ||
|
||
version: string; | ||
createUUID: () => string; | ||
on: ObservableEventSet; | ||
localStorageImpl: { | ||
setItem(key: string, value: string): void, | ||
getItem(key: string): string, | ||
removeItem(key: string): void; | ||
}; | ||
_onStorage: (event: StorageEvent) => void; | ||
} | ||
|
||
} | ||
} | ||
|
||
export default Dexie.Observable; |
Oops, something went wrong.