plastic-labs · VVoruganti · Apr 1, 2024 · Jan 31, 2024 · Jan 31, 2024 · Feb 6, 2024
diff --git a/.gitignore b/.gitignore
@@ -168,3 +168,5 @@ cython_debug/
 .DS_Store
 
 supabase/
+
+docs/node_modules
diff --git a/README.md b/README.md
@@ -1,10 +1,12 @@
 # 🫡 Honcho
-![Static Badge](https://img.shields.io/badge/Version-0.0.6-blue)
+![Static Badge](https://img.shields.io/badge/Version-0.0.7-blue)
 [![Discord](https://img.shields.io/discord/1016845111637839922?style=flat&logo=discord&logoColor=23ffffff&label=Plastic%20Labs&labelColor=235865F2)](https://discord.gg/plasticlabs)
 ![GitHub License](https://img.shields.io/github/license/plastic-labs/honcho)
 ![GitHub Repo stars](https://img.shields.io/github/stars/plastic-labs/honcho)
 [![X (formerly Twitter) URL](https://img.shields.io/twitter/url?url=https%3A%2F%2Ftwitter.com%2Fplastic_labs)](https://twitter.com/plastic_labs)
 
+Honcho is a platform for making AI agents and LLM powered applications that are personalized
+to their end users.
 Honcho is a platform for making AI agents and LLM powered applications that are personalized
 to their end users.
 
@@ -25,6 +27,19 @@ Read the user documenation [here](https://docs.honcho.dev)
 - [Contributing](#contributing)
 - [License](#license)
 
+## Table of Contents
+
+- [Project Structure](#project-structure)
+- [Usage](#usage)
+    - [API](#api)
+        - [Docker](#docker)
+        - [Manually](#manually)
+        - [Deploying on Fly.io](#deploy-on-fly)
+    - [Client SDK](#client-sdk)
+        - [Use Locally](#use-locally) 
+- [Contributing](#contributing)
+- [License](#license)
+
 ## Project Structure
 
 The Honcho repo is a monorepo containing the server/API that manages database
@@ -61,6 +76,19 @@ docker compose up -d
 
 #### Manually
 
+#### Docker
+
+The API can be run using docker-compose. The `docker-compose.yml.example` file can be copied to `docker-compose.yml` and the environment variables can be set in the `.env` file.
+
+```bash
+cd honcho/api
+cp docker-compose.yml.example docker-compose.yml
+[ update the file with openai key and other wanted environment variables ]
+docker compose up -d
+```
+
+#### Manually
+
 The API can be run either by installing the necessary dependencies and then
 specifying the appropriate environment variables.
 
@@ -75,6 +103,7 @@ poetry install # install dependencies
 2. Copy the `.env.template` file and specify the type of database and
    connection_uri. For testing sqlite is fine. The below example uses an
    in-memory sqlite database.
+   in-memory sqlite database.
 
 > Honcho has been tested with Postgresql and PGVector
 
@@ -103,6 +132,7 @@ python -m uvicorn src.main:app --reload
 The API can also be deployed on fly.io. Follow the [Fly.io
 Docs](https://fly.io/docs/getting-started/) to setup your environment and the
 `flyctl`.
+`flyctl`.
 
 Once `flyctl` is set up use the following commands to launch the application:
 
@@ -130,6 +160,10 @@ poetry add honcho-ai
 checkout the [SDK Reference](https://api.python.honcho.dev) for a detailed
 look at the different methods and how to use them. 
 
+Also, check out the[example folder](./example/) for examples of how to use the sdk 
+checkout the [SDK Reference](https://api.python.honcho.dev) for a detailed
+look at the different methods and how to use them. 
+
 Also, check out the[example folder](./example/) for examples of how to use the sdk 
 
 #### Use Locally
@@ -149,11 +183,13 @@ This project is completely open source and welcomes any and all open source
 contributions. The workflow for contributing is to make a fork of the
 repository. You can claim an issue in the issues tab or start a new thread to
 indicate a feature or bug fix you are working on.
+indicate a feature or bug fix you are working on.
 
 Once you have finished your contribution make a PR pointed at the `staging`
 branch, and it will be reviewed by a project manager. Feel free to join us in
 our [discord](http://discord.gg/plasticlabs) to discuss your changes or get
 help.
+help.
 
 Once your changes are accepted and merged into staging they will undergo a
 period of live testing before entering the upstream into `main`

diff --git a/api/.env.template b/api/.env.template
@@ -8,6 +8,11 @@ OPENAI_API_KEY=
 OPENTELEMETRY_ENABLED=false # Set to true to enable OpenTelemetry logging and tracing
 SENTRY_ENABLED=false # Set to true to enable Sentry logging and tracing
 
+# Auth
+
+USE_AUTH_SERVICE=false
+AUTH_SERVICE_URL=http://localhost:8001
+
 ## Sentry
 SENTRY_DSN=
 

diff --git a/api/CHANGELOG.md b/api/CHANGELOG.md
@@ -4,6 +4,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](http://keepachangelog.com/)
 and this project adheres to [Semantic Versioning](http://semver.org/).
 
+## [0.0.7] — 2024-04-01
+
+### Added
+
+* Authentication Middleware Interface
+
 ## [0.0.6] — 2024-03-21
 
 ### Added

diff --git a/api/docker-compose.yml.example b/api/docker-compose.yml.example
@@ -25,6 +25,7 @@ services:
       - OTEL_RESOURCE_ATTRIBUTES=
       - DEBUG_LOG_OTEL_TO_PROVIDER=false
       - DEBUG_LOG_OTEL_TO_CONSOLE=true
+      - USE_AUTH_SERVICE=false
   database:
     image: ankane/pgvector
     restart: always

diff --git a/api/fly.toml b/api/fly.toml
@@ -7,25 +7,10 @@ app = "honcho"
 kill_signal = "SIGINT"
 kill_timeout = "5s"
 
-[experimental]
-  auto_rollback = true
-
-[build]
-
 [processes]
   api = "python -m uvicorn src.main:app --host 0.0.0.0 --port 8000"
   deriver = "python -m src.deriver"
 
-[[services]]
-  auto_stop_machines = false
-  auto_start_machines = true
-  min_machines_running = 1
-  processes = ["deriver"]
-  protocol = "tcp"
-  [services.concurrency]
-    hard_limit = 250
-    soft_limit = 200
-
 [http_service]
   internal_port = 8000
   auto_stop_machines = false

diff --git a/api/poetry.lock b/api/poetry.lock
diff --git a/api/pyproject.toml b/api/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "honcho"
-version = "0.0.6"
+version = "0.0.7"
 description = "Honcho Server"
 authors = ["Plastic Labs <[email protected]>"]
 readme = "README.md"
@@ -27,6 +27,7 @@ realtime = "^1.0.2"
 psycopg = {extras = ["binary"], version = "^3.1.18"}
 langchain = "^0.1.12"
 langchain-openai = "^0.0.8"
+httpx = "^0.27.0"
 
 [tool.ruff.lint]
 # from https://docs.astral.sh/ruff/linter/#rule-selection example

diff --git a/api/src/db.py b/api/src/db.py
@@ -23,8 +23,8 @@
 
 
 def scaffold_db():
-    """Use a Sync Engine for scaffolding the database. DDL operations are unavailable
-    with Async Engines
+    """use a sync engine for scaffolding the database. ddl operations are unavailable
+    with async engines
     """
     engine = create_engine(os.environ["CONNECTION_URI"], echo=True)
     Base.metadata.create_all(bind=engine)

diff --git a/api/src/dependencies.py b/api/src/dependencies.py
@@ -1,7 +1,8 @@
 from fastapi import Depends
-from .db import SessionLocal
 from sqlalchemy.ext.asyncio import AsyncSession
 
+from .db import SessionLocal
+
 
 async def get_db():
     """FastAPI Dependency Generator for Database"""

diff --git a/api/src/deriver.py b/api/src/deriver.py
@@ -1,5 +1,6 @@
 import asyncio
 import os
+import time
 import uuid
 from typing import List
 
@@ -15,6 +16,7 @@
 from realtime.connection import Socket
 from sqlalchemy import select
 from sqlalchemy.orm import selectinload
+from websockets.exceptions import ConnectionClosedError
 
 from . import crud, models, schemas
 from .db import SessionLocal
@@ -32,7 +34,7 @@
 SUPABASE_ID = os.getenv("SUPABASE_ID")
 SUPABASE_API_KEY = os.getenv("SUPABASE_API_KEY")
 
-llm = ChatOpenAI(model_name="gpt-4")
+llm = ChatOpenAI(model_name="gpt-3.5")
 output_parser = NumberedListOutputParser()
 
 SYSTEM_DERIVE_FACTS = load_prompt(
@@ -200,9 +202,26 @@ async def check_dups(
     return new_facts
 
 
+# def listen_to_websocket(url):
+#     while True:
+#         try:
+#             s = Socket(url)
+#             s.connect()
+#             channel = s.set_channel("realtime:public:messages")
+#             channel.join().on(
+#                 "INSERT", lambda payload: asyncio.create_task(callback(payload))
+#             )
+
+#             s.listen()
+#         except ConnectionClosedError:
+#             print("Connection closed, attempting to reconnect...")
+#             time.sleep(5)
+
+
 if __name__ == "__main__":
     URL = f"wss://{SUPABASE_ID}.supabase.co/realtime/v1/websocket?apikey={SUPABASE_API_KEY}&vsn=1.0.0"
     # URL = f"ws://127.0.0.1:54321/realtime/v1/websocket?apikey={SUPABASE_API_KEY}"  # For local Supabase
+    # listen_to_websocket(URL)
     s = Socket(URL)
     s.connect()