Add basic Save and Get operations to the event store

This commit is contained in:
braginini
2022-12-06 16:17:01 +01:00
parent 65afc9a884
commit 1c1e639445
+21 -19
View File
@@ -15,33 +15,35 @@ func TestNewSQLiteStore(t *testing.T) {
} }
accountID := "account_1" accountID := "account_1"
eventTime := time.Now()
_, err = store.Save(Event{ for i := 0; i < 10; i++ {
Timestamp: eventTime, _, err = store.Save(Event{
Operation: "cool operation", Timestamp: time.Now(),
Type: ManagementEvent, Operation: "cool_operation_" + fmt.Sprint(i),
ModifierID: "user_1", Type: ManagementEvent,
TargetID: "peer_1", ModifierID: "user_" + fmt.Sprint(i),
AccountID: accountID, TargetID: "peer_" + fmt.Sprint(i),
}) AccountID: accountID,
})
if err != nil {
t.Fatal(err)
return
}
}
result, err := store.GetSince(accountID, time.Now().Add(-30*time.Second))
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
return return
} }
result, err := store.GetSince(accountID, eventTime.Add(-10*time.Second)) fmt.Println(len(result))
result, err = store.GetLast(accountID, 5)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
return return
} }
fmt.Println(result) fmt.Println(len(result))
result, err = store.GetLast(accountID, 10)
if err != nil {
t.Fatal(err)
return
}
fmt.Println(result)
} }