Kasparpeterson/auth

.github/workflows/js-sdk-publish.yaml

@@ -20,8 +20,8 @@ jobs:
       - name: Setup Node
         uses: actions/setup-node@v3
         with:
-          node-version: "16.x"
-          registry-url: "https://registry.npmjs.org"
+          node-version: '16.x'
+          registry-url: 'https://registry.npmjs.org'
           cache: npm
           cache-dependency-path: package-lock.json
 

.github/workflows/python-client-publish.yaml

@@ -21,7 +21,7 @@ jobs:
       - name: Set up Python
         uses: actions/setup-python@v4
         with:
-          python-version: "3.10"
+          python-version: '3.10'
 
       - name: Install and configure Poetry
         uses: snok/install-poetry@v1

.github/workflows/python-sdk-publish.yaml

@@ -21,7 +21,7 @@ jobs:
       - name: Set up Python
         uses: actions/setup-python@v4
         with:
-          python-version: "3.10"
+          python-version: '3.10'
 
       - name: Install and configure Poetry
         uses: snok/install-poetry@v1

.github/workflows/update-docs.yaml

@@ -31,7 +31,7 @@ jobs:
           git commit -am "Update endpoint docs" || echo "No changes to commit"
           git push
         env:
-          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}        
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
 
       - name: Install swagger-cli
         run: |
@@ -43,7 +43,7 @@ jobs:
           cd ..
           npx openapi-format schemas/openapi.yml --output schemas/openapi.yml
           swagger-cli bundle -r schemas/openapi.yml -o schemas/openapi.json -t json
-          
+
           git config --global user.email "[email protected]"
           git config --global user.name "GitHub Actions"
           git add schemas/openapi.yml

CODE_OF_CONDUCT.md

@@ -1,4 +1,3 @@
-
 # Contributor Covenant Code of Conduct
 
 ## Our Pledge
@@ -18,23 +17,23 @@ diverse, inclusive, and healthy community.
 Examples of behavior that contributes to a positive environment for our
 community include:
 
-* Demonstrating empathy and kindness toward other people
-* Being respectful of differing opinions, viewpoints, and experiences
-* Giving and gracefully accepting constructive feedback
-* Accepting responsibility and apologizing to those affected by our mistakes,
+- Demonstrating empathy and kindness toward other people
+- Being respectful of differing opinions, viewpoints, and experiences
+- Giving and gracefully accepting constructive feedback
+- Accepting responsibility and apologizing to those affected by our mistakes,
   and learning from the experience
-* Focusing on what is best not just for us as individuals, but for the overall
+- Focusing on what is best not just for us as individuals, but for the overall
   community
 
 Examples of unacceptable behavior include:
 
-* The use of sexualized language or imagery, and sexual attention or advances of
+- The use of sexualized language or imagery, and sexual attention or advances of
   any kind
-* Trolling, insulting or derogatory comments, and personal or political attacks
-* Public or private harassment
-* Publishing others' private information, such as a physical or email address,
+- Trolling, insulting or derogatory comments, and personal or political attacks
+- Public or private harassment
+- Publishing others' private information, such as a physical or email address,
   without their explicit permission
-* Other conduct which could reasonably be considered inappropriate in a
+- Other conduct which could reasonably be considered inappropriate in a
   professional setting
 
 ## Enforcement Responsibilities

packages/client/python/agent_protocol_client/docs/AgentApi.md

@@ -2,8 +2,8 @@
 
 All URIs are relative to _http://localhost_
 
