Function NewLedgerForge

ledgerforge.go:121–170

NewLedgerForge initializes a new instance of LedgerForge with the provided database datasource. It fetches the configuration, initializes Redis client, balance tracker, queue, and search client. Parameters: - db database.IDataSource: The datasource for database operations. Returns: - *LedgerForge:

(db database.IDataSource)

// - *LedgerForge: A pointer to the newly created LedgerForge instance.
// - error: An error if any of the initialization steps fail.
func NewLedgerForge(db database.IDataSource) (*LedgerForge, error) {
	configuration, err := config.Fetch()
	if err != nil {
		return nil, err
	}

	redisClient, asynqClient, err := initializeRedisClients(configuration)
	if err != nil {
		return nil, err
	}

	bt := NewBalanceTracker()
	hotPairManager := hotpairs.NewManager(redisClient, hotpairs.Config{
		Enabled:                 configuration.Queue.EnableHotLane,
		HotQueueName:            configuration.Queue.HotQueueName,
		HotPairTTL:              configuration.Queue.HotPairTTL,
		LockContentionThreshold: configuration.Queue.HotPairLockContentionThreshold,
	})
	newQueue := NewQueue(configuration, asynqClient)
	newSearch := search.NewTypesenseClient(configuration.TypeSenseKey, []string{configuration.TypeSense.Dns})
	hookManager := hooks.NewHookManager(redisClient, asynqClient)
	tokenizer := initializeTokenizationService(configuration)
	httpClient := initializeHTTPClient()

	newCache := cache.NewCacheWithClient(redisClient)

	b := &LedgerForge{
		datasource:  db,
		bt:          bt,
		queue:       newQueue,
		redis:       redisClient,
		asynqClient: asynqClient,
		search:      newSearch,
		tokenizer:   tokenizer,
		httpClient:  httpClient,
		Hooks:       hookManager,
		config:      configuration,
		cache:       newCache,
		hotPairs:    hotPairManager,
	}

	notification.RegisterWebhookSender(func(event string, payload interface{}) error {
		return b.SendWebhook(NewWebhook{
			Event:   event,
			Payload: payload,
		})
	})

	return b, nil
}

// Close properly closes all connections and resources used by the LedgerForge instance.
func (b *LedgerForge) Close() error {