File Explorer

/proc/self/root/var/runtime/node_modules/@aws-sdk/middleware-eventstream/dist-cjs

This explorer reads the filesystem of the server it runs on, so /workspace/user isn't present here. Browsing and the terminal still work against this server's own disk from /.

index.js2.2 KB · 66 lines
'use strict'; var protocols = require('@smithy/core/protocols'); function resolveEventStreamConfig(input) {    const eventSigner = input.signer;    const messageSigner = input.signer;    const newInput = Object.assign(input, {        eventSigner,        messageSigner,    });    const eventStreamPayloadHandler = newInput.eventStreamPayloadHandlerProvider(newInput);    return Object.assign(newInput, {        eventStreamPayloadHandler,    });} const eventStreamHandlingMiddleware = (options) => (next, context) => async (args) => {    const { request } = args;    if (!protocols.HttpRequest.isInstance(request))        return next(args);    return options.eventStreamPayloadHandler.handle(next, args, context);};const eventStreamHandlingMiddlewareOptions = {    tags: ["EVENT_STREAM", "SIGNATURE", "HANDLE"],    name: "eventStreamHandlingMiddleware",    relation: "after",    toMiddleware: "awsAuthMiddleware",    override: true,}; const eventStreamHeaderMiddleware = (next) => async (args) => {    const { request } = args;    if (!protocols.HttpRequest.isInstance(request))        return next(args);    request.headers = {        ...request.headers,        "content-type": "application/vnd.amazon.eventstream",        "x-amz-content-sha256": "STREAMING-AWS4-HMAC-SHA256-EVENTS",    };    return next({        ...args,        request,    });};const eventStreamHeaderMiddlewareOptions = {    step: "build",    tags: ["EVENT_STREAM", "HEADER", "CONTENT_TYPE", "CONTENT_SHA256"],    name: "eventStreamHeaderMiddleware",    override: true,}; const getEventStreamPlugin = (options) => ({    applyToStack: (clientStack) => {        clientStack.addRelativeTo(eventStreamHandlingMiddleware(options), eventStreamHandlingMiddlewareOptions);        clientStack.add(eventStreamHeaderMiddleware, eventStreamHeaderMiddlewareOptions);    },}); exports.eventStreamHandlingMiddleware = eventStreamHandlingMiddleware;exports.eventStreamHandlingMiddlewareOptions = eventStreamHandlingMiddlewareOptions;exports.eventStreamHeaderMiddleware = eventStreamHeaderMiddleware;exports.eventStreamHeaderMiddlewareOptions = eventStreamHeaderMiddlewareOptions;exports.getEventStreamPlugin = getEventStreamPlugin;exports.resolveEventStreamConfig = resolveEventStreamConfig;