zhu327

package utils

import (
	"reflect"
	"unsafe"
)

func BytesToString(b []byte) string {
	return *(*string)(unsafe.Pointer(&b))
}

zhu327

func (s *server) respond(w http.ResponseWriter, r *http.Request, data interface{}, status int) {
	w.WriteHeader(status)
	if data != nil {
		err := json.NewEncoder(w).Encode(data)
		s.logf("json encode %s", err)
	}
}

func (s *server) decode(w http.ResponseWriter, r *http.Request, v interface{}) error {
	return json.NewDecoder(r.Body).Decode(v)

zhu327

from gevent.wsgi import WSGIServer
from prometheus_client import multiprocess
from prometheus_client import generate_latest, CollectorRegistry, CONTENT_TYPE_LATEST

# Expose metrics.
def app(environ, start_response):
    registry = CollectorRegistry()
    multiprocess.MultiProcessCollector(registry)
    data = generate_latest(registry)
    status = '200 OK'

zhu327

import { serve } from "https://deno.land/std@0.181.0/http/server.ts";

async function handleRequest(request: Request): Promise<Response> {
  if (request.method === "OPTIONS") {
    return handleOPTIONS(request);
  }

  const url = new URL(request.url);
  url.host = "api.groq.com";
  url.pathname = "/openai" + url.pathname;