|
1 | 1 | package com.redis.enterprise; |
2 | 2 |
|
3 | 3 | import java.io.IOException; |
4 | | -import java.io.InputStream; |
5 | 4 | import java.security.GeneralSecurityException; |
6 | 5 | import java.util.List; |
7 | 6 | import java.util.logging.Level; |
|
25 | 24 | import org.testcontainers.junit.jupiter.Container; |
26 | 25 | import org.testcontainers.junit.jupiter.Testcontainers; |
27 | 26 |
|
28 | | -import com.redis.enterprise.rest.ModuleInstallResponse; |
29 | 27 | import com.redis.testcontainers.RedisEnterpriseContainer; |
30 | 28 |
|
31 | 29 | import io.lettuce.core.RedisURI; |
@@ -108,23 +106,6 @@ void deleteDatabase() throws ParseException, GeneralSecurityException, IOExcepti |
108 | 106 | Awaitility.await().until(() -> admin.getDatabases().stream().noneMatch(d -> d.getUid() == database.getUid())); |
109 | 107 | } |
110 | 108 |
|
111 | | - @Test |
112 | | - void installModule() throws IOException, ParseException { |
113 | | - String gearsModuleFile = "redisgears.linux-bionic-x64.1.0.6.zip"; |
114 | | - try (InputStream zipInputStream = getClass().getClassLoader().getResourceAsStream(gearsModuleFile)) { |
115 | | - log.log(Level.INFO, "Installing module {0}", gearsModuleFile); |
116 | | - ModuleInstallResponse response = admin.installModule(gearsModuleFile, zipInputStream); |
117 | | - log.log(Level.INFO, "Installed module {0}, action ID: {1}", |
118 | | - new Object[] { gearsModuleFile, response.getActionUid() }); |
119 | | - Assertions.assertTrue( |
120 | | - admin.getModules().stream().anyMatch(m -> m.getName().equals(RedisModule.GEARS.getModuleName()))); |
121 | | - } |
122 | | - admin.createDatabase(Database.name("ModuleInstallDBTest").module(RedisModule.SEARCH).build()); |
123 | | - List<Database> databases = admin.getDatabases(); |
124 | | - Assertions.assertEquals(1, databases.size()); |
125 | | - Assertions.assertEquals(RedisModule.SEARCH.getModuleName(), databases.get(0).getModules().get(0).getName()); |
126 | | - } |
127 | | - |
128 | 109 | @Test |
129 | 110 | void createDatabaseException() throws ParseException, IOException { |
130 | 111 | Assertions.assertThrows(HttpResponseException.class, () -> admin |
|
0 commit comments