forked from cwtch.im/cwtch
74 lines
1.9 KiB
Go
74 lines
1.9 KiB
Go
// Known race issue with event bus channel closure
|
|
|
|
package storage
|
|
|
|
import (
|
|
"cwtch.im/cwtch/event"
|
|
"cwtch.im/cwtch/storage/v0"
|
|
"fmt"
|
|
"git.openprivacy.ca/openprivacy/log"
|
|
"os"
|
|
"testing"
|
|
"time"
|
|
)
|
|
|
|
const testingDir = "./testing"
|
|
const filenameBase = "testStream"
|
|
const password = "asdfqwer"
|
|
const line1 = "Hello from storage!"
|
|
const testProfileName = "Alice"
|
|
const testKey = "key"
|
|
const testVal = "value"
|
|
const testInitialMessage = "howdy"
|
|
const testMessage = "Hello from storage"
|
|
|
|
func TestProfileStoreUpgradeV0toV1(t *testing.T) {
|
|
log.SetLevel(log.LevelDebug)
|
|
os.RemoveAll(testingDir)
|
|
eventBus := event.NewEventManager()
|
|
|
|
queue := event.NewQueue()
|
|
eventBus.Subscribe(event.ChangePasswordSuccess, queue)
|
|
|
|
fmt.Println("Creating and initializing v0 profile and store...")
|
|
profile := NewProfile(testProfileName)
|
|
ps1 := v0.NewProfileWriterStore(eventBus, testingDir, password, profile)
|
|
|
|
groupid, invite, err := profile.StartGroup("2c3kmoobnyghj2zw6pwv7d57yzld753auo3ugauezzpvfak3ahc4bdyd")
|
|
if err != nil {
|
|
t.Errorf("Creating group: %v\n", err)
|
|
}
|
|
if err != nil {
|
|
t.Errorf("Creating group invite: %v\n", err)
|
|
}
|
|
|
|
ps1.AddGroup(invite, profile.Onion)
|
|
|
|
fmt.Println("Sending 200 messages...")
|
|
|
|
for i := 0; i < 200; i++ {
|
|
ps1.AddGroupMessage(groupid, time.Now().Format(time.RFC3339Nano), time.Now().Format(time.RFC3339Nano), profile.Onion, testMessage)
|
|
}
|
|
|
|
fmt.Println("Shutdown v0 profile store...")
|
|
ps1.Shutdown()
|
|
|
|
fmt.Println("New v1 Profile store...")
|
|
ps2, err := LoadProfileWriterStore(eventBus, testingDir, password)
|
|
if err != nil {
|
|
t.Errorf("Error createing new profileStore with new password: %v\n", err)
|
|
return
|
|
}
|
|
|
|
profile2 := ps2.GetProfileCopy(true)
|
|
|
|
if profile2.Groups[groupid] == nil {
|
|
t.Errorf("Failed to load group %v\n", groupid)
|
|
return
|
|
}
|
|
|
|
if len(profile2.Groups[groupid].Timeline.Messages) != 200 {
|
|
t.Errorf("Failed to load group's 200 messages, instead got %v\n", len(profile2.Groups[groupid].Timeline.Messages))
|
|
}
|
|
}
|