pollo/src/server/ably.ts

import Ably from "ably";
import { env } from "~/env.mjs";
import type { EventType } from "../utils/types";

const ably = new Ably.Realtime.Promise(env.ABLY_PRIVATE_KEY);

export const publishToChannel = async (
  channel: string,
  event: EventType,
  message: string
) => {
  const channelName = ably.channels.get(`${env.APP_ENV}-${channel}`);
  await channelName.publish(event, message);
};