fix sproc and api call stuff
parent
ed505249c6
commit
733fb07b11
|
|
@ -18,3 +18,10 @@ patches:
|
|||
- op: replace
|
||||
path: /spec/rules/0/host
|
||||
value: admin.localhost
|
||||
- target:
|
||||
kind: Ingress
|
||||
name: proxy-client
|
||||
patch: |-
|
||||
- op: replace
|
||||
path: /spec/rules/0/host
|
||||
value: bh.localhost
|
||||
|
|
|
|||
|
|
@ -1,7 +1,7 @@
|
|||
-- name: GetUpcoming :many
|
||||
SELECT ua.*
|
||||
FROM catalog.upcoming_auctions ua
|
||||
LEFT JOIN catalog.upcoming_auctions_fts fts on ua.id = fts.auction_id
|
||||
LEFT JOIN catalog.upcoming_auctions_fts fts on ua.id = fts.auctionid
|
||||
WHERE fts.ts @@ phraseto_tsquery($1)
|
||||
ORDER BY ts_rank(fts.ts, phraseto_tsquery($1)) DESC
|
||||
LIMIT $2;
|
||||
|
|
|
|||
|
|
@ -7,6 +7,7 @@ import (
|
|||
|
||||
api "git.vdhsn.com/barretthousen/barretthousen/src/catalog/api/grpc"
|
||||
"git.vdhsn.com/barretthousen/barretthousen/src/catalog/internal/domain"
|
||||
"git.vdhsn.com/barretthousen/barretthousen/src/lib/kernel"
|
||||
"google.golang.org/grpc"
|
||||
"google.golang.org/protobuf/types/known/timestamppb"
|
||||
)
|
||||
|
|
@ -28,6 +29,7 @@ type catalogHandler struct {
|
|||
}
|
||||
|
||||
func (rh *catalogHandler) GetUpcoming(ctx context.Context, cmd *api.AuctionSearchCriteria) (r *api.GetUpcomingResult, err error) {
|
||||
kernel.TraceLog.Printf("GetUpcoming[searchTerm: %q - page: %d - pageSize: %d]", cmd.GetSearchTerm(), cmd.GetPage(), cmd.GetLimit())
|
||||
var results domain.UpcomingResults
|
||||
if results, err = rh.domain.GetUpcoming(ctx, domain.UpcomingQuery{
|
||||
Term: cmd.SearchTerm,
|
||||
|
|
|
|||
|
|
@ -35,10 +35,10 @@ func (app *ProxyAdminApp) Start(ctx context.Context) error {
|
|||
httpServer := &http.Server{
|
||||
Addr: fmt.Sprintf("0.0.0.0:%d", app.Port),
|
||||
ReadHeaderTimeout: time.Second,
|
||||
Handler: http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||
Handler: http.StripPrefix("/api", http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||
kernel.TraceLog.Printf("{ \"Client\": \"%s\", \"Path\":\"%s\"} ", r.RemoteAddr, r.URL.Path)
|
||||
grpcMux.ServeHTTP(w, r)
|
||||
}),
|
||||
})),
|
||||
}
|
||||
|
||||
kernel.InfoLog.Printf("Starting HTTP proxy @ %q", httpServer.Addr)
|
||||
|
|
|
|||
Loading…
Reference in New Issue