Skip to content

Commit

Permalink
#67: Moved the cmd out of pkgs
Browse files Browse the repository at this point in the history
  • Loading branch information
roma-glushko committed Aug 12, 2024
1 parent e526611 commit 24be91c
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 7 deletions.
File renamed without changes.
2 changes: 1 addition & 1 deletion main.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package main
import (
"log"

"github.com/EinStack/glide/pkg/cmd"
"github.com/EinStack/glide/cmd"
)

// @title Glide
Expand Down
12 changes: 6 additions & 6 deletions pkg/api/http/handlers.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,7 @@ func LangChatHandler(routerManager *router.Manager) Handler {
// Get router ID from path
routerID := c.Params("router")

router, err := routerManager.GetLangRouter(routerID)
r, err := routerManager.GetLangRouter(routerID)
if err != nil {
httpErr := schemas.FromErr(err)

Expand All @@ -61,7 +61,7 @@ func LangChatHandler(routerManager *router.Manager) Handler {
resp := schemas.GetChatResponse()
defer schemas.ReleaseChatResponse(resp)

resp, err = router.Chat(c.Context(), req)
resp, err = r.Chat(c.Context(), req)
if err != nil {
httpErr := schemas.FromErr(err)

Expand Down Expand Up @@ -121,7 +121,7 @@ func LangStreamChatHandler(tel *telemetry.Telemetry, routerManager *router.Manag

chatStreamC := make(chan *schemas.ChatStreamMessage)

router, _ := routerManager.GetLangRouter(routerID)
r, _ := routerManager.GetLangRouter(routerID)

defer close(chatStreamC)
defer c.Conn.Close()
Expand Down Expand Up @@ -158,7 +158,7 @@ func LangStreamChatHandler(tel *telemetry.Telemetry, routerManager *router.Manag
go func(chatRequest schemas.ChatStreamRequest) {
defer wg.Done()

router.ChatStream(context.Background(), &chatRequest, chatStreamC)
r.ChatStream(context.Background(), &chatRequest, chatStreamC)
}(chatRequest)
}

Expand All @@ -181,8 +181,8 @@ func LangRoutersHandler(routerManager *router.Manager) Handler {
configuredRouters := routerManager.GetLangRouters()
cfgs := make([]interface{}, 0, len(configuredRouters)) // opaque by design

for _, router := range configuredRouters {
cfgs = append(cfgs, router.Config)
for _, r := range configuredRouters {
cfgs = append(cfgs, r.Config)
}

return c.Status(fiber.StatusOK).JSON(schemas.RouterListSchema{Routers: cfgs})
Expand Down

0 comments on commit 24be91c

Please sign in to comment.