*rename handlers to match naming scheme

src/index.ts

@@ -75,12 +75,13 @@ addHandler("socketListenEvent", handleSocketListenEvent, {
 });
 addHandler("socketWrite", handleWriteSocketEvent);
 addHandler("socketClose", handleCloseSocketEvent);
-addHandler("createProtomuxChannel", createProtomuxChannel, {
+addHandler("createProtomuxChannel", handleCreateProtomuxChannel, {
   receiveUpdates: true,
 });
-addHandler("createProtomuxMessage", createProtomuxMessage, {
+addHandler("createProtomuxMessage", handleCreateProtomuxMessage, {
   receiveUpdates: true,
 });
+addHandler("createSwarm", handleCreateSwarm);
 
 async function handlePresentSeed(aq: ActiveQuery) {
   const pubkey = await ed.getPublicKey(aq.callerInput.rootKey);
@@ -425,7 +426,7 @@ async function handleGetSocketInfo(aq: ActiveQuery) {
   });
 }
 
-async function createProtomuxChannel(aq: ActiveQuery) {
+async function handleCreateProtomuxChannel(aq: ActiveQuery) {
   const socket = validateConnection(aq);
 
   if (!socket) {
@@ -488,7 +489,7 @@ async function createProtomuxChannel(aq: ActiveQuery) {
   aq.sendUpdate(channelId);
 }
 
-async function createProtomuxMessage(aq: ActiveQuery) {
+async function handleCreateProtomuxMessage(aq: ActiveQuery) {
   const socket = validateConnection(aq);
 
   if (!socket) {
@@ -589,6 +590,10 @@ async function createProtomuxMessage(aq: ActiveQuery) {
   });
 }
 
+async function handleCreateSwarm(aq: ActiveQuery) {
+  aq.respond(await createSwarm());
+}
+
 function getSwarmToSocketConnectionId(socket: any) {
   for (const conn of connections) {
     if (conn[1].conn === socket) {