compare and merge

.env

@@ -0,0 +1,37 @@
+# DO NOT COMMIT THIS FILE - IT WILL CONTAIN YOUR SENSITIVE KEYS.
+# Instead, rename this file to ".env" instead of ".env.example". (.env will not be committed)
+
+# Create an OpenAI API key at https://platform.openai.com/account/api-keys
+OPENAI_API_KEY="sk-123..."
+
+# (optional) Create an OpenAI Assistant at https://platform.openai.com/assistants.
+# IMPORTANT! Be sure to enable file search and code interpreter tools.
+OPENAI_ASSISTANT_ID="123..."
+
+# Briostack API configuration
+BRIOSTACK_INSTANCE_NAME="demo-instance"
+BRIOSTACK_API_KEY="demo-api-key"
+NEXT_PUBLIC_BRIOSTACK_INSTANCE_NAME="demo-instance"
+NEXT_PUBLIC_BRIOSTACK_API_KEY="demo-api-key"
+
+# Twilio configuration
+TWILIO_ACCOUNT_SID="your-sid"
+TWILIO_AUTH_TOKEN="your-token"
+TWILIO_PHONE_NUMBER="+1234567890"
+
+# SendGrid configuration
+SENDGRID_API_KEY="sg-key"
+SENDGRID_FROM_EMAIL="[email protected]"
+
+# Stripe configuration
+STRIPE_SECRET_KEY="sk_test_..."
+STRIPE_SUCCESS_URL="https://yourapp.com/success"
+STRIPE_CANCEL_URL="https://yourapp.com/cancel"
+
+# GoHighLevel / Lead Connector
+GHL_API_DOMAIN="link.jom.services"
+GHL_API_KEY="your-ghl-api-key"
+
+# NextBillion Route Optimization
+NEXTBILLION_API_KEY="nb-key"
+NEXT_PUBLIC_NEXTBILLION_API_KEY="nb-key"

.eslintrc.json

@@ -0,0 +1,3 @@
+{
+  "extends": "next"
+}

README.md

@@ -14,10 +14,21 @@ git clone https://github.com/openai/openai-assistants-quickstart.git
 cd openai-assistants-quickstart
 ```
 
-### 2. Set your [OpenAI API key](https://platform.openai.com/api-keys)
+### 2. Set your [OpenAI API key](https://platform.openai.com/api-keys) and other credentials
 
 ```shell
 export OPENAI_API_KEY="sk_..."
+# Optional integrations
+export BRIOSTACK_INSTANCE_NAME="demo-instance"
+export BRIOSTACK_API_KEY="demo-key"
+export TWILIO_ACCOUNT_SID="your-sid"
+export TWILIO_AUTH_TOKEN="your-token"
+export TWILIO_PHONE_NUMBER="+1234567890"
+export SENDGRID_API_KEY="sg-key"
+export SENDGRID_FROM_EMAIL="[email protected]"
+export STRIPE_SECRET_KEY="sk_test_..."
+export GHL_API_DOMAIN="link.jom.services"
+export GHL_API_KEY="your-ghl-api-key"
 ```
 
 (or in `.env.example` and rename it to `.env`).
@@ -27,14 +38,36 @@ export OPENAI_API_KEY="sk_..."
 ```shell
 npm install
 ```
+You can also use `pnpm install` or `yarn` if you prefer those package managers.
+
+Ensure this step completes while your environment still has network
+access so all required packages are downloaded.
+
+> **Note**: If `npm install` prints `npm warn Unknown env config "http-proxy"`,
+> your shell is exporting `npm_config_http_proxy` or `npm_config_https_proxy`.
+> Those variables are deprecated in newer versions of npm. Unset them or rename
+> them to `HTTP_PROXY`/`HTTPS_PROXY` (or `npm_config_proxy`) to remove the
+> warning.
 
 ### 4. Run
 
 ```shell
 npm run dev
 ```
 
-### 5. Navigate to [http://localhost:3000](http://localhost:3000).
+### 5. Run tests
+
+```shell
+npm test
+```
+
+This uses Node's built-in test runner to verify the included Briostack OpenAPI specification.
+
+### 6. Navigate to [http://localhost:3000](http://localhost:3000).
+
+The Briostack API specification used by the examples lives at
+`public/briostack-openapi.json`. Feel free to explore it for a full list of
+available endpoints. A basic test in `test/briostack-openapi.test.js` ensures this file can be loaded and contains the expected title.
 
 ## Deployment
 
@@ -68,6 +101,83 @@ The main logic for chat will be found in the `Chat` component in `app/components
 - `api/assistants/threads/[threadId]/actions` - `POST`: inform assistant of the result of a function it decided to call
 - `api/assistants/files` - `GET`/`POST`/`DELETE`: fetch, upload, and delete assistant files for file search
 
