diff --git a/api/mojang/queue/in_memory_textures_storage.go b/api/mojang/queue/in_memory_textures_storage.go index 31c9294..cb7d8a3 100644 --- a/api/mojang/queue/in_memory_textures_storage.go +++ b/api/mojang/queue/in_memory_textures_storage.go @@ -28,7 +28,6 @@ func CreateInMemoryTexturesStorage() *inMemoryTexturesStorage { storage := &inMemoryTexturesStorage{ data: make(map[string]*inMemoryItem), } - storage.Start() return storage } diff --git a/api/mojang/queue/in_memory_textures_storage_test.go b/api/mojang/queue/in_memory_textures_storage_test.go index 019da74..1e90812 100644 --- a/api/mojang/queue/in_memory_textures_storage_test.go +++ b/api/mojang/queue/in_memory_textures_storage_test.go @@ -178,6 +178,8 @@ func TestInMemoryTexturesStorage_GarbageCollection(t *testing.T) { storage.StoreTextures("dead24f9a4fa4877b7b04c8c6c72bb46", textures1) storage.StoreTextures("b5d58475007d4f9e9ddd1403e2497579", textures2) + storage.Start() + time.Sleep(inMemoryStorageGCPeriod + time.Millisecond) // Let it start first iteration _, textures1Err := storage.GetTextures("dead24f9a4fa4877b7b04c8c6c72bb46") diff --git a/cmd/serve.go b/cmd/serve.go index bc72be8..c0c7bf9 100644 --- a/cmd/serve.go +++ b/cmd/serve.go @@ -51,11 +51,13 @@ var serveCmd = &cobra.Command{ return } + texturesStorage := queue.CreateInMemoryTexturesStorage() + texturesStorage.Start() mojangTexturesQueue := &queue.JobsQueue{ Logger: logger, Storage: &queue.SplittedStorage{ UuidsStorage: mojangUuidsRepository, - TexturesStorage: queue.CreateInMemoryTexturesStorage(), + TexturesStorage: texturesStorage, }, } logger.Info("Mojang's textures queue is successfully initialized")