Fix daemon initialization after deleting keys (#212)

core/space/services/services_keypair.go

@@ -77,12 +77,12 @@ func (s *Space) DeleteKeypair(ctx context.Context) error {
 		return err
 	}
 
-	if err := s.keychain.DeleteKeypair(); err != nil {
+	// Tell the textile client to stop operations
+	if err := s.tc.RemoveKeys(ctx); err != nil {
 		return err
 	}
 
-	// Tell the textile client to stop operations
-	if err := s.tc.RemoveKeys(); err != nil {
+	if err := s.keychain.DeleteKeypair(); err != nil {
 		return err
 	}
 

core/textile/client.go

@@ -18,6 +18,7 @@ import (
 	"github.com/FleekHQ/space-daemon/core/textile/model"
 	"github.com/FleekHQ/space-daemon/core/textile/notifier"
 	synchronizer "github.com/FleekHQ/space-daemon/core/textile/sync"
+	"github.com/FleekHQ/space-daemon/core/textile/utils"
 	"github.com/FleekHQ/space-daemon/core/util/address"
 	"github.com/FleekHQ/space-daemon/log"
 	threadsClient "github.com/textileio/go-threads/api/client"
@@ -471,7 +472,7 @@ func (tc *textileClient) healthcheck(ctx context.Context) {
 	}
 }
 
-func (tc *textileClient) RemoveKeys() error {
+func (tc *textileClient) RemoveKeys(ctx context.Context) error {
 	if err := tc.hubAuth.ClearCache(); err != nil {
 		return err
 	}
@@ -484,6 +485,16 @@ func (tc *textileClient) RemoveKeys() error {
 	tc.isConnectedToHub = false
 	tc.keypairDeleted <- true
 
+	metathreadID, err := utils.NewDeterministicThreadID(tc.kc, utils.MetathreadThreadVariant)
+	if err != nil {
+		return err
+	}
+
+	err = tc.threads.DeleteDB(ctx, metathreadID)
+	if err != nil {
+		return err
+	}
+
 	return nil
 }
 

core/textile/model/model.go

@@ -112,7 +112,9 @@ func (m *model) findOrCreateMetaThreadID(ctx context.Context) (*thread.ID, error
 		return nil, err
 	}
 
-	if err := m.threads.NewDB(ctx, dbID, db.WithNewManagedThreadKey(managedKey)); err != nil {
+	err = m.threads.NewDB(ctx, dbID, db.WithNewManagedThreadKey(managedKey))
+	st := err.Error()
+	if err != nil && st != "rpc error: code = Unknown desc = db already exists" {
 		return nil, err
 	}
 

core/textile/textile.go

@@ -57,7 +57,7 @@ type Client interface {
 	ShareFilesViaPublicKey(ctx context.Context, paths []domain.FullPath, pubkeys []crypto.PubKey, keys [][]byte) error
 	AcceptSharedFilesInvitation(ctx context.Context, invitation domain.Invitation) (domain.Invitation, error)
 	RejectSharedFilesInvitation(ctx context.Context, invitation domain.Invitation) (domain.Invitation, error)
-	RemoveKeys() error
+	RemoveKeys(ctx context.Context) error
 	AttachMailboxNotifier(notif GrpcMailboxNotifier)
 	AttachSynchronizerNotifier(notif sync.EventNotifier)
 	GetReceivedFiles(ctx context.Context, accepted bool, seek string, limit int) ([]*domain.SharedDirEntry, string, error)