From 06ad0e9cdce48fd97fa92288a3c6a194be08d336 Mon Sep 17 00:00:00 2001
From: Jake Taylor <jake@elixxir.io>
Date: Wed, 7 Sep 2022 15:57:19 -0500
Subject: [PATCH] added basic init and implementation outline
---
go.mod | 3 +-
go.sum | 2 +
indexedDb/implementation.go | 63 +++++++++++++++++++++
indexedDb/init.go | 107 ++++++++++++++++++++++++++++++++++++
4 files changed, 174 insertions(+), 1 deletion(-)
create mode 100644 indexedDb/implementation.go
create mode 100644 indexedDb/init.go
diff --git a/go.mod b/go.mod
index 1745ad65..cb208b43 100644
--- a/go.mod
+++ b/go.mod
@@ -3,9 +3,11 @@ module gitlab.com/elixxir/xxdk-wasm
go 1.17
require (
+ github.com/hack-pad/go-indexeddb v0.2.0
github.com/pkg/errors v0.9.1
github.com/spf13/jwalterweatherman v1.1.0
gitlab.com/elixxir/client v1.5.1-0.20220907184817-0409e48f068a
+ gitlab.com/xx_network/primitives v0.0.4-0.20220809193445-9fc0a5209548
)
require (
@@ -41,7 +43,6 @@ require (
gitlab.com/elixxir/primitives v0.0.3-0.20220901220638-1acc75fabdc6 // indirect
gitlab.com/xx_network/comms v0.0.4-0.20220902164216-e3272eb0efac // indirect
gitlab.com/xx_network/crypto v0.0.5-0.20220902182733-69aad094b487 // indirect
- gitlab.com/xx_network/primitives v0.0.4-0.20220809193445-9fc0a5209548 // indirect
gitlab.com/xx_network/ring v0.0.3-0.20220222211904-da613960ad93 // indirect
go.uber.org/atomic v1.10.0 // indirect
go.uber.org/ratelimit v0.2.0 // indirect
diff --git a/go.sum b/go.sum
index 4fe1fb49..02d16899 100644
--- a/go.sum
+++ b/go.sum
@@ -299,6 +299,8 @@ github.com/grpc-ecosystem/go-grpc-middleware v1.2.2/go.mod h1:EaizFBKfUKtMIF5iaD
github.com/grpc-ecosystem/go-grpc-prometheus v1.2.0/go.mod h1:8NvIoxWQoOIhqOTXgfV/d3M/q6VIi02HzZEHgUlZvzk=
github.com/grpc-ecosystem/grpc-gateway v1.9.5/go.mod h1:vNeuVxBJEsws4ogUvrchl83t/GYV9WGTSLVdBhOQFDY=
github.com/grpc-ecosystem/grpc-gateway v1.16.0/go.mod h1:BDjrQk3hbvj6Nolgz8mAMFbcEtjT1g+wF4CSlocrBnw=
+github.com/hack-pad/go-indexeddb v0.2.0 h1:QHDM6gLrtCJvHdHUK8UdibJu4xWQlIDs4+l8L65AUdA=
+github.com/hack-pad/go-indexeddb v0.2.0/go.mod h1:NH8CaojufPNcKYDhy5JkjfyBXE/72oJPeiywlabN/lM=
github.com/hashicorp/consul/api v1.3.0/go.mod h1:MmDNSzIMUjNpY/mQ398R4bk2FnqQLoPndWW5VkKPlCE=
github.com/hashicorp/consul/api v1.12.0/go.mod h1:6pVBMo0ebnYdt2S3H87XhekM/HHrUoTD2XXb/VrZVy0=
github.com/hashicorp/consul/sdk v0.3.0/go.mod h1:VKf9jXwCTEY1QZP2MOLRhb5i/I/ssyNV1vwHyQBF0x8=
diff --git a/indexedDb/implementation.go b/indexedDb/implementation.go
new file mode 100644
index 00000000..512692f7
--- /dev/null
+++ b/indexedDb/implementation.go
@@ -0,0 +1,63 @@
+////////////////////////////////////////////////////////////////////////////////
+// Copyright © 2022 Privategrity Corporation /
+// /
+// All rights reserved. /
+////////////////////////////////////////////////////////////////////////////////
+
+package indexedDb
+
+import (
+ "github.com/hack-pad/go-indexeddb/idb"
+ "time"
+
+ "gitlab.com/elixxir/client/cmix/rounds"
+ cryptoBroadcast "gitlab.com/elixxir/crypto/broadcast"
+ cryptoChannel "gitlab.com/elixxir/crypto/channel"
+ "gitlab.com/xx_network/primitives/id"
+)
+
+// wasmModel implements [channels.EventModel] interface which uses the channels
+// system passed an object which adheres to in order to get events on the channel.
+type wasmModel struct {
+ db *idb.Database
+}
+
+// JoinChannel is called whenever a channel is joined locally.
+func (w *wasmModel) JoinChannel(channel *cryptoBroadcast.Channel) {
+
+}
+
+// LeaveChannel is called whenever a channel is left locally.
+func (w *wasmModel) LeaveChannel(channelID *id.ID) {
+
+}
+
+// ReceiveMessage is called whenever a message is received on a given channel
+// It may be called multiple times on the same message, it is incumbent on
+// the user of the API to filter such called by message ID.
+func (w *wasmModel) ReceiveMessage(channelID *id.ID, messageID cryptoChannel.MessageID,
+ senderUsername string, text string,
+ timestamp time.Time, lease time.Duration, round rounds.Round) {
+}
+
+// ReceiveReply is called whenever a message is received which is a reply
+// on a given channel. It may be called multiple times on the same message,
+// it is incumbent on the user of the API to filter such called by message ID
+// Messages may arrive our of order, so a reply in theory can arrive before
+// the initial message, as a result it may be important to buffer replies.
+func (w *wasmModel) ReceiveReply(ChannelID *id.ID, messageID cryptoChannel.MessageID,
+ replyTo cryptoChannel.MessageID, SenderUsername string,
+ text string, timestamp time.Time, lease time.Duration,
+ round rounds.Round) {
+}
+
+// ReceiveReaction is called whenever a reaction to a message is received
+// on a given channel. It may be called multiple times on the same reaction,
+// it is incumbent on the user of the API to filter such called by message ID
+// Messages may arrive our of order, so a reply in theory can arrive before
+// the initial message, as a result it may be important to buffer reactions.
+func (w *wasmModel) ReceiveReaction(channelID *id.ID, messageID cryptoChannel.MessageID,
+ reactionTo cryptoChannel.MessageID, senderUsername string,
+ reaction string, timestamp time.Time, lease time.Duration,
+ round rounds.Round) {
+}
diff --git a/indexedDb/init.go b/indexedDb/init.go
new file mode 100644
index 00000000..694e073e
--- /dev/null
+++ b/indexedDb/init.go
@@ -0,0 +1,107 @@
+////////////////////////////////////////////////////////////////////////////////
+// Copyright © 2022 Privategrity Corporation /
+// /
+// All rights reserved. /
+////////////////////////////////////////////////////////////////////////////////
+
+//go:build js && wasm
+// +build js,wasm
+
+package indexedDb
+
+import (
+ "context"
+ "github.com/hack-pad/go-indexeddb/idb"
+ "github.com/pkg/errors"
+ jww "github.com/spf13/jwalterweatherman"
+ "syscall/js"
+
+ "gitlab.com/elixxir/client/channels"
+ "gitlab.com/xx_network/primitives/id"
+)
+
+// currentVersion of the IndexDb runtime. Used for migration purposes.
+const currentVersion uint = 1
+
+// NewWasmEventModel returns a [channels.EventModel] backed by a wasmModel
+func NewWasmEventModel(receptionId *id.ID) (channels.EventModel, error) {
+ ctx := context.Background()
+ databaseName := receptionId.String()
+
+ // Attempt to open database object
+ openRequest, _ := idb.Global().Open(ctx, databaseName, currentVersion,
+ func(db *idb.Database, oldVersion, newVersion uint) error {
+ if oldVersion == newVersion {
+ jww.INFO.Printf("IndexDb version is current: v%d",
+ newVersion)
+ return nil
+ }
+
+ jww.INFO.Printf("IndexDb upgrade required: v%d -> v%d",
+ oldVersion, newVersion)
+
+ if oldVersion == 0 && newVersion == 1 {
+ return v1Upgrade(db)
+ }
+
+ return errors.Errorf("Invalid version upgrade path: v%d -> v%d",
+ oldVersion, newVersion)
+ })
+ // Wait for database open to finish
+ db, err := openRequest.Await(ctx)
+
+ return &wasmModel{db: db}, err
+}
+
+// v1Upgrade performs the v0 -> v1 database upgrade.
+// This can never be changed without permanently breaking backwards compatibility.
+func v1Upgrade(db *idb.Database) error {
+ storeOpts := idb.ObjectStoreOptions{
+ KeyPath: js.ValueOf(pkeyName),
+ AutoIncrement: false,
+ }
+ indexOpts := idb.IndexOptions{
+ Unique: false,
+ MultiEntry: false,
+ }
+
+ // Build Message ObjectStore and Indexes
+ messageStore, err := db.CreateObjectStore(messageStoreName, storeOpts)
+ if err != nil {
+ return err
+ }
+ _, err = messageStore.CreateIndex(messageStoreChannelIndex,
+ js.ValueOf(messageStoreChannel), indexOpts)
+ if err != nil {
+ return err
+ }
+ _, err = messageStore.CreateIndex(messageStoreParentIndex,
+ js.ValueOf(messageStoreParent), indexOpts)
+ if err != nil {
+ return err
+ }
+ _, err = messageStore.CreateIndex(messageStoreTimestampIndex,
+ js.ValueOf(messageStoreTimestamp), indexOpts)
+ if err != nil {
+ return err
+ }
+ _, err = messageStore.CreateIndex(messageStorePinnedIndex,
+ js.ValueOf(messageStorePinned), indexOpts)
+ if err != nil {
+ return err
+ }
+
+ // Build User ObjectStore
+ _, err = db.CreateObjectStore(userStoreName, storeOpts)
+ if err != nil {
+ return err
+ }
+
+ // Build Channel ObjectStore
+ _, err = db.CreateObjectStore(channelsStoreName, storeOpts)
+ if err != nil {
+ return err
+ }
+
+ return nil
+}
--
GitLab