dnsge / twitch-eventsub-framework Goto Github PK

func GetAppTunnel(ctx context.Context, cfg *config.Config) (net.Listener, error) {
	if cfg.AppEnv != "production" {
		tun, err := ngrok.Listen(ctx,
			ngrok_config.HTTPEndpoint(),
		)
		if err != nil {
			return nil, err
		}

		return tun, nil
	} else {
		tun, err := net.Listen("tcp", ":3003")
		if err != nil {
			return nil, err
		}
		return tun, nil
	}
}

	appTun, err := helpers.GetAppTunnel(appCtx, cfg)
	if err != nil {
		panic(err)
	}

	appAddr := lo.
		If(cfg.AppEnv != "production", appTun.Addr().String()).
		Else(fmt.Sprintf("eventsub.%s", cfg.HostName))

	eventSubHandler := handler.NewHandler(services)
		go func() {
                         // manager here is *eventsub_framework.SubHandler
			if err := http.Serve(appTun, eventSubHandler.Manager); err != nil {
				panic(err)
			}
		}()

	fmt.Println("Listening on %s", appAddr)