|
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