feat: april 1st release - enhance hasura permissions, thread fetching, gemini ai integration (#439)

* fix: change toggler wording + util hook (#424)

* impr: makes threads open on profile page and profile tweaks (#421)

* update

* fix: update

* update

* update

* update

* update

* fix: opening threads

* fix: rm threads dropdwon  & added back link to bot page thread view page

* fix: rm threads dropdwon  & added back link to bot page thread view page

* fix: update

* fix: added back to profile page

* fix: added sticky and color

* fix: codeblock ctas refactor markdown rendering, sidebar nav, code block & clipboard hook (#425)

* fix: codeblock ctas

* fix: ts build

* fix: continue thread + allMessages sequence + mobile chat css tweak (#426)

* fix: css handleCLick condition

* fix: get latest search params, continuous thread

* fix(impr): all messages sorting

* perf(impr): sign in & up redirection tweak

* perf(impr): mobile chat css

* chore: next + react security ver upt (#427)

* refactor: use chat and continue thread + continue conversation fallback (#432)

* refactor: use chat and continue generation

* fix: uniq slug and id gen (#433)

* fix: uniq thread + msg slug gen

* style: formatting

* fix: thread user attachments state upt

* perf: impr thread component at all pages + mobile tweaks

* refactor: thread-component card

* chore: restore continue generation v1

* feat(impr): thread component card

* fix: admin panel n actions

* fix: fetch getThreads

* chore: continue conversation v1.2

* chore: continue and update thread content

* chore: add ui control continue generation state

* chore: fix infinity loop

* chore(impr): enable upt msg table permission

* fix: seo thread fetch

* chore: style formating

* fix(impr): continued thread title + thread component reusability

* chore: refactor loadings + extending sonners

---------

Co-authored-by: bran18 <andreyfdez18@gmail.com>

---------

Co-authored-by: Roberto Lucas <andler@bitcash.org>

* feat: add gemini provider (#437)

* feat: add gemini provider

* chore: update icons

* feat: impr continuing thread tags + accordion first msg toggle (#435)

* feat(wip): impr continuing thread tags + accordion first msg toggle

* feat(impr): continuing thread tags + accordion at first message + header mobile tweak

* style(impr): mobile thread-component x-axis space

* perf(style): coderabbitai feedbacks

* fix: css typo

* perf: sendMessageFromResponse clicked guard + continued thread tags label tweak

* chore: user thread panel clean up

* fix: user-thread-panel infinite loader

* perf: impr shared accordion animation and ux

* style: defaultAccordionState comments loc

* fix: record type warning, hasura updateMessage

* fix: getThread user data, shared-accordion

* fix: coderabbitai observations

---------

Co-authored-by: Brandon Fernández <31634868+Bran18@users.noreply.github.com>
Co-authored-by: Jimoh sherifdeen <63134009+sheriffjimoh@users.noreply.github.com>

Author: 3 people

apps/hasura/metadata/databases/masterbots/tables/public_message.yaml

@@ -108,6 +108,24 @@ select_permissions:
       filter: {}
       allow_aggregations: true
     comment: ""
+update_permissions:
+  - role: moderator
+    permission:
+      columns:
+        - content
+      filter: {}
+      check: null
+    comment: ""
+  - role: user
+    permission:
+      columns:
+        - content
+      filter:
+        thread:
+          user_id:
+            _eq: X-Hasura-User-Id
+      check: null
+    comment: ""
 delete_permissions:
   - role: moderator
     permission:

apps/masterbots.ai/app/(browse)/[category]/[domain]/[chatbot]/[threadSlug]/[threadQuestionSlug]/page.tsx

@@ -1,7 +1,7 @@
 import BrowseList from '@/components/routes/browse/browse-list'
 import { BrowseSearchInput } from '@/components/routes/browse/browse-search-input'
 import { PAGE_SIZE } from '@/lib/constants/hasura'
-import { getCategories, getThreads } from '@/services/hasura'
+import { getBrowseThreads, getCategories } from '@/services/hasura'
 import type { PageProps } from '@/types/types'
 import { toSlug } from 'mb-lib'
 
@@ -20,20 +20,23 @@ export default async function BrowserThreadQuestionPage(props: PageProps) {
 	const category = categories.find(
 		(category) => toSlug(category.name) === params.category,
 	)
-	const threads = await getThreads({
+	const { threads, count } = await getBrowseThreads({
 		categoryId: category?.categoryId,
 		limit: PAGE_SIZE,
-		jwt: '',
 	})
 
 	return (
-		<div className="w-full max-w-screen-lg pb-10 mx-auto">
+		<div className="w-full max-w-screen-xl pb-10 mx-auto">
 			{/* <BrowseCategoryTabs
         initialCategory={params.category}
         categories={categories}
       /> */}
 			<BrowseSearchInput />
-			<BrowseList initialThreads={threads} categoryId={category?.categoryId} />
+			<BrowseList
+				initialThreads={threads}
+				initialCount={count}
+				categoryId={category?.categoryId}
+			/>
 		</div>
 	)
 }

apps/masterbots.ai/app/(browse)/[category]/[domain]/[chatbot]/[threadSlug]/page.tsx

@@ -1,7 +1,7 @@
 import BrowseList from '@/components/routes/browse/browse-list'
 import { BrowseSearchInput } from '@/components/routes/browse/browse-search-input'
 import { PAGE_SIZE } from '@/lib/constants/hasura'
-import { getCategories, getThreads } from '@/services/hasura'
+import { getBrowseThreads, getCategories } from '@/services/hasura'
 import type { PageProps } from '@/types/types'
 import { toSlug } from 'mb-lib'
 
@@ -23,20 +23,23 @@ export default async function ChatPage(props: PageProps) {
 	const category = categories.find(
 		(category) => toSlug(category.name) === params.category,
 	)
-	const threads = await getThreads({
+	const { threads, count } = await getBrowseThreads({
 		categoryId: category?.categoryId,
 		limit: PAGE_SIZE,
-		jwt: '',
 	})
 
 	return (
-		<div className="w-full max-w-screen-lg pb-10 mx-auto">
+		<div className="w-full max-w-screen-xl pb-10 mx-auto">
 			{/* <BrowseCategoryTabs
 				initialCategory={params.category}
 				categories={categories}
 			/> */}
 			<BrowseSearchInput />
-			<BrowseList initialThreads={threads} categoryId={category?.categoryId} />
+			<BrowseList
+				initialThreads={threads}
+				initialCount={count}
+				categoryId={category?.categoryId}
+			/>
 		</div>
 	)
 }

apps/masterbots.ai/app/(browse)/[category]/[domain]/[chatbot]/page.tsx

@@ -3,7 +3,7 @@ import { BrowseSearchInput } from '@/components/routes/browse/browse-search-inpu
 import { botNames } from '@/lib/constants/bots-names'
 import { PAGE_SIZE } from '@/lib/constants/hasura'
 import { generateMetadataFromSEO } from '@/lib/metadata'
-import { getChatbot, getThreads } from '@/services/hasura'
+import { getBrowseThreads, getChatbot } from '@/services/hasura'
 import type { Metadata } from 'next'
 
 export default async function BrowseCategoryChatbotPage(props: {
@@ -18,10 +18,13 @@ export default async function BrowseCategoryChatbotPage(props: {
 
 	if (!chatbot) throw new Error(`Chatbot ${chatbotName} not found`)
 
-	const threads = await getThreads({ chatbotName, limit: PAGE_SIZE, jwt: '' })
+	const { threads, count } = await getBrowseThreads({
+		chatbotName,
+		limit: PAGE_SIZE,
+	})
 
 	return (
-		<div className="w-full max-w-screen-lg pb-10 mx-auto">
+		<div className="w-full max-w-screen-xl pb-10 mx-auto">
 			{/* <BrowseCategoryTabs
         initialCategory={params.category}
         categories={categories}
@@ -31,6 +34,7 @@ export default async function BrowseCategoryChatbotPage(props: {
 				categoryId={chatbot.categories[0].categoryId}
 				chatbot={chatbot}
 				initialThreads={threads}
+				initialCount={count}
 			/>
 		</div>
 	)

apps/masterbots.ai/app/(browse)/[category]/page.tsx

@@ -2,7 +2,7 @@ import BrowseList from '@/components/routes/browse/browse-list'
 import { BrowseSearchInput } from '@/components/routes/browse/browse-search-input'
 import { PAGE_SIZE } from '@/lib/constants/hasura'
 import { generateMetadataFromSEO } from '@/lib/metadata'
-import { getCategories, getThreads } from '@/services/hasura'
+import { getBrowseThreads, getCategories } from '@/services/hasura'
 import { toSlug } from 'mb-lib'
 import type { Metadata } from 'next'
 
@@ -14,20 +14,23 @@ export default async function BrowseCategoryPage(props: {
 	const category = categories.find(
 		(category) => toSlug(category.name) === params.category,
 	)
-	const threads = await getThreads({
+	const { threads, count } = await getBrowseThreads({
 		categoryId: category?.categoryId,
 		limit: PAGE_SIZE,
-		jwt: '',
 	})
 
 	return (
-		<div className="w-full max-w-screen-lg pb-10 mx-auto">
+		<div className="w-full max-w-screen-xl pb-10 mx-auto">
 			{/* <BrowseCategoryTabs
         initialCategory={params.category}
         categories={categories}
       /> */}
 			<BrowseSearchInput />
-			<BrowseList initialThreads={threads} categoryId={category?.categoryId} />
+			<BrowseList
+				initialThreads={threads}
+				categoryId={category?.categoryId}
+				initialCount={count}
+			/>
 		</div>
 	)
 }

apps/masterbots.ai/app/(browse)/page.tsx

@@ -1,15 +1,15 @@
 import BrowseList from '@/components/routes/browse/browse-list'
 import { BrowseSearchInput } from '@/components/routes/browse/browse-search-input'
 import { PAGE_SIZE } from '@/lib/constants/hasura'
-import { getThreads } from '@/services/hasura'
+import { getBrowseThreads } from '@/services/hasura'
 
 export default async function HomePage() {
-	const threads = await getThreads({ limit: PAGE_SIZE, jwt: '' })
+	const { threads, count } = await getBrowseThreads({ limit: PAGE_SIZE })
 
 	return (
 		<>
 			<BrowseSearchInput />
-			<BrowseList initialThreads={threads} />
+			<BrowseList initialThreads={threads} initialCount={count} />
 		</>
 	)
 }

apps/masterbots.ai/app/actions/ai-main-call.ts

@@ -25,6 +25,7 @@ import type {
 	JSONResponseStream,
 } from '@/types/types'
 import { createAnthropic } from '@ai-sdk/anthropic'
+import { createGoogleGenerativeAI } from '@ai-sdk/google'
 import { createGroq } from '@ai-sdk/groq'
 import { createOpenAI } from '@ai-sdk/openai'
 import {
@@ -97,6 +98,17 @@ export async function initializePerplexity(apiKey: string) {
 	})
 }
 
+const initializeGoogle = (apiKey: string) => {
+	if (!apiKey) {
+		throw new Error(
+			'GOOGLE_GENERATIVE_AI_API_KEY is not defined in environment variables',
+		)
+	}
+	return createGoogleGenerativeAI({
+		apiKey,
+	})
+}
+
 // * This function improves the message using the AI
 export async function improveMessage(
 	userPrompt: {
@@ -412,6 +424,26 @@ export async function createResponseStream(
 				})
 				break
 			}
+			case 'Gemini': {
+				const googleAI = initializeGoogle(
+					previewToken || (process.env.GOOGLE_GENERATIVE_AI_API_KEY as string),
+				)
+				const googleModel = googleAI(model)
+				response = await streamText({
+					model: googleModel,
+					messages: coreMessages,
+					temperature: 0.3,
+					tools,
+					maxRetries: 2,
+					providerOptions: {
+						google: {
+							//? Enables web search
+							useSearchGrounding: webSearch || false,
+						},
+					},
+				})
+				break
+			}
 			default:
 				throw new Error('Unsupported client type')
 		}

apps/masterbots.ai/app/api/chat/models/models.ts

@@ -7,4 +7,5 @@ export enum AIModels {
 	WordWare = 'wordware-ai',
 	DeepSeekR1 = 'deepseek-r1',
 	DeepSeekGroq = 'deepseek-r1-distill-llama-70b',
+	Gemini = 'gemini-2.0-flash',
 }

apps/masterbots.ai/app/b/[botSlug]/page.tsx

@@ -21,7 +21,7 @@ export default async function BotThreadsPage(props: PageProps) {
 	if (!chatbot) throw new Error(`Chatbot ${chatbotName} not found`)
 
 	// session will always be defined
-	const threads = await getBrowseThreads({
+	const { threads, count } = await getBrowseThreads({
 		chatbotName,
 		limit: PAGE_SIZE,
 	})
@@ -41,6 +41,7 @@ export default async function BotThreadsPage(props: PageProps) {
 			</div>
 			<BrowseSpecificThreadList
 				initialThreads={threads}
+				initialCount={count}
 				PAGE_SIZE={PAGE_SIZE}
 				query={{
 					chatbotName,

apps/masterbots.ai/app/c/[category]/[domain]/[chatbot]/[threadSlug]/[threadQuestionSlug]/page.tsx

@@ -40,7 +40,7 @@ export default async function BotThreadPopUpQuestionPage(props: {
 		throw new Error('User ID is missing.')
 	}
 
-	const threads = await getThreads({
+	const { threads, count } = await getThreads({
 		chatbotName,
 		jwt: jwt as string,
 		userId,
@@ -49,7 +49,7 @@ export default async function BotThreadPopUpQuestionPage(props: {
 
 	return (
 		<>
-			<ThreadPanel threads={threads} />
+			<ThreadPanel threads={threads} count={count} />
 			<ChatChatbot chatbot={chatbot} />
 		</>
 	)