MAAS

Merge lp:~blake-rouse/maas/fix-1484696-1.8 into lp:maas/1.8

  1. fix-1484696-1.8
  2. Merge into 1.8
Proposed by Blake Rouse
Status: Merged
Approved by: Blake Rouse
Approved revision: no longer in the source branch.
Merged at revision: 4040
Proposed branch: lp:~blake-rouse/maas/fix-1484696-1.8
Merge into: lp:maas/1.8
Diff against target: 135 lines (+23/-18)
2 files modified
src/maasserver/static/js/angular/factories/region.js (+4/-4)
src/maasserver/static/js/angular/factories/tests/test_region.js (+19/-14)
To merge this branch: bzr merge lp:~blake-rouse/maas/fix-1484696-1.8
Reviewer Review Type Date Requested Status
Gavin Panella (community) Approve
Review via email: mp+268542@code.launchpad.net

Commit message

Regenerate the connection URL on websocket client reconnect.

To post a comment you must log in.
Revision history for this message
Gavin Panella (allenap) wrote :

Thank goodness you figured this out! I had no idea where to look when reading that bug report.

review: Approve

Preview Diff

[H/L] Next/Prev Comment, [J/K] Next/Prev File, [N/P] Next/Prev Hunk
1=== modified file 'src/maasserver/static/js/angular/factories/region.js'
2--- src/maasserver/static/js/angular/factories/region.js 2015-06-26 14:25:46 +0000
3+++ src/maasserver/static/js/angular/factories/region.js 2015-08-19 19:50:03 +0000
4@@ -117,8 +117,8 @@
5 };
6
7 // Opens the websocket connection.
8- RegionConnection.prototype.connect = function(url) {
9- this.url = url;
10+ RegionConnection.prototype.connect = function() {
11+ this.url = this._buildUrl();
12 this.autoReconnect = true;
13 this.websocket = this.buildSocket(this.url);
14
15@@ -142,7 +142,7 @@
16 });
17 if(self.autoReconnect) {
18 $timeout(function() {
19- self.connect(self.url);
20+ self.connect();
21 }, self.retryTimeout);
22 }
23 };
24@@ -236,7 +236,7 @@
25 };
26 this.registerHandler("open", opened);
27 this.registerHandler("error", errored);
28- this.connect(this._buildUrl());
29+ this.connect();
30 return defer.promise;
31 };
32
33
34=== modified file 'src/maasserver/static/js/angular/factories/tests/test_region.js'
35--- src/maasserver/static/js/angular/factories/tests/test_region.js 2015-06-26 14:25:46 +0000
36+++ src/maasserver/static/js/angular/factories/tests/test_region.js 2015-08-19 19:50:03 +0000
37@@ -199,33 +199,37 @@
38
39 describe("connect", function() {
40
41- var url = "http://test-url";
42+ var url = "http://test-url", buildUrlSpy;
43+ beforeEach(function() {
44+ buildUrlSpy = spyOn(RegionConnection, "_buildUrl");
45+ buildUrlSpy.and.returnValue(url);
46+ });
47
48 it("sets url", function() {
49- RegionConnection.connect(url);
50+ RegionConnection.connect();
51 expect(RegionConnection.url).toBe(url);
52 });
53
54 it("sets autoReconnect to true", function() {
55 RegionConnection.autoReconnect = false;
56- RegionConnection.connect(url);
57+ RegionConnection.connect();
58 expect(RegionConnection.autoReconnect).toBe(true);
59 });
60
61 it("calls buildSocket with url", function() {
62- RegionConnection.connect(url);
63+ RegionConnection.connect();
64 expect(RegionConnection.buildSocket).toHaveBeenCalledWith(url);
65 });
66
67 it("sets websocket handlers", function() {
68- RegionConnection.connect(url);
69+ RegionConnection.connect();
70 expect(webSocket.onopen).not.toBeNull();
71 expect(webSocket.onerror).not.toBeNull();
72 expect(webSocket.onclose).not.toBeNull();
73 });
74
75 it("sets connect to true when onopen called", function() {
76- RegionConnection.connect(url);
77+ RegionConnection.connect();
78 webSocket.onopen({});
79 expect(RegionConnection.connected).toBe(true);
80 });
81@@ -236,13 +240,13 @@
82 expect(evt).toBe(evt_obj);
83 done();
84 });
85- RegionConnection.connect(url);
86+ RegionConnection.connect();
87 webSocket.onerror(evt_obj);
88 });
89
90 it("sets connect to false when onclose called", function() {
91 RegionConnection.autoReconnect = false;
92- RegionConnection.connect(url);
93+ RegionConnection.connect();
94 webSocket.onclose({});
95 expect(RegionConnection.connected).toBe(false);
96 });
97@@ -250,7 +254,7 @@
98 it("calls close handler when onclose called", function(done) {
99 var evt_obj = {};
100 RegionConnection.autoReconnect = false;
101- RegionConnection.connect(url);
102+ RegionConnection.connect();
103 RegionConnection.registerHandler("close", function(evt) {
104 expect(evt).toBe(evt_obj);
105 done();
106@@ -259,15 +263,16 @@
107 });
108
109 it("onclose calls connect when autoReconnect is true", function() {
110- RegionConnection.connect(url);
111- spyOn(RegionConnection, "connect");
112+ RegionConnection.connect();
113+ var new_url = "http://new-url";
114+ buildUrlSpy.and.returnValue(new_url);
115 webSocket.onclose({});
116 $timeout.flush();
117- expect(RegionConnection.connect).toHaveBeenCalledWith(url);
118+ expect(RegionConnection.url).toBe(new_url);
119 });
120
121 it("onclose sets error", function() {
122- RegionConnection.connect(url);
123+ RegionConnection.connect();
124 webSocket.onclose();
125 $timeout.flush();
126 expect(RegionConnection.error).toBe(
127@@ -277,7 +282,7 @@
128 it("calls onMessage when onmessage called", function() {
129 var sampleData = { sample: "data" };
130 spyOn(RegionConnection, "onMessage");
131- RegionConnection.connect(url);
132+ RegionConnection.connect();
133 webSocket.onmessage({ data: angular.toJson(sampleData) });
134 expect(RegionConnection.onMessage).toHaveBeenCalledWith(
135 sampleData);

Subscribers

People subscribed via source and target branches

to all changes: