Transistor MCP Server

MIT License
Overview InspectNew Schema Related Servers Reviews Score
Transistor-MCP
src
import axios, { AxiosInstance } from "axios";
import {
  AuthorizeUploadArgs,
  CreateEpisodeArgs,
  GetAnalyticsArgs,
  GetEpisodeArgs,
  ListEpisodesArgs,
  ListShowsArgs,
  UpdateEpisodeArgs,
  GetAllEpisodeAnalyticsArgs,
  ListWebhooksArgs,
  SubscribeWebhookArgs,
  UnsubscribeWebhookArgs,
} from "./types.js";

export class TransistorApiClient {
  private api: AxiosInstance;

  constructor(apiKey: string) {
    this.api = axios.create({
      baseURL: "https://api.transistor.fm",
      headers: {
        "x-api-key": apiKey,
        Accept: "application/json",
      },
    });
  }

  async getAuthenticatedUser() {
    const response = await this.api.get("/v1");
    return response.data;
  }

  async authorizeUpload(args: AuthorizeUploadArgs) {
    const response = await this.api.get("/v1/episodes/authorize_upload", {
      params: { filename: args.filename },
    });
    return response.data;
  }

  async listShows(args: ListShowsArgs) {
    const { page = 1 } = args;
    const response = await this.api.get("/v1/shows", {
      params: { "pagination[page]": page, "pagination[per]": 10 },
    });
    return response.data;
  }

  async listEpisodes(args: ListEpisodesArgs) {
    const { show_id, page = 1, status } = args;
    const response = await this.api.get("/v1/episodes", {
      params: { show_id, "pagination[page]": page, "pagination[per]": 10, status },
    });
    return response.data;
  }

  async createEpisode(args: CreateEpisodeArgs) {
    const response = await this.api.post("/v1/episodes", {
      episode: args,
    });
    return response.data;
  }

  async updateEpisode(args: UpdateEpisodeArgs) {
    const { episode_id, ...updateData } = args;
    const response = await this.api.patch(`/v1/episodes/${episode_id}`, {
      episode: updateData,
    });
    return response.data;
  }

  async getAnalytics(args: GetAnalyticsArgs) {
    const { show_id, episode_id, start_date, end_date } = args;
    const endpoint = episode_id
      ? `/v1/analytics/episodes/${episode_id}`
      : `/v1/analytics/${show_id}`;
    const response = await this.api.get(endpoint, {
      params: { start_date, end_date },
    });
    return response.data;
  }

  async getAllEpisodeAnalytics(args: GetAllEpisodeAnalyticsArgs) {
    const { show_id, start_date, end_date } = args;
    const response = await this.api.get(`/v1/analytics/${show_id}/episodes`, {
      params: { start_date, end_date },
    });
    return response.data;
  }

  async listWebhooks(args: ListWebhooksArgs) {
    const { show_id } = args;
    const response = await this.api.get("/v1/webhooks", {
      params: { show_id },
    });
    return response.data;
  }

  async subscribeWebhook(args: SubscribeWebhookArgs) {
    const response = await this.api.post("/v1/webhooks", args);
    return response.data;
  }

  async unsubscribeWebhook(args: UnsubscribeWebhookArgs) {
    const { webhook_id } = args;
    const response = await this.api.delete(`/v1/webhooks/${webhook_id}`);
    return response.data;
  }

  async getEpisode(args: GetEpisodeArgs) {
    const { episode_id, include, fields } = args;
    const params: { [key: string]: string | string[] } = {};
    if (include) {
      params["include[]"] = include;
    }
    if (fields) {
      for (const [resource, fieldList] of Object.entries(fields)) {
        params[`fields[${resource}][]`] = fieldList;
      }
    }
    const response = await this.api.get(`/v1/episodes/${episode_id}`, {
      params,
    });
    return response.data;
  }
}