logdb #56
							
								
								
									
										27
									
								
								store/log_db.go
									
									
									
									
									
										Normal file
									
								
							
							
						
						
									
										27
									
								
								store/log_db.go
									
									
									
									
									
										Normal file
									
								
							| @ -0,0 +1,27 @@ | |||||||
|  | package store | ||||||
|  | 
 | ||||||
|  | import ( | ||||||
|  | 	"context" | ||||||
|  | 
 | ||||||
|  | 	visedb "git.defalsify.org/vise.git/db" | ||||||
|  | 	"git.grassecon.net/grassrootseconomics/sarafu-vise/store/db" | ||||||
|  | 	storedb "git.grassecon.net/grassrootseconomics/sarafu-vise/store/db" | ||||||
|  | ) | ||||||
|  | 
 | ||||||
|  | type LogDb struct { | ||||||
|  | 	visedb.Db | ||||||
|  | } | ||||||
|  | 
 | ||||||
|  | func (db *LogDb) WriteLogEntry(ctx context.Context, sessionId string, typ db.DataTyp, v []byte) error { | ||||||
|  | 	db.SetPrefix(visedb.DATATYPE_USERDATA) | ||||||
|  | 	db.SetSession(sessionId) | ||||||
|  | 	k := storedb.ToBytes(typ) | ||||||
|  | 	return db.Put(ctx, k, v) | ||||||
|  | } | ||||||
|  | 
 | ||||||
|  | func (db *LogDb) ReadLogEntry(ctx context.Context, sessionId string, typ db.DataTyp) ([]byte, error) { | ||||||
|  | 	db.SetPrefix(visedb.DATATYPE_USERDATA) | ||||||
|  | 	db.SetSession(sessionId) | ||||||
|  | 	k := storedb.ToBytes(typ) | ||||||
|  | 	return db.Get(ctx, k) | ||||||
|  | } | ||||||
		Loading…
	
		Reference in New Issue
	
	Block a user