diff --git a/console/src/oapi/management.generated.ts b/console/src/oapi/management.generated.ts
index 4e93e696..8828f0aa 100644
--- a/console/src/oapi/management.generated.ts
+++ b/console/src/oapi/management.generated.ts
@@ -2219,6 +2219,8 @@ export interface components {
             provider_id?: string;
             /** Format: uuid */
             subscription_id?: string;
+            /** @example false */
+            transactional?: boolean;
         };
         UpdateCampaign: {
             /** @example epic hopper */
@@ -2228,6 +2230,10 @@ export interface components {
              * @example 5143f27c-cca9-4dc4-9059-e1dbb08144ad
              */
             provider_id?: string;
+            /** Format: uuid */
+            subscription_id?: string;
+            /** @example false */
+            transactional?: boolean;
             variables?: components["schemas"]["CampaignVariable"][];
         };
         CampaignVariable: {
@@ -2303,6 +2309,8 @@ export interface components {
             channel: components["schemas"]["Channel"];
             /** Format: uuid */
             subscription_id?: string;
+            /** @example false */
+            transactional: boolean;
             provider?: components["schemas"]["Provider"];
             templates: components["schemas"]["Template"][];
             variables?: components["schemas"]["CampaignVariable"][];
diff --git a/console/src/types.ts b/console/src/types.ts
index 148d415f..8df5a958 100644
--- a/console/src/types.ts
+++ b/console/src/types.ts
@@ -580,6 +580,7 @@ export interface Campaign {
     provider?: OAPIProvider
     subscription_id?: UUID
     subscription?: Subscription
+    transactional?: boolean
     templates: Template[]
     variables: CampaignVariable[]
     created_at: string
@@ -589,9 +590,12 @@ export interface Campaign {
 export type CampaignSendState = "pending" | "sent" | "throttled" | "failed" | "bounced" | "aborted"
 
 export type CampaignUpdateParams = Partial<
-    Pick<Campaign, "name" | "provider_id" | "subscription_id" | "variables">
+    Pick<Campaign, "name" | "provider_id" | "subscription_id" | "transactional" | "variables">
+>
+export type CampaignCreateParams = Pick<
+    Campaign,
+    "name" | "channel" | "subscription_id" | "transactional"
 >
-export type CampaignCreateParams = Pick<Campaign, "name" | "channel">
 export type CampaignUser = User & { state: CampaignSendState; send_at: string }
 
 interface NamedEmail {
diff --git a/console/src/views/campaign/CampaignDetails.tsx b/console/src/views/campaign/CampaignDetails.tsx
index 4039bbfc..16d904d5 100644
--- a/console/src/views/campaign/CampaignDetails.tsx
+++ b/console/src/views/campaign/CampaignDetails.tsx
@@ -1,11 +1,12 @@
-import { useContext, useState, useEffect } from "react"
+import { useCallback, useContext, useMemo, useState, useEffect } from "react"
 import { CampaignContext, ProjectContext, TemplateContext } from "@/contexts"
-import type { Campaign, Template, User } from "@/types"
+import type { Campaign, Template, Subscription } from "@/types"
 import { useTranslation } from "react-i18next"
 import { Controller, useForm } from "react-hook-form"
 import { z } from "zod"
 import { zodResolver } from "@hookform/resolvers/zod"
-import api from "@/api"
+import oapiClient from "@/oapi/client"
+import { useResolver } from "@/hooks"
 
 import { channels } from "./template/channels"
 import { CampaignVariables } from "./CampaignVariables"
@@ -16,6 +17,15 @@ import { Field, FieldDescription, FieldError, FieldGroup, FieldLabel } from "@/c
 import { Input } from "@/components/ui/input"
 import { Button } from "@/components/ui/button"
 import { ProviderSelect } from "@/components/provider/select"
+import { Switch } from "@/components/ui/switch"
+import { Label } from "@/components/ui/label"
+import {
+    Select,
+    SelectContent,
+    SelectItem,
+    SelectTrigger,
+    SelectValue,
+} from "@/components/ui/select"
 
 const campaignVariableSchema = z.object({
     name: z.string(),
@@ -36,6 +46,28 @@ function CampaignReview({ campaign, template }: { campaign: Campaign; template:
     const [, setCampaign] = useContext(CampaignContext)
     const templateState = useState<Template>(template)
     const [isSubmitting, setIsSubmitting] = useState(false)
+    const [isTransactional, setTransactional] = useState(campaign.transactional ?? false)
+    const [subscriptionId, setSubscriptionId] = useState<string>(campaign.subscription_id ?? "")
+
+    const [subscriptions] = useResolver(
+        useCallback(async (): Promise<Subscription[]> => {
+            if (!project?.id) return []
+            const { data } = await oapiClient.GET("/api/admin/projects/{projectID}/subscriptions", {
+                params: {
+                    path: { projectID: project.id },
+                    query: { limit: 100 },
+                },
+            })
+            return data?.results ?? []
+        }, [project?.id]),
+    )
+
+    const filteredSubscriptions = useMemo(() => {
+        if (!subscriptions) return []
+        return subscriptions.filter((s) => {
+            return s.channel === campaign.channel
+        })
+    }, [subscriptions, campaign.channel])
 
     const form = useForm<CampaignReviewFormData>({
         resolver: zodResolver(campaignSchema),
@@ -59,13 +91,44 @@ function CampaignReview({ campaign, template }: { campaign: Campaign; template:
 
         setIsSubmitting(true)
         try {
-            const updatedCampaign = await api.campaigns.update(project.id, campaign.id, {
-                name: data.name,
-                ...(data.provider_id ? { provider_id: data.provider_id } : {}),
-                variables: data.variables.filter((v) => v.name),
-            })
+            const { data: updatedCampaign } = await oapiClient.PATCH(
+                "/api/admin/projects/{projectID}/campaigns/{campaignID}",
+                {
+                    params: {
+                        path: { projectID: project.id, campaignID: campaign.id },
+                    },
+                    body: {
+                        name: data.name,
+                        ...(data.provider_id ? { provider_id: data.provider_id } : {}),
+                        transactional: isTransactional,
+                        subscription_id: isTransactional ? undefined : subscriptionId || undefined,
+                        variables: data.variables.filter((v) => v.name),
+                    },
+                },
+            )
 
-            setCampaign(updatedCampaign)
+            if (updatedCampaign) {
+                setCampaign((prevCampaign) => ({
+                    ...prevCampaign,
+                    name: updatedCampaign.name,
+                    updated_at: updatedCampaign.updated_at,
+                    delivery: updatedCampaign.delivery,
+                    subscription_id: updatedCampaign.subscription_id,
+                    transactional: updatedCampaign.transactional,
+                    provider: updatedCampaign.provider
+                        ? {
+                              ...prevCampaign.provider,
+                              ...updatedCampaign.provider,
+                              data:
+                                  updatedCampaign.provider.data ??
+                                  prevCampaign.provider?.data ??
+                                  {},
+                              setup: prevCampaign.provider?.setup ?? [],
+                          }
+                        : undefined,
+                    variables: updatedCampaign.variables ?? [],
+                }))
+            }
         } finally {
             setIsSubmitting(false)
         }
@@ -133,6 +196,69 @@ function CampaignReview({ campaign, template }: { campaign: Campaign; template:
                                 />
                             </FieldGroup>
 
+                            <div className="flex items-center justify-between rounded-md border p-3">
+                                <div className="space-y-1">
+                                    <Label htmlFor="transactional-toggle">
+                                        {t("campaign.transactional", "Transactional")}
+                                    </Label>
+                                    <p className="text-sm text-muted-foreground">
+                                        {t(
+                                            "campaign.transactional.help",
+                                            "When enabled, subscription preference is ignored.",
+                                        )}
+                                    </p>
+                                </div>
+                                <Switch
+                                    id="transactional-toggle"
+                                    checked={isTransactional}
+                                    onCheckedChange={(checked) => {
+                                        setTransactional(checked)
+                                        if (checked) setSubscriptionId("")
+                                    }}
+                                />
+                            </div>
+
+                            {!isTransactional && (
+                                <FieldGroup>
+                                    <Field className="gap-2">
+                                        <FieldLabel htmlFor="subscription-select">
+                                            {t("campaign.subscription", "Subscription")}
+                                        </FieldLabel>
+                                        <Select
+                                            value={subscriptionId}
+                                            onValueChange={setSubscriptionId}
+                                        >
+                                            <SelectTrigger id="subscription-select">
+                                                <SelectValue
+                                                    placeholder={t(
+                                                        "campaign.subscription.placeholder",
+                                                        "Select subscription",
+                                                    )}
+                                                />
+                                            </SelectTrigger>
+                                            <SelectContent className="z-[1100]">
+                                                {filteredSubscriptions.length === 0 && (
+                                                    <SelectItem value="__empty" disabled>
+                                                        {t(
+                                                            "campaign.subscription.empty",
+                                                            "No subscriptions for this channel",
+                                                        )}
+                                                    </SelectItem>
+                                                )}
+                                                {filteredSubscriptions.map((subscription) => (
+                                                    <SelectItem
+                                                        key={subscription.id}
+                                                        value={subscription.id}
+                                                    >
+                                                        {subscription.name}
+                                                    </SelectItem>
+                                                ))}
+                                            </SelectContent>
+                                        </Select>
+                                    </Field>
+                                </FieldGroup>
+                            )}
+
                             <FieldGroup>
                                 <Controller
                                     name="variables"
@@ -190,19 +316,8 @@ function CampaignReview({ campaign, template }: { campaign: Campaign; template:
 export default function CampaignDetails() {
     const [campaign] = useContext(CampaignContext)
     const [project] = useContext(ProjectContext)
-    const [selectedUser, setSelectedUser] = useState<User | null>(null)
     const [template, setTemplate] = useState<Template | null>(null)
 
-    useEffect(() => {
-        if (!selectedUser && project?.id) {
-            api.users.search(project.id, { limit: 1 }).then((result) => {
-                if (result.results && result.results.length > 0) {
-                    setSelectedUser(result.results[0])
-                }
-            })
-        }
-    }, [project?.id, selectedUser])
-
     useEffect(() => {
         if (!campaign || campaign.templates.length === 0) {
             return
diff --git a/console/src/views/campaign/Campaigns.tsx b/console/src/views/campaign/Campaigns.tsx
index f00a0cb2..d6e47186 100644
--- a/console/src/views/campaign/Campaigns.tsx
+++ b/console/src/views/campaign/Campaigns.tsx
@@ -14,8 +14,7 @@ import {
     Copy,
     Archive,
 } from "lucide-react"
-
-import api from "../../api"
+import { oapiClient } from "@/oapi/client"
 import { useResolver } from "../../hooks"
 import { formatDate, snakeToTitle } from "../../utils"
 import { getRandomColor } from "@/lib/colors"
@@ -26,7 +25,7 @@ import { CampaignsIcon } from "@/components/icons"
 
 import { CreateCampaign } from "./CreateCampaign"
 
-import type { Campaign, CampaignDelivery, ChannelType } from "@/types"
+import type { CampaignDelivery, ChannelType } from "@/types"
 import type { UUID } from "@/types/common"
 
 import { Button } from "@/components/ui/button"
@@ -49,7 +48,7 @@ import {
 
 const channelIcons: Record<ChannelType, typeof Mail> = {
     email: Mail,
-    text: Smartphone,
+    sms: Smartphone,
     push: MessageSquareDot,
 }
 
@@ -65,6 +64,7 @@ interface CampaignsProps {
 }
 
 export default function Campaigns({ create = false }: CampaignsProps) {
+    const pageSize = 25
     const [preferences] = useContext(PreferencesContext)
     const [project] = useContext(ProjectContext)
     const navigate = useNavigate()
@@ -72,16 +72,12 @@ export default function Campaigns({ create = false }: CampaignsProps) {
 
     const [searchQuery, setSearchQuery] = useState("")
     const [debouncedQuery, setDebouncedQuery] = useState("")
-    const [cursor, setCursor] = useState<string | undefined>()
-    const [pageDirection, setPageDirection] = useState<"next" | "prev" | undefined>()
-    const [cursorHistory, setCursorHistory] = useState<string[]>([])
-    const searchTimeoutRef = useRef<ReturnType<typeof setTimeout>>()
+    const [offset, setOffset] = useState(0)
+    const searchTimeoutRef = useRef<ReturnType<typeof setTimeout> | undefined>(undefined)
 
     const handleSearch = useCallback((value: string) => {
         setSearchQuery(value)
-        setCursor(undefined)
-        setPageDirection(undefined)
-        setCursorHistory([])
+        setOffset(0)
         clearTimeout(searchTimeoutRef.current)
         searchTimeoutRef.current = setTimeout(() => {
             setDebouncedQuery(value)
@@ -90,50 +86,79 @@ export default function Campaigns({ create = false }: CampaignsProps) {
 
     const [result, , reload] = useResolver(
         useCallback(async () => {
-            return await api.campaigns.search(project.id, {
-                limit: 25,
-                cursor,
-                page: pageDirection,
-                search: debouncedQuery || undefined,
+            const response = await oapiClient.GET("/api/admin/projects/{projectID}/campaigns", {
+                params: {
+                    path: {
+                        projectID: project.id,
+                    },
+                    query: {
+                        limit: pageSize,
+                        offset,
+                        search: debouncedQuery,
+                    },
+                },
             })
-        }, [project.id, debouncedQuery, cursor, pageDirection]),
+
+            return (
+                response.data ?? {
+                    results: [],
+                    total: 0,
+                    limit: pageSize,
+                    offset,
+                }
+            )
+        }, [project.id, debouncedQuery, offset]),
     )
 
     const campaigns = result?.results
-    const hasNextPage = !!result?.nextCursor
-    const hasPrevPage = cursorHistory.length > 0
+    const hasNextPage = !!result && offset + pageSize < result.total
+    const hasPrevPage = offset > 0
 
     const handleNextPage = () => {
-        if (result?.nextCursor) {
-            setCursorHistory((prev) => [...prev, cursor ?? ""])
-            setCursor(result.nextCursor)
-            setPageDirection("next")
+        if (hasNextPage) {
+            setOffset((prev) => prev + pageSize)
         }
     }
 
     const handlePrevPage = () => {
-        if (cursorHistory.length > 0) {
-            const prev = [...cursorHistory]
-            const prevCursor = prev.pop()
-            setCursorHistory(prev)
-            setCursor(prevCursor || undefined)
-            setPageDirection(prevCursor ? "next" : undefined)
+        if (hasPrevPage) {
+            setOffset((prev) => Math.max(0, prev - pageSize))
         }
     }
 
     const handleDuplicateCampaign = async (e: React.MouseEvent, id: UUID) => {
         e.stopPropagation()
-        const campaign = await api.campaigns.duplicate(project.id, id)
-        await navigate(`/projects/${project.id}/campaigns/${campaign.id.toString()}`)
+        const response = await oapiClient.POST(
+            "/api/admin/projects/{projectID}/campaigns/{campaignID}/duplicate",
+            {
+                params: {
+                    path: {
+                        projectID: project.id,
+                        campaignID: id,
+                    },
+                },
+            },
+        )
+
+        if (response.data?.id) {
+            navigate(`/projects/${project.id}/campaigns/${response.data.id}`)
+        }
     }
 
     const handleArchiveCampaign = async (e: React.MouseEvent, id: UUID) => {
         e.stopPropagation()
-        await api.campaigns.delete(project.id, id)
+        await oapiClient.DELETE("/api/admin/projects/{projectID}/campaigns/{campaignID}", {
+            params: {
+                path: {
+                    projectID: project.id,
+                    campaignID: id,
+                },
+            },
+        })
         await reload()
     }
 
-    const handleRowClick = (campaign: Campaign) => {
+    const handleRowClick = (campaign: { id: UUID } & unknown) => {
         navigate(`/projects/${project.id}/campaigns/${campaign.id.toString()}`)
     }
 
diff --git a/console/src/views/campaign/CreateCampaign.tsx b/console/src/views/campaign/CreateCampaign.tsx
index a8f871bc..e17077dd 100644
--- a/console/src/views/campaign/CreateCampaign.tsx
+++ b/console/src/views/campaign/CreateCampaign.tsx
@@ -1,11 +1,14 @@
 import { useTranslation } from "react-i18next"
 import { useNavigate } from "react-router"
 import { ProjectContext } from "@/contexts"
-import { useContext, useState } from "react"
+import { useCallback, useContext, useMemo, useState } from "react"
+import type { ReactNode } from "react"
+import { useResolver } from "@/hooks"
 
 import { Button } from "@/components/ui/button"
 import { ArrowRight, Mail, MessageSquareDot, PlusIcon, Smartphone } from "lucide-react"
 import type { ChannelType } from "@/types"
+import type { components } from "@/oapi/management.generated"
 
 import {
     Item,
@@ -25,12 +28,23 @@ import {
     DialogTitle,
     DialogTrigger,
 } from "@/components/ui/dialog"
-import api from "@/api"
+import { Label } from "@/components/ui/label"
+import {
+    Select,
+    SelectContent,
+    SelectItem,
+    SelectTrigger,
+    SelectValue,
+} from "@/components/ui/select"
+import { Switch } from "@/components/ui/switch"
+import { oapiClient } from "@/oapi/client"
+
+type Subscription = components["schemas"]["Subscription"]
 
 interface Channel {
     key: ChannelType
     color: string
-    icon: JSX.Element
+    icon: ReactNode
     title: string
     description: string
 }
@@ -46,16 +60,79 @@ export function CreateCampaign({ open = false, onBeforeCreate, trigger }: Create
     const navigate = useNavigate()
     const { t } = useTranslation()
     const [isOpen, setIsOpen] = useState(open)
+    const [selectedChannel, setSelectedChannel] = useState<ChannelType | null>(null)
+    const [transactional, setTransactional] = useState(false)
+    const [subscriptionId, setSubscriptionId] = useState<string>("")
+
+    const [subscriptions] = useResolver(
+        useCallback(async (): Promise<Subscription[]> => {
+            if (!project?.id) return []
+
+            const response = await oapiClient.GET("/api/admin/projects/{projectID}/subscriptions", {
+                params: {
+                    path: {
+                        projectID: project.id,
+                    },
+                    query: {
+                        limit: 100,
+                    },
+                },
+            })
+
+            if (response.error || !response.data?.results) {
+                return []
+            }
+
+            return response.data.results
+        }, [project?.id]),
+    )
+
+    const filteredSubscriptions = useMemo(() => {
+        if (!selectedChannel) return []
+        return (subscriptions ?? []).filter(
+            (subscription) => subscription.channel === selectedChannel,
+        )
+    }, [selectedChannel, subscriptions])
+
+    const subscriptionsLoading = subscriptions === null
+    async function create() {
+        if (!project?.id || !selectedChannel) {
+            return
+        }
 
-    async function create(channel: ChannelType) {
         if (onBeforeCreate) {
             await onBeforeCreate()
         }
-        const campaign = await api.campaigns.create(project.id, {
+
+        const body: {
+            name: string
+            channel: components["schemas"]["Channel"]
+            transactional?: boolean
+            subscription_id?: string
+        } = {
             name: generateProjectName(),
-            channel: channel,
+            channel: selectedChannel,
+            transactional,
+        }
+
+        if (transactional) {
+            body.subscription_id = undefined
+        } else if (subscriptionId) {
+            body.subscription_id = subscriptionId
+        }
+
+        const campaign = await oapiClient.POST("/api/admin/projects/{projectID}/campaigns", {
+            params: {
+                path: {
+                    projectID: project.id,
+                },
+            },
+            body,
         })
-        await navigate(`/projects/${project.id}/campaigns/${campaign.id}/setup`)
+
+        if (campaign.data?.id) {
+            navigate(`/projects/${project.id}/campaigns/${campaign.data.id}/setup`)
+        }
     }
 
     const channels: Array<Channel> = [
@@ -83,7 +160,7 @@ export function CreateCampaign({ open = false, onBeforeCreate, trigger }: Create
     ]
 
     return (
-        <Dialog open={isOpen} onOpenChange={() => setIsOpen(!isOpen)}>
+        <Dialog open={isOpen} onOpenChange={setIsOpen}>
             <DialogTrigger asChild>
                 {trigger ?? (
                     <Button size="lg">
@@ -102,7 +179,10 @@ export function CreateCampaign({ open = false, onBeforeCreate, trigger }: Create
                         <Item key={channel.key} variant="outline" className="items-center" asChild>
                             <a
                                 className="no-underline cursor-pointer"
-                                onClick={() => create(channel.key)}
+                                onClick={() => {
+                                    setSelectedChannel(channel.key)
+                                    setSubscriptionId("")
+                                }}
                             >
                                 <ItemMedia variant="icon" className={channel.color}>
                                     {channel.icon}
@@ -118,6 +198,76 @@ export function CreateCampaign({ open = false, onBeforeCreate, trigger }: Create
                         </Item>
                     ))}
                 </ItemGroup>
+
+                {selectedChannel && (
+                    <div className="mt-4 space-y-4">
+                        <div className="flex items-center justify-between rounded-md border p-3">
+                            <div className="space-y-1">
+                                <Label htmlFor="transactional-toggle">
+                                    {t("campaign.transactional", "Transactional")}
+                                </Label>
+                                <p className="text-sm text-muted-foreground">
+                                    {t(
+                                        "campaign.transactional.help",
+                                        "When enabled, subscription preference is ignored.",
+                                    )}
+                                </p>
+                            </div>
+                            <Switch
+                                id="transactional-toggle"
+                                checked={transactional}
+                                onCheckedChange={(checked) => {
+                                    setTransactional(checked)
+                                    if (checked) setSubscriptionId("")
+                                }}
+                            />
+                        </div>
+
+                        {!transactional && (
+                            <div className="space-y-2">
+                                <Label htmlFor="subscription-select">
+                                    {t("campaign.subscription", "Subscription")}
+                                </Label>
+                                <Select value={subscriptionId} onValueChange={setSubscriptionId}>
+                                    <SelectTrigger id="subscription-select">
+                                        <SelectValue
+                                            placeholder={t(
+                                                "campaign.subscription.placeholder",
+                                                "Select subscription",
+                                            )}
+                                        />
+                                    </SelectTrigger>
+                                    <SelectContent className="z-[1100]">
+                                        {subscriptionsLoading && (
+                                            <SelectItem value="__loading" disabled>
+                                                {t("loading", "Loading...")}
+                                            </SelectItem>
+                                        )}
+                                        {!subscriptionsLoading &&
+                                            filteredSubscriptions.length === 0 && (
+                                                <SelectItem value="__empty" disabled>
+                                                    {t(
+                                                        "campaign.subscription.empty",
+                                                        "No subscriptions for this channel",
+                                                    )}
+                                                </SelectItem>
+                                            )}
+                                        {filteredSubscriptions.map((subscription) => (
+                                            <SelectItem
+                                                key={subscription.id}
+                                                value={subscription.id}
+                                            >
+                                                {subscription.name}
+                                            </SelectItem>
+                                        ))}
+                                    </SelectContent>
+                                </Select>
+                            </div>
+                        )}
+
+                        <Button onClick={() => create()}>{t("campaign.create.action")}</Button>
+                    </div>
+                )}
             </DialogContent>
         </Dialog>
     )
diff --git a/console/src/views/campaign/setup/Setup.tsx b/console/src/views/campaign/setup/Setup.tsx
index 66c5387e..edd863f9 100644
--- a/console/src/views/campaign/setup/Setup.tsx
+++ b/console/src/views/campaign/setup/Setup.tsx
@@ -1,15 +1,26 @@
 import { Controller, useForm } from "react-hook-form"
-import { useContext, useState } from "react"
+import { useCallback, useContext, useMemo, useState } from "react"
 import { CampaignContext, ProjectContext } from "@/contexts"
 import { useTranslation } from "react-i18next"
 import api from "@/api"
+import { useResolver } from "@/hooks"
 import { z } from "zod"
 import { zodResolver } from "@hookform/resolvers/zod"
+import type { Subscription } from "@/types"
 
 import { Field, FieldDescription, FieldError, FieldGroup, FieldLabel } from "@/components/ui/field"
 import { Input } from "@/components/ui/input"
 import { ProviderSelect } from "@/components/provider/select"
 import { Button } from "@/components/ui/button"
+import { Switch } from "@/components/ui/switch"
+import { Label } from "@/components/ui/label"
+import {
+    Select,
+    SelectContent,
+    SelectItem,
+    SelectTrigger,
+    SelectValue,
+} from "@/components/ui/select"
 import { useNavigate } from "react-router"
 
 const schema = z.object({
@@ -25,6 +36,23 @@ export default function CampaignSetup() {
     const [project] = useContext(ProjectContext)
     const { t } = useTranslation()
     const navigate = useNavigate()
+    const [isTransactional, setTransactional] = useState(campaign.transactional ?? false)
+    const [subscriptionId, setSubscriptionId] = useState<string>(campaign.subscription_id ?? "")
+
+    const [subscriptions] = useResolver(
+        useCallback(async (): Promise<Subscription[]> => {
+            if (!project?.id) return []
+            const result = await api.subscriptions.search(project.id, { limit: 100 })
+            return result.results ?? []
+        }, [project?.id]),
+    )
+
+    const filteredSubscriptions = useMemo(() => {
+        return (subscriptions ?? []).filter((s) => {
+            const ch = (s.channel) === "sms" ? "text" : s.channel
+            return ch === campaign.channel
+        })
+    }, [subscriptions, campaign.channel])
 
     const form = useForm<FormData>({
         resolver: zodResolver(schema),
@@ -40,6 +68,8 @@ export default function CampaignSetup() {
             const updated = await api.campaigns.update(project.id, campaign.id, {
                 name: data.name,
                 provider_id: data.provider_id,
+                transactional: isTransactional,
+                subscription_id: isTransactional ? undefined : subscriptionId,
             })
 
             setCampaign(updated)
@@ -128,6 +158,66 @@ export default function CampaignSetup() {
                         />
                     </FieldGroup>
 
+                    <div className="flex items-center justify-between rounded-md border p-3">
+                        <div className="space-y-1">
+                            <Label htmlFor="transactional-toggle">
+                                {t("campaign.transactional", "Transactional")}
+                            </Label>
+                            <p className="text-sm text-muted-foreground">
+                                {t(
+                                    "campaign.transactional.help",
+                                    "When enabled, subscription preference is ignored.",
+                                )}
+                            </p>
+                        </div>
+                        <Switch
+                            id="transactional-toggle"
+                            checked={isTransactional}
+                            onCheckedChange={(checked) => {
+                                setTransactional(checked)
+                                if (checked) setSubscriptionId("")
+                            }}
+                        />
+                    </div>
+
+                    {!isTransactional && (
+                        <FieldGroup>
+                            <Field className="gap-2">
+                                <FieldLabel htmlFor="subscription-select">
+                                    {t("campaign.subscription", "Subscription")}
+                                </FieldLabel>
+                                <Select value={subscriptionId} onValueChange={setSubscriptionId}>
+                                    <SelectTrigger id="subscription-select">
+                                        <SelectValue
+                                            placeholder={t(
+                                                "campaign.subscription.placeholder",
+                                                "Select subscription",
+                                            )}
+                                        />
+                                    </SelectTrigger>
+                                    <SelectContent className="z-[1100]">
+                                        {filteredSubscriptions.length === 0 && (
+                                            <SelectItem value="__empty" disabled>
+                                                {t(
+                                                    "campaign.subscription.empty",
+                                                    "No subscriptions for this channel",
+                                                )}
+                                            </SelectItem>
+                                        )}
+                                        {filteredSubscriptions.map((subscription) => (
+                                            <SelectItem
+                                                key={subscription.id}
+                                                value={subscription.id}
+                                            >
+                                                {subscription.name}
+                                            </SelectItem>
+                                        ))}
+                                    </SelectContent>
+                                </Select>
+                            </Field>
+                        </FieldGroup>
+                    )}
+
                     <div className="flex justify-end">
                         <Button type="submit" isLoading={isSubmitting} disabled={isSubmitting}>
                             {t("actions.submit")}
diff --git a/console/src/views/campaign/template/mail/Setup.tsx b/console/src/views/campaign/template/mail/Setup.tsx
index d43c76ed..4fa8b3a7 100644
--- a/console/src/views/campaign/template/mail/Setup.tsx
+++ b/console/src/views/campaign/template/mail/Setup.tsx
@@ -5,7 +5,7 @@ import type { Campaign, Template, User, Locale } from "@/types"
 import { useTranslation } from "react-i18next"
 import { ProjectContext, TemplateContext } from "@/contexts"
 import { useNavigate } from "react-router"
-import api from "@/api"
+import oapiClient from "@/oapi/client"
 import * as z from "zod"
 import { Render } from "@/renderTemplates"
 import { compileEmail } from "./editor/codeEditor/compileEmail"
@@ -337,8 +337,13 @@ export function EmailContentPreview({ campaign, form, edit = false }: EmailSetup
     useEffect(() => {
         const fetchLocales = async () => {
             if (project?.id) {
-                const result = await api.locales.search(project.id, { limit: 100 })
-                setLocales(result.results)
+                const { data } = await oapiClient.GET("/api/admin/projects/{projectID}/locales", {
+                    params: {
+                        path: { projectID: project.id },
+                        query: { limit: 100 },
+                    },
+                })
+                setLocales(data?.results ?? [])
             }
         }
         fetchLocales()
diff --git a/internal/http/controllers/v1/management/campaigns.go b/internal/http/controllers/v1/management/campaigns.go
index 77931723..060a5251 100644
--- a/internal/http/controllers/v1/management/campaigns.go
+++ b/internal/http/controllers/v1/management/campaigns.go
@@ -66,6 +66,25 @@ func (srv *CampaignsController) CreateCampaign(w http.ResponseWriter, r *http.Re
 		return
 	}
 
+	if body.SubscriptionId != nil {
+		subscription, err := srv.mgmt.SubscriptionsStore.GetSubscription(ctx, projectID, *body.SubscriptionId)
+		if errors.Is(err, sql.ErrNoRows) {
+			oapi.WriteProblem(w, problem.ErrBadRequest(problem.Describe("subscription not found")))
+			return
+		}
+
+		if err != nil {
+			logger.Error("failed to get subscription", zap.Error(err))
+			oapi.WriteProblem(w, err)
+			return
+		}
+
+		if subscription.Channel != string(body.Channel) {
+			oapi.WriteProblem(w, problem.ErrBadRequest(problem.Describe("subscription channel does not match campaign channel")))
+			return
+		}
+	}
+
 	tx, err := srv.mgmtDB.BeginTxx(ctx, nil)
 	if err != nil {
 		logger.Error("unexpected error while attempting to start a transaction", zap.Error(err))
@@ -195,7 +214,7 @@ func (srv *CampaignsController) UpdateCampaign(w http.ResponseWriter, r *http.Re
 		return
 	}
 
-	_, err = srv.mgmt.GetCampaign(ctx, projectID, campaignID)
+	campaign, err := srv.mgmt.GetCampaign(ctx, projectID, campaignID)
 	if errors.Is(err, sql.ErrNoRows) {
 		logger.Info("campaign not found", zap.Stringer("campaign_id", campaignID))
 		oapi.WriteProblem(w, problem.ErrNotFound(problem.Describe("campaign not found")))
@@ -209,8 +228,10 @@ func (srv *CampaignsController) UpdateCampaign(w http.ResponseWriter, r *http.Re
 	}
 
 	updated := management.CampaignUpdate{
-		Name:       body.Name,
-		ProviderID: body.ProviderId,
+		Name:           body.Name,
+		ProviderID:     body.ProviderId,
+		SubscriptionID: body.SubscriptionId,
+		Transactional:  body.Transactional,
 	}
 
 	if body.Variables != nil {
@@ -224,6 +245,30 @@ func (srv *CampaignsController) UpdateCampaign(w http.ResponseWriter, r *http.Re
 		updated.Variables = &store.JSONB[management.CampaignVariables]{Data: vars}
 	}
 
+	if body.SubscriptionId != nil {
+		subscription, err := srv.mgmt.SubscriptionsStore.GetSubscription(ctx, projectID, *body.SubscriptionId)
+		if errors.Is(err, sql.ErrNoRows) {
+			oapi.WriteProblem(w, problem.ErrBadRequest(problem.Describe("subscription not found")))
+			return
+		}
+
+		if err != nil {
+			logger.Error("failed to get subscription", zap.Error(err))
+			oapi.WriteProblem(w, err)
+			return
+		}
+
+		if subscription.ProjectID != projectID {
+			oapi.WriteProblem(w, problem.ErrBadRequest(problem.Describe("subscription does not belong to this project")))
+			return
+		}
+
+		if subscription.Channel != campaign.Channel {
+			oapi.WriteProblem(w, problem.ErrBadRequest(problem.Describe("subscription channel does not match campaign channel")))
+			return
+		}
+	}
+
 	err = srv.mgmt.UpdateCampaign(ctx, projectID, campaignID, updated)
 	if err != nil {
 		logger.Error("failed to update campaign", zap.Error(err))
@@ -231,7 +276,7 @@ func (srv *CampaignsController) UpdateCampaign(w http.ResponseWriter, r *http.Re
 		return
 	}
 
-	campaign, err := srv.mgmt.GetCampaign(ctx, projectID, campaignID)
+	campaign, err = srv.mgmt.GetCampaign(ctx, projectID, campaignID)
 	if err != nil {
 		logger.Error("failed to fetch updated campaign", zap.Error(err))
 		oapi.WriteProblem(w, err)
@@ -319,6 +364,7 @@ func (srv *CampaignsController) DuplicateCampaign(w http.ResponseWriter, r *http
 		Channel:        campaign.Channel,
 		ProviderID:     campaign.ProviderID,
 		SubscriptionID: campaign.SubscriptionID,
+		Transactional:  campaign.Transactional,
 	})
 	if err != nil {
 		logger.Error("failed to create duplicated campaign", zap.Error(err))
diff --git a/internal/http/controllers/v1/management/campaigns_test.go b/internal/http/controllers/v1/management/campaigns_test.go
index b9a08584..23b5fc3e 100644
--- a/internal/http/controllers/v1/management/campaigns_test.go
+++ b/internal/http/controllers/v1/management/campaigns_test.go
@@ -48,6 +48,24 @@ func TestCampaignCreation(t *testing.T) {
 				Name:    "Welcome to the program!",
 			},
 		},
+		"subscription channel mismatch": {
+			body: func() oapi.CreateCampaignJSONRequestBody {
+				subscriptions := management.NewSubscriptionsStore(mgmt)
+				subscriptionID, err := subscriptions.CreateSubscription(ctx, management.Subscription{
+					ProjectID: projectID,
+					Name:      "Push Only",
+					Channel:   "push",
+					IsPublic:  true,
+				})
+				require.NoError(t, err)
+
+				return oapi.CreateCampaignJSONRequestBody{
+					Channel:        oapi.ChannelEmail,
+					Name:           "Welcome to the program!",
+					SubscriptionId: &subscriptionID,
+				}
+			}(),
+		},
 	}
 
 	for name, test := range tests {
@@ -60,7 +78,11 @@ func TestCampaignCreation(t *testing.T) {
 			req = req.WithContext(actorCtx)
 			campaigns.CreateCampaign(res, req, projectID)
 
-			require.Equal(t, 201, res.Code, res.Body.String())
+			expected := 201
+			if name == "subscription channel mismatch" {
+				expected = 400
+			}
+			require.Equal(t, expected, res.Code, res.Body.String())
 		})
 	}
 }
@@ -187,12 +209,22 @@ func TestGetCampaign(t *testing.T) {
 	require.NoError(t, err)
 
 	campaignsStore := management.NewCampaignsStore(mgmt)
+	subscriptionsStore := management.NewSubscriptionsStore(mgmt)
 	templates := management.NewTemplatesStore(mgmt)
 
-	campaignID, err := campaignsStore.CreateCampaign(ctx, management.Campaign{
+	subscriptionID, err := subscriptionsStore.CreateSubscription(ctx, management.Subscription{
 		ProjectID: projectID,
-		Name:      "Test Campaign",
+		Name:      "Marketing",
 		Channel:   "email",
+		IsPublic:  true,
+	})
+	require.NoError(t, err)
+
+	campaignID, err := campaignsStore.CreateCampaign(ctx, management.Campaign{
+		ProjectID:      projectID,
+		Name:           "Test Campaign",
+		Channel:        "email",
+		SubscriptionID: &subscriptionID,
 	})
 	require.NoError(t, err)
 
@@ -247,12 +279,41 @@ func TestUpdateCampaign(t *testing.T) {
 	require.NoError(t, err)
 
 	campaignsStore := management.NewCampaignsStore(mgmt)
+	subscriptionsStore := management.NewSubscriptionsStore(mgmt)
 	templates := management.NewTemplatesStore(mgmt)
 
-	campaignID, err := campaignsStore.CreateCampaign(ctx, management.Campaign{
+	subscriptionID, err := subscriptionsStore.CreateSubscription(ctx, management.Subscription{
 		ProjectID: projectID,
-		Name:      "Test Campaign",
+		Name:      "Marketing",
+		Channel:   "email",
+		IsPublic:  true,
+	})
+	require.NoError(t, err)
+
+	campaignID, err := campaignsStore.CreateCampaign(ctx, management.Campaign{
+		ProjectID:      projectID,
+		Name:           "Test Campaign",
+		Channel:        "email",
+		SubscriptionID: &subscriptionID,
+	})
+	require.NoError(t, err)
+
+	otherProjectID, err := projects.CreateProject(ctx, DefaultProject)
+	require.NoError(t, err)
+
+	otherProjectSubscriptionID, err := subscriptionsStore.CreateSubscription(ctx, management.Subscription{
+		ProjectID: otherProjectID,
+		Name:      "Other Project",
 		Channel:   "email",
+		IsPublic:  true,
+	})
+	require.NoError(t, err)
+
+	pushSubscriptionID, err := subscriptionsStore.CreateSubscription(ctx, management.Subscription{
+		ProjectID: projectID,
+		Name:      "Push Alerts",
+		Channel:   "push",
+		IsPublic:  true,
 	})
 	require.NoError(t, err)
 
@@ -268,15 +329,43 @@ func TestUpdateCampaign(t *testing.T) {
 	controller := NewCampaignsController(logger, mgmt, usrs, engine)
 
 	tests := map[string]struct {
-		id   uuid.UUID
-		body oapi.UpdateCampaignJSONRequestBody
-		code int
+		id     uuid.UUID
+		body   oapi.UpdateCampaignJSONRequestBody
+		code   int
+		assert func(t *testing.T)
 	}{
 		"success": {
 			id:   campaignID,
 			body: oapi.UpdateCampaignJSONRequestBody{Name: ptr("Updated Name")},
 			code: 200,
 		},
+		"transactional clears subscription": {
+			id:   campaignID,
+			body: oapi.UpdateCampaignJSONRequestBody{Transactional: ptr(true)},
+			code: 200,
+			assert: func(t *testing.T) {
+				t.Helper()
+
+				updated, err := campaignsStore.GetCampaign(ctx, projectID, campaignID)
+				require.NoError(t, err)
+				require.True(t, updated.Transactional)
+				require.Nil(t, updated.SubscriptionID)
+			},
+		},
+		"rejects cross project subscription": {
+			id: campaignID,
+			body: oapi.UpdateCampaignJSONRequestBody{
+				SubscriptionId: &otherProjectSubscriptionID,
+			},
+			code: 400,
+		},
+		"rejects mismatched subscription channel": {
+			id: campaignID,
+			body: oapi.UpdateCampaignJSONRequestBody{
+				SubscriptionId: &pushSubscriptionID,
+			},
+			code: 400,
+		},
 		"not found": {
 			id:   uuid.Nil,
 			body: oapi.UpdateCampaignJSONRequestBody{Name: ptr("Updated Name")},
@@ -295,6 +384,10 @@ func TestUpdateCampaign(t *testing.T) {
 			controller.UpdateCampaign(res, req, projectID, test.id)
 
 			require.Equal(t, test.code, res.Code, res.Body.String())
+
+			if test.assert != nil {
+				test.assert(t)
+			}
 		})
 	}
 }
@@ -379,9 +472,10 @@ func TestDuplicateCampaign(t *testing.T) {
 	templates := management.NewTemplatesStore(mgmt)
 
 	campaignID, err := campaignsStore.CreateCampaign(ctx, management.Campaign{
-		ProjectID: projectID,
-		Name:      "Original Campaign",
-		Channel:   "email",
+		ProjectID:     projectID,
+		Name:          "Original Campaign",
+		Channel:       "email",
+		Transactional: true,
 	})
 	require.NoError(t, err)
 
@@ -427,6 +521,7 @@ func TestDuplicateCampaign(t *testing.T) {
 				require.NotEqual(t, test.id, response.Id)
 				require.Equal(t, "Copy of Original Campaign", response.Name)
 				require.Equal(t, projectID, response.ProjectId)
+				require.True(t, response.Transactional)
 				require.Len(t, response.Templates, 1)
 			}
 		})
diff --git a/internal/http/controllers/v1/management/oapi/resources.yml b/internal/http/controllers/v1/management/oapi/resources.yml
index 237b0ac3..bf15762e 100644
--- a/internal/http/controllers/v1/management/oapi/resources.yml
+++ b/internal/http/controllers/v1/management/oapi/resources.yml
@@ -5122,6 +5122,9 @@ components:
         subscription_id:
           type: string
           format: uuid
+        transactional:
+          type: boolean
+          example: false
 
     UpdateCampaign:
       type: object
@@ -5133,6 +5136,12 @@ components:
           type: string
           format: uuid
           example: "5143f27c-cca9-4dc4-9059-e1dbb08144ad"
+        subscription_id:
+          type: string
+          format: uuid
+        transactional:
+          type: boolean
+          example: false
         variables:
           type: array
           items:
@@ -5211,6 +5220,7 @@ components:
         - channel
         - templates
         - delivery
+        - transactional
         - created_at
         - updated_at
       properties:
@@ -5237,6 +5247,9 @@ components:
         subscription_id:
           type: string
           format: uuid
+        transactional:
+          type: boolean
+          example: false
         provider:
           $ref: "#/components/schemas/Provider"
         templates:
diff --git a/internal/http/controllers/v1/management/oapi/resources_gen.go b/internal/http/controllers/v1/management/oapi/resources_gen.go
index 1be696dd..eefdb7ab 100644
--- a/internal/http/controllers/v1/management/oapi/resources_gen.go
+++ b/internal/http/controllers/v1/management/oapi/resources_gen.go
@@ -286,6 +286,7 @@ type Campaign struct {
 	Provider       *Provider           `json:"provider,omitempty"`
 	SubscriptionId *openapi_types.UUID `json:"subscription_id,omitempty"`
 	Templates      []Template          `json:"templates"`
+	Transactional  bool                `json:"transactional"`
 	UpdatedAt      time.Time           `json:"updated_at"`
 	Variables      *[]CampaignVariable `json:"variables,omitempty"`
 }
@@ -355,6 +356,7 @@ type CreateCampaign struct {
 	Name           string              `json:"name"`
 	ProviderId     *openapi_types.UUID `json:"provider_id,omitempty"`
 	SubscriptionId *openapi_types.UUID `json:"subscription_id,omitempty"`
+	Transactional  *bool               `json:"transactional,omitempty"`
 }
 
 // CreateJourney defines model for CreateJourney.
@@ -1063,9 +1065,11 @@ type UpdateApiKey struct {
 
 // UpdateCampaign defines model for UpdateCampaign.
 type UpdateCampaign struct {
-	Name       *string             `json:"name,omitempty"`
-	ProviderId *openapi_types.UUID `json:"provider_id,omitempty"`
-	Variables  *[]CampaignVariable `json:"variables,omitempty"`
+	Name           *string             `json:"name,omitempty"`
+	ProviderId     *openapi_types.UUID `json:"provider_id,omitempty"`
+	SubscriptionId *openapi_types.UUID `json:"subscription_id,omitempty"`
+	Transactional  *bool               `json:"transactional,omitempty"`
+	Variables      *[]CampaignVariable `json:"variables,omitempty"`
 }
 
 // UpdateJourney defines model for UpdateJourney.
diff --git a/internal/pubsub/consumer/campaigns.go b/internal/pubsub/consumer/campaigns.go
index ad4663c7..25ef569c 100644
--- a/internal/pubsub/consumer/campaigns.go
+++ b/internal/pubsub/consumer/campaigns.go
@@ -6,6 +6,7 @@ import (
 	"errors"
 	"fmt"
 	"net/url"
+	"strings"
 	"time"
 
 	"github.com/lunogram/platform/internal/providers/channels"
@@ -110,13 +111,14 @@ func buildRenderData(publicURL string, user *subjects.User, campaign *management
 
 	data["now"] = time.Now()
 
-	data["preferences_url"] = fmt.Sprintf("%s/preferences/%s/%s", publicURL, campaign.ProjectID, user.ID)
+	baseURL := strings.TrimSuffix(publicURL, "/")
+	data["preferences_url"] = fmt.Sprintf("%s/preferences/%s/%s", baseURL, campaign.ProjectID, user.ID)
 
-	if campaign.SubscriptionID != nil {
+	if !campaign.Transactional && campaign.SubscriptionID != nil {
 		unsubLink := url.Values{}
 		unsubLink.Set("u", user.ID.String())
 		unsubLink.Set("c", campaign.ID.String())
-		data["unsubscribe_url"] = fmt.Sprintf("%s/unsubscribe/email?link=%s", publicURL, url.QueryEscape("?"+unsubLink.Encode()))
+		data["unsubscribe_url"] = fmt.Sprintf("%s/unsubscribe/email?link=%s", baseURL, url.QueryEscape("?"+unsubLink.Encode()))
 	}
 
 	return data
diff --git a/internal/pubsub/consumer/campaigns_test.go b/internal/pubsub/consumer/campaigns_test.go
new file mode 100644
index 00000000..e4ad8e96
--- /dev/null
+++ b/internal/pubsub/consumer/campaigns_test.go
@@ -0,0 +1,82 @@
+package consumer
+
+import (
+	"net/url"
+	"testing"
+
+	"github.com/google/uuid"
+	"github.com/lunogram/platform/internal/store/management"
+	"github.com/lunogram/platform/internal/store/subjects"
+	"github.com/stretchr/testify/require"
+)
+
+func TestBuildRenderDataIncludesUnsubscribeURLWhenSubscriptionLinked(t *testing.T) {
+	t.Parallel()
+
+	projectID := uuid.New()
+	campaignID := uuid.New()
+	subscriptionID := uuid.New()
+	userID := uuid.New()
+
+	campaign := &management.Campaign{
+		ID:             campaignID,
+		ProjectID:      projectID,
+		Transactional:  false,
+		SubscriptionID: &subscriptionID,
+	}
+	user := &subjects.User{ID: userID}
+
+	data := buildRenderData("https://example.com/", user, campaign, nil)
+
+	rawUnsubscribeURL, ok := data["unsubscribe_url"]
+	require.True(t, ok)
+
+	unsubscribeURL, ok := rawUnsubscribeURL.(string)
+	require.True(t, ok)
+
+	parsedURL, err := url.Parse(unsubscribeURL)
+	require.NoError(t, err)
+	require.Equal(t, "/unsubscribe/email", parsedURL.Path)
+
+	link := parsedURL.Query().Get("link")
+	require.NotEmpty(t, link)
+
+	parsedLink, err := url.Parse(link)
+	require.NoError(t, err)
+	require.Equal(t, userID.String(), parsedLink.Query().Get("u"))
+	require.Equal(t, campaignID.String(), parsedLink.Query().Get("c"))
+}
+
+func TestBuildRenderDataOmitsUnsubscribeURLWhenNotEligible(t *testing.T) {
+	t.Parallel()
+
+	projectID := uuid.New()
+	userID := uuid.New()
+	user := &subjects.User{ID: userID}
+
+	tests := map[string]*management.Campaign{
+		"transactional campaign": {
+			ID:             uuid.New(),
+			ProjectID:      projectID,
+			Transactional:  true,
+			SubscriptionID: func() *uuid.UUID { id := uuid.New(); return &id }(),
+		},
+		"no linked subscription": {
+			ID:             uuid.New(),
+			ProjectID:      projectID,
+			Transactional:  false,
+			SubscriptionID: nil,
+		},
+	}
+
+	for name, campaign := range tests {
+		campaign := campaign
+		t.Run(name, func(t *testing.T) {
+			t.Parallel()
+
+			data := buildRenderData("https://example.com", user, campaign, nil)
+			_, ok := data["unsubscribe_url"]
+			require.False(t, ok)
+		})
+	}
+}
diff --git a/internal/store/management/campaigns.go b/internal/store/management/campaigns.go
index ade1697f..d89269b1 100644
--- a/internal/store/management/campaigns.go
+++ b/internal/store/management/campaigns.go
@@ -33,6 +33,7 @@ type Campaign struct {
 	Channel        string                         `db:"channel"`
 	ProviderID     *uuid.UUID                     `db:"provider_id"`
 	SubscriptionID *uuid.UUID                     `db:"subscription_id"`
+	Transactional  bool                           `db:"transactional"`
 	Delivery       store.JSONB[Delivery]          `db:"delivery"`
 	Variables      store.JSONB[CampaignVariables] `db:"variables"`
 	Templates      Templates                      `db:"-"`
@@ -42,6 +43,15 @@ type Campaign struct {
 	DeletedAt      *time.Time                     `db:"deleted_at"`
 }
 
+func normalizeChannelToOAPI(channel string) oapi.Channel {
+	switch channel {
+	case "sms":
+		return oapi.ChannelSms
+	default:
+		return oapi.Channel(channel)
+	}
+}
+
 func (campaign Campaign) OAPI() oapi.Campaign {
 	variables := make([]oapi.CampaignVariable, len(campaign.Variables.Data))
 	for i, v := range campaign.Variables.Data {
@@ -55,8 +65,9 @@ func (campaign Campaign) OAPI() oapi.Campaign {
 		Id:             campaign.ID,
 		ProjectId:      campaign.ProjectID,
 		Name:           campaign.Name,
-		Channel:        oapi.Channel(campaign.Channel),
+		Channel:        normalizeChannelToOAPI(campaign.Channel),
 		SubscriptionId: campaign.SubscriptionID,
+		Transactional:  campaign.Transactional,
 		Delivery:       campaign.Delivery.Data.OAPI(),
 		Variables:      &variables,
 		Templates:      campaign.Templates.OAPI(),
@@ -104,12 +115,12 @@ type CampaignsStore struct {
 
 func (s *CampaignsStore) CreateCampaign(ctx context.Context, campaign Campaign) (uuid.UUID, error) {
 	stmt := `
-	INSERT INTO campaigns (project_id, name, channel, provider_id, subscription_id)
-	VALUES ($1, $2, $3, $4, $5)
+	INSERT INTO campaigns (project_id, name, channel, provider_id, subscription_id, transactional)
+	VALUES ($1, $2, $3, $4, $5, $6)
 	RETURNING id`
 
 	var id uuid.UUID
-	err := s.db.GetContext(ctx, &id, stmt, campaign.ProjectID, campaign.Name, campaign.Channel, campaign.ProviderID, campaign.SubscriptionID)
+	err := s.db.GetContext(ctx, &id, stmt, campaign.ProjectID, campaign.Name, campaign.Channel, campaign.ProviderID, campaign.SubscriptionID, campaign.Transactional)
 	if err != nil {
 		return uuid.Nil, err
 	}
@@ -119,7 +130,7 @@ func (s *CampaignsStore) CreateCampaign(ctx context.Context, campaign Campaign)
 
 func (s *CampaignsStore) ListCampaigns(ctx context.Context, project uuid.UUID, pagination store.Pagination, search string) (Campaigns, int, error) {
 	query := `
-	SELECT id, project_id, name, channel, provider_id, subscription_id, delivery, variables, created_at, updated_at, deleted_at,
+	SELECT id, project_id, name, channel, provider_id, subscription_id, transactional, delivery, variables, created_at, updated_at, deleted_at,
 		COUNT(*) OVER () AS total_count
 	FROM campaigns
 	WHERE project_id = $1
@@ -152,7 +163,7 @@ func (s *CampaignsStore) ListCampaigns(ctx context.Context, project uuid.UUID, p
 
 func (s *CampaignsStore) GetCampaign(ctx context.Context, projectID, campaignID uuid.UUID) (*Campaign, error) {
 	query := `
-	SELECT id, project_id, name, channel, provider_id, subscription_id, delivery, variables, created_at, updated_at, deleted_at
+	SELECT id, project_id, name, channel, provider_id, subscription_id, transactional, delivery, variables, created_at, updated_at, deleted_at
 	FROM campaigns
 	WHERE project_id = $1
 	AND id = $2
@@ -180,9 +191,11 @@ func (s *CampaignsStore) GetCampaign(ctx context.Context, projectID, campaignID
 }
 
 type CampaignUpdate struct {
-	Name       *string
-	ProviderID *uuid.UUID
-	Variables  *store.JSONB[CampaignVariables]
+	Name           *string
+	ProviderID     *uuid.UUID
+	SubscriptionID *uuid.UUID
+	Transactional  *bool
+	Variables      *store.JSONB[CampaignVariables]
 }
 
 func (s *CampaignsStore) UpdateCampaign(ctx context.Context, projectID, campaignID uuid.UUID, update CampaignUpdate) error {
@@ -191,9 +204,14 @@ func (s *CampaignsStore) UpdateCampaign(ctx context.Context, projectID, campaign
 	SET
 		name = COALESCE($1, name),
 		provider_id = COALESCE($2, provider_id),
-		variables = COALESCE($3, variables)
-	WHERE project_id = $4
-	AND id = $5
+		variables = COALESCE($3, variables),
+		transactional = COALESCE($4, transactional),
+		subscription_id = CASE
+			WHEN COALESCE($4, transactional) THEN NULL
+			ELSE COALESCE($5, subscription_id)
+		END
+	WHERE project_id = $6
+	AND id = $7
 	AND deleted_at IS NULL`
 
 	var variablesVal any
@@ -205,7 +223,17 @@ func (s *CampaignsStore) UpdateCampaign(ctx context.Context, projectID, campaign
 		variablesVal = v
 	}
 
-	_, err := s.db.ExecContext(ctx, query, update.Name, update.ProviderID, variablesVal, projectID, campaignID)
+	_, err := s.db.ExecContext(
+		ctx,
+		query,
+		update.Name,
+		update.ProviderID,
+		variablesVal,
+		update.Transactional,
+		update.SubscriptionID,
+		projectID,
+		campaignID,
+	)
 	return err
 }
 
@@ -304,13 +332,14 @@ type CampaignLookup struct {
 	ID             uuid.UUID  `db:"id"`
 	ProjectID      uuid.UUID  `db:"project_id"`
 	SubscriptionID *uuid.UUID `db:"subscription_id"`
+	Transactional  bool       `db:"transactional"`
 }
 
 // GetCampaignByID retrieves a campaign by ID without project filter.
 // This is used for unsubscribe flows where the project_id is not known.
 func (s *CampaignsStore) GetCampaignByID(ctx context.Context, campaignID uuid.UUID) (*CampaignLookup, error) {
 	query := `
-	SELECT id, project_id, subscription_id
+	SELECT id, project_id, subscription_id, transactional
 	FROM campaigns
 	WHERE id = $1
 	AND deleted_at IS NULL`
diff --git a/internal/store/management/migrations/1764106040_add_transactional_to_campaigns.down.sql b/internal/store/management/migrations/1764106040_add_transactional_to_campaigns.down.sql
new file mode 100644
index 00000000..1b9aecda
--- /dev/null
+++ b/internal/store/management/migrations/1764106040_add_transactional_to_campaigns.down.sql
@@ -0,0 +1,7 @@
+-- Remove transactional flag from campaigns
+-- If you added a CHECK constraint, drop it first
+-- ALTER TABLE campaigns
+--     DROP CONSTRAINT IF EXISTS campaigns_subscription_or_transactional;
+
+ALTER TABLE campaigns
+    DROP COLUMN IF EXISTS transactional;
diff --git a/internal/store/management/migrations/1764106040_add_transactional_to_campaigns.up.sql b/internal/store/management/migrations/1764106040_add_transactional_to_campaigns.up.sql
new file mode 100644
index 00000000..96fd5339
--- /dev/null
+++ b/internal/store/management/migrations/1764106040_add_transactional_to_campaigns.up.sql
@@ -0,0 +1,3 @@
+-- Add transactional flag to campaigns
+ALTER TABLE campaigns
+    ADD COLUMN IF NOT EXISTS transactional BOOLEAN NOT NULL DEFAULT FALSE;
diff --git a/internal/store/management/subscriptions.go b/internal/store/management/subscriptions.go
index 0333004e..8321500f 100644
--- a/internal/store/management/subscriptions.go
+++ b/internal/store/management/subscriptions.go
@@ -34,7 +34,7 @@ func (s *Subscription) OAPI() oapi.Subscription {
 		Id:        s.ID,
 		ProjectId: s.ProjectID,
 		Name:      s.Name,
-		Channel:   oapi.Channel(s.Channel),
+		Channel:   s.OAPI().Channel,
 		IsPublic:  s.IsPublic,
 		CreatedAt: s.CreatedAt,
 		UpdatedAt: s.UpdatedAt,
@@ -62,8 +62,8 @@ func (us *UserSubscription) OAPI() oapi.UserSubscription {
 	return oapi.UserSubscription{
 		SubscriptionId: us.SubscriptionID,
 		Name:           us.Name,
-		Channel:        oapi.Channel(us.Channel),
-		State:          oapi.SubscriptionState(us.State),
+		Channel:        us.OAPI().Channel,
+		State:          us.OAPI().State,
 	}
 }
 
diff --git a/internal/wasm/test/action.wasm b/internal/wasm/test/action.wasm
index a5a67245..a2113ade 100644
Binary files a/internal/wasm/test/action.wasm and b/internal/wasm/test/action.wasm differ
diff --git a/internal/wasm/test/provider.wasm b/internal/wasm/test/provider.wasm
index 01488834..5b934e0e 100644
Binary files a/internal/wasm/test/provider.wasm and b/internal/wasm/test/provider.wasm differ