Log inSign up
maxm avatar
Public
Fork
Like

Versions

  • v23

    10/30/2024
    Open: Version
    Changes from v22 to v23
    +4
    -4
    ⦚ 11 unchanged lines ⦚
    let modError: Error | undefined;
    let done = false;

    const handleRequest = async (req: Request) => {
    ⦚ 37 unchanged lines ⦚

    const start = (port: number, importUrl: string) => {
    const pendingRequests: {
    req: Request;
    resolve: (value: Response | Promise<Response>) => void;
    }[] = [];
    Deno.serve(
    {
    ⦚ 17 unchanged lines ⦚
    ⦚ 11 unchanged lines ⦚
    let modError: Error | undefined;
    let done = false;
    const pendingRequests: {
    req: Request;
    resolve: (value: Response | Promise<Response>) => void;
    }[] = [];

    const handleRequest = async (req: Request) => {
    ⦚ 37 unchanged lines ⦚

    const start = (port: number, importUrl: string) => {
    Deno.serve(
    {
    ⦚ 17 unchanged lines ⦚

  • v22

    10/30/2024
    Open: Version
    Changes from v21 to v22
    +0
    -0
    ⦚ 77 unchanged lines ⦚
    ⦚ 77 unchanged lines ⦚

  • v21

    10/30/2024
    Open: Version
    Changes from v20 to v21
    +4
    -14
    ⦚ 8 unchanged lines ⦚
    };

    const handleRequest = async (req: Request) => {
    try {
    return await asyncLocalStorage.run(
    new Map([
    [evalAnalyticsIdKey, req.headers.get(evalAnalyticsIdKey) || ""],
    ]),
    async () => {
    originalConsole.log(
    JSON.stringify({
    ...getMetadata(),
    http_url: req.url,
    http_method: req.method,
    request_headers: serializeHeaders(req.headers),
    log_type: "request_start",
    }),
    );
    if (modError || !mod) {
    return new Response(
    ⦚ 59 unchanged lines ⦚
    ⦚ 8 unchanged lines ⦚
    };

    let mod: { default: (req: Request) => Response } | undefined;
    let modError: Error | undefined;
    let done = false;

    const handleRequest = async (req: Request) => {
    try {
    if (modError || !mod) {
    return new Response(
    ⦚ 59 unchanged lines ⦚

  • v20

    10/30/2024
    Open: Version
    Changes from v19 to v20
    +53
    -0
    ⦚ 8 unchanged lines ⦚
    };

    const start = (port: number, importUrl: string) => {
    const pendingRequests: {
    req: Request;
    ⦚ 21 unchanged lines ⦚
    ⦚ 8 unchanged lines ⦚
    };

    const handleRequest = async (req: Request) => {
    try {
    return await asyncLocalStorage.run(
    new Map([
    [evalAnalyticsIdKey, req.headers.get(evalAnalyticsIdKey) || ""],
    ]),
    async () => {
    originalConsole.log(
    JSON.stringify({
    ...getMetadata(),
    http_url: req.url,
    http_method: req.method,
    request_headers: serializeHeaders(req.headers),
    log_type: "request_start",
    }),
    );
    if (modError || !mod) {
    return new Response(
    modError ? modError.message : "error initializing",
    {
    status: 500,
    },
    );
    }
    let resp, err;
    try {
    resp = await Promise.resolve(mod!.default(req));
    } catch (e) {
    err = e;
    resp = new Response(err.message, { status: 500 });
    }

  • v19

    10/30/2024
    Open: Version
    Changes from v18 to v19
    +24
    -5
    ⦚ 4 unchanged lines ⦚
    port = e.data.port as number;
    importUrl = e.data.importUrl as string;
    startServer(port, importUrl);
    }
    };

    const startServer = (port: number, importUrl: string) => {
    Deno.serve({ port }, async (req: Request): Promise<Response> => {
    return Response.json(import.meta.url);
    });
    };
    ⦚ 4 unchanged lines ⦚
    port = e.data.port as number;
    importUrl = e.data.importUrl as string;
    start(port, importUrl);
    }
    };

    const start = (port: number, importUrl: string) => {
    const pendingRequests: {
    req: Request;
    resolve: (value: Response | Promise<Response>) => void;
    }[] = [];
    Deno.serve(
    {
    port: parseInt(Deno.args[0]),
    onListen: () => {},
    onError: (err) => {
    console.error(err);
    return new Response("Internal Server Error", { status: 500 });
    },
    },
    (req) => {
    if (!done) {
    return new Promise<Response>((resolve) => {
    pendingRequests.push({ req, resolve });
    });
    }
    return handleRequest(req);
    },
    );
    };

  • v18

    10/30/2024
    Open: Version
    Changes from v17 to v18
    +1
    -1
    ⦚ 10 unchanged lines ⦚
    const startServer = (port: number, importUrl: string) => {
    Deno.serve({ port }, async (req: Request): Promise<Response> => {
    return Response.json("I am workasdfer");
    });
    };
    ⦚ 10 unchanged lines ⦚
    const startServer = (port: number, importUrl: string) => {
    Deno.serve({ port }, async (req: Request): Promise<Response> => {
    return Response.json(import.meta.url);
    });
    };

  • v17

    10/30/2024
    Open: Version
    Changes from v16 to v17
    +1
    -1
    ⦚ 10 unchanged lines ⦚
    const startServer = (port: number, importUrl: string) => {
    Deno.serve({ port }, async (req: Request): Promise<Response> => {
    return Response.json("I am worker");
    });
    };
    ⦚ 10 unchanged lines ⦚
    const startServer = (port: number, importUrl: string) => {
    Deno.serve({ port }, async (req: Request): Promise<Response> => {
    return Response.json("I am workasdfer");
    });
    };

  • v16

    10/30/2024
    Open: Version
    Changes from v15 to v16
    +0
    -0
    ⦚ 15 unchanged lines ⦚
    ⦚ 15 unchanged lines ⦚

  • v15

    10/30/2024
    Open: Version
    +15
    -0

    let port: number | undefined;
    let importUrl: string | undefined;
    self.onmessage = async (e) => {
    if (!port) {
    port = e.data.port as number;
    importUrl = e.data.importUrl as string;
    startServer(port, importUrl);
    }
    };

    const startServer = (port: number, importUrl: string) => {
    Deno.serve({ port }, async (req: Request): Promise<Response> => {
    return Response.json("I am worker");
    });
    };
…
6
Updated: October 30, 2024