-| Method                                                                       | HTTP request                                           | Description                                                   |
-| ---------------------------------------------------------------------------- | ------------------------------------------------------ | ------------------------------------------------------------- |
+| Method                                                                       | HTTP request                                                 | Description                                                   |
+| ---------------------------------------------------------------------------- | ------------------------------------------------------------ | ------------------------------------------------------------- |
 | [**create_agent_task**](AgentApi.md#create_agent_task)                       | **POST** /ap/v1/agent/tasks                                  | Creates a task for the agent.                                 |
 | [**download_agent_task_artifact**](AgentApi.md#download_agent_task_artifact) | **GET** /ap/v1/agent/tasks/{task_id}/artifacts/{artifact_id} | Download a specified artifact.                                |
 | [**execute_agent_task_step**](AgentApi.md#execute_agent_task_step)           | **POST** /ap/v1/agent/tasks/{task_id}/steps                  | Execute a step in the specified agent task.                   |

packages/sdk/js/README.md

@@ -43,6 +43,7 @@ Agent.handleTask(taskHandler).start()
 You can find more info and examples in the [docs](https://agentprotocol.ai/sdks/js).
 
 ## Contributing
+
 ```bash
 git clone https://github.com/AI-Engineers-Foundation/agent-protocol
 cd agent-protocol/sdk/js

packages/sdk/js/src/agent.ts

@@ -1,4 +1,3 @@
-
 import { v4 as uuid } from 'uuid'
 import * as fs from 'fs'
 import * as path from 'path'
@@ -21,8 +20,8 @@ import {
   ApiConfig,
   RouteRegisterFn,
   RouteContext,
-} from "./api";
-import { Router } from 'express';
+} from './api'
+import { Router } from 'express'
 
 /**
  * A function that handles a step in a task.
@@ -84,7 +83,7 @@ const registerCreateAgentTask: RouteRegisterFn = (router: Router) => {
         res.status(500).json({ error: err.message })
       }
     })()
-  });
+  })
 }
 
 /**
@@ -251,8 +250,8 @@ const registerGetAgentTaskStep: RouteRegisterFn = (router: Router) => {
 export const getArtifacts = async (
   taskId: string
 ): Promise<Artifact[] | undefined> => {
-  const task = await getAgentTask(taskId);
-  return task.artifacts;
+  const task = await getAgentTask(taskId)
+  return task.artifacts
 }
 const registerGetArtifacts: RouteRegisterFn = (router: Router) => {
   router.get('/agent/tasks/:task_id/artifacts', (req, res) => {
@@ -262,7 +261,7 @@ const registerGetArtifacts: RouteRegisterFn = (router: Router) => {
         const artifacts = await getArtifacts(taskId)
         const current_page = Number(req.query['current_page']) || 1
         const page_size = Number(req.query['page_size']) || 10
-  
+
         if (!artifacts) {
           res.status(200).send({
             artifacts: [],
@@ -310,9 +309,9 @@ export const getArtifactPath = (
   workspace: string,
   artifact: Artifact
 ): string => {
-  const rootDir = path.isAbsolute(workspace) ?
-    workspace :
-    path.join(process.cwd(), workspace);
+  const rootDir = path.isAbsolute(workspace)
+    ? workspace
+    : path.join(process.cwd(), workspace)
 
   return path.join(
     rootDir,
@@ -345,18 +344,17 @@ export const createArtifact = async (
   task.artifacts = task.artifacts || []
   task.artifacts.push(artifact)
 
-  const artifactFolderPath = getArtifactPath(
-    task.task_id,
-    workspace,
-    artifact
-  )
+  const artifactFolderPath = getArtifactPath(task.task_id, workspace, artifact)
 
   // Save file to server's file system
   fs.mkdirSync(path.join(artifactFolderPath, '..'), { recursive: true })
   fs.writeFileSync(artifactFolderPath, file.buffer)
   return artifact
 }
-const registerCreateArtifact: RouteRegisterFn = (router: Router, context: RouteContext) => {
+const registerCreateArtifact: RouteRegisterFn = (
+  router: Router,
+  context: RouteContext
+) => {
   router.post('/agent/tasks/:task_id/artifacts', (req, res) => {
     void (async () => {
       try {
@@ -406,14 +404,21 @@ export const getTaskArtifact = async (
   }
   return artifact
 }
-const registerGetTaskArtifact: RouteRegisterFn = (router: Router, context: RouteContext) => {
+const registerGetTaskArtifact: RouteRegisterFn = (
+  router: Router,
+  context: RouteContext
+) => {
   router.get('/agent/tasks/:task_id/artifacts/:artifact_id', (req, res) => {
     void (async () => {
       const taskId = req.params.task_id
       const artifactId = req.params.artifact_id
       try {
         const artifact = await getTaskArtifact(taskId, artifactId)
-        const artifactPath = getArtifactPath(taskId, context.workspace, artifact)
+        const artifactPath = getArtifactPath(
+          taskId,
+          context.workspace,
+          artifact
+        )
         res.status(200).sendFile(artifactPath)
       } catch (err: Error | any) {
         console.error(err)
@@ -424,20 +429,20 @@ const registerGetTaskArtifact: RouteRegisterFn = (router: Router, context: Route
 }
 
 export interface AgentConfig {
-  port: number;
-  workspace: string;
+  port: number
+  workspace: string
 }
 
 export const defaultAgentConfig: AgentConfig = {
   port: 8000,
-  workspace: "./workspace"
-};
+  workspace: './workspace',
+}
 
 export class Agent {
   constructor(
     public taskHandler: TaskHandler,
     public config: AgentConfig
-  ) { }
+  ) {}
 
   static handleTask(
     _taskHandler: TaskHandler,
@@ -446,8 +451,8 @@ export class Agent {
     taskHandler = _taskHandler
     return new Agent(_taskHandler, {
       workspace: config.workspace || defaultAgentConfig.workspace,
-      port: config.port || defaultAgentConfig.port
-    });
+      port: config.port || defaultAgentConfig.port,
+    })
   }
 
   start(port?: number): void {
@@ -462,13 +467,13 @@ export class Agent {
         registerGetAgentTaskStep,
         registerGetArtifacts,
         registerCreateArtifact,
-        registerGetTaskArtifact
+        registerGetTaskArtifact,
       ],
       callback: () => {
         console.log(`Agent listening at http://localhost:${this.config.port}`)
       },
       context: {
-        workspace: this.config.workspace
+        workspace: this.config.workspace,
       },
     }
 

packages/sdk/js/src/api.ts

@@ -1,55 +1,52 @@
-import * as OpenApiValidator from "express-openapi-validator";
-import yaml from "js-yaml";
-import express, { Router } from "express";  // <-- Import Router
-import * as core from "express-serve-static-core";
+import * as OpenApiValidator from 'express-openapi-validator'
+import yaml from 'js-yaml'
+import express, { Router } from 'express' // <-- Import Router
+import * as core from 'express-serve-static-core'
 
-import spec from "../agent-protocol/schemas/openapi.yml";
+import spec from '../agent-protocol/schemas/openapi.yml'
 
-export type ApiApp = core.Express;
+export type ApiApp = core.Express
 
 export interface RouteContext {
-  workspace: string;
+  workspace: string
 }
 
-export type RouteRegisterFn = (
-  app: Router,
-  context: RouteContext
-) => void;
+export type RouteRegisterFn = (app: Router, context: RouteContext) => void
 
 export interface ApiConfig {
-  context: RouteContext;
-  port: number;
-  callback?: () => void;
-  routes: RouteRegisterFn[];
+  context: RouteContext
+  port: number
+  callback?: () => void
+  routes: RouteRegisterFn[]
 }
 
 export const createApi = (config: ApiConfig) => {
-  const app = express();
+  const app = express()
 
-  app.use(express.json());
-  app.use(express.text());
-  app.use(express.urlencoded({ extended: false }));
+  app.use(express.json())
+  app.use(express.text())
+  app.use(express.urlencoded({ extended: false }))
 
-  const parsedSpec = yaml.load(spec);
+  const parsedSpec = yaml.load(spec)
 
   app.use(
     OpenApiValidator.middleware({
       apiSpec: parsedSpec as any,
       validateRequests: true, // (default)
       validateResponses: true, // false by default
     })
-  );
+  )
 
-  app.get("/openapi.yaml", (_, res) => {
-    res.setHeader("Content-Type", "text/yaml").status(200).send(spec);
-  });
+  app.get('/openapi.yaml', (_, res) => {
+    res.setHeader('Content-Type', 'text/yaml').status(200).send(spec)
+  })
 
-  const router = Router();
+  const router = Router()
 
   config.routes.map((route) => {
-    route(router, config.context);
-  });
+    route(router, config.context)
+  })
 
