[masterbots.ai] feat: wordware api (#276)

* feat: add wordware api + vercel sdk strategy

* feat: add wordware api + vercel sdk

* wordware describe feat

* wordware run + interface

* impr(masterbots.ai): upt /api/wordware/describe/route.ts

coderabbitai code suggestion.

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>

* impr(masterbots.ai): upt /api/wordware/describe/route.ts

coderabbitai code suggestion.

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>

* fix(masterbots.ai): typo /api/wordware/describe/route.ts

coderabbitai code suggestion.

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>

---------

Co-authored-by: Roberto Lucas <andler@bitcash.org>
Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>

Author: 3 people

apps/masterbots.ai/app/api/wordware/describe/route.ts

@@ -0,0 +1,57 @@
+import { NextResponse } from 'next/server'
+
+export async function GET(request: Request) {
+  const { searchParams } = new URL(request.url)
+  const promptId = searchParams.get('promptId')
+  const apiKey = process.env.WORDWARE_API_KEY
+
+  if (!apiKey) {
+    console.error('Wordware API key is not set')
+    return NextResponse.json(
+      { error: 'Internal server error' },
+      { status: 500 }
+    )
+  }
+
+  if (!promptId) {
+    return NextResponse.json(
+      { error: 'Invalid or missing promptId' },
+      { status: 400 }
+    )
+  }
+
+  try {
+    const response = await fetch(
+      `https://app.wordware.ai/api/prompt/${promptId}/describe`,
+      {
+        headers: {
+          Authorization: `Bearer ${apiKey}`
+        }
+      }
+    )
+
+    const contentType = response.headers.get('content-type')
+    if (contentType && contentType.indexOf('application/json') !== -1) {
+      const data = await response.json()
+      return NextResponse.json(data, { status: response.status })
+    } else {
+      const text = await response.text()
+      return NextResponse.json(
+        {
+          error: 'Unexpected response from Wordware API',
+          details: text.substring(0, 200)
+        },
+        { status: response.status }
+      )
+    }
+  } catch (error) {
+    console.error('Error fetching prompt details:', error)
+    return NextResponse.json(
+      {
+        error: 'An error occurred while fetching prompt details',
+        details: error
+      },
+      { status: 500 }
+    )
+  }
+}

apps/masterbots.ai/app/api/wordware/models/model.ts

@@ -0,0 +1,36 @@
+
+export const wordwareModel = (API_KEY: string) => ({
+  id: 'wordware',
+  name: 'Wordware AI',
+  specificationVersion: 'v1',
+  provider: 'wordware',
+  modelId: 'wordware-ai',
+  stream: async function* (opts: { messages: Array<{ role: string; content: string }> }) {
+    const { promptId, inputs } = JSON.parse(opts.messages[0].content);
+
+    const response = await fetch(`https://app.wordware.ai/api/prompt/${promptId}/run`, {
+      method: 'POST',
+      headers: {
+        'Authorization': `Bearer ${API_KEY}`,
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify({ inputs }),
+    });
+
+    if (!response.ok) {
+      throw new Error(`Wordware API error: ${response.statusText}`);
+    }
+
+    const reader = response.body!.getReader();
+    const decoder = new TextDecoder();
+
+    while (true) {
+      const { done, value } = await reader.read();
+      if (done) break;
+      yield decoder.decode(value);
+    }
+  },
+  defaultObjectGenerationMode: 'tool',
+  tokenizerEncode: async () => [], // Implement if needed
+  tokenizerDecode: async () => '', // Implement if needed
+});

apps/masterbots.ai/app/api/wordware/run/.route.ts.swp

@@ -0,0 +1,40 @@
+// app/api/wordware/run/route.ts
+
+import { NextResponse } from 'next/server';
+
+export async function POST(req: Request) {
+  const API_KEY = process.env.WORDWARE_API_KEY;
+
+  if (!API_KEY) {
+    return NextResponse.json({ error: 'Wordware API key is not set' }, { status: 500 });
+  }
+
+  try {
+    const { promptId, inputs } = await req.json();
+
+    const response = await fetch(`https://app.wordware.ai/api/prompt/${promptId}/run`, {
+      method: 'POST',
+      headers: {
+        'Authorization': `Bearer ${API_KEY}`,
+        'Content-Type': 'application/json',
+      },
+      body: JSON.stringify({ inputs }),
+    });
+
+    if (!response.ok) {
+      throw new Error(`Wordware API error: ${response.statusText}`);
+    }
+
+    // Instead of parsing JSON, we'll return the response as a stream
+    return new NextResponse(response.body, {
+      headers: {
+        'Content-Type': 'text/event-stream',
+        'Cache-Control': 'no-cache',
+        'Connection': 'keep-alive',
+      },
+    });
+  } catch (error) {
+    console.error('Error running Wordware prompt:', error);
+    return NextResponse.json({ error: 'An error occurred while running the prompt' }, { status: 500 });
+  }
+}

apps/masterbots.ai/app/api/wordware/run/route.ts

@@ -0,0 +1,21 @@
+import FooterCT from '@/components/layout/footer/footer-ct'
+import { ResponsiveSidebar } from '@/components/layout/sidebar/sidebar-responsive'
+import { ChatLayoutSection } from '@/components/routes/chat/chat-layout-section'
+import NextTopLoader from 'nextjs-toploader'
+
+interface ChatLayoutProps {
+  children: React.ReactNode
+}
+
+export default async function ChatLayout({ children }: ChatLayoutProps) {
+  return (
+    <main className="relative flex flex-col h-[calc(100vh-4rem)] overflow-hidden">
+      <NextTopLoader color="#1ED761" initialPosition={0.2} />
+      <ResponsiveSidebar />
+      <ChatLayoutSection>{children}</ChatLayoutSection>
+      <div className="layout-footer">
+        <FooterCT />
+      </div>
+    </main>
+  )
+}

apps/masterbots.ai/app/wordware/layout.tsx

@@ -0,0 +1,38 @@
+import { authOptions } from '@/auth'
+import { generateMetadataFromSEO } from '@/lib/metadata'
+import { isTokenExpired } from 'mb-lib'
+import { Metadata } from 'next'
+import { getServerSession } from 'next-auth'
+import { redirect } from 'next/navigation'
+import {WordwareChat} from '@/components/shared/wordware-chat';
+
+export default async function IndexPage() {
+  const session = await getServerSession(authOptions)
+
+  // NOTE: maybe we should use same expiration time
+  const jwt = session?.user?.hasuraJwt
+
+  if (!jwt || isTokenExpired(jwt)) {
+    redirect('/auth/signin')
+  }
+
+
+  return (
+    <>
+      <WordwareChat />
+    </>
+  )
+}
+
+export async function generateMetadata(): Promise<Metadata> {
+  const seoData = {
+    title: 'Wordware page',
+    description:
+      'Welcome to the chatbot page. Interact with our AI-powered chatbot and get answers to your questions.',
+    ogType: 'website',
+    ogImageUrl: '',
+    twitterCard: 'summary'
+  }
+
+  return generateMetadataFromSEO(seoData)
+}

apps/masterbots.ai/app/wordware/page.tsx

@@ -18,6 +18,8 @@ export function Header() {
         <IconSeparator className="size-6 text-muted-foreground/50" />
         <HeaderLink href="/c" text="Chat" />
         <HeaderLink href="/" text="Browse" />
+        <HeaderLink href="/wordware" text="Ww" />
+
         {appConfig.devMode && (
           <HeaderLink href="/c/p" text="Pro" />
         )}