Skip to content

Commit

Permalink
chore: Rename ControllerMessenger to Messenger
Browse files Browse the repository at this point in the history
  • Loading branch information
cryptodev-2s committed Jan 31, 2025
1 parent 0c7eb2e commit 87dc2d8
Show file tree
Hide file tree
Showing 18 changed files with 56 additions and 64 deletions.
2 changes: 1 addition & 1 deletion docs/internals/permissions.md
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,7 @@ const permissionSpecifications = {

const permissionController = new PermissionController({
caveatSpecifications,
messenger: controllerMessenger, // assume this was given
messenger: permissionControllerMessenger, // assume this was given
permissionSpecifications,
unrestrictedMethods: ['wallet_unrestrictedMethod'],
});
Expand Down
4 changes: 2 additions & 2 deletions packages/snaps-controllers/src/cronjob/CronjobController.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import type {
RestrictedControllerMessenger,
RestrictedMessenger,
ControllerGetStateAction,
ControllerStateChangeEvent,
} from '@metamask/base-controller';
Expand Down Expand Up @@ -78,7 +78,7 @@ export type CronjobControllerEvents =
| SnapDisabled
| CronjobControllerStateChangeEvent;

export type CronjobControllerMessenger = RestrictedControllerMessenger<
export type CronjobControllerMessenger = RestrictedMessenger<
typeof controllerName,
CronjobControllerActions,
CronjobControllerEvents,
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
import type {
RestrictedControllerMessenger,
RestrictedMessenger,
ControllerGetStateAction,
ControllerStateChangeEvent,
} from '@metamask/base-controller';
Expand Down Expand Up @@ -58,7 +58,7 @@ export type SnapInsightsControllerAllowedEvents =
| TransactionControllerTransactionStatusUpdatedEvent
| SignatureStateChange;

export type SnapInsightsControllerMessenger = RestrictedControllerMessenger<
export type SnapInsightsControllerMessenger = RestrictedMessenger<
typeof controllerName,
SnapInsightsControllerActions | SnapInsightsControllerAllowedActions,
SnapInsightControllerEvents | SnapInsightsControllerAllowedEvents,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ import type {
HasApprovalRequest,
} from '@metamask/approval-controller';
import type {
RestrictedControllerMessenger,
RestrictedMessenger,
ControllerGetStateAction,
ControllerStateChangeEvent,
} from '@metamask/base-controller';
Expand Down Expand Up @@ -127,7 +127,7 @@ export type SnapInterfaceControllerEvents =
| SnapInterfaceControllerStateChangeEvent
| NotificationListUpdatedEvent;

export type SnapInterfaceControllerMessenger = RestrictedControllerMessenger<
export type SnapInterfaceControllerMessenger = RestrictedMessenger<
typeof controllerName,
SnapInterfaceControllerActions | SnapInterfaceControllerAllowedActions,
SnapInterfaceControllerEvents,
Expand Down
4 changes: 2 additions & 2 deletions packages/snaps-controllers/src/multichain/MultichainRouter.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import type { RestrictedControllerMessenger } from '@metamask/base-controller';
import type { RestrictedMessenger } from '@metamask/base-controller';
import type { GetPermissions } from '@metamask/permission-controller';
import { rpcErrors } from '@metamask/rpc-errors';
import {
Expand Down Expand Up @@ -93,7 +93,7 @@ export type MultichainRouterAllowedActions =

export type MultichainRouterEvents = never;

export type MultichainRouterMessenger = RestrictedControllerMessenger<
export type MultichainRouterMessenger = RestrictedMessenger<
typeof name,
MultichainRouterActions | MultichainRouterAllowedActions,
never,
Expand Down
4 changes: 2 additions & 2 deletions packages/snaps-controllers/src/services/ExecutionService.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import type { RestrictedControllerMessenger } from '@metamask/base-controller';
import type { RestrictedMessenger } from '@metamask/base-controller';
import type { SnapRpcHookArgs } from '@metamask/snaps-utils';
import type { Json } from '@metamask/utils';

Expand Down Expand Up @@ -90,7 +90,7 @@ export type ExecutionServiceActions =
| TerminateSnapAction
| TerminateAllSnapsAction;

export type ExecutionServiceMessenger = RestrictedControllerMessenger<
export type ExecutionServiceMessenger = RestrictedMessenger<
'ExecutionService',
ExecutionServiceActions,
ExecutionServiceEvents,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -93,9 +93,7 @@ describe('NodeThreadExecutionService', () => {

it('can handle errors out of band', async () => {
expect.assertions(2);
const { service, controllerMessenger } = createService(
NodeThreadExecutionService,
);
const { service, messenger } = createService(NodeThreadExecutionService);
const snapId = 'TestSnap';
await service.executeSnap({
snapId,
Expand All @@ -118,7 +116,7 @@ describe('NodeThreadExecutionService', () => {
});

const unhandledErrorPromise = new Promise((resolve) => {
controllerMessenger.subscribe(
messenger.subscribe(
'ExecutionService:unhandledError',
(_snapId: string, error: SnapErrorJson) => {
resolve(error);
Expand Down
4 changes: 2 additions & 2 deletions packages/snaps-controllers/src/snaps/SnapController.ts
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ import type {
UpdateRequestState,
} from '@metamask/approval-controller';
import type {
RestrictedControllerMessenger,
RestrictedMessenger,
ControllerGetStateAction,
ControllerStateChangeEvent,
} from '@metamask/base-controller';
Expand Down Expand Up @@ -644,7 +644,7 @@ export type AllowedEvents =
| SnapUpdated
| KeyringControllerLock;

type SnapControllerMessenger = RestrictedControllerMessenger<
type SnapControllerMessenger = RestrictedMessenger<
typeof controllerName,
SnapControllerActions | AllowedActions,
SnapControllerEvents | AllowedEvents,
Expand Down
4 changes: 2 additions & 2 deletions packages/snaps-controllers/src/snaps/registry/json.ts
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import type {
ControllerGetStateAction,
ControllerStateChangeEvent,
RestrictedControllerMessenger,
RestrictedMessenger,
} from '@metamask/base-controller';
import { BaseController } from '@metamask/base-controller';
import type { SnapsRegistryDatabase } from '@metamask/snaps-registry';
Expand Down Expand Up @@ -88,7 +88,7 @@ export type SnapsRegistryStateChangeEvent = ControllerStateChangeEvent<

export type SnapsRegistryEvents = SnapsRegistryStateChangeEvent;

export type SnapsRegistryMessenger = RestrictedControllerMessenger<
export type SnapsRegistryMessenger = RestrictedMessenger<
'SnapsRegistry',
SnapsRegistryActions,
SnapsRegistryEvents,
Expand Down
9 changes: 3 additions & 6 deletions packages/snaps-controllers/src/test-utils/controller.ts
Original file line number Diff line number Diff line change
@@ -1,8 +1,5 @@
import type { ApprovalRequest } from '@metamask/approval-controller';
import type {
ControllerMessenger,
RestrictedControllerMessenger,
} from '@metamask/base-controller';
import type { Messenger, RestrictedMessenger } from '@metamask/base-controller';
import {
encryptWithKey,
decryptWithKey,
Expand Down Expand Up @@ -851,8 +848,8 @@ export const getRestrictedSnapInsightsControllerMessenger = (
*/
export async function waitForStateChange(
messenger:
| ControllerMessenger<any, SnapControllerStateChangeEvent>
| RestrictedControllerMessenger<
| Messenger<any, SnapControllerStateChangeEvent>
| RestrictedMessenger<
'SnapController',
any,
SnapControllerStateChangeEvent,
Expand Down
16 changes: 8 additions & 8 deletions packages/snaps-controllers/src/test-utils/service.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { ControllerMessenger } from '@metamask/base-controller';
import { Messenger } from '@metamask/base-controller';
import { JsonRpcEngine } from '@metamask/json-rpc-engine';
import { createEngineStream } from '@metamask/json-rpc-middleware-stream';
import { logError } from '@metamask/snaps-utils';
Expand All @@ -19,12 +19,9 @@ export const createService = <
'messenger' | 'setupSnapProvider'
>,
) => {
const controllerMessenger = new ControllerMessenger<
never,
ErrorMessageEvent
>();
const messenger = new Messenger<never, ErrorMessageEvent>();

const messenger = controllerMessenger.getRestricted<
const restrictedMessenger = messenger.getRestricted<
'ExecutionService',
never,
ErrorMessageEvent['type']
Expand All @@ -33,7 +30,7 @@ export const createService = <
});

const service = new ServiceClass({
messenger,
messenger: restrictedMessenger,
setupSnapProvider: (_snapId: string, rpcStream: Duplex) => {
const mux = setupMultiplex(rpcStream, 'foo');
const stream = mux.createStream('metamask-provider');
Expand All @@ -56,5 +53,8 @@ export const createService = <
...options,
});

return { service, messenger, controllerMessenger };
return {
service,
messenger: restrictedMessenger,
};
};
4 changes: 2 additions & 2 deletions packages/snaps-simulation/src/controllers.test.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { ControllerMessenger } from '@metamask/base-controller';
import { Messenger } from '@metamask/base-controller';
import {
PermissionController,
SubjectMetadataController,
Expand All @@ -21,7 +21,7 @@ const MOCK_HOOKS: RestrictedMiddlewareHooks = {
describe('getControllers', () => {
it('returns the controllers', () => {
const { permissionController, subjectMetadataController } = getControllers({
controllerMessenger: new ControllerMessenger(),
controllerMessenger: new Messenger(),
hooks: MOCK_HOOKS,
runSaga: jest.fn(),
options: getMockOptions(),
Expand Down
6 changes: 3 additions & 3 deletions packages/snaps-simulation/src/controllers.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import type { ControllerMessenger } from '@metamask/base-controller';
import type { Messenger } from '@metamask/base-controller';
import type {
CaveatSpecificationConstraint,
PermissionSpecificationConstraint,
Expand Down Expand Up @@ -42,13 +42,13 @@ export type RootControllerAllowedActions =
export type RootControllerAllowedEvents =
SnapInterfaceControllerStateChangeEvent;

export type RootControllerMessenger = ControllerMessenger<
export type RootControllerMessenger = Messenger<
RootControllerAllowedActions,
RootControllerAllowedEvents
>;

export type GetControllersOptions = {
controllerMessenger: ControllerMessenger<any, any>;
controllerMessenger: Messenger<any, any>;
hooks: RestrictedMiddlewareHooks;
runSaga: RunSagaFunction;
options: SimulationOptions;
Expand Down
6 changes: 3 additions & 3 deletions packages/snaps-simulation/src/methods/specifications.test.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { ControllerMessenger } from '@metamask/base-controller';
import { Messenger } from '@metamask/base-controller';
import {
getSnapManifest,
MOCK_SNAP_ID,
Expand Down Expand Up @@ -45,7 +45,7 @@ describe('getPermissionSpecifications', () => {
hooks: MOCK_HOOKS,
runSaga: jest.fn(),
options: getMockOptions(),
controllerMessenger: new ControllerMessenger(),
controllerMessenger: new Messenger(),
}),
).toMatchInlineSnapshot(`
{
Expand Down Expand Up @@ -324,7 +324,7 @@ describe('getPermissionSpecifications', () => {
describe('getEndowments', () => {
it('returns the endowments', async () => {
const controllers = getControllers({
controllerMessenger: new ControllerMessenger(),
controllerMessenger: new Messenger(),
hooks: MOCK_HOOKS,
runSaga: jest.fn(),
options: getMockOptions(),
Expand Down
6 changes: 3 additions & 3 deletions packages/snaps-simulation/src/simulation.ts
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ import type {
ActionConstraint,
EventConstraint,
} from '@metamask/base-controller';
import { ControllerMessenger } from '@metamask/base-controller';
import { Messenger } from '@metamask/base-controller';
import { createEngineStream } from '@metamask/json-rpc-middleware-stream';
import {
type CryptographicFunctions,
Expand Down Expand Up @@ -94,7 +94,7 @@ export type InstalledSnap = {
snapId: SnapId;
store: Store;
executionService: InstanceType<typeof AbstractExecutionService>;
controllerMessenger: ControllerMessenger<ActionConstraint, EventConstraint>;
controllerMessenger: Messenger<ActionConstraint, EventConstraint>;
runSaga: RunSagaFunction;
};

Expand Down Expand Up @@ -276,7 +276,7 @@ export async function installSnap<
// Create Redux store.
const { store, runSaga } = createStore(options);

const controllerMessenger = new ControllerMessenger<any, any>();
const controllerMessenger = new Messenger<any, any>();

registerActions(controllerMessenger, runSaga);

Expand Down
29 changes: 13 additions & 16 deletions packages/snaps-simulator/src/features/simulation/sagas.ts
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { ControllerMessenger } from '@metamask/base-controller';
import { Messenger } from '@metamask/base-controller';
import { createFetchMiddleware } from '@metamask/eth-json-rpc-middleware';
import { JsonRpcEngine } from '@metamask/json-rpc-engine';
import { createEngineStream } from '@metamask/json-rpc-middleware-stream';
Expand Down Expand Up @@ -89,17 +89,14 @@ const DEFAULT_ENVIRONMENT_URL = `https://execution.metamask.io/iframe/${packageJ
/**
* Register the misc controller actions.
*
* @param controllerMessenger - The controller messenger.
* @param messenger - The messenger.
*/
export function registerActions(
controllerMessenger: ControllerMessenger<any, any>,
) {
controllerMessenger.registerActionHandler(
'PhishingController:testOrigin',
() => ({ result: false }),
);
export function registerActions(messenger: Messenger<any, any>) {
messenger.registerActionHandler('PhishingController:testOrigin', () => ({
result: false,
}));

controllerMessenger.registerActionHandler(
messenger.registerActionHandler(
'PhishingController:maybeUpdateState',
async () => Promise.resolve(),
);
Expand All @@ -114,9 +111,9 @@ export function registerActions(
* @yields Puts the execution environment after creation.
*/
export function* initSaga({ payload }: PayloadAction<string>) {
const controllerMessenger = new ControllerMessenger<any, any>();
const messenger = new Messenger<any, any>();

registerActions(controllerMessenger);
registerActions(messenger);

const srp: string = yield select(getSrp);

Expand Down Expand Up @@ -161,7 +158,7 @@ export function* initSaga({ payload }: PayloadAction<string>) {
};

const subjectMetadataController = new SubjectMetadataController({
messenger: controllerMessenger.getRestricted({
messenger: messenger.getRestricted({
name: 'SubjectMetadataController',
allowedActions: [],
allowedEvents: [],
Expand All @@ -170,7 +167,7 @@ export function* initSaga({ payload }: PayloadAction<string>) {
});

const permissionController = new PermissionController({
messenger: controllerMessenger.getRestricted({
messenger: messenger.getRestricted({
name: 'PermissionController',
allowedActions: [
`ApprovalController:addRequest`,
Expand All @@ -192,7 +189,7 @@ export function* initSaga({ payload }: PayloadAction<string>) {
});

const snapInterfaceController = new SnapInterfaceController({
messenger: controllerMessenger.getRestricted({
messenger: messenger.getRestricted({
name: 'SnapInterfaceController',
allowedActions: [
`PhishingController:testOrigin`,
Expand Down Expand Up @@ -244,7 +241,7 @@ export function* initSaga({ payload }: PayloadAction<string>) {

const executionService = new IframeExecutionService({
iframeUrl: new URL(environmentUrl),
messenger: controllerMessenger.getRestricted({
messenger: messenger.getRestricted({
name: 'ExecutionService',
allowedActions: [],
allowedEvents: [],
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
import { ControllerMessenger } from '@metamask/base-controller';
import { Messenger } from '@metamask/base-controller';
import { SnapInterfaceController } from '@metamask/snaps-controllers';

import { registerActions } from '../sagas';
Expand All @@ -9,7 +9,7 @@ import { registerActions } from '../sagas';
* @returns The {@link SnapInterfaceController}.
*/
export function getSnapInterfaceController() {
const messenger = new ControllerMessenger<any, any>();
const messenger = new Messenger<any, any>();

registerActions(messenger);

Expand Down
Loading

0 comments on commit 87dc2d8

Please sign in to comment.