Skip to content

Commit

Permalink
Add interoperabilty tests for Unsubscribed message
Browse files Browse the repository at this point in the history
  • Loading branch information
muzzammilshahid committed Jul 2, 2024
1 parent bfd9fca commit 621cc02
Show file tree
Hide file tree
Showing 4 changed files with 56 additions and 6 deletions.
8 changes: 4 additions & 4 deletions test/interoptests/messages/event_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -14,10 +14,10 @@ void main() {

bool isEqual(Event msg1, Event msg2) =>
msg1.subscriptionID == msg2.subscriptionID &&
msg1.publicationID == msg2.publicationID &&
equality.equals(msg1.details, msg2.details) &&
equality.equals(msg1.args, msg2.args) &&
equality.equals(msg1.kwargs, msg2.kwargs);
msg1.publicationID == msg2.publicationID &&
equality.equals(msg1.details, msg2.details) &&
equality.equals(msg1.args, msg2.args) &&
equality.equals(msg1.kwargs, msg2.kwargs);

test("JSONSerializer", () async {
var msg = Event(1, 1);
Expand Down
2 changes: 1 addition & 1 deletion test/interoptests/messages/subscribe_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -51,4 +51,4 @@ void main() {
expect(isEqual(message, msg), true);
});
});
}
}
2 changes: 1 addition & 1 deletion test/interoptests/messages/subscribed_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -48,4 +48,4 @@ void main() {
expect(isEqual(message, msg), true);
});
});
}
}
50 changes: 50 additions & 0 deletions test/interoptests/messages/unsubscribed_test.dart
Original file line number Diff line number Diff line change
@@ -0,0 +1,50 @@
import "package:pinenacl/encoding.dart";
import "package:test/test.dart";

import "package:wampproto/messages.dart";
import "package:wampproto/serializers.dart";

import "../helper.dart";

void main() {
group("Unsubscribed", () {
const baseSubCommand = "message unsubscribed 1";

bool isEqual(UnSubscribed msg1, UnSubscribed msg2) => msg1.requestID == msg2.requestID;

test("JSONSerializer", () async {
var msg = UnSubscribed(1);
var command = "$baseSubCommand --serializer json";

var output = await runCommand(command);

var jsonSerializer = JSONSerializer();
var message = jsonSerializer.deserialize(output) as UnSubscribed;
expect(isEqual(message, msg), true);
});

test("CBORSerializer", () async {
var msg = UnSubscribed(1);
var command = "$baseSubCommand --serializer cbor --output hex";

var output = await runCommand(command);
var outputBytes = Base16Encoder.instance.decode(output.trim());

var cborSerializer = CBORSerializer();
var message = cborSerializer.deserialize(outputBytes) as UnSubscribed;
expect(isEqual(message, msg), true);
});

test("MsgPackSerializer", () async {
var msg = UnSubscribed(1);
var command = "$baseSubCommand --serializer msgpack --output hex";

var output = await runCommand(command);
var outputBytes = Base16Encoder.instance.decode(output.trim());

var msgPackSerializer = MsgPackSerializer();
var message = msgPackSerializer.deserialize(outputBytes) as UnSubscribed;
expect(isEqual(message, msg), true);
});
});
}

0 comments on commit 621cc02

Please sign in to comment.