update devDependencies, clean up lint issues
[squeep-authentication-module] / test / lib / session-manager.js
1 'use strict';
2
3 const assert = require('node:assert');
4 const sinon = require('sinon');
5
6 const SessionManager = require('../../lib/session-manager');
7 const Enum = require('../../lib/enum');
8 const Config = require('../stub-config');
9 const stubLogger = require('../stub-logger');
10 const stubDb = require('../stub-db');
11
12 describe('SessionManager', function () {
13 let manager, options, stubAuthenticator;
14 let res, ctx;
15
16 beforeEach(function () {
17 stubDb._reset();
18 options = new Config('test');
19 res = {
20 end: sinon.stub(),
21 setHeader: sinon.stub(),
22 appendHeader: sinon.stub(),
23 };
24 ctx = {
25 cookie: {},
26 params: {},
27 queryParams: {},
28 parsedBody: {},
29 errors: [],
30 notifications: [],
31 };
32 stubAuthenticator = {
33 isValidIdentifierCredential: sinon.stub(),
34 checkOTP: sinon.stub(),
35 _validateAuthDataCredential: sinon.stub(),
36 updateCredential: sinon.stub(),
37 db: stubDb,
38 };
39 manager = new SessionManager(stubLogger, stubAuthenticator, options);
40 sinon.stub(manager.indieAuthCommunication);
41 stubLogger._reset();
42 });
43 afterEach(function () {
44 sinon.restore();
45 });
46
47 describe('constructor', function () {
48 it('covers options', function () {
49 delete options.dingus.proxyPrefix;
50 delete options.authenticator.secureAuthOnly;
51 options.authenticator.sessionCookieSameSite = 'None';
52 manager = new SessionManager(stubLogger, stubAuthenticator, options);
53 });
54 }); // constructor
55
56 describe('_sessionCookieSet', function () {
57 let session, maxAge;
58 beforeEach(function () {
59 session = {};
60 maxAge = 86400;
61 });
62 it('covers', async function () {
63 await manager._sessionCookieSet(res, session, maxAge);
64 assert(res.appendHeader.called);
65 });
66 it('covers reset', async function () {
67 session = undefined;
68 maxAge = 0;
69 await manager._sessionCookieSet(res, session, maxAge);
70 assert(res.appendHeader.called);
71 });
72 it('covers options', async function() {
73 options.authenticator.secureAuthOnly = false;
74 await manager._sessionCookieSet(res, session, 'none', '');
75 assert(res.appendHeader.called);
76 });
77 }); // _sessionCookieSet
78
79 describe('_sessionCookieClear', function () {
80 it('covers', async function () {
81 await manager._sessionCookieClear(res);
82 assert(res.appendHeader.called);
83 });
84 }); // _sessionCookieClear
85
86 describe('getAdminLogin', function () {
87 it('covers no session', async function () {
88 await manager.getAdminLogin(res, ctx);
89 });
90 it('covers established session', async function () {
91 ctx.authenticationId = 'identifier';
92 ctx.queryParams['r'] = '/admin';
93 await manager.getAdminLogin(res, ctx);
94 assert.strictEqual(res.statusCode, 302);
95 assert(res.setHeader.called);
96 });
97 }); // getAdminLogin
98
99 describe('postAdminLogin', function () {
100 beforeEach(function () {
101 sinon.stub(manager, '_otpSubmission').resolves(false);
102 });
103 it('covers otp submission', async function () {
104 manager._otpSubmission.resolves(true);
105 await manager.postAdminLogin(res, ctx);
106 assert(res.end.notCalled);
107 });
108 it('covers valid local', async function () {
109 ctx.parsedBody.identifier = 'user';
110 ctx.parsedBody.credential = 'password';
111 manager.authenticator.isValidIdentifierCredential.resolves(true);
112 await manager.postAdminLogin(res, ctx);
113 assert.strictEqual(res.statusCode, 302);
114 });
115 it('covers invalid local', async function () {
116 ctx.parsedBody.identifier = 'user';
117 ctx.parsedBody.credential = 'password';
118 manager.authenticator.isValidIdentifierCredential.resolves(false);
119 await manager.postAdminLogin(res, ctx);
120 assert(!res.setHeader.called);
121 });
122 it('covers valid profile', async function () {
123 ctx.parsedBody.me = 'https://example.com/profile';
124 manager.indieAuthCommunication.fetchProfile.resolves({
125 metadata: {
126 authorizationEndpoint: 'https://example.com/auth',
127 },
128 });
129 await manager.postAdminLogin(res, ctx);
130 assert.strictEqual(res.statusCode, 302);
131 });
132 it('covers invalid profile', async function () {
133 ctx.parsedBody.me = 'not a profile';
134 manager.indieAuthCommunication.fetchProfile.resolves();
135 await manager.postAdminLogin(res, ctx);
136 assert(!res.setHeader.called);
137 });
138 it('covers invalid profile response', async function () {
139 ctx.parsedBody.me = 'https://example.com/profile';
140 manager.indieAuthCommunication.fetchProfile.resolves();
141 await manager.postAdminLogin(res, ctx);
142 assert(!res.setHeader.called);
143 });
144 it('covers invalid profile response endpoint', async function () {
145 ctx.parsedBody.me = 'https://example.com/profile';
146 manager.indieAuthCommunication.fetchProfile.resolves({
147 metadata: {
148 authorizationEndpoint: 'not an auth endpoint',
149 },
150 });
151 await manager.postAdminLogin(res, ctx);
152 assert(!res.setHeader.called);
153 });
154 it('covers profile scheme fallback', async function () {
155 ctx.parsedBody.me = 'https://example.com/profile';
156 ctx.parsedBody['me_auto_scheme'] = '1';
157 manager.indieAuthCommunication.fetchProfile
158 .onCall(0).resolves()
159 .onCall(1).resolves({
160 metadata: {
161 issuer: 'https://example.com/',
162 authorizationEndpoint: 'https://example.com/auth',
163 },
164 });
165 await manager.postAdminLogin(res, ctx);
166 assert.strictEqual(res.statusCode, 302);
167
168 });
169 describe('living-standard-20220212', function () {
170 it('covers valid profile', async function () {
171 ctx.parsedBody.me = 'https://example.com/profile';
172 manager.indieAuthCommunication.fetchProfile.resolves({
173 metadata: {
174 issuer: 'https://example.com/',
175 authorizationEndpoint: 'https://example.com/auth',
176 },
177 });
178 await manager.postAdminLogin(res, ctx);
179 assert.strictEqual(res.statusCode, 302);
180 });
181 it('covers bad issuer url', async function () {
182 ctx.parsedBody.me = 'https://example.com/profile';
183 manager.indieAuthCommunication.fetchProfile.resolves({
184 metadata: {
185 issuer: 'http://example.com/?bah#foo',
186 authorizationEndpoint: 'https://example.com/auth',
187 },
188 });
189 await manager.postAdminLogin(res, ctx);
190 assert(!res.setHeader.called);
191 });
192 it('covers unparsable issuer url', async function () {
193 ctx.parsedBody.me = 'https://example.com/profile';
194 manager.indieAuthCommunication.fetchProfile.resolves({
195 metadata: {
196 issuer: 'not a url',
197 authorizationEndpoint: 'https://example.com/auth',
198 },
199 });
200 await manager.postAdminLogin(res, ctx);
201 assert(!res.setHeader.called);
202 });
203 }); // living-standard-20220212
204 }); // postAdminLogin
205
206 describe('_otpSubmission', function () {
207 let otpState;
208 beforeEach(function () {
209 sinon.useFakeTimers(new Date());
210 otpState = {
211 authenticatedIdentifier: 'identifier',
212 key: '1234567890123456789012',
213 attempt: 0,
214 epochMs: Date.now(),
215 redirect: '/',
216 };
217 sinon.stub(manager.mysteryBox, 'unpack').resolves(otpState);
218 manager.authenticator.checkOTP.resolves(Enum.OTPResult.Valid);
219 ctx.parsedBody.state = 'state_data';
220 ctx.parsedBody.otp = '123456';
221 });
222 it('returns false if no otp state', async function () {
223 delete ctx.parsedBody.state;
224 const result = await manager._otpSubmission(res, ctx);
225 assert(manager.mysteryBox.unpack.notCalled);
226 assert.strictEqual(result, false);
227 });
228 it('returns false when presented with invalid otp state', async function () {
229 manager.mysteryBox.unpack.rejects();
230 const result = await manager._otpSubmission(res, ctx);
231 assert(manager.mysteryBox.unpack.called);
232 assert.strictEqual(result, false);
233 });
234 it('returns false when otp state missing identifier field', async function () {
235 delete otpState.authenticatedIdentifier;
236 manager.mysteryBox.unpack.resolves(otpState);
237 const result = await manager._otpSubmission(res, ctx);
238 assert(manager.mysteryBox.unpack.called);
239 assert.strictEqual(result, false);
240 });
241 it('returns false when otp state missing key field', async function () {
242 delete otpState.key;
243 manager.mysteryBox.unpack.resolves(otpState);
244 const result = await manager._otpSubmission(res, ctx);
245 assert(manager.mysteryBox.unpack.called);
246 assert.strictEqual(result, false);
247 });
248 it('returns false when otp state missing attempt field', async function () {
249 delete otpState.attempt;
250 manager.mysteryBox.unpack.resolves(otpState);
251 const result = await manager._otpSubmission(res, ctx);
252 assert(manager.mysteryBox.unpack.called);
253 assert.strictEqual(result, false);
254 });
255 it('returns false when otp state missing epoch field', async function () {
256 delete otpState.epochMs;
257 manager.mysteryBox.unpack.resolves(otpState);
258 const result = await manager._otpSubmission(res, ctx);
259 assert(manager.mysteryBox.unpack.called);
260 assert.strictEqual(result, false);
261 });
262 it('returns true when submitted otp is invalid, but allowed to retry', async function () {
263 manager.authenticator.checkOTP.resolves(Enum.OTPResult.InvalidSoftFail);
264 const result = await manager._otpSubmission(res, ctx);
265 assert(manager.mysteryBox.unpack.called);
266 assert.strictEqual(result, true);
267 assert(res.end.called);
268 });
269 it('returns false when submitted otp is invalid and too many attempts', async function () {
270 otpState.attempt = 10;
271 manager.mysteryBox.unpack.resolves(otpState);
272 manager.authenticator.checkOTP.resolves(Enum.OTPResult.InvalidHardFail);
273 const result = await manager._otpSubmission(res, ctx);
274 assert(manager.mysteryBox.unpack.called);
275 assert.strictEqual(result, false);
276 });
277 it('returns false when submitted otp is invalid and too much time has passed', async function () {
278 otpState.epochMs = Date.now() - 99999999;
279 manager.mysteryBox.unpack.resolves(otpState);
280 manager.authenticator.checkOTP.resolves(Enum.OTPResult.InvalidHardFail);
281 const result = await manager._otpSubmission(res, ctx);
282 assert(manager.mysteryBox.unpack.called);
283 assert.strictEqual(result, false);
284 });
285 it('returns true when no otp submitted', async function () {
286 ctx.parsedBody.otp = '';
287 const result = await manager._otpSubmission(res, ctx);
288 assert(manager.mysteryBox.unpack.called);
289 assert.strictEqual(result, true);
290 assert(res.end.called);
291 });
292 it('returns true when submitted otp is valid', async function () {
293 const result = await manager._otpSubmission(res, ctx);
294 assert(res.end.called);
295 assert.strictEqual(result, true);
296 });
297 it('covers unexpected otp response', async function () {
298 manager.authenticator.checkOTP.resolves('wrong');
299 assert.rejects(() => manager._otpSubmission(res, ctx), RangeError);
300 });
301 }); // _otpSubmission
302
303 describe('_validateOTPState', function () {
304 let otpState;
305 it('covers valid', function () {
306 otpState = {
307 authenticatedIdentifier: 'identifier',
308 key: '1234567890123456789012',
309 attempt: 0,
310 epochMs: Date.now(),
311 redirect: '/',
312 };
313 SessionManager._validateOTPState(otpState);
314 });
315 it('covers missing identifier', function () {
316 otpState = {
317 authenticatedIdentifier: '',
318 key: '1234567890123456789012',
319 attempt: 0,
320 epochMs: Date.now(),
321 redirect: '/',
322 };
323 assert.throws(() => SessionManager._validateOTPState(otpState));
324 });
325 it('covers missing key', function () {
326 otpState = {
327 authenticatedIdentifier: 'identifier',
328 key: '',
329 attempt: 0,
330 epochMs: Date.now(),
331 redirect: '/',
332 };
333 assert.throws(() => SessionManager._validateOTPState(otpState));
334 });
335 it('covers missing attempt', function () {
336 otpState = {
337 authenticatedIdentifier: 'identifier',
338 key: '1234567890123456789012',
339 epochMs: Date.now(),
340 redirect: '/',
341 };
342 assert.throws(() => SessionManager._validateOTPState(otpState));
343 });
344 it('covers missing epoch', function () {
345 otpState = {
346 authenticatedIdentifier: 'identifier',
347 key: '1234567890123456789012',
348 attempt: 0,
349 redirect: '/',
350 };
351 assert.throws(() => SessionManager._validateOTPState(otpState));
352 });
353 it('covers missing redirect', function () {
354 otpState = {
355 authenticatedIdentifier: 'identifier',
356 key: '1234567890123456789012',
357 attempt: 0,
358 epochMs: Date.now(),
359 };
360 assert.throws(() => SessionManager._validateOTPState(otpState));
361 });
362 }); // _validateOTPState
363
364 describe('_localUserAuth', function () {
365 beforeEach(function () {
366 ctx.parsedBody.identifier = 'identifier';
367 ctx.parsedBody.credential = 'credential';
368 manager.authenticator.isValidIdentifierCredential.resolves(true);
369 sinon.stub(manager.mysteryBox, 'pack').resolves('box');
370 });
371 it('returns false if indieauth available', async function () {
372 ctx.parsedBody.me = 'https://example.com/';
373 const result = await manager._localUserAuth(res, ctx);
374 assert.strictEqual(result, false);
375 });
376 it('returns true if identifier is invalid', async function () {
377 manager.authenticator.isValidIdentifierCredential.resolves(false);
378 const result = await manager._localUserAuth(res, ctx);
379 assert.strictEqual(result, true);
380 assert(manager.authenticator.isValidIdentifierCredential.called);
381 assert(res.end.called);
382 });
383 it('returns true if valid identifier', async function () {
384 const result = await manager._localUserAuth(res, ctx);
385 assert.strictEqual(result, true);
386 assert(res.end.called);
387 });
388 it('returns true if valid identifier requires otp entry', async function () {
389 ctx.otpKey = '1234567890123456789012';
390 const result = await manager._localUserAuth(res, ctx);
391 assert.strictEqual(result, true);
392 assert(manager.mysteryBox.pack.called);
393 assert(res.end.called);
394 });
395 }); // _localUserAuth
396
397 describe('getAdminLogout', function () {
398 it('covers', async function () {
399 await manager.getAdminLogout(res, ctx);
400 });
401 }); // getAdminLogout
402
403 describe('getAdminIA', function () {
404 let state, me, authorizationEndpoint;
405 beforeEach(function () {
406 state = '4ea7e936-3427-11ec-9f4b-0025905f714a';
407 me = 'https://example.com/profile';
408 authorizationEndpoint = 'https://example.com/auth';
409 ctx.cookie = {
410 squeepSession: 'sessionCookie',
411 };
412 manager.indieAuthCommunication.redeemProfileCode.resolves({
413 me,
414 });
415 manager.indieAuthCommunication.fetchProfile.resolves({
416 metadata: {
417 authorizationEndpoint,
418 },
419 });
420 sinon.stub(manager.mysteryBox, 'unpack').resolves({
421 authorizationEndpoint,
422 state,
423 me,
424 });
425 });
426 it('covers valid', async function () {
427 ctx.queryParams['state'] = state;
428 ctx.queryParams['code'] = 'codeCodeCode';
429
430 await manager.getAdminIA(res, ctx);
431
432 assert.strictEqual(res.statusCode, 302);
433 });
434 it('covers missing cookie', async function () {
435 delete ctx.cookie;
436
437 await manager.getAdminIA(res, ctx);
438
439 assert(ctx.errors.length);
440 });
441 it('covers invalid cookie', async function () {
442 manager.mysteryBox.unpack.restore();
443 sinon.stub(manager.mysteryBox, 'unpack').rejects();
444
445 await manager.getAdminIA(res, ctx);
446
447 assert(ctx.errors.length);
448 });
449 it('covers mis-matched state', async function () {
450 ctx.queryParams['state'] = 'incorrect-state';
451 ctx.queryParams['code'] = 'codeCodeCode';
452
453 await manager.getAdminIA(res, ctx);
454
455 assert(ctx.errors.length);
456 });
457 it('relays auth endpoint errors', async function () {
458 ctx.queryParams['state'] = state;
459 ctx.queryParams['code'] = 'codeCodeCode';
460 ctx.queryParams['error'] = 'error_code';
461 ctx.queryParams['error_description'] = 'something went wrong';
462
463 await manager.getAdminIA(res, ctx);
464
465 assert(ctx.errors.length);
466 });
467 it('covers empty error_description', async function () {
468 ctx.queryParams['state'] = state;
469 ctx.queryParams['code'] = 'codeCodeCode';
470 ctx.queryParams['error'] = 'error_code';
471
472 await manager.getAdminIA(res, ctx);
473
474 assert(ctx.errors.length);
475 });
476 it('covers invalid restored session', async function () {
477 manager.mysteryBox.unpack.restore();
478 sinon.stub(manager.mysteryBox, 'unpack').resolves({
479 authorizationEndpoint: 'not a url',
480 state,
481 me,
482 });
483 ctx.queryParams['state'] = state;
484 ctx.queryParams['code'] = 'codeCodeCode';
485
486 await manager.getAdminIA(res, ctx);
487
488 assert(ctx.errors.length);
489 });
490 it('covers empty profile redemption response', async function () {
491 ctx.queryParams['state'] = state;
492 ctx.queryParams['code'] = 'codeCodeCode';
493 manager.indieAuthCommunication.redeemProfileCode.restore();
494 sinon.stub(manager.indieAuthCommunication, 'redeemProfileCode').resolves();
495
496 await manager.getAdminIA(res, ctx);
497
498 assert(ctx.errors.length);
499 });
500 it('covers missing profile in redemption response', async function () {
501 ctx.queryParams['state'] = state;
502 ctx.queryParams['code'] = 'codeCodeCode';
503 manager.indieAuthCommunication.redeemProfileCode.restore();
504 sinon.stub(manager.indieAuthCommunication, 'redeemProfileCode').resolves({
505 });
506
507 await manager.getAdminIA(res, ctx);
508
509 assert(ctx.errors.length);
510 });
511 it('covers different canonical profile response', async function () {
512 ctx.queryParams['state'] = state;
513 ctx.queryParams['code'] = 'codeCodeCode';
514 manager.indieAuthCommunication.redeemProfileCode.restore();
515 sinon.stub(manager.indieAuthCommunication, 'redeemProfileCode').resolves({
516 me: 'https://different.example.com/profile',
517 });
518
519 await manager.getAdminIA(res, ctx);
520
521 assert.strictEqual(res.statusCode, 302);
522 });
523 it('covers different canonical profile response mis-matched endpoint', async function () {
524 ctx.queryParams['state'] = state;
525 ctx.queryParams['code'] = 'codeCodeCode';
526 manager.indieAuthCommunication.redeemProfileCode.restore();
527 sinon.stub(manager.indieAuthCommunication, 'redeemProfileCode').resolves({
528 me: 'https://different.example.com/profile',
529 });
530 manager.indieAuthCommunication.fetchProfile.restore();
531 sinon.stub(manager.indieAuthCommunication, 'fetchProfile').resolves({
532 metadata: {
533 authorizationEndpoint: 'https://elsewhere.example.com/auth',
534 },
535 });
536
537 await manager.getAdminIA(res, ctx);
538
539 assert(ctx.errors.length);
540 });
541 describe('living-standard-20220212', function () {
542 beforeEach(function () {
543 manager.indieAuthCommunication.fetchProfile.resolves({
544 metadata: {
545 authorizationEndpoint,
546 issuer: 'https://example.com/',
547 },
548 });
549 manager.mysteryBox.unpack.resolves({
550 authorizationEndpoint,
551 issuer: 'https://example.com/',
552 state,
553 me,
554 });
555 });
556 it('covers valid', async function () {
557 ctx.queryParams['state'] = state;
558 ctx.queryParams['code'] = 'codeCodeCode';
559 ctx.queryParams['iss'] = 'https://example.com/';
560
561 await manager.getAdminIA(res, ctx);
562
563 assert.strictEqual(res.statusCode, 302);
564 });
565 it('covers mis-matched issuer', async function () {
566 ctx.queryParams['state'] = state;
567 ctx.queryParams['code'] = 'codeCodeCode';
568
569 await manager.getAdminIA(res, ctx);
570
571 assert(ctx.errors.length);
572 });
573 }); // living-standard-20220212
574 }); // getAdminIA
575
576 describe('getAdminSettings', function () {
577 it('covers success', async function () {
578 manager.db.authenticationGet.resolves({});
579 await manager.getAdminSettings(res, ctx);
580 assert(!ctx.errors.length);
581 });
582 it('covers no user', async function () {
583 manager.db.authenticationGet.resolves();
584 await manager.getAdminSettings(res, ctx);
585 assert(ctx.errors.length);
586 });
587 it('covers db failure', async function () {
588 manager.db.authenticationGet.throws();
589 await manager.getAdminSettings(res, ctx);
590 assert(ctx.errors.length);
591 });
592 }); // getAdminSettings
593
594 describe('postAdminSettings', function () {
595 let authData;
596 beforeEach(function () {
597 authData = {
598 identifier: 'user',
599 credential: 'password',
600 otpKey: '12345678901234567890123456789012',
601 };
602 manager.db.authenticationGet.resolves(authData);
603 sinon.stub(manager, '_credentialUpdate');
604 sinon.stub(manager, '_otpEnable');
605 sinon.stub(manager, '_otpConfirm');
606 sinon.stub(manager, '_otpDisable');
607 });
608 it('covers no action', async function () {
609 await manager.postAdminSettings(res, ctx);
610 assert(!ctx.errors.length);
611 });
612 it('covers db empty', async function () {
613 manager.db.authenticationGet.resolves();
614 await manager.postAdminSettings(res, ctx);
615 assert(ctx.errors.length);
616 });
617 it('covers db error', async function () {
618 manager.db.authenticationGet.throws();
619 await manager.postAdminSettings(res, ctx);
620 assert(ctx.errors.length);
621 });
622 it('covers credential update', async function () {
623 ctx.parsedBody.credential = 'update';
624 await manager.postAdminSettings(res, ctx);
625 assert(manager._credentialUpdate.called);
626 });
627 it('covers otp enabling', async function () {
628 ctx.parsedBody.otp = 'enable';
629 await manager.postAdminSettings(res, ctx);
630 assert(manager._otpEnable.called);
631 });
632 it('covers otp confirmation', async function () {
633 ctx.parsedBody.otp = 'confirm';
634 await manager.postAdminSettings(res, ctx);
635 assert(manager._otpConfirm.called);
636 });
637 it('covers otp disabling', async function () {
638 ctx.parsedBody.otp = 'disable';
639 await manager.postAdminSettings(res, ctx);
640 assert(manager._otpDisable.called);
641 });
642 }); // postAdminSettings
643
644 describe('_otpDisable', function () {
645 let dbCtx, authData;
646 beforeEach(function () {
647 ctx.otpKey = '12345678901234567890123456789012';
648 dbCtx = {};
649 authData = {
650 otpKey: '12345678901234567890123456789012',
651 };
652 });
653 it('covers success', async function () {
654 await manager._otpDisable(dbCtx, ctx, authData);
655 assert(!ctx.otpKey);
656 assert(!authData.otpKey);
657 assert(manager.db.authenticationUpdateOTPKey.called);
658 assert(ctx.notifications.length);
659 assert(!ctx.errors.length);
660 });
661 it('covers db failure', async function () {
662 manager.db.authenticationUpdateOTPKey.throws();
663 await manager._otpDisable(dbCtx, ctx, authData);
664 assert(!ctx.notifications.length);
665 assert(ctx.errors.length);
666 });
667 }); // _otpDisable
668
669 describe('_otpEnsable', function () {
670 it('covers success', async function () {
671 await manager._otpEnable(ctx);
672 assert('otpConfirmKey' in ctx);
673 assert('otpConfirmBox' in ctx);
674 assert(!ctx.errors.length);
675 });
676 it('covers failure', async function () {
677 sinon.stub(manager.mysteryBox, 'pack').throws();
678 await manager._otpEnable(ctx);
679 assert(!('otpConfirmKey' in ctx));
680 assert(!('otpConfirmBox' in ctx));
681 assert(ctx.errors.length);
682 });
683 }); // _otpEnsable
684
685 describe('_otpConfirm', function () {
686 let dbCtx, otpState;
687 beforeEach(function () {
688 sinon.stub(Date, 'now').returns(1710435655000);
689 dbCtx = {};
690 ctx.parsedBody = {
691 'otp-box': 'xxxBoxedStatexxx',
692 'otp-token': '350876',
693 };
694 otpState = {
695 otpKey: 'CDBGB3U3B2ILECQORMINGGSZN7LXY565',
696 otpAttempt: 0,
697 otpInitiatedMs: 1710434052084,
698 };
699 sinon.stub(manager.mysteryBox, 'unpack').resolves(otpState);
700 });
701 it('covers success', async function () {
702 await manager._otpConfirm(dbCtx, ctx);
703 assert(manager.db.authenticationUpdateOTPKey.called);
704 assert(ctx.notifications.length);
705 assert(!ctx.errors.length);
706 });
707 it('covers bad state', async function () {
708 manager.mysteryBox.unpack.throws();
709 await manager._otpConfirm(dbCtx, ctx);
710 assert(ctx.errors.length);
711 assert(manager.db.authenticationUpdateOTPKey.notCalled);
712 });
713 it('covers no token entered', async function () {
714 ctx.parsedBody['otp-token'] = '';
715 await manager._otpConfirm(dbCtx, ctx);
716 assert(!ctx.errors.length);
717 assert(manager.db.authenticationUpdateOTPKey.notCalled);
718 });
719 it('covers bad token entered', async function () {
720 ctx.parsedBody['otp-token'] = '123456';
721 await manager._otpConfirm(dbCtx, ctx);
722 assert(ctx.errors.length);
723 assert(manager.db.authenticationUpdateOTPKey.notCalled);
724 });
725 it('covers db error', async function () {
726 manager.db.authenticationUpdateOTPKey.throws();
727 await manager._otpConfirm(dbCtx, ctx);
728 assert(ctx.errors.length);
729 });
730 }); // _otpConfirm
731
732 describe('_credentialUpdate', function () {
733 let dbCtx, authData;
734 beforeEach(function () {
735 ctx.parsedBody = {
736 'credential-new': 'abc',
737 'credential-new-2': 'abc',
738 'credential-current': '123',
739 };
740 authData = {};
741 manager.authenticator._validateAuthDataCredential.resolves(true);
742 });
743 it('covers success', async function () {
744 await manager._credentialUpdate(dbCtx, ctx, authData);
745 assert(ctx.notifications.length);
746 assert(!ctx.errors.length);
747 });
748 it('covers invalid current password', async function () {
749 manager.authenticator._validateAuthDataCredential.resolves(false);
750 await manager._credentialUpdate(dbCtx, ctx, authData);
751 assert(!ctx.notifications.length);
752 assert(ctx.errors.length);
753 });
754 it('covers empty new password', async function () {
755 delete ctx.parsedBody['credential-new'];
756 manager.authenticator._validateAuthDataCredential.resolves(false);
757 await manager._credentialUpdate(dbCtx, ctx, authData);
758 assert(!ctx.notifications.length);
759 assert(ctx.errors.length);
760 });
761 it('covers mismatched new password', async function () {
762 ctx.parsedBody['credential-new'] = 'cde';
763 manager.authenticator._validateAuthDataCredential.resolves(false);
764 await manager._credentialUpdate(dbCtx, ctx, authData);
765 assert(!ctx.notifications.length);
766 assert(ctx.errors.length);
767 });
768 it('covers db failure', async function () {
769 manager.authenticator.updateCredential.throws();
770 await manager._credentialUpdate(dbCtx, ctx, authData);
771 assert(!ctx.notifications.length);
772 assert(ctx.errors.length);
773 assert(manager.logger.error.called);
774 });
775 }); // _credentialUpdate
776
777 }); // SessionManager