|
22 | 22 | import eu.cloudnetservice.driver.channel.ChannelMessage; |
23 | 23 | import eu.cloudnetservice.driver.document.DocumentFactory; |
24 | 24 | import eu.cloudnetservice.driver.inject.InjectionLayer; |
25 | | -import eu.cloudnetservice.driver.network.buffer.DataBuf; |
26 | 25 | import eu.cloudnetservice.ext.rest.api.auth.RestUser; |
27 | 26 | import eu.cloudnetservice.ext.rest.api.auth.RestUserManagement; |
28 | 27 | import eu.cloudnetservice.node.database.LocalDatabase; |
|
38 | 37 |
|
39 | 38 | public final class DefaultRestUserManagement implements RestUserManagement { |
40 | 39 |
|
| 40 | + public static final String REST_USER_INVALIDATE = "rest_user_invalidate"; |
| 41 | + public static final String REST_USER_MANAGEMENT_CHANNEL = "rest_user_management_channel"; |
| 42 | + |
41 | 43 | private static final String REST_USER_DB_NAME = "cloudnet_rest_users"; |
42 | 44 | private static final Logger LOGGER = LoggerFactory.getLogger(DefaultRestUserManagement.class); |
43 | 45 |
|
44 | 46 | private final LocalDatabase localDatabase; |
45 | 47 | private final LoadingCache<UUID, RestUser> restUserCache; |
46 | 48 |
|
47 | | - public static final String REST_USER_INVALIDATE = "rest_user_invalidate"; |
48 | | - public static final String REST_USER_MANAGEMENT_CHANNEL = "rest_user_management_channel"; |
49 | | - |
50 | 49 | public DefaultRestUserManagement() { |
51 | 50 | this(InjectionLayer.ext().instance(NodeDatabaseProvider.class)); |
52 | 51 | } |
@@ -170,8 +169,7 @@ private void sendRestUserInvalidationMessage(@NonNull UUID uniqueId) { |
170 | 169 | .targetNodes() |
171 | 170 | .message(REST_USER_INVALIDATE) |
172 | 171 | .channel(REST_USER_MANAGEMENT_CHANNEL) |
173 | | - .buffer(DataBuf.empty().writeUniqueId(uniqueId)) |
174 | | - .build() |
| 172 | + .build(buffer -> buffer.writeUniqueId(uniqueId)) |
175 | 173 | .send(); |
176 | 174 | } |
177 | 175 | } |
0 commit comments