kalipso/pentapass
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

passd add init logs for user

Browse Source
This commit is contained in:
kalipso
2024-10-10 10:47:49 +02:00
parent ca6a51bf36
commit e6d05290fc
2 changed files with 16 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
cmd/ppassd/ppassd.go
View File

@@ -26,30 +26,34 @@ func main() {
ctx := context.Background() ctx := context.Background()
data := *dbPath data := *dbPath
Logger.Info("Initializing passd")
Logger.Info("Looking for Keys...")
key, err := age.LoadOrGenerateKeys(*dbPath + "/age.key") key, err := age.LoadOrGenerateKeys(*dbPath + "/age.key")
if err != nil { if err != nil {
Logger.Panic(err) Logger.Panic(err)
} }
Logger.Debugf("AgeKey: %s\n", key.String()) Logger.Infof("Found Key: %s", key.Recipient().String())
Logger.Debugf("AgePublicKey: %s\n", key.Recipient().String()) Logger.Info("Setting up DHT...")
h, dht, err := storage.SetupLibp2pHost(ctx, *dbPath) h, dht, err := storage.SetupLibp2pHost(ctx, *dbPath)
Logger.Debug(h.ID().String())
if err != nil { if err != nil {
Logger.Panic(err) Logger.Panic(err)
} }
Logger.Infof("Own ID: %s", h.ID().String())
ps, err := pubsub.NewGossipSub(ctx, h) ps, err := pubsub.NewGossipSub(ctx, h)
if err != nil { if err != nil {
Logger.Panic(err) Logger.Panic(err)
} }
Logger.Info("Starting peer discovery...")
go storage.DiscoverPeers(ctx, h, dht) go storage.DiscoverPeers(ctx, h, dht)
Logger.Info("Initializing datastore...")
store, err := badger.NewDatastore(data, &badger.DefaultOptions) store, err := badger.NewDatastore(data, &badger.DefaultOptions)
if err != nil { if err != nil {
Logger.Fatal(err) Logger.Fatal(err)
@@ -70,20 +74,25 @@ func main() {
Key: key, Key: key,
} }
Cfg, err := storageHandler.NewConfig(*dbPath + "/config.json") configPath := *dbPath + "/config.json"
Logger.Infof("Loading config from: %s", configPath)
Cfg, err := storageHandler.NewConfig(configPath)
if err != nil { if err != nil {
Logger.Fatal(err) Logger.Fatal(err)
} }
storageHandler.Config = Cfg storageHandler.Config = Cfg
storageHandler.ConfigPath = *dbPath + "/config.json" storageHandler.ConfigPath = configPath
Logger.Infof("Setting up Namespaces...")
storageHandler.InitNamespaces() storageHandler.InitNamespaces()
for _, val := range storageHandler.Namespaces { for _, val := range storageHandler.Namespaces {
defer val.Close() defer val.Close()
} }
Logger.Infof("Initialization complete!")
rpc.StorageHandler = &storageHandler rpc.StorageHandler = &storageHandler
rpc.Serve(*dbPath) rpc.Serve(*dbPath)
} }

2
internal/storage/storage.go
View File

@@ -541,7 +541,7 @@ func (s *StorageHandler) AddNamespace(Name string) (*Namespace, error) {
} }
func CreateNamespace(ID string, storageHandler *StorageHandler) (*Namespace, error) { func CreateNamespace(ID string, storageHandler *StorageHandler) (*Namespace, error) {
Logger.Debugf("Creating Namespace %s\n", ID) Logger.Infof("Creating Namespace %s\n", ID)
err := storageHandler.PubSub.RegisterTopicValidator( err := storageHandler.PubSub.RegisterTopicValidator(
ID, //== topicName ID, //== topicName
func(ctx context.Context, id peer.ID, msg *pubsub.Message) bool { func(ctx context.Context, id peer.ID, msg *pubsub.Message) bool {