AI-Powered Features

// POST /posts/generator
const response = await fetch('/posts/generator', {
  method: 'POST',
  body: JSON.stringify({
    research: 'AI trends in social media',
    isPicture: true,
    format: 'one_short',
    tone: 'professional'
  })
});

// Streaming response
const reader = response.body.getReader();
while (true) {
  const { done, value } = await reader.read();
  if (done) break;
  // Process each step update
}

// Component for AI image generation
const AiImage = ({ value, onChange }) => {
  const generateImage = async (prompt: string) => {
    // POST /media/generate-image-with-prompt
    const response = await fetch('/media/generate-image-with-prompt', {
      method: 'POST',
      body: JSON.stringify({ prompt })
    });
    
    const { id, path } = await response.json();
    onChange({ id, path });
  };
  
  return (
    <button onClick={() => generateImage(value)}>
      Generate AI Image
    </button>
  );
};

// GET /copilot/credits?type=ai_images
const { credits } = await fetch(
  '/copilot/credits?type=ai_images'
).json();

if (credits <= 0) {
  // Show upgrade prompt
  toaster.show('No AI credits remaining', 'warning');
}

const AiVideo = ({ value, onChange }) => {
  const user = useUser();
  
  // Check video generation allowance
  const { data: allowed } = useSWR(
    'generate-video-allowed',
    () => fetch('/media/generate-video/veo3/allowed').json()
  );
  
  const generateVideo = async () => {
    modal.openModal({
      children: <VideoWrapper 
        onGenerate={(video) => onChange(video)}
      />
    });
  };
  
  if (!user?.tier?.ai) {
    return <UpgradePrompt feature="AI Video" />;
  }
  
  return (
    <button onClick={generateVideo}>
      Generate AI Video
    </button>
  );
};

import { CopilotKit } from '@copilotkit/react-core';
import { CopilotChat } from '@copilotkit/react-ui';

const AgentChat = () => {
  const backendUrl = process.env.NEXT_PUBLIC_BACKEND_INTERNAL_URL;
  
  return (
    <CopilotKit
      runtimeUrl={backendUrl + '/copilot/agent'}
      agent="postiz"
      properties={{
        integrations: selectedChannels,
        organization: org.id
      }}
    >
      <CopilotChat
        instructions={
          initial: 'Hello, I am your Postiz agent. ' +
                   'I can help you create posts, schedule content, ' +
                   'and analyze your social media performance.'
        }
      />
    </CopilotKit>
  );
};

// Backend: copilot.controller.ts
@Post('/agent')
async agent(
  @Req() req: Request,
  @Res() res: Response,
  @GetOrgFromRequest() organization: Organization
) {
  const mastra = await this._mastraService.mastra();
  const runtimeContext = new RuntimeContext<ChannelsContext>();
  
  runtimeContext.set(
    'integrations',
    req?.body?.variables?.properties?.integrations || []
  );
  runtimeContext.set('organization', JSON.stringify(organization));
  runtimeContext.set('ui', 'true');
  
  const agents = MastraAgent.getLocalAgents({
    resourceId: organization.id,
    mastra,
    runtimeContext
  });
  
  const runtime = new CopilotRuntime({ agents });
  
  return copilotRuntimeNextJSAppRouterEndpoint({
    endpoint: '/copilot/agent',
    runtime,
    serviceAdapter: new OpenAIAdapter({ model: 'gpt-4.1' })
  }).handleRequest(req, res);
}

// GET /copilot/list - Get all chat threads
const { threads } = await fetch('/copilot/list').json();

// GET /copilot/:thread/list - Get messages in thread
const { messages } = await fetch(
  `/copilot/${threadId}/list`
).json();

// Hooks are generated during the content creation process
const generatedPost = {
  hook: "🚀 Did you know that AI can boost your engagement by 300%?",
  content: "Here's how artificial intelligence..."
};

const openDesignModal = () => {
  modals.openModal({
    title: 'Design Media',
    size: '80%',
    children: (close) => (
      <Polonto 
        setMedia={changeMedia} 
        closeModal={close}
        width={1080}
        height={1080}
      />
    )
  });
};

// Third-party provider for AI video avatars
const HeyGenProvider = () => {
  const generateAvatarVideo = async (script: string) => {
    const video = await heygenService.create({
      script,
      avatar: 'default',
      voice: 'en-US'
    });
    
    return video;
  };
};

const user = useUser();

if (!user?.tier?.ai) {
  // Show upgrade prompt
  return <UpgradePrompt />;
}

// AI features are available
return <AIFeatures />;

// Check available credits
GET /copilot/credits?type=ai_images
GET /copilot/credits?type=ai_videos

interface CreditResponse {
  credits: number;
  used: number;
  limit: number;
  resetDate: string;
}