-  app.use("/ap/v1", router);
-  app.listen(config.port, config.callback);
-};
+  app.use('/ap/v1', router)
+  app.listen(config.port, config.callback)
+}

packages/sdk/js/src/index.ts

@@ -41,6 +41,6 @@ export {
   getAgentTaskStep,
 }
 
-export { v4 } from "uuid"
+export { v4 } from 'uuid'
 
 export default Agent

packages/sdk/js/src/models.ts

@@ -7,10 +7,10 @@ export type TaskInput = any
  * Artifact that the task has produced. Any value is allowed.
  */
 export type Artifact = {
-  artifact_id: string,
-  agent_created: boolean,
-  file_name: string,
-  relative_path: string | null,
+  artifact_id: string
+  agent_created: boolean
+  file_name: string
+  relative_path: string | null
   created_at: string
 }
 
@@ -25,9 +25,9 @@ export type StepInput = any
 export type StepOutput = any
 
 export enum StepStatus {
-  CREATED = "created",
-  RUNNING = "running",
-  COMPLETED = "completed"
+  CREATED = 'created',
+  RUNNING = 'running',
+  COMPLETED = 'completed',
 }
 
 export interface Step {

packages/sdk/python/README.md

@@ -71,6 +71,7 @@ Agent.setup_agent(task_handler, step_handler).start(router=my_router)
 ### Testing
 
 You can test the compliance of your agent using the following script:
+
 ```bash
 URL=http://127.0.0.1:8000 bash -c "$(curl -fsSL https://agentprotocol.ai/test.sh)"
 ```
@@ -92,4 +93,4 @@ poetry install
 poetry run python examples/minimal.py
 ```
 
-Feel free to open [an issue](https://github.com/AI-Engineers-Foundation/agent-protocol/issues) if you run into any problems!
+Feel free to open [an issue](https://github.com/AI-Engineers-Foundation/agent-protocol/issues) if you run into any problems!