Remove firestore and memory cache

cmd/gen.go

@@ -72,12 +72,11 @@ var genCmd = &cobra.Command{
 			panic("invalid storage type: " + config.Storage)
 		}
 
-		memoryStorage := storage.NewMemoryWithOtherStorage(store)
-		iroha := lib.NewIroha(words, memoryStorage, config.DepthOptions)
+		iroha := lib.NewIroha(words, store, config.DepthOptions)
 
 		if config.ResetProgress {
 			log.Println("progress is reset")
-			if err := memoryStorage.ResetProgress(ctx); err != nil {
+			if err := store.ResetProgress(ctx); err != nil {
 				panic(err)
 			}
 		}

lib/iroha.go

@@ -132,7 +132,7 @@ func (i *Iroha) searchByBits(usedIndices []int, katakanaBitsAndWords []*ktkn.Kat
 	goroutineMode := depth >= i.depths.MinParallel && depth <= i.depths.MaxParallel
 	if goroutineMode {
 		eg := errgroup.Group{}
-		wordListChan := make(chan []*ktkn.Word, 100)
+		wordListChan := make(chan []*ktkn.Word, 1000000)
 		for index, word := range katakanaAndWordBits.Words {
 			gWord := word
 			newIndices := generateNewUsedIndices(usedIndices, index)

storage/firestore.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"fmt"
 	"reflect"
-	"time"
 
 	cstorage "cloud.google.com/go/storage"
 
@@ -100,7 +99,7 @@ func (f *FireStore) removeProgressByState(ctx context.Context, progress int) err
 }
 
 func (f *FireStore) Start(ctx context.Context, indices []int) error {
-	return f.updateProgress(ctx, indices, progressProcessing)
+	return nil
 }
 
 func (f *FireStore) ResetProgress(ctx context.Context) error {
@@ -125,31 +124,9 @@ func (f *FireStore) Set(ctx context.Context, indices []int, wordsList [][]*ktkn.
 	if err := f.cstorageClient.SaveWordsList(ctx, indices, wordsList); err != nil {
 		return errors.Wrap(err, "failed to set wordsList to cloud storage")
 	}
-	if err := f.updateProgress(ctx, indices, progressDone); err != nil {
-		return errors.Wrap(err, "failed to update progress to done")
-	}
-
 	return nil
 }
 
 func (f *FireStore) Get(ctx context.Context, indices []int) ([][]*ktkn.Word, bool, error) {
-L:
-	for {
-		// FIXME: watch document
-		progress, err := f.getProgress(ctx, indices)
-		if err != nil {
-			return nil, false, err
-		}
-
-		switch progress {
-		case progressNotStarted:
-			return nil, false, nil
-		case progressDone:
-			break L
-		case progressProcessing:
-			time.Sleep(500 * time.Millisecond)
-		}
-	}
-
 	return f.cstorageClient.Get(ctx, indices)
 }