mirror of
https://github.com/jwetzell/showbridge-go.git
synced 2026-04-26 21:05:30 +00:00
create http client module
This commit is contained in:
72
http-client.go
Normal file
72
http-client.go
Normal file
@@ -0,0 +1,72 @@
|
|||||||
|
package showbridge
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"log/slog"
|
||||||
|
"net/http"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
type HTTPClient struct {
|
||||||
|
config ModuleConfig
|
||||||
|
router *Router
|
||||||
|
client *http.Client
|
||||||
|
}
|
||||||
|
|
||||||
|
func init() {
|
||||||
|
RegisterModule(ModuleRegistration{
|
||||||
|
Type: "net.http.client",
|
||||||
|
New: func(config ModuleConfig) (Module, error) {
|
||||||
|
|
||||||
|
return &HTTPClient{config: config}, nil
|
||||||
|
},
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
func (hc *HTTPClient) Id() string {
|
||||||
|
return hc.config.Id
|
||||||
|
}
|
||||||
|
|
||||||
|
func (hc *HTTPClient) Type() string {
|
||||||
|
return hc.config.Type
|
||||||
|
}
|
||||||
|
|
||||||
|
func (hc *HTTPClient) RegisterRouter(router *Router) {
|
||||||
|
hc.router = router
|
||||||
|
}
|
||||||
|
|
||||||
|
func (hc *HTTPClient) Run() error {
|
||||||
|
|
||||||
|
hc.client = &http.Client{
|
||||||
|
Timeout: 10 * time.Second,
|
||||||
|
}
|
||||||
|
|
||||||
|
<-hc.router.Context.Done()
|
||||||
|
slog.Debug("router context done in module", "id", hc.config.Id)
|
||||||
|
return nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (hc *HTTPClient) Output(payload any) error {
|
||||||
|
|
||||||
|
payloadRequest, ok := payload.(*http.Request)
|
||||||
|
|
||||||
|
if !ok {
|
||||||
|
return fmt.Errorf("net.http.client is only able to output an http.Request")
|
||||||
|
}
|
||||||
|
|
||||||
|
if hc.client == nil {
|
||||||
|
return fmt.Errorf("net.http.client client is nil")
|
||||||
|
}
|
||||||
|
|
||||||
|
response, err := hc.client.Do(payloadRequest)
|
||||||
|
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
if hc.router != nil {
|
||||||
|
hc.router.HandleInput(hc.config.Id, response)
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user