+### Briostack Function Example
+
+To check that your assistant has the `call_briostack` function registered, run:
+
+```ts
+npm install
+node scripts/check-functions.ts
+```
+
+This prints the assistant's registered functions. You can also run
+
+```ts
+node scripts/briostack-example.ts
+```
+
+to try a simple request if you have set `BRIOSTACK_INSTANCE_NAME` and
+`BRIOSTACK_API_KEY` in your environment. You can also store these
+values in the browser by visiting [`/briostack-connect`](./briostack-connect).
+The page saves your instance name and API key to `localStorage` so the
+helper functions can use them on subsequent visits.
+
+The `app/utils/briostack.ts` file also exposes helper methods like
+`listCustomers`, `getCustomer`, and `listProperties` for common API calls.
+Additional helpers such as `listAppointments`, `createAppointment`, and
+`listServices` demonstrate how to access other paid endpoints defined in the
+`public/briostack-openapi.json` specification. Recent additions
+`listWebhooks`, `createWebhook`, `getWebhook`, and `updateWebhook` make it easy
+to manage webhook resources as well. New helpers `createService` and
+`updateService` let you modify a service's `serviceSchedule` if needed. You can
+try them with the new
+script:
+
+```ts
+node scripts/briostack-appointments.ts
+```
+
+You can also inspect a service's schedule with:
+
+```ts
+node scripts/briostack-services.ts
+```
+
+
+### NextBillion Route Optimization
+
+This project also includes a helper for [NextBillion's Route Optimization API](https://nextbillion.ai/route-optimization-api).
+Use the `optimize_routes` function to post a JSON payload describing jobs and vehicles.
+The helper lives in `app/utils/nextbillion.ts` and reads `NEXTBILLION_API_KEY` from the environment.
+
+```ts
+import { callNextBillionOptimizer } from "./app/utils/nextbillion";
+const result = await callNextBillionOptimizer({ payload: { /* ... */ } });
+```
+
+You can experiment with this by calling `optimize_routes` in the example chats.
+
+
+### Realtime API Demo
+
+This repo now includes a minimal example page using the new Realtime API.
+Run `npm run dev` and navigate to `/realtime` to try a WebRTC session in your
+browser. The `/api/realtime/session` endpoint mints an ephemeral token using
+your `OPENAI_API_KEY` for authentication. The client page then connects to the
+Realtime model and streams events back and forth.
+
+### Messaging and Payments
+
+This template now includes optional API routes for sending SMS via Twilio,
+sending email via SendGrid, creating Stripe Checkout sessions, and proxying
+requests to GoHighLevel's Lead Connector API. Configure the related environment
+variables in `.env` and POST to the following endpoints:
+
+- `POST /api/messages/send-sms` – send an SMS message
+- `POST /api/messages/send-email` – send an email
+- `POST /api/payments/create-checkout-session` – create a Stripe checkout session
+- `POST /api/ghl/proxy` – proxy a call to your GHL domain
+
 ## Feedback
 
 Let us know if you have any thoughts, questions, or feedback in [this form](https://docs.google.com/forms/d/e/1FAIpQLScn_RSBryMXCZjCyWV4_ebctksVvQYWkrq90iN21l1HLv3kPg/viewform?usp=sf_link)!

app/api/assistants/route.ts

@@ -31,6 +31,58 @@ export async function POST() {
           },
         },
       },
+      {
+        type: "function",
+        function: {
+          name: "call_briostack",
+          description: "Make a request to the Briostack API",
+          parameters: {
+            type: "object",
+            properties: {
+              endpoint: {
+                type: "string",
+                description: "The Briostack endpoint path, e.g. '/v1/properties'",
+              },
+              method: {
+                type: "string",
+                enum: ["GET", "POST", "PUT", "DELETE"],
+              },
+              payload: {
+                type: "object",
+                description: "JSON body for POST/PUT requests",
+              },
+              query: {
+                type: "object",
+                description: "Query params as key/value pairs",
+              },
+            },
+            required: ["endpoint", "method"],
+          },
+        },
+      },
+      {
+        type: "function",
+        function: {
+          name: "optimize_routes",
+          description:
+            "Optimize technician routes using the NextBillion API",
+          parameters: {
+            type: "object",
+            properties: {
+              payload: {
+                type: "object",
+                description:
+                  "JSON body to send to NextBillion's route optimization API",
+              },
+              apiKey: {
+                type: "string",
+                description: "Optional NextBillion API key override",
+              },
+            },
+            required: ["payload"],
+          },
+        },
+      },
       { type: "file_search" },
     ],
   });

