refactor(formatting): rename closures to use 'create' prefix for cons…

…istency
fonoster · Dec 28, 2024 · a7acc57 · a7acc57
1 parent ebc2bdd
commit a7acc57
Show file tree

Hide file tree

Showing 9 changed files with 26 additions and 9 deletions.
diff --git a/mods/apiserver/src/utils/createHandleDialEventsWithNats.ts b/mods/apiserver/src/utils/createHandleDialEventsWithNats.ts
@@ -21,7 +21,10 @@ import { mapDialStatus } from "./mapDialStatus";
 import { CALLS_TRACK_CALL_SUBJECT } from "../envs";
 
 function createHandleDialEventsWithNats(nc: NatsConnection) {
-  return async function handleDialEventsWithNats(callRef: string, event: { dialstatus: string }) {
+  return async function handleDialEventsWithNats(
+    callRef: string,
+    event: { dialstatus: string }
+  ) {
     const mappedStatus = mapDialStatus(event.dialstatus);
     if (!mappedStatus) return; // Ignore the event if status is not mapped
 

diff --git a/mods/apiserver/src/utils/createHandleDialEventsWithVoiceClient.ts b/mods/apiserver/src/utils/createHandleDialEventsWithVoiceClient.ts
@@ -20,7 +20,9 @@ import { mapDialStatus } from "./mapDialStatus";
 import { VoiceClient } from "../voice/types";
 
 function createHandleDialEventsWithVoiceClient(voiceClient: VoiceClient) {
-  return async function handleDialEventsWithVoiceClient(event: { dialstatus: string }) {
+  return async function handleDialEventsWithVoiceClient(event: {
+    dialstatus: string;
+  }) {
     const mappedStatus = mapDialStatus(event.dialstatus);
     if (!mappedStatus) return; // Ignore the event if status is not mapped
 

diff --git a/mods/apiserver/src/voice/VoiceDispatcher.ts b/mods/apiserver/src/voice/VoiceDispatcher.ts
@@ -109,7 +109,10 @@ class VoiceDispatcher {
         SC.PLAYBACK_CONTROL_REQUEST,
         createPlaybackControlHandler(ari, vc).bind(this)
       );
-      vc.on(SC.START_STREAM_GATHER_REQUEST, createStreamGatherHandler(vc).bind(this));
+      vc.on(
+        SC.START_STREAM_GATHER_REQUEST,
+        createStreamGatherHandler(vc).bind(this)
+      );
       vc.on(SC.STOP_STREAM_GATHER_REQUEST, () => {
         vc.stopStreamGather();
       });

diff --git a/mods/apiserver/src/voice/createCreateVoiceClient.ts b/mods/apiserver/src/voice/createCreateVoiceClient.ts
@@ -31,7 +31,10 @@ const logger = getLogger({ service: "apiserver", filePath: __filename });
 const createToken = createCallAccessToken(identityConfig);
 
 // Note: By the time the call arrives here the owner of the app MUST be authenticated
-function createCreateVoiceClient(createContainer: CreateContainer, filesServer) {
+function createCreateVoiceClient(
+  createContainer: CreateContainer,
+  filesServer
+) {
   return async function createVoiceClient(params: {
     ari: Client;
     event: StasisStart;

diff --git a/mods/apiserver/src/voice/handlers/dial/index.ts b/mods/apiserver/src/voice/handlers/dial/index.ts
@@ -18,4 +18,4 @@ import { createDialHandler } from "./createDialHandler";
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-export * from "./createDialHandler";
+export * from "./createDialHandler";
diff --git a/mods/apiserver/src/voice/handlers/index.ts b/mods/apiserver/src/voice/handlers/index.ts
@@ -29,4 +29,3 @@ export * from "./createStreamGatherHandler";
 export * from "./createUnmuteHandler";
 export * from "./dial/createDialHandler";
 export * from "./gather/createGatherHandler";
-
diff --git a/mods/apiserver/src/voice/integrations/createCreateContainer.ts b/mods/apiserver/src/voice/integrations/createCreateContainer.ts
@@ -55,7 +55,9 @@ function createCreateContainer(prisma: Prisma, pathToIntegrations: string) {
     process.exit(1);
   }
 
-  return async function createContainer(appRef: string): Promise<IntegrationsContainer> {
+  return async function createContainer(
+    appRef: string
+  ): Promise<IntegrationsContainer> {
     logger.verbose("creating integrations container", { appRef });
 
     const app = await prisma.application.findUnique({

diff --git a/mods/authz/src/createCheckMethodAuthorized.ts b/mods/authz/src/createCheckMethodAuthorized.ts
@@ -47,7 +47,10 @@ function createCheckMethodAuthorized(authzServer: string, methods: string[]) {
    * @param {ServerInterceptingCall} call - The call object
    * @return {ServerInterceptingCall} - The modified call object
    */
-  return function checkMethodAuthorized(methodDefinition: { path: string }, call: ServerInterceptingCall) {
+  return function checkMethodAuthorized(
+    methodDefinition: { path: string },
+    call: ServerInterceptingCall
+  ) {
     const { path: method } = methodDefinition;
 
     if (!methods.includes(method)) {

diff --git a/mods/common/src/utils/createFetchSingleCallByCallId.ts b/mods/common/src/utils/createFetchSingleCallByCallId.ts
@@ -25,7 +25,9 @@ import { CallDetailRecord } from "@fonoster/types";
 import { InfluxDBClient } from "./types";
 
 function createFetchSingleCallByCallId(influxdb: InfluxDBClient) {
-  return async function fetchSingleCallByCallId(callId: string): Promise<CallDetailRecord> {
+  return async function fetchSingleCallByCallId(
+    callId: string
+  ): Promise<CallDetailRecord> {
     const query = flux`from(bucket: "${INFLUXDB_CALLS_BUCKET}")
       |> range(start: -365d)
       |> pivot(rowKey: ["callId"], columnKey: ["_field"], valueColumn: "_value")
Original file line number	Diff line number	Diff line change
Expand Up		@@ -29,4 +29,3 @@ export * from "./createStreamGatherHandler";
		export * from "./createUnmuteHandler";
		export * from "./dial/createDialHandler";
		export * from "./gather/createGatherHandler";