mirror of
https://github.com/webstudio-is/webstudio.git
synced 2026-10-30 16:47:54 +09:00
Another layer in sync engine is composable storage. Now you can specify a chain of storages. Each can listen transactions to update some state. Though subscription for state is invoked one by one until non-undefined is provided. See tests to understand API. Here I also migrated our server data loading and synchronization to this storage api.
89 lines
2.6 KiB
TypeScript
89 lines
2.6 KiB
TypeScript
import { getStyleDeclKey, type WebstudioData } from "@webstudio-is/sdk";
|
|
import type { MarketplaceProduct } from "@webstudio-is/project-build";
|
|
import type { loader } from "~/routes/rest.data.$projectId";
|
|
import {
|
|
$assets,
|
|
$breakpoints,
|
|
$dataSources,
|
|
$instances,
|
|
$marketplaceProduct,
|
|
$pages,
|
|
$props,
|
|
$resources,
|
|
$styleSourceSelections,
|
|
$styleSources,
|
|
$styles,
|
|
} from "./nano-states";
|
|
import { fetch } from "~/shared/fetch.client";
|
|
|
|
export type BuilderData = WebstudioData & {
|
|
marketplaceProduct: undefined | MarketplaceProduct;
|
|
};
|
|
|
|
export const getBuilderData = (): BuilderData => {
|
|
const pages = $pages.get();
|
|
if (pages === undefined) {
|
|
throw Error(`Cannot get webstudio data with empty pages`);
|
|
}
|
|
return {
|
|
pages,
|
|
instances: $instances.get(),
|
|
props: $props.get(),
|
|
dataSources: $dataSources.get(),
|
|
resources: $resources.get(),
|
|
breakpoints: $breakpoints.get(),
|
|
styleSourceSelections: $styleSourceSelections.get(),
|
|
styleSources: $styleSources.get(),
|
|
styles: $styles.get(),
|
|
assets: $assets.get(),
|
|
marketplaceProduct: $marketplaceProduct.get(),
|
|
};
|
|
};
|
|
|
|
const getPair = <Item extends { id: string }>(item: Item) =>
|
|
[item.id, item] as const;
|
|
|
|
export const loadBuilderData = async ({
|
|
projectId,
|
|
signal,
|
|
}: {
|
|
projectId: string;
|
|
signal: AbortSignal;
|
|
}) => {
|
|
const currentUrl = new URL(location.href);
|
|
const url = new URL(`/rest/data/${projectId}`, currentUrl.origin);
|
|
const headers = new Headers();
|
|
const response = await fetch(url, { headers, signal });
|
|
|
|
if (response.ok) {
|
|
const data: Awaited<ReturnType<typeof loader>> = await response.json();
|
|
return {
|
|
version: data.version,
|
|
assets: new Map(data.assets.map(getPair)),
|
|
instances: new Map(data.instances.map(getPair)),
|
|
dataSources: new Map(data.dataSources.map(getPair)),
|
|
resources: new Map(data.resources.map(getPair)),
|
|
props: new Map(data.props.map(getPair)),
|
|
pages: data.pages,
|
|
breakpoints: new Map(data.breakpoints.map(getPair)),
|
|
styleSources: new Map(data.styleSources.map(getPair)),
|
|
styleSourceSelections: new Map(
|
|
data.styleSourceSelections.map((item) => [item.instanceId, item])
|
|
),
|
|
styles: new Map(data.styles.map((item) => [getStyleDeclKey(item), item])),
|
|
marketplaceProduct: data.marketplaceProduct,
|
|
} satisfies BuilderData & { version: number };
|
|
}
|
|
|
|
const text = await response.text();
|
|
|
|
// No toasts available in this context
|
|
alert(
|
|
`Unable to load builder data. Response status: ${response.status}. Response text: ${text}`
|
|
);
|
|
|
|
throw Error(
|
|
`Unable to load builder data. Response status: ${response.status}. Response text: ${text}`
|
|
);
|
|
};
|