app/api/ghl/proxy/route.ts

@@ -0,0 +1,24 @@
+import { NextRequest } from "next/server";
+
+export const runtime = "nodejs";
+
+export async function POST(req: NextRequest) {
+  const { endpoint, method = "GET", payload, query } = await req.json();
+  const domain = process.env.GHL_API_DOMAIN;
+  const key = process.env.GHL_API_KEY;
+  if (!domain || !key) {
+    return new Response("GHL not configured", { status: 500 });
+  }
+  const url = new URL(`https://${domain}${endpoint}`);
+  if (query) Object.entries(query).forEach(([k, v]) => url.searchParams.append(k, String(v)));
+  const res = await fetch(url.toString(), {
+    method,
+    headers: {
+      "Authorization": `Bearer ${key}`,
+      "Content-Type": "application/json",
+    },
+    body: payload ? JSON.stringify(payload) : undefined,
+  });
+  const bodyText = await res.text();
+  return new Response(bodyText, { status: res.status });
+}

app/api/messages/send-email/route.ts

@@ -0,0 +1,16 @@
+import { NextRequest } from "next/server";
+import sgMail from "@sendgrid/mail";
+
+export const runtime = "nodejs";
+
+export async function POST(req: NextRequest) {
+  const { to, subject, text, html } = await req.json();
+  const apiKey = process.env.SENDGRID_API_KEY;
+  const from = process.env.SENDGRID_FROM_EMAIL;
+  if (!apiKey || !from) {
+    return new Response("SendGrid not configured", { status: 500 });
+  }
+  sgMail.setApiKey(apiKey);
+  await sgMail.send({ to, from, subject, text, html });
+  return Response.json({ success: true });
+}

app/api/messages/send-sms/route.ts

@@ -0,0 +1,17 @@
+import { NextRequest } from "next/server";
+import twilio from "twilio";
+
+export const runtime = "nodejs";
+
+export async function POST(req: NextRequest) {
+  const { to, body } = await req.json();
+  const accountSid = process.env.TWILIO_ACCOUNT_SID;
+  const authToken = process.env.TWILIO_AUTH_TOKEN;
+  const from = process.env.TWILIO_PHONE_NUMBER;
+  if (!accountSid || !authToken || !from) {
+    return new Response("Twilio not configured", { status: 500 });
+  }
+  const client = twilio(accountSid, authToken);
+  const message = await client.messages.create({ from, to, body });
+  return Response.json({ sid: message.sid });
+}

app/api/payments/create-checkout-session/route.ts

@@ -0,0 +1,23 @@
+import { NextRequest } from "next/server";
+import Stripe from "stripe";
+
+export const runtime = "nodejs";
+
+export async function POST(req: NextRequest) {
+  const secret = process.env.STRIPE_SECRET_KEY;
+  if (!secret) {
+    return new Response("Stripe not configured", { status: 500 });
+  }
+  const stripe = new Stripe(secret, { apiVersion: "2023-10-16" });
+  const { priceId } = await req.json();
+  const session = await stripe.checkout.sessions.create({
+    mode: "subscription",
+    payment_method_types: ["card"],
+    line_items: [{ price: priceId, quantity: 1 }],
+    success_url:
+      process.env.STRIPE_SUCCESS_URL || "https://example.com/success",
+    cancel_url:
+      process.env.STRIPE_CANCEL_URL || "https://example.com/cancel",
+  });
+  return Response.json({ url: session.url });
+}

app/api/realtime/session/route.ts

@@ -0,0 +1,28 @@
+import { NextRequest } from "next/server";
+
+export const runtime = "nodejs";
+
+export async function POST(req: NextRequest) {
+  const { model = "gpt-4o-realtime-preview-2024-12-17", voice = "nova" } = await req.json();
+  const apiKey = process.env.OPENAI_API_KEY;
+  if (!apiKey) {
+    return new Response("OpenAI API key not configured", { status: 500 });
+  }
+
+  const res = await fetch("https://api.openai.com/v1/realtime/sessions", {
+    method: "POST",
+    headers: {
+      "Authorization": `Bearer ${apiKey}`,
+      "Content-Type": "application/json",
+    },
+    body: JSON.stringify({ model, voice }),
+  });
+
+  if (!res.ok) {
+    const text = await res.text();
+    return new Response(text, { status: res.status });
+  }
+
+  const data = await res.json();
+  return Response.json(data);
+}