Type-safe building blocks for real backends.

import { Api } from "semola/api";import { z } from "zod";const api = new Api();api.defineRoute({  path: "/hello/:name",  method: "GET",  request: {    params: z.object({ name: z.string() }),  },  response: {    200: z.object({ message: z.string() }),  },  handler: async (c) => {    return c.json(200, {      message: `Hello, ${c.req.params.name}!`,    });  },});api.serve(3000);

import { Cache } from "semola/cache";const users = new Cache<{ name: string; email: string }>({  redis: redisClient,  ttl: 60_000,  prefix: "user",});await users.set("1", {  name: "Ada",  email: "ada@example.com",});const user = await users.get("1");

import { Cron } from "semola/cron";const daily = new Cron({  name: "daily-report",  schedule: "@daily",  handler: async () => {    await sendReport();  },});daily.run();

import { mightThrow } from "semola/errors";const [error, data] = await mightThrow(  fetch("https://api.example.com"),);if (error) {  console.error(error.message);  return;}console.log(data);

import { I18n } from "semola/i18n";const i18n = new I18n({  defaultLocale: "en",  locales: {    en: {      welcome: "Welcome, {name:string}!",    },    es: {      welcome: "Bienvenido, {name:string}!",    },  },});i18n.setLocale("es");i18n.translate("welcome", { name: "Ada" });

import { Logger, ConsoleProvider } from "semola/logging";const log = new Logger("api", [new ConsoleProvider()]);log.info("server started");log.warning("slow query");log.error("request failed");

import {  createOrm,  defineTable,  string,  uuid,} from "semola/orm";const users = defineTable({  sqlName: "users",  columns: {    id: uuid("id").primaryKey().notNull(),    email: string("email").unique().notNull(),  },});const db = createOrm({  adapter: "sqlite",  url: ":memory:",  tables: { users },});const user = await db.users.findFirst({  where: { email: "hi@semola.dev" },});

import { Policy, eq } from "semola/policy";type Post = {  id: number;  authorId: number;  status: "draft" | "published";};const posts = new Policy<Post>();posts.allow({  action: "read",  conditions: { status: eq("published") },});posts.allow({  action: ["update", "delete"],  conditions: { authorId: eq(user.id) },});const canEdit = posts.can("update", post);

import { PubSub } from "semola/pubsub";type UserEvent = {  userId: string;  action: "login" | "logout";};const events = new PubSub<UserEvent>({  subscriber: redisSubscriber,  publisher: redisPublisher,  channel: "user-events",});await events.subscribe(async (message) => {  console.log(message.userId, message.action);});await events.publish({  userId: "123",  action: "login",});

import { Queue } from "semola/queue";const emails = new Queue({  name: "emails",  redis: redisClient,  concurrency: 4,  retries: 3,  handler: async (data) => {    await sendEmail(data.to, data.subject);  },});await emails.enqueue({  to: "user@example.com",  subject: "Welcome",});

import { defineWorkflow } from "semola/workflow";const fulfillOrder = defineWorkflow<{ orderId: string }>({  name: "fulfill-order",  redis: redisClient,  handler: async ({ input, step }) => {    const payment = await step("charge", async () => {      return charge(input.orderId);    });    await step("ship", async () => {      await ship(payment.orderId);    });  },});await fulfillOrder.start({ orderId: "ord_123" });