This commit is contained in:
parent
4fd40b1f9d
commit
630387f889
24
src/api.ts
24
src/api.ts
@ -17,18 +17,30 @@ export const main = (port: number) => {
|
||||
jobInsensitive.to.username = "****REDACTED****";
|
||||
jobInsensitive.to.password = "****REDACTED****";
|
||||
|
||||
const uuid = crypto.randomUUID();
|
||||
ConsoleLogger.log(
|
||||
`Received email job: ${JSON.stringify(jobInsensitive)}`,
|
||||
`[${uuid}] Received email job: ${JSON.stringify(jobInsensitive)}`,
|
||||
)();
|
||||
|
||||
const performEmailTest = perform(job)();
|
||||
return await performEmailTest
|
||||
.then(() => {
|
||||
return performEmailTest
|
||||
.then((result) => {
|
||||
if (result._tag === "Left") {
|
||||
const error = result.left;
|
||||
ConsoleLogger.log(
|
||||
`[${uuid}] job failure due to ${error.message}`,
|
||||
)();
|
||||
return new Response(error.message, {
|
||||
status: 400,
|
||||
});
|
||||
}
|
||||
ConsoleLogger.log(`[${uuid}] success`)();
|
||||
return Response.json({ success: true });
|
||||
})
|
||||
.catch((error) => {
|
||||
return new Response(error.message, {
|
||||
status: 400,
|
||||
.catch((e) => {
|
||||
ConsoleLogger.log(`[${uuid}] internal failure due to ${e}`)();
|
||||
return new Response(e.message, {
|
||||
status: 500,
|
||||
});
|
||||
});
|
||||
}
|
||||
|
@ -192,7 +192,9 @@ const findEmailUidInInbox: FindEmailUidInInbox = (
|
||||
TE.fold(
|
||||
(e) =>
|
||||
pipe(
|
||||
TE.fromIO(ConsoleLogger.log(`failed; ${retries} retries left.`)),
|
||||
TE.fromIO(
|
||||
ConsoleLogger.log(`failed to find email; ${retries} retries left.`),
|
||||
),
|
||||
TE.chain(() =>
|
||||
retries === 0
|
||||
? TE.left(e)
|
||||
|
@ -14,6 +14,7 @@ export interface EmailToInstruction extends EmailInstruction {
|
||||
}
|
||||
|
||||
export interface EmailJob {
|
||||
requestId: string;
|
||||
from: EmailFromInstruction;
|
||||
to: EmailToInstruction;
|
||||
readRetry: Retry;
|
||||
|
Loading…
Reference in New Issue
Block a user