Expose methods required for the stream sync service #147
| @ -2,12 +2,14 @@ package common | |||||||
| 
 | 
 | ||||||
| import ( | import ( | ||||||
| 	"git.defalsify.org/vise.git/db" | 	"git.defalsify.org/vise.git/db" | ||||||
|  | 
 | ||||||
|  | 	"git.grassecon.net/urdt/ussd/internal/storage" | ||||||
| ) | ) | ||||||
| 
 | 
 | ||||||
| func StoreToDb(store *UserDataStore, prefix []byte) db.Db { | func StoreToDb(store *UserDataStore) db.Db { | ||||||
| 	innerStore := store.Db | 	return store.Db | ||||||
| 	if pfx != nil { | } | ||||||
| 		innerStore = NewSubPrefixDb(innerStore, pfx)		 | 
 | ||||||
| 	} | func StoreToPrefixDb(store *UserDataStore, pfx []byte) storage.PrefixDb { | ||||||
| 	return innerStore | 	return storage.NewSubPrefixDb(store.Db, pfx)	 | ||||||
| } | } | ||||||
|  | |||||||
		Loading…
	
		Reference in New Issue
	
	Block a user