Flowcesinha - utility libraries for Cloudflare Workflows

type Env = {
	// Add your bindings here, e.g. Workers KV, D1, Workers AI, etc.
	MY_WORKFLOW: Workflow;
	R2_BUCKET: R2Bucket;
};
export class MyWorkflow extends WorkflowEntrypoint<Env, Params> {
	async run(event: WorkflowEvent<Params>, step: WorkflowStep) {
		return useFlowcesinha(
			{
				ctx: this.ctx,
				env: this.env,
				event,
				step,
				workflowName: this.constructor.name, // equivalent to writing "MyWorkflow"
				options: {
					storageEngine: new R2Storage(this.env.R2_BUCKET),
					errorReporter: new SentryErrorReporting({
						context: this.ctx,
						dsn: 'YOUR-SENTRY-DSN',
					}),
					globalFailureHandler: (error) => {
						console.log('Workflow failed!', error);
					},
				},
			},
			async (event, step) => {
				// Because we are using a storage engine, everything that is a step is stored in it, which means that
				// we can store more than 1MiB of state per step
				const providersResp = await step.fetch("Get providers for flight", "https://flight-searcher/providers");

				const providers = await providersResp.json();

				const cheapestFlight = await step.do("Choose cheapest flight", async () => {
					// assume that you have calculated the cheapest flight here
					return "LIS-LAX";
				});

				await step.reversableDo("Book flight", async () => {
					// assume that we have done some API call to the provider to reserve the flight
					return await cheapestFlight.getFull()
				}, async () => {
					// if the workflow fails after this step, it will run this callback so that, you can cancel the flight booking
				});

				await step.reversableDo("Book hotel", async () => {
					// assume that we have done some API call to the provider to reserve the hotel
					return "Hilton"
				}, async () => {
					// if the workflow fails after this step, it will run this callback so that, you can cancel the hotel booking
				});

				return 'finished';
			},
		);
	}
}