remove excesive logging

apps/test-app-runtime/src/my-workflow.ts

@@ -2,7 +2,6 @@ import { task, workflow } from "@eventual/core";
 
 export default workflow("my-workflow", async ({ name }: { name: string }) => {
   const result = await Promise.all([hello(name), hello2(name)]);
-  console.log(result);
   const result2 = await hello(name);
   return `you said ${result2} ${result}`;
 });

apps/test-app-runtime/src/parent-child-com.ts

@@ -11,8 +11,6 @@ export const workflow1 = workflow("workflow1", async () => {
   while (true) {
     const n = await mySignal.expectSignal();
 
-    console.log(n);
-
     if (n > 10) {
       child.sendSignal(doneSignal);
       break;
@@ -32,7 +30,7 @@ export const workflow1 = workflow("workflow1", async () => {
  */
 export const workflow2 = workflow(
   "workflow2",
-  async (input: { name: string }, { execution: { parentId } }) => {
+  async (_input: { name: string }, { execution: { parentId } }) => {
     let block = false;
     let done = false;
     let last = 0;
@@ -41,8 +39,6 @@ export const workflow2 = workflow(
       throw new Error("I need an adult");
     }
 
-    console.log(`Hi, I am ${input.name}`);
-
     mySignal.onSignal((n) => {
       last = n;
       block = false;

apps/test-app-sst/services/functions/service.ts

@@ -13,7 +13,7 @@ api.post("/work", async (request) => {
 });
 
 export const myWorkflow = workflow("myWorkflow", async (items: string[]) => {
-  const results = await Promise.all(items.map(doWork));
+  const results = await Promise.all(items.map((item) => doWork(item)));
 
   await workDone.emit({
     outputs: results,
@@ -23,8 +23,6 @@ export const myWorkflow = workflow("myWorkflow", async (items: string[]) => {
 });
 
 export const doWork = task("work", async (work: string) => {
-  console.log("Doing Work", work);
-
   return work.length;
 });
 

apps/tests/aws-runtime/test/async-writer-handler.ts

@@ -11,23 +11,20 @@ export interface AsyncWriterTestEvent {
 }
 
 export const handle: Handler<AsyncWriterTestEvent[], void> = async (event) => {
-  console.log(event);
-  console.log(
-    await Promise.allSettled(
-      event.map(async (e) => {
-        if (e.type === "complete") {
-          await serviceClient.sendTaskSuccess({
-            taskToken: e.token,
-            result: "hello from the async writer!",
-          });
-        } else {
-          await serviceClient.sendTaskFailure({
-            taskToken: e.token,
-            error: "AsyncWriterError",
-            message: "I was told to fail this task, sorry.",
-          });
-        }
-      })
-    )
+  await Promise.allSettled(
+    event.map(async (e) => {
+      if (e.type === "complete") {
+        await serviceClient.sendTaskSuccess({
+          taskToken: e.token,
+          result: "hello from the async writer!",
+        });
+      } else {
+        await serviceClient.sendTaskFailure({
+          taskToken: e.token,
+          error: "AsyncWriterError",
+          message: "I was told to fail this task, sorry.",
+        });
+      }
+    })
   );
 };

apps/tests/aws-runtime/test/runtime-test-harness.ts

@@ -271,7 +271,6 @@ export async function waitForWorkflowCompletion<W extends Workflow = Workflow>(
     if (!execution) {
       throw new Error("Cannot find execution id: " + executionId);
     }
-    console.log(JSON.stringify(execution, null, 4));
     if (
       execution.status === ExecutionStatus.IN_PROGRESS &&
       !(cancelCallback?.() ?? false)

apps/tests/aws-runtime/test/test-service.ts

@@ -79,7 +79,6 @@ export const asyncTask = task(
   "asyncTask",
   async (type: AsyncWriterTestEvent["type"]) => {
     return asyncResult<string>(async (token) => {
-      console.log(testQueueUrl);
       if (!process.env.EVENTUAL_LOCAL) {
         await sqs.send(
           new SendMessageCommand({
@@ -109,9 +108,7 @@ const fail = task("fail", async (value: string) => {
 export const workflow1 = workflow(
   "my-workflow",
   async ({ name }: { name: string }) => {
-    console.log("before");
     const result = await hello2(name);
-    console.log("after");
     return `you said ${result}`;
   }
 );
@@ -159,8 +156,6 @@ export const parentWorkflow = workflow("parentWorkflow", async () => {
   while (true) {
     const n = await mySignal.expectSignal({ timeout: duration(10, "seconds") });
 
-    console.log(n);
-
     if (n > 10) {
       child.sendSignal(doneSignal);
       break;
@@ -189,8 +184,6 @@ export const childWorkflow = workflow(
       throw new Error("I need an adult");
     }
 
-    console.log(`Hi, I am ${input.name}`);
-
     mySignal.onSignal((n) => {
       last = n;
       block = false;
@@ -414,7 +407,6 @@ export const onSignalEvent = subscription(
     events: [signalEvent],
   },
   async ({ executionId, signalId, proxy }) => {
-    console.debug("received signal event", { executionId, signalId, proxy });
     if (proxy) {
       // if configured to proxy, re-route this event through the signalEvent
       // reason: to test that we can emit events from within an event handler
@@ -618,7 +610,6 @@ export const counterWatcher = counter.stream(
   "counterWatcher",
   { operations: ["modify", "remove"], includeOld: true },
   async (item) => {
-    console.log(item);
     if (item.operation === "remove") {
       const { n } = item.oldValue!;
       await entitySignal2.sendSignal(item.key.id, { n: n + 1 });
@@ -635,15 +626,13 @@ export const counterNamespaceWatcher = counter.batchStream(
   async (items) => {
     await Promise.all(
       items.map(async (item) => {
-        console.log(item);
         const value = await counter.get(item.key);
         await counter.put({
           namespace: "default",
           id: value!.id,
           n: (value?.n ?? 0) + 1,
           optional: undefined,
         });
-        console.log("send signal to", value!.id);
         await entitySignal.sendSignal(value!.id);
       })
     );
@@ -786,7 +775,6 @@ export const entityWorkflow = workflow(
     // and then validate the order value against the final value at the end.
     entityOrderSignal.onSignal(({ n }) => {
       if (n > orderValue) {
-        console.log(`Ordered Value: ${orderValue} ${n}`);
         orderValue = n;
       } else {
         orderError = `order value ${n} is less than or equal to previous value ${orderValue}, the stream handler executed out of order!`;
@@ -986,12 +974,10 @@ const noise = task(
           throw err;
         }
       }
-      console.log(n);
       if (n === x) {
         transact = gitErDone({ id });
       }
     }
-    console.log("waiting...");
     try {
       return await transact;
     } catch (err) {
@@ -1332,9 +1318,8 @@ const simpleEvent = event<{ value: string }>("simpleEvent");
 export const simpleEventHandler = subscription(
   "simpleEventHandler",
   { events: [simpleEvent] },
-  (payload) => {
-    console.log("hi", payload);
-  }
+  // eslint-disable-next-line @typescript-eslint/no-empty-function
+  (_payload) => {}
 );
 
 export const blogIndex = index("blogIndex", {
@@ -1421,13 +1406,11 @@ export interface SocketMessage {
 
 const jsonSocket = socket.use({
   message: ({ request: { body }, context, next }) => {
-    console.log(body);
     const data = body
       ? body instanceof Buffer
         ? (JSON.parse(body.toString("utf-8")) as SocketMessage)
         : (JSON.parse(body) as SocketMessage)
       : undefined;
-    console.log("data", data);
     if (!data) {
       throw new Error("Expected data");
     }
@@ -1445,24 +1428,20 @@ export const socket1 = jsonSocket
   })
   .socket("socket1", {
     $connect: async ({ connectionId }, { id, n }) => {
-      console.log("sending signal to", id);
       await socketConnectSignal.sendSignal(id, {
         connectionId,
         n: Number(n),
       });
-      console.log("signal sent to", id);
     },
     $disconnect: async () => undefined,
     $default: async ({ connectionId }, { data }) => {
       if (!data.id) {
         throw new Error("Invalid id");
       }
-      console.log("sending signal to", data.id);
       await socketMessageSignal.sendSignal(data.id, {
         ...data,
         connectionId,
       });
-      console.log("signal sent to", data.id);
     },
   });
 

apps/tests/aws-runtime/test/tester.test.ts

@@ -458,18 +458,12 @@ test("socket test", async () => {
 
   const encodedId = encodeURIComponent(executionId);
 
-  console.log("pre-socket");
-
   const ws1 = new WebSocket(`${socketUrl}?id=${encodedId}&n=0`);
   const ws2 = new WebSocket(`${socketUrl}?id=${encodedId}&n=1`);
 
-  console.log("setup-socket");
-
   const running1 = setupWS(executionId, ws1);
   const running2 = setupWS(executionId, ws2);
 
-  console.log("waiting...");
-
   const result = await Promise.all([running1, running2]);
 
   expect(result).toEqual([3, 4]);
@@ -480,7 +474,6 @@ function setupWS(executionId: string, ws: WebSocket) {
   let v: number | undefined;
   return new Promise<number>((resolve, reject) => {
     ws.on("error", (err) => {
-      console.log("error", err);
       reject(err);
     });
     ws.on("message", (data) => {
@@ -493,9 +486,7 @@ function setupWS(executionId: string, ws: WebSocket) {
       );
 
       try {
-        console.log(n, "message");
         const d = (data as Buffer).toString("utf8");
-        console.log(d);
         const event = JSON.parse(d) as StartSocketEvent | DataSocketEvent;
         if (event.type === "start") {
           n = event.n;
@@ -516,8 +507,6 @@ function setupWS(executionId: string, ws: WebSocket) {
     });
     ws.on("close", (code, reason) => {
       try {
-        console.log(code, reason.toString("utf-8"));
-        console.log(n, "close", v);
         if (n === undefined) {
           throw new Error("n was not set");
         }

packages/@eventual/aws-runtime/src/clients/event-client.ts

@@ -24,8 +24,6 @@ export class AWSEventClient implements EventClient {
   ): Promise<void> {
     const self = this;
 
-    console.debug("emit", events);
-
     const eventBatches = chunkArray(
       10,
       events.map((event, i) => {
@@ -106,7 +104,6 @@ export class AWSEventClient implements EventClient {
 
       async function retry(events: EventTuple[] | readonly EventTuple[]) {
         const delayTime = Math.min(retryConfig.maxDelay, retryConfig.delayMs);
-        console.debug(`Retrying after waiting ${delayTime}ms`);
 
         await new Promise((resolve) => setTimeout(resolve, delayTime));
 

packages/@eventual/aws-runtime/src/clients/opensearch-client.ts

@@ -17,7 +17,6 @@ export class AWSOpenSearchClient implements OpenSearchClient {
     credentials: any;
     region: string;
   }) {
-    console.log("Open Search endpoint: ", node);
     this.client = new Client({
       node,
       Connection: class extends Connection {

packages/@eventual/aws-runtime/src/clients/transaction-client.ts

@@ -16,7 +16,6 @@ export class AWSTransactionClient implements TransactionClient {
   public async executeTransaction(
     request: ExecuteTransactionRequest
   ): Promise<ExecuteTransactionResponse> {
-    console.debug("Invoking Transaction: ", request.transaction);
     const response = await this.props.lambda.send(
       new InvokeCommand({
         FunctionName: getLazy(this.props.transactionWorkerFunctionArn),
@@ -36,8 +35,6 @@ export class AWSTransactionClient implements TransactionClient {
       throw new Error("Invalid response from the transaction worker");
     }
 
-    console.debug("Transaction Complete: ", request.transaction);
-
     return JSON.parse(
       Buffer.from(response.Payload).toString("utf-8")
     ) as ExecuteTransactionResponse;

packages/@eventual/aws-runtime/src/handlers/apig-command-worker.ts

@@ -36,8 +36,6 @@ export function createApiGCommandWorker({
   return async function (
     event: APIGatewayProxyEventV2
   ): Promise<APIGatewayProxyResultV2> {
-    console.debug("event", event);
-
     const serviceUrl = `https://${event.requestContext.domainName}`;
     const serviceClient = serviceClientBuilder
       ? serviceClientBuilder(serviceUrl)
@@ -96,7 +94,6 @@ export function createApiGCommandWorker({
       body: responseBody.toString("base64"),
       isBase64Encoded: true,
     };
-    console.debug("httpResponse", httpResponse);
     return httpResponse;
   };
 }

packages/@eventual/aws-runtime/src/handlers/bucket-handler-worker.ts

@@ -37,7 +37,6 @@ const worker = createBucketNotificationHandlerWorker({
 
 export default (async (event) => {
   const records = event.Records;
-  console.debug("records", JSON.stringify(records, undefined, 4));
 
   const results = await promiseAllSettledPartitioned(
     records,

packages/@eventual/aws-runtime/src/handlers/entity-stream-worker.ts

@@ -47,7 +47,6 @@ const worker = createEntityStreamWorker({
 
 export default (async (event) => {
   const records = event.Records;
-  console.log("records", JSON.stringify(records, undefined, 4));
 
   const items = records.flatMap((record) => {
     const operation = record.eventName?.toLowerCase() as

packages/@eventual/aws-runtime/src/handlers/search-index-custom-resource-handler.ts

@@ -13,8 +13,6 @@ const endpoint = process.env.OS_ENDPOINT;
 let client: Client;
 
 export const handle: CloudFormationCustomResourceHandler = async (event) => {
-  console.log(event);
-  console.log(JSON.stringify(event));
   client ??= await (async () => {
     const credentials = await defaultProvider()();
     return new Client({

packages/@eventual/aws-runtime/src/handlers/subscription-worker.ts

@@ -36,7 +36,6 @@ export const processEvent = createSubscriptionWorker({
 });
 
 export default async function (event: EventBridgeEvent<string, any>) {
-  console.debug("received", event);
   await processEvent([
     {
       name: event["detail-type"],

packages/@eventual/aws-runtime/src/handlers/task-fallback-handler.ts

@@ -18,7 +18,6 @@ interface ErrorHandlerRequest {
 }
 
 export default async (lambdaRequest: ErrorHandlerRequest) => {
-  console.log("Received fallback to request: " + JSON.stringify(lambdaRequest));
   try {
     const parsed = JSON.parse(
       lambdaRequest.responsePayload.errorMessage

packages/@eventual/aws-runtime/src/handlers/timer-handler.ts

@@ -16,7 +16,6 @@ const handleTimer = createTimerHandler({
 });
 
 export const handle: SQSHandler = async (event) => {
-  console.debug(JSON.stringify(event));
   const results = await promiseAllSettledPartitioned(event.Records, (record) =>
     handleTimer(JSON.parse(record.body) as TimerRequest)
   );