/** * Copyright (c) Meta Platforms, Inc. and affiliates. * * This source code is licensed under the MIT license found in the * LICENSE file in the root directory of this source tree. * * @flow */ import type {Thenable, ReactFormState} from 'shared/ReactTypes'; import type { ServerManifest, ClientReference as ServerReference, } from 'react-client/src/ReactFlightClientConfig'; import { resolveServerReference, preloadModule, requireModule, } from 'react-client/src/ReactFlightClientConfig'; import {createResponse, close, getRoot} from './ReactFlightReplyServer'; type ServerReferenceId = any; function bindArgs(fn: any, args: any) { return fn.bind.apply(fn, [null].concat(args)); } function loadServerReference( bundlerConfig: ServerManifest, id: ServerReferenceId, bound: null | Thenable>, ): Promise { const serverReference: ServerReference = resolveServerReference<$FlowFixMe>(bundlerConfig, id); // We expect most servers to not really need this because you'd just have all // the relevant modules already loaded but it allows for lazy loading of code // if needed. const preloadPromise = preloadModule(serverReference); if (bound) { return Promise.all([(bound: any), preloadPromise]).then( ([args]: Array) => bindArgs(requireModule(serverReference), args), ); } else if (preloadPromise) { return Promise.resolve(preloadPromise).then(() => requireModule(serverReference), ); } else { // Synchronously available return Promise.resolve(requireModule(serverReference)); } } function decodeBoundActionMetaData( body: FormData, serverManifest: ServerManifest, formFieldPrefix: string, ): {id: ServerReferenceId, bound: null | Promise>} { // The data for this reference is encoded in multiple fields under this prefix. const actionResponse = createResponse(serverManifest, formFieldPrefix, body); close(actionResponse); const refPromise = getRoot<{ id: ServerReferenceId, bound: null | Promise>, }>(actionResponse); // Force it to initialize // $FlowFixMe refPromise.then(() => {}); if (refPromise.status !== 'fulfilled') { // $FlowFixMe throw refPromise.reason; } return refPromise.value; } export function decodeAction( body: FormData, serverManifest: ServerManifest, ): Promise<() => T> | null { // We're going to create a new formData object that holds all the fields except // the implementation details of the action data. const formData = new FormData(); let action: Promise<(formData: FormData) => T> | null = null; // $FlowFixMe[prop-missing] body.forEach((value: string | File, key: string) => { if (!key.startsWith('$ACTION_')) { formData.append(key, value); return; } // Later actions may override earlier actions if a button is used to override the default // form action. if (key.startsWith('$ACTION_REF_')) { const formFieldPrefix = '$ACTION_' + key.slice(12) + ':'; const metaData = decodeBoundActionMetaData( body, serverManifest, formFieldPrefix, ); action = loadServerReference(serverManifest, metaData.id, metaData.bound); return; } if (key.startsWith('$ACTION_ID_')) { const id = key.slice(11); action = loadServerReference(serverManifest, id, null); return; } }); if (action === null) { return null; } // Return the action with the remaining FormData bound to the first argument. return action.then(fn => fn.bind(null, formData)); } export function decodeFormState( actionResult: S, body: FormData, serverManifest: ServerManifest, ): Promise | null> { const keyPath = body.get('$ACTION_KEY'); if (typeof keyPath !== 'string') { // This form submission did not include any form state. return Promise.resolve(null); } // Search through the form data object to get the reference id and the number // of bound arguments. This repeats some of the work done in decodeAction. let metaData = null; // $FlowFixMe[prop-missing] body.forEach((value: string | File, key: string) => { if (key.startsWith('$ACTION_REF_')) { const formFieldPrefix = '$ACTION_' + key.slice(12) + ':'; metaData = decodeBoundActionMetaData( body, serverManifest, formFieldPrefix, ); } // We don't check for the simple $ACTION_ID_ case because form state actions // are always bound to the state argument. }); if (metaData === null) { // Should be unreachable. return Promise.resolve(null); } const referenceId = metaData.id; return Promise.resolve(metaData.bound).then(bound => { if (bound === null) { // Should be unreachable because form state actions are always bound to the // state argument. return null; } // The form action dispatch method is always bound to the initial state. // But when comparing signatures, we compare to the original unbound action. // Subtract one from the arity to account for this. const boundArity = bound.length - 1; return [actionResult, keyPath, referenceId, boundArity]; }); }