[tunnelbroker] Ignore CONNECTIONFORCED error message
ClosedPublic
Actions

// @flow		// @flow

import invariant from 'invariant';		import invariant from 'invariant';

import {		import {
parseThreadPermissionString,		parseThreadPermissionString,
		constructThreadPermissionString,
includeThreadPermissionForThreadType,		includeThreadPermissionForThreadType,
} from './prefixes.js';		} from './prefixes.js';
import {		import {
configurableCommunityPermissions,		configurableCommunityPermissions,
threadPermissionFilterPrefixes,		threadPermissionFilterPrefixes,
threadPermissionPropagationPrefixes,		threadPermissionPropagationPrefixes,
threadPermissions,		threadPermissions,
userSurfacedPermissions,		userSurfacedPermissions,
▲ Show 20 Lines • Show All 148 Lines • ▼ Show 20 Lines	if (!parsed.propagationPrefix) {
continue;		continue;
}		}
if (		if (
parsed.propagationPrefix ===		parsed.propagationPrefix ===
threadPermissionPropagationPrefixes.DESCENDANT		threadPermissionPropagationPrefixes.DESCENDANT
) {		) {
permissionsForChildren[permissionKey] = permissionValue;		permissionsForChildren[permissionKey] = permissionValue;
}		}
const permissionWithFilterPrefix = parsed.filterPrefix		const withoutPropagationPrefix = constructThreadPermissionString({
? `${parsed.filterPrefix}${parsed.permission}`		...parsed,
: parsed.permission;		propagationPrefix: null,
permissionsForChildren[permissionWithFilterPrefix] = permissionValue;		});
		permissionsForChildren[withoutPropagationPrefix] = permissionValue;
}		}
if (Object.keys(permissionsForChildren).length === 0) {		if (Object.keys(permissionsForChildren).length === 0) {
return null;		return null;
}		}
return permissionsForChildren;		return permissionsForChildren;
}		}

function getRoleForPermissions(		function getRoleForPermissions(
▲ Show 20 Lines • Show All 373 Lines • Show Last 20 Lines

[tunnelbroker] Ignore CONNECTIONFORCED error messageClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 45153

services/tunnelbroker/src/amqp.rs

[tunnelbroker] Ignore CONNECTIONFORCED error message
ClosedPublic
Actions

Revision Contents
Changeset List