add handlers to ConnectionViewModel
This commit is contained in:
@@ -20,6 +20,9 @@ export default class ConnectionModel {
|
||||
return this.udn.ws?.url;
|
||||
}
|
||||
|
||||
connectionChangeHandler: () => void = () => {};
|
||||
messageHandler: (data: Message) => void = () => {};
|
||||
|
||||
// connection
|
||||
connect = (address: string): void => {
|
||||
this.udn.connect(address);
|
||||
@@ -29,15 +32,21 @@ export default class ConnectionModel {
|
||||
this.udn.disconnect();
|
||||
};
|
||||
|
||||
handleMessage = (data: Message): void => {}
|
||||
handleMessage = (data: Message): void => {
|
||||
this.messageHandler(data);
|
||||
};
|
||||
|
||||
handleConnectionChange = (): void => {
|
||||
console.log("connection status:", this.isConnected, this.address);
|
||||
this.connectionChangeHandler();
|
||||
|
||||
if (this.isConnected == false) return;
|
||||
|
||||
if (this.address) {
|
||||
this.storeAddress(this.address);
|
||||
}
|
||||
|
||||
this.sendMessagesInOutbox();
|
||||
};
|
||||
|
||||
// outbox
|
||||
@@ -54,7 +63,7 @@ export default class ConnectionModel {
|
||||
if (message == undefined) continue;
|
||||
if (checkIsValidObject(message) == false) continue;
|
||||
|
||||
message.push(message);
|
||||
messages.push(message);
|
||||
}
|
||||
|
||||
return messages;
|
||||
@@ -115,6 +124,15 @@ export default class ConnectionModel {
|
||||
return this.storageModel.list(dirPath);
|
||||
}
|
||||
|
||||
// handlers
|
||||
setConnectionChangeHandler = (handler: () => void): void => {
|
||||
this.connectionChangeHandler = handler;
|
||||
};
|
||||
|
||||
setMessageHandler = (handler: (data: Message) => void): void => {
|
||||
this.messageHandler = handler;
|
||||
};
|
||||
|
||||
// setup
|
||||
constructor(storageModel: StorageModel) {
|
||||
// create frontend
|
||||
@@ -132,4 +150,4 @@ export default class ConnectionModel {
|
||||
this.handleConnectionChange();
|
||||
};
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -14,7 +14,9 @@ export function ConnectionModal(connectionViewModel: ConnectionViewModel) {
|
||||
|
||||
const cannotConnect = React.createProxyState(
|
||||
[connectionViewModel.isConnected],
|
||||
() => connectionViewModel.connectionModel.address == address
|
||||
() =>
|
||||
connectionViewModel.isConnected.value == true &&
|
||||
connectionViewModel.connectionModel.address == address
|
||||
);
|
||||
|
||||
return DeletableListItem(
|
||||
|
||||
@@ -38,8 +38,8 @@ export default class ConnectionViewModel {
|
||||
|
||||
if (this.connectionModel.address) {
|
||||
this.serverAddressInput.value = this.connectionModel.address;
|
||||
this.previousAddresses.add(this.connectionModel.address);
|
||||
}
|
||||
this.updatePreviousAddresses();
|
||||
};
|
||||
|
||||
messageHandler = (data: Message): void => {};
|
||||
@@ -80,5 +80,8 @@ export default class ConnectionViewModel {
|
||||
constructor(connectionModel: ConnectionModel) {
|
||||
this.connectionModel = connectionModel;
|
||||
this.updatePreviousAddresses();
|
||||
|
||||
connectionModel.setConnectionChangeHandler(this.connectionChangeHandler);
|
||||
connectionModel.setMessageHandler(this.messageHandler);
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user