atproto-podcast-host / src / atproto-client.js

import { BskyAgent } from '@atproto/api';
import dotenv from 'dotenv';

dotenv.config();

const agent = new BskyAgent({
  service: process.env.ATPROTO_SERVICE || 'https://bsky.social'
});

let isAuthenticated = false;

export async function authenticate() {
  if (isAuthenticated) return agent;

  try {
    await agent.login({
      identifier: process.env.ATPROTO_IDENTIFIER,
      password: process.env.ATPROTO_PASSWORD
    });
    isAuthenticated = true;
    console.log('✅ Authenticated with AT Protocol');
    return agent;
  } catch (error) {
    console.error('❌ Authentication failed:', error);
    throw error;
  }
}

export const atprotoClient = {
  getAgent: async () => {
    if (!isAuthenticated) {
      await authenticate();
    }
    return agent;
  },

  uploadBlob: async (data, mimeType) => {
    const authenticatedAgent = await atprotoClient.getAgent();
    const response = await authenticatedAgent.uploadBlob(data, {
      encoding: mimeType
    });
    return response.data.blob;
  },

  getBlob: async (did, cid) => {
    // Fetch blob from the user's PDS using the public sync endpoint
    // Extract PDS from the DID (assumes did:plc: or did:web:)
    let pdsUrl;

    if (did.startsWith('did:plc:')) {
      // For did:plc, we need to resolve it to find the PDS
      // For now, try common PDS endpoints
      const didResponse = await fetch(`https://plc.directory/${did}`);
      if (didResponse.ok) {
        const didDoc = await didResponse.json();
        // Find PDS service endpoint
        const pdsService = didDoc.service?.find(s => s.id === '#atproto_pds');
        pdsUrl = pdsService?.serviceEndpoint || 'https://bsky.social';
      } else {
        pdsUrl = 'https://bsky.social';
      }
    } else {
      pdsUrl = 'https://bsky.social';
    }

    const url = `${pdsUrl}/xrpc/com.atproto.sync.getBlob?did=${did}&cid=${cid}`;
    console.log('Fetching blob from:', url);

    const response = await fetch(url);
    console.log('Blob response:', response.status, response.statusText);

    return response;
  }
};